const { ERROR } = require('../../common/error') async function getNeedCaptcha ({ uid, username, mobile, email, type = 'login', limitDuration = 7200000, // 两小时 limitTimes = 3 // 记录次数 } = {}) { const db = uniCloud.database() const dbCmd = db.command // 当用户最近“2小时内(limitDuration)”登录失败达到3次(limitTimes)时。要求用户提交验证码 const now = Date.now() const uniIdLogCollection = db.collection('uni-id-log') const userIdentifier = { user_id: uid, username, mobile, email } let totalKey = 0; let deleteKey = 0 for (const key in userIdentifier) { totalKey++ if (!userIdentifier[key] || typeof userIdentifier[key] !== 'string') { deleteKey++ delete userIdentifier[key] } } if (deleteKey === totalKey) { throw new Error('System error') // 正常情况下不会进入此条件,但是考虑到后续会有其他开发者修改此云对象,在此处做一个判断 } const { data: recentRecord } = await uniIdLogCollection.where({ ip: this.getUniversalClientInfo().clientIP, ...userIdentifier, type, create_date: dbCmd.gt(now - limitDuration) }) .orderBy('create_date', 'desc') .limit(limitTimes) .get() return recentRecord.length === limitTimes && recentRecord.every(item => item.state === 0) } async function verifyCaptcha (params = {}) { const { captcha, scene } = params if (!captcha) { throw { errCode: ERROR.CAPTCHA_REQUIRED } } const payload = await this.uniCaptcha.verify({ deviceId: this.getUniversalClientInfo().deviceId, captcha, scene }) if (payload.errCode) { throw payload } } module.exports = { getNeedCaptcha, verifyCaptcha }