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

import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.annotation.PostConstruct;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

import com.alibaba.druid.util.StringUtils;
import com.alibaba.fastjson.JSONObject;
import com.qxueyou.scc.admin.classes.service.IClassLectureService;
import com.qxueyou.scc.base.model.FileMeta;
import com.qxueyou.scc.base.model.Pager;
import com.qxueyou.scc.base.model.Result;
import com.qxueyou.scc.base.service.ICacheService;
import com.qxueyou.scc.base.service.impl.CommonAppService;
import com.qxueyou.scc.base.util.ClientUtils;
import com.qxueyou.scc.base.util.CollectionUtils;
import com.qxueyou.scc.base.util.TraceUtils;
import com.qxueyou.scc.teach.res.model.Res;
import com.qxueyou.scc.teach.res.model.ResDir;
import com.qxueyou.scc.teach.res.model.ResLib;
import com.qxueyou.scc.teach.res.service.IResItemService;
import com.qxueyou.scc.teach.res.service.IResService;
import com.qxueyou.scc.teach.subject.service.impl.SubjectLectureService;

/**
 * 资源服务
 *
 * @author 夏德虎
 */
@Service
public class ResService extends CommonAppService implements IResService {

    public static final String RES_TOUPDATE_CONVER_STATUS_LST = "RES_TOUPDATE_CONVER_STATUS_LST";

    private static final String RES_DIR_ROOT = "0";

    @Autowired
    ICacheService cacheService;

    @Autowired
    private ApplicationContext appContext;

    @Autowired
    private IClassLectureService classLectureService;

    /**
     * 各类型资源服务实现
     */
    private Map<String, IResItemService> resItemServiceMap = new HashMap<String, IResItemService>(6);

    @PostConstruct
    private void init() {
        registerResItemService(appContext.getBean("ResItemVideoService", IResItemService.class));
        registerResItemService(appContext.getBean("ResItemAudioService", IResItemService.class));
        registerResItemService(appContext.getBean("ResItemDocService", IResItemService.class));
        registerResItemService(appContext.getBean("ResItemExerciseService", IResItemService.class));
        registerResItemService(appContext.getBean("ResItemArticleService", IResItemService.class));
    }

    private void registerResItemService(IResItemService service) {
        resItemServiceMap.put(service.getResItemType(), service);
    }

    /*
     * (non-Javadoc)
     *
     * @see com.qxueyou.scc.teach.res.service.IResService#add(java.lang.String,
     * java.lang.String, java.lang.String, java.lang.String)
     */
    @Override
    public Result add(String dirId, String itemDestId, String name, String remark, String type, String coverPageUrl) {

        ResDir dir = read(ResDir.class, dirId);

        String resItemId = resItemServiceMap.get(type).add(itemDestId, name);

        Res res = new Res();
        TraceUtils.setCreateTrace(res);

        res.setCoverPageUrl(coverPageUrl);
        res.setItemDestId(resItemId);
        res.setName(name);
        res.setStatus(Res.STATUS_DRAFT);
        res.setType(type);
        res.setResDirId(dirId);
        res.setRemark(remark);
        res.setLibId(dir.getLibId());

        save(res);

        return new Result(true, "success", CollectionUtils.newStringMap("resId", res.getResId()));
    }

    @Override
    public Result addBatchRes(String dirId, String type, List<FileMeta> items) {
        ResDir dir = read(ResDir.class, dirId);
        Res res = null;
        for (FileMeta fileMeta : items) {
            String name = fileMeta.getFileName();
            String resItemId = resItemServiceMap.get(type).add(fileMeta.getFileId(), name);
            res = new Res();
            TraceUtils.setCreateTrace(res);
            res.setItemDestId(resItemId);
            res.setName(name);
            res.setStatus(Res.STATUS_DRAFT);
            res.setType(type);
            res.setLibId(dir.getLibId());
            res.setResDirId(dirId);
            save(res);
        }
        return Result.SUCCESS;
    }

