feat: 联调完善
parent
b4764d6f8d
commit
b527936b30
|
@ -4,6 +4,7 @@ import org.springframework.web.bind.annotation.RequestMapping;
|
||||||
import org.springframework.web.bind.annotation.RestController;
|
import org.springframework.web.bind.annotation.RestController;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.bind.annotation.*;
|
||||||
|
import tech.unissense.pms.business.examine.config.domain.ExamineConfig;
|
||||||
import tech.unissense.pms.business.examine.task.domain.ExamineTask;
|
import tech.unissense.pms.business.examine.task.domain.ExamineTask;
|
||||||
import tech.unissense.pms.business.examine.task.domain.TaskQueryDto;
|
import tech.unissense.pms.business.examine.task.domain.TaskQueryDto;
|
||||||
import tech.unissense.pms.business.examine.task.service.TaskService;
|
import tech.unissense.pms.business.examine.task.service.TaskService;
|
||||||
|
@ -36,6 +37,7 @@ public class TaskSetUpController extends BaseController {
|
||||||
List<ExamineTask> tasks = taskService.getTasks(queryDto);
|
List<ExamineTask> tasks = taskService.getTasks(queryDto);
|
||||||
return getDataTable(tasks);
|
return getDataTable(tasks);
|
||||||
}
|
}
|
||||||
|
|
||||||
@GetMapping("/list")
|
@GetMapping("/list")
|
||||||
public AjaxResult listTask(TaskQueryDto queryDto) {
|
public AjaxResult listTask(TaskQueryDto queryDto) {
|
||||||
return success(taskService.listTask(queryDto));
|
return success(taskService.listTask(queryDto));
|
||||||
|
@ -51,6 +53,12 @@ public class TaskSetUpController extends BaseController {
|
||||||
return AjaxResult.success(taskService.updateTask(updatedTask));
|
return AjaxResult.success(taskService.updateTask(updatedTask));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// 编辑任务
|
||||||
|
@PutMapping("/config/update")
|
||||||
|
public AjaxResult updateConfigTask(@RequestBody List<ExamineConfig> list) {
|
||||||
|
return AjaxResult.success(taskService.updateConfigTask(list));
|
||||||
|
}
|
||||||
|
|
||||||
// 删除任务
|
// 删除任务
|
||||||
@DeleteMapping("/{id}")
|
@DeleteMapping("/{id}")
|
||||||
public AjaxResult deleteTask(@PathVariable Integer id) {
|
public AjaxResult deleteTask(@PathVariable Integer id) {
|
||||||
|
@ -58,7 +66,7 @@ public class TaskSetUpController extends BaseController {
|
||||||
return AjaxResult.success();
|
return AjaxResult.success();
|
||||||
}
|
}
|
||||||
|
|
||||||
//指标配置
|
//获取指标配置
|
||||||
@GetMapping("/target/{id}")
|
@GetMapping("/target/{id}")
|
||||||
public AjaxResult getTarget(@PathVariable Integer id){
|
public AjaxResult getTarget(@PathVariable Integer id){
|
||||||
return AjaxResult.success(taskService.getTarget(id));
|
return AjaxResult.success(taskService.getTarget(id));
|
||||||
|
|
|
@ -40,5 +40,7 @@ public class ExamineTask implements Serializable {
|
||||||
|
|
||||||
|
|
||||||
private List<Integer> userIdList;
|
private List<Integer> userIdList;
|
||||||
|
|
||||||
|
private Integer year;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -8,4 +8,6 @@ public class TaskQueryDto extends BaseEntity {
|
||||||
private String taskName;
|
private String taskName;
|
||||||
|
|
||||||
private Integer taskStatus;
|
private Integer taskStatus;
|
||||||
|
|
||||||
|
private Integer year;
|
||||||
}
|
}
|
||||||
|
|
|
@ -19,4 +19,6 @@ public interface TaskService {
|
||||||
List<ExamineConfig> getTarget(Integer id);
|
List<ExamineConfig> getTarget(Integer id);
|
||||||
|
|
||||||
Map<Integer,List<ExamineTask>> listTask(TaskQueryDto queryDto);
|
Map<Integer,List<ExamineTask>> listTask(TaskQueryDto queryDto);
|
||||||
|
|
||||||
|
List<ExamineConfig> updateConfigTask(List<ExamineConfig> list);
|
||||||
}
|
}
|
||||||
|
|
|
@ -48,7 +48,7 @@ public class TaskServiceImpl implements TaskService {
|
||||||
//生成考核人员信息
|
//生成考核人员信息
|
||||||
List<Integer> userIdList = task.getUserIdList();
|
List<Integer> userIdList = task.getUserIdList();
|
||||||
Assert.notEmpty(userIdList, "考核人员不能为空");
|
Assert.notEmpty(userIdList, "考核人员不能为空");
|
||||||
List<ExamineUser> userList=new ArrayList<>();
|
List<ExamineUser> userList = new ArrayList<>();
|
||||||
for (Integer userId : userIdList) {
|
for (Integer userId : userIdList) {
|
||||||
ExamineUser examineUser = new ExamineUser();
|
ExamineUser examineUser = new ExamineUser();
|
||||||
examineUser.setTaskId(task.getId());
|
examineUser.setTaskId(task.getId());
|
||||||
|
@ -61,7 +61,17 @@ public class TaskServiceImpl implements TaskService {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public List<ExamineTask> getTasks(TaskQueryDto queryDto) {
|
public List<ExamineTask> getTasks(TaskQueryDto queryDto) {
|
||||||
return examineTaskDao.getTasks(queryDto);
|
List<ExamineTask> tasks = examineTaskDao.getTasks(queryDto);
|
||||||
|
tasks.forEach(item -> {
|
||||||
|
ExamineUser examineUser = new ExamineUser();
|
||||||
|
examineUser.setTaskId(item.getId());
|
||||||
|
List<ExamineUser> existingUsers = userMapper.list(examineUser);
|
||||||
|
List<Integer> existingUserIds = existingUsers.stream()
|
||||||
|
.map(ExamineUser::getUserId)
|
||||||
|
.collect(Collectors.toList());
|
||||||
|
item.setUserIdList(existingUserIds);
|
||||||
|
});
|
||||||
|
return tasks;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@ -97,6 +107,20 @@ public class TaskServiceImpl implements TaskService {
|
||||||
@Override
|
@Override
|
||||||
public void deleteTask(Integer id) {
|
public void deleteTask(Integer id) {
|
||||||
examineTaskDao.deleteTask(id);
|
examineTaskDao.deleteTask(id);
|
||||||
|
ExamineConfig examineConfig = new ExamineConfig();
|
||||||
|
examineConfig.setExamineTaskId(id);
|
||||||
|
List<ExamineConfig> list = examineConfigMapper.list(examineConfig);
|
||||||
|
for (ExamineConfig config : list) {
|
||||||
|
examineConfigMapper.deleteById(config.getId());
|
||||||
|
}
|
||||||
|
|
||||||
|
ExamineUser examineUser = new ExamineUser();
|
||||||
|
examineUser.setTaskId(id);
|
||||||
|
List<ExamineUser> existingUsers = userMapper.list(examineUser);
|
||||||
|
for (ExamineUser existingUser : existingUsers) {
|
||||||
|
userMapper.deleteById(existingUser.getId());
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@ -108,7 +132,7 @@ public class TaskServiceImpl implements TaskService {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
@DataScope(deptAlias = "t3", userAlias = "t2")
|
@DataScope(deptAlias = "t3", userAlias = "t2")
|
||||||
public Map<Integer,List<ExamineTask>> listTask(TaskQueryDto queryDto) {
|
public Map<Integer, List<ExamineTask>> listTask(TaskQueryDto queryDto) {
|
||||||
List<ExamineTask> examineTasks = examineTaskDao.listTask(queryDto);
|
List<ExamineTask> examineTasks = examineTaskDao.listTask(queryDto);
|
||||||
LocalDateTime now = LocalDateTime.now();
|
LocalDateTime now = LocalDateTime.now();
|
||||||
for (ExamineTask examineTask : examineTasks) {
|
for (ExamineTask examineTask : examineTasks) {
|
||||||
|
@ -127,4 +151,15 @@ public class TaskServiceImpl implements TaskService {
|
||||||
}
|
}
|
||||||
return examineTasks.stream().collect(Collectors.groupingBy(ExamineTask::getTaskStatus));
|
return examineTasks.stream().collect(Collectors.groupingBy(ExamineTask::getTaskStatus));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public List<ExamineConfig> updateConfigTask(List<ExamineConfig> list) {
|
||||||
|
for (ExamineConfig examineConfig : list) {
|
||||||
|
if (examineConfig.getId() == null) {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
examineConfigMapper.update(examineConfig);
|
||||||
|
}
|
||||||
|
return list;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue