可以支持 waitSeconds 方便调试

This commit is contained in:
liaoxuezhi 2019-10-31 15:39:32 +08:00
parent 7733b89e1c
commit 08687872fa
1 changed files with 81 additions and 65 deletions

View File

@ -6,7 +6,7 @@ module.exports = function(req, res) {
if (pathname === 'sample' && (req.method === 'POST' || req.method === 'PUT')) {
return store(req, res);
} else if (/sample\/(\d+(?:,\d+)*)?$/.test(pathname)) {
if ((req.method === 'POST' || req.method === 'PUT')) {
if (req.method === 'POST' || req.method === 'PUT') {
return update(req, res, RegExp.$1);
} else if (req.method === 'DELETE') {
return del(req, res, RegExp.$1);
@ -18,8 +18,7 @@ module.exports = function(req, res) {
}
return index(req, res);
}
};
function index(req, res) {
const perPage = parseInt(req.query.perPage, 10);
@ -43,7 +42,7 @@ function index(req, res) {
if (req.query.orderBy) {
const field = req.query.orderBy;
const direction = req.query.orderDir === 'desc' ? -1 : 1;
items = items.sort(function (a, b) {
items = items.sort(function(a, b) {
a = String(a[field]);
b = String(b[field]);
@ -57,20 +56,27 @@ function index(req, res) {
});
}
return res.json({
let response = () =>
res.json({
status: 0,
msg: 'ok',
data: {
count: items.length,
rows: perPage ? items.splice((page -1) * perPage, perPage) : items.concat()
rows: perPage ? items.splice((page - 1) * perPage, perPage) : items.concat()
}
});
if (req.query.waitSeconds) {
return setTimeout(response, parseInt(req.query.waitSeconds, 10) * 1000);
}
return response();
}
function store(req, res) {
const data = Object.assign({}, req.body);
data.id = DB.length ? (DB[DB.length - 1].id + 1) : 1;
data.id = DB.length ? DB[DB.length - 1].id + 1 : 1;
DB.push(data);
@ -83,8 +89,9 @@ function store(req, res) {
function update(req, res, id) {
const ids = id.split(',');
if (!ids.every(function(id) {
const idx = DB.findIndex(function (item) {
if (
!ids.every(function(id) {
const idx = DB.findIndex(function(item) {
return item.id == id;
});
@ -96,7 +103,8 @@ function update(req, res, id) {
item.id = id;
DB.splice(idx, 1, item);
return true;
})) {
})
) {
return res.json({
status: 404,
msg: '保存失败,数据可能已被删除!'
@ -113,8 +121,9 @@ function del(req, res, id) {
const ids = id.split(',');
console.log(ids);
if (!ids.every(function(id) {
const idx = DB.findIndex(function (item) {
if (
!ids.every(function(id) {
const idx = DB.findIndex(function(item) {
return item.id == id;
});
@ -124,7 +133,8 @@ function del(req, res, id) {
DB.splice(idx, 1);
return true;
})) {
})
) {
return res.json({
status: 404,
msg: '保存失败,数据可能已被删除!'
@ -140,8 +150,10 @@ function del(req, res, id) {
function bulkUpdate(req, res) {
const rowDiff = req.body.rowsDiff;
const ids = req.body.ids ? req.body.ids.split(',') : [];
if (!ids.length || !ids.every(function(id, index) {
const idx = DB.findIndex(function (item) {
if (
!ids.length ||
!ids.every(function(id, index) {
const idx = DB.findIndex(function(item) {
return item.id == id;
});
@ -153,7 +165,8 @@ function bulkUpdate(req, res) {
item.id = id;
DB.splice(idx, 1, item);
return true;
})) {
})
) {
return res.json({
status: 404,
msg: '保存失败,数据可能已被删除!'
@ -172,8 +185,10 @@ function bulkUpdate2(req, res) {
delete data.ids;
const ids = req.body.ids ? req.body.ids.split(',') : [];
if (!ids.length || !ids.every(function(id, index) {
const idx = DB.findIndex(function (item) {
if (
!ids.length ||
!ids.every(function(id, index) {
const idx = DB.findIndex(function(item) {
return item.id == id;
});
@ -185,7 +200,8 @@ function bulkUpdate2(req, res) {
item.id = id;
DB.splice(idx, 1, item);
return true;
})) {
})
) {
return res.json({
status: 404,
msg: '保存失败,数据可能已被删除!'