kknongchang_2506/AiWork/2025年06月/19日0824-奖励扣除收集系统用户区分实现.md

奖励扣除收集系统用户区分实现

任务概述

修改奖励和消耗收集系统 collectRewardAndDeductData，实现按用户区分收集和使用，解决原来没有区分用户的问题。

问题背景

原来的奖励扣除收集系统在收集数据时没有区分用户，所有用户的奖励和扣除数据都混在一起，无法准确追踪每个用户的具体收益和消耗情况。

修改内容

1. 服务层修改

1.1 RewardCollectorService

文件：app/Module/Game/Services/RewardCollectorService.php

修改内容：

• addItemReward() 方法增加 $userId 参数
• addCoinReward() 方法增加 $userId 参数
  
• addGodReward() 方法增加 $userId 参数
• getRewards() 方法支持可选的 $userId 参数
• hasRewards() 方法支持可选的 $userId 参数

1.2 DeductCollectorService

文件：app/Module/Game/Services/DeductCollectorService.php

修改内容：

• addItemDeduct() 方法增加 $userId 参数
• addCoinDeduct() 方法增加 $userId 参数
• getDeducts() 方法支持可选的 $userId 参数
• hasDeducts() 方法支持可选的 $userId 参数
• 新增 getItemDeducts() 和 getCoinDeducts() 方法

2. 逻辑层修改

2.1 RewardCollectorLogic

文件：app/Module/Game/Logics/RewardCollectorLogic.php

修改内容：

• 数据结构改为按用户分组：[user_id => [item_key => data]]
• 所有方法增加用户ID参数
• 查询方法支持按用户过滤或返回所有用户数据

2.2 DeductCollectorLogic

文件：app/Module/Game/Logics/DeductCollectorLogic.php

修改内容：

• 数据结构改为按用户分组：[user_id => [item_key => data]]
• 所有方法增加用户ID参数
• 查询方法支持按用户过滤或返回所有用户数据

3. 监听器修改

3.1 ItemQuantityChangedListener

文件：app/Module/Game/Listeners/ItemQuantityChangedListener.php

修改内容：

• collectRewardAndDeductData() 方法传递 $event->userId 参数
• 日志记录增加用户ID信息

3.2 FundChangedListener

文件：app/Module/Game/Listeners/FundChangedListener.php

修改内容：

• collectRewardAndDeductData() 方法传递 $event->userId 参数
• 日志记录增加用户ID信息

4. 文档更新

4.1 系统文档

文件：app/Module/Game/Docs/奖励扣除收集系统.md

更新内容：

• 手动收集示例增加用户ID参数
• 查询数据示例展示按用户查询功能
• 注意事项增加用户区分说明

4.2 历史文档

文件：AiWork/2024年12月/18日1500-Response奖励扣除数据实现.md

更新内容：

• 手动收集示例更新为包含用户ID的新格式

数据结构变化

修改前

// 物品奖励数据
[
    'item_1_0' => ['item_id' => 1, 'instance_id' => 0, 'quantity' => 10],
    'item_2_0' => ['item_id' => 2, 'instance_id' => 0, 'quantity' => 5]
]

// 代币奖励数据
[
    1 => ['type' => 1, 'quantity' => 100],
    2 => ['type' => 2, 'quantity' => 50]
]

修改后

// 物品奖励数据（按用户分组）
[
    1001 => [
        'item_1_0' => ['user_id' => 1001, 'item_id' => 1, 'instance_id' => 0, 'quantity' => 10]
    ],
    1002 => [
        'item_2_0' => ['user_id' => 1002, 'item_id' => 2, 'instance_id' => 0, 'quantity' => 5]
    ]
]

// 代币奖励数据（按用户分组）
[
    1001 => [
        1 => ['user_id' => 1001, 'type' => 1, 'quantity' => 100]
    ],
    1002 => [
        2 => ['user_id' => 1002, 'type' => 2, 'quantity' => 50]
    ]
]

API 变化

新增功能

// 获取指定用户的奖励数据
$userRewards = RewardCollectorService::getRewards($userId);

// 获取指定用户的扣除数据
$userDeducts = DeductCollectorService::getDeducts($userId);

// 检查指定用户是否有奖励数据
$hasUserRewards = RewardCollectorService::hasRewards($userId);

// 检查指定用户是否有扣除数据
$hasUserDeducts = DeductCollectorService::hasDeducts($userId);

兼容性

• 所有查询方法都支持不传用户ID，此时返回所有用户的合并数据
• 保持向后兼容，现有调用方式仍然有效

测试验证

测试命令

创建了专门的测试命令：php artisan test:reward-deduct-collector-user-separation

测试内容

1. 手动收集测试：验证手动添加不同用户的奖励扣除数据
2. 事件收集测试：验证事件触发时自动按用户收集数据
3. 查询功能测试：验证按用户查询和全局查询功能
4. 数据隔离验证：确保不同用户的数据完全隔离

测试结果

所有用户奖励数据：
- 物品奖励数量：3
- 代币奖励数量：3
- 神像奖励数量：1

用户1001奖励数据：
- 物品奖励数量：2
- 代币奖励数量：2
- 神像奖励数量：1

用户1002奖励数据：
- 物品奖励数量：1
- 代币奖励数量：1
- 神像奖励数量：0

✅ 用户数据隔离验证通过

优势

1. 精确追踪：可以准确追踪每个用户的奖励和扣除情况
2. 数据隔离：不同用户的数据完全隔离，避免混淆
3. 灵活查询：支持按用户查询或全局查询
4. 向后兼容：保持现有API的兼容性
5. 性能优化：按用户分组存储，查询效率更高

注意事项

1. 用户ID必传：所有添加方法现在都需要传递用户ID
2. 数据结构变化：内部数据结构发生变化，但对外API保持兼容
3. 内存使用：按用户分组可能会增加一些内存使用，但在可接受范围内
4. 测试覆盖：需要确保所有调用点都正确传递用户ID

总结

此次修改成功实现了奖励扣除收集系统的用户区分功能，解决了原来数据混合的问题。通过按用户分组存储和查询，系统现在可以精确追踪每个用户的收益和消耗情况，为后续的数据分析和用户体验优化提供了坚实的基础。