From 927e81f5c3402d3307b2e7b4b079cc99ecef4d18 Mon Sep 17 00:00:00 2001
From: 涂煌豪 <997058689@qq.com>
Date: 星期五, 11 三月 2022 19:21:24 +0800
Subject: [PATCH] NFMUtil

---
 force-app/main/default/classes/NFMUtil.cls |  187 +++++++++++++++-------------------------------
 1 files changed, 63 insertions(+), 124 deletions(-)

diff --git a/force-app/main/default/classes/NFMUtil.cls b/force-app/main/default/classes/NFMUtil.cls
index 75592b4..d1bd09b2 100644
--- a/force-app/main/default/classes/NFMUtil.cls
+++ b/force-app/main/default/classes/NFMUtil.cls
@@ -78,8 +78,7 @@
             //NFM007_ENDPOINT = 'http://wdp.olympus.com.cn:8089/RESTAdapter/NFM007';
             NFM007_ENDPOINT = 'https://wdp.olympus.com.cn:44301/RESTAdapter/NFM007';
             NFM008_ENDPOINT = 'https://owdc-test.olympus.co.jp/XISOAPAdapter/MessageServlet?senderParty=&senderService=OCM_SFDC_T&receiverParty=&receiverService=&interface=NFM008_Sync_BC2GPI&interfaceNamespace=http%3A%2F%2Folympus.co.jp%2Fgpi%2FNFM008';
-            // NFM103_ENDPOINT = 'http://wdp.olympus.com.cn:8089/RESTAdapter/NFM103';
-            NFM103_ENDPOINT = 'https://sfpi-mebg-test.olympuschina.com/api/nfm/103';//aws 103鎺ュ彛
+            NFM103_ENDPOINT = 'http://wdp.olympus.com.cn:8089/RESTAdapter/NFM103';
             // NFM106_ENDPOINT = 'https://owdc-test.olympus.co.jp/XISOAPAdapter/MessageServlet?senderParty=&senderService=OCM_SFDC_T&receiverParty=&receiverService=&interface=NFM106_Sync_BC2GPI&interfaceNamespace=http%3A%2F%2Folympus.co.jp%2Fgpi%2FNFM106';
             NFM106_ENDPOINT = 'http://wdp.olympus.com.cn:8089/RESTAdapter/NFM106';
             //NFM106_ENDPOINT = 'https://sfdc-ocm-test.olympus.co.jp/XISOAPAdapter/MessageServlet?senderParty=&senderService=OCM_SFDC_T&receiverParty=&receiverService=&interface=NFM106_Sync_BC2GPI&interfaceNamespace=http%3A%2F%2Folympus.co.jp%2Fgpi%2FNFM106';
@@ -101,16 +100,16 @@
             NFM401_ENDPOINT = 'http://ec2-161-189-3-104.cn-northwest-1.compute.amazonaws.com.cn:8088/dojtest/dojInfo/recevie';
             NFM402_ENDPOINT = 'http://ec2-161-189-3-104.cn-northwest-1.compute.amazonaws.com.cn:8088/dojtest/dojInfo/getDojInfoByRefNo';
 
-            // NFM501_ENDPOINT = 'http://cusdata.qianlima.com/test/v1/info/page/';
-            NFM501_ENDPOINT = 'https://sfpi-mebg-test.olympuschina.com/api/nfm/501';
-            NFM502_ENDPOINT = 'http://cusdata.qianlima.com/test/v1/info/detailHtml?url=';
-            NFM504_ENDPOINT = 'http://cusdata.qianlima.com/test/v1/customer/albs/feedback';
+            NFM501_ENDPOINT = 'http://cusdata.qianlima.com/v1/info/page/';
+            NFM502_ENDPOINT = 'http://cusdata.qianlima.com/v1/info/detailHtml?url=';
+            NFM504_ENDPOINT = 'http://cusdata.qianlima.com/v1/customer/albs/feedback';
             CBPR_Auth_Sap = 'Basic U0ZEQ19XU1VTRVI6cG9xMTIzNDU=';
             // LHJ 20180824 CBPR End
             //CBPR_Auth_Spo = 'http://cbpr.chinacloudsites.cn/sfdc/token';
             CBPR_Auth_Spo = 'http://cbpr.olympuschina.com/sfdc/token';
 
             QLM_Token = 'http://cusdata.qianlima.com/v1/token';
