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

fix(1.5.0-beta1): 修复滑动窗口提取数据的时间间隔问题和完成时为设置delete的值

Browse Source
This commit is contained in:
opensnail 2025-04-22 22:09:03 +08:00
parent e75c56c248
commit edca09ea7c
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/window/SlidingWindow.java
View File

@ -329,7 +329,7 @@ public class SlidingWindow<T> {
threadPoolExecutor.scheduleAtFixedRate(() -> {
try {
extract(LocalDateTime.now().minus(duration, chronoUnit));
extract(LocalDateTime.now());
} catch (Exception e) {
SnailJobLog.LOCAL.error("Sliding window exception", e);
}

2
snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/RetryServiceImpl.java
View File

@ -168,12 +168,14 @@ public class RetryServiceImpl implements RetryService {
waitStrategyContext.setDelayLevel(retry.getRetryCount() + 1);
WaitStrategy waitStrategy = WaitStrategyEnum.getWaitStrategy(retrySceneConfig.getBackOff());
retry.setNextTriggerAt(waitStrategy.computeTriggerTime(waitStrategyContext));
retry.setDeleted(0L);
}
if (RetryStatusEnum.FINISH.getStatus().equals(retryStatusEnum.getStatus())) {
RetryLogMetaDTO retryLogMetaDTO = RetryTaskConverter.INSTANCE.toLogMetaDTO(retry);
retryLogMetaDTO.setTimestamp(DateUtils.toNowMilli());
SnailJobLog.REMOTE.info("============Manual operation completed============. <|>{}<|>", retryLogMetaDTO);
retry.setDeleted(retry.getId());
}
retry.setUpdateDt(LocalDateTime.now());