修改目录结构

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

@@ -15,6 +15,7 @@ import com.fs.company.mapper.CompanyWorkflowNodeMapper;
 import com.fs.company.param.ExecutionContext;
 import com.fs.company.service.CompanyWorkflowEngine;
 import com.fs.company.service.IWorkflowNode;
+import com.fs.company.service.impl.call.node.WorkflowNodeFactory;
 import com.fs.company.vo.ExecutionResult;
 import com.fs.enums.ExecutionStatusEnum;
 import com.fs.enums.NodeTypeEnum;

fs-service/src/main/java/com/fs/company/service/impl/AbstractWorkflowNode.java → fs-service/src/main/java/com/fs/company/service/impl/call/node/AbstractWorkflowNode.java

@@ -1,4 +1,4 @@
-package com.fs.company.service.impl;
+package com.fs.company.service.impl.call.node;
 
 import com.fs.company.domain.CompanyAiWorkflowExec;
 import com.fs.company.domain.CompanyWorkflowEdge;

fs-service/src/main/java/com/fs/company/service/impl/AiAddWxTaskNode.java → fs-service/src/main/java/com/fs/company/service/impl/call/node/AiAddWxTaskNode.java

@@ -1,17 +1,15 @@
-package com.fs.company.service.impl;
+package com.fs.company.service.impl.call.node;
 
 import com.fs.company.domain.CompanyAiWorkflowExec;
 import com.fs.company.domain.CompanyWorkflowEdge;
 import com.fs.company.mapper.CompanyWorkflowNodeMapper;
 import com.fs.company.param.ExecutionContext;
 import com.fs.company.service.HasCompanyWorkflowNodeMapper;
-import com.fs.company.vo.AddWxWorkflowConditionVo;
 import com.fs.company.vo.ExecutionResult;
 import com.fs.enums.NodeTypeEnum;
 
 import java.util.List;
 import java.util.Map;
-import java.util.Random;
 
 /**
  * @author MixLiu

fs-service/src/main/java/com/fs/company/service/impl/AiCallTaskNode.java → fs-service/src/main/java/com/fs/company/service/impl/call/node/AiCallTaskNode.java

@@ -1,4 +1,4 @@
-package com.fs.company.service.impl;
+package com.fs.company.service.impl.call.node;
 
 import com.fs.company.mapper.CompanyWorkflowNodeMapper;
 import com.fs.company.param.ExecutionContext;

fs-service/src/main/java/com/fs/company/service/impl/AiSendMsgTaskNode.java → fs-service/src/main/java/com/fs/company/service/impl/call/node/AiSendMsgTaskNode.java

@@ -1,4 +1,4 @@
-package com.fs.company.service.impl;
+package com.fs.company.service.impl.call.node;
 
 import com.fs.company.mapper.CompanyWorkflowNodeMapper;
 import com.fs.company.param.ExecutionContext;

fs-service/src/main/java/com/fs/company/service/impl/ConditionNode.java → fs-service/src/main/java/com/fs/company/service/impl/call/node/ConditionNode.java

@@ -1,4 +1,4 @@
-package com.fs.company.service.impl;
+package com.fs.company.service.impl.call.node;
 
 import com.fs.company.param.ExecutionContext;
 import com.fs.company.vo.ExecutionResult;
@@ -11,7 +11,7 @@ import java.util.Map;
  * @date 2026/1/28 10:59
  * @description 开始节点
  */
-public class ConditionNode extends AbstractWorkflowNode{
+public class ConditionNode extends AbstractWorkflowNode {
 
     public ConditionNode(String nodeKey, String nodeName, Map<String, Object> properties) {
         super(nodeKey, nodeName, properties);

fs-service/src/main/java/com/fs/company/service/impl/DelayNode.java → fs-service/src/main/java/com/fs/company/service/impl/call/node/DelayNode.java

@@ -1,4 +1,4 @@
-package com.fs.company.service.impl;
+package com.fs.company.service.impl.call.node;
 
 import com.fs.common.core.redis.RedisCache;
 import com.fs.company.mapper.CompanyWorkflowNodeMapper;

fs-service/src/main/java/com/fs/company/service/impl/EndNode.java → fs-service/src/main/java/com/fs/company/service/impl/call/node/EndNode.java

@@ -1,4 +1,4 @@
-package com.fs.company.service.impl;
+package com.fs.company.service.impl.call.node;
 
 import com.fs.company.mapper.CompanyWorkflowNodeMapper;
 import com.fs.company.param.ExecutionContext;

fs-service/src/main/java/com/fs/company/service/impl/OutBoundTaskNode.java → fs-service/src/main/java/com/fs/company/service/impl/call/node/OutBoundTaskNode.java

@@ -1,4 +1,4 @@
-package com.fs.company.service.impl;
+package com.fs.company.service.impl.call.node;
 
 import com.fs.company.mapper.CompanyWorkflowNodeMapper;
 import com.fs.company.param.ExecutionContext;

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

@@ -1,4 +1,4 @@
-package com.fs.company.service.impl;
+package com.fs.company.service.impl.call.node;
 
 import com.fs.company.mapper.CompanyWorkflowNodeMapper;
 import com.fs.company.param.ExecutionContext;

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

@@ -1,4 +1,4 @@
-package com.fs.company.service.impl;
+package com.fs.company.service.impl.call.node;
 
 import com.fs.common.core.redis.RedisCache;
 import com.fs.company.mapper.CompanyAiWorkflowExecLogMapper;