|
@@ -1,7 +1,13 @@
|
|
|
package cn.cslg.pas.service;
|
|
|
|
|
|
+import cn.cslg.pas.common.core.base.Constants;
|
|
|
+import cn.cslg.pas.common.model.dto.ClientDTO;
|
|
|
+import cn.cslg.pas.common.model.vo.ProductVO;
|
|
|
+import cn.cslg.pas.common.model.vo.ProjectVO;
|
|
|
import cn.cslg.pas.common.utils.SecurityUtils.LoginUtils;
|
|
|
import cn.cslg.pas.common.utils.StringUtils;
|
|
|
+import cn.cslg.pas.domain.Project;
|
|
|
+import cn.cslg.pas.domain.SystemDict;
|
|
|
import cn.cslg.pas.domain.Task;
|
|
|
import cn.cslg.pas.common.model.vo.TaskVO;
|
|
|
import cn.cslg.pas.mapper.TaskMapper;
|
|
@@ -11,6 +17,8 @@ import cn.cslg.pas.common.utils.Response;
|
|
|
import cn.cslg.pas.common.model.dto.UploadFileDTO;
|
|
|
import cn.dev33.satoken.stp.StpUtil;
|
|
|
import cn.hutool.core.io.FileUtil;
|
|
|
+import com.alibaba.fastjson.JSON;
|
|
|
+import com.alibaba.fastjson.JSONArray;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
@@ -19,8 +27,11 @@ import lombok.RequiredArgsConstructor;
|
|
|
import org.springframework.context.annotation.Lazy;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
+import java.io.IOException;
|
|
|
import java.util.ArrayList;
|
|
|
+import java.util.Arrays;
|
|
|
import java.util.List;
|
|
|
+import java.util.stream.Collectors;
|
|
|
|
|
|
/**
|
|
|
* <p>
|
|
@@ -32,11 +43,11 @@ import java.util.List;
|
|
|
*/
|
|
|
@Service
|
|
|
@RequiredArgsConstructor(onConstructor_ = {@Lazy})
|
|
|
-public class TaskService extends ServiceImpl<TaskMapper, Task> {
|
|
|
+public class TaskService extends ServiceImpl<TaskMapper,Task> {
|
|
|
|
|
|
private final FileUtils fileUtils;
|
|
|
private final LoginUtils loginUtils;
|
|
|
-
|
|
|
+ private final RequestService requestService;
|
|
|
public String getFileUrl(Integer id) {
|
|
|
Task task = this.getById(id);
|
|
|
return fileUtils.getSystemPath() + task.getUrl();
|
|
@@ -81,8 +92,9 @@ public class TaskService extends ServiceImpl<TaskMapper, Task> {
|
|
|
return Response.success(true);
|
|
|
}
|
|
|
|
|
|
- public IPage<Task> getPageList(TaskVO params) {
|
|
|
+ public IPage<Task> getPageList(TaskVO params) throws IOException {
|
|
|
IPage<Task> pageList = baseMapper.getPageList(new Page<>(params.getCurrent(), params.getSize()), params);
|
|
|
+ this.setDataList(pageList.getRecords());
|
|
|
return pageList;
|
|
|
}
|
|
|
|
|
@@ -131,4 +143,24 @@ public class TaskService extends ServiceImpl<TaskMapper, Task> {
|
|
|
task.updateById();
|
|
|
}
|
|
|
|
|
|
+ private void setDataList(List<Task> taskList) throws IOException {
|
|
|
+ //获得创建人的id集合
|
|
|
+ List<Integer> createIds =taskList.stream().map(Task::getCreateBy).collect(Collectors.toList());
|
|
|
+ //获取专题库负责人对应信息
|
|
|
+ String jsonObject1 = requestService.getPersonnelFromPCS(createIds);
|
|
|
+ JSONArray jsonArray = JSON.parseArray(jsonObject1);
|
|
|
+ List<ProjectVO.Personnel> personnelList = jsonArray.toJavaList(ProjectVO.Personnel.class);
|
|
|
+ for (Task task : taskList) {
|
|
|
+ for (ProjectVO.Personnel personnel : personnelList) {
|
|
|
+ //装载创建人名
|
|
|
+ if(task.getCreateBy()!=null){
|
|
|
+ if (task.getCreateBy().equals(personnel.getId())) {
|
|
|
+ task.setCreateName(personnel.getPersonnelName());
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
}
|