Commit d302a6af authored by chenhao's avatar chenhao

Merge branch 'developer' of http://172.16.10.76/moa/amos-boot-biz into developer

parents a940b67b d5da3cb6
...@@ -32,7 +32,7 @@ public class FailureMaintainDto extends BaseDto { ...@@ -32,7 +32,7 @@ public class FailureMaintainDto extends BaseDto {
private Long maintainPhone; private Long maintainPhone;
@ApiModelProperty(value = "所属部门ID") @ApiModelProperty(value = "所属部门ID")
private String bizId; private Long bizId;
@ApiModelProperty(value = "所属部门") @ApiModelProperty(value = "所属部门")
private String department; private String department;
...@@ -52,7 +52,7 @@ public class FailureMaintainDto extends BaseDto { ...@@ -52,7 +52,7 @@ public class FailureMaintainDto extends BaseDto {
@ApiModelProperty(value = "附件") @ApiModelProperty(value = "附件")
private List<SourceFile> attachment; private List<SourceFile> attachment;
@ApiModelProperty(value = "审核结果条件判断,0同意,1拒绝,2驳回") @ApiModelProperty(value = "审核结果条件判断,0完成,1保存")
private String condition; private String condition;
} }
...@@ -44,4 +44,7 @@ public class FailureRepairlogDto extends BaseDto { ...@@ -44,4 +44,7 @@ public class FailureRepairlogDto extends BaseDto {
@ApiModelProperty(value = "设备故障报修主表ID") @ApiModelProperty(value = "设备故障报修主表ID")
private Long faultId; private Long faultId;
@ApiModelProperty(value = "操作人中文名称")
private String processAuditorCid;
} }
...@@ -45,7 +45,7 @@ public class FailureMaintain extends BaseEntity { ...@@ -45,7 +45,7 @@ public class FailureMaintain extends BaseEntity {
* 所属部门ID * 所属部门ID
*/ */
@TableField("biz_id") @TableField("biz_id")
private String bizId; private Long bizId;
/** /**
* 所属部门 * 所属部门
......
...@@ -66,4 +66,10 @@ public class FailureRepairlog extends BaseEntity { ...@@ -66,4 +66,10 @@ public class FailureRepairlog extends BaseEntity {
@TableField("fault_id") @TableField("fault_id")
private Long faultId; private Long faultId;
/**
* 操作人中文名称
*/
@TableField("process_auditor_name")
private String processAuditorCid;
} }
...@@ -14,5 +14,6 @@ public class Constants { ...@@ -14,5 +14,6 @@ public class Constants {
currentStatusNameMap.put(3,"待验收"); currentStatusNameMap.put(3,"待验收");
currentStatusNameMap.put(4,"已拒绝"); currentStatusNameMap.put(4,"已拒绝");
currentStatusNameMap.put(5,"已完结"); currentStatusNameMap.put(5,"已完结");
currentStatusNameMap.put(6,"维修中");
} }
} }
...@@ -39,8 +39,7 @@ public class FailureMaintainController extends BaseController { ...@@ -39,8 +39,7 @@ public class FailureMaintainController extends BaseController {
@PostMapping(value = "/save") @PostMapping(value = "/save")
@ApiOperation(httpMethod = "POST", value = "新增", notes = "新增") @ApiOperation(httpMethod = "POST", value = "新增", notes = "新增")
public ResponseModel<Object> save(@RequestBody FailureMaintainDto model) { public ResponseModel<Object> save(@RequestBody FailureMaintainDto model) {
failureMaintainServiceImpl.savemodel(model,getSelectedOrgInfo()); return ResponseHelper.buildResponse(failureMaintainServiceImpl.savemodel(model,getSelectedOrgInfo()));
return ResponseHelper.buildResponse(model);
} }
/** /**
......
...@@ -2,6 +2,7 @@ package com.yeejoin.amos.boot.module.common.biz.service.impl; ...@@ -2,6 +2,7 @@ package com.yeejoin.amos.boot.module.common.biz.service.impl;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
import java.util.Map;
import org.apache.commons.lang3.ObjectUtils; import org.apache.commons.lang3.ObjectUtils;
import org.slf4j.Logger; import org.slf4j.Logger;
...@@ -25,6 +26,9 @@ import com.yeejoin.amos.boot.module.common.api.enums.FailureStatuEnum; ...@@ -25,6 +26,9 @@ import com.yeejoin.amos.boot.module.common.api.enums.FailureStatuEnum;
import com.yeejoin.amos.boot.module.common.api.mapper.FailureAuditMapper; import com.yeejoin.amos.boot.module.common.api.mapper.FailureAuditMapper;
import com.yeejoin.amos.boot.module.common.api.service.IFailureAuditService; import com.yeejoin.amos.boot.module.common.api.service.IFailureAuditService;
import static com.yeejoin.amos.boot.module.common.biz.service.impl.FailureDetailsServiceImpl.EMERGENCY_COMMAND;
import static com.yeejoin.amos.boot.module.common.biz.service.impl.FailureDetailsServiceImpl.PROCESS_NAME;
/** /**
* 服务实现类 * 服务实现类
* *
...@@ -60,22 +64,25 @@ public class FailureAuditServiceImpl extends BaseService<FailureAuditDto, Failur ...@@ -60,22 +64,25 @@ public class FailureAuditServiceImpl extends BaseService<FailureAuditDto, Failur
* 发起审核 * 发起审核
*/ */
@Transactional @Transactional
public Object savemodel(FailureAuditDto model, ReginParams userInfo) throws Exception { public Object savemodel(FailureAuditDto model, ReginParams userInfo) {
int condition = Integer.parseInt(model.getCondition()); int condition = Integer.parseInt(model.getCondition());
model.setAuditTime(new Date()); model.setAuditTime(new Date());
model.setAuditDepartmentId(userInfo.getDepartment().getSequenceNbr()); model.setAuditDepartmentId(userInfo.getDepartment().getSequenceNbr());
model.setAuditor(userInfo.getRole().getRoleName()); model.setAuditor(userInfo.getUserModel().getUserName());
model.setAuditDepartment(userInfo.getDepartment().getDepartmentName()); model.setAuditDepartment(userInfo.getDepartment().getDepartmentName());
FailureDetailsDto failureDetailsDto = failureDetailsService.queryBySeq(model.getFaultId());
try { try {
//根据审核的结果进行业务操作 //根据审核的结果进行业务操作
if (condition == AuditResultEnum.AGREE.getCode()) { if (condition == AuditResultEnum.AGREE.getCode() && userInfo.getDepartment().getSequenceNbr().equals(failureDetailsDto.getBizCode())) {
updateStatus(model, FailureStatuEnum.WAITING_MAINTAIN, userInfo,condition); updateStatus(model, FailureStatuEnum.WAITING_AUDIT, userInfo,condition);
} else if (condition == (AuditResultEnum.REFUSE.getCode())) { } else if (condition == (AuditResultEnum.REFUSE.getCode())) {
updateStatus(model, FailureStatuEnum.REFUSE, userInfo,condition); updateStatus(model, FailureStatuEnum.REFUSE, userInfo,condition);
} else if (condition == (AuditResultEnum.SEND_BACK.getCode())) { } else if (condition == (AuditResultEnum.SEND_BACK.getCode())) {
updateStatus(model, FailureStatuEnum.WAITING_SUBMIT, userInfo,condition); updateStatus(model, FailureStatuEnum.WAITING_SUBMIT, userInfo,condition);
} else if (condition == AuditResultEnum.AGREE.getCode() ) {
updateStatus(model, FailureStatuEnum.WAITING_MAINTAIN, userInfo,condition);
} }
FailureAuditDto withModel = this.createWithModel(model); FailureAuditDto withModel = this.createWithModel(model);
...@@ -99,15 +106,16 @@ public class FailureAuditServiceImpl extends BaseService<FailureAuditDto, Failur ...@@ -99,15 +106,16 @@ public class FailureAuditServiceImpl extends BaseService<FailureAuditDto, Failur
FailureDetailsDto failureDetailsDto = failureDetailsService.queryBySeq(model.getFaultId()); FailureDetailsDto failureDetailsDto = failureDetailsService.queryBySeq(model.getFaultId());
//当前角色部门id为应急指挥科的时候 并且同意时 不修改主表状态 依然为待审核 //当前角色部门id为应急指挥科的时候 并且同意时 不修改主表状态 依然为待审核
//当前角色部门id为维修部门的时候 修改状态 //当前角色部门id为维修部门的时候 修改状态
if (userInfo.getDepartment().getSequenceNbr() == failureDetailsDto.getBizCode()
&& condition == AuditResultEnum.AGREE.getCode()){ /*Map<String, Object> stringObjectMap = failureDetailsService.checkExcuteTaskAuthMap(failureDetailsDto.getSequenceNbr(), userInfo);
String name = stringObjectMap.get("name").toString();
if (name.contains(EMERGENCY_COMMAND)) {
failureDetailsDto.setCurrentStatus(failureDetailsDto.getCurrentStatus()); failureDetailsDto.setCurrentStatus(failureDetailsDto.getCurrentStatus());
}else if (userInfo.getDepartment().getSequenceNbr() != failureDetailsDto.getBizCode() }*/
) { failureDetailsDto.setCurrentStatus(status.getCode());
failureDetailsDto.setCurrentStatus(status.getCode());
}
failureDetailsDto.setSequenceNbr(model.getFaultId()); failureDetailsDto.setSequenceNbr(model.getFaultId());
failureDetailsService.updateWithModel(failureDetailsDto); FailureDetailsDto failureDetailsDtos = failureDetailsService.updateWithModel(failureDetailsDto);
System.out.println(failureDetailsDtos);
String conditionText; String conditionText;
boolean result = failureDetailsService.checkExcuteTaskAuth(failureDetailsDto.getSequenceNbr(), userInfo); boolean result = failureDetailsService.checkExcuteTaskAuth(failureDetailsDto.getSequenceNbr(), userInfo);
...@@ -118,18 +126,17 @@ public class FailureAuditServiceImpl extends BaseService<FailureAuditDto, Failur ...@@ -118,18 +126,17 @@ public class FailureAuditServiceImpl extends BaseService<FailureAuditDto, Failur
String processDepartment = model.getAuditDepartment(); String processDepartment = model.getAuditDepartment();
String processAuditor = model.getAuditor(); String processAuditor = model.getAuditor();
Integer processAuditorId =Integer.parseInt(userInfo.getUserModel().getUserId()) ; Integer processAuditorId =Integer.parseInt(userInfo.getUserModel().getUserId()) ;
String processAuditorCid = userInfo.getUserModel().getUserName();
Long auditDepartmentId = (userInfo.getDepartment().getSequenceNbr()); Long auditDepartmentId = (userInfo.getDepartment().getSequenceNbr());
if (condition == AuditResultEnum.AGREE.getCode() ) { if (condition == AuditResultEnum.AGREE.getCode() ) {
conditionText = AuditResultEnum.AGREE.getName(); conditionText = AuditResultEnum.AGREE.getName();
repairlog(faultId,processAuditor,processAuditorId,auditDepartmentId,processTime,processDepartment,conditionText); repairlog(faultId,processAuditor,processAuditorId,auditDepartmentId,processTime,processDepartment,conditionText,processAuditorCid);
} } else if (condition == AuditResultEnum.SEND_BACK.getCode()) {
if (condition == AuditResultEnum.SEND_BACK.getCode()) {
conditionText = AuditResultEnum.SEND_BACK.getName(); conditionText = AuditResultEnum.SEND_BACK.getName();
repairlog(faultId,processAuditor,processAuditorId,auditDepartmentId,processTime,processDepartment,conditionText); repairlog(faultId,processAuditor,processAuditorId,auditDepartmentId,processTime,processDepartment,conditionText,processAuditorCid);
} } else if (condition == AuditResultEnum.REFUSE.getCode()){
if (condition == AuditResultEnum.REFUSE.getCode()){
conditionText = AuditResultEnum.REFUSE.getName(); conditionText = AuditResultEnum.REFUSE.getName();
repairlog(faultId,processAuditor,processAuditorId,auditDepartmentId,processTime,processDepartment,conditionText); repairlog(faultId,processAuditor,processAuditorId,auditDepartmentId,processTime,processDepartment,conditionText,processAuditorCid);
} }
failureDetailsService.excuteTask(failureDetailsDto.getProcessId(), userInfo,condition+""); failureDetailsService.excuteTask(failureDetailsDto.getProcessId(), userInfo,condition+"");
return true; return true;
...@@ -141,7 +148,8 @@ public class FailureAuditServiceImpl extends BaseService<FailureAuditDto, Failur ...@@ -141,7 +148,8 @@ public class FailureAuditServiceImpl extends BaseService<FailureAuditDto, Failur
* 添加报修日志 * 添加报修日志
*/ */
@Transactional @Transactional
public void repairlog(Long faultId, String processAuditor,Integer processAuditorId,Long departmentId,Date processTime, String processDepartment, String processResult) { public Boolean repairlog(Long faultId, String processAuditor,Integer processAuditorId,Long departmentId,Date processTime,
String processDepartment, String processResult,String processAuditorCid) {
FailureRepairlogDto failureRepairlogDto = new FailureRepairlogDto(); FailureRepairlogDto failureRepairlogDto = new FailureRepairlogDto();
failureRepairlogDto.setFaultId(faultId); failureRepairlogDto.setFaultId(faultId);
failureRepairlogDto.setProcessAuditor(processAuditor); failureRepairlogDto.setProcessAuditor(processAuditor);
...@@ -150,7 +158,12 @@ public class FailureAuditServiceImpl extends BaseService<FailureAuditDto, Failur ...@@ -150,7 +158,12 @@ public class FailureAuditServiceImpl extends BaseService<FailureAuditDto, Failur
failureRepairlogDto.setProcessTime(processTime); failureRepairlogDto.setProcessTime(processTime);
failureRepairlogDto.setProcessDepartment(processDepartment); failureRepairlogDto.setProcessDepartment(processDepartment);
failureRepairlogDto.setProcessResult(processResult); failureRepairlogDto.setProcessResult(processResult);
failureRepairlogDto.setProcessAuditorCid(processAuditorCid);
failureRepairlogService.createWithModel(failureRepairlogDto); failureRepairlogService.createWithModel(failureRepairlogDto);
if (ObjectUtils.isNotEmpty(failureRepairlogDto)){
return true;
}
return false;
} }
/** /**
......
...@@ -136,6 +136,7 @@ public class FailureDetailsServiceImpl extends BaseService<FailureDetailsDto, Fa ...@@ -136,6 +136,7 @@ public class FailureDetailsServiceImpl extends BaseService<FailureDetailsDto, Fa
return baseMapper.selectPage(failureDetailsPage, wrapper); return baseMapper.selectPage(failureDetailsPage, wrapper);
} }
/** /**
* 列表查询 示例 * 列表查询 示例
*/ */
...@@ -181,6 +182,7 @@ public class FailureDetailsServiceImpl extends BaseService<FailureDetailsDto, Fa ...@@ -181,6 +182,7 @@ public class FailureDetailsServiceImpl extends BaseService<FailureDetailsDto, Fa
} }
/** /**
* 查询任务状态数量 * 查询任务状态数量
*/ */
...@@ -201,7 +203,7 @@ public class FailureDetailsServiceImpl extends BaseService<FailureDetailsDto, Fa ...@@ -201,7 +203,7 @@ public class FailureDetailsServiceImpl extends BaseService<FailureDetailsDto, Fa
int inMaintenance = 0; int inMaintenance = 0;
List<FailureStatusCountDto> list = new ArrayList<>(); List<FailureStatusCountDto> list = new ArrayList<>();
// String[] statusName = new String[]{"待审核", "待提交", "待维修", "待验收", "已拒绝", "已完结"}; // String[] statusName = new String[]{"待审核", "待提交", "待维修", "待验收", "已拒绝", "已完结"};
List<String> statusName = new ArrayList<>(); List<String> statusName = new ArrayList<>();
Collections.addAll(statusName, FailureStatuEnum.WAITING_AUDIT.getName(), Collections.addAll(statusName, FailureStatuEnum.WAITING_AUDIT.getName(),
FailureStatuEnum.WAITING_SUBMIT.getName(), FailureStatuEnum.WAITING_MAINTAIN.getName(), FailureStatuEnum.WAITING_SUBMIT.getName(), FailureStatuEnum.WAITING_MAINTAIN.getName(),
...@@ -288,9 +290,9 @@ public class FailureDetailsServiceImpl extends BaseService<FailureDetailsDto, Fa ...@@ -288,9 +290,9 @@ public class FailureDetailsServiceImpl extends BaseService<FailureDetailsDto, Fa
String processDepartment = userInfo.getDepartment().getDepartmentName(); String processDepartment = userInfo.getDepartment().getDepartmentName();
Long departmentId = userInfo.getDepartment().getSequenceNbr(); Long departmentId = userInfo.getDepartment().getSequenceNbr();
Date processTime = model.getSubmissionTime(); Date processTime = model.getSubmissionTime();
repairlog(faultId, processAuditor, processAuditorId, departmentId, processTime, processDepartment, String processAuditorCid = userInfo.getUserModel().getUserName();
processResult); repairlog(faultId, processAuditor,processAuditorId,departmentId, processTime, processDepartment, processResult,processAuditorCid);
} catch (Exception e) { }catch (Exception e){
e.printStackTrace(); e.printStackTrace();
logger.info("添加流程日志到数据库失败"); logger.info("添加流程日志到数据库失败");
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
...@@ -319,8 +321,8 @@ public class FailureDetailsServiceImpl extends BaseService<FailureDetailsDto, Fa ...@@ -319,8 +321,8 @@ public class FailureDetailsServiceImpl extends BaseService<FailureDetailsDto, Fa
* 添加报修日志 * 添加报修日志
*/ */
@Transactional @Transactional
public Boolean repairlog(Long faultId, String processAuditor, Integer processAuditorId, Long departmentId, public Boolean repairlog(Long faultId, String processAuditor,Integer processAuditorId,Long departmentId,Date processTime,
Date processTime, String processDepartment, String processResult) { String processDepartment, String processResult,String processAuditorCid) {
FailureRepairlogDto failureRepairlogDto = new FailureRepairlogDto(); FailureRepairlogDto failureRepairlogDto = new FailureRepairlogDto();
failureRepairlogDto.setFaultId(faultId); failureRepairlogDto.setFaultId(faultId);
failureRepairlogDto.setProcessAuditor(processAuditor); failureRepairlogDto.setProcessAuditor(processAuditor);
...@@ -329,8 +331,9 @@ public class FailureDetailsServiceImpl extends BaseService<FailureDetailsDto, Fa ...@@ -329,8 +331,9 @@ public class FailureDetailsServiceImpl extends BaseService<FailureDetailsDto, Fa
failureRepairlogDto.setProcessTime(processTime); failureRepairlogDto.setProcessTime(processTime);
failureRepairlogDto.setProcessDepartment(processDepartment); failureRepairlogDto.setProcessDepartment(processDepartment);
failureRepairlogDto.setProcessResult(processResult); failureRepairlogDto.setProcessResult(processResult);
FailureRepairlogDto RepairlogModel = failureRepairlogService.createWithModel(failureRepairlogDto); failureRepairlogDto.setProcessAuditorCid(processAuditorCid);
if (ObjectUtils.isNotEmpty(RepairlogModel)) { FailureRepairlogDto repairlogModel = failureRepairlogService.createWithModel(failureRepairlogDto);
if (ObjectUtils.isNotEmpty(repairlogModel)){
return true; return true;
} }
return false; return false;
...@@ -564,7 +567,7 @@ public class FailureDetailsServiceImpl extends BaseService<FailureDetailsDto, Fa ...@@ -564,7 +567,7 @@ public class FailureDetailsServiceImpl extends BaseService<FailureDetailsDto, Fa
} }
public static String buildOrderNo() { public static String buildOrderNo() {
SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss"); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String newDate = sdf.format(new Date()); String newDate = sdf.format(new Date());
String result = ""; String result = "";
Random random = new Random(); Random random = new Random();
...@@ -576,7 +579,7 @@ public class FailureDetailsServiceImpl extends BaseService<FailureDetailsDto, Fa ...@@ -576,7 +579,7 @@ public class FailureDetailsServiceImpl extends BaseService<FailureDetailsDto, Fa
/** /**
* 获取当前登录人能够操作的任务执行Button类型 * 获取当前登录人能够操作的任务执行Button类型
* *
* @param sequenceNbr * @param sequenceNbr
* @param userInfo * @param userInfo
* @return * @return
......
...@@ -39,9 +39,13 @@ public class FailureMaintainServiceImpl extends BaseService<FailureMaintainDto,F ...@@ -39,9 +39,13 @@ public class FailureMaintainServiceImpl extends BaseService<FailureMaintainDto,F
@Autowired @Autowired
FailureRepairlogServiceImpl failureRepairlogService; FailureRepairlogServiceImpl failureRepairlogService;
private static String RECORE_TYPE = "维修记录";
private final Logger logger = LoggerFactory.getLogger(FailureMaintainServiceImpl.class); private final Logger logger = LoggerFactory.getLogger(FailureMaintainServiceImpl.class);
private static String[] MAINTENANCE_STATUS= {"维修完成","维修中"}; private static String[] MAINTENANCE_STATUS= {"维修完成","维修中"};
private static int MAINTENANCE_COMPLETE= 0;
private static int MAINTENANCE_ADD= 1;
private static String[] PROCESS_RESULT = {"验证通过","验证未通过"}; private static String[] PROCESS_RESULT = {"验证通过","验证未通过"};
/** /**
...@@ -62,35 +66,48 @@ public class FailureMaintainServiceImpl extends BaseService<FailureMaintainDto,F ...@@ -62,35 +66,48 @@ public class FailureMaintainServiceImpl extends BaseService<FailureMaintainDto,F
* 添加维修记录 * 添加维修记录
*/ */
public Object savemodel(FailureMaintainDto failureMaintainDto,ReginParams userInfo) { public Object savemodel(FailureMaintainDto failureMaintainDto,ReginParams userInfo) {
String condition = failureMaintainDto.getCondition();
int conditionStatus = Integer.parseInt(condition);
if (conditionStatus == MAINTENANCE_ADD){
boolean result = failureDetailsService.checkExcuteTaskAuth(failureMaintainDto.getFaultId(), userInfo);
if (!result){
return false;
}
try {
failureMaintainDto.setMaintainMan(userInfo.getUserModel().getUserName());
failureMaintainDto.setMaintainTime(new Date());
failureMaintainDto.setDepartment(userInfo.getDepartment().getDepartmentName());
failureMaintainDto.setBizId(userInfo.getDepartment().getSequenceNbr());
failureMaintainDto.setRecoreType(RECORE_TYPE);
this.createWithModel(failureMaintainDto);
//添加完成后修改保修单状态为待验收
FailureDetailsDto failureDetailsDto = failureDetailsService.queryBySeq(failureMaintainDto.getFaultId());
failureDetailsDto.setCurrentStatus(FailureStatuEnum.IN_MAINTENANCE.getCode());
failureDetailsService.updateWithModel(failureDetailsDto);
failureDetailsService.checkExcuteTaskAuthMap(failureMaintainDto.getFaultId(),userInfo); //添加报修日志
String processResult = MAINTENANCE_STATUS[1];//维修中
try { Integer processAuditorId = Integer.parseInt(failureMaintainDto.getRecUserId());
this.createWithModel(failureMaintainDto); String processAuditorCid = userInfo.getUserModel().getUserName();
//添加完成后修改保修单状态为待验收 repairlog(failureMaintainDto.getFaultId(),failureMaintainDto.getMaintainMan(),processAuditorId,userInfo.getDepartment().getSequenceNbr(),failureMaintainDto.getMaintainTime(),
FailureDetailsDto failureDetailsDto = failureDetailsService.queryBySeq(failureMaintainDto.getFaultId()); failureMaintainDto.getDepartment(),processResult,processAuditorCid);
failureDetailsDto.setCurrentStatus(FailureStatuEnum.WAITING_ACCEPTANCE.getCode());
failureDetailsService.updateWithModel(failureDetailsDto); if (ObjectUtils.isNotEmpty(failureMaintainDto.getAttachment())){
sourceFileServiceImpl.saveSourceFile(failureMaintainDto.getSequenceNbr(),failureMaintainDto.getAttachment());
//添加报修日志 }
String processResult = MAINTENANCE_STATUS[1];//维修中 failureDetailsService.excuteTask(failureMaintainDto.getFaultId(), userInfo, condition);
Integer processAuditorId = Integer.parseInt(failureMaintainDto.getRecUserId()); }catch (Exception e){
repairlog(failureMaintainDto.getFaultId(),failureMaintainDto.getMaintainMan(),processAuditorId,userInfo.getDepartment().getSequenceNbr(),failureMaintainDto.getMaintainTime(), e.printStackTrace();
failureMaintainDto.getDepartment(),processResult); e.printStackTrace();
logger.info("添加故障维修信息到数据库失败");
if (ObjectUtils.isNotEmpty(failureMaintainDto.getAttachment())){ TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
sourceFileServiceImpl.saveSourceFile(failureMaintainDto.getSequenceNbr(),failureMaintainDto.getAttachment()); return false ;
} }
failureDetailsService.excuteTask(failureMaintainDto.getFaultId(), userInfo, null);
}catch (Exception e){ return true;
e.printStackTrace();
e.printStackTrace();
logger.info("添加故障维修信息到数据库失败");
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
return false ;
} }
return true; return this.updateStatus(failureMaintainDto,userInfo);
} }
...@@ -101,26 +118,26 @@ public class FailureMaintainServiceImpl extends BaseService<FailureMaintainDto,F ...@@ -101,26 +118,26 @@ public class FailureMaintainServiceImpl extends BaseService<FailureMaintainDto,F
public Boolean updateStatus(FailureMaintainDto failureMaintainDto,ReginParams userInfo) { public Boolean updateStatus(FailureMaintainDto failureMaintainDto,ReginParams userInfo) {
try { try {
FailureDetailsDto failureDetailsDto = failureDetailsService.queryBySeq(failureMaintainDto.getFaultId()); FailureDetailsDto failureDetailsDto = failureDetailsService.queryBySeq(failureMaintainDto.getFaultId());
failureDetailsDto.setCurrentStatus(FailureStatuEnum.IN_MAINTENANCE.getCode()); failureDetailsDto.setCurrentStatus(FailureStatuEnum.WAITING_ACCEPTANCE.getCode());
this.updateWithModel(failureMaintainDto); this.updateWithModel(failureMaintainDto);
//添加报修日志 //添加报修日志
String processResult = MAINTENANCE_STATUS[0];//维修完成 String processResult = MAINTENANCE_STATUS[0];//维修完成
Integer processAuditorId = Integer.parseInt(failureMaintainDto.getRecUserId()); Integer processAuditorId = Integer.parseInt(failureMaintainDto.getRecUserId());
String processAuditorCid = userInfo.getUserModel().getUserName();
repairlog(failureMaintainDto.getFaultId(),failureMaintainDto.getMaintainMan(),processAuditorId,userInfo.getDepartment().getSequenceNbr(),failureMaintainDto.getMaintainTime(), repairlog(failureMaintainDto.getFaultId(),failureMaintainDto.getMaintainMan(),processAuditorId,userInfo.getDepartment().getSequenceNbr(),failureMaintainDto.getMaintainTime(),
failureMaintainDto.getDepartment(),processResult); failureMaintainDto.getDepartment(),processResult,processAuditorCid);
if (ObjectUtils.isNotEmpty(failureMaintainDto.getAttachment())){ if (ObjectUtils.isNotEmpty(failureMaintainDto.getAttachment())){
sourceFileServiceImpl.saveSourceFile(failureMaintainDto.getSequenceNbr(),failureMaintainDto.getAttachment()); sourceFileServiceImpl.saveSourceFile(failureMaintainDto.getSequenceNbr(),failureMaintainDto.getAttachment());
} }
failureDetailsService.excuteTask(failureMaintainDto.getFaultId(), userInfo, null); failureDetailsService.excuteTask(failureMaintainDto.getFaultId(), userInfo, failureMaintainDto.getCondition());
}catch (Exception e){ }catch (Exception e){
e.printStackTrace(); e.printStackTrace();
logger.info("更新故障验收信息到数据库失败"); logger.info("更新故障验收信息到数据库失败");
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
return false ; return false ;
} }
return true; return true;
} }
...@@ -132,6 +149,7 @@ public class FailureMaintainServiceImpl extends BaseService<FailureMaintainDto,F ...@@ -132,6 +149,7 @@ public class FailureMaintainServiceImpl extends BaseService<FailureMaintainDto,F
boolean result = failureDetailsService.checkExcuteTaskAuth(failureMaintainDto.getFaultId(), userInfo); boolean result = failureDetailsService.checkExcuteTaskAuth(failureMaintainDto.getFaultId(), userInfo);
FailureDetailsDto failureDetailsDto = failureDetailsService.queryBySeq(failureMaintainDto.getFaultId()); FailureDetailsDto failureDetailsDto = failureDetailsService.queryBySeq(failureMaintainDto.getFaultId());
if (result){ if (result){
this.updateWithModel(failureMaintainDto); this.updateWithModel(failureMaintainDto);
//根据status修改状态 //根据status修改状态
String processResult = new String(); String processResult = new String();
...@@ -142,12 +160,12 @@ public class FailureMaintainServiceImpl extends BaseService<FailureMaintainDto,F ...@@ -142,12 +160,12 @@ public class FailureMaintainServiceImpl extends BaseService<FailureMaintainDto,F
failureDetailsService.updateWithModel(failureDetailsDto); failureDetailsService.updateWithModel(failureDetailsDto);
processResult =PROCESS_RESULT[0] ; processResult =PROCESS_RESULT[0] ;
condition= AuditResultEnum.AGREE.getName(); condition= AuditResultEnum.AGREE.getName();
}else if (status == AuditResultEnum.AGREE.getCode() ) {//同意状态为已完结 } else if (status == AuditResultEnum.AGREE.getCode() ) {//同意状态为已完结
failureDetailsDto.setCurrentStatus(failureDetailsDto.getCurrentStatus()); failureDetailsDto.setCurrentStatus(failureDetailsDto.getCurrentStatus());
failureDetailsService.updateWithModel(failureDetailsDto); failureDetailsService.updateWithModel(failureDetailsDto);
processResult =PROCESS_RESULT[0] ; processResult =PROCESS_RESULT[0] ;
condition= AuditResultEnum.AGREE.getName(); condition= AuditResultEnum.AGREE.getName();
} else {//不同意状态为已拒绝 } else {//不同意状态为已拒绝
failureDetailsDto.setCurrentStatus(FailureStatuEnum.REFUSE.getCode()); failureDetailsDto.setCurrentStatus(FailureStatuEnum.REFUSE.getCode());
failureDetailsService.updateWithModel(failureDetailsDto); failureDetailsService.updateWithModel(failureDetailsDto);
processResult = PROCESS_RESULT[1]; processResult = PROCESS_RESULT[1];
...@@ -155,6 +173,7 @@ public class FailureMaintainServiceImpl extends BaseService<FailureMaintainDto,F ...@@ -155,6 +173,7 @@ public class FailureMaintainServiceImpl extends BaseService<FailureMaintainDto,F
} }
//添加报修日志 //添加报修日志
Integer processAuditorId = Integer.parseInt(failureMaintainDto.getRecUserId()); Integer processAuditorId = Integer.parseInt(failureMaintainDto.getRecUserId());
String processAuditorCid = userInfo.getUserModel().getUserName();
repairlog(failureMaintainDto.getFaultId(),failureMaintainDto.getMaintainMan(),processAuditorId, userInfo.getDepartment().getSequenceNbr(),failureMaintainDto.getMaintainTime(), repairlog(failureMaintainDto.getFaultId(),failureMaintainDto.getMaintainMan(),processAuditorId, userInfo.getDepartment().getSequenceNbr(),failureMaintainDto.getMaintainTime(),
failureMaintainDto.getDepartment(),processResult); failureMaintainDto.getDepartment(),processResult);
try { try {
...@@ -163,6 +182,8 @@ public class FailureMaintainServiceImpl extends BaseService<FailureMaintainDto,F ...@@ -163,6 +182,8 @@ public class FailureMaintainServiceImpl extends BaseService<FailureMaintainDto,F
return false; return false;
} }
failureMaintainDto.getDepartment(),processResult,processAuditorCid);
failureDetailsService.excuteTask(failureMaintainDto.getFaultId(), userInfo, condition);
return true; return true;
} }
return false; return false;
...@@ -181,15 +202,22 @@ public class FailureMaintainServiceImpl extends BaseService<FailureMaintainDto,F ...@@ -181,15 +202,22 @@ public class FailureMaintainServiceImpl extends BaseService<FailureMaintainDto,F
/** /**
* 添加报修日志 * 添加报修日志
*/ */
public void repairlog(Long faultId, String processAuditor,Integer processAuditorId,Long departmentId, Date processTime, String processDepartment, String processResult) { @Transactional
public Boolean repairlog(Long faultId, String processAuditor,Integer processAuditorId,Long departmentId,Date processTime,
String processDepartment, String processResult,String processAuditorCid) {
FailureRepairlogDto failureRepairlogDto = new FailureRepairlogDto(); FailureRepairlogDto failureRepairlogDto = new FailureRepairlogDto();
failureRepairlogDto.setFaultId(faultId); failureRepairlogDto.setFaultId(faultId);
failureRepairlogDto.setProcessAuditor(processAuditor); failureRepairlogDto.setProcessAuditor(processAuditor);
failureRepairlogDto.setProcessAuditorId(processAuditorId); failureRepairlogDto.setProcessAuditorId(processAuditorId);
failureRepairlogDto.setProcessDepartmentId(departmentId);
failureRepairlogDto.setProcessTime(processTime); failureRepairlogDto.setProcessTime(processTime);
failureRepairlogDto.setProcessDepartment(processDepartment); failureRepairlogDto.setProcessDepartment(processDepartment);
failureRepairlogDto.setProcessDepartmentId(departmentId);
failureRepairlogDto.setProcessResult(processResult); failureRepairlogDto.setProcessResult(processResult);
failureRepairlogDto.setProcessAuditorCid(processAuditorCid);
failureRepairlogService.createWithModel(failureRepairlogDto); failureRepairlogService.createWithModel(failureRepairlogDto);
if (ObjectUtils.isNotEmpty(failureRepairlogDto)){
return true;
}
return false;
} }
} }
\ No newline at end of file
...@@ -3,6 +3,7 @@ package com.yeejoin.amos.boot.module.common.biz.service.impl; ...@@ -3,6 +3,7 @@ package com.yeejoin.amos.boot.module.common.biz.service.impl;
import java.util.List; import java.util.List;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.typroject.tyboot.core.rdbms.service.BaseService; import org.typroject.tyboot.core.rdbms.service.BaseService;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
...@@ -21,6 +22,7 @@ import com.yeejoin.amos.boot.module.common.api.service.IFailureRepairlogService; ...@@ -21,6 +22,7 @@ import com.yeejoin.amos.boot.module.common.api.service.IFailureRepairlogService;
* @date 2021-08-12 * @date 2021-08-12
*/ */
@Service @Service
@Transactional
public class FailureRepairlogServiceImpl extends BaseService<FailureRepairlogDto,FailureRepairlog,FailureRepairlogMapper> implements IFailureRepairlogService { public class FailureRepairlogServiceImpl extends BaseService<FailureRepairlogDto,FailureRepairlog,FailureRepairlogMapper> implements IFailureRepairlogService {
/** /**
* 分页查询 * 分页查询
......
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