Commit 016b541c authored by kongfm's avatar kongfm

派遣添加救出冗余字段

parent ca8434b8
...@@ -118,4 +118,7 @@ public class DispatchPaperDto extends BaseDto { ...@@ -118,4 +118,7 @@ public class DispatchPaperDto extends BaseDto {
@ApiModelProperty(value = "到达反馈方式code") @ApiModelProperty(value = "到达反馈方式code")
private String arriveFeedbackCode; private String arriveFeedbackCode;
@ApiModelProperty(value = "救出时间-- 冗余字段便于查询")
private Date saveTime;
} }
...@@ -217,5 +217,9 @@ public class DispatchPaper extends BaseEntity { ...@@ -217,5 +217,9 @@ public class DispatchPaper extends BaseEntity {
@TableField("arrive_feedback_code") @TableField("arrive_feedback_code")
private String arriveFeedbackCode; private String arriveFeedbackCode;
/**
* 救出时间-- 冗余字段便于查询
*/
@TableField("save_time")
private Date saveTime;
} }
...@@ -440,6 +440,7 @@ ...@@ -440,6 +440,7 @@
e.address, e.address,
e.rescue_code as rescueCode, e.rescue_code as rescueCode,
p.dispatch_time as dispatchTime, p.dispatch_time as dispatchTime,
p.save_time as saveTime,
e.use_unit as useUnit, e.use_unit as useUnit,
e.use_unit_id as useUnitId, e.use_unit_id as useUnitId,
e.use_unit_authority as useUnitAuthority, e.use_unit_authority as useUnitAuthority,
......
...@@ -45,6 +45,7 @@ ...@@ -45,6 +45,7 @@
e.address, e.address,
e.rescue_code as rescueCode, e.rescue_code as rescueCode,
p.dispatch_time as dispatchTime, p.dispatch_time as dispatchTime,
p.save_time as saveTime,
e.use_unit as useUnit, e.use_unit as useUnit,
e.use_unit_id as useUnitId, e.use_unit_id as useUnitId,
e.use_unit_authority as useUnitAuthority, e.use_unit_authority as useUnitAuthority,
......
...@@ -246,12 +246,7 @@ public class DispatchTaskController extends BaseController { ...@@ -246,12 +246,7 @@ public class DispatchTaskController extends BaseController {
paperList = iAlertFormValueService.list(queryWrapper); paperList = iAlertFormValueService.list(queryWrapper);
paperList.stream().forEach(t -> { paperList.stream().forEach(t -> {
String value = t.getFieldValue(); String value = t.getFieldValue();
if("save_time".equals(t.getFieldCode())) { if("error_result".equals(t.getFieldCode())) {
// 救援完成时间
if(StringUtils.isNotBlank(value)) {
temp.setSaveTime(DateUtils.longStr2Date(value));
}
} else if("error_result".equals(t.getFieldCode())) {
// 故障原因 // 故障原因
temp.setErrorResult(value); temp.setErrorResult(value);
} else if("fix_result".equals(t.getFieldCode())) { } else if("fix_result".equals(t.getFieldCode())) {
...@@ -279,12 +274,7 @@ public class DispatchTaskController extends BaseController { ...@@ -279,12 +274,7 @@ public class DispatchTaskController extends BaseController {
paperList = iAlertFormValueService.list(queryWrapper); paperList = iAlertFormValueService.list(queryWrapper);
paperList.stream().forEach(t -> { paperList.stream().forEach(t -> {
String value = t.getFieldValue(); String value = t.getFieldValue();
if("save_time".equals(t.getFieldCode())) { if("error_result".equals(t.getFieldCode())) {
// 救援完成时间
if(StringUtils.isNotBlank(value)) {
temp.setSaveTime(DateUtils.longStr2Date(value));
}
} else if("error_result".equals(t.getFieldCode())) {
// 故障原因 // 故障原因
temp.setErrorResult(value); temp.setErrorResult(value);
} else if("fix_result".equals(t.getFieldCode())) { } else if("fix_result".equals(t.getFieldCode())) {
......
...@@ -555,12 +555,7 @@ public class WechatController extends BaseController { ...@@ -555,12 +555,7 @@ public class WechatController extends BaseController {
paperList = iAlertFormValueService.list(queryWrapper); paperList = iAlertFormValueService.list(queryWrapper);
paperList.stream().forEach(t -> { paperList.stream().forEach(t -> {
String value = t.getFieldValue(); String value = t.getFieldValue();
if("save_time".equals(t.getFieldCode())) { if("error_result".equals(t.getFieldCode())) {
// 救援完成时间
if(StringUtils.isNotBlank(value)) {
temp.setSaveTime(DateUtils.longStr2Date(value));
}
} else if("error_result".equals(t.getFieldCode())) {
// 故障原因 // 故障原因
temp.setErrorResult(value); temp.setErrorResult(value);
} else if("fix_result".equals(t.getFieldCode())) { } else if("fix_result".equals(t.getFieldCode())) {
...@@ -585,12 +580,7 @@ public class WechatController extends BaseController { ...@@ -585,12 +580,7 @@ public class WechatController extends BaseController {
paperList = iAlertFormValueService.list(queryWrapper); paperList = iAlertFormValueService.list(queryWrapper);
paperList.stream().forEach(t -> { paperList.stream().forEach(t -> {
String value = t.getFieldValue(); String value = t.getFieldValue();
if("save_time".equals(t.getFieldCode())) { if("error_result".equals(t.getFieldCode())) {
// 救援完成时间
if(StringUtils.isNotBlank(value)) {
temp.setSaveTime(DateUtils.longStr2Date(value));
}
} else if("error_result".equals(t.getFieldCode())) {
// 故障原因 // 故障原因
temp.setErrorResult(value); temp.setErrorResult(value);
} else if("fix_result".equals(t.getFieldCode())) { } else if("fix_result".equals(t.getFieldCode())) {
......
...@@ -285,6 +285,10 @@ public class DispatchTaskServiceImpl extends BaseService<DispatchTaskDto,Dispatc ...@@ -285,6 +285,10 @@ public class DispatchTaskServiceImpl extends BaseService<DispatchTaskDto,Dispatc
set(AlertFormValue::getFieldValue,DateUtils.date2LongStr(now)). set(AlertFormValue::getFieldValue,DateUtils.date2LongStr(now)).
eq(AlertFormValue::getFieldCode,"save_time"). eq(AlertFormValue::getFieldCode,"save_time").
eq(AlertFormValue::getAlertCalledId,task.getPaperId())); eq(AlertFormValue::getAlertCalledId,task.getPaperId()));
// 更新救出冗余字段
dispatchPaperServiceImpl.update(new LambdaUpdateWrapper<DispatchPaper>().eq(DispatchPaper::getSequenceNbr,task.getPaperId())
.set(DispatchPaper::getSaveTime,now)
);
// 如果存在救援过程表更新救援过程表中信息 // 如果存在救援过程表更新救援过程表中信息
if(task.getIsSaveTask()) { if(task.getIsSaveTask()) {
rescueProcessServiceImpl.update(new LambdaUpdateWrapper<RescueProcess>(). rescueProcessServiceImpl.update(new LambdaUpdateWrapper<RescueProcess>().
...@@ -457,12 +461,7 @@ public class DispatchTaskServiceImpl extends BaseService<DispatchTaskDto,Dispatc ...@@ -457,12 +461,7 @@ public class DispatchTaskServiceImpl extends BaseService<DispatchTaskDto,Dispatc
paperList = iAlertFormValueService.list(queryWrapper); paperList = iAlertFormValueService.list(queryWrapper);
paperList.stream().forEach(t -> { paperList.stream().forEach(t -> {
String value = t.getFieldValue(); String value = t.getFieldValue();
if("save_time".equals(t.getFieldCode())) { if("error_result".equals(t.getFieldCode())) {
// 救援完成时间
if(StringUtils.isNotBlank(value)) {
temp.setSaveTime(DateUtils.longStr2Date(value));
}
} else if("error_result".equals(t.getFieldCode())) {
// 故障原因 // 故障原因
temp.setErrorResult(value); temp.setErrorResult(value);
} else if("fix_result".equals(t.getFieldCode())) { } else if("fix_result".equals(t.getFieldCode())) {
...@@ -487,12 +486,7 @@ public class DispatchTaskServiceImpl extends BaseService<DispatchTaskDto,Dispatc ...@@ -487,12 +486,7 @@ public class DispatchTaskServiceImpl extends BaseService<DispatchTaskDto,Dispatc
paperList = iAlertFormValueService.list(queryWrapper); paperList = iAlertFormValueService.list(queryWrapper);
paperList.stream().forEach(t -> { paperList.stream().forEach(t -> {
String value = t.getFieldValue(); String value = t.getFieldValue();
if("save_time".equals(t.getFieldCode())) { if("error_result".equals(t.getFieldCode())) {
// 救援完成时间
if(StringUtils.isNotBlank(value)) {
temp.setSaveTime(DateUtils.longStr2Date(value));
}
} else if("error_result".equals(t.getFieldCode())) {
// 故障原因 // 故障原因
temp.setErrorResult(value); temp.setErrorResult(value);
} else if("fix_result".equals(t.getFieldCode())) { } else if("fix_result".equals(t.getFieldCode())) {
...@@ -676,12 +670,7 @@ public class DispatchTaskServiceImpl extends BaseService<DispatchTaskDto,Dispatc ...@@ -676,12 +670,7 @@ public class DispatchTaskServiceImpl extends BaseService<DispatchTaskDto,Dispatc
paperList = iAlertFormValueService.list(queryWrapper); paperList = iAlertFormValueService.list(queryWrapper);
paperList.stream().forEach(t -> { paperList.stream().forEach(t -> {
String value = t.getFieldValue(); String value = t.getFieldValue();
if("save_time".equals(t.getFieldCode())) { if("error_result".equals(t.getFieldCode())) {
// 救援完成时间
if(StringUtils.isNotBlank(value)) {
temp.setSaveTime(DateUtils.longStr2Date(value));
}
} else if("error_result".equals(t.getFieldCode())) {
// 故障原因 // 故障原因
temp.setErrorResult(value); temp.setErrorResult(value);
} else if("fix_result".equals(t.getFieldCode())) { } else if("fix_result".equals(t.getFieldCode())) {
...@@ -706,12 +695,7 @@ public class DispatchTaskServiceImpl extends BaseService<DispatchTaskDto,Dispatc ...@@ -706,12 +695,7 @@ public class DispatchTaskServiceImpl extends BaseService<DispatchTaskDto,Dispatc
paperList = iAlertFormValueService.list(queryWrapper); paperList = iAlertFormValueService.list(queryWrapper);
paperList.stream().forEach(t -> { paperList.stream().forEach(t -> {
String value = t.getFieldValue(); String value = t.getFieldValue();
if("save_time".equals(t.getFieldCode())) { if("error_result".equals(t.getFieldCode())) {
// 救援完成时间
if(StringUtils.isNotBlank(value)) {
temp.setSaveTime(DateUtils.longStr2Date(value));
}
} else if("error_result".equals(t.getFieldCode())) {
// 故障原因 // 故障原因
temp.setErrorResult(value); temp.setErrorResult(value);
} else if("fix_result".equals(t.getFieldCode())) { } else if("fix_result".equals(t.getFieldCode())) {
......
...@@ -211,6 +211,7 @@ public class RescueProcessServiceImpl extends BaseService<RescueProcessDto,Rescu ...@@ -211,6 +211,7 @@ public class RescueProcessServiceImpl extends BaseService<RescueProcessDto,Rescu
throw new BadRequest("派遣单信息未找到"); throw new BadRequest("派遣单信息未找到");
} }
DispatchPaper dispatchPaper = dispatchPaperDto.getDispatchPaper(); DispatchPaper dispatchPaper = dispatchPaperDto.getDispatchPaper();
dispatchPaper.setArriveTime(rescueProcessDto.getArriveTime());
dispatchPaper.setArriveFeedbackCode(rescueProcessDto.getArriveFeedbackCode()); dispatchPaper.setArriveFeedbackCode(rescueProcessDto.getArriveFeedbackCode());
dispatchPaper.setArriveFeedbackType(rescueProcessDto.getArriveFeedbackType()); dispatchPaper.setArriveFeedbackType(rescueProcessDto.getArriveFeedbackType());
// 更新派遣单 // 更新派遣单
...@@ -239,6 +240,10 @@ public class RescueProcessServiceImpl extends BaseService<RescueProcessDto,Rescu ...@@ -239,6 +240,10 @@ public class RescueProcessServiceImpl extends BaseService<RescueProcessDto,Rescu
if(taskId == null) { if(taskId == null) {
throw new BadRequest("派遣任务单信息未找到"); throw new BadRequest("派遣任务单信息未找到");
} }
DispatchPaper dispatchPaper = dispatchPaperDto.getDispatchPaper();
dispatchPaper.setSaveTime(rescueProcessDto.getRescueTime());
// 更新派遣单
dispatchPaperServiceImpl.updateById(dispatchPaper);
repairConsultServiceImpl.saveRepairConsultByAlertIdType(rescueProcessDto.getAlertId(),"JC",taskId,sendUser); //保存接警日志 repairConsultServiceImpl.saveRepairConsultByAlertIdType(rescueProcessDto.getAlertId(),"JC",taskId,sendUser); //保存接警日志
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment