@RestResource(urlMapping='/NFM004/*')
global with sharing class NFM004Rest implements Database.Batchable<sObject>{

    private final Id rowData_Id;
    private final Integer startIndex;
    private final Integer dataLength;
    private final Integer executeSize = 2000;

    global class PurchasePricesRest {
        public PurchasePrices PurchasePrices;
    }
    global class PurchasePrices {
        public NFMUtil.Monitoring Monitoring;
        public NFM004Rest.PurchasePrice[] PurchasePrice;
    }
    global class PurchasePrice {
        public String  PriceType;
        public String  SuppliersItemCode;
        public Decimal PurchasePrice_x;
        public String  Currency_x;
        public String  ReportedDateTime;                       // 受信しない
        public String  EffectiveDateFrom;
        public String  EffectiveDateTo;
        public String  PurposeOfAdvice;
    }
 @HttpPost
    global static void execute() {
         // 取得接口传输内容
        String strData = RestContext.request.requestBody.toString();
        PurchasePricesRest pps = (PurchasePricesRest) JSON.deserializeStrict(strData, PurchasePricesRest.class);

        if (pps == null ) {
            return;
        }
        NFMUtil.Monitoring Monitoring = pps.PurchasePrices.Monitoring;
        if (Monitoring == null) {
            return;
        }
        BatchIF_Log__c rowData = NFMUtil.saveRowData(Monitoring, 'NFM004', pps.PurchasePrices.PurchasePrice);
        if (pps.PurchasePrices.PurchasePrice == null || pps.PurchasePrices.PurchasePrice.size() == 0) {
            return;
        }
        NFM004Rest u = new NFM004Rest(rowData.Id, 0, pps.PurchasePrices.PurchasePrice.size());
        Database.executeBatch(u, 1);

        // JSONを戻す
        RestResponse res = RestContext.response;
        res.addHeader('Content-Type', 'application/json');
        res.statusCode = 200;
        //String jsonResponse = '{"status": "Success", "Message":'  + gedata + '}';
        String jsonResponse = '{"status": "Success", "Message":""}';
        res.responseBody = blob.valueOf(jsonResponse);
        return;
        
    }
    global NFM004Rest(){

    }
    global NFM004Rest(Id rowData_Id, Integer startIndex, Integer dataLength) {
        this.rowData_Id = rowData_Id;
        this.startIndex = startIndex;
        this.dataLength = dataLength;
    }
    global Database.Querylocator start(Database.BatchableContext BC) {
        return Database.getQuerylocator([
            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
        ]);
    }
    // @future
    // global static void executefuture(String rowData_Id) {
    //     main(rowData_Id);
    // }
    global void execute(Database.BatchableContext BC, List<BatchIF_Log__c> scope) {
        BatchIF_Log__c rowData = scope[0];
        String logstr = rowData.MessageGroupNumber__c + ' ' + startIndex + '/' + dataLength + ' start\n';
        BatchIF_Log__c iflog = new BatchIF_Log__c();
        iflog.Type__c = 'NFM004';
        iflog.MessageGroupNumber__c = rowData.MessageGroupNumber__c;
        iflog.Log__c = logstr;
        iflog.ErrorLog__c = '';
        insert iflog;
        String rowDataStr = NFMUtil.getRowDataStr(rowData);
        List<PurchasePrice> purchasePriceList2 = (List<PurchasePrice>) JSON.deserialize(rowDataStr, List<PurchasePrice>.class);
        if (purchasePriceList2 == null || purchasePriceList2.size() == 0) {
            return;
        }
        List<PurchasePrice> purchasePriceList = new List<PurchasePrice>();
        List<String> productCodeList = new List<String>();
        for (Integer i = startIndex; (i < startIndex + executeSize && i < purchasePriceList2.size()); i++) {
            purchasePriceList.add(purchasePriceList2.get(i));
            List<String> slicList = new List<String>();
            String Cache =  purchasePriceList2.get(i).SuppliersItemCode;
            if(String.isBlank(Cache) == false){
                slicList = Cache.split(',');
            }
            if(slicList.size()>0){
                String Slice = slicList[0];
                if (String.isBlank(Slice) == false) {
                    productCodeList.add(Slice);
                }
            }else{
                if (String.isBlank(purchasePriceList2.get(i).SuppliersItemCode) == false) {
                    productCodeList.add(purchasePriceList2.get(i).SuppliersItemCode);
                }
            }
            
        }
        logstr += 'Execute Record:' + purchasePriceList.size() + '\n';

        Savepoint sp = Database.setSavepoint();
        try {
            // 更新対応配列とMapなどをセット
            Map<String, Product2> prdsMap = new Map<String, Product2>();
            for (Product2 prd : [select Id, ProductCode, ProductCode_Ext__c,
                                             Intra_Trade_Cost_RMB_1__c,
                                             Intra_Trade_Cost_RMB_Date1__c,
                                             Intra_Trade_Cost_RMB_End_Date1__c,
                                             Intra_Trade_Cost_RMB_2__c,
                                             Intra_Trade_Cost_RMB_Date2__c,
                                             Intra_Trade_Cost_RMB_End_Date2__c,
                                             Foreign_Trade_Cost_US_1__c,
                                             Foreign_Trade_Cost_US_Date1__c,
                                             Foreign_Trade_Cost_US_End_Date1__c,
                                             Foreign_Trade_Cost_US_2__c,
                                             Foreign_Trade_Cost_US_Date2__c,
                                             Foreign_Trade_Cost_US_End_Date2__c,
                                             Intra_Trade_Cost_US__c,
                                             Intra_Trade_Cost_US_Date__c,
                                             Intra_Trade_Cost_US_End_Date__c,
                                             Foreign_Trade_Cost_RMB__c,
                                             Foreign_Trade_Cost_RMB_Date__c,
                                             VenderNumber__c,
                                             Foreign_Trade_Cost_RMB_End_Date__c
                                        from Product2
                                       where ProductCode_Ext__c in :productCodeList]
                                        //经调查，MDM接口过来的数据，手动登录区分是false，没有更新为true的程序，所以，手动登陆区分应该是
                                        //手动导入数据时，手工勾上的。
                                        //经确认，主数据无需判断是否手动登录区分，请将SFDC中手动登录区分的判断去掉。
                                        //and Manual_Entry__c = False]
            ) {
                prdsMap.put(prd.ProductCode_Ext__c, prd);
            }
            
            // 更新対応配列をセット
            Map<String, Product2> prdUpdateMap = new Map<String, Product2>();
            for (NFM004Rest.PurchasePrice PurchasePrice : purchasePriceList) {
                // deleteの場合、有効期限日に前日をセット
                if (PurchasePrice.PurposeOfAdvice == '1') {
                    PurchasePrice.EffectiveDateTo = NFMUtil.formatDate2Str(Date.today().addDays(-1));
                }

                // 必須項目がない場合、処理と飛ばす
                if (PurchasePrice.SuppliersItemCode == null || PurchasePrice.SuppliersItemCode == '') {
                    iflog.ErrorLog__c += 'SuppliersItemCode is required\n';
                    continue;
                }
                /************************************************************************************/
                //          添加针对供应商的判断   Start
                /************************************************************************************/
                String SuppliersIC = '';
                String VenderNumber = '';
                List<String> SuppliersItemCodeList = new List<String>();
                if(String.isBlank(PurchasePrice.SuppliersItemCode) == false){
                    SuppliersItemCodeList = PurchasePrice.SuppliersItemCode.split(',');
                }
                //SuppliersIC = PurchasePrice.SuppliersItemCode;

                if(SuppliersItemCodeList.size()==2){
                    if(SuppliersItemCodeList[0]=='' || SuppliersItemCodeList[0]==null){
                        iflog.ErrorLog__c += 'inputString is lack of SuppliersItemCode \n';
                    }else{
                        SuppliersIC = SuppliersItemCodeList[0];
                    }
                    if(SuppliersItemCodeList[1]=='' || SuppliersItemCodeList[1]==null){
                        iflog.ErrorLog__c += 'inputString is lack of VenderNumber \n';
                    }else{
                        VenderNumber = SuppliersItemCodeList[1];
                    }
                }else{
                    SuppliersIC = PurchasePrice.SuppliersItemCode;
                    iflog.ErrorLog__c += 'Version is unCorrect \n';
                    //continue;
                }
                /************************************************************************************/
                //          添加针对供应商的判断   END
                /************************************************************************************/
                /************************************************************************************/
                //          将SuppliersItemCode替换成SuppliersIC   Start
                /************************************************************************************/

                if (PurchasePrice.PriceType == null || PurchasePrice.PriceType == '') {
                    iflog.ErrorLog__c += '[' + SuppliersIC + ']PriceType is required\n';
                    continue;
                }
                if (PurchasePrice.PurchasePrice_x == null) {
                    iflog.ErrorLog__c += '[' + SuppliersIC + ']PurchasePrice_x is required\n';
                    continue;
                }
                if (PurchasePrice.Currency_x == null || PurchasePrice.Currency_x == '') {
                    iflog.ErrorLog__c += '[' + SuppliersIC + ']Currency is required\n';
                    continue;
                }
                if (PurchasePrice.EffectiveDateFrom == null || PurchasePrice.EffectiveDateFrom == '') {
                    iflog.ErrorLog__c += '[' + SuppliersIC + ']EffectiveDateFrom is required\n';
                    continue;
                }
                if (PurchasePrice.EffectiveDateTo == null || PurchasePrice.EffectiveDateTo == '') {
                    iflog.ErrorLog__c += '[' + SuppliersIC + ']EffectiveDateTo is required\n';
                    continue;
                }

                Product2 prd = prdsMap.get(SuppliersIC);
                if (prd == null) {
                    // 更新対象商品がない場合
                    iflog.ErrorLog__c += 'Product[' + SuppliersIC + ']NotExist\n';
                    continue;
                }

                // 項目転送のセット
                prd.ProductCode = SuppliersIC;
                prd.VenderNumber__c = VenderNumber;
                if (prdUpdateMap.get(prd.ProductCode) == null) {
                    prdUpdateMap.put(prd.ProductCode, prd);
                    logstr += SuppliersIC + ' ';
                } else {
                    prd = prdUpdateMap.get(prd.ProductCode);
                }
                /************************************************************************************/
                //          将SuppliersItemCode替换成SuppliersIC   END
                /************************************************************************************/
                Date dateFrom = NFMUtil.parseStr2Date(PurchasePrice.EffectiveDateFrom, false);
                Date dateTo = NFMUtil.parseStr2Date(PurchasePrice.EffectiveDateTo, true);
                if (PurchasePrice.PriceType == 'OCM-001' && PurchasePrice.Currency_x == 'RMB') {
                    if (prd.Intra_Trade_Cost_RMB_1__c == null || prd.Intra_Trade_Cost_RMB_End_Date1__c < Date.today() || prd.Intra_Trade_Cost_RMB_Date1__c == dateFrom) {
                        prd.Intra_Trade_Cost_RMB_1__c          = PurchasePrice.PurchasePrice_x;
                        prd.Intra_Trade_Cost_RMB_Date1__c      = dateFrom;
                        prd.Intra_Trade_Cost_RMB_End_Date1__c  = dateTo;
                    } else if (prd.Intra_Trade_Cost_RMB_2__c == null || prd.Intra_Trade_Cost_RMB_End_Date2__c < Date.today() || prd.Intra_Trade_Cost_RMB_Date2__c == dateFrom) {
                        prd.Intra_Trade_Cost_RMB_2__c          = PurchasePrice.PurchasePrice_x;
                        prd.Intra_Trade_Cost_RMB_Date2__c      = dateFrom;
                        prd.Intra_Trade_Cost_RMB_End_Date2__c  = dateTo;
                    } else if (prd.Intra_Trade_Cost_RMB_Date1__c < prd.Intra_Trade_Cost_RMB_Date2__c) {
                        prd.Intra_Trade_Cost_RMB_1__c          = PurchasePrice.PurchasePrice_x;
                        prd.Intra_Trade_Cost_RMB_Date1__c      = dateFrom;
                        prd.Intra_Trade_Cost_RMB_End_Date1__c  = dateTo;
                    } else {
                        prd.Intra_Trade_Cost_RMB_2__c          = PurchasePrice.PurchasePrice_x;
                        prd.Intra_Trade_Cost_RMB_Date2__c      = dateFrom;
                        prd.Intra_Trade_Cost_RMB_End_Date2__c  = dateTo;
                    }
                } else if (PurchasePrice.PriceType == 'OHC-001' && PurchasePrice.Currency_x == 'USD') {
                    if (prd.Foreign_Trade_Cost_US_1__c == null || prd.Foreign_Trade_Cost_US_End_Date1__c < Date.today() || prd.Foreign_Trade_Cost_US_Date1__c == dateFrom) {
                        prd.Foreign_Trade_Cost_US_1__c         = PurchasePrice.PurchasePrice_x;
                        prd.Foreign_Trade_Cost_US_Date1__c     = dateFrom;
                        prd.Foreign_Trade_Cost_US_End_Date1__c = dateTo;
                    } else if (prd.Foreign_Trade_Cost_US_2__c == null || prd.Foreign_Trade_Cost_US_End_Date2__c < Date.today() || prd.Foreign_Trade_Cost_US_Date2__c == dateFrom) {
                        prd.Foreign_Trade_Cost_US_2__c         = PurchasePrice.PurchasePrice_x;
                        prd.Foreign_Trade_Cost_US_Date2__c     = dateFrom;
                        prd.Foreign_Trade_Cost_US_End_Date2__c = dateTo;
                    } else if (prd.Foreign_Trade_Cost_US_Date1__c < prd.Foreign_Trade_Cost_US_Date2__c) {
                        prd.Foreign_Trade_Cost_US_1__c         = PurchasePrice.PurchasePrice_x;
                        prd.Foreign_Trade_Cost_US_Date1__c     = dateFrom;
                        prd.Foreign_Trade_Cost_US_End_Date1__c = dateTo;
                    } else {
                        prd.Foreign_Trade_Cost_US_2__c         = PurchasePrice.PurchasePrice_x;
                        prd.Foreign_Trade_Cost_US_Date2__c     = dateFrom;
                        prd.Foreign_Trade_Cost_US_End_Date2__c = dateTo;
                    }
                } else if (PurchasePrice.PriceType == 'OCM-001' && PurchasePrice.Currency_x == 'USD') {
                    prd.Intra_Trade_Cost_US__c             = PurchasePrice.PurchasePrice_x;
                    prd.Intra_Trade_Cost_US_Date__c        = dateFrom;
                    prd.Intra_Trade_Cost_US_End_Date__c    = dateTo;
                } else if (PurchasePrice.PriceType == 'OHC-001' && PurchasePrice.Currency_x == 'RMB') {
                    prd.Foreign_Trade_Cost_RMB__c          = PurchasePrice.PurchasePrice_x;
                    prd.Foreign_Trade_Cost_RMB_Date__c     = dateFrom;
                    prd.Foreign_Trade_Cost_RMB_End_Date__c = dateTo;
                }
            }
            List<Product2> prdList = prdUpdateMap.values();
            if (prdList.size() > 0) {
                StaticParameter.EscapeSyncProduct2Trigger = true;
                update prdList;
            }
            logstr += '\nend';
        } catch(Exception ex) {
            // エラーが発生した場合
            Database.rollback(sp);
            System.debug(Logginglevel.ERROR, 'NFM004_' + rowData.MessageGroupNumber__c + ':' + ex.getMessage());
            System.debug(Logginglevel.ERROR, 'NFM004_' + rowData.MessageGroupNumber__c + ':' + ex.getStackTraceString());
            logstr += '\n' + ex.getMessage();
            iflog.ErrorLog__c = ex.getMessage() + '\n' + ex.getStackTraceString() + '\n' + iflog.ErrorLog__c;
        }
        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 void finish(Database.BatchableContext BC) {
        if (startIndex + executeSize < dataLength) {
            NFM004Rest u = new NFM004Rest(rowData_Id, startIndex + executeSize, dataLength);
            Database.executeBatch(u, 1);
        }
    
    }
}