From 6541eb69153ab79611a0e9ee74c8e17c417d264e Mon Sep 17 00:00:00 2001 From: zhaowenyuan Date: Mon, 17 Jun 2024 18:15:14 +0800 Subject: [PATCH] =?UTF-8?q?1.=20=E4=BF=AE=E6=94=B9=20=E5=90=8E=E5=8F=B0?= =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E7=9A=84=E5=88=9B=E5=BB=BA=E4=BA=BA=E4=BB=A5?= =?UTF-8?q?=E5=8F=8A=E4=BF=AE=E6=94=B9=E4=BA=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/chushang/task/remote/RemoteTaskController.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/chushang-modules/chushang-module-task/task-service/src/main/java/com/chushang/task/remote/RemoteTaskController.java b/chushang-modules/chushang-module-task/task-service/src/main/java/com/chushang/task/remote/RemoteTaskController.java index 14fbfe0..07e4c96 100644 --- a/chushang-modules/chushang-module-task/task-service/src/main/java/com/chushang/task/remote/RemoteTaskController.java +++ b/chushang-modules/chushang-module-task/task-service/src/main/java/com/chushang/task/remote/RemoteTaskController.java @@ -32,7 +32,7 @@ public class RemoteTaskController implements RemoteTaskService { @PostMapping("/create") public Result createTask(@RequestBody CreateTaskDTO task, String source) { TaskInfo taskInfo = TaskInfo.builder() - .createBy(task.getCreateBy()) + .applicationName(task.getApplicationName().getServiceName()) .className(task.getClassName()) .methodName(task.getMethodName()) @@ -42,6 +42,7 @@ public class RemoteTaskController implements RemoteTaskService { .taskType(task.getTaskType().getCode()) .taskName(task.getTaskName()) .build(); + taskInfo.setCreateBy(task.getCreateBy()); boolean save = taskInfoService.save(taskInfo); // 如果 入库成功, 则将其发送到消息队列中 if (save){ @@ -58,12 +59,12 @@ public class RemoteTaskController implements RemoteTaskService { { TaskInfo taskInfo = TaskInfo.builder() .taskId(taskId) - .updateBy("system") .taskStatus(task.getTaskStatus().getCode()) .lastRunResult(task.getLastRunResult()) .lastRunTime(task.getLastRunTime()) .remark(task.getRemark()) .build(); + taskInfo.setUpdateBy("system"); return Result.ok(taskInfoService.updateById(taskInfo)); } }