修改

jiangping

2023-09-19 0b9c144b5110a7e2a85b2e5581ef304bb81a3ebc

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

@@ -2,20 +2,26 @@

import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.utils.Constants;
import com.doumee.core.utils.Utils;
import com.doumee.core.utils.aliyun.ALiYunUtil;
import com.doumee.dao.business.FileRecordMapper;
import com.doumee.dao.business.model.FileRecord;
import com.doumee.dao.business.model.dto.OssModel;
import com.doumee.service.business.BaseDataService;
import com.doumee.service.business.FileRecordService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;

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

/**
@@ -24,6 +30,7 @@
 * @date 2023/09/19 17:30
 */
@Service
@Slf4j
public class FileRecordServiceImpl implements FileRecordService {

    @Autowired
@@ -33,12 +40,38 @@
    private BaseDataService baseDataService;

    @Override
    @Async
    public Integer create(FileRecord fileRecord) {
        fileRecordMapper.insert(fileRecord);
        return fileRecord.getId();
    }
    @Override
    public Integer dealOploadEvent() {
    @Async
    public synchronized  Integer dealOploadEvent() {
        log.info("开始上传附件信息=================start==================");
        OssModel ossModel = baseDataService.initOssModel();
        FileRecord fileRecord = new FileRecord();
        fileRecord.setStatus(Constants.ZERO);
        fileRecord.setIsdeleted(Constants.ZERO);
        List<FileRecord> allLis = findList(fileRecord);
        if(allLis==null || allLis.size() ==0){
            log.info("开始上传附件信息=================end========无待处理数据===========");
            return 0;
        }
        Date date = new Date();
        for(FileRecord model:allLis){
            try {
                ALiYunUtil obs = new ALiYunUtil(ossModel.getEndpoint(), ossModel.getAccessId(), ossModel.getAccessKey());
                obs.uploadOnlineObject(model.getUrl(),ossModel.getBucket(), model.getKeyval(),null);
                model.setStatus(Constants.ONE);
                model.setContent("上传成功");
            }catch (Exception e){
                model.setStatus(Constants.TWO);
                model.setContent(e.getMessage());
            }
            model.setEditDate(date);
            fileRecordMapper.updateById(model);
        }
        return  0;
    }