package com.ibeetl.admin.core.file;

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

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.context.ApplicationContext;

import com.ibeetl.admin.core.dao.CoreFileDao;
import com.ibeetl.admin.core.entity.CoreFile;
import com.ibeetl.admin.core.util.DateUtil;
import com.ibeetl.admin.core.util.PlatformException;
import com.ibeetl.admin.core.util.UUIDUtil;
/**
 * 一个本地文件系统，管理临时文件和用户文件
 *
 * @author xiandafu
 */
public class LocalFileService implements FileService {
  Log log = LogFactory.getLog(this.getClass());
  DBIndexHelper dbHelper = null;
  String root = null;

  public LocalFileService(ApplicationContext ctx, String root) {
    this.root = root;
    new File(root, "temp").mkdir();
    dbHelper = new DBIndexHelper(ctx.getBean(CoreFileDao.class));
  }

  @Override
  public FileItem loadFileItemByPath(String path) {
    CoreFile coreFile = dbHelper.getFileItemByPath(path);
    if (coreFile != null) {
      return getFileItem(coreFile);
    }
    LocalFileItem item = new LocalFileItem(root);
    item.setPath(path);
    item.setName(parseTempFileName(path));
    item.setTemp(true);
    return item;
  }

  @Override
  public FileItem createFileTemp(String name) {
    FileItem item = new LocalFileItem(root);
    String fileName = "temp" + File.separator + name + "." + this.suffix();
    item.setPath(fileName);
    item.setName(name);
    item.setTemp(true);
    return item;
  }

  @Override
  public FileItem createFileItem(
      String name,
      String bizType,
      String bizId,
      Long userId,
      Long orgId,
      String fileBatchId,
      List<FileTag> tags) {
    CoreFile coreFile = new CoreFile();
    coreFile.setBizId(bizId);
    coreFile.setBizType(bizType);
    coreFile.setUserId(userId);
    coreFile.setOrgId(orgId);
    coreFile.setName(name);
    coreFile.setCreateTime(new Date());
    coreFile.setFileBatchId(fileBatchId);
    String dir = DateUtil.now("yyyyMMdd");
    File dirFile = new File(root + File.separator + dir);
    if (!dirFile.exists()) {
      dirFile.mkdirs();
    }
    String fileName = name + "." + UUIDUtil.uuid();
    String path = dir + File.separator + fileName;
    coreFile.setPath(path);
    // 目前忽略tags
    dbHelper.createFileItem(coreFile, tags);
    return this.getFileItem(coreFile);
  }

  private String suffix() {
    // TODO,改成唯一算法
    return DateUtil.now("yyyyMMddhhmm") + "-" + UUIDUtil.uuid();
  }

  private String parseTempFileName(String path) {
    File file = new File(path);
    String name = file.getName();
    // 去掉最后的临时标记
    int index = name.lastIndexOf(".");
    return name.substring(0, index);
  }

  protected FileItem getFileItem(CoreFile file) {
    LocalFileItem item = new LocalFileItem(root);
    item.setName(file.getName());
    item.setPath(file.getPath());
    item.setBizId(file.getBizId());
    item.setBizType(file.getBizType());
    item.setId(file.getId());
    item.setOrgId(file.getOrgId());
    item.setId(file.getId());
    return item;
  }

  protected List<FileItem> getFileItem(List<CoreFile> files) {
    List<FileItem> items = new ArrayList<>(files.size());
    for (CoreFile file : files) {
      items.add(this.getFileItem(file));
    }
    return items;
  }

  @Override
  public FileItem getFileItemById(Long id) {
    return this.getFileItem(dbHelper.getFileItemById(id));
  }

  @Override
  public List<FileItem> queryByUserId(Long userId, List<FileTag> tags) {
    return this.getFileItem(dbHelper.queryByUserId(userId, tags));
  }

  @Override
  public List<FileItem> queryByBiz(String bizType, String bizId) {
    return this.getFileItem(dbHelper.queryByBiz(bizType, bizId));
  }

  @Override
  public List<FileItem> queryByBatchId(String fileBatchId) {
    return this.getFileItem(dbHelper.queryByBatchId(fileBatchId));
  }

  @Override
  public void removeFile(Long id, String fileBatchId) {
    CoreFile file = dbHelper.getFileItemById(id);
    if (!file.getFileBatchId().equals(fileBatchId)) {
      return;
    }

    FileItem item = this.getFileItem(file);
    boolean success = item.delete();
    if (!success) {
      log.warn("删除文件失败 " + file.getName() + ",id=" + file.getId() + " path=" + file.getPath());
      throw new PlatformException("删除文件失败 " + file.getName());
    }
    dbHelper.fileDao.deleteById(id);
    return;
  }

  @Override
  public void updateFile(String fileBatchId, String bizType, String bizId) {
    dbHelper.fileDao.updateBatchIdInfo(bizType, bizId, fileBatchId);
  }

  @Override
  public FileItem getFileItemById(Long id, String fileBatchId) {
    CoreFile file = dbHelper.getFileItemById(id);
    if (!file.getFileBatchId().equals(fileBatchId)) {
      return null;
    }
    return this.getFileItem(file);
  }
}
