From 1b8c8764c39fc546ca1b85ff1810ae51be74331c Mon Sep 17 00:00:00 2001
From: Li Jun <buli@deloitte.com.cn>
Date: 星期四, 31 三月 2022 18:39:23 +0800
Subject: [PATCH] PIPL0331V2Deploy

---
 force-app/main/default/classes/NFM503InfoFileBatch.cls |   46 ++++++++++++++++++++++++++++------------------
 1 files changed, 28 insertions(+), 18 deletions(-)

diff --git a/force-app/main/default/classes/NFM503InfoFileBatch.cls b/force-app/main/default/classes/NFM503InfoFileBatch.cls
index d9199c8..08a48a8 100644
--- a/force-app/main/default/classes/NFM503InfoFileBatch.cls
+++ b/force-app/main/default/classes/NFM503InfoFileBatch.cls
@@ -5,6 +5,8 @@
 	public static String transUrl;
 	public static String transId;
 	public static String token;
+    public static  integer isSuccess=0; 
+    public static List<String> sfRecordIds =new List<String>();
 	//add staic sushanhu 20220302 end
     Boolean IsNeedExecute = false;  //2021-06-28 mzy  WLIG-BYHD79  SFDC鐜batch鍚堝苟璋冩煡  鏄惁绗﹀悎鎵ц鏉′欢
     //add nfm 503 aws response start sushanhu 20220301
@@ -28,8 +30,8 @@
 
     global Database.QueryLocator start(Database.BatchableContext bc) {
         String query = 'select Id, Tender_information__c, infoAddress__c, ' +
-                       'Tender_information__r.InfoType__c, isProcessed__c, ' +
-                       ' ErrorMessage__c from bidInfoFile__c where isProcessed__c = false ';
+                        'Tender_information__r.InfoType__c, isProcessed__c, ' +
+                        ' ErrorMessage__c from bidInfoFile__c where isProcessed__c = false ';
         if (String.isNotBlank(TenId)) {
             query += 'and Tender_information__r.Id =: TenId';
         }
@@ -68,14 +70,15 @@
                 timeslot = newTime.getTime() - oldTime.getTime();
             }
             // System.debug('++++1++++' + token + '  : ' + timeslot);
+            PIHelper.piIntegration pi =PIHelper.getPIIntegrationInfo('NFM503');
             if (string.isblank(token) || timeslot > 1800000) {
                 //UP TO AWAS TOKEN 20220225 SUSHANHU START
-                NFMUtil.response response = NFMUtil.getAWSToken();
-                //UP TO AWAS TOKEN 20220225 SUSHANHU END
-                if (String.isBlank(response.responseBody)) {
-                    bidInfoFile.ErrorMessage__c = '503token:' + response.status;
-                }
-                token = response.responseBody;
+                // NFMUtil.response response = NFMUtil.getAWSToken();
+                // //UP TO AWAS TOKEN 20220225 SUSHANHU END
+                // if (String.isBlank(response.responseBody)) {
+                //     bidInfoFile.ErrorMessage__c = '503token:' + response.status;
+                // }
+                token = pi.token;
                 oldTime = Datetime.now();
                 token503.NFM501_Token__c = token;
                 oldTime503.NFM501_Gain_End_Time__c = oldTime;
@@ -91,11 +94,9 @@
             //UP TO NEW  AWS method sushanhu start 20220301
             // List< Tender_information__c> updateTenderList = new  List< Tender_information__c>();
             List<FileAddress__c> fileList = new List<FileAddress__c>();
-            PIHelper.piIntegration pi =PIHelper.getPIIntegrationInfo('NFM503');
             transUrl =pi.searchUrl;
             NFMUtil.response response = NFMUtil.getAWSQLMData(pi.newUrl ,JSON.serialize(queryfileList), token);
             system.debug('aws result'+response.responseBody);
-        
             Map<String, Object> result = (Map<String, Object>)JSON.deserializeUntyped(response.responseBody);
             system.debug('NFM503 aws result--'+response.responseBody+'status'+response.status);
             transId =(String)result.get('txId');
@@ -191,15 +192,17 @@
 
             update bidInfoFileList;
             // add 纭浜嬪姟 sushanhu 20220302 start
-            List<String> sfRecordIds = new List<String>();
+            
+            if (fileList.size() > 0 ) {
 			for (FileAddress__c fileAddress : fileList) {
+                system.debug('fileAddress.Id---'+json.serialize(fileAddress));
 				sfRecordIds.add(fileAddress.Id);
                 system.debug('fileAddress.Id---'+fileAddress.Id);
 			}
+            }
             system.debug('鎴愬姛鐨則oken'+token);
-            
-             PIHelper.confirmFileTrans('NFM503',1,JSON.serialize(sfRecordIds),transId,token,transUrl);
-			
+            isSuccess =1;
+           
             // if (!confirm) {
 			// 	//鍥炴粴
             //     if (sp != null) {
@@ -215,9 +218,9 @@
             if (sp != null) {
                 Database.rollback(sp);
             }
-            //add 纭浜嬪姟 20220302 sushanhu start
-            system.debug('澶辫触鐨則oken'+token);
-             PIHelper.confirmFileTrans('NFM503',0,'',transId,token,transUrl);
+            // //add 纭浜嬪姟 20220302 sushanhu start
+            // system.debug('澶辫触鐨則oken'+token);
+            //  PIHelper.confirmFileTrans('NFM503',0,'',transId,token,transUrl);
             //add 纭浜嬪姟 20220302 sushanhu end
             bidInfoFile.ErrorMessage__c = '503鎶涘嚭寮傚父锛�' + ex.getMessage() + '\n' + ex.getStackTraceString();
             system.debug('ErrorMessage'+bidInfoFile.ErrorMessage__c);
@@ -226,6 +229,13 @@
     }
 
     global void finish(Database.BatchableContext BC) {
-
+        // add confirm transaction for pipl  sushanhu 20220314 start
+        if (isSuccess==0) {
+            PIHelper.confirmFileTrans('NFM503',isSuccess,'',transId,token,transUrl);
+        }else {
+            PIHelper.confirmFileTrans('NFM503',isSuccess,JSON.serialize(sfRecordIds),transId,token,transUrl);
+        }
+         
+         // add confirm transaction for pipl  sushanhu 20220314 end
     }
 }
\ No newline at end of file

--
Gitblit v1.9.1