企业端

Mr.Shi

2023-09-21 c153cd01974defe0d20ecbbb2c1f2fdc522d05f8

 server/service/src/main/java/com/doumee/service/business/impl/FileRecordServiceImpl.java

@@ -21,6 +21,7 @@
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

@@ -58,10 +59,21 @@
            log.info("开始上传附件信息=================end========无待处理数据===========");
            return 0;
        }
        List<String > keyList = new ArrayList<>();
        for(FileRecord model:allLis){
                keyList.add(model.getKeyval());
        }
        try {
            ALiYunUtil obs = new ALiYunUtil(ossModel.getEndpoint(), ossModel.getAccessId(), ossModel.getAccessKey());
            obs.deleteObjects(ossModel.getBucket(),keyList);
        }catch (Exception e){
        }

        Date date = new Date();
        for(FileRecord model:allLis){
            try {
                ALiYunUtil obs = new ALiYunUtil(ossModel.getEndpoint(), ossModel.getAccessId(), ossModel.getAccessKey());
                obs.deleteObjects(ossModel.getBucket(),keyList);
                obs.uploadOnlineObject(model.getUrl(),ossModel.getBucket(), model.getKeyval(),null);
                model.setStatus(Constants.ONE);
                model.setContent("上传成功");
@@ -72,6 +84,7 @@
            model.setEditDate(date);
            fileRecordMapper.updateById(model);
        }

        return  0;
    }

@@ -152,7 +165,7 @@
            queryWrapper.lambda().eq(FileRecord::getIsdeleted, pageWrap.getModel().getIsdeleted());
        }
        if (pageWrap.getModel().getName() != null) {
            queryWrapper.lambda().eq(FileRecord::getName, pageWrap.getModel().getName());
            queryWrapper.lambda().like(FileRecord::getName, pageWrap.getModel().getName());
        }
        if (pageWrap.getModel().getInfo() != null) {
            queryWrapper.lambda().eq(FileRecord::getInfo, pageWrap.getModel().getInfo());
@@ -164,18 +177,25 @@
            queryWrapper.lambda().eq(FileRecord::getType, pageWrap.getModel().getType());
        }
        if (pageWrap.getModel().getFolder() != null) {
            queryWrapper.lambda().eq(FileRecord::getFolder, pageWrap.getModel().getFolder());
            queryWrapper.lambda().like(FileRecord::getFolder, pageWrap.getModel().getFolder());
        }
        if (pageWrap.getModel().getStatus() != null) {
            queryWrapper.lambda().eq(FileRecord::getStatus, pageWrap.getModel().getStatus());
        }
        for(PageWrap.SortData sortData: pageWrap.getSorts()) {
        if (pageWrap.getModel().getKeyval() != null) {
            queryWrapper.lambda().like(FileRecord::getKeyval, pageWrap.getModel().getKeyval());
        }
        if (pageWrap.getModel().getUrl() != null) {
            queryWrapper.lambda().like(FileRecord::getUrl, pageWrap.getModel().getUrl());
        }
  /*      for(PageWrap.SortData sortData: pageWrap.getSorts()) {
            if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
                queryWrapper.orderByDesc(sortData.getProperty());
            } else {
                queryWrapper.orderByAsc(sortData.getProperty());
            }
        }
        }*/
        queryWrapper.lambda().orderByAsc(FileRecord::getStatus);
        return PageData.from(fileRecordMapper.selectPage(page, queryWrapper));
    }