|
@@ -7,6 +7,7 @@ use App\Models\LiveChatModel;
|
|
|
use App\Models\LiveModel;
|
|
use App\Models\LiveModel;
|
|
|
use App\Models\MemberModel;
|
|
use App\Models\MemberModel;
|
|
|
use App\Models\MessageModel;
|
|
use App\Models\MessageModel;
|
|
|
|
|
+use App\Models\VideoCollectModel;
|
|
|
use App\Services\Api\MemberService;
|
|
use App\Services\Api\MemberService;
|
|
|
use App\Services\RedisService;
|
|
use App\Services\RedisService;
|
|
|
use Illuminate\Console\Command;
|
|
use Illuminate\Console\Command;
|
|
@@ -291,7 +292,10 @@ class SocketServer extends Command
|
|
|
$this->info("【{$scene} {$date}】Socket:登录成功【{$frameId}-{$fromUid}-{$op}】。");
|
|
$this->info("【{$scene} {$date}】Socket:登录成功【{$frameId}-{$fromUid}-{$op}】。");
|
|
|
$this->sendMsg($frameId, ['success' => true,'op'=> $op, 'scene'=>$scene, 'message' => '登录成功', 'data' => $data, 't' => time()]);
|
|
$this->sendMsg($frameId, ['success' => true,'op'=> $op, 'scene'=>$scene, 'message' => '登录成功', 'data' => $data, 't' => time()]);
|
|
|
break;
|
|
break;
|
|
|
|
|
+ case 'live_leave': // 进入直播间消息
|
|
|
|
|
+ VideoCollectModel::where(['iser_id'=> $fromUid,'type'=>1,'source_type'=>2,'collect_id'=>$liveId])->update(['is_online'=>2,'update_time'=>time()]);
|
|
|
case 'live_entry': // 进入直播间消息
|
|
case 'live_entry': // 进入直播间消息
|
|
|
|
|
+ VideoCollectModel::where(['iser_id'=> $fromUid,'type'=>1,'source_type'=>2,'collect_id'=>$liveId])->update(['is_online'=>1,'update_time'=>time()]);
|
|
|
case 'live_like': // 进入直播间消息
|
|
case 'live_like': // 进入直播间消息
|
|
|
case 'follow': // 关注主播消息
|
|
case 'follow': // 关注主播消息
|
|
|
case 'gift': // 打赏礼物消息
|
|
case 'gift': // 打赏礼物消息
|