紧急提交更新

tangxu

2024-12-19 9acdf3c826311bd67180821ce19c625d0e384ca8

 Calc/IStation.Calc.Core/¼ÆËã»ùÀà/ErQuCalcBaseHelper.cs

@@ -2,33 +2,34 @@
using IStation.Model;
using System;
using System.Collections.Generic;
using System.Linq; 
using System.Linq;

namespace IStation.Calc
{
    internal partial class ErQuCalcBaseHelper
    {
        protected int _maxOpenPumpCount = 4;//最大开泵数量

        /// <summary>
        /// 
        ///
        /// </summary>
        /// <returns></returns>
        public static IStation.Calc.ErQuCalcBaseHelper Build(IStation.CalcModel.AnaRequest anaRequest)
        {
            if (anaRequest.MaxLimitWaterBoxLevel != null)
            if (anaRequest.MaxReservoirLevel != null)
            {
                DateTime? limit_time = GetMaxLimitWaterBoxTime(anaRequest);
                DateTime? limit_time = GetMaxReservoirLevelTime(anaRequest);

                if (limit_time == null)
                {
                    var calc = new IStation.Calc.ErQuCalcHelper_2_递归_定水位_任意时间();
                    calc.SetMaxReservoirHeight(anaRequest.MaxLimitWaterBoxLevel.Value);

                    calc.SetMaxReservoirHeight(anaRequest.MaxReservoirLevel.Value);
                    return calc;
                }
                else
                {
                    var calc = new IStation.Calc.ErQuCalcHelper_2_递归_定水位_指定时间();
                    calc.SetMaxReservoirHeight(anaRequest.MaxLimitWaterBoxLevel.Value, limit_time.Value);
                    calc.SetMaxReservoirHeight(anaRequest.MaxReservoirLevel.Value, limit_time.Value);
                    return calc;
                }
            }
@@ -36,26 +37,24 @@
            {
                return new IStation.Calc.ErQuCalcHelper_2_递归_定水量();
            }

        }

