/**
 * guang controller
 * @author: lcy<chuanyang.liu@yoho.cn>
 * @date: 2016/08/31
 */

'use strict';

const _ = require('lodash');
const cheerio = require('cheerio');

const guangModel = require('../models/guang-service');
const headerModel = require('../../../doraemon/models/header');
const ghelper = require('../models/guang-helper');
const urlHelper = require('../models/url-helper');
const tdk = require('../../../utils/getTDK');

/**
 * 首页文章列表 类型列表
 */
exports.index = (req, res, next) => {
    let channel = req.yoho.channel;
    let page = req.query.page || 1;
    let pageSize = req.query.pageSize || 20;
    let type = req.query.type || 0;

    let pathNav = req.ctx(guangModel).getPathNav(channel);
    let uid = req.user.uid;
    let udid = req.yoho.udid;
    let gender = ghelper.getGenderByCookie(req);
    let isHotDegrade = _.get(req.app.locals.pc, 'guang.removeHotTag', false);
    let isAdDegrade = _.get(req.app.locals.pc, 'guang.removeAd', false);

    const reqCtx = req.ctx(guangModel);

    Promise.all([
        reqCtx.getBanner(channel),
        reqCtx.getCategory(type, channel),
        reqCtx.getArticleList(gender, type, uid, udid, page, '', '', pageSize, channel, true),
        reqCtx.getHotTags(page, pageSize, channel, isHotDegrade),
        reqCtx.getAds(channel, isAdDegrade),
        reqCtx.getRecoArticles(gender, 1, 10),
        headerModel.requestHeaderData(channel),
        reqCtx.getTopList(gender, uid, udid, page, true)
    ]).then(ret => {

        if (!_.get(ret[2], 'msgs')) {
            res.set('Cache-Control', 'no-cache');
        }

        let seoTdk = ghelper.getIndexSeo(req.query, ret[1]);

        res.render('guang/index', Object.assign(seoTdk, {
            guang: {
                slider: ret[0],
                msgTypes: ret[1],
                msgs: (+type === 0 && +page === 1 && ret[7] && ret[7].msgs) ?
                    _.concat(ret[7].msgs, ret[2] && ret[2].msgs) : ret[2] && ret[2].msgs,
                hotTags: ret[3],
                ads: ret[4],
                exRecos: ret[5],

                guangIndexPage: true,
                pageSize: pageSize,
                type: type,
                pathNav: pathNav,
                baseUrl: urlHelper.listUrl(channel, type),
                page: page,
                total: (ret[2] && ret[2].total) || 0
            },
            module: 'guang',
            page: 'guang',
            headerData: ret[6] && ret[6].headerData
        }));
    }).catch(next);

};

/**
 * 指定标签的文章列表
 */
exports.tags = (req, res, next) => {
    let query = req.query.query = (req.query.query || req.params.query || '').replace(/<|>/ig, '');
    let page = req.query.page || req.params.page || 1;
    let pageSize = req.query.pageSize || 20;
    let type = req.query.type || 0;

    let uid = req.user.uid;
    let udid = req.yoho.udid;
    let gender = ghelper.getGenderByCookie(req);
    let channel = req.yoho.channel;
    let pathNav = req.ctx(guangModel).getPathNav(channel, query);
    let isHotDegrade = _.get(req.app.locals.pc, 'guang.removeHotTag', false);
    let isAdDegrade = _.get(req.app.locals.pc, 'guang.removeAd', false);

    const reqCtx = req.ctx(guangModel);

    Promise.all([
        reqCtx.getBanner(channel),

        reqCtx.getArticleList(gender, 0, uid, udid, page, query, '', pageSize, channel, true),
        reqCtx.getHotTags(1, 20, channel, isHotDegrade),
        reqCtx.getAds(channel, isAdDegrade),
        reqCtx.getRecoArticles(gender, 1, 10),
        headerModel.requestHeaderData(channel)
    ]).then(ret => {

        if (_.isEmpty(ret[1]) || _.isEmpty(ret[1].msgs)) {
            res.set('Cache-Control', 'no-cache');
        }

        let seoTdk = ghelper.getTagSeo(query);

        res.render('guang/tag', Object.assign(seoTdk, {
            guang: {
                slider: ret[0],
                msgs: ret[1] && ret[1].msgs,
                hotTags: ret[2],
                ads: ret[3],
                exRecos: ret[4],

                tag: query,
                guangIndexPage: true,
                baseUrl: urlHelper.tagsUrl(query),
                pageSize: pageSize,
                type: type,
                pathNav: pathNav,
                page: page,
                total: (ret[1] && ret[1].total) || 0
            },
            module: 'guang',
            page: 'list',
            headerData: ret[5] && ret[5].headerData
        }));
    }).catch(next);
};

/**
 * 作者文章列表
 */
