| | |
| | | |
| | | } |
| | | *************************************************************************/ |
| | | |
| | | |
| | | @RestResource(urlMapping = '/NFM624/*') |
| | | global with sharing class NFM624Rest { |
| | | //add to AWS 回复 start sushanhu 20220225 |
| | | static Boolean SFStatus=true; |
| | | static String SFMessage=''; |
| | | //add to AWS 回复 end sushanhu 20220225 |
| | | private static final String LOG_TYPE = 'NFM624'; |
| | | // global class GeDatasRest { |
| | | // public GeDatas GeDatas; |
| | |
| | | public NFMUtil.Monitoring Monitoring; |
| | | public GeData[] GeData; |
| | | } |
| | | |
| | | |
| | | global class GeData { |
| | | public String ContactId; //统一平台ID |
| | | public String ContactId; //统一平台ID//Update to aws 存储的AWSContactId 20220225 SUSHANHU |
| | | public String ServiceUserId; //服务平台用户ID |
| | | public String PersonManagementCode; //人员管理编码 |
| | | public String HospitalManagementCode2; //医院平台编码 平台编码 PlatformCode__c |
| | | public String DepartmentManagementCode2; //科室平台编码 平台编码 PlatformCode__c |
| | | public String Name; //姓名 |
| | | public String NameEncrypted;//姓名密文 add 20220215 |
| | | public String Mobile; //手机号码 |
| | | public String MobileEncrypted;//手机号码密文 add 20220215 |
| | | public String State; //单位所在省份 |
| | | public String City; //市 |
| | | public String AccountName; //医院名 |
| | |
| | | public String DepartmentName; //所属科室 |
| | | public String RelatedDepartment; //关联SFDC科室 客户管理编码(手写) AgentCode_Ext__c |
| | | public String Type; //职种 |
| | | public String TypeEncrypted;//职种Hash add for pipl 20220316 sushanhu |
| | | public String ContactAddress; //联系地址 |
| | | public Boolean ForbiddenStatus; //平台用户禁用标识 |
| | | public String ContactAddressEncrypted;//联系地址密文 |
| | | public Boolean ForbiddenStatus; //平台用户禁用标识 |
| | | public String RegSource; //注册平台来源 |
| | | public Boolean AgentFlag; //经销商标识 |
| | | public String ApproverID; //审核人员员工编码 |
| | | public String DataId;//aws存储凭据 |
| | | } |
| | | |
| | | |
| | | @HttpPost |
| | | global static void execute() { |
| | | |
| | | |
| | | // 取得接口传输内容 |
| | | String strData = RestContext.request.requestBody.toString(); |
| | | GeDatas ges = (GeDatas) JSON.deserializeStrict(strData, GeDatas.class); |
| | | |
| | | |
| | | system.debug('ges---'+ges); |
| | | |
| | | if (ges == null) { |
| | | return; |
| | | } |
| | | |
| | | |
| | | NFMUtil.Monitoring Monitoring = ges.Monitoring; |
| | | if (Monitoring == null) { |
| | | return; |
| | | } |
| | | |
| | | |
| | | BatchIF_Log__c rowData = NFMUtil.saveRowData(Monitoring, LOG_TYPE, ges.GeData); |
| | | system.debug('String.isBlank(rowData.Log__c) == false?'); |
| | | if (String.isBlank(rowData.Log__c) == false) { |
| | | System.debug('进入if方法,成功调用executefuture'); |
| | | 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); |
| | | // String jsonResponse = '{"status": "Success", "Message":""}'; |
| | | // res.responseBody = blob.valueOf(jsonResponse); |
| | | //updata response toAWS 20220225 sushanhu start |
| | | NFMUtil.NFMResponse result = NFMUtil.getNFMResponse(); |
| | | result.SFStatus=SFStatus; |
| | | result.SFMessage=SFMessage; |
| | | String jsonResponse =JSON.serialize(result); |
| | | system.debug('result---'+jsonResponse); |
| | | res.responseBody = blob.valueOf(jsonResponse); |
| | | //updata response toAWS 20220225 sushanhu end |
| | | return; |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | @future |
| | | global static void executefuture(String rowData_Id) { |
| | | system.debug('进入executefuture方法' + rowData_Id); |
| | | main(rowData_Id); |
| | | } |
| | | |
| | | |
| | | global static void main(String rowData_Id) { |
| | | |
| | | // Map<String,String> RecordTypeMap = new Map<String,String>(); |
| | | // RecordTypeMap.put('','') |
| | | //List<RecordType> rectDpt = [select Id from RecordType where IsActive = true and SobjectType = 'Account' and DeveloperName IN ('Department_OTH','Department_GI', 'Department_BF','Department_GYN','Department_GS','Department_URO','Department_ENT','Department_Class_ET') order by DeveloperName desc]; |
| | | Map < string, string > RecordTypeMap = new Map < string, string > (); //存放记录类型Id |
| | | //for(ID temp : rectDpt){ |
| | | // |
| | | //} |
| | | RecordTypeMap.put('呼吸科', '01210000000QfmR'); |
| | | RecordTypeMap.put('其他', '01210000000Qfmb'); |
| | | RecordTypeMap.put('妇科', '01210000000QfmM'); |
| | |
| | | iflog.Log__c = logstr; |
| | | iflog.ErrorLog__c = ''; |
| | | insert iflog; |
| | | |
| | | |
| | | String rowDataStr = NFMUtil.getRowDataStr(rowData); |
| | | List < GeData > GeDataList = (List < GeData > ) JSON.deserialize(rowDataStr, List < GeData > .class); |
| | | if (GeDataList == null || GeDataList.size() == 0) { |
| | |
| | | // continue; |
| | | // } |
| | | // } |
| | | |
| | | |
| | | Savepoint sp = Database.setSavepoint(); |
| | | List<string> ApproverIDList = new List <string>();// |
| | | List < string > PersonManagementCodeList = new List < String > (); //人员管理编码List |
| | |
| | | List < String > ManagementList = new List < String > (); //医院、科室平台编码List |
| | | List < String > StateList = new List < String > (); |
| | | List < String > CityList = new List < String > (); |
| | | List < String > NameList = new List < String >(); |
| | | try { //根据传过来的管理编码查询如果可以查询得到结果则更新,查询不到则新增 |
| | | List < Gedata > newGeDataList = new List < Gedata > (); |
| | | for (Gedata gedata: GeDataList) { |
| | | string dataComplete = verify(gedata); |
| | | |
| | | if (!String.isBlank(dataComplete)) { |
| | | logstr += dataComplete; |
| | | rowData.Is_Error__c = 1; |
| | | rowData.retry_cnt__c = 0; |
| | | continue; |
| | | } |
| | | if (!gedata.AgentFlag) { |
| | | StateList.add(gedata.State); |
| | | CityList.add(gedata.City); |
| | | ApproverIDList.add(gedata.ApproverID); |
| | | ManagementList.add(gedata.HospitalManagementCode2); |
| | | ManagementList.add(gedata.DepartmentManagementCode2); |
| | | if(string.isnotblank(gedata.HospitalManagementCode2)){ |
| | | ManagementList.add(gedata.HospitalManagementCode2); |
| | | } |
| | | if(string.isnotblank(gedata.DepartmentManagementCode2)){ |
| | | ManagementList.add(gedata.DepartmentManagementCode2); |
| | | } |
| | | //system.debug('AccountCodeList'+AccountCodeList); |
| | | if (string.isnotblank(gedata.RelatedHospital)) { |
| | | SFDCCodeList.add(gedata.RelatedHospital); |
| | |
| | | } |
| | | if (string.isnotblank(gedata.PersonManagementCode)) { |
| | | PersonManagementCodeList.add(gedata.PersonManagementCode); |
| | | } |
| | | if(String.isnotBlank(gedata.NameEncrypted)){ |
| | | NameList.add(gedata.NameEncrypted); |
| | | } |
| | | newGeDataList.add(gedata); |
| | | System.debug('ManagementList'+ManagementList); |
| | |
| | | for (Address_Level2__c temp: citytempList) { |
| | | CityMap.put(temp.Name, temp.Id); |
| | | } |
| | | |
| | | |
| | | //查询医院所有人 |
| | | Map<string,String> ownerMap = new Map<string,String>(); |
| | | List<User> ownerList = [select Id,Employee_No__c from User where Employee_No__c IN:ApproverIDList]; |
| | | for(User temp : ownerList){ |
| | | ownerMap.put(temp.Employee_No__c,temp.Id); |
| | | } |
| | | |
| | | |
| | | //查询OCSM营业窗口 |
| | | Map<string,Id> OCSMMap = new Map<string,Id>(); |
| | | List<OCM_Management_Province__c> OCSMList = [select Id,Name,Window1__c from OCM_Management_Province__c]; |
| | | for(OCM_Management_Province__c ocsm : OCSMList){ |
| | | OCSMMap.put(ocsm.name,ocsm.Window1__c); |
| | | } |
| | | |
| | | |
| | | //查询联系人 |
| | | Map < String, Map < String, Contact >> nameMap = new Map < String, Map < String, Contact >> (); //外层战略科室,内层科室名+联系人名 |
| | | List < Contact > peopleList = [select Id, |
| | | Account.Name, |
| | | Account.Name, |
| | | Department__c, |
| | | UnifiedI_Contact_ID__c, |
| | | Account.parent.Name, |
| | | Account.PlatformCode__c, |
| | | Account.Management_Code__c, |
| | | Account.parent.Department_Class_Label__c, |
| | | Name, |
| | | Name,LastName_Encrypted__c, |
| | | Account.Parent_Management_Code__c, |
| | | Account.Parent_PlatformCode__c, |
| | | CManageCode__c, |
| | | AccountId |
| | | AccountId, |
| | | // 通过姓名+手机号判断人员是否重复 thh 20220518 start |
| | | MobilePhone_Encrypted__c |
| | | // 通过姓名+手机号判断人员是否重复 thh 20220518 end |
| | | from Contact |
| | | where CManageCode__c IN: PersonManagementCodeList |
| | | OR Account.Parent_PlatformCode__c IN: ManagementList |
| | | OR Account.Parent_Management_Code__c IN: SFDCCodeList]; //根据人员管理编码检索联系人 |
| | | OR (Account.Parent_PlatformCode__c IN: ManagementList AND LastName_Encrypted__c IN:NameList) |
| | | OR (Account.Parent_Management_Code__c IN: SFDCCodeList AND LastName_Encrypted__c IN:NameList ) |
| | | ORDER BY MobilePhone ASC,CManageCode__c ASC]; //根据人员管理编码检索联系人 |
| | | Map < String, Contact > peopleMap = new Map < String, Contact > (); //联系人 |
| | | system.debug('peopleList '+peopleList); |
| | | for (Contact ct: peopleList) { |
| | | if (string.isnotblank(ct.Account.parent.Name)) { |
| | | Map < String, Contact > snameMap = new Map < String, Contact > (); |
| | | string Name = ct.Name.replaceAll(' ',''); |
| | | string namekey = ct.Account.Name + ' ' + Name; |
| | | string namekey; |
| | | string nameKey2; |
| | | if(String.isBlank(ct.MobilePhone_Encrypted__c)){ |
| | | namekey = ct.Account.Name + ' ' + ct.LastName_Encrypted__c.trim(); |
| | | nameKey2 = ct.Account.Management_Code__c + ' ' + ct.LastName_Encrypted__c.trim(); |
| | | } else{ |
| | | namekey = ct.Account.Name + ' ' + ct.LastName_Encrypted__c.trim() + ' ' + ct.MobilePhone_Encrypted__c.trim(); |
| | | nameKey2 = ct.Account.Management_Code__c + ' ' + ct.LastName_Encrypted__c.trim() + ' ' + ct.MobilePhone_Encrypted__c.trim(); |
| | | } |
| | | // snameMap.put(namekey,ct); |
| | | if (nameMap.containsKey(ct.Account.parent.Name)) { |
| | | snameMap = nameMap.get(ct.Account.parent.Name); |
| | | } |
| | | snameMap.put(namekey, ct); |
| | | snameMap.put(ct.Name, ct); |
| | | snameMap.put(nameKey2,ct); |
| | | // // 通过姓名+手机号判断人员是否重复 thh 20220518 start |
| | | // if(String.isBlank(ct.MobilePhone_Encrypted__c)){ |
| | | // snameMap.put(ct.LastName_Encrypted__c.trim(), ct); |
| | | // } else{ |
| | | // snameMap.put(ct.LastName_Encrypted__c.trim() + ct.MobilePhone_Encrypted__c.trim(), ct); |
| | | // } |
| | | // // 通过姓名+手机号判断人员是否重复 thh 20220518 end |
| | | nameMap.put(ct.Account.parent.Name, snameMap); |
| | | system.debug('snameMap'+snameMap); |
| | | } |
| | | peopleMap.put(ct.CManageCode__c, ct); |
| | | System.debug('peopleMap'+peopleMap); |
| | |
| | | //string temp = ct.Name + ct.Account.parent.Department_Class_Label__c; |
| | | // peopleMap.put(temp, ct); |
| | | } |
| | | |
| | | |
| | | //查询医院科室 |
| | | //List<Account> AccountList = [select Id,PlatformCode__c,PlatformCode__c,Department_Class_Label__c,Name,Management_Code__c,Is_Active__c,AgentCode_Ext__c,ParentId,Parent.ParentId from Account where PlatformCode__c IN :HpCodeList OR parent.PlatformCode__c IN :HpCodeList OR PlatformCode__c IN :HpCodeList OR Management_Code__c IN :RelatedHospitalList OR Parent_Management_Code__c IN :RelatedHospitalList]; |
| | | //List < Account > AccountList = [select Id, PlatformCode__c, Department_Class_Label__c, Name, Management_Code__c, Is_Active__c, AgentCode_Ext__c, ParentId, Parent.ParentId from Account where Management_Code__c IN :AccountCodeList OR Parent_Management_Code__c IN :AccountCodeList OR PlatformCode__c IN :AccountCodeList OR Parent.Parent.PlatformCode__c IN :AccountCodeList]; |
| | |
| | | } |
| | | system.debug('AccountMap '+AccountMap); |
| | | System.debug('DepartmentClassMap '+DepartmentClassMap); |
| | | |
| | | |
| | | |
| | | |
| | | //客户List(更新用) |
| | | List < Account > upsertAccountList = new List < Account > (); |
| | | //联系人List(更新用) |
| | | List < Contact > upsertContactList = new List < Contact > (); |
| | | |
| | | |
| | | for (Gedata gedata: newGeDataList) { |
| | | logstr += gedata.Name; |
| | | logstr += gedata.AccountName; |
| | | logstr += gedata.DepartmentClass; |
| | | logstr += gedata.DepartmentName; |
| | | |
| | | |
| | | string comefrom = gedata.RegSource == '1' ? '智慧医疗' : '服务客户端'; //平台来源 |
| | | |
| | | |
| | | |
| | | string comefrom = gedata.RegSource == '1' ? '智慧医疗' : (gedata.RegSource == '2' ? '服务客户端' :'医拓网'); //平台来源 |
| | | |
| | | //新建医院 |
| | | Account hp = new Account(); |
| | | |
| | | |
| | | //新建联系人 |
| | | Contact ct = new Contact(); |
| | | ct.LastName = gedata.Name; |
| | | ct.FirstName = ''; |
| | | ct.Type__c = gedata.Type; |
| | | ct.MobilePhone = gedata.Mobile; |
| | | ct.RegSource__c = comefrom; |
| | | ct.UnifiedI_Contact_ID__c = gedata.ContactId; //统一平台Id |
| | | ct.ServicePlatformCode__c = gedata.ServiceUserId; //服务平台用户Id |
| | | ct.Contact_address__c = gedata.ContactAddress;//联系地址 |
| | | ct.Platform_disabled_representation__c = gedata.ForbiddenStatus;//平台禁用标识 |
| | | //ct.IsFromPlatform__c = true; //来自智慧医疗创建 |
| | | ct.Ignore_Same_Name__c = true; //不是重复的客户名 |
| | | //ct.SendToComPlat__c = true; |
| | | |
| | | if(gedata.AgentFlag){ |
| | | //ct.FirstName = ''; 2022-4-7 yjk 注释掉 |
| | | ct.UnifiedI_Contact_ID__c = gedata.ContactId; //统一平台Id |
| | | ct.ServicePlatformCode__c = gedata.ServiceUserId; //服务平台用户Id |
| | | //ct.CManageCode__c = gedata.PersonManagementCode;//人员管理编码 |
| | | }else{ |
| | | ct.LastName = gedata.Name; |
| | | ct.FirstName = ''; |
| | | ct.Type__c = gedata.Type; |
| | | ct.Type_Encrypted__c = gedata.TypeEncrypted;//add for pipl sushanhu 20220316 |
| | | ct.MobilePhone = gedata.Mobile; |
| | | ct.RegSource__c = comefrom; |
| | | ct.UnifiedI_Contact_ID__c = gedata.ContactId; //统一平台Id |
| | | // //UPDATE TO AWS 存储的统一平台id |
| | | // ct.AWS_UnifiedI_Contact_ID__c=gedata.ContactId; //统一平台Id |
| | | ct.ServicePlatformCode__c = gedata.ServiceUserId; //服务平台用户Id |
| | | ct.Contact_address__c = gedata.ContactAddress;//联系地址 |
| | | ct.Contact_address_Encrypted__c=gedata.ContactAddressEncrypted;//联系地址密文 add 20220215 |
| | | ct.Platform_disabled_representation__c = gedata.ForbiddenStatus;//平台禁用标识 |
| | | //ct.IsFromPlatform__c = true; //来自智慧医疗创建 |
| | | ct.Ignore_Same_Name__c = true; //不是重复的客户名 |
| | | //ct.SendToComPlat__c = true; |
| | | ct.AWS_Data_Id__c =gedata.DataId;//add 20220215 aws存储凭证 |
| | | ct.MobilePhone_Encrypted__c =gedata.MobileEncrypted;//add 20220215 手机密文 |
| | | ct.LastName_Encrypted__c =gedata.NameEncrypted;//add 20220215 姓名密文 |
| | | } |
| | | |
| | | |
| | | String personCode = gedata.PersonManagementCode; |
| | | |
| | | |
| | | Map < String, Contact > contactMap = new Map < String, Contact > ();//用于暂存更新联系人 |
| | | //1经销商true |
| | | if (gedata.AgentFlag == true) { |
| | | //更新经销商联系人 |
| | | if (!peopleMap.containsKey(personCode)) { |
| | | rowData.Is_Error__c = 1; |
| | | logstr += 'error:人员管理编码 [PersonManagementCode] 对应的联系人不存在,此条数据跳过'; |
| | | continue; |
| | | } |
| | |
| | | if ('有效'.equals(hospital.Is_Active_Formula__c)) { |
| | | string DepartmentCode = string.isNotBlank(gedata.RelatedDepartment) ? gedata.RelatedDepartment : gedata.DepartmentManagementCode2; |
| | | string DepartmentClasskey = gedata.AccountName + ' ' + gedata.DepartmentClass; |
| | | system.debug('DepartmentClasskey------->'+DepartmentClasskey); |
| | | //科室存在 |
| | | if (AccountMap.containsKey(DepartmentCode)) { |
| | | //人员管理编码存在 |
| | |
| | | upsertContactList.add(ct); |
| | | } else { //联系人不存在 2 完成 |
| | | system.debug('2逻辑 有医院 有科室 有人员管理编码但查找无此人 动作:报错'); |
| | | rowData.Is_Error__c = 1; |
| | | logstr += 'error:人员管理编码 [PersonManagementCode] 对应的联系人不存在,此条数据跳过'; |
| | | continue; |
| | | } |
| | | } else { //人员管理编码不存在 |
| | | //搜索人名/且在当前战略科室科室下 |
| | | System.debug('人员管理编码不存在'); |
| | | string namekey = gedata.Name; |
| | | string namekey = gedata.RelatedDepartment + ' ' + gedata.NameEncrypted + ' ' + gedata.MobileEncrypted; |
| | | string namekey1 = gedata.RelatedDepartment + ' ' + gedata.NameEncrypted; |
| | | system.debug('DepartmentClasskey = '+DepartmentClasskey); |
| | | system.debug('nameMap22222222 '+nameMap); |
| | | if (nameMap.containskey(DepartmentClasskey)) { // 6 完成 更新操作 |
| | | Map < String, Contact > sMap = nameMap.get(DepartmentClasskey); |
| | | System.debug('sMap'+sMap); |
| | | System.debug('sMap.containsKey(namekey)'+sMap.containsKey(namekey)); |
| | | System.debug('sMap.containsKey(gedata.NameEncrypted)'+sMap.containsKey(gedata.NameEncrypted)); |
| | | if (sMap.containsKey(namekey)) { |
| | | system.debug('Id赋值'+sMap); |
| | | ct.id = sMap.get(namekey).id; |
| | | } else { // 7 完成 |
| | | } else if (sMap.containsKey(namekey1) && sMap.get(namekey1).UnifiedI_Contact_ID__c == null) { |
| | | ct.id = sMap.get(namekey1).id; |
| | | |
| | | // // 通过姓名+手机号判断人员是否重复 thh 20220518 start |
| | | // } else if(sMap.containsKey(gedata.NameEncrypted + gedata.MobileEncrypted) && sMap.get(gedata.NameEncrypted + gedata.MobileEncrypted).UnifiedI_Contact_ID__c == null){ |
| | | // ct.id = sMap.get(gedata.NameEncrypted + gedata.MobileEncrypted).id; |
| | | // // 通过姓名+手机号判断人员是否重复 thh 20220518 end |
| | | }else { // 7 完成 |
| | | system.debug('7逻辑 无人员管理编码 有医院 有科室 人名查找无 动作:新建联系人 '); |
| | | } |
| | | } |
| | |
| | | //upsertContactList.add(ct); |
| | | } else { //人员管理编码查找无值 4 完成 |
| | | system.debug('4逻辑'); |
| | | rowData.Is_Error__c = 1; |
| | | logstr += 'error:人员管理编码 [PersonManagementCode] 对应的联系人不存在,此条数据跳过'; |
| | | continue; |
| | | } |
| | | } else { //人员管理编码不存在 |
| | | system.debug('人员管理编码不存在'); |
| | | string namekey = gedata.DepartmentName+ ' ' + gedata.Name; |
| | | string namekey = gedata.DepartmentName + ' ' + gedata.NameEncrypted + ' ' + gedata.MobileEncrypted; |
| | | //string namekey = gedata.AccountName + ' ' + gedata.DepartmentName + ' ' + gedata.DepartmentClass + ' ' + gedata.Name; |
| | | system.debug('DepartmentClasskey'+DepartmentClasskey); |
| | | system.debug('351nameMap '+nameMap); |
| | |
| | | System.debug('人员管理编码不存在的情况下战略科室存在'); |
| | | system.debug('战略科室存在' + nameMap.get(DepartmentClasskey)); |
| | | Map < String, Contact > sMap = nameMap.get(DepartmentClasskey); |
| | | system.debug('namekey'+namekey); |
| | | system.debug('sMap.containsKey(namekey)'+sMap.containsKey(namekey)); |
| | | if (sMap.containsKey(namekey)) { //查找存在 8 完成 |
| | | system.debug('8逻辑'); |
| | | system.debug('该联系人存在'); |
| | | ct.id = sMap.get(namekey).id; |
| | | upsertAccountList.add(dpt); |
| | | //upsertAccountList.add(dpt);//可以注释 |
| | | upsertContactList.add(ct); |
| | | // if(sMap.containsKey(gedata.Name)){ |
| | | // ct.Id = sMap.get(gedata.Name).Id; |
| | | // } |
| | | }else if(sMap.containsKey(gedata.Name)){ |
| | | system.debug('1234567890'); |
| | | ct.Id = sMap.get(gedata.Name).Id; |
| | | //upsertAccountList.add(dpt); |
| | | } |
| | | // 通过姓名+手机号判断人员是否重复 thh 20220518 start |
| | | // else if(sMap.containsKey(gedata.NameEncrypted + gedata.MobileEncrypted) && sMap.get(gedata.NameEncrypted + gedata.MobileEncrypted).UnifiedI_Contact_ID__c == null){ |
| | | // system.debug('1234567890'); |
| | | // ct.Id = sMap.get(gedata.NameEncrypted + gedata.MobileEncrypted).Id; |
| | | // //upsertAccountList.add(dpt); |
| | | // upsertContactList.add(ct); |
| | | // } |
| | | // 通过姓名+手机号判断人员是否重复 thh 20220518 end |
| | | system.debug('contactMap ' + contactMap); |
| | | System.debug('9逻辑'); |
| | | contactMap.put(Gedata.DepartmentManagementCode2, ct); |
| | | system.debug('contactMap ' + contactMap); |
| | | //upsertContactList.add(ct); |
| | | } |
| | | system.debug('创建联系人和科室'); |
| | | dpt.Department_Name__c = gedata.DepartmentName; |
| | |
| | | } |
| | | } |
| | | }else if('无效'.equals(hospital.Is_Active_Formula__c)){ |
| | | rowData.Is_Error__c = 1; |
| | | logstr += 'error:该医院无效,此条数据跳过'; |
| | | continue; |
| | | }else{ |
| | |
| | | StaticParameter.EscapeNFM001AgencyContractTrigger2 = true; |
| | | system.debug('upsertAccountList ' + upsertAccountList); |
| | | upsert upsertAccountList; |
| | | system.debug('SFDCCodeList'+SFDCCodeList); |
| | | system.debug('SFDCCodeList'+ManagementList); |
| | | List < Account > List1 = [select Id,RecordTypeId,Is_Active__c,PlatformCode__c,OCM_man_province_HP__c,OwnerId from Account where PlatformCode__c In: SFDCCodeList OR PlatformCode__c IN: ManagementList];//客户所有人修改11.18 11.35 未完成 |
| | | system.debug('List1'+List1); |
| | | List<Account> updateHPList = new List<Account>(); |
| | | for (Account ac: List1) { |
| | | Contact c = new contact(); |
| | | system.debug('ac.PlatformCode__c'+ac.PlatformCode__c); |
| | | system.debug('ContactMap'+ContactMap); |
| | | system.debug('ContactMap.containsKey(ac.PlatformCode__c)'+ContactMap.containsKey(ac.PlatformCode__c)); |
| | | if(ContactMap.containsKey(ac.PlatformCode__c)){ |
| | | c = contactMap.get(ac.PlatformCode__c); |
| | | if(string.isblank(c.Id)|| c.AccountId != ac.Id){ |
| | |
| | | system.debug('OwnerId'+ac.OwnerId); |
| | | system.debug('upsertContactList'+upsertContactList); |
| | | } |
| | | |
| | | |
| | | if(ac.RecordTypeId == '01210000000QemGAAS' && ac.Is_Active__c == '草案中' && string.isNotBlank( OCSMMap.get(ac.OCM_man_province_HP__c))){ |
| | | ac.OwnerId = OCSMMap.get(ac.OCM_man_province_HP__c); |
| | | updateHPList.add(ac); |
| | |
| | | //2022/2/10 修改 在新建联系人之后手动执行NFM620RestBatch NFM623RestBatch |
| | | // Database.executeBatch(new NFM620RestBatch(), 1); |
| | | // Database.executeBatch(new NFM623RestBatch(), 1); |
| | | // supplement(gedata.ContactId); |
| | | supplement(gedata.ContactId); |
| | | } |
| | | } |
| | | } |
| | |
| | | } |
| | | update iflog; |
| | | } |
| | | |
| | | |
| | | private static String verify(GeData gda) { |
| | | String result = ''; |
| | | if (string.isblank(gda.ContactId)) { |
| | | result += 'DataError: ContactId 统一平台ID为空\n'; |
| | | } |
| | | if (gda.AgentFlag == null) { |
| | | result += 'DataError:经销商标识为空\n'; |
| | | } |
| | | if (string.isblank(gda.Name)) { |
| | | result += 'DataError:姓名为空\n'; |
| | | } |
| | | if (string.isblank(gda.Mobile)) { |
| | | result += 'DataError:手机号为空\n'; |
| | | } |
| | | if (string.isblank(gda.RegSource)) { |
| | | result += 'DataError:注册平台来源为空\n'; |
| | | } |
| | | if (gda.AgentFlag) { |
| | | if (string.isblank(gda.ContactId)) { |
| | | result += 'DataError: ContactId 统一平台ID为空\n'; |
| | | } |
| | | if (string.isblank(gda.PersonManagementCode)) { |
| | | result += 'DataError:PersonManagementCode 人员管理编码为空\n'; |
| | | } |
| | | } else { |
| | | // if (string.isnotblank(gda.PersonManagementCode) && string.isBlank(gda.RelatedHospital)) { |
| | | // result += 'DataError: 关联医院编码为空\n'; |
| | | // } |
| | | if(string.isBlank(gda.RelatedDepartment) && String.isBlank(gda.ApproverID)){ |
| | | result += 'DataError: 在关联SFDC科室[RelatedDepartment]为空时,审核人员员工编码[ApproverID]必填\n'; |
| | | if (string.isblank(gda.ServiceUserId)) { |
| | | result += 'ServiceUserId 服务平台用户Id为空\n'; |
| | | } |
| | | }else{ |
| | | if (string.isblank(gda.ContactId)) { |
| | | result += 'DataError: ContactId 统一平台ID为空\n'; |
| | | } |
| | | if (gda.AgentFlag == null) { |
| | | result += 'DataError:经销商标识为空\n'; |
| | | } |
| | | if (string.isblank(gda.Name)) { |
| | | result += 'DataError:姓名为空\n'; |
| | | } |
| | | if (string.isblank(gda.Mobile)) { |
| | | result += 'DataError:手机号为空\n'; |
| | | } |
| | | if (string.isblank(gda.RegSource)) { |
| | | result += 'DataError:注册平台来源为空\n'; |
| | | } |
| | | if(string.isBlank(gda.RelatedHospital) && String.isBlank(gda.HospitalManagementCode2) && String.isBlank(gda.ApproverID)){ |
| | | result += 'DataError: 新建医院时,审核人员员工编码[ApproverID]必填\n'; |
| | | } |
| | | if (string.isblank(gda.HospitalManagementCode2)) { |
| | | result += 'DataError:医院平台编码为空\n'; |
| | |
| | | } |
| | | return result; |
| | | } |
| | | // global static String contactAllName(String contactName){ |
| | | // // 中国 复姓大全 |
| | | // String CompoundSurname = '濮阳、公冶、太叔、申屠、公孙、慕容、仲孙、钟离、长孙、宇文、司徒、鲜于、司空、闾丘、子车、亓官、司寇、巫马、公西、颛孙、壤驷、公良、漆雕、乐正、宰父、谷梁、拓跋、夹谷、轩辕、令狐、段干、百里、呼延、东郭、南门、羊舌、微生、公户、公玉、公仪、梁丘、公仲、公上、公门、公山、公坚、左丘、公伯、西门、公祖、第五、公乘、贯丘、公皙、南荣、东里、东宫、仲长、子书、子桑、即墨、达奚、褚师、吴铭'; |
| | | // // string allname = '朱启贤'; |
| | | // // contactName = '第五惆怅'; |
| | | // String lastName = ''; |
| | | // String firstName = ''; |
| | | // String result = ''; |
| | | // if (contactName.contains('·')) { |
| | | // lastName = contactName.split('·')[0]; |
| | | // firstName = contactName.split('·')[1]; |
| | | // } else { |
| | | // if (contactName.length() > 2) { |
| | | |
| | | // system.debug('CompoundSurname--->01' + contactName.subString(0, 2)); |
| | | // if (CompoundSurname.contains(contactName.subString(0, 2))) { |
| | | // lastName = contactName.substring(0,2); |
| | | // firstName = contactName.substring(2,contactName.length()); |
| | | // system.debug('lastName--->'+lastName); |
| | | // system.debug('firstName--->'+firstName); |
| | | // } else { |
| | | // lastName = contactName.substring(0,1); |
| | | // firstName = contactName.substring(1,contactName.length()); |
| | | // system.debug('lastName--->'+lastName); |
| | | // system.debug('firstName--->'+firstName); |
| | | // } |
| | | // } else { |
| | | // if (contactName.length() == 2) { |
| | | // lastName = contactName.substring(0,1); |
| | | // firstName = contactName.substring(1,contactName.length()); |
| | | // system.debug('lastName--->'+lastName); |
| | | // system.debug('firstName--->'+firstName); |
| | | // } else { |
| | | // lastName = contactName; |
| | | // firstName = contactName; |
| | | // system.debug('lastName--->'+lastName); |
| | | // system.debug('firstName--->'+firstName); |
| | | // } |
| | | // } |
| | | // } |
| | | // if (!contactName.equals(lastName+firstName)) { |
| | | // lastName = contactName; |
| | | // firstName = contactName; |
| | | // } |
| | | // result = lastName + '_' + firstName; |
| | | // //system.debug('CompoundSurname--->02' + CompoundSurname); |
| | | // return result; |
| | | // } |
| | | |
| | | |
| | | private static void supplement (String ContactId){ |
| | | //把620Batch 和 623Batch 搬过来 |
| | | //补充询问单部分 start |
| | | //更新用 |
| | | List<CampaignMember__c> campaignMemberList = new List<CampaignMember__c>(); |
| | | List<Inquiry_form__c> inquiryFormList = new List<Inquiry_form__c>(); |
| | | //根据统一用户Id查询询问单 |
| | | List<Inquiry_form__c> InquiryList = [select Id,Inquiry_No__c,ContactId__c,Hospital_Name__c,Department_Class__c,Contact_Name__c from Inquiry_form__c where ContactId__c = :ContactId]; |
| | |
| | | //根据统一用户Id查询联系人 |
| | | List<Contact> contactList = [select Id,Name,UnifiedI_Contact_ID__c,Account.Id,Strategic_dept_Class__c,AccountId,Account.Name,Strategic_dept_Class__r.OwnerId from Contact where UnifiedI_Contact_ID__c = :ContactId]; |
| | | system.debug('contactList' + contactList); |
| | | //统一用户ID存入List、询问单ID存Map |
| | | Map<String, String> inquiryMap = new Map<String, String>(); |
| | | //List<String> contactIdList = new List<String>(); |
| | | for (Inquiry_form__c inquiryInfo : inquiryList) { |
| | | //contactIdList.add(inquiryInfo.ContactId__c); |
| | | inquiryMap.put(inquiryInfo.ContactId__c, inquiryInfo.Id); |
| | | } |
| | | if (contactList.size() >0 ) { |
| | | for (Contact contactInfo : contactList) { |
| | | Inquiry_form__c inquiry = new Inquiry_form__c(); |
| | | inquiry.Id = inquiryMap.get(contactInfo.UnifiedI_Contact_ID__c); //ID |
| | | inquiry.Hospital_Name__c = contactInfo.Account.Id; //科室名 |
| | | inquiry.Department_Class__c = contactInfo.Strategic_dept_Class__c; //战略科室分类 |
| | | inquiry.Contact_Name__c = contactInfo.Id; //客户姓名 |
| | | inquiry.OwnerId = contactInfo.Strategic_dept_Class__r.OwnerId; //所有人 |
| | | inquiryFormList.add(inquiry); |
| | | |
| | | if(InquiryList.size()>0){ |
| | | //统一用户ID存入List、询问单ID存Map |
| | | Map<String, String> inquiryMap = new Map<String, String>(); |
| | | //List<String> contactIdList = new List<String>(); |
| | | for (Inquiry_form__c inquiryInfo : inquiryList) { |
| | | //contactIdList.add(inquiryInfo.ContactId__c); |
| | | // map的k-v改造 thh 20220517 start |
| | | inquiryMap.put(inquiryInfo.Id, inquiryInfo.ContactId__c); |
| | | // map的k-v改造 thh 20220517 end |
| | | } |
| | | } |
| | | if(inquiryFormList.size()>0){ |
| | | update inquiryFormList; |
| | | // map的k-v改造 thh 20220517 start |
| | | if (contactList.size() >0 && inquiryMap.size() > 0) { |
| | | for(String Id : inquiryMap.keySet()){ |
| | | Inquiry_form__c inquiry = new Inquiry_form__c(); |
| | | for (Contact contactInfo : contactList) { |
| | | if(inquiryMap.get(Id) == contactInfo.UnifiedI_Contact_ID__c){ |
| | | inquiry.Id = Id; //ID |
| | | inquiry.Hospital_Name__c = contactInfo.Account.Id; //科室名 |
| | | inquiry.Department_Class__c = contactInfo.Strategic_dept_Class__c; //战略科室分类 |
| | | inquiry.Contact_Name__c = contactInfo.Id; //客户姓名 |
| | | inquiry.OwnerId = contactInfo.Strategic_dept_Class__r.OwnerId; //所有人 |
| | | inquiryFormList.add(inquiry); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | // map的k-v改造 thh 20220517 end |
| | | system.debug('inquiryFormList=========>'+inquiryFormList); |
| | | if(inquiryFormList.size()>0){ |
| | | update inquiryFormList; |
| | | } |
| | | } |
| | | //补充询问单部分 end |
| | | |
| | | //补充学会部分 start |
| | | List<CampaignMember__c> campaignMemberList = new List<CampaignMember__c>(); |
| | | //List<CampaignMember__c> campaignMemberList = new List<CampaignMember__c>(); |
| | | List<CampaignMember__c> capMemList = [select Id,Contact_ID__c,Campaign__c,Campaign__r.Num__c,ViewContactId__c from CampaignMember__c where Contact_ID__c = :ContactId]; |
| | | Map<String, String> capMemMap = new Map<String, String>(); |
| | | //统一用户ID存入List,参会人员记录ID存入MAP |
| | | //List<String> contactIdList = new List<String>(); |
| | | for (CampaignMember__c capMemInfo : capMemList) { |
| | | //contactIdList.add(capMemInfo.ViewContactId__c); |
| | | capMemMap.put(capMemInfo.ViewContactId__c,capMemInfo.Id); |
| | | } |
| | | //List<Contact> contactList = [select Id,Name,UnifiedI_Contact_ID__c,Account.Id,Strategic_dept_Class__c,AccountId,Account.Name,Strategic_dept_Class__r.OwnerId,Id from Contact where UnifiedI_Contact_ID__c = ContactId]; |
| | | if (contactList.size() > 0) { |
| | | for (Contact contactInfo : contactList) { |
| | | CampaignMember__c camMemberInfo = new CampaignMember__c(); |
| | | camMemberInfo.Id = capMemMap.get(contactInfo.UnifiedI_Contact_ID__c); |
| | | camMemberInfo.Contact_ID__c = contactInfo.ID; //参会人员ID |
| | | camMemberInfo.Department_ID__c = contactInfo.AccountId; //医院科室 |
| | | camMemberInfo.Department__c = contactInfo.Account.Name; //医院科室(文本) |
| | | camMemberInfo.Contact__c = contactInfo.Name; //客户人员姓名 |
| | | campaignMemberList.add(camMemberInfo); |
| | | if(capMemList.size() > 0){ |
| | | system.debug('capMemList=================>'+capMemList); |
| | | Map<String, String> capMemMap = new Map<String, String>(); |
| | | //统一用户ID存入List,参会人员记录ID存入MAP |
| | | //List<String> contactIdList = new List<String>(); |
| | | for (CampaignMember__c capMemInfo : capMemList) { |
| | | //contactIdList.add(capMemInfo.ViewContactId__c); |
| | | capMemMap.put(capMemInfo.ViewContactId__c,capMemInfo.Id); |
| | | } |
| | | |
| | | } |
| | | if (campaignMemberList.size() > 0) { |
| | | update campaignMemberList; |
| | | system.debug('capMemMap======>'+capMemMap); |
| | | //List<Contact> contactList = [select Id,Name,UnifiedI_Contact_ID__c,Account.Id,Strategic_dept_Class__c,AccountId,Account.Name,Strategic_dept_Class__r.OwnerId,Id from Contact where UnifiedI_Contact_ID__c = ContactId]; |
| | | if (contactList.size() > 0) { |
| | | for (Contact contactInfo : contactList) { |
| | | CampaignMember__c camMemberInfo = new CampaignMember__c(); |
| | | camMemberInfo.Id = capMemMap.get(contactInfo.UnifiedI_Contact_ID__c); |
| | | camMemberInfo.Contact_ID__c = contactInfo.Id; //参会人员ID |
| | | camMemberInfo.Department_ID__c = contactInfo.AccountId; //医院科室 |
| | | camMemberInfo.Department__c = contactInfo.Account.Name; //医院科室(文本) |
| | | camMemberInfo.Contact__c = contactInfo.Name; //客户人员姓名 |
| | | campaignMemberList.add(camMemberInfo); |
| | | } |
| | | } |
| | | system.debug('campaignMemberList================>'+campaignMemberList); |
| | | if (campaignMemberList.size() > 0) { |
| | | System.debug('--------1-------'); |
| | | update campaignMemberList; |
| | | } |
| | | } |
| | | //补充学会部分 end |
| | | } |