From 25beb2c84d65c3f77361a5add4de3eeb172d37f1 Mon Sep 17 00:00:00 2001
From: duheng <2784771470@qq.com>
Date: 星期四, 05 九月 2024 10:23:41 +0800
Subject: [PATCH] 对切换泵时间间隔进行赋值

---
 WebApi/Controllers/ZyPrjController.cs |  645 ++++++++++++++++++++++++++++++++++++++++++++++++++--------
 1 files changed, 552 insertions(+), 93 deletions(-)

diff --git a/WebApi/Controllers/ZyPrjController.cs b/WebApi/Controllers/ZyPrjController.cs
index 08ea833..558f085 100644
--- a/WebApi/Controllers/ZyPrjController.cs
+++ b/WebApi/Controllers/ZyPrjController.cs
@@ -16,8 +16,6 @@
 using System.Threading.Tasks;
 using System.Web;
 using System.Web.Http;
-using System.Web.UI.WebControls;
-using System.Web.UI.WebControls.WebParts;
 
 namespace IStation.ZyDto
 {
@@ -28,14 +26,16 @@
 
         public string StartTime { get; set; }
         public string EndTime { get; set; }
-        public int? StartOpenCount { get; set; } = -1;
-        public double? TotalFlowIn { get; set; }//鍙栨按鎬婚噺 (鍗曚綅 鍚�)
+        //public int? StartOpenCount { get; set; } = -1;//宸蹭綔搴�
 
         public string StartReservoirLevel { get; set; }//寮�濮嬫按搴撴按浣�(鍙┖):鍗曚綅m
+        public string StartOpenPumpIndexArray { get; set; }//寮�濮嬫満娉靛紑鏈虹姸鎬�(涓嶅彲绌�)
+
+        public string TotalFlowIn { get; set; }//鍙栨按鎬婚噺 (鍗曚綅 鍚�)
+        public string TotalFlowOut { get; set; }//渚涙按鎬婚噺 (鍗曚綅 鍚�) 涓嶈緭鍏ュ氨鐢ㄩ娴嬪��
+
         public string MaxReservoirLevel { get; set; }//鏈�楂樻按搴撴按浣嶉檺鍒�(鍙┖):鍗曚綅m
         public string MaxReservoirLevelTime { get; set; }//鏈�楂樻按搴撴按浣嶉檺鍒舵椂闂�(鍙┖) 鏃堕棿鏍煎紡
-
-        public string IsSubmit { get; set; }//璁$畻瀹�,鏄惁鎺ㄩ��
     }
 }
 
@@ -68,6 +68,9 @@
             {
                 return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "EndTime is null" };
             }
+            //
+            IStation.LogHelper.Info("--------------------------START-----------------------------------------");
+            IStation.LogHelper.Info(string.Format("Zy Prj Calc Request:  {0}", JsonHelper.Object2Json(request)));
 
             DateTime start_timme = DateTime.Now;
             DateTime end_timme = DateTime.Now;
@@ -91,87 +94,327 @@
                 IStation.LogHelper.Error(string.Format("ZyPrjRequest Time:{0}-{1} 鏃堕棿鑼冨洿閿欒,涓嶈兘瓒呰繃24灏忔椂", start_timme, end_timme));
                 return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "鏃堕棿鑼冨洿閿欒,涓嶈兘瓒呰繃24灏忔椂" };
             }
-            if (request.TotalFlowIn == null)
-            {
-                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "鍙栨按鎬婚噺閿欒" };
-            }
-            if (request.TotalFlowIn < 10000)
-            {
-                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "娉ㄦ剰鍙栨按鎬婚噺鍗曚綅鏄惃,褰撳墠鍙傛暟鍙傛暟杩囧皬" };
-            }
-
-            IStation.LogHelper.Info(string.Format("Zy Prj  Time:{0}-{1} ,StartOpenCount:{2}, TotalFlowIn:{3}",
-                start_timme, end_timme, request.StartOpenCount, request.TotalFlowIn));
 
             IStation.CalcModel.AnaRequest anaRequest = new AnaRequest();
             anaRequest.CalcOptType = (eCalcOptType)IStation.AnaGlobalParas.Setting.OptSortType;
             anaRequest.StartTime = start_timme;
             anaRequest.EndTime = end_timme;
-            anaRequest.WaterLevels闀挎睙 = GetTide3Day(start_timme);
+            anaRequest.WaterLevels闀挎睙 = GetTide3Day(_tideSouce, start_timme);
 
-            anaRequest.TotalFlow鍙栨按鎬婚噺 = request.TotalFlowIn;
+            #region 鍙栨按鎬婚噺
 
-            if (request.StartOpenCount == null)
+            if (!string.IsNullOrEmpty(request.TotalFlowIn) && !string.IsNullOrWhiteSpace(request.TotalFlowIn))
             {
-                anaRequest.StartOpenCount = -1;
-            }
-            else
-            {
-                anaRequest.StartOpenCount = request.StartOpenCount.Value;
+                double TotalFlowIn = 0;
+                if (!double.TryParse(request.TotalFlowIn, out TotalFlowIn))
+                {
+                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "璇疯緭鍏ユ暟瀛楀瀷鍙栨按鎬婚噺,鎺ュ彈鍒扮殑杈撳叆鍊兼槸:" + request.TotalFlowIn };
+                }
+                if (TotalFlowIn < 10000)
+                {
+                    IStation.LogHelper.Info(string.Format("Zy Prj  Time:{0}-{1} ,  娉ㄦ剰鍙栨按鎬婚噺鍗曚綅鏄惃,褰撳墠鍙傛暟鍙傛暟杩囧皬",
+                start_timme, end_timme));
+                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "娉ㄦ剰鍙栨按鎬婚噺鍗曚綅鏄惃,褰撳墠鍙傛暟鍙傛暟杩囧皬" };
+                }
+
+                anaRequest.TotalFlowIn = TotalFlowIn;
             }
 
