OlyMEBG.git - Gitblit

			@@ -63,6 +63,9 @@
			public static String NFM703_ENDPOINT = null;

			public static String NFM115_ENDPOINT = null;
			// 电子签收单SFDC2SAP thh 20220427 start
			public static String NFM116_ENDPOINT = null;
			// 电子签收单SFDC2SAP thh 20220427 end

			public static String NFM112_ENDPOINT = null;

			@@ -78,7 +81,8 @@
			//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 = 'http://wdp.olympus.com.cn:8089/RESTAdapter/NFM103';
			NFM103_ENDPOINT = 'https://sfpi-mebg-test.olympuschina.com/api/nfm/103';//aws 103接口
			// 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';
			@@ -100,7 +104,7 @@
			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/v1/info/page/';
			NFM501_ENDPOINT = 'https://sfpi-mebg-test.olympuschina.com/api/nfm/501';
			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=';
			@@ -109,7 +113,7 @@
			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';
			@@ -122,16 +126,22 @@
			NFM702_ENDPOINT = 'https://wdp.olympus.com.cn:44301/RESTAdapter/NFM702';
			NFM703_ENDPOINT = 'https://wdp.olympus.com.cn:44301/RESTAdapter/NFM703';

			NFM112_ENDPOINT = 'http://wdp.olympus.com.cn:8089/RESTAdapter/NFM112';
			NFM112_ENDPOINT = 'https://wdp.olympus.com.cn:44301/RESTAdapter/NFM112';

			NFM115_ENDPOINT = 'https://wdp.olympus.com.cn:44301/RESTAdapter/NFM115';

			// sanbox电子签收单SFDC2SAP thh 20220427 start
			NFM116_ENDPOINT = 'https://wdp.olympus.com.cn:44301/RESTAdapter/NFM116';
			// sanbox电子签收单SFDC2SAP thh 20220427 end

			// 新服务系统测试环境
			AWS_DOMAIN = 'https://olympus.bqbot.com';
			// 新服务系统本地环境（临时）
			// 新服务系统本地环境（临时）
			// AWS_DOMAIN = 'http://114.249.236.98:29990';
			// AWS_DOMAIN = 'http://114.249.231.75:29995';
			// AWS_DOMAIN = 'http://jzbase.bqbot.com:29990';
			// AWS_DOMAIN = 'http://114.249.238.243:29990';



			requestURILMS = '/v1/uc/user/syncOlympusUnit';
			appSecretLMS = 'CAE1D68BE3EB4F7AB5FE97EBDD11B83E';
			@@ -158,7 +168,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';
			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=';
			@@ -174,6 +184,18 @@
			// 智慧医疗&服务新系统通信用户接口
			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';

			//先款后修
			NFM112_ENDPOINT = 'https://wdp.olympus.com.cn:44302/RESTAdapter/NFM112';
			//样本管理
			NFM115_ENDPOINT = 'https://wdp.olympus.com.cn:44302/RESTAdapter/NFM115';

			// 电子签收单SFDC2SAP thh 20220427 start
			NFM116_ENDPOINT = 'https://wdp.olympus.com.cn:44302/RESTAdapter/NFM116';
			// 电子签收单SFDC2SAP thh 20220427 end

			// 新服务系统
			AWS_DOMAIN = 'https://svc-elb.olympuschina.com';
			@@ -225,7 +247,27 @@
			webservice String timestamp;
			webservice String appKey;
			}

			// add to aws response sushanhu 20220224 start
			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;

			}
			// add to aws response sushanhu 20220224 end
			/**
			* @return yyyyMMdd の日付文字列
			*/
			@@ -338,7 +380,25 @@
			return rtn;
			}

			// lt 20220419 Start
			/**
			* @return yyyy/MM/dd の日付文字列
			*/
			public static String formatDateTime2StrSprit2(DateTime dt) {
			String rtn = null;
			if (dt == null) {
			rtn = '';
			} else {
			String pDate = formatDateTime2Str(dt);
			rtn = (pDate.substring(0, 4)) + '/' +
			(pDate.substring(4, 6)) + '/' +
			(pDate.substring(6, 8));
			}
			return rtn;
			}
			// lt 20220419 End

			/**
			* add wangweipeng 2022/02/11
			* [formatDateTime2StrDateTime description]
			* @param dt [日期/时间]
			@@ -372,7 +432,7 @@
			return parseStr2Date(pDateTime.substring(0, 8));
			}

			/**
			/**
			* add wangweipeng 2022/02/15
			* [parseStr2DateTime description]
			* @param pDate [日期（不包括时间）]
			@@ -413,13 +473,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());
			}
			@@ -449,10 +509,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());
			}
			@@ -490,7 +550,7 @@
			col = '';
			}
			rtn = transferMap.get(col + key);
			if (rtn == null) {
			if (!transferMap.containsKey(col + key)) { //lt 20220530 update
			iflog.ErrorLog__c += 'Warning! Please check [' + col + '] can not transfer key [' + key + ']\n';
			rtn = key;
			}
			@@ -598,7 +658,7 @@
			return rowData;
			}

			// public static BatchIF_Log__c makeRowDataToOnline(NFMUtil.MonitoringToOnline Monitoring, String NFMType, Object NFMData) {
			// 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;
			@@ -865,7 +925,30 @@
			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;
			@@ -903,10 +986,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

			@@ -927,8 +1010,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);
			@@ -986,6 +1069,51 @@
			//正常执行
			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 = String.valueof(response.getStatusCode());
			System.debug('response:' + response);
			//http：状态和code
			//如果状态不通过，则将状态及空的的数据，返回
			// if (String.isNotBlank(statusCode)) {
			// return new response(statusCode, null);
			// }
			System.debug('=====2======' + response.getBody());
			//正常执行
			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 = String.valueof(response.getStatusCode());
			System.debug('response:' + response);
			//http：状态和code
			//如果状态不通过，则将状态及空的的数据，返回
			// if (String.isNotBlank(statusCode)) {
			// return new response(statusCode, null);
			// }
			System.debug('=====2======' + response.getBody());
			//正常执行
			return new response(statusCode, response.getBody());
			}

			//接口3，获取其他附件
			public static response503 getFileData(String token503, String endpoint) {
			@@ -1032,7 +1160,7 @@
			public static String sendTenInfo(String token504, String jsonStr, String endpoint) {
			Http http = new Http();
			HttpRequest req = new HttpRequest();
			req.setEndpoint('http://cusdata.qianlima.com/test/v1/customer/albs/feedback');
			req.setEndpoint(endpoint);
			req.setHeader('open-authorization', 'Bearer' + token504);
			req.setHeader('Content-Type', 'application/x-www-form-urlencoded');
			req.setMethod('POST');
			@@ -1131,6 +1259,31 @@
			}
			return rowDataSFDC;
			}
			// 2022-12-06 zyh add start DB202211540694-重发只发自己
			public static BatchIF_Log__c LogAutoSend(BatchIF_Log__c rowDataSFDC, Exception ex, String status, Boolean check){
			Integer batch_retry_max_cnt = Integer.valueOf(System.Label.batch_retry_max_cnt);
			if (rowDataSFDC.retry_cnt__c == null) rowDataSFDC.retry_cnt__c = 0;
			if (rowDataSFDC.retry_cnt__c < batch_retry_max_cnt){
			rowDataSFDC.retry_cnt__c++;
			// 20230131 ljh start
			// LogAutoSendSchedule.logId = rowDataSFDC.Id; // 赋值本日志Id
			// LogAutoSendSchedule.messageGroupNumber = rowDataSFDC.MessageGroupNumber__c; // messagenum号赋值 2023-01-19 zyh add
			// LogAutoSendSchedule.type = rowDataSFDC.Type__c; // 赋值本日志type 2023-01-19 zyh add
			System.debug('NFM接口测试==========>Id：' + rowDataSFDC.Id + ';===MessageGroupNumber：' + rowDataSFDC.MessageGroupNumber__c + ';===Type' + rowDataSFDC.Type__c);
			// LogAutoSendSchedule.assignOneMinute();
			LogAutoSendSchedule.assignOneMinute(rowDataSFDC.MessageGroupNumber__c,rowDataSFDC.Type__c);
			// 20230131 ljh end
			}
			if (rowDataSFDC.retry_cnt__c >= batch_retry_max_cnt){
			if (ex == null) {
			rowDataSFDC.ErrorLog__c = status + '\n错误次数已经超过自动送信设定的最大次数，请手动送信';
			} else {
			rowDataSFDC.ErrorLog__c = ex.getMessage() + '\n' + ex.getStackTraceString() + '\n' + rowDataSFDC.ErrorLog__c+'错误次数已经超过自动送信设定的最大次数，请手动送信';
			}
			}
			return rowDataSFDC;
			}// 建议以后重发调用此方法
			// 2022-12-06 zyh add end DB202211540694-重发只发自己
			// https://oly.ngrok.kunchuangtech.net/api/sso/sfdc_activitydata
			//发送给共通平台精琢技术 thh 2021-09-22 start
			public static String sendToComPlat(String rowDataStr, String endpoint) {
			@@ -1150,10 +1303,76 @@
			system.debug('resb:' + resb);
			return resb;
			}


			//发送给共通平台精琢技术 thh 2021-09-22 end


			//zhj batch 调用624接口的时候需要调用AWS 2023-01-08 start
			public static void batchSendToAWS624(String rowDataId) {
			System.debug('enter batchSendToAWS624');
			BatchIF_Log__c rowData = [Select Id, Name, Log__c,Is_Error__c, ErrorLog__c, Log2__c, Log3__c, Log4__c, Log5__c, Log6__c, Log7__c, Log8__c, Log9__c, Log10__c, Log11__c, Log12__c, MessageGroupNumber__c, retry_cnt__c,NFM624_Secondary_processing__c from BatchIF_Log__c where RowDataFlg__c = true and Id =: rowDataId];
			String rowDataStr = getRowDataStr(rowData);
			List < NFM624Rest2.GeData > GeDataList = (List < NFM624Rest2.GeData > ) JSON.deserialize(rowDataStr, List < NFM624Rest2.GeData > .class);
			Http http = new Http();
			HttpRequest request = new HttpRequest();
			PIHelper.PIIntegration documentPI=PIHelper.getPIIntegrationInfo('Document');
			String hostUrl = documentPI.hostUrl;
			System.debug('GeDataList[0].nfm624RequestId = ' + GeDataList[0].nfm624RequestId);
			System.debug('documentPI.hostUrl = ' + documentPI.hostUrl);
			System.debug('documentPI.token = ' + documentPI.token);
			request.setEndpoint(hostUrl + '/api/nfm/reCallNFM624Batch?nfm624RequestId=' + GeDataList[0].nfm624RequestId + '&rowDataId=' + rowDataId);
			request.setMethod('GET');
			request.setHeader('pi-token',documentPI.token);
			HttpResponse response = http.send(request);
			System.debug('send batchSendToAWS624');
			}
			//zhj batch 调用624接口的时候需要调用AWS 2023-01-08 end

			//zhj 重新调用624接口的时候调用AWS 2023-01-11 start
			public static void againSendToAWS624(String rowDataId) {
			if(!Test.isRunningTest()){
			System.debug('enter againSendToAWS624');
			BatchIF_Log__c rowData = [Select Id, Name, Log__c,Is_Error__c, ErrorLog__c, Log2__c, Log3__c, Log4__c, Log5__c, Log6__c, Log7__c, Log8__c, Log9__c, Log10__c, Log11__c, Log12__c, MessageGroupNumber__c, retry_cnt__c,NFM624_Secondary_processing__c from BatchIF_Log__c where RowDataFlg__c = true and Id =: rowDataId];
			String rowDataStr = getRowDataStr(rowData);
			List < NFM624Rest2.GeData > GeDataList = (List < NFM624Rest2.GeData > ) JSON.deserialize(rowDataStr, List < NFM624Rest2.GeData > .class);
			Http http = new Http();
			HttpRequest request = new HttpRequest();
			PIHelper.PIIntegration documentPI=PIHelper.getPIIntegrationInfo('Document');
			String hostUrl = documentPI.hostUrl;
			System.debug('GeDataList[0].nfm624RequestId = ' + GeDataList[0].reCallNfm624RequestId);
			System.debug('documentPI.hostUrl = ' + documentPI.hostUrl);
			System.debug('documentPI.token = ' + documentPI.token);
			request.setEndpoint(hostUrl + '/api/nfm/reCallNFM624?reCallNfm624RequestId=' + GeDataList[0].reCallNfm624RequestId + '&rowDataId=' + rowDataId);
			request.setMethod('GET');
			request.setHeader('pi-token',documentPI.token);
			HttpResponse response = http.send(request);
			System.debug('send againSendToAWS624');
			}
			}
			//zhj 重新调用624接口的时候调用AWS 2023-01-11 end

			//zhj 新方案改造 624Batch更新日志将日志内容更新到rowdata里面 2023-01-09 start
			public static BatchIF_Log__c updateRowData(String rowDataId, Object NFMData) {
			BatchIF_Log__c rowData = [Select Id, Name, Log__c,Is_Error__c, ErrorLog__c, Log2__c, Log3__c, Log4__c, Log5__c, Log6__c, Log7__c, Log8__c, Log9__c, Log10__c, Log11__c, Log12__c, MessageGroupNumber__c, retry_cnt__c,NFM624_Secondary_processing__c from BatchIF_Log__c where Id =: rowDataId];
			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()));
			}
			}
			update rowData;
			return rowData;
			}
			//zhj 新方案改造 624Batch更新日志将日志内容更新到rowdata里面 2023-01-09 end

			public static Integer ControllerUtil() {
			Integer i = 0;
			i++;