|
@@ -92,8 +92,8 @@ 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->auth(123456);
|
|
|
+
|
|
|
|
|
|
$where = [];
|
|
|
$where["user_id"] = $user_id;
|
|
@@ -227,8 +227,8 @@ 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->auth(123456);
|
|
|
+
|
|
|
|
|
|
// 更新redis 加入缓存
|
|
|
$redPartyInfo = $redis->get($this->roomTypeArr[$room_type]."_".$partyInfo["id"]);
|
|
@@ -259,8 +259,8 @@ 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->auth(123456);
|
|
|
+
|
|
|
$redis->zRem($this->roomTypeArr[$room_type]."Rank",$party_id);
|
|
|
$redis->del($this->roomTypeArr[$room_type]."_".$party_id);
|
|
|
$this->success("删除成功!");
|
|
@@ -290,8 +290,8 @@ 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->auth(123456);
|
|
|
+
|
|
|
$redisPartyRankList = $redis->zRevRange($this->roomTypeArr[$room_type]."Rank",0,-1,true);
|
|
|
$partyModel = new \app\common\model\Party();
|
|
|
if(!$redisPartyRankList) {
|
|
@@ -339,8 +339,8 @@ 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"]);$redis->auth(123456);
|
|
|
+
|
|
|
|
|
|
$res = [];
|
|
|
// 获取今天
|
|
@@ -395,8 +395,8 @@ 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->auth(123456);
|
|
|
+
|
|
|
// 更新热度
|
|
|
$redis->zIncrBy($this->roomTypeArr[$room_type]."Rank", $party_hot, $party_id);
|
|
|
return $this->success("更新成功!");
|
|
@@ -442,7 +442,7 @@ class Party extends Common
|
|
|
|
|
|
$redis = new Redis();
|
|
|
$redisconfig = config("redis");
|
|
|
- $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);$redis->auth(123456);
|
|
|
+ $redis->connect($redisconfig["host"], $redisconfig["port"]);$redis->auth(123456);
|
|
|
$redisData = $redis->get($this->roomTypeArr[$room_type]."_".$party_id);
|
|
|
if($redisData) {
|
|
|
$partyInfo = json_decode($redisData,true);
|
|
@@ -1031,8 +1031,8 @@ 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->auth(123456);
|
|
|
+
|
|
|
|
|
|
$data = [];
|
|
|
$data["user_id"] = $user_id;
|
|
@@ -1070,8 +1070,8 @@ 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"]);$redis->auth(123456);
|
|
|
+
|
|
|
|
|
|
|
|
|
$hget=$redis->hGetAll("party_manage_".$party_id);
|