对切换泵时间间隔进行赋值

duheng

2024-09-05 25beb2c84d65c3f77361a5add4de3eeb172d37f1

 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; }//供水总量 (单位 吨) 不输入就用预测值
@@ -56,7 +56,6 @@
        [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,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;
@@ -101,14 +103,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 +129,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 +144,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 +162,7 @@
            double TotalFlowOut = 0;
            double TotalFlowOutPrecid = 0;//预测值的供水总量

            if (string.IsNullOrEmpty(request.TotalFlowOut))
            if (string.IsNullOrEmpty(request.TotalFlowOut) || string.IsNullOrWhiteSpace(request.TotalFlowOut))
            {//用预测值
                #region 用预测值

@@ -197,6 +200,7 @@
                    TotalFlowOutPrecid += r.LastPredictValue;
                    anaRequest.PerHourFlowOut.Add(r.LastPredictValue);//计算中用吨
                }
                IStation.LogHelper.Info(string.Format("  获取水量预测值:  {0}   ", string.Join(",", anaRequest.PerHourFlowOut)));

                #endregion 用预测值
            }
@@ -204,9 +208,7 @@
            {
                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 +229,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))
@@ -265,19 +282,16 @@

            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);

            //
@@ -426,8 +440,11 @@

            dto_prj.BlockTimes = new List<ZyDto.SubmitPrjBlockTime>();
            double maxHeight = 0;
            double startHeight = 0;

            if (defaultPrj.BlockTimes != null)
            {
                startHeight = defaultPrj.BlockTimes.First().ReservoirStartHeight;
                foreach (var bt in defaultPrj.BlockTimes)
                {
                    if (bt.OpenPumpIndexs == null)
@@ -453,12 +470,14 @@
                }
            }
            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");//时间
@@ -550,32 +569,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;



            if (model_setting.SwitchPumpIgnoreTimes != null)
            {
@@ -624,7 +649,7 @@
        {
            if (dto == null)
            {
                return new IStation.Dto.ApiResult<bool>(false);
                return new IStation.Dto.ApiResult<bool>(false) { Message = "入参为空" };
            }
            var model_setting = IStation.AnaGlobalParas.Setting;

@@ -649,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)
            {
@@ -752,7 +782,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 +794,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 +806,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);
@@ -831,7 +861,33 @@
            return new IStation.Dto.ApiResult<List<int>>(overhallStatus);
        }

        private string BuildSequenceFromDto(int[] sequenceDto, out int[] sequenceDs)
        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 " 设置参数不合理,机泵序号有非数字";
                    }
                }
            }

            return BuildSequenceFromDto(list, out sequenceDs);
        }

        private string BuildSequenceFromDto(List<int> sequenceDto, out int[] sequenceDs)
        {
            sequenceDs = null;
            if (sequenceDto == null || sequenceDto.Count() == 0)