Ver código fonte

修改目录结构

吴树波 3 semanas atrás
pai
commit
478f43e91b

+ 23 - 0
fs-service/src/main/java/com/fs/company/service/impl/call/node/AiAddWxTaskNode.java

@@ -2,6 +2,10 @@ package com.fs.company.service.impl.call.node;
 
 import com.fs.company.domain.CompanyAiWorkflowExec;
 import com.fs.company.domain.CompanyWorkflowEdge;
+import com.fs.company.domain.CompanyWorkflowNode;
+import com.fs.company.mapper.CompanyAiWorkflowExecLogMapper;
+import com.fs.company.mapper.CompanyAiWorkflowExecMapper;
+import com.fs.company.mapper.CompanyWorkflowEdgeMapper;
 import com.fs.company.mapper.CompanyWorkflowNodeMapper;
 import com.fs.company.param.ExecutionContext;
 import com.fs.company.service.HasCompanyWorkflowNodeMapper;
@@ -19,18 +23,37 @@ import java.util.Map;
 public class AiAddWxTaskNode extends AbstractWorkflowNode implements HasCompanyWorkflowNodeMapper {
 
     private CompanyWorkflowNodeMapper companyWorkflowNodeMapper;
+    private CompanyAiWorkflowExecMapper companyAiWorkflowExecMapper;
+    private CompanyAiWorkflowExecLogMapper companyAiWorkflowExecLogMapper;
+    private CompanyWorkflowEdgeMapper companyWorkflowEdgeMapper;
 
     @Override
     public void setCompanyWorkflowNodeMapper(CompanyWorkflowNodeMapper mapper) {
         this.companyWorkflowNodeMapper = mapper;
     }
 
+    @Override
+    public void setCompanyAiWorkflowExecMapper(CompanyAiWorkflowExecMapper companyAiWorkflowExecMapper) {
+        this.companyAiWorkflowExecMapper = companyAiWorkflowExecMapper;
+    }
+
+    @Override
+    public void setCompanyAiWorkflowExecLogMapper(CompanyAiWorkflowExecLogMapper companyAiWorkflowExecLogMapper) {
+        this.companyAiWorkflowExecLogMapper = companyAiWorkflowExecLogMapper;
+    }
+
+    @Override
+    public void setCompanyWorkflowEdgeMapper(CompanyWorkflowEdgeMapper companyWorkflowEdgeMapper) {
+        this.companyWorkflowEdgeMapper = companyWorkflowEdgeMapper;
+    }
+
     public AiAddWxTaskNode(String nodeKey, String nodeName, Map<String, Object> properties) {
         super(nodeKey, nodeName, properties);
     }
 
     @Override
     protected ExecutionResult doExecute(ExecutionContext context) {
+        CompanyWorkflowNode node = companyWorkflowNodeMapper.selectById(context.getCurrentNodeId());
 
         return null;
     }