diff --git a/src/main/java/neatlogic/framework/autoexec/constvalue/AutoexecJobPhaseNodeErrorType.java b/src/main/java/neatlogic/framework/autoexec/constvalue/AutoexecJobPhaseNodeErrorType.java
new file mode 100644
index 0000000000000000000000000000000000000000..00dc14bca9fa4177462e86cccfa41599f420f685
--- /dev/null
+++ b/src/main/java/neatlogic/framework/autoexec/constvalue/AutoexecJobPhaseNodeErrorType.java
@@ -0,0 +1,52 @@
+/*
+ * Copyright (C) 2024  深圳极向量科技有限公司 All Rights Reserved.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+
+package neatlogic.framework.autoexec.constvalue;
+
+import neatlogic.framework.util.$;
+
+public enum AutoexecJobPhaseNodeErrorType{
+    IP_INVALID(1,"ip不合法"),
+    RUNNER_NOT_MATCH(2,"根据ip找不到匹配的runner，请核对runner组配置")
+    ;
+
+    private final int value;
+    private final String text;
+
+    AutoexecJobPhaseNodeErrorType(int value, String text) {
+        this.value = value;
+        this.text = text;
+    }
+
+
+    public Integer getValue() {
+        return value;
+    }
+
+    public static AutoexecJobPhaseNodeErrorType getErrorType(int value){
+        for (AutoexecJobPhaseNodeErrorType errorType : AutoexecJobPhaseNodeErrorType.values()){
+            if(errorType.getValue() == value){
+                return errorType;
+            }
+        }
+        return null;
+    }
+
+    public String getText() {
+        return $.t(text);
+    }
+}
diff --git a/src/main/java/neatlogic/framework/autoexec/constvalue/JobNodeStatus.java b/src/main/java/neatlogic/framework/autoexec/constvalue/JobNodeStatus.java
index 5c179d8a840dfffec7b8e95842816ded05a7b9f0..26baea7a1a0e907f446956641931c0e689c6466b 100755
--- a/src/main/java/neatlogic/framework/autoexec/constvalue/JobNodeStatus.java
+++ b/src/main/java/neatlogic/framework/autoexec/constvalue/JobNodeStatus.java
@@ -17,7 +17,8 @@ public enum JobNodeStatus implements IEnum {
     SUCCEED("succeed", "已成功"),
     FAILED("failed", "已失败"),
     IGNORED("ignored", "已忽略"),
-    WAIT_INPUT("waitInput", "待输入");
+    WAIT_INPUT("waitInput", "待输入"),
+    INVALID("invalid", "非法节点");
     private final String status;
     private final String text;
 
diff --git a/src/main/java/neatlogic/framework/autoexec/dao/mapper/AutoexecJobMapper.java b/src/main/java/neatlogic/framework/autoexec/dao/mapper/AutoexecJobMapper.java
index 3355463c0571cd4b050734cdbfd972807f19536e..5baf7dbd43bdf8861e3d82a19211c02b8a296d38 100644
--- a/src/main/java/neatlogic/framework/autoexec/dao/mapper/AutoexecJobMapper.java
+++ b/src/main/java/neatlogic/framework/autoexec/dao/mapper/AutoexecJobMapper.java
@@ -133,16 +133,12 @@ public interface AutoexecJobMapper {
 
     List<AutoexecJobPhaseNodeVo> getJobPhaseNodeIdListByNodeVoAndStartNum(@Param("nodeVo") AutoexecJobPhaseNodeVo jobPhaseNodeVo, @Param("startNum") Integer startNum);
 
-    int searchJobPhaseNodeCountWithResource(AutoexecJobPhaseNodeVo jobPhaseNodeVo);
-
     int searchJobPhaseNodeCount(AutoexecJobPhaseNodeVo jobPhaseNodeVo);
 
     int searchJobPhaseNodeByDistinctResourceIdCount(AutoexecJobPhaseNodeVo jobPhaseNodeVo);
 
     List<AutoexecJobPhaseNodeStatusCountVo> getJobPhaseNodeStatusCount(Long jobId);
 
-    int checkIsJobPhaseNodeExist(AutoexecJobPhaseNodeVo nodeVo);
-
     List<CustomTemplateVo> getJobPhaseOperationCustomTemplateListByJobPhaseId(Long jobPhaseId);
 
     List<Long> getJobPhaseOpertionIdListByJobPhaseId(Long jobPhaseId);
@@ -154,8 +150,6 @@ public interface AutoexecJobMapper {
 
     int updateJobPhaseNodeStatus(AutoexecJobPhaseNodeVo nodeVo);
 
-    int updateJobPhaseNodeStatusByJobIdAndJobPhaseIdListAndRunnerId(@Param("jobId") Long jobId, @Param("jobPhaseIdList") List<Long> jobPhaseIdList, @Param("nodeStatusList") List<String> jobNodeStatusList, @Param("runnerId") Long runnerId);
-
     int searchJobPhaseSqlCount(AutoexecJobPhaseNodeVo jobPhaseNodeVo);
 
     AutoexecJobPhaseNodeVo getJobPhaseNodeInfoByJobNodeId(@Param("nodeId") Long nodeId);
@@ -168,7 +162,7 @@ public interface AutoexecJobMapper {
 
     List<AutoexecJobPhaseNodeVo> getJobPhaseNodeListByJobIdAndPhaseNameAndExceptStatusAndRunnerId(@Param("jobId") Long jobId, @Param("phaseName") String phaseName, @Param("exceptStatus") List<String> exceptStatus, @Param("runnerId") Long runnerId);
 
-    List<AutoexecJobPhaseNodeVo> getJobPhaseNodeListByJobIdAndPhaseIdAndExceptStatus(@Param("jobId") Long jobId, @Param("phaseId") Long phaseId, @Param("exceptStatus") List<String> exceptStatus);
+    List<AutoexecJobPhaseNodeVo> getJobPhaseNodeListByJobIdAndPhaseIdAndExceptStatus(@Param("phaseId") Long phaseId, @Param("exceptStatus") List<String> exceptStatus);
 
     List<AutoexecJobPhaseNodeVo> getJobPhaseNodeListByJobIdAndPhaseIdAndExceptStatusAndRunnerMapId(@Param("jobId") Long jobId, @Param("phaseId") Long phaseId, @Param("exceptStatus") List<String> exceptStatus, @Param("runnerMapId") Long runnerMapId);
 
@@ -309,10 +303,6 @@ public interface AutoexecJobMapper {
 
     int insertJobInvoke(AutoexecJobInvokeVo invokeVo);
 
-    Integer insertIgnoreJobPhaseNodeRunner(AutoexecJobPhaseNodeRunnerVo nodeRunnerVo);
-    
-    Integer batchInsertJobPhaseNodeRunner(List<AutoexecJobPhaseNodeRunnerVo> nodeRunnerVo);
-
     Integer insertJobPhaseRunner(@Param("jobId") Long jobId, @Param("jobGroupId") Long jobGroupId, @Param("jobPhaseId") Long jobPhaseId, @Param("runnerMapId") Long runnerMapId, @Param("lcd") Date lcd);
 
     Integer insertJob(AutoexecJobVo jobVo);
@@ -325,6 +315,10 @@ public interface AutoexecJobMapper {
 
     Integer batchInsertJobPhaseNode(List<AutoexecJobPhaseNodeVo> nodeList);
 
+    Integer batchInsertIgnoreJobPhaseNode(List<AutoexecJobPhaseNodeVo> nodeList);
+
+    Integer batchInsertDuplicateJobPhaseNode(List<AutoexecJobPhaseNodeVo> nodeList);
+
     Integer insertJobPhaseOperation(AutoexecJobPhaseOperationVo operationVo);
 
     Integer insertIgnoreJobContent(AutoexecJobContentVo contentVo);
@@ -337,8 +331,6 @@ public interface AutoexecJobMapper {
 
     Integer updateJobPhaseStatusByJobIdAndPhaseStatus(@Param("jobId") Long jobId, @Param("whereStatus") String whereStatus, @Param("status") String status);
 
-    Integer updateJobPhaseNodeStatusByJobIdAndIsDelete(@Param("jobId") Long id, @Param("status") String status, @Param("isDelete") Integer isDelete);
-
     Integer updateJobPhaseNodeStatusByJobPhaseIdAndIsDelete(@Param("jobPhaseId") Long id, @Param("status") String status, @Param("isDelete") Integer isDelete);
 
     Integer updateJobPhaseRunnerStatusBatch(@Param("phaseIdList") List<Long> phaseIdList, @Param("status") String phaseStatus, @Param("runnerId") Long runnerId);
@@ -357,8 +349,6 @@ public interface AutoexecJobMapper {
 
     Integer updateJobPhaseNodeById(AutoexecJobPhaseNodeVo jobPhaseNodeVo);
 
-    Integer updateJobPhaseNodeByJobIdAndPhaseIdAndResourceId(AutoexecJobPhaseNodeVo jobPhaseNodeVo);
-
     Integer updateJobPhaseRunnerFireNextByPhaseIdAndRunnerId(@Param("phaseId") Long phaseId, @Param("isFireNext") int isFireNext, @Param("runnerMapId") Long runnerMapId);
 
     Integer updateJobPhaseRunnerFireNextByJobIdAndGroupSortAndRunnerId(@Param("jobId") Long jobId, @Param("groupSort") Integer groupSort, @Param("isFireNext") int isFireNext, @Param("runnerMapId") Long runnerMapId);
@@ -367,7 +357,7 @@ public interface AutoexecJobMapper {
 
     Integer updateJobPhaseLncdById(@Param("jobPhaseId") Long jobPhaseId, @Param("lcd") Date lcd);
 
-    Integer updateJobPhaseNodeIsDeleteByJobPhaseIdAndLcd(@Param("jobPhaseId") Long jobPhaseId, @Param("lcd") Date lcd);
+    Integer updateJobPhaseNodeIsDeleteByJobPhaseIdAndUpdateTag(@Param("jobPhaseId") Long jobPhaseId, @Param("updateTag") Long updateTag);
 
     Integer updateJobParamHashById(@Param("jobId") Long jobId, @Param("paramHash") String paramHash);
 
@@ -417,13 +407,7 @@ public interface AutoexecJobMapper {
 
     void deleteJobPhaseRunnerByJobId(Long jobId);
 
-    void deleteJobPhaseNodeRunnerByJobId(Long jobId);
-
-    void deleteJobPhaseNodeByJobPhaseIdAndLcd(@Param("jobPhaseId") Long jobPhaseId, @Param("lcd") Date lcd);
-
-    Integer deleteJobPhaseNodeByJobPhaseIdAndLcdAndStatus(@Param("jobPhaseId") Long jobPhaseId, @Param("lcd") Date lcd, @Param("status") String status);
-
-    void deleteJobPhaseNodeRunnerByJobPhaseIdAndLcdAndStatus(@Param("jobPhaseId") Long jobPhaseId, @Param("lcd") Date lcd, @Param("status") String status);
+    Integer deleteJobPhaseNodeByJobPhaseIdAndUpdateTagAndStatus(@Param("jobPhaseId") Long jobPhaseId, @Param("updateTag") Long updateTag, @Param("status") String status);
 
     void deleteJobEvnByJobId(Long jobId);
 
@@ -444,4 +428,10 @@ public interface AutoexecJobMapper {
     void updateJobSqlStatusByJobIdAndPhaseId(@Param("jobId") Long jobId,@Param("phaseId") Long phaseId,@Param("status") String status);
 
     void updateJobPhaseRunnerStatusByJobIdAndPhaseId(@Param("jobId") Long jobId,@Param("phaseId") Long phaseId,@Param("status") String status);
+
+    void updateJobPhaseNodeBatch(@Param("jobPhaseId") Long phaseId,@Param("resourceIdList") List<Long> resourceIdList,@Param("status") String value,@Param("updateTag") long time);
+
+    void updateJobPhaseNodeListStatusByPhaseIdAndExceptStatus(@Param("phaseId") Long phaseId, @Param("exceptStatus") List<String> exceptStatus,@Param("status") String status);
+
+    Integer isHasPendingNode(Long jobPhaseId);
 }
diff --git a/src/main/java/neatlogic/framework/autoexec/dao/mapper/AutoexecJobMapper.xml b/src/main/java/neatlogic/framework/autoexec/dao/mapper/AutoexecJobMapper.xml
index 3bced62d4df9e385e71625692aa32ad624329333..a6a3edd895f27e3d1908abd96efc419668c07537 100644
--- a/src/main/java/neatlogic/framework/autoexec/dao/mapper/AutoexecJobMapper.xml
+++ b/src/main/java/neatlogic/framework/autoexec/dao/mapper/AutoexecJobMapper.xml
@@ -295,10 +295,11 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
         ajpn.`start_time` AS startTime,
         ajpn.`end_time` AS endTime,
         ajpn.`status`,
+        ajpn.`error_type` as errorType,
         ajpn.`protocol_id` as protocolId,
         ajpn.`resource_id` AS resourceId,
         ajpn.`warn_count` as warnCount,
-        ri.`id` AS nodeId,
+        ajpn.`resource_id` AS nodeId,
         ajpn.name AS nodeName,
         ajpn.type AS nodeType,
         ajpn.is_delete as isDelete,
@@ -312,9 +313,7 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
         `autoexec_job_phase_node` ajpn
         LEFT JOIN `autoexec_job_phase` ajp ON ajpn.`job_phase_id` = ajp.`id`
         left join `autoexec_job_group` ajg on ajp.job_id = ajg.job_id and ajp.group_id = ajg.id
-        LEFT JOIN @{DATA_SCHEMA}.`scence_ipobject_id` ri ON ajpn.resource_id = ri.`id`
-        LEFT JOIN `autoexec_job_phase_node_runner` ajpnr ON ajpn.id = ajpnr.`node_id`
-        LEFT JOIN `runner_map` arm ON ajpnr.`runner_map_id` = arm.`id`
+        LEFT JOIN `runner_map` arm ON ajpn.`runner_map_id` = arm.`id`
         LEFT JOIN `runner` ap ON arm.`runner_id` = ap.`id`
         <where>
             <include refid="searchJobPhaseNodeSql"/>
@@ -358,8 +357,7 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
         `autoexec_job_phase_node` ajpn
         LEFT JOIN `autoexec_job_phase` ajp ON ajpn.`job_phase_id` = ajp.`id`
         left join `autoexec_job_group` ajg on ajp.job_id = ajg.job_id and ajp.group_id = ajg.id
-        LEFT JOIN `autoexec_job_phase_node_runner` ajpnr ON ajpn.id = ajpnr.`node_id`
-        LEFT JOIN `runner_map` arm ON ajpnr.`runner_map_id` = arm.`id`
+        LEFT JOIN `runner_map` arm ON ajpn.`runner_map_id` = arm.`id`
         LEFT JOIN `runner` ap ON arm.`runner_id` = ap.`id`
         <where>
             <if test="isDownloadGroup != null and isDownloadGroup == 1">
@@ -401,20 +399,6 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
         limit #{startNum}, #{nodeVo.pageSize}
     </select>
 
-    <select id="searchJobPhaseNodeCountWithResource" resultType="java.lang.Integer">
-        SELECT
-        count(ajpn.`id`)
-        FROM
-        `autoexec_job_phase_node` ajpn
-        LEFT JOIN `autoexec_job_phase` ajp on ajpn.`job_phase_id` = ajp.`id`
-        LEFT JOIN @{DATA_SCHEMA}.`scence_ipobject_id` ri ON ajpn.resource_id = ri.`id`
-        LEFT JOIN `autoexec_job_phase_node_runner` ajpnr ON ajpn.id = ajpnr.`node_id`
-        LEFT JOIN `runner_map` arm ON ajpnr.`runner_map_id` = arm.`id`
-        <where>
-            <include refid="searchJobPhaseNodeSql"/>
-        </where>
-    </select>
-
     <select id="searchJobPhaseNodeCount" resultType="java.lang.Integer">
         SELECT
         count(distinct ajpn.`id`)
@@ -765,16 +749,6 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
           AND `param_hash` = #{hash}
     </select>
 
-    <select id="checkIsJobPhaseNodeExist" parameterType="neatlogic.framework.autoexec.dto.job.AutoexecJobPhaseNodeVo"
-            resultType="java.lang.Integer">
-        select count(1)
-        from `autoexec_job_phase_node`
-        where `job_id` = #{jobId}
-          and `job_phase_id` = #{jobPhaseId}
-          and `host` = #{host}
-          and port = #{port}
-    </select>
-
     <select id="getJobPhaseByJobIdAndPhaseName"
             resultType="neatlogic.framework.autoexec.dto.job.AutoexecJobPhaseVo">
         SELECT id,
@@ -939,8 +913,7 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
                ap.`url`            AS runnerUrl
         FROM `autoexec_job_phase_node` ajpn
                  LEFT JOIN `autoexec_job_phase` ajp ON ajpn.`job_phase_id` = ajp.`id`
-                 LEFT JOIN `autoexec_job_phase_node_runner` ajpnr ON ajpn.id = ajpnr.`node_id`
-                 LEFT JOIN `runner_map` arm ON ajpnr.`runner_map_id` = arm.`id`
+                 LEFT JOIN `runner_map` arm ON ajpn.`runner_map_id` = arm.`id`
                  LEFT JOIN `runner` ap ON arm.`runner_id` = ap.`id`
         where ajpn.`id` = #{nodeId}
     </select>
@@ -958,8 +931,7 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
                ajpn.`status`,
                arm.`runner_id`     as runnerId
         FROM `autoexec_job_phase_node` ajpn
-                 LEFT JOIN `autoexec_job_phase_node_runner` ajpnr on ajpn.id = ajpnr.`node_id`
-                 LEFT JOIN `runner_map` arm ON ajpnr.`runner_map_id` = arm.`id`
+                 LEFT JOIN `runner_map` arm ON ajpn.`runner_map_id` = arm.`id`
         WHERE ajpn.`job_id` = #{jobId}
           AND ajpn.`job_phase_id` = #{phaseId}
     </select>
@@ -988,9 +960,8 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
         arm.`runner_id` AS runnerId,
         ajp.`name` AS jobPhaseName
         FROM `autoexec_job_phase_node` ajpn
-        LEFT JOIN `autoexec_job_phase_node_runner` ajpnr ON ajpn.id = ajpnr.`node_id`
         LEFT JOIN `autoexec_job_phase` ajp ON ajpn.`job_phase_id` = ajp.`id`
-        LEFT JOIN `runner_map` arm ON ajpnr.`runner_map_id` = arm.`id`
+        LEFT JOIN `runner_map` arm ON ajpn.`runner_map_id` = arm.`id`
         where ajpn.`job_id` = #{jobId} and ajp.`name` = #{phaseName} and arm.`runner_id` = #{runnerId} and
         ajpn.`status` not in
         <foreach collection="exceptStatus" item="status" separator="," open="(" close=")">
@@ -1001,15 +972,10 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
     <select id="getJobPhaseNodeListByJobIdAndPhaseIdAndExceptStatus"
             resultType="neatlogic.framework.autoexec.dto.job.AutoexecJobPhaseNodeVo">
         SELECT ajpn.`id`,
-        ajpn.`job_id` AS jobId,
-        ajpn.`job_phase_id` AS jobPhaseId,
         ajpn.`host`,
-        ajpn.`port`,
-        ajpn.`start_time` AS startTime,
-        ajpn.`end_time` AS endTime,
-        ajpn.`status`
+        ajpn.`port`
         FROM `autoexec_job_phase_node` ajpn
-        where ajpn.`job_id` = #{jobId} and ajpn.`job_phase_id` = #{phaseId} and
+        where ajpn.`job_phase_id` = #{phaseId} and
         ajpn.`status` not in
         <foreach collection="exceptStatus" item="status" separator="," open="(" close=")">
             #{status}
@@ -1027,9 +993,8 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
         ajpn.`end_time` AS endTime,
         ajpn.`status`
         FROM `autoexec_job_phase_node` ajpn
-        left join autoexec_job_phase_node_runner ajpnr on ajpn.id = ajpnr.node_id
         where ajpn.`job_id` = #{jobId} and ajpn.`job_phase_id` = #{phaseId}
-        and ajpnr.runner_map_id = #{runnerMapId}
+        and ajpn.runner_map_id = #{runnerMapId}
         and
         ajpn.`status` not in
         <foreach collection="exceptStatus" item="status" separator="," open="(" close=")">
@@ -1065,10 +1030,9 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
                ajpn.`end_time`     AS endTime,
                ajpn.`status`,
                ajpn.`resource_id` as resourceId,
-               ajpnr.runner_map_id as runnerMapId
+               ajpn.runner_map_id as runnerMapId
         FROM `autoexec_job_phase_node` ajpn
-                 left join autoexec_job_phase_node_runner ajpnr on ajpn.id = ajpnr.node_id
-        where ajpn.`job_id` = #{jobId}
+        where ajpn.`job_id` = #{jobId} and status not in ('invalid')
     </select>
 
     <select id="getJobPhaseNodeListWithoutDeleteByJobIdAndPhaseId"
@@ -1091,9 +1055,8 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
     <select id="getJobRunnerListByJobId" resultType="neatlogic.framework.dto.runner.RunnerVo">
         SELECT DISTINCT ar.`id`, ar.`name`, ar.`url`, ar.`host`, ar.`port`
         FROM `autoexec_job_phase_node` ajpn
-                 LEFT JOIN `autoexec_job_phase_node_runner` ajpnr ON ajpn.id = ajpnr.`node_id`
-                 LEFT JOIN `runner_map` arm ON ajpnr.`runner_map_id` = arm.`id`
-                 LEFT JOIN `runner` ar ON arm.`runner_id` = ar.`id`
+                  JOIN `runner_map` arm ON ajpn.`runner_map_id` = arm.`id`
+                  JOIN `runner` ar ON arm.`runner_id` = ar.`id`
         WHERE ajpn.`job_id` = #{value}
     </select>
 
@@ -1280,11 +1243,10 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
         ajpn.`type` as nodeType,
         ajpn.`protocol_id` as protocolId,
         ajpn.`status`,
-        ajpnr.runner_map_id as runnerMapId,
+        ajpn.runner_map_id as runnerMapId,
         r.url as runnerUrl
         FROM `autoexec_job_phase_node` ajpn
-        LEFT JOIN `autoexec_job_phase_node_runner` ajpnr ON ajpnr.`node_id` = ajpn.`id`
-        LEFT JOIN `runner_map` arm ON ajpnr.`runner_map_id` = arm.`id`
+        LEFT JOIN `runner_map` arm ON ajpn.`runner_map_id` = arm.`id`
         LEFT JOIN `runner` r on arm.runner_id = r.id
         where ajpn.`id` in
         <foreach collection="nodeIdList" item="nodeId" separator="," open="(" close=")">
@@ -1307,11 +1269,10 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
         ajpn.`type` as nodeType,
         ajpn.`protocol_id` as protocolId,
         ajpn.`status`,
-        ajpnr.runner_map_id as runnerMapId,
+        ajpn.runner_map_id as runnerMapId,
         r.url as runnerUrl
         FROM `autoexec_job_phase_node` ajpn
-        LEFT JOIN `autoexec_job_phase_node_runner` ajpnr ON ajpnr.`node_id` = ajpn.`id`
-        LEFT JOIN `runner_map` arm ON ajpnr.`runner_map_id` = arm.`id`
+        LEFT JOIN `runner_map` arm ON ajpn.`runner_map_id` = arm.`id`
         LEFT JOIN `runner` r on arm.runner_id = r.id
         where ajpn.`job_phase_id` = #{jobPhaseId} and ajpn.`is_delete` = 0 and ajpn.`status` not in
         <foreach collection="statusList" item="status" separator="," open="(" close=")">
@@ -1390,8 +1351,7 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
         ap.`url` AS runnerUrl
         FROM `autoexec_job_phase_node` ajpn
         LEFT JOIN `autoexec_job_phase` ajp ON ajpn.`job_phase_id` = ajp.`id`
-        LEFT JOIN `autoexec_job_phase_node_runner` ajpnr ON ajpn.id = ajpnr.`node_id`
-        LEFT JOIN `runner_map` arm ON ajpnr.`runner_map_id` = arm.`id`
+        LEFT JOIN `runner_map` arm ON ajpn.`runner_map_id` = arm.`id`
         LEFT JOIN `runner` ap ON arm.`runner_id` = ap.`id`
         where ajpn.`job_phase_id` = #{jobPhaseId}
         <if test="resourceId == null">
@@ -1422,8 +1382,7 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
         ap.`url` AS runnerUrl
         FROM `autoexec_job_phase_node` ajpn
         LEFT JOIN `autoexec_job_phase` ajp ON ajpn.`job_phase_id` = ajp.`id`
-        LEFT JOIN `autoexec_job_phase_node_runner` ajpnr ON ajpn.id = ajpnr.`node_id`
-        LEFT JOIN `runner_map` arm ON ajpnr.`runner_map_id` = arm.`id`
+        LEFT JOIN `runner_map` arm ON ajpn.`runner_map_id` = arm.`id`
         LEFT JOIN `runner` ap ON arm.`runner_id` = ap.`id`
         where ajpn.job_id = #{jobId} and ajp.`name` = #{jobPhaseName}
         <if test="resourceId == null">
@@ -1548,8 +1507,7 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
         ajpn.`resource_id` as resourceId
         FROM `autoexec_job_phase_node` ajpn
         LEFT JOIN `autoexec_job_phase` ajp ON ajpn.`job_phase_id` = ajp.`id`
-        LEFT JOIN `autoexec_job_phase_node_runner` ajpnr ON ajpn.`id` = ajpnr.`node_id`
-        WHERE ajpnr.`runner_map_id` = #{runnerId}
+        WHERE ajpn.`runner_map_id` = #{runnerId}
         AND ajpn.`job_phase_id` IN
         <foreach collection="jobPhaseIdList" separator="," open="(" close=")" item="jobPhaseId">
             #{jobPhaseId}
@@ -1663,12 +1621,12 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
         ar.`url`,
         ar.`host`,
         ar.`port`,
-        ajpr.runner_map_id as runnerMapId
-        FROM `autoexec_job_phase_node_runner` ajpr
-        LEFT JOIN `runner_map` arm ON ajpr.`runner_map_id` = arm.`id`
+        ajpn.runner_map_id as runnerMapId
+        FROM `autoexec_job_phase_node` ajpn
+        LEFT JOIN `runner_map` arm ON ajpn.`runner_map_id` = arm.`id`
         LEFT JOIN `runner` ar ON arm.`runner_id` = ar.`id`
-        WHERE ajpr.`job_id` = #{jobId}
-        and ajpr.node_id in
+        WHERE ajpn.`job_id` = #{jobId}
+        and ajpn.id in
         <foreach collection="nodeIdList" item="nodeId" close=")" separator="," open="(">
             #{nodeId}
         </foreach>
@@ -1676,9 +1634,9 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
 
     <select id="getJobRunnerMapIdListByJobId" resultType="java.lang.Long">
         SELECT DISTINCT
-        ajpr.runner_map_id as runnerMapId
-        FROM `autoexec_job_phase_node_runner` ajpr
-        WHERE ajpr.`job_id` = #{jobId}
+        ajpn.runner_map_id as runnerMapId
+        FROM `autoexec_job_phase_node` ajpn
+        WHERE ajpn.`job_id` = #{jobId}
     </select>
 
     <select id="getJobPhaseNodeRunnerListByJobPhaseId"
@@ -1688,11 +1646,11 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
                         ar.`url`,
                         ar.`host`,
                         ar.`port`,
-                        ajpnr.runner_map_id as runnerMapId
-        FROM `autoexec_job_phase_node_runner` ajpnr
-                 LEFT JOIN `runner_map` arm ON ajpnr.`runner_map_id` = arm.`id`
-                 LEFT JOIN `runner` ar ON arm.`runner_id` = ar.`id`
-        WHERE ajpnr.`job_phase_id` = #{value}
+                        ajpn.runner_map_id as runnerMapId
+        FROM `autoexec_job_phase_node` ajpn
+                  JOIN `runner_map` arm ON ajpn.`runner_map_id` = arm.`id`
+                  JOIN `runner` ar ON arm.`runner_id` = ar.`id`
+        WHERE ajpn.`job_phase_id` = #{value}
     </select>
     <select id="getJobPhaseListWithGroupByJobIdAndPhaseIdList"
             resultMap="AutoexecJobPhaseMap">
@@ -1796,8 +1754,7 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
         `autoexec_job_phase_node` ajpn
         LEFT JOIN `autoexec_job_phase` ajp ON ajpn.`job_phase_id` = ajp.`id`
         LEFT JOIN `autoexec_job_group` ajg ON ajp.job_id = ajg.job_id AND ajp.group_id = ajg.id
-        LEFT JOIN `autoexec_job_phase_node_runner` ajpnr ON ajpn.id = ajpnr.`node_id`
-        LEFT JOIN `runner_map` arm ON ajpnr.`runner_map_id` = arm.`id`
+        LEFT JOIN `runner_map` arm ON ajpn.`runner_map_id` = arm.`id`
         <where>
             <if test="isDownloadGroup != null and isDownloadGroup == 1">
                 ajp.node_from != "0"
@@ -2087,7 +2044,7 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
             <id column="id" property="id"/>
             <result column="name" property="name"/>
             <result column="status" property="status"/>
-            <result column="errorMsg" property="errorMsg"/>
+            <result column="errorType" property="errorType"/>
             <result column="planStartTime" property="planStartTime"/>
             <result column="startTime" property="startTime"/>
             <result column="endTime" property="endTime"/>
@@ -2317,12 +2274,11 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
         select ajpn.job_id                          as jobId,
                ajpn.job_phase_id                    as jobPhaseId,
                GROUP_CONCAT(DISTINCT ajpn.`status`) as status,
-               ajpnr.runner_map_id                  as runnerMapId
-        from autoexec_job_phase_node ajpn
-                 JOIN autoexec_job_phase_node_runner ajpnr on ajpn.id = ajpnr.node_id
+               ajpn.runner_map_id                  as runnerMapId
+        from `autoexec_job_phase_node` ajpn
         where ajpn.job_id = #{jobId}
           and ajpn.job_phase_id = #{jobPhaseId}
-        group by ajpn.job_id, ajpn.job_phase_id, ajpnr.runner_map_id
+        group by ajpn.job_id, ajpn.job_phase_id, ajpn.runner_map_id
     </select>
 
     <select id="getJobIdListByProcessTaskStepId" parameterType="java.lang.Long" resultType="java.lang.Long">
@@ -2350,6 +2306,12 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
         WHERE aj.`parent_id` = #{value} for
         update
     </select>
+    <select id="isHasPendingNode" resultType="java.lang.Integer">
+        select ajpn.id
+        from `autoexec_job_phase_node` ajpn
+        where ajpn.job_phase_id = #{value} and ajpn.`status` = 'pending'
+        limit 1
+    </select>
 
     <insert id="insertJob" parameterType="neatlogic.framework.autoexec.dto.job.AutoexecJobVo">
         INSERT INTO `autoexec_job` (`id`,
@@ -2442,8 +2404,8 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
                                                `type`,
                                                `user_name`,
                                                `resource_id`,
-                                               `lcd`,
-                                               `status`)
+                                               `status`,
+                                               `runner_map_id`)
         VALUES (#{id},
                 #{jobId},
                 #{jobPhaseId},
@@ -2454,11 +2416,77 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
                 #{nodeType},
                 #{userName},
                 #{resourceId},
-                #{lcd},
-                #{status})
+                #{status},
+                #{runnerMapId})
     </insert>
 
     <insert id="batchInsertJobPhaseNode" parameterType="neatlogic.framework.autoexec.dto.job.AutoexecJobPhaseNodeVo">
+        INSERT IGNORE INTO `autoexec_job_phase_node` (`id`,
+        `job_id`,
+        `job_phase_id`,
+        `host`,
+        `port`,
+        `protocol_id`,
+        `name`,
+        `type`,
+        `user_name`,
+        `resource_id`,
+        `status`,
+        `update_tag`,
+        `runner_map_id`,
+        `error_type`)
+        VALUES   <foreach collection="list" item="node" separator="),(" open="(" close=")">
+        #{node.id},
+        #{node.jobId},
+        #{node.jobPhaseId},
+        #{node.host},
+        #{node.port},
+        #{node.protocolId},
+        #{node.nodeName},
+        #{node.nodeType},
+        #{node.userName},
+        #{node.resourceId},
+        #{node.status},
+        #{node.updateTag},
+        #{node.runnerMapId},
+        #{node.errorType}
+    </foreach>
+    </insert>
+
+    <insert id="batchInsertIgnoreJobPhaseNode" parameterType="neatlogic.framework.autoexec.dto.job.AutoexecJobPhaseNodeVo">
+        INSERT IGNORE INTO `autoexec_job_phase_node` (`id`,
+        `job_id`,
+        `job_phase_id`,
+        `host`,
+        `port`,
+        `protocol_id`,
+        `name`,
+        `type`,
+        `user_name`,
+        `resource_id`,
+        `status`,
+        `update_tag`,
+        `runner_map_id`,
+        `error_type`)
+        VALUES   <foreach collection="list" item="node" separator="),(" open="(" close=")">
+        #{node.id},
+        #{node.jobId},
+        #{node.jobPhaseId},
+        #{node.host},
+        #{node.port},
+        #{node.protocolId},
+        #{node.nodeName},
+        #{node.nodeType},
+        #{node.userName},
+        #{node.resourceId},
+        #{node.status},
+        #{node.updateTag},
+        #{node.runnerMapId},
+        #{node.errorType}
+    </foreach>
+    </insert>
+
+    <insert id="batchInsertDuplicateJobPhaseNode" parameterType="neatlogic.framework.autoexec.dto.job.AutoexecJobPhaseNodeVo">
         INSERT INTO `autoexec_job_phase_node` (`id`,
                                                `job_id`,
                                                `job_phase_id`,
@@ -2469,8 +2497,9 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
                                                `type`,
                                                `user_name`,
                                                `resource_id`,
-                                               `lcd`,
-                                               `status`)
+                                               `status`,
+                                               `update_tag`,
+                                                `runner_map_id`)
         VALUES   <foreach collection="list" item="node" separator="),(" open="(" close=")">
                 #{node.id},
                 #{node.jobId},
@@ -2482,15 +2511,16 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
                 #{node.nodeType},
                 #{node.userName},
                 #{node.resourceId},
-                #{node.lcd},
-                #{node.status}
+                #{node.status},
+                #{node.updateTag},
+                #{node.runnerMapId}
             </foreach>
         ON DUPLICATE KEY UPDATE
         `status` = VALUES(`status`),
         `start_time` = VALUES(start_time),
         `end_time` = VALUES(end_time),
         `is_delete` = 0,
-        `lcd` = VALUES(lcd)
+        `update_tag` = VALUES(update_tag)
 
     </insert>
 
@@ -2550,20 +2580,6 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
         VALUES (#{hash}, #{content})
     </insert>
 
-    <insert id="insertIgnoreJobPhaseNodeRunner"
-            parameterType="neatlogic.framework.autoexec.dto.job.AutoexecJobPhaseNodeRunnerVo">
-        INSERT ignore INTO `autoexec_job_phase_node_runner` (`job_id`, `job_phase_id`, `node_id`, `runner_map_id`)
-        VALUES (#{jobId}, #{jobPhaseId}, #{nodeId}, #{runnerMapId})
-    </insert>
-
-    <insert id="batchInsertJobPhaseNodeRunner" parameterType="neatlogic.framework.autoexec.dto.job.AutoexecJobPhaseNodeVo">
-        INSERT ignore INTO `autoexec_job_phase_node_runner` (`job_id`, `job_phase_id`, `node_id`, `runner_map_id`)
-        VALUES
-            <foreach collection="list" item="nodeRunner" separator="),(" open="(" close=")">
-                #{nodeRunner.jobId}, #{nodeRunner.jobPhaseId}, #{nodeRunner.nodeId}, #{nodeRunner.runnerMapId}
-            </foreach>
-    </insert>
-
     <insert id="insertJobPhaseRunner">
         INSERT INTO `autoexec_job_phase_runner` (`job_id`, `job_group_id`, `job_phase_id`, `runner_map_id`, `lcd`)
         VALUES (#{jobId}, #{jobGroupId}, #{jobPhaseId}, #{runnerMapId}, #{lcd})
@@ -2812,15 +2828,7 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
           , `end_time`   = NULL
         WHERE `job_id` = #{jobId}
     </update>
-    <update id="updateJobPhaseNodeStatusByJobIdAndIsDelete">
-        UPDATE `autoexec_job_phase_node`
-        SET `status`     = #{status}
-          , `start_time` = NULL
 
-          , `end_time`   = NULL
-        WHERE `job_id` = #{jobId}
-          and `is_delete` = #{isDelete}
-    </update>
     <update id="updateJobPhaseNodeStatusByJobPhaseIdAndIsDelete">
         UPDATE `autoexec_job_phase_node`
         SET `status`     = #{status}
@@ -2828,6 +2836,7 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
           , `end_time`   = NULL
         WHERE `job_phase_id` = #{jobPhaseId}
           and `is_delete` = #{isDelete}
+          and `status` not in ('invalid')
     </update>
     <update id="updateJobPhaseRunnerStatus">
         UPDATE
@@ -2885,6 +2894,7 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
         <foreach collection="nodeIdList" item="nodeId" open="(" close=")" separator=",">
             #{nodeId}
         </foreach>
+        and `status` != 'invalid'
         and `is_delete` = 0
     </update>
     <update id="updateJobPhaseStatusByPhaseIdList">
@@ -2906,41 +2916,6 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
         WHERE `id` = #{id}
     </update>
 
-    <update id="updateJobPhaseNodeByJobIdAndPhaseIdAndResourceId">
-        UPDATE
-        `autoexec_job_phase_node`
-        SET `status` = #{status},
-        `start_time` = #{startTime},
-        `end_time` = #{endTime},
-        `is_delete` = 0,
-        `lcd` = #{lcd}
-        WHERE `job_id` = #{jobId}
-        and `job_phase_id` = #{jobPhaseId}
-        <if test="resourceId == null">
-            and `resource_id` is null
-        </if>
-        <if test="resourceId != null">
-            and `resource_id` = #{resourceId}
-        </if>
-
-    </update>
-
-    <update id="updateJobPhaseNodeStatusByJobIdAndJobPhaseIdListAndRunnerId">
-        UPDATE
-        `autoexec_job_phase_node`
-        SET
-        `end_time` = NOW(3),
-        `status` = #{status}
-        WHERE `job_id` = #{jobId}
-        AND `job_phase_id` in
-        <foreach collection="jobPhaseIdList" item="jobPhaseId" separator="," open="(" close=")">
-            #{jobPhaseId}
-        </foreach>
-        and `status` in
-        <foreach collection="nodeStatusList" item="nodeStatus" open="(" separator="," close=")">
-            #{nodeStatus}
-        </foreach>
-    </update>
     <update id="updateJobPhaseRunnerFireNextByPhaseIdAndRunnerId">
         update `autoexec_job_phase_runner`
         set is_fire_next = #{isFireNext}
@@ -3041,12 +3016,13 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
         `id` = #{id}
     </update>
 
-    <delete id="updateJobPhaseNodeIsDeleteByJobPhaseIdAndLcd">
+    <delete id="updateJobPhaseNodeIsDeleteByJobPhaseIdAndUpdateTag">
         update
             `autoexec_job_phase_node`
         set `is_delete` = 1
         where `job_phase_id` = #{jobPhaseId}
-          and (`lcd` != #{lcd} OR `lcd` IS NULL)
+          and `update_tag` != #{updateTag}
+          and `status` not in ('invalid','ignored')
           and `is_delete` != 1
     </delete>
 
@@ -3123,6 +3099,40 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
         </if>
         WHERE `job_id` = #{jobId} and `job_phase_id` = #{phaseId}
     </update>
+    <update id="updateJobPhaseNodeBatch">
+        UPDATE
+        `autoexec_job_phase_node`
+        SET `update_tag` = #{updateTag},
+            `status` = #{status},
+            `start_time` = null,
+            `end_time` = null
+        WHERE
+        `job_phase_id` = #{jobPhaseId}
+        and `resource_id` in
+        <foreach collection="resourceIdList" item="resourceId" open="(" close=")" separator=",">
+            #{resourceId}
+        </foreach>
+        and `status` != 'invalid'
+    </update>
+    <update id="updateJobPhaseNodeListStatusByPhaseIdAndExceptStatus">
+        UPDATE
+        `autoexec_job_phase_node`
+        SET
+        `status` = #{status},
+        <if test="status == 'pending'">
+            `start_time` = null,
+        </if>
+        <if test="status == 'pending'">
+            `end_time` = null
+        </if>
+        WHERE `job_phase_id` = #{phaseId} and
+        `status` not in
+        <foreach collection="exceptStatus" item="status" separator="," open="(" close=")">
+            #{status}
+        </foreach>
+        and `status` != 'invalid'
+        and `is_delete` = 0
+    </update>
 
     <delete id="deleteJobContentByHash" parameterType="java.lang.String">
         DELETE
@@ -3169,38 +3179,16 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.-->
         FROM `autoexec_job_phase_runner`
         WHERE `job_id` = #{value}
     </delete>
-    <delete id="deleteJobPhaseNodeRunnerByJobId">
-        DELETE ajpnr
-        FROM `autoexec_job_phase_node_runner` ajpnr
-                 LEFT JOIN `autoexec_job_phase_node` ajpn ON ajpnr.`node_id` = ajpn.`id`
-        WHERE ajpn.`job_id` = #{value}
-          and ajpn.`is_executed` = 0
-    </delete>
-    <delete id="deleteJobPhaseNodeByJobPhaseIdAndLcd">
-        DELETE
-        FROM `autoexec_job_phase_node`
-        where `job_phase_id` = #{jobPhaseId}
-          and (`lcd` != #{lcd} OR `lcd` IS NULL)
-          and `is_executed` = 0
-    </delete>
-    <delete id="deleteJobPhaseNodeByJobPhaseIdAndLcdAndStatus">
+
+    <delete id="deleteJobPhaseNodeByJobPhaseIdAndUpdateTagAndStatus">
         DELETE
         FROM `autoexec_job_phase_node`
         where `job_phase_id` = #{jobPhaseId}
-          and (`lcd` != #{lcd} OR `lcd` IS NULL)
+          and `update_tag` != #{updateTag}
           and `status` = #{status}
           and `is_delete` = 0
           and `is_executed` = 0
     </delete>
-    <delete id="deleteJobPhaseNodeRunnerByJobPhaseIdAndLcdAndStatus">
-        DELETE ajpnr
-        FROM `autoexec_job_phase_node_runner` ajpnr
-                 LEFT JOIN `autoexec_job_phase_node` ajpn ON ajpnr.`node_id` = ajpn.`id`
-        WHERE ajpn.`job_phase_id` = #{jobPhaseId}
-          and (ajpn.`lcd` != #{lcd} OR ajpn.`lcd` IS NULL)
-          and ajpn.`status` = #{status}
-          and ajpn.`is_executed` = 0
-    </delete>
     <delete id="deleteJobEvnByJobId">
         DELETE
         FROM `autoexec_job_env`
diff --git a/src/main/java/neatlogic/framework/autoexec/dto/job/AutoexecJobPhaseNodeVo.java b/src/main/java/neatlogic/framework/autoexec/dto/job/AutoexecJobPhaseNodeVo.java
index e40890478d72ccf70eb5559819d8cae4fed043f8..f68f9b421c612fcb31699697714dc4c217b90fd5 100644
--- a/src/main/java/neatlogic/framework/autoexec/dto/job/AutoexecJobPhaseNodeVo.java
+++ b/src/main/java/neatlogic/framework/autoexec/dto/job/AutoexecJobPhaseNodeVo.java
@@ -17,6 +17,7 @@ package neatlogic.framework.autoexec.dto.job;
 
 import com.alibaba.fastjson.JSONObject;
 import com.alibaba.fastjson.annotation.JSONField;
+import neatlogic.framework.autoexec.constvalue.AutoexecJobPhaseNodeErrorType;
 import neatlogic.framework.autoexec.constvalue.JobNodeStatus;
 import neatlogic.framework.autoexec.dto.INodeDetail;
 import neatlogic.framework.autoexec.dto.combop.AutoexecCombopParamVo;
@@ -105,6 +106,8 @@ public class AutoexecJobPhaseNodeVo extends AutoexecJobNodeVo implements INodeDe
     private Integer isExecuted;//是否执行过，用于标识执行过的节点不能删除
     @JSONField(serialize = false)
     private Integer isDownloadGroup;//是否下载组节点，用于下载节点接口
+    @EntityField(name = "初始化节点异常类型", type = ApiParamType.STRING)
+    private Integer errorType;
 
     public AutoexecJobPhaseNodeVo() {
     }
@@ -466,4 +469,28 @@ public class AutoexecJobPhaseNodeVo extends AutoexecJobNodeVo implements INodeDe
         this.isDownloadGroup = isDownloadGroup;
     }
 
+    public Long getUpdateTag(){
+        if(this.getLcd() != null){
+            return this.getLcd().getTime();
+        }
+        return null;
+    }
+
+    public Integer getErrorType() {
+        return errorType;
+    }
+
+    public void setErrorType(Integer errorType) {
+        this.errorType = errorType;
+    }
+
+    public String getErrorMsg() {
+        if(errorType != null){
+            AutoexecJobPhaseNodeErrorType errorTypeEnum = AutoexecJobPhaseNodeErrorType.getErrorType(errorType);
+            if(errorTypeEnum != null){
+                return errorTypeEnum.getText();
+            }
+        }
+        return StringUtils.EMPTY;
+    }
 }
diff --git a/src/main/java/neatlogic/framework/autoexec/dto/job/AutoexecJobVo.java b/src/main/java/neatlogic/framework/autoexec/dto/job/AutoexecJobVo.java
index 3f49f0fc7ac385be6d915d04ead4e52b18dae69d..19248bb670c23acc3b56ec8d91dab86ae2903e01 100644
--- a/src/main/java/neatlogic/framework/autoexec/dto/job/AutoexecJobVo.java
+++ b/src/main/java/neatlogic/framework/autoexec/dto/job/AutoexecJobVo.java
@@ -257,6 +257,10 @@ public class AutoexecJobVo extends BaseEditorVo implements Serializable {
     @EntityField(name = "runner执行组标签", type = ApiParamType.JSONOBJECT)
     private ParamMappingVo runnerGroupTag;
 
+    @JSONField(serialize = false)
+    @EntityField(name = "是否第一次初始化", type = ApiParamType.JSONOBJECT)
+    private int isFirstInit = 0;
+
     public AutoexecJobVo() {
     }
 
@@ -1083,4 +1087,12 @@ public class AutoexecJobVo extends BaseEditorVo implements Serializable {
     public void setRunnerGroupTag(ParamMappingVo runnerGroupTag) {
         this.runnerGroupTag = runnerGroupTag;
     }
+
+    public int getIsFirstInit() {
+        return isFirstInit;
+    }
+
+    public void setIsFirstInit(int isFirstInit) {
+        this.isFirstInit = isFirstInit;
+    }
 }