add:添加任务配置

wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/flow_manage/flow/framework/entity/node/base/impl/EventEntity.java

@@ -0,0 +1,13 @@
+package org.nl.wms.flow_manage.flow.framework.entity.node.base.impl;
+
+import com.alibaba.fastjson.JSONObject;
+
+/*
+ * @author ZZQ
+ * @Date 2024/6/6 17:21
+ */
+public class EventEntity {
+    private Boolean pre;
+    private String eventType;
+    private JSONObject eventParams;
+}

wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/flow_manage/flow/framework/entity/node/base/impl/FlowElement.java

@@ -27,9 +27,6 @@ public abstract class FlowElement extends BaseElement {
     /**
      * 是否自动触发下个节点
      */
-
-    protected List<Map> executionListeners = new ArrayList<>();
-
 //    protected FlowElementsContainer parentContainer;
 
 }

wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/flow_manage/flow/framework/entity/node/base/impl/FlowNode.java

@@ -18,6 +18,9 @@ public abstract class FlowNode extends FlowElement {
     private String documentation;
     //监听器配置暂时不需要
     private List<Map> executionListeners = new ArrayList<>();
+    //事件触发器
+    private List<EventEntity> executionEvents = new ArrayList<>();
+
     private boolean asynchronous;
     private boolean asynchronousLeave;
     private boolean notExclusive;

wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/flow_manage/flow/service/classprocessimpl/StorageChangesProcessHandler.java

@@ -3,6 +3,8 @@ package org.nl.wms.flow_manage.flow.service.classprocessimpl;
 import cn.hutool.core.date.DateUtil;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import org.apache.commons.lang3.StringUtils;
+import org.nl.common.domain.exception.BadRequestException;
 import org.nl.common.enums.StatusEnum;
 import org.nl.common.publish.BussEventMulticaster;
 import org.nl.common.utils.SecurityUtils;
@@ -24,7 +26,7 @@ import java.util.List;
  * @Date 2024/5/6 14:34
  */
 @Service
-public class FinishTaskProcessHandler implements ClassProcess {
+public class StorageChangesProcessHandler implements ClassProcess {
 
     @Autowired
     private ISchBaseTaskService schBaseTaskService;
@@ -38,6 +40,10 @@ public class FinishTaskProcessHandler implements ClassProcess {
         from.put("status",param.getString("status"));
         from.put("update_time",DateUtil.now());
         from.put("update_name",SecurityUtils.getCurrentNickName());
+        String vehicle_code = from.getString("vehicle_code");
+        if (StringUtils.isEmpty(vehicle_code)){
+            throw new BadRequestException("库存变动失败：请求参数载具编码不能为空");
+        }
         SchBaseTask schBaseTask = from.toJavaObject(SchBaseTask.class);
         schBaseTaskService.updateById(schBaseTask);