oos-tencent/index.js at master · BetterJS/oos-tencent · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
/* global module, GLOBAL */
var tof = require('./node-tof');
var crypto = require('crypto');
var log4js = require('log4js'),
    logger = log4js.getLogger();

var isError = function(res, error) {
    if (error) {
        res.json({
            ret: 1,
            msg: error
        });
        return true;
    }
    return false;
};

module.exports = function(req, res, next) {
    var params = req.query;
    var user = req.session.user;
    // 获取用户model
    var userDao = req.models.userDao;

    req.indexUrl = req.protocol + "://" + req.get('host') + '/user/index.html';

    if (/^\/oalogin/i.test(req.url)) { // 登录
        var redirectUrl = req.indexUrl;
        res.redirect('http://passport.oa.com/modules/passport/signin.ashx?url=' + redirectUrl);
        return;
    }
    if (params && params.ticket) { // oa 登录跳转
        tof.passport(params.ticket, function(result) {
            if (result) {
                // 登录成功
                user = req.session.user = {
                    loginName: result.LoginName,
                    chineseName: result.ChineseName,
                    role: 0
                };

                userDao.one({
                    loginName: result.LoginName
                }, function(err, dbUser) {
                    if (isError(res, err)) {
                        return;
                    }

                    if (!dbUser) { // 第一次登陆，将用户信息写入数据库
                        req.session.user.email = user.loginName + GLOBAL.pjconfig.email.emailSuffix;
                        req.session.user.password = crypto.createHash("md5").update(user.loginName).digest('hex');

                        userDao.create(req.session.user, function(err, result) {
                            if (isError(res, err)) {
                                return;
                            }

                            req.session.user.role = result.role;
                            req.session.user.id = result.id;

                            logger.info("New User:" + JSON.stringify(req.session.user) + "insert into db-badjs");
                            next();
                        });
                    } else { // 已经登录过，判断是否更新信息
                        logger.info("Old User:" + JSON.stringify(req.session.user));
                        req.session.user.role = dbUser.role;
                        req.session.user.id = dbUser.id;
                        req.session.user.email = dbUser.email;

                        // 尚未登录过， 但是添加过，分配中文名字
                        if (!dbUser.chineseName) {
                            dbUser.chineseName = result.ChineseName;
                            dbUser.save(function(err, result) {});
                        }
                        next();
                    }

                });

            } else {
                res.send(403, 'Sorry! you can not see that.');
            }
        });
    } else {
        next();
    }
};