exports.editor = (req, res, next) => {

    let authorId = req.query.author_id;
    let channel = req.yoho.channel;
    let gender = ghelper.getGenderByCookie(req);
    let isHotDegrade = _.get(req.app.locals.pc, 'guang.removeHotTag', false);
    let isAdDegrade = _.get(req.app.locals.pc, 'guang.removeAd', false);

    let uid = req.user.uid;
    let udid = req.yoho.udid;

    let pathNav = req.ctx(guangModel).getPathNav(channel);

    let page = req.query.page || 1;
    let pageSize = req.query.pageSize || 20;

    const reqCtx = req.ctx(guangModel);

    Promise.all([
        reqCtx.getAuthor(channel, authorId),
        reqCtx.getArticleList(gender, null, uid, udid, page, '', authorId, pageSize, channel, true),
        reqCtx.getHotTags(1, 20, channel, isHotDegrade),
        reqCtx.getAds(channel, isAdDegrade),
        reqCtx.getRecoArticles(gender, 1, 10),
        headerModel.requestHeaderData(channel)
    ]).then(ret => {

        if (_.isEmpty(ret[1]) || _.isEmpty(ret[1].msgs)) {
            res.set('Cache-Control', 'no-cache');
        }

        let seoTdk = ghelper.getEditorSeo(_.get(ret[0], 'name', ''));

        res.render('guang/editor', Object.assign(seoTdk, {
            guang: {
                editor: ret[0],
                msgs: ret[1] && ret[1].msgs,
                hotTags: ret[2],
                ads: ret[3],
                exRecos: ret[4],

                gender: gender,
                baseUrl: urlHelper.editorUrl(channel, authorId),
                pageSize: pageSize,
                pathNav: pathNav,
                page: page,
                total: (ret[1] && ret[1].total) || 0
            },
            module: 'guang',
            page: 'list',
            headerData: ret[5] && ret[5].headerData
        }));
    }).catch(next);
};

/**
 * 文章详情
 */
exports.detail = (req, res, next) => {

    let id = req.params.id || req.query.id || req.params[0];
    let page = req.query.page || 1;
    let pageSize = req.query.pageSize || 10;
    let col = req.query.col || 0;
    let pjax = req.query._pjax;
    let uid = req.user.uid;
    let udid = req.yoho.udid;
    let gender = ghelper.getGenderByCookie(req);
    let channel = req.yoho.channel;
    let isHotDegrade = _.get(req.app.locals.pc, 'guang.removeHotTag', false);
    let isAdDegrade = _.get(req.app.locals.pc, 'guang.removeAd', false);

    const reqCtx = req.ctx(guangModel);

    if (!_.isNumber(id)) {
        id = _.parseInt(id);
    }

    if (pjax) {
        req.ctx(guangModel).getArticleComments(udid, uid, id, page, pageSize).then(ret => {

            res.set('Cache-Control', 'no-cache');
            res.render('guang/detail-comment', {
                layout: false,
                comment: ret
            }, function(err, html) {
                if (err) {
                    return res.send('');
                }
                return res.status(200).send(html);
            });
        });

        return;
    }

    // 登陆后自动收藏
    if (col === 1 && uid > 0) {
        reqCtx.collectArticle(id, uid);
    }

    reqCtx.getArticleInfo(id, channel).then(info => {

        // 判断参数是否有效, 无效会跳转到错误页面
        if (!info || !info.title) {
            return next();
        }

        let promises = [
            headerModel.requestHeaderData(channel, true),
            reqCtx.getArticleContent(id, info.title),
            reqCtx.getHotTags(1, 20, channel, isHotDegrade),
            reqCtx.getArticleComments(udid, uid, id, page, pageSize),
            reqCtx.getArticleBaseInfo(id, uid, udid),
            reqCtx.getArticleRelateBrand(id),
            reqCtx.getRecoArticles(gender, 1, 10),
            reqCtx.getAds(channel, isAdDegrade),
            tdk('article', id, req)
        ];

        if (info.authorId) {
            promises.push(req.ctx(guangModel).getAuthor(channel, info.authorId));
        } else {
            promises.push({});
        }

        if (info.tag) {
            promises.push(req.ctx(guangModel).getRelateArticleList(id, info.tag, 6));
        } else {
            promises.push({});
        }

        // 获取作者前10遍文章
        if (info.authorId) {
            promises.push(req.ctx(guangModel).getFirstArticleList(
                gender, null, uid, udid, 1, '', info.authorId, 17, channel, true, id
            ));
        } else {
            promises.push({});
        }

        let pathNav = req.ctx(guangModel).getPathNav(channel, info.title);

        Promise.all(promises).then(ret => {

            if (_.isEmpty(ret[1])) {
                res.set('Cache-Control', 'no-cache');
            }

            let title, keywords, description;

            if (ret[8][0]) {
                req.tdk = {
                    title: ret[8][1],
                    keywords: ret[8][2],
                    description: ret[8][3]
                };
            }

            let ctext = '';

            _.forEach(ret[1] || [], val => {
                if (!ctext && val.text) {
                    ctext = val.text;
                    return false;
                }
            });
            let $ = cheerio.load(ctext);

            $('p').each(function() {
                if (!description) {
                    description = _.trim($(this).text());
                }
            });

            title = `${info.title}_潮流资讯-YOHO!BUY 有货`;
            keywords = info.title;
            description = description || '潮流商品搜索,上衣,衬衫，TEE，卫衣，冲锋衣，风衣，羽绒服，裤子,休闲鞋,板鞋,配饰，复古眼镜';

            res.render('guang/detail', Object.assign({
                module: 'guang',
                page: 'detail',
                headerData: ret[0] && ret[0].headerData,
                guang: {
                    pathNav: pathNav,

                    id: id,
                    header: Object.assign({}, info, ret[9] || {},
                        { commentNum: _.get(ret[3], 'commentNum', 0) }),
                    content: ret[1],
                    hotTags: ret[2],
                    comment: ret[3],
                    commentInfo: req.session['comment_' + udid],
                    userInfo: ret[4],
                    brands: ret[5],

                    tag: info.tags,
                    relatedPost: (ret[10] && ret[10].length) ? ret[10] : ret[11].slice(10, 16),
                    exRecos: ret[6],
                    ads: ret[7],
                    authorArticle: ret[11].slice(0, 10),

                    // 分享
                    shareImg: info.shareImg,
                    sharedTitle: info.title,
                    shareDesc: info.desc,
                    weixinUrl: info.weixinUrl,
                    commentFirstPageUrl: '?pageSize=10'
                }
            }, {
                title: title,
                keywords: keywords,
                description: description,
                webNavHeader: channel
            }));
        });
    }).catch(next);
};

