添加OPENAPI接口

tangxu

2025-02-07 03a0d99de9c5fed6bea8bc83b49ce27786bda38c

 WebApi/Controllers/ZyPrjController.cs

@@ -48,14 +48,14 @@
    public class ZyPrjController : ApiController
    {
        /// <summary>
        ///
        ///  计算
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [Route("Calc")]
        [HttpPost]
        public IStation.Dto.ApiResult Calc([FromBody] ZyPrjRequest request)
        { 
        {
            if (request == null)
            {
                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "request is null" };
@@ -71,8 +71,6 @@
            //
            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;
@@ -96,20 +94,23 @@
                IStation.LogHelper.Error(string.Format("ZyPrjRequest Time:{0}-{1} 时间范围错误,不能超过24小时", start_timme, end_timme));
                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "时间范围错误,不能超过24小时" };
            }

   
            IStation.CalcModel.AnaRequest anaRequest = new AnaRequest();
            anaRequest.CalcOptType = (eCalcOptType)IStation.AnaGlobalParas.Setting.OptSortType;
            anaRequest.StartTime = start_timme;
            anaRequest.EndTime = end_timme;
            anaRequest.WaterLevels长江 = GetTide3Day(_tideSouce, start_timme);
            if(anaRequest.WaterLevels长江 ==null || anaRequest.WaterLevels长江.Count()==0)
            { 
                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "无法获取长江水位数据" };
            }

            #region 取水总量

            double TotalFlowIn = 0;
            if (!string.IsNullOrEmpty(request.TotalFlowIn) && !string.IsNullOrWhiteSpace(request.TotalFlowIn))
            {
                double TotalFlowIn = 0;
            { 
                if (!double.TryParse(request.TotalFlowIn, out TotalFlowIn))
                { 
                {
                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "请输入数字型取水总量,接受到的输入值是:" + request.TotalFlowIn };
                }
                if (TotalFlowIn < 10000)
@@ -123,7 +124,7 @@
            }

            #endregion 取水总量

       
            #region 水位要求

            if (!string.IsNullOrEmpty(request.MaxReservoirLevelTime))
@@ -150,10 +151,10 @@
                {
                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "请输入取水总量或水位要求" };
                }
                double TotalFlowIn = 0;
                if (!double.TryParse(request.TotalFlowIn, out TotalFlowIn))
              
                if (TotalFlowIn < 1000)
                {
                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "请输入数字型取水总量,接受到的输入值是:"+ request.TotalFlowIn };
                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "请输入取水总量,接受到的输入值是:" + request.TotalFlowIn };
                }
            }

@@ -161,13 +162,13 @@

            #region 供水量

            double TotalFlowOut = 0;
            double TotalFlowOutPrecid = 0;//预测值的供水总量

            double TotalFlowOut手动输入需求 = 0;//预测值的供水总量(单位 吨)
            double TotalFlowOut预测值的供水总量 = 0;//预测值的供水总量 (单位 吨)
            double FlowTotalOut需求 = 0;
            bool isPredictRecord = false; //是否是用到水量预测
            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);
