RemoveCropHandler.php 3.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116
  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\Validations\CropRemoveValidation;
  6. use App\Module\GameItems\Services\ItemService;
  7. use Google\Protobuf\Internal\Message;
  8. use Illuminate\Support\Facades\DB;
  9. use Illuminate\Support\Facades\Log;
  10. use Uraus\Kku\Request\RequestLandRemoveCrop;
  11. use Uraus\Kku\Response\ResponseLandRemoveCrop;
  12. use UCore\Exception\LogicException;
  13. /**
  14. * 处理铲除作物操作请求
  15. * RemoveCrop
  16. */
  17. class RemoveCropHandler extends BaseHandler
  18. {
  19. /**
  20. * 是否需要登录
  21. * @var bool
  22. */
  23. protected bool $need_login = true;
  24. /**
  25. * 处理铲除作物操作请求
  26. *
  27. * @param RequestLandRemoveCrop $data 铲除作物操作请求数据
  28. * @return ResponseLandRemoveCrop 铲除作物操作响应
  29. */
  30. public function handle(Message $data): Message
  31. {
  32. // 创建响应对象
  33. $response = new ResponseLandRemoveCrop();
  34. // 获取请求参数
  35. $landId = $data->getLandId();
  36. $toolItemId = $data->getItemId() ?? 0; // 铲除工具ID,可选
  37. $userId = $this->user_id;
  38. // 先进行验证,避免不必要的事务开销
  39. $validation = new CropRemoveValidation([
  40. 'user_id' => $userId,
  41. 'land_id' => $landId,
  42. 'tool_item_id' => $toolItemId
  43. ]);
  44. // 验证数据
  45. $validation->validated();
  46. try {
  47. // 验证通过后,开启事务
  48. DB::beginTransaction();
  49. // 调用铲除作物服务
  50. $result = CropService::removeCrop($userId, $landId);
  51. if (!$result['success']) {
  52. throw new LogicException("铲除作物失败,请检查土地状态");
  53. }
  54. // 如果使用了工具,消耗工具
  55. if ($toolItemId > 0) {
  56. ItemService::consumeItem($userId, $toolItemId, null, 1, [
  57. 'source_type' => 'land_remove_crop',
  58. 'source_id' => $landId,
  59. 'details' => ['land_id' => $landId]
  60. ]);
  61. }
  62. // 提交事务
  63. DB::commit();
  64. // 如果土地状态发生变更,触发土地状态变更事件(在事务外)
  65. if ($result['status_changed']) {
  66. event(new \App\Module\Farm\Events\LandStatusChangedEvent(
  67. $userId,
  68. $landId,
  69. $result['old_status'],
  70. $result['new_status']
  71. ));
  72. }
  73. Log::info('用户铲除作物成功', [
  74. 'user_id' => $userId,
  75. 'land_id' => $landId,
  76. 'tool_item_id' => $toolItemId,
  77. 'status_changed' => $result['status_changed'],
  78. 'old_status' => $result['old_status'],
  79. 'new_status' => $result['new_status']
  80. ]);
  81. } catch (\Exception $e) {
  82. // 系统异常,需要回滚事务
  83. if (DB::transactionLevel() > 0) {
  84. DB::rollBack();
  85. }
  86. $this->response->setCode(500);
  87. $this->response->setMsg('系统错误,请稍后再试');
  88. Log::error('铲除作物操作异常', [
  89. 'user_id' => $userId ?? null,
  90. 'land_id' => $landId ?? null,
  91. 'tool_item_id' => $toolItemId ?? null,
  92. 'error' => $e->getMessage(),
  93. 'trace' => $e->getTraceAsString()
  94. ]);
  95. }
  96. return $response;
  97. }
  98. }