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)); } }