login_controller.js 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279
  1. /**
  2. * 登录页面控制器
  3. *
  4. * @author CaiAoLin
  5. * @date 2017/6/1
  6. * @version
  7. */
  8. import BaseController from "../../common/base/base_controller";
  9. import ManagerModel from "../models/manager_model";
  10. import PermissionModel from "../models/permission_model";
  11. import PermissionGroupModel from "../models/permission_group_model";
  12. import crypto from "crypto";
  13. import Test1Model from "../../../test/models/test1_model";
  14. import Test2Model from "../../../test/models/test2_model";
  15. import Test3Model from "../../../test/models/test3_model";
  16. class LoginController extends BaseController {
  17. /**
  18. * 登录页面
  19. *
  20. * @param {object} request
  21. * @param {object} response
  22. * @return {void|Mixed}
  23. */
  24. index(request, response) {
  25. let renderData = {
  26. layout: false,
  27. };
  28. let managerSessionData = request.session.managerData;
  29. if (managerSessionData !== undefined) {
  30. return response.redirect("/dashboard");
  31. }
  32. response.render('users/views/login/index', renderData);
  33. }
  34. /**
  35. * 登录操作
  36. *
  37. * @param {object} request
  38. * @param {object} response
  39. * @return {string}
  40. */
  41. async login(request, response) {
  42. let username = request.body.username;
  43. let password = request.body.password;
  44. let managerModel = new ManagerModel();
  45. let permissionModel = new PermissionModel();
  46. let permissionGroupModel = new PermissionGroupModel();
  47. let responseData = {
  48. error: 0,
  49. msg: ''
  50. };
  51. try {
  52. let managerData = await managerModel.validLogin(username, password);
  53. // 成功后写入session
  54. let currentTime = new Date().getTime();
  55. let sessionToken = crypto.createHmac('sha1', currentTime + '').update(managerData.username)
  56. .digest().toString('base64');
  57. // 对权限进行管理分类
  58. let menuData = {
  59. 'dashboard': {
  60. title: '首页',
  61. url: '/dashboard',
  62. name: 'dashboard',
  63. iconClass: 'glyphicon glyphicon-home'
  64. }
  65. };
  66. let toolMenuData = [];
  67. let toolPermissionController = [];
  68. if (managerData.super_admin !== 1) {
  69. let permissionGroup = managerData.permission !== undefined && managerData.permission !== '' ?
  70. await permissionGroupModel.findDataByCondition({_id: managerData.permission}) : '';
  71. // let otherPermission = [];
  72. if (permissionGroup !== undefined && permissionGroup !== '' && permissionGroup.permission !== undefined && permissionGroup.permission !== '') {
  73. let permissionIdList = JSON.parse(permissionGroup.permission);
  74. for (let top of permissionIdList.top) {
  75. let permissionInfo = await permissionModel.findDataByCondition({_id:top});
  76. menuData[permissionInfo.controller] = {
  77. title: permissionInfo.name,
  78. url: permissionInfo.url,
  79. name: permissionInfo.controller,
  80. iconClass: 'glyphicon ' + permissionInfo.iconClass,
  81. children: {},
  82. }
  83. }
  84. for (let per in permissionIdList) {
  85. if (per !== 'top' && per !== 'tool') {
  86. let permissionArray = permissionIdList[per];
  87. for (let pa of permissionArray) {
  88. let permissionInfo = await permissionModel.findDataByCondition({_id:pa});
  89. if (permissionInfo !== undefined && permissionInfo !== '') {
  90. if (permissionInfo.isMenu) {
  91. // 属于二级菜单
  92. let action = {
  93. title: permissionInfo.name,
  94. url: permissionInfo.url,
  95. name: permissionInfo.action,
  96. };
  97. menuData[permissionInfo.controller].children[permissionInfo.action] = action;
  98. } else {
  99. // 其它权限
  100. // otherPermission.push({
  101. // title: permissionInfo.name,
  102. // url: permissionInfo.url,
  103. // name: permissionInfo.action,
  104. // });
  105. }
  106. }
  107. }
  108. } else if (per === 'tool') {
  109. // 工具里的页面权限
  110. let permissionArray = permissionIdList[per];
  111. for (let pa of permissionArray) {
  112. let permissionInfo = await permissionModel.findDataByCondition({_id:pa});
  113. if (permissionInfo.isMenu) {
  114. toolMenuData.push({
  115. title: permissionInfo.name,
  116. controller: permissionInfo.controller,
  117. url: permissionInfo.url,
  118. sort: permissionInfo.ID // 用来排序
  119. });
  120. }
  121. toolPermissionController.push(permissionInfo.controller);
  122. // 对于工具里的多个控制层进行优化处理
  123. if (permissionInfo.otherController !== undefined && permissionInfo.otherController !== '') {
  124. for (let other of permissionInfo.otherController.split(',')) {
  125. toolPermissionController.push(other);
  126. }
  127. }
  128. }
  129. }
  130. }
  131. }
  132. } else {
  133. // 获取数据库菜单列表
  134. let menuPermissionList = await permissionModel.getList({isMenu:true});
  135. for (let menu of menuPermissionList) {
  136. if (menu.pid === 0) {
  137. menuData[menu.controller] = {
  138. title: menu.name,
  139. url: menu.url,
  140. name: menu.controller,
  141. iconClass: 'glyphicon ' + menu.iconClass,
  142. children: {},
  143. }
  144. } else if (menu.pid !== 4) {
  145. let action = {
  146. title: menu.name,
  147. url: menu.url,
  148. name: menu.action,
  149. };
  150. menuData[menu.controller].children[menu.action] = action;
  151. }
  152. }
  153. // 超级管理员二级菜单添加
  154. menuData['manager'].children['admin'] = {
  155. title: '超级管理员',
  156. url: '/manager/admin',
  157. name: 'admin',
  158. }
  159. }
  160. // 获取所有工具里的权限控制器名称
  161. let toolAllPermission = [];
  162. let toolAllPermissionList = await permissionModel.getList({pid:4});
  163. for (let tool of toolAllPermissionList) {
  164. toolAllPermission.push(tool.controller);
  165. if (managerData.super_admin === 1) {
  166. toolMenuData.push({
  167. title: tool.name,
  168. controller: tool.controller,
  169. url: tool.url,
  170. sort: tool.ID // 用来排序
  171. });
  172. }
  173. if (tool.otherController !== undefined && tool.otherController !== '') {
  174. for (let other of tool.otherController.split(',')) {
  175. toolAllPermission.push(other);
  176. }
  177. }
  178. }
  179. let managerSession = {
  180. username: managerData.username,
  181. real_name:managerData.real_name,
  182. loginTime: currentTime,
  183. sessionToken: sessionToken,
  184. userID: managerData.id,
  185. toolPermission: toolPermissionController.join(','),
  186. toolMenuData: toolMenuData,
  187. toolAllPermission: toolAllPermission.join(','),
  188. menuData: menuData,
  189. superAdmin: managerData.super_admin
  190. };
  191. request.session.managerData = managerSession;
  192. // 更新登录信息
  193. let ip = request.connection.remoteAddress;
  194. ip = ip.split(':');
  195. ip = ip[3] === undefined ? '' : ip[3];
  196. let updateData = {
  197. login_ip: ip,
  198. last_login: new Date().getTime()
  199. };
  200. let updateResult = managerModel.updateById(managerData._id, updateData);
  201. if (!updateResult) {
  202. throw {code: 44003, err: '更新登录信息失败!'};
  203. }
  204. } catch (error) {
  205. responseData.error = error.code;
  206. responseData.msg = error.err;
  207. }
  208. response.json(responseData);
  209. }
  210. /**
  211. * 退出操作
  212. *
  213. * @param {object} request
  214. * @param {object} response
  215. * @return {void}
  216. */
  217. logout(request, response) {
  218. // 清空session
  219. request.session.destroy();
  220. response.redirect('/login');
  221. }
  222. /**
  223. * 压测接口
  224. *
  225. * @param {object} request
  226. * @param {object} response
  227. * @return {void}
  228. */
  229. async test(request, response) {
  230. let responseData = {
  231. error: 0,
  232. msg: ''
  233. };
  234. try {
  235. // 第一个库的操作
  236. let test1Model = new Test1Model();
  237. let test1Result = await test1Model.test();
  238. if (!test1Result) {
  239. throw 'test1出错';
  240. }
  241. // 第二个库操作
  242. let test2Model = new Test2Model();
  243. let test2Result = await test2Model.test();
  244. if (!test2Result) {
  245. throw 'test2出错';
  246. }
  247. // 第三个库操作
  248. let test3Model = new Test3Model();
  249. let test3Result = await test3Model.test();
  250. if (!test3Result) {
  251. throw 'test3出错';
  252. }
  253. } catch (error) {
  254. console.log(error);
  255. responseData.error = 1;
  256. responseData.msg = error;
  257. }
  258. response.json(responseData);
  259. }
  260. }
  261. export default LoginController;