置成功

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

@@ -766,7 +766,8 @@ public class ApiFlowServiceImpl implements ApiFlowService {
         //Flow flow = flowMapper.getByWorkSpaceAndName(workspace.getWorkspaceId(), runInfo.getFlowName());
         ValidationUtil.dataNotNull(byWorkSpaceAndName, runInfo.getFlowName() + "工作流不存在");
 
-        Node node = nodeMapper.getByNameAndFlow(runInfo.getNodeName(), byWorkSpaceAndName.getFlowId());
+        NodeVersion node = nodeVersionMapper.getByNameAndFlow(runInfo.getNodeName(), byWorkSpaceAndName.getFlowVersionId());
+
         ValidationUtil.dataNotNull(node, runInfo.getNodeName() + "节点不存在");
         //获取运行日志实例
         JobTaskRunLog jobTaskRunLog = jobTaskRunLogMapper.findByRunIdAndNodeId(runInfo.getRunId(), node.getNodeId());

byit-myth-core/myth-admin-core/src/main/java/com/byit/mapper/NodeVersionMapper.java

 package com.byit.mapper;
 
+import com.byit.model.Node;
 import com.byit.model.NodeVersion;
 import org.apache.ibatis.annotations.Param;
 import org.springframework.stereotype.Repository;
@@ -28,6 +29,8 @@ public interface NodeVersionMapper {
 
     NodeVersion getById(Integer nodeVersionId);
 
+    NodeVersion getByNameAndFlow(@Param("nodeName") String nodeName, @Param("flowVersionId") Integer flowVersionId);
+
     int updateByIdSelective(NodeVersion record);
 
     /**

byit-myth-core/myth-admin-core/src/main/resources/mapper/NodeVersionMapper.xml

@@ -97,6 +97,16 @@
     </select>
 
 
+    <select id="getByNameAndFlow" resultMap="ResultMapWithBLOBs">
+      select
+      <include refid="Base_Column_List" />
+      ,
+      <include refid="Blob_Column_List" />
+      from node_version
+      where node_name = #{nodeName} and flow_version_id = #{flowVersionId}
+    </select>
+
+
     <delete id="deleteById" parameterType="java.lang.Integer">
     <!-- generated @mbg.generated date: 2019-12-31 -->
     delete from node_version