Skip to content

谢明辉 / fanxing3

Go to a project
Commit 005d6629 by xmh
Options

<fix> 取消任务状态判断

1 parent 25e3069b
Inline Side-by-side
Showing 1 changed file with 0 additions and 4 deletions
fanxing-task/src/main/java/com/viontech/fanxing/task/service/VAServerService.java
...@@ -3,7 +3,6 @@ package com.viontech.fanxing.task.service; ...@@ -3,7 +3,6 @@ package com.viontech.fanxing.task.service;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.viontech.fanxing.commons.config.VionConfig; import com.viontech.fanxing.commons.config.VionConfig;
import com.viontech.fanxing.commons.constant.RedisKeys; import com.viontech.fanxing.commons.constant.RedisKeys;
import com.viontech.fanxing.commons.constant.TaskStatus;
import com.viontech.fanxing.commons.exception.FanXingException; import com.viontech.fanxing.commons.exception.FanXingException;
import com.viontech.fanxing.commons.model.Task; import com.viontech.fanxing.commons.model.Task;
import com.viontech.fanxing.commons.service.RedisService; import com.viontech.fanxing.commons.service.RedisService;
...@@ -178,9 +177,6 @@ public class VAServerService { ...@@ -178,9 +177,6 @@ public class VAServerService {
if (taskData == null) { if (taskData == null) {
throw new FanXingException("找不到对应的任务"); throw new FanXingException("找不到对应的任务");
} }
if (!TaskStatus.RUNNING.valEqual(taskData.getTask().getStatus())) {
throw new FanXingException("任务不在运行状态");
}
VaServerInfo vaServerInfo = taskDataService.taskRunOn(taskUnid); VaServerInfo vaServerInfo = taskDataService.taskRunOn(taskUnid);
if (vaServerInfo != null) { if (vaServerInfo != null) {
if (vaServerInfo.getStatus() == 0) { if (vaServerInfo.getStatus() == 0) {
......
Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!