diff --git a/.idea/jarRepositories.xml b/.idea/jarRepositories.xml
index bdbb288..222fa1c 100644
--- a/.idea/jarRepositories.xml
+++ b/.idea/jarRepositories.xml
@@ -4,12 +4,12 @@
     <remote-repository>
       <option name="id" value="central" />
       <option name="name" value="Central Repository" />
-      <option name="url" value="http://maven.aliyun.com/nexus/content/groups/public/" />
+      <option name="url" value="https://repo.maven.apache.org/maven2" />
     </remote-repository>
     <remote-repository>
       <option name="id" value="central" />
       <option name="name" value="Central Repository" />
-      <option name="url" value="https://repo.maven.apache.org/maven2" />
+      <option name="url" value="http://maven.aliyun.com/nexus/content/groups/public/" />
     </remote-repository>
     <remote-repository>
       <option name="id" value="central" />
diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index 863495b..20a0642 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -22,16 +22,17 @@
     <select />
   </component>
   <component name="ChangeListManager">
-    <list default="true" id="a38a4155-0e8c-4ddb-9f60-993f173584d3" name="Default Changelist" comment="新增字段及接口">
-      <change beforePath="$PROJECT_DIR$/.idea/dataSources.local.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/dataSources.local.xml" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/.idea/dataSources/f3c9cb31-a068-40bc-b157-fc2fddb017d4.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/dataSources/f3c9cb31-a068-40bc-b157-fc2fddb017d4.xml" afterDir="false" />
+    <list default="true" id="a38a4155-0e8c-4ddb-9f60-993f173584d3" name="Default Changelist" comment="新增安全单位接口">
+      <change afterPath="$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/DbDistLockUtilMapper.java" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/DbDistLockUtil.java" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/DbDistLockUtilMapper.xml" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/.idea/jarRepositories.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/jarRepositories.xml" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/xxl-job-admin/src/main/java/com/xxl/job/admin/XxlJobAdminApplication.java" beforeDir="false" afterPath="$PROJECT_DIR$/xxl-job-admin/src/main/java/com/xxl/job/admin/XxlJobAdminApplication.java" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/xxl-job-admin/src/main/java/com/xxl/job/admin/core/model/XxlJobRegistry.java" beforeDir="false" afterPath="$PROJECT_DIR$/xxl-job-admin/src/main/java/com/xxl/job/admin/core/model/XxlJobRegistry.java" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/xxl-job-admin/src/main/resources/application.properties" beforeDir="false" afterPath="$PROJECT_DIR$/xxl-job-admin/src/main/resources/application.properties" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/xxl-job-admin/src/main/resources/xxl-job/XxlJobInfoMapper.xml" beforeDir="false" afterPath="$PROJECT_DIR$/xxl-job-admin/src/main/resources/xxl-job/XxlJobInfoMapper.xml" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjDayPlan.java" beforeDir="false" afterPath="$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/entity/JjDayPlan.java" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService.java" beforeDir="false" afterPath="$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/xxl-job-admin/src/main/resources/mybatis-mapper/XxlJobInfoMapper.xml" beforeDir="false" afterPath="$PROJECT_DIR$/xxl-job-admin/src/main/resources/mybatis-mapper/XxlJobInfoMapper.xml" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/xxl-job-admin/src/main/resources/xxl-job/xxl-job2/XxlJobInfoMapper.xml" beforeDir="false" />
+      <change beforePath="$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/DataCenterXxlJob.java" beforeDir="false" afterPath="$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/DataCenterXxlJob.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/JJBusinessXxlJob.java" beforeDir="false" afterPath="$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/JJBusinessXxlJob.java" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/application.properties" beforeDir="false" afterPath="$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/application.properties" afterDir="false" />
     </list>
     <option name="SHOW_DIALOG" value="false" />
@@ -58,11 +59,20 @@
   <component name="MavenImportPreferences">
     <option name="generalSettings">
       <MavenGeneralSettings>
-        <option name="customMavenHome" value="$PROJECT_DIR$/../../maven/apache-maven-3.6.1" />
+        <option name="customMavenHome" value="D:\maven\apache-maven-3.6.1" />
+        <option name="localRepository" value="D:\maven\resp" />
         <option name="mavenHomeTypeForPersistence" value="CUSTOM" />
-        <option name="userSettingsFile" value="D:\maven\apache-maven-3.6.1\conf\settings-jjsp.xml" />
+        <option name="userSettingsFile" value="D:\maven\apache-maven-3.6.1\conf\settings.xml" />
       </MavenGeneralSettings>
     </option>
+    <option name="importingSettings">
+      <MavenImportingSettings>
+        <option name="jdkForImporter" value="1.8" />
+      </MavenImportingSettings>
+    </option>
+  </component>
+  <component name="MavenRunner">
+    <option name="jreName" value="1.8" />
   </component>
   <component name="ProjectColorInfo">{
   &quot;associatedIndex&quot;: 0
@@ -89,19 +99,21 @@
     "RequestMappingsPanelWidth1": "75",
     "RunOnceActivity.OpenProjectViewOnStart": "true",
     "RunOnceActivity.ShowReadmeOnStart": "true",
+    "RunOnceActivity.git.unshallow": "true",
+    "SONARLINT_PRECOMMIT_ANALYSIS": "true",
     "Spring Boot.XxlJobAdminApplication.executor": "Debug",
     "Spring Boot.XxlJobExecutorApplication.executor": "Debug",
     "WebServerToolWindowFactoryState": "false",
     "git-widget-placeholder": "main",
     "ignore.virus.scanning.warn.message": "true",
     "kotlin-language-version-configured": "true",
-    "last_opened_file_path": "F:/workspace/idea/xxl-job",
+    "last_opened_file_path": "F:/workspace/idea/xxl-job/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper",
     "node.js.detected.package.eslint": "true",
     "node.js.detected.package.tslint": "true",
     "node.js.selected.package.eslint": "(autodetect)",
     "node.js.selected.package.tslint": "(autodetect)",
     "nodejs_package_manager_path": "npm",
-    "project.structure.last.edited": "Modules",
+    "project.structure.last.edited": "Libraries",
     "project.structure.proportion": "0.15",
     "project.structure.side.proportion": "0.2",
     "settings.editor.selected.configurable": "MavenSettings",
@@ -116,11 +128,11 @@
 }]]></component>
   <component name="RecentsManager">
     <key name="CopyFile.RECENT_KEYS">
