session_auth.js 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960
  1. 'use strict';
  2. // 加密类
  3. const crypto = require('crypto');
  4. const messageType = require('../const/message_type');
  5. module.exports = options => {
  6. /**
  7. * session判断中间件
  8. *
  9. * @param {function} next - 中间件继续执行的方法
  10. * @return {void}
  11. */
  12. return function* sessionAuth(next) {
  13. try {
  14. // 判断session
  15. const sessionUser = this.session.sessionUser;
  16. if (sessionUser === undefined) {
  17. throw '不存在session';
  18. }
  19. // 校验session
  20. if (sessionUser.account === undefined || sessionUser.loginTime === undefined) {
  21. throw '用户数据不完整';
  22. }
  23. // 校验session
  24. const sessionToken = crypto.createHmac('sha1', sessionUser.loginTime + '')
  25. .update(sessionUser.account).digest('hex').toString('base64');
  26. if (sessionToken !== sessionUser.sessionToken) {
  27. throw 'session数据错误';
  28. }
  29. // 获取用户新建标段权利
  30. const accountInfo = yield this.service.projectAccount.getDataById(this.session.sessionUser.accountId);
  31. this.session.sessionUser.permission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
  32. // 同步消息
  33. yield this.service.notify.syncNotifyData();
  34. // 同步系统维护信息
  35. yield this.service.maintain.syncMaintainData();
  36. } catch (error) {
  37. console.log(error);
  38. if (this.helper.isAjax(this.request)) {
  39. return this.body = {
  40. err: 2,
  41. msg: '登录信息异常,请重新登录',
  42. data: '',
  43. };
  44. } else {
  45. this.session.message = {
  46. type: messageType.ERROR,
  47. icon: 'exclamation-circle',
  48. message: '登录信息异常,请重新登录',
  49. };
  50. return this.redirect('/login?referer=' + this.url);
  51. }
  52. }
  53. yield next;
  54. };
  55. };