public without sharing class ConsumInventoryDetailHandler extends Oly_TriggerHandler {
    private Map<Id, Consum_Inventory_Detail__c> newMap;
    private Map<Id, Consum_Inventory_Detail__c> oldMap;
    private List<Consum_Inventory_Detail__c> newList;
    private List<Consum_Inventory_Detail__c> oldList;

    private static Set<Id> updatedAsset = new Set<Id>();
    private static Map<Id, Asset> needUpdateAsset = new Map<Id, Asset>();

    public ConsumInventoryDetailHandler() {
        this.newMap = (Map<Id, Consum_Inventory_Detail__c>) Trigger.newMap;
        this.oldMap = (Map<Id, Consum_Inventory_Detail__c>) Trigger.oldMap;
        this.newList = (List<Consum_Inventory_Detail__c>) Trigger.new;
        this.oldList = (List<Consum_Inventory_Detail__c>) Trigger.old;
    }

    protected override void beforeInsert() {

    }

    protected override void beforeUpdate() {
        needUpdateAsset = new Map<Id, Asset>();
        beforeSetValue();
    }

    protected override void afterUpdate() {
        setFrozenQuantity();
        //CheckOnetoOneLink();
        setAsset();
        // OLY_OCM-663 汇总子明细的盘点状态到主明细中。未来如果盘点表画面可能需要更多过滤方式的话，考虑修改Batch在主明细中追加Asset单位的数量等字段
        checkInventoryStatus();
        if (needUpdateAsset.isEmpty() == false) {
            update needUpdateAsset.values();
        }
    }

    private void beforeSetValue() {
        for (Consum_Inventory_Detail__c nObj : newList) {
            Consum_Inventory_Detail__c oObj;
            if (Trigger.isUpdate) {
                oObj = oldMap.get(nObj.Id);
            }
            //if (oObj != null
            //        && oObj.Auto_Lost_item_giveup__c == false
            //        && nObj.Auto_Lost_item_giveup__c == true) {
            //    nObj.Auto_Giveup_Time__c = Datetime.now();
            //}
        }
    }

    private void setFrozenQuantity() {
        Map<Id, Decimal> assetCount = new Map<Id, Decimal>();
        Map<Id, Decimal> assetCount2 = new Map<Id, Decimal>();
        Map<String, Decimal> otoLinkCount = new Map<String, Decimal>();
        Set<Id> astSet = new Set<Id>();
        for (Consum_Inventory_Detail__c nObj : newList) {
            Consum_Inventory_Detail__c oObj = oldMap.get(nObj.Id);
            if (oObj.Inventory_Count__c == nObj.Inventory_Count__c) continue;
            Decimal oldDeviation = oObj.Inventory_Count__c == null ? 0 :oObj.Inventory_Deviation__c;
            Decimal newDeviation = nObj.Inventory_Count__c == null ? 0 :nObj.Inventory_Deviation__c;

            //盘点盘亏数
            //实盘数不能大于应盘数，盘盈不能反映到冻结里
            if (oldDeviation < 0 || newDeviation < 0) {
                Decimal count;
                Decimal oto_count;
                if (oldDeviation >= 0) {
                    count = 0 - newDeviation;
                } else if (newDeviation >= 0) {
                    count = oldDeviation;
                } else {
                    count = oldDeviation - newDeviation;
                }
                oto_count = count;
                if (assetCount.containsKey(nObj.Asset__c)) {
                    count += assetCount.get(nObj.Asset__c);
                }
                assetCount.put(nObj.Asset__c, count);
                //一对一附属品盘亏冻结数
                //if (nObj.Fixture_OneToOne_Link__c != null) {
                //    if (otoLinkCount.containsKey(nObj.Fixture_OneToOne_Link__c)) {
                //        oto_count += otoLinkCount.get(nObj.Fixture_OneToOne_Link__c);
                //    }
                //    otoLinkCount.put(nObj.Fixture_OneToOne_Link__c, oto_count);
                //}
                astSet.add(nObj.Asset__c);
            }

            //盘点盘盈数
            //盘亏不能反映到盘盈数里
            if (oldDeviation > 0 || newDeviation > 0) {
                Decimal count;
                if (oldDeviation <= 0) {
                    count = newDeviation;
                } else if (newDeviation <= 0) {
                    count = 0 - oldDeviation;
                } else {
                    count = newDeviation - oldDeviation;
                }
                if (assetCount2.containsKey(nObj.Asset__c)) {
                    count += assetCount2.get(nObj.Asset__c);
                }
                assetCount2.put(nObj.Asset__c, count);
                astSet.add(nObj.Asset__c);
            }
        }

        List<Asset> updateList = new List<Asset>();
        List<Consum_Inventory_Detail__c> updateIdList = new List<Consum_Inventory_Detail__c>();
        if (astSet.isEmpty() == false) {
            List<Asset> astList = [select Id, Inventory_Frozen_Quantity__c, Inventory_Profit_Quantity__c from asset where Id in :astSet];
            List<Consum_Inventory_Detail__c> idList = [select Id, Sync_Asset_Frozen_Quantity__c, Sync_Asset_Profit_Quantity__c, Asset__c from Consum_Inventory_Detail__c where Asset__c in :astSet and Sync_Asset_Record_Flag__c = true];
            for (Asset ast : astList) {
                if (ast.Inventory_Frozen_Quantity__c == null) ast.Inventory_Frozen_Quantity__c = 0;
                if (ast.Inventory_Profit_Quantity__c == null) ast.Inventory_Profit_Quantity__c = 0;
                if (assetCount.containsKey(ast.Id)) {
                    ast.Inventory_Frozen_Quantity__c += assetCount.get(ast.Id);
                }
                if (assetCount2.containsKey(ast.Id)) {
                    ast.Inventory_Profit_Quantity__c += assetCount2.get(ast.Id);
                }
                
                updateList.add(ast);
            }

            for (Consum_Inventory_Detail__c idl : idList) {
                if (idl.Sync_Asset_Frozen_Quantity__c == null) idl.Sync_Asset_Frozen_Quantity__c = 0;
                if (idl.Sync_Asset_Profit_Quantity__c == null) idl.Sync_Asset_Profit_Quantity__c = 0;
                if (assetCount.containsKey(idl.Asset__c)) {
                    idl.Sync_Asset_Frozen_Quantity__c += assetCount.get(idl.Asset__c);
                }
                if (assetCount2.containsKey(idl.Asset__c)) {
                    idl.Sync_Asset_Profit_Quantity__c += assetCount2.get(idl.Asset__c);
                }
                
                updateIdList.add(idl);
            }
            update updateList;
            update updateIdList;
        }
        //一对一附属品盘亏数处理
        //if (otoLinkCount.isEmpty() == false) {
        //    List<Fixture_OneToOne_Link__c> otoList = [select Id, Inventory_Frozen_Quantity__c from Fixture_OneToOne_Link__c where Id in :otoLinkCount.keySet()];
        //    for (Fixture_OneToOne_Link__c oto : otoList) {
        //        if (oto.Inventory_Frozen_Quantity__c == null) oto.Inventory_Frozen_Quantity__c = 0;
        //        oto.Inventory_Frozen_Quantity__c += otoLinkCount.get(oto.Id);
        //    }
        //    update otoList;
        //}
    }

    private void setAsset() {
        for (Consum_Inventory_Detail__c nObj : newList) {
            Consum_Inventory_Detail__c oObj = oldMap.get(nObj.Id);
            if (oObj.Auto_Lost_item_giveup__c == false
                    && nObj.Auto_Lost_item_giveup__c == true
                    && !updatedAsset.contains(nObj.Asset__c)) {
                Asset ass = new Asset(Id = nObj.Asset__c);
                if (nObj.Appended_Inventory_Frozen_Quantity_F__c > 0) {
                    ass.Abandoned_Inventory__c = nObj.Abandoned_Inventory_F__c + nObj.Appended_Inventory_Frozen_Quantity_F__c;
                }
                updatedAsset.add(nObj.Asset__c);
                ass.Appended_Inventory_Frozen_Quantity__c = 0;
                needUpdateAsset.put(nObj.Asset__c, ass);
            }
        }
    }

    //private void CheckOnetoOneLink() {
    //    Set<Id> otoIds = new Set<Id>();
    //    for (Consum_Inventory_Detail__c nObj : newList) {
    //        Consum_Inventory_Detail__c oObj;
    //        if (Trigger.isUpdate) {
    //            oObj = oldMap.get(nObj.Id);
    //        }
    //        if (oObj != null 
    //                && nObj.Fixture_OneToOne_Link__c != null
    //                && oObj.Auto_Lost_item_giveup__c == false
    //                && nObj.Auto_Lost_item_giveup__c == true
    //                && nObj.Manage_type__c == FixtureUtil.managetypeMap.get(FixtureUtil.Managetype.Shu_Liang_Guan_Li)) {
    //            otoIds.add(nObj.Fixture_OneToOne_Link__c);
    //        }
    //    }
        
    //    if (otoIds.size() > 0) {
    //        List<Fixture_OneToOne_Link__c> delList = new List<Fixture_OneToOne_Link__c>();
    //        List<Fixture_OneToOne_Link__c> otoList = [select Id, Inventory_Frozen_Quantity__c, Quantity__c from Fixture_OneToOne_Link__c where Id in :otoIds];
    //        for (Fixture_OneToOne_Link__c oto : otoList) {
    //            if (oto.Inventory_Frozen_Quantity__c >= oto.Quantity__c) {
    //                delList.add(oto);
    //            }
    //        }
    //        if (delList.size() > 0) {
    //            delete delList;
    //        }
    //    }
    //}

    private void checkInventoryStatus() {
        Set<Id> assetIds = new Set<Id>();
        for (Consum_Inventory_Detail__c nObj : newList) {
            Consum_Inventory_Detail__c oObj;
            if (Trigger.isUpdate) {
                oObj = oldMap.get(nObj.Id);
            }
            if (oObj != null 
                    && oObj.Inventory_Time__c == null
                    && nObj.Inventory_Time__c != null) {
                assetIds.add(nObj.Asset__c);
            }
        }

        if (assetIds.size() > 0) {
            AggregateResult[] results = [select count(Id) cnt, Asset__c
                                            from Consum_Inventory_Detail__c 
                                            where Asset__c in :assetIds and Asset_Status__c in ('在库','冻结') and Amount__c <> 0 and Inventory_Time__c = null
                                            AND Inventory_Header__r.Inventory_Status__c = '盘点中'
                                            group by Asset__c];
            for (AggregateResult ar : results) {
                if(Integer.valueOf(ar.get('cnt')) > 0) {
                    assetIds.remove((Id)String.valueOf(ar.get('Asset__c')));
                }
            }
            List<Consum_Inventory_Detail__c> updateDetails = [select Id, Asset_Inventory_Flg__c 
                                                            from Consum_Inventory_Detail__c 
                                                            where Asset__c in :assetIds and Sync_Asset_Record_Flag__c = true];
            if (updateDetails.size() > 0) {
                for (Consum_Inventory_Detail__c upd : updateDetails) {
                    upd.Asset_Inventory_Flg__c = true;
                }

                update updateDetails;
            }
        }
    }
}