Commit 8de3a259 by 穆龙飞

modify:修改文件上传

parent c3c29ba3
...@@ -139,9 +139,9 @@ public class ChangeFlowBiz { ...@@ -139,9 +139,9 @@ public class ChangeFlowBiz {
itemIds = itemVOS.stream().map(ItemVO::getItemId).collect(Collectors.toList()); itemIds = itemVOS.stream().map(ItemVO::getItemId).collect(Collectors.toList());
} }
// 工单负责人 // 工单负责人
String changeCommander; String changeCommander = null;
// 获取工单负责人 // 获取工单负责人
GoodsResponseRpc goodsResponseRpc = null; GoodsResponseRpc goodsResponseRpc;
try { try {
goodsResponseRpc = interiorChangeConfigService.queryCommanderInfo( goodsResponseRpc = interiorChangeConfigService.queryCommanderInfo(
ChangeCommanderPO.builder().parentChangeClassId(parentChangeClassId).sonChangeClassId(sonChangeClassId) ChangeCommanderPO.builder().parentChangeClassId(parentChangeClassId).sonChangeClassId(sonChangeClassId)
...@@ -149,6 +149,8 @@ public class ChangeFlowBiz { ...@@ -149,6 +149,8 @@ public class ChangeFlowBiz {
changeCommander = goodsResponseRpc.getEmail(); changeCommander = goodsResponseRpc.getEmail();
} catch (Exception e) { } catch (Exception e) {
log.error("[op:queryCommanderInfo] error, e:{}", e); log.error("[op:queryCommanderInfo] error, e:{}", e);
}
if (changeCommander == null) {
changeCommander = appConfig.getTestEmail(); changeCommander = appConfig.getTestEmail();
} }
// Assert.notNull(goodsResponseRpc, "未查询到负责人信息"); // Assert.notNull(goodsResponseRpc, "未查询到负责人信息");
...@@ -449,7 +451,11 @@ public class ChangeFlowBiz { ...@@ -449,7 +451,11 @@ public class ChangeFlowBiz {
Assert.notNull(changeConfig, "二级变更类型不存在"); Assert.notNull(changeConfig, "二级变更类型不存在");
Integer needFile = changeConfig.getNeedFile(); Integer needFile = changeConfig.getNeedFile();
if (NeedFileEnum.NEED.getStatus().equals(needFile)) { if (NeedFileEnum.NEED.getStatus().equals(needFile)) {
Assert.notEmpty(changeFlowSubmitReq.getFiles(), "必须上传资料"); List<ChangeFlowFile> fileList = changeFlowSubmitReq.getChangeFiles();
fileList.addAll(changeFlowSubmitReq.getUploadFiles());
if (CollectionUtils.isEmpty(fileList)) {
throw ExceptionFactory.createBiz(ResponseCode.BAD_REQUEST, "必须上传资料");
}
} }
// 变更行动项不可为空,最多20项 // 变更行动项不可为空,最多20项
List<ChangeExecConfigReq> changeExecProjectList = changeFlowSubmitReq.getChangeExecProjectList(); List<ChangeExecConfigReq> changeExecProjectList = changeFlowSubmitReq.getChangeExecProjectList();
...@@ -487,12 +493,17 @@ public class ChangeFlowBiz { ...@@ -487,12 +493,17 @@ public class ChangeFlowBiz {
changeFlowSubmitReq.getChangeExecProjectList()); changeFlowSubmitReq.getChangeExecProjectList());
changeExecRecords.forEach(exec -> changeFlowExecService.saveRecord(exec)); changeExecRecords.forEach(exec -> changeFlowExecService.saveRecord(exec));
// 更新附件,覆盖操作,先删除,后插入 // 更新附件,覆盖操作,先删除,后插入
List<ChangeFlowFile> files = changeFlowSubmitReq.getFiles();
if (CollectionUtils.isNotEmpty(files)) {
changeFileService.deleteByChangeRecordId(changeRecord.getId()); changeFileService.deleteByChangeRecordId(changeRecord.getId());
List<ChangeFlowFile> files = changeFlowSubmitReq.getChangeFiles();
if (CollectionUtils.isNotEmpty(files)) {
List<ChangeFile> changeFiles = buildChangeFileRecord(changeRecord.getId(), files, FileTypeEnum.CHANGE.getType()); List<ChangeFile> changeFiles = buildChangeFileRecord(changeRecord.getId(), files, FileTypeEnum.CHANGE.getType());
changeFiles.forEach(file -> changeFileService.saveRecord(file)); changeFiles.forEach(file -> changeFileService.saveRecord(file));
} }
List<ChangeFlowFile> uploadFiles = changeFlowSubmitReq.getUploadFiles();
if (CollectionUtils.isNotEmpty(uploadFiles)) {
List<ChangeFile> changeFiles = buildChangeFileRecord(changeRecord.getId(), uploadFiles, FileTypeEnum.UPLOAD.getType());
changeFiles.forEach(file -> changeFileService.saveRecord(file));
}
HashMap<String, Object> param = new HashMap<>(); HashMap<String, Object> param = new HashMap<>();
param.put("changeId", changeRecord.getFlowId()); param.put("changeId", changeRecord.getFlowId());
param.put("changeSubject", ChangeSubjectEnum.getChangeSubjectEnum(changeRecord.getChangeSubject()).getDesc()); param.put("changeSubject", ChangeSubjectEnum.getChangeSubjectEnum(changeRecord.getChangeSubject()).getDesc());
......
...@@ -59,9 +59,19 @@ public class ChangeFlowSubmitReq { ...@@ -59,9 +59,19 @@ public class ChangeFlowSubmitReq {
private String changeContent; private String changeContent;
/** /**
* 变更工单附件 * 变更前后图片/视频
*/ */
private List<ChangeFlowFile> files; private List<ChangeFlowFile> changeFiles;
/**
* 资料上传
*/
private List<ChangeFlowFile> uploadFiles;
/**
* 变更管理及行动项结果相关的资料文件
*/
private List<ChangeFlowFile> changeResultFiles;
/** /**
* 变更潜在风险 * 变更潜在风险
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment