|
|
// 云函数 updateUserInfo
|
|
|
const cloud = require('wx-server-sdk');
|
|
|
|
|
|
// 初始化cloud
|
|
|
cloud.init({
|
|
|
env: 'cloud1-5gqeisa06659849a'
|
|
|
});
|
|
|
|
|
|
const db = cloud.database();
|
|
|
|
|
|
exports.main = async (event, context) => {
|
|
|
console.log('updateUserInfo 云函数开始执行，参数 event:', event);
|
|
|
|
|
|
const wxContext = cloud.getWXContext();
|
|
|
const openid = wxContext.OPENID; // 获取用户的openid
|
|
|
console.log('获取到的 openid:', openid);
|
|
|
|
|
|
if (!openid) {
|
|
|
console.warn('未获取到用户身份信息');
|
|
|
return {
|
|
|
success: false,
|
|
|
message: '未获取到用户身份信息'
|
|
|
};
|
|
|
}
|
|
|
|
|
|
const { userInfo } = event;
|
|
|
console.log('接收到的 userInfo:', userInfo);
|
|
|
|
|
|
if (!userInfo) {
|
|
|
console.warn('未提供用户信息');
|
|
|
return {
|
|
|
success: false,
|
|
|
message: '未提供用户信息'
|
|
|
};
|
|
|
}
|
|
|
|
|
|
try {
|
|
|
// 检查用户是否已存在
|
|
|
const userCheck = await db.collection('users').where({
|
|
|
openid: openid
|
|
|
}).get();
|
|
|
|
|
|
console.log('数据库查询结果:', userCheck);
|
|
|
|
|
|
if (userCheck.data.length === 0) {
|
|
|
// 用户不存在，创建新用户
|
|
|
const addRes = await db.collection('users').add({
|
|
|
data: {
|
|
|
openid: openid,
|
|
|
nickName: userInfo.nickName || '宿小君用户',
|
|
|
avatarUrl: userInfo.avatarUrl || '',
|
|
|
gender: userInfo.gender || 0,
|
|
|
createTime: db.serverDate(),
|
|
|
updateTime: db.serverDate(),
|
|
|
balance: 0, // 初始余额
|
|
|
credit: 100, // 初始信用分
|
|
|
secondhandCount: 0 // 二手交易完成数
|
|
|
}
|
|
|
});
|
|
|
|
|
|
console.log('新用户创建成功，记录ID:', addRes._id);
|
|
|
|
|
|
return {
|
|
|
success: true,
|
|
|
message: '用户创建成功',
|
|
|
isNewUser: true
|
|
|
};
|
|
|
} else {
|
|
|
// 用户已存在，更新信息
|
|
|
const updateRes = await db.collection('users').where({
|
|
|
openid: openid
|
|
|
}).update({
|
|
|
data: {
|
|
|
nickName: userInfo.nickName,
|
|
|
avatarUrl: userInfo.avatarUrl,
|
|
|
gender: userInfo.gender,
|
|
|
updateTime: db.serverDate()
|
|
|
}
|
|
|
});
|
|
|
|
|
|
console.log('用户信息更新成功，更新结果:', updateRes);
|
|
|
|
|
|
return {
|
|
|
success: true,
|
|
|
message: '用户信息更新成功',
|
|
|
isNewUser: false
|
|
|
};
|
|
|
}
|
|
|
} catch (err) {
|
|
|
console.error('更新用户信息失败', err);
|
|
|
return {
|
|
|
success: false,
|
|
|
message: '更新用户信息失败',
|
|
|
error: err.message
|
|
|
};
|
|
|
}
|
|
|
};
|
