public with sharing class NFM207Controller { public static boolean isRunning = false; //通过NFM207.trriger进行触发 public class GeDatas{ public NFMUtil.Monitoring Monitoring; public NFM207Controller.GeData[] GeData; } public class GeData{ public String AssistantNo; //QIS助理员工编号 public String QISCode; //QIS编号 public NFM207Controller.GeDataDetails[] Products; } public class GeDataDetails{ public String ProductCode; //产品编码 public String ProductName; //产品名称 public String SerialNumber; //保有设备(机身号(设备))，耗材(批号(耗材)) public String ManagementNumber; //管理编码 注:只有保有设备有 public String ContractNumber; // 订单编码 public String CreateDate ; // 生产日期 public String EndDate ; // 有效期 } @future (callout=true) public static void callout(String iflog_Id, List qisIds){ if (qisIds == null || qisIds.size() == 0) { return; } // MessageGroupNumber の取得 List iflogList = [Select Id, Name, Log__c, ErrorLog__c from BatchIF_Log__c where Id = :iflog_Id]; BatchIF_Log__c iflog = null; if (iflogList.size() > 0) { iflog = iflogList.get(0); iflog.ErrorLog__c = ''; } else { // データ取れってないとは、rollbackされていることです return; } String logstr = iflog.Log__c + ' ' + 'NumberOfRecord=' + qisIds.size() + '\n'; GeDatas gds = new GeDatas(); NFMUtil.Monitoring me = new NFMUtil.Monitoring(); Datetime nowDT = Datetime.now(); String nowStr = nowDT.format('yyyyMMddHHmm'); me.Tag = 'MSGH'; me.Sender = 'SFDC'; me.Receiver = 'SPO'; me.MessageType = 'NFM207'; me.MessageGroupNumber = iflog.Name; me.NumberOfRecord = '' + qisIds.size(); me.TransmissionDateTime = nowStr; me.Text = ''; gds.Monitoring = me; BatchIF_Log__c rowData = null; try { List qisList = [select Id, Name, Nonyushohin__c, Consumable__c, Contract_number__c, QIS_product_name__c, Lot_or_serial__c, nonyushohin__r.Product2.ProductCode, nonyushohin__r.TracingCode__c, consumable__r.ProductCode, Salesdepartment__c, BusinessAssistantNo__r.Employee_No__c, nonyushohin__r.ProductionDate__c, nonyushohin__r.Guaranteen_end__c from QIS_Report__c where Id In :qisIds ]; gds.GeData = new List(); GeData gd = new GeData(); gd.Products = new List(); for (QIS_Report__c qis: qisList) { logstr += qis.Name + '\n'; gds.GeData.add(gd); gd.QISCode = qis.Name; gd.AssistantNo = qis.BusinessAssistantNo__r.Employee_No__c; // 保有设备/耗材层级 GeDataDetails gdds = new GeDataDetails(); gdds.ContractNumber = qis.Contract_number__c; // 订单编号 gdds.ProductName = qis.QIS_product_name__c; // QIS设备名 //gdds.SerialNumber = qis.Lot_or_serial__c; // 机身号/批号 if (qis.Lot_or_serial__c.indexOf('(') >= 0 ) { gdds.SerialNumber = qis.Lot_or_serial__c.SubString(0, qis.Lot_or_serial__c.indexOf('(')); // 机身号/批号 } else { gdds.SerialNumber = qis.Lot_or_serial__c; // 机身号/批号 } if (!String.isBlank(qis.nonyushohin__c)) { // 保有设备 gdds.ProductCode = qis.nonyushohin__r.Product2.ProductCode; gdds.ManagementNumber = qis.nonyushohin__r.TracingCode__c; gdds.CreateDate = String.valueOf(qis.nonyushohin__r.ProductionDate__c); gdds.EndDate = String.valueOf(qis.nonyushohin__r.Guaranteen_end__c); } else if (!String.isBlank(qis.consumable__c)) { // 耗材 gdds.ProductCode = qis.consumable__r.ProductCode; gdds.ManagementNumber = null; } gd.Products.add(gdds); } if (gds.GeData.size() > 0) { //logstr += '\ncallout count=' + gds.GeData.size(); // 原則非同期ですので、logsを確認する必要がないでしょう。 NFMUtil.Monitoring Monitoring = new NFMUtil.Monitoring(); Monitoring.Tag = gds.Monitoring.Tag; Monitoring.Sender = gds.Monitoring.Sender; Monitoring.Receiver = gds.Monitoring.Receiver; Monitoring.MessageType = gds.Monitoring.MessageType; Monitoring.MessageGroupNumber = gds.Monitoring.MessageGroupNumber; Monitoring.NumberOfRecord = gds.Monitoring.NumberOfRecord; Monitoring.TransmissionDateTime = gds.Monitoring.TransmissionDateTime; Monitoring.Text = ''; rowData = NFMUtil.makeRowData(Monitoring, 'NFM207', gds); execute(rowData, iflog); } logstr += '\nend'; rowData.retry_cnt__c=0; } catch (Exception ex) { // エラーが発生した場合 System.debug(Logginglevel.ERROR, 'NFM207_' + iflog.Name + ':' + ex.getMessage()); System.debug(Logginglevel.ERROR, 'NFM207_' + iflog.Name + ':' + ex.getStackTraceString()); logstr += ex.getMessage(); iflog.ErrorLog__c += ex.getMessage() + '\n'; iflog.ErrorLog__c += ex.getStackTraceString() + '\n'; } if (rowData != null) { insert rowData; } System.debug(Logginglevel.DEBUG, 'NFM001_' + iflog.Name + ' end'); iflog.Log__c = logstr; update iflog; } public static void execute(BatchIF_Log__c rowData, BatchIF_Log__c iflog) { //xinhonglu Integer batch_retry_max_cnt = Integer.valueOf(System.Label.batch_retry_max_cnt); String rowDataStr = NFMUtil.getRowDataStr(rowData); GeDatas gds = (GeDatas) JSON.deserialize(rowDataStr, GeDatas.class); String logstr = gds.Monitoring.MessageGroupNumber + ' start\n'; Boolean needUpdateIflog = false; if (iflog == null) { needUpdateIflog = true; iflog = new BatchIF_Log__c(); iflog.Type__c = 'NFM207'; iflog.MessageGroupNumber__c = gds.Monitoring.MessageGroupNumber; iflog.Log__c = logstr; iflog.ErrorLog__c = ''; } else { logstr = iflog.Log__c; } try { NFMUtil.sendToSpo(rowDataStr, NFMUtil.NFM207_ENDPOINT); } catch(Exception ex) { // TODO IOException // エラーが発生した場合 System.debug(Logginglevel.ERROR, 'NFM207_' + iflog.Name + ':' + ex.getMessage()); System.debug(Logginglevel.ERROR, 'NFM207_' + iflog.Name + ':' + ex.getStackTraceString()); logstr += ex.getMessage(); iflog.ErrorLog__c += ex.getMessage() + '\n'; iflog.ErrorLog__c += ex.getStackTraceString() + '\n'; if (rowData.retry_cnt__c == null) rowData.retry_cnt__c = 0; if (rowData.retry_cnt__c < batch_retry_max_cnt){ rowData.retry_cnt__c++; LogAutoSendSchedule.assignOneMinute(); } if (rowData.retry_cnt__c >= batch_retry_max_cnt){ rowData.ErrorLog__c = ex.getMessage() + '\n' + ex.getStackTraceString() + '\n' + rowData.ErrorLog__c+'错误次数已经超过自动送信设定的最大次数，请手动送信'; } } iflog.Log__c = logstr; if (needUpdateIflog) { insert iflog; update rowData; } } }