+            
 
             // 鏅烘収鍖荤枟&鏈嶅姟鏂扮郴缁熼�氫俊 瀹㈡埛鎺ュ彛
             NFM601_ENDPOINT = 'https://wdp.olympus.com.cn:44301/RESTAdapter/NFM601';
@@ -128,11 +127,11 @@
             NFM115_ENDPOINT = 'https://wdp.olympus.com.cn:44301/RESTAdapter/NFM115';
             // 鏂版湇鍔$郴缁� 娴嬭瘯鐜
             AWS_DOMAIN = 'https://olympus.bqbot.com';
-             // 鏂版湇鍔$郴缁� 鏈湴鐜锛堜复鏃讹級
+            // 鏂版湇鍔$郴缁� 鏈湴鐜锛堜复鏃讹級
             // AWS_DOMAIN = 'http://114.249.236.98:29990';
             // AWS_DOMAIN = 'http://jzbase.bqbot.com:29990';
             // AWS_DOMAIN = 'http://114.249.238.243:29990';
-
+            
 
             requestURILMS = '/v1/uc/user/syncOlympusUnit';
             appSecretLMS = 'CAE1D68BE3EB4F7AB5FE97EBDD11B83E';
@@ -144,7 +143,7 @@
             NFM007_ENDPOINT = 'https://wdp.olympus.com.cn:44302/RESTAdapter/NFM007';
             NFM008_ENDPOINT = 'https://owdc.olympus.co.jp/XISOAPAdapter/MessageServlet?senderParty=&senderService=OCM_SFDC_P&receiverParty=&receiverService=&interface=NFM008_Sync_BC2GPI&interfaceNamespace=http%3A%2F%2Folympus.co.jp%2Fgpi%2FNFM008';
             //NFM103_ENDPOINT = 'https://owdc.olympus.co.jp/XISOAPAdapter/MessageServlet?senderParty=&senderService=OCM_SFDC_P&receiverParty=&receiverService=&interface=NFM103_Sync_BC2GPI&interfaceNamespace=http%3A%2F%2Folympus.co.jp%2Fgpi%2FNFM103';
-            NFM103_ENDPOINT = 'https://wdp.olympus.com.cn:44302/RESTAdapter/NFM103';// 鍘焥aphost
+            NFM103_ENDPOINT = 'https://wdp.olympus.com.cn:44302/RESTAdapter/NFM103';
             //NFM106_ENDPOINT = 'https://owdc.olympus.co.jp/XISOAPAdapter/MessageServlet?senderParty=&senderService=OCM_SFDC_P&receiverParty=&receiverService=&interface=NFM106_Sync_BC2GPI&interfaceNamespace=http%3A%2F%2Folympus.co.jp%2Fgpi%2FNFM106';
             NFM106_ENDPOINT = 'https://wdp.olympus.com.cn:44302/RESTAdapter/NFM106';
             // LHJ 20180824 CBPR Start
@@ -159,8 +158,7 @@
             NFM401_ENDPOINT = 'http://ec2-161-189-3-104.cn-northwest-1.compute.amazonaws.com.cn:8082/doj/dojInfo/recevie';
             NFM402_ENDPOINT = 'http://ec2-161-189-3-104.cn-northwest-1.compute.amazonaws.com.cn:8082/doj/dojInfo/getDojInfoByRefNo';
 
-            // NFM501_ENDPOINT = 'http://cusdata.qianlima.com/v1/info/page/';
-            NFM501_ENDPOINT   ='https://sfpi-mebg-test.olympuschina.com/api/nfm/501';
+            NFM501_ENDPOINT = 'http://cusdata.qianlima.com/v1/info/page/';
             NFM502_ENDPOINT = 'http://cusdata.qianlima.com/v1/info/detailHtml?url=';
             NFM504_ENDPOINT = 'http://cusdata.qianlima.com/v1/customer/albs/feedback';
             CBPR_Auth_Sap = 'Basic U0ZEQ19XU1VTRVI6cG9wMTIzNDU=';
