diff --git a/nl-module-task/nl-module-task-server/src/main/java/cn/code/nl/module/task/api/TransportTaskApiImpl.java b/nl-module-task/nl-module-task-server/src/main/java/cn/code/nl/module/task/api/TransportTaskApiImpl.java new file mode 100644 index 00000000..490c3473 --- /dev/null +++ b/nl-module-task/nl-module-task-server/src/main/java/cn/code/nl/module/task/api/TransportTaskApiImpl.java @@ -0,0 +1,33 @@ +package cn.code.nl.module.task.api; + +import cn.code.nl.framework.common.pojo.CommonResult; +import cn.code.nl.module.task.dto.TransportTaskCreateReqDTO; +import cn.code.nl.module.task.enums.ApiConstants; +import cn.code.nl.module.task.service.transporttask.TransportTaskService; +import jakarta.annotation.Resource; +import org.springframework.validation.annotation.Validated; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import jakarta.validation.Valid; + +import static cn.code.nl.framework.common.pojo.CommonResult.success; + +/** + * Task 服务 RPC 接口实现 + */ +@RestController +@RequestMapping(ApiConstants.PREFIX) +@Validated +public class TransportTaskApiImpl { + + @Resource + private TransportTaskService transportTaskService; + + @PostMapping("/transport/create") + public CommonResult createTransportTask(@Valid @RequestBody TransportTaskCreateReqDTO reqDTO) { + return success(transportTaskService.createTransportTaskByRpc(reqDTO)); + } +}