pan/heros
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

金币经验掉落

Browse Source
This commit is contained in:
panfudan
2025-08-19 22:30:59 +08:00
parent 854affeaae
commit c47ecc21e6
12 changed files with 1809 additions and 462 deletions
Download Patch File Download Diff File Expand all files Collapse all files

175
build-templates/wechatgame/cloud_functions/cocos_cloud/index.js
View File

@@ -7,6 +7,9 @@ const gameDataModule = require('./modules/gameData');
const fightHerosModule = require('./modules/fightHeros');
const herosModule = require('./modules/heros');
const inventoryModule = require('./modules/inventory');
const itemsModule = require('./modules/items');
const talsModule = require('./modules/tals');
const equipsModule = require('./modules/equips');
const responseModule = require('./modules/response');
cloud.init({ env: cloud.DYNAMIC_CURRENT_ENV }); // 使用当前云环境
@@ -72,13 +75,7 @@ exports.main = async (event, context) => {
if (spendValidation) return spendValidation;
result = await gameDataModule.spendDataField(db, wxContext.OPENID, params.field, params.amount);
break;
case 'data_set':
const setValidation = responseModule.validateRequiredParams(params, ['field', 'value']);
if (setValidation) return setValidation;
result = await gameDataModule.setDataField(db, wxContext.OPENID, params.field, params.value);
break;
case 'data_reset':
result = await gameDataModule.resetData(db, wxContext.OPENID);
break;
@@ -159,7 +156,7 @@ exports.main = async (event, context) => {
result = await herosModule.getOwnedHeroIds(db, wxContext.OPENID);
break;
// ==================== 库存管理 (items, tals, equips) ====================
// ==================== 库存管理 (通用接口) ====================
case 'inventory_get':
const invGetValidation = responseModule.validateRequiredParams(params, ['type']);
if (invGetValidation) return invGetValidation;
@@ -209,40 +206,139 @@ exports.main = async (event, context) => {
result = await inventoryModule.getOwnedItems(db, wxContext.OPENID, params.type);
break;
// ==================== 兼容旧接口 ====================
case 'load':
result = await authModule.login(db, wxContext);
// ==================== 物品管理 (items) ====================
case 'items_get':
result = await itemsModule.getItems(db, wxContext.OPENID);
break;
case 'save':
// 兼容旧的保存接口
if (params.data) {
const tasks = [];
if (params.data.data) tasks.push(gameDataModule.updateData(db, wxContext.OPENID, params.data.data));
if (params.data.fight_heros) tasks.push(fightHerosModule.updateFightHeros(db, wxContext.OPENID, params.data.fight_heros));
if (params.data.heros) {
// 批量更新英雄
for (const heroId in params.data.heros) {
tasks.push(herosModule.updateHero(db, wxContext.OPENID, parseInt(heroId), params.data.heros[heroId]));
}
}
if (params.data.items) tasks.push(inventoryModule.updateInventory(db, wxContext.OPENID, 'items', params.data.items));
if (params.data.tals) tasks.push(inventoryModule.updateInventory(db, wxContext.OPENID, 'tals', params.data.tals));
if (params.data.equips) tasks.push(inventoryModule.updateInventory(db, wxContext.OPENID, 'equips', params.data.equips));
const results = await Promise.all(tasks);
const hasError = results.some(r => r.code !== 200);
if (hasError) {
result = responseModule.error(-1, "Partial save failed", { results });
} else {
result = responseModule.success({ results }, "All data saved successfully");
}
} else {
result = responseModule.badRequest("No data to save");
}
case 'item_get':
const itemIdValidation = responseModule.validateRequiredParams(params, ['item_id']);
if (itemIdValidation) return itemIdValidation;
result = await itemsModule.getItem(db, wxContext.OPENID, params.item_id);
break;
case 'item_add':
const addItemValidation = responseModule.validateRequiredParams(params, ['item_id', 'count']);
if (addItemValidation) return addItemValidation;
result = await itemsModule.addItem(db, wxContext.OPENID, params.item_id, params.count);
break;
case 'item_consume':
const consumeItemValidation = responseModule.validateRequiredParams(params, ['item_id', 'count']);
if (consumeItemValidation) return consumeItemValidation;
result = await itemsModule.consumeItem(db, wxContext.OPENID, params.item_id, params.count);
break;
case 'item_set':
const setItemValidation = responseModule.validateRequiredParams(params, ['item_id', 'count']);
if (setItemValidation) return setItemValidation;
result = await itemsModule.setItem(db, wxContext.OPENID, params.item_id, params.count);
break;
case 'items_update':
const updateItemsValidation = responseModule.validateRequiredParams(params, ['data']);
if (updateItemsValidation) return updateItemsValidation;
const itemsMerge = params.merge !== false;
result = await itemsModule.updateItems(db, wxContext.OPENID, params.data, itemsMerge);
break;
case 'items_reset':
result = await itemsModule.resetItems(db, wxContext.OPENID);
break;
case 'items_owned':
result = await itemsModule.getOwnedItems(db, wxContext.OPENID);
break;
// ==================== 天赋管理 (tals) ====================
case 'tals_get':
result = await talsModule.getTals(db, wxContext.OPENID);
break;
case 'tal_get':
const talIdValidation = responseModule.validateRequiredParams(params, ['tal_id']);
if (talIdValidation) return talIdValidation;
result = await talsModule.getTal(db, wxContext.OPENID, params.tal_id);
break;
case 'tal_add':
const addTalValidation = responseModule.validateRequiredParams(params, ['tal_id', 'count']);
if (addTalValidation) return addTalValidation;
result = await talsModule.addTal(db, wxContext.OPENID, params.tal_id, params.count);
break;
case 'tal_consume':
const consumeTalValidation = responseModule.validateRequiredParams(params, ['tal_id', 'count']);
if (consumeTalValidation) return consumeTalValidation;
result = await talsModule.consumeTal(db, wxContext.OPENID, params.tal_id, params.count);
break;
case 'tal_set':
const setTalValidation = responseModule.validateRequiredParams(params, ['tal_id', 'count']);
if (setTalValidation) return setTalValidation;
result = await talsModule.setTal(db, wxContext.OPENID, params.tal_id, params.count);
break;
case 'tals_update':
const updateTalsValidation = responseModule.validateRequiredParams(params, ['data']);
if (updateTalsValidation) return updateTalsValidation;
const talsMerge = params.merge !== false;
result = await talsModule.updateTals(db, wxContext.OPENID, params.data, talsMerge);
break;
case 'tals_reset':
result = await talsModule.resetTals(db, wxContext.OPENID);
break;
case 'tals_owned':
result = await talsModule.getOwnedTals(db, wxContext.OPENID);
break;
// ==================== 装备管理 (equips) ====================
case 'equips_get':
result = await equipsModule.getEquips(db, wxContext.OPENID);
break;
case 'equip_get':
const equipIdValidation = responseModule.validateRequiredParams(params, ['equip_id']);
if (equipIdValidation) return equipIdValidation;
result = await equipsModule.getEquip(db, wxContext.OPENID, params.equip_id);
break;
case 'equip_add':
const addEquipValidation = responseModule.validateRequiredParams(params, ['equip_id', 'count']);
if (addEquipValidation) return addEquipValidation;
result = await equipsModule.addEquip(db, wxContext.OPENID, params.equip_id, params.count);
break;
case 'equip_consume':
const consumeEquipValidation = responseModule.validateRequiredParams(params, ['equip_id', 'count']);
if (consumeEquipValidation) return consumeEquipValidation;
result = await equipsModule.consumeEquip(db, wxContext.OPENID, params.equip_id, params.count);
break;
case 'equip_set':
const setEquipValidation = responseModule.validateRequiredParams(params, ['equip_id', 'count']);
if (setEquipValidation) return setEquipValidation;
result = await equipsModule.setEquip(db, wxContext.OPENID, params.equip_id, params.count);
break;
case 'equips_update':
const updateEquipsValidation = responseModule.validateRequiredParams(params, ['data']);
if (updateEquipsValidation) return updateEquipsValidation;
const equipsMerge = params.merge !== false;
result = await equipsModule.updateEquips(db, wxContext.OPENID, params.data, equipsMerge);
break;
case 'equips_reset':
result = await equipsModule.resetEquips(db, wxContext.OPENID);
break;
case 'equips_owned':
result = await equipsModule.getOwnedEquips(db, wxContext.OPENID);
break;
default:
const availableCommands = [
'login', 'user_info', 'version', 'upgrade',
@@ -250,6 +346,9 @@ exports.main = async (event, context) => {
'fight_heros_get', 'fight_hero_set', 'fight_heros_update', 'fight_heros_active', 'fight_heros_swap', 'fight_heros_reset',
'heros_get', 'hero_get', 'hero_add', 'hero_update', 'hero_property_set', 'hero_levelup', 'hero_delete', 'heros_owned',
'inventory_get', 'inventory_item_get', 'inventory_item_add', 'inventory_item_consume', 'inventory_item_set', 'inventory_update', 'inventory_reset', 'inventory_owned',
'items_get', 'item_get', 'item_add', 'item_consume', 'item_set', 'items_update', 'items_reset', 'items_owned',
'tals_get', 'tal_get', 'tal_add', 'tal_consume', 'tal_set', 'tals_update', 'tals_reset', 'tals_owned',
'equips_get', 'equip_get', 'equip_add', 'equip_consume', 'equip_set', 'equips_update', 'equips_reset', 'equips_owned',
'load', 'save'
];
result = responseModule.unknownCommand(cmd, availableCommands);

421
build-templates/wechatgame/cloud_functions/cocos_cloud/modules/equips.js Normal file
View File

@@ -0,0 +1,421 @@
// 装备库存操作模块 (equips)
const { getOrCreaterUser } = require('./auth');
const user_db_name = "cocos_users";
const DATA_TYPE = 'equips';
/**
* 获取装备库存数据
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @returns {Object} 操作结果
*/
async function getEquips(db, openid) {
try {
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
return {
code: 200,
data: user[DATA_TYPE],
msg: `${DATA_TYPE}获取成功`
};
} catch (error) {
console.error(`获取${DATA_TYPE}错误:`, error);
return {
code: -5,
msg: `获取${DATA_TYPE}错误: ${error.message}`
};
}
}
/**
* 获取单个装备数据
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @param {number} equipId 装备ID
* @returns {Object} 操作结果
*/
async function getEquip(db, openid, equipId) {
try {
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
const equipCount = user[DATA_TYPE][equipId];
if (equipCount === undefined) {
return {
code: -6,
msg: `${DATA_TYPE.slice(0, -1)} ${equipId} 未找到`
};
}
return {
code: 200,
data: {
item_id: equipId,
count: equipCount
},
msg: `${DATA_TYPE.slice(0, -1)} ${equipId} 获取成功`
};
} catch (error) {
console.error(`获取${DATA_TYPE}物品错误:`, error);
return {
code: -5,
msg: `获取${DATA_TYPE}物品错误: ${error.message}`
};
}
}
/**
* 添加装备
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @param {number} equipId 装备ID
* @param {number} count 添加数量
* @returns {Object} 操作结果
*/
async function addEquip(db, openid, equipId, count) {
try {
const _ = db.command;
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
if (typeof count !== 'number' || count < 0) {
return {
code: -3,
msg: "数量必须是非负数"
};
}
const currentCount = user[DATA_TYPE][equipId] || 0;
const newCount = currentCount + count;
let updateRes = await db.collection(user_db_name).doc(user._id).update({
data: {
[`${DATA_TYPE}.${equipId}`]: _.set(newCount),
last_save_time: _.set(Date.now())
}
});
if (updateRes?.stats?.updated >= 1) {
return {
code: 200,
data: {
item_id: equipId,
old_count: currentCount,
new_count: newCount,
added: count
},
msg: `${DATA_TYPE.slice(0, -1)} ${equipId} 添加成功`
};
} else {
return {
code: -1,
msg: `添加 ${DATA_TYPE.slice(0, -1)} 失败`
};
}
} catch (error) {
console.error(`添加${DATA_TYPE}物品错误:`, error);
return {
code: -5,
msg: `添加${DATA_TYPE}物品错误: ${error.message}`
};
}
}
/**
* 消耗装备
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @param {number} equipId 装备ID
* @param {number} count 消耗数量
* @returns {Object} 操作结果
*/
async function consumeEquip(db, openid, equipId, count) {
try {
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
if (typeof count !== 'number' || count < 0) {
return {
code: -3,
msg: "数量必须是非负数"
};
}
const currentCount = user[DATA_TYPE][equipId] || 0;
if (currentCount < count) {
return {
code: -6,
msg: `${DATA_TYPE.slice(0, -1)} ${equipId}不足, 当前: ${currentCount}, 需要: ${count}`
};
}
return await addEquip(db, openid, equipId, -count);
} catch (error) {
console.error(`消耗${DATA_TYPE}物品错误:`, error);
return {
code: -5,
msg: `消耗${DATA_TYPE}物品错误: ${error.message}`
};
}
}
/**
* 设置装备数量
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @param {number} equipId 装备ID
* @param {number} count 新的数量
* @returns {Object} 操作结果
*/
async function setEquip(db, openid, equipId, count) {
try {
const _ = db.command;
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
if (typeof count !== 'number' || count < 0) {
return {
code: -3,
msg: "数量必须是非负数"
};
}
const oldCount = user[DATA_TYPE][equipId] || 0;
let updateRes = await db.collection(user_db_name).doc(user._id).update({
data: {
[`${DATA_TYPE}.${equipId}`]: _.set(count),
last_save_time: _.set(Date.now())
}
});
if (updateRes?.stats?.updated >= 1) {
return {
code: 200,
data: {
item_id: equipId,
old_count: oldCount,
new_count: count
},
msg: `${DATA_TYPE.slice(0, -1)} ${equipId} 设置成功`
};
} else {
return {
code: -1,
msg: `设置 ${DATA_TYPE.slice(0, -1)} 失败`
};
}
} catch (error) {
console.error(`设置${DATA_TYPE}物品错误:`, error);
return {
code: -5,
msg: `设置${DATA_TYPE}物品错误: ${error.message}`
};
}
}
/**
* 批量更新装备库存
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @param {Object} updateData 更新数据对象
* @param {boolean} merge 是否合并更新（默认true）
* @returns {Object} 操作结果
*/
async function updateEquips(db, openid, updateData, merge = true) {
try {
const _ = db.command;
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
// 验证更新数据
if (!updateData || typeof updateData !== 'object') {
return {
code: -3,
msg: "无效的更新数据格式"
};
}
// 验证所有值都是非负数
for (const equipId in updateData) {
const count = updateData[equipId];
if (typeof count !== 'number' || count < 0) {
return {
code: -3,
msg: `装备 ${equipId} 的数量无效: ${count}`
};
}
}
let newData;
if (merge) {
// 合并更新
newData = { ...user[DATA_TYPE], ...updateData };
} else {
// 完全替换
newData = updateData;
}
let updateRes = await db.collection(user_db_name).doc(user._id).update({
data: {
[DATA_TYPE]: _.set(newData),
last_save_time: _.set(Date.now())
}
});
if (updateRes?.stats?.updated >= 1) {
return {
code: 200,
data: newData,
msg: `${DATA_TYPE} 更新成功`
};
} else {
return {
code: -1,
msg: `更新 ${DATA_TYPE} 失败`
};
}
} catch (error) {
console.error(`更新${DATA_TYPE}错误:`, error);
return {
code: -5,
msg: `更新${DATA_TYPE}错误: ${error.message}`
};
}
}
/**
* 重置装备库存数据
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @returns {Object} 操作结果
*/
async function resetEquips(db, openid) {
try {
const _ = db.command;
const { getNewUserInitData } = require('../user_init_data');
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
const defaultData = getNewUserInitData();
let resetRes = await db.collection(user_db_name).doc(user._id).update({
data: {
[DATA_TYPE]: _.set(defaultData[DATA_TYPE]),
last_save_time: _.set(Date.now()),
reset_time: _.set(Date.now())
}
});
if (resetRes?.stats?.updated >= 1) {
return {
code: 200,
data: defaultData[DATA_TYPE],
msg: `${DATA_TYPE} 重置成功`
};
} else {
return {
code: -1,
msg: `重置 ${DATA_TYPE} 失败`
};
}
} catch (error) {
console.error(`重置${DATA_TYPE}错误:`, error);
return {
code: -5,
msg: `重置${DATA_TYPE}错误: ${error.message}`
};
}
}
/**
* 获取拥有的装备列表（数量大于0的）
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @returns {Object} 操作结果
*/
async function getOwnedEquips(db, openid) {
try {
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
const ownedEquips = [];
for (const equipId in user[DATA_TYPE]) {
const count = user[DATA_TYPE][equipId];
if (count > 0) {
ownedEquips.push({
item_id: parseInt(equipId),
count: count
});
}
}
return {
code: 200,
data: {
owned_items: ownedEquips,
total_types: ownedEquips.length
},
msg: `拥有的${DATA_TYPE}获取成功`
};
} catch (error) {
console.error(`获取拥有的${DATA_TYPE}错误:`, error);
return {
code: -5,
msg: `获取拥有的${DATA_TYPE}错误: ${error.message}`
};
}
}
module.exports = {
getEquips,
getEquip,
addEquip,
consumeEquip,
setEquip,
updateEquips,
resetEquips,
getOwnedEquips
};

501
build-templates/wechatgame/cloud_functions/cocos_cloud/modules/inventory.js
View File

@@ -1,7 +1,8 @@
// 通用库存操作模块 (items, tals, equips)
const { getOrCreaterUser } = require('./auth');
const user_db_name = "cocos_users";
// 现在作为统一接口，调用各个独立模块
const itemsModule = require('./items');
const talsModule = require('./tals');
const equipsModule = require('./equips');
// 支持的数据类型
const SUPPORTED_TYPES = ['items', 'tals', 'equips'];
@@ -15,6 +16,24 @@ function validateDataType(dataType) {
return SUPPORTED_TYPES.includes(dataType);
}
/**
* 根据数据类型获取对应的模块
* @param {string} dataType 数据类型
* @returns {Object} 对应的模块
*/
function getModuleByType(dataType) {
switch(dataType) {
case 'items':
return itemsModule;
case 'tals':
return talsModule;
case 'equips':
return equipsModule;
default:
return null;
}
}
/**
* 获取库存数据
* @param {Object} db 数据库实例
@@ -23,33 +42,26 @@ function validateDataType(dataType) {
* @returns {Object} 操作结果
*/
async function getInventory(db, openid, dataType) {
try {
if (!validateDataType(dataType)) {
if (!validateDataType(dataType)) {
return {
code: -3,
msg: `无效的数据类型: ${dataType}`
};
}
const module = getModuleByType(dataType);
switch(dataType) {
case 'items':
return await module.getItems(db, openid);
case 'tals':
return await module.getTals(db, openid);
case 'equips':
return await module.getEquips(db, openid);
default:
return {
code: -3,
msg: `无效的数据类型: ${dataType}`
};
}
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
return {
code: 200,
data: user[dataType],
msg: `${dataType}获取成功`
};
} catch (error) {
console.error(`获取${dataType}错误:`, error);
return {
code: -5,
msg: `获取${dataType}错误: ${error.message}`
};
}
}
@@ -62,44 +74,26 @@ async function getInventory(db, openid, dataType) {
* @returns {Object} 操作结果
*/
async function getInventoryItem(db, openid, dataType, itemId) {
try {
if (!validateDataType(dataType)) {
if (!validateDataType(dataType)) {
return {
code: -3,
msg: `无效的数据类型: ${dataType}`
};
}
const module = getModuleByType(dataType);
switch(dataType) {
case 'items':
return await module.getItem(db, openid, itemId);
case 'tals':
return await module.getTal(db, openid, itemId);
case 'equips':
return await module.getEquip(db, openid, itemId);
default:
return {
code: -3,
msg: `无效的数据类型: ${dataType}`
};
}
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
const itemCount = user[dataType][itemId];
if (itemCount === undefined) {
return {
code: -6,
msg: `${dataType.slice(0, -1)} ${itemId} 未找到`
};
}
return {
code: 200,
data: {
item_id: itemId,
count: itemCount
},
msg: `${dataType.slice(0, -1)} ${itemId} 获取成功`
};
} catch (error) {
console.error(`获取${dataType}物品错误:`, error);
return {
code: -5,
msg: `获取${dataType}物品错误: ${error.message}`
};
}
}
@@ -113,63 +107,26 @@ async function getInventoryItem(db, openid, dataType, itemId) {
* @returns {Object} 操作结果
*/
async function addInventoryItem(db, openid, dataType, itemId, count) {
try {
if (!validateDataType(dataType)) {
if (!validateDataType(dataType)) {
return {
code: -3,
msg: `无效的数据类型: ${dataType}`
};
}
const module = getModuleByType(dataType);
switch(dataType) {
case 'items':
return await module.addItem(db, openid, itemId, count);
case 'tals':
return await module.addTal(db, openid, itemId, count);
case 'equips':
return await module.addEquip(db, openid, itemId, count);
default:
return {
code: -3,
msg: `无效的数据类型: ${dataType}`
};
}
const _ = db.command;
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
if (typeof count !== 'number' || count < 0) {
return {
code: -3,
msg: "数量必须是非负数"
};
}
const currentCount = user[dataType][itemId] || 0;
const newCount = currentCount + count;
let updateRes = await db.collection(user_db_name).doc(user._id).update({
data: {
[`${dataType}.${itemId}`]: _.set(newCount),
last_save_time: _.set(Date.now())
}
});
if (updateRes?.stats?.updated >= 1) {
return {
code: 200,
data: {
item_id: itemId,
old_count: currentCount,
new_count: newCount,
added: count
},
msg: `${dataType.slice(0, -1)} ${itemId} 添加成功`
};
} else {
return {
code: -1,
msg: `添加 ${dataType.slice(0, -1)} 失败`
};
}
} catch (error) {
console.error(`添加${dataType}物品错误:`, error);
return {
code: -5,
msg: `添加${dataType}物品错误: ${error.message}`
};
}
}
@@ -183,44 +140,26 @@ async function addInventoryItem(db, openid, dataType, itemId, count) {
* @returns {Object} 操作结果
*/
async function consumeInventoryItem(db, openid, dataType, itemId, count) {
try {
if (!validateDataType(dataType)) {
if (!validateDataType(dataType)) {
return {
code: -3,
msg: `无效的数据类型: ${dataType}`
};
}
const module = getModuleByType(dataType);
switch(dataType) {
case 'items':
return await module.consumeItem(db, openid, itemId, count);
case 'tals':
return await module.consumeTal(db, openid, itemId, count);
case 'equips':
return await module.consumeEquip(db, openid, itemId, count);
default:
return {
code: -3,
msg: `无效的数据类型: ${dataType}`
};
}
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
if (typeof count !== 'number' || count < 0) {
return {
code: -3,
msg: "数量必须是非负数"
};
}
const currentCount = user[dataType][itemId] || 0;
if (currentCount < count) {
return {
code: -6,
msg: `${dataType.slice(0, -1)} ${itemId}不足, 当前: ${currentCount}, 需要: ${count}`
};
}
return await addInventoryItem(db, openid, dataType, itemId, -count);
} catch (error) {
console.error(`消耗${dataType}物品错误:`, error);
return {
code: -5,
msg: `消耗${dataType}物品错误: ${error.message}`
};
}
}
@@ -234,61 +173,26 @@ async function consumeInventoryItem(db, openid, dataType, itemId, count) {
* @returns {Object} 操作结果
*/
async function setInventoryItem(db, openid, dataType, itemId, count) {
try {
if (!validateDataType(dataType)) {
if (!validateDataType(dataType)) {
return {
code: -3,
msg: `无效的数据类型: ${dataType}`
};
}
const module = getModuleByType(dataType);
switch(dataType) {
case 'items':
return await module.setItem(db, openid, itemId, count);
case 'tals':
return await module.setTal(db, openid, itemId, count);
case 'equips':
return await module.setEquip(db, openid, itemId, count);
default:
return {
code: -3,
msg: `无效的数据类型: ${dataType}`
};
}
const _ = db.command;
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
if (typeof count !== 'number' || count < 0) {
return {
code: -3,
msg: "数量必须是非负数"
};
}
const oldCount = user[dataType][itemId] || 0;
let updateRes = await db.collection(user_db_name).doc(user._id).update({
data: {
[`${dataType}.${itemId}`]: _.set(count),
last_save_time: _.set(Date.now())
}
});
if (updateRes?.stats?.updated >= 1) {
return {
code: 200,
data: {
item_id: itemId,
old_count: oldCount,
new_count: count
},
msg: `${dataType.slice(0, -1)} ${itemId} 设置成功`
};
} else {
return {
code: -1,
msg: `设置 ${dataType.slice(0, -1)} 失败`
};
}
} catch (error) {
console.error(`设置${dataType}物品错误:`, error);
return {
code: -5,
msg: `设置${dataType}物品错误: ${error.message}`
};
}
}
@@ -302,77 +206,27 @@ async function setInventoryItem(db, openid, dataType, itemId, count) {
* @returns {Object} 操作结果
*/
async function updateInventory(db, openid, dataType, updateData, merge = true) {
try {
if (!validateDataType(dataType)) {
return {
code: -3,
msg: `Invalid data type: ${dataType}`
};
}
const _ = db.command;
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "User not found"
};
}
// 验证更新数据
if (!updateData || typeof updateData !== 'object') {
return {
code: -3,
msg: "Invalid update data format"
};
}
// 验证所有值都是非负数
for (const itemId in updateData) {
const count = updateData[itemId];
if (typeof count !== 'number' || count < 0) {
return {
code: -3,
msg: `Invalid count for item ${itemId}: ${count}`
};
}
}
let newData;
if (merge) {
// 合并更新
newData = { ...user[dataType], ...updateData };
} else {
// 完全替换
newData = updateData;
}
let updateRes = await db.collection(user_db_name).doc(user._id).update({
data: {
[dataType]: _.set(newData),
last_save_time: _.set(Date.now())
}
});
if (updateRes?.stats?.updated >= 1) {
return {
code: 200,
data: newData,
msg: `${dataType} updated successfully`
};
} else {
return {
code: -1,
msg: `Update ${dataType} fail`
};
}
} catch (error) {
console.error(`Update ${dataType} error:`, error);
if (!validateDataType(dataType)) {
return {
code: -5,
msg: `Update ${dataType} error: ${error.message}`
code: -3,
msg: `无效的数据类型: ${dataType}`
};
}
const module = getModuleByType(dataType);
switch(dataType) {
case 'items':
return await module.updateItems(db, openid, updateData, merge);
case 'tals':
return await module.updateTals(db, openid, updateData, merge);
case 'equips':
return await module.updateEquips(db, openid, updateData, merge);
default:
return {
code: -3,
msg: `无效的数据类型: ${dataType}`
};
}
}
/**
@@ -383,52 +237,26 @@ async function updateInventory(db, openid, dataType, updateData, merge = true) {
* @returns {Object} 操作结果
*/
async function resetInventory(db, openid, dataType) {
try {
if (!validateDataType(dataType)) {
if (!validateDataType(dataType)) {
return {
code: -3,
msg: `无效的数据类型: ${dataType}`
};
}
const module = getModuleByType(dataType);
switch(dataType) {
case 'items':
return await module.resetItems(db, openid);
case 'tals':
return await module.resetTals(db, openid);
case 'equips':
return await module.resetEquips(db, openid);
default:
return {
code: -3,
msg: `Invalid data type: ${dataType}`
msg: `无效的数据类型: ${dataType}`
};
}
const _ = db.command;
const { getNewUserInitData } = require('../user_init_data');
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "User not found"
};
}
const defaultData = getNewUserInitData();
let resetRes = await db.collection(user_db_name).doc(user._id).update({
data: {
[dataType]: _.set(defaultData[dataType]),
last_save_time: _.set(Date.now()),
reset_time: _.set(Date.now())
}
});
if (resetRes?.stats?.updated >= 1) {
return {
code: 200,
data: defaultData[dataType],
msg: `${dataType} reset successfully`
};
} else {
return {
code: -1,
msg: `Reset ${dataType} fail`
};
}
} catch (error) {
console.error(`Reset ${dataType} error:`, error);
return {
code: -5,
msg: `Reset ${dataType} error: ${error.message}`
};
}
}
@@ -440,47 +268,26 @@ async function resetInventory(db, openid, dataType) {
* @returns {Object} 操作结果
*/
async function getOwnedItems(db, openid, dataType) {
try {
if (!validateDataType(dataType)) {
if (!validateDataType(dataType)) {
return {
code: -3,
msg: `无效的数据类型: ${dataType}`
};
}
const module = getModuleByType(dataType);
switch(dataType) {
case 'items':
return await module.getOwnedItems(db, openid);
case 'tals':
return await module.getOwnedTals(db, openid);
case 'equips':
return await module.getOwnedEquips(db, openid);
default:
return {
code: -3,
msg: `Invalid data type: ${dataType}`
msg: `无效的数据类型: ${dataType}`
};
}
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "User not found"
};
}
const ownedItems = [];
for (const itemId in user[dataType]) {
const count = user[dataType][itemId];
if (count > 0) {
ownedItems.push({
item_id: parseInt(itemId),
count: count
});
}
}
return {
code: 200,
data: {
owned_items: ownedItems,
total_types: ownedItems.length
},
msg: `Owned ${dataType} retrieved successfully`
};
} catch (error) {
console.error(`Get owned ${dataType} error:`, error);
return {
code: -5,
msg: `Get owned ${dataType} error: ${error.message}`
};
}
}

421
build-templates/wechatgame/cloud_functions/cocos_cloud/modules/items.js Normal file
View File

@@ -0,0 +1,421 @@
// 物品库存操作模块 (items)
const { getOrCreaterUser } = require('./auth');
const user_db_name = "cocos_users";
const DATA_TYPE = 'items';
/**
* 获取物品库存数据
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @returns {Object} 操作结果
*/
async function getItems(db, openid) {
try {
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
return {
code: 200,
data: user[DATA_TYPE],
msg: `${DATA_TYPE}获取成功`
};
} catch (error) {
console.error(`获取${DATA_TYPE}错误:`, error);
return {
code: -5,
msg: `获取${DATA_TYPE}错误: ${error.message}`
};
}
}
/**
* 获取单个物品数据
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @param {number} itemId 物品ID
* @returns {Object} 操作结果
*/
async function getItem(db, openid, itemId) {
try {
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
const itemCount = user[DATA_TYPE][itemId];
if (itemCount === undefined) {
return {
code: -6,
msg: `${DATA_TYPE.slice(0, -1)} ${itemId} 未找到`
};
}
return {
code: 200,
data: {
item_id: itemId,
count: itemCount
},
msg: `${DATA_TYPE.slice(0, -1)} ${itemId} 获取成功`
};
} catch (error) {
console.error(`获取${DATA_TYPE}物品错误:`, error);
return {
code: -5,
msg: `获取${DATA_TYPE}物品错误: ${error.message}`
};
}
}
/**
* 添加物品
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @param {number} itemId 物品ID
* @param {number} count 添加数量
* @returns {Object} 操作结果
*/
async function addItem(db, openid, itemId, count) {
try {
const _ = db.command;
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
if (typeof count !== 'number' || count < 0) {
return {
code: -3,
msg: "数量必须是非负数"
};
}
const currentCount = user[DATA_TYPE][itemId] || 0;
const newCount = currentCount + count;
let updateRes = await db.collection(user_db_name).doc(user._id).update({
data: {
[`${DATA_TYPE}.${itemId}`]: _.set(newCount),
last_save_time: _.set(Date.now())
}
});
if (updateRes?.stats?.updated >= 1) {
return {
code: 200,
data: {
item_id: itemId,
old_count: currentCount,
new_count: newCount,
added: count
},
msg: `${DATA_TYPE.slice(0, -1)} ${itemId} 添加成功`
};
} else {
return {
code: -1,
msg: `添加 ${DATA_TYPE.slice(0, -1)} 失败`
};
}
} catch (error) {
console.error(`添加${DATA_TYPE}物品错误:`, error);
return {
code: -5,
msg: `添加${DATA_TYPE}物品错误: ${error.message}`
};
}
}
/**
* 消耗物品
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @param {number} itemId 物品ID
* @param {number} count 消耗数量
* @returns {Object} 操作结果
*/
async function consumeItem(db, openid, itemId, count) {
try {
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
if (typeof count !== 'number' || count < 0) {
return {
code: -3,
msg: "数量必须是非负数"
};
}
const currentCount = user[DATA_TYPE][itemId] || 0;
if (currentCount < count) {
return {
code: -6,
msg: `${DATA_TYPE.slice(0, -1)} ${itemId}不足, 当前: ${currentCount}, 需要: ${count}`
};
}
return await addItem(db, openid, itemId, -count);
} catch (error) {
console.error(`消耗${DATA_TYPE}物品错误:`, error);
return {
code: -5,
msg: `消耗${DATA_TYPE}物品错误: ${error.message}`
};
}
}
/**
* 设置物品数量
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @param {number} itemId 物品ID
* @param {number} count 新的数量
* @returns {Object} 操作结果
*/
async function setItem(db, openid, itemId, count) {
try {
const _ = db.command;
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
if (typeof count !== 'number' || count < 0) {
return {
code: -3,
msg: "数量必须是非负数"
};
}
const oldCount = user[DATA_TYPE][itemId] || 0;
let updateRes = await db.collection(user_db_name).doc(user._id).update({
data: {
[`${DATA_TYPE}.${itemId}`]: _.set(count),
last_save_time: _.set(Date.now())
}
});
if (updateRes?.stats?.updated >= 1) {
return {
code: 200,
data: {
item_id: itemId,
old_count: oldCount,
new_count: count
},
msg: `${DATA_TYPE.slice(0, -1)} ${itemId} 设置成功`
};
} else {
return {
code: -1,
msg: `设置 ${DATA_TYPE.slice(0, -1)} 失败`
};
}
} catch (error) {
console.error(`设置${DATA_TYPE}物品错误:`, error);
return {
code: -5,
msg: `设置${DATA_TYPE}物品错误: ${error.message}`
};
}
}
/**
* 批量更新物品库存
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @param {Object} updateData 更新数据对象
* @param {boolean} merge 是否合并更新（默认true）
* @returns {Object} 操作结果
*/
async function updateItems(db, openid, updateData, merge = true) {
try {
const _ = db.command;
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
// 验证更新数据
if (!updateData || typeof updateData !== 'object') {
return {
code: -3,
msg: "无效的更新数据格式"
};
}
// 验证所有值都是非负数
for (const itemId in updateData) {
const count = updateData[itemId];
if (typeof count !== 'number' || count < 0) {
return {
code: -3,
msg: `物品 ${itemId} 的数量无效: ${count}`
};
}
}
let newData;
if (merge) {
// 合并更新
newData = { ...user[DATA_TYPE], ...updateData };
} else {
// 完全替换
newData = updateData;
}
let updateRes = await db.collection(user_db_name).doc(user._id).update({
data: {
[DATA_TYPE]: _.set(newData),
last_save_time: _.set(Date.now())
}
});
if (updateRes?.stats?.updated >= 1) {
return {
code: 200,
data: newData,
msg: `${DATA_TYPE} 更新成功`
};
} else {
return {
code: -1,
msg: `更新 ${DATA_TYPE} 失败`
};
}
} catch (error) {
console.error(`更新${DATA_TYPE}错误:`, error);
return {
code: -5,
msg: `更新${DATA_TYPE}错误: ${error.message}`
};
}
}
/**
* 重置物品库存数据
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @returns {Object} 操作结果
*/
async function resetItems(db, openid) {
try {
const _ = db.command;
const { getNewUserInitData } = require('../user_init_data');
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
const defaultData = getNewUserInitData();
let resetRes = await db.collection(user_db_name).doc(user._id).update({
data: {
[DATA_TYPE]: _.set(defaultData[DATA_TYPE]),
last_save_time: _.set(Date.now()),
reset_time: _.set(Date.now())
}
});
if (resetRes?.stats?.updated >= 1) {
return {
code: 200,
data: defaultData[DATA_TYPE],
msg: `${DATA_TYPE} 重置成功`
};
} else {
return {
code: -1,
msg: `重置 ${DATA_TYPE} 失败`
};
}
} catch (error) {
console.error(`重置${DATA_TYPE}错误:`, error);
return {
code: -5,
msg: `重置${DATA_TYPE}错误: ${error.message}`
};
}
}
/**
* 获取拥有的物品列表（数量大于0的）
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @returns {Object} 操作结果
*/
async function getOwnedItems(db, openid) {
try {
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
const ownedItems = [];
for (const itemId in user[DATA_TYPE]) {
const count = user[DATA_TYPE][itemId];
if (count > 0) {
ownedItems.push({
item_id: parseInt(itemId),
count: count
});
}
}
return {
code: 200,
data: {
owned_items: ownedItems,
total_types: ownedItems.length
},
msg: `拥有的${DATA_TYPE}获取成功`
};
} catch (error) {
console.error(`获取拥有的${DATA_TYPE}错误:`, error);
return {
code: -5,
msg: `获取拥有的${DATA_TYPE}错误: ${error.message}`
};
}
}
module.exports = {
getItems,
getItem,
addItem,
consumeItem,
setItem,
updateItems,
resetItems,
getOwnedItems
};

421
build-templates/wechatgame/cloud_functions/cocos_cloud/modules/tals.js Normal file
View File

@@ -0,0 +1,421 @@
// 天赋库存操作模块 (tals)
const { getOrCreaterUser } = require('./auth');
const user_db_name = "cocos_users";
const DATA_TYPE = 'tals';
/**
* 获取天赋库存数据
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @returns {Object} 操作结果
*/
async function getTals(db, openid) {
try {
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
return {
code: 200,
data: user[DATA_TYPE],
msg: `${DATA_TYPE}获取成功`
};
} catch (error) {
console.error(`获取${DATA_TYPE}错误:`, error);
return {
code: -5,
msg: `获取${DATA_TYPE}错误: ${error.message}`
};
}
}
/**
* 获取单个天赋数据
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @param {number} talId 天赋ID
* @returns {Object} 操作结果
*/
async function getTal(db, openid, talId) {
try {
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
const talCount = user[DATA_TYPE][talId];
if (talCount === undefined) {
return {
code: -6,
msg: `${DATA_TYPE.slice(0, -1)} ${talId} 未找到`
};
}
return {
code: 200,
data: {
item_id: talId,
count: talCount
},
msg: `${DATA_TYPE.slice(0, -1)} ${talId} 获取成功`
};
} catch (error) {
console.error(`获取${DATA_TYPE}物品错误:`, error);
return {
code: -5,
msg: `获取${DATA_TYPE}物品错误: ${error.message}`
};
}
}
/**
* 添加天赋
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @param {number} talId 天赋ID
* @param {number} count 添加数量
* @returns {Object} 操作结果
*/
async function addTal(db, openid, talId, count) {
try {
const _ = db.command;
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
if (typeof count !== 'number' || count < 0) {
return {
code: -3,
msg: "数量必须是非负数"
};
}
const currentCount = user[DATA_TYPE][talId] || 0;
const newCount = currentCount + count;
let updateRes = await db.collection(user_db_name).doc(user._id).update({
data: {
[`${DATA_TYPE}.${talId}`]: _.set(newCount),
last_save_time: _.set(Date.now())
}
});
if (updateRes?.stats?.updated >= 1) {
return {
code: 200,
data: {
item_id: talId,
old_count: currentCount,
new_count: newCount,
added: count
},
msg: `${DATA_TYPE.slice(0, -1)} ${talId} 添加成功`
};
} else {
return {
code: -1,
msg: `添加 ${DATA_TYPE.slice(0, -1)} 失败`
};
}
} catch (error) {
console.error(`添加${DATA_TYPE}物品错误:`, error);
return {
code: -5,
msg: `添加${DATA_TYPE}物品错误: ${error.message}`
};
}
}
/**
* 消耗天赋
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @param {number} talId 天赋ID
* @param {number} count 消耗数量
* @returns {Object} 操作结果
*/
async function consumeTal(db, openid, talId, count) {
try {
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
if (typeof count !== 'number' || count < 0) {
return {
code: -3,
msg: "数量必须是非负数"
};
}
const currentCount = user[DATA_TYPE][talId] || 0;
if (currentCount < count) {
return {
code: -6,
msg: `${DATA_TYPE.slice(0, -1)} ${talId}不足, 当前: ${currentCount}, 需要: ${count}`
};
}
return await addTal(db, openid, talId, -count);
} catch (error) {
console.error(`消耗${DATA_TYPE}物品错误:`, error);
return {
code: -5,
msg: `消耗${DATA_TYPE}物品错误: ${error.message}`
};
}
}
/**
* 设置天赋数量
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @param {number} talId 天赋ID
* @param {number} count 新的数量
* @returns {Object} 操作结果
*/
async function setTal(db, openid, talId, count) {
try {
const _ = db.command;
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
if (typeof count !== 'number' || count < 0) {
return {
code: -3,
msg: "数量必须是非负数"
};
}
const oldCount = user[DATA_TYPE][talId] || 0;
let updateRes = await db.collection(user_db_name).doc(user._id).update({
data: {
[`${DATA_TYPE}.${talId}`]: _.set(count),
last_save_time: _.set(Date.now())
}
});
if (updateRes?.stats?.updated >= 1) {
return {
code: 200,
data: {
item_id: talId,
old_count: oldCount,
new_count: count
},
msg: `${DATA_TYPE.slice(0, -1)} ${talId} 设置成功`
};
} else {
return {
code: -1,
msg: `设置 ${DATA_TYPE.slice(0, -1)} 失败`
};
}
} catch (error) {
console.error(`设置${DATA_TYPE}物品错误:`, error);
return {
code: -5,
msg: `设置${DATA_TYPE}物品错误: ${error.message}`
};
}
}
/**
* 批量更新天赋库存
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @param {Object} updateData 更新数据对象
* @param {boolean} merge 是否合并更新（默认true）
* @returns {Object} 操作结果
*/
async function updateTals(db, openid, updateData, merge = true) {
try {
const _ = db.command;
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
// 验证更新数据
if (!updateData || typeof updateData !== 'object') {
return {
code: -3,
msg: "无效的更新数据格式"
};
}
// 验证所有值都是非负数
for (const talId in updateData) {
const count = updateData[talId];
if (typeof count !== 'number' || count < 0) {
return {
code: -3,
msg: `天赋 ${talId} 的数量无效: ${count}`
};
}
}
let newData;
if (merge) {
// 合并更新
newData = { ...user[DATA_TYPE], ...updateData };
} else {
// 完全替换
newData = updateData;
}
let updateRes = await db.collection(user_db_name).doc(user._id).update({
data: {
[DATA_TYPE]: _.set(newData),
last_save_time: _.set(Date.now())
}
});
if (updateRes?.stats?.updated >= 1) {
return {
code: 200,
data: newData,
msg: `${DATA_TYPE} 更新成功`
};
} else {
return {
code: -1,
msg: `更新 ${DATA_TYPE} 失败`
};
}
} catch (error) {
console.error(`更新${DATA_TYPE}错误:`, error);
return {
code: -5,
msg: `更新${DATA_TYPE}错误: ${error.message}`
};
}
}
/**
* 重置天赋库存数据
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @returns {Object} 操作结果
*/
async function resetTals(db, openid) {
try {
const _ = db.command;
const { getNewUserInitData } = require('../user_init_data');
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
const defaultData = getNewUserInitData();
let resetRes = await db.collection(user_db_name).doc(user._id).update({
data: {
[DATA_TYPE]: _.set(defaultData[DATA_TYPE]),
last_save_time: _.set(Date.now()),
reset_time: _.set(Date.now())
}
});
if (resetRes?.stats?.updated >= 1) {
return {
code: 200,
data: defaultData[DATA_TYPE],
msg: `${DATA_TYPE} 重置成功`
};
} else {
return {
code: -1,
msg: `重置 ${DATA_TYPE} 失败`
};
}
} catch (error) {
console.error(`重置${DATA_TYPE}错误:`, error);
return {
code: -5,
msg: `重置${DATA_TYPE}错误: ${error.message}`
};
}
}
/**
* 获取拥有的天赋列表（数量大于0的）
* @param {Object} db 数据库实例
* @param {string} openid 用户openid
* @returns {Object} 操作结果
*/
async function getOwnedTals(db, openid) {
try {
let user = await getOrCreaterUser(db, openid);
if (!user) {
return {
code: -4,
msg: "未找到用户"
};
}
const ownedTals = [];
for (const talId in user[DATA_TYPE]) {
const count = user[DATA_TYPE][talId];
if (count > 0) {
ownedTals.push({
item_id: parseInt(talId),
count: count
});
}
}
return {
code: 200,
data: {
owned_items: ownedTals,
total_types: ownedTals.length
},
msg: `拥有的${DATA_TYPE}获取成功`
};
} catch (error) {
console.error(`获取拥有的${DATA_TYPE}错误:`, error);
return {
code: -5,
msg: `获取拥有的${DATA_TYPE}错误: ${error.message}`
};
}
}
module.exports = {
getTals,
getTal,
addTal,
consumeTal,
setTal,
updateTals,
resetTals,
getOwnedTals
};