blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
彭锟
2022-03-24 87dbb4ae09e5e16ff2e39199f2617f4847420ad7 
 force-app/main/default/classes/NFM624Rest.cls


@@ -7,27 +7,33 @@


        


    }


*************************************************************************/




 


@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;


    // }




 


    global class 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; //医院名


@@ -36,55 +42,66 @@


        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('','')


        Map < string, string > RecordTypeMap = new Map < string, string > (); //存放记录类型Id 


@@ -105,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) {


@@ -119,7 +136,7 @@


        //         continue;


        //     }


        // }




 


        Savepoint sp = Database.setSavepoint();


        List<string> ApproverIDList = new List <string>();//


        List < string > PersonManagementCodeList = new List < String > (); //人员管理编码List


@@ -130,7 +147,11 @@


        try { //根据传过来的管理编码查询如果可以查询得到结果则更新，查询不到则新增


            List < Gedata > newGeDataList = new List < Gedata > ();


            for (Gedata gedata: GeDataList) {


                string dataComplete = verify(gedata);


                //for test


                gedata.AgentFlag=false;


                // string dataComplete = verify(gedata);


                string dataComplete =null;


                // test  end  for pi


                if (!String.isBlank(dataComplete)) {


                    logstr += dataComplete;


                    rowData.Is_Error__c = 1;


@@ -140,8 +161,12 @@


                    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);


@@ -171,21 +196,21 @@


                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, 


@@ -225,7 +250,7 @@


                    //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];


@@ -255,42 +280,49 @@


                }


                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;


                    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) {


@@ -454,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);


@@ -506,7 +538,7 @@


        }


        update iflog;


    }




 


    private static String verify(GeData gda) {


        String result = '';


        if (string.isblank(gda.ContactId)) {


@@ -518,11 +550,19 @@


        if (string.isblank(gda.Name)) {


            result += 'DataError：姓名为空\n';


        }


        if (string.isblank(gda.NameEncrypted)) {


            result += 'DataError：姓名密文为空\n';


        }


        if (string.isblank(gda.Mobile)) {


            result += 'DataError：手机号为空\n';


        }


        if (string.isblank(gda.MobileEncrypted)) {


            result += 'DataError：手机号密文为空\n';


        }


        if (string.isblank(gda.RegSource)) {


            result += 'DataError：注册平台来源为空\n';


        }if (string.isblank(gda.DataId)) {


            result += 'DataError：AWS加密凭据为空\n';


        }


        if (gda.AgentFlag) {


            if (string.isblank(gda.PersonManagementCode)) {


@@ -559,55 +599,7 @@


        }


        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


@@ -618,12 +610,11 @@


        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];


        system.debug('InquiryList'+InquiryList);


        //根据统一用户Id查询联系人


        //select Id,Name,UnifiedI_Contact_ID__c,AccountId,Account.Name from Contact


        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);  


        


        system.debug('contactList' + contactList);


 


        if(InquiryList.size()>0){


             //统一用户ID存入List、询问单ID存Map


            //统一用户ID存入List、询问单ID存Map


            Map<String, String> inquiryMap = new Map<String, String>();


            //List<String> contactIdList = new List<String>();


            for (Inquiry_form__c inquiryInfo : inquiryList) {


@@ -649,7 +640,8 @@


        //补充询问单部分 end


        


        //补充学会部分 start


        List<CampaignMember__c> capMemList = [select Id,Contact_ID__c,Campaign__c,Campaign__r.Num__c,ViewContactId__c from CampaignMember__c where ViewContactId__c = :ContactId];


        //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];


        if(capMemList.size() > 0){


            system.debug('capMemList=================>'+capMemList);


            Map<String, String> capMemMap = new Map<String, String>(); 


@@ -680,4 +672,3 @@


        }


        //补充学会部分 end


    }


}