-            #region 闄堣姘村簱姘翠綅
+            #endregion 鍙栨按鎬婚噺
 
-            if (!string.IsNullOrEmpty(request.StartReservoirLevel))
-            {
-                anaRequest.CurrentWaterBoxLevel = Convert.ToDouble(request.StartReservoirLevel);
-            }
-            else
-            {
-                /*      var tagDict = new Dictionary<string, string> { { "_0402010201030103006", "闄堣姘村簱姘翠綅" } };
-                     var input = new { search = "real", tablename = "闄堣鏅鸿兘璋冨害" };
-                     var tags = tagDict.Keys.ToList();
-                     var realScadaRecordList = ZyConnectHelper.GetRealScadaResultAsync(tags, input).GetAwaiter().GetResult();
-                      if (realScadaRecordList != null && realScadaRecordList.Count() > 0)
-                     {
-                         anaRequest.CurrentWaterBoxLevel = realScadaRecordList.Last().Value;
-                     }*/
-                anaRequest.CurrentWaterBoxLevel = ZyConnectHelper.GetRealReservoirWaterLevel();
-            }
+            #region 姘翠綅瑕佹眰
 
-            #endregion 闄堣姘村簱姘翠綅
-
-            if (!string.IsNullOrEmpty(request.MaxReservoirLevel))
-                anaRequest.MaxLimitWaterBoxLevel = Convert.ToDouble(request.MaxReservoirLevel);
             if (!string.IsNullOrEmpty(request.MaxReservoirLevelTime))
