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 18:27:45 +08:00
parent d284ee8346
commit 8269218c7d
1 changed files with 22 additions and 81 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -767,74 +767,28 @@ class BlindBoxTurntableGiftDrawWorld extends Model
*/ */
private function handleXlhOperations($room_id, $xlh_ext, $currentXlhPeriodsNum,$addcurrentXlhPeriodsNum,$room) private function handleXlhOperations($room_id, $xlh_ext, $currentXlhPeriodsNum,$addcurrentXlhPeriodsNum,$room)
{ {
// 增加对 $xlh_ext 的安全检查 $xlhIsPiaoPing = 0;
if (empty($xlh_ext) || !isset($xlh_ext['open_condition'])) { $xlhPeriodsNum = $this->getCachedXlhPeriodsNum("get");
return; if($xlhPeriodsNum < $xlh_ext['open_condition']['waiting_start_num'] && $currentXlhPeriodsNum >= $xlh_ext['open_condition']['waiting_start_num']){
$xlhIsPiaoPing = 1;
} }
// 使用 Redis 锁防止并发问题 if($xlhPeriodsNum < $xlh_ext['open_condition']['start_num'] && $currentXlhPeriodsNum >= $xlh_ext['open_condition']['start_num']){
$lockKey = "xlh_operation_lock_{$room_id}"; $xlhIsPiaoPing = 2;
$lockAcquired = false;
if ($this->redis) {
// 尝试获取锁，最多等待3秒
$lockValue = uniqid();
for ($i = 0; $i < 30; $i++) {
if ($this->redis->set($lockKey, $lockValue, ['NX', 'EX' => 10])) {
$lockAcquired = true;
break;
}
usleep(100000); // 等待100ms
}
} }
try { // 更新房间巡乐会次数
$xlhPeriodsNum = $this->getCachedXlhPeriodsNum("get"); $this->getCachedXlhPeriodsNum("set",$addcurrentXlhPeriodsNum);
$xlhIsPiaoPing = 0;
if($xlhPeriodsNum < $xlh_ext['open_condition']['waiting_start_num'] && $currentXlhPeriodsNum >= $xlh_ext['open_condition']['waiting_start_num']){
$xlhIsPiaoPing = 1;
}
if($xlhPeriodsNum < $xlh_ext['open_condition']['start_num'] && $currentXlhPeriodsNum >= $xlh_ext['open_condition']['start_num']){
$xlhIsPiaoPing = 2;
}
// 更新房间巡乐会次数
$this->getCachedXlhPeriodsNum("set",$addcurrentXlhPeriodsNum);
// 处理飘屏 // 处理飘屏
if ($xlhIsPiaoPing == 1 || $xlhIsPiaoPing == 2) { if ($xlhIsPiaoPing == 1 || $xlhIsPiaoPing == 2) {
$this->handleXlhPiaoPing($room_id, $xlh_ext, $xlhIsPiaoPing); $this->handleXlhPiaoPing($room_id, $xlh_ext, $xlhIsPiaoPing);
} }
// 减少不必要的数据库查询 if($xlhPeriodsNum <= $xlh_ext['open_condition']['waiting_start_num']){
$shouldUpdateStatus = false; $this->updateAndPushXlhStatus($room_id, $xlh_ext, $currentXlhPeriodsNum);
if ($xlhPeriodsNum <= $xlh_ext['open_condition']['waiting_start_num']) { }else{
$shouldUpdateStatus = true; $pan_xlh = db::name('vs_room_pan_xlh')->where('send_time',0)->order('id desc')->find();
} else { if(empty($pan_xlh)){
// 使用缓存优化，避免每次都查询数据库
$panXlhCacheKey = "pan_xlh_status";
$hasActiveXlh = Cache::get($panXlhCacheKey);
if ($hasActiveXlh === null) {
$pan_xlh = db::name('vs_room_pan_xlh')
->where('send_time', 0)
->order('id', 'desc')
->find();
$hasActiveXlh = !empty($pan_xlh) ? 1 : 0;
Cache::set($panXlhCacheKey, $hasActiveXlh, 30); // 缓存30秒
}
if (!$hasActiveXlh) {
$shouldUpdateStatus = true;
// 清除缓存以便下次重新检查
Cache::rm($panXlhCacheKey);
}
}
if ($shouldUpdateStatus) {
$this->updateAndPushXlhStatus($room_id, $xlh_ext, $currentXlhPeriodsNum); $this->updateAndPushXlhStatus($room_id, $xlh_ext, $currentXlhPeriodsNum);
} }
} finally {
// 释放锁
if ($lockAcquired && $this->redis) {
$this->redis->del($lockKey);
}
} }
} }
private function handleXlhPiaoPing($room_id, $xlh_ext, $xlhIsPiaoPing){ private function handleXlhPiaoPing($room_id, $xlh_ext, $xlhIsPiaoPing){
@@ -1054,25 +1008,12 @@ class BlindBoxTurntableGiftDrawWorld extends Model
*/ */
private function getCachedXlhPeriodsNum($type="get",$num=1) { private function getCachedXlhPeriodsNum($type="get",$num=1) {
$cacheKey = "xlh_periods_num"; $cacheKey = "xlh_periods_num";
if ($type == "set") { $xlh_periods_num = Cache::get($cacheKey) ?? 0;
if ($this->redis) { if($type=="set"){
// 使用 Redis 原子操作 $xlh_periods_num = $xlh_periods_num + $num;
return $this->redis->incrBy($cacheKey, $num); Cache::set($cacheKey, $xlh_periods_num, 0);
} else {
// 回退到缓存操作
$xlh_periods_num = Cache::get($cacheKey) ?? 0;
$xlh_periods_num = $xlh_periods_num + $num;
Cache::set($cacheKey, $xlh_periods_num, 0);
return $xlh_periods_num;
}
} else {
if ($this->redis) {
$value = $this->redis->get($cacheKey);
return $value !== false ? (int)$value : 0;
} else {
return Cache::get($cacheKey) ?? 0;
}
} }
return $xlh_periods_num;
} }
/** /**
* 获取缓存的巡乐会期数 * 获取缓存的巡乐会期数