/** * 调用地址： * ContactTriggerHandler.sendToComPlat 直接调用 接口 */ public without sharing class NFM606Controller { public static String logstr; public static String status; //add aws respnse sushanhu 20220228 start public static String responseBody; //add aws respnse sushanhu 20220228 end private static final String LOG_TYPE = 'NFM606'; private static final String API = '/admin/api/user/save'; public class NFM606 { public GeDatas GeDatas; } public Class GeDatas { public NFMUtil.MonitoringToComPlat Monitoring; public GeData[] GeData; } public Class GeData { public String ContactId; //智慧医疗ID public String ServiceUserId; //服务平台用户ID public String Mobile; //手机号码 public String PersonManagementCode; //人员管理编码 public Boolean AgentFlag; //经销商标识 True：是经销商；False：是医院 public String State; //省 public String City; //市 public String SalesBusinessDivision; //销售本部 public Boolean Status; //状态 public String Hospital; //医院编码 public String Department; //科室编码 public String Name; //姓名 public String Account; //经销商名称 public String AgentCode; //经销商编码 public String AgentUserType; //人员类型 public String Email; //电子邮件 //add aws pi start sushanhu 20220228 public String DataId;//aws 存储凭据 //add aws pi end sushanhu 20220228 } @future(callout = true) public static void callout(String iflog_Id, List < String > conIdList) { executeNotFuture(iflog_Id, conIdList); } public static void executeNotFuture(String iflog_Id, List < String > conIdList) { Datetime nowDT = Datetime.now(); String nowStr = nowDT.format('yyyyMMddHHmmss'); BatchIF_Log__c iflog = new BatchIF_Log__c(); if (string.isNotBlank(iflog_Id)) { iflog = [Select Id, Name, Log__c, ErrorLog__c,MessageGroupNumber__c from BatchIF_Log__c where Id =: iflog_Id]; } iflog.MessageGroupNumber__c = String.isBlank(iflog.Id)?nowStr:iflog.MessageGroupNumber__c; iflog.Log__c = 'callout start\n'; iflog.Type__c = LOG_TYPE; iflog.ErrorLog__c = ''; NFMUtil.MonitoringToComPlat me = new NFMUtil.MonitoringToComPlat(); me.Tag = 'MSGH'; me.Sender = 'SFDC'; me.Receiver = '智慧医疗/服务新系统'; me.MessageType = LOG_TYPE; me.MessageGroupNumber = nowStr; if (String.isNotBlank(iflog.Name)) { me.MessageGroupNumber = iflog.Name; } me.TransmissionDateTime = nowStr; me.Text = ''; String randomstr = NFMUtil.randomUUID(16); Long timestamp = DateTime.now().getTime(); String timestampStr = String.valueOf(timestamp); String getToken = NFMUtil.getToken(randomstr, timestamp); me.API_RANDOM_STR = randomstr; me.API_TIME = timestampStr; me.API_TOKEN = getToken; GeDatas gds = new GeDatas(); gds.GeData = new List < GeData > (); BatchIF_Log__c rowData = null; // 排除 记录类型为 社内员工的联系人 List < Contact > conList = [select id, UnifiedI_Contact_ID__c, MobilePhone, Salesdepartment_Text__c, Account.Management_Code__c, Account.Hospital__r.State_Master__r.Name, Account.Hospital__r.City_Master__r.Name, Account.Hospital__r.State_Master__r.Level1_Code__c, Account.Hospital__r.City_Master__r.Level2_Code__c, Isactive__c, ContactType__c, Account.Name, CManageCode__c, Account.Salesdepartment_Dept__c, Account.Hospital__r.Salesdepartment_Dept__c, Account.Hospital_Department_Class__r.Salesdepartment_Dept__c, Agency_User__c, RecordTypeId, ServicePlatformCode__c, Account.Parent_Management_Code__c, Account.State_Master__r.Level1_Code__c, Account.City_Master__r.Level2_Code__c, Account.Hospital_Department_Class__r.State_Master__r.Level1_Code__c, Account.Hospital_Department_Class__r.City_Master__r.Level2_Code__c, Account.ParentId, Account.Parent.ParentId, UniqueNumber__c, AWS_Data_Id__c, Name, Email from Contact where id in: conIdList AND RecordTypeId != '01210000000QtkyAAC' ]; String logstr = iflog.Log__c + ' ' + 'NumberOfRecord=' + conList.size() + '\n'; try { for (Contact con: conList) { String flag = ''; GeData ged = new GeData(); ged.ContactId = String.isBlank(con.UnifiedI_Contact_ID__c) ? '':con.UnifiedI_Contact_ID__c; //智慧医疗ID //update to AWS_UnifiedI_Contact_ID__c sushanhu 20220228 start //ged.ContactId = String.isBlank(con.) ? '':con.AWS_UnifiedI_Contact_ID__c; //AWS 智慧医疗ID ////update to AWS_UnifiedI_Contact_ID__c sushanhu 20220228 end ged.ServiceUserId = String.isBlank(con.ServicePlatformCode__c) ? '':con.ServicePlatformCode__c; //服务平台用户ID??? ged.Mobile = String.isNotBlank(con.UniqueNumber__c) ? con.UniqueNumber__c:con.MobilePhone;//手机 ged.PersonManagementCode = con.CManageCode__c; //人员管理编码 ged.Status = '有效'.equals(con.Isactive__c) ? true:false ;//状态 ged.Name = con.Name;//姓名 ged.Email = ''; ged.Hospital =''; //医院编码 ged.Department = ''; //科室编码 ged.Account = '';//经销商名 ged.AgentCode = '';//经销商编码 ged.AgentUserType =''; //人员类型 ged.AgentFlag = false;//经销商标识 if (!ged.Status) { ged.Mobile = con.MobilePhone; } // 医师 if ('01210000000QfWdAAK'.equals(con.RecordTypeId)) { ged.Hospital = con.Account.Parent_Management_Code__c;//医院编码 ged.Department = con.Account.Management_Code__c; //科室编码 ged.AgentFlag = false;//医院 } // 经销商 if ('01210000000QfWiAAK'.equals(con.RecordTypeId)) { //ged.Name = con.Name;//姓名 ged.Account = con.Account.Name;//经销商名 ged.AgentCode = con.Account.Management_Code__c;//经销商编码 ged.AgentUserType = String.isBlank(con.ContactType__c) ? '': con.ContactType__c.replaceAll(';',',');//人员类型 ged.AgentFlag = true;//经销商 ged.Email = con.Email; } ged.DataId =con.AWS_Data_Id__c;//add aws 存储凭据 ged = getStateAndCity(ged,con); gds.GeData.add(ged); } logstr += '\nend'; if (gds.GeData.size() > 0) { me.NumberOfRecord = '' + gds.GeData.size(); gds.Monitoring = me; logstr = iflog.Log__c + '\nNumberOfRecord=' + gds.GeData.size() + ' '; 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 = ''; NFM606 nfm606 = new NFM606(); nfm606.GeDatas = new GeDatas(); nfm606.GeDatas = gds; rowData = NFMUtil.makeRowData(Monitoring, LOG_TYPE, nfm606); execute(rowData, iflog); } } catch (Exception e) { //发生错误时 System.debug(Logginglevel.ERROR, LOG_TYPE + iflog.Name + ':' + e.getMessage()); System.debug(Logginglevel.ERROR, LOG_TYPE + iflog.Name + ':' + e.getStackTraceString()); logstr += e.getMessage(); iflog.ErrorLog__c += e.getMessage() + '\n'; iflog.ErrorLog__c += e.getStackTraceString() + '\n'; iflog.Log__c = iflog.Log__c + logstr; } if (rowData != null) { upsert rowData; } iflog.Log__c = logstr; system.debug('======================================'+logstr); upsert iflog; } private static GeData getStateAndCity(GeData ged,Contact con){ String state = ''; String city = ''; String salesdepartment_Dept = ''; if (String.isBlank(con.Account.ParentId)) {//医院/经销商下的联系人，获取医院/经销商的省和市的编码;销售本部 state = con.Account.State_Master__r.Level1_Code__c; city = con.Account.City_Master__r.Level2_Code__c; salesdepartment_Dept = con.Account.Salesdepartment_Dept__c; //销售本部 } else if(String.isNotBlank(con.Account.Parent.ParentId)){//科室下的联系人， 获取医院的省和市的编码;销售本部 state = con.Account.Hospital__r.State_Master__r.Level1_Code__c;//省 city = con.Account.Hospital__r.City_Master__r.Level2_Code__c;//市 salesdepartment_Dept = con.Account.Hospital__r.Salesdepartment_Dept__c;//销售本部 } else {//战略科室下的联系人，获取医院的省和市的编码;销售本部 state = con.Account.Hospital_Department_Class__r.State_Master__r.Level1_Code__c;//省 city = con.Account.Hospital_Department_Class__r.City_Master__r.Level2_Code__c;//市 salesdepartment_Dept = con.Account.Hospital_Department_Class__r.Salesdepartment_Dept__c;//销售本部 } ged.State = state; ged.City = city; ged.SalesBusinessDivision = salesdepartment_Dept; return ged; } /** * 接口发送失败 根据BatchLogId进行手动发送 * @Author XHL * @DateTime 2021-07-22 * @param rowDataId [BatchLogId] */ public static void ManualExecute(String rowDataId) { List < BatchIF_Log__c > row = [select id, name, MessageGroupNumber__c, retry_cnt__c, RowDataFlg__c, ErrorLog__c, Type__c, Log__c, Log2__c, Log3__c, Log4__c, Log5__c, Log6__c, Log7__c, Log8__c, Log9__c, Log10__c, Log11__c, Log12__c from BatchIF_Log__c where id =: rowDataId ]; if (row.size() > 0) execute(row[0], null); } /** * 逻辑正常执行发送 * @Author XHL * @DateTime 2021-07-22 * @param rowDataSFDC [BatchLogId] * @param iflog [执行情况记录] */ public static void execute(BatchIF_Log__c rowDataSFDC, BatchIF_Log__c iflog) { Integer batch_retry_max_cnt = Integer.valueOf(System.Label.batch_retry_max_cnt); String rowDataStr = NFMUtil.getRowDataStr(rowDataSFDC); String logstr = rowDataSFDC.MessageGroupNumber__c + ' start\n'; if (iflog == null) { iflog = new BatchIF_Log__c(); iflog.Type__c = LOG_TYPE; iflog.MessageGroupNumber__c = rowDataSFDC.MessageGroupNumber__c; iflog.Log__c = logstr; iflog.ErrorLog__c = ''; } else { iflog.Type__c = LOG_TYPE; iflog.MessageGroupNumber__c = rowDataSFDC.MessageGroupNumber__c; logstr = iflog.Log__c; } try { // // 发往PO // status = NFMUtil.sendToSapRet(rowDataStr, NFMUtil.NFM606_ENDPOINT); // System.debug('NFM606Log--status->'+ status); // // status = '' // if ('Accepted'.equals(status)) { // logstr += status+'\n'; // rowDataSFDC.retry_cnt__c = 0; // } // else { // rowDataSFDC = NFMUtil.LogAutoSend(rowDataSFDC, null, status); // } //update to aws 20220228 sushanhu satrt PIHelper.PIIntegration pi =PIHelper.getPIIntegrationInfo('NFM606'); NFMUtil.response result =NFMUtil.sendToPiAWS(rowDataStr,pi.newUrl,pi.token); system.debug('aws result---'+result); responseBody=result.responseBody; //Map res = (Map)JSON.deserializeUntyped(responseBody); //status=(String)res.get(status); status =result.status; system.debug('stadtucode--'+result.status); if ('202'.equals(status)) { logstr += status+'\n'; rowDataSFDC.retry_cnt__c = 0; } else { logstr+=responseBody+'\n'; rowDataSFDC = NFMUtil.LogAutoSend(rowDataSFDC, null, status); } //update to aws 20220228 sushanhu end } catch (Exception ex) { // TODO IOException // 异常重发 // Callout from triggers are currently not supported. if (!String.valueOf(ex.getMessage()).contains('Callout from triggers')) { logstr += ex.getMessage(); iflog.ErrorLog__c += ex.getMessage() + '\n'; iflog.ErrorLog__c += ex.getStackTraceString() + '\n'; } rowDataSFDC = NFMUtil.LogAutoSend(rowDataSFDC, null, status); } iflog.Log__c = iflog.Log__c + logstr; upsert iflog; upsert rowDataSFDC; } }