changes

liuhaonan

2022-11-04 e55c8b0a92eb9715edd90c31dfd4de51a47b588b

 ximon-admin/src/main/java/com/sandu/ximon/admin/service/IpVolumeFileService.java

@@ -1,6 +1,7 @@
package com.sandu.ximon.admin.service;

import com.alibaba.fastjson.JSON;
import com.alipay.service.schema.util.StringUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.github.pagehelper.PageHelper;
@@ -60,31 +61,33 @@
        return save(file);
    }

    public boolean deleteFile(Long fileId) {
        IpVolumeFile byId = getById(fileId);
        String bucketName;
        if (SecurityUtils.getClientId() == null) {
            bucketName = MinIoConstant.ADMIN_BROADCAST_FILE.getBucketName();
        } else {
            bucketName = MinIoConstant.BROADCAST_FILE.getBucketName() + SecurityUtils.getUserId();
        }
        if (byId == null) {
            throw new BusinessException("找不到对应文件");
        }
        boolean b = minIoUtil.deleteFile(bucketName, byId.getFileName());
    public boolean deleteFile(List<Long> fileIds) {
        fileIds.forEach(fileId -> {
            IpVolumeFile byId = getById(fileId);
            String bucketName;
            if (SecurityUtils.getClientId() == null) {
                bucketName = MinIoConstant.ADMIN_BROADCAST_FILE.getBucketName();
            } else {
                bucketName = MinIoConstant.BROADCAST_FILE.getBucketName() + SecurityUtils.getUserId();
            }
            if (byId == null) {
                throw new BusinessException("找不到对应文件");
            }
            boolean b = minIoUtil.deleteFile(bucketName, byId.getFileName());
//        if (!b) {
//            throw new BusinessException("服务器删除失败");
//        }
        /**
         * 音柱文件删除 日志记录开始
         */
        String content = "删除文件id:" + fileId + "音柱文件名称：" + byId.getFileName() + "，文件大小：" + byId.getOriginSize() + "，文件路径：" + byId.getFileUrl();
        StoreOperationRecordsUtils.storeOperationData(null, null, "音柱文件删除", content);
        /**
         * 音柱文件删除 日志记录结束
         */
            /**
             * 音柱文件删除 日志记录开始
             */
            String content = "删除文件id:" + fileId + "音柱文件名称：" + byId.getFileName() + "，文件大小：" + byId.getOriginSize() + "，文件路径：" + byId.getFileUrl();
            StoreOperationRecordsUtils.storeOperationData(null, null, "音柱文件删除", content);
            /**
             * 音柱文件删除 日志记录结束
             */

        return removeById(fileId);
        });
        return removeByIds(fileIds);
    }

    public List<IpVolumeFile> ipVolumeFileList(BaseConditionVO baseConditionVO, String keyword, Integer order, Integer seq) {
@@ -128,13 +131,15 @@
        //排序方式
        String orderBy = orderByResult + " " + orderBySeq;

        PageHelper.startPage(baseConditionVO.getPageNo(), baseConditionVO.getPageSize(), orderBy);
        if (baseConditionVO != null) {
            PageHelper.startPage(baseConditionVO.getPageNo(), baseConditionVO.getPageSize(), orderBy);
        }
        List<IpVolumeFile> list = list(wrapper);

        return list;
    }

    public List<IpVolumeFile> listFiles() {
    public List<IpVolumeFile> listFiles(String keyword) {
        LambdaQueryWrapper<IpVolumeFile> wrapper = Wrappers.lambdaQuery(IpVolumeFile.class);

        //不是超管
@@ -144,6 +149,9 @@
                        file.eq(IpVolumeFile::getUserId, SecurityUtils.getUserId());
                    });
        }
        if (keyword != null && !StringUtil.isEmpty(keyword)) {
            wrapper.like(IpVolumeFile::getFileName, keyword);
        }
        return list(wrapper);
    }