// Repair単位、差分？ or 全部？
|
// SAP側の送信タイミング？ GoldenTaxInvoiceNo が Repair単位一意ですか？ 必須ですか？
|
global class NFM107WebService {
|
// Integer batchsize = 200; 考量する必要がないと思います。
|
global class Invoice {
|
webservice NFMUtil.Monitoring Monitoring;
|
webservice NFM107WebService.GeneralData[] GeneralData;
|
}
|
global class GeneralData {
|
webservice String SFDCRepairNo;
|
webservice String InvoiceResource;
|
webservice String PayerNo;
|
webservice String BilltoPartyNo;
|
webservice String ReverseFlag;
|
webservice String InvoiceAmount;
|
webservice String AccuTotalCost;
|
webservice String AccuTotalInvoiceAmount;
|
webservice String GoldenTaxInvoiceNo;
|
webservice String GoldenTaxDate;
|
}
|
// 非同期を見せかけ、常にreturn void
|
webservice static void NFM107(NFM107WebService.Invoice Invoice) {
|
if (Invoice == null) {
|
return;
|
}
|
NFMUtil.Monitoring Monitoring = Invoice.Monitoring;
|
if (Monitoring == null) {
|
return;
|
}
|
BatchIF_Log__c rowData = NFMUtil.saveRowData(Monitoring, 'NFM107', Invoice.GeneralData);
|
if (String.isBlank(rowData.Log__c) == false) executefuture(rowData.Id);
|
}
|
|
@future
|
global static void executefuture(String rowData_Id) {
|
execute(rowData_Id);
|
}
|
global static void execute(String rowData_Id) {
|
Integer batch_retry_max_cnt = Integer.valueOf(System.Label.batch_retry_max_cnt);
|
BatchIF_Log__c rowData = [Select Id, Name, Log__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 from BatchIF_Log__c where RowDataFlg__c = true and Id = :rowData_Id];
|
String logstr = rowData.MessageGroupNumber__c + ' start\n';
|
BatchIF_Log__c iflog = new BatchIF_Log__c();
|
iflog.Type__c = 'NFM107';
|
iflog.MessageGroupNumber__c = rowData.MessageGroupNumber__c;
|
iflog.Log__c = logstr;
|
iflog.ErrorLog__c = '';
|
insert iflog;
|
String rowDataStr = NFMUtil.getRowDataStr(rowData);
|
List<GeneralData> generalDataList = (List<GeneralData>) JSON.deserialize(rowDataStr, List<GeneralData>.class);
|
if (generalDataList == null || generalDataList.size() == 0) {
|
return;
|
}
|
|
Savepoint sp = Database.setSavepoint();
|
try {
|
// 更新対応配列とMapなどをセット
|
List<String> accManagementCodeList = new List<String>();
|
List<String> receiptNoList = new List<String>();
|
List<String> mcManagementCodeList = new List<String>();
|
for (NFM107WebService.GeneralData iData : generalDataList) {
|
if (String.isBlank(iData.SFDCRepairNo)
|
|| String.isBlank(iData.GoldenTaxInvoiceNo)
|
) continue;
|
if (iData.InvoiceResource == '维修单')
|
receiptNoList.add(iData.SFDCRepairNo);
|
else if (iData.InvoiceResource == '维修合同')
|
mcManagementCodeList.add(iData.SFDCRepairNo);
|
else if (iData.InvoiceResource == '维修成本')
|
receiptNoList.add(iData.SFDCRepairNo);
|
else continue;
|
|
if (String.isBlank(iData.PayerNo) == false) {
|
accManagementCodeList.add(iData.PayerNo);
|
accManagementCodeList.add(NFMUtil.trimLeft(iData.PayerNo, '0'));
|
}
|
if (String.isBlank(iData.BilltoPartyNo) == false) {
|
accManagementCodeList.add(iData.BilltoPartyNo);
|
accManagementCodeList.add(NFMUtil.trimLeft(iData.BilltoPartyNo, '0'));
|
}
|
}
|
|
Map<String, Repair__c> recptsMap = new Map<String, Repair__c>();
|
Map<Id, Repair__c> recptsUpdMap = new Map<Id, Repair__c>();
|
for (Repair__c recpt : [
|
Select Id, Name, Billing_Amount__c, NFM107_MessageGroupNumber__c from Repair__c where Name IN :receiptNoList
|
]) {
|
recptsMap.put(recpt.Name, recpt);
|
}
|
|
Map<String, Maintenance_Contract__c> mcMap = new Map<String, Maintenance_Contract__c>();
|
Map<Id, Maintenance_Contract__c> mcUpdMap = new Map<Id, Maintenance_Contract__c>();
|
for (Maintenance_Contract__c mc : [
|
Select Id, Maintenance_Contract_No__c, Invoice_amount__c, NFM107_MessageGroupNumber__c from Maintenance_Contract__c where Maintenance_Contract_No__c IN :mcManagementCodeList
|
]) {
|
mcMap.put(mc.Maintenance_Contract_No__c, mc);
|
}
|
|
// 検索して顧客名を取得
|
Map<String, Account> accManagementCodeMap = new Map<String, Account>();
|
if (accManagementCodeList.size() > 0) {
|
for (Account acc : [select Id, Management_Code__c, Name from Account where Management_Code__c in :accManagementCodeList]) {
|
accManagementCodeMap.put(acc.Management_Code__c, acc);
|
}
|
}
|
|
Map<String, Repair_receipt__c> receiptMap = new Map<String, Repair_receipt__c>();
|
for (NFM107WebService.GeneralData iData : generalDataList) {
|
if (String.isBlank(iData.SFDCRepairNo)
|
|| String.isBlank(iData.GoldenTaxInvoiceNo)
|
) {
|
iflog.ErrorLog__c += 'GoldenTaxInvoiceNo[' + iData.GoldenTaxInvoiceNo + '], SFDCRepairNo[' + iData.SFDCRepairNo + ']Required\n';
|
continue;
|
}
|
// ManagementCodeから顧客名を取得
|
String payerId = null;
|
String billtoPartyId = null;
|
if (String.isBlank(iData.PayerNo) == false) {
|
if (accManagementCodeMap.containsKey(iData.PayerNo)) {
|
payerId = accManagementCodeMap.get(iData.PayerNo).Id;
|
} else if (accManagementCodeMap.containsKey(NFMUtil.trimLeft(iData.PayerNo, '0'))) {
|
payerId = accManagementCodeMap.get(NFMUtil.trimLeft(iData.PayerNo, '0')).Id;
|
} else {
|
iflog.ErrorLog__c += iData.GoldenTaxInvoiceNo + ':PayerNo[' + iData.PayerNo + ']NotExist\n';
|
}
|
}
|
if (String.isBlank(iData.BilltoPartyNo) == false) {
|
if (accManagementCodeMap.containsKey(iData.BilltoPartyNo)) {
|
billtoPartyId = accManagementCodeMap.get(iData.BilltoPartyNo).Id;
|
} else if (accManagementCodeMap.containsKey(NFMUtil.trimLeft(iData.BilltoPartyNo, '0'))) {
|
billtoPartyId = accManagementCodeMap.get(NFMUtil.trimLeft(iData.BilltoPartyNo, '0')).Id;
|
} else {
|
iflog.ErrorLog__c += iData.GoldenTaxInvoiceNo + ':BilltoPartyNo[' + iData.BilltoPartyNo + ']NotExist\n';
|
}
|
}
|
|
Decimal accuTotalInvoiceAmount = String.isBlank(iData.AccuTotalInvoiceAmount) ? null : Decimal.valueOf(iData.AccuTotalInvoiceAmount);
|
if (iData.InvoiceResource == '维修单') {
|
Repair__c rpr = recptsMap.get(iData.SFDCRepairNo);
|
if (rpr == null) {
|
iflog.ErrorLog__c += 'GoldenTaxInvoiceNo[' + iData.GoldenTaxInvoiceNo + '], 修理[' + iData.SFDCRepairNo + ']NotExist\n';
|
continue;
|
}
|
logstr += iData.SFDCRepairNo + ':' + iData.GoldenTaxInvoiceNo + ' ';
|
if (rpr.Billing_Amount__c != accuTotalInvoiceAmount) {
|
if (String.isBlank(rpr.NFM107_MessageGroupNumber__c)
|
|| Integer.valueOf(rpr.NFM107_MessageGroupNumber__c) <= Integer.valueOf(rowData.MessageGroupNumber__c)) {
|
rpr.Billing_Amount__c = accuTotalInvoiceAmount;
|
rpr.Invoice_Date__c = NFMUtil.parseStr2Date(iData.GoldenTaxDate);
|
recptsUpdMap.put(rpr.Id, rpr);
|
}
|
}
|
receiptMap.put(rpr.Id + ':' + iData.GoldenTaxInvoiceNo,
|
new Repair_receipt__c(
|
Name = iData.GoldenTaxInvoiceNo,
|
UniqueKey__c = rpr.Id + ':' + iData.GoldenTaxInvoiceNo,
|
Repair__c = rpr.Id,
|
Maintenance_Contract__c = System.Label.Olympus_Dummy_MC,
|
SFDCRepairNo__c = iData.SFDCRepairNo,
|
PayerNo__c = iData.PayerNo,
|
BilltoPartyNo__c = iData.BilltoPartyNo,
|
PayerNoAccount__c = payerId,
|
BilltoPartyNoAccount__c = billtoPartyId,
|
ReverseFlag__c = iData.ReverseFlag == 'X' ? true : false,
|
InvoiceAmount__c = String.isBlank(iData.InvoiceAmount) ? null : Decimal.valueOf(iData.InvoiceAmount),
|
AccuTotalCost__c = String.isBlank(iData.AccuTotalCost) ? null : Decimal.valueOf(iData.AccuTotalCost),
|
AccuTotalInvoiceAmount__c = accuTotalInvoiceAmount,
|
GoldenTaxDate__c = NFMUtil.parseStr2Date(iData.GoldenTaxDate),
|
MessageGroupNumber__c = rowData.MessageGroupNumber__c
|
)
|
);
|
}
|
else if (iData.InvoiceResource == '维修合同' || iData.InvoiceResource == ' 维修合同') {
|
Maintenance_Contract__c mc = mcMap.get(iData.SFDCRepairNo);
|
if (mc == null) {
|
iflog.ErrorLog__c += 'GoldenTaxInvoiceNo[' + iData.GoldenTaxInvoiceNo + '], 维修合同[' + iData.SFDCRepairNo + ']NotExist\n';
|
continue;
|
}
|
logstr += iData.SFDCRepairNo + ':' + iData.GoldenTaxInvoiceNo + ' ';
|
if (mc.Invoice_amount__c != accuTotalInvoiceAmount) {
|
if (String.isBlank(mc.NFM107_MessageGroupNumber__c)
|
|| Integer.valueOf(mc.NFM107_MessageGroupNumber__c) <= Integer.valueOf(rowData.MessageGroupNumber__c)) {
|
mc.Invoice_amount__c = accuTotalInvoiceAmount;
|
mc.Receipt_Date__c = NFMUtil.parseStr2Date(iData.GoldenTaxDate);
|
mcUpdMap.put(mc.Id, mc);
|
}
|
}
|
receiptMap.put(mc.Id + ':' + iData.GoldenTaxInvoiceNo,
|
new Repair_receipt__c(
|
Name = iData.GoldenTaxInvoiceNo,
|
UniqueKey__c = mc.Id + ':' + iData.GoldenTaxInvoiceNo,
|
Repair__c = System.Label.Olympus_Dummy_Repair,
|
Maintenance_Contract__c = mc.Id,
|
SFDCRepairNo__c = iData.SFDCRepairNo,
|
PayerNo__c = iData.PayerNo,
|
BilltoPartyNo__c = iData.BilltoPartyNo,
|
PayerNoAccount__c = payerId,
|
BilltoPartyNoAccount__c = billtoPartyId,
|
ReverseFlag__c = iData.ReverseFlag == 'X' ? true : false,
|
InvoiceAmount__c = String.isBlank(iData.InvoiceAmount) ? null : Decimal.valueOf(iData.InvoiceAmount),
|
AccuTotalCost__c = String.isBlank(iData.AccuTotalCost) ? null : Decimal.valueOf(iData.AccuTotalCost),
|
AccuTotalInvoiceAmount__c = accuTotalInvoiceAmount,
|
GoldenTaxDate__c = NFMUtil.parseStr2Date(iData.GoldenTaxDate),
|
MessageGroupNumber__c = rowData.MessageGroupNumber__c
|
)
|
);
|
}
|
else if (iData.InvoiceResource == '维修成本') {
|
Repair__c rpr = recptsMap.get(iData.SFDCRepairNo);
|
if (rpr == null) {
|
iflog.ErrorLog__c += 'AccuTotalCost[' + iData.AccuTotalCost + ']GoldenTaxDate[' + iData.GoldenTaxDate + '], 修理[' + iData.SFDCRepairNo + ']NotExist\n';
|
continue;
|
}
|
logstr += iData.SFDCRepairNo + ':' + iData.AccuTotalCost + ' ' + iData.GoldenTaxDate + ' ';
|
if (String.isBlank(rpr.NFM107_MessageGroupNumber__c)
|
|| Integer.valueOf(rpr.NFM107_MessageGroupNumber__c) <= Integer.valueOf(rowData.MessageGroupNumber__c)) {
|
rpr.Repair_cost__c = String.isBlank(iData.AccuTotalCost) ? null : Decimal.valueOf(iData.AccuTotalCost);
|
rpr.Repair_cost_date__c = NFMUtil.parseStr2Date(iData.GoldenTaxDate);
|
recptsUpdMap.put(rpr.Id, rpr);
|
}
|
}
|
else {
|
iflog.ErrorLog__c += 'SFDCRepairNo[' + iData.SFDCRepairNo + ']' + iData.InvoiceResource + ':Undefined\n';
|
continue;
|
}
|
}
|
if (receiptMap.size() > 0) {
|
upsert receiptMap.values() UniqueKey__c;
|
}
|
if (recptsUpdMap.size() > 0) {
|
update recptsUpdMap.values();
|
}
|
if (mcUpdMap.size() > 0) {
|
update mcUpdMap.values();
|
}
|
logstr += '\nend';
|
rowData.retry_cnt__c=0;
|
} catch (Exception ex) {
|
// エラーが発生した場合
|
Database.rollback(sp);
|
System.debug(Logginglevel.ERROR, 'NFM107_' + rowData.MessageGroupNumber__c + ':' + ex.getMessage());
|
System.debug(Logginglevel.ERROR, 'NFM107_' + rowData.MessageGroupNumber__c + ':' + ex.getStackTraceString());
|
logstr += '\n' + ex.getMessage();
|
iflog.ErrorLog__c = ex.getMessage() + '\n' + ex.getStackTraceString() + '\n' + iflog.ErrorLog__c;
|
if (rowData.retry_cnt__c == null) rowData.retry_cnt__c = 0;
|
if (rowData.retry_cnt__c < batch_retry_max_cnt){
|
rowData.retry_cnt__c++;
|
LogAutoSendSchedule.assignOneMinute();
|
} else {
|
rowData.ErrorLog__c = ex.getMessage() + '\n' + ex.getStackTraceString() + '\n' + rowData.ErrorLog__c+'错误次数已经超过自动送信设定的最大次数，请手动受信';
|
}
|
}
|
update rowData;
|
iflog.Log__c = logstr;
|
if (iflog.Log__c.length() > 131072) {
|
iflog.Log__c = iflog.Log__c.subString(0, 131065) + ' ...';
|
}
|
if (iflog.ErrorLog__c.length() > 32768) {
|
iflog.ErrorLog__c = iflog.ErrorLog__c.subString(0, 32760) + ' ...';
|
}
|
update iflog;
|
}
|
}
|
