mirror of
https://github.com/YMFE/yapi.git
synced 2024-12-21 05:19:42 +08:00
1206 lines
52 KiB
JavaScript
1206 lines
52 KiB
JavaScript
'use strict';
|
||
|
||
var _stringify = require('babel-runtime/core-js/json/stringify');
|
||
|
||
var _stringify2 = _interopRequireDefault(_stringify);
|
||
|
||
var _regenerator = require('babel-runtime/regenerator');
|
||
|
||
var _regenerator2 = _interopRequireDefault(_regenerator);
|
||
|
||
var _asyncToGenerator2 = require('babel-runtime/helpers/asyncToGenerator');
|
||
|
||
var _asyncToGenerator3 = _interopRequireDefault(_asyncToGenerator2);
|
||
|
||
var _getPrototypeOf = require('babel-runtime/core-js/object/get-prototype-of');
|
||
|
||
var _getPrototypeOf2 = _interopRequireDefault(_getPrototypeOf);
|
||
|
||
var _classCallCheck2 = require('babel-runtime/helpers/classCallCheck');
|
||
|
||
var _classCallCheck3 = _interopRequireDefault(_classCallCheck2);
|
||
|
||
var _createClass2 = require('babel-runtime/helpers/createClass');
|
||
|
||
var _createClass3 = _interopRequireDefault(_createClass2);
|
||
|
||
var _possibleConstructorReturn2 = require('babel-runtime/helpers/possibleConstructorReturn');
|
||
|
||
var _possibleConstructorReturn3 = _interopRequireDefault(_possibleConstructorReturn2);
|
||
|
||
var _inherits2 = require('babel-runtime/helpers/inherits');
|
||
|
||
var _inherits3 = _interopRequireDefault(_inherits2);
|
||
|
||
var _interface = require('../models/interface.js');
|
||
|
||
var _interface2 = _interopRequireDefault(_interface);
|
||
|
||
var _interfaceCat = require('../models/interfaceCat.js');
|
||
|
||
var _interfaceCat2 = _interopRequireDefault(_interfaceCat);
|
||
|
||
var _interfaceCase = require('../models/interfaceCase.js');
|
||
|
||
var _interfaceCase2 = _interopRequireDefault(_interfaceCase);
|
||
|
||
var _underscore = require('underscore');
|
||
|
||
var _underscore2 = _interopRequireDefault(_underscore);
|
||
|
||
var _base = require('./base.js');
|
||
|
||
var _base2 = _interopRequireDefault(_base);
|
||
|
||
var _yapi = require('../yapi.js');
|
||
|
||
var _yapi2 = _interopRequireDefault(_yapi);
|
||
|
||
var _user = require('../models/user.js');
|
||
|
||
var _user2 = _interopRequireDefault(_user);
|
||
|
||
var _project = require('../models/project.js');
|
||
|
||
var _project2 = _interopRequireDefault(_project);
|
||
|
||
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
|
||
|
||
var interfaceController = function (_baseController) {
|
||
(0, _inherits3.default)(interfaceController, _baseController);
|
||
|
||
function interfaceController(ctx) {
|
||
(0, _classCallCheck3.default)(this, interfaceController);
|
||
|
||
var _this = (0, _possibleConstructorReturn3.default)(this, (interfaceController.__proto__ || (0, _getPrototypeOf2.default)(interfaceController)).call(this, ctx));
|
||
|
||
_this.Model = _yapi2.default.getInst(_interface2.default);
|
||
_this.catModel = _yapi2.default.getInst(_interfaceCat2.default);
|
||
_this.projectModel = _yapi2.default.getInst(_project2.default);
|
||
_this.caseModel = _yapi2.default.getInst(_interfaceCase2.default);
|
||
return _this;
|
||
}
|
||
|
||
/**
|
||
* 添加项目分组
|
||
* @interface /interface/add
|
||
* @method POST
|
||
* @category interface
|
||
* @foldnumber 10
|
||
* @param {Number} project_id 项目id，不能为空
|
||
* @param {String} title 接口标题，不能为空
|
||
* @param {String} path 接口请求路径，不能为空
|
||
* @param {String} method 请求方式
|
||
* @param {Array} [req_headers] 请求的header信息
|
||
* @param {String} [req_headers[].name] 请求的header信息名
|
||
* @param {String} [req_headers[].value] 请求的header信息值
|
||
* @param {Boolean} [req_headers[].required] 是否是必须，默认为否
|
||
* @param {String} [req_headers[].desc] header描述
|
||
* @param {String} [req_body_type] 请求参数方式，有["form", "json", "text", "xml"]四种
|
||
* @param {Array} [req_params] name, desc两个参数
|
||
* @param {Mixed} [req_body_form] 请求参数,如果请求方式是form，参数是Array数组，其他格式请求参数是字符串
|
||
* @param {String} [req_body_form[].name] 请求参数名
|
||
* @param {String} [req_body_form[].value] 请求参数值，可填写生成规则（mock）。如@email，随机生成一条email
|
||
* @param {String} [req_body_form[].type] 请求参数类型，有["text", "file"]两种
|
||
* @param {String} [req_body_other] 非form类型的请求参数可保存到此字段
|
||
* @param {String} [res_body_type] 相应信息的数据格式，有["json", "text", "xml"]三种
|
||
* @param {String} [res_body] 响应信息，可填写任意字符串，如果res_body_type是json,则会调用mock功能
|
||
* @param {String} [desc] 接口描述
|
||
* @returns {Object}
|
||
* @example ./api/interface/add.json
|
||
*/
|
||
|
||
|
||
(0, _createClass3.default)(interfaceController, [{
|
||
key: 'add',
|
||
value: function () {
|
||
var _ref = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee(ctx) {
|
||
var _this2 = this;
|
||
|
||
var params, auth, checkRepeat, data, paths, name, i, result;
|
||
return _regenerator2.default.wrap(function _callee$(_context) {
|
||
while (1) {
|
||
switch (_context.prev = _context.next) {
|
||
case 0:
|
||
params = ctx.request.body;
|
||
|
||
params = _yapi2.default.commons.handleParams(params, {
|
||
project_id: 'number',
|
||
title: 'string',
|
||
path: 'string',
|
||
method: 'string',
|
||
desc: 'string',
|
||
catid: 'number'
|
||
});
|
||
|
||
_context.next = 4;
|
||
return this.checkAuth(params.project_id, 'project', 'edit');
|
||
|
||
case 4:
|
||
auth = _context.sent;
|
||
|
||
if (auth) {
|
||
_context.next = 7;
|
||
break;
|
||
}
|
||
|
||
return _context.abrupt('return', ctx.body = _yapi2.default.commons.resReturn(null, 400, '没有权限'));
|
||
|
||
case 7:
|
||
params.method = params.method || 'GET';
|
||
params.method = params.method.toUpperCase();
|
||
params.req_params = params.req_params || [];
|
||
params.res_body_type = params.res_body_type ? params.res_body_type.toLowerCase() : 'json';
|
||
|
||
if (params.project_id) {
|
||
_context.next = 13;
|
||
break;
|
||
}
|
||
|
||
return _context.abrupt('return', ctx.body = _yapi2.default.commons.resReturn(null, 400, '项目id不能为空'));
|
||
|
||
case 13:
|
||
if (params.path) {
|
||
_context.next = 15;
|
||
break;
|
||
}
|
||
|
||
return _context.abrupt('return', ctx.body = _yapi2.default.commons.resReturn(null, 400, '接口请求路径不能为空'));
|
||
|
||
case 15:
|
||
if (_yapi2.default.commons.verifyPath(params.path)) {
|
||
_context.next = 17;
|
||
break;
|
||
}
|
||
|
||
return _context.abrupt('return', ctx.body = _yapi2.default.commons.resReturn(null, 400, '接口path第一位必须是/，最后一位不能为/'));
|
||
|
||
case 17:
|
||
_context.next = 19;
|
||
return this.Model.checkRepeat(params.project_id, params.path, params.method);
|
||
|
||
case 19:
|
||
checkRepeat = _context.sent;
|
||
|
||
if (!(checkRepeat > 0)) {
|
||
_context.next = 22;
|
||
break;
|
||
}
|
||
|
||
return _context.abrupt('return', ctx.body = _yapi2.default.commons.resReturn(null, 401, '已存在的接口:' + params.path + '[' + params.method + ']'));
|
||
|
||
case 22:
|
||
_context.prev = 22;
|
||
data = {
|
||
project_id: params.project_id,
|
||
catid: params.catid,
|
||
title: params.title,
|
||
path: params.path,
|
||
desc: params.desc,
|
||
method: params.method,
|
||
req_headers: params.req_headers,
|
||
req_body_type: params.req_body_type,
|
||
res_body: params.res_body,
|
||
res_body_type: params.res_body_type,
|
||
uid: this.getUid(),
|
||
add_time: _yapi2.default.commons.time(),
|
||
up_time: _yapi2.default.commons.time()
|
||
};
|
||
|
||
|
||
if (params.req_query) {
|
||
data.req_query = params.req_query;
|
||
}
|
||
|
||
if (params.req_body_form) {
|
||
data.req_body_form = params.req_body_form;
|
||
}
|
||
|
||
if (params.path.indexOf(":") > 0) {
|
||
paths = params.path.split("/"), name = void 0, i = void 0;
|
||
|
||
for (i = 1; i < paths.length; i++) {
|
||
if (paths[i][0] === ':') {
|
||
name = paths[i].substr(1);
|
||
if (!_underscore2.default.find(params.req_params, { name: name })) {
|
||
params.req_params.push({
|
||
name: name,
|
||
desc: ''
|
||
});
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
if (params.req_params.length > 0) {
|
||
data.type = 'var';
|
||
data.req_params = params.req_params;
|
||
} else {
|
||
data.type = 'static';
|
||
}
|
||
if (params.req_body_other) {
|
||
data.req_body_other = params.req_body_other;
|
||
}
|
||
|
||
_context.next = 31;
|
||
return this.Model.save(data);
|
||
|
||
case 31:
|
||
result = _context.sent;
|
||
|
||
|
||
// let project = await this.projectModel.get(params.project_id);
|
||
this.catModel.get(params.catid).then(function (cate) {
|
||
var username = _this2.getUsername();
|
||
_yapi2.default.commons.saveLog({
|
||
content: '\u7528\u6237 "' + username + '" \u4E3A\u5206\u7C7B "' + cate.name + '" \u6DFB\u52A0\u4E86\u63A5\u53E3 "' + data.title + '"',
|
||
type: 'project',
|
||
uid: _this2.getUid(),
|
||
username: username,
|
||
typeid: params.project_id
|
||
});
|
||
});
|
||
|
||
ctx.body = _yapi2.default.commons.resReturn(result);
|
||
_context.next = 39;
|
||
break;
|
||
|
||
case 36:
|
||
_context.prev = 36;
|
||
_context.t0 = _context['catch'](22);
|
||
|
||
ctx.body = _yapi2.default.commons.resReturn(null, 402, _context.t0.message);
|
||
|
||
case 39:
|
||
case 'end':
|
||
return _context.stop();
|
||
}
|
||
}
|
||
}, _callee, this, [[22, 36]]);
|
||
}));
|
||
|
||
function add(_x) {
|
||
return _ref.apply(this, arguments);
|
||
}
|
||
|
||
return add;
|
||
}()
|
||
|
||
/**
|
||
* 添加项目分组
|
||
* @interface /interface/get
|
||
* @method GET
|
||
* @category interface
|
||
* @foldnumber 10
|
||
* @param {Number} id 接口id，不能为空
|
||
* @returns {Object}
|
||
* @example ./api/interface/get.json
|
||
*/
|
||
|
||
}, {
|
||
key: 'get',
|
||
value: function () {
|
||
var _ref2 = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee2(ctx) {
|
||
var params, result;
|
||
return _regenerator2.default.wrap(function _callee2$(_context2) {
|
||
while (1) {
|
||
switch (_context2.prev = _context2.next) {
|
||
case 0:
|
||
params = ctx.request.query;
|
||
|
||
if (params.id) {
|
||
_context2.next = 3;
|
||
break;
|
||
}
|
||
|
||
return _context2.abrupt('return', ctx.body = _yapi2.default.commons.resReturn(null, 400, '接口id不能为空'));
|
||
|
||
case 3:
|
||
_context2.prev = 3;
|
||
_context2.next = 6;
|
||
return this.Model.get(params.id);
|
||
|
||
case 6:
|
||
result = _context2.sent;
|
||
|
||
ctx.body = _yapi2.default.commons.resReturn(result);
|
||
_context2.next = 13;
|
||
break;
|
||
|
||
case 10:
|
||
_context2.prev = 10;
|
||
_context2.t0 = _context2['catch'](3);
|
||
|
||
ctx.body = _yapi2.default.commons.resReturn(null, 402, _context2.t0.message);
|
||
|
||
case 13:
|
||
case 'end':
|
||
return _context2.stop();
|
||
}
|
||
}
|
||
}, _callee2, this, [[3, 10]]);
|
||
}));
|
||
|
||
function get(_x2) {
|
||
return _ref2.apply(this, arguments);
|
||
}
|
||
|
||
return get;
|
||
}()
|
||
|
||
/**
|
||
* 接口列表
|
||
* @interface /interface/list
|
||
* @method GET
|
||
* @category interface
|
||
* @foldnumber 10
|
||
* @param {Number} project_id 项目id，不能为空
|
||
* @returns {Object}
|
||
* @example ./api/interface/list.json
|
||
*/
|
||
|
||
}, {
|
||
key: 'list',
|
||
value: function () {
|
||
var _ref3 = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee3(ctx) {
|
||
var project_id, result;
|
||
return _regenerator2.default.wrap(function _callee3$(_context3) {
|
||
while (1) {
|
||
switch (_context3.prev = _context3.next) {
|
||
case 0:
|
||
project_id = ctx.request.query.project_id;
|
||
|
||
if (project_id) {
|
||
_context3.next = 3;
|
||
break;
|
||
}
|
||
|
||
return _context3.abrupt('return', ctx.body = _yapi2.default.commons.resReturn(null, 400, '项目id不能为空'));
|
||
|
||
case 3:
|
||
_context3.prev = 3;
|
||
_context3.next = 6;
|
||
return this.Model.list(project_id);
|
||
|
||
case 6:
|
||
result = _context3.sent;
|
||
|
||
ctx.body = _yapi2.default.commons.resReturn(result);
|
||
_context3.next = 13;
|
||
break;
|
||
|
||
case 10:
|
||
_context3.prev = 10;
|
||
_context3.t0 = _context3['catch'](3);
|
||
|
||
ctx.body = _yapi2.default.commons.resReturn(null, 402, _context3.t0.message);
|
||
|
||
case 13:
|
||
case 'end':
|
||
return _context3.stop();
|
||
}
|
||
}
|
||
}, _callee3, this, [[3, 10]]);
|
||
}));
|
||
|
||
function list(_x3) {
|
||
return _ref3.apply(this, arguments);
|
||
}
|
||
|
||
return list;
|
||
}()
|
||
}, {
|
||
key: 'listByCat',
|
||
value: function () {
|
||
var _ref4 = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee4(ctx) {
|
||
var catid, result;
|
||
return _regenerator2.default.wrap(function _callee4$(_context4) {
|
||
while (1) {
|
||
switch (_context4.prev = _context4.next) {
|
||
case 0:
|
||
catid = ctx.request.query.catid;
|
||
|
||
if (catid) {
|
||
_context4.next = 3;
|
||
break;
|
||
}
|
||
|
||
return _context4.abrupt('return', ctx.body = _yapi2.default.commons.resReturn(null, 400, 'catid不能为空'));
|
||
|
||
case 3:
|
||
_context4.prev = 3;
|
||
_context4.next = 6;
|
||
return this.Model.listByCatid(catid);
|
||
|
||
case 6:
|
||
result = _context4.sent;
|
||
|
||
ctx.body = _yapi2.default.commons.resReturn(result);
|
||
_context4.next = 13;
|
||
break;
|
||
|
||
case 10:
|
||
_context4.prev = 10;
|
||
_context4.t0 = _context4['catch'](3);
|
||
|
||
ctx.body = _yapi2.default.commons.resReturn(null, 402, _context4.t0.message);
|
||
|
||
case 13:
|
||
case 'end':
|
||
return _context4.stop();
|
||
}
|
||
}
|
||
}, _callee4, this, [[3, 10]]);
|
||
}));
|
||
|
||
function listByCat(_x4) {
|
||
return _ref4.apply(this, arguments);
|
||
}
|
||
|
||
return listByCat;
|
||
}()
|
||
}, {
|
||
key: 'listByMenu',
|
||
value: function () {
|
||
var _ref5 = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee5(ctx) {
|
||
var project_id, result, newResult, i, item, list, j;
|
||
return _regenerator2.default.wrap(function _callee5$(_context5) {
|
||
while (1) {
|
||
switch (_context5.prev = _context5.next) {
|
||
case 0:
|
||
project_id = ctx.request.query.project_id;
|
||
|
||
if (project_id) {
|
||
_context5.next = 3;
|
||
break;
|
||
}
|
||
|
||
return _context5.abrupt('return', ctx.body = _yapi2.default.commons.resReturn(null, 400, '项目id不能为空'));
|
||
|
||
case 3:
|
||
_context5.prev = 3;
|
||
_context5.next = 6;
|
||
return this.catModel.list(project_id);
|
||
|
||
case 6:
|
||
result = _context5.sent;
|
||
newResult = [];
|
||
i = 0;
|
||
|
||
case 9:
|
||
if (!(i < result.length)) {
|
||
_context5.next = 20;
|
||
break;
|
||
}
|
||
|
||
item = result[i].toObject();
|
||
_context5.next = 13;
|
||
return this.Model.listByCatid(item._id, '_id title method path');
|
||
|
||
case 13:
|
||
list = _context5.sent;
|
||
|
||
for (j = 0; j < list.length; j++) {
|
||
list[j] = list[j].toObject();
|
||
}
|
||
item.list = list;
|
||
newResult[i] = item;
|
||
|
||
case 17:
|
||
i++;
|
||
_context5.next = 9;
|
||
break;
|
||
|
||
case 20:
|
||
ctx.body = _yapi2.default.commons.resReturn(newResult);
|
||
_context5.next = 26;
|
||
break;
|
||
|
||
case 23:
|
||
_context5.prev = 23;
|
||
_context5.t0 = _context5['catch'](3);
|
||
|
||
ctx.body = _yapi2.default.commons.resReturn(null, 402, _context5.t0.message);
|
||
|
||
case 26:
|
||
case 'end':
|
||
return _context5.stop();
|
||
}
|
||
}
|
||
}, _callee5, this, [[3, 23]]);
|
||
}));
|
||
|
||
function listByMenu(_x5) {
|
||
return _ref5.apply(this, arguments);
|
||
}
|
||
|
||
return listByMenu;
|
||
}()
|
||
|
||
/**
|
||
* 编辑接口
|
||
* @interface /interface/up
|
||
* @method POST
|
||
* @category interface
|
||
* @foldnumber 10
|
||
* @param {Number} id 接口id，不能为空
|
||
* @param {String} [path] 接口请求路径
|
||
* @param {String} [method] 请求方式
|
||
* @param {Array} [req_headers] 请求的header信息
|
||
* @param {String} [req_headers[].name] 请求的header信息名
|
||
* @param {String} [req_headers[].value] 请求的header信息值
|
||
* @param {Boolean} [req_headers[].required] 是否是必须，默认为否
|
||
* @param {String} [req_headers[].desc] header描述
|
||
* @param {String} [req_body_type] 请求参数方式，有["form", "json", "text", "xml"]四种
|
||
* @param {Mixed} [req_body_form] 请求参数,如果请求方式是form，参数是Array数组，其他格式请求参数是字符串
|
||
* @param {String} [req_body_form[].name] 请求参数名
|
||
* @param {String} [req_body_form[].value] 请求参数值，可填写生成规则（mock）。如@email，随机生成一条email
|
||
* @param {String} [req_body_form[].type] 请求参数类型，有["text", "file"]两种
|
||
* @param {String} [req_body_other] 非form类型的请求参数可保存到此字段
|
||
* @param {String} [res_body_type] 相应信息的数据格式，有["json", "text", "xml"]三种
|
||
* @param {String} [res_body] 响应信息，可填写任意字符串，如果res_body_type是json,则会调用mock功能
|
||
* @param {String} [desc] 接口描述
|
||
* @returns {Object}
|
||
* @example ./api/interface/up.json
|
||
*/
|
||
|
||
}, {
|
||
key: 'up',
|
||
value: function () {
|
||
var _ref6 = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee6(ctx) {
|
||
var _this3 = this;
|
||
|
||
var params, id, interfaceData, auth, checkRepeat, data, result, username, cateid;
|
||
return _regenerator2.default.wrap(function _callee6$(_context6) {
|
||
while (1) {
|
||
switch (_context6.prev = _context6.next) {
|
||
case 0:
|
||
params = ctx.request.body;
|
||
|
||
params = _yapi2.default.commons.handleParams(params, {
|
||
title: 'string',
|
||
path: 'string',
|
||
method: 'string',
|
||
desc: 'string',
|
||
catid: 'number'
|
||
});
|
||
|
||
params.method = params.method || 'GET';
|
||
params.method = params.method.toUpperCase();
|
||
|
||
id = ctx.request.body.id;
|
||
|
||
if (id) {
|
||
_context6.next = 7;
|
||
break;
|
||
}
|
||
|
||
return _context6.abrupt('return', ctx.body = _yapi2.default.commons.resReturn(null, 400, '接口id不能为空'));
|
||
|
||
case 7:
|
||
_context6.next = 9;
|
||
return this.Model.get(id);
|
||
|
||
case 9:
|
||
interfaceData = _context6.sent;
|
||
_context6.next = 12;
|
||
return this.checkAuth(interfaceData.project_id, 'project', 'edit');
|
||
|
||
case 12:
|
||
auth = _context6.sent;
|
||
|
||
if (auth) {
|
||
_context6.next = 15;
|
||
break;
|
||
}
|
||
|
||
return _context6.abrupt('return', ctx.body = _yapi2.default.commons.resReturn(null, 400, '没有权限'));
|
||
|
||
case 15:
|
||
if (!(params.path && !_yapi2.default.commons.verifyPath(params.path))) {
|
||
_context6.next = 17;
|
||
break;
|
||
}
|
||
|
||
return _context6.abrupt('return', ctx.body = _yapi2.default.commons.resReturn(null, 400, '接口path第一位必须是/，最后一位不能为/'));
|
||
|
||
case 17:
|
||
if (!(params.path && (params.path !== interfaceData.path || params.method !== interfaceData.method))) {
|
||
_context6.next = 23;
|
||
break;
|
||
}
|
||
|
||
_context6.next = 20;
|
||
return this.Model.checkRepeat(interfaceData.project_id, params.path, params.method);
|
||
|
||
case 20:
|
||
checkRepeat = _context6.sent;
|
||
|
||
if (!(checkRepeat > 0)) {
|
||
_context6.next = 23;
|
||
break;
|
||
}
|
||
|
||
return _context6.abrupt('return', ctx.body = _yapi2.default.commons.resReturn(null, 401, '已存在的接口:' + params.path + '[' + params.method + ']'));
|
||
|
||
case 23:
|
||
data = {
|
||
up_time: _yapi2.default.commons.time()
|
||
};
|
||
|
||
|
||
if (!_underscore2.default.isUndefined(params.path)) {
|
||
data.path = params.path;
|
||
}
|
||
if (!_underscore2.default.isUndefined(params.title)) {
|
||
data.title = params.title;
|
||
}
|
||
if (!_underscore2.default.isUndefined(params.desc)) {
|
||
data.desc = params.desc;
|
||
}
|
||
if (!_underscore2.default.isUndefined(params.method)) {
|
||
data.method = params.method;
|
||
}
|
||
|
||
if (!_underscore2.default.isUndefined(params.catid)) {
|
||
data.catid = params.catid;
|
||
}
|
||
|
||
if (!_underscore2.default.isUndefined(params.req_headers)) {
|
||
data.req_headers = params.req_headers;
|
||
}
|
||
|
||
if (!_underscore2.default.isUndefined(params.req_body_form)) {
|
||
data.req_body_form = params.req_body_form;
|
||
}
|
||
if (params.req_params && Array.isArray(params.req_params) && params.req_params.length > 0) {
|
||
data.type = 'var';
|
||
data.req_params = params.req_params;
|
||
} else {
|
||
data.type = 'static';
|
||
}
|
||
|
||
if (!_underscore2.default.isUndefined(params.req_query)) {
|
||
data.req_query = params.req_query;
|
||
}
|
||
if (!_underscore2.default.isUndefined(params.req_body_other)) {
|
||
data.req_body_other = params.req_body_other;
|
||
}
|
||
|
||
if (!_underscore2.default.isUndefined(params.req_body_type)) {
|
||
data.req_body_type = params.req_body_type;
|
||
}
|
||
|
||
if (!_underscore2.default.isUndefined(params.res_body_type)) {
|
||
data.res_body_type = params.res_body_type;
|
||
}
|
||
if (!_underscore2.default.isUndefined(params.res_body)) {
|
||
data.res_body = params.res_body;
|
||
}
|
||
|
||
if (!_underscore2.default.isUndefined(params.status)) {
|
||
data.status = params.status;
|
||
}
|
||
|
||
_context6.prev = 38;
|
||
_context6.next = 41;
|
||
return this.Model.up(id, data);
|
||
|
||
case 41:
|
||
result = _context6.sent;
|
||
username = this.getUsername();
|
||
|
||
if (params.catid) {
|
||
this.catModel.get(+params.catid).then(function (cate) {
|
||
_yapi2.default.commons.saveLog({
|
||
content: '\u7528\u6237 "' + username + '" \u66F4\u65B0\u4E86\u5206\u7C7B "' + cate.name + '" \u4E0B\u7684\u63A5\u53E3 "' + data.title + '"',
|
||
type: 'project',
|
||
uid: _this3.getUid(),
|
||
username: username,
|
||
typeid: cate.project_id
|
||
});
|
||
});
|
||
} else {
|
||
cateid = interfaceData.catid;
|
||
|
||
this.catModel.get(cateid).then(function (cate) {
|
||
_yapi2.default.commons.saveLog({
|
||
content: '\u7528\u6237 "' + username + '" \u66F4\u65B0\u4E86\u5206\u7C7B "' + cate.name + '" \u4E0B\u7684\u63A5\u53E3 "' + data.title + '"',
|
||
type: 'project',
|
||
uid: _this3.getUid(),
|
||
username: username,
|
||
typeid: cate.project_id
|
||
});
|
||
});
|
||
}
|
||
|
||
ctx.body = _yapi2.default.commons.resReturn(result);
|
||
_context6.next = 50;
|
||
break;
|
||
|
||
case 47:
|
||
_context6.prev = 47;
|
||
_context6.t0 = _context6['catch'](38);
|
||
|
||
ctx.body = _yapi2.default.commons.resReturn(null, 402, _context6.t0.message);
|
||
|
||
case 50:
|
||
case 'end':
|
||
return _context6.stop();
|
||
}
|
||
}
|
||
}, _callee6, this, [[38, 47]]);
|
||
}));
|
||
|
||
function up(_x6) {
|
||
return _ref6.apply(this, arguments);
|
||
}
|
||
|
||
return up;
|
||
}()
|
||
|
||
/**
|
||
* 删除接口
|
||
* @interface /interface/del
|
||
* @method GET
|
||
* @category interface
|
||
* @foldnumber 10
|
||
* @param {Number} id 接口id，不能为空
|
||
* @returns {Object}
|
||
* @example ./api/interface/del.json
|
||
*/
|
||
|
||
}, {
|
||
key: 'del',
|
||
value: function () {
|
||
var _ref7 = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee7(ctx) {
|
||
var _this4 = this;
|
||
|
||
var id, data, auth, inter, result, username;
|
||
return _regenerator2.default.wrap(function _callee7$(_context7) {
|
||
while (1) {
|
||
switch (_context7.prev = _context7.next) {
|
||
case 0:
|
||
_context7.prev = 0;
|
||
id = ctx.request.body.id;
|
||
|
||
if (id) {
|
||
_context7.next = 4;
|
||
break;
|
||
}
|
||
|
||
return _context7.abrupt('return', ctx.body = _yapi2.default.commons.resReturn(null, 400, '接口id不能为空'));
|
||
|
||
case 4:
|
||
_context7.next = 6;
|
||
return this.Model.get(ctx.request.body.id);
|
||
|
||
case 6:
|
||
data = _context7.sent;
|
||
|
||
if (!(data.uid != this.getUid())) {
|
||
_context7.next = 13;
|
||
break;
|
||
}
|
||
|
||
_context7.next = 10;
|
||
return this.checkAuth(data.project_id, 'project', 'danger');
|
||
|
||
case 10:
|
||
auth = _context7.sent;
|
||
|
||
if (auth) {
|
||
_context7.next = 13;
|
||
break;
|
||
}
|
||
|
||
return _context7.abrupt('return', ctx.body = _yapi2.default.commons.resReturn(null, 400, '没有权限'));
|
||
|
||
case 13:
|
||
_context7.next = 15;
|
||
return this.Model.get(id);
|
||
|
||
case 15:
|
||
inter = _context7.sent;
|
||
_context7.next = 18;
|
||
return this.Model.del(id);
|
||
|
||
case 18:
|
||
result = _context7.sent;
|
||
_context7.next = 21;
|
||
return this.caseModel.delByInterfaceId(id);
|
||
|
||
case 21:
|
||
username = this.getUsername();
|
||
|
||
this.catModel.get(inter.catid).then(function (cate) {
|
||
_yapi2.default.commons.saveLog({
|
||
content: '\u7528\u6237 "' + username + '" \u5220\u9664\u4E86\u5206\u7C7B "' + cate.name + '" \u4E0B\u7684\u63A5\u53E3 "' + inter.title + '"',
|
||
type: 'project',
|
||
uid: _this4.getUid(),
|
||
username: username,
|
||
typeid: cate.project_id
|
||
});
|
||
});
|
||
|
||
ctx.body = _yapi2.default.commons.resReturn(result);
|
||
_context7.next = 29;
|
||
break;
|
||
|
||
case 26:
|
||
_context7.prev = 26;
|
||
_context7.t0 = _context7['catch'](0);
|
||
|
||
ctx.body = _yapi2.default.commons.resReturn(null, 402, _context7.t0.message);
|
||
|
||
case 29:
|
||
case 'end':
|
||
return _context7.stop();
|
||
}
|
||
}
|
||
}, _callee7, this, [[0, 26]]);
|
||
}));
|
||
|
||
function del(_x7) {
|
||
return _ref7.apply(this, arguments);
|
||
}
|
||
|
||
return del;
|
||
}()
|
||
}, {
|
||
key: 'solveConflict',
|
||
value: function () {
|
||
var _ref8 = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee8(ctx) {
|
||
var _this5 = this;
|
||
|
||
var id, result, userInst, userinfo, data;
|
||
return _regenerator2.default.wrap(function _callee8$(_context8) {
|
||
while (1) {
|
||
switch (_context8.prev = _context8.next) {
|
||
case 0:
|
||
_context8.prev = 0;
|
||
id = parseInt(ctx.query.id, 10), result = void 0, userInst = void 0, userinfo = void 0, data = void 0;
|
||
|
||
if (id) {
|
||
_context8.next = 4;
|
||
break;
|
||
}
|
||
|
||
return _context8.abrupt('return', ctx.websocket.send("id 参数有误"));
|
||
|
||
case 4:
|
||
_context8.next = 6;
|
||
return this.Model.get(id);
|
||
|
||
case 6:
|
||
result = _context8.sent;
|
||
userinfo;
|
||
|
||
if (!(result.edit_uid !== 0 && result.edit_uid !== this.getUid())) {
|
||
_context8.next = 16;
|
||
break;
|
||
}
|
||
|
||
userInst = _yapi2.default.getInst(_user2.default);
|
||
_context8.next = 12;
|
||
return userInst.findById(result.edit_uid);
|
||
|
||
case 12:
|
||
userinfo = _context8.sent;
|
||
|
||
data = {
|
||
errno: result.edit_uid,
|
||
data: { uid: result.edit_uid, username: userinfo.username }
|
||
};
|
||
_context8.next = 18;
|
||
break;
|
||
|
||
case 16:
|
||
this.Model.upEditUid(id, this.getUid()).then();
|
||
data = {
|
||
errno: 0,
|
||
data: result
|
||
};
|
||
|
||
case 18:
|
||
ctx.websocket.send((0, _stringify2.default)(data));
|
||
ctx.websocket.on('close', function () {
|
||
_this5.Model.upEditUid(id, 0).then();
|
||
});
|
||
_context8.next = 25;
|
||
break;
|
||
|
||
case 22:
|
||
_context8.prev = 22;
|
||
_context8.t0 = _context8['catch'](0);
|
||
|
||
_yapi2.default.commons.log(_context8.t0, 'error');
|
||
|
||
case 25:
|
||
case 'end':
|
||
return _context8.stop();
|
||
}
|
||
}
|
||
}, _callee8, this, [[0, 22]]);
|
||
}));
|
||
|
||
function solveConflict(_x8) {
|
||
return _ref8.apply(this, arguments);
|
||
}
|
||
|
||
return solveConflict;
|
||
}()
|
||
}, {
|
||
key: 'addCat',
|
||
value: function () {
|
||
var _ref9 = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee9(ctx) {
|
||
var params, auth, result, username;
|
||
return _regenerator2.default.wrap(function _callee9$(_context9) {
|
||
while (1) {
|
||
switch (_context9.prev = _context9.next) {
|
||
case 0:
|
||
_context9.prev = 0;
|
||
params = ctx.request.body;
|
||
|
||
params = _yapi2.default.commons.handleParams(params, {
|
||
name: 'string',
|
||
project_id: 'number',
|
||
desc: 'string'
|
||
});
|
||
|
||
if (params.project_id) {
|
||
_context9.next = 5;
|
||
break;
|
||
}
|
||
|
||
return _context9.abrupt('return', ctx.body = _yapi2.default.commons.resReturn(null, 400, '项目id不能为空'));
|
||
|
||
case 5:
|
||
_context9.next = 7;
|
||
return this.checkAuth(params.project_id, 'project', 'edit');
|
||
|
||
case 7:
|
||
auth = _context9.sent;
|
||
|
||
if (auth) {
|
||
_context9.next = 10;
|
||
break;
|
||
}
|
||
|
||
return _context9.abrupt('return', ctx.body = _yapi2.default.commons.resReturn(null, 400, '没有权限'));
|
||
|
||
case 10:
|
||
if (params.name) {
|
||
_context9.next = 12;
|
||
break;
|
||
}
|
||
|
||
return _context9.abrupt('return', ctx.body = _yapi2.default.commons.resReturn(null, 400, '名称不能为空'));
|
||
|
||
case 12:
|
||
_context9.next = 14;
|
||
return this.catModel.save({
|
||
name: params.name,
|
||
project_id: params.project_id,
|
||
desc: params.desc,
|
||
uid: this.getUid(),
|
||
add_time: _yapi2.default.commons.time(),
|
||
up_time: _yapi2.default.commons.time()
|
||
});
|
||
|
||
case 14:
|
||
result = _context9.sent;
|
||
username = this.getUsername();
|
||
|
||
_yapi2.default.commons.saveLog({
|
||
content: '\u7528\u6237 "' + username + '" \u6DFB\u52A0\u4E86\u5206\u7C7B "' + params.name + '"',
|
||
type: 'project',
|
||
uid: this.getUid(),
|
||
username: username,
|
||
typeid: params.project_id
|
||
});
|
||
|
||
ctx.body = _yapi2.default.commons.resReturn(result);
|
||
|
||
_context9.next = 23;
|
||
break;
|
||
|
||
case 20:
|
||
_context9.prev = 20;
|
||
_context9.t0 = _context9['catch'](0);
|
||
|
||
ctx.body = _yapi2.default.commons.resReturn(null, 402, _context9.t0.message);
|
||
|
||
case 23:
|
||
case 'end':
|
||
return _context9.stop();
|
||
}
|
||
}
|
||
}, _callee9, this, [[0, 20]]);
|
||
}));
|
||
|
||
function addCat(_x9) {
|
||
return _ref9.apply(this, arguments);
|
||
}
|
||
|
||
return addCat;
|
||
}()
|
||
}, {
|
||
key: 'upCat',
|
||
value: function () {
|
||
var _ref10 = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee10(ctx) {
|
||
var params, result, username, cate, auth;
|
||
return _regenerator2.default.wrap(function _callee10$(_context10) {
|
||
while (1) {
|
||
switch (_context10.prev = _context10.next) {
|
||
case 0:
|
||
_context10.prev = 0;
|
||
params = ctx.request.body;
|
||
_context10.next = 4;
|
||
return this.catModel.up(params.catid, {
|
||
name: params.name,
|
||
desc: params.desc,
|
||
up_time: _yapi2.default.commons.time()
|
||
});
|
||
|
||
case 4:
|
||
result = _context10.sent;
|
||
username = this.getUsername();
|
||
_context10.next = 8;
|
||
return this.catModel.get(params.catid);
|
||
|
||
case 8:
|
||
cate = _context10.sent;
|
||
_context10.next = 11;
|
||
return this.checkAuth(cate.project_id, 'project', 'edit');
|
||
|
||
case 11:
|
||
auth = _context10.sent;
|
||
|
||
if (auth) {
|
||
_context10.next = 14;
|
||
break;
|
||
}
|
||
|
||
return _context10.abrupt('return', ctx.body = _yapi2.default.commons.resReturn(null, 400, '没有权限'));
|
||
|
||
case 14:
|
||
_yapi2.default.commons.saveLog({
|
||
content: '\u7528\u6237 "' + username + '" \u66F4\u65B0\u4E86\u5206\u7C7B "' + cate.name + '"',
|
||
type: 'project',
|
||
uid: this.getUid(),
|
||
username: username,
|
||
typeid: cate.project_id
|
||
});
|
||
|
||
ctx.body = _yapi2.default.commons.resReturn(result);
|
||
_context10.next = 21;
|
||
break;
|
||
|
||
case 18:
|
||
_context10.prev = 18;
|
||
_context10.t0 = _context10['catch'](0);
|
||
|
||
ctx.body = _yapi2.default.commons.resReturn(null, 400, _context10.t0.message);
|
||
|
||
case 21:
|
||
case 'end':
|
||
return _context10.stop();
|
||
}
|
||
}
|
||
}, _callee10, this, [[0, 18]]);
|
||
}));
|
||
|
||
function upCat(_x10) {
|
||
return _ref10.apply(this, arguments);
|
||
}
|
||
|
||
return upCat;
|
||
}()
|
||
}, {
|
||
key: 'delCat',
|
||
value: function () {
|
||
var _ref11 = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee11(ctx) {
|
||
var id, catData, auth, username, result, r;
|
||
return _regenerator2.default.wrap(function _callee11$(_context11) {
|
||
while (1) {
|
||
switch (_context11.prev = _context11.next) {
|
||
case 0:
|
||
_context11.prev = 0;
|
||
id = ctx.request.body.catid;
|
||
_context11.next = 4;
|
||
return this.catModel.get(id);
|
||
|
||
case 4:
|
||
catData = _context11.sent;
|
||
|
||
if (!catData) {
|
||
ctx.body = _yapi2.default.commons.resReturn(null, 400, "不存在的分类");
|
||
}
|
||
|
||
if (!(catData.uid !== this.getUid())) {
|
||
_context11.next = 12;
|
||
break;
|
||
}
|
||
|
||
_context11.next = 9;
|
||
return this.checkAuth(catData.project_id, 'project', 'danger');
|
||
|
||
case 9:
|
||
auth = _context11.sent;
|
||
|
||
if (auth) {
|
||
_context11.next = 12;
|
||
break;
|
||
}
|
||
|
||
return _context11.abrupt('return', ctx.body = _yapi2.default.commons.resReturn(null, 400, '没有权限'));
|
||
|
||
case 12:
|
||
username = this.getUsername();
|
||
|
||
_yapi2.default.commons.saveLog({
|
||
content: '\u7528\u6237 "' + username + '" \u5220\u9664\u4E86\u5206\u7C7B "' + catData.name + '" \u53CA\u8BE5\u5206\u7C7B\u4E0B\u7684\u63A5\u53E3',
|
||
type: 'project',
|
||
uid: this.getUid(),
|
||
username: username,
|
||
typeid: catData.project_id
|
||
});
|
||
|
||
_context11.next = 16;
|
||
return this.catModel.del(id);
|
||
|
||
case 16:
|
||
result = _context11.sent;
|
||
_context11.next = 19;
|
||
return this.Model.delByCatid(id);
|
||
|
||
case 19:
|
||
r = _context11.sent;
|
||
return _context11.abrupt('return', ctx.body = _yapi2.default.commons.resReturn(r));
|
||
|
||
case 23:
|
||
_context11.prev = 23;
|
||
_context11.t0 = _context11['catch'](0);
|
||
|
||
_yapi2.default.commons.resReturn(null, 400, _context11.t0.message);
|
||
|
||
case 26:
|
||
case 'end':
|
||
return _context11.stop();
|
||
}
|
||
}
|
||
}, _callee11, this, [[0, 23]]);
|
||
}));
|
||
|
||
function delCat(_x11) {
|
||
return _ref11.apply(this, arguments);
|
||
}
|
||
|
||
return delCat;
|
||
}()
|
||
}]);
|
||
return interfaceController;
|
||
}(_base2.default);
|
||
|
||
module.exports = interfaceController; |