cid

fs-service/src/main/java/com/fs/company/domain/CompanyWorkflowEdge.java

@@ -1,6 +1,7 @@
 package com.fs.company.domain;
 
 import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fs.common.core.domain.BaseEntity;
 import lombok.Data;
 
 import java.io.Serializable;

fs-service/src/main/java/com/fs/company/domain/CompanyWorkflowNode.java

@@ -13,7 +13,7 @@ import java.util.Date;
  * @date 2026-01-06
  */
 @Data
-public class CompanyWorkflowNode implements Serializable {
+public class CompanyWorkflowNode  implements Serializable {
     private static final long serialVersionUID = 1L;
 
     /** 节点ID */

fs-service/src/main/java/com/fs/company/mapper/CompanyWorkflowEdgeMapper.java

@@ -1,6 +1,8 @@
 package com.fs.company.mapper;
 
 
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.fs.company.domain.CompanyVoiceRobotic;
 import com.fs.company.domain.CompanyWorkflowEdge;
 
 import java.util.List;
@@ -11,7 +13,7 @@ import java.util.List;
  * @author fs
  * @date 2026-01-06
  */
-public interface CompanyWorkflowEdgeMapper {
+public interface CompanyWorkflowEdgeMapper  extends BaseMapper<CompanyWorkflowEdge> {
 
     CompanyWorkflowEdge selectCompanyWorkflowEdgeById(Long edgeId);
 

fs-service/src/main/java/com/fs/company/mapper/CompanyWorkflowMapper.java

@@ -1,7 +1,9 @@
 package com.fs.company.mapper;
 
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.fs.company.domain.CompanyUser;
 import com.fs.company.domain.CompanyWorkflow;
+import com.fs.company.domain.CompanyWorkflowEdge;
 import com.fs.company.domain.CompanyWorkflowNode;
 import com.fs.company.vo.CompanyWorkflowNodeVoiceVo;
 import org.apache.ibatis.annotations.Param;
@@ -14,7 +16,7 @@ import java.util.List;
  * @author fs
  * @date 2026-01-06
  */
-public interface CompanyWorkflowMapper {
+public interface CompanyWorkflowMapper extends BaseMapper<CompanyWorkflow>  {
 
     CompanyWorkflow selectCompanyWorkflowById(Long workflowId);
 

fs-service/src/main/java/com/fs/company/service/impl/ActionNode.java

@@ -1,40 +0,0 @@
-package com.fs.company.service.impl;
-
-import com.fs.company.mapper.CompanyWorkflowNodeMapper;
-import com.fs.company.param.ExecutionContext;
-import com.fs.company.service.HasCompanyWorkflowNodeMapper;
-import com.fs.company.vo.ExecutionResult;
-import com.fs.enums.NodeTypeEnum;
-
-import java.util.Map;
-
-/**
- * @author MixLiu
- * @date 2026/1/28 10:59
- * @description
- */
-public class ActionNode extends AbstractWorkflowNode implements HasCompanyWorkflowNodeMapper {
-
-    private CompanyWorkflowNodeMapper companyWorkflowNodeMapper;
-
-    @Override
-    public void setCompanyWorkflowNodeMapper(CompanyWorkflowNodeMapper mapper) {
-        this.companyWorkflowNodeMapper = mapper;
-    }
-
-    public ActionNode(String nodeKey, String nodeName, Map<String, Object> properties) {
-        super(nodeKey, nodeName, properties);
-    }
-
-    @Override
-    public ExecutionResult doExecute(ExecutionContext context) {
-        return null;
-    }
-
-    @Override
-    public NodeTypeEnum getType() {
-        return NodeTypeEnum.ACTION;
-    }
-
-
-}

fs-service/src/main/java/com/fs/company/service/impl/AiAnalysisNode.java

@@ -1,36 +0,0 @@
-package com.fs.company.service.impl;
-
-import com.fs.company.mapper.CompanyWorkflowNodeMapper;
-import com.fs.company.param.ExecutionContext;
-import com.fs.company.service.HasCompanyWorkflowNodeMapper;
-import com.fs.company.vo.ExecutionResult;
-import com.fs.enums.NodeTypeEnum;
-
-import java.util.Map;
-
-/**
- * @author MixLiu
- * @date 2026/1/28 10:59
- * @description
- */
-public class AiAnalysisNode extends AbstractWorkflowNode implements HasCompanyWorkflowNodeMapper {
-    private CompanyWorkflowNodeMapper companyWorkflowNodeMapper;
-
-    @Override
-    public void setCompanyWorkflowNodeMapper(CompanyWorkflowNodeMapper mapper) {
-        this.companyWorkflowNodeMapper = mapper;
-    }
-    public AiAnalysisNode(String nodeKey, String nodeName, Map<String, Object> properties) {
-        super(nodeKey, nodeName, properties);
-    }
-
-    @Override
-    public ExecutionResult doExecute(ExecutionContext context) {
-        return null;
-    }
-
-    @Override
-    public NodeTypeEnum getType() {
-        return NodeTypeEnum.AI_ANALYSIS;
-    }
-}

fs-service/src/main/java/com/fs/company/service/impl/AiDialogNode.java

@@ -1,36 +0,0 @@
-package com.fs.company.service.impl;
-
-import com.fs.company.mapper.CompanyWorkflowNodeMapper;
-import com.fs.company.param.ExecutionContext;
-import com.fs.company.service.HasCompanyWorkflowNodeMapper;
-import com.fs.company.vo.ExecutionResult;
-import com.fs.enums.NodeTypeEnum;
-
-import java.util.Map;
-
-/**
- * @author MixLiu
- * @date 2026/1/28 10:59
- * @description
- */
-public class AiDialogNode extends AbstractWorkflowNode implements HasCompanyWorkflowNodeMapper {
-    private CompanyWorkflowNodeMapper companyWorkflowNodeMapper;
-
-    @Override
-    public void setCompanyWorkflowNodeMapper(CompanyWorkflowNodeMapper mapper) {
-        this.companyWorkflowNodeMapper = mapper;
-    }
-    public AiDialogNode(String nodeKey, String nodeName, Map<String, Object> properties) {
-        super(nodeKey, nodeName, properties);
-    }
-
-    @Override
-    public ExecutionResult doExecute(ExecutionContext context) {
-        return null;
-    }
-
-    @Override
-    public NodeTypeEnum getType() {
-        return NodeTypeEnum.AI_DIALOG;
-    }
-}

fs-service/src/main/java/com/fs/company/service/impl/HttpRequestNode.java

@@ -1,35 +0,0 @@
-package com.fs.company.service.impl;
-
-import com.fs.company.mapper.CompanyWorkflowNodeMapper;
-import com.fs.company.param.ExecutionContext;
-import com.fs.company.service.HasCompanyWorkflowNodeMapper;
-import com.fs.company.vo.ExecutionResult;
-import com.fs.enums.NodeTypeEnum;
-
-import java.util.Map;
-
-/**
- * @author MixLiu
- * @date 2026/1/28 10:59
- * @description
- */
-public class HttpRequestNode extends AbstractWorkflowNode implements HasCompanyWorkflowNodeMapper {
-    private CompanyWorkflowNodeMapper companyWorkflowNodeMapper;
-    @Override
-    public void setCompanyWorkflowNodeMapper(CompanyWorkflowNodeMapper mapper) {
-        this.companyWorkflowNodeMapper = mapper;
-    }
-    public HttpRequestNode(String nodeKey, String nodeName, Map<String, Object> properties) {
-        super(nodeKey, nodeName, properties);
-    }
-
-    @Override
-    public ExecutionResult doExecute(ExecutionContext context) {
-        return null;
-    }
-
-    @Override
-    public NodeTypeEnum getType() {
-        return NodeTypeEnum.HTTP_REQUEST;
-    }
-}

fs-service/src/main/java/com/fs/company/service/impl/MessageNotificationNode.java

@@ -1,35 +0,0 @@
-package com.fs.company.service.impl;
-
-import com.fs.company.mapper.CompanyWorkflowNodeMapper;
-import com.fs.company.param.ExecutionContext;
-import com.fs.company.service.HasCompanyWorkflowNodeMapper;
-import com.fs.company.vo.ExecutionResult;
-import com.fs.enums.NodeTypeEnum;
-
-import java.util.Map;
-
-/**
- * @author MixLiu
- * @date 2026/1/28 10:59
- * @description
- */
-public class MessageNotificationNode extends AbstractWorkflowNode implements HasCompanyWorkflowNodeMapper {
-    private CompanyWorkflowNodeMapper companyWorkflowNodeMapper;
-    @Override
-    public void setCompanyWorkflowNodeMapper(CompanyWorkflowNodeMapper mapper) {
-        this.companyWorkflowNodeMapper = mapper;
-    }
-    public MessageNotificationNode(String nodeKey, String nodeName, Map<String, Object> properties) {
-        super(nodeKey, nodeName, properties);
-    }
-
-    @Override
-    public ExecutionResult doExecute(ExecutionContext context) {
-        return null;
-    }
-
-    @Override
-    public NodeTypeEnum getType() {
-        return NodeTypeEnum.MESSAGE_NOTIFICATION;
-    }
-}

fs-service/src/main/java/com/fs/company/service/impl/StartNode.java

@@ -32,4 +32,9 @@ public class StartNode extends AbstractWorkflowNode implements HasCompanyWorkflo
     public NodeTypeEnum getType() {
         return NodeTypeEnum.START;
     }
+
+    @Override
+    protected void preExecute(ExecutionContext context){
+        super.preExecute(context);
+    }
 }

fs-service/src/main/java/com/fs/company/service/impl/WorkflowNodeFactory.java

@@ -36,18 +36,9 @@ public class WorkflowNodeFactory implements IWorkflowNodeFactory {
             case CONDITION:
                 node = new ConditionNode(nodeKey, nodeName, properties);
                 break;
-            case ACTION:
-                node = new ActionNode(nodeKey, nodeName, properties);
-                break;
             case END:
                 node = new EndNode(nodeKey, nodeName, properties);
                 break;
-            case AI_DIALOG:
-                node = new AiDialogNode(nodeKey, nodeName, properties);
-                break;
-            case AI_ANALYSIS:
-                node = new AiAnalysisNode(nodeKey, nodeName, properties);
-                break;
             case AI_CALL_TASK:
                 node = new AiCallTaskNode(nodeKey, nodeName, properties);
                 break;
@@ -57,18 +48,9 @@ public class WorkflowNodeFactory implements IWorkflowNodeFactory {
             case AI_ADD_WX_TASK:
                 node = new AiAddWxTaskNode(nodeKey, nodeName, properties);
                 break;
-            case HTTP_REQUEST:
-                node = new HttpRequestNode(nodeKey, nodeName, properties);
-                break;
-            case MESSAGE_NOTIFICATION:
-                node = new MessageNotificationNode(nodeKey, nodeName, properties);
-                break;
             case OUTBOUND_TASK:
                 node = new OutBoundTaskNode(nodeKey, nodeName, properties);
                 break;
-            case VARIABLE_SET:
-                node = new VariableSetNode(nodeKey, nodeName, properties);
-                break;
             case DELAY:
                 node = new DelayNode(nodeKey, nodeName, properties);
                 break;