From 97270e48e35dbce006263f6dc5fa6b6d8f81d0f5 Mon Sep 17 00:00:00 2001
From: tangxu <tangxu76880903>
Date: 星期五, 02 八月 2024 10:44:48 +0800
Subject: [PATCH] 123

---
 WebApi/Controllers/ZyPrjController.cs |  140 +++++++++++++++++++++++++++++++---------------
 1 files changed, 94 insertions(+), 46 deletions(-)

diff --git a/WebApi/Controllers/ZyPrjController.cs b/WebApi/Controllers/ZyPrjController.cs
index 4a7446e..4509d18 100644
--- a/WebApi/Controllers/ZyPrjController.cs
+++ b/WebApi/Controllers/ZyPrjController.cs
@@ -29,7 +29,7 @@
         //public int? StartOpenCount { get; set; } = -1;//宸蹭綔搴�
 
         public string StartReservoirLevel { get; set; }//寮�濮嬫按搴撴按浣�(鍙┖):鍗曚綅m
-        public List<int> StartOpenPumpIndexArray { get; set; }//寮�濮嬫満娉靛紑鏈虹姸鎬�(鏂�)
+        public string StartOpenPumpIndexArray { get; set; }//寮�濮嬫満娉靛紑鏈虹姸鎬�(涓嶅彲绌�)
 
         public string TotalFlowIn { get; set; }//鍙栨按鎬婚噺 (鍗曚綅 鍚�)
         public string TotalFlowOut { get; set; }//渚涙按鎬婚噺 (鍗曚綅 鍚�) 涓嶈緭鍏ュ氨鐢ㄩ娴嬪��
@@ -55,8 +55,7 @@
         [Route("Calc")]
         [HttpPost]
         public IStation.Dto.ApiResult Calc([FromBody] ZyPrjRequest request)
-        {
-            LogHelper.Info(JsonHelper.Object2Json(request));
+        { 
             if (request == null)
             {
                 return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "request is null" };
@@ -69,6 +68,11 @@
             {
                 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;
@@ -101,14 +105,12 @@
 
             #region 鍙栨按鎬婚噺
 
-            if (!string.IsNullOrEmpty(request.TotalFlowIn))
+            if (!string.IsNullOrEmpty(request.TotalFlowIn) && !string.IsNullOrWhiteSpace(request.TotalFlowIn))
             {
                 double TotalFlowIn = 0;
                 if (!double.TryParse(request.TotalFlowIn, out TotalFlowIn))
-                {
-                    IStation.LogHelper.Info(string.Format("Zy Prj  Time:{0}-{1} ,  娉ㄦ剰鍙栨按鎬婚噺鍗曚綅鏄惃,褰撳墠鍙傛暟鍙傛暟杩囧皬",
-                start_timme, end_timme));
-                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "娉ㄦ剰鍙栨按鎬婚噺鍗曚綅鏄惃,褰撳墠鍙傛暟鍙傛暟杩囧皬" };
+                { 
+                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "璇疯緭鍏ユ暟瀛楀瀷鍙栨按鎬婚噺,鎺ュ彈鍒扮殑杈撳叆鍊兼槸:" + request.TotalFlowIn };
                 }
                 if (TotalFlowIn < 10000)
                 {
@@ -129,7 +131,7 @@
                 anaRequest.MaxReservoirLevelTime = request.MaxReservoirLevelTime;
             }
 
-            if (!string.IsNullOrEmpty(request.MaxReservoirLevel))
+            if (!string.IsNullOrEmpty(request.MaxReservoirLevel) && !string.IsNullOrWhiteSpace(request.MaxReservoirLevel))
             {
                 double MaxReservoirLevel = 0;
                 if (!double.TryParse(request.MaxReservoirLevel, out MaxReservoirLevel))
@@ -144,11 +146,14 @@
             }
             else
             {
-                if (string.IsNullOrEmpty(request.TotalFlowIn))
+                if (string.IsNullOrEmpty(request.TotalFlowIn) || string.IsNullOrWhiteSpace(request.TotalFlowIn))
                 {
-                    IStation.LogHelper.Info(string.Format("Zy Prj  Time:{0}-{1} ,  璇疯緭鍏ュ彇姘存�婚噺鎴栨按浣嶈姹�",
-                start_timme, end_timme));
                     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 };
                 }
             }
 
@@ -159,7 +164,7 @@
             double TotalFlowOut = 0;
             double TotalFlowOutPrecid = 0;//棰勬祴鍊肩殑渚涙按鎬婚噺
 
-            if (string.IsNullOrEmpty(request.TotalFlowOut))
+            if (string.IsNullOrEmpty(request.TotalFlowOut) || string.IsNullOrWhiteSpace(request.TotalFlowOut))
             {//鐢ㄩ娴嬪��
                 #region 鐢ㄩ娴嬪��
 
@@ -197,16 +202,14 @@
                     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))
-                {
-                    IStation.LogHelper.Info(string.Format("Zy Prj  Time:{0}-{1} ,  娉ㄦ剰鍙栨按鎬婚噺鍗曚綅鏄惃,褰撳墠鍙傛暟鍙傛暟杩囧皬",
-                start_timme, end_timme));
-                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "娉ㄦ剰渚涙按鎬婚噺鍗曚綅鏄惃,褰撳墠鍙傛暟鍙傛暟杩囧皬" };
+                { 
+                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "娉ㄦ剰渚涙按鎬婚噺杈撳叆鍙傛暟鏃犳硶璇嗗埆,鍙傛暟鏄�:"+ request.TotalFlowOut };
                 }
                 if (TotalFlowOut < 10000)
                 {
@@ -227,13 +230,28 @@
             #endregion 渚涙按閲�
 
             //寮�濮嬫椂鐨勫紑鏈虹姸鎬�
-            if (request.StartOpenPumpIndexArray == null)
+            List<int> StartOpenPumpIndexArray = new List<int>();    
+            if (!string.IsNullOrEmpty(request.StartOpenPumpIndexArray  ))
             {
-                IStation.LogHelper.Info(" 鏈缃紑濮嬫椂鏈烘车寮�鍋滅姸鎬� (Error: StartOpenPumpIndexArray is null)");
-                return new IStation.Dto.ApiResult<string>() { Code = ApiResultCode.Error, Data = "鏈缃紑濮嬫椂鏈烘车寮�鍋滅姸鎬� (Error: StartOpenPumpIndexArray is null)" };
+                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 = request.StartOpenPumpIndexArray;
+            anaRequest.StartOpenPumpIndexArray = StartOpenPumpIndexArray;
 
             //闄堣姘村簱姘翠綅
             if (string.IsNullOrEmpty(request.StartReservoirLevel))
@@ -264,20 +282,17 @@
             string error_info = calcHelper.Calc(anaRequest, out defaultPrj);
 
             if (!string.IsNullOrEmpty(error_info) || defaultPrj == null)
-            {
-                var er = string.Format("Zy Prj  Time:{0}-{1} ,  璁$畻閿欒, 鍘熷洜鏄�:{2} ,Request:::  {3}",
-                start_timme, end_timme, error_info, JsonHelper.Object2Json(anaRequest));
-
-                IStation.LogHelper.Info(er);
+            { 
+                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  Time:{0}-{1} ,  璁$畻鎴愬姛", start_timme, end_timme));
+            { 
+              //  IStation.LogHelper.Info(string.Format("Zy Prj  璁$畻鎴愬姛:  \r\n {0}  ",  JsonHelper.Object2Json(defaultPrj)));
             }
+            IStation.LogHelper.Info("-----------------------------END--------------------------------------");
 
-            //淇濆瓨鏂规
-            //defaultPrj.Name
+            //淇濆瓨鏂规 
             var ret = Common.HistoryAnaPrjFileHelper.SavePrj(IStation.AnaGlobalParas.Setting, anaRequest, defaultPrj);
 
             //
@@ -550,30 +565,38 @@
             dto_setting.OptSortType = model_setting.OptSortType;
             dto_setting.SwitchPumpMinuteSpace = model_setting.SwitchPumpMinuteSpace;
 
-            dto_setting.OpenPumpIndexSequence = model_setting.OpenPumpIndexSequence;
-            dto_setting.ClosePumpIndexSequence = model_setting.ClosePumpIndexSequence;
-            dto_setting.OptimalPumpIndexSequence = model_setting.OptimalPumpIndexSequence;
+            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 琛ㄧず浜屽彿娉� 涓虹┖,琛ㄧず娌℃湁妫�淇�
-            var overhallStatus = ZyConnectHelper.GetOverhaulStatus();
-            if(overhallStatus == null || overhallStatus.Count == 0)
+            try
             {
-                if(model_setting.UnablePumpIndexArray != null)
+                var overhallStatus = ZyConnectHelper.GetOverhaulStatus();
+                if (overhallStatus == null || overhallStatus.Count == 0)
                 {
-                    model_setting.UnablePumpIndexArray = null;
+                    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);
                 } 
             }
-            else
+            catch(Exception ex)
             {
-                model_setting.UnablePumpIndexArray = overhallStatus.ToArray();
-                IStation.Common.AnaSetting.SaveSetting(model_setting);
+                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "鏃犳硶閾炬帴宸ユ帶鏈嶅姟鍣�,閿欒鍘熷洜:" + ex.Message};
             }
-            dto_setting.UnablePumpIndexArray = model_setting.UnablePumpIndexArray;
 
 
 
@@ -752,7 +775,7 @@
                 }
             }
 
