合并,解决冲突

This commit is contained in:
s2042968 2025-03-05 10:27:37 +08:00
commit 080d369e42
10 changed files with 121 additions and 7 deletions

View File

@ -0,0 +1,25 @@
package com.electromagnetic.industry.software.manage.controller;
import com.electromagnetic.industry.software.common.annotations.UserOperation;
import com.electromagnetic.industry.software.common.enums.UserOperationModuleEnum;
import com.electromagnetic.industry.software.common.resp.ElectromagneticResult;
import com.electromagnetic.industry.software.manage.service.FileBackLogService;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
@RestController
@RequestMapping("/data/ed/backup/")
public class FileBackupLogController {
@Resource
private FileBackLogService fileBackLogService;
@RequestMapping(value = "list")
@UserOperation(value="查询了备份日志", modelName = UserOperationModuleEnum.BACKUP_FILE)
public ElectromagneticResult<?> list(@RequestParam int pageNum, @RequestParam int pageSize) {
return fileBackLogService.query(pageNum, pageSize);
}
}

View File

@ -4,7 +4,6 @@ import com.electromagnetic.industry.software.common.annotations.UserOperation;
import com.electromagnetic.industry.software.common.enums.UserOperationModuleEnum; import com.electromagnetic.industry.software.common.enums.UserOperationModuleEnum;
import com.electromagnetic.industry.software.common.resp.ElectromagneticResult; import com.electromagnetic.industry.software.common.resp.ElectromagneticResult;
import com.electromagnetic.industry.software.common.util.ElectromagneticResultUtil; import com.electromagnetic.industry.software.common.util.ElectromagneticResultUtil;
import com.electromagnetic.industry.software.manage.pojo.models.FileFormat;
import com.electromagnetic.industry.software.manage.service.serviceimpl.FileFormatService; import com.electromagnetic.industry.software.manage.service.serviceimpl.FileFormatService;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;

View File

@ -0,0 +1,22 @@
package com.electromagnetic.industry.software.manage.pojo.resp;
import lombok.Data;
import java.util.Date;
@Data
public class FileBackLogVO {
private String id;
private String fileId;
private String fileCode;
private String fileName;
private Date backStartTime;
private Date backEndTime;
}

View File

@ -0,0 +1,9 @@
package com.electromagnetic.industry.software.manage.service;
import com.electromagnetic.industry.software.common.resp.ElectromagneticResult;
public interface FileBackLogService {
ElectromagneticResult<?> query(Integer pageNumber, Integer pageSize);
}

View File

@ -122,8 +122,8 @@ public class CommonService {
} }
public String createFileCode(String parentId, String fileType, int version, String timeStr) { public String createFileCode(String parentId, String fileType, int version, String timeStr) {
FileFormat fileFormat = fileFormatService.getBaseMapper().selectOne(Wrappers.lambdaQuery(FileFormat.class).eq(FileFormat::getSuffixNo, fileType)); FileFormat fileFormat = fileFormatService.getBaseMapper().selectOne(Wrappers.lambdaQuery(FileFormat.class).eq(FileFormat::getSuffixName, fileType));
Assert.notNull(fileFormat, "不支持当前格式 {}"); Assert.notNull(fileFormat, "不支持当前格式 {}", fileType);
return parentId + fileFormat.getSuffixNo() + version + timeStr; return parentId + fileFormat.getSuffixNo() + version + timeStr;
} }

View File

@ -446,11 +446,11 @@ public class EdFileInfoServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileI
String info = FileUtil.readString(prjDirPath + File.separator + "mysql.info", Charset.defaultCharset()); String info = FileUtil.readString(prjDirPath + File.separator + "mysql.info", Charset.defaultCharset());
List<EdFileInfo> importAllFiles = JSONUtil.toList(info, EdFileInfo.class); List<EdFileInfo> importAllFiles = JSONUtil.toList(info, EdFileInfo.class);
// 找出层级文件夹 // 找出层级文件夹
List<EdFileInfo> prjFolders = importAllFiles.stream().filter(e -> ObjUtil.equals(e.getDataOwn(), dataOwnCode)) List<EdFileInfo> prjFolders = importAllFiles.stream().filter(e -> DataOwnEnum.isPrjCode(e.getDataOwn()))
.collect(Collectors.toList()); .collect(Collectors.toList());
// 找出用户创建的文件夹 // 找出用户创建的文件夹
List<EdFileInfo> userFolders = importAllFiles.stream().filter(e -> ObjUtil.equals(e.getDataType(), EleDataTypeEnum.FOLDER.code)) List<EdFileInfo> userFolders = importAllFiles.stream().filter(e -> ObjUtil.equals(e.getDataType(), EleDataTypeEnum.FOLDER.code))
.filter(e -> ObjUtil.equals(e.getDataOwn(), dataOwnCode)) .filter(e -> DataOwnEnum.isFileCode(e.getDataOwn()))
.collect(Collectors.toList()); .collect(Collectors.toList());
// 找出所有文件 // 找出所有文件
List<EdFileInfo> allFiles = importAllFiles.stream().filter(e -> ObjUtil.equals(e.getDataType(), EleDataTypeEnum.FILE.code)).collect(Collectors.toList()); List<EdFileInfo> allFiles = importAllFiles.stream().filter(e -> ObjUtil.equals(e.getDataType(), EleDataTypeEnum.FILE.code)).collect(Collectors.toList());
@ -803,6 +803,8 @@ public class EdFileInfoServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileI
.setDataStatus(PublishEnum.PUBLISHED.getCode()) .setDataStatus(PublishEnum.PUBLISHED.getCode())
.setEffectFlag(EffectFlagEnum.NOT_EFFECTIVE.code) .setEffectFlag(EffectFlagEnum.NOT_EFFECTIVE.code)
.setSaveStatus(EleDataSaveStatusEnum.FAIL.code) .setSaveStatus(EleDataSaveStatusEnum.FAIL.code)
.setFileVersion(0)
.setFileCode("")
.setDataOwn(dataOwnCode); .setDataOwn(dataOwnCode);
this.saveOrUpdate(newEdFileInfo); this.saveOrUpdate(newEdFileInfo);
log.error(info, e); log.error(info, e);

View File

@ -0,0 +1,46 @@
package com.electromagnetic.industry.software.manage.service.serviceimpl;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateUtil;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.electromagnetic.industry.software.common.enums.FileBackupSource;
import com.electromagnetic.industry.software.common.resp.ElectromagneticResult;
import com.electromagnetic.industry.software.common.util.ElectromagneticResultUtil;
import com.electromagnetic.industry.software.manage.mapper.FileBackupLogMapper;
import com.electromagnetic.industry.software.manage.pojo.resp.FileBackLogVO;
import com.electromagnetic.industry.software.manage.pojo.resp.RespPageVO;
import com.electromagnetic.industry.software.manage.service.FileBackLogService;
import com.electromagnetic.industry.software.manage.pojo.models.FileBackupLog;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.List;
@Service
public class FileBackLogServiceImpl extends ServiceImpl<FileBackupLogMapper, FileBackupLog> implements FileBackLogService {
@Override
public ElectromagneticResult<?> query(Integer pageNumber, Integer pageSize) {
Page<FileBackupLog> fileBackupLogPage = this.baseMapper.selectPage(new Page<>(pageNumber, pageSize), Wrappers.<FileBackupLog>lambdaQuery().eq(FileBackupLog::getSource, FileBackupSource.SYS_BACKUP.code));
List<FileBackupLog> records = fileBackupLogPage.getRecords();
if (CollUtil.isEmpty(records)) {
return ElectromagneticResultUtil.success(new RespPageVO<>(0L, records));
}
long total = fileBackupLogPage.getTotal();
List<FileBackLogVO> list = new ArrayList<>();
for (FileBackupLog fileBackupLog : records) {
FileBackLogVO fileBackLogVO = BeanUtil.copyProperties(fileBackupLog, FileBackLogVO.class);
fileBackLogVO.setBackStartTime(DateUtil.date(fileBackupLog.getStartTime()));
fileBackLogVO.setBackEndTime(DateUtil.date(fileBackupLog.getEndTime()));
list.add(fileBackLogVO);
}
return ElectromagneticResultUtil.success(new RespPageVO<>(total, list));
}
}

View File

@ -8,7 +8,6 @@ import cn.hutool.core.text.StrFormatter;
import cn.hutool.http.HttpUtil; import cn.hutool.http.HttpUtil;
import cn.hutool.json.JSONUtil; import cn.hutool.json.JSONUtil;
import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.electromagnetic.industry.software.common.enums.EleDataTypeEnum; import com.electromagnetic.industry.software.common.enums.EleDataTypeEnum;
import com.electromagnetic.industry.software.common.enums.FileBackupSource; import com.electromagnetic.industry.software.common.enums.FileBackupSource;
import com.electromagnetic.industry.software.common.enums.UserOperationModuleEnum; import com.electromagnetic.industry.software.common.enums.UserOperationModuleEnum;
@ -36,7 +35,7 @@ import java.util.Map;
import java.util.stream.Collectors; import java.util.stream.Collectors;
@Component @Component
public class BackupTask extends ServiceImpl<FileBackupLogMapper, FileBackupLog> { public class BackupTask {
@Resource @Resource
private ElePropertyConfig elePropertyConfig; private ElePropertyConfig elePropertyConfig;

View File

@ -15,4 +15,14 @@ public enum DataOwnEnum {
public int code; public int code;
public String desc; public String desc;
public static boolean isPrjCode(int code) {
return code == SYS_PRJ.code || code == USER_PRJ.code || code == REPO_PRJ.code;
}
public static boolean isFileCode(int code) {
return code == SYS_FILE.code || code == USER_FILE.code || code == REPO_FILE.code;
}
} }

View File

@ -15,8 +15,10 @@ public enum UserOperationModuleEnum {
TAG("tag","标签管理"), TAG("tag","标签管理"),
LOG("log", "操作记录审计"), LOG("log", "操作记录审计"),
TMP("tmp", "临时文件"), TMP("tmp", "临时文件"),
BACKUP_FILE("backupFile", "系统文件备份"),
PERMISSION("permission", "权限管理"); PERMISSION("permission", "权限管理");
public final String key; public final String key;
public final String desc; public final String desc;