|
@@ -62,6 +62,7 @@ public class TaskService {
|
|
|
String linuxTempPath;
|
|
|
|
|
|
public void taskTick(String taskId) {
|
|
|
+ log.info("------- 接收到任务 " + taskId + "的心跳!");
|
|
|
// 刷新 redis 心跳时间
|
|
|
ProjectPO projectPO = projectMapper.selectById(taskId);
|
|
|
String projectId = projectPO.getId();
|
|
@@ -73,6 +74,7 @@ public class TaskService {
|
|
|
|
|
|
@Transactional
|
|
|
public void taskState(String taskId, String state) {
|
|
|
+ log.info("------- 接收到任务 " + taskId + "的状态:" + state);
|
|
|
//1 根据 taskId 修改任务状态 taskState。
|
|
|
taskMapper.updateState(taskId, state);
|
|
|
//2 如果 taskState 为完成状态,校验一下项目的已完成数量。
|