refactor(TsComplaintAcceptService): 优化钢卷关联插入逻辑

- 将单条插入改为批量插入以提升性能
- 使用Stream API重构钢卷关联数据构建过程
- 减少了数据库操作次数,提高处理效率
This commit is contained in:
2026-06-21 15:40:25 +08:00
parent a07ced4b25
commit de5a82d0a7

View File

@@ -101,14 +101,15 @@ public class TsComplaintAcceptServiceImpl implements ITsComplaintAcceptService {
boolean flag = baseMapper.insert(add) > 0; boolean flag = baseMapper.insert(add) > 0;
if (flag) { if (flag) {
bo.setAcceptId(add.getAcceptId()); bo.setAcceptId(add.getAcceptId());
// 插入关联钢卷 // 批量插入关联钢卷
if (bo.getCoilIds() != null && !bo.getCoilIds().isEmpty()) { if (bo.getCoilIds() != null && !bo.getCoilIds().isEmpty()) {
for (Long coilId : bo.getCoilIds()) { List<TsAcceptCoilRel> relList = bo.getCoilIds().stream().map(coilId -> {
TsAcceptCoilRel rel = new TsAcceptCoilRel(); TsAcceptCoilRel rel = new TsAcceptCoilRel();
rel.setAcceptId(add.getAcceptId()); rel.setAcceptId(add.getAcceptId());
rel.setCoilId(coilId); rel.setCoilId(coilId);
tsAcceptCoilRelMapper.insert(rel); return rel;
} }).collect(java.util.stream.Collectors.toList());
tsAcceptCoilRelMapper.insertBatch(relList);
} }
} }
return flag; return flag;