Commit 89f8527a authored by suhuiguang's avatar suhuiguang

refact(jg):设备移交调整

1.监管码落库否则代办缺少监管码字段
parent 9aa1cf16
...@@ -157,7 +157,7 @@ public class JgEquipTransfer extends BaseEntity { ...@@ -157,7 +157,7 @@ public class JgEquipTransfer extends BaseEntity {
/** /**
* 设备监管码 * 设备监管码
*/ */
@TableField(exist = false) @TableField(value = "supervisory_code")
private String supervisoryCode; private String supervisoryCode;
/** /**
......
...@@ -160,7 +160,6 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto, ...@@ -160,7 +160,6 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,
this.handleApplyNoList(applyNoList); this.handleApplyNoList(applyNoList);
//启动工作流 //启动工作流
List<WorkflowResultDto> workflowResultList = this.startWorkFlow(model.getInstallUnitCreditCode(), submitType, deviceList); List<WorkflowResultDto> workflowResultList = this.startWorkFlow(model.getInstallUnitCreditCode(), submitType, deviceList);
List<JgEquipTransfer> transferList = new ArrayList<>(); List<JgEquipTransfer> transferList = new ArrayList<>();
List<JgEquipTransferEq> equipTransferEqList = new ArrayList<>(); List<JgEquipTransferEq> equipTransferEqList = new ArrayList<>();
IntStream.range(0, deviceList.size()).forEach(i -> { IntStream.range(0, deviceList.size()).forEach(i -> {
...@@ -176,56 +175,16 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto, ...@@ -176,56 +175,16 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,
.setEquipTransferId(applyNo); .setEquipTransferId(applyNo);
equipTransferEqList.add(jgEquipTransferEq); equipTransferEqList.add(jgEquipTransferEq);
}); });
List<String> records = equipList.stream().map(equ -> String.valueOf(equ.get(record))).collect(Collectors.toList());
JgEquipTransfer transfer = buildJgEquipTransfer(model, applyNo, reginParams, submitType, workflowResultList, i); JgEquipTransfer transfer = buildJgEquipTransfer(model, applyNo, reginParams, submitType, workflowResultList, i);
transfer.setProjectContraptionSeq(proConSeq); transfer.setProjectContraptionSeq(proConSeq);
transfer.setEquList(EquipmentClassifityEnum.YLGD.getName()); transfer.setEquList(EquipmentClassifityEnum.YLGD.getName());
transfer.setEquListCode(equListCode); transfer.setEquListCode(equListCode);
transfer.setEquCategory(equipmentCategoryMapper.selectOne(new LambdaQueryWrapper<EquipmentCategory>().eq(EquipmentCategory::getCode, idxBizJgRegisterInfoServiceImpl.lambdaQuery().eq(IdxBizJgRegisterInfo::getRecord, equipList.get(0).get(record)).one().getEquCategory())).getName()); transfer.setEquCategory(projectContraption.getEquCategory());
transfer.setEquDefine(equipmentCategoryMapper.selectOne(new LambdaQueryWrapper<EquipmentCategory>().eq(EquipmentCategory::getCode, idxBizJgRegisterInfoServiceImpl.lambdaQuery().eq(IdxBizJgRegisterInfo::getRecord, equipList.get(0).get(record)).one().getEquDefine())).getName()); transfer.setEquDefine(projectContraption.getEquDefine());
transfer.setSupervisoryCode(org.apache.commons.lang3.StringUtils.join(
idxBizJgOtherInfoServiceImpl.lambdaQuery()
.in(IdxBizJgOtherInfo::getRecord, records)
.list()
.stream()
.filter(Objects::nonNull)
.map(IdxBizJgOtherInfo::getSupervisoryCode)
.filter(Objects::nonNull)
.distinct()
.collect(Collectors.toList()), ","
));
transfer.setProductName(org.apache.commons.lang3.StringUtils.join(
idxBizJgRegisterInfoServiceImpl.lambdaQuery()
.in(IdxBizJgRegisterInfo::getRecord, records)
.list()
.stream()
.filter(Objects::nonNull)
.map(IdxBizJgRegisterInfo::getProductName)
.filter(Objects::nonNull)
.distinct()
.collect(Collectors.toList()), ","
));
transfer.setUseRegistCode(projectContraption.getUseRegistrationCode()); transfer.setUseRegistCode(projectContraption.getUseRegistrationCode());
transfer.setUseInnerCode(org.apache.commons.lang3.StringUtils.join(
idxBizJgUseInfoServiceImpl.lambdaQuery()
.in(IdxBizJgUseInfo::getRecord, records)
.list()
.stream()
.filter(Objects::nonNull)
.map(IdxBizJgUseInfo::getUseInnerCode)
.distinct()
.collect(Collectors.toList()), ","));
transfer.setEquAddress(projectContraption.getAddress()); transfer.setEquAddress(projectContraption.getAddress());
transfer.setSupervisoryCode(projectContraption.getSupervisoryCode()); transfer.setSupervisoryCode(projectContraption.getSupervisoryCode());
transfer.setEquCode(org.apache.commons.lang3.StringUtils.join( transfer.setEquCode(projectContraption.getEquCode());
idxBizJgRegisterInfoServiceImpl.lambdaQuery()
.in(IdxBizJgRegisterInfo::getRecord, records)
.list()
.stream()
.filter(Objects::nonNull)
.map(IdxBizJgRegisterInfo::getEquCode)
.distinct()
.collect(Collectors.toList()), ","));
transferList.add(transfer); transferList.add(transfer);
} else { } else {
JgEquipTransferEq jgEquipTransferEq = buildJgEquipTransferEq(obj, applyNo); JgEquipTransferEq jgEquipTransferEq = buildJgEquipTransferEq(obj, applyNo);
......
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