@RestResource(urlMapping = '/NFM609/*') global with sharing class NFM609Rest { public static final String LOG_TYPE = 'NFM609'; global class GeData { public String CICstaff; //CIC所属人 public String complaintID; //业务单号 public String[] QuestionList; //询问内容 public String InquireContent; //询问内容(数据不保存) public String InquirePlatform; //询问方式 public String InquireProduct; //询问产品 public String InquirerDate; //询问日期 public String InquirerType; //询问方 public String[] AnswerList; //回答内容 public String answerContent; //回答内容(数据不保存) public String answerDate; //回答日期 public String attachmentName; //附件名称 public String attachmentfile; //附件 public String dealMethod; //应对方法 public String faultJudgment; //故障判断 public String field; //所属领域 public String mngCd; //投诉人管理编码 public String province; //管辖部门 public String questionType; //问题分类 public String remarks; //备注 public String status; //状态 public String trackType; //跟踪 public String unifiedUserID; //投诉人统一ID } @HttpPost global static void doPost() { //取得接口传输内容 String strData = RestContext.request.requestBody.toString(); List < GeData > ges = (List < GeData > ) JSON.deserializeStrict(strData, List < GeData > .class); if (ges == null) { return; } BatchIF_Log__c iflog = new BatchIF_Log__c(); iflog.Type__c = LOG_TYPE; iflog.ErrorLog__c = ''; iflog.Log__c = 'callout start\n'; BatchIF_Log__c rowData = NFMUtil.makeRowData(iflog, LOG_TYPE, ges); 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 = '{"status":"Success","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 < String > cicstaffList = new List < String > (); //存放cic所属人 List < String > inquireList = new List < String > (); //存放询问产品 List < String > mngCdList = new List < String > (); Map < String, GeData > geDataMap = new Map < String, GeData > (); //遍历给oldcicIdList存放id，给map赋值 for (GeData ged: itemMasterList) { String dataComplete = verify(ged); if (!String.isBlank(dataComplete)) { logstr += dataComplete; continue; } geDataMap.put(ged.complaintID, ged); //key是接口拿到的id，value是GeData一整条数据 cicstaffList.add(ged.CICstaff); inquireList.add(ged.InquireProduct); if (String.isNotBlank(ged.mngCd)) { mngCdList.add(ged.mngCd); } } if (geDataMap.size() > 0) { // 获取CIC Map < String, Case > caseMap = getCaseMap(geDataMap); // 获取 启用的用户 Map < String, Id > cicstaffmap = getCaseOwnerMap(cicstaffList); // 获取产品 Map < String, Id > inquireMap = getProductMap(inquireList); // 获取联系人以及联系人对应的客户 Map < String, Contact > accountIdMap = getContactMap(mngCdList); List < Case > upsertList = new List < Case > (); Map < String, List < String >> answerMap = new Map < String, List < String >> (); Boolean attachmentDownloadFlg = false; String complaintIDStr = '业务单号 [ \n'; for (String complaintID: geDataMap.keySet()) { GeData ged = geDataMap.get(complaintID); if (!cicstaffmap.containsKey(ged.CICstaff)) { logstr += ged.CICstaff + '员工编码不存在或对应用户无效,此条数据跳过'; continue; } Case cas = caseMap.containsKey(complaintID) ? caseMap.get(complaintID) : new Case(); //new Case(); //询问产品 if (inquireMap.containsKey(ged.InquireProduct)) { cas.prod__c = inquireMap.get(ged.InquireProduct); } else { cas.Other_company_product__c = ged.InquireProduct; } if (accountIdMap.containsKey(ged.mngCd)) { Contact con = accountIdMap.get(ged.mngCd); cas.ContactId = con.Id; cas.Account__c = getAccountId(con); } cas.Ownerid = cicstaffmap.get(ged.CICstaff); //CIC所属人 cas.inquiry_detail__c =ged.InquireContent; //询问内容 //'内容太长，详情请见 CIC问答内容 相关内容'; //ged.InquireContent; //询问内容 cas.complaintID__c = ged.complaintID; //业务单号 cas.Origin = '客户端'; //(个案来源)(20220106修改) cas.Received_call_day__c = NFMUtil.parseStr2Date(ged.InquirerDate); //询问日期(收到电话日) cas.Contact_staff__c = ged.InquirerType; //询问方 cas.answer_detail_content__c = ged.answerContent; //回答内容 '内容太长，详情请见 CIC问答内容 相关内容'; // cas.answer_day__c = NFMUtil.parseStr2Date(ged.answerDate); //回答日期 cas.Process_method__c = ged.dealMethod; //对应方法 cas.solutuion__c = ged.faultJudgment; //故障判断 cas.Question_Area_new__c = ged.field; //所属领域 cas.Province__c = ged.province; //管辖部门 cas.inquiry_type__c = ged.questionType; //问题类别 cas.Text_attachement__c = ged.remarks; //备注 cas.Status = ged.status; //状态 cas.Follow_category__c = ged.trackType; //跟踪 cas.RecordTypeId = '01210000000QsYpAAK'; cas.AttachmentLink__c = ged.attachmentfile; String attachmentName = ged.attachmentName; cas.AttachmentName__c = attachmentName; if (String.isNotBlank(ged.attachmentfile)) { cas.AttachmentDownload__c = true; attachmentDownloadFlg = true; if (String.isBlank(attachmentName) || (String.isNotBlank(attachmentName) && !attachmentName.contains('.zip'))){ cas.AttachmentName__c = '附件.zip'; } } upsertList.add(cas); if ('投诉'.equals(ged.questionType)) { //问答时 AnswerList放全部， 投诉时 需合并 QuestionList ged.AnswerList.addAll(ged.QuestionList); } complaintIDStr += complaintID + '\n'; answerMap.put(complaintID, ged.AnswerList); } if (upsertList.size() > 0) { upsert upsertList; logstr += complaintIDStr + ' ]\n保存成功\n'; if (attachmentDownloadFlg) { NFM609Schedule.assignOneMinute('Case'); } } } logstr += 'END'; rowData.retry_cnt__c = 0; } catch (Exception ex) { //发生错误时 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); } finally { update rowData; iflog.Log__c = logstr; update iflog; } } private static String verify(GeData ged) { String result = ''; String complaintID = ''; if (ged == null) { result += 'DataError: is null!\n'; } else { if (String.isBlank(ged.complaintID)) { result += 'DataError: 业务单号 [ complaintID ] is null!\n'; } else { complaintID = '业务单号 [ ' + ged.complaintID + ' ]\n'; } if (String.isBlank(ged.CICstaff)) { result += 'DataError: CIC所属人 [ CICstaff ] is null!\n'; } if (String.isBlank(ged.questionType)) { result += 'DataError: 问题类别 [ questionType ] is null!\n'; } if (String.isBlank(ged.InquireProduct)) { result += 'DataError: 询问产品 [ InquireProduct ] is null!\n'; } if (ged.AnswerList == null) { result += 'DataError: 回答内容 [ AnswerList ] is null!\n'; } if (String.isNotBlank(complaintID) && String.isNotBlank(result)) { result += complaintID + result; } } return result; } // 查找 CIC(个案) private static Map < String, Case > getCaseMap(Map < String, GeData > geDataMap) { List < Case > caseList = [SELECT Id, complaintID__c FROM Case WHERE complaintID__c IN: geDataMap.keySet()]; Map < String, Case > caseMap = new Map < String, Case > (); for (Case cas: caseList) { caseMap.put(cas.complaintID__c, cas); } return caseMap; } // 查找 启用的用户 private static Map < String, Id > getCaseOwnerMap(List < String > cicstaffList) { List < User > userList = [SELECT id, Employee_No__c FROM User WHERE Employee_No__c IN: cicstaffList and IsActive = true]; Map < String, Id > cicstaffmap = new Map < String, Id > (); for (User u: userList) { cicstaffmap.put(u.Employee_No__c, u.Id); } return cicstaffmap; } // 获取客户Id private static String getAccountId(Contact con) { String result = null; // 医院/经销商 if (String.isBlank(con.Account.ParentId)) { result = con.AccountId; } else if (String.isNotBlank(con.Account.Parent.ParentId)) { //科室 result = con.Account.Parent.ParentId; } else { //战略科室 result = con.Account.ParentId; } return result; } // 查找 联系人 public static Map < String, Contact > getContactMap(List < String > mngCdList) { Map < String, Contact > accountIdMap = new Map < String, Contact > (); if (mngCdList.size() > 0) { String contactId = null; List < Contact > contactList = [ SELECT Id, AccountId, Account.Name, Account.ParentId, Account.Parent.ParentId, CManageCode__c, Employee_No_manual__c FROM Contact WHERE CManageCode__c IN: mngCdList OR Employee_No_manual__c IN: mngCdList ]; for (Contact con: contactList) { if (String.isNotBlank(con.Employee_No_manual__c)) { accountIdMap.put(con.Employee_No_manual__c, con); } accountIdMap.put(con.CManageCode__c, con); } } return accountIdMap; } // 根据产品型号 查找最晚创建的产品 private static Map < String, Id > getProductMap(List < String > inquireList) { List < Product2 > productList = [SELECT Id, Asset_Model_No__c, createdDate FROM product2 WHERE Asset_Model_No__c IN: inquireList ORDER BY Asset_Model_No__c, createdDate]; Map < String, Id > inquireMap = new Map < String, Id > (); for (Product2 pro: productList) { inquireMap.put(pro.Asset_Model_No__c, pro.Id); } return inquireMap; } }