/**
|
* 调用地址
|
* UpdateContractAimAmountHandler.SetAwaitToSendAWS
|
*/
|
public without sharing class NFM601Controller {
|
public static String logstr = '';
|
public static String status;
|
private static final String LOG_TYPE = 'NFM601';
|
public class NFM601 {
|
public GeDatas GeDatas;
|
}
|
public class GeDatas {
|
public NFMUtil.MonitoringToComPlat Monitoring;
|
public GeData[] GeData;
|
}
|
public class GeData {
|
public String ManageCode; //管理编码 SFDC的管理编码（医院/科室/经销商
|
public String ManageCode2; //智慧医疗编码 标识为经销商时，本字段不需要传输；SFDC新建医院或科室时本字段值为空；
|
public String Name; //名称
|
public String Identification; //标识 1:医院；2：科室；3：经销商
|
public String SalesBusinessDivision; //销售本部
|
public String State; //省(文本)
|
public String City; //市
|
public Boolean Status; //状态
|
// 医院
|
public String Alias1; //别名1
|
public String Alias2; //别名2
|
public String Abbreviation; //简称 （SFDC需新加字段）
|
public String Phone; //电话
|
public String ZIPCode; //邮编
|
public String Address; //地址
|
public String OCSMCategory; //OCSM分类
|
public String HospitalLevel; //政府等级
|
// 科室
|
public String DepartmentClass; //科室类别
|
public String HospitalCode; //关联医院
|
// 经销商
|
public String QuolifiedValidityDate; //三证资质最早有效期
|
public String ContractEndDate; //最晚合同有效期
|
}
|
|
|
|
//正常调用
|
@future(callout = true)
|
public static void callout(String iflog_Id, List < String > accountIdList) {
|
executefuture(iflog_Id, accountIdList);
|
}
|
//Batch调用
|
public static void executefuture(String iflog_Id, List < String > accountIdList) {
|
BatchIF_Log__c iflog = null;
|
Datetime nowDT = Datetime.now();
|
String nowStr = nowDT.format('yyyyMMddHHmmss');
|
|
if (String.isNotBlank(iflog_Id)) {
|
List < BatchIF_Log__c > iflogList = [Select Id, Name, Log__c, ErrorLog__c from BatchIF_Log__c where Id =: iflog_Id];
|
if (iflogList.size() > 0) {
|
iflog = iflogList.get(0);
|
iflog.ErrorLog__c = '';
|
} else {
|
iflog = new BatchIF_Log__c();
|
iflog.MessageGroupNumber__c = nowStr;
|
}
|
} else {
|
iflog = new BatchIF_Log__c();
|
iflog.MessageGroupNumber__c = nowStr;
|
}
|
|
|
NFMUtil.MonitoringToComPlat me = new NFMUtil.MonitoringToComPlat();
|
me.Tag = 'MSGH';
|
me.Sender = 'SFDC';
|
me.Receiver = '智慧医疗/服务新系统';
|
me.MessageType = LOG_TYPE;
|
me.MessageGroupNumber = nowStr; //iflog.Name;
|
if (String.isNotBlank(iflog.Name)) {
|
me.MessageGroupNumber = iflog.Name;
|
}
|
// me.NumberOfRecord = '' + qisIds.size();
|
me.TransmissionDateTime = nowStr;
|
me.Text = '';
|
String randomstr = NFMUtil.randomUUID(16);
|
Long timestamp = DateTime.now().getTime();
|
String timestampStr = String.valueOf(timestamp);
|
String getToken = NFMUtil.getToken(randomstr, timestamp);
|
me.API_RANDOM_STR = randomstr;
|
me.API_TIME = timestampStr;
|
me.API_TOKEN = getToken;
|
me.sign = NFMUtil.getSignMD5();
|
me.timestamp = timestampStr;
|
me.appKey = NFMUtil.appKeyLMS;
|
|
|
|
BatchIF_Log__c rowData = null;
|
|
//省
|
List < Address_Level__c > address_LevelList = [select Id, Name, Level1_Code__c from Address_Level__c];
|
Map < String, Address_Level__c > regionNameMap = new Map < String, Address_Level__c > ();
|
for (Address_Level__c level1: address_LevelList) {
|
regionNameMap.put(level1.Id, level1);
|
}
|
//市
|
List < Address_Level2__c > address_Level2List = [select Id, Name, Level2_Code__c from Address_Level2__c];
|
Map < String, Address_Level2__c > cityMap = new Map < String, Address_Level2__c > ();
|
for (Address_Level2__c level2: address_Level2List) {
|
cityMap.put(level2.Id, level2);
|
}
|
List < Account > accountList =
|
[
|
SELECT Id,
|
Name, //名称
|
Department_Name__c,
|
Parent.Name,
|
Management_Code__c, //管理编码
|
Salesdepartment_HP__c, //销售本部(医院)
|
Salesdepartment_Dept__c, //销售本部(科室)
|
Salesdepartment_DeptClass__c, //销售本部(科室分类)
|
State_Master__c, //省
|
State_Master__r.Name, //
|
State_Master__r.Level1_Code__c, //
|
City_Master__c, //市
|
City_Master__r.Name, //
|
City_Master__r.Level2_Code__c, //
|
Is_Active_Formula__c, //有效/无效（公式）
|
Address__c, //地址
|
OCM_Category__c, //OCSM分类(医院)
|
Phone, //电话
|
RecordType_DeveloperName__c, //客户记录类型_DeveloperName
|
Site, //别名1
|
Alias_Name2__c, //别名2
|
Ban_On_Use_Date__c, //禁用日期
|
Ban_On_Use_DateDD__c, //DD有效期至
|
Postal_Code__c, //邮政编码
|
RecordType.Name, //记录类型名称
|
RecordTypeId, //记录类型Id
|
Department_RecordType_Name__c, //科室分类名
|
Parent.Parent.Management_Code__c, //医院的 管理编码
|
Grade__c, //政府等级
|
PlatformCode__c, //智慧医疗编码
|
Abbreviation__c, //简称
|
Parent.Parent.State_Master__r.Level1_Code__c,
|
Parent.Parent.City_Master__r.Level2_Code__c,
|
Parent.ParentId, //医院Id
|
Parent.Parent.RecordTypeId //记录类型
|
FROM Account
|
WHERE(Id IN: accountIdList OR Parent.ParentId IN: accountIdList)
|
AND RecordTypeId != '01210000000QjCNAA0'
|
AND(Is_Active_Formula__c = '有效'
|
OR Is_Active_Formula__c = '无效')
|
ORDER BY Parent.ParentId, ParentId, Id
|
];
|
//数据拼装
|
GeDatas gds = new GeDatas();
|
gds.GeData = new List < GeData > ();
|
iflog.Log__c= iflog.Log__c == null? '':iflog.Log__c;
|
try {
|
// 获取经销商Id
|
Set < Id > agencySet = new Set < Id > ();
|
Map < Id, String > getLicenceEarliestMap = new Map < Id, String > ();
|
Map < Id, String > getAgencyContractLatestMap = new Map < Id, String > ();
|
for (Account acc: accountList) {
|
if ('01210000000Qem1AAC'.equals(acc.RecordTypeId)) {
|
agencySet.add(acc.Id);
|
}
|
}
|
if (agencySet.size() > 0) {
|
//查找 三证资质最早有效期(经销商)
|
getLicenceEarliestMap = getLicenceEarliestDate(agencySet);
|
//查找 最晚合同有效期（契约）（经销商）
|
getAgencyContractLatestMap = getAgencyContractLatestDate(agencySet);
|
}
|
for (Account acc: accountList) {
|
String level1_Code = acc.State_Master__r.Level1_Code__c;
|
String level2_Code = acc.City_Master__r.Level2_Code__c;
|
if (String.isNotBlank(acc.Parent.ParentId)) {
|
level1_Code = acc.Parent.Parent.State_Master__r.Level1_Code__c;
|
level2_Code = acc.Parent.Parent.City_Master__r.Level2_Code__c;
|
}
|
|
|
GeData gd = new GeData();
|
|
gd.ManageCode = acc.Management_Code__c; //管理编码 SFDC的管理编码（医院/科室/经销商)
|
gd.ManageCode2 = ''; //智慧医疗编码 标识为经销商时，本字段不需要传输；SFDC新建医院或科室时本字段值为空；
|
|
gd.Name = acc.Name; //名称
|
gd.Identification = ''; //标识 1:医院；2：科室；3：经销商
|
gd.SalesBusinessDivision = ''; //销售本部(经销商没有)
|
gd.State = String.isBlank(level1_Code) ? '' : level1_Code; //省(文本)
|
gd.City = String.isBlank(level2_Code) ? '' : level2_Code; //市
|
gd.Status = '有效'.equals(acc.Is_Active_Formula__c) ? true : false; //状态
|
|
// 医院
|
gd.Alias1 = ''; //别名1
|
gd.Alias2 = ''; //别名2
|
gd.Abbreviation = ''; //简称 （SFDC需新加字段）
|
gd.Phone = ''; //电话
|
gd.ZIPCode = ''; //邮编
|
gd.Address = ''; //地址
|
gd.OCSMCategory = ''; //OCSM分类
|
gd.HospitalLevel = ''; //政府等级
|
// 科室
|
gd.DepartmentClass = ''; //科室类别
|
gd.HospitalCode = ''; //关联医院
|
|
// 经销商
|
gd.QuolifiedValidityDate = ''; //三证资质最早有效期
|
gd.ContractEndDate = ''; //最晚合同有效期
|
|
|
String manageCode2 = String.isBlank(acc.PlatformCode__c) ? '' : acc.PlatformCode__c; //智慧医疗编码
|
// 医院
|
if ('01210000000QemGAAS'.equals(acc.RecordTypeId)) {
|
iflog.Log__c += '医院 ManageCode [ ' +gd.ManageCode + ' ]\n';
|
|
gd.Identification = '1';
|
gd.SalesBusinessDivision = acc.Salesdepartment_HP__c; //销售本部(医院)
|
gd.Alias1 = String.isBlank(acc.Site) ? '' : acc.Site; //别名1
|
gd.Alias2 = String.isBlank(acc.Alias_Name2__c) ? '' : acc.Alias_Name2__c; //别名2
|
gd.Abbreviation = String.isBlank(acc.Abbreviation__c) ? '' : acc.Abbreviation__c; //简称
|
gd.Phone = String.isBlank(acc.Phone) ? '' : acc.Phone; //电话
|
gd.ZIPCode = String.isBlank(acc.Postal_Code__c) ? '000000' : acc.Postal_Code__c; //邮编
|
gd.Address = String.isBlank(acc.Address__c) ? '' : acc.Address__c; //地址
|
gd.ManageCode2 = manageCode2; //智慧医疗编码
|
gd.OCSMCategory = acc.OCM_Category__c; //OCSM分类(医院)
|
gd.HospitalLevel = acc.Grade__c; //政府等级
|
}
|
|
// 经销商
|
if ('01210000000Qem1AAC'.equals(acc.RecordTypeId)) {
|
iflog.Log__c += '经销商 ManageCode [ ' +gd.ManageCode + ' ]\n';
|
|
gd.Identification = '3';
|
String quolifiedValidityDate = getLicenceEarliestMap.get(acc.Id) == null ? '00000000' : getLicenceEarliestMap.get(acc.Id);
|
gd.QuolifiedValidityDate = quolifiedValidityDate; //三证资质最早有效期
|
String contractEndDate = getAgencyContractLatestMap.get(acc.Id) == null ? '00000000' : getAgencyContractLatestMap.get(acc.Id);
|
gd.ContractEndDate = contractEndDate; //最晚合同有效期
|
}
|
// 科室
|
if ('01210000000QemGAAS'.equals(acc.Parent.Parent.RecordTypeId)) {
|
iflog.Log__c += '科室 ManageCode [ ' +gd.ManageCode + ' ]\n';
|
|
gd.Name = acc.Parent.Name +' ' +acc.Department_Name__c;
|
|
gd.DepartmentClass = ''; //科室类别
|
String departmentClass = acc.Department_RecordType_Name__c;
|
if (String.isNotBlank(departmentClass) && departmentClass.contains('.')) {
|
gd.DepartmentClass = departmentClass.substring(2, departmentClass.length());
|
}
|
gd.Identification = '2';
|
gd.SalesBusinessDivision = acc.Salesdepartment_Dept__c; //销售本部(科室)
|
gd.HospitalCode = acc.Parent.Parent.Management_Code__c; //关联医院
|
gd.ManageCode2 = manageCode2; //智慧医疗编码
|
}
|
|
if (String.isNotBlank(gd.Identification)) {
|
gds.GeData.add(gd);
|
}
|
}
|
|
if (gds.GeData.size() > 0) {
|
me.NumberOfRecord = '' + gds.GeData.size();
|
gds.Monitoring = me;
|
iflog.Log__c += '\nNumberOfRecord=' + gds.GeData.size() + ' ';
|
|
|
NFMUtil.Monitoring Monitoring = new NFMUtil.Monitoring();
|
Monitoring.Tag = gds.Monitoring.Tag;
|
Monitoring.Sender = gds.Monitoring.Sender;
|
Monitoring.Receiver = gds.Monitoring.Receiver;
|
Monitoring.MessageType = gds.Monitoring.MessageType;
|
Monitoring.MessageGroupNumber = gds.Monitoring.MessageGroupNumber;
|
Monitoring.NumberOfRecord = gds.Monitoring.NumberOfRecord;
|
Monitoring.TransmissionDateTime = gds.Monitoring.TransmissionDateTime;
|
Monitoring.Text = '';
|
|
NFM601 nfm601 = new NFM601();
|
NFM601.GeDatas = new GeDatas();
|
NFM601.GeDatas = gds;
|
|
rowData = NFMUtil.makeRowData(Monitoring, LOG_TYPE, nfm601);
|
execute(rowData, iflog);
|
}
|
|
} catch (Exception ex) {
|
// エラーが発生した場合
|
logstr += ex.getMessage();
|
iflog.ErrorLog__c += ex.getMessage() + '\n';
|
iflog.ErrorLog__c += ex.getStackTraceString() + '\n';
|
}
|
if (rowData != null) {
|
upsert rowData;
|
}
|
iflog.Log__c = logstr;
|
upsert iflog;
|
|
}
|
|
/**
|
* 接口发送失败 根据BatchLogId进行手动发送
|
* @Author XHL
|
* @DateTime 2021-07-22
|
* @param rowDataId [BatchLogId]
|
*/
|
public static void ManualExecute(String rowDataId) {
|
List < BatchIF_Log__c > row = [select id, name, MessageGroupNumber__c, retry_cnt__c,
|
RowDataFlg__c, ErrorLog__c, Type__c,
|
Log__c, Log2__c, Log3__c, Log4__c, Log5__c, Log6__c,
|
Log7__c, Log8__c, Log9__c, Log10__c, Log11__c, Log12__c
|
from BatchIF_Log__c
|
where id =: rowDataId
|
];
|
if (row.size() > 0) NFM601Controller.execute(row[0], null);
|
}
|
/**
|
* 逻辑正常执行发送
|
* @Author XHL
|
* @DateTime 2021-07-22
|
* @param rowDataSFDC [BatchLogId]
|
* @param iflog [执行情况记录]
|
*/
|
public static void execute(BatchIF_Log__c rowDataSFDC, BatchIF_Log__c iflog) {
|
Integer batch_retry_max_cnt = Integer.valueOf(System.Label.batch_retry_max_cnt);
|
|
logstr += rowDataSFDC.MessageGroupNumber__c + ' start\n';
|
Boolean needUpdateIflog = false;
|
if (iflog == null) {
|
needUpdateIflog = true;
|
iflog = new BatchIF_Log__c();
|
iflog.Type__c = LOG_TYPE;
|
iflog.MessageGroupNumber__c = rowDataSFDC.MessageGroupNumber__c;
|
iflog.Log__c = logstr;
|
iflog.ErrorLog__c = '';
|
|
} else {
|
needUpdateIflog = true;
|
iflog.Type__c = LOG_TYPE;
|
iflog.MessageGroupNumber__c = rowDataSFDC.MessageGroupNumber__c;
|
logstr = iflog.Log__c;
|
}
|
|
try {
|
String data = NFMUtil.getRowDataStr(rowDataSFDC);
|
System.debug('data--------0>'+data);
|
|
String jsonReplace = JsonReplace(data);
|
if (String.isNotBlank(jsonReplace)) {
|
data = jsonReplace;
|
}
|
System.debug('data--------1>'+data);
|
status = NFMUtil.sendToSapRet(data, NFMUtil.NFM601_ENDPOINT);
|
if ('Accepted'.equals(status)) {
|
logstr += status + '\n';
|
rowDataSFDC.retry_cnt__c = 0;
|
logstr += 'end';
|
} else {
|
// 异常重发
|
rowDataSFDC = NFMUtil.LogAutoSend(rowDataSFDC, null, status);
|
}
|
System.debug('NFM601Log--status->' + status);
|
} catch (Exception ex) {
|
// TODO IOException
|
|
// 异常重发
|
// Callout from triggers are currently not supported.
|
if (!String.valueOf(ex.getMessage()).contains('Callout from triggers')) {
|
logstr += ex.getMessage();
|
iflog.ErrorLog__c += ex.getMessage() + '\n';
|
iflog.ErrorLog__c += ex.getStackTraceString() + '\n';
|
}
|
rowDataSFDC = NFMUtil.LogAutoSend(rowDataSFDC, ex, null);
|
}
|
iflog.Log__c = logstr;
|
if (needUpdateIflog) {
|
upsert iflog;
|
upsert rowDataSFDC;
|
}
|
|
|
}
|
|
//查找 三证资质最早有效期(经销商)
|
public static Map < Id, String > getLicenceEarliestDate(Set < Id > agencySet) {
|
Map < Id, String > result = new Map < Id, String > ();
|
|
List < License_Information__c > getLicenceList = [
|
SELECT Id, ValidFrom__c, LicenseAndAccount__c
|
FROM License_Information__c
|
WHERE LicenseAndAccount__c In: agencySet AND ValidFrom__c != null
|
ORDER BY LicenseAndAccount__c, ValidFrom__c desc
|
];
|
if (getLicenceList.size() > 0) {
|
for (License_Information__c li: getLicenceList) {
|
Id accountId = li.LicenseAndAccount__c;
|
String validFromStr = NFMUtil.formatDate2Str(li.ValidFrom__c);
|
result.put(accountId, validFromStr);
|
}
|
}
|
|
return result;
|
}
|
//查找 最晚合同有效期（契约）
|
public static Map < Id, String > getAgencyContractLatestDate(Set < Id > agencySet) {
|
Map < Id, String > result = new Map < Id, String > ();
|
|
List < Account > getAgencyContractList = [
|
SELECT Id, Name, Contract_End_Date__c, Agent_Ref__c
|
FROM Account
|
WHERE Agent_Ref__c IN: agencySet AND Contract_End_Date__c != null AND RecordTypeId = '01210000000QjCNAA0'
|
ORDER BY Agent_Ref__c, Contract_End_Date__c
|
];
|
if (getAgencyContractList.size() > 0) {
|
for (Account acc: getAgencyContractList) {
|
Id accountId = acc.Agent_Ref__c;
|
String contractEndDateStr = NFMUtil.formatDate2Str(acc.Contract_End_Date__c);
|
result.put(accountId, contractEndDateStr);
|
}
|
}
|
return result;
|
}
|
/**
|
* [因LMS系统timestamp有6分钟时效性，为了可以在系统宕机后，批量发送，用当前时间替换BatchLog日志里的timestamp的值]
|
* @param data [json字符串]
|
* @return [json字符串]
|
*/
|
public static String JsonReplace(String data){
|
|
List<String> jsonList = data.split(',');
|
System.debug('jsonList---->'+jsonList);
|
String jsonStr00 = '';
|
Integer num = 1;
|
String timestamp = String.valueOf(DateTime.now().getTime());
|
for(String str:data.split(',')){
|
if (str.contains('timestamp')) {
|
system.debug('str--->'+str);
|
str = '\"timestamp\"'+':'+'\"'+ timestamp +'\"';
|
}
|
jsonStr00 += str;
|
if (num++ != data.length()) {
|
jsonStr00 += ',';
|
}
|
|
}
|
String result = jsonStr00.substring(0,jsonStr00.length()-1);
|
System.debug('jsonStr00--->'+jsonStr00.substring(0,jsonStr00.length()-1));
|
return result;
|
}
|
}
|