-                anaRequest.MaxLimitWaterBoxTime = request.MaxReservoirLevelTime;
+            {
+                anaRequest.MaxReservoirLevelTime = request.MaxReservoirLevelTime;
+            }
+
+            if (!string.IsNullOrEmpty(request.MaxReservoirLevel) && !string.IsNullOrWhiteSpace(request.MaxReservoirLevel))
+            {
+                double MaxReservoirLevel = 0;
+                if (!double.TryParse(request.MaxReservoirLevel, out MaxReservoirLevel))
+                {
+                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "璇疯緭鍏ュ悎鐞嗙殑姘翠綅瑕佹眰鍊�" };
+                }
+                if (MaxReservoirLevel < 1 || MaxReservoirLevel > 10)
+                {
+                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "璇疯緭鍏ュ悎鐞嗙殑姘翠綅瑕佹眰鍊�" };
+                }
+                anaRequest.MaxReservoirLevel = MaxReservoirLevel;
+            }
+            else
+            {
+                if (string.IsNullOrEmpty(request.TotalFlowIn) || string.IsNullOrWhiteSpace(request.TotalFlowIn))
+                {
+                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "璇疯緭鍏ュ彇姘存�婚噺鎴栨按浣嶈姹�" };
+                }
+                double TotalFlowIn = 0;
+                if (!double.TryParse(request.TotalFlowIn, out TotalFlowIn))
+                {
+                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "璇疯緭鍏ユ暟瀛楀瀷鍙栨按鎬婚噺,鎺ュ彈鍒扮殑杈撳叆鍊兼槸:" + request.TotalFlowIn };
+                }
+            }
+
+            #endregion 姘翠綅瑕佹眰
+
+            #region 渚涙按閲�
+
+            double TotalFlowOut = 0;
+            double TotalFlowOutPrecid = 0;//棰勬祴鍊肩殑渚涙按鎬婚噺
+
+            if (string.IsNullOrEmpty(request.TotalFlowOut) || string.IsNullOrWhiteSpace(request.TotalFlowOut))
+            {//鐢ㄩ娴嬪��
+                #region 鐢ㄩ娴嬪��
+
+                anaRequest.PerHourFlowOut = new List<double>();
+                IStation.DAL.WaterPredictRecord dal = new DAL.WaterPredictRecord();
+                var water_records = dal.GetByHourRangle(start_timme, end_timme);
+                //LogHelper.Info(water_records.Count.ToString());
+                if (water_records == null)
+                {
+                    IStation.LogHelper.Info(string.Format("Zy Prj  Time:{0}-{1} ,  姘翠綅棰勬祴鏁版嵁涓虹┖,璇峰厛淇濇寔姘翠綅棰勬祴鏈嶅姟姝e父杩愯",
+                start_timme, end_timme));
+                    return new IStation.Dto.ApiResult<string>() { Code = ApiResultCode.Error, Data = "姘翠綅棰勬祴鏁版嵁涓虹┖,璇峰厛淇濇寔姘翠綅棰勬祴鏈嶅姟姝e父杩愯" };
+                }
+                var count = (end_timme - start_timme).TotalHours;
+                if (water_records.Count != count)
+                {
+                    IStation.LogHelper.Info(string.Format("Zy Prj  Time:{0}-{1} ,  棰勬祴鏁版嵁鑾峰彇澶辫触,鏁版嵁鏉℃棤娉曞尮閰�, 妫�鏌ユ槸鍚﹂娴嬫湇鍔′腑鏂�",
+                start_timme, end_timme));
+                    return new IStation.Dto.ApiResult<string>() { Code = ApiResultCode.Error, Data = "棰勬祴鏁版嵁鑾峰彇澶辫触,鏁版嵁鏉℃棤娉曞尮閰�, 妫�鏌ユ槸鍚﹂娴嬫湇鍔′腑鏂�" };
+                }
+
+                foreach (var r in water_records)
+                {
+                    if (r.States == 0)
+                    {
+                        var error_info11 = string.Format("棰勬祴鏁版嵁寮傚父,鏃犳硶杩涜姘翠綅璁$畻:{0} {1},{2}", r.DayHour, r.LastPredictValue, r.Description);
+                        IStation.LogHelper.Info(string.Format("Zy Prj  Time:{0}-{1} , {2}}",
+                start_timme, end_timme, error_info11));
+                        return new IStation.Dto.ApiResult<string>()
+                        {
+                            Code = ApiResultCode.Error,
+                            Data = error_info11
+                        };
+                    }
+                    TotalFlowOutPrecid += r.LastPredictValue;
+                    anaRequest.PerHourFlowOut.Add(r.LastPredictValue);//璁$畻涓敤鍚�
+                }
+                IStation.LogHelper.Info(string.Format("  鑾峰彇姘撮噺棰勬祴鍊�:  {0}   ", string.Join(",", anaRequest.PerHourFlowOut)));
+
+                #endregion 鐢ㄩ娴嬪��
+            }
+            else
+            {
+                if (!double.TryParse(request.TotalFlowOut, out TotalFlowOut))
+                {
+                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "娉ㄦ剰渚涙按鎬婚噺杈撳叆鍙傛暟鏃犳硶璇嗗埆,鍙傛暟鏄�:" + request.TotalFlowOut };
+                }
+                if (TotalFlowOut < 10000)
+                {
+                    IStation.LogHelper.Info(string.Format("Zy Prj  Time:{0}-{1} ,  娉ㄦ剰鍙栨按鎬婚噺鍗曚綅鏄惃,褰撳墠鍙傛暟鍙傛暟杩囧皬",
+                start_timme, end_timme));
+                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "娉ㄦ剰渚涙按鎬婚噺鍗曚綅鏄惃,褰撳墠鍙傛暟鍙傛暟杩囧皬" };
+                }
+                //TotalFlowOut = TotalFlowOut / 10000;//璁$畻涓敤鍚�
+                List<double> list = new List<double>();
+                var count = (end_timme - start_timme).TotalHours;
+                for (var d = start_timme; d <= end_timme; d = d.AddHours(1))
+                {
+                    list.Add(Math.Round(TotalFlowOut / count, 1));
+                }
+                anaRequest.PerHourFlowOut = list;
+            }
+
+            #endregion 渚涙按閲�
+
+            //寮�濮嬫椂鐨勫紑鏈虹姸鎬�
+            List<int> StartOpenPumpIndexArray = new List<int>();
+            if (!string.IsNullOrEmpty(request.StartOpenPumpIndexArray))
+            {
+                var sss = request.StartOpenPumpIndexArray.Split(',');
+                foreach (var item in sss)
+                {
+                    if (int.TryParse(item, out int index))
+                    {
+                        if (index < 0 || index > 4)
+                        {
+                            return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "寮�濮嬫椂鐨勫紑鏈虹姸鎬�,鏈烘车瑙掓爣瑕佹眰涓嶈秴杩�4" };
+                        }
+                        StartOpenPumpIndexArray.Add(index);
+                    }
+                    else
+                    {
+                        return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "寮�濮嬫椂鐨勫紑鏈虹姸鎬�,鍙傛暟涓嶆纭�" };
+                    }
+                }
+            }
+            anaRequest.IsKnownStartOpenPump = true;
+            anaRequest.StartOpenPumpIndexArray = StartOpenPumpIndexArray;
+
+            //闄堣姘村簱姘翠綅
+            if (string.IsNullOrEmpty(request.StartReservoirLevel))
+            {
+                IStation.LogHelper.Info(" 鏈缃紑濮嬫椂姘村簱姘翠綅 (Error: StartReservoirLevel is null)");
+                return new IStation.Dto.ApiResult<string>() { Code = ApiResultCode.Error, Data = "鏈缃紑濮嬫椂姘村簱姘翠綅 (Error: StartReservoirLevel is null) " };
+            }
+            anaRequest.StartReservoirLevel = Convert.ToDouble(request.StartReservoirLevel);
+            if (anaRequest.StartReservoirLevel < 2)
+            {
+                IStation.LogHelper.Info(string.Format("  璁剧疆寮�濮嬫椂姘村簱姘翠綅鐨勬暟鎹繃灏� (Error: StartReservoirLevel is {0}})",
+                    anaRequest.StartReservoirLevel));
+                return new IStation.Dto.ApiResult<string>()
+                {
+                    Code = ApiResultCode.Error,
+                    Data = string.Format("  璁剧疆寮�濮嬫椂姘村簱姘翠綅鐨勬暟鎹繃灏� (Error: StartReservoirLevel is {0}})",
+                    anaRequest.StartReservoirLevel)
+                };
+            }
+            //bool isTemp = false;
+            //if (!string.IsNullOrEmpty(request.IsTemporary))
+            //{
+            //    isTemp = Convert.ToBoolean(request.IsTemporary);
+            //}
 
             var calcHelper = new IStation.CalcPrjHelper();
             AnaPrj defaultPrj = null;
             string error_info = calcHelper.Calc(anaRequest, out defaultPrj);
