modify: 批量插入

yanxuan-qc-change-system-biz/src/main/java/com/netease/mail/yanxuan/change/biz/biz/ChangeFlowBiz.java

@@ -143,12 +143,12 @@ public class ChangeFlowBiz {
         // 保存变更行动方案记录
         List<ChangeExecRecord> changeExecRecords = buildChangeExecRecord(changeRecord.getId(), changeExecProject);
         changeFlowExecService.batchSaveRecord(changeExecRecords);
+        changeExecRecords.forEach(exec->changeFlowExecService.saveRecord(exec));
         // 保存附件
         List<ChangeFlowFile> files = changeFlowCreateReq.getFiles();
         if (CollectionUtils.isNotEmpty(files)) {
             List<ChangeFile> changeFiles = buildChangeFileRecord(changeRecord.getId(), files);
-            changeFileService.batchSaveRecord(changeFiles);
-
+            changeFiles.forEach(file->changeFileService.saveRecord(file));
         }
         // 如果发起人=变更负责人
         if (changeCommander.equals(uid)) {
@@ -417,13 +417,13 @@ public class ChangeFlowBiz {
                 log.info("[CHANGE_FLOW_SUBMIT] delete changeExecCount:{}", changeExecCount);
                 // 保存变更行动方案记录
                 List<ChangeExecRecord> changeExecRecords = buildChangeExecUpdateRecord(changeRecord.getId(), changeFlowSubmitReq.getChangeExecProjectList());
-                changeFlowExecService.batchSaveRecord(changeExecRecords);
+                changeExecRecords.forEach(exec->changeFlowExecService.saveRecord(exec));
                 // 更新附件，覆盖操作，先删除，后插入
                 List<ChangeFlowFile> files = changeFlowSubmitReq.getFiles();
                 if (CollectionUtils.isNotEmpty(files)) {
                     changeFileService.deleteByChangeRecordId(changeRecord.getId());
                     List<ChangeFile> changeFiles = buildChangeFileRecord(changeRecord.getId(), files);
-                    changeFileService.batchSaveRecord(changeFiles);
+                    changeFiles.forEach(file -> changeFileService.saveRecord(file));
                 }
                 // todo: 发送邮件
 

yanxuan-qc-change-system-biz/src/main/java/com/netease/mail/yanxuan/change/biz/service/ChangeFileService.java

@@ -27,4 +27,6 @@ public interface ChangeFileService {
     void batchSaveRecord(List<ChangeFile> changeFiles);
 
     Integer deleteByChangeRecordId(Long changeRecordId);
+
+    void saveRecord(ChangeFile changeFile);
 }
\ No newline at end of file

yanxuan-qc-change-system-biz/src/main/java/com/netease/mail/yanxuan/change/biz/service/ChangeFlowExecService.java

@@ -34,4 +34,6 @@ public interface ChangeFlowExecService {
     Boolean update(ChangeExecRecord exec);
 
     Integer deleteByChangeRecordId(Long id);
+
+    void saveRecord(ChangeExecRecord exec);
 }
\ No newline at end of file

yanxuan-qc-change-system-biz/src/main/java/com/netease/mail/yanxuan/change/biz/service/impl/ChangeFileServiceImpl.java

@@ -48,4 +48,9 @@ public class ChangeFileServiceImpl implements ChangeFileService {
     public Integer deleteByChangeRecordId(Long changeRecordId) {
         return changeFileMapper.deleteByBaseId(changeRecordId);
     }
+
+    @Override
+    public void saveRecord(ChangeFile changeFile) {
+        changeFileMapper.insertSelective(changeFile);
+    }
 }
\ No newline at end of file

yanxuan-qc-change-system-biz/src/main/java/com/netease/mail/yanxuan/change/biz/service/impl/ChangeFlowExecServiceImpl.java

@@ -58,4 +58,9 @@ public class ChangeFlowExecServiceImpl implements ChangeFlowExecService {
     public Integer deleteByChangeRecordId(Long changeRecordId) {
         return changeExecRecordMapper.deleteByBaseId(changeRecordId);
     }
+
+    @Override
+    public void saveRecord(ChangeExecRecord exec) {
+        changeExecRecordMapper.insertSelective(exec);
+    }
 }
\ No newline at end of file