global without sharing class AssetMaintainAutoBatch implements Database.Batchable<Id>, Database.Stateful {
    global Integer allCount = 0;
    global Integer doneCount = 0;
    global List<String> errorList = new List<String>();
    global Date today = System.today();
    global String headerId;
    global Integer round;

    /**
    @description 调试用：传入盘点表头Id或遗失报告Id，得到需要维护的保有设备，无视批准情况
    @param headerId 盘点表头Id或遗失报告Id
    */
    global AssetMaintainAutoBatch(String headerId) {
        this.headerId = headerId;
        this.round = 4;
    }
    /**
    @description 5工作日前批准的盘点报告和遗失报告
    */
    global AssetMaintainAutoBatch() {
        this.headerId = '';
        this.round = 4;
    }
    global AssetMaintainAutoBatch(String headerId, Integer round){
        this.headerId = headerId;
        this.round = round;
    }

    global Iterable<Id> start(Database.BatchableContext bc) {
        List<Id> headerIdList = new List<Id>();
        List<Inventory_Header__c> invHeaderList = new List<Inventory_Header__c>();
        // 确认传入的Id是否有效，Id无效时返回空列表，execute不会执行
        if(String.isNotBlank(this.headerId)){
            invHeaderList = [
                SELECT Id
                FROM Inventory_Header__c
                WHERE Id=:this.headerId
            ];
            if(!invHeaderList.isEmpty()){
                headerIdList.add(this.headerId);
            }
            return headerIdList;
        }

        OlympusCalendar__c oc = [
            SELECT Id
                , Before_5_WorkDay__c
                , Before_4_WorkDay__c
            FROM OlympusCalendar__c
            WHERE Date__c =:today
        ];

        invHeaderList = [
            SELECT Id
            FROM Inventory_Header__c
            WHERE AutoMaintained__c = false
            AND Inventory_Header_approval_time__c <: oc.Before_4_WorkDay__c
        ];

        for(Inventory_Header__c header:invHeaderList){
            headerIdList.add(header.Id);
        }
        return headerIdList;
    }

    // schedule里scope设为1，保证是以表头为单位做修改
    // Database.executeBatch(new AssetMaintainAutoBatch(), 1);
    global void execute(Database.BatchableContext BC, List<Id> headerIdList) {
        allCount += headerIdList.size();
        Savepoint sp = Database.setSavepoint();
        try{
            AssetInfoInHeader info = loadAssetIdSet(headerIdList[0]);
            Map<Id, Integer> abandondLostMap = info.abandondLostMap;   //<AssetId, 丢失数>
            Map<Id, Integer> abandondDeficitMap = info.abandondDeficitMap; //<AssetId, 盘亏数>
            Map<Id, Integer> profitMap = info.profitMap;         //<AssetId, 盘盈数>
            Map<Id, Integer> consumedMap = info.consumedMap;       //<AssetId, 已消耗数>
            Set<Id> oneToOneAccessoryAssetIdSet = info.oneToOneAccessoryAssetIdSet; //一对一附属品Asset
            String yearMonthStart = info.yearMonthStart;
            String yearMonthEnd = info.yearMonthEnd;
            List<Asset> assetList = [
                SELECT Id
                   , Abandoned_Inventory__c
                   , Appended_Inventory_Frozen_Quantity__c
                   , Appended_Inventory_Profit_Quantity__c
                   , Asset_loaner_category__c
                   , Consumable_Guaranteen_end__c
                   , Consumed_Count__c
                   , Fixture_Model_No_F__c
                   , Fixture_OneToOne_Link__r.Main_Asset__c
                   , Internal_asset_location__c
                   , Internal_Asset_number_key__c
                   , Manage_Type__c
                   , Quantity
                   , Salesdepartment__c
                   , SerialNumber
                FROM Asset
                WHERE Id IN:abandondLostMap.keySet()
                 OR Id IN: abandondDeficitMap.keySet()
                 OR Id IN: profitMap.keySet()
                 OR Id IN: consumedMap.keySet()
            ];
            // 维护明细
            List<AssetMaintainDetail__c> amdLostList = new List<AssetMaintainDetail__c> (); // 废弃(丢失)
            List<AssetMaintainDetail__c> amdDeficitList = new List<AssetMaintainDetail__c> (); //废弃(盘亏)
            List<AssetMaintainDetail__c> amdProfitList = new List<AssetMaintainDetail__c> (); // 盘盈
            List<AssetMaintainDetail__c> amdConsumedList = new List<AssetMaintainDetail__c> (); // 耗材已消耗数

            List<Database.SaveResult> updResultList = Database.update(assetList, false);
            List<Asset> updateList = new List<Asset>();
            for(Integer i = 0; i < updResultList.size(); i++){
                Database.SaveResult sr = updResultList[i];
                if(!sr.isSuccess()){
                    for (Database.Error err : sr.getErrors()) {
                        errorList.add(err.getStatusCode() + ':' + err.getMessage() + err.getFields());
                    }
                    continue;
                }
                Asset ass = assetList[i];
                Boolean isOneToOneAccessory = oneToOneAccessoryAssetIdSet.contains(ass.Id);
                if(abandondLostMap.containsKey(ass.Id)){
                    AssetMaintainDetail__c amd = createAssetMaintainDetail(ass, isOneToOneAccessory);
                    amd.AbandonCount__c = abandondLostMap.get(ass.Id);
                    amdLostList.add(amd);

                    ass.Quantity = intValueOf(ass.Quantity) - abandondLostMap.get(ass.Id);
                    ass.ChangeQuantityReason__c = '废弃';
                    ass.Abandoned_Inventory__c = intValueOf(ass.Abandoned_Inventory__c) - abandondLostMap.get(ass.Id);
                    if(ass.Quantity <= 0) {
                        if(ass.Manage_Type__c == '个体管理'
                            || (ass.Consumable_Guaranteen_end__c != null && ass.Consumable_Guaranteen_end__c < today)){
                            ass.Status = FixtureUtil.assetStatusMap.get(FixtureUtil.AssetStatus.Fei_Qi.ordinal());
                        }
                    }
                }
                if(abandondDeficitMap.containsKey(ass.Id)){
                    if(String.isBlank(ass.Internal_Asset_number_key__c)){
                        AssetMaintainDetail__c amd = createAssetMaintainDetail(ass, isOneToOneAccessory);
                        amd.AbandonCount__c = abandondDeficitMap.get(ass.Id);
                        amdDeficitList.add(amd);

                        ass.Quantity = intValueOf(ass.Quantity) - abandondDeficitMap.get(ass.Id);
                        ass.Abandoned_Inventory__c = intValueOf(ass.Abandoned_Inventory__c) - abandondDeficitMap.get(ass.Id);
                        ass.ChangeQuantityReason__c = '盘亏';
                    }
                    if(ass.Quantity <= 0) {
                        if(ass.Manage_Type__c == '个体管理'
                            || (ass.Consumable_Guaranteen_end__c != null && ass.Consumable_Guaranteen_end__c < today)){
                            ass.Status =  FixtureUtil.assetStatusMap.get(FixtureUtil.AssetStatus.Fei_Qi.ordinal());
                        }
                    }
                }
                if(profitMap.containsKey(ass.Id)){
                    AssetMaintainDetail__c amd = createAssetMaintainDetail(ass, isOneToOneAccessory);
                    amd.MaintainCount__c = profitMap.get(ass.Id);
                    amdProfitList.add(amd);

                    ass.Quantity = intValueOf(ass.Quantity) + profitMap.get(ass.Id);
                    ass.Appended_Inventory_Profit_Quantity__c = intValueOf(ass.Appended_Inventory_Profit_Quantity__c) - profitMap.get(ass.Id);
                    ass.ChangeQuantityReason__c = '盘盈';
                }
                if(consumedMap.containsKey(ass.Id)){
                    AssetMaintainDetail__c amd = createAssetMaintainDetail(ass, isOneToOneAccessory);
                    amd.MaintainCount__c = consumedMap.get(ass.Id);
                    amdConsumedList.add(amd);

                    ass.Consumed_Count__c = intValueOf(ass.Consumed_Count__c) - consumedMap.get(ass.Id);
                }
                updateList.add(ass);
            }
            if(!updateList.isEmpty()){
                update updateList;
            }

            if(!amdLostList.isEmpty()){
                insertAssetMaintainDetails('废弃(丢失)', amdLostList, yearMonthStart, yearMonthEnd);
            }
            if(!amdDeficitList.isEmpty()){
                insertAssetMaintainDetails('废弃(盘亏)', amdDeficitList, yearMonthStart, yearMonthEnd);
            }
            if(!amdProfitList.isEmpty()){
                insertAssetMaintainDetails('盘盈(数量管理)', amdProfitList, yearMonthStart, yearMonthEnd);
            }
            if(!amdConsumedList.isEmpty()){
                insertAssetMaintainDetails('耗材已消耗数', amdConsumedList, yearMonthStart, yearMonthEnd);
            }
            updateHeaders(headerIdList[0]);

            doneCount += headerIdList.size();
        }
        catch (Exception e) {
            Database.rollback(sp);
            errorList.add(e.getMessage() + '\n' + e.getStackTraceString());
            System.debug(LoggingLevel.ERROR, e.getMessage() + '\n' + e.getStackTraceString());
            throw e;
        }
    }
    /**
    @description 盘点明细和遗失报告明细中取出保有设备
    @param headerId 盘点报告或遗失报告的Id
    @return 表头下保有设备的更新信息
    */
    private AssetInfoInHeader loadAssetIdSet(Id headerId){
        Map<Id, Integer> abandondLostMap = new Map<Id, Integer>();   //<AssetId, 丢失数>
        Map<Id, Integer> abandondDeficitMap = new Map<Id, Integer>(); //<AssetId, 盘亏数>
        Map<Id, Integer> profitMap = new Map<Id, Integer>();         //<AssetId, 盘盈数>
        Map<Id, Integer> consumedMap = new Map<Id, Integer>();       //<AssetId, 已消耗数>
        Set<Id> oneToOneAccessoryAssetIdSet = new Set<Id>(); //一对一附属品Asset
        String location = null;
        Datetime endDate = null;
        Id recordTypeId = null;

        List<Inventory_Detail__c> invdList = [SELECT Id
                                                , Asset__c
                                                , Abandoned_Inventory_Start__c
                                                , Inventory_Deviation__c
                                                , OneToOne_Accsessary__c
                                                , Inventory_Header__r.CreatedDate
                                                , Inventory_Header__r.Internal_asset_location__c
                                                , Inventory_Header__r.RecordTypeId
                                                , Inventory_Count__c
                                            FROM Inventory_Detail__c
                                            WHERE Inventory_Header__c =:headerId
                                            AND (Abandoned_Inventory_Start__c > 0
                                                    OR (Inventory_Count__c != null AND Inventory_Deviation__c != 0 )
                                                )
                                                ];
        List<Consum_Inventory_Detail__c> cinvdList = [SELECT Id
                                                         , Asset__c
                                                         , Abandoned_Inventory_Start__c
                                                         , Consumed_Count_Start__c
                                                         , Inventory_Header__r.CreatedDate
                                                         , Inventory_Header__r.Internal_asset_location__c
                                                         , Inventory_Header__r.RecordTypeId
                                                         , Inventory_Deviation__c
                                                         , Inventory_Count__c
                                                    FROM Consum_Inventory_Detail__c
                                                    WHERE Inventory_Header__c =:headerId
                                                    AND (Abandoned_Inventory_Start__c > 0
                                                        OR (Inventory_Count__c != null AND Inventory_Deviation__c != 0)
                                                        OR Consumed_Count_Start__c > 0
                                                        )
                                                    ];
        for(Inventory_Detail__c invd:invdList){
            endDate = invd.Inventory_Header__r.CreatedDate;
            location = invd.Inventory_Header__r.Internal_asset_location__c;
            recordTypeId = invd.Inventory_Header__r.RecordTypeId;
            if(invd.Abandoned_Inventory_Start__c > 0) {
                Integer c = intValueOf(invd.Abandoned_Inventory_Start__c);
                if(abandondLostMap.containsKey(invd.Asset__c)) {
                    c += abandondLostMap.get(invd.Asset__c);  
                }
                abandondLostMap.put(invd.Asset__c, c);
            }
            if(invd.Inventory_Count__c != null && invd.Inventory_Deviation__c < 0){
                Integer c = -intValueOf(invd.Inventory_Deviation__c);
                if(abandondDeficitMap.containsKey(invd.Asset__c)) {
                    c += abandondDeficitMap.get(invd.Asset__c);
                }
                abandondDeficitMap.put(invd.Asset__c, c);
            }
            if(invd.Inventory_Count__c != null && invd.Inventory_Deviation__c > 0){
                Integer c = intValueOf(invd.Inventory_Deviation__c);
                if(profitMap.containsKey(invd.Asset__c)) {
                    c += profitMap.get(invd.Asset__c);
                }
                profitMap.put(invd.Asset__c, c);
            }
            if(invd.OneToOne_Accsessary__c){
                oneToOneAccessoryAssetIdSet.add(invd.Asset__c);
            }
        }
        for(Consum_Inventory_Detail__c cinvd:cinvdList){
            endDate = cinvd.Inventory_Header__r.CreatedDate;
            location = cinvd.Inventory_Header__r.Internal_asset_location__c;
            recordTypeId = cinvd.Inventory_Header__r.RecordTypeId;
            if(cinvd.Abandoned_Inventory_Start__c > 0){
                abandondLostMap.put(cinvd.Asset__c, intValueOf(cinvd.Abandoned_Inventory_Start__c));
            }
            if(cinvd.Inventory_Count__c != null && cinvd.Inventory_Deviation__c < 0){
                abandondDeficitMap.put(cinvd.Asset__c, -intValueOf(cinvd.Inventory_Deviation__c));
            }
            if(cinvd.Inventory_Count__c != null && cinvd.Inventory_Deviation__c > 0){
                profitMap.put(cinvd.Asset__c, intValueOf(cinvd.Inventory_Deviation__c));
            }
            if(cinvd.Consumed_Count_Start__c > 0){
                consumedMap.put(cinvd.Asset__c, intValueOf(cinvd.Consumed_Count_Start__c));
            }
        }
        // 获取同一存放地，同一记录类型的上一次盘点表头
        List<Inventory_Header__c> lastHeader = [
            SELECT CreatedDate
            FROM Inventory_Header__c
            WHERE CreatedDate <: endDate
            AND RecordTypeId =: recordTypeId
            AND Internal_asset_location__c =: location
            ORDER BY CreatedDate DESC
            LIMIT 1
        ];

        String yearMonthStart = '';
        String yearMonthEnd = '';
        if(lastHeader.size() == 1){
            yearMonthStart = getYearMonthStr(lastHeader[0].CreatedDate);
        }
        yearMonthEnd = getYearMonthStr(endDate);

        AssetInfoInHeader info = new AssetInfoInHeader();
        info.abandondLostMap = abandondLostMap;
        info.abandondDeficitMap = abandondDeficitMap;
        info.profitMap = profitMap;
        info.consumedMap = consumedMap;
        info.oneToOneAccessoryAssetIdSet = oneToOneAccessoryAssetIdSet;
        info.yearMonthStart = yearMonthStart;
        info.yearMonthEnd = yearMonthEnd;
        return info;
    }
    private Integer intValueOf(Decimal d) {
        if(d == null) {
            return 0;
        }
        return Integer.valueOf(d);
    }
    /**
    @description 根据asset造出维护明细
    @param ass 保有设备
    @param isOneToOneAccessory 是否是一对一附属品，来自盘点明细里的OneToOne_Accsessary__c字段
    @return 维护明细
    */
    private AssetMaintainDetail__c createAssetMaintainDetail(Asset ass, Boolean isOneToOneAccessory){
        AssetMaintainDetail__c amd = new AssetMaintainDetail__c();
        amd.Asset__c = ass.Id;
        amd.Internal_asset_location__c = ass.Internal_asset_location__c;
        amd.Salesdepartment__c = ass.Salesdepartment__c;
        amd.Fixture_Model_No__c = ass.Fixture_Model_No_F__c;
        amd.Internal_Asset_number_key__c = ass.Internal_Asset_number_key__c;
        amd.Manage_type__c = ass.Manage_type__c;
        amd.SerialNumber__c = ass.SerialNumber;
        if(isOneToOneAccessory) {
            amd.Is_OneToOne_Accessory__c = true;
            amd.OneToOne_Main__c = ass.Fixture_OneToOne_Link__r.Main_Asset__c;
        }
        return amd;
    }
    /**
    @description 造出维护表单和维护明细，并更新
    @param maintainType 维护类型
    @param amdList 维护表明细
    @param yearMonthStart 盘点开始日，来自盘点报告的Inventory_Date_From__c
    @param yearMonthEnd 盘点结束日，来自盘点报告的Inventory_Date_To__c
    */
    private void insertAssetMaintainDetails(String maintainType, List<AssetMaintainDetail__c> amdList,
                                            String yearMonthStart, String yearMonthEnd){

        // 插入缺少的维护单表头
        List<AssetMaintainHeader__c> amhList = [
            SELECT Id
                 , DetailCount__c
            FROM AssetMaintainHeader__c
            WHERE MaintainType__c =: maintainType
              AND Date__c =: today
              AND Status__c='已完成'
              LIMIT 1];
        Integer startIndex = 1;
        if(amhList.isEmpty()){
            AssetMaintainHeader__c newAmh = new AssetMaintainHeader__c (
                                          MaintainType__c = maintainType
                                        , Date__c = today
                                        , Status__c = '已完成');
            insert newAmh;
            amhList.add(newAmh);
        }
        else {
            startIndex = intValueOf(amhList[0].DetailCount__c);
        }

        // 插入明细
        String maintainReason = getMaintainReason(maintainType, yearMonthStart, yearMonthEnd);
        Datetime now = System.now();
        for (AssetMaintainDetail__c amd: amdList) {
            amd.AssetMaintainHeader__c = amhList[0].Id;
            amd.MaintainType__c = maintainType;
            amd.Batch_Status__c = '完成';
            if (maintainType == '废弃(丢失)' || maintainType == '废弃(盘亏)') {
                amd.AbandonReason__c = maintainReason;
                amd.AbandonedTime__c = now;
            }
            else {
                amd.MaintainReason__c = maintainReason;
                amd.MaintainedTime__c = now;
            }
            amd.OrderNumber__c = startIndex++;
        }

        insert amdList;
    }
    private void updateHeaders(Id headerId){
        List<Inventory_Header__c> ihList = [
            SELECT Id
            FROM Inventory_Header__c
            WHERE Id =:headerId
            FOR UPDATE
        ];
        List<Inventory_Header__c> updateList = new List <Inventory_Header__c>();
        for(Inventory_Header__c ih: ihList){
            ih.AutoMaintained__c = true;
            updateList.add(ih);
        }
        if(!updateList.isEmpty()){
            update updateList;
        }
    }
    /**
    @description 根据维护类型生成维护原因
    @param maintainType 维护类型
    @param yearMonthStart 盘点开始日，来自盘点报告的Inventory_Date_From__c
    @param yearMonthEnd 盘点结束日，来自盘点报告的Inventory_Date_To__c
    */
    private String getMaintainReason(String maintainType, String yearMonthStart, String yearMonthEnd){
        String reason = '';
        switch on maintainType{
            when '废弃(丢失)'{
                if(String.isNotBlank(yearMonthStart)){
                    reason += yearMonthStart + '盘点开始后至';
                }
                reason += yearMonthEnd + '盘点开始前的现场丢失数量';
            }
            when '废弃(盘亏)'{
                reason = yearMonthEnd + '盘点盘亏数量';
            }
            when '盘盈(数量管理)'{
                reason = yearMonthEnd + '盘点数量管理备品盘盈数量';
            }
            when '耗材已消耗数'{
                if(String.isNotBlank(yearMonthStart)){
                    reason += yearMonthStart + '盘点开始后至';
                }
                reason += yearMonthEnd + '盘点开始前的耗材消耗数量';
            }
        }
        return reason;
    }
    /**
    @description 日期转成年度月
    @param d 日期
    */
    private String getYearMonthStr(Datetime d){
        String res = '';
        if(d == null){
            return res;
        }
        if(d.month() <= 3){
            res += (d.year() - 1 - 1867);
        }
        else{
            res += (d.year() - 1867);
        }
        res += 'P' + d.month() + '月';
        return res;
    }

    global void finish(Database.BatchableContext BC) {
        this.round -= 1;
        // 当所有错误都是lock引起时才要重跑
        Boolean lockFailure = this.errorList.size() > 0;
        for(String errorMsg :this.errorList){
            if (!errorMsg.contains('Record Currently Unavailable')
                && !errorMsg.contains('记录当前不可用')
                && !errorMsg.contains('レコードは現在利用できません')) {
                lockFailure = false;
                break;
            }
        }
        if(lockFailure && this.round > 0){
            AssetMaintainAutoBatch bat = new AssetMaintainAutoBatch(this.headerId, this.round);
            Database.executeBatch(bat);
        }
        else{
            if (allCount != doneCount || this.errorList.size() > 0) {
                BatchEmailUtil be = new BatchEmailUtil();
                String[] toList = new String[]{};
                String title = '自动数据维护batch';
                String[] ccList = new String[]{};
                for (OrgWideEmailAddress tmpEmailObj : [SELECT Id, Address, DisplayName
                        FROM OrgWideEmailAddress
                        WHERE DisplayName like 'BatchNotify']) {
                    toList.add(tmpEmailObj.Address);
                }
                for (Consum_Apply_Meta__mdt camd : [SELECT Id
                            , Key__c
                            , ValueLong__c
                         FROM Consum_Apply_Meta__mdt
                        WHERE Package__c = 'AssetMaintainAutoBatch'
                          AND Key__c = 'ErrorMailAddress'
                        ORDER BY Key__c]) {

                    for (String email:camd.ValueLong__c.split(',')) {
                        if (!toList.contains(email)) {
                            toList.add(email);
                        }
                    }
                }
                be.failedMail(toList, ccList, title, String.join(this.errorList, '\n'), allCount, doneCount, errorList.size());
                be.send();
            }
        }
    }
    class AssetInfoInHeader {
        public Map<Id, Integer> abandondLostMap = new Map<Id, Integer>();   //<AssetId, 丢失数>
        public Map<Id, Integer> abandondDeficitMap = new Map<Id, Integer>(); //<AssetId, 盘亏数>
        public Map<Id, Integer> profitMap = new Map<Id, Integer>();         //<AssetId, 盘盈数>
        public Map<Id, Integer> consumedMap = new Map<Id, Integer>();       //<AssetId, 已消耗数>
        public Set<Id> oneToOneAccessoryAssetIdSet = new Set<Id>(); //一对一附属品Asset
        public String yearMonthStart;
        public String yearMonthEnd;
    }
}