-            if (dto.OpenPumpIndexSequence != null)
+            if (!string.IsNullOrEmpty(dto.OpenPumpIndexSequence))
             {
                 int[] new_set_sequence;
                 var error = BuildSequenceFromDto(dto.OpenPumpIndexSequence, out new_set_sequence);
@@ -764,7 +787,7 @@
                 model_setting.OpenPumpIndexSequence = new_set_sequence;
             }
 
-            if (dto.ClosePumpIndexSequence != null)
+            if (!string.IsNullOrEmpty(dto.ClosePumpIndexSequence))// if (dto.ClosePumpIndexSequence != null)
             {
                 int[] new_set_sequence;
                 var error = BuildSequenceFromDto(dto.ClosePumpIndexSequence, out new_set_sequence);
@@ -776,7 +799,7 @@
                 model_setting.ClosePumpIndexSequence = new_set_sequence;
             }
 
-            if (dto.OptimalPumpIndexSequence != null)
+            if (!string.IsNullOrEmpty(dto.OptimalPumpIndexSequence))// if (dto.OptimalPumpIndexSequence != null)
             {
                 int[] new_set_sequence;
                 var error = BuildSequenceFromDto(dto.OptimalPumpIndexSequence, out new_set_sequence);
@@ -830,8 +853,33 @@
 
             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))
+                    {
+                        list.Add(index);
+                    }
+                    else
+                    {
+                        return " 璁剧疆鍙傛暟涓嶅悎鐞�,鏈烘车搴忓彿鏈夐潪鏁板瓧";
+                    }
+                }
+            }
 
-        private string BuildSequenceFromDto(int[] sequenceDto, out int[] sequenceDs)
+            return BuildSequenceFromDto(list,out sequenceDs);
+        }
+        
+        private string BuildSequenceFromDto(List<int>  sequenceDto, out int[] sequenceDs)
         {
             sequenceDs = null;
             if (sequenceDto == null || sequenceDto.Count() == 0)

--
Gitblit v1.9.3