gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

feat: 3.2.0

Browse Source 
优化日志合并逻辑
This commit is contained in:
byteblogs168 2024-03-26 10:45:42 +08:00
parent 33627a08e0
commit 1a9d2e43bc
2 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
easy-retry-server/easy-retry-server-job-task/src/main/java/com/aizuda/easy/retry/server/job/task/support/JobTaskConverter.java
View File

@ -129,4 +129,6 @@ public interface JobTaskConverter {
CompleteJobBatchDTO completeJobBatchDTO(JobTaskPrepareDTO jobTaskPrepareDTO); CompleteJobBatchDTO completeJobBatchDTO(JobTaskPrepareDTO jobTaskPrepareDTO);
JobLogMessage toJobLogMessage(JobLogMessage jobLogMessage);
} }

9
easy-retry-server/easy-retry-server-job-task/src/main/java/com/aizuda/easy/retry/server/job/task/support/schedule/JobLogMergeSchedule.java
View File

@ -168,11 +168,12 @@ public class JobLogMergeSchedule extends AbstractSchedule implements Lifecycle {
systemProperties.getMergeLogNum()); systemProperties.getMergeLogNum());
for (int i = 0; i < partitionMessages.size(); i++) { for (int i = 0; i < partitionMessages.size(); i++) {
JobLogMessage jobLogMessage = jobLogMessageMap.getValue().get(i); // 深拷贝
// 剔除不需要删除的数据 JobLogMessage jobLogMessage = JobTaskConverter.INSTANCE.toJobLogMessage( jobLogMessageMap.getValue().get(0));
jobLogMessageDeleteBatchIds.remove(jobLogMessage.getId()); List<String> messages = partitionMessages.get(i);
jobLogMessage.setMessage(JsonUtil.toJsonString(partitionMessages.get(0))); jobLogMessage.setLogNum(messages.size());
jobLogMessage.setMessage(JsonUtil.toJsonString(messages));
jobLogMessageUpdateList.add(jobLogMessage); jobLogMessageUpdateList.add(jobLogMessage);
} }