package cn.gistack.job.executor.service.impl;
|
|
import cn.gistack.job.executor.entity.XxlJobInfo;
|
import cn.gistack.job.executor.entity.XxlJobInfoType;
|
import cn.gistack.job.executor.mapper.XxlJobInfoMapper;
|
import cn.gistack.job.executor.service.IXxlJobInfoService;
|
import cn.gistack.job.executor.vo.XxlJobInfoVO;
|
import com.baomidou.dynamic.datasource.annotation.DS;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import org.springframework.stereotype.Service;
|
|
/**
|
* @PROJECT_NAME: skjcmanager
|
* @DESCRIPTION:
|
* @USER: aix
|
* @DATE: 2023/5/15 14:53
|
*/
|
@Service
|
@DS("xxljob")
|
public class XxlJobInfoServiceImpl extends ServiceImpl<XxlJobInfoMapper, XxlJobInfo> implements IXxlJobInfoService {
|
|
/**
|
* 自定义新增定时任务
|
* @param xxlJobInfo
|
* @return
|
*/
|
@Override
|
public Object saveXxlJob(XxlJobInfoVO xxlJobInfo) {
|
boolean flag = false;
|
boolean save = save(xxlJobInfo);
|
if (save){
|
XxlJobInfoType xxlJobInfoType = new XxlJobInfoType();
|
xxlJobInfoType.setXxlJobInfoId(xxlJobInfo.getId());
|
xxlJobInfoType.setTypeName(xxlJobInfo.getTypeName());
|
// 插入成功则
|
Integer insert = baseMapper.insertXxlJobInfoType(xxlJobInfoType);
|
if (insert >0){
|
flag = true;
|
}
|
}
|
return flag;
|
}
|
|
/**
|
* 自定义修改定时任务
|
* @param xxlJobInfo
|
* @return
|
*/
|
@Override
|
public Object updateXxlJobById(XxlJobInfoVO xxlJobInfo) {
|
boolean update = updateById(xxlJobInfo);
|
return update;
|
}
|
|
/**
|
* 自定义分页查询定时任务列表信息
|
* @param xxlJobInfo
|
* @param page
|
* @return
|
*/
|
@Override
|
public IPage<XxlJobInfoVO> selectXxlJobPage(IPage<XxlJobInfoVO> page, XxlJobInfoVO xxlJobInfo) {
|
return page.setRecords(baseMapper.selectXxlJobPage(page,xxlJobInfo));
|
}
|
}
|
