/********************************************************************** * * * @url: /services/apexrest/rest * @data: * { } * @msg: * 1.接收到会议结果后，更新学会的状态(非赞助会) *************************************************************************/ @RestResource(urlMapping='/NFM707/*') global with sharing class NFM707Rest { public static final String LOG_TYPE = 'NFM707'; global class GeDatas { public NFMUtil.Monitoring Monitoring; public GeData[] GeData; } global class GeData { public String MeetingApprovedNo; // 会议决裁编码 public String Num; // 会议编码 public String Competitor; // 竞品公司 public String Publicity; // 宣传方式 public String SocietyHoldPlace; // 会议日程 } @HttpPost global static void execute() { // 取得接口传输内容 String strData = RestContext.request.requestBody.toString(); GeDatas geds = (GeDatas) JSON.deserializeStrict(strData, GeDatas.class); if (geds == null) { return; } NFMUtil.Monitoring Monitoring = geds.Monitoring; if (Monitoring == null) { return; } BatchIF_Log__c rowData = NFMUtil.saveRowData(Monitoring, LOG_TYPE, geds.GeData); // insert rowData; if (String.isBlank(rowData.Log__c) == false) { executefuture(rowData.Id); } // JSONを戻す RestResponse res = RestContext.response; res.addHeader('Content-Type', 'application/json'); res.statusCode = 200; String jsonResponse = '{"Result":{"Result":"00","Message":"成功"}}'; res.responseBody = Blob.valueOf(jsonResponse); return; } @future(callout = true) global static void executefuture(String rowData_Id) { main(rowData_Id); } global static void main(String rowData_Id) { 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, Log9__c, Log10__c, Log11__c, Log12__c, MessageGroupNumber__c, retry_cnt__c from BatchIF_Log__c where RowDataFlg__c = true and Id =: rowData_Id]; String logstr = 'start\n'; BatchIF_Log__c iflog = new BatchIF_Log__c(); iflog.Type__c = LOG_TYPE; iflog.MessageGroupNumber__c = rowData.MessageGroupNumber__c; iflog.Log__c = logstr; iflog.ErrorLog__c = ''; insert iflog; String rowDataStr = NFMUtil.getRowDataStr(rowData); List < GeData > itemMasterList = (List < GeData > ) JSON.deserialize(rowDataStr, List < GeData > .class); logstr += '数据总数为：' + itemMasterList.size() + '\n'; if (itemMasterList == null || itemMasterList.size() == 0) { return; } Savepoint sp = Database.setSavepoint(); try { List rcaList = new List(); Map meetingApprovedNoMap = new Map(); // Map camMap = new Map(); List camList = new List(); for(GeData ged : itemMasterList){ //验证数据完整性 // String dataComplete = verify(ged); // if (!String.isBlank(dataComplete)) { // logstr += dataComplete; // iflog.ErrorLog__c += dataComplete; // upsert iflog; // continue; // } // if (String.isNotBlank(ged.Num)) { // camMap.put(ged.Num, ged.MeetingApprovedNo); // camList.add(ged.MeetingApprovedNo); // } camList.add(ged.MeetingApprovedNo); meetingApprovedNoMap.put(ged.MeetingApprovedNo, ged); } if (meetingApprovedNoMap.size() > 0) { // 查询系统里的 会议决裁申请 Map acaMap = getAcaMap(meetingApprovedNoMap); // 查询系统里的 市场活动 // Map campaignMap = new Map(); // if (camList.size() > 0) { // campaignMap = getcampaignMap(camList); // } for (String meetingApprovedNo : meetingApprovedNoMap.keySet()) { Result_for_Conference_Adjudication__c rca = new Result_for_Conference_Adjudication__c(); GeData ged = meetingApprovedNoMap.get(meetingApprovedNo); if (!acaMap.containsKey(ged.MeetingApprovedNo)) { logstr += '会议决裁申请不存在，此条数据跳过'; iflog.ErrorLog__c += 'Error! MeetingApprovedNo['+ ged.MeetingApprovedNo +']NotExist. This data is skipped.\n'; upsert iflog; continue; } rca.Application_for_Conference_Adjudication__c = acaMap.get(ged.MeetingApprovedNo).Id; rca.Competitor__c = ged.Competitor; rca.Publicity__c = ged.Publicity; rca.SocietyHoldPlace__c = ged.SocietyHoldPlace; rca.Campaign_Num__c = ged.Num; // if (campaignMap.containsKey(ged.Num)) { // rca.Campaign__c = campaignMap.get(ged.Num).Id; // // 更新会议日程 // Campaign cam = campaignMap.get(ged.Num); // cam.Meeting_Report__c = rca.Id; // cam.Society_Hold_Place__c = rca.SocietyHoldPlace__c; // cam.Report_approved_day__c = Date.today(); // } rcaList.add(rca); } if (rcaList.size() > 0) { insert rcaList; } // if (campaignMap.size() > 0) { // update campaignMap.values(); // } List camNoList = [select id,Num__c,MeetingApprovedNo__c,Meeting_Approved_No__c, Meeting_Approved_No__r.MeetingApprovedNo__c, CampaignStatus__c from Campaign where Meeting_Approved_No__r.MeetingApprovedNo__c in: camList and CampaignStatus__c = '会议结束']; // System.debug(camNoList); if (camNoList != null && camNoList.size() > 0) { List cam_ids = new List(); for(Campaign cam : camNoList) { // System.debug('cam: ' + cam.Num__c + '|' + cam.Meeting_Approved_No__c + '|' + cam.Meeting_Approved_No__r.MeetingApprovedNo__c); Application_for_Conference_Adjudication__c app = acaMap.get(cam.Meeting_Approved_No__r.MeetingApprovedNo__c); // System.debug('app: ' + (app != null ? app.Id : 'null')); cam_ids.add(cam.id); for (Result_for_Conference_Adjudication__c rca : rcaList) { // System.debug('rca: ' + rca.Application_for_Conference_Adjudication__c); if (cam.Meeting_Approved_No__c == rca.Application_for_Conference_Adjudication__c || (app != null && app.Id == rca.Application_for_Conference_Adjudication__c)) { // 更新会议日程 cam.Meeting_Report__c = rca.Id; cam.Society_Hold_Place__c = rca.SocietyHoldPlace__c; cam.Competitor__c = rca.Competitor__c; // 更新报告日期和状态 cam.Report_approved_day__c = Date.today(); cam.Approved_day__c = Date.today(); cam.Status = '已结束'; } break; } } update camNoList; // 更新OPD计划 List opdlist = [select id,status__c from OPDPlan__c WHERE OPDType__c = '学会' and status__c != '完毕' and Campaign__c in: cam_ids]; //将OPD计划的状态更新为 完毕 if (opdlist != null && opdlist.size() > 0) { for (OPDPlan__c opdc : opdlist) { opdc.Status__c= '完毕'; } update opdlist; } } } logstr += '\nend'; rowData.retry_cnt__c = 0; }catch (Exception ex) { Integer batch_retry_max_cnt = Integer.valueOf(System.Label.batch_retry_max_cnt); // エラーが発生した場合 Database.rollback(sp); logstr += '\n' + ex.getMessage(); iflog.ErrorLog__c = ex.getMessage() + '\n' + ex.getStackTraceString() + '\n' + iflog.ErrorLog__c; // 异常重发 rowData = NFMUtil.LogAutoSend(rowData, ex, null); } update rowData; iflog.Log__c = logstr; if (iflog.Log__c.length() > 131072) { iflog.Log__c = iflog.Log__c.subString(0, 131065) + ' ...'; } if (iflog.ErrorLog__c.length() > 32768) { iflog.ErrorLog__c = iflog.ErrorLog__c.subString(0, 32760) + ' ...'; } upsert iflog; } /** * [查询系统里的 会议决裁申请] * @param meetingApprovedNoMap [description] * @return [description] */ public static Map getAcaMap(Map meetingApprovedNoMap){ List acaList = [ select id,MeetingApprovedNo__c from Application_for_Conference_Adjudication__c where MeetingApprovedNo__c in: meetingApprovedNoMap.keySet()]; Map acaMap = new Map(); for (Application_for_Conference_Adjudication__c aca : acaList ) { acaMap.put(aca.MeetingApprovedNo__c, aca); } return acaMap; } /** * [查询系统里的 市场活动] * @param camMap [description] * @return [description] */ // public static Map getcampaignMap(List camList){ // Map campaignMap = new Map(); // List camNoList = [select id,Num__c,MeetingApprovedNo__c // from Campaign // where MeetingApprovedNo__c in: camList]; // if (camNoList.size() > 0) { // for (Campaign cam : camNoList) { // campaignMap.put(cam.Num__c, cam); // } // } // return campaignMap; // } // 必填字段验证 // private static String verify(GeData ged) { // String result = ''; // if (String.isBlank(ged.MeetingApprovedNo)) { // result += 'DataError: 会议决裁编码 [ MeetingApprovedNo ] is null!This data is skipped.\n'; // } // if (String.isBlank(ged.SocietyHoldPlace)) { // result += 'DataError: 会议日程 [ SocietyHoldPlace ] is null!This data is skipped.\n'; // } // return result; // } }