/**
 * 列表页(列表首页、标签列表页、作者列表页)动态数据，如：查看数，点赞数，评论数，是否点赞，是否回复
 * @param req
 * @param res
 */
exports.listDynamicData = (req, res) => {
    let ids = req.query.ids;

    let udid = req.yoho.udid;

    let other = {};
    let query = req.query.query,
        type = req.query.type;

    if (req.user.uid) {
        other.uid = req.user.uid;
    }

    if (query) {
        other.query = query;
    }

    if (type) {
        other.type = type;
    }

    req.ctx(guangModel).getDynamicDataByIds(ids, udid, other).then(ret => {
        res.send(ret);
    });
};

/**
 * 详情页动态数据，如：评论数，回复数，是否点赞，是否收藏
 * @param req
 * @param res
 */
exports.detailDynamicData = (req, res) => {
    let id = req.query.id,
        uid = req.user.uid,
        udid = req.yoho.udid;

    req.ctx(guangModel).getDynamicDataById(id, uid, udid).then((ret) => {
        res.status(200).send(ret);
    }).catch(() => {
        res.status(400);
    });
};

/**
 * 添加评论
 */
exports.comment = (req, res) => {

    let id = req.body.id || req.query.id;
    let uid = req.user.uid;
    let udid = req.yoho.udid;
    let comment = req.body.comment;

    // let pageSize = req.query.pageSize || 20;

    if (!uid) {
        req.session['comment_' + udid] = comment;
        return res.send({
            code: 401
        });
    }

    req.ctx(guangModel).addComment(id, uid, comment).then(() => {
        if (req.session['comment_' + udid]) {
            req.session['comment_' + udid] = null;
        }

        return req.ctx(guangModel).getArticleComments(udid, uid, id, 1, 20);
    }).then(commentInfo => {

        res.render('guang/detail-comment', {
            comment: commentInfo,
            layout: false
        }, (err, content) => {

            if (err) {

                return res.send({
                    code: 401
                });
            }
            return res.send({
                code: 200,
                data: {
                    count: commentInfo.commentNum,
                    content: content
                }
            });
        });
    }).catch(() => {
        return res.send({
            code: 400,
            message: '评论失败'
        });
    });
};

/**
 * 赞
 */
exports.praise = (req, res) => {

    let id = req.body.id || req.query.id;

    // let uid = req.user.uid;
    let udid = req.yoho.udid;

    req.ctx(guangModel).praise(id, udid).then(ret => {
        res.send(ret);
    }).catch(() => {
        res.send({
            code: 400
        });
    });
};

/**
 * 取消赞
 */
exports.cancelPraise = (req, res) =>{
    let id = req.body.id || req.query.id;
    let udid = req.yoho.udid;

    req.ctx(guangModel).cancelPraise(id, udid).then(ret => {
        res.send(ret);
    }).catch(() => {
        res.send({
            code: 400
        });
    });
};

/**
 * 收藏
 */
exports.collect = (req, res) =>{
    let id = req.body.id || req.query.id;
    let uid = req.user.uid;

    if (!uid) {
        return res.send({
            code: 401
        });
    }

    req.ctx(guangModel).collect(id, uid).then(ret => {
        res.send(ret);
    }).catch(() => {
        res.send({
            code: 400,
            message: '收藏失败'
        });
    });
};

/**
 * 取消收藏
 */
exports.cancelCollect = (req, res) =>{
    let id = req.body.id || req.query.id;
    let uid = req.user.uid;

    if (!uid) {
        return res.send({
            code: 401
        });
    }

    req.ctx(guangModel).cancelCollect(id, uid).then(ret => {
        res.send(ret);
    }).catch(() => {
        res.send({
            code: 400,
            message: '取消收藏失败'
        });
    });
};