buli
2022-05-14 ead4df22dca33a867279471821ca675f91dec760
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
global class SBG004WebService {
    public class SBG004WebServiceException extends Exception {}
    private final Id rowData_Id;
 
    global class GeDatas {
        webservice NFMUtil.Monitoring Monitoring;
        webservice SBG004WebService.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 CostPrice;
        webservice String  EffectiveDateFrom;
        webservice String  EffectiveDateTo;
        webservice String  PurposeOfAdvice;
        webservice String  Other1;
        webservice String  Other2;
        webservice String  Other3;
    }
    webservice static void SBG004(GeDatas geDatas) {
        if (geDatas == null) {
            return;
        }
        NFMUtil.Monitoring Monitoring = GeDatas.Monitoring;
        if (Monitoring == null) {
            return;
        }
        BatchIF_Log__c rowData = NFMUtil.saveRowData(Monitoring, 'SBG004', GeDatas.GeData);
        if (GeDatas.GeData == null || GeDatas.GeData.size() == 0) {
            return;
        }
        rowData.retry_cnt__c = 1;
        update rowData;
        //SBG004WebService u = new SBG004WebService(rowData.Id, 0, GeDatas.GeData.size());
        //Database.executeBatch(u, 1);
        if (Test.isRunningTest()) {
            Id execBTId = Database.executeBatch(new LogAutoSendBatchProduct(), 4);
        }else{
            LogAutoSendScheduleProduct.assignOneMinute();
        }
        
    }
 
    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 = 'SBG004';
        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<String> productCodeList = new List<String>();
        List<String> prekeys = new List<String>();
        for (Integer i = 0; i <purchasePriceList2.size(); i++) 
        {    GeData data = purchasePriceList2[i];
            if (data.SalesChannel == '99') {
                prekeys.add(data.ProductSegment + '_' + data.TradeType + '_dealer_' + data.MachineParts + '_' + data.ProductCode + '_' + data.Currency_x);
                prekeys.add(data.ProductSegment + '_' + data.TradeType + '_direct_' + data.MachineParts + '_' + data.ProductCode + '_' + data.Currency_x);
            } else {
                String salesChannel = data.SalesChannel == '41' ? 'dealer' : 'direct';
                prekeys.add(data.ProductSegment + '_' + data.TradeType + '_' + salesChannel + '_' + data.MachineParts + '_' + data.ProductCode + '_' + data.Currency_x);
            }
            productCodeList.add(purchasePriceList2.get(i).ProductCode);
        }
 
        Map <String,PricebookEntry > premap = new Map<String,PricebookEntry >();
        for(PricebookEntry pre : [Select Id,Name,KEY__c,EffectiveDateFrom1__c,EffectiveDateFrom2__c,UnitPrice,
                                 EffectiveDateTo1__c,EffectiveDateTo2__c,CostPrice1__c,CostPrice2__c,SalesPrice1__c,SalesPrice2__c
                                 from PricebookEntry where KEY__c in:prekeys])
        {
            premap.put(pre.KEY__c,pre);
        }
 
        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);
        }
        System.debug('prebookis' + prebookmap);
 
 
        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);
        }
 
        Savepoint sp = Database.setSavepoint();
        try {
            List<PricebookEntry> pres = new List<PricebookEntry>();
            Set<String> updPresSet = new Set<String>();
 
            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) {
                    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;
                    }
 
                    if(data.SalesChannel == '99')
                    {
                        String pdedikey = data.ProductSegment + '_' + data.TradeType + '_' + 'direct' + '_' + data.MachineParts + '_' + data.ProductCode + '_' + data.Currency_x;
                        String pbedekey = data.ProductSegment + '_' + data.TradeType + '_' + 'dealer' + '_' + data.MachineParts + '_' + data.ProductCode + '_' + data.Currency_x;
                        String pddikey = data.ProductSegment + '_' + data.TradeType + '_' + 'direct' + '_' + data.MachineParts;
                        String pddekey = data.ProductSegment + '_' + data.TradeType + '_' + 'dealer' + '_' + data.MachineParts;
                        PricebookEntry pre1 = setpricebookec(data,premap,prdsMap.get(data.ProductCode).Id,prebookmap.get(pddikey),pdedikey,updPresSet);
                        PricebookEntry pre2 = setpricebookec(data,premap,prdsMap.get(data.ProductCode).Id,prebookmap.get(pddekey),pbedekey,updPresSet);
 
                        pres.add(pre1);
                        pres.add(pre2);
 
                    }
                    else {
                        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(pbekey);
                        System.debug(prebookmap);
 
                        PricebookEntry pre1 = setpricebookec(data,premap,prdsMap.get(data.ProductCode).Id,prebookmap.get(pbkey),pbekey,updPresSet);
                        pres.add(pre1);
                    }
 
                }
            }
      
            System.debug(logstr);
            logstr += 'Execute Record:' + pres.size() + '\n';
            if(pres.size()>0) {
                upsert(pres);
            }
            logstr += '\nend';
            rowData.retry_cnt__c = 0;
        } catch(Exception ex) {
            // エラーが発生した場合
            Database.rollback(sp);
            System.debug(ex);
            System.debug(Logginglevel.ERROR, 'SBG004_' + rowData.MessageGroupNumber__c + ':' + ex.getMessage());
            System.debug(Logginglevel.ERROR, 'SBG004_' + 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++;
                LogAutoSendScheduleProduct.assignOneMinute();
            }
            if (rowData.retry_cnt__c >= batch_retry_max_cnt){
                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;
    }
 
    global static PricebookEntry setpricebookec(GeData data,Map<String,PricebookEntry> premap,String productid,Pricebook2 pricebook2,String pbekey, Set<String> updPresSet) {
        System.debug('setpricebookec start productid=' + productid);
        System.debug('setpricebookec start Pricebook2id=' + pricebook2.Id);
        Date dateFrom = NFMUtil.parseStr2Date(data.EffectiveDateFrom, false);
        Date dateTo = NFMUtil.parseStr2Date(data.EffectiveDateTo, true);
        System.debug('fram' + dateFrom);
        System.debug('to' + dateTo);
        String curr = data.Currency_x == 'RMB' ? 'CNY' : data.Currency_x;
        System.debug('Currency_x is ' + curr);
        if (updPresSet.contains(pbekey))
        {
            throw new SBG004WebServiceException(pbekey + ' is doubled in message file.');
        }
 
        PricebookEntry pre = premap.get(pbekey);
        if(pre != null){
            System.debug('fram111' + pre.EffectiveDateFrom1__c);
            System.debug('to111' + pre.EffectiveDateTo1__c);
        }
 
        // TODO CurrencyIsoCode 等
        // UnitPrice = 0
        if (pre == null) {
            pre = new PricebookEntry(KEY__c =  pbekey,
                                     CostPrice1__c = data.CostPrice,
                                     CurrencyIsoCode = curr,
                                     EffectiveDateFrom1__c = dateFrom,
                                     EffectiveDateTo1__c = dateTo,
                                     UnitPrice = 0,
                                     Product2Id = productid,
                                     Pricebook2id = pricebook2.Id,
                                     isActive = pricebook2.isActive,
                                     UseStandardPrice = false);
        }
        else if (pre.EffectiveDateFrom1__c == null || pre.EffectiveDateTo1__c < Date.today() || pre.EffectiveDateFrom1__c == dateFrom) {
            pre = new PricebookEntry(KEY__c =  pbekey,
                                     Id = pre.Id,
                                     CostPrice1__c = data.CostPrice,
                                     CurrencyIsoCode = curr,
                                     EffectiveDateFrom1__c = dateFrom,
                                     EffectiveDateTo1__c = dateTo,
                                     UnitPrice = 0,
                                     Product2Id = productid,
                                     Pricebook2id = pricebook2.Id,
                                     isActive = pricebook2.isActive,
                                     UseStandardPrice = false);
        }
        else if(pre.EffectiveDateFrom2__c == null || pre.EffectiveDateTo2__c < Date.today() || pre.EffectiveDateFrom2__c == dateFrom) {
            pre = new PricebookEntry(KEY__c =  pbekey,
                                     Id = pre.Id,
                                     CostPrice2__c = data.CostPrice,
                                     CurrencyIsoCode = curr,
                                     EffectiveDateFrom2__c = dateFrom,
                                     EffectiveDateTo2__c = dateTo,
                                     UnitPrice = 0,
                                     Product2Id = productid,
                                     Pricebook2id = pricebook2.Id,
                                     isActive = pricebook2.isActive,
                                     UseStandardPrice = false);
        }
        else if(pre.EffectiveDateFrom1__c < pre.EffectiveDateFrom2__c) {
            pre = new PricebookEntry(KEY__c =  pbekey,
                                     Id = pre.Id,
                                     CostPrice1__c = data.CostPrice,
                                     CurrencyIsoCode = curr,
                                     EffectiveDateFrom1__c = dateFrom,
                                     EffectiveDateTo1__c = dateTo,
                                     UnitPrice = 0,
                                     Product2Id = productid,
                                     Pricebook2id = pricebook2.Id,
                                     isActive = pricebook2.isActive,
                                     UseStandardPrice = false);
        }
        else {
            pre = new PricebookEntry(KEY__c =  pbekey,
                                     Id = pre.Id,
                                     CostPrice2__c = data.CostPrice,
                                     CurrencyIsoCode = curr,
                                     EffectiveDateFrom2__c = dateFrom,
                                     EffectiveDateTo2__c = dateTo,
                                     UnitPrice = 0,
                                     Product2Id = productid,
                                     Pricebook2id = pricebook2.Id,
                                     isActive = pricebook2.isActive,
                                     UseStandardPrice = false);
        }
        updPresSet.add(pbekey);
        return pre;
    }
}