ccsens_wiki
/
ccsenscloud
5
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity
Browse Source

20210422v1.4

recovery
zy_Java 4 years ago
parent
cdb2c12d65
commit
3823436af3
2 changed files with 192 additions and 215 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 41
      tall/src/main/java/com/ccsens/tall/service/IInputDocService.java
  2. 366
      tall/src/main/java/com/ccsens/tall/service/InputDocService.java

41
tall/src/main/java/com/ccsens/tall/service/IInputDocService.java
View File

@ -3,42 +3,39 @@ package com.ccsens.tall.service;
import com.ccsens.tall.bean.dto.InputDocDto; import com.ccsens.tall.bean.dto.InputDocDto;
import com.ccsens.tall.bean.dto.LwbsDto; import com.ccsens.tall.bean.dto.LwbsDto;
import com.ccsens.tall.bean.vo.InputDocVo; import com.ccsens.tall.bean.vo.InputDocVo;
import com.ccsens.tall.bean.vo.LwbsVo;
import com.ccsens.tall.bean.vo.TaskVo; import com.ccsens.tall.bean.vo.TaskVo;
import com.ccsens.util.bean.dto.QueryDto;
import com.github.pagehelper.Page;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import java.util.List; import java.util.List;
public interface IInputDocService { public interface IInputDocService {
/** // /**
* 查询 该人参加得所有的项目 // * 查询 该人参加得所有的项目
* @param param // * @param param
* @param userId // * @param userId
* @return // * @return
*/ // */
List<LwbsVo.SelByUserIdToComProjectVo> selBylwbs(LwbsDto.SelByUserIdToComProject param, Long userId); // List<LwbsVo.SelByUserIdToComProjectVo> selBylwbs(LwbsDto.SelByUserIdToComProject param, Long userId);
//
/** // /**
* 查询 该人参加的项目（把项目当成一级任务）及项目下的二级任务 // * 查询 该人参加的项目（把项目当成一级任务）及项目下的二级任务
* @param param // * @param param
* @param userId // * @param userId
* @return // * @return
*/ // */
TaskVo.ProTaskInfo selByProjectIdToTask(LwbsDto.SelByProjectIdToTaskDto param, Long userId); // TaskVo.ProTaskInfo selByProjectIdToTask(LwbsDto.SelByProjectIdToTaskDto param, Long userId);
/** /**
* 查询二级任务下的所有的子任务 * 查询二级任务下的所有的子任务
* @param param * @param param 查询条件
* @param userId * @param userId userId
* @return * @return 返回任务列表
*/ */
List<TaskVo.NormalTask> selByTwoTaskId(LwbsDto.SelByProjectIdToTaskDto param, Long userId,Long taskId); List<TaskVo.NormalTask> selByTwoTaskId(LwbsDto.SelByProjectIdToTaskDto param, Long userId,Long taskId);
/** /**
* 根据任务id查询输入文档 * 根据任务id查询输入文档
* @param params 任务id * @param params 任务id
* @return * @return 返回输入文档
*/ */
List<InputDocVo.DocOfTask> findDocByTask(InputDocDto.FindDocByTask params); List<InputDocVo.DocOfTask> findDocByTask(InputDocDto.FindDocByTask params);

366
tall/src/main/java/com/ccsens/tall/service/InputDocService.java
View File

@ -1,7 +1,6 @@
package com.ccsens.tall.service; package com.ccsens.tall.service;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.lang.Snowflake; import cn.hutool.core.lang.Snowflake;
@ -10,21 +9,16 @@ import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.ccsens.tall.bean.dto.InputDocDto; import com.ccsens.tall.bean.dto.InputDocDto;
import com.ccsens.tall.bean.dto.LwbsDto; import com.ccsens.tall.bean.dto.LwbsDto;
import com.ccsens.tall.bean.po.*; import com.ccsens.tall.bean.po.*;
import com.ccsens.tall.bean.vo.*; import com.ccsens.tall.bean.vo.*;
import com.ccsens.tall.persist.dao.*; import com.ccsens.tall.persist.dao.*;
import com.ccsens.tall.persist.mapper.*; import com.ccsens.tall.persist.mapper.*;
import com.ccsens.tall.util.TaskUtil;
import com.ccsens.util.CodeEnum; import com.ccsens.util.CodeEnum;
import com.ccsens.util.JsonResponse; import com.ccsens.util.JsonResponse;
import com.ccsens.util.PropUtil; import com.ccsens.util.PropUtil;
import com.ccsens.util.RestTemplateUtil; import com.ccsens.util.RestTemplateUtil;
import com.ccsens.util.exception.BaseException; import com.ccsens.util.exception.BaseException;
import com.github.pagehelper.Page;
import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
@ -39,8 +33,6 @@ import java.util.*;
@Service @Service
@Transactional(propagation = Propagation.REQUIRED,rollbackFor = Exception.class) @Transactional(propagation = Propagation.REQUIRED,rollbackFor = Exception.class)
public class InputDocService implements IInputDocService { public class InputDocService implements IInputDocService {
@Resource
public ProMemberMapper proMemberMapper;
@Resource @Resource
public SysProjectDao sysProjectDao; public SysProjectDao sysProjectDao;
@Resource @Resource
@ -67,164 +59,158 @@ public class InputDocService implements IInputDocService {
private ProDeliverHistoryRecordDao deliverHistoryRecordDao; private ProDeliverHistoryRecordDao deliverHistoryRecordDao;
@Resource @Resource
private IProMemberService iProMemberService; private IProMemberService iProMemberService;
@Resource
private ProPluginConfigDao pluginConfigDao;
@Override
public List<LwbsVo.SelByUserIdToComProjectVo> selBylwbs(LwbsDto.SelByUserIdToComProject param, Long userId) {
List<LwbsVo.SelByUserIdToComProjectVo> selByUserIdToComProjectVos =new ArrayList<LwbsVo.SelByUserIdToComProjectVo>();
//手动添加一个我的
LwbsVo.SelByUserIdToComProjectVo mine =new LwbsVo.SelByUserIdToComProjectVo();
mine.setName("我的");
mine.setType(0);
mine.setId(userId);
selByUserIdToComProjectVos.add(mine);
// //查询普通项目
// List<LwbsVo.SelByUserIdToComProjectVo> projectVoList = sysProjectDao.queryByUserId(param.getStartTime(),param.getEndTime(),userId);
// selByUserIdToComProjectVos.addAll(projectVoList);
//查询中间的项目
ProMemberExample proMemberExample=new ProMemberExample();
proMemberExample.createCriteria().andRecStatusEqualTo((byte) 0).andUserIdEqualTo(userId);
List<ProMember> proMembers = proMemberMapper.selectByExample(proMemberExample);
List<Long> longList=new ArrayList<Long>();
proMembers.forEach(proMember -> {
longList.add(proMember.getProjectId());
});
SysProjectExample sysProjectExample=new SysProjectExample();
sysProjectExample.createCriteria().andRecStatusEqualTo((byte)0).andIdIn(longList).andBeginTimeLessThanOrEqualTo(param.getEndTime()).andEndTimeGreaterThanOrEqualTo(param.getStartTime());
List<SysProject> sysProjects = sysProjectDao.selectByExample(sysProjectExample);
sysProjects.forEach(sysProject -> {
LwbsVo.SelByUserIdToComProjectVo selByUserIdToComProjectVo_zhongjian =new LwbsVo.SelByUserIdToComProjectVo();
selByUserIdToComProjectVo_zhongjian.setName(sysProject.getName());
selByUserIdToComProjectVo_zhongjian.setId(sysProject.getId());
selByUserIdToComProjectVo_zhongjian.setType(1);
selByUserIdToComProjectVos.add(selByUserIdToComProjectVo_zhongjian);
});
//手动添加一个其他
LwbsVo.SelByUserIdToComProjectVo other =new LwbsVo.SelByUserIdToComProjectVo();
other.setName("其他");
other.setType(2);
selByUserIdToComProjectVos.add(other);
return selByUserIdToComProjectVos;
}
@Override
public TaskVo.ProTaskInfo selByProjectIdToTask(LwbsDto.SelByProjectIdToTaskDto param, Long userId) {
TaskVo.ProTaskInfo taskInfo=new TaskVo.ProTaskInfo();
// //查询其他
// if (param.getQueryType() == 2){
// List<TaskVo.NormalTask> taskList = taskDetailDao.selectOtherTask(userId);
// //区分全局任务和普通任务
// TaskUtil.Task task = TaskUtil.splitTask(taskList, param.getStartTime(), param.getEndTime(), param.getProcess());
// List<TaskVo.GlobalTask> globalTaskList = new ArrayList<>();
// //如果全局任务不为空
// if(CollectionUtil.isNotEmpty(task.getGlobalTask())){
// TaskVo.GlobalTask globalTask = new TaskVo.GlobalTask();
// for (TaskVo.NormalTask normalTask : task.getGlobalTask()) {
// BeanUtil.copyProperties(normalTask,globalTask);
// globalTaskList.add(globalTask);
// }
// taskInfo.setGlobalTaskList(globalTaskList);
// }
// //如果普通任务不为空
// if (CollectionUtil.isNotEmpty(task.getCommonTask())){
// taskInfo.setNormalTaskList(task.getCommonTask());
// }
// return taskInfo;
// }
// //
// if (param.getQueryType() == 0){ // @Override
// param.setId(null); // public List<LwbsVo.SelByUserIdToComProjectVo> selBylwbs(LwbsDto.SelByUserIdToComProject param, Long userId) {
// } // List<LwbsVo.SelByUserIdToComProjectVo> selByUserIdToComProjectVos =new ArrayList<LwbsVo.SelByUserIdToComProjectVo>();
// //手动添加一个我的
// LwbsVo.SelByUserIdToComProjectVo mine =new LwbsVo.SelByUserIdToComProjectVo();
// mine.setName("我的");
// mine.setType(0);
// mine.setId(userId);
// selByUserIdToComProjectVos.add(mine);
//// //查询普通项目
//// List<LwbsVo.SelByUserIdToComProjectVo> projectVoList = sysProjectDao.queryByUserId(param.getStartTime(),param.getEndTime(),userId);
//// selByUserIdToComProjectVos.addAll(projectVoList);
// //查询中间的项目
// ProMemberExample proMemberExample=new ProMemberExample();
// proMemberExample.createCriteria().andRecStatusEqualTo((byte) 0).andUserIdEqualTo(userId);
// List<ProMember> proMembers = proMemberMapper.selectByExample(proMemberExample);
// List<Long> longList=new ArrayList<Long>();
// proMembers.forEach(proMember -> {
// longList.add(proMember.getProjectId());
// });
// SysProjectExample sysProjectExample=new SysProjectExample();
// sysProjectExample.createCriteria().andRecStatusEqualTo((byte)0).andIdIn(longList).andBeginTimeLessThanOrEqualTo(param.getEndTime()).andEndTimeGreaterThanOrEqualTo(param.getStartTime());
// List<SysProject> sysProjects = sysProjectDao.selectByExample(sysProjectExample);
// sysProjects.forEach(sysProject -> {
// LwbsVo.SelByUserIdToComProjectVo selByUserIdToComProjectVo_zhongjian =new LwbsVo.SelByUserIdToComProjectVo();
// selByUserIdToComProjectVo_zhongjian.setName(sysProject.getName());
// selByUserIdToComProjectVo_zhongjian.setId(sysProject.getId());
// selByUserIdToComProjectVo_zhongjian.setType(1);
// selByUserIdToComProjectVos.add(selByUserIdToComProjectVo_zhongjian);
// });
// //手动添加一个其他
// LwbsVo.SelByUserIdToComProjectVo other =new LwbsVo.SelByUserIdToComProjectVo();
// other.setName("其他");
// other.setType(2);
// selByUserIdToComProjectVos.add(other);
// //
// //普通的任务和全局的 // return selByUserIdToComProjectVos;
// List<TaskVo.NormalTask> normalTaskList1= iInputDocDao.selectByCompany(param,userId); // }
// //
// //给二级任务下添加子任务 // @Override
// //遍历项目 // public TaskVo.ProTaskInfo selByProjectIdToTask(LwbsDto.SelByProjectIdToTaskDto param, Long userId) {
// if(param.getId()!=null){ // TaskVo.ProTaskInfo taskInfo=new TaskVo.ProTaskInfo();
// for (int i = 0; i < normalTaskList1.size(); i++) { //// //查询其他
// //遍历任务 //// if (param.getQueryType() == 2){
// for (int i1 = 0; i1 < normalTaskList1.get(i).getSecondTasks().size(); i1++) { //// List<TaskVo.NormalTask> taskList = taskDetailDao.selectOtherTask(userId);
// Long taskId= normalTaskList1.get(i).getSecondTasks().get(i1).getDetailId(); //// //区分全局任务和普通任务
// //查询该任务下的子任务 //// TaskUtil.Task task = TaskUtil.splitTask(taskList, param.getStartTime(), param.getEndTime(), param.getProcess());
// List<TaskVo.NormalTask> list = selByTwoTaskId(param, userId, taskId); //// List<TaskVo.GlobalTask> globalTaskList = new ArrayList<>();
// //给二级任务添加子任务 //// //如果全局任务不为空
// if(CollectionUtil.isNotEmpty(list)){ //// if(CollectionUtil.isNotEmpty(task.getGlobalTask())){
// // 第i个项目 i1个二级任务 添加二级任务的子任务 //// TaskVo.GlobalTask globalTask = new TaskVo.GlobalTask();
// normalTaskList1.get(i).getSecondTasks().get(i1).getSecondTasks().addAll(list); //// for (TaskVo.NormalTask normalTask : task.getGlobalTask()) {
// } //// BeanUtil.copyProperties(normalTask,globalTask);
// } //// globalTaskList.add(globalTask);
// } //// }
// } //// taskInfo.setGlobalTaskList(globalTaskList);
// //拆分后得全局任务和普通任务 //// }
// List<TaskVo.GlobalTask> globalTaskList = new ArrayList<>(); //// //如果普通任务不为空
// List<TaskVo.NormalTask> normalTaskList = new ArrayList<>(); //// if (CollectionUtil.isNotEmpty(task.getCommonTask())){
// for (int i = 0; i < normalTaskList1.size(); i++) { //// taskInfo.setNormalTaskList(task.getCommonTask());
// //拆分项目下得普通任务和全局任务 //// }
// List<TaskVo.NormalTask> list= normalTaskList1.get(i).getSecondTasks(); //// return taskInfo;
// //判断全局还是普通任务 //// }
// TaskUtil.Task task = TaskUtil.splitTask(list, param.getStartTime(), param.getEndTime(), param.getProcess()); ////
// if(CollectionUtil.isNotEmpty(task.getGlobalTask())){ //// if (param.getQueryType() == 0){
// if(param.getId()==null) { //// param.setId(null);
// //给全局任务下先存项目名称 //// }
// TaskVo.GlobalTask globalTask = new TaskVo.GlobalTask(); ////
// BeanUtil.copyProperties(normalTaskList1.get(i), globalTask); //// //普通的任务和全局的
// globalTask.setNormalTaskList(task.getGlobalTask()); //// List<TaskVo.NormalTask> normalTaskList1= iInputDocDao.selectByCompany(param,userId);
// globalTaskList.add(globalTask); ////
// }else { //// //给二级任务下添加子任务
// //直接存二级任务信息 //// //遍历项目
// task.getGlobalTask().forEach(ac->{ //// if(param.getId()!=null){
// TaskVo.GlobalTask globalTask = new TaskVo.GlobalTask(); //// for (int i = 0; i < normalTaskList1.size(); i++) {
// BeanUtil.copyProperties(ac,globalTask); //// //遍历任务
// globalTask.setNormalTaskList(ac.getSecondTasks()); //// for (int i1 = 0; i1 < normalTaskList1.get(i).getSecondTasks().size(); i1++) {
// globalTaskList.add(globalTask); //// Long taskId= normalTaskList1.get(i).getSecondTasks().get(i1).getDetailId();
// }); //// //查询该任务下的子任务
// } //// List<TaskVo.NormalTask> list = selByTwoTaskId(param, userId, taskId);
// } //// //给二级任务添加子任务
// if(CollectionUtil.isNotEmpty(task.getCommonTask())){ //// if(CollectionUtil.isNotEmpty(list)){
// if(param.getId()==null) { //// // 第i个项目 i1个二级任务 添加二级任务的子任务
// //给普通任务下先存项目 //// normalTaskList1.get(i).getSecondTasks().get(i1).getSecondTasks().addAll(list);
// TaskVo.NormalTask normalTask = new TaskVo.NormalTask(); //// }
// BeanUtil.copyProperties(normalTaskList1.get(i), normalTask); //// }
// normalTask.setSecondTasks(task.getCommonTask()); //// }
// normalTaskList.add(normalTask); //// }
// }else { //// //拆分后得全局任务和普通任务
// //自查项目不要项目信息 //// List<TaskVo.GlobalTask> globalTaskList = new ArrayList<>();
// task.getCommonTask().forEach(ac1->{ //// List<TaskVo.NormalTask> normalTaskList = new ArrayList<>();
// normalTaskList.add(ac1); //// for (int i = 0; i < normalTaskList1.size(); i++) {
// }); //// //拆分项目下得普通任务和全局任务
// } //// List<TaskVo.NormalTask> list= normalTaskList1.get(i).getSecondTasks();
// } //// //判断全局还是普通任务
// } //// TaskUtil.Task task = TaskUtil.splitTask(list, param.getStartTime(), param.getEndTime(), param.getProcess());
// taskInfo.setGlobalTaskList(globalTaskList); //// if(CollectionUtil.isNotEmpty(task.getGlobalTask())){
// taskInfo.setNormalTaskList(normalTaskList); //// if(param.getId()==null) {
// for (TaskVo.NormalTask normalTask : taskInfo.getNormalTaskList()) { //// //给全局任务下先存项目名称
// if (null != normalTask.getDetailId()){ //// TaskVo.GlobalTask globalTask = new TaskVo.GlobalTask();
// ProPluginConfigExample configExample = new ProPluginConfigExample(); //// BeanUtil.copyProperties(normalTaskList1.get(i), globalTask);
// configExample.createCriteria().andTaskIdEqualTo(normalTask.getDetailId()).andPlaceLocationEqualTo((byte) 0); //// globalTask.setNormalTaskList(task.getGlobalTask());
// List<ProPluginConfig> proPluginConfigs = pluginConfigDao.selectByExample(configExample); //// globalTaskList.add(globalTask);
// if (CollectionUtil.isNotEmpty(proPluginConfigs)){ //// }else {
// ProPluginConfig config = proPluginConfigs.get(0); //// //直接存二级任务信息
// normalTask.setImportParam(config.getImportParam()); //// task.getGlobalTask().forEach(ac->{
// normalTask.setRoutineLocation(config.getRoutineLocation()); //// TaskVo.GlobalTask globalTask = new TaskVo.GlobalTask();
// normalTask.setWebPath(config.getWebPath()); //// BeanUtil.copyProperties(ac,globalTask);
// } //// globalTask.setNormalTaskList(ac.getSecondTasks());
// } //// globalTaskList.add(globalTask);
// } //// });
//// }
return taskInfo; //// }
} //// if(CollectionUtil.isNotEmpty(task.getCommonTask())){
//// if(param.getId()==null) {
//// //给普通任务下先存项目
//// TaskVo.NormalTask normalTask = new TaskVo.NormalTask();
//// BeanUtil.copyProperties(normalTaskList1.get(i), normalTask);
//// normalTask.setSecondTasks(task.getCommonTask());
//// normalTaskList.add(normalTask);
//// }else {
//// //自查项目不要项目信息
//// task.getCommonTask().forEach(ac1->{
//// normalTaskList.add(ac1);
//// });
//// }
//// }
//// }
//// taskInfo.setGlobalTaskList(globalTaskList);
//// taskInfo.setNormalTaskList(normalTaskList);
//// for (TaskVo.NormalTask normalTask : taskInfo.getNormalTaskList()) {
//// if (null != normalTask.getDetailId()){
//// ProPluginConfigExample configExample = new ProPluginConfigExample();
//// configExample.createCriteria().andTaskIdEqualTo(normalTask.getDetailId()).andPlaceLocationEqualTo((byte) 0);
//// List<ProPluginConfig> proPluginConfigs = pluginConfigDao.selectByExample(configExample);
//// if (CollectionUtil.isNotEmpty(proPluginConfigs)){
//// ProPluginConfig config = proPluginConfigs.get(0);
//// normalTask.setImportParam(config.getImportParam());
//// normalTask.setRoutineLocation(config.getRoutineLocation());
//// normalTask.setWebPath(config.getWebPath());
//// }
//// }
//// }
//
// return taskInfo;
// }
/** /**
* 查询二级任务下的所有的子任务 * 查询二级任务下的所有的子任务
*
* @param param
* @param userId
* @return
*/ */
@Override @Override
public List<TaskVo.NormalTask> selByTwoTaskId(LwbsDto.SelByProjectIdToTaskDto param, Long userId,Long taskId) { public List<TaskVo.NormalTask> selByTwoTaskId(LwbsDto.SelByProjectIdToTaskDto param, Long userId,Long taskId) {
@ -233,8 +219,6 @@ public class InputDocService implements IInputDocService {
/** /**
* 根据任务id查找输入文档 * 根据任务id查找输入文档
* @param param 任务id
* @return
*/ */
@Override @Override
public List<InputDocVo.DocOfTask> findDocByTask(InputDocDto.FindDocByTask param) { public List<InputDocVo.DocOfTask> findDocByTask(InputDocDto.FindDocByTask param) {
@ -253,20 +237,8 @@ public class InputDocService implements IInputDocService {
for (InputDocVo.Record record:docs.getRecords()){ for (InputDocVo.Record record:docs.getRecords()){
if(ObjectUtil.isNotNull(record.getFileIds())) { if(ObjectUtil.isNotNull(record.getFileIds())) {
try { try {
//拆分文件id List<FileVo.FilePosition> fileByFileIds = getFileByFileIds(record.getFileIds());
String[] split = record.getFileIds().split(","); record.setFileList(fileByFileIds);
List<String> splits =new ArrayList<>(Arrays.asList(split));
if(split.length != 0){
//获取文件项目的路径
String requestUrl = PropUtil.filedeal;
//通过文件id查询文件信息
String c = RestTemplateUtil.postBody1(requestUrl,splits);
JsonResponse<List<FileVo.FilePosition>> a = JSONObject.parseObject(c,JsonResponse.class);
if(ObjectUtil.isNotNull(a) && ObjectUtil.isNotNull(a.getData())){
List<FileVo.FilePosition> fileList = a.getData();
record.setFileList(fileList);
}
}
}catch (Exception e){ }catch (Exception e){
log.info("查询文件信息失败:{}", e); log.info("查询文件信息失败:{}", e);
} }
@ -278,6 +250,24 @@ public class InputDocService implements IInputDocService {
return docByTasks; return docByTasks;
} }
private List<FileVo.FilePosition> getFileByFileIds(String fileIds) {
List<FileVo.FilePosition> filePositions = new ArrayList<>();
//拆分文件id
String[] split = fileIds.split(",");
List<String> splits =new ArrayList<>(Arrays.asList(split));
if(split.length != 0){
//获取文件项目的路径
String requestUrl = PropUtil.filedeal;
//通过文件id查询文件信息
String c = RestTemplateUtil.postBody1(requestUrl,splits);
JsonResponse<List<FileVo.FilePosition>> a = JSONObject.parseObject(c,JsonResponse.class);
if(ObjectUtil.isNotNull(a) && ObjectUtil.isNotNull(a.getData())){
filePositions = a.getData();
}
}
return filePositions;
}
/** /**
* 给输入文档上传文件 * 给输入文档上传文件
* @param param docId 文档id * @param param docId 文档id
@ -298,17 +288,17 @@ public class InputDocService implements IInputDocService {
ProTaskInputRecord proTaskInputRecord = new ProTaskInputRecord(); ProTaskInputRecord proTaskInputRecord = new ProTaskInputRecord();
//多文件添加 //多文件添加
if (!ArrayUtil.isEmpty(param.getFileIds())){ if (!ArrayUtil.isEmpty(param.getFileIds())){
String fileIds = ""; StringBuilder fileIds = new StringBuilder();
for (int i = 0; i < param.getFileIds().length; i++) { for (int i = 0; i < param.getFileIds().length; i++) {
fileIds = fileIds + param.getFileIds()[i]+","; fileIds.append(param.getFileIds()[i]).append(",");
} }
fileIds = fileIds.substring(0,fileIds.length()-1); fileIds = new StringBuilder(fileIds.substring(0, fileIds.length() - 1));
proTaskInputRecord.setFileId(fileIds); proTaskInputRecord.setFileId(fileIds.toString());
proTaskInputRecord.setInputDocId(param.getDocId()); proTaskInputRecord.setInputDocId(param.getDocId());
proTaskInputRecord.setStatus((byte)1); proTaskInputRecord.setStatus((byte)1);
proTaskInputRecord.setId(snowflake.nextId());
proTaskInputRecord.setUserId(userId); proTaskInputRecord.setUserId(userId);
proTaskInputRecord.setId(snowflake.nextId());
proTaskInputRecord.setRemark(param.getRemark()); proTaskInputRecord.setRemark(param.getRemark());
proTaskInputRecordMapper.insertSelective(proTaskInputRecord); proTaskInputRecordMapper.insertSelective(proTaskInputRecord);
historyRecord.setHistoryRemark(param.getRemark()); historyRecord.setHistoryRemark(param.getRemark());
@ -334,8 +324,8 @@ public class InputDocService implements IInputDocService {
//通过输入文档id将输入文档表中的状态更改为已上传 //通过输入文档id将输入文档表中的状态更改为已上传
ProTaskInputDoc proTaskInputDoc = new ProTaskInputDoc(); ProTaskInputDoc proTaskInputDoc = new ProTaskInputDoc();
proTaskInputDoc.setId(param.getDocId());
proTaskInputDoc.setIsUpload(1); proTaskInputDoc.setIsUpload(1);
proTaskInputDoc.setId(param.getDocId());
proTaskInputDocMapper.updateByPrimaryKeySelective(proTaskInputDoc); proTaskInputDocMapper.updateByPrimaryKeySelective(proTaskInputDoc);
} }
//查找项目id //查找项目id
@ -366,8 +356,6 @@ public class InputDocService implements IInputDocService {
/** /**
* 查看文档上传文件历史记录 * 查看文档上传文件历史记录
* @param param docId 文档id
* @return
*/ */
@Override @Override
public List<InputDocVo.HistoryRecord> viewDocHistory(InputDocDto.ViewDocHistory param) { public List<InputDocVo.HistoryRecord> viewDocHistory(InputDocDto.ViewDocHistory param) {
@ -409,7 +397,6 @@ public class InputDocService implements IInputDocService {
/** /**
* 添加输入文档 * 添加输入文档
* @param param
*/ */
@Override @Override
public void addDoc(InputDocDto.AddDoc param) { public void addDoc(InputDocDto.AddDoc param) {
@ -441,7 +428,6 @@ public class InputDocService implements IInputDocService {
/** /**
* 修改输入文档 * 修改输入文档
* @param param
*/ */
@Override @Override
public void updateDoc(InputDocDto.UpdateDoc param) { public void updateDoc(InputDocDto.UpdateDoc param) {
@ -473,7 +459,6 @@ public class InputDocService implements IInputDocService {
/** /**
* 删除输入文档 * 删除输入文档
* @param param
*/ */
@Override @Override
public void delDoc(InputDocDto.DeleteDoc param) { public void delDoc(InputDocDto.DeleteDoc param) {
@ -500,7 +485,6 @@ public class InputDocService implements IInputDocService {
/** /**
* 删除输入文档中的文件 * 删除输入文档中的文件
* @param param
*/ */
@Override @Override
public void delDocOfFile(InputDocDto.DeleteDocOfFile param,Long userId) throws Exception{ public void delDocOfFile(InputDocDto.DeleteDocOfFile param,Long userId) throws Exception{
@ -556,7 +540,6 @@ public class InputDocService implements IInputDocService {
/** /**
* 修改上传文件的备注信息 * 修改上传文件的备注信息
* @param param
*/ */
@Override @Override
public void updateDocOfRemark(InputDocDto.UpdateDocOfRemark param,Long userId) throws Exception{ public void updateDocOfRemark(InputDocDto.UpdateDocOfRemark param,Long userId) throws Exception{
@ -596,8 +579,6 @@ public class InputDocService implements IInputDocService {
/** /**
* 查询历史记录(根据任务id) * 查询历史记录(根据任务id)
* @param param
* @return
*/ */
@Override @Override
public PageInfo<InputDocVo.DocRecordOfTask> findDocRecordByTask(InputDocDto.FindDocRecordByTask param) { public PageInfo<InputDocVo.DocRecordOfTask> findDocRecordByTask(InputDocDto.FindDocRecordByTask param) {
@ -660,8 +641,6 @@ public class InputDocService implements IInputDocService {
/** /**
* 查看交付物的历史记录 * 查看交付物的历史记录
* @param param
* @return
*/ */
@Override @Override
public PageInfo<InputDocVo.DeliverHistory> viewDeliverHistory(InputDocDto.DeliverHistory param) { public PageInfo<InputDocVo.DeliverHistory> viewDeliverHistory(InputDocDto.DeliverHistory param) {
@ -733,10 +712,11 @@ public class InputDocService implements IInputDocService {
} }
}else { }else {
if (StrUtil.isNotBlank(deliverHistory.getFileIds())){ if (StrUtil.isNotBlank(deliverHistory.getFileIds())){
List<String> idList = new ArrayList<>();
idList.add(deliverHistory.getFileIds());
//获取文件项目的路径 //获取文件项目的路径
String requestUrl = PropUtil.filedeal; String requestUrl = PropUtil.filedeal;
List<String> idList = new ArrayList<>();
idList.add(deliverHistory.getFileIds());
//通过文件id查询文件信息 //通过文件id查询文件信息
String c = RestTemplateUtil.postBody1(requestUrl, idList); String c = RestTemplateUtil.postBody1(requestUrl, idList);
JsonResponse<List<FileVo.FilePosition>> a = JSONObject.parseObject(c, JsonResponse.class); JsonResponse<List<FileVo.FilePosition>> a = JSONObject.parseObject(c, JsonResponse.class);

Write Preview
Loading…
Cancel
Save