固化流程，建立node；

yangys

2025-08-06 053a438acf9ec33e182b25211ce8108f0367feac

 blade-service/blade-mdm/src/main/java/org/springblade/mdm/flow/service/ApproveRecordService.java

@@ -38,6 +38,25 @@

      String processDefinitionKey = flowCommonService.getDefinitionKey(processInstanceId);

      ApproveRecord rec = new ApproveRecord();
      rec.setTaskName(task.getName());
      rec.setComment(comment==null? StringUtils.EMPTY:comment);
      //rec.setNcProgramId(refObj.getNcProgramId());
      rec.setOperateResult(operateResult);//审批结果
      rec.setOperateTime(DateUtil.now());
      rec.setProcessInstanceId(processInstanceId);
      rec.setProcessDefinitionKey(processDefinitionKey);
      rec.setUserId(AuthUtil.getUserId());
      rec.setUserNickname(AuthUtil.getNickName());

      save(rec);
   }
   /*

   public void saveApproveRecordsOld(Task task, String processInstanceId, String operateResult, String comment) {

      String processDefinitionKey = flowCommonService.getDefinitionKey(processInstanceId);

      LambdaQueryWrapper<ProcessProgRef> queryWrapper = new LambdaQueryWrapper<>();
      queryWrapper.eq(ProcessProgRef::getProcessInstanceId, processInstanceId);
      List<ProcessProgRef> refList =  processProgRefService.list(queryWrapper);
@@ -46,7 +65,7 @@
            ApproveRecord rec = new ApproveRecord();
            rec.setTaskName(task.getName());
            rec.setComment(comment==null? StringUtils.EMPTY:comment);
            rec.setNcProgramId(refObj.getNcProgramId());

            rec.setOperateResult(operateResult);//审批结果
            rec.setOperateTime(DateUtil.now());
            rec.setProcessInstanceId(processInstanceId);
@@ -57,8 +76,6 @@
            save(rec);
         }

         //检查ncprogram为null的数据
         updateApproveRecords(processInstanceId,refList);
      }else{
         //如果还没有关联的程序数据，则插入一个programId为null的
         ApproveRecord rec = new ApproveRecord();
@@ -70,46 +87,11 @@
         rec.setProcessDefinitionKey(processDefinitionKey);
         rec.setOperateResult(operateResult);
         rec.setOperateTime(DateUtil.now());
         rec.setNcProgramId(null);//空的程序id
         rec.setUserId(AuthUtil.getUserId());
         rec.setUserNickname(AuthUtil.getNickName());

         save(rec);
      }
   }

   /**
    * 更新以前无文件时候的数据。
    * @param processInstanceId
    */
   void updateApproveRecords(String processInstanceId,List<ProcessProgRef> refList) {

      if(refList.isEmpty()) {
         return;
      }
      List<ApproveRecord> records = this.lambdaQuery().isNull(ApproveRecord::getNcProgramId).eq(ApproveRecord::getProcessInstanceId, processInstanceId).list();
      if(records.isEmpty()) {
         return;
      }

      for(ApproveRecord record:records) {

         for(int j=0;j< refList.size();j++) {
            ProcessProgRef refObj = refList.get(j);

            ApproveRecord record2 = new ApproveRecord();
            BeanUtils.copyProperties(record, record2);
            record2.setNcProgramId(refObj.getNcProgramId());

            if(j>0){//后续数据需要新增数据
               record2.setId(null);
               save(record2);
            }else{//第一条是更新原纪录
               updateById(record2);
            }
         }

      }

   }
   */
}