| | |
| | | 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; |
| | |
| | | @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); |
| | | } |
| | | } |