blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
Li Jun
2022-03-31 3ba0123db48f8bab81ddf0913e1b95280ef545e8 
 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();    


@@ -52,13 +58,14 @@


        insert traLog;


    }


     // confirm tx transaction




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


    @future(callout =true)


     public static void confirmTrans(String module,Integer isSuccess, String   sfRecordId ,String transId ,String token,String transUrl,String 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 {


@@ -70,12 +77,16 @@


             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.idList=idList;


             requestBody.idList=(List < idList >)JSON.deserialize(idList,List < idList > .class);


             requestBody.txId =transId;


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


             traLog.Request__c =JSON.serialize(requestBody);


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


             HttpResponse response = http.send(request);


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


@@ -83,7 +94,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 +115,40 @@


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


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




        //获取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;


@@ -148,6 +186,9 @@




        //获取敏感字段


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


        if(displayByOrderNumberObject.contains(sobjectType)){


            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 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,6 +202,7 @@


        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;


@@ -180,6 +222,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;}