From f26537e926d7ad2d725e059700142ba14c0c2b1f Mon Sep 17 00:00:00 2001
From: jiangqs <jiangqs>
Date: 星期三, 12 七月 2023 21:04:27 +0800
Subject: [PATCH] 定时任务延时任务
---
ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/config/DelayTaskServiceImpl.java | 48 +++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 47 insertions(+), 1 deletions(-)
diff --git a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/config/DelayTaskServiceImpl.java b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/config/DelayTaskServiceImpl.java
index 6b53f85..ed85561 100644
--- a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/config/DelayTaskServiceImpl.java
+++ b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/config/DelayTaskServiceImpl.java
@@ -1,6 +1,8 @@
package com.ruoyi.system.service.impl.config;
-import com.ruoyi.system.domain.pojo.config.DelayTask;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
+import com.ruoyi.system.api.domain.poji.config.DelayTask;
import com.ruoyi.system.mapper.config.DelayTaskMapper;
import com.ruoyi.system.service.config.DelayTaskService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -17,4 +19,48 @@
@Service
public class DelayTaskServiceImpl extends ServiceImpl<DelayTaskMapper, DelayTask> implements DelayTaskService {
+
+ /**
+ * @description
+ * @author jqs
+ * @date 2023/7/12 11:38
+ * @param key
+ * @return DelayTask
+ */
+ @Override
+ public DelayTask getDelayTask(String key){
+ LambdaQueryWrapper<DelayTask> queryWrapper = new LambdaQueryWrapper<>();
+ queryWrapper.eq(DelayTask::getDelFlag,0);
+ queryWrapper.eq(DelayTask::getRedisKey,key);
+ DelayTask delayTask = this.getOne(queryWrapper,false);
+ return delayTask;
+ }
+
+ /**
+ * @description
+ * @author jqs
+ * @date 2023/7/12 11:37
+ * @param delayTask
+ * @return void
+ */
+ @Override
+ public void addDelayTask(DelayTask delayTask){
+ this.saveOrUpdate(delayTask);
+ }
+
+ /**
+ * @description
+ * @author jqs
+ * @date 2023/7/12 11:39
+ * @param key
+ * @return DelayTask
+ */
+ @Override
+ public void deleteDelayTask(String key){
+ LambdaUpdateWrapper<DelayTask> updateWrapper = new LambdaUpdateWrapper<>();
+ updateWrapper.eq(DelayTask::getDelFlag,0);
+ updateWrapper.eq(DelayTask::getRedisKey,key);
+ updateWrapper.set(DelayTask::getDelFlag,1);
+ this.update(updateWrapper);
+ }
}
--
Gitblit v1.7.1