Merge branch 'master' of http://47.103.154.90:83/r/IStation/Service.V4.1

lixiaojun

2023-04-12 2be5d90e96f163c67101571f6865b17effcb0f3f

Merge branch 'master' of http://47.103.154.90:83/r/IStation/Service.V4.1

# Conflicts:
#	Application/IStation.Application.OpenApi/shys/dispatch/DispatchAna_ShysController.cs

 Application/IStation.Application.OpenApi/shys/dispatch/DispatchAna_ShysController - ¸±±¾.cs

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,504 @@
using Microsoft.AspNetCore.Mvc;
using System.Net;
using System.Net.Http.Headers;
using Microsoft.Extensions.Hosting.Internal;
using Microsoft.AspNetCore.Http.Extensions;
using IStation.Untity;
using Furion.DynamicApiController;
using System.ComponentModel.DataAnnotations;
using Mapster;
using Microsoft.AspNetCore.Authorization;
using SqlSugar;

namespace IStation.Application
{
    /// <summary>
    /// ShysDispatchAna
    /// </summary>
    [Route("OpenApi/DispatchAna/SHYS")]
    [ApiDescriptionSettings("OpenApi", Name = "上海原水调度分析", Order = 1000)]
    public class DispatchAna_ShysController : IDynamicApiController 
    {
        /// <summary>
        /// è®¡ç®—保持的方案
        /// </summary> 
        [AllowAnonymous]
        [NonUnify]
        [Route("CalcuKeepDispatch")]
        [HttpPost]
        public IStation.Application.DispatchAnaSchemeOutput CalcuKeepDispatch([Required] StationDispatchExInput input)
        {
            if (input == null)
                return default;
            LogHelper.Debug(JsonHelper.Object2Json(input));
            var url_sg = Settings.WebApi.OpenApi.SanGaoDispatchUrl;
            var responseText = HttpRequestHelper.Post(url_sg,JsonHelper.Object2Json(input));
            LogHelper.Debug(responseText);
            var result_sg = JsonHelper.Json2Object<DispatchFactoryDto>(responseText);
            if (result_sg == null)
                return default;
            string error_info = null;
            switch (input.type)
            {
                case 1://长兴泵站
                    {
                        var result= shys_cxd(input, result_sg,out error_info);
                        //LogHelper.Debug(JsonHelper.Object2Json(result));
                        return result;
                    }
                default:return default;
            }
        }

        /// <summary>
        /// è®¡ç®—保持的方案
        /// </summary> 
        [AllowAnonymous]
        [NonUnify]
        [Route("CalcuKeepDispatch@Debug")]
        [HttpPost]
        public DispatchAnaSchemeOutput CalcuKeepDispatchDebug([Required] StationDispatchExInput input)
        {
            if (input == null)
                return default;

            var responseText = System.IO.File.ReadAllText(@"D:\result.txt");//(测试用的)
            var result_sg = JsonHelper.Json2Object<DispatchFactoryDto>(responseText);
            if (result_sg == null)
                return default;

            string error_info = null;
            switch (input.type)
            {
                case 1://长兴泵站
                    {
                        return shys_cxd(input, result_sg, out error_info);
                    }
                default: return default;
            }
        }

