package com.iplatform.file.support;

import com.iplatform.base.util.UserUtils;
import com.iplatform.file.FileStoreCallback;
import com.iplatform.file.service.FileServiceImpl;
import com.iplatform.model.po.S_file;
import com.iplatform.model.po.S_file_mapper;
import com.walker.file.DefaultFileInfo;
import com.walker.file.FileInfo;
import com.walker.file.FileStoreType;
import com.walker.infrastructure.utils.DateUtils;
import com.walker.infrastructure.utils.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;

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

/**
 * 通过数据库写入上传的文件记录。
 * @author 时克英
 * @date 2023-02-14
 * @date 2023-06-05 使用新附件表（sf_attachment），参考：{@linkplain AttachmentJdbcCallback}
 */
@Deprecated
public class JdbcCallback implements FileStoreCallback {

    protected final transient Logger logger = LoggerFactory.getLogger(getClass());

    @Override
    public void onCallback(FileInfo fileInfo, FileStoreType fileStoreType) {
        if(logger.isDebugEnabled()){
            logger.debug("保存文件:{}", fileInfo);
        }
        S_file s_file = new S_file();
        s_file.setId(Long.parseLong(fileInfo.getId()));
        s_file.setCreate_time(DateUtils.getDateTimeNumber(System.currentTimeMillis()));
        s_file.setUser_name(UserUtils.getUserInfo().getUser_name());
        s_file.setFile_name(fileInfo.getFileName());
        s_file.setFile_ext(fileInfo.getFileExt());
        s_file.setContent_type("");
        s_file.setFile_path(fileInfo.getUrl());
        s_file.setFile_size(fileInfo.getFileSize());
        s_file.setFile_store_type(fileStoreType.getIndex());
        if(StringUtils.isNotEmpty(fileInfo.getGroupId())){
            s_file.setGroup_id(fileInfo.getGroupId());
        }
        this.fileService.insert(s_file);

//        String fileExt = fileInfo.getFileExt();
//
//        SfAttachment attachment = new SfAttachment();
//        attachment.setAttId(Long.parseLong(fileInfo.getId()));
//        attachment.setCreateTime(DateUtils.getDateTimeNumber());
//        attachment.setUpdateTime(attachment.getCreateTime());
//        attachment.setUserName(UserUtils.getUserInfo().getUser_name());
//        attachment.setName(fileInfo.getFileName());
//        attachment.setSattDir(fileInfo.getUrl());
//        attachment.setAttType(fileExt);   // 这里目前是后缀名，后续可参考电商系统存放:mimeType
//        attachment.setAttSize(fileInfo.getFileSize());
//        attachment.setFileStoreType(fileStoreType.getIndex());
//        if(StringUtils.isNotEmpty(fileInfo.getGroupId())){
//            attachment.setGroupId(fileInfo.getGroupId());
//        }
//        if(ImageUtils.isImage(fileExt) || ImageUtils.isVideo(fileExt)){
//            // 暂时存放为1，表示媒体格式
//            attachment.setImageType(1);
//        } else {
//            // 非媒体格式
//            attachment.setImageType(0);
//        }
//        // pid 和 owner 需要传过来
//        attachment.setPid(0);
//        attachment.setOwner(-1);
//        this.fileService.insert(attachment);
    }

    @Override
    public FileInfo onAcquireFileInfo(String id) {
        S_file s_file = this.fileService.get(new S_file(Long.parseLong(id)));
        return toFileInfo(s_file);
    }

    @Override
    public List<FileInfo> onAcquireFileInfoList(List<String> ids) {
        if(StringUtils.isEmptyList(ids)){
            return null;
        }
        MapSqlParameterSource sqlParameterSource = new MapSqlParameterSource();
        sqlParameterSource.addValue("ids", ids);
        List<S_file> list = this.fileService.sqlListObjectWhereIn("select * from s_file where id in(:ids)"
                , S_file_mapper.ROW_MAPPER, sqlParameterSource);
        if(StringUtils.isEmptyList(list)){
            return null;
        }
        List<FileInfo> fileInfoList = new ArrayList<>(list.size());
        for(S_file s_file : list){
            fileInfoList.add(this.toFileInfo(s_file));
        }
        return fileInfoList;
    }

    private FileInfo toFileInfo(S_file s_file){
        if(s_file == null){
            return null;
        }
        DefaultFileInfo fileInfo = new DefaultFileInfo();
        fileInfo.setId(String.valueOf(s_file.getId()));
        fileInfo.setFileSize(s_file.getFile_size());
        fileInfo.setUrl(s_file.getFile_path());
        fileInfo.setFileExt(s_file.getFile_ext());
        fileInfo.setFileName(s_file.getFile_name());
        fileInfo.setFileStoreType(FileStoreType.getType(s_file.getFile_store_type()));
        fileInfo.setGroupId(s_file.getGroup_id());
        return fileInfo;
    }

    public void setFileService(FileServiceImpl fileService) {
        this.fileService = fileService;
    }

    private FileServiceImpl fileService;
}