        private static DateTime? GetMaxLimitWaterBoxTime(IStation.CalcModel.AnaRequest anaRequest)
        private static DateTime? GetMaxReservoirLevelTime(IStation.CalcModel.AnaRequest anaRequest)
        {
            if (string.IsNullOrEmpty(anaRequest.MaxLimitWaterBoxTime))
            if (string.IsNullOrEmpty(anaRequest.MaxReservoirLevelTime))
            {
                return null;
            }


            DateTime time;
            if (DateTime.TryParse(anaRequest.MaxLimitWaterBoxTime, out time))
            if (DateTime.TryParse(anaRequest.MaxReservoirLevelTime, out time))
            {
                return time;
            }

            if (anaRequest.MaxLimitWaterBoxTime.Contains(":"))
            if (anaRequest.MaxReservoirLevelTime.Contains(":"))
            {
                var sss = anaRequest.MaxLimitWaterBoxTime.Split(':');
                var sss = anaRequest.MaxReservoirLevelTime.Split(':');
                if (sss.Count() == 2)
                {
                    int hour = 0;
@@ -72,22 +71,20 @@
            else
            {
                int hour = 0;
                if (int.TryParse(anaRequest.MaxLimitWaterBoxTime, out hour))
                if (int.TryParse(anaRequest.MaxReservoirLevelTime, out hour))
                {
                    if (hour < anaRequest.StartTime.Hour)
                        return new DateTime(anaRequest.EndTime.Year, anaRequest.EndTime.Month, anaRequest.EndTime.Day, hour, 0, 0);
                    else
                        return new DateTime(anaRequest.StartTime.Year, anaRequest.StartTime.Month, anaRequest.StartTime.Day, hour, 0, 0);
                }


            }

            return null;
        }

        /// <summary>
        /// 
        ///
        /// </summary>
        public class RunBlock
        {
@@ -101,18 +98,26 @@
        }

        /// <summary>
        /// 
        ///
        /// </summary>
        protected ErQuCalcBaseHelper()
        {
            _calStartTime = DateTime.Now;
            _calEndTime = DateTime.Now.AddDays(1);
            var calStartTime = DateTime.Now;
            _calStartTime =  new DateTime(calStartTime.Year, calStartTime.Month, calStartTime.Day, calStartTime.Hour, 0, 0);
            _calEndTime = _calStartTime.AddDays(1);
        }
        public void SetCalcTimeRange(DateTime calStartTime, DateTime calEndTime)

        public void SetCalcTimeRange(DateTime calStartTime, DateTime calEndTime,int calcSpaceMinute)
        {
            this._calStartTime = calStartTime;
            this._calEndTime = calEndTime;
            if (calcSpaceMinute <= 1)
            {
                calcSpaceMinute = 10;
            }
            this._calcSpaceMinute = calcSpaceMinute;
            this._calStartTime = new DateTime(calStartTime.Year, calStartTime.Month, calStartTime.Day, calStartTime.Hour, ((int)(calStartTime.Minute/ calcSpaceMinute)) * calcSpaceMinute, 0);  
            this._calEndTime = new DateTime(calEndTime.Year, calEndTime.Month, calEndTime.Day, calEndTime.Hour, ((int)(calEndTime.Minute / calcSpaceMinute)) * calcSpaceMinute, 0);
        }

        //
        public Action<string> OnShowDebugInfo = null;

@@ -120,22 +125,22 @@
        protected IStation.CalcModel.eCalcOptType _clacOptType = CalcModel.eCalcOptType.功率;

        /// <summary>
        /// 
        ///
        /// </summary>
        protected double _stationTotalFlow = 0;//供水总量(不一定有值 å•ä½: å¨) 
        protected double _flowInTotalFlow = 0;//取水总量(不一定有值 å•ä½: å¨)

        /// <summary>
        /// 
        ///
        /// </summary>
        /// <param name="anaRequest"></param>
        public void SetAnaRequest(IStation.CalcModel.AnaRequest anaRequest)
        {
            this._start_level水库水位 = anaRequest.CurrentWaterBoxLevel; 
            this._start_level水库水位 = anaRequest.StartReservoirLevel;
            this._clacOptType = anaRequest.CalcOptType;

            if(anaRequest.IsKnownStartOpenPump)
            { 
                if(anaRequest.StartOpenPumpIndexArray == null)
           
            if (anaRequest.IsKnownStartOpenPump)
            {
                if (anaRequest.StartOpenPumpIndexArray == null)
                {//没有赋值就是表示不知道, å¦‚果都不开机, èµ‹å€¼[]
                    this._startOpenPumpCount = -1;
                }
@@ -151,7 +156,7 @@
            }

            if (anaRequest.TotalFlowIn != null)
                this._stationTotalFlow = anaRequest.TotalFlowIn.Value;
                this._flowInTotalFlow = anaRequest.TotalFlowIn.Value;

            this.Initial水库参数(anaRequest);

@@ -169,11 +174,15 @@
            error_info = null;

            #region æ£€æŸ¥æ•°æ®

            if (this._calStartTime >= this._calEndTime)
            {
                error_info = "时间范围不对";
                return null;
            }
 


            if (this._allPumpInfo == null || this._allPumpInfo.Count() != 5)
            {
                error_info = "泵台数不正确";
@@ -194,30 +203,23 @@
                    return null;
                }
            }
            #endregion







            #endregion æ£€æŸ¥æ•°æ®

            // List<AnaPrj> listPrj;
            System.Diagnostics.Stopwatch sw2 = new System.Diagnostics.Stopwatch();
            sw2.Start();
            //System.Diagnostics.Stopwatch sw2 = new System.Diagnostics.Stopwatch();
            //sw2.Start();

            //迭代浮动, ä¸è¦æ¯æ¬¡éƒ½ä»Ž0开始, å¯èƒ½å·®å‡ åˆ†é’Ÿæ›´ä¼˜, åŽé¢æ­¤å˜é‡ä¹Ÿè¦è¿­ä»£
            int dd_minute = 0;
            //
            CalcTimeData(dd_minute);

            // çœŸæ­£å¼€å§‹åˆ†æž 
            // çœŸæ­£å¼€å§‹åˆ†æž
            var optPrj = CalcOptPrjsCore();
            sw2.Stop();
            //sw2.Stop();


            var seconds = (int)(sw2.ElapsedMilliseconds / 1000);
            //var seconds = (int)(sw2.ElapsedMilliseconds / 1000);
            //故意加1分钟
            //if (this._calcSpaceMinute >= 5)
            //{
@@ -239,37 +241,35 @@
            optPrj.StartTime = this._calStartTime;
            optPrj.EndTime = this._calEndTime;



            OnShowDebugInfo.Invoke(string.Format("计算用时: {0} ç§’", seconds));
            // OnShowDebugInfo.Invoke(string.Format("计算用时: {0} ç§’", seconds));

            return optPrj;
        }


        /// <summary>
        /// 
        ///
        /// </summary>
        /// <returns></returns>
        protected virtual AnaPrj CalcOptPrjsCore()
        {
            return null;
        }

        /// <summary>
        /// 
        ///
        /// </summary>
        protected ulong _totalCalcCount = 0;//计算次数

        protected ulong _totalCacheCount = 0;//缓存使用次数



        //时间范围
        protected DateTime _calStartTime;
        protected DateTime _calEndTime;

        protected DateTime _calEndTime;

        //泵信息
        internal List<IStation.CalcModel.PumpCurveInfo> _allPumpInfo = null;

        public void SetPumpInfo(List<IStation.CalcModel.PumpInfo> allPumpInfo)
        {
            if (allPumpInfo == null)
@@ -307,18 +307,23 @@

        //计算时间跨度
        protected int _calcSpaceMinute = 5;
        public int CalcSpaceMinute { get { return _calcSpaceMinute; } set { _calcSpaceMinute = value; } }

        public int CalcSpaceMinute
        { get { return _calcSpaceMinute; } set { _calcSpaceMinute = value; } }

        /// <summary>
        /// ä¸­é—´æœ€å¤šåˆ‡æ¢æ¬¡æ•°
        /// </summary>
        protected int _maxPumpSwitchCount = 3;
        public int MaxPumpSwitchCount { get { return _maxPumpSwitchCount; } set { _maxPumpSwitchCount = value; } }

        public int MaxPumpSwitchCount
        { get { return _maxPumpSwitchCount; } set { _maxPumpSwitchCount = value; } }

        /// <summary>
        /// ä¸è®¸åˆ‡æ³µæ—¶é—´
        /// </summary>
        protected List<IStation.CalcModel.TimeRange> _limitSwitchPumpTimes = null;

        public List<IStation.CalcModel.TimeRange> LimitSwitchPumpTimes
        {
            get { return _limitSwitchPumpTimes; }
@@ -328,11 +333,11 @@
            }
        }


        /// <summary>
        /// ä¸è®¸å¼€æ³µæ—¶é—´
        /// </summary>
        protected List<IStation.CalcModel.TimeRange> _limitOpenPumpTimes = null;

        public List<IStation.CalcModel.TimeRange> LimitOpenPumpTimes
        {
            get { return _limitOpenPumpTimes; }
@@ -341,9 +346,6 @@
                _limitOpenPumpTimes = value;
            }
        }




        #region æ³µå‡ºå£åŽ‹åŠ›

@@ -364,8 +366,8 @@
            return 0.068 * 100;
            //return _outBoxLevels.First().Level;
        }
        #endregion

