Commit f33823b6 authored by 刘林's avatar 刘林

fix(jg):气瓶履历信息处理

parent 64eca2fe
...@@ -26,14 +26,14 @@ public class JgResumeInfoEq implements Serializable { ...@@ -26,14 +26,14 @@ public class JgResumeInfoEq implements Serializable {
/** /**
* 主键 * 主键
*/ */
@TableId(value = "sequence_nbr", type = IdType.ID_WORKER) @TableId(value = "sequence_nbr", type = IdType.UUID)
private Long sequenceNbr; private String sequenceNbr;
/** /**
* 履历主表id * 履历主表id
*/ */
@TableField("resume_id") @TableField("resume_id")
private Long resumeId; private String resumeId;
/** /**
* 设备ID * 设备ID
......
...@@ -149,19 +149,27 @@ ...@@ -149,19 +149,27 @@
t.apply_no AS applyNo, t.apply_no AS applyNo,
t.rec_user_id AS recUserId, t.rec_user_id AS recUserId,
t.rec_user_name AS recUserName, t.rec_user_name AS recUserName,
DATE_FORMAT(rec_date,'%Y-%m-%d %H:%i:%s') as recDate, DATE_FORMAT(t.rec_date,'%Y-%m-%d %H:%i:%s') AS recDate,
t.approval_unit AS approvalUnit, t.approval_unit AS approvalUnit,
t.status, t.status,
t.route_path AS routePath t.route_path AS routePath
FROM FROM tzs_jg_resume_info t
tzs_jg_resume_info t JOIN (
JOIN (SELECT apply_no, MAX(rec_date) AS max_rec_date SELECT r.apply_no, MAX(r.rec_date) AS max_rec_date
FROM tzs_jg_resume_info FROM tzs_jg_resume_info r
WHERE equ_id = #{record} LEFT JOIN tzs_jg_resume_info_eq eq
GROUP BY apply_no ON eq.resume_id = r.sequence_nbr
) AS latest WHERE (r.equ_id = #{record} OR eq.equ_id = #{record})
ON t.apply_no = latest.apply_no AND t.rec_date = latest.max_rec_date GROUP BY r.apply_no
) latest
ON t.apply_no = latest.apply_no
AND t.rec_date = latest.max_rec_date
WHERE t.equ_id = #{record} WHERE t.equ_id = #{record}
OR t.sequence_nbr IN (
SELECT resume_id
FROM tzs_jg_resume_info_eq
WHERE equ_id = #{record}
)
ORDER BY t.rec_date ASC ORDER BY t.rec_date ASC
</select> </select>
<select id="selectPromoterData" resultType="java.lang.String"> <select id="selectPromoterData" resultType="java.lang.String">
......
...@@ -3502,7 +3502,7 @@ public class CommonServiceImpl implements ICommonService { ...@@ -3502,7 +3502,7 @@ public class CommonServiceImpl implements ICommonService {
public void batchInsertResumeEq(Long resumeId, List<Map<String, Object>> equipmentLists) { public void batchInsertResumeEq(Long resumeId, List<Map<String, Object>> equipmentLists) {
jgResumeInfoEqService.saveBatchResumeEq(equipmentLists.stream() jgResumeInfoEqService.saveBatchResumeEq(equipmentLists.stream()
.map(e -> JgResumeInfoEq.builder() .map(e -> JgResumeInfoEq.builder()
.resumeId(resumeId) .resumeId(String.valueOf(resumeId))
.equId(String.valueOf(e.get("record"))) .equId(String.valueOf(e.get("record")))
.build()) .build())
.collect(Collectors.toList())); .collect(Collectors.toList()));
......
...@@ -1760,7 +1760,7 @@ public class DataDockServiceImpl { ...@@ -1760,7 +1760,7 @@ public class DataDockServiceImpl {
jgResumeInfoService.save(info); jgResumeInfoService.save(info);
jgResumeInfoEqService.saveBatchResumeEq(records.stream() jgResumeInfoEqService.saveBatchResumeEq(records.stream()
.map(record -> JgResumeInfoEq.builder() .map(record -> JgResumeInfoEq.builder()
.resumeId(info.getSequenceNbr()) .resumeId(String.valueOf(info.getSequenceNbr()))
.equId(record) .equId(record)
.build()) .build())
.collect(Collectors.toList())); .collect(Collectors.toList()));
......
...@@ -3927,7 +3927,7 @@ public class IdxBizJgRegisterInfoServiceImpl extends BaseService<IdxBizJgRegiste ...@@ -3927,7 +3927,7 @@ public class IdxBizJgRegisterInfoServiceImpl extends BaseService<IdxBizJgRegiste
info.setRoutePath(routePath); info.setRoutePath(routePath);
jgResumeInfoService.save(info); jgResumeInfoService.save(info);
jgResumeInfoEqMapper.insert(JgResumeInfoEq.builder() jgResumeInfoEqMapper.insert(JgResumeInfoEq.builder()
.resumeId(info.getSequenceNbr()) .resumeId(String.valueOf(info.getSequenceNbr()))
.equId(record) .equId(record)
.build()); .build());
} }
......
...@@ -563,7 +563,7 @@ public class JgCertificateReplenishServiceImpl extends BaseService<JgCertificate ...@@ -563,7 +563,7 @@ public class JgCertificateReplenishServiceImpl extends BaseService<JgCertificate
jgResumeInfoService.save(info); jgResumeInfoService.save(info);
jgResumeInfoEqService.saveBatchResumeEq(replenishEqs.stream() jgResumeInfoEqService.saveBatchResumeEq(replenishEqs.stream()
.map(eq -> JgResumeInfoEq.builder() .map(eq -> JgResumeInfoEq.builder()
.resumeId(info.getSequenceNbr()) .resumeId(String.valueOf(info.getSequenceNbr()))
.equId(eq.getEquId()) .equId(eq.getEquId())
.build()) .build())
.collect(Collectors.toList())); .collect(Collectors.toList()));
......
...@@ -1108,7 +1108,7 @@ public class JgChangeRegistrationNameServiceImpl extends BaseService<JgChangeReg ...@@ -1108,7 +1108,7 @@ public class JgChangeRegistrationNameServiceImpl extends BaseService<JgChangeReg
jgResumeInfoService.save(resumeInfo); jgResumeInfoService.save(resumeInfo);
jgResumeInfoEqService.saveBatchResumeEq(cylinderEquipIds.stream() jgResumeInfoEqService.saveBatchResumeEq(cylinderEquipIds.stream()
.map(e -> JgResumeInfoEq.builder() .map(e -> JgResumeInfoEq.builder()
.resumeId(resumeInfo.getSequenceNbr()) .resumeId(String.valueOf(resumeInfo.getSequenceNbr()))
.equId(e) .equId(e)
.build()) .build())
.collect(Collectors.toList())); .collect(Collectors.toList()));
......
...@@ -2244,7 +2244,7 @@ public class JgChangeRegistrationUnitServiceImpl extends BaseService<JgChangeReg ...@@ -2244,7 +2244,7 @@ public class JgChangeRegistrationUnitServiceImpl extends BaseService<JgChangeReg
jgResumeInfoService.save(resumeInfo); jgResumeInfoService.save(resumeInfo);
jgResumeInfoEqService.saveBatchResumeEq(records.stream() jgResumeInfoEqService.saveBatchResumeEq(records.stream()
.map(e -> JgResumeInfoEq.builder() .map(e -> JgResumeInfoEq.builder()
.resumeId(resumeInfo.getSequenceNbr()) .resumeId(String.valueOf(resumeInfo.getSequenceNbr()))
.equId(e) .equId(e)
.build()) .build())
.collect(Collectors.toList())); .collect(Collectors.toList()));
......
...@@ -494,7 +494,7 @@ public class JgChangeVehicleRegistrationUnitServiceImpl extends BaseService<JgCh ...@@ -494,7 +494,7 @@ public class JgChangeVehicleRegistrationUnitServiceImpl extends BaseService<JgCh
jgResumeInfoService.save(info); jgResumeInfoService.save(info);
jgResumeInfoEqService.saveBatchResumeEq(registrationUnitEqs.stream() jgResumeInfoEqService.saveBatchResumeEq(registrationUnitEqs.stream()
.map(eq -> JgResumeInfoEq.builder() .map(eq -> JgResumeInfoEq.builder()
.resumeId(info.getSequenceNbr()) .resumeId(String.valueOf(info.getSequenceNbr()))
.equId(eq.getEquId()) .equId(eq.getEquId())
.build()) .build())
.collect(Collectors.toList())); .collect(Collectors.toList()));
......
...@@ -752,7 +752,7 @@ public class JgEnableDisableServiceImpl extends BaseService<JgEnableDisableDto, ...@@ -752,7 +752,7 @@ public class JgEnableDisableServiceImpl extends BaseService<JgEnableDisableDto,
} }
jgResumeInfoEqService.saveBatchResumeEq(eqs.stream() jgResumeInfoEqService.saveBatchResumeEq(eqs.stream()
.map(eq -> JgResumeInfoEq.builder() .map(eq -> JgResumeInfoEq.builder()
.resumeId(resumeId) .resumeId(String.valueOf(resumeId))
.equId(eq.getEquId()) .equId(eq.getEquId())
.build()).collect(Collectors.toList())); .build()).collect(Collectors.toList()));
} }
......
...@@ -744,7 +744,7 @@ public class JgOverDesignServiceLifeServiceImpl extends BaseService<JgOverDesign ...@@ -744,7 +744,7 @@ public class JgOverDesignServiceLifeServiceImpl extends BaseService<JgOverDesign
jgResumeInfoService.save(info); jgResumeInfoService.save(info);
jgResumeInfoEqService.saveBatchResumeEq(designInfoList.stream() jgResumeInfoEqService.saveBatchResumeEq(designInfoList.stream()
.map(eq -> JgResumeInfoEq.builder() .map(eq -> JgResumeInfoEq.builder()
.resumeId(info.getSequenceNbr()) .resumeId(String.valueOf(info.getSequenceNbr()))
.equId(eq.getRecord()) .equId(eq.getRecord())
.build()) .build())
.collect(Collectors.toList())); .collect(Collectors.toList()));
......
...@@ -1066,7 +1066,7 @@ public class JgVehicleInformationServiceImpl extends BaseService<JgVehicleInform ...@@ -1066,7 +1066,7 @@ public class JgVehicleInformationServiceImpl extends BaseService<JgVehicleInform
jgResumeInfoService.save(info); jgResumeInfoService.save(info);
jgResumeInfoEqService.saveBatchResumeEq(equipIdList.stream() jgResumeInfoEqService.saveBatchResumeEq(equipIdList.stream()
.map(equipId -> JgResumeInfoEq.builder() .map(equipId -> JgResumeInfoEq.builder()
.resumeId(info.getSequenceNbr()) .resumeId(String.valueOf(info.getSequenceNbr()))
.equId(equipId) .equId(equipId)
.build()) .build())
.collect(Collectors.toList())); .collect(Collectors.toList()));
......
...@@ -903,7 +903,7 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec ...@@ -903,7 +903,7 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec
// TODO 暂存json,在结果录入后,将数据更新技术参数-检验详情使用 考虑兼容老数据 // TODO 暂存json,在结果录入后,将数据更新技术参数-检验详情使用 考虑兼容老数据
if (model.getEquCategory().equals(CylinderTypeEnum.CYLINDER.getCode())){ if (model.getEquCategory().equals(CylinderTypeEnum.CYLINDER.getCode())){
jgResumeInfoEqList.add(JgResumeInfoEq.builder() jgResumeInfoEqList.add(JgResumeInfoEq.builder()
.resumeId(resultSeq) .resumeId(String.valueOf(resultSeq))
.equId(applicationEquipModels.get(i).getEquipUnicode()) .equId(applicationEquipModels.get(i).getEquipUnicode())
.build()); .build());
// 主表只创建一次 // 主表只创建一次
......
...@@ -9,19 +9,26 @@ ...@@ -9,19 +9,26 @@
t.apply_no AS applyNo, t.apply_no AS applyNo,
t.rec_user_id AS recUserId, t.rec_user_id AS recUserId,
t.rec_user_name AS recUserName, t.rec_user_name AS recUserName,
DATE_FORMAT(rec_date,'%Y-%m-%d %H:%i:%s') as recDate, DATE_FORMAT(t.rec_date,'%Y-%m-%d %H:%i:%s') AS recDate,
t.approval_unit AS approvalUnit, t.approval_unit AS approvalUnit,
t.status, t.status,
t.route_path AS routePath t.route_path AS routePath
FROM FROM tzs_jg_resume_info t
tzs_jg_resume_info t LEFT JOIN tzs_jg_resume_info_eq eq
JOIN (SELECT apply_no, MAX(rec_date) AS max_rec_date ON eq.resume_id = t.sequence_nbr
FROM tzs_jg_resume_info JOIN (
WHERE equ_id = #{record} SELECT r.apply_no, MAX(r.rec_date) AS max_rec_date
GROUP BY apply_no FROM tzs_jg_resume_info r
) AS latest LEFT JOIN tzs_jg_resume_info_eq eq2
ON t.apply_no = latest.apply_no AND t.rec_date = latest.max_rec_date ON eq2.resume_id = r.sequence_nbr
WHERE r.equ_id = #{record}
OR eq2.equ_id = #{record}
GROUP BY r.apply_no
) latest
ON t.apply_no = latest.apply_no
AND t.rec_date = latest.max_rec_date
WHERE t.equ_id = #{record} WHERE t.equ_id = #{record}
OR eq.equ_id = #{record}
ORDER BY t.rec_date ASC ORDER BY t.rec_date ASC
</select> </select>
......
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