+      <recent name="F:\workspace\idea\xxl-job\xxl-job-executor-samples\xxl-job-executor-sample-springboot\src\main\resources\mapper" />
+      <recent name="F:\workspace\idea\xxl-job\xxl-job-executor-samples\xxl-job-executor-sample-springboot\src\main\java\com\xxl\job\executor\inter\entity" />
       <recent name="D:\workspace\xxl-job\xxl-job-executor-samples\xxl-job-executor-sample-springboot\src\main\resources\mapper" />
       <recent name="D:\workspace\xxl-job\xxl-job-executor-samples\xxl-job-executor-sample-springboot\src\main\java\com\xxl\job\executor\inter\entity" />
       <recent name="D:\workspace\xxl-job\xxl-job-admin\src\main\resources\mybatis-mapper" />
-      <recent name="D:\workspace\xxl-job\xxl-job-admin\src\main\resources" />
-      <recent name="D:\workspace\xxl-job\xxl-job-executor-samples\xxl-job-executor-sample-springboot\src\main\resources\lib" />
     </key>
     <key name="CopyClassDialog.RECENTS_KEY">
       <recent name="com.xxl.job.executor.inter.entity" />
@@ -132,8 +144,8 @@
   </component>
   <component name="RunAnythingCache">
     <option name="myCommands">
-      <command value="mvn install" />
       <command value="mvn clean" />
+      <command value="mvn install" />
     </option>
   </component>
   <component name="RunManager" selected="Spring Boot.XxlJobExecutorApplication">
@@ -221,9 +233,9 @@
     </configuration>
     <recent_temporary>
       <list>
+        <item itemvalue="Application.GenEntity" />
         <item itemvalue="JUnit.FramelessApplicationTest.test" />
         <item itemvalue="Application.DataUtils" />
-        <item itemvalue="Application.GenEntity" />
         <item itemvalue="Application.DataCenterXxlJob" />
         <item itemvalue="Application.PostUtils" />
       </list>
@@ -495,7 +507,18 @@
       <workItem from="1755136940711" duration="605000" />
       <workItem from="1755160595798" duration="618000" />
       <workItem from="1755566535267" duration="6629000" />
-      <workItem from="1757658871943" duration="40000" />
+      <workItem from="1757658871943" duration="2135000" />
+      <workItem from="1758873748521" duration="169000" />
+      <workItem from="1759036926254" duration="254000" />
+      <workItem from="1759037616683" duration="25000" />
+      <workItem from="1760429201023" duration="192000" />
+      <workItem from="1760429650217" duration="201000" />
+      <workItem from="1762302965783" duration="7101000" />
+      <workItem from="1762334647681" duration="12864000" />
+      <workItem from="1762423073353" duration="3565000" />
+      <workItem from="1763027067254" duration="2637000" />
+      <workItem from="1764577090400" duration="1118000" />
+      <workItem from="1766380473286" duration="4235000" />
     </task>
     <task id="LOCAL-00001" summary="初始化提交">
       <option name="closed" value="true" />
@@ -633,7 +656,31 @@
       <option name="project" value="LOCAL" />
       <updated>1755134051551</updated>
     </task>
-    <option name="localTasksCounter" value="18" />
+    <task id="LOCAL-00018" summary="新增字段及接口">
+      <option name="closed" value="true" />
+      <created>1757658946076</created>
+      <option name="number" value="00018" />
+      <option name="presentableId" value="LOCAL-00018" />
+      <option name="project" value="LOCAL" />
+      <updated>1757658946076</updated>
+    </task>
+    <task id="LOCAL-00019" summary="新增安全单位接口">
+      <option name="closed" value="true" />
+      <created>1762333452815</created>
+      <option name="number" value="00019" />
+      <option name="presentableId" value="LOCAL-00019" />
+      <option name="project" value="LOCAL" />
+      <updated>1762333452815</updated>
+    </task>
+    <task id="LOCAL-00020" summary="新增安全单位接口">
+      <option name="closed" value="true" />
+      <created>1762422871294</created>
+      <option name="number" value="00020" />
+      <option name="presentableId" value="LOCAL-00020" />
+      <option name="project" value="LOCAL" />
+      <updated>1762422871295</updated>
+    </task>
+    <option name="localTasksCounter" value="21" />
     <servers />
   </component>
   <component name="TypeScriptGeneratedFilesManager">
@@ -725,7 +772,8 @@
     <MESSAGE value="修新增接口预警" />
     <MESSAGE value="修改未执行日计划接口" />
     <MESSAGE value="新增字段及接口" />
-    <option name="LAST_COMMIT_MESSAGE" value="新增字段及接口" />
+    <MESSAGE value="新增安全单位接口" />
+    <option name="LAST_COMMIT_MESSAGE" value="新增安全单位接口" />
   </component>
   <component name="XDebuggerManager">
     <breakpoint-manager>
@@ -742,92 +790,97 @@
         </line-breakpoint>
         <line-breakpoint type="java-line">
           <url>file://$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/JjBusinessService.java</url>
-          <line>254</line>
+          <line>260</line>
           <option name="timeStamp" value="66" />
         </line-breakpoint>
         <line-breakpoint type="java-line">
           <url>file://$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService.java</url>
-          <line>880</line>
+          <line>913</line>
           <option name="timeStamp" value="72" />
         </line-breakpoint>
         <line-breakpoint type="java-line">
           <url>file://$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/InterService.java</url>
-          <line>910</line>
+          <line>943</line>
           <option name="timeStamp" value="73" />
         </line-breakpoint>
         <line-breakpoint type="java-line">
           <url>file://$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/JjBusinessService.java</url>
-          <line>120</line>
+          <line>126</line>
           <option name="timeStamp" value="90" />
         </line-breakpoint>
         <line-breakpoint type="java-line">
           <url>file://$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/JjBusinessService.java</url>
-          <line>159</line>
+          <line>165</line>
           <option name="timeStamp" value="92" />
         </line-breakpoint>
         <line-breakpoint type="java-line">
           <url>file://$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/JjBusinessService.java</url>
-          <line>198</line>
+          <line>204</line>
           <option name="timeStamp" value="93" />
         </line-breakpoint>
         <line-breakpoint type="java-line">
           <url>file://$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/JjBusinessService.java</url>
-          <line>446</line>
+          <line>452</line>
           <option name="timeStamp" value="97" />
         </line-breakpoint>
         <line-breakpoint type="java-line">
           <url>file://$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/JjBusinessService.java</url>
-          <line>467</line>
+          <line>473</line>
           <option name="timeStamp" value="98" />
         </line-breakpoint>
         <line-breakpoint type="java-line">
           <url>file://$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/JjBusinessService.java</url>
-          <line>502</line>
+          <line>508</line>
           <option name="timeStamp" value="99" />
         </line-breakpoint>
         <line-breakpoint type="java-line">
           <url>file://$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/JjBusinessService.java</url>
-          <line>637</line>
+          <line>643</line>
           <option name="timeStamp" value="102" />
         </line-breakpoint>
         <line-breakpoint type="java-line">
           <url>file://$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/JjBusinessService.java</url>
