| | |
| | | import com.zy.acs.manager.core.service.MainService; |
| | | import com.zy.acs.manager.manager.entity.Bus; |
| | | import com.zy.acs.manager.manager.entity.Task; |
| | | import com.zy.acs.manager.manager.enums.TaskStsType; |
| | | import com.zy.acs.manager.manager.service.BusService; |
| | | import com.zy.acs.manager.manager.service.TaskService; |
| | | import com.zy.acs.manager.system.controller.BaseController; |
| | | import io.swagger.annotations.Api; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | |
| | | @Api(tags = "Open Api") |
| | | @RestController |
| | | @RequestMapping("/api/open") |
| | | public class OpenController extends BaseController { |
| | | public class OpenController { |
| | | |
| | | @Autowired |
| | | private MainService mainService; |
| | |
| | | for (String taskNo : param.getTasks()) { |
| | | Task task = taskService.selectBySeqNum(bus.getId(), taskNo); |
| | | if (null == task) { |
| | | result.getTasks().add(new TaskBoolDto(taskNo, Boolean.FALSE, taskNo + " is not exist")); |
| | | result.getTasks().add(new TaskBoolDto(taskNo, Boolean.FALSE, "task " + taskNo + " is not exist")); |
| | | continue; |
| | | } |
| | | if (!task.getTaskSts().equals(TaskStsType.INIT.val())) { |
| | | result.getTasks().add(new TaskBoolDto(taskNo, Boolean.FALSE, "task " + taskNo + " has already been assigned")); |
| | | continue; |
| | | } |
| | | Boolean cancel = false; |
| | |
| | | } catch (Exception e) { |
| | | log.error("failed to cancel task {}", taskNo, e); |
| | | } |
| | | result.getTasks().add(new TaskBoolDto(taskNo, cancel)); |
| | | result.getTasks().add(new TaskBoolDto(taskNo, cancel, "failed to cancel task " + taskNo)); |
| | | } |
| | | return R.ok("cancel tasks success").add(result); |
| | | } |