苏州金庭10个泵站 对接程序写完

ningshuxia

2022-12-01 ad494f13d2ddf31f142cf7fb908b3a6e90395a1a

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
 
namespace IStation.Calculation
{
    /// <summary>
    /// 能效汇总单日辅助类
    /// </summary>
    public class EtaSumSingleDayHelper
    {
 
        /// <summary>
        /// 汇总
        /// </summary>
        public static Model.EtaSumSingleDayRecord Sum
            (
                long CorpID,
                string ObjectType,
                long ObjectID,
                DateTime Day,
                IEnumerable<Model.EtaSingleRealRecord> records
            )
        {
            if (records == null || records.Count() < 1)
                return default;
            var run_record_list = records.Where(x => x.RSa == RunStatus.Run).ToList();
            var run_normal_record_list = run_record_list.Where(x => x.AnalyStatus == Model.Eta.eAnalyStatus.Normal).ToList();
 
            var model = new Model.EtaSumSingleDayRecord();
            model.CorpID = CorpID;
            model.ObjectType = ObjectType;
            model.ObjectID = ObjectID;
            model.DataDay = Day.Date;
            model.DataTime = DateTime.Now;
            model.Qt = run_record_list.Sum(x => (x.Qa ?? 0) * x.Duration) / 3600f;
            model.Dt = run_record_list.Sum(x => (x.Pa ?? 0) * x.Duration) / 3600f;
            model.RunTime = run_record_list.Sum(x => x.Duration);
            model.PointCount = run_record_list.Count;
 
            if (run_normal_record_list.Count > 0)
            {
                if (run_normal_record_list.Exists(x => x.Qa.HasValue))
                {
                    model.Qmin = run_normal_record_list.Where(x => x.Qa.HasValue).Min(x => x.Qa.Value);
                    model.Qmax = run_normal_record_list.Where(x => x.Qa.HasValue).Max(x => x.Qa.Value);
                    model.Qavg = run_normal_record_list.Where(x => x.Qa.HasValue).Average(x => x.Qa.Value);
                }
                if (run_normal_record_list.Exists(x => x.Ha.HasValue))
                {
                    model.Hmin = run_normal_record_list.Where(x => x.Ha.HasValue).Min(x => x.Ha.Value);
                    model.Hmax = run_normal_record_list.Where(x => x.Ha.HasValue).Max(x => x.Ha.Value);
                    model.Havg = run_normal_record_list.Where(x => x.Ha.HasValue).Average(x => x.Ha.Value);
                }
                if (run_normal_record_list.Exists(x => x.Ea.HasValue))
                {
                    model.Emin = run_normal_record_list.Where(x => x.Ea.HasValue).Min(x => x.Ea.Value);
                    model.Emax = run_normal_record_list.Where(x => x.Ea.HasValue).Max(x => x.Ea.Value);
                    model.Eavg = run_normal_record_list.Where(x => x.Ea.HasValue).Average(x => x.Ea.Value);
                }
                if (run_normal_record_list.Exists(x => x.Pa.HasValue))
                {
                    model.Pmin = run_normal_record_list.Where(x => x.Pa.HasValue).Min(x => x.Pa.Value);
                    model.Pmax = run_normal_record_list.Where(x => x.Pa.HasValue).Max(x => x.Pa.Value);
                    model.Pavg = run_normal_record_list.Where(x => x.Pa.HasValue).Average(x => x.Pa.Value);
                }
                if (run_normal_record_list.Exists(x => x.WPa.HasValue))
                {
                    model.WPmin = run_normal_record_list.Where(x => x.WPa.HasValue).Min(x => x.WPa.Value);
                    model.WPmax = run_normal_record_list.Where(x => x.WPa.HasValue).Max(x => x.WPa.Value);
                    model.WPavg = run_normal_record_list.Where(x => x.WPa.HasValue).Average(x => x.WPa.Value);
                }
                if (run_normal_record_list.Exists(x => x.UWPa.HasValue))
                {
                    model.UWPmin = run_normal_record_list.Where(x => x.UWPa.HasValue).Min(x => x.UWPa.Value);
                    model.UWPmax = run_normal_record_list.Where(x => x.UWPa.HasValue).Max(x => x.UWPa.Value);
                    model.UWPavg = run_normal_record_list.Where(x => x.UWPa.HasValue).Average(x => x.UWPa.Value);
                }
            }
 
            if (run_record_list.Count > 1)
            {
                var run_boot_list = run_record_list.OrderBy(x => x.DataTime).ToList();
                for (int j = 1; j < run_boot_list.Count; j++)
                {
                    if ((run_boot_list[j].DataTime - run_boot_list[j - 1].DataTime).TotalSeconds > 5 * run_boot_list[j].Duration)
                    {
                        model.BootTimes += 1;
                    }
                }
            }
 
            return model;
             
        }
 
    }
}