运行模块中新增业务月统计

lixiaojun

2022-08-17 d3024a7b50b35a8f24c1bfe0f13f4f86cc63a253

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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using SqlSugar;
 
 
namespace IStation.DAL
{
    /// <summary>
    /// 年监测记录
    /// </summary>
    public partial class MonitorYearRecord : CorpDAL<Entity.MonitorYearRecord>
    {
        /// <summary>
        /// 
        /// </summary>
        public override ConnectionConfig ConnectionConfig
        {
            get { return ConfigHelper.MonitorRecordConnectionConfig; }
        }
 
        #region 通过 MonitorPointID 获取
 
        /// <summary>
        /// 通过 MonitorPointID 获取
        /// </summary>
        public List<Entity.MonitorYearRecord> GetByMonitorPointID(long CorpID, long MonitorPointID)
        {
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.MonitorYearRecord>()
                    .Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID)
                    .OrderBy(x => x.DataTime, OrderByType.Asc).ToList();
            }
        }
 
        /// <summary>
        /// 通过 MonitorPointID 获取某年的数据
        /// </summary>
        public List<Entity.MonitorYearRecord> GetByMonitorPointIDOfYear(long CorpID, long MonitorPointID, int Year)
        {
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.MonitorYearRecord>()
                    .Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID)
                    .Where(x => x.DataYear == Year)
                    .OrderBy(x => x.DataTime, OrderByType.Asc).ToList();
            }
        }
 
        /// <summary>
        /// 通过 MonitorPointID 获取年区间的数据
        /// </summary>
        public List<Entity.MonitorYearRecord> GetByMonitorPointIDOfYearRange(long CorpID, long MonitorPointID, int StartYear, int EndYear)
        {
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.MonitorYearRecord>()
                    .Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID)
                    .Where(x => x.DataYear >= StartYear && x.DataYear <= EndYear)
                    .OrderBy(x => x.DataTime, OrderByType.Asc).ToList();
            }
        }
 
        #endregion
 
        #region 通过 SignalID 获取
 
        /// <summary>
        /// 通过 SignalID 获取
        /// </summary>
        public List<Entity.MonitorYearRecord> GetBySignalID(long CorpID, long MonitorPointID, long SignalID)
        {
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.MonitorYearRecord>()
                    .Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID)
                    .OrderBy(x => x.DataTime, OrderByType.Asc).ToList();
            }
        }
 
        /// <summary>
        /// 通过 SignalID 获取某年的数据
        /// </summary>
        public Entity.MonitorYearRecord GetBySignalIDOfYear(long CorpID, long MonitorPointID, long SignalID, int Year)
        {
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.MonitorYearRecord>()
                    .Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID)
                    .Where(x => x.DataYear == Year)
                    .First();
            }
        }
 
        /// <summary>
        /// 通过 SignalID 获取年区间的数据
        /// </summary>
        public List<Entity.MonitorYearRecord> GetBySignalIDOfYearRange(long CorpID, long MonitorPointID, long SignalID, int StartYear, int EndYear)
        {
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.MonitorYearRecord>()
                    .Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID)
                    .Where(x => x.DataYear >= StartYear && x.DataYear <= EndYear)
                    .OrderBy(x => x.DataTime, OrderByType.Asc).ToList();
            }
        }
 
        #endregion
 
        #region Delete
 
        /// <summary>
        /// 通过 SignalID 删除某年的数据
        /// </summary>
        public bool DeleteBySignalIDOfYear(long CorpID, long MonitorPointID, long SignalID, int Year)
        {
            using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Deleteable<Entity.MonitorYearRecord>()
                    .Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID)
                    .Where(x => x.DataYear == Year)
                    .ExecuteCommand() > 0;
            }
        }
 
        /// <summary>
        /// 通过 SignalID 删除年区间的数据
        /// </summary>
        public bool DeleteBySignalIDOfYearRange(long CorpID, long MonitorPointID, long SignalID, int StartYear, int EndYear)
        {
            if (StartYear > EndYear) 
                return false;
 
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Deleteable<Entity.MonitorYearRecord>()
                    .Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.SignalID == SignalID)
                    .Where(x => x.DataYear>=StartYear&&x.DataYear<=EndYear)
                    .ExecuteCommand() > 0;
            }
        }
 
        #endregion
 
 
 
 
    }
}