|
@@ -92,7 +92,7 @@ class Party extends Common
|
|
|
// 判断派对是否存在
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
|
|
|
|
|
|
$where = [];
|
|
@@ -227,7 +227,7 @@ class Party extends Common
|
|
|
// 更新redis 加入缓存排序
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
|
|
|
|
|
|
// 更新redis 加入缓存
|
|
@@ -259,7 +259,7 @@ class Party extends Common
|
|
|
// redis 删除
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
|
|
|
$redis->zRem($this->roomTypeArr[$room_type]."Rank",$party_id);
|
|
|
$redis->del($this->roomTypeArr[$room_type]."_".$party_id);
|
|
@@ -290,7 +290,7 @@ class Party extends Common
|
|
|
// 获取排序
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
|
|
|
$redisPartyRankList = $redis->zRevRange($this->roomTypeArr[$room_type]."Rank",0,-1,true);
|
|
|
$partyModel = new \app\common\model\Party();
|
|
@@ -340,7 +340,7 @@ class Party extends Common
|
|
|
if (!$party_id) $this->error(__('Invalid parameters'));
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
|
|
|
|
|
|
$res = [];
|
|
@@ -396,7 +396,7 @@ class Party extends Common
|
|
|
}
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
|
|
|
// 更新热度
|
|
|
$redis->zIncrBy($this->roomTypeArr[$room_type]."Rank", $party_hot, $party_id);
|
|
@@ -443,7 +443,7 @@ class Party extends Common
|
|
|
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
$redisData = $redis->get($this->roomTypeArr[$room_type]."_".$party_id);
|
|
|
if($redisData) {
|
|
|
$partyInfo = json_decode($redisData,true);
|
|
@@ -477,7 +477,7 @@ class Party extends Common
|
|
|
}
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
|
|
|
$res = $redis->hGetAll("online_".$party_id);
|
|
|
$user_ids = [];$userList = [];
|
|
@@ -536,7 +536,7 @@ class Party extends Common
|
|
|
$user_id = $this->auth->id;
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
$redis->zAdd("party_user_".$party_id,$this->auth->username,$user_id);
|
|
|
|
|
|
// 判断当前用户是否存在在直播间通过切换过来的
|
|
@@ -660,7 +660,7 @@ class Party extends Common
|
|
|
}
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
|
|
|
// 判断当前用户是否被该房间设置限制 //项目:1=房管,2=禁言,3=拉黑,4=踢出
|
|
|
$lsetList = [];
|
|
@@ -691,11 +691,11 @@ class Party extends Common
|
|
|
$user_u_id = $this->auth->u_id;
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
$redis->zRem("party_user_".$party_id,$user_u_id);
|
|
|
|
|
|
// 处理online_party_id
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
$redis->HDel("online_" . $party_id, $this->auth->id);
|
|
|
|
|
|
// 扣除在线用户在房间情况
|
|
@@ -735,7 +735,7 @@ class Party extends Common
|
|
|
|
|
|
// $redis = new Redis();
|
|
|
// $redisconfig = config("redis");
|
|
|
-// $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+// $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
// $userids = $redis->zRange("party_user_".$party_id,0,-1,true);
|
|
|
// $useridArr = [];
|
|
|
// if($userids)foreach($userids as $k => $v) $useridArr[$v] = $k; // 因为array_slip 不能交换数字啊
|
|
@@ -761,7 +761,7 @@ class Party extends Common
|
|
|
}
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
|
|
|
$partyModel = new \app\common\model\Party();
|
|
|
$data = [];
|
|
@@ -799,7 +799,7 @@ class Party extends Common
|
|
|
$user_id = $this->auth->id;
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
|
|
|
$partycellectionModel = new \app\common\model\PartyCellection();
|
|
|
// 添加记录
|
|
@@ -843,7 +843,7 @@ class Party extends Common
|
|
|
if($list) {
|
|
|
// $redis = new Redis();
|
|
|
// $redisconfig = config("redis");
|
|
|
-// $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+// $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
// // 获取本周第一天
|
|
|
// $weekday = $this->firstOfWeek(date("Y-m-d H:i:s"));
|
|
|
// // 获取redis 中 用户排行榜前五名
|
|
@@ -967,7 +967,7 @@ class Party extends Common
|
|
|
// 存redis 房间信息
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
$partyInfo = $redis->get($this->roomTypeArr[$room_type]."_".$party_id);
|
|
|
if($partyInfo) {
|
|
|
$partyInfo = json_decode($partyInfo,true);
|
|
@@ -1035,7 +1035,7 @@ class Party extends Common
|
|
|
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
|
|
|
|
|
|
$data = [];
|
|
@@ -1074,7 +1074,7 @@ class Party extends Common
|
|
|
$time = time();
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
|
|
|
|
|
|
|
|
@@ -1107,7 +1107,7 @@ class Party extends Common
|
|
|
}
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
$res = $redis->hDel("party_manage_".$party_id,$id."-".$item);
|
|
|
|
|
|
if ($item==1) {
|
|
@@ -1144,7 +1144,7 @@ class Party extends Common
|
|
|
// 存redis 房间信息
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
$partyInfo = $redis->get($this->roomTypeArr[$room_type]."_".$party_id);
|
|
|
if($partyInfo) {
|
|
|
$partyInfo = json_decode($partyInfo,true);
|
|
@@ -1176,7 +1176,7 @@ class Party extends Common
|
|
|
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
$data = unserialize($redis->hGet("party_lineup",$party_id));
|
|
|
$data[$userid]["user_id"] = $userInfo['id'];
|
|
|
$data[$userid]["avatar"] = $userInfo['avatar'];
|
|
@@ -1210,7 +1210,7 @@ class Party extends Common
|
|
|
$userid = $this->auth->id;
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
$data=unserialize($redis->hGet("party_lineup",$party_id));
|
|
|
if($data && $is_empty != 1) {
|
|
|
foreach($data as $k => $v) {
|
|
@@ -1238,7 +1238,7 @@ class Party extends Common
|
|
|
}
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
$data = $redis->hGet("party_lineup",$party_id);
|
|
|
$dataArr = unserialize($data);
|
|
|
$datas = [];
|
|
@@ -1275,7 +1275,7 @@ class Party extends Common
|
|
|
// 存redis 房间信息
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
$partyInfo = $redis->get($this->roomTypeArr[$room_type]."_".$party_id);
|
|
|
if($partyInfo) {
|
|
|
$partyInfo = json_decode($partyInfo,true);
|
|
@@ -1467,7 +1467,7 @@ class Party extends Common
|
|
|
try {
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"], 86400 * 31);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"], 86400 * 31);
|
|
|
// 事务处理余额与记录信息
|
|
|
$userjewellogModel = new \app\common\model\UserJewelLog();
|
|
|
$usersoundcoinlogModel = new \app\common\model\UserSoundcoinLog();
|
|
@@ -2265,7 +2265,7 @@ class Party extends Common
|
|
|
// 更新redis 加入缓存排序
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
$redis->zAdd($this->roomTypeArr[$room_type]."Rank", $partyInfo['party_hot'], $partyInfo["id"]);
|
|
|
|
|
|
// 更新redis 加入缓存
|
|
@@ -2298,7 +2298,7 @@ class Party extends Common
|
|
|
private function getPartyUserTop($party_id,$room_type) {
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
|
|
|
// 获取本周第一天
|
|
|
$weekday = $this->firstOfWeek(date("Y-m-d H:i:s"));
|
|
@@ -2339,7 +2339,7 @@ class Party extends Common
|
|
|
private function updateUserCharm($party_id,$user_id,$giftValue) {
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
|
|
|
// 获取用户魅力值
|
|
|
$users = $redis->zRange("hourCharm_".$party_id,0,-1,true);
|
|
@@ -2370,7 +2370,7 @@ class Party extends Common
|
|
|
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
|
|
|
if ($userId) {
|
|
|
$redis->zRem("hourCharm_" . $party_id, $userId);
|
|
@@ -2407,7 +2407,7 @@ class Party extends Common
|
|
|
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
// 获取所有派对ID
|
|
|
$party_ids = \app\common\model\Party::where(["status"=>1])->column("id");
|
|
|
// 获取数据
|
|
@@ -2443,7 +2443,7 @@ class Party extends Common
|
|
|
$partyList = \app\common\model\Party::where('is_online',1)->select();
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);
|
|
|
|
|
|
// $redis->del("online_" . 3);die;
|
|
|
// $redis->hSet("online_" . 3, 4, 4);die;
|