From ff087240b3dee29ce4e14ad0836e76b9fdf312cf Mon Sep 17 00:00:00 2001
From: MrShi <1878285526@qq.com>
Date: 星期二, 19 八月 2025 09:28:07 +0800
Subject: [PATCH] Merge branch 'master' of http://139.186.142.91:10010/r/productDev/lianhelihua_sh
---
server/src/main/java/com/doumee/biz/system/impl/SystemJobTriggerBizImpl.java | 9 ++++++---
1 files changed, 6 insertions(+), 3 deletions(-)
diff --git a/server/src/main/java/com/doumee/biz/system/impl/SystemJobTriggerBizImpl.java b/server/src/main/java/com/doumee/biz/system/impl/SystemJobTriggerBizImpl.java
index 6a4f965..e8bd12c 100644
--- a/server/src/main/java/com/doumee/biz/system/impl/SystemJobTriggerBizImpl.java
+++ b/server/src/main/java/com/doumee/biz/system/impl/SystemJobTriggerBizImpl.java
@@ -11,6 +11,7 @@
import com.doumee.core.job.JobContext;
import com.doumee.core.job.JobParam;
import com.doumee.core.utils.Utils;
+import com.doumee.dao.system.SystemJobLogMapper;
import com.doumee.dao.system.SystemJobMapper;
import com.doumee.dao.system.SystemJobSnippetMapper;
import com.doumee.dao.system.model.SystemJob;
@@ -32,7 +33,7 @@
public class SystemJobTriggerBizImpl implements SystemJobTriggerBiz {
@Autowired
- private SystemJobLogService systemJobLogService;
+ private SystemJobLogMapper systemJobLogMapper;
@Autowired
private SystemJobMapper systemJobMapper;
@@ -75,7 +76,7 @@
systemJobLog.setStatus(Constants.Job.LogStatus.NONE.getCode());
systemJobLog.setTriggerType(dto.getTriggerType());
systemJobLog.setRemark("浠诲姟姝ｅ湪鎵ц涓�");
- systemJobLogService.create(systemJobLog);
+ systemJobLogMapper.insert(systemJobLog);
}
// 浠诲姟鍔犻攣锛岄槻姝㈠鏈嶅姟鍣ㄩ噸澶嶆墽琛�
this.lock(job);
@@ -132,7 +133,7 @@
if (job != null && job.getWithLog() && systemJobLog.getId() != null) {
systemJobLog.setRunTimeEnd(new Date());
systemJobLog.setRunSpendTime(Integer.valueOf("" + (systemJobLog.getRunTimeEnd().getTime() - systemJobLog.getRunTimeStart().getTime())));
- systemJobLogService.updateById(systemJobLog);
+ systemJobLogMapper.updateById(systemJobLog);
}
// 浠诲姟瑙ｉ攣
if (locked) {
@@ -205,6 +206,7 @@
snippet.setDistributeLimit(job.getDistributeLimit());
snippet.setHandler(job.getHandler());
snippet.setSnippetIndex(0);
+ snippet.setCreateTime(new Date());
snippet.setSnippetCode(UUID.randomUUID().toString());
snippet.setWithLog(job.getWithLog());
snippet.setAllowServerIps(job.getAllowServerIps());
@@ -235,6 +237,7 @@
snippet.setJobDistributeGroup(distributeGroup);
snippet.setHandler(job.getHandler());
snippet.setSnippetIndex(i);
+ snippet.setCreateTime(new Date());
snippet.setSnippetCode(UUID.randomUUID().toString());
snippet.setSnippetData(JSON.toJSONString(snippetData));
snippet.setSnippetDataSize(snippetData.size());
--
Gitblit v1.9.3