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 Uraus\Kku\Common\RESPONSE_CODE;
  12. use UCore\Exception\LogicException;
  13. /**
  14. * 处理除草操作请求
  15. * Weedicide
  16. *
  17. */
  18. class WeedicideHandler extends BaseHandler
  19. {
  20. /**
  21. * 是否需要登录
  22. * @var bool
  23. */
  24. protected bool $need_login = true;
  25. /**
  26. * 处理除草操作请求
  27. *
  28. * @param RequestLandWeedicide $data 除草操作请求数据
  29. * @return ResponseLandWeedicide 除草操作响应
  30. */
  31. public function handle(Message $data): Message
  32. {
  33. // 创建响应对象
  34. $response = new ResponseLandWeedicide();
  35. try {
  36. // 获取请求参数
  37. $landId = $data->getLandId();
  38. $userItemId = $data->getItemId();
  39. $userId = $this->user_id;
  40. // 先进行验证,避免不必要的事务开销
  41. $validation = new \App\Module\Farm\Validations\DisasterRemovalValidation([
  42. 'user_id' => $userId,
  43. 'land_id' => $landId,
  44. 'item_id' => $userItemId,
  45. 'disaster_type' => DISASTER_TYPE::WEED->value
  46. ]);
  47. // 验证数据
  48. $validation->validated();
  49. // 验证通过后,开启事务
  50. DB::beginTransaction();
  51. // 执行业务逻辑(不再需要验证)
  52. $result = CropService::removeDisasterWithItem(
  53. $userId,
  54. $landId,
  55. $userItemId,
  56. DISASTER_TYPE::WEED->value,
  57. 'land_weedicide'
  58. );
  59. // 提交事务
  60. DB::commit();
  61. // 设置响应状态
  62. $this->response->setCode(RESPONSE_CODE::OK);
  63. $this->response->setMsg($result['message']);
  64. } catch (\Exception $e) {
  65. // 系统异常,需要回滚事务
  66. if (DB::transactionLevel() > 0) {
  67. DB::rollBack();
  68. }
  69. Log::error('除草操作异常', [
  70. 'user_id' => $this->user_id,
  71. 'land_id' => $landId ?? null,
  72. 'item_id' => $userItemId ?? null,
  73. 'error' => $e->getMessage(),
  74. 'trace' => $e->getTraceAsString()
  75. ]);
  76. // 重新抛出异常,交由框架处理
  77. throw $e;
  78. }
  79. return $response;
  80. }
  81. }