本地提交备份

沙世明

2022-09-13 bfca7a84bec815da594f1d12558535ed06d2490b

 force-app/main/default/classes/ConsumApplyTriggerHandler.cls

@@ -59,6 +59,7 @@
        // Check本部是否可以选择
        // checkbenbu();
        setRental_Apply_Consum_ApplyId();
        decryptInsert(newList);//Dennis updated for pi 
    }
    protected override void beforeUpdate() {
        checkOneConsumApplyForQIS();
@@ -558,6 +559,117 @@
            update raess;
        }
    }
    //Dennis updated for pi start
    public static void decryptInsert(List<Consum_Apply__c> newList){
        if(!system.isFuture()){
            List<Consum_Apply__c> fendanList = new List<Consum_Apply__c>();
            for(Consum_Apply__c ra : newList){
                if(ra.Old_Consum_Apply__c != null){
                    fendanList.add(ra);
                }
            }
            
            if(fendanList.size() == 0){
                system.debug('no need split');
                return;
            }
            
           decryptInsertFuture(JSON.serialize(fendanList)); 
        }
    }
    
    @future(callout=true)
    public static void decryptInsertFuture(string json_list){
        decryptInsertCore(json_list);
    }
    
    // List<Consum_Apply__c> temps = [select id,AWS_Data_Id__c,name, direct_shippment_address__c,  Direct_Shippment_Address_Encrypt__c, Phone_number__c,  Phone_Number_Encrypt__c,CreatedDate   from Consum_Apply__c where AWS_Data_Id__c != null order by CreatedDate desc limit 2];
    public static void decryptInsertCore(string json_list){
        system.debug('enter decryptInsertCore');
        //调用滨璜接口更新
        PIHelper.PIIntegration staticResource =  PIHelper.getPIIntegrationInfo('Consum_Apply__c');
        system.debug('staticResource.token='+staticResource.token);
        if(String.isBlank(staticResource.token)){
            System.debug('获取aws token 失败');
            return;
        }
        List<Consum_Apply__c> newList = (List<Consum_Apply__c>)Json.deserialize(json_list, List<Consum_Apply__c>.class);
        Map<Id,Consum_Apply__c> newMap = new Map<Id,Consum_Apply__c>(newList);
        List<Map<string,object>> lmso = new List<Map<string,object>>();
        for(Consum_Apply__c ra : newList){
            Map<string,object> mso = new Map<string,object>();
            
            /*if(!string.isBlank(ra.AWS_Data_Id__c)){
                continue;
            }*/
            for(PI_Field_Policy_Detail__c detail : staticResource.PIDetails){
                if(ra.isSet(detail.SF_Field_API_Name__c)){
                    mso.put(detail.AWS_Field_API__c,ra.get(detail.SF_Field_API_Name__c));
                    mso.put(detail.AWS_Encrypted_Field_API__c,ra.get(detail.SF_Field_Encrypted_API__c));
                }
            }
            mso.put('sfRecordId',ra.Id);
            lmso.add(mso);
        }
        
        if(lmso.size()==0){
            system.debug('lmso.size()='+lmso.size());
            return;
        }
        string payload = Json.serialize(lmso);
        system.debug('payload='+payload);
        String awsApi = staticResource.viewUnifiedContactUrl;
        NFMUtil.response response = NFMUtil.sendToPiAWS(payload, awsApi,staticResource.token);
        system.debug(response);
        Map<string,object> res_obj = (Map<string,object>)Json.deserializeUntyped(response.responseBody);
        if(res_obj == null || !res_obj.containsKey('object') ){
            System.debug('res_obj == null || !res_obj.containsKey(\'object\')');
            return;
        }
        
        List<object> objList = (List<object>)res_obj.get('object');
        if(objList == null){
            System.debug('objList == null');
            return;
        }
        
        List<Consum_Apply__c> updateList = new List<Consum_Apply__c>();
        for(object obj : objList){
            Map<string,object> obj_map = (Map<string,object>)obj;
            string sfRecordId = null;
            string dataId = null;
            if(obj_map.containsKey('sfRecordId')){
                sfRecordId = string.valueOf(obj_map.get('sfRecordId'));
            }else{
                system.debug('obj_map.containsKey(\'sfRecordId\')='+obj_map.containsKey('sfRecordId'));
                continue;
            }
            
            if(obj_map.containsKey('dataId')){
                dataId = string.valueOf(obj_map.get('dataId'));
            }else{
                system.debug('obj_map.containsKey(\'dataId\')='+obj_map.containsKey('dataId'));
                continue;
            }
            
            
            if(newMap.containsKey(sfRecordId)){
                Consum_Apply__c ra = newMap.get(sfRecordId);
                ra.AWS_Data_Id__c = dataId;
                updateList.add(ra);
            }else{
                system.debug('newMap.containsKey('+sfRecordId+')='+newMap.containsKey(sfRecordId));
                continue;
            }
        }
        
        system.debug('updateList.size='+updateList.size());
        if(updateList.size()>0){
            update updateList;
        }
        
    }
    //Dennis updated for pi end

    // From ConsumApplyApprovalProcess.trigger TODO test
    private void approvalCheck() {