/**
 * 我的消息model
 * @author: yyq<yanqing.yang@yoho.cn>
 * @date: 2016/8/29
 */
'use strict';

const _ = require('lodash');
const Promise = require('bluebird');

const UserApi = require('./user-api');
const setPager = require(`${global.utils}/pager`).setPager;

const co = Promise.coroutine;

module.exports = class extends global.yoho.BaseModel {
    constructor(ctx) {
        super(ctx);
    }

    getMessageTabList(uid) {

        let data = {
            method: 'app.inbox.getAllInboxCatInfo',
            uid: uid
        };

        return this.get({
            data: data,
            param: {
                code: 200
            }
        });
    }

    getMessageAsync(uid, page, size, type) {
        let data = {
            method: 'app.inbox.getlistnew',
            uid: uid,
            page: page || 1,
            size: size || 10
        };

        if (type) {
            data.displayTab = type;
        }

        return this.get({
            data: data,
            param: {
                code: 200
            }
        });
    }

    delMessageAsync(uid, id) {

        let data = {
            method: 'app.inbox.delmessage',
            uid: uid,
            id: id
        };

        return this.get({
            data: data,
            param: {
                code: 200
            }
        });
    }

    readMessageAsync(uid, id) {

        let data = {
            method: 'web.inbox.setread',
            uid: uid,
            ids: id
        };

        return this.get({
            data: data,
            param: {
                code: 200
            }
        });
    }

    getBirthCouponAsync(uid, couponId) {

        let data = {
            method: 'app.promotion.getCoupon',
            uid: uid,
            couponId: couponId
        };

        return this.get({
            data: data,
            param: {
                code: 200
            }
        });
    }

    /**
     * 根据用户uid获取生日券id
     * @function getCouponAsync
     * @param { Number } uid 用户uid
     * @return { Object } 生日券数据
     */
    getCouponAsync(uid) {

        let data = {
            method: 'app.promotion.queryBirthCoupon',
            uid: uid,
            couponType: 4
        };

        return this.get({
            data: data,
            param: {
                code: 200
            }
        });

    }

    /**
     * 未读消息
     * @function unreadTotal
     * @param { Number } uid 用户uid
     * @return { Number } 未读消息数量
     */
    unreadTotal(uid) {

        let data = {
            method: 'app.inbox.getTotal',
            uid: uid,
            is_read: 'N'
        };

        return this.get({
            data: data,
            param: {
                code: 200
            }
        });
    }

    /**
     * 获取消息列表
     * @function getMessageList
     * @param { Number } uid 用户uid
     * @param { Object } params url参数
     * @param { Number } limit 每页数目
     * @return { Object } 消息列表数据
     */
    getMessageList(uid, params, limit) {
        let that = this;
        let resData = {};
        let page = parseInt(`0${params.page}`, 10) || 1,
            type = parseInt(`0${params.type}`, 10);
        let userDataModel = new UserApi(that.ctx);

        return Promise.all([
            userDataModel.getUserInfo(uid),
            that.getMessageTabList(uid),
            that.getMessageAsync(uid, page, limit, type)
        ]).then(result => {
            const msgBaseUrl = '/home/message';

            resData.userThumb = _.get(result, '[0].data.head_ico', '');

            let tabList = [{
                name: '全部',
                focus: !type,
                href: msgBaseUrl
            }];

            let focusTabName = '';

            _.forEach(_.get(result, '[1]data.list', []), value => {
                let tab = {
                    name: `${value.inboxCatName}`,
                    focus: type === value.id * 1,
                    href: `${msgBaseUrl}?type=${value.id}`
                };

                if (value.unReadCount * 1) {
                    tab.name += ` (${value.unReadCount})`;
                }

                if (tab.focus) {
                    focusTabName = value.inboxCatName;
                }

                tabList.push(tab);
            });

            resData.tabList = tabList;

            if (result[2].data) {
                let data = result[2].data;
                let msg = [];

                _.forEach(_.get(data, 'list', []), value => {
                    // 信息过滤
                    if (value.type === '$inboxval' || value.type === 'notice') {
                        return;
                    }

                    let href = 'javascript:;'; // eslint-disable-line

                    href += type ? `&type=${type}` : '';
                    switch (value.type) {
                        case 'pullCoupon':
                        case 'button':
                        case 'pushCoupon':
                            break;
                        default:
                            if (value.pcLink) {
                                href = value.pcLink.replace('http:', '');
                            }
                            break;
                    }

                    msg.push({
                        id: value.id || 0,
                        href: href,
                        title: value.title || '',
                        content: _.get(value, 'body.content', ''),
                        sender: value.from || '',
                        time: value.create_date,
                        isNew: value.is_read === 'Y' ? false : true
                    });
                });

                resData.messages = msg;

                let pagerList = setPager(_.get(data, 'page_total', 1),
                    Object.assign(params, {page: page}));

                resData.pager = Object.assign({
                    count: _.get(data, 'total', 0),
                    curPage: page,
                    totalPages: _.get(data, 'page_total', 0)
                }, pagerList);
            }

            if (_.isEmpty(resData.messages)) {
                resData.messages = {empty: `您尚未收到任何${focusTabName}消息`};
            }

            return resData;
        });
    }

    /**
     * 获取消息内容
     * @function getMessageDetail
     * @param { Number } uid 用户uid
     * @param { Object } params url参数
     * @param { Number } limit 每页数目
     * @return { Object } 消息列表数据
     */
    getMessageDetail(uid, params, limit) {
        let that = this;
        let mid = parseInt(`0${params.id}`, 10);
        let page = parseInt(`0${params.page}`, 10) || 1;
        let type = parseInt(`0${params.type}`, 10);
        let userDataModel = new UserApi(that.ctx);

        let process = function*() {
            let result = yield Promise.all([
                userDataModel.getUserInfo(uid),
                that.getMessageAsync(uid, page, limit, type)
            ]);
            let resData = {
                backUrl: `/home/message?page=${page}`,
                userThumb: _.get(result, '[0].data.head_ico', '')
            };
            let msg = _.find(_.get(result, '[1]data.list', []), {id: mid});

            if (type) {
                resData.backUrl += `&type=${type}`;
            }

            if (!_.isEmpty(msg)) {
                resData.message = {
                    sender: msg.from, // 消息发言人
                    title: msg.title, // 消息标题
                    time: msg.create_date // 消息创建时间
                };

                switch (msg.type) {
                    case 'pullCoupon': // eslint-disable-line
                        resData.message.birthCoupon = {
                            text: `${_.get(result, '[0].data.nickname', '')} 有货祝您生日快乐！感谢您对有货的支持，特赠您VIP生日专属礼，即刻享受生日福利吧！`
                        };

                        if (_.get(msg, 'body.is_collar', '') === 'Y') {
                            Object.assign(resData.message.birthCoupon, {
                                over: true,
                                overText: '已领取'
                            });
                            break;
                        }

                        if (_.get(msg, 'body.is_over_time', '') === 'Y') {
                            Object.assign(resData.message.birthCoupon, {
                                over: true,
                                overText: '生日券已过期'
                            });
                            break;
                        }

                        let couponInfo = yield that.getCouponAsync(uid);
                        let coupons = [];

                        if (!_.isEmpty(couponInfo.data)) {
                            _.forEach(couponInfo.data, value => {
                                coupons.push({
                                    id: value.id,
                                    remark: value.couponName || '',
                                    useTime: _.get(msg, 'body.use_time', ''),
                                    pickTime: _.get(msg, 'body.collar_time', ''),
                                    canPick: true
                                });
                            });
                        } else {
                            // 已过期生日券信息
                            coupons.push({
                                remark: _.get(msg, 'body.name', ''),
                                useTime: _.get(msg, 'body.use_time', ''),
                                pickTime: _.get(msg, 'body.collar_time', '')
                            });
                        }
                        resData.message.coupons = coupons;
                        break;
                    case 'button':
                        // 促销活动
                        resData.message.sale = {
                            image: _.get(msg, 'body.image', ''),
                            content: _.get(msg, 'body.text', ''),
                            btnLink: _.get(msg, 'body.pc_link', ''),
                            btnName: _.get(msg, 'body.button_text', '') || '查看详情'
                        };
                        break;
                    case 'pushCoupon':
                        // 查看优惠券
                        resData.message.coupons = [{
                            remark: _.get(msg, 'body.coupon_name', ''),
                            useTime: _.get(msg, 'body.time', ''),
                            id: _.get(msg, 'body.inboxId', ''),
                            price: _.get(msg, 'body.price', ''),
                            url: '/home/coupons'
                        }];
                        break;
                    default:
                        // 普通文本
                        resData.message.text = {
                            content: _.get(msg, 'body.content', '')
                        };
                        break;
                }
            }

            return resData;
        };

        return co(process)();
    }

    /**
     * 删除用户消息
     * @function getMessageDetail
     * @param { Number } uid 用户uid
     * @param { Number } mid 消息id
     * @return { Object } 消息列表数据
     */
    delMessage(uid, mid) {
        let that = this;
        let process = function*() {
            let resData = {code: 400, message: '删除失败'};
            let result = yield that.delMessageAsync(uid, mid);

            if (result.code === 200) {
                Object.assign(resData, {
                    code: 200,
                    message: '删除成功'
                });
            }

            return resData;
        };

        return co(process)();
    }

    /**
     * 删除用户消息
     * @function getMessageDetail
     * @param { Number } uid 用户uid
     * @param { Number } mid 消息id
     * @return { Object } 消息列表数据
     */
    readMessage(uid, mid) {
        let that = this;
        let process = function*() {
            let resData = {code: 400, message: '标记失败'};
            let result = yield that.readMessageAsync(uid, mid);

            if (result.code === 200) {
                resData = result;
            }

            return resData;
        };

        return co(process)();
    }

    pickBirthCoupon(uid, id) {
        let that = this;

        return that.getBirthCouponAsync(uid, id);
    }
};