WeedicideHandler.php 2.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596
  1. <?php
  2. namespace App\Module\AppGame\Handler\Land;
  3. use App\Module\AppGame\Handler\BaseHandler;
  4. use App\Module\Farm\Services\CropService;
  5. use App\Module\Farm\Enums\DISASTER_TYPE;
  6. use Google\Protobuf\Internal\Message;
  7. use Illuminate\Support\Facades\DB;
  8. use Illuminate\Support\Facades\Log;
  9. use Uraus\Kku\Request\RequestLandWeedicide;
  10. use Uraus\Kku\Response\ResponseLandWeedicide;
  11. use UCore\Exception\LogicException;
  12. /**
  13. * 处理除草操作请求
  14. */
  15. class WeedicideHandler extends BaseHandler
  16. {
  17. /**
  18. * 是否需要登录
  19. * @var bool
  20. */
  21. protected bool $need_login = true;
  22. /**
  23. * 处理除草操作请求
  24. *
  25. * @param RequestLandWeedicide $data 除草操作请求数据
  26. * @return ResponseLandWeedicide 除草操作响应
  27. */
  28. public function handle(Message $data): Message
  29. {
  30. // 创建响应对象
  31. $response = new ResponseLandWeedicide();
  32. try {
  33. // 获取请求参数
  34. $landId = $data->getLandId();
  35. $userItemId = $data->getItemId();
  36. $userId = $this->user_id;
  37. // 开启事务
  38. DB::beginTransaction();
  39. // 使用统一的灾害去除逻辑,包含概率判断和事务检测
  40. $result = CropService::removeDisasterWithItem(
  41. $userId,
  42. $landId,
  43. $userItemId,
  44. DISASTER_TYPE::WEED->value,
  45. 'land_weedicide'
  46. );
  47. // 提交事务
  48. DB::commit();
  49. // 设置响应状态
  50. $this->response->setCode(0);
  51. $this->response->setMsg($result['message']);
  52. } catch (LogicException $e) {
  53. // 回滚事务
  54. DB::rollBack();
  55. // 设置错误响应
  56. $this->response->setCode(400);
  57. $this->response->setMsg($e->getMessage());
  58. Log::warning('用户除草失败', [
  59. 'user_id' => $this->user_id,
  60. 'land_id' => $landId ?? null,
  61. 'item_id' => $userItemId ?? null,
  62. 'error' => $e->getMessage(),
  63. 'trace' => $e->getTraceAsString()
  64. ]);
  65. } catch (\Exception $e) {
  66. // 回滚事务
  67. DB::rollBack();
  68. // 设置错误响应
  69. $this->response->setCode(500);
  70. $this->response->setMsg('系统错误,请稍后再试');
  71. Log::error('除草操作异常', [
  72. 'user_id' => $this->user_id,
  73. 'land_id' => $landId ?? null,
  74. 'item_id' => $userItemId ?? null,
  75. 'error' => $e->getMessage(),
  76. 'trace' => $e->getTraceAsString()
  77. ]);
  78. }
  79. return $response;
  80. }
  81. }