@@ -199,19 +200,23 @@
                            Data = error_info11
                        };
                    }
                    TotalFlowOutPrecid += r.LastPredictValue;
                    TotalFlowOut预测值的供水总量 += r.LastPredictValue;
                    anaRequest.PerHourFlowOut.Add(r.LastPredictValue);//计算中用吨
                }
                IStation.LogHelper.Info(string.Format("  获取水量预测值:  {0}   ", string.Join(",",anaRequest.PerHourFlowOut)));
                IStation.LogHelper.Info(
                    string.Format("获取水量预测值:  {0} ,  预测值总供水总量:{1} ", 
                    string.Join(",", anaRequest.PerHourFlowOut), TotalFlowOut预测值的供水总量));
                FlowTotalOut需求 = TotalFlowOut预测值的供水总量;
                isPredictRecord = true ;
                #endregion 用预测值
            }
            else
            {
                if (!double.TryParse(request.TotalFlowOut, out TotalFlowOut))
                { 
                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "注意供水总量输入参数无法识别,参数是:"+ request.TotalFlowOut };
                if (!double.TryParse(request.TotalFlowOut, out TotalFlowOut手动输入需求))
                {
                    return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "注意供水总量输入参数无法识别,参数是:" + request.TotalFlowOut };
                }
                if (TotalFlowOut < 10000)
                if (TotalFlowOut手动输入需求 < 10000)
                {
                    IStation.LogHelper.Info(string.Format("Zy Prj  Time:{0}-{1} ,  注意取水总量单位是吨,当前参数参数过小",
                start_timme, end_timme));
@@ -222,18 +227,21 @@
                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));
                    list.Add(Math.Round(TotalFlowOut手动输入需求 / count, 1));
                }
                anaRequest.PerHourFlowOut = list;

                FlowTotalOut需求 = TotalFlowOut手动输入需求;
                isPredictRecord = false ;
            }

            #endregion 供水量

            //开始时的开机状态
            List<int> StartOpenPumpIndexArray = new List<int>();    
            if (!string.IsNullOrEmpty(request.StartOpenPumpIndexArray  ))
            List<int> StartOpenPumpIndexArray = new List<int>();
            if (!string.IsNullOrEmpty(request.StartOpenPumpIndexArray))
            {
                var sss = request.StartOpenPumpIndexArray.Split(','); 
                var sss = request.StartOpenPumpIndexArray.Split(',');
                foreach (var item in sss)
                {
                    if (int.TryParse(item, out int index))
@@ -271,43 +279,33 @@
                    anaRequest.StartReservoirLevel)
                };
            }
            //bool isTemp = false;
            //if (!string.IsNullOrEmpty(request.IsTemporary))
            //{
            //    isTemp = Convert.ToBoolean(request.IsTemporary);
            //}

            IStation.LogHelper.Info("kashi 计算取水总量 ");

            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(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 ret = Common.HistoryAnaPrjFileHelper.SavePrj(IStation.AnaGlobalParas.Setting, isPredictRecord, anaRequest, defaultPrj);

            //
            var dto_prj = ToPrjDto(defaultPrj);
            if (TotalFlowOutPrecid > 1)
            {
                dto_prj.FlowTotalOut = Math.Round(TotalFlowOutPrecid / 10000, 1);
            }
            else
            {
                dto_prj.FlowTotalOut = TotalFlowOut;
            }
            dto_prj.FlowTotalOut = FlowTotalOut需求;

            #region 推送

            //推送:代码保留
            //if (!string.IsNullOrEmpty(request.IsSubmit) && Convert.ToBoolean(request.IsSubmit))
            //{
            //    Task.Run(() =>
@@ -316,9 +314,10 @@
            //    });
            //}

            #endregion 推送

            // IStation.LogHelper.Info(string.Format(" 产生计算方案:{0}", dto_prj.schemeID));
            //IStation.LogHelper.Info(string.Format(" 产生计算方案:{0}", dto_prj.schemeID));
            //IStation.LogHelper.Info(string.Format("Zy Prj  计算成功:  \r\n {0}  ", JsonHelper.Object2Json(dto_prj)));


            return new IStation.Dto.ApiResult<IStation.ZyDto.SubmitPrj>(dto_prj) { Code = ApiResultCode.Success };
        }
