global class OPDPlanMarkBatch implements Database.Batchable<sObject>, Database.Stateful {
    //SWAG-BA65JL 2019/03/22   XHL AddStart
    public static Integer FIELDMAX = 200;
    //String query;
    List<String> oPDPlanIds = null;
    private BatchIF_Log__c iflog;
    private String thismonth_Lastday;

    global OPDPlanMarkBatch() {
        // CHAN-BBW5DQ 20190507 LHJ Start
        //thismonth_Lastday = String.valueOf(Date.toDay().addMonths(1).toStartOfMonth().addDays(-1));
        thismonth_lastday = String.valueOf(Date.toDay().addMonths(-1).toStartOfMonth());
        // CHAN-BBW5DQ LHJ 20190507  End
        iflog = new BatchIF_Log__c();
        iflog.Type__c = 'PushNotification';
        iflog.Log__c  = 'OPDPlanMarkBatch start\n';
        iflog.ErrorLog__c = '';
        insert iflog;
    }
    //  格式 为"2019-03-31"
    global OPDPlanMarkBatch(string thismonth_Lastday) {
        this.thismonth_Lastday = thismonth_Lastday;
    }
    // 指定"OPD计划"的Id
    global OPDPlanMarkBatch(List<String> oPDPlanIds) {
        this.oPDPlanIds = oPDPlanIds;
        iflog = new BatchIF_Log__c();
        iflog.Type__c = 'PushNotification';
        iflog.Log__c  = 'OPDPlanMarkBatch start\n';
        iflog.ErrorLog__c = '';
        insert iflog;
    }


    global Database.QueryLocator start(Database.BatchableContext BC) {
        // select項目を opdpMapping より生成
        SS_Batch_Column_Mapping__c opdpMapping = SS_Batch_Column_Mapping__c.getValues('OPDPlan__c');
        Set<String> apiTempSet = new Set<String>();
        //apiTempSet.add('StageName');
        for (Integer i = 1; i <= FIELDMAX; i++) {
            String lpadI = ('00' + i).right(3);
            String fromColumn = 'From_Column_' + lpadI + '__c';
            String apiStr = String.valueOf(opdpMapping.get(fromColumn));
            if (String.isBlank(apiStr) == false) {
                String ssColumn = 'SS_Column_' + lpadI + '__c';
                String ssApiStr = String.valueOf(opdpMapping.get(ssColumn));
                if (ssApiStr.toLowerCase().startsWith('opdplan__c.')) {
                    // 商談の項目を更新、変更があるかどうか判断するため、元データも取得
                    //System.debug('ssApiStr=' + ssApiStr + ', substring(11)=' + ssApiStr.substring(11));
                    apiTempSet.add(ssApiStr.substring(11));
                }
            }
        }
        String soql = makeSql(opdpMapping, apiTempSet);
        if (oPDPlanIds <> null) {
            soql += ' where Id IN: oPDPlanIds';
        } else {
            Date nowDay = Date.valueOf(thismonth_Lastday);
            // CHAN-BBW5DQ 20190507 LHJ Start
            //soql += ' Where OPDPlan_ImplementDate__c <=  : nowDay';
            soql += ' Where FinalDate__c = Null or FinalDate__c >=  :nowDay';
            // CHAN-BBW5DQ 20190507 LHJ End

        }

        System.debug('soql=' + soql);
        return Database.getQueryLocator(soql);

    }

    global void execute(Database.BatchableContext BC, List<OPDPlan__c> OPDPlans) {
        List<OPDPlan__c> updSelfList = new List<OPDPlan__c>();
        List<SObject> insSSOpdpList = new List<SObject>();
        // 商談
        SS_Batch_Column_Mapping__c opdpMapping = SS_Batch_Column_Mapping__c.getValues('OPDPlan__c');
        Schema.SObjectType ssOppType = Schema.getGlobalDescribe().get(String.valueOf(opdpMapping.get('SS_TableName__c')));
        for (OPDPlan__c opdp : OPDPlans) {
            Boolean updSelfFlg = false;
            SObject insSSOpdp = ssOppType.newSObject();
            for (Integer i = 1; i <= FIELDMAX; i++) {
                String lpadI = ('00' + i).right(3);
                String fromColumn = 'From_Column_' + lpadI + '__c';
                String apiStr = String.valueOf(opdpMapping.get(fromColumn));
                if (String.isBlank(apiStr) == false) {
                    String ssColumn = 'SS_Column_' + lpadI + '__c';
                    String ssApiStr = String.valueOf(opdpMapping.get(ssColumn));
                    if (ssApiStr.toLowerCase().startsWith('opdplan__c.')) {
                        // 項目更新、変更判断
                        if (opdp.get(ssApiStr.substring(11)) != opdp.get(apiStr)) {
                            try {
                                opdp.put(ssApiStr.substring(11), opdp.get(apiStr));
                                updSelfFlg = true;
                            } catch (Exception e) {
                                iflog.ErrorLog__c = 'ERROR [' + apiStr + '] => [' + ssApiStr + ']' + e.getMessage() + '\n';
                            }
                        }
                    } else {
                        try {
                            insSSOpdp.put(ssApiStr, getValue(opdp, apiStr));
                        } catch (Exception e) {
                            iflog.ErrorLog__c = 'ERROR ' + String.valueOf(opdpMapping.get('SS_TableName__c')) + ' [' + apiStr + '] => [' + ssApiStr + ']' + e.getMessage() + '\n';
                        }
                    }
                }
            }
            if (updSelfFlg) {
                updSelfList.add(opdp);
            }
            insSSOpdpList.add(insSSOpdp);
        }

        // 记下更新OPD计划错误log
        if (updSelfList.size() > 0) {
            Database.SaveResult[] lsr = Database.update(updSelfList, false);
            for (Integer tIdx = 0; tIdx < lsr.size(); tIdx++) {
                Database.SaveResult sr = lsr[tIdx];
                if (!sr.isSuccess()) {
                    Database.Error emsg = sr.getErrors()[0];
                    if (!String.valueOf(emsg.getStatusCode()).contains('INACTIVE_OWNER_OR_USER')) {

                        iflog.ErrorLog__c += 'ERROR ' + updSelfList[tIdx].Id + ' OPDPlan__c:' + emsg + '\n';
                    }
                }
            }
        }

        //插入备份表
        Database.SaveResult[] lsr2 = Database.insert(insSSOpdpList, false);
        for (Integer tIdx = 0; tIdx < lsr2.size(); tIdx++) {
            Database.SaveResult sr = lsr2[tIdx];
            if (!sr.isSuccess()) {
                Database.Error emsg = sr.getErrors()[0];
                // 2020-11-27  mzy  update    原:insSSOpdpList[tIdx].get('OPDPlan__c')  改为  insSSOpdpList[tIdx].get('SSOPDPlan__c')
                if (!String.valueOf(emsg.getStatusCode()).contains('INACTIVE_OWNER_OR_USER')) {
                    iflog.ErrorLog__c += 'ERROR ' + insSSOpdpList[tIdx].get('SSOPDPlan__c') + ' SS_opd:' + emsg + '\n';
                }
            }
        }



    }

    public static String makeSql(SS_Batch_Column_Mapping__c setting, Set<String> apiTempSet) {
        apiTempSet.add('Id');
        for (Integer i = 1; i <= FIELDMAX; i++) {
            String fromColumn = 'From_Column_' + ('00' + i).right(3) + '__c';
            String apiStr = String.valueOf(setting.get(fromColumn));
            if (String.isBlank(apiStr) == false && apiTempSet.contains(apiStr) == false) {
                apiTempSet.add(apiStr);
            }
        }
        String soql = 'Select ' + String.join(new List<String>(apiTempSet), ',') + ' from ' + setting.Name;
        return soql;
    }
    public static Object getValue(SObject sobj, String field) {
        List<String> fieldPathList = field.split('\\.');
        Object rtn = null;
        for (Integer i = 0; i < fieldPathList.size(); i++) {
            String fieldPath = fieldPathList[i];
            if (i == fieldPathList.size() - 1) {
                rtn = sobj.get(fieldPath);
            } else {
                sobj = sobj.getSObject(fieldPath);
                if (sobj == null) {
                    break;
                }
            }
        }
        return rtn;
    }
    global void finish(Database.BatchableContext BC) {
        iflog.Log__c += '\nOPDPlanMarkBatch 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;
        //------20200330-----XHL-----AddStart
        //以下为每个季度的第一个工作日执行，分别为4月、7月、10月、1月的第一个工作日执行，
        //OPD计划的特别执行，季度计划不参与执行，若需要执行，请调OPDQuarterPlanPhotographBatch里面的方法去执行，特此说明
        //  Date toDate = Date.today();
        //  Date yesterDate = toDate.addDays(-1);
        //   Integer executeMonth = toDate.month();
        //  Date mon1stDate = Date.newInstance(toDate.year(), toDate.month(), 1);
        //  //每月到今天的工作日
        //  Integer workdays = UpdateUserTextColBatch.getOlympusWorkDayCount(mon1stDate, toDate);
        //  //每月到昨天的工作日
        //  Integer workdays1 = UpdateUserTextColBatch.getOlympusWorkDayCount(mon1stDate, yesterDate);

        // Integer OSFBacth_Execute_Day = Integer.valueOf(System.Label.OSFBacth_Execute_Day);
        //  if (workdays1 != OSFBacth_Execute_Day && workdays == OSFBacth_Execute_Day) {
        //      if ( executeMonth == 1 || executeMonth == 4 || executeMonth == 7 || executeMonth == 10) {
        //          if (oPDPlanIds <> null ) {
        //              //Database.executebatch(new OPDQuarterPlanPhotographBatch(oPDPlanIds), 100);
        //          } else{
        //              Database.executebatch(new OPDQuarterPlanPhotographBatch(), 100);
        //          }

        //      }

        //  }     修改在schedule里调用。符合倒数第二天，就调月度。符合季度，就调季度 (移至 OPDPlanMarkBatchSchedule)

        // 2020-11-25   mzy  add  ss拷贝之后,发送邮件  start
        boolean result =  sendMail();
        if (!result) {
            System.debug('邮件发送失败,请检查');
        }
        // 2020-11-25   mzy  add  ss拷贝之后,发送邮件  end

    }

    public static boolean sendMail() {

        Boolean result = true;
        String title = '';
        String body = '';
        List<String> toMailList = new List<String>();
        //List<String> ccMailList = new List<String>();
        List<String> statementIdList = new List<String>();
        Date today = Date.today();

        // 标题与内容
        title = 'OPD计划排序拍照已经完成';
        body += '各位好！<br/>';
        body += '<br/>本月的OPD计划排序结果拍照已经完成，请参考以下报表查看详细信息：<br/>';
        body += '<a href="' + URL.getSalesforceBaseUrl().toExternalForm() + '/' + System.Label.SSOPD_Report + '">'
                + URL.getSalesforceBaseUrl().toExternalForm() + '/' + System.Label.SSOPD_Report + '</a><br/>';

        body += '<br/>谢谢';

        //收件人与抄送人
        //1. 邮件群组
        String str = System.Label.OPDTPMailboxGroup;
        toMailList.addAll(str.split(';'));
        //2. 公共小组
        //用来存放用户的id
        List<String> idList = new List<String>();
        //查询公用小组
        List<Group> gList = [ SELECT (select userOrGroupId from groupMembers) FROM group WHERE name = 'OPD拍照收件人'];
        if (gList != null && gList.size() > 0) {
            for (Group g : gList) {
                for (GroupMember gm : g.groupMembers) {
                    idList.add(gm.userOrGroupId);
                }
            }
        }

        //根据用户id查询用户信息
        List<User> usrList = [SELECT email FROM user WHERE id in :idList];
        //获取各个用户的email
        for (User u : usrList) {
            toMailList.add(u.email);
        }


        List<Messaging.SingleEmailMessage> sendMails = new List<Messaging.SingleEmailMessage>();
        Messaging.SingleEmailMessage messageNEW = new Messaging.SingleEmailMessage();
        messageNEW.setSubject(title);
        messageNEW.setHtmlBody(body);
        messageNEW.setCharset('UTF-8');
        messageNEW.setToAddresses(toMailList);
        //messageNEW.setCcAddresses(ccMailList);

        sendMails.add(messageNEW);
        if (sendMails.size() > 0) {
            Messaging.SendEmailResult[] results = messaging.sendEmail(sendMails);
            for (Integer i = 0; i < results.size(); i++) {
                if (results[i].success == false) {
                    system.debug('=====send mail error:' + results[i].errors[0].message);
                    result = false;
                }
            }
        }
        return result;
    }

}