'use strict';

const Router = require('koa-router');
const _ = require('lodash');
const pager = require('../utils/pager');

let r = new Router();

const TYPE_LIST = [
    {name: '商品', type: 'skn', lt: 'SKN'},
    {name: '逛', type: 'article', lt: 'ID'},
    {name: '店铺', type: 'shop', lt: 'ShopId'},
    {name: '链接', type: 'url', lt: 'URL'}
];

const tdk = {

    // tdk 列表
    index: async(ctx, next) => {
        let resData = {};
        let type = ctx.query.type || 'skn',
            page = parseInt(`0${ctx.query.page}`, 10) || 1,
            limit = parseInt(`0${ctx.query.limit}`, 10) || 20;
        let listKey = `tdk:${type}:links`,
            startId = (page - 1) * limit,
            typeObj = _.find(TYPE_LIST, {'type': type}) || {};
        let hmget = [];

        await ctx.redis.multi([
            ['llen', listKey],
            ['lrange', listKey, startId, page * limit]
        ]).execAsync().then(function(res) {
            let total = res[0] || 1;

            resData.pager = pager(Math.floor((total - 1) / limit) + 1, ctx.query);

            _.forEach(res[1], value => {
                hmget.push(['hmget', `tdk:${type}:${value}`, 'key', 'title', 'keywords', 'description']);
            });
        });

        await ctx.redis.multi(hmget).execAsync().then(function(res) {
            let tdkList = [];

            _.forEach(res, value => {
                tdkList.push({
                    id: ++startId,
                    typeName: typeObj.name,
                    typeLt: typeObj.lt,
                    key: value[0],
                    title: value[1],
                    keywords: value[2],
                    description: value[3]
                });
            });

            if (tdkList.length) {
                resData.tdkList = tdkList;
            }
        });

        await ctx.render('action/seo_tdk', Object.assign(resData, {
            title: 'TDK管理',
            typeList: TYPE_LIST,
            type: typeObj.type,
            typeName: typeObj.name
        }));
    },

    // 添加tdk
    add: async(ctx, next) => {
        let result = {code: 500, message: '非法参数'},
            typeList = ['skn', 'article', 'shop', 'url'];

        // skn, article, shop, url
        let type = ctx.request.body.type,
            val = ctx.request.body.val,
            title = ctx.request.body.title || '',
            keywords = ctx.request.body.keywords || '',
            description = ctx.request.body.description || '';


        // type 不合法， 返回错误
        if (!_.find(typeList, type)) {
            ctx.response.body = result;
        }

        ctx.redis.multi([
            ["lpush", `tdk:${type}:links`, val],
            ["hmset", `tdk:${type}:${val}`, "title", title, "keywords", keywords, "description", description]
        ]).execAsync().then(function(res) {
            Object.assign(result, {code:200, message: 'success'})
        });

        ctx.response.body = result;
    },

};

r.get('/', tdk.index);
r.get('/tdk', tdk.index);
r.post('/tdk/add', tdk.add);


module.exports = r;