|
@ -6,11 +6,14 @@ import cn.hutool.core.collection.CollectionUtil; |
|
|
|
|
|
|
|
|
import cn.hutool.core.lang.Snowflake; |
|
|
import cn.hutool.core.lang.Snowflake; |
|
|
import cn.hutool.core.util.ArrayUtil; |
|
|
import cn.hutool.core.util.ArrayUtil; |
|
|
|
|
|
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.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.FileVo; |
|
|
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.LwbsVo; |
|
|
import com.ccsens.tall.bean.vo.TaskVo; |
|
|
import com.ccsens.tall.bean.vo.TaskVo; |
|
@ -20,13 +23,21 @@ import com.ccsens.tall.persist.mapper.*; |
|
|
import com.ccsens.tall.util.TaskUtil; |
|
|
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.PropUtil; |
|
|
|
|
|
import com.ccsens.util.RestTemplateUtil; |
|
|
import com.ccsens.util.exception.BaseException; |
|
|
import com.ccsens.util.exception.BaseException; |
|
|
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
import org.springframework.stereotype.Service; |
|
|
import org.springframework.stereotype.Service; |
|
|
|
|
|
import org.springframework.transaction.annotation.Propagation; |
|
|
|
|
|
import org.springframework.transaction.annotation.Transactional; |
|
|
|
|
|
|
|
|
import javax.annotation.Resource; |
|
|
import javax.annotation.Resource; |
|
|
import java.util.*; |
|
|
import java.util.*; |
|
|
|
|
|
|
|
|
|
|
|
@Slf4j |
|
|
@Service |
|
|
@Service |
|
|
|
|
|
@Transactional(propagation = Propagation.REQUIRED,rollbackFor = Exception.class) |
|
|
public class InputDocService implements IInputDocService { |
|
|
public class InputDocService implements IInputDocService { |
|
|
@Resource |
|
|
@Resource |
|
|
public ProMemberMapper proMemberMapper; |
|
|
public ProMemberMapper proMemberMapper; |
|
@ -165,24 +176,48 @@ public class InputDocService implements IInputDocService { |
|
|
List<InputDocVo.DocOfTask> docByTasks = iInputDocDao.findDocByTask(param.getTaskId()); |
|
|
List<InputDocVo.DocOfTask> docByTasks = iInputDocDao.findDocByTask(param.getTaskId()); |
|
|
for (InputDocVo.DocOfTask docs:docByTasks){ |
|
|
for (InputDocVo.DocOfTask docs:docByTasks){ |
|
|
for (InputDocVo.Record record:docs.getRecords()){ |
|
|
for (InputDocVo.Record record:docs.getRecords()){ |
|
|
if (record.getFileIds().contains(",")){ |
|
|
if(ObjectUtil.isNotNull(record.getFileIds())) { |
|
|
|
|
|
try { |
|
|
|
|
|
//拆分文件id
|
|
|
String[] split = record.getFileIds().split(","); |
|
|
String[] split = record.getFileIds().split(","); |
|
|
for (int i = 0; i < split.length; i++) { |
|
|
List<String> splits =new ArrayList<>(Arrays.asList(split)); |
|
|
File file = fileMapper.selectByPrimaryKey(Long.valueOf(split[i])); |
|
|
if(split.length != 0){ |
|
|
InputDocVo.File nowFile = new InputDocVo.File(); |
|
|
//获取文件项目的路径
|
|
|
nowFile.setFileName(file.getFileName()); |
|
|
String requestUrl = PropUtil.filedeal; |
|
|
nowFile.setFileUrl(file.getVisitLocation()); |
|
|
//通过文件id查询文件信息
|
|
|
record.getFileList().add(nowFile); |
|
|
String c = RestTemplateUtil.postBody1(requestUrl,splits); |
|
|
} |
|
|
JsonResponse<List<FileVo.FilePosition>> a = JSONObject.parseObject(c,JsonResponse.class); |
|
|
}else{ |
|
|
if(ObjectUtil.isNotNull(a) && ObjectUtil.isNotNull(a.getData())){ |
|
|
if (StrUtil.isNotBlank(record.getFileIds())){ |
|
|
List<FileVo.FilePosition> fileList = a.getData(); |
|
|
File file = fileMapper.selectByPrimaryKey(Long.valueOf(record.getFileIds())); |
|
|
record.setFileList(fileList); |
|
|
InputDocVo.File nowFile = new InputDocVo.File(); |
|
|
} |
|
|
nowFile.setFileName(file.getFileName()); |
|
|
} |
|
|
nowFile.setFileUrl(file.getVisitLocation()); |
|
|
}catch (Exception e){ |
|
|
record.getFileList().add(nowFile); |
|
|
log.info("查询文件信息失败:{}", e); |
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
// if (record.getFileIds().contains(",")){
|
|
|
|
|
|
// String[] split = record.getFileIds().split(",");
|
|
|
|
|
|
// for (int i = 0; i < split.length; i++) {
|
|
|
|
|
|
//
|
|
|
|
|
|
//
|
|
|
|
|
|
//// File file = fileMapper.selectByPrimaryKey(Long.valueOf(split[i]));
|
|
|
|
|
|
//// InputDocVo.File nowFile = new InputDocVo.File();
|
|
|
|
|
|
//// nowFile.setFileName(file.getFileName());
|
|
|
|
|
|
//// nowFile.setFileUrl(file.getVisitLocation());
|
|
|
|
|
|
//// record.getFileList().add(nowFile);
|
|
|
|
|
|
// }
|
|
|
|
|
|
// }else{
|
|
|
|
|
|
// if (StrUtil.isNotBlank(record.getFileIds())){
|
|
|
|
|
|
//// File file = fileMapper.selectByPrimaryKey(Long.valueOf(record.getFileIds()));
|
|
|
|
|
|
//// InputDocVo.File nowFile = new InputDocVo.File();
|
|
|
|
|
|
//// nowFile.setFileName(file.getFileName());
|
|
|
|
|
|
//// nowFile.setFileUrl(file.getVisitLocation());
|
|
|
|
|
|
//// record.getFileList().add(nowFile);
|
|
|
|
|
|
// }
|
|
|
|
|
|
// }
|
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
return docByTasks; |
|
|
return docByTasks; |
|
|