PesticideHandler.php 2.7 KB

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