package com.doumee.service.business.impl;

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.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * 附件上传进度表Service实现
 * @author 江蹄蹄
 * @date 2023/09/19 17:30
 */
@Service
@Slf4j
public class FileRecordServiceImpl implements FileRecordService {

    @Autowired
    private FileRecordMapper fileRecordMapper;
    @Autowired
    @Lazy
    private BaseDataService baseDataService;

    @Override
    @Async
    public Integer create(FileRecord fileRecord) {
        fileRecordMapper.insert(fileRecord);
        return fileRecord.getId();
    }
    @Override
    @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;
        }
        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("上传成功");
            }catch (Exception e){
                model.setStatus(Constants.TWO);
                model.setContent(e.getMessage());
            }
            model.setEditDate(date);
            fileRecordMapper.updateById(model);
        }

        return  0;
    }

    @Override
    public void deleteById(Integer id) {
        fileRecordMapper.deleteById(id);
    }

    @Override
    public void delete(FileRecord fileRecord) {
        UpdateWrapper<FileRecord> deleteWrapper = new UpdateWrapper<>(fileRecord);
        fileRecordMapper.delete(deleteWrapper);
    }

    @Override
    public void deleteByIdInBatch(List<Integer> ids) {
        if (CollectionUtils.isEmpty(ids)) {
            return;
        }
        fileRecordMapper.deleteBatchIds(ids);
    }

    @Override
    public void updateById(FileRecord fileRecord) {
        fileRecordMapper.updateById(fileRecord);
    }

    @Override
    public void updateByIdInBatch(List<FileRecord> fileRecords) {
        if (CollectionUtils.isEmpty(fileRecords)) {
            return;
        }
        for (FileRecord fileRecord: fileRecords) {
            this.updateById(fileRecord);
        }
    }

    @Override
    public FileRecord findById(Integer id) {
        return fileRecordMapper.selectById(id);
    }

    @Override
    public FileRecord findOne(FileRecord fileRecord) {
        QueryWrapper<FileRecord> wrapper = new QueryWrapper<>(fileRecord);
        return fileRecordMapper.selectOne(wrapper);
    }

    @Override
    public List<FileRecord> findList(FileRecord fileRecord) {
        QueryWrapper<FileRecord> wrapper = new QueryWrapper<>(fileRecord);
        return fileRecordMapper.selectList(wrapper);
    }
  
    @Override
    public PageData<FileRecord> findPage(PageWrap<FileRecord> pageWrap) {
        IPage<FileRecord> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
        QueryWrapper<FileRecord> queryWrapper = new QueryWrapper<>();
        Utils.MP.blankToNull(pageWrap.getModel());
        if (pageWrap.getModel().getId() != null) {
            queryWrapper.lambda().eq(FileRecord::getId, pageWrap.getModel().getId());
        }
        if (pageWrap.getModel().getCreator() != null) {
            queryWrapper.lambda().eq(FileRecord::getCreator, pageWrap.getModel().getCreator());
        }
        if (pageWrap.getModel().getCreateDate() != null) {
            queryWrapper.lambda().ge(FileRecord::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate()));
            queryWrapper.lambda().le(FileRecord::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate()));
        }
        if (pageWrap.getModel().getEditor() != null) {
            queryWrapper.lambda().eq(FileRecord::getEditor, pageWrap.getModel().getEditor());
        }
        if (pageWrap.getModel().getEditDate() != null) {
            queryWrapper.lambda().ge(FileRecord::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate()));
            queryWrapper.lambda().le(FileRecord::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate()));
        }
        if (pageWrap.getModel().getIsdeleted() != null) {
            queryWrapper.lambda().eq(FileRecord::getIsdeleted, pageWrap.getModel().getIsdeleted());
        }
        if (pageWrap.getModel().getName() != null) {
            queryWrapper.lambda().like(FileRecord::getName, pageWrap.getModel().getName());
        }
        if (pageWrap.getModel().getInfo() != null) {
            queryWrapper.lambda().eq(FileRecord::getInfo, pageWrap.getModel().getInfo());
        }
        if (pageWrap.getModel().getObjId() != null) {
            queryWrapper.lambda().eq(FileRecord::getObjId, pageWrap.getModel().getObjId());
        }
        if (pageWrap.getModel().getType() != null) {
            queryWrapper.lambda().eq(FileRecord::getType, pageWrap.getModel().getType());
        }
        if (pageWrap.getModel().getFolder() != null) {
            queryWrapper.lambda().like(FileRecord::getFolder, pageWrap.getModel().getFolder());
        }
        if (pageWrap.getModel().getStatus() != null) {
            queryWrapper.lambda().eq(FileRecord::getStatus, pageWrap.getModel().getStatus());
        }
        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));
    }

    @Override
    public long count(FileRecord fileRecord) {
        QueryWrapper<FileRecord> wrapper = new QueryWrapper<>(fileRecord);
        return fileRecordMapper.selectCount(wrapper);
    }
}