From c82f3095482d3954f754fc946abdd9de3930f0da Mon Sep 17 00:00:00 2001 From: liyongde <1419499670@qq.com> Date: Tue, 14 Jul 2026 17:39:05 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20TransportTaskApiImpl=20RPC=E5=88=9B?= =?UTF-8?q?=E5=BB=BA=E4=BB=BB=E5=8A=A1=E6=8E=A5=E5=8F=A3=E5=AE=9E=E7=8E=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../module/task/api/TransportTaskApiImpl.java | 33 +++++++++++++++++++ 1 file changed, 33 insertions(+) create mode 100644 nl-module-task/nl-module-task-server/src/main/java/cn/code/nl/module/task/api/TransportTaskApiImpl.java 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)); + } +}