调度性能提升：任务触发后分批批量更新，提升调度性能；

doc/XXL-JOB官方文档.md

@@ -2785,10 +2785,11 @@ public void execute() {
 - 10、【优化】统一项目依赖管理结构，依赖版本统一到父级pom提升可维护性；
 
 ### 7.44 版本 v3.4.0 Release Notes[ING]
-- 1、【优化】父POM依赖配置优化，移除容易配置；合并PR-3926；
+- 1、【优化】调度性能提升：任务触发后分批批量更新，提升调度性能；
 - 2、【调整】Docker基础镜像调整为eclipse-temurin；
-- 3、【TODO】调度触发性能优化：调度触发后任务分批批量更新，提升调度性能；
-- 4、【TODO】调度中心OpenAPI完善，提供任务管理能力；封装Agent Skill并推送ClawHub；
+- 3、【优化】父POM依赖配置优化，移除容易配置；合并PR-3926；
+- 4、【升级】升级多项maven依赖至较新版本；
+- 5、【TODO】调度中心OpenAPI完善，提供任务管理能力；封装Agent Skill并推送ClawHub；
 
 
 ### TODO LIST
@@ -2827,11 +2828,10 @@ public void execute() {
   - 调度日志：全局配置：废弃； 新增“调度日志策略”：任务维度自定义，保留3天、7天、1个月、3个月、一年、永久；
   - 执行日志：新增“执行RollingLog开关”：任务维度自定义，支持：RollingLog、普通日志（slf4j输出）、关闭（不输出）；
 - 21、AccessToken：废弃全局配置；支持在线管理，动态生成、动态启停；
-- 22、任务执行后分批批量更新，提升调度性能；
-- 23、任务管理OpenAPI;
-- 24、调度中心启动参数线上配置：告警发送邮箱、Token，支持线上配置生效，修改不需重启机器；
-- 25、执行器内嵌server切换tomcat，精简依赖；
-- 26、日志策略新增：
+- 22、任务管理OpenAPI;
+- 23、调度中心启动参数线上配置：告警发送邮箱、Token，支持线上配置生效，修改不需重启机器；
+- 24、执行器内嵌server切换tomcat，精简依赖；
+- 25、日志策略新增：
   - 调度日志策略：任务级设置，最少保留1天。 
   - 执行日志策略：可选 RollingLog、slf4jLog；
   - 清理逻辑，性能重构。

pom.xml

@@ -25,29 +25,29 @@
 		<maven.compiler.target>17</maven.compiler.target>
 		<maven.test.skip>true</maven.test.skip>
 		<!-- plugin -->
-		<maven-compiler-plugin.version>3.14.1</maven-compiler-plugin.version>
+		<maven-compiler-plugin.version>3.15.0</maven-compiler-plugin.version>
 		<maven-source-plugin.version>3.4.0</maven-source-plugin.version>
 		<maven-javadoc-plugin.version>3.12.0</maven-javadoc-plugin.version>
 		<maven-gpg-plugin.version>3.2.8</maven-gpg-plugin.version>
-		<central-publishing-maven-plugin.version>0.9.0</central-publishing-maven-plugin.version>
+		<central-publishing-maven-plugin.version>0.10.0</central-publishing-maven-plugin.version>
 		<!-- base -->
 		<slf4j-api.version>2.0.17</slf4j-api.version>
-		<junit-jupiter.version>6.0.1</junit-jupiter.version>
+		<junit-jupiter.version>6.0.3</junit-jupiter.version>
 
 		<!-- jakarta.annotation-api -->
 		<jakarta.annotation-api.version>3.0.0</jakarta.annotation-api.version>
 
 		<!-- spring -->
-		<spring-boot.version>4.0.1</spring-boot.version>
-		<spring.version>7.0.2</spring.version>
+		<spring-boot.version>4.0.5</spring-boot.version>
+		<spring.version>7.0.6</spring.version>
 		<!-- mybatis & db -->
 		<mybatis-spring-boot-starter.version>4.0.1</mybatis-spring-boot-starter.version>
-		<mysql-connector-j.version>9.5.0</mysql-connector-j.version>
+		<mysql-connector-j.version>9.6.0</mysql-connector-j.version>
 
 		<!-- net -->
-		<netty.version>4.2.9.Final</netty.version>
+		<netty.version>4.2.12.Final</netty.version>
 		<!-- groovy -->
-		<groovy.version>5.0.3</groovy.version>
+		<groovy.version>5.0.4</groovy.version>
 
 		<!-- xxl-sso -->
 		<xxl-sso.version>2.3.2</xxl-sso.version>
@@ -57,9 +57,9 @@
 		<gson.version>2.13.2</gson.version>
 
 		<!-- spring-ai -->
-		<spring-ai.version>2.0.0-M1</spring-ai.version>
+		<spring-ai.version>2.0.0-M4</spring-ai.version>
 		<!-- dify -->
-		<dify-java-client.version>1.2.3</dify-java-client.version>
+		<dify-java-client.version>1.2.5</dify-java-client.version>
 	</properties>
 
 	<dependencyManagement>

xxl-job-admin/src/main/java/com/xxl/job/admin/mapper/XxlJobInfoMapper.java

@@ -61,5 +61,12 @@ public interface XxlJobInfoMapper {
 	 */
 	public int scheduleUpdate(XxlJobInfo xxlJobInfo);
 
+	/**
+	 * batch update job info
+	 *
+	 * @param jobInfoList
+	 * @return
+	 */
+	public int scheduleBatchUpdate(@Param("list") List<XxlJobInfo> jobInfoList);
 
 }

xxl-job-admin/src/main/java/com/xxl/job/admin/scheduler/thread/JobScheduleHelper.java

@@ -59,7 +59,7 @@ public class JobScheduleHelper {
                 }
                 logger.info(">>>>>>>>> init xxl-job admin scheduler success.");
 
-                // pre-read count: treadpool-size * trigger-qps (each trigger cost 100ms, qps = 1000/100 = 100)
+                // pre-read count: treadpool-size * 10 (trigger-qps: 1000ms / 100ms each trigger cost)
                 int preReadCount = (XxlJobAdminBootstrap.getInstance().getTriggerPoolFastMax() + XxlJobAdminBootstrap.getInstance().getTriggerPoolSlowMax()) * 10;
 
                 // do schedule
@@ -138,8 +138,14 @@ public class JobScheduleHelper {
                             }
 
                             // 3、update trigger info
-                            for (XxlJobInfo jobInfo: scheduleList) {
+                            /*for (XxlJobInfo jobInfo: scheduleList) {
                                 XxlJobAdminBootstrap.getInstance().getXxlJobInfoMapper().scheduleUpdate(jobInfo);
+                            }*/
+                            int batchSize = 100;
+                            List<List<XxlJobInfo>> scheduleListBatches = CollectionTool.split(scheduleList, batchSize);
+                            for (List<XxlJobInfo> scheduleListBatch : scheduleListBatches) {
+                                int totalAffected = XxlJobAdminBootstrap.getInstance().getXxlJobInfoMapper().scheduleBatchUpdate(scheduleListBatch);
+                                logger.debug(">>>>>>>>>>> xxl-job, JobScheduleHelper scheduleBatchUpdate records:" + totalAffected);
                             }
 
                         } else {

xxl-job-admin/src/main/resources/mapper/XxlJobInfoMapper.xml

@@ -240,34 +240,39 @@
 		  AND trigger_status = 1
 	</update>
 
-	<!--int scheduleUpdateBatch(@Param("list") List<XxlJobInfo> jobs);
-	<update id="scheduleUpdateBatch" parameterType="java.util.List">
+	<update id="scheduleBatchUpdate" parameterType="java.util.List">
 		UPDATE xxl_job_info
 		SET
 			trigger_last_time = CASE id
-			<foreach collection="list" item="item">
+			<foreach collection="list" item="item" separator=" ">
 				WHEN #{item.id} THEN #{item.triggerLastTime}
 			</foreach>
+			ELSE trigger_last_time
 			END,
 			trigger_next_time = CASE id
-			<foreach collection="list" item="item">
+			<foreach collection="list" item="item" separator=" ">
 				WHEN #{item.id} THEN #{item.triggerNextTime}
 			</foreach>
+			ELSE trigger_next_time
 			END,
 			trigger_status = CASE id
-			<foreach collection="list" item="item">
+			<foreach collection="list" item="item" separator=" ">
 				WHEN #{item.id} THEN
 				<choose>
-					<when test="item.triggerStatus >= 0">#{item.triggerStatus}</when>
-					<otherwise>trigger_status</otherwise> &lt;!&ndash; 保持原值 &ndash;&gt;
+					<when test="item.triggerStatus gte 0">
+						#{item.triggerStatus}
+					</when>
+					<otherwise>trigger_status</otherwise>
 				</choose>
 			</foreach>
+			ELSE trigger_status
 			END
 		WHERE id IN
 			<foreach collection="list" item="item" open="(" separator="," close=")">
 				#{item.id}
 			</foreach>
 			AND trigger_status = 1
-	</update>-->
+	</update>
+
 
 </mapper>

xxl-job-admin/src/test/java/com/xxl/job/admin/mapper/XxlJobInfoMapperTest.java

@@ -1,8 +1,12 @@
 package com.xxl.job.admin.mapper;
 
+import com.xxl.job.admin.constant.TriggerStatus;
 import com.xxl.job.admin.model.XxlJobInfo;
+import com.xxl.job.admin.scheduler.config.XxlJobAdminBootstrap;
 import com.xxl.job.admin.scheduler.misfire.MisfireStrategyEnum;
 import com.xxl.job.admin.scheduler.type.ScheduleTypeEnum;
+import com.xxl.tool.core.CollectionTool;
+import com.xxl.tool.core.DateTool;
 import jakarta.annotation.Resource;
 import org.junit.jupiter.api.Test;
 import org.slf4j.Logger;
@@ -83,4 +87,28 @@ public class XxlJobInfoMapperTest {
 
 	}
 
+	@Test
+	public void scheduleBatchUpdateTest(){
+
+		List<XxlJobInfo> list1 = xxlJobInfoMapper.pageList(0, 20, 0, -1, null, null, null);
+		int batchSize = 5;
+
+		// update
+		List<XxlJobInfo> list2 = list1.stream().filter(item -> (item.getId()>=4 && item.getId()<=14)).toList();
+		list2.forEach(item -> {
+			item.setTriggerLastTime(DateTool.addHours(new Date(), -1).getTime());
+			item.setTriggerNextTime(DateTool.addHours(new Date(), 1).getTime());
+			if (item.getId() == 5) {
+				item.setTriggerStatus(TriggerStatus.STOPPED.getValue());
+			}
+		});
+
+		// batch update
+		List<List<XxlJobInfo>> scheduleListBatches = CollectionTool.split(list2, batchSize);
+		for (List<XxlJobInfo> scheduleListBatch : scheduleListBatches) {
+			int totalAffected = XxlJobAdminBootstrap.getInstance().getXxlJobInfoMapper().scheduleBatchUpdate(scheduleListBatch);
+			logger.info("scheduleBatchUpdate records:" + totalAffected);
+		}
+	}
+
 }