|
|
@@ -5,17 +5,18 @@ import com.alibaba.fastjson.JSON;
|
|
5
|
5
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
6
|
6
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
7
|
7
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
8
|
+import com.github.pagehelper.PageHelper;
|
|
|
9
|
+import com.github.pagehelper.PageInfo;
|
|
8
|
10
|
import com.unissoft.MyConstant;
|
|
9
|
11
|
import com.unissoft.mapper.GrainAbnormalDescribeMapper;
|
|
10
|
12
|
import com.unissoft.mapper.GrainCheckChooseRecordMapper;
|
|
11
|
13
|
import com.unissoft.mapper.GrainConditionRecordMapper;
|
|
12
|
14
|
import com.unissoft.mapper.SysResourceRoleMapper;
|
|
13
|
|
-import com.unissoft.model.GrainAbnormalDescribe;
|
|
14
|
|
-import com.unissoft.model.GrainCheckChooseRecord;
|
|
15
|
|
-import com.unissoft.model.GrainConditionRecord;
|
|
16
|
|
-import com.unissoft.model.SysResourceRole;
|
|
|
15
|
+import com.unissoft.model.*;
|
|
17
|
16
|
import com.unissoft.result.PageParam;
|
|
18
|
17
|
import com.unissoft.grainManage.service.GrainConditionRecordService;
|
|
|
18
|
+import com.unissoft.result.ResultView;
|
|
|
19
|
+import com.unissoft.utils.DateUtil;
|
|
19
|
20
|
import org.apache.commons.lang.ObjectUtils;
|
|
20
|
21
|
import org.json.JSONObject;
|
|
21
|
22
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
@@ -25,9 +26,7 @@ import org.springframework.stereotype.Service;
|
|
25
|
26
|
import org.springframework.transaction.annotation.Transactional;
|
|
26
|
27
|
import org.springframework.util.StringUtils;
|
|
27
|
28
|
|
|
28
|
|
-import java.util.Date;
|
|
29
|
|
-import java.util.List;
|
|
30
|
|
-import java.util.Map;
|
|
|
29
|
+import java.util.*;
|
|
31
|
30
|
import java.util.concurrent.TimeUnit;
|
|
32
|
31
|
import java.util.stream.Collectors;
|
|
33
|
32
|
|
|
|
@@ -51,11 +50,11 @@ public class GrainConditionRecordServiceImpl extends ServiceImpl<GrainConditionR
|
|
51
|
50
|
@Autowired
|
|
52
|
51
|
private GrainAbnormalDescribeMapper grainAbnormalDescribeMapper;
|
|
53
|
52
|
|
|
54
|
|
- @Autowired
|
|
|
53
|
+ /* @Autowired
|
|
55
|
54
|
private RedisTemplate redisTemplate;
|
|
56
|
55
|
|
|
57
|
56
|
@Autowired
|
|
58
|
|
- private StringRedisTemplate stringRedisTemplate;
|
|
|
57
|
+ private StringRedisTemplate stringRedisTemplate;*/
|
|
59
|
58
|
|
|
60
|
59
|
@Autowired
|
|
61
|
60
|
private GrainCheckChooseRecordMapper grainCheckChooseRecordMapper;
|
|
|
@@ -80,11 +79,11 @@ public class GrainConditionRecordServiceImpl extends ServiceImpl<GrainConditionR
|
|
80
|
79
|
QueryWrapper<GrainConditionRecord> ew = new QueryWrapper<>();
|
|
81
|
80
|
if (!StringUtils.isEmpty(pageParam.getCondition())) {
|
|
82
|
81
|
JSONObject object = new JSONObject(pageParam.getCondition());
|
|
83
|
|
- String checkPerson = object.getString("check_person").trim();
|
|
84
|
|
- String startTime = object.getString("check_time").trim();
|
|
85
|
|
- String endTime = object.getString("check_time").trim();
|
|
|
82
|
+ String checkPerson = object.optString("check_person").trim();
|
|
|
83
|
+ String startTime = object.optString("check_start_time").trim();
|
|
|
84
|
+ String endTime = object.optString("check_end_time").trim();
|
|
86
|
85
|
if (!StringUtils.isEmpty(checkPerson)) {
|
|
87
|
|
- ew.like("check_person", checkPerson);
|
|
|
86
|
+ ew.eq("check_person", checkPerson);
|
|
88
|
87
|
}
|
|
89
|
88
|
if (!StringUtils.isEmpty(startTime)) {
|
|
90
|
89
|
ew.ge("check_time", startTime);
|
|
|
@@ -100,6 +99,11 @@ public class GrainConditionRecordServiceImpl extends ServiceImpl<GrainConditionR
|
|
100
|
99
|
page = new Page(pageIndex, pageSize);
|
|
101
|
100
|
}
|
|
102
|
101
|
Page<GrainConditionRecord> pageResult = grainConditionRecordMapper.selectPage(page, ew);
|
|
|
102
|
+ List<GrainConditionRecord> records = pageResult.getRecords();
|
|
|
103
|
+ for(GrainConditionRecord grainConditionRecord : records){
|
|
|
104
|
+ GrainAbnormalDescribe grainAbnormalDescribe = grainAbnormalDescribeMapper.getSelectId(grainConditionRecord.getId());
|
|
|
105
|
+ grainConditionRecord.setGrainAbnormalDescribe(grainAbnormalDescribe);
|
|
|
106
|
+ }
|
|
103
|
107
|
return pageResult;
|
|
104
|
108
|
}
|
|
105
|
109
|
|
|
|
@@ -107,44 +111,50 @@ public class GrainConditionRecordServiceImpl extends ServiceImpl<GrainConditionR
|
|
107
|
111
|
@Override
|
|
108
|
112
|
public void saveGrainRecord(GrainConditionRecord model) {
|
|
109
|
113
|
//新增粮情检查
|
|
|
114
|
+ String checkChooseRecord = model.getCheckDescribe();
|
|
|
115
|
+ System.out.println("检查项,选项"+checkChooseRecord);
|
|
|
116
|
+
|
|
110
|
117
|
grainConditionRecordMapper.insert(model);
|
|
|
118
|
+ if(org.apache.commons.lang.StringUtils.isNotBlank(checkChooseRecord)) {
|
|
111
|
119
|
|
|
112
|
|
- GrainAbnormalDescribe grainAbnormalDescribe = model.getGrainAbnormalDescribe();
|
|
113
|
|
- int id = grainConditionRecordMapper.getSelectId();
|
|
114
|
|
- grainAbnormalDescribe.setGrainRecordId(id);
|
|
115
|
|
-
|
|
116
|
|
- //新增粮情检查描述
|
|
117
|
|
- grainAbnormalDescribeMapper.insert(grainAbnormalDescribe);
|
|
118
|
|
- String json = JSON.toJSONString(model);
|
|
119
|
|
-
|
|
120
|
|
- String checkDescribe = model.getCheckDescribe();
|
|
121
|
|
- Map mapTypes = JSON.parseObject(checkDescribe);
|
|
122
|
|
- for (Object key : mapTypes.keySet()) {
|
|
123
|
|
- System.out.println("key为:" + key + "值为:" + mapTypes.get(key));
|
|
124
|
|
- GrainCheckChooseRecord grainCheckChooseRecord = new GrainCheckChooseRecord();
|
|
125
|
|
- grainCheckChooseRecord.setCheckList(ObjectUtils.toString(key));
|
|
126
|
|
- grainCheckChooseRecord.setChoose(ObjectUtils.toString(mapTypes.get(key)));
|
|
127
|
|
- grainCheckChooseRecord.setGrainRecordId(id);
|
|
128
|
|
- grainCheckChooseRecord.setCreateTime(new Date());
|
|
129
|
|
- grainCheckChooseRecordMapper.insert(grainCheckChooseRecord);
|
|
|
120
|
+ Integer id = grainConditionRecordMapper.getSelectRecordId();
|
|
|
121
|
+ System.out.println("grainConditionRecordId =========" +id);
|
|
|
122
|
+ //保存检查项和选项
|
|
|
123
|
+ Map mapTypes = JSON.parseObject(checkChooseRecord);
|
|
|
124
|
+ for (Object key : mapTypes.keySet()) {
|
|
|
125
|
+ System.out.println("key为:" + key + "值为:" + mapTypes.get(key));
|
|
|
126
|
+ GrainCheckChooseRecord grainCheckChooseRecord = new GrainCheckChooseRecord();
|
|
|
127
|
+ grainCheckChooseRecord.setCheckList(ObjectUtils.toString(key));
|
|
|
128
|
+ grainCheckChooseRecord.setGrainRecordId(id);
|
|
|
129
|
+ Map map = JSON.parseObject(JSON.toJSONString(mapTypes.get(key)), Map.class);
|
|
|
130
|
+ if(map != null && !map.isEmpty()) {
|
|
|
131
|
+ grainCheckChooseRecord.setChoose(ObjectUtils.toString(map.get("choose")));
|
|
|
132
|
+ grainCheckChooseRecord.setCreateTime(ObjectUtils.toString(map.get("time")));
|
|
|
133
|
+ }
|
|
|
134
|
+ grainCheckChooseRecordMapper.insert(grainCheckChooseRecord);
|
|
|
135
|
+ }
|
|
|
136
|
+ if(model.getGrainAbnormalDescribe() != null) {
|
|
|
137
|
+ GrainAbnormalDescribe grainAbnormalDescribe = model.getGrainAbnormalDescribe();
|
|
|
138
|
+ grainAbnormalDescribe.setGrainRecordId(id);
|
|
|
139
|
+ //新增粮情检查描述
|
|
|
140
|
+ grainAbnormalDescribeMapper.insert(grainAbnormalDescribe);
|
|
|
141
|
+ }
|
|
130
|
142
|
}
|
|
131
|
|
-
|
|
132
|
|
- String redisKey = String.valueOf(StrUtil.format("{}{}",
|
|
133
|
|
- "grainConditionRecord_", id));
|
|
134
|
|
- redisTemplate.opsForValue().set(redisKey, json, 7, TimeUnit.DAYS);
|
|
135
|
143
|
}
|
|
136
|
144
|
|
|
137
|
145
|
@Transactional
|
|
138
|
146
|
@Override
|
|
139
|
147
|
public void updateGrainRecord(GrainConditionRecord model) {
|
|
140
|
148
|
|
|
|
149
|
+ String checkChooseRecord = model.getCheckDescribe();
|
|
|
150
|
+ model.setCheckDescribe(checkChooseRecord);
|
|
141
|
151
|
grainConditionRecordMapper.updateById(model);
|
|
142
|
152
|
QueryWrapper<GrainAbnormalDescribe> qw = new QueryWrapper<>();
|
|
143
|
153
|
qw.eq("grain_record_id", model.getId());
|
|
144
|
154
|
GrainAbnormalDescribe grainAbnormalDescribe = grainAbnormalDescribeMapper.selectOne(qw);
|
|
145
|
|
-
|
|
|
155
|
+ //保存异常描述
|
|
146
|
156
|
if(grainAbnormalDescribe != null){
|
|
147
|
|
- grainAbnormalDescribe.setGrainRecordId(model.getGrainAbnormalDescribe().getGrainRecordId());
|
|
|
157
|
+ grainAbnormalDescribe.setGrainRecordId(model.getId());
|
|
148
|
158
|
grainAbnormalDescribe.setAbnormalGrain(model.getGrainAbnormalDescribe().getAbnormalGrain());
|
|
149
|
159
|
grainAbnormalDescribe.setAbnormalWater(model.getGrainAbnormalDescribe().getAbnormalWater());
|
|
150
|
160
|
grainAbnormalDescribe.setOccurArea(model.getGrainAbnormalDescribe().getOccurArea());
|
|
|
@@ -153,16 +163,19 @@ public class GrainConditionRecordServiceImpl extends ServiceImpl<GrainConditionR
|
|
153
|
163
|
grainAbnormalDescribe.setPestType(model.getGrainAbnormalDescribe().getPestType());
|
|
154
|
164
|
grainAbnormalDescribeMapper.updateById(grainAbnormalDescribe);
|
|
155
|
165
|
}
|
|
156
|
|
- if(org.apache.commons.lang.StringUtils.isNotBlank(model.getCheckDescribe())){
|
|
157
|
|
- String checkDescribe = model.getCheckDescribe();
|
|
158
|
|
- Map mapTypes = JSON.parseObject(checkDescribe);
|
|
|
166
|
+ //保存检查项和选项
|
|
|
167
|
+ if(org.apache.commons.lang.StringUtils.isNotBlank(checkChooseRecord)){
|
|
|
168
|
+ Map mapTypes = JSON.parseObject(checkChooseRecord);
|
|
159
|
169
|
for (Object key : mapTypes.keySet()) {
|
|
160
|
170
|
System.out.println("key为:" + key + "值为:" + mapTypes.get(key));
|
|
161
|
171
|
GrainCheckChooseRecord grainCheckChooseRecord = new GrainCheckChooseRecord();
|
|
162
|
172
|
grainCheckChooseRecord.setCheckList(ObjectUtils.toString(key));
|
|
163
|
|
- grainCheckChooseRecord.setChoose(ObjectUtils.toString(mapTypes.get(key)));
|
|
164
|
173
|
grainCheckChooseRecord.setGrainRecordId(model.getId());
|
|
165
|
|
- grainCheckChooseRecord.setCreateTime(new Date());
|
|
|
174
|
+ Map map = JSON.parseObject(JSON.toJSONString(mapTypes.get(key)), Map.class);
|
|
|
175
|
+ if(map != null && !map.isEmpty()) {
|
|
|
176
|
+ grainCheckChooseRecord.setChoose(ObjectUtils.toString(map.get("choose")));
|
|
|
177
|
+ grainCheckChooseRecord.setCreateTime(ObjectUtils.toString(map.get("time")));
|
|
|
178
|
+ }
|
|
166
|
179
|
grainCheckChooseRecordMapper.updateById(grainCheckChooseRecord);
|
|
167
|
180
|
}
|
|
168
|
181
|
}
|
|
|
@@ -172,41 +185,54 @@ public class GrainConditionRecordServiceImpl extends ServiceImpl<GrainConditionR
|
|
172
|
185
|
@Override
|
|
173
|
186
|
public void deleteById(Integer id) {
|
|
174
|
187
|
|
|
175
|
|
- GrainCheckChooseRecord grainCheckChooseRecord = new GrainCheckChooseRecord();
|
|
176
|
|
- grainCheckChooseRecord.setGrainRecordId(id);
|
|
177
|
|
- grainAbnormalDescribeMapper.deleteById(grainCheckChooseRecord);
|
|
|
188
|
+ grainCheckChooseRecordMapper.getDeleteById(id);
|
|
178
|
189
|
|
|
179
|
|
- GrainAbnormalDescribe grainAbnormalDescribe = new GrainAbnormalDescribe();
|
|
180
|
|
- grainAbnormalDescribe.setGrainRecordId(id);
|
|
181
|
|
- grainAbnormalDescribeMapper.deleteById(grainAbnormalDescribe);
|
|
|
190
|
+ grainAbnormalDescribeMapper.getDeleteById(id);
|
|
182
|
191
|
|
|
183
|
192
|
GrainConditionRecord grainConditionRecord = new GrainConditionRecord();
|
|
184
|
193
|
grainConditionRecord.setId(id);
|
|
185
|
194
|
grainConditionRecordMapper.deleteById(grainConditionRecord);
|
|
186
|
195
|
//删除redis中值
|
|
187
|
|
- if (redisTemplate.hasKey(String.valueOf(StrUtil.format("{}{}", "grainConditionRecord_", id)))) {
|
|
188
|
|
- String redisKey = String.valueOf(StrUtil.format("{}{}",
|
|
189
|
|
- "grainConditionRecord_", id));
|
|
190
|
|
- redisTemplate.delete(redisKey);
|
|
191
|
|
- }
|
|
192
|
196
|
}
|
|
193
|
197
|
|
|
194
|
198
|
@Override
|
|
195
|
|
- public List<GrainConditionRecord> getByRoleTime() {
|
|
|
199
|
+ public List<GrainConditionRecord> getByRoleTime(PageParam pageParam) {
|
|
|
200
|
+
|
|
196
|
201
|
List<GrainConditionRecord> list = grainConditionRecordMapper.getByCheckPersonAndCheckTime();
|
|
197
|
202
|
for (GrainConditionRecord conditionRecord : list) {
|
|
198
|
203
|
String checkDescribe = conditionRecord.getCheckDescribe();
|
|
199
|
|
- Map mapTypes = JSON.parseObject(checkDescribe);
|
|
200
|
|
- for (Object key : mapTypes.keySet()) {
|
|
201
|
|
- System.out.println("key为:" + key + "值为:" + mapTypes.get(key));
|
|
202
|
|
- if("pest_abnormal".equals(key) || "grain_abnormal".equals(key) ||"water_abnormal".equals(key) ){
|
|
203
|
|
- conditionRecord.setWaterAbnormal(ObjectUtils.toString(mapTypes.get(key)));
|
|
204
|
|
- conditionRecord.setGrainAbnormal(ObjectUtils.toString(mapTypes.get(key)));
|
|
205
|
|
- conditionRecord.setPestAbnormal(ObjectUtils.toString(mapTypes.get(key)));
|
|
|
204
|
+ if(org.apache.commons.lang.StringUtils.isNotBlank(checkDescribe)){
|
|
|
205
|
+ Map mapTypes = JSON.parseObject(checkDescribe);
|
|
|
206
|
+ for (Object key : mapTypes.keySet()) {
|
|
|
207
|
+ System.out.println("key为:" + key + "值为:" + mapTypes.get(key));
|
|
|
208
|
+ if("pest_abnormal".equals(key) || "grain_abnormal".equals(key) ||"water_abnormal".equals(key) ){
|
|
|
209
|
+ Map map = JSON.parseObject(JSON.toJSONString(mapTypes.get(key)), Map.class);
|
|
|
210
|
+ if(map != null && !map.isEmpty()) {
|
|
|
211
|
+ conditionRecord.setWaterAbnormal(ObjectUtils.toString(map.get("choose")));
|
|
|
212
|
+ conditionRecord.setGrainAbnormal(ObjectUtils.toString(map.get("choose")));
|
|
|
213
|
+ conditionRecord.setPestAbnormal(ObjectUtils.toString(map.get("choose")));
|
|
|
214
|
+ }
|
|
|
215
|
+ }
|
|
206
|
216
|
}
|
|
207
|
217
|
}
|
|
208
|
218
|
}
|
|
209
|
|
- return list;
|
|
|
219
|
+ List<GrainConditionRecord> listPage = new ArrayList<GrainConditionRecord>();
|
|
|
220
|
+ int currIdx = (pageParam.getPageIndex() > 1 ? (pageParam.getPageIndex() -1) * pageParam.getPageSize() : 0);
|
|
|
221
|
+ for (int i = 0; i < pageParam.getPageSize() && i < list.size() - currIdx; i++) {
|
|
|
222
|
+ GrainConditionRecord page = list.get(currIdx + i);
|
|
|
223
|
+ listPage.add(page);
|
|
|
224
|
+ }
|
|
|
225
|
+ return listPage;
|
|
|
226
|
+ }
|
|
|
227
|
+
|
|
|
228
|
+ @Override
|
|
|
229
|
+ public GrainConditionRecord getRecordById(Long id) {
|
|
|
230
|
+ GrainConditionRecord grainConditionRecord = grainConditionRecordMapper.selectById(id);
|
|
|
231
|
+ QueryWrapper<GrainAbnormalDescribe> ew = new QueryWrapper<>();
|
|
|
232
|
+ ew.eq("grain_record_id",id);
|
|
|
233
|
+ GrainAbnormalDescribe grainAbnormalDescribe = grainAbnormalDescribeMapper.selectOne(ew);
|
|
|
234
|
+ grainConditionRecord.setGrainAbnormalDescribe(grainAbnormalDescribe);
|
|
|
235
|
+ return grainConditionRecord;
|
|
210
|
236
|
}
|
|
211
|
237
|
|
|
212
|
238
|
|