@@ -176,6 +174,9 @@
             // 鏅烘収鍖荤枟&鏈嶅姟鏂扮郴缁熼�氫俊 鐢ㄦ埛鎺ュ彛
             NFM621_ENDPOINT = 'https://wdp.olympus.com.cn:44302/RESTAdapter/NFM621';
             NFM622_ENDPOINT = 'https://api-platform.olympuschina.com/prod-api/api/sso/sfdc_activitydata';
+            NFM701_ENDPOINT = 'https://wdp.olympus.com.cn:44302/RESTAdapter/NFM701';
+            NFM702_ENDPOINT = 'https://wdp.olympus.com.cn:44302/RESTAdapter/NFM702';
+            NFM703_ENDPOINT = 'https://wdp.olympus.com.cn:44302/RESTAdapter/NFM703';
 
             //鏍锋湰绠$悊
             NFM115_ENDPOINT = 'https://wdp.olympus.com.cn:44302/RESTAdapter/NFM115';
@@ -230,25 +231,7 @@
         webservice String timestamp;
         webservice String appKey;
     }
-    global class NFMResponse{
-        public Boolean SFStatus;
-        public String SFMessage;
-        public StaticResponse staticResponse;
-    }
-    global class StaticResponse{
-        public string status;
-        public String Message;
-        public StaticResponse(){
-            status='Success';
-            Message='';
-        }
-    }
-    public static NFMResponse getNFMResponse(){
-        NFMResponse  result=new NFMResponse();
-        result.staticResponse =new StaticResponse();
-        return result;
-        
-    }
+
     /**
      * @return yyyyMMdd 銇棩浠樻枃瀛楀垪
      */
@@ -361,7 +344,7 @@
         return rtn;
     }
 
