xservice/xservice-cornucopia
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat:定时任务开发

Browse Source
This commit is contained in:
Xiang
2026-01-09 16:43:45 +08:00
parent 6f998d06ce
commit 429ff6fdfa
1 changed files with 0 additions and 44 deletions
Download Patch File Download Diff File Expand all files Collapse all files

44
xservice-core/src/main/java/com/xiang/app/common/manage/QuartzConfigManageImpl.java
View File

@@ -1,44 +0,0 @@
package com.xiang.app.common.manage;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.xiang.xmc.service.quartz.domain.entity.JobConfigDO;
import com.xiang.xmc.service.quartz.manage.IQuartzConfigManage;
import com.xiang.xmc.service.quartz.mapper.JobConfigMapper;
import com.xiang.xmc.xservice.mysql.annotation.DynamicDataSource;
import org.springframework.stereotype.Service;
import java.util.List;
/**
* @Author: xiang
* @Date: 2026-01-05 14:21
*/
@Service
public class QuartzConfigManageImpl extends ServiceImpl<JobConfigMapper, JobConfigDO> implements IQuartzConfigManage {
@Override
@DynamicDataSource(value = "xxz-job")
public JobConfigDO getByName(String appName, String beanName) {
LambdaQueryWrapper<JobConfigDO> lqw = Wrappers.lambdaQuery();
lqw.eq(JobConfigDO::getApplicationName, appName);
lqw.eq(JobConfigDO::getBeanName, beanName);
lqw.eq(JobConfigDO::getDelFlag, 0);
return baseMapper.selectOne(lqw);
}
@Override
@DynamicDataSource(value = "xxz-job")
public List<JobConfigDO> selectByAppName(String appName) {
LambdaQueryWrapper<JobConfigDO> lqw = Wrappers.lambdaQuery();
lqw.eq(JobConfigDO::getApplicationName, appName);
lqw.eq(JobConfigDO::getDelFlag, 0);
return baseMapper.selectList(lqw);
}
@Override
@DynamicDataSource(value = "xxz-job")
public int delByAppName(String appName) {
return 0;
}
}