package com.qxueyou.scc.teach.res.service.impl;

import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.util.Calendar;
import java.util.GregorianCalendar;
import java.util.Map;

import org.apache.commons.io.FileUtils;
import org.apache.commons.io.IOUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.qxueyou.scc.base.model.Result;
import com.qxueyou.scc.base.service.impl.CommonAppService;
import com.qxueyou.scc.base.util.CollectionUtils;
import com.qxueyou.scc.base.util.QFileUtils;
import com.qxueyou.scc.base.util.TraceUtils;
import com.qxueyou.scc.base.util.UUIDUtils;
import com.qxueyou.scc.config.SccConfig;
import com.qxueyou.scc.teach.res.model.ResFile;
import com.qxueyou.scc.teach.res.service.IFileService;

/**
 * 所有文件上传的操作，单独到文件上传工程后，后续业务操作需要下载文件调用的方法
 *
 * @author xiadehu
 *
 */
@Service
public class FileService extends CommonAppService implements IFileService {

	private final Logger log = LogManager.getLogger(FileService.class);

	/*
	 * 文件类型:目前支持四种
	 */
	public final static String FILE_TYPE_VIDEO = "video";

	public final static String FILE_TYPE_DOC = "doc";

	public final static String FILE_TYPE_AUDIO = "audio";

	public final static String FILE_TYPE_DATA = "data";

	public final static String FILE_TYPE_IMG = "img";

	private static final Map<String, String> fileFormatMap = CollectionUtils.newStringMap("MPEG", FILE_TYPE_VIDEO,
			"AVI", FILE_TYPE_VIDEO, "MOV", FILE_TYPE_VIDEO, "ASF", FILE_TYPE_VIDEO, "WMV", FILE_TYPE_VIDEO, "NAVI",
			FILE_TYPE_VIDEO, "3GP", FILE_TYPE_VIDEO, "RAM", FILE_TYPE_VIDEO, "RA", FILE_TYPE_VIDEO, "MKV",
			FILE_TYPE_VIDEO, "F4V", FILE_TYPE_VIDEO, "RMVB", FILE_TYPE_VIDEO, "MP4", FILE_TYPE_VIDEO,

			"DOC", FILE_TYPE_DOC, "DOCX", FILE_TYPE_DOC, "PDF", FILE_TYPE_DOC, "PPT", FILE_TYPE_DOC, "PPTX",
			FILE_TYPE_DOC, "XLS", FILE_TYPE_DOC, "XLSX", FILE_TYPE_DOC,

			"MP3", FILE_TYPE_AUDIO, "WMA", FILE_TYPE_AUDIO, "WAV", FILE_TYPE_AUDIO,

			"DATA", FILE_TYPE_DATA,

			"JPG", FILE_TYPE_IMG,"JPEG", FILE_TYPE_IMG, "GIF", FILE_TYPE_IMG, "BMP", FILE_TYPE_IMG, "PNG", FILE_TYPE_IMG

	);

	@Autowired
	private SccConfig config;

	@Override
	public Result doUpload(InputStream in, String name) {
		try {

			String destPath = getDestPath(name);
			String fullPath = config.getResRootPath() + "/" + destPath;

			File fileRoot = new File(fullPath.substring(0, fullPath.lastIndexOf("/")));

			if (!fileRoot.exists()) {
				fileRoot.mkdirs();
			}
			FileUtils.copyInputStreamToFile(in, new File(fullPath));

			ResFile file = insertFileToDB(name, fullPath, destPath, getFileType(name));

			return new Result(true, "success",
					CollectionUtils.newStringMap("fileId", file.getFileId(), "path", destPath));
		} catch (Exception e) {
			log.error(e, e);
		} finally {
			IOUtils.closeQuietly(in);
		}
		return new Result(false, "save file error");
	}

