cq_anquan
/
safety-eval-service
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

sign

dev
luotaiqian 2026-08-06 14:09:44 +08:00
parent cb4e152925
commit d49b451112
1 changed files with 35 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/gatewayimpl/QualFilingChangeGatewayImpl.java
View File

@ -4,6 +4,7 @@ import cn.hutool.json.JSONUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.toolkit.Db;
import org.qinan.safetyeval.domain.change.model.*; import org.qinan.safetyeval.domain.change.model.*;
import org.qinan.safetyeval.domain.entity.QualFilingChangeEntity; import org.qinan.safetyeval.domain.entity.QualFilingChangeEntity;
import org.qinan.safetyeval.domain.exception.BizException; import org.qinan.safetyeval.domain.exception.BizException;
@ -185,29 +186,35 @@ public class QualFilingChangeGatewayImpl implements QualFilingChangeGateway {
commitmentDataObject.setFilingChangeId(dataObject.getId()); commitmentDataObject.setFilingChangeId(dataObject.getId());
qualFilingCommitmentChangeMapper.insert(commitmentDataObject); qualFilingCommitmentChangeMapper.insert(commitmentDataObject);
//备案装备 //备案装备
equipmentEntities.stream().map(item -> { if (!CollectionUtils.isEmpty(equipmentEntities)) {
List<QualFilingEquipmentChangeDO> equipmentDataObjects = equipmentEntities.stream().map(item -> {
QualFilingEquipmentChangeDO equipmentDataObject = qualFilingEquipmentChangeDoConvertor.convertEeToDo(item); QualFilingEquipmentChangeDO equipmentDataObject = qualFilingEquipmentChangeDoConvertor.convertEeToDo(item);
InsertFieldDefaults.apply(equipmentDataObject); InsertFieldDefaults.apply(equipmentDataObject);
equipmentDataObject.setFilingChangeId(dataObject.getId()); equipmentDataObject.setFilingChangeId(dataObject.getId());
return equipmentDataObject; return equipmentDataObject;
}).collect(Collectors.toList()).forEach( }).collect(Collectors.toList());
equipmentDataObject -> qualFilingEquipmentChangeMapper.insert(equipmentDataObject)); Db.saveBatch(equipmentDataObjects);
}
//备案材料 //备案材料
materialEntities.stream().map(item -> { if (!CollectionUtils.isEmpty(materialEntities)) {
List<QualFilingMaterialChangeDO> materialDataObjects = materialEntities.stream().map(item -> {
QualFilingMaterialChangeDO materialDataObject = qualFilingMaterialChangeDoConvertor.convertEeToDo(item); QualFilingMaterialChangeDO materialDataObject = qualFilingMaterialChangeDoConvertor.convertEeToDo(item);
InsertFieldDefaults.apply(materialDataObject); InsertFieldDefaults.apply(materialDataObject);
materialDataObject.setFilingChangeId(dataObject.getId()); materialDataObject.setFilingChangeId(dataObject.getId());
return materialDataObject; return materialDataObject;
}).collect(Collectors.toList()).forEach( }).collect(Collectors.toList());
materialDataObject -> qualFilingMaterialChangeMapper.insert(materialDataObject)); Db.saveBatch(materialDataObjects);
}
//备案人员 //备案人员
personnelEntities.stream().map(item -> { if (!CollectionUtils.isEmpty(personnelEntities)) {
List<QualFilingPersonnelChangeDO> personnelDataObjects = personnelEntities.stream().map(item -> {
QualFilingPersonnelChangeDO personnelDataObject = qualFilingPersonnelChangeDoConvertor.convertEeToDo(item); QualFilingPersonnelChangeDO personnelDataObject = qualFilingPersonnelChangeDoConvertor.convertEeToDo(item);
InsertFieldDefaults.apply(personnelDataObject); InsertFieldDefaults.apply(personnelDataObject);
personnelDataObject.setFilingChangeId(dataObject.getId()); personnelDataObject.setFilingChangeId(dataObject.getId());
return personnelDataObject; return personnelDataObject;
}).collect(Collectors.toList()).forEach( }).collect(Collectors.toList());
personnelDataObject -> qualFilingPersonnelChangeMapper.insert(personnelDataObject)); Db.saveBatch(personnelDataObjects);
}
//备案人员证书 //备案人员证书
if (CollectionUtils.isEmpty(personnelCertEntities)) { if (CollectionUtils.isEmpty(personnelCertEntities)) {
List<Long> sourcePersonnelIds = personnelEntities List<Long> sourcePersonnelIds = personnelEntities
@ -216,23 +223,24 @@ public class QualFilingChangeGatewayImpl implements QualFilingChangeGateway {
List<OrgPersonnelCertDO> orgPersonnelCertDOS = orgPersonnelCertMapper.selectList(new LambdaQueryWrapper<OrgPersonnelCertDO>() List<OrgPersonnelCertDO> orgPersonnelCertDOS = orgPersonnelCertMapper.selectList(new LambdaQueryWrapper<OrgPersonnelCertDO>()
.in(OrgPersonnelCertDO::getPersonnelId, sourcePersonnelIds)); .in(OrgPersonnelCertDO::getPersonnelId, sourcePersonnelIds));
if (!CollectionUtils.isEmpty(orgPersonnelCertDOS)) { if (!CollectionUtils.isEmpty(orgPersonnelCertDOS)) {
for (OrgPersonnelCertDO orgPersonnelCertDO : orgPersonnelCertDOS) { List<QualFilingPersonnelCertChangeDO> personnelCertDataObjects = orgPersonnelCertDOS.stream().map(orgPersonnelCertDO -> {
QualFilingPersonnelCertChangeDO qualFilingPersonnelCertChangeDO = QualFilingPersonnelCertChangeDO qualFilingPersonnelCertChangeDO =
qualFilingPersonnelCertChangeDoConvertor.convertOrgDoToChangeDo(orgPersonnelCertDO); qualFilingPersonnelCertChangeDoConvertor.convertOrgDoToChangeDo(orgPersonnelCertDO);
InsertFieldDefaults.apply(qualFilingPersonnelCertChangeDO); InsertFieldDefaults.apply(qualFilingPersonnelCertChangeDO);
qualFilingPersonnelCertChangeDO.setFilingChangeId(dataObject.getId()); qualFilingPersonnelCertChangeDO.setFilingChangeId(dataObject.getId());
qualFilingPersonnelCertChangeMapper.insert(qualFilingPersonnelCertChangeDO); return qualFilingPersonnelCertChangeDO;
} }).collect(Collectors.toList());
Db.saveBatch(personnelCertDataObjects);
} }
} }
} else { } else {
personnelCertEntities.stream().map(item -> { List<QualFilingPersonnelCertChangeDO> personnelCertDataObjects = personnelCertEntities.stream().map(item -> {
QualFilingPersonnelCertChangeDO personnelCertDataObject = qualFilingPersonnelCertChangeDoConvertor.convertEeToDo(item); QualFilingPersonnelCertChangeDO personnelCertDataObject = qualFilingPersonnelCertChangeDoConvertor.convertEeToDo(item);
InsertFieldDefaults.apply(personnelCertDataObject); InsertFieldDefaults.apply(personnelCertDataObject);
personnelCertDataObject.setFilingChangeId(dataObject.getId()); personnelCertDataObject.setFilingChangeId(dataObject.getId());
return personnelCertDataObject; return personnelCertDataObject;
}).collect(Collectors.toList()).forEach( }).collect(Collectors.toList());
personnelCertDataObject -> qualFilingPersonnelCertChangeMapper.insert(personnelCertDataObject)); Db.saveBatch(personnelCertDataObjects);
} }
return dataObject.getId(); return dataObject.getId();
} }