//implements Queueable
|
public with sharing class NFM511Controller implements Queueable {
|
|
public static String status;
|
public static String logstr;
|
|
private static final String LOG_TYPE = 'NFM511';
|
|
// public class NFM511 {
|
// public Gedatas Gedatas;
|
// }
|
|
public class AllData {
|
public Integer code;
|
public ZCData data;
|
public String message;
|
}
|
|
public class ZCData {
|
public Integer total;
|
public Integer current;
|
public Integer size;
|
public Boolean hitCount;
|
public Integer pages;
|
public Boolean optimizeCountSql;
|
public Boolean searchCount;
|
public ListItem[] records;
|
public Object[] orders;
|
}
|
|
public class ListItem {
|
public String sfdcCode; //上传编码
|
public String bid; //标讯 id
|
public String title; //标题
|
public String projectNo; //项目编号
|
public String originalUrl; //原文链接
|
public String tenderee; //归一招标单位
|
public String province; //省
|
public String city; //市
|
public String district; //区
|
public String supplier; //归一中标单位
|
public String contractObject; //标的名称
|
public String brand; //归一品牌名称
|
public String brandType; //品牌类型
|
public String speci; // 归一型号
|
public String noticeType ; //公告类型
|
public String progress ; // 中标进度
|
public String oneClass ; //大类
|
public String twoClass ; //产品线
|
public String threeClass ; //细分品种
|
public String hostIf ; //是否包含主机
|
public String fundingSource ; //资金来源
|
public String url ; //众成链接
|
|
public Integer winningDetailId; //标注结果 id
|
public Integer bidQuantity; //补全数量
|
public Decimal bidUnitPrice; //补全单价
|
public Decimal bidTotalPrice ; //补全总价
|
public String projectTotalPrice ; //项目总价
|
|
public String createTime ;
|
public String modifyTime ;
|
public String publishTime ; //中标日期
|
|
public String projectJudgeId ; //项目id-大包标识 20240105 lt add project_judge_id
|
}
|
|
// 日志rowData的Id
|
public String logId;
|
|
//取众成数据的开始/结束时间
|
public static String startTime;
|
public static String endTime;
|
|
// 无参的构造方法
|
public NFM511Controller() {
|
}
|
|
// 包含Id的构造方法
|
public NFM511Controller(String rowdataId) {
|
this.logId = rowdataId;
|
}
|
|
// 包含 开始时间/结束时间 的构造方法
|
// 文本格式 'yyyy-MM-dd'
|
// public NFM511Controller(String startTime1,String endTime1) {
|
// startTime = startTime1;
|
// endTime = endTime1;
|
// }
|
|
// 最大值为3，用来作为判断错误的条件（重发三次）
|
public static Integer batch_retry_max_cnt = Integer.valueOf(System.Label.batch_retry_max_cnt);
|
|
// 开始执行
|
public void execute(QueueableContext context) {
|
|
Datetime nowDT = Datetime.now();
|
String nowStr = nowDT.format('yyyyMMddHHmmss');
|
|
//1 创建日志
|
BatchIF_Log__c rowData = new BatchIF_Log__c();
|
System.debug('lt123--logId:'+this.logId);
|
if (String.isBlank(this.logId)) {
|
rowData.Type__c = 'NFM511';
|
rowData.RowDataFlg__c = true;
|
rowData.MessageGroupNumber__c = nowStr;
|
rowData.retry_cnt__c = 0;
|
insert rowData;
|
} else {
|
rowData.Id = this.logId;
|
}
|
|
BatchIF_Log__c iflog = new BatchIF_Log__c();
|
iflog.Type__c = 'NFM511';
|
iflog.MessageGroupNumber__c = rowData.MessageGroupNumber__c;
|
insert iflog;
|
System.debug('rowDataId: ' + rowData.Id);
|
System.debug('iflogId: ' + iflog.Id);
|
|
//2 执行接口请求
|
NFM511Controller.sendRequest(rowData.Id, iflog.Id);
|
|
}
|
|
@Future(callout=true)
|
public static void sendRequest(String rowDataId, String iflogId) {
|
BatchIF_Log__c rowData = [select Id, Name, Log__c, ErrorLog__c, MessageGroupNumber__c, retry_cnt__c
|
from BatchIF_Log__c where id = :rowDataId ];
|
BatchIF_Log__c iflog = [select Id, Name, Log__c, ErrorLog__c, MessageGroupNumber__c, retry_cnt__c
|
from BatchIF_Log__c where id = :iflogId ];
|
BatchIF_Transfer__c tokeninfo = null;
|
BatchIF_Transfer__c indexinfo = null;
|
Boolean updateToken = false; // 是否更新token
|
Boolean doFuture = false; // 是否执行511future
|
|
//startTime/EndTime 转送表 start
|
// BatchIF_Log__c iflog1 = new BatchIF_Log__c();
|
// iflog1.Type__c = 'NFM511Time';
|
// iflog1.Log__c = 'timeCtroller start\n';
|
// iflog1.ErrorLog__c = '';
|
// insert iflog1;
|
|
Map<String, String> transferMap = new Map<String, String>();
|
List<BatchIF_Transfer__c> transferList = [
|
select Table__c,
|
Column__c,
|
External_value__c,
|
Internal_value__c
|
from BatchIF_Transfer__c
|
where Dropped_Flag__c = false
|
and Table__c = 'NFM511'];
|
for (BatchIF_Transfer__c t : transferList) {
|
transferMap.put(t.Column__c, t.Internal_value__c);
|
}
|
System.debug('20231009---transferMap:'+transferMap);
|
System.debug('20231009---startTime表:'+transferMap.get('StartTime'));
|
System.debug('20231009---EndTime表:'+transferMap.get('EndTime'));
|
|
startTime = transferMap.get('StartTime');
|
endTime = transferMap.get('EndTime');
|
// if (!transferMap.containsKey('StartTime') || !transferMap.containsKey('EndTime')) {
|
// iflog1.ErrorLog__c += '请检查转送表\n';
|
// }
|
//startTime/EndTime 转送表 end
|
|
Datetime nowDT = Datetime.now();
|
Long nowM = Long.valueOf(nowDT.format('yyyyMMddHHmm'));
|
Long nowD = Long.valueOf(nowDT.format('yyyyMMdd'));
|
System.debug('20231009---startTime:'+startTime);
|
System.debug('20231009---endTime:'+endTime);
|
String yestoday = String.isBlank(startTime) ? system.now().format('yyyy-MM-dd') + '%2000:00:00' : startTime + '%2000:00:00';
|
String totoday = String.isBlank(endTime) ? system.now().format('yyyy-MM-dd') + '%2023:59:55' : endTime + '%2023:59:55';
|
System.debug('20231009---yestoday:'+yestoday);
|
System.debug('20231009---totoday:'+totoday);
|
|
try {
|
//1 获得token和当前任务页数数据
|
String token;
|
String loginNo;
|
String systemId;
|
String pindex;
|
tokeninfo = [Select ID, NFM501_Token__c,LastModifiedDate FROM BatchIF_Transfer__c
|
Where Table__c = 'NFM511Token' limit 1];
|
indexinfo = [Select ID, Internal_Value__c,LastModifiedDate FROM BatchIF_Transfer__c
|
Where Table__c = 'NFM511GainEndTime' limit 1];
|
Long lastModM = tokeninfo == null ? 0 : Long.valueOf(tokeninfo.LastModifiedDate.format('yyyyMMddHHmm'));
|
Long lastModD = tokeninfo == null ? 0 : Long.valueOf(tokeninfo.LastModifiedDate.format('yyyyMMdd'));
|
String[] tokeninfos = null;
|
//2 判断是否要取新token
|
if (nowM - lastModM > 8) {
|
String tokennew = getZCToken();
|
System.debug('token: ' + tokennew);
|
Map<String, Object> tr = (Map<String, Object>) JSON.deserializeUntyped(tokennew);
|
System.debug('test20231007---tr: ' + tr);
|
Map<String, Object> retdata = (Map<String, Object>) tr.get('data');
|
String strtokeninfo = (String) retdata.get('access_token') + ';' + retdata.get('loginNo') + ';' + retdata.get('systemId');
|
if (tokeninfo == null) {
|
tokeninfo = new BatchIF_Transfer__c();
|
tokeninfo.Table__c = 'NFM511Token';
|
}
|
tokeninfo.NFM501_Token__c = strtokeninfo;
|
updateToken = true;
|
tokeninfos = strtokeninfo.split(';');
|
} else {
|
tokeninfos = tokeninfo.NFM501_Token__c.split(';');
|
}
|
token = tokeninfos[0];
|
loginNo = tokeninfos[1];
|
systemId = tokeninfos[2];
|
pindex = indexinfo == null || String.isBlank(indexinfo.Internal_Value__c) || (nowD - lastModD > 0) ? '1' : indexinfo.Internal_Value__c;
|
// token和页数信息写入执行日志
|
iflog.Log__c = 'token: ' + token + '\n';
|
iflog.Log__c += 'loginNo: ' + loginNo + '\n';
|
iflog.Log__c += 'systemId: ' + systemId + '\n';
|
iflog.Log__c += 'pindex: ' + pindex + '\n';
|
// 获取数据日志
|
String datalog = sendToZCRet(token, loginNo, systemId, pindex, yestoday,totoday);
|
rowData.Log__c = datalog;
|
AllData metaData = (AllData) JSON.deserializeStrict(datalog, AllData.class);
|
|
if (metaData.code == 200) {
|
doFuture = true;
|
if (metaData.data.pages > Integer.valueOf(pindex)) {
|
System.enqueueJob(new NFM511Controller());
|
}
|
}
|
|
System.debug('lt123-rowData.id:'+rowData.id);
|
System.debug('lt123-iflog.id:'+iflog.id);
|
// NFM511FutureController.main(rowData.id,iflog.Id,false);
|
// System.enqueueJob(new NFM511FutureController(rowData.id),1);
|
|
if (indexinfo == null) {
|
indexinfo = new BatchIF_Transfer__c();
|
indexinfo.Table__c = 'NFM511GainEndTime';
|
}
|
indexinfo.Internal_Value__c = String.valueOf(Integer.valueOf(pindex) + 1);
|
} catch (Exception ex) {
|
// Database.rollback(sp);
|
System.debug('ex.getlinenumber()------'+ex.getlinenumber());
|
iflog.ErrorLog__c = '511抛出异常：' + ex.getMessage() + '\n'
|
+ ex.getStackTraceString() + '\n' + iflog.ErrorLog__c;
|
rowData.retry_cnt__c += 1;
|
|
System.debug('lt123-rowData.retry_cnt__c:'+rowData.retry_cnt__c);
|
|
if (rowData.retry_cnt__c == batch_retry_max_cnt) {
|
rowData.ErrorLog__c = '511抛出异常：' +
|
ex.getMessage() + '\n' + ex.getStackTraceString()
|
+ '\n' +
|
'错误次数已经超过自动收信设定的最大次数，请手动收信';
|
} else {
|
// rowData.ErrorLog__c = 'error:' + ex.getMessage() + '\n' + ex.getStackTraceString()
|
// + '\n' ;
|
System.enqueueJob(new NFM511Controller(rowData.Id), 1);
|
}
|
} finally {
|
update iflog;
|
update rowData;
|
if (updateToken) {
|
upsert tokeninfo;
|
}
|
upsert indexinfo;
|
if (doFuture) {
|
NFM511FutureController.main(rowData.id,iflog.Id,false);
|
}
|
}
|
}
|
|
// 获得众成token
|
public static String getZCToken() {
|
Http http = new Http();
|
HttpRequest req = new HttpRequest();
|
HTTPResponse res;
|
String resb;
|
// System.debug('endpoint: ' + NFMUtil.NFM511_TOKEN_ENDPOINT);
|
// System.debug('username: ' + NFMUtil.NFM511_USERNAME);
|
// System.debug('password: ' + NFMUtil.NFM511_PASSWORD);
|
String url = NFMUtil.NFM511_TOKEN_ENDPOINT;
|
url += '?username=' + NFMUtil.NFM511_USERNAME;
|
url += '&password=' + NFMUtil.NFM511_PASSWORD;
|
System.debug('token url: ' + url);
|
req.setMethod('GET');
|
req.setEndpoint(url);
|
// req.setEndpoint(NFMUtil.NFM511_TOKEN_ENDPOINT);
|
// req.setHeader('username', NFMUtil.NFM511_USERNAME);
|
// req.setHeader('password', NFMUtil.NFM511_PASSWORD);
|
// req.setBody('');
|
res = http.send(req);
|
resb = res.getBody();
|
System.debug('511 get token:' + resb);
|
|
return resb;
|
}
|
|
// 获得众成数据
|
public static String sendToZCRet(String token, String loginNo, String systemId, string pageIndex, String updStart, String updEnd) {
|
|
// 发送接口
|
Http http2 = new Http();
|
HttpRequest req2 = new HttpRequest();
|
HTTPResponse res2;
|
String resb2;
|
|
String url = NFMUtil.NFM511_DATA_ENDPOINT;
|
url += '?loginNo=' + loginNo;
|
url += '&systemId=' + systemId;
|
url += '&pageIndex=' + pageIndex;
|
url += '&pageSize=10';
|
url += '&updateTimeStart=' + updStart;
|
url += '&updateTimeEnd=' + updEnd;
|
// url += '&updateTimeStart=2023-10-09%2017:44:00';
|
// url += '&updateTimeEnd=2023-10-09%2017:45:00';
|
|
System.debug('20231009---url:'+url);
|
|
req2.setTimeout(110000);
|
req2.setMethod('GET');
|
req2.setEndpoint(url);
|
// req2.setEndpoint(NFMUtil.NFM511_DATA_ENDPOINT);
|
req2.setHeader('Authorization', 'Bearer ' + token);
|
// req2.setHeader('loginNo', loginNo);
|
// req2.setHeader('systemId', systemId);
|
// req2.setHeader('Content-Type', 'application/json');
|
// req2.setHeader('pageIndex', pageIndex);
|
// req2.setHeader('pageSize', '20');
|
// req2.setHeader('updateTimeStart', updStart); // 格式 '2023-04-01 00:00:00'
|
// req2.setHeader('updateTimeEnd', updEnd);
|
// req2.setBody('');
|
System.debug('20231009---res2---1:'+res2);
|
res2 = http2.send(req2);
|
System.debug('20231009---res2--2:'+res2);
|
resb2 = res2.getBody();
|
System.debug('20231009---resb2:'+resb2);
|
return resb2;
|
}
|
|
}
|
