MBI/MBI/SAGA.MBI/ToolsData/CheckEquipCategory.cs

/* ==============================================================================
 * 功能描述：检查物理世界的Category与模型的Category是否一致
 * 创 建 者：Garrett
 * 创建日期：2018/7/12 14:25:17
 * ==============================================================================*/
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using SAGA.DotNetUtils.Others;
using SAGA.MBI.Calc;
using SAGA.MBI.Model;
using SAGA.MBI.RequestData;
using SAGA.MBI.WinView.Upload;
using Autodesk.Revit.DB;
using Autodesk.Revit.DB.Mechanical;
using SAGA.DotNetUtils;
using SAGA.DotNetUtils.Logger;
using SAGA.MBI.DataArrange;
using SAGA.MBI.Tools;
using SAGA.RevitUtils.Extends;

namespace SAGA.MBI.ToolsData
{
    /// <summary>
    /// CheckEquipCategory
    /// </summary>
    public class CheckEquipCategory
    {
        /// <summary>
        /// 检查并处理所有楼层
        /// </summary>
        public static void OperateAll()
        {
            var floors = DalUploadFloor.GetHasFileFloors();
            List<CalcContext> contexts = new List<CalcContext>();
            foreach (UploadFloor floor in floors)
            {
                Operate(floor.MFloor);
            }
        }
        /// <summary>
        /// 只处理当前楼层
        /// </summary>
        public static void OperateCurFloor()
        {
            MFloor floor = ExternalDataWrapper.Current.Doc.GetCurMFloor();
            if (floor != null)
                Operate(floor);
        }
        /// <summary>
        /// 检查并处理
        /// </summary>
        /// <param name="floor"></param>
        /// <returns></returns>
        private static void Operate(MFloor floor)
        {
            var context = DalCommon.DownLoadCouldData(floor);
            context.OpenDocument();
            try
            {
                //CalcEquipPartRlt(context);
                CalcContext delcontext = new CalcContext(floor);
                CalcContext addContext = new CalcContext(floor);
                Check(context, delcontext, addContext);
                RebuildCloudData(delcontext, addContext);
            }
            catch (Exception e)
            {
                MessageShowBase.Show(e);
            }
            finally
            {
                context.RevitDoc.CloseDoc();
            }
        }
        /// <summary>
        /// 检查设备，部件，空间，有那些模型族类型和云平台存储的类型不一致
        /// </summary>
        /// <param name="baseContext"></param>
        /// <param name="delcontext"></param>
        /// <param name="addContext"></param>
        private static void Check(CalcContext baseContext, CalcContext delcontext, CalcContext addContext)
        {
            var doc = baseContext.RevitDoc;
            //检查空间，逻辑不通，暂时注释掉
            //foreach (var mode in baseContext.MSpaces)
            //{
            //    string cBimId = mode.BimID;
            //    if (cBimId.IsNullOrEmpty()) continue;
            //    int bimid = cBimId.GetBIMID();
            //    Element elem = doc.GetElement(bimid);
            //    if (elem == null) continue;
            //    Space fi = elem as Space;
            //    if (fi == null)
            //    {
            //        mode.Operator = DocumentChangedOperator.Add;
            //        delcontext.MSpaces.Add(mode);
            //        //addContext.MSpaces.Add(mode);
            //    }
            //}
            //检查设备
            foreach (var mode in baseContext.MEquipments)
            {
                string cBimId = mode.BimID;
                if (cBimId.IsNullOrEmpty()) continue;
                int bimid = cBimId.GetBIMID();
                Element elem = doc.GetElement(bimid);
                if (elem == null) continue;
                FamilyInstance fi = elem as FamilyInstance;
                if (fi == null) continue;
                var code = fi.GetFamilyCode();
                var cCode = mode.EquipClassCode;
                if (code != cCode)
                {
                    delcontext.MEquipments.Add(mode);

                    MEquipment equip = DalEquip.GetEquipment(fi);
                    if (equip == null) continue;
                    //暂时保留本地名称和本地编码
                    equip.LocalId = mode.LocalId;
                    equip.LocalName = mode.LocalName;
                    equip.Operator = DocumentChangedOperator.Add;
                    addContext.MEquipments.Add(equip);

                    //识别设备所在空间
                    var space = fi.GetReferenceSpace();
                    if (space == null) continue;
                    string spaceId = space.GetCloudBIMId();
                    MISpace mSpace = addContext.MSpaces.FirstOrDefault(t => t.BimID == spaceId);
                    if (mSpace == null)
                    {
                        mSpace = DalSpace.GetSpace(space);
                        addContext.MSpaces.Add(mSpace);
                        //设备所在空间添加添加一组关系
                        addContext.RltEquipInSpaces.Add(new RltEquipInSpace(mSpace, equip){Operator = DocumentChangedOperator.Add});
                    }
                }
            }
            //检查部件 
            foreach (var mode in baseContext.MEquipmentParts)
            {
                string cBimId = mode.BimID;
                if (cBimId.IsNullOrEmpty()) continue;
                int bimid = cBimId.GetBIMID();
                Element elem = doc.GetElement(bimid);
                if (elem == null) continue;
                FamilyInstance fi = elem as FamilyInstance;
                if (fi == null) continue;
                var code = fi.GetFamilyCode();
                var cCode = mode.EquipClassCode;
                if (code != cCode)
                {
                    delcontext.MEquipmentParts.Add(mode);

                    MEquipmentPart equipment = DalEquipPart.GetEquipPart(fi);
                    if (equipment == null) continue;
                    equipment.Operator = DocumentChangedOperator.Add;
                    addContext.MEquipmentParts.Add(equipment);
                    //识别设备所在空间
                    var space = fi.GetReferenceSpace();
                    if (space == null) continue;
                    string spaceId = space.GetCloudBIMId();
                    MISpace mSpace = addContext.MSpaces.FirstOrDefault(t => t.BimID == spaceId);
                    if (mSpace == null)
                    {
                        mSpace = DalSpace.GetSpace(space);
                        addContext.MSpaces.Add(mSpace);
                        //设备所在空间添加添加一组关系
                        addContext.RltEquipInSpaces.Add(new RltEquipInSpace(mSpace, equipment) { Operator = DocumentChangedOperator.Add });
                    }
                }
            }
            //信标不用检查
        }
        /// <summary>
        /// 重建物理世界有问题的数据
        /// </summary>
        /// <param name="delcontext"></param>
        /// <param name="addContext"></param>
        private static void RebuildCloudData(CalcContext delcontext, CalcContext addContext)
        {
            //删除
            delcontext.Del();
            //添加
            addContext.Upload();
            //var tip =
            //    $"{addContext.MEquipments} 个设备受到影响;{string.Join(addContext.MEquipments.Select(t => t.BimID).ToArray())}";
            //Log4Net.Debug(tip);
        }
    }
}