|
|
|
@ -3,11 +3,13 @@ |
|
|
|
package com.gaotao.modules.job.controller; |
|
|
|
|
|
|
|
import com.gaotao.common.annotation.SysLog; |
|
|
|
import com.gaotao.common.constant.SysMsgConstant; |
|
|
|
import com.gaotao.common.utils.PageUtils; |
|
|
|
import com.gaotao.common.utils.R; |
|
|
|
import com.gaotao.common.validator.ValidatorUtils; |
|
|
|
import com.gaotao.modules.job.entity.ScheduleJobEntity; |
|
|
|
import com.gaotao.modules.job.service.ScheduleJobService; |
|
|
|
import com.gaotao.modules.sys.controller.AbstractController; |
|
|
|
import org.apache.shiro.authz.annotation.RequiresPermissions; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
import org.springframework.web.bind.annotation.*; |
|
|
|
@ -21,7 +23,7 @@ import java.util.Map; |
|
|
|
*/ |
|
|
|
@RestController |
|
|
|
@RequestMapping("/sys/schedule") |
|
|
|
public class ScheduleJobController { |
|
|
|
public class ScheduleJobController extends AbstractController { |
|
|
|
@Autowired |
|
|
|
private ScheduleJobService scheduleJobService; |
|
|
|
|
|
|
|
@ -58,7 +60,7 @@ public class ScheduleJobController { |
|
|
|
|
|
|
|
scheduleJobService.saveJob(scheduleJob); |
|
|
|
|
|
|
|
return R.ok(); |
|
|
|
return R.ok(getLanguageMsg(SysMsgConstant.OBJECT_ID_200000)); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
@ -72,7 +74,7 @@ public class ScheduleJobController { |
|
|
|
|
|
|
|
scheduleJobService.update(scheduleJob); |
|
|
|
|
|
|
|
return R.ok(); |
|
|
|
return R.ok(getLanguageMsg(SysMsgConstant.OBJECT_ID_200000)); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
@ -84,7 +86,7 @@ public class ScheduleJobController { |
|
|
|
public R delete(@RequestBody Long[] jobIds){ |
|
|
|
scheduleJobService.deleteBatch(jobIds); |
|
|
|
|
|
|
|
return R.ok(); |
|
|
|
return R.ok(getLanguageMsg(SysMsgConstant.OBJECT_ID_200000)); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
@ -96,7 +98,7 @@ public class ScheduleJobController { |
|
|
|
public R run(@RequestBody Long[] jobIds){ |
|
|
|
scheduleJobService.run(jobIds); |
|
|
|
|
|
|
|
return R.ok(); |
|
|
|
return R.ok(getLanguageMsg(SysMsgConstant.OBJECT_ID_200000)); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
@ -108,7 +110,7 @@ public class ScheduleJobController { |
|
|
|
public R pause(@RequestBody Long[] jobIds){ |
|
|
|
scheduleJobService.pause(jobIds); |
|
|
|
|
|
|
|
return R.ok(); |
|
|
|
return R.ok(getLanguageMsg(SysMsgConstant.OBJECT_ID_200000)); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
@ -120,7 +122,7 @@ public class ScheduleJobController { |
|
|
|
public R resume(@RequestBody Long[] jobIds){ |
|
|
|
scheduleJobService.resume(jobIds); |
|
|
|
|
|
|
|
return R.ok(); |
|
|
|
return R.ok(getLanguageMsg(SysMsgConstant.OBJECT_ID_200000)); |
|
|
|
} |
|
|
|
|
|
|
|
} |