|
@@ -72,7 +72,7 @@ public class LawenforcementRecordServiceImpl extends BaseServiceImpl implements
|
|
|
@Override
|
|
|
public int insertEnforceLawInfoByList(JSONArray records) {
|
|
|
log.error("============================================数据开始===================================================");
|
|
|
- log.error("接受到的报文数据长度===>{}",records.size());
|
|
|
+ log.error("接受到的报文数据长度===>{}", records.size());
|
|
|
//存储原始报文
|
|
|
return insertJsonData(records);
|
|
|
}
|
|
@@ -177,21 +177,17 @@ public class LawenforcementRecordServiceImpl extends BaseServiceImpl implements
|
|
|
Map<String, Object> userCodeByUserId = userMapper.getUserCodeByUserId(record.getUserId());
|
|
|
record.setPersonCode(MapUtils.getString(userCodeByUserId, "personCode"));
|
|
|
|
|
|
- //检查当前绑定设备的执法人是否为主办人
|
|
|
-// Map<String, Object> isMainPerson = recordMapper.getIsMainPerson(record);
|
|
|
//将设备与人员绑定
|
|
|
int i = recordMapper.bindDeviceToPerson(record);
|
|
|
|
|
|
- LawenforcementRecordLog lawenforcementRecordLog = new LawenforcementRecordLog(IdUtils.fastSimpleUUID(), record.getPersonCode(), record.getRecordId(), record.getDeviceId(), record.getDeviceName(), new Date(), null);
|
|
|
- //将工单执行记录,写入到日志表中:数据id、任务id、执法人编号、设备编号、开始时间
|
|
|
+ LawenforcementRecordLog lawenforcementRecordLog = new LawenforcementRecordLog(IdUtils.fastSimpleUUID(), record.getPersonCode(), record.getRecordId(), record.getDeviceId(), record.getDeviceName(), new Date(), null, "0");
|
|
|
+ //将工单执行记录,写入到日志表中:数据id、任务id、执法人编号、设备编号、开始时间、子任务状态
|
|
|
recordMapper.addRecordLog(lawenforcementRecordLog);
|
|
|
- //判断是否为主办人,如果是主办人则开始工单
|
|
|
-// if ("1".equals(MapUtils.getString(isMainPerson, "mainPerson"))) {
|
|
|
+ //修改工单状态为执法中
|
|
|
recordMapper.startRecord(record);
|
|
|
//绑定设备后关闭定时任务
|
|
|
deviceService.cancelTask(lawenforcementRecordLog.getDeviceId());
|
|
|
deviceService.setOpenedDevice(lawenforcementRecordLog.getDeviceId());
|
|
|
-// }
|
|
|
return i;
|
|
|
}
|
|
|
|
|
@@ -264,12 +260,8 @@ public class LawenforcementRecordServiceImpl extends BaseServiceImpl implements
|
|
|
Map<String, Object> userCodeByUserId = userMapper.getUserCodeByUserId(record.getUserId());
|
|
|
record.setPersonCode(MapUtils.getString(userCodeByUserId, "personCode"));
|
|
|
|
|
|
- //检查当前绑定设备的执法人是否为主办人
|
|
|
-// Map<String, Object> isMainPerson = recordMapper.getIsMainPerson(record);
|
|
|
-// if ("1".equals(MapUtils.getString(isMainPerson, "mainPerson"))) {
|
|
|
- //设置任务完成状态
|
|
|
- recordMapper.updateRecordStatus(record);
|
|
|
-// }
|
|
|
+ //设置任务完成状态
|
|
|
+ recordMapper.updateRecordStatus(record);
|
|
|
|
|
|
//设置任务结束时间
|
|
|
int i = recordMapper.updateRecordLogEndTime(record);
|
|
@@ -292,21 +284,21 @@ public class LawenforcementRecordServiceImpl extends BaseServiceImpl implements
|
|
|
//查询任务集合
|
|
|
List<LawenforcementRecord> recordList = recordMapper.getRecordList(record);
|
|
|
//处理工单状态
|
|
|
- recordList.forEach(data->{
|
|
|
- if(StringUtils.isNotEmpty(record.getRecordStatus())){
|
|
|
+ recordList.forEach(data -> {
|
|
|
+ if (StringUtils.isNotEmpty(record.getRecordStatus())) {
|
|
|
//查询带执法
|
|
|
- if(DAI_ZHI_FA.equals(record.getRecordStatus())){
|
|
|
+ if (DAI_ZHI_FA.equals(record.getRecordStatus())) {
|
|
|
//查询结果中可能存在已经进行中的任务;需要修改为带执法状态
|
|
|
- if(ZHI_FA_ZHONG.equals(data.getRecordStatus())){
|
|
|
+ if (ZHI_FA_ZHONG.equals(data.getRecordStatus())) {
|
|
|
data.setRecordStatus(DAI_ZHI_FA);
|
|
|
- }else if(ER_CI_ZHI_FA.equals(data.getRecordStatus())){
|
|
|
+ } else if (ER_CI_ZHI_FA.equals(data.getRecordStatus())) {
|
|
|
data.setRecordStatus(ZHI_FA_YI_CHANG);
|
|
|
}
|
|
|
- //查询执法进行中
|
|
|
- }else if(ZHI_FA_ZHONG.equals(record.getRecordStatus())){
|
|
|
- if(ZHI_FA_WAN_CHENG.equals(data.getRecordStatus())){
|
|
|
+ //查询执法进行中
|
|
|
+ } else if (ZHI_FA_ZHONG.equals(record.getRecordStatus())) {
|
|
|
+ if (ZHI_FA_WAN_CHENG.equals(data.getRecordStatus())) {
|
|
|
data.setRecordStatus(ZHI_FA_ZHONG);
|
|
|
- }else if(ER_CI_ZHI_FA_WAN_CHENG.equals(data.getRecordStatus())){
|
|
|
+ } else if (ER_CI_ZHI_FA_WAN_CHENG.equals(data.getRecordStatus())) {
|
|
|
data.setRecordStatus(ER_CI_ZHI_FA);
|
|
|
}
|
|
|
|
|
@@ -342,7 +334,7 @@ public class LawenforcementRecordServiceImpl extends BaseServiceImpl implements
|
|
|
idArray.add(message.getString("id"));
|
|
|
recordMap.put(message.getString("id"), message);
|
|
|
}
|
|
|
- log.info("本次数据的id集合===>{}",idArray);
|
|
|
+ log.info("本次数据的id集合===>{}", idArray);
|
|
|
|
|
|
//遍历报文数据,存储需要的信息
|
|
|
/* recordListMessage.forEach(message->{
|
|
@@ -352,7 +344,7 @@ public class LawenforcementRecordServiceImpl extends BaseServiceImpl implements
|
|
|
|
|
|
//调用获取数据方法,查出存在的数据
|
|
|
List<Map<String, Object>> existMessage = recordMapper.getExistMessage(idArray);
|
|
|
- log.error("获取存在的数据量===>{}",existMessage.size());
|
|
|
+ log.error("获取存在的数据量===>{}", existMessage.size());
|
|
|
|
|
|
//对存在的数据进行遍历更新;并且在recordMap中移除已经更新的数据
|
|
|
existMessage.forEach(existMap -> {
|
|
@@ -367,7 +359,7 @@ public class LawenforcementRecordServiceImpl extends BaseServiceImpl implements
|
|
|
addMessage.put("updateTime", simpleDateFormat.format(new Date()));
|
|
|
addMessage.put("dataUpdateTime", message.getString("updateTime"));
|
|
|
recordMapper.updateJsonData(addMessage);
|
|
|
- }else{
|
|
|
+ } else {
|
|
|
log.error("时间相同====>数据id===>{};获取的报文数据:{}<<>>;mysql数据:{}", message.getString("id"), message, existMap);
|
|
|
}
|
|
|
|
|
@@ -468,7 +460,7 @@ public class LawenforcementRecordServiceImpl extends BaseServiceImpl implements
|
|
|
@Override
|
|
|
public LawenforcementFillFormBO getFillForm(LawenforcementFillFormBO fillFormBO) {
|
|
|
LawenforcementFillFormBO fillForm = recordMapper.getFillForm(fillFormBO);
|
|
|
- if (fillForm!=null) {
|
|
|
+ if (fillForm != null) {
|
|
|
StringBuilder newDiles = new StringBuilder();
|
|
|
String filename = fillForm.getAttachName();
|
|
|
newDiles.append(fillForm.getAttachPath()).append("+").append(filename);
|