RemoveCropHandler.php 6.1 KB

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