zhubaomin
2025-04-11 a1744d0bf7f0ad8ac861d672cffd7c710dac4e7e
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
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
package com.dy.pipIrrGlobal.daoRm;
 
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.dy.pipIrrGlobal.pojoRm.RmIntakeAmountDay;
import com.dy.pipIrrGlobal.voRm.VoIntakeAmountDay;
import com.dy.pipIrrGlobal.voSt.*;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
 
import java.util.Date;
import java.util.List;
import java.util.Map;
 
/**
 * @Author: liurunyu
 * @Date: 2024/7/8 18:53
 * @Description
 */
@Mapper
public interface RmIntakeAmountDayMapper extends BaseMapper<RmIntakeAmountDay> {
    /**
     * delete by primary key
     * @param id primaryKey
     * @return deleteCount
     */
    int deleteByPrimaryKey(Long id);
 
    /**
     * insert record to table
     * @param record the record
     * @return insert count
     */
    int insert(RmIntakeAmountDay record);
 
    /**
     * insert record to table selective
     * @param record the record
     * @return insert count
     */
    int insertSelective(RmIntakeAmountDay record);
 
    /**
     * select by primary key
     * @param id primary key
     * @return object by primary key
     */
    RmIntakeAmountDay selectByPrimaryKey(Long id);
 
    /**
     * select by dt
     * @param date 日期(yyyy-mm-dd)
     * @return object by rtuAddr
     */
    List<RmIntakeAmountDay> selectByDate(Date date) ;
 
    /**
     * update record selective
     * @param record the updated record
     * @return update count
     */
    int updateByPrimaryKeySelective(RmIntakeAmountDay record);
 
    /**
     * update record
     * @param record the updated record
     * @return update count
     */
    int updateByPrimaryKey(RmIntakeAmountDay record);
 
    /**
     * 根据指定条件获取记录总数
     * @param params
     * @return
     */
    Long getRecordCount(Map<?, ?> params);
 
    /**
     * 根据指定条件获取记录
     * @param params
     * @return
     */
    List<VoIntakeAmountDay> getIntakeAmountDayHistory(Map<?, ?> params);
 
 
    /**
     * 以取水口维度统计取水口取水量
     * @param statisticsStartId 统计时间段开始时间对应的ID
     * @param statisticsEndId 统计时间段结束时间对应的ID
     * @return
     */
    List<VoIntakeAmountStatistics> statisticsByIntake(@Param("startId")Long statisticsStartId, @Param("endId")Long statisticsEndId) ;
 
    /**
     * 指定月份各天用水量记录数量
     * @param params
     * @return
     */
    Long getDayIntakeAmountCount(Map<?, ?> params);
 
    /**
     * 统计指定月份各天用水量
     * @param params
     * @return
     */
    List<VoDayIntakeAmount> getDayIntakeAmount(Map<?, ?> params);
 
    /**
     * 统计指定年份各月用水量记录数量
     * @param params
     * @return
     */
    Long getMonthIntakeAmountCount(Map<?, ?> params);
 
    /**
     * 统计指定年份各月用水量
     * @param params
     * @return
     */
    List<VoMonthAmount> getMonthIntakeAmount(Map<?, ?> params);
 
    ////////////////////////////////////////////////
    // 统计查询
    ///////////////////////////////////////////////
 
    /**
     * 为查询统计取水口日漏损量,统计取水口数量
     * @param intakeN
     * @return
     */
    Long selectIntakeCount4AmountDay(@Param("intakeNum")String intakeN) ;
 
    /**
     * 为查询统计取水口日漏损量,查询一页取水口ID
     * @param params
     * @return
     */
    List<VoDayIntakeAmount> selectIntakes4AmountDay(Map<?, ?> params) ;
 
    /**
     * 查询统计取水口日漏损量
     * @param params
     * @return
     */
    //下面1到31号分了6个查询,原因是入一个查询中,非常慢,不知道什么原因,也许是子查询太多的原因
    List<VoDayIntakeAmount> selectIntakeAmountOfDay01_05(Map<?, ?> params);
    List<VoDayIntakeAmount> selectIntakeAmountOfDay06_10(Map<?, ?> params);
    List<VoDayIntakeAmount> selectIntakeAmountOfDay11_15(Map<?, ?> params);
    List<VoDayIntakeAmount> selectIntakeAmountOfDay16_20(Map<?, ?> params);
    List<VoDayIntakeAmount> selectIntakeAmountOfDay21_25(Map<?, ?> params);
    List<VoDayIntakeAmount> selectIntakeAmountOfDay26_31(Map<?, ?> params);
 
 
    /**
     * 指定时间段用水量超过指定值的取水口数量
     * @param params
     * @return
     */
    Long getUseWaterGtValueIntakesCount(Map<String, Object> params);
 
    /**
     * 指定时间段用水量超过指定值的取水口
     * @param params
     * @return
     */
    List<VoIntakeAccumulateAmount> getUseWaterGtValueIntakes(Map<String, Object> params);
    /**
     * 指定时间段内消费金额超过指定值的取水口的数量
     * @param params
     * @return
     */
    Long getExpenseGtValueIntakesCount(Map<String, Object> params);
 
    /**
     * 指定时间段内消费金额超过指定值的取水口
     * @param params
     * @return
     */
    List<VoIntakeAccumulateAmount> getExpenseGtValueIntakes(Map<String, Object> params);
 
   /**
     * 指定时间段内取水次数超过指定值的取水口的数量
     * @param params
     * @return
     */
    Long getUseWaterTimesGtValueIntakesCount(Map<String, Object> params);
 
    /**
     * 指定时间段内取水次数超过指定值的取水口
     * @param params
     * @return
     */
    List<VoIntakeAccumulateAmount> getUseWaterTimesGtValueIntakes(Map<String, Object> params);
 
}