+
             if (!string.IsNullOrEmpty(error_info) || defaultPrj == null)
             {
+                IStation.LogHelper.Info(string.Format("Zy Prj  璁$畻閿欒:  \r\n {0}  ", error_info));
                 return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "璁$畻閿欒, 鍘熷洜鏄�:" + error_info };
             }
+            else
+            {
+                //  IStation.LogHelper.Info(string.Format("Zy Prj  璁$畻鎴愬姛:  \r\n {0}  ",  JsonHelper.Object2Json(defaultPrj)));
+            }
+            IStation.LogHelper.Info("-----------------------------END--------------------------------------");
 
             //淇濆瓨鏂规
             var ret = Common.HistoryAnaPrjFileHelper.SavePrj(IStation.AnaGlobalParas.Setting, anaRequest, defaultPrj);
 
+            //
             var dto_prj = ToPrjDto(defaultPrj);
+            if (TotalFlowOutPrecid > 1)
+            {
+                dto_prj.FlowTotalOut = Math.Round(TotalFlowOutPrecid / 10000, 1);
+            }
+            else
+            {
+                dto_prj.FlowTotalOut = TotalFlowOut;
+            }
 
             #region 鎺ㄩ��
 
-            if (!string.IsNullOrEmpty(request.IsSubmit) && Convert.ToBoolean(request.IsSubmit))
-            {
-                Task.Run(() =>
-                {
-                    _ = ZyProjectHelper.SubmitPrj(defaultPrj);
-                });
-            }
+            //if (!string.IsNullOrEmpty(request.IsSubmit) && Convert.ToBoolean(request.IsSubmit))
+            //{
+            //    Task.Run(() =>
+            //    {
+            //        _ = ZyProjectHelper.SubmitPrj(defaultPrj);
+            //    });
+            //}
 
             #endregion 鎺ㄩ��
 
+            // IStation.LogHelper.Info(string.Format(" 浜х敓璁$畻鏂规:{0}", dto_prj.schemeID));
+
             return new IStation.Dto.ApiResult<IStation.ZyDto.SubmitPrj>(dto_prj) { Code = ApiResultCode.Success };
+        }
+
+        /// <summary>
+        /// 鑾峰彇鍒濆姘翠綅,鍜屽綋鏃剁殑寮�鏈虹姸鎬�
+        /// </summary>
+        /// <param name="request"></param>
+        /// <returns></returns>
+        [Route("GetAnaStartPara")]
+        [HttpGet]
+        public IStation.Dto.ApiResult GetAnaStartPara(string AnaStartTime)
+        {
+            if (string.IsNullOrEmpty(AnaStartTime)) { return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "day 鏍煎紡涓嶆纭�" }; }
+
+            try
+            {
+                DateTime last_end_time;
+                if (!DateTime.TryParse(AnaStartTime, out last_end_time))
+                {
+                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "day 鏍煎紡涓嶆纭�" };
+                }
+
+                IStation.CalcModel.AnaRequestBase requestBase;
+                var prj = Common.HistoryAnaPrjFileHelper.GetByEndTime澶т簬(last_end_time, out requestBase);
+                if (prj == null)
+                {
+                    IStation.LogHelper.Info(string.Format("GetAnaStartPara 鏈壘鍒皗0}缁撴潫鐨勫垎鏋愰」鐩�", AnaStartTime));
+                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = string.Format("鏈壘鍒皗0}缁撴潫鐨勫垎鏋愰」鐩�", AnaStartTime) };
+                }
+
+                IStation.CalcModel.ZyStartInfo zyStartInfo = new IStation.CalcModel.ZyStartInfo();
+                //zyStartInfo.OpenPumpStatus = prj.EndTimeOpenPumpStatus;
+                if (prj.EndTimeOpenPumpStatus != null && prj.EndTimeOpenPumpStatus.Count > 0)
+                {
+                    zyStartInfo.OpenPumpStatus = string.Join(",", prj.EndTimeOpenPumpStatus);
+                }
+
+                var near_pt = prj.NearPointTime(DateTime.Now);
+                if (near_pt == null)
+                {
+                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = string.Format("鍦ㄩ」鐩腑, 鏈壘鍒皗0}鐨勬按搴撴按浣嶆暟鎹�", DateTime.Now) };
+                }
+
+                var new_yuce = near_pt.WaterLevelH;//鏄ㄥぉ棰勬祴姘翠綅
+                double now_level = ZyConnectHelper.GetRealReservoirWaterLevel();//瀹炴椂姘翠綅
+                if (prj.BlockTimes == null || prj.BlockTimes.Count() == 0)
+                {
+                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "鍦ㄩ」鐩腑, BlockTimes鍊间负绌�" };
+                }
+                if (prj.BlockTimes.Last().PointTimes == null || prj.BlockTimes.Last().PointTimes.Count() == 0)
+                {
+                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "鍦ㄩ」鐩腑, 鏈�鍚庝竴涓� BlockTime鐨� PointTimes 灞炴�у�间负绌�" };
+                }
+                var lz = prj.BlockTimes.Last().PointTimes.Last().WaterLevelH;
+                var lz_pt = prj.FindPointTime(last_end_time);
+                if (lz_pt != null)
+                {
+                    lz = lz_pt.WaterLevelH;
+                }
+
+                double start_yuce = lz + now_level - new_yuce;
+
+                IStation.LogHelper.Info(string.Format("GetAnaStartPara StartTime {0}    Level: {1},{2},{3} ,{4}  ", AnaStartTime, lz, now_level, new_yuce, start_yuce));
+
+                zyStartInfo.ReservoirWaterLevel = Math.Round(start_yuce, 3);
+                return new IStation.Dto.ApiResult<IStation.CalcModel.ZyStartInfo>(zyStartInfo) { Code = ApiResultCode.Success };
+            }
+            catch (Exception ex)
+            {
+                IStation.LogHelper.Error("GetAnaStartPara line 277", ex);
+                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = string.Format("鍦ㄩ」鐩腑, 鎺ュ彛鎶ラ敊: {0} ", ex.Message) };
+            }
+        }
+
+        /// <summary>
+        /// 纭璋冨害鏂规
+        /// </summary>
+        /// <param name="ana"></param>
+        /// <returns></returns>
+        [Route("ConfirmSchemeByID")]
+        [HttpPost]
+        public IStation.Dto.ApiResult ConfirmSchemeByID(string ID)
+        {
+            if (string.IsNullOrEmpty(ID) || ID == "string")
+            {
+                return new IStation.Dto.ApiResult<bool>(false);
+            }
+            var dal = new IStation.DAL.AnaProject();
+            var info = dal.SetConfirmStatusByID(ID);
+            if (string.IsNullOrEmpty(info))
+                return new IStation.Dto.ApiResult<bool>(true);
+            else
+            {
+                IStation.LogHelper.Info(string.Format(" ConfirmSchemeByID error ID:{0}, reason:{1}", ID, info));
+                return new IStation.Dto.ApiResult<bool>(false);
+            }
         }
 
         #region 鎹㈢畻鎴怐TO
