构建故障流程

kgraph-graph/src/main/java/com/kgraph/graph/suport/domain/TBuildFlow.java

@@ -22,7 +22,7 @@ public class TBuildFlow extends BaseEntity
 
     /** 子任务id */
     @Excel(name = "子任务id")
-    private String subTaskId;
+    private Long subTaskId;
 
     /** 故障编码 */
     @Excel(name = "故障名称")

kgraph-graph/src/main/java/com/kgraph/graph/suport/service/impl/TBuildFlowServiceImpl.java

@@ -1,14 +1,17 @@
 package com.kgraph.graph.suport.service.impl;
 
+import java.util.Date;
 import java.util.List;
 import java.util.Map;
 
 import com.kgraph.common.utils.DateUtils;
+import com.kgraph.graph.suport.mapper.BuildEntityRelationMapper;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import com.kgraph.graph.suport.mapper.TBuildFlowMapper;
 import com.kgraph.graph.suport.domain.TBuildFlow;
 import com.kgraph.graph.suport.service.ITBuildFlowService;
+import com.kgraph.graph.suport.mapper.ExtractKnowledgeSubTaskMapper;
 
 /**
  * 构建流程Service业务层处理
@@ -22,6 +25,9 @@ public class TBuildFlowServiceImpl implements ITBuildFlowService
     @Autowired
     private TBuildFlowMapper tBuildFlowMapper;
 
+    @Autowired
+    private ExtractKnowledgeSubTaskMapper extractKnowledgeSubTaskMapper;
+
     /**
      * 查询构建流程
      * 
@@ -56,6 +62,12 @@ public class TBuildFlowServiceImpl implements ITBuildFlowService
     public int insertTBuildFlow(TBuildFlow tBuildFlow)
     {
         tBuildFlow.setCreateTime(DateUtils.getNowDate());
+        if(tBuildFlow.getSubTaskId() != null) {
+            // 更新子任务状态
+            extractKnowledgeSubTaskMapper.updateSubTaskStatusById(tBuildFlow.getSubTaskId(), "3", null, new Date());
+            // 更新任务状态
+            extractKnowledgeSubTaskMapper.updateTaskStatusBySubTaskId(tBuildFlow.getSubTaskId());
+        }
         return tBuildFlowMapper.insertTBuildFlow(tBuildFlow);
     }
 
@@ -69,6 +81,12 @@ public class TBuildFlowServiceImpl implements ITBuildFlowService
     public int updateTBuildFlow(TBuildFlow tBuildFlow)
     {
         tBuildFlow.setUpdateTime(DateUtils.getNowDate());
+        if(tBuildFlow.getSubTaskId() != null) {
+            // 更新子任务状态
+            extractKnowledgeSubTaskMapper.updateSubTaskStatusById(tBuildFlow.getSubTaskId(), "3", null, new Date());
+            // 更新任务状态
+            extractKnowledgeSubTaskMapper.updateTaskStatusBySubTaskId(tBuildFlow.getSubTaskId());
+        }
         return tBuildFlowMapper.updateTBuildFlow(tBuildFlow);
     }
 

kgraph-graph/src/main/resources/mapper/suport/TBuildFlowMapper.xml

@@ -64,8 +64,8 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     <update id="updateTBuildFlow" parameterType="TBuildFlow">
         update t_build_flow
         <trim prefix="SET" suffixOverrides=",">
-            <if test="subTaskId != null">#{subTaskId},</if>
-            <if test="errorAppearance != null">#{errorAppearance},</if>
+            <if test="subTaskId != null">sub_task_id = #{subTaskId},</if>
+            <if test="errorAppearance != null">error_appearance = #{errorAppearance},</if>
             <if test="errorCode != null">error_code = #{errorCode},</if>
             <if test="flowEncode != null">flow_encode = #{flowEncode},</if>
             <if test="flowTreeJson != null">flow_tree_json = #{flowTreeJson},</if>