|
@@ -25,7 +25,7 @@ class WXWorkLogin extends API {
|
|
try {
|
|
try {
|
|
const idRes = await getUserID(code);
|
|
const idRes = await getUserID(code);
|
|
if (!idRes || !idRes.success) {
|
|
if (!idRes || !idRes.success) {
|
|
- return res.json({ ...BaseStdResponse.ERR, endpoint: 7894377, msg: `登录失败!${idRes.msg}` });
|
|
|
|
|
|
+ return res.json({ ...BaseStdResponse.ERR, endpoint: 7894377, msg: `获取企微信息失败!${idRes.msg}` });
|
|
}
|
|
}
|
|
|
|
|
|
const wxid = idRes.userid;
|
|
const wxid = idRes.userid;
|
|
@@ -34,16 +34,15 @@ class WXWorkLogin extends API {
|
|
let sql = 'SELECT id, uuid, username, avatar, email FROM users WHERE wxid = ?';
|
|
let sql = 'SELECT id, uuid, username, avatar, email FROM users WHERE wxid = ?';
|
|
let rows = await db.query(sql, [wxid]);
|
|
let rows = await db.query(sql, [wxid]);
|
|
|
|
|
|
- let id, result, uuid, username, avatar, email;
|
|
|
|
- if (rows.length > 0) {
|
|
|
|
- ({ id, uuid, username, avatar, email } = rows[0]);
|
|
|
|
- const updateQuery = 'UPDATE users SET session = ? WHERE wxid = ?';
|
|
|
|
- result = await db.query(updateQuery, [session, id]);
|
|
|
|
- } else {
|
|
|
|
|
|
+ if(!rows || rows.length === 0)
|
|
return res.json({
|
|
return res.json({
|
|
...BaseStdResponse.USER_NOT_EXISTS
|
|
...BaseStdResponse.USER_NOT_EXISTS
|
|
})
|
|
})
|
|
- }
|
|
|
|
|
|
+
|
|
|
|
+ let id, uuid, username, avatar, email = rows[0];
|
|
|
|
+
|
|
|
|
+ const updateQuery = 'UPDATE users SET session = ? WHERE id = ?';
|
|
|
|
+ const result = await db.query(updateQuery, [session, id]);
|
|
|
|
|
|
if (result && result.affectedRows > 0) {
|
|
if (result && result.affectedRows > 0) {
|
|
return res.json({
|
|
return res.json({
|