增加对任务流的和版本的查询

byit-myth-core/myth-admin-core/src/main/java/com/byit/dao/FlowVersionMapper.java

+package com.byit.dao;
+
+import com.byit.job.model.FlowVersion;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+/**
+ * @program: byit-myth-job->FlowVersionMapper
+ * @description: 工作流版本查询
+ * @author: huangfu
+ * @date: 2019/12/18 11:22
+ **/
+@Repository
+public interface FlowVersionMapper {
+
+    List<FlowVersion> findAllFlowVersion();
+}

byit-myth-core/myth-admin-core/src/main/java/com/byit/dao/MythJobFlowMapper.java

+package com.byit.dao;
+
+import com.byit.job.model.MythJobFlow;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+/**
+ * @program: byit-myth-job->MythJobFlowMapper
+ * @description: 工作流的查询
+ * @author: huangfu
+ * @date: 2019/12/18 11:21
+ **/
+@Repository
+public interface MythJobFlowMapper {
+
+    List<MythJobFlow> findAllMythJobFlowMapper();
+}

byit-myth-core/myth-admin-core/src/main/java/com/byit/service/FlowVersionService.java

+package com.byit.service;
+
+import com.byit.job.model.FlowVersion;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+/**
+ * @program: byit-myth-job->FlowVersionMapper
+ * @description: 工作流版本查询
+ * @author: huangfu
+ * @date: 2019/12/18 11:22
+ **/
+public interface FlowVersionService {
+    /**
+     * 查询所有的没有删除的工作流版本
+     * @return
+     */
+    List<FlowVersion> findAllFlowVersion();
+}

byit-myth-core/myth-admin-core/src/main/java/com/byit/service/MythJobFlowService.java

+package com.byit.service;
+
+import com.byit.job.model.MythJobFlow;
+
+import java.util.List;
+
+/**
+ * @program: byit-myth-job->MythJobFlowMapper
+ * @description: 工作流的查询
+ * @author: huangfu
+ * @date: 2019/12/18 11:21
+ **/
+public interface MythJobFlowService {
+
+    /**
+     * 查询所有的工作流
+     * @return return
+     */
+    List<MythJobFlow> findAllMythJobFlowMapper();
+}

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

+package com.byit.service.impl;
+
+import com.byit.dao.FlowVersionMapper;
+import com.byit.job.model.FlowVersion;
+import com.byit.service.FlowVersionService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @program: byit-myth-job->FlowVersionServiceImpl
+ * @description: 工作流版本
+ * @author: huangfu
+ * @date: 2019/12/18 13:44
+ **/
+@Service
+public class FlowVersionServiceImpl implements FlowVersionService {
+    private final FlowVersionMapper flowVersionMapper;
+
+    @Autowired
+    public FlowVersionServiceImpl(FlowVersionMapper flowVersionMapper) {
+        this.flowVersionMapper = flowVersionMapper;
+    }
+
+    @Override
+    public List<FlowVersion> findAllFlowVersion() {
+        return flowVersionMapper.findAllFlowVersion();
+    }
+}

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