@@ -186,34 +429,64 @@
                 defaultPrj.ID = $"{time.Year}{time.Month}{time.Day}{time.Hour}{time.Minute}{time.Second}";
             }
             dto_prj.schemeID = defaultPrj.ID;
+            dto_prj.schemeName = defaultPrj.Name;
             dto_prj.Day = defaultPrj.StartTime.ToString("yyyy-MM-dd");
             dto_prj.StartTime = defaultPrj.StartTime.ToString("yyyy-MM-dd HH:mm:ss");
             dto_prj.EndTime = defaultPrj.EndTime.ToString("yyyy-MM-dd HH:mm:ss");
 
-            dto_prj.FlowTotal = Math.Round(defaultPrj.SumFlow, 0);
+            dto_prj.FlowTotalIn = Math.Round(defaultPrj.SumFlow, 0);
             dto_prj.PowerTotal = Math.Round(defaultPrj.SumPower, 0);
             dto_prj.MoneyTotal = Math.Round(defaultPrj.SumMoney, 0);
 
-            dto_prj.Items = new List<ZyDto.SubmitPrjItem>();
-            foreach (var bt in defaultPrj.BlockTimes)
+            dto_prj.BlockTimes = new List<ZyDto.SubmitPrjBlockTime>();
+            double maxHeight = 0;
+            double startHeight = 0;
+
+            if (defaultPrj.BlockTimes != null)
             {
-                if (bt.OpenPumpCount == 0)
-                    continue;
-                ZyDto.SubmitPrjItem dto_item = new ZyDto.SubmitPrjItem();
-                dto_item.StartTime = bt.StartTime;
-                dto_item.EndTime = bt.EndTime;
-                dto_item.OpenPumpCount = bt.OpenPumpCount;
-                dto_item.OpenPumpIndexs = IStation.AnaGlobalParas.Setting.GetOpenPumpIndexArrays(bt.OpenPumpCount);
-                dto_prj.Items.Add(dto_item);
-            }
-            if (defaultPrj.PointTimes != null)
-            {
-                dto_prj.Records = new List<SubmitPrjTime>();
-                foreach (var bt in defaultPrj.PointTimes)
+                startHeight = defaultPrj.BlockTimes.First().ReservoirStartHeight;
+                foreach (var bt in defaultPrj.BlockTimes)
                 {
-                    dto_prj.Records.Add(new SubmitPrjTime(bt));
+                    if (bt.OpenPumpIndexs == null)
+                        continue;
+                    ZyDto.SubmitPrjBlockTime dto_item = new ZyDto.SubmitPrjBlockTime();
+                    dto_item.StartTime = bt.StartTime;
+                    dto_item.EndTime = bt.EndTime;
+                    dto_item.OpenPumpCount = bt.OpenPumpIndexs.Count;
+                    dto_item.OpenPumpIndexs = bt.OpenPumpIndexs;
+                    dto_item.StartSwitchGroupID = bt.StartSwitchGroupID;
+
+                    if (bt.PointTimes != null)
+                    {
+                        dto_item.Records = new List<SubmitPrjTime>();
+                        foreach (var bt2 in bt.PointTimes)
+                        {
+                            maxHeight = Math.Max(maxHeight, bt2.WaterLevelH);
+                            dto_item.Records.Add(new SubmitPrjTime(bt2));
+                        }
+                    }
+
+                    dto_prj.BlockTimes.Add(dto_item);
                 }
             }
