OlympusSSBG
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
GWY
2022-04-15 b823c7f3569cf9368e2245846e918f78f32e903a 
 force-app/main/default/classes/PIHelper.cls


@@ -17,7 +17,88 @@


            return '';


        }    


    }


    // confirm file transaction


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


        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;


            requestBody.txId =transId;


            request.setBody(JSON.serialize(requestBody));


            system.debug('request---'+request.tostring());


            HttpResponse response = http.send(request);


            system.debug('token--'+token);


            system.debug('confirm result--'+response.getBody());


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


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


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


            traLog.Status__c = 'success';


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


        }


        insert traLog;


    }


     // confirm tx transaction




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


        Boolean result =false;


        Transaction_Log__c traLog = new Transaction_Log__c();


        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 {


        traLog.SFRecordId__c=JSON.serialize(idList);


        }


        


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


            TransactionRequestBody requestBody =new TransactionRequestBody();


            requestBody.isSuccess=isSuccess;


            requestBody.sfRecordId=sfRecordId;


            requestBody.idList=idList;


            requestBody.txId =transId;


            request.setBody(JSON.serialize(requestBody));


            system.debug('request---'+request.tostring());


            HttpResponse response = http.send(request);


            system.debug('confirm result--'+response.getBody());


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


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


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


            traLog.Status__c = 'success';


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


        }


        insert traLog;


    }


    // Use this log method


    public static void saveTransLog(String module,String awsDataId,String sfId, String transId,String content,String status,String respMsg){


        Transaction_Log__c traLog = new Transaction_Log__c();


@@ -31,14 +112,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


        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,TransactionURL__c from PI_Policy_Configuration__c where Sobject_Type__c =: sobjectType];


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


        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;


@@ -60,13 +169,14 @@


            request.setEndpoint(url);


            request.setMethod('GET');


            HttpResponse response = http.send(request);


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


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


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


@@ -78,6 +188,7 @@


        //Insert Get Token Log




        //获取敏感字段


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


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


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


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


@@ -92,11 +203,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;


@@ -110,6 +225,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;}


@@ -117,6 +233,9 @@


        public String queryUrl{set;get;}


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


@@ -126,4 +245,20 @@


        public List<String> PIFields{set;get;}


        public List<PI_Field_Policy_Detail__c > PIDetails{set;get;}


    }


    global class TransRequestBody{


        public Integer isSuccess{set;get;}


        public String sfRecordId{set;get;}


        public String txId{set;get;}


        


    }


    global class TransactionRequestBody{


        public Integer isSuccess{set;get;}


        public String sfRecordId{set;get;}


        public String txId{set;get;}


        public List<idList> idList{set;get;} 


    }


    global class idList{


        public String awsId{set;get;}


        public String sfRecordId{set;get;}


    }


}