-          <line>674</line>
+          <line>680</line>
           <option name="timeStamp" value="103" />
         </line-breakpoint>
         <line-breakpoint type="java-line">
           <url>file://$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/JjBusinessService.java</url>
-          <line>856</line>
+          <line>862</line>
           <option name="timeStamp" value="106" />
         </line-breakpoint>
         <line-breakpoint type="java-line">
           <url>file://$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/JjBusinessService.java</url>
-          <line>547</line>
+          <line>553</line>
           <option name="timeStamp" value="109" />
         </line-breakpoint>
         <line-breakpoint type="java-line">
           <url>file://$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/JjBusinessService.java</url>
-          <line>42</line>
+          <line>48</line>
           <option name="timeStamp" value="110" />
         </line-breakpoint>
         <line-breakpoint type="java-line">
           <url>file://$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/JjBusinessService.java</url>
-          <line>841</line>
+          <line>847</line>
           <option name="timeStamp" value="150" />
         </line-breakpoint>
         <line-breakpoint type="java-line">
           <url>file://$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/JjBusinessService.java</url>
-          <line>830</line>
+          <line>836</line>
           <option name="timeStamp" value="151" />
         </line-breakpoint>
         <line-breakpoint type="java-line">
           <url>file://$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/JjBusinessService.java</url>
-          <line>784</line>
+          <line>790</line>
           <option name="timeStamp" value="156" />
         </line-breakpoint>
+        <line-breakpoint enabled="true" type="java-line">
+          <url>file://$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/utils/PostUtils.java</url>
+          <line>55</line>
+          <option name="timeStamp" value="162" />
+        </line-breakpoint>
         <line-breakpoint type="java-method">
           <url>file://$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/InterMapper.java</url>
-          <line>71</line>
+          <line>77</line>
           <properties class="com.xxl.job.executor.inter.mapper.InterMapper" method="insertJjBall">
             <option name="WATCH_EXIT" value="false" />
           </properties>
@@ -835,7 +888,7 @@
         </line-breakpoint>
         <line-breakpoint type="java-method">
           <url>file://$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/JjBusinessMapper.java</url>
-          <line>132</line>
+          <line>130</line>
           <properties class="com.xxl.job.executor.inter.mapper.JjBusinessMapper" method="deleteWarnInfo">
             <option name="EMULATED" value="true" />
             <option name="WATCH_EXIT" value="false" />
@@ -844,7 +897,7 @@
         </line-breakpoint>
         <line-breakpoint type="java-method">
           <url>file://$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/JjBusinessMapper.java</url>
-          <line>91</line>
+          <line>89</line>
           <properties class="com.xxl.job.executor.inter.mapper.JjBusinessMapper" method="getTeamNum">
             <option name="EMULATED" value="true" />
             <option name="WATCH_EXIT" value="false" />
@@ -853,7 +906,7 @@
         </line-breakpoint>
         <line-breakpoint type="java-method">
           <url>file://$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/JjBusinessMapper.java</url>
-          <line>305</line>
+          <line>303</line>
           <properties class="com.xxl.job.executor.inter.mapper.JjBusinessMapper" method="getClassRisk">
             <option name="EMULATED" value="true" />
             <option name="WATCH_EXIT" value="false" />
@@ -862,7 +915,7 @@
         </line-breakpoint>
         <line-breakpoint type="java-method">
           <url>file://$PROJECT_DIR$/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/JjBusinessMapper.java</url>
-          <line>303</line>
+          <line>301</line>
           <properties class="com.xxl.job.executor.inter.mapper.JjBusinessMapper" method="getTodayWorkInfo">
             <option name="EMULATED" value="true" />
             <option name="WATCH_EXIT" value="false" />
diff --git a/xxl-job-admin/src/main/resources/application.properties b/xxl-job-admin/src/main/resources/application.properties
index 28a7940..b33b65d 100644
--- a/xxl-job-admin/src/main/resources/application.properties
+++ b/xxl-job-admin/src/main/resources/application.properties
@@ -30,6 +30,10 @@ spring.datasource.url=jdbc:mysql://127.0.0.1:3306/gwjjspaq?useUnicode=true&chara
 spring.datasource.username=mroot
 spring.datasource.password=bonus@admin123
 
+#spring.datasource.url=jdbc:mysql://192.168.0.7:13306/gwjjspaq?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai
+#spring.datasource.username=root
+#spring.datasource.password=Bonus@admin123!
+
 #spring.datasource.url=jdbc:mysql://192.168.0.14:4417/gwjjspaq?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai
 #spring.datasource.username=root
 #spring.datasource.password=Bonus@admin123!
diff --git a/xxl-job-admin/src/main/resources/mybatis-mapper/XxlJobInfoMapper.xml b/xxl-job-admin/src/main/resources/mybatis-mapper/XxlJobInfoMapper.xml
index ed4fa5e..b118727 100644
--- a/xxl-job-admin/src/main/resources/mybatis-mapper/XxlJobInfoMapper.xml
+++ b/xxl-job-admin/src/main/resources/mybatis-mapper/XxlJobInfoMapper.xml
@@ -59,7 +59,7 @@
 
 	<select id="pageList" parameterType="java.util.HashMap" resultMap="XxlJobInfo">
 		SELECT <include refid="Base_Column_List" />
-		FROM xxl_job_info2 AS t
+		FROM xxl_job_info AS t
 		<trim prefix="WHERE" prefixOverrides="AND | OR" >
 			<if test="jobGroup gt 0">
 				AND t.job_group = #{jobGroup}
@@ -83,7 +83,7 @@
 
 	<select id="pageListCount" parameterType="java.util.HashMap" resultType="int">
 		SELECT count(1)
-		FROM xxl_job_info2 AS t
+		FROM xxl_job_info AS t
 		<trim prefix="WHERE" prefixOverrides="AND | OR" >
 			<if test="jobGroup gt 0">
 				AND t.job_group = #{jobGroup}
@@ -104,7 +104,7 @@
 	</select>
 
 	<insert id="save" parameterType="com.xxl.job.admin.core.model.XxlJobInfo" useGeneratedKeys="true" keyProperty="id" >
