From 02ddc35714cbd1688b7cb057f770f1410de79dab Mon Sep 17 00:00:00 2001
From: buli <137736985@qq.com>
Date: 星期五, 11 三月 2022 12:19:33 +0800
Subject: [PATCH] PIPL Updated Code 20220311

---
 force-app/main/default/classes/NFM501Controller.cls |   46 +++++++++++++++++++++++++++++++++++++++-------
 1 files changed, 39 insertions(+), 7 deletions(-)

diff --git a/force-app/main/default/classes/NFM501Controller.cls b/force-app/main/default/classes/NFM501Controller.cls
index 9e05b9c..b8ec71c 100644
--- a/force-app/main/default/classes/NFM501Controller.cls
+++ b/force-app/main/default/classes/NFM501Controller.cls
@@ -1,5 +1,6 @@
 public with sharing class NFM501Controller implements Queueable {
     //鍏堝畾涔�
+    //add aws response
     public class AllData {
         public String code;
         public QLMData data;
@@ -45,6 +46,17 @@
         public String[] ZhaoRelationName;
         public String[] ZhongRelationName;
         public String infoTypeSegment;
+        //add aws pi start sushanhu 20220223 start
+        public String[] AgentRelationWayEncrypted;//浠g悊鏈烘瀯鑱旂郴鏂瑰紡瀵嗘枃
+        public String[] AgentRelationNameEncrypted;//浠g悊鏈烘瀯鑱旂郴鏂瑰紡浜哄瘑鏂�
+        public String[] ZhongRelationWayEncrypted;//涓爣鍗曚綅鑱旂郴鏂瑰紡瀵嗘枃
+        public String[] ZhongRelationNameEncrypted;//涓爣鍗曚綅鑱旂郴浜哄瘑鏂�
+        public String[] ZhaoRelationNameEncrypted;//鎷涙爣鍗曚綅鑱旂郴浜哄瘑鏂�
+        public String[] ZhaoRelationWayEncrypted;//鎷涙爣鍗曚綅鑱旂郴鏂瑰紡瀵嗘枃
+        public String DataId;// AWS 瀛樺偍鍑嵁
+
+        //add aws pi start sushanhu 20220223 start
+
     }
     public class AmountItem {
         public String Amount;
@@ -166,7 +178,10 @@
             System.debug('++++1++++' + token + '  : ' + timeslot);
             if (string.isblank(token) || timeslot > 1800000) {
                 System.debug('++++2++++' + token + '  : ' + timeslot);
-                NFMUtil.response response = NFMUtil.receiveToken();
+                // NFMUtil.response response = NFMUtil.receiveToken();
+                //update to aws token sushanhu start 20220223
+                NFMUtil.response response=NFMUtil.getAwsToken();
+                //update to aws token sushanhu end 20220223
                 System.debug('++++response++++' + response);
                 //鍒ゆ柇rowdata涓暟鎹幏鍙栨垚鍔熶笌鍚︼紝濡傛灉澶辫触閲嶅彂涓夋锛屽鏋滃ぇ浜庝笁娆″垯鎵嬪姩鎿嶄綔
                 if (String.isBlank(response.responseBody)) {
@@ -188,11 +203,19 @@
                 oldTimeTran.NFM501_Gain_End_Time__c = oldTime;
 
             }
-            //鏇挎崲鑾峰彇鍒版暟鎹腑鐨勫叧閿瓧
-            NFMUtil.response response = NFMUtil.getQLMData(NFMUtil.NFM501_ENDPOINT
-                                        + oldMark.Internal_Value__c + '/10', token);
-            // aaaaaaaa 杩欓噷椤哄簭閿欎簡锛岃偗瀹氭槸搴旇鍏堝垽鏂槸涓嶆槸鍥犱负http 鎶ラ敊锛岀劧鍚庢墠鏄崈閲岄┈鐨刢ode瑙f瀽
+            
+
+            // //鏇挎崲鑾峰彇鍒版暟鎹腑鐨勫叧閿瓧
+            // NFMUtil.response response = NFMUtil.getQLMData(NFMUtil.NFM501_ENDPOINT
+            //                             + oldMark.Internal_Value__c + '/10', token);
+            // // aaaaaaaa 杩欓噷椤哄簭閿欎簡锛岃偗瀹氭槸搴旇鍏堝垽鏂槸涓嶆槸鍥犱负http 鎶ラ敊锛岀劧鍚庢墠鏄崈閲岄┈鐨刢ode瑙f瀽
+            //update to aws start sushanhu 20220223
+            PIHelper.PIIntegration NFM501AWS =PIHelper.getPIIntegrationInfo('QLMNFM501');
+            NFMUtil.response response = NFMUtil.getAWSQLMData(NFM501AWS.newUrl+'cursorMark='
+                                         + oldMark.Internal_Value__c + '&pageSize=10', token);
+            //update to aws  sushanhu end 20220223
             //http鐨勬姤閿欏鐞嗭紙閲嶅彂涓夐亶锛�
+            //
             if (String.isBlank(response.responseBody)) {
                 System.debug('-------7-------');
                 // aaaaaaaa 鎶ラ敊鍘熷洜鍐欑殑涓嶅
@@ -209,7 +232,14 @@
             // 瑙f瀽鍚庣殑code鎶ラ敊澶勭悊
             String NFM501responseBody = response.responseBody;
             System.debug('-------------NFM501responseBody------------' + NFM501responseBody);
-            NFM501responseBody = NFM501responseBody.replaceAll('"list"', '"list1"').replaceAll('"number":', '"number1":');
+            //update to aws response sushanhu 20220223 start
+            Map<String, Object> results = (Map<String, Object>) JSON.deserializeUntyped(NFM501responseBody);
+            //String qlmResult =(String)results.get('object');
+            String qlmResult =JSON.serialize(results.get('object'));
+            System.debug('-------------NFM501responseBody qlmResult------------' + qlmResult);
+            // NFM501responseBody = NFM501responseBody.replaceAll('"list"', '"list1"').replaceAll('"number":', '"number1":');
+            NFM501responseBody = qlmResult.replaceAll('"list"', '"list1"').replaceAll('"number":', '"number1":');
+            //update to aws response sushanhu 20220223 end
             AllData getQLMData =  (AllData) JSON.deserializeStrict(NFM501responseBody, AllData.class);
             System.debug('-------------8------------' + getQLMData);
             if (!getQLMData.code.equals('0')) {
@@ -223,6 +253,8 @@
                 return;
             }
             rowData = NFMUtil.QLMmakeRowData(NFM501responseBody, rowData);
+            rowData.AWS_Transaction_Id__c = (String)results.get('txId');// add for pi susanhu 20220310
+            system.debug('rowData---'+rowData);
             System.debug('======2221234======');
 
             update tokenTran;
@@ -244,7 +276,7 @@
                 // 12鐐硅嚜鍔ㄦ姄鍙栨嫑鎶曟爣鏁版嵁
                 // NFM501Controller.TwoMarkEqualAgainSend();
             }
-
+            
             rowData.retry_cnt__c = 0;
             if (System.Test.isRunningTest()) {
                 throw new ControllerUtil.myException('aaa');

--
Gitblit v1.9.1