@@ -16,8 +16,12 @@ import java.util.List;
  **/
 @Service
 public class JobFlightScheduleServiceImpl implements JobFlightScheduleService {
+    private final JobFlightScheduleMapper jobFlightScheduleMapper;
+
     @Autowired
-    private JobFlightScheduleMapper jobFlightScheduleMapper;
+    public JobFlightScheduleServiceImpl(JobFlightScheduleMapper jobFlightScheduleMapper) {
+        this.jobFlightScheduleMapper = jobFlightScheduleMapper;
+    }
 
 
     @Override

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

@@ -18,8 +18,12 @@ import java.util.List;
  **/
 @Service
 public class JobLogServiceImpl implements JobLogService {
+    private final JobLogMapper jobLogMapper;
+
     @Autowired
-    private JobLogMapper jobLogMapper;
+    public JobLogServiceImpl(JobLogMapper jobLogMapper) {
+        this.jobLogMapper = jobLogMapper;
+    }
 
     @Override
     public List<MythJobLog> findUndoneMythJobLogByParenIdAndInRunId(String runId, List<String> parenIds) {

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

@@ -19,8 +19,13 @@ import java.util.List;
 @Slf4j
 public class JobReadAheadServiceImpl implements JobReadAheadService {
 
+    private final JobInfoMapper jobInfoMapper;
+
     @Autowired
-    private JobInfoMapper jobInfoMapper;
+    public JobReadAheadServiceImpl(JobInfoMapper jobInfoMapper) {
+        this.jobInfoMapper = jobInfoMapper;
+    }
+
     @Override
     public List<MythJobReadAhead> findMythJobReadAheadByTriggerNextTime(long maxNextTime) {
         return jobInfoMapper.findMythJobReadAheadByTriggerNextTime(maxNextTime);

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

+package com.byit.service.impl;
+
+import com.byit.dao.MythJobFlowMapper;
+import com.byit.job.model.MythJobFlow;
+import com.byit.service.MythJobFlowService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @program: byit-myth-job->MythJobFlowServiceImpl
+ * @description: 工作流操作
+ * @author: huangfu
+ * @date: 2019/12/18 13:45
+ **/
+@Service
+public class MythJobFlowServiceImpl implements MythJobFlowService {
+    private final MythJobFlowMapper mythJobFlowMapper;
+
+    @Autowired
+    public MythJobFlowServiceImpl(MythJobFlowMapper mythJobFlowMapper) {
+        this.mythJobFlowMapper = mythJobFlowMapper;
+    }
+
+    @Override
+    public List<MythJobFlow> findAllMythJobFlowMapper() {
+        return mythJobFlowMapper.findAllMythJobFlowMapper();
+    }
+}

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

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
+<mapper namespace="com.byit.dao.FlowVersionMapper">
+    <sql id="Base_Column_List">
+        t.id,
+        t.version_name,
+        t.node_count,
+        t.flow_desc,
+        t.add_time,
+        t.version_sign,
+        t.flow_id,
+        t.timeout,
+        t.trigger_next_time,
+        t.repeat_count,
+        t.remaining_count,
+        t.alarm_email,
+        t.node_follow,
+        t.remove_mark
+    </sql>
+
+    <resultMap id="MythJobFlowVersion" type="com.byit.job.model.FlowVersion">
+        <id column="id" property="id"/>
+        <result column="version_name" property="versionName"/>
+        <result column="node_count" property="nodeCount"/>
+        <result column="flow_desc" property="flowDesc"/>
+        <result column="add_time" property="addTime"/>
+        <result column="version_sign" property="versionSign"/>
+        <result column="flow_id" property="flowId"/>
+        <result column="timeout" property="timeout"/>
+        <result column="trigger_next_time" property="triggerNextTime"/>
+        <result column="repeat_count" property="repeatCount"/>
+        <result column="remaining_count" property="remainingCount"/>
+        <result column="alarm_email" property="alarmEmail"/>
+        <result column="node_follow" property="nodeFollow"/>
+        <result column="remove_mark" property="removeMark"/>
+    </resultMap>
+
+    <select id="findAllFlowVersion" resultMap="MythJobFlowVersion">
+        SELECT <include refid="Base_Column_List"/> from flow_version t
+        WHERE remove_mark = '1'
+    </select>
+</mapper>
\ No newline at end of file

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

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
+<mapper namespace="com.byit.dao.MythJobFlowMapper">
+    <sql id="Base_Column_List">
+        t.id,
+        t.flow_name,
+        t.add_time,
+        t.update_time,
+        t.remove_mark
+    </sql>
+
+    <resultMap id="JobFlow" type="com.byit.job.model.MythJobFlow">
+        <id column="id" property="id"/>
+        <result column="flow_name" property="flowName"/>
+        <result column="add_time" property="addTime"/>
+        <result column="update_time" property="updateTime"/>
+        <result column="remove_mark" property="removeMark"/>
+    </resultMap>
+
+    <select id="findAllMythJobFlowMapper" resultMap="JobFlow">
+        SELECT <include refid="Base_Column_List"/> FROM job_flow t
+        WHERE remove_mark = '1'
+    </select>
+</mapper>
\ No newline at end of file

byit-myth-core/myth-core-common/src/main/java/com/byit/job/model/FlowVersion.java

@@ -62,4 +62,12 @@ public class FlowVersion {
      * 报警邮箱
      */
     private String alarmEmail;
+    /**
+     * 节点是否跟随任务流时间  1跟随  2不跟随
+      */
+    private String nodeFollow;
+    /**
+     * 删除标志
+     */
+    private String removeMark;
 }

byit-myth-core/myth-core-common/src/main/java/com/byit/job/model/MythJobFlow.java

@@ -17,8 +17,20 @@ import java.util.Date;
 @EqualsAndHashCode
 public class MythJobFlow {
     private String id;
+    /**
+     * 任务流名称
+     */
     private String flowName;
+    /**
+     * 修改时间
+     */
     private Date updateTime;
+    /**
+     * 添加时间
+     */
     private Date addTime;
+    /**
+     * 删除标志
+     */
     private String removeMark;
 }