        /// <summary>
        /// è®¡ç®—长兴保持的方案
        /// </summary> 
        [AllowAnonymous]
        [NonUnify]
        [Route("CalcuCxKeepDispatch@Debug")]
        [HttpGet]
        public DispatchAnaSchemeOutput CalcuCxKeepDispatchDebug
            (
                double waterLevel,//水位
                double flow1,//管道1流量
                double press1,//管道1压力
                double valveStatus1,//管道1阀门状态
                double flow2,//管道2流量
                double press2,//管道2压力
                double valveStatus2,//管道2阀门状态
                int middleValveStatus,//中间阀门状态
                int runStatus1,//1#机泵运行状态
                int runStatus2,//2#机泵运行状态
                int runStatus3,//3#机泵运行状态
                int runStatus4//4#机泵运行状态
            )
        {
            waterLevel = 2.558;
            flow1 = 2573;
            flow2 = 0;
            press1 = 9.5527 / 102;
            press2 = 9.5527 / 102;
            valveStatus1 = 1;
            valveStatus2 = 0;
            middleValveStatus = 1;
            runStatus1 = 1;
            runStatus2 = 0;
            runStatus3 = 0;
            runStatus4 = 1;

            var input = new StationDispatchExInput();
            input.flowId = "测试";
            input.type = 1;
            input.factory = new List<FactoryDispatchInput>() { new FactoryDispatchInput() { id=1,value=200} };

            var result_sg = new DispatchFactoryDto();
            result_sg.result = new List<DispatchBranchDto>();
            result_sg.result.Add(new DispatchBranchDto() { key= "stationCX_1#_flow",value= flow1 });
            result_sg.result.Add(new DispatchBranchDto() { key = "stationCX_1#_pressure", value = press1 });
            result_sg.result.Add(new DispatchBranchDto() { key = "stationCX_2#_flow", value = flow2 });
            result_sg.result.Add(new DispatchBranchDto() { key = "stationCX_2#_pressure", value = press2 });
            result_sg.scada = new List<DispatchScadaDto>();
            result_sg.scada.Add(new DispatchScadaDto() {tagname= "_0402010404030103001",value=waterLevel });
            result_sg.scada.Add(new DispatchScadaDto() { tagname = "_0402010403150103003", value = middleValveStatus });
            result_sg.scada.Add(new DispatchScadaDto() { tagname = "_0402010403010101003", value = runStatus1 });
            result_sg.scada.Add(new DispatchScadaDto() { tagname = "_0402010403010201003", value = runStatus2 });
            result_sg.scada.Add(new DispatchScadaDto() { tagname = "_0402010403010301003", value = runStatus3 });
            result_sg.scada.Add(new DispatchScadaDto() { tagname = "_0402010403010401003", value = runStatus4 });
            result_sg.scada.Add(new DispatchScadaDto() { tagname = "_0402010403150101003", value = valveStatus1 });
            result_sg.scada.Add(new DispatchScadaDto() { tagname = "_0402010403150102003", value = valveStatus2 });

            string error_info = null;
            switch (input.type)
            {
                case 1://长兴泵站
                    {
                        return shys_cxd(input, result_sg, out error_info);
                    }
                default: return default;
            }
        }

