login_controller.js 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295
  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. console.log(Object.keys(menuData[permissionInfo.controller].children).length);
  98. if (Object.keys(menuData[permissionInfo.controller].children).length === 0) {
  99. menuData[permissionInfo.controller].url = action.url;
  100. }
  101. menuData[permissionInfo.controller].children[permissionInfo.action] = action;
  102. } else {
  103. // 其它权限
  104. // otherPermission.push({
  105. // title: permissionInfo.name,
  106. // url: permissionInfo.url,
  107. // name: permissionInfo.action,
  108. // });
  109. }
  110. }
  111. }
  112. } else if (per === 'tool') {
  113. // 工具里的页面权限
  114. let permissionArray = permissionIdList[per];
  115. for (let pa of permissionArray) {
  116. let permissionInfo = await permissionModel.findDataByCondition({_id:pa});
  117. if (!permissionInfo) {
  118. console.log(`pa`);
  119. console.log(pa);
  120. }
  121. if (permissionInfo.isMenu) {
  122. toolMenuData.push({
  123. title: permissionInfo.name,
  124. controller: permissionInfo.controller,
  125. url: permissionInfo.url,
  126. sort: permissionInfo.ID // 用来排序
  127. });
  128. }
  129. toolPermissionController.push(permissionInfo.controller);
  130. // 对于工具里的多个控制层进行优化处理
  131. if (permissionInfo.otherController !== undefined && permissionInfo.otherController !== '') {
  132. for (let other of permissionInfo.otherController.split(',')) {
  133. toolPermissionController.push(other);
  134. }
  135. }
  136. }
  137. }
  138. }
  139. }
  140. } else {
  141. // 获取数据库菜单列表
  142. let menuPermissionList = await permissionModel.getList({isMenu:true});
  143. let subList = [];
  144. for (let menu of menuPermissionList) {
  145. if (menu.pid === 0) {
  146. menuData[menu.controller] = {
  147. title: menu.name,
  148. url: menu.url,
  149. name: menu.controller,
  150. iconClass: 'glyphicon ' + menu.iconClass,
  151. children: {},
  152. }
  153. } else if (menu.pid !== 4) {
  154. subList.push(menu);//防止子节点ID比父节点ID小的问题
  155. }
  156. }
  157. for(let s of subList){
  158. let action = {
  159. title: s.name,
  160. url: s.url,
  161. name: s.action,
  162. };
  163. menuData[s.controller].children[s.action] = action;
  164. }
  165. // 超级管理员二级菜单添加
  166. menuData['manager'].children['admin'] = {
  167. title: '超级管理员',
  168. url: '/manager/admin',
  169. name: 'admin',
  170. }
  171. }
  172. // 获取所有工具里的权限控制器名称
  173. let toolAllPermission = [];
  174. let toolAllPermissionList = await permissionModel.getList({pid:4});
  175. console.log(`toolAllPermissionList`);
  176. console.log(toolAllPermissionList);
  177. for (let tool of toolAllPermissionList) {
  178. toolAllPermission.push(tool.controller);
  179. if (managerData.super_admin === 1) {
  180. toolMenuData.push({
  181. title: tool.name,
  182. controller: tool.controller,
  183. url: tool.url,
  184. sort: tool.ID // 用来排序
  185. });
  186. }
  187. if (tool.otherController !== undefined && tool.otherController !== '') {
  188. for (let other of tool.otherController.split(',')) {
  189. toolAllPermission.push(other);
  190. }
  191. }
  192. }
  193. let managerSession = {
  194. username: managerData.username,
  195. real_name:managerData.real_name,
  196. loginTime: currentTime,
  197. sessionToken: sessionToken,
  198. userID: managerData.id,
  199. toolPermission: toolPermissionController.join(','),
  200. toolMenuData: toolMenuData,
  201. toolAllPermission: toolAllPermission.join(','),
  202. menuData: menuData,
  203. superAdmin: managerData.super_admin
  204. };
  205. request.session.managerData = managerSession;
  206. // 更新登录信息
  207. let ip = request.connection.remoteAddress;
  208. ip = ip.split(':');
  209. ip = ip[3] === undefined ? '' : ip[3];
  210. let updateData = {
  211. login_ip: ip,
  212. last_login: new Date().getTime()
  213. };
  214. let updateResult = managerModel.updateById(managerData._id, updateData);
  215. if (!updateResult) {
  216. throw {code: 44003, err: '更新登录信息失败!'};
  217. }
  218. } catch (error) {
  219. console.log(error);
  220. responseData.error = error.code;
  221. responseData.msg = error.err;
  222. }
  223. response.json(responseData);
  224. }
  225. /**
  226. * 退出操作
  227. *
  228. * @param {object} request
  229. * @param {object} response
  230. * @return {void}
  231. */
  232. logout(request, response) {
  233. // 清空session
  234. request.session.destroy();
  235. response.redirect('/login');
  236. }
  237. /**
  238. * 压测接口
  239. *
  240. * @param {object} request
  241. * @param {object} response
  242. * @return {void}
  243. */
  244. async test(request, response) {
  245. let responseData = {
  246. error: 0,
  247. msg: ''
  248. };
  249. try {
  250. // 第一个库的操作
  251. let test1Model = new Test1Model();
  252. let test1Result = await test1Model.test();
  253. if (!test1Result) {
  254. throw 'test1出错';
  255. }
  256. // 第二个库操作
  257. let test2Model = new Test2Model();
  258. let test2Result = await test2Model.test();
  259. if (!test2Result) {
  260. throw 'test2出错';
  261. }
  262. // 第三个库操作
  263. let test3Model = new Test3Model();
  264. let test3Result = await test3Model.test();
  265. if (!test3Result) {
  266. throw 'test3出错';
  267. }
  268. } catch (error) {
  269. console.log(error);
  270. responseData.error = 1;
  271. responseData.msg = error;
  272. }
  273. response.json(responseData);
  274. }
  275. }
  276. export default LoginController;