|
|
@@ -3,8 +3,8 @@
|
|
|
namespace App\Module\AppGame\Handler\Pet;
|
|
|
|
|
|
use App\Module\AppGame\Handler\BaseHandler;
|
|
|
+use App\Module\AppGame\Validations\PetEatValidation;
|
|
|
use App\Module\Pet\Services\PetService;
|
|
|
-use App\Module\Pet\Validation\PetEatValidation;
|
|
|
use Google\Protobuf\Internal\Message;
|
|
|
use Illuminate\Support\Facades\DB;
|
|
|
use Illuminate\Support\Facades\Log;
|
|
|
@@ -16,8 +16,10 @@ use Uraus\Kku\Response\ResponsePetEat;
|
|
|
*/
|
|
|
class EatHandler extends BaseHandler
|
|
|
{
|
|
|
+
|
|
|
/**
|
|
|
* 是否需要登录
|
|
|
+ *
|
|
|
* @var bool
|
|
|
*/
|
|
|
protected bool $need_login = true;
|
|
|
@@ -30,59 +32,20 @@ class EatHandler extends BaseHandler
|
|
|
*/
|
|
|
public function handle(Message $data): Message
|
|
|
{
|
|
|
- // 创建响应对象
|
|
|
- $response = new ResponsePetEat();
|
|
|
-
|
|
|
- try {
|
|
|
- // 创建验证对象
|
|
|
- $validation = PetEatValidation::makeByProrobuf($data);
|
|
|
-
|
|
|
- // 设置用户ID
|
|
|
- $validation->user_id = $this->user_id;
|
|
|
+ // 创建验证对象
|
|
|
+ $validation = PetEatValidation::makeByProrobufUser($data);
|
|
|
+ // 验证请求数据
|
|
|
+ $validation->validated();
|
|
|
+ // 验证完成
|
|
|
|
|
|
- // 验证请求数据
|
|
|
- $validation->validated();
|
|
|
|
|
|
- // 获取验证后的数据
|
|
|
- $petId = $validation->pet_id;
|
|
|
- $itemId = $validation->item_id;
|
|
|
- $amount = $validation->num;
|
|
|
|
|
|
- // 开启事务
|
|
|
- DB::beginTransaction();
|
|
|
|
|
|
- try {
|
|
|
- // 调用宠物服务进行喂食
|
|
|
- $result = PetService::feedPet($this->user_id, $petId, $itemId, $amount);
|
|
|
|
|
|
- // 提交事务
|
|
|
- DB::commit();
|
|
|
-
|
|
|
- // 记录日志
|
|
|
- Log::info('宠物喂食成功', [
|
|
|
- 'user_id' => $this->user_id,
|
|
|
- 'pet_id' => $petId,
|
|
|
- 'item_id' => $itemId,
|
|
|
- 'amount' => $amount,
|
|
|
- 'result' => $result
|
|
|
- ]);
|
|
|
- } catch (\Exception $e) {
|
|
|
- // 回滚事务
|
|
|
- DB::rollBack();
|
|
|
- throw $e;
|
|
|
- }
|
|
|
- } catch (\Exception $e) {
|
|
|
- // 记录错误日志
|
|
|
- Log::error('宠物喂食失败', [
|
|
|
- 'user_id' => $this->user_id,
|
|
|
- 'error' => $e->getMessage(),
|
|
|
- 'trace' => $e->getTraceAsString()
|
|
|
- ]);
|
|
|
-
|
|
|
- // 抛出异常,让框架处理错误响应
|
|
|
- throw $e;
|
|
|
- }
|
|
|
|
|
|
+ // 创建响应对象
|
|
|
+ $response = new ResponsePetEat();
|
|
|
return $response;
|
|
|
}
|
|
|
-}
|
|
|
+
|
|
|
+}
|