资源共享功能实现（二）

用户登录基本功能

登录

exports.main &＃61; async (event, context) &＃61;> {const clientIp &＃61; context.ip;const { captcha } &＃61; event;if (!captcha) {console.error(&＃96;captcha is null, ip &＃61; ${clientIp}&＃96;);return null;}const user &＃61; await db.collection(&＃39;user&＃39;).where({captcha,captchaExpireTime: _.gt(new Date()),isDelete: false,}).limit(1).get().then(({ data }) &＃61;> data[0]);


对用户身份合法性检验

// 用户不存在if (!user) {console.log(&＃96;user not exists, captcha &＃61; ${captcha}&＃96;);return null;}// 用户非法if (!isValidUser(user)) {console.error(&＃96;user is invalid, ip &＃61; ${clientIp}, user &＃61; ${JSON.stringify(user)}&＃96;);throw new MyError(FORBIDDEN_ERROR_CODE, &＃39;禁止访问&＃39;);}


若用户合法&＃xff0c;则创建登录凭证

// 创建登录凭证const ticket &＃61; app.auth().createTicket(user.unionId, {refresh: 30 * 24 * 60 * 60 * 1000, // 30 天刷新一次});// 存 session 登录态context.session.userInfo &＃61; user;return {ticket,user,};


限流功能

如果由于人数太多不响应&＃xff0c;那就锁定登录功能

const getLock &＃61; await app.callFunction({name: &＃39;redisService&＃39;,data: {op: &＃39;setnx&＃39;,key: &＃96;login_${clientIp}&＃96;,value: 1,expireSeconds: 3,},}).then((tmpRes) &＃61;> tmpRes.result);if (!getLock) {console.error(&＃96;cannot getLock, ip &＃61; ${clientIp}&＃96;);return FORBIDDEN_CODE;}


登出

exports.main &＃61; async (event, context) &＃61;> {// 清除登录态context.session.userInfo &＃61; undefined;return true;
};


封号或者解封用户

此功能仅管理员可以操作&＃xff0c;对于一些用户发表不当言论或者违规操作&＃xff0c;管理员可以审核后将其加入黑名单中&＃xff0c;用户的账号将会被封禁&＃xff1b;当封禁到期&＃xff0c;管理员可以移除用户账号&＃xff0c;用户即可正常登录。

exports.main &＃61; async (event, context) &＃61;> {const { userId } &＃61; event;if (!userId) {return false;}// 获取当前登录用户const currentUser &＃61; await getLoginUser(context);// 仅管理员可操作if (!isAdminUser(currentUser)) {throw new MyError(FORBIDDEN_ERROR_CODE, &＃39;禁止访问&＃39;);}const user &＃61; await db.collection(&＃39;user&＃39;).where({_id: userId,isDelete: false,}).limit(1).get().then(({ data }) &＃61;> data[0]);if (!user) {return false;}const updateData &＃61; {authority: user.authority?.includes(&＃39;ban&＃39;) ? &＃39;user&＃39; : &＃39;ban&＃39;,_updateTime: new Date(),};// 更新const result &＃61; await db.collection(&＃39;user&＃39;).doc(user._id).update(updateData);console.log(&＃96;updateUser data &＃61; ${JSON.stringify(updateData)}&＃96;);return {code: 200,data: result,};
};


用户积分机制

更新用户积分&＃xff0c;用户通过优质评论可以获得一定积分&＃xff0c;用户下载他人得资源&＃xff0c;管理员负责发放积分。

exports.main &＃61; async (event, context) &＃61;> {const { userId, score, reason &＃61; -1, detail } &＃61; event;// 请求参数校验if (!userId || !score || reason < 0) {return false;}// 封装数据const data &＃61; {userId,score,reason,detail,_createTime: new Date(),_updateTime: new Date(),isDelete: false,};const transaction &＃61; await db.startTransaction();let res;try {// 插入用户积分记录res &＃61; await transaction.collection(&＃39;userScore&＃39;).add(data).then((res) &＃61;> {console.log(&＃96;addUserScore succeed, id &＃61; ${res.id}&＃96;);return true;}).catch((e) &＃61;> {console.error(&＃39;addUserScore error&＃39;, e);throw e;});// 更新用户积分res &＃61; await transaction.collection(&＃39;user&＃39;).where({_id: userId,isDelete: false,}).update({score: _.inc(score),_updateTime: new Date(),}).then((res) &＃61;> {console.log(&＃39;updateUserScore succeed&＃39;, res);return true;}).catch((e) &＃61;> {console.error(&＃39;updateUserScore error&＃39;, e);throw e;});await transaction.commit();return res;} catch (e) {await transaction.rollback();console.error(&＃39;未知错误&＃xff01;&＃39;, e);return false;}
};