|
|
|
/**
|
|
|
|
*
|
|
|
|
* @author: jiangfeng<jeff.jiang@yoho.cn>
|
|
|
|
* @date: 16/8/22
|
|
|
|
* @author: shijian<jian.shi@yoho.cn>
|
|
|
|
* @date: 17/5/31
|
|
|
|
*/
|
|
|
|
|
|
|
|
'use strict';
|
|
|
|
|
|
|
|
const Router = require('koa-router');
|
|
|
|
const moment = require('moment');
|
|
|
|
const redisStore = require('koa-redis');
|
|
|
|
const redis = require("redis");
|
|
|
|
const client = redis.createClient();
|
|
|
|
const multi = client.multi();
|
|
|
|
|
|
|
|
client.on("error", function (err) {
|
|
|
|
console.log("Error " + err);
|
|
|
|
});
|
|
|
|
|
|
|
|
const {
|
|
|
|
OperationLogger
|
|
...
|
...
|
@@ -15,46 +23,46 @@ const { |
|
|
|
|
|
|
|
const r = new Router();
|
|
|
|
|
|
|
|
r.get('/', async(ctx) => {
|
|
|
|
await ctx.render('action/keywords');
|
|
|
|
});
|
|
|
|
const setData = ()=>{
|
|
|
|
client.set('keywords_mana:aaa', 'aaa');
|
|
|
|
client.set('keywords_mana:bbb', 'bbb');
|
|
|
|
let arr = ['keywords_mana:aaa', 'keywords_mana:bbb'];
|
|
|
|
|
|
|
|
// r.post('/log/query', async(ctx) => {
|
|
|
|
for (var i=0; i<arr.length; i++) {
|
|
|
|
multi.sadd('keywords_mana_list', arr[i]);
|
|
|
|
}
|
|
|
|
|
|
|
|
// let q = ctx.request.body;
|
|
|
|
multi.exec(function(errors, results) {
|
|
|
|
|
|
|
|
// let start = parseInt(q.start || 0, 10);
|
|
|
|
// let length = parseInt(q.length || 10, 10);
|
|
|
|
// let draw = parseInt(q.draw, 10);
|
|
|
|
});
|
|
|
|
}
|
|
|
|
|
|
|
|
// let sort = {time: -1};
|
|
|
|
// if (q.order && q.order.length > 0) {
|
|
|
|
// let col = q.order[0].column;
|
|
|
|
// let dir = q.order[0].dir === 'desc' ? -1 : 1;
|
|
|
|
const getData = async(key)=>{
|
|
|
|
multi.smembers(key);
|
|
|
|
return new Promise(function (resolve, reject) {
|
|
|
|
multi.exec(function(errors, results) {
|
|
|
|
resolve(results);
|
|
|
|
});
|
|
|
|
});
|
|
|
|
}
|
|
|
|
|
|
|
|
// col = parseInt(col, 10);
|
|
|
|
// if (q.columns && q.columns.length > col) {
|
|
|
|
// sort = {};
|
|
|
|
// sort[q.columns[col].data] = dir;
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
r.get('/', async(ctx) => {
|
|
|
|
await ctx.render('action/keywords');
|
|
|
|
});
|
|
|
|
|
|
|
|
r.get('/getKeywords', async(ctx) => {
|
|
|
|
|
|
|
|
// let logs = await OperationLogger.cfind({}).sort(sort).skip(start).limit(length).exec();
|
|
|
|
// let total = await OperationLogger.count();
|
|
|
|
let q = ctx.request.query;
|
|
|
|
|
|
|
|
// logs.forEach(l => {
|
|
|
|
// l.username = l.user.username;
|
|
|
|
// l.time = moment(l.time).format('YYYY-MM-DD HH:mm:ss.sss');
|
|
|
|
// l.meta = JSON.stringify(l.meta || {});
|
|
|
|
// });
|
|
|
|
let r = await getData("keywords_mana_list");
|
|
|
|
|
|
|
|
// ctx.body = {
|
|
|
|
// draw: draw,
|
|
|
|
// recordsTotal: total,
|
|
|
|
// recordsFiltered: total,
|
|
|
|
// data: logs
|
|
|
|
// };
|
|
|
|
ctx.body = {
|
|
|
|
code: 200,
|
|
|
|
message: 'success',
|
|
|
|
data: r[0]
|
|
|
|
};
|
|
|
|
|
|
|
|
// });
|
|
|
|
|
|
|
|
});
|
|
|
|
|
|
|
|
module.exports = r; |
...
|
...
|
|
