MIDI/midi-php
7
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

新需求-活动需求-盲盒转盘调通盘-巡乐会-调试

Browse Source
This commit is contained in:
赵钊
2025-10-16 22:18:09 +08:00
parent 4edc124d15
commit 7a703e3cfd
1 changed files with 40 additions and 40 deletions
Download Patch File Download Diff File Expand all files Collapse all files

80
application/api/model/BlindBoxTurntableGiftDrawWorld.php
View File

@@ -37,9 +37,9 @@ class BlindBoxTurntableGiftDrawWorld extends Model
public function draw_gift($gift_bag_id, $user_id, $gift_user_ids, $num = 1, $room_id = 0, $heart_id = 0,$auction_id = 0)
{
// 最大重试次数
// $maxRetries = 3;
// for ($attempt = 0; $attempt < $maxRetries; $attempt++) {
// try {
$maxRetries = 3;
for ($attempt = 0; $attempt < $maxRetries; $attempt++) {
try {
// 1. 验证参数并提前处理错误
$validationResult = $this->validateDrawParameters($gift_bag_id, $user_id, $gift_user_ids);
if ($validationResult !== true) {
@@ -107,29 +107,29 @@ class BlindBoxTurntableGiftDrawWorld extends Model
// 6. 构建并返回结果
return $this->buildDrawResult($boxTurntableLog, $giftCounts);
// } catch (\Exception $e) {
// $key = 'blind_box_draw_errors_' . date('Y-m-d-H-i-s');
// $errorData = [
// 'gift_bag_id' => $gift_bag_id,
// 'user_id' => $user_id,
// 'gift_user_ids' => $gift_user_ids,
// 'num' => $num,
// 'room_id' => $room_id,
// 'heart_id' => $heart_id,
// 'auction_id' => $auction_id,
// ];
// if ($this->redis) {
// $this->redis->setex($key, 86400 * 7, $e->getMessage() . ' ' . json_encode($errorData));
// }
// // 如果是死锁且还有重试机会
// if (strpos($e->getMessage(), 'Deadlock') !== false && $attempt < $maxRetries - 1) {
// // 随机延迟后重试
// usleep(rand(50000, 200000)); // 50-200ms
// continue;
// }
// return ['code' => 0, 'msg' => "网络加载失败，请重试！", 'data' => null];
// }
// }
} catch (\Exception $e) {
$key = 'blind_box_draw_errors_' . date('Y-m-d-H-i-s');
$errorData = [
'gift_bag_id' => $gift_bag_id,
'user_id' => $user_id,
'gift_user_ids' => $gift_user_ids,
'num' => $num,
'room_id' => $room_id,
'heart_id' => $heart_id,
'auction_id' => $auction_id,
];
if ($this->redis) {
$this->redis->setex($key, 86400 * 7, $e->getMessage() . ' ' . json_encode($errorData));
}
// 如果是死锁且还有重试机会
if (strpos($e->getMessage(), 'Deadlock') !== false && $attempt < $maxRetries - 1) {
// 随机延迟后重试
usleep(rand(50000, 200000)); // 50-200ms
continue;
}
return ['code' => 0, 'msg' => "网络加载失败，请重试！", 'data' => null];
}
}
}
/**
* 验证抽奖参数
@@ -495,9 +495,9 @@ class BlindBoxTurntableGiftDrawWorld extends Model
$bagGiftPrice = $bag_data['gift_price'] * $num * $gift_user_num;
// 增加重试机制
// $maxRetries = 3;
// for ($retry = 0; $retry < $maxRetries; $retry++) {
// try {
$maxRetries = 3;
for ($retry = 0; $retry < $maxRetries; $retry++) {
try {
db::startTrans();
// 按照固定顺序处理事务步骤
// 1. 扣除用户金币（优先处理）
@@ -542,17 +542,17 @@ class BlindBoxTurntableGiftDrawWorld extends Model
'gift_counts' => $giftCounts
]
];
// } catch (\Exception $e) {
// db::rollback();
// // 检查是否是死锁错误
// if (strpos($e->getMessage(), 'Deadlock') !== false && $retry < $maxRetries - 1) {
// // 等待随机时间后重试
// usleep(rand(10000, 100000)); // 10-100ms
// continue;
// }
// return ['code' => 0, 'msg' => $e->getMessage(), 'data' => null];
// }
// }
} catch (\Exception $e) {
db::rollback();
// 检查是否是死锁错误
if (strpos($e->getMessage(), 'Deadlock') !== false && $retry < $maxRetries - 1) {
// 等待随机时间后重试
usleep(rand(10000, 100000)); // 10-100ms
continue;
}
return ['code' => 0, 'msg' => $e->getMessage(), 'data' => null];
}
}
return ['code' => 0, 'msg' => '操作超时，请重试', 'data' => null];
}