UpdateInspectionTaskDetailCmd.java
19.8 KB
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
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
package com.java110.community.cmd.inspectionTaskDetail;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.core.annotation.Java110Cmd;
import com.java110.core.annotation.Java110Transactional;
import com.java110.core.context.ICmdDataFlowContext;
import com.java110.core.event.cmd.Cmd;
import com.java110.core.event.cmd.CmdEvent;
import com.java110.core.log.LoggerFactory;
import com.java110.dto.inspection.InspectionDto;
import com.java110.dto.inspection.InspectionTaskDetailDto;
import com.java110.dto.inspection.InspectionTaskDto;
import com.java110.intf.common.IFileRelInnerServiceSMO;
import com.java110.intf.community.IInspectionTaskDetailInnerServiceSMO;
import com.java110.intf.community.IInspectionTaskDetailV1InnerServiceSMO;
import com.java110.intf.community.IInspectionTaskInnerServiceSMO;
import com.java110.intf.community.IInspectionTaskV1InnerServiceSMO;
import com.java110.intf.community.IInspectionPointV1InnerServiceSMO;
import com.java110.po.file.FileRelPo;
import com.java110.po.inspection.InspectionTaskDetailPo;
import com.java110.po.inspection.InspectionTaskPo;
import com.java110.po.property.AttendanceRecordPo;
import com.java110.utils.exception.CmdException;
import com.java110.utils.factory.ApplicationContextFactory;
import com.java110.utils.util.Assert;
import com.java110.utils.util.BeanConvertUtil;
import com.java110.utils.util.DateUtil;
import com.java110.utils.util.StringUtil;
import org.slf4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import java.math.BigDecimal;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 巡检任务明细更新命令类
* 负责处理巡检任务明细的更新操作，包括巡检点完成状态更新、照片处理、巡检任务状态更新等业务逻辑
*
* @author Java110
* @version 1.0
* @since 2023
*/
@Java110Cmd(serviceCode = "inspectionTaskDetail.updateInspectionTaskDetail")
public class UpdateInspectionTaskDetailCmd extends Cmd {
private static Logger logger = LoggerFactory.getLogger(UpdateInspectionTaskDetailCmd.class);
@Autowired
private IFileRelInnerServiceSMO fileRelInnerServiceSMOImpl;
@Autowired
private IInspectionTaskInnerServiceSMO inspectionTaskInnerServiceSMOImpl;
@Autowired
private IInspectionTaskDetailInnerServiceSMO inspectionTaskDetailInnerServiceSMOImpl;
@Autowired
private IInspectionTaskDetailV1InnerServiceSMO inspectionTaskDetailV1InnerServiceSMOImpl;
@Autowired
private IInspectionTaskV1InnerServiceSMO inspectionTaskV1InnerServiceSMOImpl;
@Autowired
private IInspectionPointV1InnerServiceSMO inspectionPointV1InnerServiceSMOImpl;
/**
* 参数校验方法
* 验证请求参数中是否包含必要的字段
*
* @param event 命令事件对象
* @param context 数据流上下文对象
* @param reqJson 请求参数JSON对象
* @throws CmdException 当参数校验失败时抛出异常
*/
@Override
public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
// 校验必要参数是否存在
Assert.hasKeyAndValue(reqJson, "taskDetailId", "请求报文中未包含taskDetailId");
Assert.hasKeyAndValue(reqJson, "taskId", "请求报文中未包含taskId");
Assert.hasKeyAndValue(reqJson, "inspectionId", "请求报文中未包含inspectionId");
// qrcode打卡时communityId从任务中获取，不强制要求
if (!"qrcode".equals(reqJson.getString("source"))) {
Assert.hasKeyAndValue(reqJson, "communityId", "请求报文中未包含communityId");
}
Assert.hasKeyAndValue(reqJson, "photos", "请求报文中未包含照片");
}
/**
* 执行巡检任务明细更新命令
* 主要业务流程：处理照片、更新巡检明细、检查并更新巡检任务状态
*
* @param event 命令事件对象
* @param context 数据流上下文对象
* @param reqJson 请求参数JSON对象
* @throws CmdException 当业务处理失败时抛出异常
*/
@Override
@Java110Transactional
public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
// 处理上传的照片
if (reqJson.containsKey("photos")) {
dealPhotos(reqJson);
}
// GPS校验：所有打卡都必须有有效坐标
String lng = reqJson.getString("longitude");
String lat = reqJson.getString("latitude");
if (StringUtil.isEmpty(lng) || "0".equals(lng) || "0.0".equals(lng) || "0.0000000".equals(lng)
|| StringUtil.isEmpty(lat) || "0".equals(lat) || "0.0".equals(lat) || "0.0000000".equals(lat)) {
throw new CmdException("请开启GPS获取位置后再打卡");
}
// 二维码打卡时校验距离（仅H5，不影响App）
if ("qrcode".equals(reqJson.getString("source"))) {
// 从任务中获取communityId
if (StringUtil.isEmpty(reqJson.getString("communityId"))) {
InspectionTaskDto taskDto = new InspectionTaskDto();
taskDto.setTaskId(reqJson.getString("taskId"));
List<InspectionTaskDto> tasks = inspectionTaskInnerServiceSMOImpl.queryInspectionTasks(taskDto);
if (tasks != null && tasks.size() > 0) {
reqJson.put("communityId", tasks.get(0).getCommunityId());
}
}
checkQrcodeDistance(reqJson);
saveQrcodeAttendanceRecord(reqJson);
}
// 设置巡检点完成状态
reqJson.put("state", "20200407"); // 巡检点完成状态码
try {
// 更新巡检任务明细
updateInspectionTaskDetail(reqJson);
} catch (ParseException e) {
logger.error("更新明细失败", e);
throw new CmdException(e.getMessage());
}
// 检查是否存在进行中的巡检任务
InspectionTaskDto inspectionTaskDto = new InspectionTaskDto();
inspectionTaskDto.setTaskId(reqJson.getString("taskId"));
inspectionTaskDto.setCommunityId(reqJson.getString("communityId"));
inspectionTaskDto.setState("20200405"); // 进行中状态码
List<InspectionTaskDto> inspectionTaskDtos = inspectionTaskInnerServiceSMOImpl.queryInspectionTasks(inspectionTaskDto);
// 如果存在进行中的巡检任务，更新为巡检中状态
if (inspectionTaskDtos != null && inspectionTaskDtos.size() > 0) {
reqJson.put("state", "20200406"); // 巡检中状态码
updateInspectionTask(reqJson);
}
// 检查是否还有未完成的巡检点
InspectionTaskDetailDto inspectionTaskDetailDto = new InspectionTaskDetailDto();
inspectionTaskDetailDto.setCommunityId(reqJson.getString("communityId"));
inspectionTaskDetailDto.setTaskId(reqJson.getString("taskId"));
inspectionTaskDetailDto.setState("20200405"); // 未完成状态码
int count = inspectionTaskDetailInnerServiceSMOImpl.queryInspectionTaskDetailsCount(inspectionTaskDetailDto);
// 如果还有未完成的巡检点，直接返回
if (count > 0) {
return;
}
// 所有巡检点都已完成，更新巡检任务为完成状态
reqJson.put("state", "20200407"); // 巡检完成状态码
updateInspectionTask(reqJson);
}
/**
* 处理照片信息
* 遍历照片数组，为每张照片调用添加照片方法
*
* @param reqJson 请求参数JSON对象，包含照片数组
*/
private void dealPhotos(JSONObject reqJson) {
JSONArray photos = reqJson.getJSONArray("photos");
// 遍历所有照片并逐一处理
for (int photoIndex = 0; photoIndex < photos.size(); photoIndex++) {
Object photo = photos.get(photoIndex);
reqJson.put("fileName", photo.toString());
addPhoto(reqJson);
}
}
/**
* 添加照片关联信息
* 将照片信息保存到文件关联表中
*
* @param paramInJson 接口调用方传入的参数，包含文件名称等信息
* @throws CmdException 当保存照片失败时抛出异常
*/
public void addPhoto(JSONObject paramInJson) {
// 构建文件关联业务对象
JSONObject businessUnit = new JSONObject();
businessUnit.put("fileRelId", "-1");
businessUnit.put("relTypeCd", "90000"); // 关联类型编码
businessUnit.put("saveWay", "ftp"); // 保存方式
businessUnit.put("objId", paramInJson.getString("taskDetailId")); // 关联对象ID
businessUnit.put("fileRealName", paramInJson.getString("fileName")); // 文件真实名称
businessUnit.put("fileSaveName", paramInJson.getString("fileName")); // 文件保存名称
// 转换为PO对象并保存
FileRelPo fileRelPo = BeanConvertUtil.covertBean(businessUnit, FileRelPo.class);
int flag = fileRelInnerServiceSMOImpl.saveFileRel(fileRelPo);
// 检查保存结果
if (flag < 1) {
throw new CmdException("保存图片失败");
}
}
/**
* 更新巡检任务明细
* 更新巡检点的详细信息，包括巡检时间、状态等，并根据时间判断巡检状态
*
* @param paramInJson 接口调用方传入的参数
* @throws ParseException 当时间解析失败时抛出异常
* @throws CmdException 当更新失败时抛出异常
*/
public void updateInspectionTaskDetail(JSONObject paramInJson) throws ParseException {
// 查询现有的巡检任务明细
InspectionTaskDetailDto inspectionTaskDetailDto = new InspectionTaskDetailDto();
inspectionTaskDetailDto.setTaskDetailId(paramInJson.getString("taskDetailId"));
inspectionTaskDetailDto.setCommunityId(paramInJson.getString("communityId"));
List<InspectionTaskDetailDto> inspectionTaskDetailDtos = inspectionTaskDetailInnerServiceSMOImpl.queryInspectionTaskDetails(inspectionTaskDetailDto);
// 确保只查询到一条记录
Assert.listOnlyOne(inspectionTaskDetailDtos, "未找到需要修改的活动 或多条数据");
// 合并原有数据和更新数据
JSONObject businessInspectionTaskDetail = new JSONObject();
businessInspectionTaskDetail.putAll(BeanConvertUtil.beanCovertMap(inspectionTaskDetailDtos.get(0)));
businessInspectionTaskDetail.putAll(paramInJson);
// 转换为PO对象
InspectionTaskDetailPo inspectionTaskDetailPoPo = BeanConvertUtil.covertBean(businessInspectionTaskDetail, InspectionTaskDetailPo.class);
inspectionTaskDetailPoPo.setInspectionTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A)); // 设置巡检时间
inspectionTaskDetailPoPo.setActUserId(paramInJson.getString("userId")); // 设置操作用户ID
inspectionTaskDetailPoPo.setActUserName(paramInJson.getString("userName")); // 设置操作用户名称
// 查询关联的巡检任务信息
String taskId = paramInJson.getString("taskId");
InspectionTaskDto inspectionTaskDto = new InspectionTaskDto();
inspectionTaskDto.setTaskId(taskId);
List<InspectionTaskDto> inspectionTaskDtos = inspectionTaskInnerServiceSMOImpl.queryInspectionTasks(inspectionTaskDto);
Assert.listOnlyOne(inspectionTaskDtos, "查询巡检任务数据错误！");
// 时间格式化和当前日期获取
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
Date date = new Date();
SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd");
String currentDate = sdf1.format(date);
// 获取巡检点的巡检时间限制
String inspectionStartTime = "";
String inspectionEndTime = "";
long planStartTime;
long planFinishTime;
String pointStartTime = inspectionTaskDetailDtos.get(0).getPointStartTime();
String pointEndTime = inspectionTaskDetailDtos.get(0).getPointEndTime();
// 计算计划开始时间
if (!StringUtil.isEmpty(pointStartTime)) {
// 使用巡检点自定义的开始时间
inspectionStartTime = currentDate + " " + pointStartTime + ":00";
Date startTime = format.parse(inspectionStartTime);
planStartTime = startTime.getTime();
} else {
// 使用巡检任务的计划开始时间
String planInsTime = inspectionTaskDtos.get(0).getPlanInsTime();
Date startTime = format.parse(planInsTime);
planStartTime = startTime.getTime();
}
// 计算计划结束时间
if (!StringUtil.isEmpty(pointEndTime)) {
// 使用巡检点自定义的结束时间
inspectionEndTime = currentDate + " " + pointEndTime + ":00";
Date endTime = format.parse(inspectionEndTime);
planFinishTime = endTime.getTime();
} else {
// 使用巡检任务的计划结束时间
String planEndTime = inspectionTaskDtos.get(0).getPlanEndTime();
Date endTime = format.parse(planEndTime);
planFinishTime = endTime.getTime();
}
// 获取巡检点签到时间并判断巡检状态
String inspectionTime = inspectionTaskDetailPoPo.getInspectionTime();
Date inspectionDetailTime = format.parse(inspectionTime);
long detailTime = inspectionDetailTime.getTime();
// 根据签到时间判断巡检状态
if (detailTime < planStartTime) {
// 早到状态
inspectionTaskDetailPoPo.setInspectionState("40000");
} else if (detailTime > planFinishTime) {
// 迟到状态
inspectionTaskDetailPoPo.setInspectionState("50000");
} else {
// 正常状态
inspectionTaskDetailPoPo.setInspectionState("60000");
}
// 执行更新操作
int flag = inspectionTaskDetailV1InnerServiceSMOImpl.updateInspectionTaskDetail(inspectionTaskDetailPoPo);
// 检查更新结果
if (flag < 1) {
throw new CmdException("更新任务明细失败");
}
}
/**
* 更新巡检任务信息
* 更新巡检任务的状态、实际巡检时间等信息
*
* @param paramInJson 接口调用方传入的参数
* @throws CmdException 当更新失败时抛出异常
*/
public void updateInspectionTask(JSONObject paramInJson) {
// 查询现有的巡检任务
InspectionTaskDto inspectionTaskDto = new InspectionTaskDto();
inspectionTaskDto.setTaskId(paramInJson.getString("taskId"));
inspectionTaskDto.setCommunityId(paramInJson.getString("communityId"));
List<InspectionTaskDto> inspectionTaskDtos = inspectionTaskInnerServiceSMOImpl.queryInspectionTasks(inspectionTaskDto);
// 确保只查询到一条记录
Assert.listOnlyOne(inspectionTaskDtos, "未找到需要修改的巡检任务 或多条数据");
// 合并原有数据和更新数据
JSONObject businessInspectionTask = new JSONObject();
businessInspectionTask.putAll(BeanConvertUtil.beanCovertMap(inspectionTaskDtos.get(0)));
// 转换为PO对象并设置更新字段
InspectionTaskPo inspectionTaskPo = BeanConvertUtil.covertBean(businessInspectionTask, InspectionTaskPo.class);
inspectionTaskPo.setActInsTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A)); // 设置实际巡检时间
inspectionTaskPo.setActUserId(paramInJson.getString("userId")); // 设置操作用户ID
inspectionTaskPo.setActUserName(paramInJson.getString("userName")); // 设置操作用户名称
inspectionTaskPo.setState(paramInJson.getString("state")); // 设置任务状态
// 处理任务转派情况
if (!StringUtil.isEmpty(paramInJson.getString("taskType")) && paramInJson.getString("taskType").equals("2000")) {
// 设置转派相关信息
inspectionTaskPo.setPlanUserId(paramInJson.getString("staffId")); // 设置计划用户ID
inspectionTaskPo.setPlanUserName(paramInJson.getString("staffName")); // 设置计划用户名称
inspectionTaskPo.setTaskType(paramInJson.getString("taskType")); // 设置任务类型
inspectionTaskPo.setTransferDesc(paramInJson.getString("transferDesc")); // 设置转派描述
}
// 执行更新操作
int flag = inspectionTaskV1InnerServiceSMOImpl.updateInspectionTask(inspectionTaskPo);
// 检查更新结果
if (flag < 1) {
throw new CmdException("修改任务失败");
}
}
/**
* 二维码打卡时同步写入考勤记录（attendance_record），使打卡记录在考勤页面可见
*/
private void saveQrcodeAttendanceRecord(JSONObject reqJson) {
try {
AttendanceRecordPo po = new AttendanceRecordPo();
po.setId(com.java110.core.factory.GenerateCodeFactory.getGeneratorId("10"));
po.setUserId(reqJson.getString("userId"));
po.setUserName(reqJson.getString("userName"));
po.setPunchType(reqJson.containsKey("punchType") ? reqJson.getString("punchType") : "ON");
po.setPunchTime(new Date());
try { po.setLongitude(new BigDecimal(reqJson.getString("longitude"))); } catch(Exception ex) {}
try { po.setLatitude(new BigDecimal(reqJson.getString("latitude"))); } catch(Exception ex) {}
po.setPunchAddress(reqJson.containsKey("address") ? reqJson.getString("address") : "");
po.setStoreId("");
po.setWorkType("qrcode");
po.setPhotoUrl(reqJson.containsKey("photos") ? reqJson.getJSONArray("photos").getString(0) : "");
Object dao = ApplicationContextFactory.getBean("attendanceRecordV1ServiceDaoImpl");
if (dao != null) {
java.lang.reflect.Method m = dao.getClass().getMethod("saveAttendanceRecord", AttendanceRecordPo.class);
m.invoke(dao, po);
}
} catch (Exception e) {
logger.error("保存考勤记录失败", e);
}
}
/**
* 二维码打卡距离校验（仅H5页面，不影响Android App）
*/
private void checkQrcodeDistance(JSONObject reqJson) {
double userLng = Double.parseDouble(reqJson.getString("longitude"));
double userLat = Double.parseDouble(reqJson.getString("latitude"));
// 查询巡检点坐标
InspectionDto pointDto = new InspectionDto();
pointDto.setInspectionId(reqJson.getString("inspectionId"));
pointDto.setCommunityId(reqJson.getString("communityId"));
List<InspectionDto> points =
inspectionPointV1InnerServiceSMOImpl.queryInspectionPoints(pointDto);
if (points == null || points.size() == 0) {
throw new CmdException("巡检点不存在");
}
String lng = points.get(0).getLng();
String lat = points.get(0).getLat();
if (StringUtil.isEmpty(lng) || StringUtil.isEmpty(lat)) {
return; // 无坐标时跳过距离校验
}
double pointLng = Double.parseDouble(lng);
double pointLat = Double.parseDouble(lat);
// Haversine距离计算
double R = 6371;
double dLat = Math.toRadians(pointLat - userLat);
double dLng = Math.toRadians(pointLng - userLng);
double a = Math.sin(dLat / 2) * Math.sin(dLat / 2)
+ Math.cos(Math.toRadians(userLat)) * Math.cos(Math.toRadians(pointLat))
* Math.sin(dLng / 2) * Math.sin(dLng / 2);
double distance = R * 2 * Math.atan2(Math.sqrt(a), Math.sqrt(1 - a));
if (distance > 2) {
throw new CmdException("距离巡检点超过2km，无法打卡（距离：" + String.format("%.2f", distance) + "km）");
}
}
}