~liucheng/OlyMEBG.git

			@@ -7,7 +7,7 @@

			}
			*************************************************************************/


			@RestResource(urlMapping = '/NFM624/*')
			global with sharing class NFM624Rest {
			//add to AWS 回复 start sushanhu 20220225
			@@ -18,12 +18,12 @@
			// global class GeDatasRest {
			// public GeDatas GeDatas;
			// }


			global class GeDatas {
			public NFMUtil.Monitoring Monitoring;
			public GeData[] GeData;
			}


			global class GeData {
			public String ContactId; //统一平台ID//Update to aws 存储的AWSContactId 20220225 SUSHANHU
			public String ServiceUserId; //服务平台用户ID
			@@ -51,31 +51,31 @@
			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');
			@@ -92,16 +92,16 @@
			//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('','')
			Map < string, string > RecordTypeMap = new Map < string, string > (); //存放记录类型Id
			@@ -122,7 +122,7 @@
			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) {
			@@ -136,7 +136,7 @@
			// continue;
			// }
			// }


			Savepoint sp = Database.setSavepoint();
			List<string> ApproverIDList = new List <string>();//
			List < string > PersonManagementCodeList = new List < String > (); //人员管理编码List
			@@ -190,28 +190,27 @@
			for (Address_Level__c temp: statetempList) {
			StateMap.put(temp.Name, temp.Id);
			}
			system.debug('StateMap----->'+StateMap);
			//查询市区Id
			Map < String, String > CityMap = new Map < String, String > (); //市Map
			List < Address_Level2__c > citytempList = [select Id, Name from Address_Level2__c where Name IN: CityList];
			for (Address_Level2__c temp: citytempList) {
			CityMap.put(temp.Name, temp.Id);
			}
			system.debug('CityMap----->'+CityMap);

			//查询医院所有人
			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,
			@@ -221,15 +220,13 @@
			Account.PlatformCode__c,
			Account.Management_Code__c,
			Account.parent.Department_Class_Label__c,
			Name,LastName_Encrypted__c,
			Name,
			Account.Parent_Management_Code__c,
			Account.Parent_PlatformCode__c,
			CManageCode__c,
			CManageCode__c,
			AccountId
			from Contact
			where CManageCode__c IN: PersonManagementCodeList
			OR Account.PlatformCode__c IN: ManagementList
			OR Account.Management_Code__c IN: SFDCCodeList
			OR Account.Parent_PlatformCode__c IN: ManagementList
			OR Account.Parent_Management_Code__c IN: SFDCCodeList]; //根据人员管理编码检索联系人
			Map < String, Contact > peopleMap = new Map < String, Contact > (); //联系人
			@@ -238,21 +235,22 @@
			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 + ' ' + ct.LastName_Encrypted__c;
			string namekey = ct.Account.Name + ' ' + Name;
			// 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.LastName_Encrypted__c, ct);
			snameMap.put(ct.Name, ct);
			nameMap.put(ct.Account.parent.Name, snameMap);
			}
			peopleMap.put(ct.CManageCode__c, ct);
			System.debug('peopleMap'+peopleMap);
			// peopleMap.put(ct.Name, ct);
			//string temp = ct.Name + ct.Account.parent.Department_Class_Label__c;
			// peopleMap.put(temp, ct);
			}
			System.debug('peopleMap'+peopleMap);

			//查询医院科室
			//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];
			@@ -263,16 +261,12 @@
			OCM_man_province_HP__c,
			Name, Management_Code__c,
			Is_Active__c, AgentCode_Ext__c,
			RelatedMessageGroupNumber__c,
			ParentId,
			Parent.ParentId,
			OwnerId
			from Account
			where Parent_PlatformCode__c IN: ManagementList
			OR Parent_Management_Code__c IN: SFDCCodeList
			OR PlatformCode__c IN: ManagementList
			OR Management_Code__c IN: SFDCCodeList
			OR (State_Master__c IN:StateMap.Values() AND City_Master__c IN:CityMap.Values())];
			OR Parent_Management_Code__c IN: SFDCCodeList];
			Map <String,Account> DepartmentClassMap = new Map <String,Account>();//战略科室Map
			Map < String, Account > AccountMap = new Map < String, Account > (); //医院科室
			for (Account ac: AccountList) {
			@@ -283,31 +277,28 @@
			if (string.isNotBlank(ac.PlatformCode__c)) {
			AccountMap.put(ac.PlatformCode__c, ac);
			}
			if(string.isNotBlank(ac.Name) && ac.ParentId == null && ac.Parent.ParentId == null){
			AccountMap.put(ac.name,ac);
			}
			}
			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' ? '智慧医疗' : '服务客户端'; //平台来源


			//新建医院
			Account hp = new Account();


			//新建联系人
			Contact ct = new Contact();
			ct.LastName = gedata.Name;
			@@ -329,9 +320,9 @@
			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) {
			@@ -354,14 +345,14 @@
			dpt.Hospital__c = hospital.Id;

			//判断医院是否有效
			if ('有效'.equals(hospital.Is_Active_Formula__c) \|\| '无效'.equals(hospital.Is_Active_Formula__c)) {
			if ('有效'.equals(hospital.Is_Active_Formula__c)) {
			string DepartmentCode = string.isNotBlank(gedata.RelatedDepartment) ? gedata.RelatedDepartment : gedata.DepartmentManagementCode2;
			string DepartmentClasskey = gedata.AccountName + ' ' + gedata.DepartmentClass;
			//科室存在
			if (AccountMap.containsKey(DepartmentCode)) {
			//人员管理编码存在
			ct.AccountId = AccountMap.get(DepartmentCode).id;//科室确定，将联系人挂在该科室下
			ct.OwnerId = AccountMap.get(DepartmentCode).OwnerId;//科室确定，将将联系人所有人的值赋为科室所有人
			ct.OwnerId = AccountMap.get(DepartmentCode).OwnerId;//可是确定，将将联系人所有人的值赋为科室所有人
			system.debug('personCode' + personCode);
			if (string.isnotblank(personCode)) {
			system.debug('人员管理编码存在');
			@@ -378,8 +369,7 @@
			} else { //人员管理编码不存在
			//搜索人名/且在当前战略科室科室下
			System.debug('人员管理编码不存在');
			string namekey = gedata.NameEncrypted;
			system.debug('namekey----->'+namekey);
			string namekey = gedata.Name;
			system.debug('DepartmentClasskey = '+DepartmentClasskey);
			system.debug('nameMap22222222 '+nameMap);
			if (nameMap.containskey(DepartmentClasskey)) { // 6 完成更新操作
			@@ -450,141 +440,29 @@
			contactMap.put(Gedata.DepartmentManagementCode2, ct);
			}
			}
			}else if('无效'.equals(hospital.Is_Active_Formula__c)){
			logstr += 'error:该医院无效，此条数据跳过';
			continue;
			}else{
			logstr += '该医院处于草案中/申请中，请等待审批完成';
			//状态------>草案中/申请中------->等待，plan1:把医院Id写到日志表上（后续检索根据医院id检索未处理过的日志）,plan2:把MessageGroupNumber存到医院上
			logstr += '该医院处于草案中，请等待审批完成';
			rowData.NFM624_Secondary_processing__c = false;
			continue;
			}
			} else { //医院不存在则需要增加判断根据名判重
			if(accountMap.containskey(gedata.AccountName)){//如果根据名字判断有重复则数据新建指向这个医院
			Account dpt = new Account();
			Account hospital = AccountMap.get(gedata.AccountName);
			dpt.PlatformCode__c = gedata.DepartmentManagementCode2;
			dpt.Hospital__c = hospital.Id;
			//医院存在↓取状态,有效无效都新建
			if ('有效'.equals(hospital.Is_Active_Formula__c) \|\| '无效'.equals(hospital.Is_Active_Formula__c)) {
			string DepartmentCode = string.isNotBlank(gedata.RelatedDepartment) ? gedata.RelatedDepartment : gedata.DepartmentManagementCode2;
			string DepartmentClasskey = gedata.AccountName + ' ' + gedata.DepartmentClass;
			//科室存在
			if (AccountMap.containsKey(DepartmentCode)) {//因为SOQL没有检索到科室所以没有判定为没有科室
			//人员管理编码存在
			ct.AccountId = AccountMap.get(DepartmentCode).id;//科室确定，将联系人挂在该科室下
			ct.OwnerId = AccountMap.get(DepartmentCode).OwnerId;//可是确定，将将联系人所有人的值赋为科室所有人
			system.debug('personCode' + personCode);
			if (string.isnotblank(personCode)) {
			system.debug('人员管理编码存在');
			//联系人存在 11 医院名字排重存在，科室存在，更新联系人，完成
			if (peopleMap.containsKey(personCode)) {
			system.debug('11逻辑名字查重医院有科室有人员管理编码且查找有此人动作：更新');
			ct.Id = peopleMap.get(personCode).Id;
			upsertContactList.add(ct);
			} else { //联系人不存在 12 完成
			system.debug('12逻辑名字查重医院有科室有人员管理编码但查找无此人动作：报错');
			logstr += 'error:人员管理编码 [PersonManagementCode] 对应的联系人不存在，此条数据跳过';
			continue;
			}
			} else { //人员管理编码不存在
			//搜索人名/且在当前战略科室科室下
			System.debug('人员管理编码不存在');
			string namekey = gedata.NameEncrypted;
			system.debug('DepartmentClasskey = '+DepartmentClasskey);
			system.debug('nameMap22222222 '+nameMap);
			system.debug('nameMap.containskey(DepartmentClasskey)'+nameMap.containskey(DepartmentClasskey));
			if (nameMap.containskey(DepartmentClasskey)) { // 16 完成更新操作
			Map < String, Contact > sMap = nameMap.get(DepartmentClasskey);
			if (sMap.containsKey(namekey)) {
			system.debug('Id赋值'+sMap);
			ct.id = sMap.get(namekey).id;
			system.debug('16逻辑无人员管理编码医院查重存在有科室人名查找有动作：更新联系人 ');
			} else { // 17 完成
			system.debug('17逻辑无人员管理编码医院查重存在有科室人名查找无动作：新建联系人 ');
			}
			}
			upsertContactList.add(ct);
			}
			dpt.Id = AccountMap.get(DepartmentCode).Id;
			upsertAccountList.add(dpt);
			} else { //科室不存在
			//为科室赋值
			dpt.Name = gedata.DepartmentName;
			dpt.RecordTypeId = RecordTypeMap.get(gedata.DepartmentClass);
			//因为没有医院管理编码，无法检索到战略科室，所以在给科室的战略科室字段赋值时空指针
			dpt.Department_Class__c = DepartmentClassMap.get(gedata.DepartmentClass).Id;
			dpt.ParentId = DepartmentClassMap.get(gedata.DepartmentClass).Id;
			if (string.isnotblank(personCode)) { //人员管理编码存在
			if (peopleMap.containsKey(personCode)) { //人员管理编码查找有值 13 完成
			System.debug('13逻辑');
			//新建科室+新建联系人,
			ct.id = peopleMap.get(personCode).id;
			contactMap.put(Gedata.DepartmentManagementCode2, ct);
			system.debug('contactMap ' + contactMap);
			dpt.Department_Name__c = gedata.DepartmentName;
			upsertAccountList.add(dpt);
			//upsertContactList.add(ct);
			} else { //人员管理编码查找无值 14 完成
			system.debug('14逻辑');
			logstr += 'error:人员管理编码 [PersonManagementCode] 对应的联系人不存在，此条数据跳过';
			continue;
			}
			} else { //人员管理编码不存在
			system.debug('人员管理编码不存在');
			string namekey = gedata.DepartmentName+ ' ' + gedata.Name;
			//string namekey = gedata.AccountName + ' ' + gedata.DepartmentName + ' ' + gedata.DepartmentClass + ' ' + gedata.Name;
			system.debug('DepartmentClasskey'+DepartmentClasskey);
			system.debug('351nameMap '+nameMap);
			if (nameMap.containsKey(DepartmentClasskey)) { //查找是否存在该战略科室
			System.debug('人员管理编码不存在的情况下战略科室存在');
			system.debug('战略科室存在' + nameMap.get(DepartmentClasskey));
			Map < String, Contact > sMap = nameMap.get(DepartmentClasskey);
			if (sMap.containsKey(namekey)) { //查找存在 18 完成
			system.debug('18逻辑');
			system.debug('该联系人存在');
			ct.id = sMap.get(namekey).id;
			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);
			}
			system.debug('contactMap ' + contactMap);
			System.debug('19逻辑');
			contactMap.put(Gedata.DepartmentManagementCode2, ct);
			}
			system.debug('创建联系人和科室');
			dpt.Department_Name__c = gedata.DepartmentName;
			upsertAccountList.add(dpt);
			contactMap.put(Gedata.DepartmentManagementCode2, ct);
			}
			}
			}else{
			logstr += '该医院处于草案中/申请中，请等待审批完成';
			//状态------>草案中/申请中------->等待，plan1:把医院Id写到日志表上（后续检索根据医院id检索未处理过的日志）,plan2:把MessageGroupNumber存到医院上
			hospital.RelatedMessageGroupNumber__c += iflog.MessageGroupNumber__c + ';';
			rowData.NFM624_Secondary_processing__c = false;
			upsertAccountList.add(hospital);
			}
			}else{
			//↓新建医院
			system.debug('新建医院逻辑5逻辑10逻辑15逻辑20 无论人员管理编码是否有值都需要新建医院');
			hp.Name = gedata.AccountName; //医院名赋值
			if(ownerMap.containsKey(gedata.ApproverID)){
			hp.OwnerId = ownerMap.get(gedata.ApproverID);//审核人员员工编码赋值给用户所有人
			}
			hp.RecordTypeId = '01210000000QemG';
			hp.OCM_Category__c = 'L';
			hp.PlatformCode__c = gedata.HospitalManagementCode2;
			hp.State_Master__c = StateMap.get(gedata.State); // 省
			hp.City_Master__c = CityMap.get(gedata.City); // 市
			hp.Hospital_Source__c = '智慧医疗';
			upsertAccountList.add(hp);
			System.debug('upsertAccountList'+upsertAccountList);
			rowData.NFM624_Secondary_processing__c = false;//数据需要二次处理标记
			} else { //医院不存在
			system.debug('新建医院逻辑5逻辑10 无论人员管理编码是否有值都需要新建医院');
			hp.Name = gedata.AccountName; //医院名赋值
			if(ownerMap.containsKey(gedata.ApproverID)){
			hp.OwnerId = ownerMap.get(gedata.ApproverID);//审核人员员工编码赋值给用户所有人
			}
			hp.RecordTypeId = '01210000000QemG';
			hp.OCM_Category__c = 'L';
			hp.PlatformCode__c = gedata.HospitalManagementCode2;
			hp.State_Master__c = StateMap.get(gedata.State); // 省
			hp.City_Master__c = CityMap.get(gedata.City); // 市
			hp.Hospital_Source__c = '智慧医疗';
			upsertAccountList.add(hp);
			System.debug('upsertAccountList'+upsertAccountList);
			rowData.NFM624_Secondary_processing__c = false;//数据需要二次处理标记
			}
			}
			system.debug('upsertContactList ' + upsertContactList);
			@@ -608,7 +486,7 @@
			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);
			@@ -660,7 +538,7 @@
			}
			update iflog;
			}


			private static String verify(GeData gda) {
			String result = '';
			if (string.isblank(gda.ContactId)) {
			@@ -734,7 +612,7 @@
			//根据统一用户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);


			if(InquiryList.size()>0){
			//统一用户ID存入List、询问单ID存Map
			Map<String, String> inquiryMap = new Map<String, String>();
			@@ -794,29 +672,3 @@
			}
			//补充学会部分 end
			}
			//前置条件，医院管理编码不存在的时候执行这个操作
			// private static Account duplicate_removal (Map<String,ACcount> accountNameMap,Gedate ged,BatchIF_Log__c iflog){//医院名Map,接口数据，日志表
			// //查询医院是新增条件OR （省 = 传入省 AND 市 = 传入市），增加一个一名字为key的map，根据传入数据的名字判断是否存在
			// //不存在———>新建
			// //存在——>取状态
			// //状态------>草案中/申请中------->等待，plan1:把医院Id写到日志表上（后续检索根据医院id检索未处理过的日志）,plan2:把MessageGroupNumber存到医院上
			// //状态------>有效，数据新建到该医院下,发送联系人信息
			// //状态------>无效，数据新建到该医院下,先发送联系人信息，再发送医院信息
			// if(accountNameMap.containskey(ged.AccountName)){//根据医院名判断医院是否存在
			// //医院存在
			// Account tempHp = accountNameMap.get(ged.AccountName);
			// if('草案中'.equals(tempHp.Is_Active_Formula__c) \|\| '申请中'.equals(tempHp.Is_Active_Formula__c)){//判断医院状态
			// //草案中/申请中状态
			// tempHp.RelatedMessageGroupNumber__c += iflog.MessageGroupNumber__c + ';';
			// //continue;
			// return tempHp;
			// }else{

			// }
			// }else{
			// //医院不存在

			// return hp;
			// }
			// }
			}