123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960 |
- 'use strict';
- // 加密类
- const crypto = require('crypto');
- const messageType = require('../const/message_type');
- module.exports = options => {
- /**
- * session判断中间件
- *
- * @param {function} next - 中间件继续执行的方法
- * @return {void}
- */
- return function* sessionAuth(next) {
- try {
- // 判断session
- const sessionUser = this.session.sessionUser;
- if (sessionUser === undefined) {
- throw '不存在session';
- }
- // 校验session
- if (sessionUser.account === undefined || sessionUser.loginTime === undefined) {
- throw '用户数据不完整';
- }
- // 校验session
- const sessionToken = crypto.createHmac('sha1', sessionUser.loginTime + '')
- .update(sessionUser.account).digest('hex').toString('base64');
- if (sessionToken !== sessionUser.sessionToken) {
- throw 'session数据错误';
- }
- // 获取用户新建标段权利
- const accountInfo = yield this.service.projectAccount.getDataById(this.session.sessionUser.accountId);
- this.session.sessionUser.permission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
- // 同步消息
- yield this.service.notify.syncNotifyData();
- // 同步系统维护信息
- yield this.service.maintain.syncMaintainData();
- } catch (error) {
- console.log(error);
- if (this.helper.isAjax(this.request)) {
- return this.body = {
- err: 2,
- msg: '登录信息异常,请重新登录',
- data: '',
- };
- } else {
- this.session.message = {
- type: messageType.ERROR,
- icon: 'exclamation-circle',
- message: '登录信息异常,请重新登录',
- };
- return this.redirect('/login?referer=' + this.url);
- }
- }
- yield next;
- };
- };
|