| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798 |
- <?php
- namespace App\Module\AppGame\Handler\Land;
- use App\Module\AppGame\Handler\BaseHandler;
- use App\Module\Farm\Services\CropService;
- use App\Module\Farm\Enums\DISASTER_TYPE;
- use Google\Protobuf\Internal\Message;
- use Illuminate\Support\Facades\DB;
- use Illuminate\Support\Facades\Log;
- use Uraus\Kku\Request\RequestLandPesticide;
- use Uraus\Kku\Response\ResponseLandPesticide;
- use UCore\Exception\LogicException;
- /**
- * 处理除虫操作请求
- * Pesticide
- *
- */
- class PesticideHandler extends BaseHandler
- {
- /**
- * 是否需要登录
- * @var bool
- */
- protected bool $need_login = true;
- /**
- * 处理除虫操作请求
- *
- * @param RequestLandPesticide $data 除虫操作请求数据
- * @return ResponseLandPesticide 除虫操作响应
- */
- public function handle(Message $data): Message
- {
- // 创建响应对象
- $response = new ResponseLandPesticide();
- try {
- // 获取请求参数
- $landId = $data->getLandId();
- $userItemId = $data->getItemId();
- $userId = $this->user_id;
- // 开启事务
- DB::beginTransaction();
- // 使用统一的灾害去除逻辑,包含概率判断和事务检测
- $result = CropService::removeDisasterWithItem(
- $userId,
- $landId,
- $userItemId,
- DISASTER_TYPE::PEST->value,
- 'land_pesticide'
- );
- // 提交事务
- DB::commit();
- // 设置响应状态
- $this->response->setCode(0);
- $this->response->setMsg($result['message']);
- } catch (LogicException $e) {
- // 回滚事务
- DB::rollBack();
- // 设置错误响应
- $this->response->setCode(400);
- $this->response->setMsg($e->getMessage());
- Log::warning('用户除虫失败', [
- 'user_id' => $this->user_id,
- 'land_id' => $landId ?? null,
- 'item_id' => $userItemId ?? null,
- 'error' => $e->getMessage(),
- 'trace' => $e->getTraceAsString()
- ]);
- } catch (\Exception $e) {
- // 回滚事务
- DB::rollBack();
- // 设置错误响应
- $this->response->setCode(500);
- $this->response->setMsg('系统错误,请稍后再试');
- Log::error('除虫操作异常', [
- 'user_id' => $this->user_id,
- 'land_id' => $landId ?? null,
- 'item_id' => $userItemId ?? null,
- 'error' => $e->getMessage(),
- 'trace' => $e->getTraceAsString()
- ]);
- }
- return $response;
- }
- }
|