|
|
|
'use strict';
|
|
|
|
|
|
|
|
const schedule = require('node-schedule');
|
|
|
|
const Router = require('koa-router');
|
|
|
|
const moment = require('moment');
|
|
|
|
const Check = require('../../ci/checkcode');
|
|
|
|
|
|
|
|
const {
|
|
|
|
Project
|
|
|
|
Project,
|
|
|
|
Checklist,
|
|
|
|
Checklogs
|
|
|
|
} = require('../../models');
|
|
|
|
|
|
|
|
const router = new Router();
|
|
|
|
|
|
|
|
router.get('/list', async(ctx) => {
|
|
|
|
await ctx.render('action/checklist');
|
|
|
|
});
|
|
|
|
|
|
|
|
router.post('/list/query', async(ctx) => {
|
|
|
|
let q = ctx.request.body;
|
|
|
|
let start = parseInt(q.start || 0, 10);
|
|
|
|
let length = parseInt(q.length || 10, 10);
|
|
|
|
let draw = parseInt(q.draw, 10);
|
|
|
|
|
|
|
|
let sort = {buildtime: -1};
|
|
|
|
if (q.order && q.order.length > 0) {
|
|
|
|
let col = q.order[0].column;
|
|
|
|
let dir = q.order[0].dir === 'desc' ? -1 : 1;
|
|
|
|
|
|
|
|
col = parseInt(col, 10);
|
|
|
|
if (q.columns && q.columns.length > col) {
|
|
|
|
sort = {};
|
|
|
|
sort[q.columns[col].data] = dir;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
let logs = await Checklist.cfind({}).sort(sort).skip(start).limit(length).exec();
|
|
|
|
let total = await Checklist.count();
|
|
|
|
|
|
|
|
logs.forEach(l => {
|
|
|
|
l.buildtime = moment(Number(l.buildtime)).format('YYYY-MM-DD HH:mm:ss');
|
|
|
|
});
|
|
|
|
|
|
|
|
ctx.body = {
|
|
|
|
draw: draw,
|
|
|
|
recordsTotal: total,
|
|
|
|
recordsFiltered: total,
|
|
|
|
data: logs
|
|
|
|
};
|
|
|
|
});
|
|
|
|
|
|
|
|
router.get('/log', async(ctx) => {
|
|
|
|
await ctx.render('action/checklog');
|
|
|
|
});
|
|
|
|
|
|
|
|
router.post('/log/query', async(ctx) => {
|
|
|
|
let q = ctx.request.body;
|
|
|
|
let data;
|
|
|
|
if (!q.id) {
|
|
|
|
data = "未找到相应id的数据";
|
|
|
|
} else {
|
|
|
|
data = await Checklogs.findById(q.id);
|
|
|
|
data = (data || {}).text;
|
|
|
|
}
|
|
|
|
|
|
|
|
ctx.body = {
|
|
|
|
data: data
|
|
|
|
}
|
|
|
|
});
|
|
|
|
|
|
|
|
router.post('/exec', async(ctx) => {
|
|
|
|
let q = ctx.request.body;
|
|
|
|
|
|
|
|
if (!q.name || !q.branch) {
|
|
|
|
ctx.body = {
|
|
|
|
msg: "请输入正确的项目名及分支名"
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
let project = await Project.findByName(q.name);
|
|
|
|
|
|
|
|
new Check(project.name, project.gitlab, q.branch).check();
|
|
|
|
ctx.body = {
|
|
|
|
code: 200
|
|
|
|
}
|
|
|
|
}
|
|
|
|
});
|
|
|
|
|
|
|
|
module.exports = {
|
|
|
|
router,
|
|
|
|
async check() {
|
|
|
|
let rule = new schedule.RecurrenceRule();
|
|
|
|
|
|
|
|
// rule.dayOfWeek = [0, new schedule.Range(1, 6)];
|
|
|
|
// rule.hour = 23;
|
|
|
|
// rule.minute = 59;
|
|
|
|
// schedule.scheduleJob(rule, function() {
|
|
|
|
// console.log("执行任务");
|
|
|
|
|
|
|
|
// let projects = await Project.findAll();
|
|
|
|
// if (!projects || !projects.length) {
|
|
|
|
// return;
|
|
|
|
// }
|
|
|
|
|
|
|
|
// projects.forEach(async(p) => {
|
|
|
|
// if( p.name !== 'yohobuywap-node') {
|
|
|
|
// return;
|
|
|
|
// }
|
|
|
|
|
|
|
|
// //new Check(p.gitlab, 'master').check();
|
|
|
|
// new Check(p.gitlab, 'feature/checkcode').check();
|
|
|
|
// });
|
|
|
|
// });
|
|
|
|
console.log("执行任务");
|
|
|
|
|
|
|
|
let projects = await Project.findAll();
|
|
|
|
if (!projects || !projects.length) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
let projects = await Project.findAll();
|
|
|
|
if (!projects || !projects.length) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
rule.dayOfWeek = [0, new schedule.Range(1, 6)];
|
|
|
|
rule.hour = 23;
|
|
|
|
rule.minute = 59;
|
|
|
|
schedule.scheduleJob(rule, function() {
|
|
|
|
projects.forEach(async(p) => {
|
|
|
|
if(p.name !== 'yohobuywap-node') {
|
|
|
|
if (p.name !== 'yohobuywap-node') { // todo 暂时只检查wap站
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
//new Check(p.name, p.gitlab, 'master').check();
|
|
|
|
new Check(p.name, p.gitlab, 'feature/checkcode').check();
|
|
|
|
new Check(p.name, p.gitlab, 'master').check();
|
|
|
|
});
|
|
|
|
}
|
|
|
|
});
|
|
|
|
},
|
|
|
|
}; |
|
|
\ No newline at end of file |
...
|
...
|
|
