/**
|
* 用户相关表操作
|
*/
|
const dbName_user = "uni-id-users"; // 用户
|
|
var dao = {};
|
var util = {};
|
// 初始化
|
dao.init = function(obj){
|
util = obj;
|
}
|
/**
|
* 获取用户信息
|
* 调用示例
|
* await vk.daoCenter.userDao.findById(user_id);
|
* data 请求参数说明
|
* @params {String} user_id 用户ID
|
*/
|
dao.findById = async (user_id) => {
|
let { vk , db, _ } = util;
|
let res = {};
|
// 数据库操作开始-----------------------------------------------------------
|
res = await vk.baseDao.findById({
|
dbName:dbName_user,
|
id:user_id,
|
fieldJson:{ token:false, password:false },
|
});
|
// 数据库操作结束-----------------------------------------------------------
|
return res;
|
};
|
|
/**
|
* 获取用户信息,根据
|
* _id
|
* username
|
* mobile
|
* email
|
* wx_openid.app-plus
|
* wx_openid.mp-weixin
|
* wx_unionid
|
* ali_openid
|
* my_invite_code
|
* 调用示例
|
await vk.daoCenter.userDao.findByUserInfo({
|
mobile:mobile
|
});
|
* data 请求参数说明
|
* @params {Object} userInfo 用户信息
|
*/
|
dao.findByUserInfo = async (userInfo) => {
|
let { vk , db, _ } = util;
|
let res;
|
// 数据库操作开始-----------------------------------------------------------
|
let whereJson = {};
|
let list = [
|
"_id",
|
"username",
|
"mobile",
|
"email",
|
"wx_openid.app-plus",
|
"wx_openid.mp-weixin",
|
"wx_unionid",
|
"ali_openid",
|
"my_invite_code"
|
];
|
let orArr = [];
|
for(let i=0; i<list.length; i++){
|
let keyName = list[i];
|
let orObj = {};
|
if(vk.pubfn.isNotNull(userInfo[keyName])) orObj[keyName] = userInfo[keyName];
|
if(vk.pubfn.isNotNull(orObj)){
|
orArr.push(orObj);
|
}
|
}
|
if(orArr.length > 0){
|
whereJson = _.or(orArr);
|
res = await vk.baseDao.findByWhereJson({
|
dbName:dbName_user,
|
fieldJson:{ token:false, password:false },
|
whereJson:whereJson
|
});
|
}
|
// 数据库操作结束-----------------------------------------------------------
|
return res;
|
};
|
/**
|
* 根据ID数组获取用户列表 最多支持500个
|
* 调用示例
|
* await vk.daoCenter.userDao.listByIds(userIdArr);
|
* data 请求参数说明
|
* @params {Array} userIdArr 用户ID数组
|
*/
|
dao.listByIds = async (userIdArr) => {
|
let { vk , db, _ } = util;
|
let res = {};
|
let selectRes = await vk.baseDao.select({
|
dbName:dbName_user,
|
pageIndex:1,
|
pageSize:500,
|
fieldJson:{ token:false, password:false },
|
whereJson:{
|
_id:_.in(userIdArr)
|
},
|
});
|
res = selectRes.rows;
|
// 数据库操作结束-----------------------------------------------------------
|
return res;
|
};
|
/**
|
* 根据手机号直接注册账号并登录
|
* 若手机号已存在,则直接登录
|
* @params {Object} data 参数
|
* mobile 手机号 必填
|
* password 初始密码
|
* inviteCode 邀请人的邀请码
|
* myInviteCode 设置当前注册用户自己的邀请码
|
* needPermission 设置为true时会在checkToken时返回用户权限（permission），建议在管理控制台中使用
|
* 调用示例
|
await vk.daoCenter.userDao.registerUserByMobile({
|
mobile,
|
});
|
*/
|
dao.registerUserByMobile = async (data) => {
|
let { vk , db, _, uniID } = util;
|
let res = {};
|
let {
|
mobile,
|
password,
|
inviteCode,
|
myInviteCode,
|
needPermission
|
} = data;
|
// 数据库操作开始-----------------------------------------------------------
|
let code = vk.pubfn.random(6);
|
// 设置验证码
|
await uniID.setVerifyCode({
|
mobile,
|
code,
|
expiresIn:60,
|
type:"login"
|
});
|
// 若手机号不存在，则注册并登录。存在，则直接登录。
|
res = await uniID.loginBySms({
|
mobile,
|
code,
|
password,
|
inviteCode,
|
myInviteCode,
|
needPermission
|
});
|
if(res.uid && vk.pubfn.isNull(res.userInfo)){
|
res.userInfo = await vk.daoCenter.userDao.findById(res.uid);
|
}
|
// 数据库操作结束-----------------------------------------------------------
|
return res;
|
};
|
|
module.exports = dao;
|