	/**
	 * 插入文件信息到数据库
	 *
	 * @param name
	 * @param fullPath
	 *            全路径
	 * @param relativePath
	 *            相对路径
	 * @param type
	 *            文件类型，非文件格式
	 * @return
	 */
	public ResFile insertFileToDB(String name, String fullPath, String relativePath, String type) {

		ResFile file = new ResFile();

		TraceUtils.setCreateTrace(file);
		file.setFileName(name);
		file.setFileFormat(QFileUtils.getFileFormat(name));
		file.setFileType(type);
		// TODO
		file.setMd5Hash(null);
		file.setPath(relativePath);
		file.setSize(FileUtils.sizeOf(new File(fullPath)));
		// TODO
		file.setTenantId(null);
		file.setDeleteFlag(false);

		save(file);

		return file;

	}
	/**
	 * 插入文件信息到数据库
	 *
	 * @param name
	 * @param relativePath
	 *            相对路径
	 * @param type
	 *            文件类型，非文件格式
	 * @return
	 */
	public ResFile insertFileToDBTwo(String name, Long Size, String relativePath, String type) {

		ResFile file = new ResFile();

		TraceUtils.setCreateTrace(file);
		file.setFileName(name);
		file.setFileFormat(QFileUtils.getFileFormat(name));
		file.setFileType(type);
		// TODO
		file.setMd5Hash(null);
		file.setPath(relativePath);
		file.setSize(Size);
		// TODO
		file.setTenantId(null);
		file.setDeleteFlag(false);

		save(file);

		return file;

	}

	/**
	 * 获取文件类型
	 *
	 * @param name
	 * @return
	 */
	private String getFileType(String name) {
		String fileType = fileFormatMap.get(QFileUtils.getFileFormat(name));
		return StringUtils.isEmpty(fileType) ? FILE_TYPE_DATA : fileType;
	}

	/**
	 * 获取文件目标路径
	 *
	 * @param name
	 * @return
	 */
	private String getDestPath(String name) {
		String fileType = getFileType(name);

		StringBuffer path = new StringBuffer(128);
		path.append(fileType);

		Calendar now = new GregorianCalendar();

		path.append('/');
		path.append(now.get(Calendar.YEAR));
		path.append(StringUtils.leftPad(String.valueOf(now.get(Calendar.MONTH)), 2, '0'));
		path.append('/');
		path.append(now.get(Calendar.DAY_OF_MONTH));
		path.append('/');
		path.append(UUIDUtils.UUID());
		path.append('.');
		path.append(QFileUtils.getFileFormat(name));

		return path.toString();

	}

	@Override
	public ResFile read(String fileId) {
		ResFile file = read(ResFile.class, fileId);
		return file;
	}

	@Override
	public String readIdByPath(String path) {

		String hql = "from ResFile where path=? and deleteFlag is false";

		ResFile result = findUnique(hql, CollectionUtils.newList(chopFirstSlash(path)), ResFile.class);

		return result.getFileId();
	}

	private String chopFirstSlash(String path) {
		if (path.startsWith("/")) {
			return path.substring(1);
		}
		return path;
	}

	@Override
	public InputStream readStreamById(String id) {

		ResFile file = read(id);

		if (null == file) {
			return null;
		}

		String absolutePath = config.getResRootPath() + "/" + file.getPath();

		try {
			return FileUtils.openInputStream(new File(absolutePath));
		} catch (IOException e) {
			log.error(e, e);
		}
		return null;
	}

	@Override
	public Result checkMd5(String md5, String fileName) {
//		if(StringUtils.isBlank(md5)){
//			return Result.FAIL;
//		}
//
//
//			Boolean objectExist;
//			objectExist = authOssService.doseObjectExist(resFile.getPath());
//
//			if (objectExist) {
//
//				ResFileDO resFileToDB = new ResFileDO();
//				BeanUtils.copyProperties(resFile, resFileToDB);
//				resFileToDB.setId(null);
//				TraceUtils.setCreateTrace(resFileToDB);
//				ResFileDO resFileDB = save(resFileToDB);
//
//				Result result = new Result(true, "fileId", resFileDB.getId(), "path", resFileDB.getPath(),"fileName",fileName,
//						"fileSize",resFileToDB.getSize(),"fileType",resFileToDB.getFileType(),"hit",true);
//				result.setResultCode(201);
//				return result;
//
//		}

		return Result.FAIL;
	}
}