public with sharing class NFM511FutureController implements Queueable { //先定义 // public String txId; public String rowData_id; public NFM511FutureController(String rowData_id) { this.rowData_id = rowData_id; } public static Integer batch_retry_max_cnt = Integer.valueOf(System.Label.batch_retry_max_cnt); public void execute(QueueableContext context /*, String iflog_Id*/ ) { //需加一数字变量（如果获取到 html附件，其他附件，在日志中显示数量） BatchIF_Log__c rowData = [Select Id, Name, Log__c, ErrorLog__c, Log2__c, Log3__c, MessageGroupNumber__c, retry_cnt__c From BatchIF_Log__c Where RowDataFlg__c = true And Id = : rowData_id ]; //存放报错信息 BatchIF_Log__c iflog511Future = new BatchIF_Log__c(); iflog511Future.Type__c = 'NFM511Future'; iflog511Future.MessageGroupNumber__c = rowData.MessageGroupNumber__c; iflog511Future.Log__c = ' '; iflog511Future.ErrorLog__c = ' '; iflog511Future.RowDataFlg__c = false; // iflog511Future.AWS_Transaction_Id__c=rowData.AWS_Transaction_Id__c; insert iflog511Future; NFM511FutureController.main(rowData.Id, iflog511Future.Id, false); } @future(callout = true) public static void callout(String rowData_id, String iflog_id, boolean Manual_execution511future) { NFM511FutureController.main(rowData_id, iflog_id, false); } // @future(callout = true) //重发（把从接口获取到的数据存入日志中，再把日志中存入的数据重新JOSN解析一遍） public static void main(String rowData_id, String iflog_id, boolean Manual_execution511future) { BatchIF_Log__c rowData = [Select Id, Name, Log__c, ErrorLog__c, Log2__c, Log3__c, Log4__c, Log5__c, Log6__c, Log7__c, Log8__c, MessageGroupNumber__c, retry_cnt__c From BatchIF_Log__c Where Id = : rowData_id ]; BatchIF_Log__c iflog511Future = [select Id, Name, Log__c, ErrorLog__c, Log2__c, Log3__c, Log4__c,Log5__c, Log6__c, Log7__c, Log8__c, MessageGroupNumber__c, retry_cnt__c From BatchIF_Log__c Where id = : iflog_id ]; // 由于检索出来的rowData和iflog为空，则进行一下判断 iflog511Future.Log__c = iflog511Future.Log__c == null ? '' : iflog511Future.Log__c; iflog511Future.ErrorLog__c = iflog511Future.ErrorLog__c == null ? '' : iflog511Future.ErrorLog__c; rowData.Log__c = rowData.Log__c == null ? '' : rowData.Log__c; rowData.ErrorLog__c = rowData.ErrorLog__c == null ? '' : rowData.ErrorLog__c; //20230909 iflog511Future.Type__c = 'NFM511Future'; iflog511Future.MessageGroupNumber__c = rowData.MessageGroupNumber__c; iflog511Future.RowDataFlg__c = false; //20230909 System.debug('+++++++NFM511+++++++iflog511Future:'+iflog511Future); System.debug('+++++++NFM511+++++++rowData:'+rowData); // String QLMDataStr = NFMUtil.QLMgetRowDataStr(rowData); String QLMDataStr = rowData.Log__c; system.debug('+++++++NFM511+++++++QLMDataStr:'+QLMDataStr); NFM511controller.AllData getQLMData1 = (NFM511controller.AllData) JSON.deserialize(QLMDataStr, NFM511controller.AllData.class); system.debug('+++++++NFM511+++++++getQLMData1:'+json.serialize(getQLMData1)); if (getQLMData1 == null) { return; } Savepoint sp = Database.setSavepoint(); //覆盖之前的数据（更新成新数据--以下三步） //1、for 遍历接口数据，做一个infoId 的list //2、通过list查招标信息；做一个Map key infoid value 招标信息id try { // 招标信息 // Map < string, List < bidInfoFile__c >> createbidInfoFileMap = new map < string, List < bidInfoFile__c >> (); // Map < String, List < Tender_information_details__c >> tempList1 = new Map < String, List < Tender_information_details__c >> (); // Map < string, Tender_information__c > updateTenderMap = new map < string, Tender_information__c > (); // Set < String > TarDetailSet = new Set < String > (); for (NFM511Controller.ListItem records: getQLMData1.data.records) { system.debug('+++++++NFM511+++++++records:'+json.serialize(records)); // 項目転送のセット ZCData__c zc = new ZCData__c(); // if (String.isBlank(records.bid)) { // iflog511Future.ErrorLog__c += 'Error! [' + records.bid + ']NotExist. This information is skipped.\n'; // continue; // } else { // zc.bid__c = records.bid; // } if (!String.isBlank(records.sfdcCode)){ zc.sfdcCode__c = records.sfdcCode; } if (!String.isBlank(records.bid)){ zc.bid__c = records.bid; } if (records.bidQuantity != null){ zc.bidQuantity__c = records.bidQuantity; } if (!String.isBlank(records.city)){ zc.city__c = records.city; } if (!String.isBlank(records.speci)){ zc.speci__c = records.speci; } if (!String.isBlank(records.contractObject)){ zc.contractObject__c = records.contractObject; } if (!String.isBlank(records.title)){ zc.title__c = records.title; } if (records.bidTotalPrice != null){ zc.bidTotalPrice__c = records.bidTotalPrice; } if (!String.isBlank(records.threeClass)){ zc.threeClass__c = records.threeClass; } if (!String.isBlank(records.projectNo)){ zc.projectNo__c = records.projectNo; } if (records.modifyTime != null){ zc.modifyTime__c = records.modifyTime; } if (!String.isBlank(records.province)){ zc.province__c = records.province; } if (!String.isBlank(records.twoClass)){ zc.twoClass__c = records.twoClass; } if (!String.isBlank(records.supplier)){ zc.supplier__c = records.supplier; } if (!String.isBlank(records.brand)){ zc.brand__c = records.brand; } if (records.bidUnitPrice != null){ zc.bidUnitPrice__c = records.bidUnitPrice; } if (records.winningDetailId != null){ zc.winningDetailId__c = records.winningDetailId; } if (records.publishTime != null){ zc.publishTime__c = records.publishTime; } if (records.projectTotalPrice != null){ zc.projectTotalPrice__c = records.projectTotalPrice; } if (!String.isBlank(records.noticeType)){ zc.noticeType__c = records.noticeType; } if (!String.isBlank(records.originalUrl)){ zc.originalUrl__c = records.originalUrl; } if (!String.isBlank(records.url)){ zc.url__c = records.url; } if (!String.isBlank(records.hostIf)){ zc.hostIf__c = records.hostIf; } if (!String.isBlank(records.brandType)){ zc.brandType__c = records.brandType; } if (records.createTime != null){ zc.createTime__c = records.createTime; } if (!String.isBlank(records.tenderee)){ zc.tenderee__c = records.tenderee; } if (!String.isBlank(records.district)){ zc.district__c = records.district; } if (!String.isBlank(records.progress)){ zc.progress__c = records.progress; } if (!String.isBlank(records.fundingSource)){ zc.fundingSource__c = records.fundingSource; } if (!String.isBlank(records.oneClass)){ zc.oneClass__c = records.oneClass; } //20240105 lt start if (!String.isBlank(records.projectJudgeId)){ zc.project_judge_id__c = records.projectJudgeId; } //20240105 lt end insert zc; if (System.Test.isRunningTest()) { throw new ControllerUtil.myException('aaa'); } } }catch (Exception ex) { // 如果数据获取过程中，有错误（同一游标，如果报错，是他重新获取一遍，如果三次都没能获取到，就发送邮件报错信息，然后手动进行获取） Database.rollback(sp); System.debug('ex.getlinenumber()------'+ex.getlinenumber()); System.debug(Logginglevel.ERROR, 'QLMData_' + rowData.MessageGroupNumber__c + ':' + ex.getMessage()); System.debug(Logginglevel.ERROR, 'QLMData_' + rowData.MessageGroupNumber__c + ':' + ex.getStackTraceString()); // logstr += '\n' + ex.getMessage(); iflog511Future.ErrorLog__c ='发生错误行数'+ ex.getlinenumber() + ':' + '511Future抛出异常：' + ex.getMessage() + '\n' + ex.getStackTraceString() + '\n' + iflog511Future.ErrorLog__c; if (!Manual_execution511future) { // NFM511Controller.againSendExceptionRequest(iflog511Future, 'NFM511Future_Count__c', rowData, '511Future抛出异常：' + ex.getMessage() + '\n' + ex.getStackTraceString() + '\n' + rowData.ErrorLog__c + '错误次数已经超过自动收信设定的最大次数，请手动收信'); } //System.debug(ANY o); } // update rowData; System.debug('+++++++5+++++++' + rowData); System.debug('+++++++3+++++++' + iflog511Future.Log__c); System.debug('+++++++2+++++++' + iflog511Future.ErrorLog__c); //如果存入信息超出限制，用省略号代替 if (iflog511Future.Log__c.length() > 131072) { iflog511Future.Log__c = iflog511Future.Log__c.subString(0, 131065) + ' ...'; } if (iflog511Future.ErrorLog__c.length() > 32768) { iflog511Future.ErrorLog__c = iflog511Future.ErrorLog__c.subString(0, 32760) + ' ...'; } upsert iflog511Future; } }