DismantleHandler.php 3.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120
  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 Uraus\Kku\Request\RequestItemDismantle;
  9. use Uraus\Kku\Response\ResponseItemDismantle;
  10. use UCore\Exception\LogicException;
  11. /**
  12. * 处理物品分解请求
  13. */
  14. class DismantleHandler extends BaseHandler
  15. {
  16. /**
  17. * 是否需要登录
  18. * @var bool
  19. */
  20. protected bool $need_login = true;
  21. /**
  22. * 处理物品分解请求
  23. *
  24. * @param RequestItemDismantle $data 物品分解请求数据
  25. * @return ResponseItemDismantle 物品分解响应
  26. */
  27. public function handle(Message $data): Message
  28. {
  29. // 创建响应对象
  30. $response = new ResponseItemDismantle();
  31. try {
  32. // 获取请求参数
  33. $itemId = $data->getId();
  34. $quantity = $data->getNumber();
  35. $userId = $this->user_id;
  36. // 设置默认数量
  37. if ($quantity <= 0) {
  38. $quantity = 1;
  39. }
  40. // 先进行验证,避免不必要的事务开销
  41. $validation = new ItemDismantleValidation([
  42. 'user_id' => $userId,
  43. 'item_id' => $itemId,
  44. 'quantity' => $quantity,
  45. 'instance_id' => 0 // 默认不指定实例
  46. ]);
  47. // 验证数据
  48. $validation->validated();
  49. // 调用分解服务(服务内部会处理事务)
  50. $result = DismantleService::dismantleItem($userId, $itemId, null, $quantity, [
  51. 'source_type' => 'app_dismantle',
  52. 'device_info' => request()->userAgent(),
  53. 'ip_address' => request()->ip(),
  54. ]);
  55. if (!$result) {
  56. throw new LogicException("分解失败,请检查物品是否存在或是否可分解");
  57. }
  58. // 设置响应状态
  59. $this->response->setCode(0);
  60. $this->response->setMsg('分解成功');
  61. Log::info('用户物品分解成功', [
  62. 'user_id' => $userId,
  63. 'item_id' => $itemId,
  64. 'quantity' => $quantity,
  65. 'result' => $result
  66. ]);
  67. } catch (\UCore\Exception\ValidateException $e) {
  68. // 验证失败
  69. $this->response->setCode(400);
  70. $this->response->setMsg($e->getMessage());
  71. Log::warning('物品分解验证失败', [
  72. 'user_id' => $userId ?? null,
  73. 'item_id' => $itemId ?? null,
  74. 'quantity' => $quantity ?? null,
  75. 'error' => $e->getMessage()
  76. ]);
  77. } catch (LogicException $e) {
  78. // 业务逻辑异常
  79. $this->response->setCode(400);
  80. $this->response->setMsg($e->getMessage());
  81. Log::warning('用户物品分解失败', [
  82. 'user_id' => $userId ?? null,
  83. 'item_id' => $itemId ?? null,
  84. 'quantity' => $quantity ?? null,
  85. 'error' => $e->getMessage()
  86. ]);
  87. } catch (\Exception $e) {
  88. // 系统异常
  89. $this->response->setCode(500);
  90. $this->response->setMsg('系统错误,请稍后再试');
  91. Log::error('物品分解操作异常', [
  92. 'user_id' => $userId ?? null,
  93. 'item_id' => $itemId ?? null,
  94. 'quantity' => $quantity ?? null,
  95. 'error' => $e->getMessage(),
  96. 'trace' => $e->getTraceAsString()
  97. ]);
  98. }
  99. return $response;
  100. }
  101. }