RemoveCropHandler.php 6.2 KB

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