package jnpf.service.impl;

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 jnpf.base.ActionResult;
import jnpf.base.vo.PaginationVO;
import jnpf.constant.MsgCode;
import jnpf.entity.FileEntity;
import jnpf.mapper.FileMapper;
import jnpf.model.YozoFileParams;
import jnpf.model.YozoParams;
import jnpf.service.YozoService;
import jnpf.utils.SplicingUrlUtil;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;

import java.io.UnsupportedEncodingException;
import java.net.URLDecoder;
import java.util.List;

/**
 * @author JNPF
 */
@Service
@RequiredArgsConstructor
public class YozoServiceImpl implements YozoService {

    
    private final FileMapper fileMapper;

    public static final String F_FILE_VERSION = "F_FileVersion";

    @Override
    public String getPreviewUrl(YozoFileParams params) {
        return SplicingUrlUtil.getPreviewUrl(params);
    }

    @Override
    public ActionResult<Object>saveFileId(String fileVersionId, String fileId, String fileName) {

        FileEntity fileEntity =new FileEntity();
        fileEntity.setId(fileId);
        fileEntity.setFileName(fileName);
        fileEntity.setFileVersionId(fileVersionId);
        fileEntity.setType("create");

        fileMapper.insert(fileEntity);

        return ActionResult.success(MsgCode.SU001.get());
    }

    @Override
    public FileEntity selectByName(String fileNa) {
        QueryWrapper<FileEntity> wrapper =new QueryWrapper<>();
        wrapper.eq("F_FileName",fileNa);
        return fileMapper.selectOne(wrapper);
    }

    @Override
    public ActionResult<Object>saveFileIdByHttp(String fileVersionId, String fileId, String fileUrl) {
        String fileName = "";
        String url="";
        String name="";
        try {
             url = URLDecoder.decode(fileUrl, "UTF-8");
             if (url.contains("/")){
                 fileName = url.substring(url.lastIndexOf("/") + 1);
             }else {
                 fileName = url.substring(url.lastIndexOf("\\") + 1);
             }
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        }
        //同一url文件数
        QueryWrapper<FileEntity> wrapper =new QueryWrapper<>();
        wrapper.eq("F_Url",url);
        Integer total = 0;
        if (total==0){
            name=fileName;
        }else{
            String t =total.toString();
            name= fileName+"(" + t +")";
        }
        FileEntity fileEntity =new FileEntity();
        fileEntity.setType(url.contains("http") ? "http" : "local");
        fileEntity.setFileVersionId(fileVersionId );
        fileEntity.setId(fileId);
        fileEntity.setFileName(name);
        fileEntity.setUrl(url);
        fileMapper.insert(fileEntity);
        return ActionResult.success(MsgCode.SU001.get());
    }

    @Override
    public ActionResult<Object>deleteFileByVersionId(String versionId) {
        QueryWrapper<FileEntity> wrapper = new QueryWrapper<>();
        wrapper.eq(F_FILE_VERSION,versionId);
        int i = fileMapper.delete(wrapper);
        if (i==1){
            return ActionResult.success(MsgCode.SU003.get());
        }
            return ActionResult.fail(MsgCode.FA003.get());
    }

    @Override
    public FileEntity selectByVersionId(String fileVersionId) {
        QueryWrapper<FileEntity> wrapper = new QueryWrapper<>();
        wrapper.eq(F_FILE_VERSION,fileVersionId);
        return fileMapper.selectOne(wrapper);
    }

    @Override
    public ActionResult<Object>deleteBatch(String[] versions) {
        for (String version : versions){
            QueryWrapper<FileEntity> wrapper = new QueryWrapper<>();
            wrapper.eq(F_FILE_VERSION,version);
            int i = fileMapper.delete(wrapper);
            if (i==0){
                return ActionResult.fail(MsgCode.FA045.get(version));
            }
        }
        return ActionResult.success(MsgCode.SU003.get());

    }

    @Override
    public void editFileVersion(String oldFileId, String newFileId) {
        UpdateWrapper<FileEntity> wrapper = new UpdateWrapper<>();
        wrapper.eq(F_FILE_VERSION,oldFileId);
        FileEntity fileEntity =new FileEntity();
        fileEntity.setFileVersionId(newFileId);
        fileEntity.setOldFileVersionId(oldFileId);
        fileMapper.update(fileEntity,wrapper);
    }

    @Override
    public List<FileEntity> getAllList(PaginationVO pageModel) {
        Page<FileEntity> page = new Page<>(pageModel.getCurrentPage(), pageModel.getPageSize());
        IPage<FileEntity> iPage = fileMapper.selectPage(page,null);
        return iPage.getRecords();
    }


}