        #endregion æ³µå‡ºå£åŽ‹åŠ›

        /// <summary>
        /// èŽ·å–扬程(暂时简单处理)
@@ -407,16 +409,16 @@
            //    }
            //}


            m1 = m1 - dropHeight;


            return (m2 - m1);
        }

        //电费
        protected List<ElecPriceMonthSetting> _elecPrice = null;

        public List<ElecPriceMonthSetting> ElecPrice { get => _elecPrice; set => _elecPrice = value; }

        public double CalcMoney(DateTime time, double power)
        {
            var month = time.Month;
@@ -435,11 +437,11 @@
            }
        }


        /// <summary>
        /// æœ€å°‘开泵时间
        /// </summary>
        public int MinOpenPumpMinute = 30;

        protected int _minTimeCountOpenPump = 0;
        public int MinSwitchPumpMinute = 30;
        protected int _minTimeCountSwitch = 0;
@@ -448,16 +450,18 @@
        /// åˆå§‹åŒ–开机台数
        /// </summary>
        protected int _startOpenPumpCount = -1;

        protected List<int> _startOpenPumpArray = null;

        /// <summary>
        /// 
        ///
        /// </summary>
        protected bool isDispDebug = false;

        public bool IsDispDebug { get => isDispDebug; set => isDispDebug = value; }

        /// <summary>
        /// 
        ///
        /// </summary>
        /// <param name="prj"></param>
        /// <returns></returns>
@@ -501,7 +505,5 @@

            return true;
        }


    }
}
}