99 lines
2.6 KiB
JavaScript
99 lines
2.6 KiB
JavaScript
const {
|
||
dbCmd,
|
||
userCollection
|
||
} = require('../../common/constants')
|
||
const {
|
||
USER_IDENTIFIER
|
||
} = require('../../common/constants')
|
||
const {
|
||
batchFindObjctValue,
|
||
getType,
|
||
isMatchUserApp
|
||
} = require('../../common/utils')
|
||
|
||
/**
|
||
* 查询满足条件的用户
|
||
* @param {Object} params
|
||
* @param {Object} params.userQuery 用户唯一标识组成的查询条件
|
||
* @param {Object} params.authorizedApp 用户允许登录的应用
|
||
* @returns userMatched 满足条件的用户列表
|
||
*/
|
||
async function findUser (params = {}) {
|
||
const {
|
||
userQuery,
|
||
authorizedApp = []
|
||
} = params
|
||
const condition = getUserQueryCondition(userQuery)
|
||
if (condition.length === 0) {
|
||
throw new Error('Invalid user query')
|
||
}
|
||
const authorizedAppType = getType(authorizedApp)
|
||
if (authorizedAppType !== 'string' && authorizedAppType !== 'array') {
|
||
throw new Error('Invalid authorized app')
|
||
}
|
||
|
||
let finalQuery
|
||
|
||
if (condition.length === 1) {
|
||
finalQuery = condition[0]
|
||
} else {
|
||
finalQuery = dbCmd.or(condition)
|
||
}
|
||
const userQueryRes = await userCollection.where(finalQuery).get()
|
||
return {
|
||
total: userQueryRes.data.length,
|
||
userMatched: userQueryRes.data.filter(item => {
|
||
return isMatchUserApp(item.dcloud_appid, authorizedApp)
|
||
})
|
||
}
|
||
}
|
||
|
||
function getUserIdentifier (userRecord = {}) {
|
||
const keys = Object.keys(USER_IDENTIFIER)
|
||
return batchFindObjctValue(userRecord, keys)
|
||
}
|
||
|
||
function getUserQueryCondition (userRecord = {}) {
|
||
const userIdentifier = getUserIdentifier(userRecord)
|
||
const condition = []
|
||
for (const key in userIdentifier) {
|
||
const value = userIdentifier[key]
|
||
if (!value) {
|
||
// 过滤所有value为假值的条件，在查询用户时没有意义
|
||
continue
|
||
}
|
||
const queryItem = {
|
||
[key]: value
|
||
}
|
||
// 为兼容用户老数据用户名及邮箱需要同时查小写及原始大小写数据
|
||
if (key === 'mobile') {
|
||
queryItem.mobile_confirmed = 1
|
||
} else if (key === 'email') {
|
||
queryItem.email_confirmed = 1
|
||
const email = userIdentifier.email
|
||
if (email.toLowerCase() !== email) {
|
||
condition.push({
|
||
email: email.toLowerCase(),
|
||
email_confirmed: 1
|
||
})
|
||
}
|
||
} else if (key === 'username') {
|
||
const username = userIdentifier.username
|
||
if (username.toLowerCase() !== username) {
|
||
condition.push({
|
||
username: username.toLowerCase()
|
||
})
|
||
}
|
||
} else if (key === 'identities') {
|
||
queryItem.identities = dbCmd.elemMatch(value)
|
||
}
|
||
condition.push(queryItem)
|
||
}
|
||
return condition
|
||
}
|
||
|
||
module.exports = {
|
||
findUser,
|
||
getUserIdentifier
|
||
}
|