chujinwang
/
chushangcloud
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

1. 修改 后台任务的创建人以及修改人

This commit is contained in:
zhaowenyuan 2024-06-17 18:15:14 +08:00
parent 188a64f437
commit 6541eb6915
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
chushang-modules/chushang-module-task/task-service/src/main/java/com/chushang/task/remote/RemoteTaskController.java
View File

@ -32,7 +32,7 @@ public class RemoteTaskController implements RemoteTaskService {
@PostMapping("/create") @PostMapping("/create")
public Result<Long> createTask(@RequestBody CreateTaskDTO task, String source) { public Result<Long> createTask(@RequestBody CreateTaskDTO task, String source) {
TaskInfo taskInfo = TaskInfo.builder() TaskInfo taskInfo = TaskInfo.builder()
.createBy(task.getCreateBy())
.applicationName(task.getApplicationName().getServiceName()) .applicationName(task.getApplicationName().getServiceName())
.className(task.getClassName()) .className(task.getClassName())
.methodName(task.getMethodName()) .methodName(task.getMethodName())
@ -42,6 +42,7 @@ public class RemoteTaskController implements RemoteTaskService {
.taskType(task.getTaskType().getCode()) .taskType(task.getTaskType().getCode())
.taskName(task.getTaskName()) .taskName(task.getTaskName())
.build(); .build();
taskInfo.setCreateBy(task.getCreateBy());
boolean save = taskInfoService.save(taskInfo); boolean save = taskInfoService.save(taskInfo);
// 如果 入库成功, 则将其发送到消息队列中 // 如果 入库成功, 则将其发送到消息队列中
if (save){ if (save){
@ -58,12 +59,12 @@ public class RemoteTaskController implements RemoteTaskService {
{ {
TaskInfo taskInfo = TaskInfo.builder() TaskInfo taskInfo = TaskInfo.builder()
.taskId(taskId) .taskId(taskId)
.updateBy("system")
.taskStatus(task.getTaskStatus().getCode()) .taskStatus(task.getTaskStatus().getCode())
.lastRunResult(task.getLastRunResult()) .lastRunResult(task.getLastRunResult())
.lastRunTime(task.getLastRunTime()) .lastRunTime(task.getLastRunTime())
.remark(task.getRemark()) .remark(task.getRemark())
.build(); .build();
taskInfo.setUpdateBy("system");
return Result.ok(taskInfoService.updateById(taskInfo)); return Result.ok(taskInfoService.updateById(taskInfo));
} }
} }