Commit 94f033a8 authored by suhuiguang's avatar suhuiguang

1.维保作废历史维保数据被清空bug

parent 0737ae07
...@@ -14,6 +14,4 @@ import java.util.List; ...@@ -14,6 +14,4 @@ import java.util.List;
public interface JgMaintenanceContractEqMapper extends CustomBaseMapper<JgMaintenanceContractEq> { public interface JgMaintenanceContractEqMapper extends CustomBaseMapper<JgMaintenanceContractEq> {
Boolean deleteForBatch(@Param("ids") List<Long> ids); Boolean deleteForBatch(@Param("ids") List<Long> ids);
void updateIdxBizJgRegisterInfo(@Param("list") List<String> list);
} }
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.yeejoin.amos.boot.module.jg.api.mapper.JgMaintenanceContractEqMapper"> <mapper namespace="com.yeejoin.amos.boot.module.jg.api.mapper.JgMaintenanceContractEqMapper">
<update id="updateIdxBizJgRegisterInfo">
UPDATE idx_biz_jg_maintenance_record_info
SET
"ME_UNIT_NAME" = NULL,
"ME_UNIT_CREDIT_CODE" = NULL,
"ME_MASTER" = NULL,
"ME_MASTER_PHONE" = NULL,
"ME_MASTER_ID" = NULL,
"ME_MASTER1" = NULL,
"ME_MASTER1_PHONE" = NULL,
"ME_MASTER1_ID" = NULL,
"INFORM_START" = NULL,
"INFORM_END" = NULL,
"REPAIR_INFORM" = NULL
WHERE
RECORD IN
<foreach collection="list" item="id" index="index" open="(" separator="," close=")">
#{id}
</foreach>
</update>
<delete id="deleteForBatch"> <delete id="deleteForBatch">
UPDATE amos_tzs_biz.tzs_jg_maintenance_contract_eq tjmce UPDATE amos_tzs_biz.tzs_jg_maintenance_contract_eq tjmce
set tjmce.is_delete = 1 set tjmce.is_delete = 1
......
...@@ -83,10 +83,6 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC ...@@ -83,10 +83,6 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC
@Autowired @Autowired
TzsServiceFeignClient tzsServiceFeignClient; TzsServiceFeignClient tzsServiceFeignClient;
@Autowired @Autowired
RestHighLevelClient restHighLevelClient;
@Autowired
RedisUtils redisUtils;
@Autowired
ICmWorkflowService workflowService; ICmWorkflowService workflowService;
@Autowired @Autowired
CommonServiceImpl commonService; CommonServiceImpl commonService;
...@@ -111,9 +107,6 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC ...@@ -111,9 +107,6 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC
@Autowired @Autowired
private ICmWorkflowService iCmWorkflowService; private ICmWorkflowService iCmWorkflowService;
@Autowired @Autowired
IIdxBizJgUseInfoService useInfoService;
@Autowired
EventPublisher eventPublisher; EventPublisher eventPublisher;
/** /**
...@@ -724,6 +717,8 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC ...@@ -724,6 +717,8 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC
info.setInformStart(ObjectUtils.isEmpty(jgMaintenanceContract.getInformStart()) ? null : jgMaintenanceContract.getInformStart()); info.setInformStart(ObjectUtils.isEmpty(jgMaintenanceContract.getInformStart()) ? null : jgMaintenanceContract.getInformStart());
info.setInformEnd(ObjectUtils.isEmpty(jgMaintenanceContract.getInformEnd()) ? null : jgMaintenanceContract.getInformEnd()); info.setInformEnd(ObjectUtils.isEmpty(jgMaintenanceContract.getInformEnd()) ? null : jgMaintenanceContract.getInformEnd());
info.setRepairInform(ObjectUtils.isEmpty(jgMaintenanceContract.getMaintenanceContract()) ? null : jgMaintenanceContract.getMaintenanceContract()); info.setRepairInform(ObjectUtils.isEmpty(jgMaintenanceContract.getMaintenanceContract()) ? null : jgMaintenanceContract.getMaintenanceContract());
// 记录创建业务的id,在维保备案作废时,将对应的维保记录删除
info.setSourceId(id + "");
maintenanceRecordInfoList.add(info); maintenanceRecordInfoList.add(info);
}); });
...@@ -896,27 +891,14 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC ...@@ -896,27 +891,14 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC
queryWrapper.eq(JgMaintenanceContractEq::getEquipTransferId, maintenanceContract.getSequenceNbr()); queryWrapper.eq(JgMaintenanceContractEq::getEquipTransferId, maintenanceContract.getSequenceNbr());
List<JgMaintenanceContractEq> equipmentLists = maintenanceContractEqMapper.selectList(queryWrapper); List<JgMaintenanceContractEq> equipmentLists = maintenanceContractEqMapper.selectList(queryWrapper);
if (!CollectionUtils.isEmpty(equipmentLists)) { if (!CollectionUtils.isEmpty(equipmentLists)) {
List<String> list = equipmentLists.stream().filter(t -> t.getEquId() != null).map(JgMaintenanceContractEq::getEquId).collect(Collectors.toList()); // 删除在审批完成时写入的设备维保记录
maintenanceContractEqMapper.updateIdxBizJgRegisterInfo(list); idxBizJgMaintenanceRecordInfoService.remove(new LambdaQueryWrapper<IdxBizJgMaintenanceRecordInfo>().eq(IdxBizJgMaintenanceRecordInfo::getSourceId, maintenanceContract.getSequenceNbr()));
// 删除批量业务ID信息 // 删除批量业务ID信息
List<String> equipTransferIds = equipmentLists.stream() List<String> equipTransferIds = Collections.singletonList(maintenanceContract.getSequenceNbr().toString());
.map(JgMaintenanceContractEq::getEquipTransferId)
.filter(Objects::nonNull)
.collect(Collectors.toList());
if (!equipTransferIds.isEmpty()) {
jgResumeInfoService.deleteBatchByBusinessId(equipTransferIds); jgResumeInfoService.deleteBatchByBusinessId(equipTransferIds);
}
jgResumeInfoService.deleteBatchByBusinessId(equipmentLists.stream().filter(t -> t.getEquipTransferId() != null).map(JgMaintenanceContractEq::getEquId).collect(Collectors.toList())); jgResumeInfoService.deleteBatchByBusinessId(equipmentLists.stream().filter(t -> t.getEquipTransferId() != null).map(JgMaintenanceContractEq::getEquId).collect(Collectors.toList()));
} }
} }
// private void delRepeatUseEquipData(JgMaintenanceContract maintenanceContract) {
// LambdaQueryWrapper<JgMaintenanceContractEq> queryWrapper = new LambdaQueryWrapper<>();
// queryWrapper.eq(JgMaintenanceContractEq::getEquipTransferId, maintenanceContract.getSequenceNbr());
// List<JgMaintenanceContractEq> maintenanceContractEq = maintenanceContractEqMapper.selectList(queryWrapper);
// for (JgMaintenanceContractEq jgMaintenanceContractEq : maintenanceContractEq) {
// EquipUsedCheckStrategyContext.getUsedStrategy("maintenanceContract").delDataForCheckEquipRepeatUsed(Collections.singletonList(jgMaintenanceContractEq.getEquId()), maintenanceContract.getReceiveOrgCode());
// }
// }
private void finishedTask(JgMaintenanceContract maintenanceContract) { private void finishedTask(JgMaintenanceContract maintenanceContract) {
HashMap<String, Object> taskMap = new HashMap<>(); HashMap<String, Object> taskMap = new HashMap<>();
......
...@@ -689,10 +689,7 @@ public class JgScrapCancelServiceImpl extends BaseService<JgScrapCancelDto, JgSc ...@@ -689,10 +689,7 @@ public class JgScrapCancelServiceImpl extends BaseService<JgScrapCancelDto, JgSc
taskV2Model.setFlowStatus(this.getTaskStatusByName(jgScrapCancelDto.getAuditStatus())); taskV2Model.setFlowStatus(this.getTaskStatusByName(jgScrapCancelDto.getAuditStatus()));
taskV2Model.setFlowStatusLabel(jgScrapCancelDto.getAuditStatus()); taskV2Model.setFlowStatusLabel(jgScrapCancelDto.getAuditStatus());
taskV2Model.setTaskType(businessTypeJudgment(jgScrapCancelDto.getCancelType()).getCode()); taskV2Model.setTaskType(businessTypeJudgment(jgScrapCancelDto.getCancelType()).getCode());
// taskV2Model.setStartUser(jgScrapCancelDto.getRecUserName());
taskV2Model.setTaskTypeLabel(businessTypeJudgment(jgScrapCancelDto.getCancelType()).getName()); taskV2Model.setTaskTypeLabel(businessTypeJudgment(jgScrapCancelDto.getCancelType()).getName());
taskV2Model.setStartDate(jgScrapCancelDto.getCreateDate());
taskV2Model.setStartUserId(jgScrapCancelDto.getCreateUserId());
taskV2Model.setStartUserCompanyName(jgScrapCancelDto.getUseUnitName()); taskV2Model.setStartUserCompanyName(jgScrapCancelDto.getUseUnitName());
taskV2Model.setExecuteUserIds(nextUserIds); taskV2Model.setExecuteUserIds(nextUserIds);
taskV2Model.setFlowCode(jgScrapCancelDto.getNextTaskId()); taskV2Model.setFlowCode(jgScrapCancelDto.getNextTaskId());
......
...@@ -146,4 +146,10 @@ public class IdxBizJgMaintenanceRecordInfo extends TzsBaseEntity { ...@@ -146,4 +146,10 @@ public class IdxBizJgMaintenanceRecordInfo extends TzsBaseEntity {
@TableField(exist = false) @TableField(exist = false)
private String supervisoryCode; private String supervisoryCode;
/**
* 原始业务id(如维保备案id)
*/
@TableField("\"SOURCE_ID\"")
private String sourceId;
} }
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