@@ -418,79 +417,7 @@
            }
        }

        #region 换算成DTO

        private IStation.ZyDto.SubmitPrj ToPrjDto(AnaPrj defaultPrj)
        {
            IStation.ZyDto.SubmitPrj dto_prj = new ZyDto.SubmitPrj();

            if (string.IsNullOrEmpty(defaultPrj.ID))
            {
                var time = DateTime.Now;
                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.FlowTotalIn = Math.Round(defaultPrj.SumFlow, 0);
            dto_prj.PowerTotal = Math.Round(defaultPrj.SumPower, 0);
            dto_prj.MoneyTotal = Math.Round(defaultPrj.SumMoney, 0);

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

        #endregion 换算成DTO

        /// <summary>
        ///  获取某一天,最近一条
@@ -510,24 +437,42 @@
            {
                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.GetByCreateDay(d, out requestBase);

            if (prj != null)
            {
                //IStation.LogHelper.Info(string.Format(" api GetHistoryByDay {0}    format: {1}  OK", day, d));
                var dto_prj = ToPrjDto(prj);
                if (requestBase != null && requestBase.PerHourFlowOut != null)
                {
                    var sumFlow = (from x in requestBase.PerHourFlowOut select x).Sum();
                    dto_prj.FlowTotalOut = sumFlow;
                }
                if(dto_prj.Switchs != null)
                {
                    var switch2 = from x in dto_prj.Switchs orderby x.Time select x;
                    int index = 1;
                    foreach (var sw in switch2)
                    {
                        sw.Index = index;
                        index++;
                    }
                    dto_prj.Switchs = switch2.ToList();
                }

                return new IStation.Dto.ApiResult<IStation.ZyDto.SubmitPrj>(dto_prj) { Code = ApiResultCode.Success };
            }
            else
            {
                IStation.LogHelper.Info(string.Format(" api GetHistoryByDay {0}    format: {1} (未找到项目) ", day, d));
                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Alert, Message = "未找到项目" };
            }
        }

        /// <summary>
        ///  获取最近一条
        ///  获取最近一条(确认的)
        /// </summary>
        /// <param name="day"></param>
        /// <returns></returns>
@@ -536,22 +481,96 @@
        public IStation.Dto.ApiResult GetLastHistoryRecord()
        {
            var dal = new IStation.DAL.AnaProject();
            var record = dal.GetLastRecord();
            var record = dal.GetLastConfirmRecord();
            if (record == null)
            {
                IStation.LogHelper.Info(" api GetLastHistoryRecord is null ");
                return null;

            }
       
            IStation.CalcModel.AnaRequestBase requestBase = null;
            var prj = Common.HistoryAnaPrjFileHelper.GetByStartTime(record.StartTime, out requestBase);
            if (prj != null)
            {
            { 
                var dto_prj = ToPrjDto(prj);
                if (requestBase != null && requestBase.PerHourFlowOut != null)
                {
                    var sumFlow = (from x in requestBase.PerHourFlowOut select x).Sum();
                    dto_prj.FlowTotalOut = sumFlow;
                }
                if (dto_prj.Switchs != null)
                {
                    var switch2 = from x in dto_prj.Switchs orderby x.Time select x;
                    int index = 1;
                    foreach (var sw in switch2)
                    {
                        sw.Index = index;
                        index++;
                    }
                    dto_prj.Switchs = switch2.ToList();
                }
                return new IStation.Dto.ApiResult<IStation.ZyDto.SubmitPrj>(dto_prj) { Code = ApiResultCode.Success };
            }
            else
            {
                IStation.LogHelper.Info(string.Format(
                    " api GetLastHistoryRecord is null (未找到项目) LastRecord 信息: ID:{0}, StartTime:{1}, EndTime:{2}", 
                    record.ID, 
                    record.StartTime, record.EndTime));
                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Alert, Message = "未找到项目" };
            }
        }

        /// <summary>
        ///  获取最近一条(新建)
        /// </summary>
        /// <param name="day"></param>
        /// <returns></returns>
        [Route("GetLastCreateRecord")]
        [HttpGet]
        public IStation.Dto.ApiResult GetLastCreateRecord()
        {
            var dal = new IStation.DAL.AnaProject();
            var record = dal.GetLastRecord();
            if (record == null)
            {
                IStation.LogHelper.Info(" api GetLastHistoryRecord is null ");
                return null;
            }

            IStation.CalcModel.AnaRequestBase requestBase = null;
            var prj = Common.HistoryAnaPrjFileHelper.GetByStartTime(record.StartTime, out requestBase);
            if (prj != null)
            { 
                var dto_prj = ToPrjDto(prj);
                if (requestBase != null && requestBase.PerHourFlowOut != null )
                {
                    var sumFlow = (from x in requestBase.PerHourFlowOut select x).Sum();
                    dto_prj.FlowTotalOut = sumFlow;
                }
                if (dto_prj.Switchs != null)
                {
                    var switch2 = from x in dto_prj.Switchs orderby x.Time select x;
                    int index = 1;
                    foreach (var sw in switch2)
                    {
                        sw.Index = index;
                        index++;
                    }
                    dto_prj.Switchs = switch2.ToList();
                }
                return new IStation.Dto.ApiResult<IStation.ZyDto.SubmitPrj>(dto_prj) { Code = ApiResultCode.Success };
            }
            else
            {
                IStation.LogHelper.Info(string.Format(
                    " api GetLastHistoryRecord is null (未找到项目) GetLastCreateRecord 信息: ID:{0}, StartTime:{1}, EndTime:{2}",
                    record.ID,
                    record.StartTime, record.EndTime));
                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Alert, Message = "未找到项目" };
            }
        }


        /// <summary>
        ///
@@ -569,7 +588,7 @@
            dto_setting.OptSortType = model_setting.OptSortType;
            dto_setting.SwitchPumpMinuteSpace = model_setting.SwitchPumpMinuteSpace;

            dto_setting.OpenPumpIndexSequence = IStation.Dto.ZyPrjAnaSetting.ListToString( model_setting.OpenPumpIndexSequence);
            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);