+            dto_prj.MaxWaterLevelH = maxHeight;
+            dto_prj.StartWaterLevelH = startHeight;
+            dto_prj.Switchs = new List<SubmitPrjSwitchInfo>();
+            if (defaultPrj.PumpSwitchs != null)
+            {
+                foreach (var bt in defaultPrj.PumpSwitchs)
+                {
+                    ZyDto.SubmitPrjSwitchInfo dto_item = new ZyDto.SubmitPrjSwitchInfo();
+                    dto_item.Index = bt.Index;
+                    dto_item.GroupID = bt.GroupID;//鍒嗙粍ID
+                    dto_item.PumpIndex = bt.PumpIndex;//娉佃鏍�
+                    dto_item.Time = bt.Time.ToString("yyyy-MM-dd HH:mm:ss");//鏃堕棿
+                    dto_item.SwitchType = bt.SwitchType;///1 寮�鏈� 0 鍏虫満
+
+                    dto_prj.Switchs.Add(dto_item);
+                }
+            }
+
             return dto_prj;
         }
 
@@ -237,8 +510,10 @@
             {
                 return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "day 鏍煎紡涓嶆纭�" };
             }
+            IStation.LogHelper.Info(string.Format(" api GetHistoryByDay {0}    format: {1}  ", day, d));
+
             IStation.CalcModel.AnaRequestBase requestBase = null;
-            var prj = Common.HistoryAnaPrjFileHelper.GetByDay(d, out requestBase);
+            var prj = Common.HistoryAnaPrjFileHelper.GetByCreateDay(d, out requestBase);
 
             if (prj != null)
             {
@@ -290,9 +565,42 @@
             IStation.Dto.ZyPrjAnaSetting dto_setting = new ZyPrjAnaSetting();
             dto_setting.MinOpenTimeMinute = model_setting.MinOpenTimeMinute;
             dto_setting.MinSwitchTimeMinute = model_setting.MinSwitchTimeMinute;
-            dto_setting.MaxPumpSwitchCount = model_setting.MaxPumpSwitchCountQ;
+            dto_setting.MaxPumpSwitchCount = model_setting.MaxPumpSwitchCount;
             dto_setting.OptSortType = model_setting.OptSortType;
-            dto_setting.OpenPumpIndexs = model_setting.OpenPumpIndexs;
+            dto_setting.SwitchPumpMinuteSpace = model_setting.SwitchPumpMinuteSpace;
+
+            dto_setting.OpenPumpIndexSequence = IStation.Dto.ZyPrjAnaSetting.ListToString(model_setting.OpenPumpIndexSequence);
+            dto_setting.ClosePumpIndexSequence = IStation.Dto.ZyPrjAnaSetting.ListToString(model_setting.ClosePumpIndexSequence);
+            dto_setting.OptimalPumpIndexSequence = IStation.Dto.ZyPrjAnaSetting.ListToString(model_setting.OptimalPumpIndexSequence);
+
+            //dto_setting.OpenPumpIndexSequence = BuildSequenceToDto(model_setting.OpenPumpIndexSequence);
+            //dto_setting.ClosePumpIndexSequence = BuildSequenceToDto(model_setting.ClosePumpIndexSequence);
+            //dto_setting.OptimalPumpIndexSequence = BuildSequenceToDto(model_setting.OptimalPumpIndexSequence);
+
+            //妫�淇车鐨勮鏍�, 0 琛ㄧず1鍙锋车 1 琛ㄧず浜屽彿娉� 涓虹┖,琛ㄧず娌℃湁妫�淇�
+            try
+            {
+                var overhallStatus = ZyConnectHelper.GetOverhaulStatus();
+                if (overhallStatus == null || overhallStatus.Count == 0)
+                {
+                    if (model_setting.UnablePumpIndexArray != null)
+                    {
+                        dto_setting.UnablePumpIndexArray = "";
+                        model_setting.UnablePumpIndexArray = null;
+                        IStation.Common.AnaSetting.SaveSetting(model_setting);
+                    }
+                }
+                else
+                {
+                    model_setting.UnablePumpIndexArray = overhallStatus.ToArray();
+                    dto_setting.UnablePumpIndexArray = string.Join(",", overhallStatus);
+                    IStation.Common.AnaSetting.SaveSetting(model_setting);
+                }
+            }
+            catch (Exception ex)
+            {
+                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "鏃犳硶閾炬帴宸ユ帶鏈嶅姟鍣�,閿欒鍘熷洜:" + ex.Message };
+            }
 
             if (model_setting.SwitchPumpIgnoreTimes != null)
             {
@@ -325,6 +633,8 @@
                 }
             }
 
+            IStation.LogHelper.Info("ZyPrj GetSetting : Content: " + JsonHelper.Object2Json(dto_setting));
+
             return new IStation.Dto.ApiResult<IStation.Dto.ZyPrjAnaSetting>(dto_setting);
         }
 
