diff --git a/klp-flow/src/main/java/com/klp/flow/domain/bo/TsComplaintAcceptBo.java b/klp-flow/src/main/java/com/klp/flow/domain/bo/TsComplaintAcceptBo.java index 091163e7..00082c77 100644 --- a/klp-flow/src/main/java/com/klp/flow/domain/bo/TsComplaintAcceptBo.java +++ b/klp-flow/src/main/java/com/klp/flow/domain/bo/TsComplaintAcceptBo.java @@ -6,6 +6,7 @@ import lombok.EqualsAndHashCode; import javax.validation.constraints.*; import java.util.Date; +import java.util.List; import com.fasterxml.jackson.annotation.JsonFormat; /** @@ -90,5 +91,10 @@ public class TsComplaintAcceptBo extends BaseEntity { */ private String remark; + /** + * 关联的钢卷ID列表(新增受理单时一并插入到ts_accept_coil_rel) + */ + private List coilIds; + } diff --git a/klp-flow/src/main/java/com/klp/flow/service/impl/TsComplaintAcceptServiceImpl.java b/klp-flow/src/main/java/com/klp/flow/service/impl/TsComplaintAcceptServiceImpl.java index 860fe559..320c9ac7 100644 --- a/klp-flow/src/main/java/com/klp/flow/service/impl/TsComplaintAcceptServiceImpl.java +++ b/klp-flow/src/main/java/com/klp/flow/service/impl/TsComplaintAcceptServiceImpl.java @@ -17,9 +17,11 @@ import com.klp.flow.domain.vo.TsComplaintAcceptVo; import com.klp.flow.domain.TsComplaintAccept; import com.klp.flow.domain.TsComplaintTask; import com.klp.flow.domain.TsPlanExecuteRel; +import com.klp.flow.domain.TsAcceptCoilRel; import com.klp.flow.mapper.TsComplaintAcceptMapper; import com.klp.flow.mapper.TsComplaintTaskMapper; import com.klp.flow.mapper.TsPlanExecuteRelMapper; +import com.klp.flow.mapper.TsAcceptCoilRelMapper; import com.klp.flow.service.ITsComplaintAcceptService; import java.util.List; @@ -42,6 +44,8 @@ public class TsComplaintAcceptServiceImpl implements ITsComplaintAcceptService { private final TsPlanExecuteRelMapper tsPlanExecuteRelMapper; + private final TsAcceptCoilRelMapper tsAcceptCoilRelMapper; + /** * 查询投诉受理单主 */ @@ -97,6 +101,15 @@ public class TsComplaintAcceptServiceImpl implements ITsComplaintAcceptService { boolean flag = baseMapper.insert(add) > 0; if (flag) { bo.setAcceptId(add.getAcceptId()); + // 插入关联钢卷 + if (bo.getCoilIds() != null && !bo.getCoilIds().isEmpty()) { + for (Long coilId : bo.getCoilIds()) { + TsAcceptCoilRel rel = new TsAcceptCoilRel(); + rel.setAcceptId(add.getAcceptId()); + rel.setCoilId(coilId); + tsAcceptCoilRelMapper.insert(rel); + } + } } return flag; }