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:05:23 +08:00
parent 173084e016
commit 55b90a3068
1 changed files with 45 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/gatewayimpl/QualFilingGatewayImpl.java
View File

@ -3,6 +3,7 @@ package org.qinan.safetyeval.infrastructure.gatewayimpl;
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.constant.QualFilingStatusEnum; import org.qinan.safetyeval.domain.constant.QualFilingStatusEnum;
import org.qinan.safetyeval.domain.entity.*; import org.qinan.safetyeval.domain.entity.*;
import org.qinan.safetyeval.domain.exception.BizException; import org.qinan.safetyeval.domain.exception.BizException;
@ -197,35 +198,46 @@ public class QualFilingGatewayImpl implements QualFilingGateway {
qualFilingPersonnelCertMapper.delete(new LambdaQueryWrapper<QualFilingPersonnelCertDO>().eq(QualFilingPersonnelCertDO::getFilingId, dataObject.getId())); qualFilingPersonnelCertMapper.delete(new LambdaQueryWrapper<QualFilingPersonnelCertDO>().eq(QualFilingPersonnelCertDO::getFilingId, dataObject.getId()));
//备案承诺书 //备案承诺书
if (Objects.nonNull(commitmentEntity)) {
QualFilingCommitmentDO commitmentDataObject = new QualFilingCommitmentDO(); QualFilingCommitmentDO commitmentDataObject = new QualFilingCommitmentDO();
BeanUtils.copyProperties(commitmentEntity, commitmentDataObject); BeanUtils.copyProperties(commitmentEntity, commitmentDataObject);
InsertFieldDefaults.apply(commitmentDataObject); InsertFieldDefaults.apply(commitmentDataObject);
commitmentDataObject.setFilingId(dataObject.getId()); commitmentDataObject.setFilingId(dataObject.getId());
qualFilingCommitmentMapper.insert(commitmentDataObject); qualFilingCommitmentMapper.insert(commitmentDataObject);
}
//备案装备 //备案装备
equipmentEntities.stream().map(item -> { if (!CollectionUtils.isEmpty(equipmentEntities)) {
List<QualFilingEquipmentDO> equipmentDataObjects = equipmentEntities.stream().map(item -> {
QualFilingEquipmentDO equipmentDataObject = new QualFilingEquipmentDO(); QualFilingEquipmentDO equipmentDataObject = new QualFilingEquipmentDO();
BeanUtils.copyProperties(item, equipmentDataObject); BeanUtils.copyProperties(item, equipmentDataObject);
InsertFieldDefaults.apply(equipmentDataObject); InsertFieldDefaults.apply(equipmentDataObject);
equipmentDataObject.setFilingId(dataObject.getId()); equipmentDataObject.setFilingId(dataObject.getId());
return equipmentDataObject; return equipmentDataObject;
}).collect(Collectors.toList()).forEach(equipmentDataObject -> qualFilingEquipmentMapper.insert(equipmentDataObject)); }).collect(Collectors.toList());
Db.saveBatch(equipmentDataObjects);
}
//备案材料 //备案材料
materialEntities.stream().map(item -> { if (!CollectionUtils.isEmpty(materialEntities)) {
List<QualFilingMaterialDO> materialDataObjects = materialEntities.stream().map(item -> {
QualFilingMaterialDO materialDataObject = new QualFilingMaterialDO(); QualFilingMaterialDO materialDataObject = new QualFilingMaterialDO();
BeanUtils.copyProperties(item, materialDataObject); BeanUtils.copyProperties(item, materialDataObject);
InsertFieldDefaults.apply(materialDataObject); InsertFieldDefaults.apply(materialDataObject);
materialDataObject.setFilingId(dataObject.getId()); materialDataObject.setFilingId(dataObject.getId());
return materialDataObject; return materialDataObject;
}).collect(Collectors.toList()).forEach(materialDataObject -> qualFilingMaterialMapper.insert(materialDataObject)); }).collect(Collectors.toList());
Db.saveBatch(materialDataObjects);
}
//备案人员 //备案人员
personnelEntities.stream().map(item -> { if (!CollectionUtils.isEmpty(personnelEntities)) {
List<QualFilingPersonnelDO> personnelDataObjects = personnelEntities.stream().map(item -> {
QualFilingPersonnelDO personnelDataObject = new QualFilingPersonnelDO(); QualFilingPersonnelDO personnelDataObject = new QualFilingPersonnelDO();
BeanUtils.copyProperties(item, personnelDataObject); BeanUtils.copyProperties(item, personnelDataObject);
InsertFieldDefaults.apply(personnelDataObject); InsertFieldDefaults.apply(personnelDataObject);
personnelDataObject.setFilingId(dataObject.getId()); personnelDataObject.setFilingId(dataObject.getId());
return personnelDataObject; return personnelDataObject;
}).collect(Collectors.toList()).forEach(personnelDataObject -> qualFilingPersonnelMapper.insert(personnelDataObject)); }).collect(Collectors.toList());
Db.saveBatch(personnelDataObjects);
}
//备案人员证书 //备案人员证书
if (CollectionUtils.isEmpty(personnelCertEntities)) { if (CollectionUtils.isEmpty(personnelCertEntities)) {
List<Long> sourcePersonnelIds = personnelEntities.stream().map(QualFilingPersonnelEntity::getSourcePersonnelId).collect(Collectors.toList()); List<Long> sourcePersonnelIds = personnelEntities.stream().map(QualFilingPersonnelEntity::getSourcePersonnelId).collect(Collectors.toList());
@ -233,7 +245,7 @@ public class QualFilingGatewayImpl implements QualFilingGateway {
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<QualFilingPersonnelCertDO> personnelCertDataObjects = orgPersonnelCertDOS.stream().map(orgPersonnelCertDO -> {
QualFilingPersonnelCertDO qualFilingPersonnelCertDO = new QualFilingPersonnelCertDO(); QualFilingPersonnelCertDO qualFilingPersonnelCertDO = new QualFilingPersonnelCertDO();
BeanUtils.copyProperties(orgPersonnelCertDO, qualFilingPersonnelCertDO, "id"); BeanUtils.copyProperties(orgPersonnelCertDO, qualFilingPersonnelCertDO, "id");
InsertFieldDefaults.apply(qualFilingPersonnelCertDO); InsertFieldDefaults.apply(qualFilingPersonnelCertDO);
@ -241,18 +253,20 @@ public class QualFilingGatewayImpl implements QualFilingGateway {
qualFilingPersonnelCertDO.setFilingId(dataObject.getId()); qualFilingPersonnelCertDO.setFilingId(dataObject.getId());
qualFilingPersonnelCertDO.setFilingPersonnelId(orgPersonnelCertDO.getPersonnelId()); qualFilingPersonnelCertDO.setFilingPersonnelId(orgPersonnelCertDO.getPersonnelId());
qualFilingPersonnelCertDO.setSourceCertId(orgPersonnelCertDO.getId()); qualFilingPersonnelCertDO.setSourceCertId(orgPersonnelCertDO.getId());
qualFilingPersonnelCertMapper.insert(qualFilingPersonnelCertDO); return qualFilingPersonnelCertDO;
} }).collect(Collectors.toList());
Db.saveBatch(personnelCertDataObjects);
} }
} }
} else { } else {
personnelCertEntities.stream().map(item -> { List<QualFilingPersonnelCertDO> personnelCertDataObjects = personnelCertEntities.stream().map(item -> {
QualFilingPersonnelCertDO personnelCertDataObject = new QualFilingPersonnelCertDO(); QualFilingPersonnelCertDO personnelCertDataObject = new QualFilingPersonnelCertDO();
BeanUtils.copyProperties(item, personnelCertDataObject, "id"); BeanUtils.copyProperties(item, personnelCertDataObject, "id");
InsertFieldDefaults.apply(personnelCertDataObject); InsertFieldDefaults.apply(personnelCertDataObject);
personnelCertDataObject.setFilingId(dataObject.getId()); personnelCertDataObject.setFilingId(dataObject.getId());
return personnelCertDataObject; return personnelCertDataObject;
}).collect(Collectors.toList()).forEach(personnelCertDataObject -> qualFilingPersonnelCertMapper.insert(personnelCertDataObject)); }).collect(Collectors.toList());
Db.saveBatch(personnelCertDataObjects);
} }
return dataObject.getId(); return dataObject.getId();
} }