| | |
| | | |
| | | import com.zy.acs.framework.common.Cools; |
| | | import com.zy.acs.framework.common.R; |
| | | import com.zy.acs.manager.common.annotation.IntegrationAuth; |
| | | import com.zy.acs.manager.common.annotation.OperationLog; |
| | | import com.zy.acs.manager.common.constant.Constants; |
| | | import com.zy.acs.manager.common.domain.TaskBoolDto; |
| | | import com.zy.acs.manager.core.domain.type.NamespaceType; |
| | | import com.zy.acs.manager.core.integrate.dto.OpenBusCancelParam; |
| | | import com.zy.acs.manager.core.integrate.dto.OpenBusCancelResult; |
| | | import com.zy.acs.manager.core.integrate.dto.OpenBusSubmitParam; |
| | |
| | | import org.springframework.web.bind.annotation.RequestBody; |
| | | import org.springframework.web.bind.annotation.RequestMapping; |
| | | import org.springframework.web.bind.annotation.RestController; |
| | | |
| | | import javax.servlet.http.HttpServletRequest; |
| | | |
| | | /** |
| | | * Created by vincent on 2023/6/12 |
| | |
| | | |
| | | @PostMapping("/bus/submit") |
| | | @OperationLog("generate task from open api") |
| | | public R submit(@RequestBody OpenBusSubmitParam param) { |
| | | @IntegrationAuth(name = NamespaceType.RCS_BUS_RECEIVE) |
| | | public R submit(@RequestBody OpenBusSubmitParam param, HttpServletRequest request) { |
| | | mainService.generateBusAndTask(param, null); |
| | | return R.ok("generate tasks success"); |
| | | } |
| | | |
| | | @PostMapping("/task/cancel") |
| | | @OperationLog("cancel task from open api") |
| | | @IntegrationAuth(name = NamespaceType.RCS_TASK_CANCEL) |
| | | public R cancel(@RequestBody OpenBusCancelParam param) { |
| | | if (Cools.isEmpty(param.getBatchNo())) { |
| | | return R.error("batchNo is empty"); |