Merge branch 'dev' of http://git.estsh.com/i3-IMPP/i3plus-core into dev
wei.peng
6 years ago
commit
b9b8484a1a
@ -0,0 +1,150 @@
|
||||
package cn.estsh.i3plus.core.apiservice.controller.busi;
|
||||
|
||||
import cn.estsh.i3plus.core.api.iservice.busi.ISysTaskService;
|
||||
import cn.estsh.i3plus.platform.common.tool.StringTool;
|
||||
import cn.estsh.i3plus.platform.common.util.PlatformConstWords;
|
||||
import cn.estsh.i3plus.pojo.base.bean.ListPager;
|
||||
import cn.estsh.i3plus.pojo.base.common.Pager;
|
||||
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
|
||||
import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil;
|
||||
import cn.estsh.i3plus.pojo.platform.bean.SysTask;
|
||||
import cn.estsh.impp.framework.base.controller.CoreBaseController;
|
||||
import cn.estsh.impp.framework.boot.exception.ImppBusiException;
|
||||
import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
|
||||
import cn.estsh.impp.framework.boot.exception.ImppExceptionEnum;
|
||||
import cn.estsh.impp.framework.boot.util.ResultBean;
|
||||
import cn.estsh.impp.framework.boot.util.ValidatorBean;
|
||||
import io.swagger.annotations.Api;
|
||||
import io.swagger.annotations.ApiOperation;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.web.bind.annotation.*;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* @Description : 任务管理服务
|
||||
* @Reference :
|
||||
* @Author : yunhao
|
||||
* @CreateDate : 2018-12-27 15:13
|
||||
* @Modify:
|
||||
**/
|
||||
@RestController
|
||||
@Api(description = "任务管理服务")
|
||||
@RequestMapping(PlatformConstWords.BASE_URL + "/task")
|
||||
public class SysTaskController extends CoreBaseController {
|
||||
|
||||
public static final Logger LOGGER = LoggerFactory.getLogger(SysTaskController.class);
|
||||
|
||||
@Autowired
|
||||
private ISysTaskService sysTaskService;
|
||||
|
||||
@PostMapping(value = "/insert")
|
||||
@ApiOperation(value = "添加任务", notes = "添加任务")
|
||||
public ResultBean insertSysTask(SysTask sysTask) {
|
||||
try {
|
||||
// 数据校验
|
||||
ValidatorBean.beginValid(sysTask)
|
||||
.notNull("name", sysTask.getName())
|
||||
.notNull("taskPackage", sysTask.getTaskPackage())
|
||||
.notNull("taskClass", sysTask.getTaskClass());
|
||||
|
||||
sysTaskService.insertSysTask(sysTask);
|
||||
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultObject(sysTask);
|
||||
} catch (ImppBusiException busExcep) {
|
||||
return ResultBean.fail(busExcep);
|
||||
} catch (Exception e) {
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
@PutMapping(value = "/update")
|
||||
@ApiOperation(value = "修改任务", notes = "修改任务")
|
||||
public ResultBean updateSysTask(SysTask sysTask) {
|
||||
try {
|
||||
// 数据校验
|
||||
ValidatorBean.beginValid(sysTask)
|
||||
.notNull("name", sysTask.getName())
|
||||
.notNull("taskPackage", sysTask.getTaskPackage())
|
||||
.notNull("taskClass", sysTask.getTaskClass());
|
||||
|
||||
sysTaskService.updateSysTask(sysTask);
|
||||
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
|
||||
} catch (ImppBusiException busExcep) {
|
||||
return ResultBean.fail(busExcep);
|
||||
} catch (Exception e) {
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
@DeleteMapping(value = "/delete/{id}")
|
||||
@ApiOperation(value = "删除任务", notes = "删除任务")
|
||||
public ResultBean deleteSysTaskById(@PathVariable("id") String idStr) {
|
||||
try {
|
||||
// 数据校验
|
||||
ValidatorBean.checkNotNull(idStr, "id不能为空");
|
||||
if (sysTaskService.getSysTaskById(Long.parseLong(idStr)) == null) {
|
||||
throw ImppExceptionBuilder.newInstance()
|
||||
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
|
||||
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION_DATA_NOT_EXIT.getCode())
|
||||
.setErrorDetail("任务不存在")
|
||||
.setErrorSolution("请重新选择")
|
||||
.build();
|
||||
}
|
||||
|
||||
sysTaskService.deleteSysTaskById(Long.parseLong(idStr));
|
||||
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
|
||||
} catch (ImppBusiException busExcep) {
|
||||
return ResultBean.fail(busExcep);
|
||||
} catch (Exception e) {
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
@GetMapping(value = "/list")
|
||||
@ApiOperation(value = "查询所有任务", notes = "查询所有任务")
|
||||
public ResultBean listSysTask() {
|
||||
try {
|
||||
List sysTaskList = sysTaskService.listSysTask();
|
||||
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultList(sysTaskList);
|
||||
} catch (ImppBusiException busExcep) {
|
||||
return ResultBean.fail(busExcep);
|
||||
} catch (Exception e) {
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
@GetMapping(value = "/query")
|
||||
@ApiOperation(value = "任务复杂查询", notes = "任务复杂查询,分页，排序")
|
||||
public ResultBean querySysTaskByPager(SysTask sysTask, Pager pager) {
|
||||
try {
|
||||
ListPager<SysTask> sysTaskList = sysTaskService.querySysTaskByPager(sysTask, pager);
|
||||
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setListPager(sysTaskList);
|
||||
} catch (ImppBusiException busExcep) {
|
||||
return ResultBean.fail(busExcep);
|
||||
} catch (Exception e) {
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
@DeleteMapping(value = "/batch-delete")
|
||||
@ApiOperation(value = "根据id批量删除任务", notes = "根据id批量删除任务")
|
||||
public ResultBean deleteSysTaskByIds(String[] idsStr) {
|
||||
try {
|
||||
if (idsStr == null || idsStr.length == 0) {
|
||||
throw ImppExceptionBuilder.newInstance()
|
||||
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
|
||||
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
|
||||
.setErrorDetail("请选择需要删除的资源。")
|
||||
.build();
|
||||
}
|
||||
sysTaskService.deleteSysTaskByIds(StringTool.getArrayLong(idsStr));
|
||||
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
|
||||
} catch (ImppBusiException busExcep) {
|
||||
return ResultBean.fail(busExcep);
|
||||
} catch (Exception e) {
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,223 @@
|
||||
package cn.estsh.i3plus.core.apiservice.controller.busi;
|
||||
|
||||
import cn.estsh.i3plus.core.api.iservice.busi.ISysTaskCycleService;
|
||||
import cn.estsh.i3plus.core.api.iservice.busi.ISysTaskPlanService;
|
||||
import cn.estsh.i3plus.core.api.iservice.busi.ISysTaskService;
|
||||
import cn.estsh.i3plus.platform.common.util.PlatformConstWords;
|
||||
import cn.estsh.i3plus.pojo.base.bean.ListPager;
|
||||
import cn.estsh.i3plus.pojo.base.common.Pager;
|
||||
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
|
||||
import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil;
|
||||
import cn.estsh.i3plus.pojo.platform.bean.SysTask;
|
||||
import cn.estsh.i3plus.pojo.platform.bean.SysTaskCycle;
|
||||
import cn.estsh.i3plus.pojo.platform.bean.SysTaskPlan;
|
||||
import cn.estsh.impp.framework.base.controller.CoreBaseController;
|
||||
import cn.estsh.impp.framework.boot.auth.AuthUtil;
|
||||
import cn.estsh.impp.framework.boot.exception.ImppBusiException;
|
||||
import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
|
||||
import cn.estsh.impp.framework.boot.util.ResultBean;
|
||||
import cn.estsh.impp.framework.boot.util.ValidatorBean;
|
||||
import io.swagger.annotations.Api;
|
||||
import io.swagger.annotations.ApiOperation;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.web.bind.annotation.*;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* @Description : 任务计划管理服务
|
||||
* @Reference :
|
||||
* @Author : yunhao
|
||||
* @Date : 2018-12-27 10:45
|
||||
* @Modify :
|
||||
**/
|
||||
@RestController
|
||||
@Api(description = "任务计划管理服务")
|
||||
@RequestMapping(PlatformConstWords.BASE_URL +"/task-plan")
|
||||
public class SysTaskPlanController extends CoreBaseController{
|
||||
|
||||
public static final Logger LOGGER = LoggerFactory.getLogger(SysTaskPlanController.class);
|
||||
|
||||
@Autowired
|
||||
private ISysTaskPlanService sysTaskPlanService;
|
||||
|
||||
@Autowired
|
||||
private ISysTaskCycleService sysTaskCycleService;
|
||||
|
||||
@Autowired
|
||||
private ISysTaskService sysTaskService;
|
||||
|
||||
@PostMapping(value = "/insert")
|
||||
@ApiOperation(value = "新增任务计划", notes = "任务计划")
|
||||
public ResultBean insertSysTaskTime(SysTaskPlan sysTaskPlan, Boolean isExecute) {
|
||||
try {
|
||||
// 数据校验
|
||||
ValidatorBean.beginValid(sysTaskPlan)
|
||||
.notNull("name", sysTaskPlan.getName())
|
||||
.notNull("groupName",sysTaskPlan.getGroupName())
|
||||
.notNull("taskCycleId",sysTaskPlan.getTaskCycleId())
|
||||
.notNull("taskId",sysTaskPlan.getTaskId())
|
||||
.notNull("taskMethodType", sysTaskPlan.getTaskMethodType());
|
||||
|
||||
SysTaskCycle sysTaskCycle = sysTaskCycleService.getSysTaskCycleById(sysTaskPlan.getTaskCycleId());
|
||||
ValidatorBean.checkNotNull(sysTaskCycle,"任务周期不存在");
|
||||
|
||||
SysTask sysTask = sysTaskService.getSysTaskById(sysTaskPlan.getTaskId());
|
||||
ValidatorBean.checkNotNull(sysTask,"任务不存在");
|
||||
|
||||
// 设置冗余信息
|
||||
sysTaskPlan.setTaskPlanExecNum(0);
|
||||
sysTaskPlan.setTaskNameRdd(sysTask.getName());
|
||||
sysTaskPlan.setTaskCycleNameRdd(sysTaskCycle.getName());
|
||||
sysTaskPlan.setTaskCycleExpsRdd(sysTaskCycle.getTaskCycleExps());
|
||||
sysTaskPlan.setTaskCycleStartDateTimeRdd(sysTaskCycle.getTaskCycleStartDatetime());
|
||||
sysTaskPlan.setTaskCycleEndDateTimeRdd(sysTaskCycle.getTaskCycleEndDatetime());
|
||||
sysTaskPlan.setTaskPlanStatus(CommonEnumUtil.DATA_STATUS.ENABLE.getValue());
|
||||
|
||||
sysTaskPlan = sysTaskPlanService.insertSysTaskPlan(sysTaskPlan,sysTaskCycle,sysTask);
|
||||
// 立即执行
|
||||
if(isExecute != null && isExecute){
|
||||
sysTaskPlanService.executeSysTaskPlan(sysTaskPlan);
|
||||
}
|
||||
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultObject(sysTaskPlan);
|
||||
}catch(ImppBusiException busExcep){
|
||||
return ResultBean.fail(busExcep);
|
||||
}catch(Exception e){
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
@PutMapping(value = "/update")
|
||||
@ApiOperation(value = "修改任务计划", notes = "任务计划")
|
||||
public ResultBean updateSysTaskTime(SysTaskPlan sysTaskPlan, Boolean isExecute) {
|
||||
try {
|
||||
// 数据校验
|
||||
ValidatorBean.beginValid(sysTaskPlan)
|
||||
.notNull("name", sysTaskPlan.getName())
|
||||
.notNull("groupName",sysTaskPlan.getGroupName())
|
||||
.notNull("taskCycleId",sysTaskPlan.getTaskCycleId())
|
||||
.notNull("taskId",sysTaskPlan.getTaskId())
|
||||
.notNull("taskMethodType", sysTaskPlan.getTaskMethodType());
|
||||
|
||||
SysTaskCycle sysTaskCycle = sysTaskCycleService.getSysTaskCycleById(sysTaskPlan.getTaskCycleId());
|
||||
ValidatorBean.checkNotNull(sysTaskCycle,"任务周期不存在");
|
||||
|
||||
SysTask sysTask = sysTaskService.getSysTaskById(sysTaskPlan.getTaskId());
|
||||
ValidatorBean.checkNotNull(sysTask,"任务不存在");
|
||||
|
||||
sysTaskPlan.setTaskNameRdd(sysTask.getName());
|
||||
sysTaskPlan.setTaskCycleNameRdd(sysTaskCycle.getName());
|
||||
sysTaskPlan.setTaskCycleExpsRdd(sysTaskCycle.getTaskCycleExps());
|
||||
sysTaskPlan.setTaskCycleStartDateTimeRdd(sysTaskCycle.getTaskCycleStartDatetime());
|
||||
sysTaskPlan.setTaskCycleEndDateTimeRdd(sysTaskCycle.getTaskCycleEndDatetime());
|
||||
|
||||
sysTaskPlanService.updateSysTaskPlan(sysTaskPlan,sysTaskCycle);
|
||||
if(isExecute != null && isExecute){
|
||||
sysTaskPlanService.executeSysTaskPlan(sysTaskPlan);
|
||||
}
|
||||
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultObject(sysTaskPlan);
|
||||
}catch(ImppBusiException busExcep){
|
||||
return ResultBean.fail(busExcep);
|
||||
}catch(Exception e){
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
@DeleteMapping(value = "/delete/{id}")
|
||||
@ApiOperation(value = "删除任务计划", notes = "删除任务计划")
|
||||
public ResultBean deleteSysTaskTime(@PathVariable("id") String id) {
|
||||
try {
|
||||
// 数据校验
|
||||
ValidatorBean.checkNotNull(id, "任务计划id 不能为空");
|
||||
|
||||
sysTaskPlanService.deleteSysTaskPlanById(Long.parseLong(id));
|
||||
return ResultBean.success().setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
|
||||
}catch(ImppBusiException busExcep){
|
||||
return ResultBean.fail(busExcep);
|
||||
}catch(Exception e){
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
@GetMapping(value = "/list")
|
||||
@ApiOperation(value = "查询SysTaskTime", notes = "查询所有任务计划")
|
||||
public ResultBean findSysTaskTimeAll() {
|
||||
try {
|
||||
List<SysTaskPlan> list = sysTaskPlanService.listSysTaskPlan();
|
||||
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultList(list);
|
||||
}catch(ImppBusiException busExcep){
|
||||
return ResultBean.fail(busExcep);
|
||||
}catch(Exception e){
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
@GetMapping(value = "/get/{id}")
|
||||
@ApiOperation(value = "查询任务计划", notes = "查询根据ID查询任务计划")
|
||||
public ResultBean getBySysTaskTimeId(@PathVariable("id") String id) {
|
||||
try {
|
||||
// 数据校验
|
||||
ValidatorBean.checkNotNull(id, "任务计划id 不能为空");
|
||||
|
||||
SysTaskPlan taskTime = sysTaskPlanService.getSysTaskPlanById(Long.parseLong(id));
|
||||
if (taskTime != null) {
|
||||
return ResultBean.success("查询成功").setResultObject(taskTime).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
|
||||
}else {
|
||||
return ResultBean.fail("任务计划不存在").setCode(ResourceEnumUtil.MESSAGE.EMPTY.getCode());
|
||||
}
|
||||
}catch(ImppBusiException busExcep){
|
||||
return ResultBean.fail(busExcep);
|
||||
}catch(Exception e){
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
@PutMapping(value = "/status/{id}/{status}")
|
||||
@ApiOperation(value = "修改任务计划状态", notes = "根据ID修改任务计划状态")
|
||||
public ResultBean updateQuartzStatus(@PathVariable("id") String idStr,@PathVariable("status") Integer status) {
|
||||
try {
|
||||
// 数据校验
|
||||
ValidatorBean.checkNotNull(idStr, "id 不能为空");
|
||||
ValidatorBean.checkNotZero(status, "状态不能为空");
|
||||
|
||||
sysTaskPlanService.updateSysTaskPlanStatus(Long.parseLong(idStr),status,AuthUtil.getSessionUser());
|
||||
return new ResultBean(true);
|
||||
}catch(ImppBusiException busExcep){
|
||||
return ResultBean.fail(busExcep);
|
||||
}catch(Exception e){
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
@GetMapping("/query")
|
||||
@ApiOperation(value = "任务计划复杂查询，分页，排序",notes = "任务计划复杂查询，分页，排序")
|
||||
public ResultBean querySysTaskTimeByPager(SysTaskPlan taskTime, Pager pager){
|
||||
try {
|
||||
ListPager taskTimeListPager = sysTaskPlanService.querySysTaskPlanByPager(taskTime,pager);
|
||||
return ResultBean.success("查询成功").setListPager(taskTimeListPager).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
|
||||
}catch(ImppBusiException busExcep){
|
||||
return ResultBean.fail(busExcep);
|
||||
}catch(Exception e){
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
@GetMapping(value = "/execute/{id}")
|
||||
@ApiOperation(value = "立即执行", notes = "立即执行")
|
||||
public ResultBean executeBySysTaskTimeId(@PathVariable("id") String id) {
|
||||
try {
|
||||
// 数据校验
|
||||
ValidatorBean.checkNotNull(id, "任务计划id 不能为空");
|
||||
SysTaskPlan sysTaskPlan = sysTaskPlanService.getSysTaskPlanById(Long.parseLong(id));
|
||||
|
||||
sysTaskPlanService.executeSysTaskPlan(sysTaskPlan);
|
||||
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
|
||||
}catch(ImppBusiException busExcep){
|
||||
return ResultBean.fail(busExcep);
|
||||
}catch(Exception e){
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -1,260 +0,0 @@
|
||||
package cn.estsh.i3plus.core.apiservice.controller.busi;
|
||||
|
||||
import cn.estsh.i3plus.core.api.iservice.busi.ISysTaskTimeExpressionService;
|
||||
import cn.estsh.i3plus.core.api.iservice.busi.ISysTaskTimeService;
|
||||
import cn.estsh.i3plus.platform.common.tool.StringTool;
|
||||
import cn.estsh.i3plus.platform.common.util.PlatformConstWords;
|
||||
import cn.estsh.i3plus.pojo.base.bean.ListPager;
|
||||
import cn.estsh.i3plus.pojo.base.common.Pager;
|
||||
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
|
||||
import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil;
|
||||
import cn.estsh.i3plus.pojo.platform.bean.SysTaskTime;
|
||||
import cn.estsh.i3plus.pojo.platform.bean.SysTaskTimeExpression;
|
||||
import cn.estsh.impp.framework.base.controller.CoreBaseController;
|
||||
import cn.estsh.impp.framework.boot.auth.AuthUtil;
|
||||
import cn.estsh.impp.framework.boot.exception.ImppBusiException;
|
||||
import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
|
||||
import cn.estsh.impp.framework.boot.exception.ImppExceptionEnum;
|
||||
import cn.estsh.impp.framework.boot.util.ResultBean;
|
||||
import cn.estsh.impp.framework.boot.util.ValidatorBean;
|
||||
import io.swagger.annotations.Api;
|
||||
import io.swagger.annotations.ApiOperation;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.web.bind.annotation.*;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* @Description : 定时任务服务
|
||||
* @Reference :
|
||||
* @Author : wei.peng
|
||||
* @Date : 2018-10-22 16:58:43.982
|
||||
* @Modify :
|
||||
**/
|
||||
@RestController
|
||||
@Api(description = "定时任务服务")
|
||||
@RequestMapping(PlatformConstWords.BASE_URL +"/task-time")
|
||||
public class SysTaskTimeController extends CoreBaseController{
|
||||
|
||||
public static final Logger LOGGER = LoggerFactory.getLogger(SysTaskTimeController.class);
|
||||
|
||||
@Autowired
|
||||
private ISysTaskTimeService taskTimeService;
|
||||
|
||||
@Autowired
|
||||
private ISysTaskTimeExpressionService taskTimeExpressionService;
|
||||
|
||||
@PostMapping(value = "/insert")
|
||||
@ApiOperation(value = "新增定时任务", notes = "定时任务")
|
||||
public ResultBean insertSysTaskTime(SysTaskTime taskTime,Boolean isExecute) {
|
||||
try {
|
||||
// 数据校验
|
||||
ValidatorBean.beginValid(taskTime)
|
||||
.notNull("name", taskTime.getName())
|
||||
.notNull("groupName",taskTime.getGroupName())
|
||||
.notNull("timeExpressionId",taskTime.getTimeExpressionId())
|
||||
.notNull("taskMethodType", taskTime.getTaskMethodType())
|
||||
.notNull("taskPackage",taskTime.getTaskPackage())
|
||||
.notNull("taskClass",taskTime.getTaskClass());
|
||||
|
||||
SysTaskTimeExpression taskTimeExpression = taskTimeExpressionService
|
||||
.getSysTaskTimeExpressionById(taskTime.getTimeExpressionId());
|
||||
ValidatorBean.checkNotNull(taskTimeExpression,"定时执行策略不存在");
|
||||
|
||||
taskTime.setTimeExpressionNameRdd(taskTimeExpression.getName());
|
||||
taskTime.setTimeExpressionContentRdd(taskTimeExpression.getExpressionContent());
|
||||
taskTime.setTaskStartDateTimeRdd(taskTimeExpression.getExpressionStartDatetime());
|
||||
taskTime.setTaskEndDateTimeRdd(taskTimeExpression.getExpressionEndDatetime());
|
||||
taskTime.setTaskStatus(CommonEnumUtil.DATA_STATUS.ENABLE.getValue());
|
||||
|
||||
taskTime = taskTimeService.insertSysTaskTime(taskTime,taskTimeExpression);
|
||||
// 立即执行
|
||||
if(isExecute != null && isExecute){
|
||||
taskTimeService.executeSysTaskTimeById(taskTime.getId());
|
||||
}
|
||||
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultObject(taskTime);
|
||||
}catch(ImppBusiException busExcep){
|
||||
return ResultBean.fail(busExcep);
|
||||
}catch(Exception e){
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
@PutMapping(value = "/update")
|
||||
@ApiOperation(value = "修改定时任务", notes = "定时任务")
|
||||
public ResultBean updateSysTaskTime(SysTaskTime taskTime,Boolean isExecute) {
|
||||
try {
|
||||
// 数据校验
|
||||
ValidatorBean.beginValid(taskTime)
|
||||
.notNull("id", taskTime.getId())
|
||||
.notNull("name", taskTime.getName())
|
||||
.notNull("groupName",taskTime.getGroupName())
|
||||
.notNull("timeExpressionId",taskTime.getTimeExpressionId())
|
||||
.notNull("taskMethodType", taskTime.getTaskMethodType())
|
||||
.notNull("taskPackage",taskTime.getTaskPackage())
|
||||
.notNull("taskClass",taskTime.getTaskClass());
|
||||
|
||||
SysTaskTimeExpression taskTimeExpression = taskTimeExpressionService
|
||||
.getSysTaskTimeExpressionById(taskTime.getTimeExpressionId());
|
||||
ValidatorBean.checkNotNull(taskTimeExpression,"定时执行策略不存在");
|
||||
|
||||
taskTime.setTimeExpressionNameRdd(taskTimeExpression.getName());
|
||||
taskTime.setTimeExpressionContentRdd(taskTimeExpression.getExpressionContent());
|
||||
taskTime.setTaskStartDateTimeRdd(taskTimeExpression.getExpressionStartDatetime());
|
||||
taskTime.setTaskEndDateTimeRdd(taskTimeExpression.getExpressionEndDatetime());
|
||||
taskTime.setTaskStatus(CommonEnumUtil.DATA_STATUS.ENABLE.getValue());
|
||||
|
||||
taskTimeService.updateSysTaskTime(taskTime,taskTimeExpression);
|
||||
if(isExecute != null && isExecute){
|
||||
taskTimeService.executeSysTaskTimeById(taskTime.getId());
|
||||
}
|
||||
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultObject(taskTime);
|
||||
}catch(ImppBusiException busExcep){
|
||||
return ResultBean.fail(busExcep);
|
||||
}catch(Exception e){
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
@DeleteMapping(value = "/delete/{id}")
|
||||
@ApiOperation(value = "删除定时任务", notes = "删除定时任务")
|
||||
public ResultBean deleteSysTaskTime(@PathVariable("id") String id) {
|
||||
try {
|
||||
// 数据校验
|
||||
ValidatorBean.checkNotNull(id, "定时任务id 不能为空");
|
||||
|
||||
taskTimeService.deleteSysTaskTimeById(Long.parseLong(id));
|
||||
return ResultBean.success().setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
|
||||
}catch(ImppBusiException busExcep){
|
||||
return ResultBean.fail(busExcep);
|
||||
}catch(Exception e){
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
@GetMapping(value = "/list")
|
||||
@ApiOperation(value = "查询SysTaskTime", notes = "查询所有定时任务")
|
||||
public ResultBean findSysTaskTimeAll() {
|
||||
try {
|
||||
List<SysTaskTime> list = taskTimeService.listSysTaskTime();
|
||||
return ResultBean.success("操作成功")
|
||||
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode())
|
||||
.setResultList(list);
|
||||
}catch(ImppBusiException busExcep){
|
||||
return ResultBean.fail(busExcep);
|
||||
}catch(Exception e){
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
@GetMapping(value = "/get/{id}")
|
||||
@ApiOperation(value = "查询定时任务", notes = "查询根据ID查询定时任务")
|
||||
public ResultBean getBySysTaskTimeId(@PathVariable("id") String id) {
|
||||
try {
|
||||
// 数据校验
|
||||
ValidatorBean.checkNotNull(id, "定时任务id 不能为空");
|
||||
|
||||
SysTaskTime taskTime = taskTimeService.getSysTaskTimeById(Long.parseLong(id));
|
||||
|
||||
return ResultBean.success("操作成功")
|
||||
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode())
|
||||
.setResultObject(taskTime);
|
||||
}catch(ImppBusiException busExcep){
|
||||
return ResultBean.fail(busExcep);
|
||||
}catch(Exception e){
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
@PutMapping(value = "/status/{id}/{status}")
|
||||
@ApiOperation(value = "修改定时任务状态", notes = "根据ID修改定时任务状态")
|
||||
public ResultBean updateQuartzStatus(@PathVariable("id") String idStr,@PathVariable("status") Integer status) {
|
||||
try {
|
||||
// 数据校验
|
||||
ValidatorBean.checkNotNull(idStr, "id 不能为空");
|
||||
ValidatorBean.checkNotZero(status, "状态不能为空");
|
||||
|
||||
taskTimeService.updateSysTaskTimeStatus(Long.parseLong(idStr),status,AuthUtil.getSessionUser());
|
||||
return new ResultBean(true);
|
||||
}catch(ImppBusiException busExcep){
|
||||
return ResultBean.fail(busExcep);
|
||||
}catch(Exception e){
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
@GetMapping("/query")
|
||||
@ApiOperation(value = "定时任务复杂查询，分页，排序",notes = "定时任务复杂查询，分页，排序")
|
||||
public ResultBean querySysTaskTimeByPager(SysTaskTime taskTime, Pager pager){
|
||||
try {
|
||||
ListPager taskTimeListPager = taskTimeService.querySysTaskTimeByPager(taskTime,pager);
|
||||
return ResultBean.success("查询成功").setListPager(taskTimeListPager).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
|
||||
}catch(ImppBusiException busExcep){
|
||||
return ResultBean.fail(busExcep);
|
||||
}catch(Exception e){
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
@DeleteMapping("/batch-delete")
|
||||
@ApiOperation(value = "根据id批量删除定时任务",notes = "根据id批量删除定时任务")
|
||||
public ResultBean deleteSysTaskTimeByIds(String[] ids){
|
||||
try{
|
||||
if(ids.length == 0){
|
||||
throw ImppExceptionBuilder.newInstance()
|
||||
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
|
||||
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
|
||||
.setErrorDetail("请选择需要删除的资源。")
|
||||
.build();
|
||||
}
|
||||
|
||||
taskTimeService.deleteSysTaskTimeByIds(StringTool.getArrayLong(ids));
|
||||
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
|
||||
}catch(ImppBusiException busExcep){
|
||||
return ResultBean.fail(busExcep);
|
||||
}catch(Exception e){
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
@PutMapping(value = "/batch-status")
|
||||
@ApiOperation(value = "批量修改系统任务状态",notes = "批量修改系统任务状态")
|
||||
public ResultBean updateSysTaskTimeStatusByIds(String[] ids,Integer status){
|
||||
try {
|
||||
// 数据校验
|
||||
if(ids.length == 0){
|
||||
throw ImppExceptionBuilder.newInstance()
|
||||
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
|
||||
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
|
||||
.setErrorDetail("请选择需要删除的资源。")
|
||||
.build();
|
||||
}
|
||||
ValidatorBean.checkNotZero(status,"状态不能为空");
|
||||
|
||||
taskTimeService.updateSysTaskTimeStatusByIds(StringTool.getArrayLong(ids),status);
|
||||
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
|
||||
}catch(ImppBusiException busExcep){
|
||||
return ResultBean.fail(busExcep);
|
||||
}catch(Exception e){
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
@GetMapping(value = "/execute/{id}")
|
||||
@ApiOperation(value = "立即执行", notes = "立即执行")
|
||||
public ResultBean executeBySysTaskTimeId(@PathVariable("id") String id) {
|
||||
try {
|
||||
// 数据校验
|
||||
ValidatorBean.checkNotNull(id, "定时任务id 不能为空");
|
||||
|
||||
taskTimeService.executeSysTaskTimeById(Long.parseLong(id));
|
||||
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
|
||||
}catch(ImppBusiException busExcep){
|
||||
return ResultBean.fail(busExcep);
|
||||
}catch(Exception e){
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,109 @@
|
||||
package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
|
||||
|
||||
import cn.estsh.i3plus.core.api.iservice.busi.ISysTaskCycleService;
|
||||
import cn.estsh.i3plus.pojo.base.bean.ListPager;
|
||||
import cn.estsh.i3plus.pojo.base.common.Pager;
|
||||
import cn.estsh.i3plus.pojo.base.common.PagerHelper;
|
||||
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
|
||||
import cn.estsh.i3plus.pojo.platform.bean.SysRefTaskCyclePlan;
|
||||
import cn.estsh.i3plus.pojo.platform.bean.SysTaskCycle;
|
||||
import cn.estsh.i3plus.pojo.platform.repository.SysRefTaskCyclePlanRepository;
|
||||
import cn.estsh.i3plus.pojo.platform.repository.SysTaskCycleRepository;
|
||||
import cn.estsh.i3plus.pojo.platform.repository.SysTaskPlanRepository;
|
||||
import cn.estsh.i3plus.pojo.platform.sqlpack.CoreHqlPack;
|
||||
import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
|
||||
import cn.estsh.impp.framework.boot.exception.ImppExceptionEnum;
|
||||
import io.swagger.annotations.ApiOperation;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* @Description : 定时任务周期 业务逻辑实现
|
||||
* @Reference :
|
||||
* @Author : wei.peng
|
||||
* @Date : 2018-10-24 20:40
|
||||
* @Modify :
|
||||
**/
|
||||
@Service
|
||||
public class SysTaskCycleService implements ISysTaskCycleService {
|
||||
|
||||
public static final Logger LOGGER = LoggerFactory.getLogger(SysTaskCycleService.class);
|
||||
|
||||
@Autowired
|
||||
private SysTaskCycleRepository sysTaskCycleRDao;
|
||||
|
||||
@Autowired
|
||||
private SysTaskPlanRepository sysTaskPlanRDao;
|
||||
|
||||
@Autowired
|
||||
private SysRefTaskCyclePlanRepository sysRefTaskCyclePlanRDao;
|
||||
|
||||
@Override
|
||||
@ApiOperation(value = "修改任务周期",notes = "修改任务周期")
|
||||
public void updateSysTaskCycle(SysTaskCycle sysTaskCycle) {
|
||||
sysTaskCycleRDao.update(sysTaskCycle);
|
||||
}
|
||||
|
||||
@Override
|
||||
@ApiOperation(value = "删除任务周期",notes = "根据id删除任务周期")
|
||||
public void deleteSysTaskCycleById(Long id) {
|
||||
int refExpressionTriggerList = sysRefTaskCyclePlanRDao.findByPropertyCount("taskCycleId",id);
|
||||
if(refExpressionTriggerList != 0){
|
||||
throw ImppExceptionBuilder.newInstance()
|
||||
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
|
||||
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
|
||||
.setErrorDetail("存在关联任务计划，无法删除")
|
||||
.setErrorSolution("请重新选择")
|
||||
.build();
|
||||
}
|
||||
|
||||
sysTaskCycleRDao.deleteById(id);
|
||||
}
|
||||
|
||||
@Override
|
||||
@ApiOperation(value = "新增任务周期",notes = "新增任务周期")
|
||||
public SysTaskCycle insertSysTaskCycle(SysTaskCycle sysTaskCycle) {
|
||||
return sysTaskCycleRDao.insert(sysTaskCycle);
|
||||
}
|
||||
|
||||
@Override
|
||||
@ApiOperation(value = "查询所有任务周期信息",notes = "查询所有任务周期信息")
|
||||
public List<SysTaskCycle> listSysTaskCycle() {
|
||||
return sysTaskCycleRDao.list();
|
||||
}
|
||||
|
||||
@Override
|
||||
@ApiOperation(value = "根据ID 查询任务周期",notes = "根据ID 查询任务周期")
|
||||
public SysTaskCycle getSysTaskCycleById(Long id) {
|
||||
return sysTaskCycleRDao.getById(id);
|
||||
}
|
||||
|
||||
@Override
|
||||
@ApiOperation(value = "任务周期查询，分页，排序",notes = "任务周期查询，分页，排序")
|
||||
public ListPager querySysTaskCycleByPager(SysTaskCycle sysTaskCycle, Pager pager) {
|
||||
if(sysTaskCycle == null) {
|
||||
pager = PagerHelper.getPager(pager, sysTaskCycleRDao.listCount());
|
||||
return new ListPager(sysTaskCycleRDao.listPager(pager),pager);
|
||||
}else {
|
||||
String hqlPack = CoreHqlPack.packHqlSysTaskCycle(sysTaskCycle);
|
||||
pager = PagerHelper.getPager(pager, sysTaskCycleRDao.findByHqlWhereCount(hqlPack));
|
||||
return new ListPager(sysTaskCycleRDao.findByHqlWherePage(hqlPack + sysTaskCycle.orderBy(),pager),pager);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
@ApiOperation(value = "根据id批量删除任务周期",notes = "根据id批量删除任务周期")
|
||||
public void deleteSysTaskCycleByIds(Long[] ids) {
|
||||
sysTaskCycleRDao.deleteByIds(ids);
|
||||
}
|
||||
|
||||
@Override
|
||||
@ApiOperation(value = "根据任务周期id查询相关任务计划信息",notes = "根据任务周期id查询相关任务计划信息")
|
||||
public List<SysRefTaskCyclePlan> findRefTaskCyclePlanByCycleId(Long cycleId) {
|
||||
return sysRefTaskCyclePlanRDao.findByProperty("taskCycleId",cycleId);
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,100 @@
|
||||
package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
|
||||
|
||||
import cn.estsh.i3plus.core.api.iservice.busi.ISysTaskService;
|
||||
import cn.estsh.i3plus.pojo.base.bean.ListPager;
|
||||
import cn.estsh.i3plus.pojo.base.common.Pager;
|
||||
import cn.estsh.i3plus.pojo.base.common.PagerHelper;
|
||||
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
|
||||
import cn.estsh.i3plus.pojo.platform.bean.SysTask;
|
||||
import cn.estsh.i3plus.pojo.platform.repository.SysTaskPlanRepository;
|
||||
import cn.estsh.i3plus.pojo.platform.repository.SysTaskRepository;
|
||||
import cn.estsh.i3plus.pojo.platform.sqlpack.CoreHqlPack;
|
||||
import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
|
||||
import cn.estsh.impp.framework.boot.exception.ImppExceptionEnum;
|
||||
import io.swagger.annotations.ApiOperation;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* @Description : 任务管理业务接口实现
|
||||
* @Reference :
|
||||
* @Author : yunhao
|
||||
* @CreateDate : 2018-12-26 21:42
|
||||
* @Modify:
|
||||
**/
|
||||
@Service
|
||||
public class SysTaskService implements ISysTaskService {
|
||||
|
||||
public static final Logger LOGGER = LoggerFactory.getLogger(SysTaskService.class);
|
||||
|
||||
@Autowired
|
||||
private SysTaskRepository sysTaskRDao;
|
||||
|
||||
@Autowired
|
||||
private SysTaskPlanRepository sysTaskPlanRDao;
|
||||
|
||||
@Override
|
||||
@ApiOperation(value = "添加任务",notes = "添加任务")
|
||||
public SysTask insertSysTask(SysTask sysTask) {
|
||||
return sysTaskRDao.insert(sysTask);
|
||||
}
|
||||
|
||||
@Override
|
||||
@ApiOperation(value = "修改任务信息",notes = "修改任务信息")
|
||||
public void updateSysTask(SysTask sysTask) {
|
||||
sysTaskRDao.update(sysTask);
|
||||
// 修改冗余信息
|
||||
sysTaskPlanRDao.updateByProperties("taskId",sysTask.getId(),
|
||||
"taskNameRdd",sysTask.getName());
|
||||
}
|
||||
|
||||
@Override
|
||||
@ApiOperation(value = "查询所有任务",notes = "查询所有任务")
|
||||
public List<SysTask> listSysTask() {
|
||||
return sysTaskRDao.list();
|
||||
}
|
||||
|
||||
@Override
|
||||
@ApiOperation(value = "根据id查询任务信息",notes = "根据id查询任务信息")
|
||||
public SysTask getSysTaskById(Long id) {
|
||||
return sysTaskRDao.getById(id);
|
||||
}
|
||||
|
||||
@Override
|
||||
@ApiOperation(value = "删除任务",notes = "根据id删除任务")
|
||||
public void deleteSysTaskById(Long id) {
|
||||
if(sysTaskPlanRDao.isExitByProperty("taskId",id)){
|
||||
throw ImppExceptionBuilder.newInstance()
|
||||
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
|
||||
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
|
||||
.setErrorDetail("存在关联任务计划，无法删除")
|
||||
.setErrorSolution("请重新选择")
|
||||
.build();
|
||||
}
|
||||
|
||||
sysTaskRDao.deleteById(id);
|
||||
}
|
||||
|
||||
@Override
|
||||
@ApiOperation(value = "删除任务",notes = "根据id批量删除任务")
|
||||
public void deleteSysTaskByIds(Long[] ids) {
|
||||
sysTaskRDao.deleteByIds(ids);
|
||||
}
|
||||
|
||||
@Override
|
||||
@ApiOperation(value = "任务管理复杂查询，分页，排序",notes = "任务管理复杂查询，分页，排序")
|
||||
public ListPager<SysTask> querySysTaskByPager(SysTask sysTask, Pager pager) {
|
||||
if(sysTask == null) {
|
||||
pager = PagerHelper.getPager(pager, sysTaskRDao.listCount());
|
||||
return new ListPager(sysTaskRDao.listPager(pager),pager);
|
||||
}else {
|
||||
String hqlPack = CoreHqlPack.packHqlSysTask(sysTask);
|
||||
pager = PagerHelper.getPager(pager, sysTaskRDao.findByHqlWhereCount(hqlPack));
|
||||
return new ListPager(sysTaskRDao.findByHqlWherePage(hqlPack + sysTask.orderBy(),pager),pager);
|
||||
}
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue