疯狂的狮子li
2021-08-26 31c2cfa53c34732ffdea8418ef04f373337ef0d4
ruoyi-quartz/src/main/java/com/ruoyi/quartz/service/impl/SysJobServiceImpl.java
@@ -87,7 +87,7 @@
     * @param job 调度信息
     */
    @Override
    @Transactional
    @Transactional(rollbackFor = Exception.class)
    public int pauseJob(SysJob job) throws SchedulerException {
        Long jobId = job.getJobId();
        String jobGroup = job.getJobGroup();
@@ -105,7 +105,7 @@
     * @param job 调度信息
     */
    @Override
    @Transactional
    @Transactional(rollbackFor = Exception.class)
    public int resumeJob(SysJob job) throws SchedulerException {
        Long jobId = job.getJobId();
        String jobGroup = job.getJobGroup();
@@ -123,7 +123,7 @@
     * @param job 调度信息
     */
    @Override
    @Transactional
    @Transactional(rollbackFor = Exception.class)
    public int deleteJob(SysJob job) throws SchedulerException {
        Long jobId = job.getJobId();
        String jobGroup = job.getJobGroup();
@@ -141,7 +141,7 @@
     * @return 结果
     */
    @Override
    @Transactional
    @Transactional(rollbackFor = Exception.class)
    public void deleteJobByIds(Long[] jobIds) throws SchedulerException {
        for (Long jobId : jobIds) {
            SysJob job = getById(jobId);
@@ -155,7 +155,7 @@
     * @param job 调度信息
     */
    @Override
    @Transactional
    @Transactional(rollbackFor = Exception.class)
    public int changeStatus(SysJob job) throws SchedulerException {
        int rows = 0;
        String status = job.getStatus();
@@ -173,7 +173,7 @@
     * @param job 调度信息
     */
    @Override
    @Transactional
    @Transactional(rollbackFor = Exception.class)
    public void run(SysJob job) throws SchedulerException {
        Long jobId = job.getJobId();
        String jobGroup = job.getJobGroup();
@@ -190,7 +190,7 @@
     * @param job 调度信息 调度信息
     */
    @Override
    @Transactional
    @Transactional(rollbackFor = Exception.class)
    public int insertJob(SysJob job) throws SchedulerException, TaskException {
        job.setStatus(ScheduleConstants.Status.PAUSE.getValue());
        int rows = baseMapper.insert(job);
@@ -206,7 +206,7 @@
     * @param job 调度信息
     */
    @Override
    @Transactional
    @Transactional(rollbackFor = Exception.class)
    public int updateJob(SysJob job) throws SchedulerException, TaskException {
        SysJob properties = selectJobById(job.getJobId());
        int rows = baseMapper.updateById(job);