global class SBG005WebService {
|
public class SBG005WebServiceException extends Exception {}
|
private final Id rowData_Id;
|
|
global class GeDatas {
|
webservice NFMUtil.Monitoring Monitoring;
|
webservice SBG005WebService.GeData[] GeData;
|
}
|
global class GeData {
|
webservice String ProductCode;
|
webservice String Currency_x;
|
webservice String ProductSegment;
|
webservice String TradeType;
|
webservice String MachineParts;
|
webservice String SalesChannel;
|
webservice Decimal SalesPrice;
|
webservice String DealerDistinguish;
|
webservice String EffectiveDateFrom;
|
webservice String EffectiveDateTo;
|
webservice String PurposeOfAdvice;
|
webservice String Other1;
|
webservice String Other2;
|
webservice String Other3;
|
}
|
webservice static void SBG005(GeDatas geDatas) {
|
if (geDatas == null) {
|
return;
|
}
|
NFMUtil.Monitoring Monitoring = GeDatas.Monitoring;
|
if (Monitoring == null) {
|
return;
|
}
|
BatchIF_Log__c rowData = NFMUtil.saveRowData(Monitoring, 'SBG005', GeDatas.GeData);
|
if (GeDatas.GeData == null || GeDatas.GeData.size() == 0) {
|
return;
|
}
|
rowData.retry_cnt__c = 1;
|
update rowData;
|
//SBG005WebService u = new SBG005WebService(rowData.Id, 0, GeDatas.GeData.size());
|
//Database.executeBatch(u, 1);
|
if (Test.isRunningTest()) {
|
Id execBTId = Database.executeBatch(new LogAutoSendBatchProduct(), 4);
|
}
|
else{
|
LogAutoSendScheduleProduct.assignOneMinute();
|
}
|
}
|
|
/**
|
* batchコンスタント、パラメータを受け取る
|
*/
|
|
|
global static void execute(Database.BatchableContext BC, List<BatchIF_Log__c> scope) {
|
Integer batch_retry_max_cnt = Integer.valueOf(System.Label.batch_retry_max_cnt);
|
BatchIF_Log__c rowData = scope[0];
|
//String logstr = rowData.MessageGroupNumber__c + ' ' + startIndex + '/' + dataLength + ' start\n';
|
String logstr = '';
|
BatchIF_Log__c iflog = new BatchIF_Log__c();
|
iflog.Type__c = 'SBG005';
|
iflog.MessageGroupNumber__c = rowData.MessageGroupNumber__c;
|
//iflog.Log__c = logstr;
|
iflog.ErrorLog__c = '';
|
insert iflog;
|
String rowDataStr = NFMUtil.getRowDataStr(rowData);
|
List<GeData> purchasePriceList2 = (List<GeData>) JSON.deserialize(rowDataStr, List<GeData>.class);
|
if (purchasePriceList2 == null || purchasePriceList2.size() == 0) {
|
return;
|
}
|
List<GeData> purchasePriceList = new List<GeData>();
|
List<String> productCodeList = new List<String>();
|
for (Integer i = 0; i < purchasePriceList2.size(); i++) {
|
purchasePriceList.add(purchasePriceList2.get(i));
|
if (String.isBlank(purchasePriceList2.get(i).ProductCode) == false) {
|
productCodeList.add(purchasePriceList2.get(i).ProductCode);
|
}
|
}
|
|
Map<String, Product2> prdsMap = new Map<String, Product2>();
|
for (Product2 prd : [select Id, ProductCode, Product_ECCode__c,
|
EffectiveDateTo__c,
|
ProductModels__c,
|
ProductStatus__c
|
from Product2
|
where ProductModels__c = false and ProductCode in :productCodeList]
|
) {
|
prdsMap.put(prd.ProductCode, prd);
|
}
|
|
Map <String,Pricebook2 > prebookmap = new Map<String,Pricebook2 >();
|
|
for(Pricebook2 pre : [Select Id,Name,MachineParts__c,ProductSegment__c,SalesChannel__c,TradeType__c,isActive
|
from Pricebook2 where IsStandard = false])
|
{
|
prebookmap.put(pre.ProductSegment__c + '_' + pre.TradeType__c + '_' + pre.SalesChannel__c + '_' + pre.MachineParts__c,pre);
|
}
|
|
|
List<String> prekeys = new List<String>();
|
for(GeData data : purchasePriceList2)
|
{
|
String salesChannel = data.SalesChannel == '41' ? 'dealer' : 'direct';
|
String key = data.ProductSegment + '_' + data.TradeType + '_' + salesChannel + '_' + data.MachineParts + '_' + data.ProductCode + '_' + data.Currency_x;
|
prekeys.add(key);
|
}
|
system.debug('=====0:' + prekeys);
|
Map <String,PricebookEntry > premap = new Map<String,PricebookEntry >();
|
for(PricebookEntry pre : [Select Id,Name,KEY__c,EffectiveDateFrom1__c,EffectiveDateFrom2__c,EffectiveDateTo1__c,EffectiveDateTo2__c,
|
EffectiveDateFrom1_sales__c,EffectiveDateFrom1_sales_A__c,EffectiveDateFrom1_sales_B__c,EffectiveDateFrom1_sales_C__c,
|
EffectiveDateFrom2_sales__c,EffectiveDateFrom2_sales_A__c,EffectiveDateFrom2_sales_B__c,EffectiveDateFrom2_sales_C__c,
|
EffectiveDateTo1_sales__c,EffectiveDateTo1_sales_A__c,EffectiveDateTo1_sales_B__c,EffectiveDateTo1_sales_C__c,
|
EffectiveDateTo2_sales__c,EffectiveDateTo2_sales_A__c,EffectiveDateTo2_sales_B__c,EffectiveDateTo2_sales_C__c,
|
CostPrice1__c,CostPrice2__c,
|
SalesPrice1__c,SalesPrice1A__c,SalesPrice1B__c,SalesPrice1C__c,
|
SalesPrice2__c,SalesPrice2A__c,SalesPrice2B__c,SalesPrice2C__c
|
from PricebookEntry where KEY__c in:prekeys])
|
{
|
premap.put(pre.KEY__c,pre);
|
}
|
|
Savepoint sp = Database.setSavepoint();
|
try {
|
Map<String,PricebookEntry> updPresMap = new Map<String,PricebookEntry>();
|
for (Integer i = 0; i < purchasePriceList2.size(); i++)
|
{
|
//purchasePriceList.add(purchasePriceList2.get(i));
|
GeData data = purchasePriceList2.get(i);
|
if (data.PurposeOfAdvice == '1') {
|
data.EffectiveDateTo = NFMUtil.formatDate2Str(Date.today().addDays(-1));
|
}
|
if (String.isBlank(purchasePriceList2.get(i).ProductCode) == false)
|
{
|
//productCodeList.add(purchasePriceList2.get(i).ProductCode);
|
if (data.ProductCode == null || data.ProductCode == '') {
|
iflog.ErrorLog__c += 'ProductCode is required\n';
|
continue;
|
}
|
if (data.ProductSegment == null || data.ProductSegment == '') {
|
iflog.ErrorLog__c += '[' + data.ProductCode + ']PriceType is required\n';
|
continue;
|
}
|
if (data.Currency_x == null || data.Currency_x == '') {
|
iflog.ErrorLog__c += '[' + data.ProductCode + ']Currency is required\n';
|
continue;
|
}
|
if (data.EffectiveDateFrom == null || data.EffectiveDateFrom == '') {
|
iflog.ErrorLog__c += '[' + data.ProductCode + ']EffectiveDateFrom is required\n';
|
continue;
|
}
|
if (data.EffectiveDateTo == null || data.EffectiveDateTo == '') {
|
iflog.ErrorLog__c += '[' + data.ProductCode + ']EffectiveDateTo is required\n';
|
continue;
|
}
|
if(prdsMap.get(data.ProductCode) == null){
|
iflog.ErrorLog__c += 'Product[' + data.ProductCode + ']NotExist\n';
|
continue;
|
}
|
|
String salesChannel = data.SalesChannel == '41' ? 'dealer' : 'direct';
|
String pbekey = data.ProductSegment + '_' + data.TradeType + '_' + salesChannel + '_' + data.MachineParts + '_' + data.ProductCode + '_' + data.Currency_x;
|
String pbkey = data.ProductSegment + '_' + data.TradeType + '_' + salesChannel + '_' + data.MachineParts;
|
System.debug(prdsMap.get(data.ProductCode));
|
System.debug(prebookmap);
|
if(!prebookmap.keyset().contains(pbkey)){
|
iflog.ErrorLog__c += 'Pricebook2[' + pbkey + ']NotExist\n';
|
continue;
|
}
|
if(String.isBlank(prebookmap.get(pbkey).Id))
|
{
|
iflog.ErrorLog__c += 'Pricebook2[' + pbkey + ']NotExist\n';
|
continue;
|
}
|
System.debug('=====1:' + premap);
|
PricebookEntry pre1 = setpricebookec(data,premap,prdsMap.get(data.ProductCode).Id,prebookmap.get(pbkey),pbekey,updPresMap);
|
System.debug('=====2:' + pre1);
|
|
|
}
|
}
|
logstr += 'Execute Record:' + updPresMap.keySet().size() + '\n';
|
upsert(updPresMap.Values());
|
|
logstr += '\nend';
|
rowData.retry_cnt__c = 0;
|
} catch(Exception ex) {
|
// エラーが発生した場合
|
System.debug(Logginglevel.ERROR, 'SBG005_' + rowData.MessageGroupNumber__c + ':' + ex.getMessage());
|
System.debug(Logginglevel.ERROR, 'SBG005_' + rowData.MessageGroupNumber__c + ':' + ex.getStackTraceString());
|
Database.rollback(sp);
|
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++;
|
LogAutoSendScheduleProduct.assignOneMinute();
|
}
|
}
|
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;
|
}
|
|
global static PricebookEntry setpricebookec(GeData data,Map<String,PricebookEntry> premap,String productid,Pricebook2 pricebook2,String pbekey,Map<String,PricebookEntry> updPresMap)
|
{ System.debug(productid);
|
Date dateFrom = NFMUtil.parseStr2Date(data.EffectiveDateFrom, false);
|
Date dateTo = NFMUtil.parseStr2Date(data.EffectiveDateTo, true);
|
String curr = data.Currency_x == 'RMB' ? 'CNY' : data.Currency_x;
|
|
PricebookEntry pre = premap.get(pbekey);
|
if(updPresMap.containsKey(pbekey))
|
{
|
pre = updPresMap.get(pbekey);
|
}
|
System.debug('=====3' + pre);
|
String dea = String.isBlank(data.DealerDistinguish) ? '' : '_' + data.DealerDistinguish;
|
if (pre == null){
|
pre = new PricebookEntry(KEY__c = pbekey,
|
//SalesPrice1__c = data.SalesPrice,
|
DealerDistinguish_del__c = data.DealerDistinguish,
|
CurrencyIsoCode = curr,
|
//EffectiveDateFrom1_sales__c = dateFrom,
|
//EffectiveDateTo1_sales__c = dateTo,
|
UnitPrice = 0,
|
Product2Id = productid,
|
Pricebook2id = pricebook2.Id,
|
isActive = pricebook2.isActive,
|
UseStandardPrice = false);
|
if(String.isNotBlank(data.DealerDistinguish)){
|
pre.put('SalesPrice1' + data.DealerDistinguish + '__c',data.SalesPrice);
|
pre.put('EffectiveDateFrom1_sales_' + data.DealerDistinguish + '__c' , dateFrom);
|
pre.put('EffectiveDateTo1_sales_' + data.DealerDistinguish + '__c',dateTo);
|
}
|
else{
|
pre.put('SalesPrice1__c',data.SalesPrice);
|
pre.put('EffectiveDateFrom1_sales__c' , dateFrom);
|
pre.put('EffectiveDateTo1_sales__c',dateTo);
|
}
|
|
}
|
else if((Date)pre.get('EffectiveDateFrom1_sales' + dea + '__c') == null || (Date)pre.get('EffectiveDateTo1_sales' + dea + '__c') < Date.today() || (Date)pre.get('EffectiveDateFrom1_sales'+ dea + '__c') == dateFrom){
|
//pre = new PricebookEntry(KEY__c = pbekey,
|
// Id = pre.Id,
|
// //SalesPrice1__c = data.SalesPrice,
|
// DealerDistinguish_del__c = data.DealerDistinguish,
|
// CurrencyIsoCode = curr,
|
// //EffectiveDateFrom1_sales__c = dateFrom,
|
// //EffectiveDateTo1_sales__c = dateTo,
|
// UnitPrice = 0,
|
// Product2Id = productid,
|
// Pricebook2id = pricebook2.Id,
|
// isActive = pricebook2.isActive,
|
// UseStandardPrice = false);
|
pre.put('Id' , pre.Id);
|
pre.put('DealerDistinguish_del__c',data.DealerDistinguish);
|
pre.put('UnitPrice',0);
|
pre.put('isActive',pricebook2.isActive);
|
pre.put('UseStandardPrice',false);
|
if(String.isNotBlank(data.DealerDistinguish)){
|
pre.put('SalesPrice1' + data.DealerDistinguish + '__c',data.SalesPrice);
|
pre.put('EffectiveDateFrom1_sales_' + data.DealerDistinguish + '__c' , dateFrom);
|
pre.put('EffectiveDateTo1_sales_' + data.DealerDistinguish + '__c',dateTo);
|
}
|
else{
|
pre.put('SalesPrice1__c',data.SalesPrice);
|
pre.put('EffectiveDateFrom1_sales__c' , dateFrom);
|
pre.put('EffectiveDateTo1_sales__c',dateTo);
|
}
|
}
|
else if((Date)pre.get('EffectiveDateFrom2_sales' + dea + '__c') == null || (Date)pre.get('EffectiveDateTo2_sales' + dea + '__c') < Date.today() || (Date)pre.get('EffectiveDateFrom2_sales' + dea + '__c') == dateFrom){
|
//pre = new PricebookEntry(KEY__c = pbekey,
|
// Id = pre.Id,
|
// //SalesPrice2__c = data.SalesPrice,
|
// DealerDistinguish_del__c = data.DealerDistinguish,
|
// CurrencyIsoCode = curr,
|
// //EffectiveDateFrom2_sales__c = dateFrom,
|
// //EffectiveDateTo2_sales__c = dateTo,
|
// UnitPrice = 0,
|
// Product2Id = productid,
|
// Pricebook2id = pricebook2.Id,
|
// isActive = pricebook2.isActive,
|
// UseStandardPrice = false);
|
pre.put('Id' , pre.Id);
|
pre.put('DealerDistinguish_del__c',data.DealerDistinguish);
|
pre.put('UnitPrice',0);
|
pre.put('isActive',pricebook2.isActive);
|
pre.put('UseStandardPrice',false);
|
if(String.isNotBlank(data.DealerDistinguish)){
|
pre.put('SalesPrice2' + data.DealerDistinguish + '__c',data.SalesPrice);
|
pre.put('EffectiveDateFrom2_sales_' + data.DealerDistinguish + '__c' , dateFrom);
|
pre.put('EffectiveDateTo2_sales_' + data.DealerDistinguish + '__c',dateTo);
|
}
|
else{
|
pre.put('SalesPrice2__c',data.SalesPrice);
|
pre.put('EffectiveDateFrom2_sales__c' , dateFrom);
|
pre.put('EffectiveDateTo2_sales__c',dateTo);
|
}
|
}
|
else if((Date)pre.get('EffectiveDateFrom1_sales' + dea + '__c') < (Date)pre.get('EffectiveDateFrom2_sales' + dea + '__c')){
|
//pre = new PricebookEntry(KEY__c = pbekey,
|
// Id = pre.Id,
|
// //SalesPrice1__c = data.SalesPrice,
|
// DealerDistinguish_del__c = data.DealerDistinguish,
|
// CurrencyIsoCode = curr,
|
// //EffectiveDateFrom1_sales__c = dateFrom,
|
// //EffectiveDateTo1_sales__c = dateTo,
|
// UnitPrice = 0,
|
// Product2Id = productid,
|
// Pricebook2id = pricebook2.Id,
|
// isActive = pricebook2.isActive,
|
// UseStandardPrice = false);
|
pre.put('Id' , pre.Id);
|
pre.put('DealerDistinguish_del__c',data.DealerDistinguish);
|
pre.put('UnitPrice',0);
|
pre.put('isActive',pricebook2.isActive);
|
pre.put('UseStandardPrice',false);
|
if(String.isNotBlank(data.DealerDistinguish)){
|
pre.put('SalesPrice1' + data.DealerDistinguish + '__c',data.SalesPrice);
|
pre.put('EffectiveDateFrom1_sales_' + data.DealerDistinguish + '__c' , dateFrom);
|
pre.put('EffectiveDateTo1_sales_' + data.DealerDistinguish + '__c',dateTo);
|
}
|
else{
|
pre.put('SalesPrice1__c',data.SalesPrice);
|
pre.put('EffectiveDateFrom1_sales__c' , dateFrom);
|
pre.put('EffectiveDateTo1_sales__c',dateTo);
|
}
|
}
|
else{
|
//pre = new PricebookEntry(KEY__c = pbekey,
|
// Id = pre.Id,
|
// //SalesPrice2__c = data.SalesPrice,
|
// DealerDistinguish_del__c = data.DealerDistinguish,
|
// CurrencyIsoCode = curr,
|
// //EffectiveDateFrom2_sales__c = dateFrom,
|
// //EffectiveDateTo2_sales__c = dateTo,
|
// UnitPrice = 0,
|
// Product2Id = productid,
|
// Pricebook2id = pricebook2.Id,
|
// isActive = pricebook2.isActive,
|
// UseStandardPrice = false);
|
pre.put('Id' , pre.Id);
|
pre.put('DealerDistinguish_del__c',data.DealerDistinguish);
|
pre.put('UnitPrice',0);
|
pre.put('isActive',pricebook2.isActive);
|
pre.put('UseStandardPrice',false);
|
if(String.isNotBlank(data.DealerDistinguish)){
|
pre.put('SalesPrice2' + data.DealerDistinguish + '__c',data.SalesPrice);
|
pre.put('EffectiveDateFrom2_sales_' + data.DealerDistinguish + '__c' , dateFrom);
|
pre.put('EffectiveDateTo2_sales_' + data.DealerDistinguish + '__c',dateTo);
|
}
|
else{
|
pre.put('SalesPrice2__c',data.SalesPrice);
|
pre.put('EffectiveDateFrom2_sales__c' , dateFrom);
|
pre.put('EffectiveDateTo2_sales__c',dateTo);
|
}
|
}
|
updPresMap.put(pbekey,pre);
|
return pre;
|
}
|
|
}
|