-		INSERT INTO xxl_job_info2 (
+		INSERT INTO xxl_job_info (
 			job_group,
 			job_desc,
 			add_time,
@@ -161,12 +161,12 @@
 
 	<select id="loadById" parameterType="java.util.HashMap" resultMap="XxlJobInfo">
 		SELECT <include refid="Base_Column_List" />
-		FROM xxl_job_info2 AS t
+		FROM xxl_job_info AS t
 		WHERE t.id = #{id}
 	</select>
 
 	<update id="update" parameterType="com.xxl.job.admin.core.model.XxlJobInfo" >
-		UPDATE xxl_job_info2
+		UPDATE xxl_job_info
 		SET
 			job_group = #{jobGroup},
 			job_desc = #{jobDesc},
@@ -195,25 +195,25 @@
 
 	<delete id="delete" parameterType="java.util.HashMap">
 		DELETE
-		FROM xxl_job_info2
+		FROM xxl_job_info
 		WHERE id = #{id}
 	</delete>
 
 	<select id="getJobsByGroup" parameterType="java.util.HashMap" resultMap="XxlJobInfo">
 		SELECT <include refid="Base_Column_List" />
-		FROM xxl_job_info2 AS t
+		FROM xxl_job_info AS t
 		WHERE t.job_group = #{jobGroup}
 	</select>
 
 	<select id="findAllCount" resultType="int">
 		SELECT count(1)
-		FROM xxl_job_info2
+		FROM xxl_job_info
 	</select>
 
 
 	<select id="scheduleJobQuery" parameterType="java.util.HashMap" resultMap="XxlJobInfo">
 		SELECT <include refid="Base_Column_List" />
-		FROM xxl_job_info2 AS t
+		FROM xxl_job_info AS t
 		WHERE t.trigger_status = 1
 			and t.trigger_next_time <![CDATA[ <= ]]> #{maxNextTime}
 		ORDER BY id ASC
@@ -221,7 +221,7 @@
 	</select>
 
 	<update id="scheduleUpdate" parameterType="com.xxl.job.admin.core.model.XxlJobInfo"  >
-		UPDATE xxl_job_info2
+		UPDATE xxl_job_info
 		SET
 			trigger_last_time = #{triggerLastTime},
 			trigger_next_time = #{triggerNextTime},
diff --git a/xxl-job-admin/src/main/resources/xxl-job/xxl-job2/XxlJobInfoMapper.xml b/xxl-job-admin/src/main/resources/xxl-job/xxl-job2/XxlJobInfoMapper.xml
deleted file mode 100644
index ed4fa5e..0000000
--- a/xxl-job-admin/src/main/resources/xxl-job/xxl-job2/XxlJobInfoMapper.xml
+++ /dev/null
@@ -1,232 +0,0 @@
-<?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.xxl.job.admin.dao.XxlJobInfoDao">
-
-	<resultMap id="XxlJobInfo" type="com.xxl.job.admin.core.model.XxlJobInfo" >
-		<result column="id" property="id" />
-		<result column="job_group" property="jobGroup" />
-	    <result column="job_desc" property="jobDesc" />
-	    <result column="add_time" property="addTime" />
-	    <result column="update_time" property="updateTime" />
-	    <result column="author" property="author" />
-	    <result column="alarm_email" property="alarmEmail" />
-		<result column="schedule_type" property="scheduleType" />
-		<result column="schedule_conf" property="scheduleConf" />
-		<result column="misfire_strategy" property="misfireStrategy" />
-		<result column="executor_route_strategy" property="executorRouteStrategy" />
-		<result column="executor_handler" property="executorHandler" />
-	    <result column="executor_param" property="executorParam" />
-		<result column="executor_block_strategy" property="executorBlockStrategy" />
-		<result column="executor_timeout" property="executorTimeout" />
-		<result column="executor_fail_retry_count" property="executorFailRetryCount" />
-	    <result column="glue_type" property="glueType" />
-	    <result column="glue_source" property="glueSource" />
-	    <result column="glue_remark" property="glueRemark" />
-		<result column="glue_updatetime" property="glueUpdatetime" />
-		<result column="child_jobid" property="childJobId" />
-		<result column="trigger_status" property="triggerStatus" />
-		<result column="trigger_last_time" property="triggerLastTime" />
-		<result column="trigger_next_time" property="triggerNextTime" />
-	</resultMap>
-
-	<sql id="Base_Column_List">
-		t.id,
-		t.job_group,
-		t.job_desc,
-		t.add_time,
-		t.update_time,
-		t.author,
-		t.alarm_email,
-		t.schedule_type,
-		t.schedule_conf,
-		t.misfire_strategy,
-		t.executor_route_strategy,
-		t.executor_handler,
-		t.executor_param,
-		t.executor_block_strategy,
-		t.executor_timeout,
-		t.executor_fail_retry_count,
-		t.glue_type,
-		t.glue_source,
-		t.glue_remark,
-		t.glue_updatetime,
-		t.child_jobid,
-		t.trigger_status,
-		t.trigger_last_time,
-		t.trigger_next_time
-	</sql>
-
-	<select id="pageList" parameterType="java.util.HashMap" resultMap="XxlJobInfo">
-		SELECT <include refid="Base_Column_List" />
-		FROM xxl_job_info2 AS t
-		<trim prefix="WHERE" prefixOverrides="AND | OR" >
-			<if test="jobGroup gt 0">
-				AND t.job_group = #{jobGroup}
-			</if>
-            <if test="triggerStatus gte 0">
-                AND t.trigger_status = #{triggerStatus}
-            </if>
-			<if test="jobDesc != null and jobDesc != ''">
-				AND t.job_desc like CONCAT(CONCAT('%', #{jobDesc}), '%')
-			</if>
-			<if test="executorHandler != null and executorHandler != ''">
-				AND t.executor_handler like CONCAT(CONCAT('%', #{executorHandler}), '%')
-			</if>
-			<if test="author != null and author != ''">
-				AND t.author like CONCAT(CONCAT('%', #{author}), '%')
-			</if>
-		</trim>
-		ORDER BY id DESC
-		LIMIT #{offset}, #{pagesize}
-	</select>
-
-	<select id="pageListCount" parameterType="java.util.HashMap" resultType="int">
-		SELECT count(1)
-		FROM xxl_job_info2 AS t
-		<trim prefix="WHERE" prefixOverrides="AND | OR" >
-			<if test="jobGroup gt 0">
-				AND t.job_group = #{jobGroup}
-			</if>
-            <if test="triggerStatus gte 0">
-                AND t.trigger_status = #{triggerStatus}
-            </if>
-			<if test="jobDesc != null and jobDesc != ''">
-				AND t.job_desc like CONCAT(CONCAT('%', #{jobDesc}), '%')
-			</if>
-			<if test="executorHandler != null and executorHandler != ''">
-				AND t.executor_handler like CONCAT(CONCAT('%', #{executorHandler}), '%')
-			</if>
-			<if test="author != null and author != ''">
-				AND t.author like CONCAT(CONCAT('%', #{author}), '%')
-			</if>
-		</trim>
-	</select>
-
-	<insert id="save" parameterType="com.xxl.job.admin.core.model.XxlJobInfo" useGeneratedKeys="true" keyProperty="id" >
-		INSERT INTO xxl_job_info2 (
-			job_group,
-			job_desc,
-			add_time,
-			update_time,
-			author,
-			alarm_email,
-			schedule_type,
-			schedule_conf,
-			misfire_strategy,
-            executor_route_strategy,
-			executor_handler,
-			executor_param,
-			executor_block_strategy,
-			executor_timeout,
-			executor_fail_retry_count,
-			glue_type,
-			glue_source,
-			glue_remark,
-			glue_updatetime,
-			child_jobid,
-			trigger_status,
-			trigger_last_time,
-			trigger_next_time
-		) VALUES (
-			#{jobGroup},
-			#{jobDesc},
-			#{addTime},
-			#{updateTime},
-			#{author},
-			#{alarmEmail},
-			#{scheduleType},
-			#{scheduleConf},
-			#{misfireStrategy},
-			#{executorRouteStrategy},
-			#{executorHandler},
-			#{executorParam},
-			#{executorBlockStrategy},
-			#{executorTimeout},
-			#{executorFailRetryCount},
-			#{glueType},
-			#{glueSource},
-			#{glueRemark},
-			#{glueUpdatetime},
-			#{childJobId},
-			#{triggerStatus},
-			#{triggerLastTime},
-			#{triggerNextTime}
-		);
-		<!--<selectKey resultType="java.lang.Integer" order="AFTER" keyProperty="id">
-			SELECT LAST_INSERT_ID()
-			/*SELECT @@IDENTITY AS id*/
-		</selectKey>-->
-	</insert>
-
-	<select id="loadById" parameterType="java.util.HashMap" resultMap="XxlJobInfo">
-		SELECT <include refid="Base_Column_List" />
-		FROM xxl_job_info2 AS t
-		WHERE t.id = #{id}
-	</select>
-
-	<update id="update" parameterType="com.xxl.job.admin.core.model.XxlJobInfo" >
-		UPDATE xxl_job_info2
-		SET
-			job_group = #{jobGroup},
-			job_desc = #{jobDesc},
-			update_time = #{updateTime},
-			author = #{author},
-			alarm_email = #{alarmEmail},
-			schedule_type = #{scheduleType},
-			schedule_conf = #{scheduleConf},
-			misfire_strategy = #{misfireStrategy},
-			executor_route_strategy = #{executorRouteStrategy},
-			executor_handler = #{executorHandler},
-			executor_param = #{executorParam},
-			executor_block_strategy = #{executorBlockStrategy},
-			executor_timeout = ${executorTimeout},
-			executor_fail_retry_count = ${executorFailRetryCount},
-			glue_type = #{glueType},
-			glue_source = #{glueSource},
-			glue_remark = #{glueRemark},
-			glue_updatetime = #{glueUpdatetime},
-			child_jobid = #{childJobId},
-			trigger_status = #{triggerStatus},
-			trigger_last_time = #{triggerLastTime},
-			trigger_next_time = #{triggerNextTime}
-		WHERE id = #{id}
-	</update>
-
-	<delete id="delete" parameterType="java.util.HashMap">
-		DELETE
-		FROM xxl_job_info2
-		WHERE id = #{id}
-	</delete>
-
-	<select id="getJobsByGroup" parameterType="java.util.HashMap" resultMap="XxlJobInfo">
-		SELECT <include refid="Base_Column_List" />
-		FROM xxl_job_info2 AS t
-		WHERE t.job_group = #{jobGroup}
-	</select>
-
-	<select id="findAllCount" resultType="int">
-		SELECT count(1)
-		FROM xxl_job_info2
-	</select>
-
-
-	<select id="scheduleJobQuery" parameterType="java.util.HashMap" resultMap="XxlJobInfo">
-		SELECT <include refid="Base_Column_List" />
-		FROM xxl_job_info2 AS t
-		WHERE t.trigger_status = 1
-			and t.trigger_next_time <![CDATA[ <= ]]> #{maxNextTime}
-		ORDER BY id ASC
-		LIMIT #{pagesize}
-	</select>
-
-	<update id="scheduleUpdate" parameterType="com.xxl.job.admin.core.model.XxlJobInfo"  >
-		UPDATE xxl_job_info2
-		SET
-			trigger_last_time = #{triggerLastTime},
-			trigger_next_time = #{triggerNextTime},
-			trigger_status = #{triggerStatus}
-		WHERE id = #{id}
-	</update>
-
-</mapper>
\ No newline at end of file
diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/DbDistLockUtilMapper.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/DbDistLockUtilMapper.java
new file mode 100644
index 0000000..7ed317b
--- /dev/null
+++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/mapper/DbDistLockUtilMapper.java
@@ -0,0 +1,20 @@
+package com.xxl.job.executor.inter.mapper;
+
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.Date;
+
+@Mapper
+public interface DbDistLockUtilMapper {
+    /**
+     * 更新锁
+     * @param lockKey
+     * @param now
+     */
+    void update(@Param("lockKey") String lockKey, @Param("now")Date now);
+
+    int insert(@Param("jobId") Long jobId, @Param("lockKey") String lockKey,@Param("lockOwner")  String lockOwner,@Param("now")  Date now,@Param("expireTime")  Date expireTime);
+
+    void delete(@Param("lockKey") String lockKey,@Param("lockOwner") String lockOwner);
+}
diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/DbDistLockUtil.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/DbDistLockUtil.java
new file mode 100644
index 0000000..5e0e5e7
--- /dev/null
+++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/inter/service/DbDistLockUtil.java
@@ -0,0 +1,67 @@
+package com.xxl.job.executor.inter.service;
+
+import com.xxl.job.executor.inter.mapper.DbDistLockUtilMapper;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Component;
+import org.springframework.stereotype.Service;
+
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+import java.util.Date;
+
+@Service
+@Slf4j
+@Component
+public class DbDistLockUtil {
+
+    @Value("${xxl.job.executor.port}")
+    private String port;
+
+    @Autowired
+    private JdbcTemplate jdbcTemplate;
+
+    @Autowired
+    private DbDistLockUtilMapper mapper;
+
+    // 获取锁（返回true表示获取成功）
+    public boolean tryLock(Long jobId, long expireSeconds) {
+        String lockKey = "xxl_job_lock_" + jobId;
+        // 执行器唯一标识（IP+端口，避免同机多实例冲突）
+        String lockOwner = getLocalIp() + ":" + port;
+        Date now = new Date();
+        Date expireTime = new Date(now.getTime() + expireSeconds * 1000);
+
+        try {
+            // 1. 先清理过期锁（防止死锁）
+            mapper.update( lockKey, now);
+            // 2. 插入锁（唯一键约束，仅一个执行器能成功）
+            int affected=mapper.insert( jobId, lockKey, lockOwner, now, expireTime);
+            return affected > 0;
+        } catch (Exception e) {
+            log.error(e.getMessage(), e);
+            // 唯一键冲突时，说明已被其他执行器抢占
+            return false;
+        }
+    }
+
+    // 释放锁（仅释放自己持有的锁）
+    public void releaseLock(Long jobId) {
+        String lockKey = "xxl_job_lock_" + jobId;
+        String lockOwner = getLocalIp() + ":" + port;
+        mapper.delete(lockKey, lockOwner);
+
+    }
+    // 辅助：获取本地IP
+    private String getLocalIp() {
+        try {
+            return InetAddress.getLocalHost().getHostAddress();
+        } catch (UnknownHostException e) {
+            return "127.0.0.1";
+        }
+    }
+
+
+}
\ No newline at end of file
diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/DataCenterXxlJob.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/DataCenterXxlJob.java
index 08717d8..ec953b2 100644
--- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/DataCenterXxlJob.java
+++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/DataCenterXxlJob.java
@@ -1,6 +1,8 @@
 package com.xxl.job.executor.service.jobhandler;
 
+import com.xxl.job.core.context.XxlJobHelper;
 import com.xxl.job.core.handler.annotation.XxlJob;
+import com.xxl.job.executor.inter.service.DbDistLockUtil;
 import com.xxl.job.executor.inter.service.InterService;
 import com.xxl.job.executor.inter.service.InterTwoService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -17,15 +19,34 @@ public class DataCenterXxlJob {
 
     @Autowired
     private InterService interService;
+
     @Autowired
     private InterTwoService twtoService ;
+    @Autowired
+    DbDistLockUtil lockUtil;
+    /**
     /**
      * 项目信息
      */
     @XxlJob("getProInfo")
     public void getProInfo(){
-        interService.getProInfo(1);
-        twtoService.getProInfo(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getProInfo(1);
+            twtoService.getProInfo(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
+
     }
 
     /**
@@ -33,8 +54,22 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getBidPro")
     public void getBidPro(){
-        interService.getBidPro(1);
-        twtoService.getBidPro(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getBidPro(1);
+            twtoService.getBidPro(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
 
@@ -43,8 +78,22 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getTeam")
     public  void getTeam(){
-        interService.getTeam(1);
-        twtoService.getTeam(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getTeam(1);
+            twtoService.getTeam(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -52,8 +101,22 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getTeamPeople")
     public  void getTeamPeople(){
-        interService.getTeamPeople(1);
-        twtoService.getTeamPeople(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getTeamPeople(1);
+            twtoService.getTeamPeople(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -61,8 +124,22 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getTicket")
     public  void getTicket(){
-        interService.getTicket(1);
-        twtoService.getTicket(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getTicket(1);
+            twtoService.getTicket(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -70,7 +147,21 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getTicketInfo")
     public  void getTicketInfo(){
-        interService.getTicketInfo();
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getTicketInfo();
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -78,8 +169,22 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getTicketPeople")
     public  void getTicketPeople(){
-        interService.getTicketPeople(1);
-        twtoService.getTicketPeople(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getTicketPeople(1);
+            twtoService.getTicketPeople(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -87,8 +192,22 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getNewTicketPeople")
     public  void getNewTicketPeople(){
-        interService.getNewTicketPeople(1);
-        twtoService.getNewTicketPeople(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getNewTicketPeople(1);
+            twtoService.getNewTicketPeople(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
 
@@ -97,16 +216,45 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getDayPlan")
     public  void getDayPlan(){
-        interService.getDayPlan(1);
-        twtoService.getDayPlan(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getDayPlan(1);
+            twtoService.getDayPlan(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
+
     }
     /**
      * 周计划
      */
     @XxlJob("getWeeksPlan")
     public  void getWeeksPlan(){
-        interService.getWeeksPlan(1);
-        twtoService.getWeeksPlan(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getWeeksPlan(1);
+            twtoService.getWeeksPlan(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -114,8 +262,22 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getJJUser")
     public  void getJJUser(){
-        interService.getJJUser(1);
-        twtoService.getJJUser(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getJJUser(1);
+            twtoService.getJJUser(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -123,16 +285,45 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getJJAQUnit")
     public  void getJJAQUnit(){
-        interService.getJJAQUnit(1);
-        twtoService.getJJAQUnit(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getJJAQUnit(1);
+            twtoService.getJJAQUnit(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
+
     }
     /**
      * 布控球
      */
     @XxlJob("getJJBall")
     public  void getJJBall(){
-        interService.getJJBall(1);
-        twtoService.getJJBall(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getJJBall(1);
+            twtoService.getJJBall(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -140,23 +331,48 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getJJBidInfo")
     public  void getJJBidInfo(){
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getJJBidInfo(1);
+            twtoService.getJJBidInfo(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
 
-        interService.getJJBidInfo(1);
-        twtoService.getJJBidInfo(1);
     }
 
 
-
-
-
     /**
      * 站班会定时任务
      */
     @XxlJob("getClassMeetingInfo")
     @PostConstruct
     public void getClassMeetingInfo() {
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
             interService.getClassMeetingInfo(1);
             twtoService.getClassMeetingInfo(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -164,8 +380,22 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getClassMeetingPeopleInfo")
     public void getClassMeetingPeopleInfo() {
-        interService.getClassMeetingPeopleInfo(1);
-        twtoService.getClassMeetingPeopleInfo(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getClassMeetingPeopleInfo(1);
+            twtoService.getClassMeetingPeopleInfo(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -173,8 +403,22 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getNewClassMeetingPeopleInfo")
     public void getNewClassMeetingPeopleInfo() {
-        interService.getNewClassMeetingPeopleInfo(1);
-        twtoService.getNewClassMeetingPeopleInfo(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getNewClassMeetingPeopleInfo(1);
+            twtoService.getNewClassMeetingPeopleInfo(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -186,8 +430,22 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getSingleProjectInfo")
     public void getSingleProjectInfo() {
-        interService.getSingleProjectInfo(1);
-        twtoService.getSingleProjectInfo(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getSingleProjectInfo(1);
+            twtoService.getSingleProjectInfo(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -199,8 +457,22 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getOnDutyInfo")
     public void getOnDutyInfo() {
-        interService.getOnDutyInfo(1);
-        twtoService.getOnDutyInfo(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getOnDutyInfo(1);
+            twtoService.getOnDutyInfo(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -212,8 +484,22 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getRiskPrecautionInfo")
     public void getRiskPrecautionInfo() {
-        interService.getRiskPrecautionInfo(1);
-        twtoService.getRiskPrecautionInfo(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getRiskPrecautionInfo(1);
+            twtoService.getRiskPrecautionInfo(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -225,8 +511,22 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getUnitInfo")
     public void getUnitInfo() {
-        interService.getUnitInfo(1);
-        twtoService.getUnitInfo(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getUnitInfo(1);
+            twtoService.getUnitInfo(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
 
@@ -239,8 +539,22 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getGtInfo")
     public void getGtInfo() {
-        interService.getGtInfo(1);
-        twtoService.getGtInfo(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getGtInfo(1);
+            twtoService.getGtInfo(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -251,20 +565,24 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getDeptGcProject")
     public void getDeptGcProject() {
-        interService.getDeptGcProject(1);
-        twtoService.getDeptGcProject(1);
-    }
-    /**
-     * 扩展信息定时任务
-     *风险管控一本账 -风险预控措施
-     * @return void
-     * @author cwchen
-     * @date 2024/5/8 14:53
-     */
-    @XxlJob("getSmDwRiskPrecautionInfo")
-    public void getSmDwRiskPrecautionInfo() {
-     //   interService.getSmDwRiskPrecautionInfo(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getDeptGcProject(1);
+            twtoService.getDeptGcProject(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
+
     /**
      * 扩展信息定时任务
      *风险管控一本账 -风险预控措施
@@ -274,73 +592,31 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getInfo")
     public void getInfo() {
-        interService.getInfo(1,"40");
-        interService.getInfo(1,"10");
-        interService.getInfo(1,"20");
-        interService.getInfo(1,"30");
-        interService.getInfo(1,"50");
-        interService.getInfo(1,"60");
-        interService.getClassMeting();
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getInfo(1,"40");
+            interService.getInfo(1,"10");
+            interService.getInfo(1,"20");
+            interService.getInfo(1,"30");
+            interService.getInfo(1,"50");
+            interService.getInfo(1,"60");
+            interService.getClassMeting();
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
 
     }
 
 
 
-    /**
-     * 扩展信息定时任务
-     *施工作业票_预控措施
-     * @return void
-     * @author cwchen
-     * @date 2024/5/8 14:53
-     */
-    @XxlJob("getSmConstructionWorkTicketInfo")
-    public void getSmConstructionWorkTicketInfo() {
-      //  interService.getSmConstructionWorkTicketInfo(1);
-    }
-    /**
-     * 扩展信息定时任务
-     *预控措施_站班会
-     * @return void
-     * @author cwchen
-     * @date 2024/5/8 14:53
-     */
-    @XxlJob("getSmDwToolBoxTalkInfo")
-    public void getSmDwToolBoxTalkInfo() {
-     //   interService.getSmDwToolBoxTalkInfo(1);
-    }
-
-    /**
-     * 作业票->扩展信息
-     */
-    @XxlJob("getSmConstructionWorkTicketInfo2")
-    public void getSmConstructionWorkTicketInfo2() {
-      //  interService.getSmConstructionWorkTicketInfo2(1);
-    }
-
-    /**
-     * 风险一本账扩展信息
-     */
-    @XxlJob("getSmDwRiskPrecautionInfo2")
-    public void getSmDwRiskPrecautionInfo2() {
-       // interService.getSmDwRiskPrecautionInfo2(1);
-    }
-
-    /**
-     * 站班会扩展信息
-     */
-    @XxlJob("getSmDwToolBoxTalkInfo2")
-    public void getSmDwToolBoxTalkInfo2() {
-     //   interService.getSmDwToolBoxTalkInfo2(1);
-    }
-
-    /**
-     * 站班会_拆分扩展信息
-     */
-    @XxlJob("getSmDwDataStandardExtInfo")
-    public void getSmDwDataStandardExtInfo() {
-        //  interService.getSmDwDataStandardExtInfo(1);
-    }
-
 
     /**
      * 扩展信息定时任务
@@ -351,7 +627,22 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getClassMettingInfo")
     public void getClassMettingInfo() {
-        interService.getClassMettingInfo();
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getClassMettingInfo();
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
+
     }
 
     /**
@@ -359,15 +650,44 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getJjFile")
     public void getJjFile(){
-             interService.getJjFile();
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getJjFile();
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
+
     }
     /**
      * 固有风险清册
      */
     @XxlJob("getJjRisk")
     public void getJjRisk() {
-        interService.getJjRisk(1);
-        twtoService.getJjRisk(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getJjRisk(1);
+            twtoService.getJjRisk(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -375,9 +695,23 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getSignInfoPro")
     public void getSignInfoPro() {
-        interService.deleteData();
-        interService.getSignInfoPro(1);
-        twtoService.getSignInfoPro(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.deleteData();
+            interService.getSignInfoPro(1);
+            twtoService.getSignInfoPro(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -385,7 +719,21 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getProGf")
     public void getProGf() {
-        interService.getProGf(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getProGf(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -393,8 +741,22 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getGcLL")
     public  void getGcLL(){
-        interService.getGcLL(1);
-        twtoService.getGcLL(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getGcLL(1);
+            twtoService.getGcLL(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -402,8 +764,22 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getBidProNew")
     public void getBidProNew(){
-        interService.getBidProNew(1);
-        twtoService.getBidProNew(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getBidProNew(1);
+            twtoService.getBidProNew(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -411,14 +787,42 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getJjDljData")
     public void getJjDljData(){
-        interService.getJjDljData(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getJjDljData(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
     /**
      * 区段
      */
     @XxlJob("getQdData")
     public void getQdData(){
-        interService.getQdData(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getQdData(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -426,7 +830,21 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getBdData")
     public void getBdData(){
-        interService.getBdData(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getBdData(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
 
@@ -435,7 +853,22 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getBallByClass")
     public void getBallByClass(){
-        interService.getBallByClass();
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getBallByClass();
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
+
     }
 
     /**
@@ -443,8 +876,22 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getProHt")
     public void getProHt(){
-        interService.getProHt(1);
-        twtoService.getProHt(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getProHt(1);
+            twtoService.getProHt(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -452,8 +899,22 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getProProcess")
     public void getProProcess(){
-        interService.getProProcess(1);
-        twtoService.getProProcess(1);
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            interService.getProProcess(1);
+            twtoService.getProProcess(1);
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
 
@@ -462,7 +923,21 @@ public class DataCenterXxlJob {
      */
     @XxlJob("getWeeksInfo")
     public void getWeeksInfo(){
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
             interService.getWeeksInfo();
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
 
diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/JJBusinessXxlJob.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/JJBusinessXxlJob.java
index af6ceab..65cca1f 100644
--- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/JJBusinessXxlJob.java
+++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/JJBusinessXxlJob.java
@@ -1,6 +1,8 @@
 package com.xxl.job.executor.service.jobhandler;
 
+import com.xxl.job.core.context.XxlJobHelper;
 import com.xxl.job.core.handler.annotation.XxlJob;
+import com.xxl.job.executor.inter.service.DbDistLockUtil;
 import com.xxl.job.executor.inter.service.JjBusinessService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
@@ -16,14 +18,27 @@ public class JJBusinessXxlJob {
 
     @Autowired
     private JjBusinessService service ;
-
-
+    @Autowired
+    DbDistLockUtil lockUtil;
     /**
      * 预警管理-今日未施工
      */
     @XxlJob("todayNoWork")
     public void todayNoWork(){
-        service.todayNoWork();
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            service.todayNoWork();
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
     }
 
     /**
@@ -31,7 +46,20 @@ public class JJBusinessXxlJob {
      */
     @XxlJob("todayNewTeam")
     public void todayNewTeam(){
-        service.todayNewTeam();
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            service.todayNewTeam();
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
     }
 
     /**
@@ -39,14 +67,42 @@ public class JJBusinessXxlJob {
      */
     @XxlJob("todaySevenNoWork")
     public void todaySevenNoWork(){
-        service.todaySevenNoWork();
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            service.todaySevenNoWork();
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
     /**
      * 预警管理-人数变化大
      */
     @XxlJob("todayUseNumChange")
     public void todayUseNumChange(){
-         service.todayUseNumChange();
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            service.todayUseNumChange();
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+          lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -54,7 +110,21 @@ public class JJBusinessXxlJob {
      */
     @XxlJob("todayGxChange")
     public void todayGxChange(){
-        service.todayGxChange();
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            service.todayGxChange();
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -62,7 +132,20 @@ public class JJBusinessXxlJob {
      */
     @XxlJob("todayWorkChange")
     public void todayWorkChange(){
-        service.todayWorkChange();
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            service.todayWorkChange();
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
     }
 
     /**
@@ -71,7 +154,21 @@ public class JJBusinessXxlJob {
     @XxlJob("todayWarnFpByUserId")
     @PostConstruct
     public void todayWarnFpByUserId(){
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
             service.todayWarnFpByUserId();
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -80,7 +177,21 @@ public class JJBusinessXxlJob {
      */
     @XxlJob("startEndWork")
     public void startEndWork(){
-        service.startEndWork();
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            service.startEndWork();
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -89,7 +200,21 @@ public class JJBusinessXxlJob {
     @XxlJob("getBallFew")
 
     public void getBallFew(){
-        service.getBallFew();
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            service.getBallFew();
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -97,14 +222,42 @@ public class JJBusinessXxlJob {
      */
     @XxlJob("getBallUpDown")
     public void getBallUpDown(){
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
             service.getBallUpDown();
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
     /**
      * 对施工班组进行初始化添加
      */
     @XxlJob("addNewTeam")
     private void addNewTeam(){
-        service.addNewTeam();
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            service.addNewTeam();
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
+
     }
 
     /**
@@ -113,7 +266,20 @@ public class JJBusinessXxlJob {
     @XxlJob("threeSpan")
     @PostConstruct
     private void threeSpan(){
-        service.threeSpan();
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            service.threeSpan();
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
     }
 
     /**
@@ -122,7 +288,20 @@ public class JJBusinessXxlJob {
     @XxlJob("teamThreeSpan")
     @PostConstruct
     private void teamThreeSpan(){
-        service.teamThreeSpan();
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            service.teamThreeSpan();
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
     }
 
 
@@ -133,12 +312,38 @@ public class JJBusinessXxlJob {
     @XxlJob("getWorkGxNoWork")
     @PostConstruct
     public void getWorkGxNoWork(){
-        service.getWorkGxNoWork();
-    }
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            service.getWorkGxNoWork();
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
 
+    }
 
     @PostConstruct
     private void addNewTeam2(){
-        service.addNewTeam2();
+        Long jobId = XxlJobHelper.getJobId();
+        boolean locked = lockUtil.tryLock(jobId, 60);
+        if (!locked) {
+            XxlJobHelper.log("已有执行器执行该任务，本次放弃");
+            XxlJobHelper.handleFail("任务已在执行");
+            return;
+        }
+        try {
+            // 核心业务逻辑
+            service.addNewTeam2();
+        } finally {
+            // 最终释放锁（防止任务异常导致锁残留）
+            lockUtil.releaseLock(jobId);
+        }
     }
 }
diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/application.properties b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/application.properties
index 32bca4b..242c885 100644
--- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/application.properties
+++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/application.properties
@@ -4,8 +4,9 @@ server.port=18084
 #spring.main.web-environment=false
 # log config
 logging.config=classpath:logback.xml
-#xxl.job.admin.addresses=http://20.51.8.9:18083/xxl-job-admin
+#xxl.job.admin.addresses=http://20.51.8.10:18083/xxl-job-admin
 xxl.job.admin.addresses=http://127.0.0.1:18083/xxl-job-admin
+#xxl.job.admin.addresses=http://192.168.0.7:58883/xxl-job-admin
 #xxl.job.admin.addresses=http://192.168.0.14:58883/xxl-job-admin
 ### xxl-job, access token
 xxl.job.accessToken=default_token
@@ -31,6 +32,9 @@ spring.datasource.url=jdbc:mysql://127.0.0.1:3306/gwjjspaq?useUnicode=true&chara
 spring.datasource.username=mroot
 spring.datasource.password=bonus@admin123
 
+#spring.datasource.url=jdbc:mysql://192.168.0.7:13306/gwjjspaq?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai
+#spring.datasource.username=root
+#spring.datasource.password=Bonus@admin123!
 #spring.datasource.url=jdbc:mysql://192.168.0.14:4417/gwjjspaq?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai
 #spring.datasource.username=root
 #spring.datasource.password=Bonus@admin123!
diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/DbDistLockUtilMapper.xml b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/DbDistLockUtilMapper.xml
new file mode 100644
index 0000000..dd1d73c
--- /dev/null
+++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/mapper/DbDistLockUtilMapper.xml
@@ -0,0 +1,16 @@
+<?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.xxl.job.executor.inter.mapper.DbDistLockUtilMapper">
+	<insert id="insert">
+		INSERT INTO xxl_job_dist_lock (job_id, lock_key, lock_owner, lock_time, expire_time) VALUES
+ 			(#{jobId}, #{lockKey}, #{lockOwner}, #{now}, #{expireTime})
+	</insert>
+	<delete id="update">
+		DELETE FROM xxl_job_dist_lock WHERE lock_key = #{lockKey} AND expire_time &lt; #{now}
+	</delete>
+	<delete id="delete">
+		DELETE FROM xxl_job_dist_lock WHERE lock_key = #{lockKey} AND lock_owner = #{lockOwner}
+
+	</delete>
+</mapper>
\ No newline at end of file