/**
 * 1.新しい商品追加された場合、UniqueKey__c にて、新しいrecord生成されます(upsert)。
 * 2.UniqueKey__c:OLY财年,第三分类,新4.5分类
ET_Product_ScoreTable_Batch bat = new ET_Product_ScoreTable_Batch ();
Database.executeBatch(bat);
 */
global without sharing class ET_Product_ScoreTable_Batch implements Database.Batchable<sObject>, Database.Stateful{

    //private BatchEmailUtil.BatchErrorBean eb = new BatchEmailUtil.BatchErrorBean(); // 邮件发送ERRORBEAN
    //private static final Integer MAXERRORCNT = 500; // 邮件表单位最大错误信息显示数量
    global Integer totalCount = 0; // 总件数
    global Integer executedCount = 0;
    global Integer successCount = 0; // 成功件数
    global Integer failedCount = 0;  // 失败件数
    global Set<String> createdList;
    global Set<String> updatedList;
    global Set<String> failedList;
    global Boolean isAllFlag = false;
    global Integer testSkip = 0;

    global ET_Product_ScoreTable_Batch(){
        createdList = new Set<String> ();
        updatedList = new Set<String> ();
        failedList = new Set<String> ();

        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
        testSkip++;
    }

    global Database.QueryLocator start(Database.BatchableContext BC){
        System.debug('********** ET_Product_ScoreTable_Batch .start');
        
        Date systemDate = system.today();
        systemDate = systemDate.addDays(-Integer.valueof(System.Label.ET_Date_Calculate));
        //system.debug('systemDate ' + systemDate);
        Set<String> s = new Set<String>{'停止','有効','有効（再申請中）','失効（期限内生産済在庫対応）'};

        Product2 p = [SELECT Plan_Term__c FROM Product2
            WHERE Is_ET_APP__c = TRUE
            AND Category3__c <> ''
            AND SFDA_Status__c IN :s
            LIMIT 1];
        String term = p.Plan_Term__c.left(4);

        /*
         *  按年筛选本次 Batch 产生/更新的行
         */
        Product_Score_Table__c [] psts = [
                SELECT Id
                FROM  Product_Score_Table__c
                WHERE OCM_Term__c = :term
        ];
        /*
         *  清除表中临时统计信息
         */
        for(Product_Score_Table__c  pst: psts) {
            pst.put('Is_Disabled__c', true);
        }
        update psts;

        //商品取得
        String query = 'SELECT Id, Family, Plan_Term__c, SFDA_Status__c, Is_ET_APP__c, Asset_Model_No__c,' +
                        ' Category3__c, Category4__c, Category5__c, Plan_Category3__c, Plan_Category4__c' + 
                        ' FROM Product2' +
                        ' where Is_ET_APP__c = true ';
        // if (true != this.isAllFlag) {
        //        query += ' and LastModifiedDate >= :systemDate ';
        // }
               // query += ' and SFDA_Status__c in :s';
        return Database.getQueryLocator(query);
    }

    global void execute(Database.BatchableContext BC, List<Product2> productList){
        totalCount += productList.size();

        System.debug('ET_Product_ScoreTable_Batch execute start');

        Set<String> validStatus = new Set<String>{'停止','有効','有効（再申請中）','失効（期限内生産済在庫対応）'};
        //upsert产品得分表
        //List<Product_Score_Table__c> pstUpsertList =  new List<Product_Score_Table__c>();
        Map<String,Product_Score_Table__c> pstUpsertList =  new Map<String,Product_Score_Table__c>();
        Set<String> unDisabledList = new Set<String>();
        //system.debug(productList.size());
        if(!productList.isEmpty()){
            for (Product2 pd : productList){
                Product_Score_Table__c pst = new Product_Score_Table__c();
                //计画财年 151P, 152P 产品的计画财年前三码+P
                pst.OCM_Term__c = pd.Plan_Term__c.left(4);
                //第1分类
                pst.Category1__c = pd.Family;
                //重点第3分类
                pst.Plan_Category3__c = pd.Plan_Category3__c;
                //重点第4分类
                pst.Plan_Category4__c = pd.Plan_Category4__c;
                //第3分类
                pst.Category3__c = pd.Category3__c; 
                //第4分类
                pst.Category4__c = pd.Category4__c; 
                //UniqueKey : 151P+第三分类+第4分类
                pst.UniqueKey__c = pst.OCM_Term__c + ':' + pst.Category3__c + ':' + pst.Category4__c;

                if ('吸引活检针' == pd.Category4__c && 'EUS' == pd.Category3__c) {
                    if (pd.Asset_Model_No__c.startsWith('NA-U200H')) {
                        pst.Category4__c = '吸引活检针-EZ3P';
                        pst.Plan_Category4__c = '吸引活检针-EZ3P';
                        pst.UniqueKey__c = pst.OCM_Term__c + ':' + pst.Category3__c + ':吸引活检针-EZ3P';
                    } else {
                        pst.Category4__c = '吸引活检针-EZ3P以外';
                        pst.Plan_Category4__c = '吸引活检针-EZ3P以外';
                        pst.UniqueKey__c = pst.OCM_Term__c + ':' + pst.Category3__c + ':吸引活检针-EZ3P以外';
                    }
                } else if ('先端系粘膜切开刀' == pd.Category4__c && 'ESD' == pd.Category3__c) {
                    if (pd.Asset_Model_No__c.startsWith('KD-655')) {
                        pst.Category4__c = '先端系粘膜切开刀-DualJ';
                        pst.Plan_Category4__c = '先端系粘膜切开刀-DualJ';
                        pst.UniqueKey__c = pst.OCM_Term__c + ':' + pst.Category3__c + ':先端系粘膜切开刀-DualJ';
                    } else {
                        pst.Category4__c = '先端系粘膜切开刀-DualJ以外';
                        pst.Plan_Category4__c = '先端系粘膜切开刀-DualJ以外';
                        pst.UniqueKey__c = pst.OCM_Term__c + ':' + pst.Category3__c + ':先端系粘膜切开刀-DualJ以外';
                    }
                }

                //是否无效
                if (unDisabledList.contains(pst.UniqueKey__c)) {
                    pst.Is_Disabled__c = false;
                } else {
                    if (validStatus.contains(pd.SFDA_Status__c)) {
                        unDisabledList.add(pst.UniqueKey__c);
                        pst.Is_Disabled__c = false;
                    } else {
                        pst.Is_Disabled__c = true;
                    }
                }
                //pstUpsertList.add(pst);
                pstUpsertList.put(pst.UniqueKey__c,pst);
            }
        }

        for(Product_Score_Table__c tmpObj : [SELECT Id, UniqueKey__c, Is_Disabled__c
                FROM Product_Score_Table__c
                WHERE UniqueKey__c IN :pstUpsertList.keySet()]){
            if (false == tmpObj.Is_Disabled__c) {
                pstUpsertList.remove(tmpObj.UniqueKey__c);
            } else {
                Product_Score_Table__c pstUpsertItem = pstUpsertList.get(tmpObj.UniqueKey__c);
                if (unDisabledList.contains(tmpObj.UniqueKey__c)) {
                    pstUpsertItem.Is_Disabled__c = false;
                } else {
                    pstUpsertItem.Is_Disabled__c = true;
                }
                pstUpsertList.put(tmpObj.UniqueKey__c, pstUpsertItem);
            }
        }
        if(!pstUpsertList.isEmpty()){
            //System.debug('pstUpsertList.size '+pstUpsertList.size());
            Database.UpsertResult [] results = Database.upsert(pstUpsertList.values(), Product_Score_Table__c.UniqueKey__c,false );
            //System.debug('results.size '+results.size());
            for(Integer index = 0; index < results.size(); index++) {
                if(results[index].isSuccess()) { 
                    if(results[index].isCreated()) {
                        createdList.add(results[index].getId());
                    } else if(!createdList.contains(results[index].getId())){
                        updatedList.add(results[index].getId());
                    } else {
                        // do nothing
                    }
                }
                else{
                    for (Database.Error err : results[index].getErrors()) {
                        String message = 'UniqueKey :' + pstUpsertList.values()[index].UniqueKey__c + ' ; '
                        + err.getStatusCode() + '; '
                        + err.getFields() + ' ; '
                        + err.getMessage();
                        failedList.add(message);
                    }
                }
            }
        }

        executedCount += productList.size();
        System.debug('ET_Product_ScoreTable_Batch execute end');
    }  
    global void finish(Database.BatchableContext BC){
        System.debug('ET_Product_ScoreTable_Batch finish method start');
        String title = '产品得分表Batch';
        String messagesPlanText = '';
        String tempText = '';
        for(string s : createdList){
            successCount += 1;
            //messagesPlanText += s+' 已建立\n';
        }
        for(string s : updatedList){
            successCount += 1;
            //messagesPlanText += s+' 已更新\n';
        }
        for(string s : failedList){
            failedCount += 1;
            messagesPlanText += s+'\n';
        }
        
        BatchEmailUtil eb = new BatchEmailUtil();
        String[] emailList = new String[] {};
        // 失败件数为0 寄出成功的mail
        if (failedCount == 0 && totalCount == executedCount) {
            String emailLabel = 'BatchNotify';
            for (OrgWideEmailAddress tmpEmailObj : [SELECT Id, Address, DisplayName 
                FROM OrgWideEmailAddress
                WHERE DisplayName = :emailLabel]) {
                    emailList.add(tmpEmailObj.Address);
            }
            eb.successMail(emailList, null, title, executedCount);
        }
        else {
            if (totalCount != executedCount) {
                messagesPlanText += '有一部分Batch没有运行, 请确认系统管理员。\n';
            }
            eb.failedMail(title, messagesPlanText, totalCount, executedCount, failedCount);
        }
        eb.send();

        System.debug('ET_Product_ScoreTable_Batch finish method end');
    }
}