chenxudong
/
electromagnetic-data-new
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

调通了导入prd上的各个功能。

This commit is contained in:
chenxudong 2025-04-15 11:05:28 +08:00
parent efb9d4f055
commit 67fb0f2b39
1 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
electrmangnetic/src/main/java/com/electromagnetic/industry/software/manage/service/serviceimpl/EdFileInfoServiceImpl.java
View File

@ -556,7 +556,7 @@ public class EdFileInfoServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileI
List<EdFileInfo> deepCopyImport = JSONUtil.toList(JSONUtil.toJsonStr(importFiles), EdFileInfo.class); List<EdFileInfo> deepCopyImport = JSONUtil.toList(JSONUtil.toJsonStr(importFiles), EdFileInfo.class);
List<EdFileInfo> deepCopyDb = JSONUtil.toList(JSONUtil.toJsonStr(dbFileInfos), EdFileInfo.class); List<EdFileInfo> deepCopyDb = JSONUtil.toList(JSONUtil.toJsonStr(dbFileInfos), EdFileInfo.class);
// 导入的文件在线下已经被废除了 // 导入的文件在线下已经被废除了，不同步到线上
Optional<EdFileInfo> first = deepCopyImport.stream().filter(e -> e.getEffectFlag().equals(EffectFlagEnum.EFFECT.code)).findFirst(); Optional<EdFileInfo> first = deepCopyImport.stream().filter(e -> e.getEffectFlag().equals(EffectFlagEnum.EFFECT.code)).findFirst();
if (first.isEmpty()) { if (first.isEmpty()) {
continue; continue;
@ -573,8 +573,10 @@ public class EdFileInfoServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileI
} else { } else {
dbEffectFile = first1.get(); dbEffectFile = first1.get();
} }
// 如果导入的时间比数据库的时间新，则将导入的置为effect // 如果导入的时间比数据库的时间新，则将导入的置为effect
String effectId; String effectId;
// 如果数据库中的有效文件为null，则使用导入的
if (ObjUtil.isNull(dbEffectFile)) { if (ObjUtil.isNull(dbEffectFile)) {
effectId = importEffectFile.getId(); effectId = importEffectFile.getId();
} else { } else {
@ -582,11 +584,12 @@ public class EdFileInfoServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileI
} }
Map<String, String> importVersionRelation = getVersionRelation(deepCopyImport); Map<String, String> importVersionRelation = getVersionRelation(deepCopyImport);
Map<String, String> dbVersionRelation = getVersionRelation(deepCopyDb); Map<String, String> dbVersionRelation = getVersionRelation(deepCopyDb);
dbVersionRelation.putAll(importVersionRelation); dbVersionRelation.putAll(importVersionRelation);
//************************** //**************************
int start = FILE_START_VERSION; int start = FILE_START_VERSION;
List<EdFileInfo> saveObjs = new ArrayList<>(); List<EdFileInfo> saveObjs = new ArrayList<>();
importFiles = importFiles.stream().distinct().toList();
for (EdFileInfo importFileInfo : importFiles) { for (EdFileInfo importFileInfo : importFiles) {
// 该文件在数据库中存在，是从线上导出的。 // 该文件在数据库中存在，是从线上导出的。
if (dbIdMap.containsKey(importFileInfo.getId())) { if (dbIdMap.containsKey(importFileInfo.getId())) {
@ -594,14 +597,17 @@ public class EdFileInfoServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileI
// 线下版本的修改时间比线上的新，用线下的版本 // 线下版本的修改时间比线上的新，用线下的版本
if (dbFileInfo.getUpdatedTime().before(importFileInfo.getUpdatedTime())) { if (dbFileInfo.getUpdatedTime().before(importFileInfo.getUpdatedTime())) {
importFileInfo.setFileVersion(start); importFileInfo.setFileVersion(start);
saveObjs.add(importFileInfo); saveObjs.add(importFileInfo);
dbIdMap.remove(importFileInfo.getId()); dbIdMap.remove(importFileInfo.getId());
} else { // 线上版本的修改时间比线下新，用线上的版本。 // 线上版本的修改时间比线下新，用线上的版本。
} else {
dbFileInfo.setFileVersion(start); dbFileInfo.setFileVersion(start);
saveObjs.add(dbFileInfo); saveObjs.add(dbFileInfo);
dbIdMap.remove(dbFileInfo.getId()); dbIdMap.remove(dbFileInfo.getId());
} }
} else { // 该文件是线下上传的。 // 该文件是线下上传的。
} else {
importFileInfo.setFileVersion(start); importFileInfo.setFileVersion(start);
saveObjs.add(importFileInfo); saveObjs.add(importFileInfo);
dbIdMap.remove(importFileInfo.getId()); dbIdMap.remove(importFileInfo.getId());
@ -610,8 +616,9 @@ public class EdFileInfoServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileI
} }
// 添加数据库中剩余的 // 添加数据库中剩余的
for (EdFileInfo edFileInfo : dbIdMap.values()) { for (EdFileInfo edFileInfo : dbIdMap.values()) {
edFileInfo.setFileVersion(++start); edFileInfo.setFileVersion(start);
saveObjs.add(edFileInfo); saveObjs.add(edFileInfo);
++start;
} }
//************************* //*************************
for (EdFileInfo saveObj : saveObjs) { for (EdFileInfo saveObj : saveObjs) {