RemoveCropHandler.php 6.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169
  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\Game\Enums\REWARD_SOURCE_TYPE;
  7. use App\Module\GameItems\Services\ItemService;
  8. use App\Module\GameItems\Models\Item;
  9. use App\Module\Game\Services\RewardService;
  10. use Google\Protobuf\Internal\Message;
  11. use Illuminate\Support\Facades\DB;
  12. use Illuminate\Support\Facades\Log;
  13. use Uraus\Kku\Request\RequestLandRemoveCrop;
  14. use Uraus\Kku\Response\ResponseLandRemoveCrop;
  15. use UCore\Exception\LogicException;
  16. /**
  17. * 处理铲除作物操作请求
  18. * RemoveCrop
  19. */
  20. class RemoveCropHandler extends BaseHandler
  21. {
  22. /**
  23. * 是否需要登录
  24. * @var bool
  25. */
  26. protected bool $need_login = true;
  27. /**
  28. * 处理铲除作物操作请求
  29. *
  30. * @param RequestLandRemoveCrop $data 铲除作物操作请求数据
  31. * @return ResponseLandRemoveCrop 铲除作物操作响应
  32. */
  33. public function handle(Message $data): Message
  34. {
  35. // 创建响应对象
  36. $response = new ResponseLandRemoveCrop();
  37. // 获取请求参数
  38. $landId = $data->getLandId();
  39. $toolItemId = $data->getItemId() ?? 0; // 铲除工具ID,可选
  40. $userId = $this->user_id;
  41. // 先进行验证,避免不必要的事务开销
  42. $validation = new CropRemoveValidation([
  43. 'user_id' => $userId,
  44. 'land_id' => $landId,
  45. 'tool_item_id' => $toolItemId
  46. ]);
  47. // 验证数据
  48. $validation->validated();
  49. try {
  50. // 验证通过后,开启事务
  51. DB::beginTransaction();
  52. // 调用铲除作物服务
  53. $result = CropService::removeCrop($userId, $landId, $toolItemId);
  54. if (!$result['success']) {
  55. throw new LogicException("铲除作物失败,请检查土地状态");
  56. }
  57. // 如果使用了工具,消耗工具并检查奖励
  58. if ($toolItemId > 0) {
  59. // 先获取工具物品信息,检查是否有铲除奖励
  60. $toolItem = Item::find($toolItemId);
  61. $rewardGroupId = 0;
  62. if ($toolItem && $toolItem->numeric_attributes) {
  63. $rewardGroupId = $toolItem->numeric_attributes->fram_remove_reward_group ?? 0;
  64. }
  65. // 消耗工具
  66. ItemService::consumeItem($userId, $toolItemId, null, 1, [
  67. 'source_type' => 'land_remove_crop',
  68. 'source_id' => $landId,
  69. 'details' => ['land_id' => $landId]
  70. ]);
  71. // 如果工具有铲除奖励,发放奖励
  72. if ($rewardGroupId > 0) {
  73. try {
  74. $rewardResult = RewardService::grantReward(
  75. $userId,
  76. $rewardGroupId,
  77. REWARD_SOURCE_TYPE::LAND_REMOVE_CROP,
  78. $landId
  79. );
  80. if ($rewardResult->success) {
  81. Log::info('铲除作物奖励发放成功', [
  82. 'user_id' => $userId,
  83. 'land_id' => $landId,
  84. 'tool_item_id' => $toolItemId,
  85. 'reward_group_id' => $rewardGroupId,
  86. 'reward_items' => $rewardResult->items
  87. ]);
  88. } else {
  89. Log::warning('铲除作物奖励发放失败', [
  90. 'user_id' => $userId,
  91. 'land_id' => $landId,
  92. 'tool_item_id' => $toolItemId,
  93. 'reward_group_id' => $rewardGroupId,
  94. 'error' => $rewardResult->errorMessage
  95. ]);
  96. }
  97. } catch (\Exception $e) {
  98. Log::error('铲除作物奖励发放异常', [
  99. 'user_id' => $userId,
  100. 'land_id' => $landId,
  101. 'tool_item_id' => $toolItemId,
  102. 'reward_group_id' => $rewardGroupId,
  103. 'error' => $e->getMessage(),
  104. 'trace' => $e->getTraceAsString()
  105. ]);
  106. // 奖励发放失败不影响主流程,只记录日志
  107. }
  108. }
  109. }
  110. // 提交事务
  111. DB::commit();
  112. // 如果土地状态发生变更,触发土地状态变更事件(在事务外)
  113. if ($result['status_changed']) {
  114. event(new \App\Module\Farm\Events\LandStatusChangedEvent(
  115. $userId,
  116. $landId,
  117. $result['old_status'],
  118. $result['new_status']
  119. ));
  120. }
  121. Log::info('用户铲除作物成功', [
  122. 'user_id' => $userId,
  123. 'land_id' => $landId,
  124. 'tool_item_id' => $toolItemId,
  125. 'status_changed' => $result['status_changed'],
  126. 'old_status' => $result['old_status'],
  127. 'new_status' => $result['new_status'],
  128. 'has_reward' => $toolItemId > 0 && isset($rewardGroupId) && $rewardGroupId > 0
  129. ]);
  130. } catch (\Exception $e) {
  131. // 系统异常,需要回滚事务
  132. if (DB::transactionLevel() > 0) {
  133. DB::rollBack();
  134. }
  135. Log::error('铲除作物操作异常', [
  136. 'user_id' => $userId ?? null,
  137. 'land_id' => $landId ?? null,
  138. 'tool_item_id' => $toolItemId ?? null,
  139. 'error' => $e->getMessage(),
  140. 'trace' => $e->getTraceAsString()
  141. ]);
  142. throw $e;
  143. }
  144. return $response;
  145. }
  146. }