@@ -339,9 +649,11 @@
         {
             if (dto == null)
             {
-                return new IStation.Dto.ApiResult<bool>(false);
+                return new IStation.Dto.ApiResult<bool>(false) { Message = "鍏ュ弬涓虹┖" };
             }
             var model_setting = IStation.AnaGlobalParas.Setting;
+
+            IStation.LogHelper.Info("ZyPrj SaveSetting : Content: " + JsonHelper.Object2Json(dto));
 
             if (dto.MinOpenTimeMinute < 5)
             {
@@ -362,6 +674,11 @@
                 return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "鏈�灏戝垏娉垫椂闂� 璁剧疆杩囬暱" };
             }
             model_setting.MinSwitchTimeMinute = dto.MinSwitchTimeMinute;
+            if (dto.SwitchPumpMinuteSpace < 2 || dto.SwitchPumpMinuteSpace > 30)
+            {
+                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "鍒囨崲娉垫椂闂撮棿闅� 璁剧疆涓嶅悎鐞�" };
+            }
+            model_setting.SwitchPumpMinuteSpace = dto.SwitchPumpMinuteSpace;
 
             if (dto.MaxPumpSwitchCount < 1)
             {
@@ -371,14 +688,19 @@
             {
                 return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "鏈�澶у垏娉垫鏁� 璁剧疆杩囬暱" };
             }
-            model_setting.MaxPumpSwitchCountQ = dto.MaxPumpSwitchCount;
-
+            model_setting.MaxPumpSwitchCount = dto.MaxPumpSwitchCount;
+            if (dto.OptSortType >= 2)
+            {
+                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "OptSortType 鍙兘璁剧疆 0 鎴栬�� 1,  0浠h〃 鐢ㄧ數閲忔渶灏�  1浠h〃 鐢佃垂鏈�灏�" };
+            }
             model_setting.OptSortType = dto.OptSortType;
             if (dto.SwitchPumpIgnoreTimes != null)
             {
                 model_setting.SwitchPumpIgnoreTimes = new List<CalcModel.AnaSetting.TimeRange>();
                 foreach (var m in dto.SwitchPumpIgnoreTimes)
                 {
+                    if (m.StartHour == 0 && m.EndHour == 0 && m.StartMinute == 0 && m.EndMinute == 0)
+                        continue;
                     if (m.StartHour < 0 || m.StartHour > 24)
                     {
                         return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "涓嶈鍒囨车鏃堕棿 鏃堕棿鑼冨洿璁剧疆涓嶅悎鐞�" };
@@ -460,32 +782,169 @@
                 }
             }
 
-            if (dto.OpenPumpIndexs != null)
+            if (!string.IsNullOrEmpty(dto.OpenPumpIndexSequence))
             {
-                List<int> penPumpIndexs = new List<int>();
-                foreach (var ind in dto.OpenPumpIndexs)
+                int[] new_set_sequence;
+                var error = BuildSequenceFromDto(dto.OpenPumpIndexSequence, out new_set_sequence);
+                if (!string.IsNullOrEmpty(error))
                 {
-                    if (ind < 0 || ind > 5)
+                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "寮�娉甸『搴� " + error };
+                }
+
+                model_setting.OpenPumpIndexSequence = new_set_sequence;
+            }
+
+            if (!string.IsNullOrEmpty(dto.ClosePumpIndexSequence))// if (dto.ClosePumpIndexSequence != null)
+            {
+                int[] new_set_sequence;
+                var error = BuildSequenceFromDto(dto.ClosePumpIndexSequence, out new_set_sequence);
+                if (!string.IsNullOrEmpty(error))
+                {
+                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "鍏虫车椤哄簭 " + error };
+                }
+
+                model_setting.ClosePumpIndexSequence = new_set_sequence;
+            }
+
+            if (!string.IsNullOrEmpty(dto.OptimalPumpIndexSequence))// if (dto.OptimalPumpIndexSequence != null)
+            {
+                int[] new_set_sequence;
+                var error = BuildSequenceFromDto(dto.OptimalPumpIndexSequence, out new_set_sequence);
+                if (!string.IsNullOrEmpty(error))
+                {
+                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "璋冨害娉典紭鍏堝害椤哄簭 " + error };
+                }
+
+                model_setting.OptimalPumpIndexSequence = new_set_sequence;
+            }
+
+            //妫�淇姸鎬�, 鐩存帴璇籗CADA绯荤粺
+            //if (dto.UnablePumpIndexArray != null && dto.UnablePumpIndexArray.Count()>0)
+            //{
+            //    if (dto.UnablePumpIndexArray.Count() > 2)
+            //    {
+            //        return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "妫�淇车鏁伴噺涓嶈兘瓒呰繃2鍙� "  };
+            //    }
+            //    if (dto.UnablePumpIndexArray.Contains(5))
+            //    {
+            //        List<int> penPumpIndexs1 = new List<int>();
+            //        foreach (var p in dto.UnablePumpIndexArray)
+            //        {
+            //            penPumpIndexs1.Add(p - 1);
+            //        }
+            //        model_setting.UnablePumpIndexArray = penPumpIndexs1.ToArray();
+            //    }
+            //    else
+            //    {
+            //        model_setting.UnablePumpIndexArray = dto.UnablePumpIndexArray;
+            //    }
+            //    model_setting.Check_Optimal_UnablePumpIndexArray();
+            //}
+            //else
+            //{
+            //    model_setting.UnablePumpIndexArray = null;
+            //}
+
+            return new IStation.Dto.ApiResult<bool>(IStation.Common.AnaSetting.SaveSetting(model_setting));
+        }
+
+        /// <summary>
+        ///鑾峰彇鏈烘车妫�淇姸鎬�
+        /// </summary>
+        /// <returns></returns>
+        [Route("SynOverhaulStatus")]
+        [HttpGet]
+        public IStation.Dto.ApiResult SynOverhaulStatus()
+        {
+            var overhallStatus = ZyConnectHelper.GetOverhaulStatus();//妫�淇车鐨勮鏍�, 0 琛ㄧず1鍙锋车 1 琛ㄧず浜屽彿娉� 涓虹┖,琛ㄧず娌℃湁妫�淇�
+
+            return new IStation.Dto.ApiResult<List<int>>(overhallStatus);
+        }
+
+        private string BuildSequenceFromDto(string sequenceDto, out int[] sequenceDs)
+        {
+            sequenceDs = null;
+            if (string.IsNullOrEmpty(sequenceDto))
+                return null;
+
+            List<int> list = new List<int>();
+            if (!string.IsNullOrEmpty(sequenceDto))
+            {
+                var sss = sequenceDto.Split(',');
+                foreach (var item in sss)
+                {
+                    if (int.TryParse(item, out int index))
                     {
-                        return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "鏈烘车寮�娉甸『搴忚缃弬鏁颁笉鍚堢悊" };
+                        list.Add(index);
                     }
                     else
                     {
-                        penPumpIndexs.Add(ind);
+                        return " 璁剧疆鍙傛暟涓嶅悎鐞�,鏈烘车搴忓彿鏈夐潪鏁板瓧";
                     }
                 }
-                if (penPumpIndexs.Distinct().Count() != 5)
-                {
-                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "鏈烘车寮�娉甸『搴忚缃弬鏁颁笉鍚堢悊" };
-                }
-                model_setting.OpenPumpIndexs = penPumpIndexs.ToArray();
             }
