Test.php 1.6 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859
  1. <?php
  2. namespace app\index\controller;
  3. use think\Db;
  4. use Redis;
  5. class Test
  6. {
  7. public function outlivebc(){
  8. $party_id = input('party_id');
  9. if(empty($party_id)){
  10. $this->error();
  11. }
  12. $redis = new Redis();
  13. $redisconfig = config("redis");
  14. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  15. $userModel = new \app\common\model\User();
  16. // 获取条数
  17. $num = 3;
  18. // 获取3条财富排行周记录
  19. $getweek = $redis->zRevRange("livebc_jewel_to_".$party_id,0,-1,true);
  20. $getweek2 = $redis->zRevRange("livebc_jewel_get_".$party_id,0,0,true);
  21. $userList = $userModel->rankList($getweek);
  22. $userList2 = $userModel->rankList($getweek2);
  23. dump($getweek);
  24. dump($getweek2);
  25. dump($userList);
  26. dump($userList2);
  27. $avatarArr = [];
  28. if($userList) {
  29. foreach($userList as $k => $v) {
  30. $v["jewel"] > 0 && $avatarArr[] = $v["avatar"];
  31. }
  32. // 加入缓存做备份
  33. $redis->hSet("user_jewel_top3",$party_id,json_encode($avatarArr));
  34. //$redis->hSet("livebc_jewel_top3",$party_id,json_encode($avatarArr));
  35. }
  36. dump($avatarArr);
  37. }
  38. public function clear(){
  39. $paery_id = 54;
  40. //清空房间排行榜
  41. $redis = new Redis();
  42. $redisconfig = config("redis");
  43. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  44. $redis->del('livebc_jewel_to_' . $paery_id);
  45. $redis->del('livebc_jewel_get_' . $paery_id);
  46. $redis->hDel("user_jewel_top3",$paery_id);
  47. }
  48. }