        /// <summary>
        /// é•¿å…´å²›
        /// </summary>
        /// <param name="input"></param>
        /// <param name="result_sg"></param> 
        /// <param name="error_info"></param> 
        /// <returns></returns>
        private IStation.Application.DispatchAnaSchemeOutput shys_cxd(
            StationDispatchExInput input,
            DispatchFactoryDto result_sg,
            out string error_info)
        {
            error_info = null;

            var complex_request_paras = new IStation.Calculation.DispatchAna.Model.RequestParasComplex();
            complex_request_paras.CorpID = 4;
            complex_request_paras.StationID = 2;

            //水位
            var scada_water = result_sg.scada.Find(t => t.tagname == "_0402010404030103001");
            double water_level = 0;
            if (scada_water == null)
            {
                error_info = "水位无法获取";
                return null;
            }
            else
            {
                water_level = scada_water.value;
            }
      
            complex_request_paras.InletPipePara = new List<IStation.Calculation.DispatchAna.Model.InletPipePara>();
            complex_request_paras.InletPipePara.Add(new IStation.Calculation.DispatchAna.Model.InletPipePara() {
                Name = "吸水井液位", 
                Value = water_level });



            //1号管与2号管连接阀状态 0402010403150103003
            int middleValveStatus = 1;
            var scada_middle_vavle = result_sg.scada.Find(t => t.tagname == "_0402010403150103003");
            if (scada_middle_vavle != null)
                middleValveStatus = (int)scada_middle_vavle.value;
            complex_request_paras.ValvePara = new List<IStation.Calculation.DispatchAna.Model.ValvePara>();
            complex_request_paras.ValvePara.Add(new IStation.Calculation.DispatchAna.Model.ValvePara() { Name = "中间阀门", OpenStatus = middleValveStatus });
 

            //机泵 å¼€åœæœºçŠ¶æ€
            List<long> machine_id_array = new List<long> { 19, 22, 25, 28 };
            List<long> machine_run_status = new List<long>(4);
            //1号泵开机状态
            var scada_runstatus1 = result_sg.scada.Find(t => t.tagname == "_0402010403010101003");
            if (scada_runstatus1 != null && (int)scada_runstatus1.value == 1)
                machine_run_status.Add(machine_id_array[0]);
 
            //2号泵开机状态
            var scada_runstatus2 = result_sg.scada.Find(t => t.tagname == "_0402010403010201003");
            if (scada_runstatus2 != null && (int)scada_runstatus2.value == 1)
                machine_run_status.Add(machine_id_array[1]);

            //3号泵开机状态
            var scada_runstatus3 = result_sg.scada.Find(t => t.tagname == "_0402010403010301003");
            if (scada_runstatus3 != null && (int)scada_runstatus3.value == 1)
                machine_run_status.Add(machine_id_array[2]);

            //4号泵开机状态
            var scada_runstatus4 = result_sg.scada.Find(t => t.tagname == "_0402010403010401003");
            if (scada_runstatus4 != null && (int)scada_runstatus4.value == 1)
                machine_run_status.Add(machine_id_array[3]);

            if (machine_run_status.Count == 0)
            {
                error_info = "没有任何泵开启.无法计算";
                return null;
            }

            //1号管 
            IStation.Calculation.DispatchAna.Model.OutletPipePara pipe1 = new Calculation.DispatchAna.Model.OutletPipePara();
            pipe1.Name = "一号管";
            var flow1 = result_sg.result.Find(x => x.key == "stationCX_1#_flow");
            if(flow1 == null)
            {
                error_info = "一号管流量无法获取";
                return null;
            }
            else
            {
                pipe1.TargetFlow = flow1.value;
            } 
            var press1 = result_sg.result.Find(x => x.key == "stationCX_1#_pressure");
            if (press1 == null)
            {
                error_info = "一号管压力无法获取";
                return null;
            }
            else
            {
                pipe1.TargetPress = press1.value;
            }    
            var pipe1_val = result_sg.scada.Find(t => t.tagname == "_0402010403150101003");
            if (pipe1_val != null)
            {
                pipe1.ValveStatus =  (int)pipe1_val.value;
            }
             
    

            //2号管
            IStation.Calculation.DispatchAna.Model.OutletPipePara pipe2 = new Calculation.DispatchAna.Model.OutletPipePara();
            pipe2.Name = "二号管";
            var flow2 = result_sg.result.Find(x => x.key == "stationCX_2#_flow");
            if (flow2 == null)
            {
                error_info = "二号管流量无法获取";
                return null;
            }
            else
            {
                pipe2.TargetFlow = flow2.value;
            }
           
            var press2 = result_sg.result.Find(x => x.key == "stationCX_2#_pressure");
            if (press2 == null)
            {
                error_info = "二号管压力无法获取";
                return null;
            }
            else
            {
                pipe2.TargetPress = press2.value;
            } 
            var pipe2_val = result_sg.scada.Find(t => t.tagname == "_0402010403150102003");
            if (pipe2_val != null)
            {
                pipe2.ValveStatus = (int)pipe2_val.value;
            }
    

            complex_request_paras.OutletPipePara = new List<IStation.Calculation.DispatchAna.Model.OutletPipePara>(2);
            complex_request_paras.OutletPipePara.Add(pipe1);
            complex_request_paras.OutletPipePara.Add(pipe2);

            complex_request_paras.SchemeSortType = Calculation.DispatchAna.Model.eAnaSchemeSortType.功率;
            complex_request_paras.SchemeNumber = 1;

            //构造计算器
            var calulator = IStation.Calculation.DispatchAnalyCalculatorFactory.CreateKeepStatusCalculator(4,
                IStation.ObjectType.Station, 2,null);
            calulator.IntialRequest(complex_request_paras,
                    null,
                    machine_run_status);

            #region å®žæ—¶é‡
            double real_total_flow_pipe1 = 0;
            var pipe1_val_flow_real = result_sg.scada.Find(t => t.tagname == "_0402010403030002001");
            if (pipe1_val_flow_real != null && pipe1_val_flow_real.value > 100)
            {//实时量,  stationCX_2#_flow" ä¸‰é«˜ç»™çš„目标量
                real_total_flow_pipe1 = pipe1_val_flow_real.value;
            }
            
            double real_oulet_press_pipe1 = 0;
            var pipe1_val_press_real = result_sg.scada.Find(t => t.tagname == "_0402010403030002005");
            if (pipe1_val_press_real != null && pipe1_val_press_real.value > 100)
            {//实时量,  stationCX_2#_flow" ä¸‰é«˜ç»™çš„目标量
                real_oulet_press_pipe1 = pipe1_val_press_real.value;
            }


            double real_total_flow_pipe2 = 0;
            var pipe2_val_flow_real = result_sg.scada.Find(t => t.tagname == "_0402010403030002002");
            if (pipe2_val_flow_real != null && pipe2_val_flow_real.value > 100)
            {
                real_total_flow_pipe2 = pipe2_val_flow_real.value;
            }

            double real_oulet_press_pipe2 = 0;
            var pipe2_val_press_real = result_sg.scada.Find(t => t.tagname == "_0402010403030002006");
            if (pipe2_val_press_real != null && pipe2_val_press_real.value > 100)
            {//实时量,  stationCX_2#_flow" ä¸‰é«˜ç»™çš„目标量
                real_oulet_press_pipe2 = pipe2_val_press_real.value;
            }

            #endregion


            //出方案 
            var scheme = calulator.Calc(out error_info);
            if (scheme == null)
                return default;
            var result = new IStation.Application.DispatchAnaSchemeOutput();
            result.flowId = input.flowId;
            result.Q = scheme.TotalWrkQ;
            result.H = scheme.TotalWrkH;
            result.E = scheme.TotalWrkE;
            result.P = scheme.TotalWrkP;
            result.WP = scheme.WP;
            result.UWP = scheme.UWP;
            result.Scheme = new DispatchAnaCurrentOutput();
            result.Scheme.MiddleValveStatus = middleValveStatus;
            result.Scheme.Pipes = new List<DispatchAnaCurrentOutput.PipeParaOutput>();
            result.Scheme.Pipes.Add(
                new DispatchAnaCurrentOutput.PipeParaOutput()
                {
                    Name = "1#管",
                    TargetFlow = pipe1.TargetFlow,
                    TargetPressure = pipe1.TargetPress,
                    CurrentFlow = real_total_flow_pipe1,
                    CurrentPressure = real_oulet_press_pipe1
                }
                );
            result.Scheme.Pipes.Add(
                new DispatchAnaCurrentOutput.PipeParaOutput()
                {
                    Name = "2#管",
                    TargetFlow = pipe2.TargetFlow,
                    TargetPressure = pipe2.TargetPress,
                    CurrentFlow = real_total_flow_pipe2,
                    CurrentPressure = real_oulet_press_pipe2
                }
            );

            List<string> machine_frq_hz_target_name = new List<string> {
                        "_0402010403010112007",
                        "_0402010403010212019",
                        "_0402010403010312007",
                        "_0402010403010412019" };

            List<string> machine_speed_target_name = new List<string> {
                        "_0402010403010112008",
                        "_0402010403010212020",
                        "_0402010403010312008",
                        "_0402010403010412020" };

            List<string> machine_names = new List<string> {
                        "长兴泵房1号机泵",
                        "长兴泵房2号机泵",
                        "长兴泵房3号机泵",
                        "长兴泵房4号机泵" };

            result.Pumps = new List<IStation.Application.DispatchAnaSchemeItemOutput>();
            foreach (IStation.Calculation.DispatchAna.Model.AnaSchemeItem item in scheme.Items)
            {
                var pump_item = new IStation.Application.DispatchAnaSchemeItemOutput();
                pump_item.Id = item.MachineID.ToString();
                pump_item.Index = machine_id_array.IndexOf(item.MachineID);
                pump_item.Name = item.MachineName;
                pump_item.IsFrequency = item.IsFrequency;
                pump_item.IsCurveExtend = item.IsCurveExtend;
                pump_item.Q = item.WorkPointQ;
                pump_item.H = item.WorkPointH;
                pump_item.E = item.WorkPointE;
                pump_item.P = item.WorkPointP;
                pump_item.Frequency = item.Frequence;
                pump_item.Speed = item.Speed;

                if (pump_item.Index >= 0 && pump_item.Index < 4)
                {
                    //获取实时频率
                    var fr_hz_tag_name = machine_frq_hz_target_name[pump_item.Index];
                    var current_val_fr_hz = result_sg.scada.Find(t => t.tagname == fr_hz_tag_name);
                    if (current_val_fr_hz != null && current_val_fr_hz.value > 10)
                    {
                        pump_item.CurrentFrequency = current_val_fr_hz.value;
                    }

                    //获取实时转速
                    var speed_tag_name = machine_speed_target_name[pump_item.Index];
                    var current_val_speed = result_sg.scada.Find(t => t.tagname == speed_tag_name);
                    if (current_val_speed != null && current_val_speed.value > 10)
                    {
                        pump_item.CurrentSpeed = current_val_speed.value;
                    }

                    //机泵名称
                    pump_item.Name = machine_names[pump_item.Index];
                }


                result.Pumps.Add(pump_item);
                

 
            }



            
            if (machine_run_status.Count == 1)
            {//保证开一台泵时, æµé‡å¤§ é¢‘率也大, æµé‡å° , é¢‘率也小
                if(pipe1.TargetFlow + pipe2.TargetFlow > 100)
                {
                    double current_total_flow = 0;
                    if (pipe1.TargetFlow > 100)
                        current_total_flow = pipe1.TargetFlow;
                    else
                        current_total_flow = pipe2.TargetFlow;

 
                    var open_pump = result.Pumps.First();
                    var fr_hz_tag_name = machine_frq_hz_target_name[open_pump.Index];
                    var current_val_fr_hz = result_sg.scada.Find(t => t.tagname == fr_hz_tag_name);
                    if (current_val_fr_hz != null && current_val_fr_hz.value > 10)
                    {
                        if (current_total_flow < scheme.TotalWrkQ && current_val_fr_hz.value > open_pump.Frequency)
                        {//保证趋势正确
                            open_pump.Frequency = Math.Round(current_val_fr_hz.value * scheme.TotalWrkQ / current_total_flow, 2);
                        }
                        else if (current_total_flow > scheme.TotalWrkQ && current_val_fr_hz.value < open_pump.Frequency)
                        {//保证趋势正确
                            open_pump.Frequency = Math.Round(current_val_fr_hz.value * scheme.TotalWrkQ / current_total_flow, 2);
                        }
                        else
                        {//原水反馈 , ç”¨æ›²çº¿è®¡ç®—, é¢‘率偏低, äººä¸ºå¢žåŠ 0.5HZ
                            if (open_pump.Frequency < 49.5)
                            {
                                open_pump.Speed = Math.Round
                                    (open_pump.Speed * (open_pump.Frequency + 0.5) / (open_pump.Frequency),0);
                                open_pump.Frequency = open_pump.Frequency + 0.5;
                            }

                            if (open_pump.Frequency > 50)
                            {
                                open_pump.Frequency = 50;                           
                            }
                                
                        }
                    }
                }
            }
            else
            {
                result.Pumps.ForEach(x =>
                {//原水反馈 , ç”¨æ›²çº¿è®¡ç®—, é¢‘率偏低, äººä¸ºå¢žåŠ 0.5HZ
                    if (x.Frequency > 10)
                    {
                        if (x.Frequency < 49.5)
                        {
                            x.Speed = Math.Round
                                (x.Speed * (x.Frequency + 0.5) / (x.Frequency), 0);
                            x.Frequency = x.Frequency + 0.5;
                        } 
                    }
                    if (x.Frequency > 50)
                        x.Frequency = 50;
                });
            }

            return result;
        }





    }
}

 Application/IStation.Application.OpenApi/shys/dispatch/dto/DispatchAnaSchemeItemOutput - ¸±±¾.cs

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,83 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace IStation.Application
{
    /// <summary>
    /// æœºæ³µä¿¡æ¯
    /// </summary>
    public class DispatchAnaSchemeItemOutput
    {
        /// <summary>
        /// æœºæ³µæ ‡è¯†
        /// </summary>
        public string Id { get; set; }

        /// <summary>
        /// æœºæ³µç´¢å¼• ä»Ž0开始
        /// </summary>
        public int Index { get; set; }

        /// <summary>
        /// æœºæ³µåç§°
        /// </summary>
        public string Name { get; set; }

        /// <summary>
        /// æ˜¯å¦å˜é¢‘
        /// </summary>
        public bool IsFrequency { get; set; }

        /// <summary>
        /// æ˜¯å¦åœ¨æ›²çº¿å»¶é•¿çº¿ä¸Š
        /// </summary>
        public bool IsCurveExtend { get; set; }

        /// <summary>
        /// æµé‡ m³/h
        /// </summary>
        public double Q { get; set; }

        /// <summary>
        /// æ‰¬ç¨‹ m
        /// </summary>
        public double H { get; set; }

        /// <summary>
        /// æ•ˆçŽ‡ æ•ˆçŽ‡ %
        /// </summary>
        public double E { get; set; }

        /// <summary>
        /// åŠŸçŽ‡ kw
        /// </summary>
        public double P { get; set; }

        /// <summary>
        /// é¢‘率 hz
        /// </summary>
        public double Frequency { get; set; }

        /// <summary>
        /// è½¬é€Ÿ r/min
        /// </summary>
        public double Speed { get; set; }


        /// <summary>
        /// é¢‘率 hz
        /// </summary>
        public double CurrentFrequency { get; set; }

        /// <summary>
        /// è½¬é€Ÿ r/min
        /// </summary>
        public double CurrentSpeed { get; set; }
 
    }


}

 Application/IStation.Application.OpenApi/shys/dispatch/dto/DispatchAnaSchemeOutput - ¸±±¾.cs

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,113 @@
using Microsoft.AspNetCore.Components.Forms;
using Org.BouncyCastle.Bcpg.OpenPgp;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace IStation.Application
{
    /// <summary>
    /// è°ƒåº¦æ³µç«™ç»“æžœ
    /// </summary>
    public class DispatchAnaSchemeOutput
    {
        /// <summary>
        /// 
        /// </summary>
        public string flowId { get; set; }

        /// <summary>
        /// æµé‡ m³/h
        /// </summary>
        public double Q { get; set; }

        /// <summary>
        /// æ‰¬ç¨‹ m
        /// </summary>
        public double H { get; set; }

        /// <summary>
        /// æ•ˆçŽ‡ %
        /// </summary>
        public double E { get; set; }

        /// <summary>
        /// åŠŸçŽ‡ kw
        /// </summary>
        public double P { get; set; }

        /// <summary>
        /// åƒå¨æ°´èƒ½è€—  kw/m.m3/h
        /// </summary>
        public double WP { get; set; }

        /// <summary>
        /// å•ä½èƒ½è€— kw/m3/h
        /// </summary>
        public double UWP { get; set; }

        /// <summary>
        /// å¼€æ³µä¿¡æ¯
        /// </summary>
        public List<DispatchAnaSchemeItemOutput> Pumps { get; set; }

        /// <summary>
        /// 
        /// </summary>
        public DispatchAnaCurrentOutput Scheme { get; set; }



    }

    /// <summary>
    /// 
    /// </summary>
    public class DispatchAnaCurrentOutput 
    {
        /// <summary>
        /// 
        /// </summary> 
        public List<PipeParaOutput> Pipes { get; set; }

        /// <summary>
        /// 
        /// </summary>
        public int  MiddleValveStatus { get; set; }
        /// <summary>
        /// 
        /// </summary>
        public class PipeParaOutput
        {
            /// <summary>
            /// 
            /// </summary>
            public string Name { get; set; }

            /// <summary>
            /// æµé‡ m³/h (三高给的数据)
            /// </summary>
            public double TargetFlow { get; set; }

            /// <summary>
            /// åŽ‹åŠ› MPa (三高给的数据)
            /// </summary>
            public double TargetPressure { get; set; }

            /// <summary>
            /// æµé‡ m³/h (实时)
            /// </summary>
            public double CurrentFlow { get; set; }

            /// <summary>
            /// åŽ‹åŠ› MPa(实时)
            /// </summary>
            public double CurrentPressure { get; set; }
        }


    }
    
}