public with sharing class CreateOpportunityTaskBatch implements Database.Batchable<SObject>, Database.Stateful {
    
    public final List<Id> TEST_ID = null;
    
    // 报错的询价ID
    public String logstr = '';

    // 报错信息
    public String errorstr = '';

    public List<String> emailMessages = new List<String>();

    public Integer totalCount = 0; // 总件数
    public Integer failedCount = 0; // 失败件数
    //Boolean isExecuteOPD = false; //20210203 zh SWAG-BXQDHZ 是否执行OPD,自动执行时为true     mzy  update SWAG-C4V6GU   询价任务派送时间更改
    Boolean  isNeedExecute = false; // mzy update  2021-07-13  SFDC-Batch合并

    public CreateOpportunityTaskBatch() {
    }
    //20210203 zh SWAG-BXQDHZ start
    public CreateOpportunityTaskBatch(Boolean tempOPD) {
        isNeedExecute = tempOPD; 
    }
    //20210203 zh SWAG-BXQDHZ end
    public CreateOpportunityTaskBatch(List<Id> testId) {
        TEST_ID = testId;
    }

    public Database.QueryLocator start(Database.BatchableContext BC) {
        // System.debug('CreateOpportunityTaskBatch start');
        
        // 销售本部（预测用）包含1，2，3，4，5，6；
        List<String> areas = new List<String>();
        areas.add('1.华北'); 
        areas.add('2.东北'); 
        areas.add('3.西北'); 
        areas.add('4.西南'); 
        areas.add('5.华东'); 
        areas.add('6.华南'); 
        String oppSql = 'select id,name,StageName,ForecastAccuracyObject__c,SalesdepartmentForecast__c,Account.Name,';
        oppSql += ' OwnerId,Owner.IsActive,Department_Name__c,AccountId,IsNextMonthOfVisit__c,OCM__c,Opportunity_Category__c,OCSMRMB_Without_Tax__c';
        //2021-08-10  mzy  update   SWAG-C5R6GW   询价任务新增字段  start
        oppSql += ',Competitor__c,Close_Forecasted_Date__c,Created_Day__c,StageName__c,Bid_Date__c,Closing_Bid_Date__c ';
        //2021-08-10  mzy  update  SWAG-C5R6GW   询价任务新增字段  end
        oppSql += ', OCSM_RMB_Without_Tax_1000__c '; //2022-2-28 yjk 【委托】【询价任务】询价任务派送时点字段记录增加
        oppSql += ' from Opportunity ';

        // 询价科室分类（Opportunity_Category__c） 是GI
        List<String> opportunityCategoryGI = new List<String>();
        opportunityCategoryGI.add('GI');
        opportunityCategoryGI.add('BF');
        opportunityCategoryGI.add('ET');
        // 询价科室分类（Opportunity_Category__c） 是SP
        List<String> opportunityCategorySP = new List<String>();
        opportunityCategorySP.add('GS');
        opportunityCategorySP.add('URO');
        opportunityCategorySP.add('GYN');
        opportunityCategorySP.add('OTH');
        opportunityCategorySP.add('ENT');

        if (TEST_ID != null && TEST_ID.size() > 0) {
            oppSql += ' where id in :TEST_ID';
        }else{
            oppSql += ' where StageName = \'引合\' and ForecastAccuracyObject__c = true';
            oppSql += ' and Competitor__c in (\'A\',\'B\',\'C\',\'D\',\'E\') '; //2021-11-22 yjk 增加判断条件 询价等级
            oppSql += ' and IsNextMonthOfVisit__c = false and SalesdepartmentForecast__c in :areas';
            // 5）客户为H层客户的询价
            // oppSql += ' and (OCM__c = \'H0\' or OCM__c = \'H1\')';
            // 6）预测合同金额超过设定值的询价（GI：200万以上，SP：100万以上）
            // oppSql += ' and ((Opportunity_Category__c in :opportunityCategoryGI and Wholesale_Price__c >= 2000000) or (Opportunity_Category__c in :opportunityCategorySP and Wholesale_Price__c >= 1000000))';
            // 7）未来两个月内预测成交的询价
            // 20210104 zh 询价被动任务修复 start

            //SWAG-C3J4U5 20210602 start rentx(注释掉了62,64行代码) （1and2and3）and(4 OR 5) 4是(H0 || H1)
            /*1.预测精度对象2.下月无拜访计划3.未来两个月内订货（预测OCSM签约日在未来两个内）4.H层客户询价5.大订单（GI 200万以上，SP 100万以上）*/
            //oppSql += ' and (OCM__c = \'H0\' or OCM__c = \'H1\' OR (Opportunity_Category__c in :opportunityCategoryGI and Wholesale_Price__c >= 2000000) OR (Opportunity_Category__c in :opportunityCategorySP and Wholesale_Price__c >= 1000000))';
            
            //SWAG-C3J4U5 20210602 end rentx

            // Integer nextMonth = Date.today().month()+1;
            // Integer nnextMonth = nextMonth+1;
            // oppSql += ' and (CALENDAR_MONTH(Close_Forecasted_Date__c) = :nextMonth or CALENDAR_MONTH(Close_Forecasted_Date__c) = :nnextMonth)';
            
            Date today  = date.today();
            //下月第一天
            Date nextMonthFirstDay = today.addMonths(2).toStartOfMonth();
            //下下月最后一天
            Date nnexMonthLastDay = today.addMonths(3).toStartOfMonth().addDays(-1);
            //半年后最后一天
            Date halfYearLastDay = today.addMonths(7).toStartOfMonth().addDays(-1);

            oppSql += ' and (((OCM__c = \'H0\' or OCM__c = \'H1\' )';
            oppSql += ' and (Close_Forecasted_Date__c >= :nextMonthFirstDay AND Close_Forecasted_Date__c <= :nnexMonthLastDay))';

            oppSql += ' or (((Opportunity_Category__c in :opportunityCategoryGI and OCSMRMB_Without_Tax__c >= 2000000) OR (Opportunity_Category__c in :opportunityCategorySP and OCSMRMB_Without_Tax__c >= 1000000))';
            oppSql += ' and (Close_Forecasted_Date__c >= :nextMonthFirstDay AND Close_Forecasted_Date__c <= :halfYearLastDay)))';
            // 20210104 zh 询价被动任务修复 end

            oppSql += ' and Bidding_Project_Name_Bid__r.subInfoType__c not in (\'3-3：开标公示\',\'3-4：候选人公示\',\'3-5：中标通知\',\'3-6：合同公告\')';
            
        }
        //2021-07-13  mzy  SWAG-C4V6GU   询价任务派送时间更改  改为  每月最后一天的  19:00   start
        //每月最后一天
        Date ThisMonthLastDay = Date.today().addMonths(1).toStartOfMonth().addDays(-1);
        //20210203 zh SWAG-BXQDHZ start   
        if (Date.today() != ThisMonthLastDay && isNeedExecute == true) {
            oppSql = 'select id from Opportunity where Name=\'\' and Name!=\'\' ';
        }
        //20210203 zh SWAG-BXQDHZ end
        //2021-07-13  mzy  SWAG-C4V6GU   询价任务派送时间更改  改为  每月最后一天的  19:00   end
        System.debug('oppSql'+oppSql);

        
        return Database.getQueryLocator(oppSql);
    }


    public void execute(Database.BatchableContext BC, List<Opportunity> oppList) {
        List<task__c>  insertTasks = new List<task__c>();

        Date today  = date.today();
        Date nextMonthFirstDay = today.addMonths(2).toStartOfMonth();
        //下下月最后一天
        Date nnexMonthLastDay = today.addMonths(3).toStartOfMonth().addDays(-1);
                // 询价科室分类（Opportunity_Category__c） 是GI
        List<String> opportunityCategoryGI = new List<String>();
        opportunityCategoryGI.add('GI');
        opportunityCategoryGI.add('BF');
        opportunityCategoryGI.add('ET');
        // 询价科室分类（Opportunity_Category__c） 是SP
        List<String> opportunityCategorySP = new List<String>();
        opportunityCategorySP.add('GS');
        opportunityCategorySP.add('URO');
        opportunityCategorySP.add('GYN');
        opportunityCategorySP.add('OTH');
        opportunityCategorySP.add('ENT');

        for (Opportunity opp : oppList){
            if(opp.Owner.IsActive){//2021-08-30 yjk 增加判断任务对应的用户必须为IsActive
                task__c newTask = new task__c();
                newTask.assignee__c = opp.OwnerId;
                newTask.OwnerId = opp.OwnerId;
                newTask.RecordTypeId = Schema.SObjectType.task__c.getRecordTypeInfosByDeveloperName().get('OpportunityFollow').getRecordTypeId();
                newTask.taskDifferent__c = '被动任务';
                newTask.Name = '用户拜访:' + opp.Account.Name; 
                newTask.account__c = opp.AccountId;
                newTask.OpportunityId__c = opp.Id;
                newTask.taskStatus__c = '01 分配';
                //2021-08-10  mzy  update   SWAG-C5R6GW   询价任务新增字段  start
                //询价等级（分配）：记录分配时点的询价等级
                //预测OCSM签约日（分配）：记录分配时点的预测签约日
                //询价状态 (分配) : 记录分配时点的询价状态
                //询价创建日 (分配) : 记录分配时点的询价创建日
                //询价招标日 (分配) : 记录分配时点的询价招标日
                //询价中标日 (分配) : 记录分配时点的询价中标日
                newTask.OppCompetitorDbt__c = opp.Competitor__c;
                newTask.CloseForecastedDateDbt__c = opp.Close_Forecasted_Date__c;
                newTask.OpportunityStatusDbt__c = opp.StageName__c;
                newTask.OppCreateDateDbt__c =opp.Created_Day__c;
                newTask.Bid_DateDbt__c =opp.Bid_Date__c;
                newTask.Closing_Bid_DateDbt__c =opp.Closing_Bid_Date__c;
                //2021-08-10  mzy  update   SWAG-C5R6GW   询价任务新增字段  end

                //2021-11-26 yjk 询价任务增加派发原因字段

                newTask.OCSM_RMB_Without_Tax_1000__c = opp.OCSM_RMB_Without_Tax_1000__c; //2022-2-28 yjk 【委托】【询价任务】询价任务派送时点字段记录增加

                if(opp.Close_Forecasted_Date__c >= nextMonthFirstDay && opp.Close_Forecasted_Date__c<= nnexMonthLastDay){
                    if(
                        (opp.OCM__c == 'H0' || opp.OCM__c == 'H1') && 
                        (
                            (opportunityCategoryGI.contains(opp.Opportunity_Category__c)  && opp.OCSMRMB_Without_Tax__c >= 2000000) 
                            ||
                            (opportunityCategorySP.contains(opp.Opportunity_Category__c) && opp.OCSMRMB_Without_Tax__c >= 1000000)
                            )){
                        newTask.distributeReason__c = 'H层次月预测大合同';
                    }else if(opp.OCM__c == 'H0' || opp.OCM__c == 'H1'){
                        newTask.distributeReason__c = 'H层次月预测';
                    }else{
                        newTask.distributeReason__c = '非H层次月预测大合同';
                    }
                    
                }else{
                    newTask.distributeReason__c = '半年大合同';
                }
                insertTasks.add(newTask);
            }
        }
        if (insertTasks.size() > 0) {
            Database.SaveResult[] saveResults = Database.insert(insertTasks,false);
            totalCount = + saveResults.size();
            for (Integer i = 0; i < saveResults.size(); i++) {
                if (!saveResults.get(i).isSuccess()) {
                    logstr += '询价:' + insertTasks.get(i).OpportunityId__c + ' ,';
                    errorstr += saveResults.get(i).getErrors() + '\n';
                    failedCount ++;
                }
            }
        }
        // insert insertTasks;
    }

    public void finish(Database.BatchableContext BC) {
        BatchIF_Log__c batchIfLog = new BatchIF_Log__c();
        batchIfLog.Type__c = 'CreateOpportunityTaskBatch';
        if (logstr.length() > 60000) {
            logstr = logstr.substring(0, 60000);
        }
        batchIfLog.Log__c = logstr;
        logstr += '\nBatchCreateOpportunityTaskEnd';
        if (errorstr.length() > 60000) {
            batchIfLog.ErrorLog__c = errorstr.substring(0, 60000);
        } else {
            batchIfLog.ErrorLog__c = errorstr.substring(0, errorstr.length());
        }
        insert batchIfLog;
        emailMessages.add('失败日志ID为：' + batchIfLog.Id);
        sendFieldEmail();
        //2021-07-13  mzy  SFDC-Batch合并  end
        //因为 询价任务派送时间 变为 每月最后一天的 19:00 故剔除Batch链     mzy  update
        //20210203 zh SWAG-BXQDHZ start
        //if(!test.isRunningTest() && isExecuteOPD == true){
        //    Database.executebatch(new CreatePassiveTaskBatch(true), 10);
        //}
        if(!Test.isRunningTest() &&IsNeedExecute==true){
          //batch里调用下一个batch时，希望跟原有的Schedule里面传的条数保持一致
           Id execBTId = Database.executebatch(new SubAuthorizedBatch(true),10);
        }
        //20210203 zh SWAG-BXQDHZ end
        //2021-07-13  mzy  SFDC-Batch合并  end
    }

    // 发送提醒邮件
    private void sendFieldEmail() {
        PretechBatchEmailUtil be = new PretechBatchEmailUtil();
        String[] toList = new String[] {UserInfo.getUserEmail()};
        String title = '创建询价对应的task失败';
        String[] ccList = new String[] {};
        if (System.Test.isRunningTest()) {
            be.successMail('', 1);
        }
        if (emailMessages.size() > 0 && failedCount > 0) {
            be.failedMail(toList, ccList, title,
                            String.join(this.emailMessages, '\n'),
                            totalCount, totalCount - failedCount, failedCount,'',true);
            if(!Test.isRunningTest())
                be.send();
        }
    }
}