-            return new IStation.Dto.ApiResult<bool>(IStation.Common.AnaSetting.SaveSetting(model_setting));
+
+            return BuildSequenceFromDto(list, out sequenceDs);
+        }
+
+        private string BuildSequenceFromDto(List<int> sequenceDto, out int[] sequenceDs)
+        {
+            sequenceDs = null;
+            if (sequenceDto == null || sequenceDto.Count() == 0)
+                return null;
+            List<int> penPumpIndexs = new List<int>();
+            foreach (var ind in sequenceDto)
+            {
+                if (ind < 0)
+                {
+                    return " 璁剧疆鍙傛暟涓嶅悎鐞�,鏈烘车搴忓彿鏈夎礋鏁�";
+                }
+                else if (ind > 5)
+                {
+                    return " 璁剧疆鍙傛暟涓嶅悎鐞�,鏈烘车搴忓彿瓒呰繃5";
+                }
+                else
+                {
+                    penPumpIndexs.Add(ind);
+                }
+            }
+            if (penPumpIndexs.Distinct().Count() != 5)
+            {
+                return " 璁剧疆鍙傛暟涓嶅悎鐞�";
+            }
+
+            if (penPumpIndexs.Contains(5))
+            {//琛ㄧず鐣岄潰浠�1 2 3 4 5
+                List<int> penPumpIndexs1 = new List<int>();
+                foreach (var p in penPumpIndexs)
+                {
+                    penPumpIndexs1.Add(p - 1);
+                }
+                sequenceDs = penPumpIndexs1.ToArray();
+            }
+            else
+            {
+                sequenceDs = penPumpIndexs.ToArray();
+            }
+            return null;
+        }
+
+        private int[] BuildSequenceToDto(int[] sequenceDs)
+        {
+            if (sequenceDs == null || sequenceDs.Length == 0) return null;
+
+            List<int> sequenceDto = new List<int>();
+
+            foreach (var sequence in sequenceDs)
+            {
+                sequenceDto.Add(sequence + 1);
+            }
+            return sequenceDto.ToArray();
         }
 
         private Model.eTideSouce _tideSouce = Model.eTideSouce.Book;
 
-        private List<Model.TimeWaterLevel> GetTide3Day(DateTime calc_day)
+        public static List<Model.TimeWaterLevel> GetTide3Day(Model.eTideSouce tideSouce, DateTime calc_day)
         {
             DateTime _rangDay1, _rangDay2, _rangDay3;
             string error1, error2, error3;
@@ -508,9 +967,9 @@
                 _rangDay2 = calc_day;
                 _rangDay3 = calc_day.AddDays(1);
             }
-            waterLevels闀挎睙1 = TideHelper.GetByDay(_tideSouce, _rangDay1, out error1);
-            waterLevels闀挎睙2 = TideHelper.GetByDay(_tideSouce, _rangDay2, out error2);
-            waterLevels闀挎睙3 = TideHelper.GetByDay(_tideSouce, _rangDay3, out error3);
+            waterLevels闀挎睙1 = TideHelper.GetByDay(tideSouce, _rangDay1, out error1);
+            waterLevels闀挎睙2 = TideHelper.GetByDay(tideSouce, _rangDay2, out error2);
+            waterLevels闀挎睙3 = TideHelper.GetByDay(tideSouce, _rangDay3, out error3);
 
             List<Model.TimeWaterLevel> timeValues = new List<Model.TimeWaterLevel>();
             if (waterLevels闀挎睙1 != null)

--
Gitblit v1.9.3