修改接口
This commit is contained in:
parent
68d7678a1f
commit
7e4994f058
|
|
@ -93,8 +93,23 @@ public class TaskPlanController extends BaseController
|
||||||
@PutMapping
|
@PutMapping
|
||||||
public R<Boolean> updateTaskPlan(@RequestBody TaskPlanDTO taskPlanDTO)
|
public R<Boolean> updateTaskPlan(@RequestBody TaskPlanDTO taskPlanDTO)
|
||||||
{
|
{
|
||||||
boolean result = taskPlanService.updateTaskPlan(TaskPlanControllerConvert.to(taskPlanDTO));
|
|
||||||
return R.ok(result);
|
taskPlanService.updateTaskPlan(TaskPlanControllerConvert.to(taskPlanDTO));
|
||||||
|
// taskPlanService.deleteTaskPlan(taskPlanDTO.getId());
|
||||||
|
// if(!Objects.isNull(taskPlanDTO.getPlanType())) {
|
||||||
|
// if(Objects.equals(taskPlanDTO.getPlanType(), PlanTypeEnum.TIMED)){
|
||||||
|
// taskPlanDTO.setPlanType(PlanTypeEnum.TIMED);
|
||||||
|
// setDefaultPlan(taskPlanDTO);
|
||||||
|
// taskPlanService.createTimedTaskPlan(TaskPlanControllerConvert.to(taskPlanDTO));
|
||||||
|
// return R.ok(true);
|
||||||
|
// }else if (Objects.equals(taskPlanDTO.getPlanType(), PlanTypeEnum.CYCLE)){
|
||||||
|
// taskPlanDTO.setPlanType(PlanTypeEnum.CYCLE);
|
||||||
|
// setDefaultPlan(taskPlanDTO);
|
||||||
|
// taskPlanService.createCycleTaskPlan(TaskPlanControllerConvert.to(taskPlanDTO));
|
||||||
|
// return R.ok(true);
|
||||||
|
// }
|
||||||
|
// }
|
||||||
|
return R.ok(true);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
|
||||||
|
|
@ -18,7 +18,7 @@ public interface ITaskDomain {
|
||||||
* @param task 任务领域模型
|
* @param task 任务领域模型
|
||||||
* @return 创建后的任务
|
* @return 创建后的任务
|
||||||
*/
|
*/
|
||||||
Task createTaskWithoutPlan(Task task);
|
Task createTask(Task task);
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 更新任务
|
* 更新任务
|
||||||
|
|
|
||||||
|
|
@ -24,9 +24,8 @@ public class TaskDomainImpl implements ITaskDomain {
|
||||||
private TaskInfoMapper taskInfoMapper;
|
private TaskInfoMapper taskInfoMapper;
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public Task createTaskWithoutPlan(Task task) {
|
public Task createTask(Task task) {
|
||||||
// 确保planId为null,表示无关联计划
|
// 确保planId为null,表示无关联计划
|
||||||
task.setPlanId(null);
|
|
||||||
// 转换为实体
|
// 转换为实体
|
||||||
TaskInfoEntity entity = TaskConvert.toEntity(task);
|
TaskInfoEntity entity = TaskConvert.toEntity(task);
|
||||||
// 插入数据库
|
// 插入数据库
|
||||||
|
|
|
||||||
|
|
@ -7,13 +7,13 @@ import com.ruoyi.task.domain.model.Task;
|
||||||
import com.ruoyi.task.domain.model.TaskPlan;
|
import com.ruoyi.task.domain.model.TaskPlan;
|
||||||
import com.ruoyi.task.service.api.ITaskPlanService;
|
import com.ruoyi.task.service.api.ITaskPlanService;
|
||||||
import com.ruoyi.task.service.convert.TaskPlanDTOConvert;
|
import com.ruoyi.task.service.convert.TaskPlanDTOConvert;
|
||||||
import com.ruoyi.task.service.convert.TaskDTOConvert;
|
|
||||||
import com.ruoyi.task.service.dto.TaskPlanDTO;
|
import com.ruoyi.task.service.dto.TaskPlanDTO;
|
||||||
import com.ruoyi.task.service.dto.TaskPlanQueryDTO;
|
import com.ruoyi.task.service.dto.TaskPlanQueryDTO;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
|
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
@Service
|
@Service
|
||||||
public class TaskPlanServiceImpl implements ITaskPlanService {
|
public class TaskPlanServiceImpl implements ITaskPlanService {
|
||||||
|
|
@ -37,7 +37,14 @@ public class TaskPlanServiceImpl implements ITaskPlanService {
|
||||||
if (taskPlan.getPlanType() == null) {
|
if (taskPlan.getPlanType() == null) {
|
||||||
taskPlan.setPlanType(PlanTypeEnum.TIMED);
|
taskPlan.setPlanType(PlanTypeEnum.TIMED);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// 设置结束时间:开始时间 + 执行时长
|
||||||
|
if (taskPlan.getExecuteTime() != null && taskPlan.getDuration() != null) {
|
||||||
|
taskPlan.setStartDate(taskPlan.getExecuteTime());
|
||||||
|
taskPlan.setEndDate(taskPlan.getExecuteTime());
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
TaskPlan result = taskPlanDomain.createTimedTaskPlan(taskPlan);
|
TaskPlan result = taskPlanDomain.createTimedTaskPlan(taskPlan);
|
||||||
|
|
||||||
// 创建对应的任务记录
|
// 创建对应的任务记录
|
||||||
|
|
@ -107,7 +114,7 @@ public class TaskPlanServiceImpl implements ITaskPlanService {
|
||||||
task.setDescription("由任务计划自动创建");
|
task.setDescription("由任务计划自动创建");
|
||||||
|
|
||||||
// 创建任务
|
// 创建任务
|
||||||
taskDomain.createTaskWithoutPlan(task);
|
taskDomain.createTask(task);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
@ -192,7 +199,7 @@ public class TaskPlanServiceImpl implements ITaskPlanService {
|
||||||
task.setDescription("由任务计划自动创建");
|
task.setDescription("由任务计划自动创建");
|
||||||
|
|
||||||
// 创建任务
|
// 创建任务
|
||||||
taskDomain.createTaskWithoutPlan(task);
|
taskDomain.createTask(task);
|
||||||
}
|
}
|
||||||
|
|
||||||
// 增加一天
|
// 增加一天
|
||||||
|
|
@ -259,7 +266,7 @@ public class TaskPlanServiceImpl implements ITaskPlanService {
|
||||||
public boolean updateTaskPlan(TaskPlanDTO taskPlanDTO) {
|
public boolean updateTaskPlan(TaskPlanDTO taskPlanDTO) {
|
||||||
TaskPlan taskPlan = TaskPlanDTOConvert.toDomain(taskPlanDTO);
|
TaskPlan taskPlan = TaskPlanDTOConvert.toDomain(taskPlanDTO);
|
||||||
TaskPlan result = taskPlanDomain.updateTaskPlan(taskPlan);
|
TaskPlan result = taskPlanDomain.updateTaskPlan(taskPlan);
|
||||||
|
|
||||||
if (result != null) {
|
if (result != null) {
|
||||||
// 先删除该计划下的所有未执行任务
|
// 先删除该计划下的所有未执行任务
|
||||||
List<Task> tasks = taskDomain.getTaskByPlanId(result.getId());
|
List<Task> tasks = taskDomain.getTaskByPlanId(result.getId());
|
||||||
|
|
@ -268,11 +275,16 @@ public class TaskPlanServiceImpl implements ITaskPlanService {
|
||||||
taskDomain.deleteTask(task.getId());
|
taskDomain.deleteTask(task.getId());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// 重新创建任务
|
if(Objects.equals(taskPlan.getPlanType(),PlanTypeEnum.TIMED)){
|
||||||
createTaskFromPlan(result);
|
createTimedTaskPlan(taskPlanDTO);
|
||||||
|
}else {
|
||||||
|
createCycleTaskPlan(taskPlanDTO);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
return result != null;
|
return result != null;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -1,8 +1,6 @@
|
||||||
package com.ruoyi.task.service.impl;
|
package com.ruoyi.task.service.impl;
|
||||||
|
|
||||||
import com.ruoyi.task.api.enums.StatusEnum;
|
import com.ruoyi.task.api.enums.StatusEnum;
|
||||||
import com.ruoyi.task.api.enums.TaskCategoryEnum;
|
|
||||||
import com.ruoyi.task.api.enums.TaskTypeEnum;
|
|
||||||
import com.ruoyi.task.domain.api.ITaskDomain;
|
import com.ruoyi.task.domain.api.ITaskDomain;
|
||||||
import com.ruoyi.task.domain.model.Task;
|
import com.ruoyi.task.domain.model.Task;
|
||||||
import com.ruoyi.task.service.api.ITaskService;
|
import com.ruoyi.task.service.api.ITaskService;
|
||||||
|
|
@ -23,7 +21,8 @@ public class TaskServiceImpl implements ITaskService {
|
||||||
@Override
|
@Override
|
||||||
public Long createTaskWithoutPlan(TaskDTO taskDTO) {
|
public Long createTaskWithoutPlan(TaskDTO taskDTO) {
|
||||||
Task task = TaskDTOConvert.toDomain(taskDTO);
|
Task task = TaskDTOConvert.toDomain(taskDTO);
|
||||||
Task result = taskDomain.createTaskWithoutPlan(task);
|
task.setPlanId(null);
|
||||||
|
Task result = taskDomain.createTask(task);
|
||||||
return result != null ? result.getId() : null;
|
return result != null ? result.getId() : null;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -0,0 +1,8 @@
|
||||||
|
-- 修改 task_plan 表的 status 字段类型为 VARCHAR(20)
|
||||||
|
ALTER TABLE task_plan MODIFY COLUMN status VARCHAR(20) COMMENT '计划状态';
|
||||||
|
|
||||||
|
-- 修改 task_info 表的 status 字段类型为 VARCHAR(20)
|
||||||
|
ALTER TABLE task_info MODIFY COLUMN status VARCHAR(20) COMMENT '任务状态';
|
||||||
|
|
||||||
|
-- 修改 task_stat 表的 task_status 字段类型为 VARCHAR(20)
|
||||||
|
ALTER TABLE task_stat MODIFY COLUMN task_status VARCHAR(20) COMMENT '任务状态';
|
||||||
Loading…
Reference in New Issue