-     /**
+    /**
      * add       wangweipeng       2022/02/11
      * [formatDateTime2StrDateTime description]
      * @param  dt [鏃ユ湡/鏃堕棿]
@@ -395,7 +378,7 @@
         return parseStr2Date(pDateTime.substring(0, 8));
     }
 
-     /**
+    /**
      * add    wangweipeng           2022/02/15
      * [parseStr2DateTime description]
      * @param  pDate [鏃ユ湡锛堜笉鍖呮嫭鏃堕棿锛塢
@@ -436,13 +419,13 @@
                 return null;
             }
             rtn = Datetime.newinstance(
-                      Integer.valueOf(pDate.substring(0, 4)),
-                      Integer.valueOf(pDate.substring(4, 6)),
-                      Integer.valueOf(pDate.substring(6, 8)),
-                      Integer.valueOf(pTime.substring(0, 2)),
-                      Integer.valueOf(pTime.substring(2, 4)),
-                      Integer.valueOf(pTime.substring(4, 6))
-                  );
+                Integer.valueOf(pDate.substring(0, 4)),
+                Integer.valueOf(pDate.substring(4, 6)),
+                Integer.valueOf(pDate.substring(6, 8)),
+                Integer.valueOf(pTime.substring(0, 2)),
+                Integer.valueOf(pTime.substring(2, 4)),
+                Integer.valueOf(pTime.substring(4, 6))
+            );
         } catch (Exception ex) {
             System.debug(Logginglevel.ERROR, 'NFMUtil#parseStr2DateTime(' + pDate + ', ' + pTime + ')' + ex.getMessage());
         }
@@ -472,10 +455,10 @@
                 return null;
             }
             rtn = Date.newinstance(
-                      Integer.valueOf(pStr.substring(0, 4)),
-                      Integer.valueOf(pStr.substring(4, 6)),
-                      Integer.valueOf(pStr.substring(6, 8))
-                  );
+                Integer.valueOf(pStr.substring(0, 4)),
+                Integer.valueOf(pStr.substring(4, 6)),
+                Integer.valueOf(pStr.substring(6, 8))
+            );
         } catch (Exception ex) {
             System.debug(Logginglevel.ERROR, 'NFMUtil#parseStr2Date(' + pStr + ')' + ex.getMessage());
         }
@@ -621,6 +604,32 @@
         return rowData;
     }
 
+    // public static BatchIF_Log__c makeRowDataToOnline(NFMUtil.MonitoringToOnline Monitoring, String NFMType, Object NFMData) {
+    //     BatchIF_Log__c rowData = new BatchIF_Log__c();
+    //     rowData.Type__c = NFMType;
+    //     rowData.MessageGroupNumber__c = Monitoring.MessageGroupNumber;
+    //     rowData.TransmissionDateTime__c = Monitoring.TransmissionDateTime;
+    //     rowData.RowDataFlg__c = true;
+    //     rowData.Log__c = '';
+    //     rowData.ErrorLog__c = '';
+    //     String rowDataStr = JSON.serialize(NFMData);
+    //     if (rowDataStr.length() > 0) {
+    //         Integer splitIdx = 1;
+    //         while (rowDataStr.length() > 0) {
+    //             if (splitIdx == 1) {
+    //                 rowData.put('Log__c', rowDataStr.substring(0, (rowDataStr.length() > MaxLogColumnLength ? MaxLogColumnLength : rowDataStr.length())));
+    //             } else if (splitIdx == 13) {
+    //                 rowData.ErrorLog__c = rowDataStr;
+    //                 break;
+    //             } else {
+    //                 rowData.put('Log' + splitIdx + '__c', rowDataStr.substring(0, (rowDataStr.length() > MaxLogColumnLength ? MaxLogColumnLength : rowDataStr.length())));
+    //             }
+    //             splitIdx++;
+    //             rowDataStr = rowDataStr.substring((rowDataStr.length() > MaxLogColumnLength ? MaxLogColumnLength : rowDataStr.length()));
+    //         }
+    //     }
+    //     return rowData;
+    // }
     public static BatchIF_Log__c makeRowData(BatchIF_Log__c iflog, String NFMType, Object NFMData) {
         // TransmissionDateTime銇ō瀹�
         Datetime nowDT = Datetime.now();
@@ -862,36 +871,13 @@
         system.debug('ress:' + ress);
         return new response(ress, resb);
     }
-    // send to aws to sap sushuanhu 20220222
-    public static response sendToPiAWS(String rowDataStr, String endpoint,String awsToken) {
 
-        Http http = new Http();
-        HttpRequest req = new HttpRequest();
-        HTTPResponse res;
-        String resb;       
-        req.setTimeout(120000);
-        req.setEndpoint(endpoint);
-        req.setMethod('POST');
-        req.setHeader('Content-Type', 'application/json');
-        req.setHeader('pi-token', awsToken);
-        req.setBody(rowDataStr);
-        res = http.send(req);
-        string ress =String.valueof(res.getStatusCode());
-        resb = res.getBody();
-        system.debug('ress:' + ress);
-        return new response(ress, resb);
-    }
-    // 鑾峰彇aws token sushanhu 20220222
-    public static response getAwsToken(){
-        String responseBody = AWSServiceTool.getAWSToken();
-        return new response('success', responseBody);
-    }
     public class response {
         public string status;
         public string responseBody;
-        public response(string status, string responseBody ) {
-            this.status         = status;
-            this.responseBody   = responseBody;
+        public response(string status, string responseBody) {
+            this.status = status;
+            this.responseBody = responseBody;
         }
     }
     // WLIG-BXQBH6 end
@@ -923,10 +909,10 @@
             return null;
         }
         return Time.newInstance(
-                   Integer.valueOf(timeStr.substring(0, 2)),
-                   Integer.valueOf(timeStr.substring(2, 4)),
-                   Integer.valueOf(timeStr.substring(4, 6)),
-                   0);
+            Integer.valueOf(timeStr.substring(0, 2)),
+            Integer.valueOf(timeStr.substring(2, 4)),
+            Integer.valueOf(timeStr.substring(4, 6)),
+            0);
     }
     //insert by rentongxiao 2020-10-12 end
 
@@ -947,8 +933,8 @@
         //1銆� 鑾峰彇token:
         Http http = new Http();
         HttpRequest req = new HttpRequest();
-        String content = 'appKey=' + EncodingUtil.urlEncode(appKey, 'UTF-8') + 
-                         '&appSecret=' + EncodingUtil.urlEncode(appSecret, 'UTF-8');
+        String content = 'appKey=' + EncodingUtil.urlEncode(appKey, 'UTF-8') +
+            '&appSecret=' + EncodingUtil.urlEncode(appSecret, 'UTF-8');
         //璇锋眰璺緞
         req.setEndpoint(QLM_Token);
         req.setHeader('Content-Type', QLM_NFM501_Point);
@@ -1006,51 +992,6 @@
         //姝e父鎵ц
         return new response(ress, response.getBody());
     }
-    // NEW QLM AWS 501  鎺ュ彛 sushanhu 20220223
-    public static response getAWSQLMData(String endpoint, String token) {
-        //2銆佽幏鍙栨嫑鏍囦俊鎭細璁板緱浣跨敤1涓幏鍙栫殑token
-        Http http = new Http();
-        HttpRequest req = new HttpRequest();
-        req.setHeader('Content-Type', 'application/json');
-        req.setHeader('pi-token',  token);
-        req.setTimeout(120000);
-        req.setEndpoint(endpoint);
-        req.setMethod('GET');
-        HTTPResponse response = http.send(req);
-        String statusCode = response.getStatus();
-        System.debug('response:' + response);
-        //http锛氱姸鎬佸拰code
-        //濡傛灉鐘舵�佷笉閫氳繃 锛� 鍒欏皢鐘舵�佸強绌虹殑鐨勬暟鎹� 锛� 杩斿洖
-        if (String.isNotBlank(statusCode)) {
-            return new response(statusCode, null);
-        }
-        System.debug('=====2======' + response.getBody());
-        //姝e父鎵ц
-        return new response(statusCode, response.getBody());
-    }
-    // NEW QLM AWS 502 503鎺ュ彛 sushanhu 20220223
-    public static response getAWSQLMData(String endpoint,String jsonStr,  String token) {
-        //2銆佽幏鍙栨嫑鏍囦俊鎭細璁板緱浣跨敤1涓幏鍙栫殑token
-        Http http = new Http();
-        HttpRequest req = new HttpRequest();
-        req.setHeader('Content-Type', 'application/json');
-        req.setHeader('pi-token',  token);
-        req.setTimeout(120000);
-        req.setEndpoint(endpoint);
-        req.setMethod('POST');
-        req.setBody(jsonStr);
-        HTTPResponse response = http.send(req);
-        String statusCode = response.getStatus();
-        System.debug('response:' + response);
-        //http锛氱姸鎬佸拰code
-        //濡傛灉鐘舵�佷笉閫氳繃 锛� 鍒欏皢鐘舵�佸強绌虹殑鐨勬暟鎹� 锛� 杩斿洖
-        if (String.isNotBlank(statusCode)) {
-            return new response(statusCode, null);
-        }
-        System.debug('=====2======' + response.getBody());
-        //姝e父鎵ц
-        return new response(statusCode, response.getBody());
-    }
 
     //鎺ュ彛3锛岃幏鍙栧叾浠栭檮浠�
     public static response503 getFileData(String token503, String endpoint) {
@@ -1097,7 +1038,7 @@
     public static String sendTenInfo(String token504, String jsonStr, String endpoint) {
         Http http = new Http();
         HttpRequest req = new HttpRequest();
-        req.setEndpoint(endpoint);
+        req.setEndpoint('http://cusdata.qianlima.com/test/v1/customer/albs/feedback');
         req.setHeader('open-authorization', 'Bearer' + token504);
         req.setHeader('Content-Type', 'application/x-www-form-urlencoded');
         req.setMethod('POST');
@@ -1215,10 +1156,8 @@
         system.debug('resb:' + resb);
         return resb;
     }
-
-    
     //鍙戦�佺粰鍏遍�氬钩鍙� 绮剧悽鎶�鏈� thh 2021-09-22 end
-
+    
     public static Integer ControllerUtil() {
         Integer i = 0;
         i++;

--
Gitblit v1.9.1