补批枷锁

byit-myth-admin/src/main/java/com/byit/service/impl/ApiFlowServiceImpl.java

@@ -16,6 +16,7 @@ import com.byit.model.*;
 import com.byit.model.vo.RunRecordingVo;
 import com.byit.service.ApiFlowService;
 import com.byit.util.ApiFlowDagCheck;
+import com.byit.util.lock.RedissLockUtil;
 import com.byit.utils.ValidationUtil;
 import com.google.common.base.Joiner;
 import lombok.extern.slf4j.Slf4j;
@@ -971,6 +972,7 @@ public class ApiFlowServiceImpl implements ApiFlowService {
 
     @Override
     public void repairFlow(String param) {
+
         ValidationUtil.dataNotBank(param, "请求参数不允许为空！");
         JSONObject jsonObject = JSON.parseObject(param);
         //获取工作空间名称
@@ -996,6 +998,8 @@ public class ApiFlowServiceImpl implements ApiFlowService {
         ValidationUtil.dataNotNull(flow, flowName + "工作流不存在");
         List<Node> nodeList = nodeMapper.findByFlowIdAndName(flow.getFlowId(), nodeNameList);
 
+        RedissLockUtil.lock(flow.getFlowId().toString(), 60);
+
         //设置触发时间
         Long triggerTime = System.currentTimeMillis();
 
@@ -1035,9 +1039,10 @@ public class ApiFlowServiceImpl implements ApiFlowService {
                 waitingTask.setWaitId(waitingRecord.getWaitId());
                 waitingTaskMapper.insertSelective(waitingTask);
             });
-
         }
 
+        RedissLockUtil.unlock(flow.getFlowId().toString());
+
     }