|
|
@ -208,9 +208,9 @@ public class SchBaseTaskServiceImpl extends ServiceImpl<SchBaseTaskMapper, SchBa |
|
|
|
} |
|
|
|
// 根据标识找到任务
|
|
|
|
SchBaseTask taskOne = this.getByCode(task_code); |
|
|
|
if (Integer.parseInt(taskOne.getTask_status()) >= Integer.parseInt(TaskStatus.FINISHED.getCode())) { |
|
|
|
/* if (Integer.parseInt(taskOne.getTask_status()) >= Integer.parseInt(TaskStatus.FINISHED.getCode())) { |
|
|
|
throw new BadRequestException("任务已完成或已取消!"); |
|
|
|
} |
|
|
|
}*/ |
|
|
|
// 根据配置去工厂类获得类对象
|
|
|
|
String processing_class = config_code; |
|
|
|
String message = ""; |
|
|
@ -229,6 +229,9 @@ public class SchBaseTaskServiceImpl extends ServiceImpl<SchBaseTaskMapper, SchBa |
|
|
|
case "cancel": |
|
|
|
abstractTask.cancel(task_code); |
|
|
|
break; |
|
|
|
case "back": |
|
|
|
abstractTask.backMes(task_code); |
|
|
|
break; |
|
|
|
default: |
|
|
|
break; |
|
|
|
} |
|
|
|