package com.ruoyi.system.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ruoyi.system.api.domain.DelayTask;
|
import com.ruoyi.system.mapper.DelayTaskMapper;
|
import com.ruoyi.system.service.DelayTaskService;
|
import org.springframework.stereotype.Service;
|
|
/**
|
* <p>
|
* 服务实现类
|
* </p>
|
*
|
* @author jqs
|
* @since 2023-05-29
|
*/
|
@Service
|
public class DelayTaskServiceImpl extends ServiceImpl<DelayTaskMapper, DelayTask> implements
|
DelayTaskService {
|
|
|
/**
|
* @param key
|
* @return DelayTask
|
* @description
|
* @author jqs
|
* @date 2023/7/12 11:38
|
*/
|
@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;
|
}
|
|
/**
|
* @param delayTask
|
* @return void
|
* @description
|
* @author jqs
|
* @date 2023/7/12 11:37
|
*/
|
@Override
|
public void addDelayTask(DelayTask delayTask) {
|
this.saveOrUpdate(delayTask);
|
}
|
|
/**
|
* @param key
|
* @return DelayTask
|
* @description
|
* @author jqs
|
* @date 2023/7/12 11:39
|
*/
|
@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);
|
}
|
}
|
