ningshuxia
2022-12-12 e81ca048ef4e9345e904b74ffffd3e8413d18a7e
Application/IStation.Application.Eta/eta_analy_largescreenkpi/EtaAnalyLargeScreenKpi_Controller.cs
@@ -512,15 +512,15 @@
        }
       /* /// <summary>
        /// <summary>
        /// 修正日测点数据 (临时)
        /// </summary>
        [Route("RepairEtaDayRecordList")]
        [HttpGet]
        public bool RepairEtaDayRecordList([FromQuery] long CorpID, DateTime StartTime, DateTime EndTime)
        {
            var spanDays = (EndTime - StartTime).TotalDays;
            var spanDays = (EndTime - StartTime).TotalDays;
            //获取业务区域
            var logic_catalog_list = new Service.LogicCatalog().GetByCorpID(CorpID);
@@ -619,58 +619,40 @@
            }
            return true;
        }
*/
        /// <summary>
        /// 修正业务区域日测点数据 (临时)
        /// 修正泵站日测点数据 (临时)
        /// </summary>
        [Route("RepairEtaSumLogicRecordList")]
        [Route("RepairEtaSumMultiRecordList")]
        [HttpGet]
        public bool RepairEtaSumLogicRecordList([FromQuery] long CorpID, DateTime StartTime, DateTime EndTime)
        {
            var spanDays = (EndTime - StartTime).TotalDays;
        public bool RepairEtaSumMultiRecordList([FromQuery] long CorpID, long StationID, DateTime StartTime, DateTime EndTime)
        {
            var spanDays = (EndTime - StartTime).TotalDays;
            //获取业务区域
            var logic_catalog_list = new Service.LogicCatalog().GetByCorpID(CorpID);
            if (logic_catalog_list == null || logic_catalog_list.Count < 1)
                return false;
            var service_EtaLogicRealRecord = new Service.EtaLogicRealRecord();
            var service_EtaSumLogicRecord = new Service.EtaSumLogicRecord();
            var service_eta= new Service.EtaMultiRealRecord();
            var service_eta_sum = new Service.EtaSumMultiRecord();
            //遍历业务类别
            foreach (var logicCataog in logic_catalog_list)
            for (int i = 0; i <= spanDays; i++)
            {
                //获取业务清单
                var logicTreeList = new Service.LogicTree().GetByCatalogID(CorpID, logicCataog.ID);
                if (logicTreeList == null || logicTreeList.Count < 1)
                var currentTime = StartTime.AddDays(i);
                var realRecordList = service_eta.GetByObjectOfDay(CorpID, ObjectType.Station, StationID, currentTime);
                if (realRecordList == null || realRecordList.Count < 1)
                    continue;
                foreach (var logicTree in logicTreeList)
                var cureentDayRecord = service_eta_sum.GetDayByObjectOfDay(CorpID, ObjectType.Station, StationID, currentTime);
                var records =EtaSumMultiDayHelper.Sum(CorpID, ObjectType.Station, StationID, currentTime, realRecordList);
                if (cureentDayRecord == null)
                {
                    if (logicTree.LogicType == ObjectType.LogicArea)
                    {
                        for (int i = 0; i <= spanDays; i++)
                        {
                            var currentTime = StartTime.AddDays(i);
                            var realRecordList = service_EtaLogicRealRecord.GetByObjectOfDay(CorpID, ObjectType.LogicArea, logicTree.LogicID, currentTime);
                            if (realRecordList == null || realRecordList.Count < 1)
                                continue;
                            var cureentDayRecord = service_EtaSumLogicRecord.GetDayByObjectOfDay(CorpID, ObjectType.LogicArea, logicTree.LogicID, currentTime);
                            var record = EtaSumLogicDayHelper.Sum(CorpID, ObjectType.LogicArea, logicTree.LogicID, currentTime, realRecordList);
                            if (cureentDayRecord == null)
                            {
                                service_EtaSumLogicRecord.Insert(record);
                            }
                            else
                            {
                                service_EtaSumLogicRecord.Update(record);
                            }
                        }
                    }
                    service_eta_sum.Inserts(records);
                }
                else
                {
                    service_eta_sum.Updates(records);
                }
            }
@@ -681,5 +663,6 @@
    }
}