public without sharing class SSBackorderBatch implements Database.Batchable<SObject>, Database.Stateful {
    public final List<Id> TEST_ID = null;
    private BatchIF_Log__c iflog;

    /**
     * コンスタント、パラメータを受け取る
     */
    public SSBackorderBatch(List<Id> testId) {
        TEST_ID = testId;
        System.debug('TEST_ID=' + TEST_ID);
        iflog = new BatchIF_Log__c();
        iflog.Type__c = 'PushNotification';
        iflog.Log__c  = 'SSBackorderBatch start\n';
        iflog.ErrorLog__c = '';
        insert iflog;
    }

    /**
     * startには、queryを実行、引合全件
     */
    public Database.QueryLocator start(Database.BatchableContext BC) {
        // 注残
        SS_Batch_Column_Mapping__c staMapping = SS_Batch_Column_Mapping__c.getValues('Statu_Achievements__c');
        // select項目を staMapping より生成
        Set<String> apiTempSet = new Set<String>();
        for (Integer i = 1; i <= SSOpportunityBatch.FIELDMAX; i++) {
            String lpadI = ('00' + i).right(3);
            String fromColumn = 'From_Column_' + lpadI + '__c';
            String apiStr = String.valueOf(staMapping.get(fromColumn));
            if (String.isBlank(apiStr) == false) {
                String ssColumn = 'SS_Column_' + lpadI + '__c';
                String ssApiStr = String.valueOf(staMapping.get(ssColumn));
                if (ssApiStr.toLowerCase().startsWith('statu_achievements__c.')) {
                    // 注残の項目を更新、変更があるかどうか判断するため、元データも取得
                    System.debug('ssApiStr=' + ssApiStr + ', substring(22)=' + ssApiStr.substring(22));
                    apiTempSet.add(ssApiStr.substring(22));
                }
            }
        }
        String staSql = SSOpportunityBatch.makeSql(staMapping, apiTempSet);

        //staSql += ' where OverviewStatus__c <> \'无效合同\' and (OverviewStatus__c <> \'订单完成\' or (SS_backorderID__c <> null and OverviewStatus_SS_IsEqual__c = false))';
        //*************************************************************************************************************//
        //
        //*************************************************************************************************************//
        staSql += ' where (( OverviewStatus__c <> \'无效合同\' and (OverviewStatus__c <> \'订单完成\' or (SS_backorderID__c <> null and OverviewStatus_SS_IsEqual__c = false))) or Forecast_Equal__c=false)  ';
        //      staSql += ' where OverviewStatus__c <> \'无效合同\' and OverviewStatus__c <> \'订单完成\'';
        if (TEST_ID <> null) {
            staSql += ' and id IN :TEST_ID';
        }
        System.debug('staSql=' + staSql);
        return Database.getQueryLocator(staSql);
    }

    public void execute(Database.BatchableContext BC, List<Statu_Achievements__c> staList) {
        System.debug('是否走方法-----');
        Map<Id, Statu_Achievements__c> updSelfMap = new Map<Id, Statu_Achievements__c>();
        List<SObject> insSSStaList = new List<SObject>();
        SS_Batch_Column_Mapping__c staMapping = SS_Batch_Column_Mapping__c.getValues('Statu_Achievements__c');
        Schema.SObjectType ssStaType = Schema.getGlobalDescribe().get(String.valueOf(staMapping.get('SS_TableName__c')));
        for (Statu_Achievements__c sta : staList) {
            // Statu_Achievements__cの場合、updSelfMap 必ずいれる
            updSelfMap.put(sta.Id, sta);
            SObject insSSSta = ssStaType.newSObject();
            insSSStaList.add(insSSSta);
            insSSSta.put('BackorderID__c', sta.Id);     // 設定しなくでも、入れる
            for (Integer i = 1; i <= SSOpportunityBatch.FIELDMAX; i++) {
                String lpadI = ('00' + i).right(3);
                String fromColumn = 'From_Column_' + lpadI + '__c';
                String apiStr = String.valueOf(staMapping.get(fromColumn));
                if (String.isBlank(apiStr) == false) {
                    String ssColumn = 'SS_Column_' + lpadI + '__c';
                    String ssApiStr = String.valueOf(staMapping.get(ssColumn));
                    if (ssApiStr.toLowerCase().startsWith('statu_achievements__c.')) {
                        // 注残の項目を更新、変更があるかどうか判断する
                        if (sta.get(ssApiStr.substring(22)) != sta.get(apiStr)) {
                            try {
                                sta.put(ssApiStr.substring(22), sta.get(apiStr));
                            } catch (Exception e) {
                                iflog.ErrorLog__c += 'ERROR [' + apiStr + '] => [' + ssApiStr + ']' + e.getMessage() + '\n';
                            }
                        }
                    } else {
                        try {
                            insSSSta.put(ssApiStr, SSOpportunityBatch.getValue(sta, apiStr));
                        } catch (Exception e) {
                            iflog.ErrorLog__c += 'ERROR ' + String.valueOf(staMapping.get('SS_TableName__c')) + ' [' + apiStr + '] => [' + ssApiStr + ']' + e.getMessage() + '\n';
                        }
                    }
                }
            }
        }
        //if (insSSStaList.size() > 0) insert insSSStaList;
        if (insSSStaList.size() > 0) {
            Database.SaveResult[] lsr = Database.insert(insSSStaList, false);
            for (Integer tIdx = 0; tIdx < lsr.size(); tIdx++) {
                Database.SaveResult sr = lsr[tIdx];
                if (!sr.isSuccess()) {
                    Database.Error emsg = sr.getErrors()[0];
                   // 2020-09-09  mzy update  日志修改 start
                    if (!String.valueOf(emsg.getStatusCode()).contains('INACTIVE_OWNER_OR_USER')) {
                      iflog.ErrorLog__c += 'ERROR ' + insSSStaList[tIdx].get('Order_no_without_0__c') + ' SS_Sta:' + emsg + '\n';
                    }
                  //  iflog.ErrorLog__c += 'ERROR ' + insSSStaList[tIdx].get('Order_no_without_0__c') + ' SS_Sta:' + emsg + '\n';
                 // 2020-09-09  mzy update  日志修改 end    
                }
            }
        }

        // SS_backorder_list__cのIDを注残に書き戻す
        for (SObject insSSSta : insSSStaList) {
            Id BackorderID = (Id) insSSSta.get('BackorderID__c');
            Statu_Achievements__c sa = updSelfMap.get(BackorderID);
            sa.SS_backorderID__c = (Id) insSSSta.get('Id');
        }
        if (updSelfMap.size() > 0) {
            // エラーをlogに書き出す
            List<Statu_Achievements__c> updSelfList = updSelfMap.values();
            Database.SaveResult[] lsr = Database.update(updSelfList, false);
            List<Statu_Achievements__c> reuseUpdateList = new List<Statu_Achievements__c>();
            System.debug('-=-=-=-=-=-='+lsr);
            for (Integer tIdx = 0; tIdx < lsr.size(); tIdx++) {
                Database.SaveResult sr = lsr[tIdx];
                if (!sr.isSuccess()) {
                    //wangweipeng   20210618   获取没有update的数据
                    reuseUpdateList.add(updSelfList[tIdx]);

                    //Database.Error emsg = sr.getErrors()[0];
                    //iflog.ErrorLog__c += 'ERROR ' + updSelfMap.values()[tIdx].Name + ' Statu_Achievements__c:' + emsg + '\n';
                }
            }
            //wangweipeng  20210618  如果update失败,重复更新，最多3次，如果失败记录日志  start 
            if(reuseUpdateList.size() > 0){
                reuseUpdate(reuseUpdateList,1);
            }
            //wangweipeng  20210618  如果update失败,重复更新，最多3次，如果失败记录日志  end 
        }
    }

    public void finish(Database.BatchableContext BC) {

        iflog.Log__c += '\nSSBackorderBatch end';
        String tmp = iflog.ErrorLog__c;
        if (tmp.length() > 65000) {
            tmp = tmp.substring(0, 65000);
            tmp += ' ...have more lines...';
            iflog.ErrorLog__c = tmp;
        }
        update iflog;
    }

    //wangweipeng  20210618  如果update失败,重复更新，最多3次，如果失败记录日志  start 
    //参数：updSelfList   要重新插入的数据     indexUpdate   第几次插入
    public void reuseUpdate(List<Statu_Achievements__c> updSelfList,Integer indexUpdate){
        System.debug('这是循环的第：'+indexUpdate+' 次。');
        Database.SaveResult[] lsr = Database.update(updSelfList, false);
        List<Statu_Achievements__c> reuseUpdateMap = new List<Statu_Achievements__c>();
        for (Integer tIdx = 0; tIdx < lsr.size(); tIdx++) {
            Database.SaveResult sr = lsr[tIdx];
            if (!sr.isSuccess()) {
                if(indexUpdate >= 3){
                    Database.Error emsg = sr.getErrors()[0];
                    iflog.ErrorLog__c += 'ERROR ' + updSelfList[tIdx].Name + ' Statu_Achievements__c:' + emsg + '\n';
                }else{
                    //获取没有update的数据
                    ID succId = sr.getId();
                    reuseUpdateMap.add(updSelfList[tIdx]);
                }
            }
        }
        if(indexUpdate < 3){
            indexUpdate ++;
            if(reuseUpdateMap != null && reuseUpdateMap.size() > 0){
                reuseUpdate(reuseUpdateMap,indexUpdate);
            }
        }
    }
    //wangweipeng  20210618  如果update失败,重复更新，最多3次，如果失败记录日志  end
}