DismantleHandler.php 2.9 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697
  1. <?php
  2. namespace App\Module\AppGame\Handler\Item;
  3. use App\Module\AppGame\Handler\BaseHandler;
  4. use App\Module\GameItems\Services\DismantleService;
  5. use App\Module\GameItems\Validations\ItemDismantleValidation;
  6. use Google\Protobuf\Internal\Message;
  7. use Illuminate\Support\Facades\Log;
  8. use UCore\Helper\Logger;
  9. use Uraus\Kku\Request\RequestItemDismantle;
  10. use Uraus\Kku\Response\ResponseItemDismantle;
  11. use Uraus\Kku\Common\RESPONSE_CODE;
  12. use UCore\Exception\LogicException;
  13. /**
  14. * 处理物品分解请求
  15. */
  16. class DismantleHandler extends BaseHandler
  17. {
  18. /**
  19. * 是否需要登录
  20. * @var bool
  21. */
  22. protected bool $need_login = true;
  23. /**
  24. * 处理物品分解请求
  25. *
  26. * @param RequestItemDismantle $data 物品分解请求数据
  27. * @return ResponseItemDismantle 物品分解响应
  28. */
  29. public function handle(Message $data): Message
  30. {
  31. // 创建响应对象
  32. $response = new ResponseItemDismantle();
  33. try {
  34. // 获取请求参数
  35. $itemId = $data->getId();
  36. $quantity = $data->getNumber();
  37. $userId = $this->user_id;
  38. // 设置默认数量
  39. if ($quantity <= 0) {
  40. $quantity = 1;
  41. }
  42. // 先进行验证,避免不必要的事务开销
  43. $validation = new ItemDismantleValidation([
  44. 'user_id' => $userId,
  45. 'item_id' => $itemId,
  46. 'quantity' => $quantity,
  47. 'instance_id' => 0 // 默认不指定实例
  48. ]);
  49. // 验证数据
  50. $validation->validated();
  51. // 调用分解服务(服务内部会处理事务)
  52. $result = DismantleService::dismantleItem($userId, $itemId, null, $quantity, [
  53. 'source_type' => 'app_dismantle',
  54. 'device_info' => request()->userAgent(),
  55. 'ip_address' => request()->ip(),
  56. ]);
  57. if (!$result) {
  58. throw new LogicException("分解失败,请检查物品是否存在或是否可分解");
  59. }
  60. // 设置响应状态
  61. $this->response->setCode(RESPONSE_CODE::OK);
  62. $this->response->setMsg('分解成功');
  63. Log::info('用户物品分解成功', [
  64. 'user_id' => $userId,
  65. 'item_id' => $itemId,
  66. 'quantity' => $quantity,
  67. 'result' => $result
  68. ]);
  69. } catch (\Exception $e) {
  70. Logger::error('物品分解操作异常', [
  71. 'user_id' => $userId ?? null,
  72. 'item_id' => $itemId ?? null,
  73. 'quantity' => $quantity ?? null,
  74. 'error' => $e->getMessage(),
  75. 'trace' => $e->getTraceAsString()
  76. ]);
  77. // 重新抛出异常,交由框架处理
  78. throw $e;
  79. }
  80. return $response;
  81. }
  82. }