    /*
     * (non-Javadoc)
     *
     * @see com.qxueyou.scc.teach.res.service.IResService#update(java.lang.String,
     * java.lang.String, java.lang.String)
     */
    @Override
    public Result update(String resId, String name, String remark, String coverPageUrl) {

        Res res = read(Res.class, resId);

        resItemServiceMap.get(res.getType()).update(res.getItemDestId(), name);

        TraceUtils.setUpdateTrace(res);
        res.setName(name);
        res.setCoverPageUrl(coverPageUrl);
        res.setRemark(remark);
        res.setStatus(Res.STATUS_DRAFT);
        save(res);

        return new Result(true, "success");
    }

    /*
     * (non-Javadoc)
     *
     * @see com.qxueyou.scc.teach.res.service.IResService#delete(java.lang.String[])
     */
    @Override
    public Result delete(String[] resIds) {

        for (String resId : resIds) {
            delete(resId);
        }

        return new Result(true, "success");
    }

    /**
     * @param resId 资源id
     * @return
     */
    private Result delete(String resId) {

        Res res = read(Res.class, resId);

        TraceUtils.setUpdateTrace(res);
        res.setDeleteFlag(true);

        save(res);

        return new Result(true, "success");
    }

    @Override
    public Result doCopy(String resId, String destDirId, String name) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public Result doMove(String resId, String destDirId, String name) {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public List<Res> listRes(String dirId, String text, Integer pageSize, Integer pageNum, String type) {

        StringBuffer hql = new StringBuffer("from Res where deleteFlag is false and name like ? and resDirId=? ");

        List<Object> args = CollectionUtils.newList(text + "%", dirId);

        if (!StringUtils.isEmpty(type)) {
            hql.append(" and type=?");
            args.add(type);
        }
        hql.append(" order by createTime desc");
        List<Res> result = findList(hql.toString(), new Pager(pageSize, pageNum), args, Res.class);
        return result;
    }

    @Override
    public List<Res> listMyRes(String keyword, Integer pageSize, Integer pageNum, String type) {

        ResLib lib = readUserLib();

        StringBuffer hql = new StringBuffer("from Res where deleteFlag is false and libId=? and status ='draft'");

        List<Object> args = CollectionUtils.newList(lib.getLibId());

        if (!StringUtils.isEmpty(type)) {
            hql.append(" and type=?");
            args.add(type);
        }

        if (!StringUtils.isEmpty(keyword)) {
            hql.append(" and name like ?");
            args.add("%" + keyword + "%");
        }

        hql.append(" order by updateTime desc");

        List<Res> result = findList(hql.toString(), new Pager(pageSize, pageNum), args, Res.class);

        return result;
    }

    @Override
    public int listMyResCount(String text, String type) {

        ResLib lib = readUserLib();

        StringBuffer hql = new StringBuffer("from Res where deleteFlag is false and libId=? and status ='draft'");

        List<Object> args = CollectionUtils.newList(lib.getLibId());

        if (!StringUtils.isEmpty(type)) {
            hql.append(" and type=?");
            args.add(type);
        }

        if (!StringUtils.isEmpty(text)) {
            hql.append(" and name like ?");
            args.add("%" + text + "%");
        }

        hql.append(" order by updateTime desc");

        return findCount(hql.toString(), args);

    }

    @Override
    public List<Res> listResByLib(String libType, String ownerId, String keyword, Integer pageSize, Integer pageNum,
                                  String resType) {

        ResLib lib = this.getResLib(libType, ownerId);

        StringBuffer hql = new StringBuffer(
                "from Res where deleteFlag is false and name like ? and libId like ? and status=? order by updateTime desc");

        List<Object> args = CollectionUtils.newList(keyword + "%", lib == null ? "%" : lib.getLibId() + "%",Res.STATUS_DRAFT);

        if (!StringUtils.isEmpty(resType)) {
            hql.append(" and type=?");
            args.add(resType);
        }

        List<Res> result = findList(hql.toString(), new Pager(pageSize, pageNum), args, Res.class);

        return result;
    }

    @Override
    public int listResCountByLib(String libType, String ownerId, String text, String resType) {
        ResLib lib = this.getResLib(libType, ownerId);

        StringBuffer hql = new StringBuffer("from Res where deleteFlag is false and libId like ? order by updateTime desc");

        List<Object> args = CollectionUtils.newList(null == lib ? "%" : lib.getLibId()+"%");

        if (!StringUtils.isEmpty(resType)) {
            hql.append(" and type=?");
            args.add(resType);
        }

        return findCount(hql.toString(), args);

    }

    @Override
    public int listResCount(String dirId, String text, String type) {

        String hql = "from Res where resDirId=? and deleteFlag is false and name like ? ";
        List<Object> args = CollectionUtils.newList(dirId, text + "%");
        if (!StringUtils.isEmpty(type)) {
            hql = hql.concat(" and type = ?");
            args.add(type);
        }
        return findCount(hql, args);

    }

    @Override
    public Result readAccessPath(String resId, String attribute) {

        Res res = read(Res.class, resId);
        String type="0";
//        Object path = Res.FILE_TYPE_VIDEO.equals(res.getType())? JSONObject.parse(resItemServiceMap.get(res.getType()).readAccessPath(res.getItemDestId(), attribute)):CollectionUtils.newObjectMap("path", resItemServiceMap.get(res.getType()).readAccessPath(res.getItemDestId(), attribute));
        Object path = Res.FILE_TYPE_VIDEO.equals(type)? resItemServiceMap.get(type).readAccessPath(res.getItemDestId(), attribute):resItemServiceMap.get(type).readAccessPath(res.getItemDestId(), attribute);
        if(Res.FILE_TYPE_DOC.equals(res.getType())) {
        	 return new Result(true, "success",
                     CollectionUtils.newObjectMap("path", path, "name", res.getName(), "coverPageUrl", res.getCoverPageUrl(), "size",
                    		 this.classLectureService.readDocPageCount(res.getItemDestId())));//文件的页数
        }else {
        	 return new Result(true, "success",
                     CollectionUtils.newObjectMap("path", path, "name", res.getName(), "coverPageUrl", res.getCoverPageUrl(), "size", 0));
        }

    }

    @Override
    public Result addDir(String parentDirId, String name) {

        ResDir parent = read(ResDir.class, parentDirId);

        ResDir resDir = new ResDir();

        TraceUtils.setCreateTrace(resDir);
        resDir.setName(name);
        resDir.setParentDirId(parentDirId);
        resDir.setLibId(null == parent ? null : parent.getLibId());

        save(resDir);

        return new Result(true, "success", CollectionUtils.newObjectMap("dirId", resDir.getDirId(), "name", name));

    }

    @Override
    public ResDir readDir(String dirId) {
        return read(ResDir.class, dirId);
    }

    @Override
    public Result updateDir(String dirId, String name) {

        ResDir resDir = read(ResDir.class, dirId);

        TraceUtils.setUpdateTrace(resDir);
        resDir.setName(name);

        save(resDir);

        return new Result(true, "success", CollectionUtils.newObjectMap("dirId", resDir.getDirId(), "name", name));
    }

    @Override
    public Result deleteDir(String[] dirIds) {

        for (String dirId : dirIds) {
            deleteFile4Dir(dirId);// 删除对应的文件
            deleteDir(dirId);
        }

        return new Result(true, "success");
    }

    private void deleteDir(String dirId) {

        ResDir resDir = read(ResDir.class, dirId);

        TraceUtils.setUpdateTrace(resDir);
        resDir.setDeleteFlag(true);

        save(resDir);

    }

    /**
     * 删除资源库文件夹对应删除文件
     *
     * @param dirId 文件夹id
     */
    @Override
    public void deleteFile4Dir(String dirId) {
        String[] dirIds = dirId.split(",");
        this.bulkUpdateInLoop("update Res set deleteFlag = true where deleteFlag is false and resDirId = ?", dirIds);

    }

    @Override
    public ResDir doGetRootDir(String type, String ownerId) {
        ResLib lib = getResLib(type, ownerId);
        // 无资源库则初始化,并返回根节点
        if (lib == null) {
            Result result = initResLib(type, ownerId);
            return read(ResDir.class, result.getDataT("rootDirId"));
        }
//        System.out.println(lib.getRootDirId());
        return read(ResDir.class, lib.getRootDirId());
    }

    @Override
    public List<ResDir> doGetMyLibChildDirs(String parentDirId) {

        return doGetChildDirsInner(parentDirId, ResLib.OWNNER_TYPE_USER);

    }

    private List<ResDir> doGetChildDirsInner(String parentDirId, String type) {

        // 根节点的处理
        if (StringUtils.isEmpty(parentDirId)) {
            ResLib lib = getResLib(type, ClientUtils.getUserId());

            // 无资源库则初始化,并返回根节点
            if (lib == null) {
                Result result = initUserLib();
                return CollectionUtils.newList(ResDir.class, read(ResDir.class, result.getDataT("rootDirId")));
            }
            return CollectionUtils.newList(ResDir.class, read(ResDir.class, lib.getRootDirId()));
        }

        return listDir(parentDirId);
    }

    private List<ResDir> listDir(String parentDirId) {

        String hql = "from ResDir where parentDirId=? and deleteFlag is false";

        List<ResDir> result = find(hql, CollectionUtils.newList(parentDirId), ResDir.class);

        return result;
    }

    @Override
    public Res read(String resId) {
        return read(Res.class, resId);
    }

    @Override
    public Result initUserLib() {

        return initResLib(ResLib.OWNNER_TYPE_USER, ClientUtils.getUserId());
    }

    private Result initResLib(String type, String ownerId) {

        String hql = "from ResLib where ownerId=? and ownerType=? and deleteFlag is false";

        ResLib lib = findUnique(hql, CollectionUtils.newList(ownerId, type), ResLib.class);

        if (lib == null) {

            Result result = addDir(RES_DIR_ROOT, "根目录");

            lib = new ResLib();

            TraceUtils.setCreateTrace(lib);
            lib.setOwnerId(ownerId);
            lib.setOwnerType(type);
            lib.setRootDirId(result.getDataT("dirId"));

            save(lib);

            ResDir root = read(ResDir.class, result.getDataT("dirId"));
            root.setLibId(lib.getLibId());
            save(root);

            return new Result(true, "success",
                    CollectionUtils.newStringMap("rootDirId", lib.getRootDirId(), "libId", lib.getLibId()));
        }

        return new Result(true, "success",
                CollectionUtils.newStringMap("rootDirId", lib.getRootDirId(), "libId", lib.getLibId()));
    }

    @Override
    public ResLib readUserLib() {

        String hql = "from ResLib where ownerId=? and ownerType=? and deleteFlag is false";

        ResLib lib = findUnique(hql, CollectionUtils.newList(ClientUtils.getUserId(), ResLib.OWNNER_TYPE_USER),
                ResLib.class);

        return lib;
    }

    @Override
    public ResLib getResLib(String type, String ownerId) {
        String hql = "from ResLib where ownerId=? and ownerType=? and deleteFlag is false";

        return findUnique(hql, CollectionUtils.newList(ownerId, type), ResLib.class);
    }

    @Override
    public List<ResDir> doGetChildDirs(String parentDirId, String type) {
        return doGetChildDirsInner(parentDirId, type);
    }

    /**
     * 定时器监控转码完成后设置同步res表的状态
     */
    @Scheduled(cron = "0/2 * * * * ?")
    public void doTimer() {
        String itemDestId = cacheService.lstLeftPop(RES_TOUPDATE_CONVER_STATUS_LST);

        if (StringUtils.isEmpty(itemDestId)) {
            return;
        }
        Res res = findUnique("from Res where deleteFlag is false and itemDestId = ?",
                CollectionUtils.newList(itemDestId), Res.class);
        res.setStatus(Res.STATUS_DRAFT);
        TraceUtils.setUpdateTrace(res);
        save(res);

        cacheService.lstRightPush(SubjectLectureService.RES_LECTURE_CONVER_LST, res.getResId());
    }

}