You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
131 lines
4.8 KiB
131 lines
4.8 KiB
3 years ago
|
package com.fr.plugin;
|
||
|
|
|
||
|
|
|
||
|
|
import com.fanruan.api.log.LogKit;
|
||
|
|
import com.fr.plugin.models.MyListSimCardsResponse;
|
||
|
|
import com.fr.plugin.models.MySimDeviceVO;
|
||
|
|
import com.fr.plugin.transform.ExecuteFunctionRecord;
|
||
|
|
import com.fr.plugin.transform.FunctionRecorder;
|
||
|
|
import com.fr.script.AbstractFunction;
|
||
|
|
import com.fr.stable.exception.FormulaException;
|
||
|
|
import com.huaweicloud.sdk.core.auth.BasicCredentials;
|
||
|
|
import com.huaweicloud.sdk.core.http.HttpConfig;
|
||
|
|
import com.huaweicloud.sdk.gsl.v3.model.ListSimCardsRequest;
|
||
|
|
import com.huaweicloud.sdk.gsl.v3.region.GslRegion;
|
||
|
|
|
||
|
|
import java.util.Date;
|
||
|
|
import java.util.UUID;
|
||
|
|
|
||
|
|
|
||
|
|
@FunctionRecorder
|
||
|
|
public class GetSIMDataFun extends AbstractFunction {
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 接口地址：
|
||
|
|
* https://xxxx/api-ocgsl/gsl_07_0008.html
|
||
|
|
* 表名：fine_plugin_siminfo
|
||
|
|
* 数据链接名：FRDW
|
||
|
|
*
|
||
|
|
* @param objects
|
||
|
|
* @return
|
||
|
|
* @throws FormulaException
|
||
|
|
*/
|
||
|
|
|
||
|
|
@Override
|
||
|
|
@ExecuteFunctionRecord
|
||
|
|
public Object run(Object[] objects) throws FormulaException {
|
||
|
|
if (objects.length<2) {
|
||
|
|
return "调用参数顺序应该为getSIMData('ak','sk') 当前参数个数不足";
|
||
|
|
}
|
||
|
|
HttpConfig config = HttpConfig.getDefaultHttpConfig();
|
||
|
|
String ak = objects[0].toString();
|
||
|
|
String sk = objects[1].toString();
|
||
|
|
config.withIgnoreSSLVerification(true);
|
||
|
|
BasicCredentials auth = new BasicCredentials()
|
||
|
|
.withAk(ak)
|
||
|
|
.withSk(sk);
|
||
|
|
MyGslClient ecsClient = MyGslClient.newBuilder()
|
||
|
|
.withHttpConfig(config)
|
||
|
|
.withRegion(GslRegion.CN_NORTH_4)
|
||
|
|
.withCredential(auth)
|
||
|
|
.build();
|
||
|
|
Integer count;
|
||
|
|
Long offset = 1L;
|
||
|
|
Integer sum = 0;
|
||
|
|
DBUtils dbUtils = new DBUtils();
|
||
|
|
do {
|
||
|
|
MyListSimCardsResponse cardsResponse = getSIMS(ecsClient, offset);
|
||
|
|
count = cardsResponse.getSimCards().size();
|
||
|
|
if(count==0){
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
try {
|
||
|
|
for (MySimDeviceVO simCard : cardsResponse.getSimCards()) {
|
||
|
|
insert2DB(simCard, dbUtils);
|
||
|
|
}
|
||
|
|
} catch (Exception e) {
|
||
|
|
LogKit.error("SIM卡保存异常:", e);
|
||
|
|
}
|
||
|
|
sum += count;
|
||
|
|
offset++;
|
||
|
|
} while (count > 0);
|
||
|
|
LogKit.info("一共同步了:{} 条记录", sum);
|
||
|
|
return "success";
|
||
|
|
}
|
||
|
|
|
||
|
|
private void insert2DB(MySimDeviceVO vo, DBUtils dbUtils) throws Exception {
|
||
|
|
Object[] params = new Object[]{
|
||
|
|
UUID.randomUUID().toString(),
|
||
|
|
vo.getSimCardId(),
|
||
|
|
vo.getAccountId(),
|
||
|
|
vo.getCid(),
|
||
|
|
vo.getSimPoolId(),
|
||
|
|
vo.getImei(),
|
||
|
|
vo.getSimStatus(),
|
||
|
|
vo.getDeviceStatus(),
|
||
|
|
vo.getDeviceModel(),
|
||
|
|
vo.getActDate(),
|
||
|
|
vo.getDeviceStatusDate(),
|
||
|
|
vo.getNodeId(),
|
||
|
|
vo.getIccid(),
|
||
|
|
vo.getNetworkType(),
|
||
|
|
vo.getDbm(),
|
||
|
|
vo.getSignalLevel(),
|
||
|
|
vo.getSimType(),
|
||
|
|
vo.getTagNames(),
|
||
|
|
vo.getOrderId(),
|
||
|
|
vo.getExpireTime(),
|
||
|
|
vo.getPricePlanName(),
|
||
|
|
vo.getFlowLeft(),
|
||
|
|
vo.getFlowUsed(),
|
||
|
|
vo.getOperatorStatus(),
|
||
|
|
vo.getMsisdn(),
|
||
|
|
vo.getImsi(),
|
||
|
|
vo.getRealNamed(),
|
||
|
|
vo.getCutNetFlag(),
|
||
|
|
vo.getExceedCutNetFlag(),
|
||
|
|
vo.getExceedCutNetQuota(),
|
||
|
|
vo.getImeiBindRemainTimes(),
|
||
|
|
vo.getSpeedValue(),
|
||
|
|
new Date()
|
||
|
|
};
|
||
|
|
String sql = "INSERT INTO `fine_plugin_siminfo`(`s_id`, `sim_card_id`, `account_id`, `cid`, `sim_pool_id`, `imei`, `sim_status`, `device_status`, `device_model`, `act_date`, `device_status_date`, `node_id`, `iccid`, `network_type`, `dbm`, `signal_level`, `sim_type`, `tag_names`, `order_id`, `expire_time`, `price_plan_name`, `flow_left`, `flow_used`, `operator_status`, `msisdn`, `imsi`, `real_named`, `cut_net_flag`, `exceed_cut_net_flag`, `exceed_cut_net_quota`, `imei_bind_remain_times`, `speed_value`, `update_time`) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
|
||
|
|
dbUtils.exSqlUpdate(sql, params);
|
||
|
|
}
|
||
|
|
|
||
|
|
//展示的当前页
|
||
|
|
private MyListSimCardsResponse getSIMS(MyGslClient MyGslClient, Long offset) {
|
||
|
|
//显示的数据数量 最大500
|
||
|
|
Long limit = 500L;
|
||
|
|
//SIM卡状态-11-未激活
|
||
|
|
Integer simStatus = 20;
|
||
|
|
MyListSimCardsResponse response = MyGslClient.listSimCards(
|
||
|
|
new ListSimCardsRequest().withLimit(limit).withOffset(offset) );
|
||
|
|
LogKit.info("请求响应:{} ", response.toString());
|
||
|
|
return response;
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
}
|
||
|
|
|