com.platform.service.impl

Class ScheduleJobServiceImpl

java.lang.Object

com.baomidou.mybatisplus.extension.service.impl.ServiceImpl<ScheduleJobDao,ScheduleJobEntity>

com.platform.service.impl.ScheduleJobServiceImpl

All Implemented Interfaces:

com.baomidou.mybatisplus.extension.service.IService<ScheduleJobEntity>, ScheduleJobService

@Service(value="scheduleJobService")
public class ScheduleJobServiceImpl
extends com.baomidou.mybatisplus.extension.service.impl.ServiceImpl<ScheduleJobDao,ScheduleJobEntity>
implements ScheduleJobService

Author:

李鹏军

Field Summary

Fields inherited from class com.baomidou.mybatisplus.extension.service.impl.ServiceImpl

baseMapper

Constructor Summary

Constructors

Constructor and Description
ScheduleJobServiceImpl()

Method Summary

Modifier and Type	Method and Description
void	add(ScheduleJobEntity scheduleJob) 新增定时任务
void	deleteBatch(Long[] jobIds) 批量删除定时任务
void	init() 项目启动时，初始化定时器
void	pause(Long[] jobIds) 暂停运行
PageUtilsPlus	queryPage(Map<String,Object> params) 获取分页数据
void	resume(Long[] jobIds) 恢复运行
void	run(Long[] jobIds) 立即执行
void	update(ScheduleJobEntity scheduleJob) 更新定时任务
void	updateBatch(Long[] jobIds, int status) 批量更新定时任务状态

Methods inherited from class com.baomidou.mybatisplus.extension.service.impl.ServiceImpl

closeSqlSession, count, currentModelClass, getBaseMapper, getById, getMap, getOne, list, listByIds, listByMap, listMaps, listObjs, page, pageMaps, remove, removeById, removeByIds, removeByMap, retBool, save, saveBatch, saveOrUpdate, saveOrUpdateBatch, sqlSessionBatch, sqlStatement, update, updateBatchById, updateById

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.baomidou.mybatisplus.extension.service.IService

count, count, getBaseMapper, getById, getMap, getObj, getOne, getOne, lambdaQuery, lambdaUpdate, list, list, listByIds, listByMap, listMaps, listMaps, listObjs, listObjs, listObjs, listObjs, page, page, pageMaps, pageMaps, query, remove, removeById, removeByIds, removeByMap, save, saveBatch, saveBatch, saveOrUpdate, saveOrUpdateBatch, saveOrUpdateBatch, update, update, update, updateBatchById, updateBatchById, updateById

Constructor Detail

ScheduleJobServiceImpl

public ScheduleJobServiceImpl()

Method Detail

init

@PostConstruct
public void init()

项目启动时，初始化定时器

queryPage

public PageUtilsPlus queryPage(Map<String,Object> params)

Description copied from interface: ScheduleJobService

获取分页数据

Specified by:

queryPage in interface ScheduleJobService

Parameters:

params - 查询参数

Returns:

Page

add

@Transactional(rollbackFor=java.lang.Exception.class)
public void add(ScheduleJobEntity scheduleJob)

Description copied from interface: ScheduleJobService

新增定时任务

Specified by:

add in interface ScheduleJobService

Parameters:

scheduleJob - scheduleJob

update

@Transactional(rollbackFor=java.lang.Exception.class)
public void update(ScheduleJobEntity scheduleJob)

Description copied from interface: ScheduleJobService

更新定时任务

Specified by:

update in interface ScheduleJobService

Parameters:

scheduleJob - scheduleJob

deleteBatch

@Transactional(rollbackFor=java.lang.Exception.class)
public void deleteBatch(Long[] jobIds)

Description copied from interface: ScheduleJobService

批量删除定时任务

Specified by:

deleteBatch in interface ScheduleJobService

Parameters:

jobIds - jobIds

updateBatch

public void updateBatch(Long[] jobIds,
                        int status)

Description copied from interface: ScheduleJobService

批量更新定时任务状态

Specified by:

updateBatch in interface ScheduleJobService

Parameters:

jobIds - jobIds

status - status

run

@Transactional(rollbackFor=java.lang.Exception.class)
public void run(Long[] jobIds)

Description copied from interface: ScheduleJobService

立即执行

Specified by:

run in interface ScheduleJobService

Parameters:

jobIds - jobIds

pause

@Transactional(rollbackFor=java.lang.Exception.class)
public void pause(Long[] jobIds)

Description copied from interface: ScheduleJobService

暂停运行

Specified by:

pause in interface ScheduleJobService

Parameters:

jobIds - jobIds

resume

@Transactional(rollbackFor=java.lang.Exception.class)
public void resume(Long[] jobIds)

Description copied from interface: ScheduleJobService

恢复运行

Specified by:

resume in interface ScheduleJobService

Parameters:

jobIds - jobIds