派生自 OlyMEBG

blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
Li Jun
2022-04-19 2f183a6b0a83ec3f7d35375d5d25d200efc2a3e1 
 force-app/main/default/classes/PIHelper.cls


@@ -8,6 +8,7 @@


 * 


 * */


global without sharing class PIHelper {


    public static Set<String> displayByOrderNumberObject = new set<String>{'Report__c'};


    public static String getObjectKeyPrefix(String objName){


        try{


            schema.sObjectType sObjType = Schema.getGlobalDescribe().get(objName);


@@ -18,19 +19,22 @@


        }    


    }


    // confirm file transaction


    @future(callout =true)


    // @future(callout =true)


    public static void confirmFileTrans(String module,Integer isSuccess, String   sfRecordId ,String transId ,String token,String transUrl){


        Boolean result =false;


        Transaction_Log__c traLog = new Transaction_Log__c();


        traLog.Module__c = 'ConfirmFileTransaction '+module;


        traLog.Interface_URL__c = transUrl;


        traLog.TransId__c = transId;


        traLog.SFRecordId__c=sfRecordId;


        // traLog.SFRecordId__c=sfRecordId;


        Integer MaxLogColumnLength = 131072;


        try {


            Http http = new Http();


            HttpRequest request = new HttpRequest();


            request.setEndpoint(transUrl);


            request.setMethod('POST');


            request.setHeader('pi-token',token);


            request.setHeader('Content-Type', 'application/json');


            TransRequestBody requestBody =new TransRequestBody();


            requestBody.isSuccess=isSuccess;


            requestBody.sfRecordId=sfRecordId;


@@ -44,7 +48,9 @@


            result = (Boolean)results.get('success');


            System.debug('result = ' + result);


            traLog.Status__c = 'success';


            traLog.Response__c=response.getBody();


            String res=response.getBody();


            traLog.Response__c=res.substring(0, (res.length() > MaxLogColumnLength ? MaxLogColumnLength : res.length()));


           


        } catch (Exception e) {  


            traLog.Status__c = 'fail';


            traLog.Response__c = e.getMessage();    


@@ -59,6 +65,7 @@


         traLog.Module__c = 'Confirm Transaction '+module;


         traLog.Interface_URL__c = transUrl;


         traLog.TransId__c = transId;


         Integer MaxLogColumnLength = 131072;


         if (!String.isEmpty(sfRecordId)) {


            traLog.SFRecordId__c=sfRecordId;


         }else {


@@ -70,6 +77,8 @@


             HttpRequest request = new HttpRequest();


             request.setEndpoint(transUrl);


             request.setMethod('POST');


             request.setHeader('pi-token',token);


             request.setHeader('Content-Type', 'application/json');


             TransactionRequestBody requestBody =new TransactionRequestBody();


             requestBody.isSuccess=isSuccess;


             requestBody.sfRecordId=sfRecordId;


@@ -83,7 +92,8 @@


             result = (Boolean)results.get('success');


             System.debug('result = ' + result);


             traLog.Status__c = 'success';


             traLog.Response__c=response.getBody();


             String res=response.getBody();


             traLog.Response__c=res.substring(0, (res.length() > MaxLogColumnLength ? MaxLogColumnLength : res.length()));


         } catch (Exception e) {  


             traLog.Status__c = 'fail';


             traLog.Response__c = e.getMessage();    


@@ -103,14 +113,42 @@


        traLog.Interface_URL__c = traLog.Module__c;


        insert traLog;


    }


    //save qianlima log method add sushanhu 20220324


    // model 0 为文件 1为数据


    public static void insertConfirmTrans(String module,Integer isSuccess, String   sfRecordId ,String transId ,Integer model,String transUrl,List<idList> idList){


        Boolean result =false;


        Transaction_Log__c traLog = new Transaction_Log__c();


        if (model==0) {


            traLog.Module__c = 'ConfirmFileTransaction '+module;


        }else {


            traLog.Module__c = 'Confirm Transaction '+module;


        }


        traLog.Interface_URL__c = transUrl;


        traLog.TransId__c = transId;


        Integer MaxLogColumnLength = 131072;


        if (!String.isEmpty(sfRecordId)) {


           traLog.Request__c=sfRecordId.substring(0, (sfRecordId.length() > MaxLogColumnLength ? MaxLogColumnLength : sfRecordId.length()));


        }else {


            String sfIds =JSON.serialize(idList);


           traLog.Request__c=sfIds.substring(0, (sfIds.length() > MaxLogColumnLength ? MaxLogColumnLength : sfIds.length()));


        }


         if(isSuccess==0){


            traLog.Status__c = 'fail';


         } else {


            traLog.Status__c='success';


         }  


        insert traLog;


    }


    public static PIIntegration getPIIntegrationInfo(String sobjectType){


        PIIntegration piIntegration = new PIIntegration();


        //查询url


        PI_Policy_Configuration__c config = [select Full_New_URL__c,Full_Search_URL__c,Full_Update_URL__c,Full_Undelete_URL__c,Full_Read_URL__c,Full_Delete_URL__c,Full_View_Unified_Contact_URL__c,TransactionURL__c from PI_Policy_Configuration__c where Sobject_Type__c =: sobjectType];


        System.debug('config = ' + config);


        System.debug('thhsobjectType = ' + sobjectType);


        PI_Policy_Configuration__c config = [SELECT Full_New_URL__c,Full_New_Encrypt_URL__c,Full_Update_Encrypt_URL__c,Full_Search_URL__c,Full_Update_URL__c,Full_Undelete_URL__c,Full_Read_URL__c,Full_Delete_URL__c,Full_View_Unified_Contact_URL__c,TransactionURL__c FROM PI_Policy_Configuration__c WHERE Sobject_Type__c =:sobjectType];


        // PI_Policy_Configuration__c config = [SELECT Full_New_URL__c,Full_Search_URL__c,Full_Update_URL__c,Full_Undelete_URL__c,Full_Read_URL__c,Full_Delete_URL__c,Full_View_Unified_Contact_URL__c,TransactionURL__c,Full_New_Encrypt_URL__c FROM PI_Policy_Configuration__c WHERE Sobject_Type__c =:sobjectType];


        System.debug('thhconfig = ' + config);




        //获取appid和appsecret


        AWS_Integration_Info__mdt awsConfiguration = [SELECT App_Id__c,Token_URL__c,App_Secret__c,Host_URL__c FROM AWS_Integration_Info__mdt  WHERE DeveloperName = 'AWS_Default_Configuration'];


        AWS_Integration_Info__mdt awsConfiguration = [SELECT App_Id__c,Max_Query_Number__c,Token_URL__c,App_Secret__c,Host_URL__c FROM AWS_Integration_Info__mdt  WHERE DeveloperName = 'AWS_Default_Configuration'];


        if (awsConfiguration == null) {


            System.debug('AWS_Integration_Info__mdt没配置');


            return null;


@@ -132,10 +170,14 @@


            request.setEndpoint(url);


            request.setMethod('GET');


            HttpResponse response = http.send(request);


         system.debug('response.getBody()='+response.getBody());


            Map<String, Object> results = (Map<String, Object>) JSON.deserializeUntyped(response.getBody());


            token = (String)results.get('object');


            System.debug('token = ' + token);


        }catch(Exception e){


            system.debug(e.getMessage());


            system.debug(e.getStackTraceString());


            


            Transaction_Log__c traLog = new Transaction_Log__c();


            traLog.Module__c = 'Get Token';


            traLog.Status__c = 'fail';


@@ -147,7 +189,10 @@


        //Insert Get Token Log




        //获取敏感字段


        piIntegration.PIDetails = [select id,PI_Policy_Configuration__r.Full_New_URL__c, Enable_Encrypt__c, SF_Field_API_Name__c,SF_Field_Encrypted_API__c, AWS_Field_API__c,AWS_Encrypted_Field_API__c,Field_Type__c from PI_Field_Policy_Detail__c  where PI_Policy_Configuration_Name__c =:sobjectType and Enable_Encrypt__c=true];


        piIntegration.PIDetails = [select id,PI_Policy_Configuration__r.Full_New_URL__c,PI_Policy_Configuration__r.Full_New_Encrypt_URL__c,PI_Policy_Configuration__r.Full_Update_Encrypt_URL__c, Enable_Encrypt__c, SF_Field_API_Name__c,SF_Field_Encrypted_API__c, AWS_Field_API__c,AWS_Encrypted_Field_API__c,Field_Type__c from PI_Field_Policy_Detail__c  where PI_Policy_Configuration_Name__c =:sobjectType and Enable_Encrypt__c=true];


        if(displayByOrderNumberObject.contains(sobjectType)){


            piIntegration.PIDetails = [select id,PI_Policy_Configuration__r.Full_New_URL__c,PI_Policy_Configuration__r.Full_New_Encrypt_URL__c,PI_Policy_Configuration__r.Full_Update_Encrypt_URL__c, Enable_Encrypt__c, SF_Field_API_Name__c,SF_Field_Encrypted_API__c, AWS_Field_API__c,AWS_Encrypted_Field_API__c,Field_Type__c from PI_Field_Policy_Detail__c  where PI_Policy_Configuration_Name__c =:sobjectType and Enable_Encrypt__c=true order by Order_Number__c];


        }


        List<String> vLookUpFields = new List<String>();


        List<String> PIFields = new List<String>();


        for (PI_Field_Policy_Detail__c PIDetail : piIntegration.PIDetails) {


@@ -161,12 +206,15 @@


        System.debug('PIFields = ' + PIFields.toString());




        //填充数据


        piIntegration.maxQueryNumber = Integer.valueof(awsConfiguration.Max_Query_Number__c);


        piIntegration.newUrl = config.Full_New_URL__c;


        piIntegration.updateUrl = config.Full_Update_URL__c;


        piIntegration.queryUrl = config.Full_Read_URL__c;


        piIntegration.deleteUrl = config.Full_Delete_URL__c;


        piIntegration.undeleteUrl = config.Full_Undelete_URL__c;


        piIntegration.viewUnifiedContactUrl = config.Full_View_Unified_Contact_URL__c;


        piIntegration.newEncryptUrl = config.Full_New_Encrypt_URL__c;


        piIntegration.updateEncryptUrl = config.Full_Update_Encrypt_URL__c;


        piIntegration.transactionURL = config.TransactionURL__c;


        piIntegration.hostUrl = awsConfiguration.Host_URL__c;


        piIntegration.searchUrl = config.Full_Search_URL__c;


@@ -180,6 +228,7 @@


        return piIntegration;


    }


    global class PIIntegration{


        public Integer maxQueryNumber{set;get;}


        public String sobjectPrefix{set;get;}


        public String searchUrl{set;get;}


        public String newUrl{set;get;}


@@ -188,6 +237,8 @@


        public String deleteUrl{set;get;}


        public String undeleteUrl{set;get;}


        public String viewUnifiedContactUrl{set;get;}


        public String newEncryptUrl{set;get;}


        public String updateEncryptUrl{set;get;}


        public String hostUrl{set;get;}


        public String token{set;get;}


        public String awsAppId{set;get;}