@@ -595,14 +614,12 @@
                    model_setting.UnablePumpIndexArray = overhallStatus.ToArray();
                    dto_setting.UnablePumpIndexArray = string.Join(",", overhallStatus);
                    IStation.Common.AnaSetting.SaveSetting(model_setting);
                } 
                }
            }
            catch(Exception ex)
            catch (Exception ex)
            {
                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "无法链接工控服务器,错误原因:" + ex.Message};
                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "无法链接工控服务器,错误原因:" + ex.Message };
            }



            if (model_setting.SwitchPumpIgnoreTimes != null)
            {
@@ -676,6 +693,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)
            {
@@ -857,12 +879,13 @@

            return new IStation.Dto.ApiResult<List<int>>(overhallStatus);
        }
        private string BuildSequenceFromDto(string  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))
            {
@@ -880,10 +903,10 @@
                }
            }

            return BuildSequenceFromDto(list,out sequenceDs);
            return BuildSequenceFromDto(list, out sequenceDs);
        }
        
        private string BuildSequenceFromDto(List<int>  sequenceDto, out int[] sequenceDs)

        private string BuildSequenceFromDto(List<int> sequenceDto, out int[] sequenceDs)
        {
            sequenceDs = null;
            if (sequenceDto == null || sequenceDto.Count() == 0)
@@ -985,5 +1008,127 @@

            return timeValues;
        }

        #region 换算成DTO

        private IStation.ZyDto.SubmitPrj ToPrjDto(AnaPrj defaultPrj)
        {
            IStation.ZyDto.SubmitPrj dto_prj = new ZyDto.SubmitPrj();

            if (string.IsNullOrEmpty(defaultPrj.ID))
            {
                var time = DateTime.Now;
                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.FlowTotalIn = Math.Round(defaultPrj.SumFlow, 0);
            dto_prj.FlowTotalOut = 0; //外面赋值
            dto_prj.PowerTotal = Math.Round(defaultPrj.SumPower, 0);
            dto_prj.MoneyTotal = Math.Round(defaultPrj.SumMoney, 0);

            dto_prj.BlockTimes = new List<ZyDto.SubmitPrjBlockTime>();

            double startHeight = 0;

            if (defaultPrj.BlockTimes != null)
            {
                startHeight = defaultPrj.BlockTimes.First().ReservoirStartHeight;
                foreach (var bt in defaultPrj.BlockTimes)
                {
                    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)
                        {
                            //if(maxHeight < bt2.WaterLevelH)
                            //{
                            //    maxHeight = bt2.WaterLevelH;
                            //    //maxHeight = Math.Max(maxHeight, bt2.WaterLevelH);
                            //    maxHeightTime = bt2.Time;
                            //}

                            dto_item.Records.Add(new SubmitPrjTime(bt2));
                        }
                    }

                    dto_prj.BlockTimes.Add(dto_item);
                }
            }
            if (defaultPrj.MaxWaterLevelH <= 0)
            {        
                double maxHeight = 0;               
                DateTime maxHeightTime = defaultPrj.StartTime;
                if (defaultPrj.BlockTimes != null)
                {
                    foreach (var bt in defaultPrj.BlockTimes)
                    {
                        if (bt.OpenPumpIndexs == null)
                            continue;

                        if (bt.PointTimes != null)
                        {
                            foreach (var bt2 in bt.PointTimes)
                            {
                                if (maxHeight < bt2.WaterLevelH)
                                {
                                    maxHeight = bt2.WaterLevelH;
                                    //maxHeight = Math.Max(maxHeight, bt2.WaterLevelH);
                                    maxHeightTime = bt2.Time;
                                }
                            }
                        }
                    }
                }
                defaultPrj.MaxWaterLevelH = maxHeight;
                defaultPrj.MaxWaterLevelTime = maxHeightTime;
            }
   
            if(defaultPrj.MaxWaterLevelTime> defaultPrj.StartTime)
            dto_prj.MaxWaterLevelH = string.Format("{0:N2}  ({1})",  Math.Round( defaultPrj.MaxWaterLevelH,2) ,
                defaultPrj.MaxWaterLevelTime.ToString("HH:mm"));
            else
                dto_prj.MaxWaterLevelH = string.Format("{0:N2} ", Math.Round(defaultPrj.MaxWaterLevelH, 2));

            //dto_prj.MaxWaterLevelH = defaultPrj.MaxWaterLevelH;
            //dto_prj.MaxWaterLevelTime = defaultPrj.MaxWaterLevelTime;

            dto_prj.StartWaterLevelH = string.Format("{0:N2}  ({1})", Math.Round(startHeight, 2),
                defaultPrj.StartTime.ToString("HH:mm")); ;
            dto_prj.Switchs = new List<SubmitPrjSwitchInfo>();
            if (defaultPrj.PumpSwitchs != null)
            {
                var fi_PumpSwitchs = from x in defaultPrj.PumpSwitchs orderby x.Time select x;
                foreach (var bt in fi_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;
        }

        #endregion 换算成DTO

    }
}