FT/foton-slrs-system-rest
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/dev_20230216' into dev_20230216

Browse Source
This commit is contained in:
gaojiabao
2023-03-16 09:02:57 +08:00
parent 5f466027b1 57e01dff10
commit 0e28163281
14 changed files with 79 additions and 116 deletions
Download Patch File Download Diff File Expand all files Collapse all files
adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/controller/SarBussionessStandController.java
+1 -5
View File
@@ -418,12 +418,8 @@ public class SarBussionessStandController extends BaseController<SarBussionessSt
@PostMapping("/importSarBussionessStandFile")
public ResponseMessage<SarBussionessStand> importSarBussionessStandFile(@RequestParam(value = "file",required = false)MultipartFile file) throws Exception{
ResponseMessage<SarBussionessStand> message = sarBussionessStandEOService.importSarBussionessStandFile(file);
if (message != null && ! message.equals("")){
sarBussionessStandEOService.importSarBussionessStandFile(file);
return Result.success();
}else {
return Result.error("导入失败,导入的文件为空");
}
}
@ApiOperation(value = "|SarBussionessStand|判断原文译文")
adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/service/ISarBussionessStandService.java
+1 -1
View File
@@ -58,7 +58,7 @@ public interface ISarBussionessStandService extends IService<SarBussionessStand>
ResponseMessage emptyFileAnewStorage(String type);
ResponseMessage<SarBussionessStand> importSarBussionessStandFile(MultipartFile file);
ResponseMessage<SarBussionessStand> importSarBussionessStandFile(MultipartFile file)throws Exception;
ResponseMessage repetitionFile();
}
adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/service/impl/SarBussionessStandServiceImpl.java
+14 -104
View File
@@ -2017,7 +2017,7 @@ public class SarBussionessStandServiceImpl extends ServiceImpl<SarBussionessStan
* @throws Exception
*/
@Override
public ResponseMessage<SarBussionessStand> importSarBussionessStandFile(MultipartFile file) {
public ResponseMessage<SarBussionessStand> importSarBussionessStandFile(MultipartFile file)throws Exception {
//给出头部信息
String[] headerExcel = {"企标编号,中文名称,英文名称,文本状态,发布日期,企标实施日期,企标制修订状态,起草部门,废止日期,代替企标编号,复审日期,起草人,被代替企标编号,采用标准,文件上传人员,采标程度,引用标准,适用车型,能源类型,适用产品线,上传时间,体系类别,备案日期,关联模块-乘用车VPPS编码,关联模块--乘用车vpps中文名称,关联模块--卡车VPPS编码,关联模块--卡车vpps中文名称,附件,企标类型,标准年份,"};
@@ -2042,7 +2042,7 @@ public class SarBussionessStandServiceImpl extends ServiceImpl<SarBussionessStan
saveDirectory.mkdir();
}
//将文件写入到指定路径中
//FileUtils.copyInputStreamToFile(file.getInputStream(),new File(path + "/" + fileNameStr));
FileUtils.copyInputStreamToFile(file.getInputStream(),new File(path + "/" + fileNameStr));
try {
//解压缩
String zipEntryName = FileUnZip.unZipFiles(path + "/" + fileNameStr, path);
@@ -2134,7 +2134,7 @@ public class SarBussionessStandServiceImpl extends ServiceImpl<SarBussionessStan
Date issueTime = sdfs.parse( rowList.get("发布日期"));
String issueTimeStr = sdfs.format(issueTime);
if (StringUtils.isNotBlank(issueTimeStr)){
sarBussStandAttrInfo.setIssueTime(issueTime);
sarBussStandAttrInfo.setIssueTime(issueTimeStr);
}else {
return Result.error("发布日期不能为空");
}
@@ -2143,7 +2143,7 @@ public class SarBussionessStandServiceImpl extends ServiceImpl<SarBussionessStan
Date putTime = sdfs.parse(rowList.get("企标实施日期"));
String putTimeStr = sdfs.format(putTime);
if (StringUtils.isNotBlank(putTimeStr)){
sarBussStandAttrInfo.setPutTime(putTime);
sarBussStandAttrInfo.setPutTime(putTimeStr);
}else {
return Result.error("企标实施日期不能为空");
}
@@ -2332,43 +2332,8 @@ public class SarBussionessStandServiceImpl extends ServiceImpl<SarBussionessStan
standMap = com.alibaba.fastjson.JSONObject.parseObject(standJson);
String bussId = "";
if (standMap != null && !standMap.isEmpty()) {
// String standCode = String.valueOf(standMap.get("standCode"));
// String standName = String.valueOf(standMap.get("standName"));
// String standEnName = String.valueOf(standMap.get("standEnName"));
// String textStatusBuss = String.valueOf(standMap.get("textStatusBuss"));
// String issueTime = String.valueOf(standMap.get("issueTime"));
// String putTime = String.valueOf(standMap.get("putTime"));
// String revisionStatus = String.valueOf(standMap.get("revisionStatus"));
// String qcdw = String.valueOf(standMap.get("qcdw"));
// String fzrqbuss = String.valueOf(standMap.get("fzrqbuss"));
// String dtqbbhbuss = String.valueOf(standMap.get("dtqbbhbuss"));
// String fsrqbuss = String.valueOf(standMap.get("fsrqbuss"));
// String qcrbuss = String.valueOf(standMap.get("qcrbuss"));
// String bdtqbbhbuss = String.valueOf(standMap.get("bdtqbbhbuss"));
// String wjscrybuss = String.valueOf(standMap.get("wjscrybuss"));
// String sycxclass = String.valueOf(standMap.get("sycxclass"));
// String nylxclass = String.valueOf(standMap.get("nylxclass"));
// String sycpxclass = String.valueOf(standMap.get("sycpxclass"));
// String xcsjbuss = String.valueOf(standMap.get("xcsjbuss"));
// String txlbbuss = String.valueOf(standMap.get("txlbbuss"));
// String fbgBuss = String.valueOf(standMap.get("fbgBuss"));
// String standSort = String.valueOf(standMap.get("standSort"));
// String standYear = String.valueOf(standMap.get("standYear"));
SarBussionessStand sarBussionessStand = new SarBussionessStand();
// if(standMap.containsKey("standId")) {
// if (standMap.get("standId") != null && !standMap.get("standId").toString().equals("")) {
// String resId = standMap.get("standId").toString();
// //此处说明是带入的形式
// sarStandardsInfoEO.setId(resId);
// SarCompResAssess assessInfoByResId = sarCompResAssessEOService.ssessInfoByResId(resId);
// if (assessInfoByResId != null) {
// assessInfoByResId.setProcessState("2");
// sarCompResAssessEOService.updateByPrimaryKeySelective(assessInfoByResId);
// }
// }
// }
Map<String,Object> attInfoMap = new HashMap<>();
List<String> jsonArray = new ArrayList<>();
@@ -2397,9 +2362,6 @@ public class SarBussionessStandServiceImpl extends ServiceImpl<SarBussionessStan
createStandBaseField(sarBussionessStand,entry.getKey(),value);
}
}
//处理文件
//此处需要处理之前的文件信息，防止文件丢失
// attInfoMap = saveFileMsg(attInfoMap,sarStandardsInfoEO.getFileIds(),sarStandardsInfoEO.getTextStatus());
String resData = JSON.toJSONString(attInfoMap, SerializerFeature.WriteMapNullValue);
sarBussionessStand.setSarStandAttrEOStr(resData);
// 根据标准号判断数据是否已存在
@@ -2417,12 +2379,7 @@ public class SarBussionessStandServiceImpl extends ServiceImpl<SarBussionessStan
standCode = sarBussionessStand.getStandCode();
}
List<SarBussionessStand> lawsList = iSarBussionessStandService.selectStandardsByStandNumber(standCode);
// if (StringUtils.isBlank(sarStandardsInfoEO.getMenuId()) && "INLAND".equals(sarStandardsInfoEO.getStandType())) {
// sarStandardsInfoEO.setMenuId("64df1d5522bb49c09af2");
// sarStandardsInfoEO.setCountry("CN");
// } else if (StringUtils.isBlank(sarStandardsInfoEO.getMenuId()) && "FOREIGN".equals(sarStandardsInfoEO.getStandType())) {
// sarStandardsInfoEO.setMenuId("22179d54d4e640098e29");
// }
//此处判断是否是带入的标准
if(StringUtils.isNotBlank(sarBussionessStand.getId())) {
bussId = sarBussionessStand.getId();
@@ -2431,29 +2388,13 @@ public class SarBussionessStandServiceImpl extends ServiceImpl<SarBussionessStan
iSarBussionessStandService.attrInfoDetails(query);
Map<String, Object> attrInfoMap = query.getAttrInfoMap();
if(attInfoMap!=null && !attInfoMap.isEmpty()){
// updateStandFileFieldData(attInfoMap,attrInfoMap);
resData = JSON.toJSONString(attInfoMap, SerializerFeature.WriteMapNullValue);
sarBussionessStand.setSarStandAttrEOStr(resData);
}
// 查询原相关流程
// String relatePro = sarBussStandAttrInfoService.selectFieldValByStandId("XGLC",sarBussionessStand.getId());
// if (StringUtils.isNotBlank(relatePro)) {
// String[] processSplit = relatePro.split(",");
// Set<String> processSet = new HashSet<>();
// for(String sData:processSplit){
// processSet.add(sData);
// }
// //processSet.add(prcNum);
// relatePro = StringUtils.join(processSet.toArray(), ",");
// }// else {
// relatePro = prcNum;
// }
// 编辑标准
iSarBussionessStandService.updateSarBussionessStand(sarBussionessStand);
// 编辑相关流程
// sarBussStandAttrInfoService.updateStandInfo(sarBussionessStand.getId(),"XGLC",relatePro);
// String content = "新增一条相关流程:" +standName;
// sarUpdLogEOService.createBaseProcessLog(sarBussionessStand.getId(),"BUSINESS",content,standName);
}else if (lawsList != null && !lawsList.isEmpty()) {//Id不存在，但是标准号存在的情况
String standId = lawsList.get(0).getId();
bussId = lawsList.get(0).getId();
@@ -2466,57 +2407,26 @@ public class SarBussionessStandServiceImpl extends ServiceImpl<SarBussionessStan
resData = JSON.toJSONString(attInfoMap, SerializerFeature.WriteMapNullValue);
sarBussionessStand.setSarStandAttrEOStr(resData);
}
// 查询原相关流程
// String relatePro = sarBussStandAttrInfoService.selectFieldValByStandId("XGLC",standId);
// if (StringUtils.isNotBlank(relatePro)) {
// String[] processSplit = relatePro.split(",");
// Set<String> processSet = new HashSet<>();
// for(String sData:processSplit){
// processSet.add(sData);
// }
// //processSet.add(prcNum);
// relatePro = StringUtils.join(processSet.toArray(), ",");
// }// else {
// relatePro = prcNum;
// }
// 编辑标准
sarBussionessStand.setId(standId);
iSarBussionessStandService.updateSarBussionessStand(sarBussionessStand);
// 编辑相关流程
// sarBussStandAttrInfoService.updateStandInfo(standId,"XGLC",relatePro);
// String content = "新增一条相关流程:" +standName;
// sarUpdLogEOService.createBaseProcessLog(standId,"BUSINESS",content,standName);
} else {//标准号、ID都不存在的情况
// 新增方法
sarBussionessStand.setStandCode(standCode);
// sarBussionessStand.setStandNumber("");
// sarBussionessStand.setStandSn("");
// sarBussionessStand.setReviseStatus("");
ResponseMessage<SarBussionessStand> responseMessage = iSarBussionessStandService.createSarBussionessStand(sarBussionessStand);
if(responseMessage.isOk()){
SarBussionessStand bussionessStand = responseMessage.getData();
bussId = bussionessStand.getId() == null ? "":bussionessStand.getId();
}
// 编辑相关流程
//sarBussStandAttrInfoService.updateStandInfo(sarBussionessStand.getId(),"XGLC",standName);
}
List<SarStandItems> allItems = new ArrayList<>();
//开始处理条款数据，从去重后的结果中直接处理即可
// if(itemData!=null && !itemData.isEmpty()){
// // allItems =
// saveStandItemsData(itemData, sarStandardsInfoEO);
// }
//技术评估结果入库 重构技术评估结果入库内容
// if ("0".equals(isJudge)) {
// saveCompStatusInfo(sarStandardsInfoEO,breakVal,allItems,prcNum);
// }
// List<BusProcessEvaluationHis> evaluationHisFilter = workFlowFeignClient.evaluationHisList(pid);
List<BusProcessEvaluationHis> evaluationHis = new ArrayList<>();
Map<String, List<BusProcessEvaluationHis>> listMap = new TreeMap<>();
// 按 相同数据分组
// listMap = evaluationHisFilter.stream().collect(
// Collectors.groupingBy(a -> Utils.format("{0}#{1}#{2}", a.getPId(),a.getTaskInfo(),a.getUserId())));
List<QualityEvaluation> evaluations = new ArrayList<>();
if(!listMap.isEmpty()){
SimpleDateFormat sdf=new SimpleDateFormat("yyy-MM-dd HH:mm:ss");
@@ -2612,8 +2522,8 @@ public class SarBussionessStandServiceImpl extends ServiceImpl<SarBussionessStan
//查询字典表,形成Hash映射提升速度
List<DicTypeEO> dicInfo = dicTypeEODao.getDicInfo("dic_type_code", "dic_type_name");
Map<String, String> dicMap = dicInfo.stream()
.filter(item-> !item.getDicTypeCode().isEmpty())
.collect(Collectors.toMap(DicTypeEO::getDicTypeCode,DicTypeEO::getDicTypeName,(value1, value2 )->value2));
.filter(item-> !item.getDicTypeName().isEmpty())
.collect(Collectors.toMap(DicTypeEO::getDicTypeName,DicTypeEO::getDicTypeCode,(value1, value2 )->value2));
for(SarBussStandAttrInfoExecl row : sarlist){
attrInfoDetailsImport(row);