OpenBoxHandler.php 2.9 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495
  1. <?php
  2. namespace App\Module\AppGame\Handler\Item;
  3. use App\Module\AppGame\Handler\BaseHandler;
  4. use App\Module\GameItems\Services\ChestService;
  5. use Google\Protobuf\Internal\Message;
  6. use Illuminate\Support\Facades\Log;
  7. use Uraus\Kku\Request\RequestItemOpenBox;
  8. use Uraus\Kku\Response\ResponseItemOpenBox;
  9. use UCore\Exception\LogicException;
  10. /**
  11. * 处理宝箱开启请求
  12. */
  13. class OpenBoxHandler extends BaseHandler
  14. {
  15. /**
  16. * 是否需要登录
  17. * @var bool
  18. */
  19. protected bool $need_login = true;
  20. /**
  21. * 处理宝箱开启请求
  22. *
  23. * @param RequestItemOpenBox $data 宝箱开启请求数据
  24. * @return ResponseItemOpenBox 宝箱开启响应
  25. */
  26. public function handle(Message $data): Message
  27. {
  28. // 创建响应对象
  29. $response = new ResponseItemOpenBox();
  30. try {
  31. // 获取请求参数
  32. $itemId = $data->getItemId();
  33. $instanceId = $data->getItemInstanceId();
  34. $selectIds = $data->getSelectIds()->getIterator()->getArrayCopy();
  35. $userId = $this->user_id;
  36. // 验证参数
  37. if ($itemId <= 0) {
  38. throw new LogicException("宝箱ID无效");
  39. }
  40. // 调用宝箱开启服务
  41. $result = ChestService::openChest($userId, $itemId, $instanceId, [
  42. 'select_ids' => $selectIds,
  43. 'source_type' => 'app_open_box',
  44. 'device_info' => request()->userAgent(),
  45. 'ip_address' => request()->ip(),
  46. ]);
  47. if (!$result) {
  48. throw new LogicException("开启宝箱失败,请检查宝箱是否存在或是否可开启");
  49. }
  50. // 设置响应状态
  51. $this->response->setCode(0);
  52. $this->response->setMsg('开启宝箱成功');
  53. Log::info('用户开启宝箱成功', [
  54. 'user_id' => $userId,
  55. 'item_id' => $itemId,
  56. 'instance_id' => $instanceId,
  57. 'select_ids' => $selectIds,
  58. 'result' => $result
  59. ]);
  60. } catch (LogicException $e) {
  61. // 设置错误响应
  62. $this->response->setCode(400);
  63. $this->response->setMsg($e->getMessage());
  64. Log::warning('用户开启宝箱失败', [
  65. 'user_id' => $this->user_id,
  66. 'error' => $e->getMessage(),
  67. 'trace' => $e->getTraceAsString()
  68. ]);
  69. } catch (\Exception $e) {
  70. // 设置错误响应
  71. $this->response->setCode(500);
  72. $this->response->setMsg('系统错误,请稍后再试');
  73. Log::error('开启宝箱操作异常', [
  74. 'user_id' => $this->user_id,
  75. 'error' => $e->getMessage(),
  76. 'trace' => $e->getTraceAsString()
  77. ]);
  78. }
  79. return $response;
  80. }
  81. }