Party.php 89 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206
  1. <?php
  2. namespace app\api\controller;
  3. use app\api\controller\Common;
  4. use app\common\model\PartyJoin;
  5. use fast\Random;
  6. use app\common\controller\RedisLeaderboard;
  7. use Redis;
  8. use think\Db;
  9. use think\Exception;
  10. use think\exception\PDOException;
  11. use think\exception\ValidateException;
  12. use think\Request;
  13. use app\common\service\RoomService;
  14. use app\common\library\GatewayworkerTools;
  15. /**
  16. * 派对信息接口
  17. */
  18. class Party extends Common
  19. {
  20. protected $noNeedLogin = ['updatePartyInfo','getPatyType','addUserPositionToParty', 'clearMoney','clearCharm','getPartyRankList','getDefaultBackground','getPartGifList','getPartHeadgifList','isNotalk','getMusicList','updateTops','handleParty'];
  21. protected $noNeedRight = ['*'];
  22. public function __construct(Request $request = null)
  23. {
  24. $this->roomTypeArr = [1=>"party",2=>"live"];
  25. parent::__construct($request);
  26. }
  27. /**
  28. * 创建/进入派对
  29. */
  30. public function createParty() {
  31. $room_type = $this->request->request('room_type',2); // 房间类型:1=派对,2=直播
  32. $partyModel = new \app\common\model\Party();
  33. $user_id = $this->auth->id;
  34. // 开直播时,判断当前用户是否为主播
  35. $anchorInfo = [];
  36. if($room_type == 2) {
  37. $anchorInfo = \app\common\model\UserAnchor::where(["user_id"=>$user_id])->find();
  38. $anchorInfo || $this->error("您还未申请主播!");
  39. $anchorInfo->status == 0 && $this->error("您的主播申请信息还未受理,请耐心等待!");
  40. $anchorInfo->status == 2 && $this->error("您的主播申请未通过,请重新提交!");
  41. }
  42. // 1。实名认证
  43. $userAuthInfo = \app\common\model\UserAuth::where(["user_id"=>$user_id])->find();
  44. if($userAuthInfo) {
  45. if($userAuthInfo->status == 0) {
  46. $this->error("您的实名认证还在这审核中...,请耐心等待!");
  47. } elseif($userAuthInfo->status == 2) {
  48. $this->error("您的实名认证审核未通过,请重新审核!");
  49. }
  50. } else {
  51. $this->error("请先申请实名认证!");
  52. }
  53. if($room_type == 1) {
  54. // 2。开厅申请
  55. $authInfo = model('Guild')->where(["user_id"=>$user_id])->order('id desc')->find();
  56. if($authInfo) {
  57. if($authInfo->status == 0) {
  58. $this->error("您的家族申请还在这审核中...,请耐心等待!");
  59. } elseif($authInfo->status == -1) {
  60. $this->error("您的家族申请已解散,请重新申请!");
  61. }
  62. } else {
  63. $this->error("请先申请家族!");
  64. }
  65. }
  66. // 判断派对是否存在
  67. $redis = new Redis();
  68. $redisconfig = config("redis");
  69. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  70. if ($redisconfig['redis_pwd']) {
  71. $redis->auth($redisconfig['redis_pwd']);
  72. }
  73. if($redisconfig['redis_selectdb'] > 0){
  74. $redis->select($redisconfig['redis_selectdb']);
  75. }
  76. $where = [];
  77. $where["user_id"] = $user_id;
  78. $where["room_type"] = $room_type;
  79. $sqlPartyInfo = $partyModel->where($where)->find();
  80. if(!$sqlPartyInfo) { // sql中不存在派对信息
  81. $partylimit = config("site.roomLimit");
  82. $partycount = $partyModel->count("id");
  83. if($partycount >= $partylimit && $partylimit != -1) {
  84. $this->error("房间数量已达上线,请联系客服!");
  85. }
  86. $party_name = $this->auth->u_id."的房间"; // 派对名称
  87. $party_logo = "/assets/api/party_logo.png"; // 派对logo
  88. $party_type = isset($anchorInfo['party_type_id']) ? $anchorInfo['party_type_id'] : 0; // 派对类型(情感互动,心动点单 等)
  89. $party_notice = "请编辑房间公告"; // 派对公告
  90. $party_notice_detail = "请编辑房间公告内容!"; // 派对公告详情
  91. if (!$party_name || !$party_logo || !$party_notice) {
  92. $this->error(__('Invalid parameters'));
  93. }
  94. $party_ids = $partyModel->column("party_id");
  95. // 创建派对ID (临时ID四位,派对数不超过8999)
  96. $party_id = $this->auth->getUinqueId(4,$party_ids);
  97. if($party_id > 9999) {
  98. $this->error("派对超限,请联系客服");
  99. }
  100. $data = [];
  101. $data["user_id"] = $this->auth->id;
  102. $data["room_type"] = $room_type;
  103. $data["party_id"] = $party_id;
  104. $data["party_hot"] = 0;
  105. $data["party_name"] = $party_name;
  106. $data["party_logo"] = $party_logo;
  107. $data["party_type"] = $party_type;
  108. $data["party_notice"] = $party_notice;
  109. $data["party_notice_detail"] = $party_notice_detail;
  110. $data["is_online"] = 1;
  111. $data["status"] = 1;
  112. $data["is_recommend"] = 0;
  113. $data["createtime"] = time();
  114. $id = $partyModel->insertGetId($data);
  115. if(!$id) {
  116. $this->error("派对创建失败,请稍后重试!");
  117. }
  118. $data["id"] = $id;
  119. if($room_type == 2) {
  120. \app\common\model\User::update(["is_live"=>1],["id"=>$user_id]);
  121. }
  122. $partyInfo = $partyModel->where(["id"=>$id])->find();
  123. $partyInfo["is_new"] = 1;
  124. // 冠名
  125. $userInfo = [];
  126. if($partyInfo["naming"]) {
  127. $userInfo = \app\common\model\User::field("id,nickname,avatar")->where(["id"=>$partyInfo["naming"]])->find();
  128. }
  129. // 头像
  130. if($partyInfo["user_id"] > 0 && $room_type == 2) {
  131. $partyInfo["avatar"] = \app\common\model\User::where(["id"=>$partyInfo["user_id"]])->value("avatar");
  132. }
  133. // 派对类型
  134. $partyTypeName = "普通房";
  135. if($partyInfo["party_type"]) {
  136. $partyTypeName = \app\common\model\PartyType::where(["id"=>$partyInfo["party_type"]])->value("name");
  137. }
  138. $partyInfo["naming"] = $userInfo;
  139. $partyInfo["type_name"] = $partyTypeName;
  140. // 加入缓存排序
  141. $redis->zAdd($this->roomTypeArr[$room_type]."Rank", $partyInfo['party_hot'], $partyInfo["id"]);
  142. // 加入缓存
  143. $redis->set($this->roomTypeArr[$room_type]."_".$partyInfo["id"],json_encode($partyInfo));
  144. if($room_type != 2) {
  145. // 创建公会
  146. /*\app\common\model\Guild::createGuild($partyInfo["id"], $partyInfo["party_name"], $user_id);
  147. \app\common\model\User::update(["is_guild" => 3,'guild_id'], ["id" => $user_id]);*/
  148. //更新家族 party_id
  149. $guildWhere['id'] = $user_id;
  150. $guildWhere['status'] = 1;
  151. $guild = model('Guild')->where($guildWhere)->order('id desc')->find();
  152. if (!empty($guild)) {
  153. model('Guild')->where($guildWhere)->update(['party_id'=>$partyInfo['id']]);
  154. }
  155. }
  156. } else {
  157. if($sqlPartyInfo["is_close"] == 1) $this->error("该房间已被关闭!");
  158. if($sqlPartyInfo["status"] == 0){
  159. // 清楚对应的记录
  160. $redis->del($this->roomTypeArr[$room_type]."_".$sqlPartyInfo["id"]);
  161. // 删除派对记录
  162. \app\common\model\Party::where('id',$sqlPartyInfo["id"])->delete();
  163. $this->error("创建失败,请重试");
  164. }
  165. // if($sqlPartyInfo["status"] != 1) $this->error("该房间为预创建房间,请联系管理员正式开通!");
  166. // 如果是房主并且房间处于离线状态下激活
  167. if ($sqlPartyInfo['user_id'] != $user_id) {
  168. $this->error("当前直播已结束!");
  169. }
  170. $partyInfo = $sqlPartyInfo;
  171. $partyInfo["is_new"] = 0;
  172. }
  173. $this->success("获取成功!",$partyInfo);
  174. }
  175. /**
  176. * 更新房间状态为正常
  177. */
  178. public function savePartyStatus() {
  179. $party_id = $this->request->request('party_id'); // 派对ID
  180. $room_type = $this->request->request('room_type',1); // 房间类型:1=派对,2=直播
  181. if (!$party_id || !in_array($room_type,[1,2])) $this->error(__('Invalid parameters'));
  182. $user_id = $this->auth->id;
  183. $partyInfo = \app\common\model\Party::get($party_id);
  184. if($partyInfo->status < 0) $this->error("当前状态不支持变更!");
  185. if($partyInfo->user_id !== $user_id) $this->error("当前账号异常,非工会长禁止操作!");
  186. $partyInfo->status = 1;
  187. $res = $partyInfo->save();
  188. if($res !== false) {
  189. // 更新redis 加入缓存排序
  190. $redis = new Redis();
  191. $redisconfig = config("redis");
  192. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  193. if ($redisconfig['redis_pwd']) {
  194. $redis->auth($redisconfig['redis_pwd']);
  195. }
  196. if($redisconfig['redis_selectdb'] > 0){
  197. $redis->select($redisconfig['redis_selectdb']);
  198. }
  199. // 更新redis 加入缓存
  200. $redPartyInfo = $redis->get($this->roomTypeArr[$room_type]."_".$partyInfo["id"]);
  201. if($redPartyInfo) {
  202. $redPartyInfo = json_decode($redPartyInfo,true);
  203. $redPartyInfo["status"] = 1;
  204. $redis->set($this->roomTypeArr[$room_type]."_".$partyInfo["id"],json_encode($redPartyInfo));
  205. }
  206. $this->success("更新公会状态成功!");
  207. } else {
  208. $this->error("网络错误,请稍后重试!");
  209. }
  210. }
  211. /**
  212. * 删除派对(群解散)
  213. */
  214. public function closeParty() {
  215. $party_id = $this->request->request('party_id'); // 派对ID
  216. $room_type = $this->request->request('room_type',1); // 房间类型:1=派对,2=直播
  217. if (!$party_id || !in_array($room_type,[1,2])) $this->error(__('Invalid parameters'));
  218. $partyInfo = \app\common\model\Party::where(["id"=>$party_id])->find();
  219. if(!$partyInfo) $this->error(__('派对不存在!'));
  220. $res = $partyInfo->delete();
  221. if($res !== false) {
  222. // redis 删除
  223. $redis = new Redis();
  224. $redisconfig = config("redis");
  225. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  226. if ($redisconfig['redis_pwd']) {
  227. $redis->auth($redisconfig['redis_pwd']);
  228. }
  229. if($redisconfig['redis_selectdb'] > 0){
  230. $redis->select($redisconfig['redis_selectdb']);
  231. }
  232. $redis->zRem($this->roomTypeArr[$room_type]."Rank",$party_id);
  233. $redis->del($this->roomTypeArr[$room_type]."_".$party_id);
  234. $this->success("删除成功!");
  235. } else {
  236. $this->error("删除失败!");
  237. }
  238. }
  239. /**
  240. * 获取派对列表排序
  241. */
  242. public function getPartyRankList() {
  243. $thispage = $this->request->request('thispage',1,"intval"); // 当前页数
  244. $pagenum = $this->request->request('pagenum',10,"intval"); // 每页显示条数0=不做分页
  245. $type_id = $this->request->request('type_id'); // 派对类型
  246. $room_type = $this->request->request('room_type',1); // 房间类型:1=派对,2=直播
  247. $is_recommend = $this->request->request('is_recommend'); // 推荐0=否1=是
  248. $all = $this->request->request('all'); // 全部分类0=否1=是
  249. $index = $this->request->request('index',0); // 全部分类0=否1=是
  250. $start = ($thispage-1)*$pagenum;
  251. $end = $start+($pagenum-1);
  252. // 获取排序
  253. $redis = new Redis();
  254. $redisconfig = config("redis");
  255. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  256. if ($redisconfig['redis_pwd']) {
  257. $redis->auth($redisconfig['redis_pwd']);
  258. }
  259. if($redisconfig['redis_selectdb'] > 0){
  260. $redis->select($redisconfig['redis_selectdb']);
  261. }
  262. $redisPartyRankList = $redis->zRevRange($this->roomTypeArr[$room_type]."Rank",0,-1,true);
  263. $partyModel = new \app\common\model\Party();
  264. if(!$redisPartyRankList) {
  265. $userModel = new \app\common\model\User();
  266. // 直接从数据库获取所有数据
  267. $where = [];
  268. $where["a.status"] = 1;
  269. $where["a.is_online"] = 1;
  270. $where["a.room_type"] = $room_type;
  271. $sqlPartyList = $partyModel->alias("a")->field("a.*,b.name as type_name")
  272. ->join("hx_party_type b","a.party_type = b.id","left")->where($where)->select();
  273. $userList = $userModel->field("id,nickname,avatar")->where(["status"=>"normal"])->select();
  274. $userInfoArr = [];
  275. if($userList) foreach($userList as $k => $v) $userInfoArr[$v["id"]] = $v;
  276. if($sqlPartyList) {
  277. foreach($sqlPartyList as $k => $v) {
  278. // 加入缓存排序
  279. $redis->zAdd($this->roomTypeArr[$room_type]."Rank", $v['party_hot'], $v["id"]);
  280. // 设置冠名
  281. $sqlPartyList[$k]["naming"] = isset($userInfoArr[$v["naming"]])?$userInfoArr[$v["naming"]]:[];
  282. // 设置房主头像
  283. $sqlPartyList[$k]["avatar"] = isset($userInfoArr[$v["user_id"]])?$userInfoArr[$v["user_id"]]["avatar"]:[];
  284. // 加入缓存
  285. $redis->set($this->roomTypeArr[$room_type]."_".$v["id"],json_encode($v));
  286. }
  287. $redisPartyRankList = $redis->zRevRange($this->roomTypeArr[$room_type]."Rank",0,-1,true);
  288. }
  289. }
  290. if($redisPartyRankList) {
  291. $resultInfo = $partyModel->getPatyInfoByPartyId($redisPartyRankList,$this->roomTypeArr[$room_type],$type_id,$is_recommend,$all,$start,$end,$index);
  292. $this->success("获取成功!",$resultInfo);
  293. }else{
  294. $this->success("获取成功!",[]);
  295. }
  296. }
  297. /**
  298. * 获取派对列表排序
  299. */
  300. public function getPartyList() {
  301. try {
  302. $thispage = $this->request->request('thispage',1,"intval"); // 当前页数
  303. $pagenum = $this->request->request('pagenum',10,"intval"); // 每页显示条数0=不做分页
  304. $type_id = $this->request->request('type_id'); // 派对类型
  305. $is_recommend = $this->request->request('is_recommend'); // 推荐0=否1=是
  306. $all = $this->request->request('all'); // 全部分类0=否1=是
  307. $index = $this->request->request('index',0); // 全部分类0=否1=是
  308. $start = ($thispage-1)*$pagenum;
  309. $end = $start+($pagenum-1);
  310. // 获取排序
  311. $redis = new Redis();
  312. $redisconfig = config("redis");
  313. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  314. if ($redisconfig['redis_pwd']) {
  315. $redis->auth($redisconfig['redis_pwd']);
  316. }
  317. if($redisconfig['redis_selectdb'] > 0){
  318. $redis->select($redisconfig['redis_selectdb']);
  319. }
  320. $redisPartyRankList = $redis->zRevRange("partyRank",0,-1,true);
  321. $redisLiveRankList = $redis->zRevRange("liveRank",0,-1,true);
  322. $roomService = new RoomService();
  323. if(!$redisPartyRankList) {//party
  324. $roomParams = ['room_type' => 1];
  325. $roomPartyRes = $roomService->roomRedis($roomParams);
  326. $redisPartyRankList = $roomPartyRes['data'];
  327. }
  328. if(!$redisLiveRankList) {//live
  329. $roomParams = ['room_type' => 2];
  330. $roomLiveRes = $roomService->roomRedis($roomParams);
  331. $redisLiveRankList = $roomLiveRes['data'];
  332. }
  333. $redisRoomListIds = [];
  334. $partyIds = !empty($redisPartyRankList) ? array_keys($redisPartyRankList) : [];
  335. $liveIds = !empty($redisLiveRankList) ? array_keys($redisLiveRankList) : [];
  336. $redisRoomListIds = array_merge($redisRoomListIds,$partyIds,$liveIds);
  337. if(!empty($redisRoomListIds)) {
  338. $roomListParams = [
  339. 'ids' => $redisRoomListIds,
  340. 'type_id' => $type_id,
  341. 'is_recommend' => $is_recommend,
  342. 'all' => $all,
  343. 'start' => $start,
  344. 'end' => $end,
  345. 'index' => $index,
  346. ];
  347. $resultInfo = $roomService->getRoomList($roomListParams);
  348. if (!$resultInfo['status']) {
  349. throw new Exception($resultInfo['msg']);
  350. }
  351. }
  352. $this->success("获取成功!",$resultInfo['data']);
  353. } catch (Exception $e) {;
  354. $this->error($e->getMessage());
  355. }
  356. }
  357. /**
  358. * 获取派对用户排序
  359. */
  360. public function getPartyUserRank() {
  361. $room_type = $this->request->request('room_type',1); // 房间类型
  362. $party_id = $this->request->request("party_id");// 派对ID
  363. if (!$party_id) $this->error(__('Invalid parameters'));
  364. $redis = new Redis();
  365. $redisconfig = config("redis");
  366. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  367. if ($redisconfig['redis_pwd']) {
  368. $redis->auth($redisconfig['redis_pwd']);
  369. }
  370. if($redisconfig['redis_selectdb'] > 0){
  371. $redis->select($redisconfig['redis_selectdb']);
  372. }
  373. $res = [];
  374. // 获取今天
  375. $day = date("Ymd");
  376. // 获取本周第一天
  377. $weekday = $this->firstOfWeek(date("Y-m-d H:i:s"));
  378. // 获取本月第一天
  379. $monthday = date("Ym01");
  380. $userModel = new \app\common\model\User();
  381. // 获取条数
  382. $num = 50;
  383. // 获取50条财富排行日记录
  384. $getday = $redis->zRevRange($this->roomTypeArr[$room_type]."_jewel_get_".$party_id.":".$day."d",0,$num-1,true);
  385. $res['getRankListDay'] = $userModel->rankList($getday);
  386. // 获取50条财富排行日记录
  387. $today = $redis->zRevRange($this->roomTypeArr[$room_type]."_jewel_to_".$party_id.":".$day."d",0,$num-1,true);
  388. $res['toRankListDay'] = $userModel->rankList($today);
  389. // 获取50条财富排行周记录
  390. $getweek = $redis->zRevRange($this->roomTypeArr[$room_type]."_jewel_get_".$party_id.":".$weekday."w",0,$num-1,true);
  391. $res['getRankListWeek'] = $userModel->rankList($getweek);
  392. // 获取50条贡献排行周记录
  393. $toweek = $redis->zRevRange($this->roomTypeArr[$room_type]."_jewel_to_".$party_id.":".$weekday."w",0,$num-1,true);
  394. $res['toRankListWeek'] = $userModel->rankList($toweek);
  395. // 获取50条财富排行月记录
  396. $toweek = $redis->zRevRange($this->roomTypeArr[$room_type]."_jewel_get_".$party_id.":".$monthday."m",0,$num-1,true);
  397. $res['getRankListMonth'] = $userModel->rankList($toweek);
  398. // 获取50条贡献排行周记录
  399. $toweek = $redis->zRevRange($this->roomTypeArr[$room_type]."_jewel_to_".$party_id.":".$monthday."m",0,$num-1,true);
  400. $res['toRankListMonth'] = $userModel->rankList($toweek);
  401. return $this->success("获取成功!",$res);
  402. }
  403. /**
  404. * 派对热度更新(已废弃)
  405. */
  406. public function changeUserPartyhot() {
  407. $party_id = $this->request->request('party_id',0,"intval"); // 派对ID
  408. $room_type = $this->request->request('room_type',1); // 房间类型
  409. $party_hot = $this->request->request('party_hot'); // 房间热度(正数表示提高的热度值,负数表示降低的热度值)
  410. if (!$party_id || !$party_hot) {
  411. $this->error(__('Invalid parameters'));
  412. }
  413. $redis = new Redis();
  414. $redisconfig = config("redis");
  415. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  416. if ($redisconfig['redis_pwd']) {
  417. $redis->auth($redisconfig['redis_pwd']);
  418. }
  419. if($redisconfig['redis_selectdb'] > 0){
  420. $redis->select($redisconfig['redis_selectdb']);
  421. }
  422. // 更新热度
  423. $redis->zIncrBy($this->roomTypeArr[$room_type]."Rank", $party_hot, $party_id);
  424. return $this->success("更新成功!");
  425. }
  426. /**
  427. * 更新主持人和麦位前四位至首页房间排行
  428. */
  429. public function addUserPositionToParty() {
  430. $party_id = $this->request->request('party_id',0,"intval"); // 直播间ID
  431. $user_id = $this->request->request('user_id',0,"intval"); // 用户ID
  432. $upOrdown = $this->request->request('upordown'); // 上下麦:1=上麦-1=下麦
  433. $room_type = $this->request->request('room_type',1); // 房间类型
  434. $avatar = $this->request->request('avatar'); // 用户头像 (upOrdown参数为-1时可以不传)
  435. $position = $this->request->request('position'); // 麦位置:0=支持人,1=1号麦,2=2号麦,3=3号麦,4=4号麦
  436. if (!$party_id || !$user_id || !in_array($position,[0,1,2,3,4,5,6,7,8]) || !in_array($upOrdown,[1,-1])) {
  437. $this->error(__('Invalid parameters'));
  438. }
  439. if($upOrdown == 1) {
  440. // 先完成所有麦上记录
  441. \app\common\model\UserOnsiteTime::update(["status"=>2],["user_id"=>$user_id]);
  442. // 保存上麦记录
  443. $data = [];
  444. $data["user_id"] = $user_id;
  445. $data["party_id"] = $party_id;
  446. $data["onsite_time"] = time();
  447. \app\common\model\UserOnsiteTime::insert($data);
  448. }
  449. if($upOrdown == -1) {
  450. // 更新下麦时间
  451. $update = [];
  452. $update["offsite_time"] = time();
  453. $update["status"] = 2;
  454. \app\common\model\UserOnsiteTime::update($update,["user_id"=>$user_id,"status"=>1]);
  455. }
  456. if(in_array($position,[5,6,7,8])) return $this->success("设置成功!");
  457. $redis = new Redis();
  458. $redisconfig = config("redis");
  459. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  460. if ($redisconfig['redis_pwd']) {
  461. $redis->auth($redisconfig['redis_pwd']);
  462. }
  463. if($redisconfig['redis_selectdb'] > 0){
  464. $redis->select($redisconfig['redis_selectdb']);
  465. }
  466. $redisData = $redis->get($this->roomTypeArr[$room_type]."_".$party_id);
  467. if($redisData) {
  468. $partyInfo = json_decode($redisData,true);
  469. if($upOrdown == 1) {
  470. // 删掉已有头像,防止重复
  471. $partyuser = isset($partyInfo["party_user"])?$partyInfo["party_user"]:"";
  472. if(is_array($partyuser)) foreach($partyuser as $k => $v) if($v === $avatar) unset($partyInfo["party_user"][$k]);
  473. $partyInfo["party_user"][$position] = $avatar;
  474. } else {
  475. if(isset($partyInfo["party_user"])) unset($partyInfo["party_user"][$position]);
  476. }
  477. // sort($partyInfo["party_user"]);
  478. $redis->set($this->roomTypeArr[$room_type]."_".$party_id,json_encode($partyInfo));
  479. }
  480. return $this->success("设置成功!");
  481. }
  482. /**
  483. * 获取派对在线人数列表
  484. */
  485. public function getOnlieList() {
  486. $party_id = $this->request->request('party_id',0,"intval"); // 直播间ID 逻辑ID
  487. $page = $this->request->request('page',1); // 分页
  488. $pageNum = $this->request->request('pageNum',10); // 分页
  489. // 分页搜索构建
  490. $pageStart = ($page-1)*$pageNum;
  491. if (!$party_id) {
  492. $this->error(__('Invalid parameters'));
  493. }
  494. $redis = new Redis();
  495. $redisconfig = config("redis");
  496. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  497. if ($redisconfig['redis_pwd']) {
  498. $redis->auth($redisconfig['redis_pwd']);
  499. }
  500. if($redisconfig['redis_selectdb'] > 0){
  501. $redis->select($redisconfig['redis_selectdb']);
  502. }
  503. $res = $redis->hGetAll("online_".$party_id);
  504. $user_ids = [];$userList = [];
  505. if($res) $user_ids = array_values($res);
  506. // 获取用户列表信息
  507. $user_ids && $userList = \app\common\model\User::field("id,avatar,nickname,level,gender")->where(["id"=>["in",$user_ids]])->limit($pageStart,$pageNum)->select();
  508. $this->success("获取成功!",$userList);
  509. }
  510. /**
  511. * 加入派对
  512. */
  513. public function joinParty() {
  514. $party_id = $this->request->request('party_id',0,"intval"); // 直播间ID 逻辑ID
  515. $room_type = $this->request->request("room_type",1);//
  516. $party_pass = $this->request->request("party_pass");//
  517. if (!$party_id || !in_array($room_type,[1,2])) {
  518. $this->error(__('Invalid parameters'));
  519. }
  520. $user_id = $this->auth->id;
  521. $redis = new Redis();
  522. $redisconfig = config("redis");
  523. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  524. if ($redisconfig['redis_pwd']) {
  525. $redis->auth($redisconfig['redis_pwd']);
  526. }
  527. if($redisconfig['redis_selectdb'] > 0){
  528. $redis->select($redisconfig['redis_selectdb']);
  529. }
  530. $redis->zAdd("party_user_".$party_id,$this->auth->u_id,$user_id);
  531. // 判断当前用户是否存在在直播间通过切换过来的
  532. $livingUserPartyId = $redis->hGet("livingUser", $user_id);
  533. if ($livingUserPartyId) {
  534. if($livingUserPartyId != $party_id){
  535. // 扣除房间在线人数
  536. $redis->HDel("online_" . $livingUserPartyId, $user_id);
  537. // 扣除在线用户在房间情况
  538. $redis->hDel("livingUser", $user_id);
  539. }
  540. }
  541. // 记录在线用户在房间情况
  542. $redis->hSet("livingUser", $user_id, $party_id);
  543. // 判断当前用户是否被该房间设置限制 //项目:1=房管,2=禁言,3=拉黑,4=踢出
  544. $lsetList = [];
  545. for($i=1;$i<=4;$i++) {
  546. $hgetlist = $redis->hGet("party_manage_".$party_id,$user_id."-".$i);
  547. $hgetlist = unserialize($hgetlist);
  548. $restime = time() - intval($hgetlist["createtime"]);
  549. // 房管
  550. if($hgetlist && $i == 1) $lsetList["manage_restime"] = "";
  551. // 禁言
  552. if($hgetlist && $i == 2 && $restime < $hgetlist["time"]) $lsetList["manage_notalk"] = $restime;
  553. // 拉黑
  554. if($hgetlist && $i == 3 && $restime < $hgetlist["time"]) {
  555. $restime = date("Y-m-d H:i:s",($hgetlist["time"]+$hgetlist["createtime"]));
  556. $this->error(__('您已被该房间拉黑,解除时间:'.$restime));
  557. break;
  558. }
  559. // 踢出
  560. if($hgetlist && $i == 4 && $restime < $hgetlist["time"]) {
  561. $restime = date("Y-m-d H:i:s",($hgetlist["time"]+$hgetlist["createtime"]));
  562. $this->error(__('您已被该房间踢出,解除时间:'.$restime));
  563. break;
  564. }
  565. }
  566. // 判断派对密码
  567. $partyInfo = $redis->get($this->roomTypeArr[$room_type]."_".$party_id);
  568. if($partyInfo) {
  569. $partyInfo = json_decode($partyInfo,true);
  570. if($partyInfo["is_close"] == 1) $this->error("该房间已被关闭!");
  571. if($partyInfo["status"] != 1) $this->error("该房间为预创建房间,请联系管理员正式开通!");
  572. if(isset($partyInfo["party_pass"]) && $partyInfo["party_pass"] && $partyInfo["user_id"] != $user_id) {
  573. if(($party_pass != $partyInfo["party_pass"] || strlen($party_pass) != 4) && $this->auth->id != 4) {
  574. $this->error("派对密码不正确!");
  575. }
  576. }
  577. // 公会管理员和工会长激活派对厅
  578. $guildInfo = \app\common\model\Guild::where(['user_id' => $partyInfo['user_id'], 'status' => 1])->find();
  579. if ($guildInfo) {
  580. // 获取公会管理员
  581. $guildMemberInfo = \app\common\model\GuildMember::where(["user_id" => $user_id, "guild_id" => $guildInfo['id'], 'status' => 1])->find();
  582. if ($guildMemberInfo && $guildMemberInfo['role'] == 0) {
  583. $this->error("当前直播已结束!");
  584. }
  585. }
  586. // // 如果是房主自己进入房间,则更新用户 为在线状态
  587. // if ($partyInfo["user_id"] == $user_id) {
  588. // if ($room_type == 2)
  589. // \app\common\model\User::update(["is_live" => 1], ["id" => $partyInfo["user_id"]]);
  590. // }
  591. } else {
  592. $this->error("派对信息获取失败!");
  593. }
  594. // 获取用户魅力值
  595. $users = $redis->zRange("hourCharm_".$party_id,0,-1,true);
  596. $u = [];
  597. if($users) {
  598. foreach($users as $k => $v) $u[] = [
  599. "user_id"=>$k,
  600. "charm"=>$this->changeW($v)
  601. ];
  602. }
  603. $lsetList["userCharm"] = $u;
  604. // 获取用户排行榜前三名头像
  605. $heads = $redis->hGet("user_jewel_top3",$party_id);
  606. $lsetList["userJewelTop3"] = $heads?json_decode($heads,true):[];
  607. // 判断当前用户是否收藏了此房间
  608. $cellection = $redis->hGet("room_cellection",$user_id."-".$party_id);
  609. $lsetList["is_cellection"] = $cellection?1:0;
  610. if(isset($partyInfo["type_name"]) && $partyInfo["type_name"]) {
  611. // $partyInfo["type_name"] = $partyInfo["type_name"];
  612. } else {
  613. $partyInfo["type_name"] = "普通房";
  614. }
  615. $partyInfo["party_hot"] = $this->changeW($partyInfo["party_hot"]);
  616. $lsetList["partyInfo"] = $partyInfo;
  617. return $this->success("加入成功!",$lsetList);
  618. }
  619. /**
  620. * 判断是否被禁言
  621. */
  622. public function isNotalk() {
  623. $party_id = $this->request->request('party_id',0,"intval"); // 直播间ID 逻辑ID
  624. $user_id = $this->request->request('user_id',0,"intval"); // 用户ID 逻辑ID
  625. if (!$user_id || !$party_id) {
  626. $this->error(__('Invalid parameters'));
  627. }
  628. $redis = new Redis();
  629. $redisconfig = config("redis");
  630. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  631. if ($redisconfig['redis_pwd']) {
  632. $redis->auth($redisconfig['redis_pwd']);
  633. }
  634. if($redisconfig['redis_selectdb'] > 0){
  635. $redis->select($redisconfig['redis_selectdb']);
  636. }
  637. // 判断当前用户是否被该房间设置限制 //项目:1=房管,2=禁言,3=拉黑,4=踢出
  638. $lsetList = [];
  639. $lsetList["is_notalk"] = 0;
  640. $lsetList["notalk_time"] = 0;
  641. $hgetlist = $redis->hGet("party_manage_".$party_id,$user_id."-2");
  642. $hgetlist = unserialize($hgetlist);
  643. $restime = time() - intval($hgetlist["createtime"]);
  644. // 禁言
  645. if($hgetlist && $restime < $hgetlist["time"]) {
  646. $lsetList["is_notalk"] = 1;
  647. $lsetList["notalk_time"] = $restime;
  648. }
  649. return $this->success("获取成功!",$lsetList);
  650. }
  651. /**
  652. * 退出派对
  653. */
  654. public function outParty() {
  655. $party_id = $this->request->request('party_id',0,"intval"); // 直播间ID
  656. if (!$party_id) {
  657. $this->error(__('Invalid parameters'));
  658. }
  659. $user_u_id = $this->auth->u_id;
  660. $userId = $this->auth->id;
  661. $redis = new Redis();
  662. $redisconfig = config("redis");
  663. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  664. if ($redisconfig['redis_pwd']) {
  665. $redis->auth($redisconfig['redis_pwd']);
  666. }
  667. if($redisconfig['redis_selectdb'] > 0){
  668. $redis->select($redisconfig['redis_selectdb']);
  669. }
  670. $redis->zRem("party_user_".$party_id,$userId);
  671. // 处理online_party_id
  672. //$redis->connect($redisconfig["host"], $redisconfig["port"]);
  673. $redis->HDel("online_" . $party_id, $this->auth->id);
  674. // 扣除在线用户在房间情况
  675. $redis->hDel("livingUser", $this->auth->id);
  676. // 更新房间在线状态
  677. $partyInfo = $redis->get("party_" . $party_id);
  678. if ($partyInfo) {
  679. $partyInfo = json_decode($partyInfo, true);
  680. $memCount = count($redis->hGetAll("online_" . $party_id));
  681. if ($memCount <= 0) {
  682. $partyInfo["is_online"] = 0;
  683. $redis->set("party_" . $party_id, json_encode($partyInfo));
  684. \app\common\model\Party::update(["is_online" => 0], ["id" => $party_id]);
  685. }
  686. }
  687. $liveInfo = $redis->get("live_" . $party_id);
  688. if ($liveInfo) {
  689. $liveInfo = json_decode($liveInfo, true);
  690. $memCount = count($redis->hGetAll("online_" . $party_id));
  691. if ($memCount <= 0) {
  692. $liveInfo["is_online"] = 0;
  693. $redis->set("live_" . $party_id, json_encode($liveInfo));
  694. \app\common\model\Party::update(["is_online" => 0], ["id" => $party_id]);
  695. }
  696. }
  697. return $this->success("退出成功!",[]);
  698. }
  699. /**
  700. * 派对内搜索用户
  701. */
  702. public function searchUserParty() {
  703. $u_id = $this->request->request('u_id',0,"intval"); // 用户u_id
  704. $party_id = $this->request->request('party_id',0,"intval"); // 直播间ID
  705. // $redis = new Redis();
  706. // $redisconfig = config("redis");
  707. // $redis->connect($redisconfig["host"], $redisconfig["port"]);
  708. /*if ($redisconfig['redis_pwd']) {
  709. $redis->auth($redisconfig['redis_pwd']);
  710. }
  711. if($redisconfig['redis_selectdb'] > 0){
  712. $redis->select($redisconfig['redis_selectdb']);
  713. }*/
  714. // $userids = $redis->zRange("party_user_".$party_id,0,-1,true);
  715. // $useridArr = [];
  716. // if($userids)foreach($userids as $k => $v) $useridArr[$v] = $k; // 因为array_slip 不能交换数字啊
  717. // $userid = isset($useridArr[$u_id])?$useridArr[$u_id]:0;
  718. $userModel = new \app\common\model\User();
  719. $where = [];
  720. $where["u_id"] = $u_id;
  721. $userInfo = $userModel->field("id,u_id,avatar,nickname,level,gender")->where($where)->select();
  722. return $this->success("查询成功!",$userInfo);
  723. }
  724. /**
  725. * 设置冠名
  726. */
  727. public function setNaming() {
  728. $party_id = $this->request->request('party_id',0,"intval"); // 直播间ID
  729. $user_id = $this->request->request('user_id',0,"intval"); // 用户ID
  730. $type = $this->request->request('type',1); // 1:设置 0:取消设置
  731. if (!$party_id || !$user_id || ($type != 1 && $type != 0)) {
  732. $this->error(__('Invalid parameters'));
  733. }
  734. $redis = new Redis();
  735. $redisconfig = config("redis");
  736. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  737. if ($redisconfig['redis_pwd']) {
  738. $redis->auth($redisconfig['redis_pwd']);
  739. }
  740. if($redisconfig['redis_selectdb'] > 0){
  741. $redis->select($redisconfig['redis_selectdb']);
  742. }
  743. $partyModel = new \app\common\model\Party();
  744. $data = [];
  745. $where = [];
  746. $where["id"] = $party_id;
  747. $partyInfo = $partyModel->where(["id"=>$party_id])->find();
  748. $getredisPartyInfo = $redis->get($this->roomTypeArr[$partyInfo->room_type].'_'.$party_id);
  749. $redisPartyInfo = json_decode($getredisPartyInfo,true);
  750. if($type == 1) {
  751. $data["naming"] = $user_id;
  752. // 冠名
  753. $userInfo = \app\common\model\User::field("id,nickname,avatar")->where(["id"=>$user_id])->find($user_id);
  754. $redisPartyInfo["naming"] = $userInfo;
  755. } else {
  756. $data["naming"] = 0;
  757. $redisPartyInfo["naming"] = [];
  758. }
  759. $redis->set($this->roomTypeArr[$partyInfo->room_type].'_'.$party_id,json_encode($redisPartyInfo));
  760. $res = $partyModel->update($data,$where);
  761. if($res !== false) {
  762. $this->success("操作成功!");
  763. } else {
  764. $this->error("网络错误,请稍后重试!");
  765. }
  766. }
  767. /**
  768. * 派对收藏
  769. */
  770. public function cellectionParty() {
  771. $party_id = $this->request->request('party_id',0,"intval"); // 直播间ID
  772. if (!$party_id) {
  773. $this->error(__('Invalid parameters'));
  774. }
  775. $user_id = $this->auth->id;
  776. $redis = new Redis();
  777. $redisconfig = config("redis");
  778. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  779. if ($redisconfig['redis_pwd']) {
  780. $redis->auth($redisconfig['redis_pwd']);
  781. }
  782. if($redisconfig['redis_selectdb'] > 0){
  783. $redis->select($redisconfig['redis_selectdb']);
  784. }
  785. $partycellectionModel = new \app\common\model\PartyCellection();
  786. // 添加记录
  787. $data = [];
  788. $data["user_id"] = $user_id;
  789. $data["party_id"] = $party_id;
  790. if($partycellectionModel->where($data)->find()) {
  791. $res = $partycellectionModel->where($data)->delete();
  792. $redis->hDel("room_cellection",$user_id."-".$party_id);
  793. return $this->success("取消收藏成功!",$res);
  794. }
  795. $data["createtime"] = time();
  796. $res = $partycellectionModel->insert($data);
  797. $redis->hSet("room_cellection",$user_id."-".$party_id,1);
  798. return $this->success("收藏成功!",$res);
  799. }
  800. /**
  801. * 派对收藏列表
  802. */
  803. public function cellectionPartyList() {
  804. $page = $this->request->request('page',1); // 分页
  805. $pageNum = $this->request->request('pageNum',10); // 分页
  806. // 分页搜索构建
  807. $pageStart = ($page-1)*$pageNum;
  808. $partycellectionModel = new \app\common\model\PartyCellection();
  809. $userModel = new \app\common\model\User();
  810. $where = [];
  811. $where["a.user_id"] = $this->auth->id;
  812. $where["r.room_type"] = 1;
  813. $list = $partycellectionModel->alias("a")
  814. ->field("a.party_id,r.party_logo,r.party_hot,r.party_id as r_id,r.party_name,t.id as party_type_id,t.name as party_type")
  815. ->where($where)
  816. ->join("hx_party r","a.party_id = r.id")
  817. ->join("hx_party_type t","t.id = r.party_type","left")
  818. ->limit($pageStart,$pageNum)
  819. ->select();
  820. if($list) {
  821. // $redis = new Redis();
  822. // $redisconfig = config("redis");
  823. // $redis->connect($redisconfig["host"], $redisconfig["port"]);
  824. /*if ($redisconfig['redis_pwd']) {
  825. $redis->auth($redisconfig['redis_pwd']);
  826. }
  827. if($redisconfig['redis_selectdb'] > 0){
  828. $redis->select($redisconfig['redis_selectdb']);
  829. }*/
  830. // // 获取本周第一天
  831. // $weekday = $this->firstOfWeek(date("Y-m-d H:i:s"));
  832. // // 获取redis 中 用户排行榜前五名
  833. // foreach($list as $k => $v) {
  834. // $getweek = $redis->zRevRange("party_jewel_get_".$v["r_id"].":".$weekday,0,4,true);
  835. // $userlist = $userModel->rankList($getweek);
  836. // if($userlist) {
  837. // $users = [];
  838. // foreach($userlist as $m => $n) {
  839. // $users[] = $n["avatar"];
  840. // }
  841. // $list[$k]["users"] = $users;
  842. // } else {
  843. // $list[$k]["users"] = [];
  844. // }
  845. //
  846. // $mod = isset($v["party_type_id"])?intval($v["party_type_id"])%5:1;
  847. // $list[$k]["party_type_color"] = $mod == 0?5:$mod;
  848. // }
  849. $users = [];
  850. foreach($list as $k => $v) {
  851. $users[$v["party_id"]] = $v["party_hot"];
  852. }
  853. $partyModel = new \app\common\model\Party();
  854. $resultInfo = $partyModel->getPatyInfoByPartyId($users,"party",0,0,1,0,20,0);
  855. $this->success("获取成功!",$resultInfo);
  856. }
  857. return $this->success("获取成功!",$list);
  858. }
  859. /**
  860. * 获取派对信息
  861. */
  862. public function getPartyInfo() {
  863. $party_id = $this->request->request('party_id',0,"intval"); // 直播间ID
  864. if (!$party_id) {
  865. $this->error(__('Invalid parameters'));
  866. }
  867. $user_id = $this->auth->id;
  868. $partyModel = new \app\common\model\Party();
  869. $partycellectionModel = new \app\common\model\PartyCellection();
  870. $userModel = new \app\common\model\User();
  871. // 获取主体信息
  872. $where = [];
  873. $where["a.id"] = $party_id;
  874. $partyInfo = $partyModel->alias("a")
  875. ->field("a.id,a.user_id,a.party_id,a.party_name,a.party_hot,a.party_logo,rt.id as party_type,rt.name as type_name,a.party_notice,a.party_notice_detail")
  876. ->join("hx_party_type rt","rt.id = a.party_type", "left")
  877. ->where($where)
  878. ->find();
  879. if($partyInfo) {
  880. $mod = isset($partyInfo["party_type"])?intval($partyInfo["party_type"])%5:1;
  881. $partyInfo["party_type_color"] = $mod == 0?5:$mod;
  882. if(isset($partyInfo["type_name"]) && $partyInfo["type_name"]) {
  883. // $partyInfo["type_name"] = $partyInfo["type_name"];
  884. } else {
  885. $partyInfo["type_name"] = "普通房";
  886. }
  887. // 获取是否被当前用户收藏
  888. $partyInfo["is_sellection"] = 0;
  889. $where = [];
  890. $where["user_id"] = $user_id;
  891. $where["party_id"] = $party_id;
  892. if($partycellectionModel->where($where)->find()) {
  893. $partyInfo["is_sellection"] = 1;
  894. }
  895. // 获取房主信息
  896. $where = [];
  897. $where["id"] = $partyInfo["user_id"];
  898. $userInfo = $userModel->field("avatar,nickname")->where($where)->find();
  899. // 获取技能信息
  900. $skillList = Model("ViewUserSkill")->getSkillInfo($partyInfo["user_id"]);
  901. $userInfo["skill"] = implode("/",$skillList);
  902. $partyInfo["userInfo"] = $userInfo;
  903. $partyInfo["party_hot"] = $this->changeW($partyInfo["party_hot"]);
  904. }
  905. $this->success("获取成功!",$partyInfo);
  906. }
  907. /**
  908. * 派对设置
  909. */
  910. public function setParty() {
  911. $party_id = $this->request->request('party_id',0,"intval"); // 直播间ID
  912. $party_name = $this->request->request('party_name'); // 派对名称
  913. $party_logo = $this->request->request('party_logo'); // 派对logo/封面
  914. $party_pass = $this->request->request('party_pass'); // 派对密码
  915. $party_type = $this->request->request('party_type'); // 使用场景
  916. $is_screen = $this->request->request('is_screen'); // 是否关闭公屏:1=是,0=否
  917. $on_model = $this->request->request('on_model'); // 上麦模式:1=自由模式,2=麦序模式
  918. $room_type = $this->request->request('room_type',1); // 房间类型:1=派对,2=直播
  919. $background = $this->request->request('background'); // 派对背景
  920. if (!$party_id || (!$party_name && !$party_logo && !$party_pass && !$party_type && !$is_screen && !$on_model && !$background)) {
  921. $this->error(__('Invalid parameters'));
  922. }
  923. if($party_pass && strlen($party_pass) != 4) {
  924. $this->error("房间密码必须为四位!");
  925. }
  926. $partyModel = new \app\common\model\Party();
  927. $data = [];
  928. $party_name && $data["party_name"] = $party_name;
  929. $party_logo && $data["party_logo"] = $party_logo;
  930. $data["party_pass"] = $party_pass;
  931. $party_type && $data["party_type"] = $party_type;
  932. $is_screen && $data["is_screen"] = $is_screen;
  933. $on_model && $data["on_model"] = $on_model;
  934. $background && $data["background"] = $background;
  935. $where = [];
  936. $where["id"] = $party_id;
  937. $res = $partyModel->update($data,$where);
  938. if($res) {
  939. // 获取派对类型
  940. if($party_type) $data["type_name"] = \app\common\model\PartyType::where(["id"=>$party_type])->value("name");
  941. // 存redis 房间信息
  942. $redis = new Redis();
  943. $redisconfig = config("redis");
  944. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  945. if ($redisconfig['redis_pwd']) {
  946. $redis->auth($redisconfig['redis_pwd']);
  947. }
  948. if($redisconfig['redis_selectdb'] > 0){
  949. $redis->select($redisconfig['redis_selectdb']);
  950. }
  951. $partyInfo = $redis->get($this->roomTypeArr[$room_type]."_".$party_id);
  952. if($partyInfo) {
  953. $partyInfo = json_decode($partyInfo,true);
  954. $partyInfo = array_replace($partyInfo,$data);
  955. $redis->set($this->roomTypeArr[$room_type]."_".$party_id,json_encode($partyInfo));
  956. }
  957. $this->success("房间设置成功!",$data);
  958. } else {
  959. $this->error("网络错误,请稍后重试!");
  960. }
  961. }
  962. /**
  963. * 获取派对背景
  964. */
  965. public function getDefaultBackground() {
  966. $room_type = $this->request->request('room_type',1); // 房间类型
  967. if (!in_array($room_type,[1,2])) {
  968. $this->error(__('Invalid parameters'));
  969. }
  970. $this->success("获取成功!",\app\common\model\PartyBackground::where(["room_type"=>$room_type])->select());
  971. }
  972. /**
  973. * 派对管理设置
  974. */
  975. public function partyManageSet() {
  976. $party_id = $this->request->request('party_id',0,"intval"); // 直播间ID
  977. $user_id = $this->request->request('user_id',0,"intval"); // 用户ID
  978. $item = $this->request->request('item'); // 项目:1=房管,2=禁言,3=拉黑,4=踢出
  979. $time = $this->request->request('time'); // 限制时间(单位:秒):0=永久
  980. if (!$party_id || !$user_id || !in_array($item,[1,2,3,4])) {
  981. $this->error(__('Invalid parameters'));
  982. }
  983. if($item>1 && $time<=0) {
  984. $this->error(__('时间设置有误'));
  985. }
  986. $partyUserId = \app\common\model\Party::where('id', $party_id)->value('user_id');
  987. if ($partyUserId == $user_id && in_array($item, [2, 3, 4])) {
  988. $this->error("您当前无权限操作!");
  989. }
  990. // 获取用户信息
  991. $userInfo = \app\common\model\User::field("noble,avatar,nickname,gender,level")->where(["id"=>$user_id])->find();
  992. if(!$userInfo) $this->error("用户信息获取失败!");
  993. // 国王防踢。
  994. $noble_no = \app\common\model\NobleLevel::where(["id"=>$userInfo->noble])->value("level_no");
  995. if(($item == 3 || $item == 4) && $noble_no == "p08PCcNB") {
  996. $this->error("对方已开通国王贵族,踢出房间失败!");
  997. }
  998. $redis = new Redis();
  999. $redisconfig = config("redis");
  1000. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  1001. if ($redisconfig['redis_pwd']) {
  1002. $redis->auth($redisconfig['redis_pwd']);
  1003. }
  1004. if($redisconfig['redis_selectdb'] > 0){
  1005. $redis->select($redisconfig['redis_selectdb']);
  1006. }
  1007. $data = [];
  1008. $data["user_id"] = $user_id;
  1009. $data["avatar"] = $userInfo->avatar;
  1010. $data["nickname"] = $userInfo->nickname;
  1011. $data["gender"] = $userInfo->gender;
  1012. $data["level"] = $userInfo->level;
  1013. $data["item"] = $item;
  1014. $data["time"] = $time;
  1015. $data["createtime"] = time();
  1016. $res = $redis->hSet("party_manage_".$party_id,$user_id."-".$item,serialize($data));
  1017. if($res !== false) {
  1018. $this->success("设置成功!",$data);
  1019. } else {
  1020. $this->error("网络错误,请稍后重试!");
  1021. }
  1022. }
  1023. /**
  1024. * 派对管理设置列表
  1025. */
  1026. public function partyManageSetList() {
  1027. $party_id = $this->request->request('party_id',0,"intval"); // 直播间ID
  1028. $item = $this->request->request('item',1,"intval"); // 项目:1=房管,2=禁言,3=拉黑,4=踢出
  1029. if (!$party_id || !in_array($item,[1,2,3,4])) {
  1030. $this->error(__('Invalid parameters'));
  1031. }
  1032. $time = time();
  1033. $redis = new Redis();
  1034. $redisconfig = config("redis");
  1035. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  1036. if ($redisconfig['redis_pwd']) {
  1037. $redis->auth($redisconfig['redis_pwd']);
  1038. }
  1039. if($redisconfig['redis_selectdb'] > 0){
  1040. $redis->select($redisconfig['redis_selectdb']);
  1041. }
  1042. $hget=$redis->hGetAll("party_manage_".$party_id);
  1043. $list=array();
  1044. foreach($hget as $key=>$val) {
  1045. if(substr($key,-2) == "-".$item){
  1046. array_push($list,unserialize($val));
  1047. }
  1048. }
  1049. if($list) {
  1050. foreach($list as $k => $v) if(bcadd($v["createtime"],$v["time"]) <= $time && $v["item"] > 1) unset($list[$k]);
  1051. if($list) $list = array_values($list);
  1052. }
  1053. $this->success("获取成功!",$list);
  1054. }
  1055. /**
  1056. * 派对管理设置移除
  1057. */
  1058. public function partyManageSetDel() {
  1059. $id = $this->request->request('user_id',0,"intval"); // userid
  1060. $party_id = $this->request->request('party_id',0,"intval"); // 房间ID
  1061. $item = $this->request->request('item',1,"intval"); // 项目:1=房管,2=禁言,3=拉黑,4=踢出
  1062. if (!$id || !in_array($item,[1,2,3,4])) {
  1063. $this->error(__('Invalid parameters'));
  1064. }
  1065. $redis = new Redis();
  1066. $redisconfig = config("redis");
  1067. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  1068. if ($redisconfig['redis_pwd']) {
  1069. $redis->auth($redisconfig['redis_pwd']);
  1070. }
  1071. if($redisconfig['redis_selectdb'] > 0){
  1072. $redis->select($redisconfig['redis_selectdb']);
  1073. }
  1074. $res = $redis->hDel("party_manage_".$party_id,$id."-".$item);
  1075. if($res !== false) {
  1076. $this->success("移除成功!",$res);
  1077. } else {
  1078. $this->error("网络错误,请稍后重试!");
  1079. }
  1080. }
  1081. /**
  1082. * 更新派对公告
  1083. */
  1084. public function savePartyNotice() {
  1085. $party_id = $this->request->request('party_id',0,"intval"); // 直播间ID
  1086. $room_type = $this->request->request('room_type',1); // 房间类型:1=派对2=直播
  1087. $party_notice = $this->request->request('party_notice'); // 公告标题
  1088. $party_notice_detail = $this->request->request('party_notice_detail'); // 公告内容
  1089. if (!$party_id || !$party_notice || !$party_notice_detail) {
  1090. $this->error(__('Invalid parameters'));
  1091. }
  1092. $partyModel = new \app\common\model\Party();
  1093. $where = [];
  1094. $where["id"] = $party_id;
  1095. $data = [];
  1096. $data["party_notice"] = $party_notice;
  1097. $data["party_notice_detail"] = $party_notice_detail;
  1098. $res = $partyModel->update($data,$where);
  1099. if($res) {
  1100. // 存redis 房间信息
  1101. $redis = new Redis();
  1102. $redisconfig = config("redis");
  1103. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  1104. if ($redisconfig['redis_pwd']) {
  1105. $redis->auth($redisconfig['redis_pwd']);
  1106. }
  1107. if($redisconfig['redis_selectdb'] > 0){
  1108. $redis->select($redisconfig['redis_selectdb']);
  1109. }
  1110. $partyInfo = $redis->get($this->roomTypeArr[$room_type]."_".$party_id);
  1111. if($partyInfo) {
  1112. $partyInfo = json_decode($partyInfo,true);
  1113. $partyInfo = array_replace($partyInfo,$data);
  1114. $redis->set($this->roomTypeArr[$room_type]."_".$party_id,json_encode($partyInfo));
  1115. }
  1116. $this->success("更新成功!",$res);
  1117. } else {
  1118. $this->error("网络错误,请稍后重试!");
  1119. }
  1120. }
  1121. /**
  1122. * 开始排麦
  1123. */
  1124. public function addLineUp() {
  1125. $party_id = $this->request->request('party_id',0,"intval"); // 直播间ID
  1126. $mai_id = $this->request->request('mai_id',"1"); // 麦位置
  1127. if (!$party_id) {
  1128. $this->error(__('Invalid parameters'));
  1129. }
  1130. $userInfo = $this->auth->getUserinfo();
  1131. $userid = $userInfo['id'];
  1132. // 获取 房间信息
  1133. $partyUser = \app\common\model\Party::where(['id'=>$party_id])->value("user_id");
  1134. if(!$partyUser) $this->error(__('房间信息未找到!'));
  1135. // $is_home = $partyUser == $userInfo->id?1:0;
  1136. $redis = new Redis();
  1137. $redisconfig = config("redis");
  1138. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  1139. if ($redisconfig['redis_pwd']) {
  1140. $redis->auth($redisconfig['redis_pwd']);
  1141. }
  1142. if($redisconfig['redis_selectdb'] > 0){
  1143. $redis->select($redisconfig['redis_selectdb']);
  1144. }
  1145. $data = unserialize($redis->hGet("party_lineup",$party_id));
  1146. $data[$userid]["user_id"] = $userInfo['id'];
  1147. $data[$userid]["avatar"] = $userInfo['avatar'];
  1148. $data[$userid]["mai_id"] = $mai_id;
  1149. $data[$userid]["nickname"] = $userInfo['nickname'];
  1150. // $data["is_home"] = $is_home;
  1151. $data[$userid]["level"] = $userInfo['level'];
  1152. $data[$userid]["gender"] = $userInfo['gender'];
  1153. $res = false;
  1154. $data && $res = $redis->hSet("party_lineup",$party_id,serialize($data));
  1155. $data = array_values($data);
  1156. if($res !== false) {
  1157. $this->success("设置成功!",$data);
  1158. } else {
  1159. $this->error("网络错误,请稍后重试!");
  1160. }
  1161. }
  1162. /**
  1163. * 取消排麦
  1164. */
  1165. public function cancelLineUp() {
  1166. $party_id = $this->request->request('party_id',0,"intval"); // 直播间ID
  1167. $user_id = $this->request->request('user_id',0); // 直播间ID
  1168. $is_empty = $this->request->request('is_empty',0,"intval"); // 是否清空排麦列表 1=清空,0=不清空
  1169. if (!$party_id) {
  1170. $this->error(__('Invalid parameters'));
  1171. }
  1172. $userid = $this->auth->id;
  1173. $redis = new Redis();
  1174. $redisconfig = config("redis");
  1175. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  1176. if ($redisconfig['redis_pwd']) {
  1177. $redis->auth($redisconfig['redis_pwd']);
  1178. }
  1179. if($redisconfig['redis_selectdb'] > 0){
  1180. $redis->select($redisconfig['redis_selectdb']);
  1181. }
  1182. $data=unserialize($redis->hGet("party_lineup",$party_id));
  1183. if($data && $is_empty != 1) {
  1184. foreach($data as $k => $v) {
  1185. if($v["user_id"] == $user_id) {
  1186. unset($data[$k]);
  1187. break;
  1188. }
  1189. }
  1190. }
  1191. // unset($data[$userid]);
  1192. if($is_empty == 1) $data = [];
  1193. $redis->hSet("party_lineup",$party_id,serialize($data));
  1194. $this->success("移除成功!");
  1195. }
  1196. /**
  1197. * 排麦列表
  1198. */
  1199. public function lineUpList() {
  1200. $party_id = $this->request->request('party_id',0,"intval"); // 直播间ID
  1201. if (!$party_id) {
  1202. $this->error(__('Invalid parameters'));
  1203. }
  1204. $redis = new Redis();
  1205. $redisconfig = config("redis");
  1206. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  1207. if ($redisconfig['redis_pwd']) {
  1208. $redis->auth($redisconfig['redis_pwd']);
  1209. }
  1210. if($redisconfig['redis_selectdb'] > 0){
  1211. $redis->select($redisconfig['redis_selectdb']);
  1212. }
  1213. $data = $redis->hGet("party_lineup",$party_id);
  1214. $dataArr = unserialize($data);
  1215. $datas = [];
  1216. is_array($dataArr) && $datas=array_values($dataArr);
  1217. if($datas) {
  1218. $this->success("获取成功!",$datas);
  1219. } else {
  1220. $this->success("获取成功!",[]);
  1221. }
  1222. }
  1223. /**
  1224. * 获取派对类型
  1225. */
  1226. public function getPatyType() {
  1227. $room_type = $this->request->request("room_type",1);//
  1228. if (!in_array($room_type,[1,2])) $this->error(__('Invalid parameters'));
  1229. $partytypeModel = new \app\common\model\PartyType();
  1230. $partytypeList = $partytypeModel->where(["room_type"=>$room_type])->select();
  1231. $this->success("获取成功!",$partytypeList);
  1232. }
  1233. /**
  1234. * 判断派对是否设置过密码
  1235. */
  1236. public function getPatyIspass() {
  1237. $party_id = $this->request->request("party_id");// 派对ID
  1238. $room_type = $this->request->request("room_type",1);//
  1239. $is_miniprogram = $this->request->request("is_miniprogram",0);//
  1240. if (!$party_id) $this->error(__('Invalid parameters'));
  1241. $user_id = $this->auth->id;
  1242. // 存redis 房间信息
  1243. $redis = new Redis();
  1244. $redisconfig = config("redis");
  1245. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  1246. if ($redisconfig['redis_pwd']) {
  1247. $redis->auth($redisconfig['redis_pwd']);
  1248. }
  1249. if($redisconfig['redis_selectdb'] > 0){
  1250. $redis->select($redisconfig['redis_selectdb']);
  1251. }
  1252. $partyInfo = $redis->get($this->roomTypeArr[$room_type]."_".$party_id);
  1253. if($partyInfo) {
  1254. $partyInfo = json_decode($partyInfo,true);
  1255. } else {
  1256. $partyModel = new \app\common\model\Party();
  1257. $partyInfo = $partyModel->field("id,user_id,party_pass")->where(["id"=>$party_id])->find();
  1258. if(!$partyInfo) {
  1259. $this->error(__('房间信息获取失败!'));
  1260. }
  1261. }
  1262. $data = [];
  1263. $data["status"] = 0;
  1264. $data["is_pass"] = $partyInfo["party_pass"]?1:0;
  1265. if($partyInfo["user_id"] == $user_id || $this->auth->mobile == '17353993050') $data["is_pass"] = 0;
  1266. if($is_miniprogram == 1) { // 小程序单独处理
  1267. // 判断当前用户是否被该房间设置限制 //项目:1=房管,2=禁言,3=拉黑,4=踢出
  1268. $lsetList = [];
  1269. for($i=1;$i<=4;$i++) {
  1270. $hgetlist = $redis->hGet("party_manage_".$party_id,$user_id."-".$i);
  1271. $hgetlist = unserialize($hgetlist);
  1272. $restime = time() - intval($hgetlist["createtime"]);
  1273. // 房管
  1274. if($hgetlist && $i == 1) $lsetList["manage_restime"] = "";
  1275. // 禁言
  1276. if($hgetlist && $i == 2 && $restime < $hgetlist["time"]) $lsetList["manage_notalk"] = $restime;
  1277. // 拉黑
  1278. if($hgetlist && $i == 3 && $restime < $hgetlist["time"]) {
  1279. $restime = date("Y-m-d H:i:s",($hgetlist["time"]+$hgetlist["createtime"]));
  1280. $lsetList["manage_black"] = $restime;
  1281. $lsetList["tips"] = '您已被该房间拉黑,解除时间:'.$restime;
  1282. // $this->error(__('您已被该房间拉黑,解除时间:'.$restime));
  1283. break;
  1284. }
  1285. // 踢出
  1286. if($hgetlist && $i == 4 && $restime < $hgetlist["time"]) {
  1287. $restime = date("Y-m-d H:i:s",($hgetlist["time"]+$hgetlist["createtime"]));
  1288. $lsetList["manage_takeout"] = $restime;
  1289. $lsetList["tips"] = '您已被该房间踢出,解除时间:'.$restime;
  1290. // $this->error(__('您已被该房间踢出,解除时间:'.$restime));
  1291. break;
  1292. }
  1293. }
  1294. if($lsetList) {
  1295. $data["status"] = 1;
  1296. $data["hgetlist"] = $lsetList;
  1297. }
  1298. }
  1299. $this->success("获取成功!",$data);
  1300. }
  1301. /**
  1302. * 获取房间gif表情列表
  1303. */
  1304. public function getPartGifList() {
  1305. $this->success("获取成功!",\app\common\model\PartyGif::field("id,gif_image")->order("weight","asc")->select());
  1306. }
  1307. /**
  1308. * 获取房间头像gif表情列表
  1309. */
  1310. public function getPartHeadgifList() {
  1311. $this->success("获取成功!",\app\common\model\PartyHeadgif::field("id,name,gif_image")->order("weight","asc")->select());
  1312. }
  1313. /**
  1314. * 随机获取礼物盒礼物
  1315. */
  1316. private function getBoxGift($gift_box_type) {
  1317. // 查询本奖池内礼物是否还有可抽礼物
  1318. $where = [];
  1319. $where["Jackpot_id"] = $gift_box_type;
  1320. $where["is_use"] = 0;
  1321. $boxhasgift = \app\common\model\GiftBox::where($where)->select();
  1322. $giftcount = count($boxhasgift);
  1323. $giftArr = [];
  1324. foreach($boxhasgift as $k => $v) $giftArr[$v["id"]] = $v;
  1325. if($giftcount > 1) {
  1326. // 随机抽取$num个礼物
  1327. $giftids = array_rand($giftArr,1);
  1328. \app\common\model\GiftBox::update(["is_use"=>1],["id"=>$giftids]);
  1329. }
  1330. if($giftcount == 1) {
  1331. $giftids = $boxhasgift[0]["id"];
  1332. // 更新宝箱奖池全部礼物为未使用
  1333. \app\common\model\GiftBox::update(["is_use"=>0],["Jackpot_id"=>$gift_box_type]);
  1334. }
  1335. $giftInfo = $giftArr[$giftids];
  1336. return $giftInfo;
  1337. }
  1338. /**
  1339. * 单独赠送礼物,一键清空背包
  1340. */
  1341. public function giveAllbackGiftToYou(){
  1342. // 接口防并发
  1343. if (!$this->apiLimit(1, 1000)) {
  1344. $this->error(__('Operation frequently'));
  1345. }
  1346. $user_ids = $this->request->request("user_id");// 赠送对象
  1347. $party_id = $this->request->request("party_id",0);// 派对ID
  1348. $room_type = $this->request->request('room_type',1); // 房间类型
  1349. $is_back = 1; // 是否背包赠送: 1=是,0=否
  1350. if (!$user_ids || !in_array($room_type,[1,2])) $this->error(__('Invalid parameters'));
  1351. }
  1352. /**
  1353. * 全麦/单独赠送礼物
  1354. */
  1355. public function giveGiftToYou() {
  1356. // 接口防并发
  1357. if (!$this->apiLimit(1, 1000)) {
  1358. $this->error(__('Operation frequently'));
  1359. }
  1360. $user_ids = $this->request->request("user_id");// 赠送对象
  1361. $gift_id = $this->request->request("gift_id");// 礼物ID
  1362. $party_id = $this->request->request("party_id",0);// 派对ID
  1363. $room_type = $this->request->request('room_type',1); // 房间类型
  1364. $number = $this->request->request("number");// 赠送数量
  1365. $is_back = $this->request->request("is_back",0);// 是否背包赠送: 1=是,0=否
  1366. if (!$user_ids || !in_array($is_back,[0,1]) || !$gift_id || !$number || !in_array($room_type,[1,2])) $this->error(__('Invalid parameters'));
  1367. $user_id_arr = explode(",",$user_ids);
  1368. $userCount = count($user_id_arr);
  1369. $userauthid = $this->auth->id;
  1370. //$soundCoinRate = config("site.giftCoin"); // 声币兑换比例
  1371. $money_to_jewel = config('site.money_to_jewel') ?: 10; //余额兑换钻石
  1372. $userModel = new \app\common\model\User();
  1373. $backGiftId = 0;
  1374. $boxgiftInfo = [];
  1375. if($is_back == 1) {
  1376. // 获取背包礼物信息
  1377. $giftInfo = \app\common\model\GiftBack::get($gift_id);
  1378. if(!$giftInfo) $this->error("背包礼物获取失败");
  1379. $backGiftId = $giftInfo->gift_id;
  1380. // 随机获取一个礼物
  1381. $allCount = $number*$userCount;
  1382. $giftbackList = \app\common\model\GiftBack::where(["name"=>$giftInfo->name,"user_id"=>$userauthid,'is_use'=>0])->limit($allCount)->select();
  1383. $giftInfo = isset($giftbackList[0])?$giftbackList[0]:[];
  1384. $giftcount = 0;
  1385. $giftList = [];
  1386. if($giftbackList) foreach($giftbackList as $k => $v) {
  1387. $giftcount = $giftcount + $v["number"];
  1388. $giftList[$k] = $v;
  1389. if($giftcount >= $allCount) {
  1390. break;
  1391. }
  1392. }
  1393. if($giftcount < $allCount) $this->error("背包数量不足");
  1394. $giftValue = $giftInfo["value"] * $number;
  1395. $getValue = $giftInfo["value"] * $number;
  1396. } else {
  1397. // // 不可以赠送给自己
  1398. // if(in_array($userauthid,$user_id_arr)) $this->error("不可以赠送给自己!");
  1399. // 获取礼物信息
  1400. $giftModel = new \app\common\model\Gift();
  1401. $where = [];
  1402. $where["id"] = $gift_id;
  1403. $giftInfo = $giftModel->where($where)->find();
  1404. if (!$giftInfo) $this->error("请选择礼物!");
  1405. $giftValue = $giftInfo["value"] * $number;
  1406. $giftCountValue = $giftInfo["value"] * $number * $userCount;
  1407. $getValue = $giftValue;
  1408. // 判断如果是礼物盒则随机开礼物盒礼物
  1409. if($giftInfo->box_type > 0) {
  1410. $boxgiftInfo = $this->getBoxGift($giftInfo->box_type);
  1411. $getValue = $boxgiftInfo["price"];
  1412. }
  1413. // 判断当前用户余额
  1414. $where = [];
  1415. $where["id"] = $userauthid;
  1416. $userInfo = $userModel->where($where)->lock(true)->find();
  1417. if (!$userInfo) $this->error("用户信息查询失败!");
  1418. if($userInfo["jewel"] < $giftCountValue) $this->error("您的钻石余额不足!");
  1419. }
  1420. $hotValue = $getValue;
  1421. //$getValue = round($getValue * ($soundCoinRate/100));
  1422. // 转换统计
  1423. $progetValue = $hotValue - $getValue;
  1424. if($progetValue >0) {
  1425. $data = [];
  1426. $data["user_id"] = $user_ids;
  1427. $data["party_id"] = $party_id?$party_id:0;
  1428. $data["gift_value"] = $hotValue;
  1429. $data["plat_value"] = $hotValue - $getValue;
  1430. $data["createtime"] = time();
  1431. \app\common\model\UserChangeLog::insert($data);
  1432. }
  1433. // 转换声币后 再进行抽点设置
  1434. $partyInfo = null;
  1435. if(!$party_id) {
  1436. $platRate = 10;
  1437. $guilderRate = 30;
  1438. } else {
  1439. $partyInfo = \app\common\model\Party::field("user_id,platRate,guilderRate")->where(["id"=>$party_id])->find();
  1440. // 获取系统配置信息
  1441. $platRate = $partyInfo->platRate; // 平台抽成百分比
  1442. $guilderRate = $partyInfo->guilderRate; // 工会长抽成百分比
  1443. }
  1444. $platValue = bcmul($platRate/100,$getValue,2);
  1445. $guilderValue = bcmul($guilderRate/100,$getValue,2);
  1446. $getValue = bcsub(bcsub($getValue,$platValue,2),$guilderValue,2);
  1447. // $gif_image = $is_back==1?$giftInfo["gif_image"]:$giftInfo["special"];
  1448. $returnData = [];
  1449. Db::startTrans();
  1450. try {
  1451. $redis = new Redis();
  1452. $redisconfig = config("redis");
  1453. $redis->connect($redisconfig["host"], $redisconfig["port"], 86400 * 31);
  1454. if ($redisconfig['redis_pwd']) {
  1455. $redis->auth($redisconfig['redis_pwd']);
  1456. }
  1457. if($redisconfig['redis_selectdb'] > 0){
  1458. $redis->select($redisconfig['redis_selectdb']);
  1459. }
  1460. // 事务处理余额与记录信息
  1461. $userjewellogModel = new \app\common\model\UserJewelLog();
  1462. //$usersoundcoinlogModel = new \app\common\model\UserSoundcoinLog();
  1463. // 获取当天零点
  1464. $day = date("Ymd");
  1465. // 获取本周第一天
  1466. $weekday = $this->firstOfWeek(date("Y-m-d H:i:s"));
  1467. // 获取本月第一天
  1468. $monthday = date("Ym01");
  1469. $allVal = 0;
  1470. $i = 0;
  1471. foreach($user_id_arr as $user_id) {
  1472. // 获取赠送用户信息
  1473. $where = [];
  1474. $where["id"] = $user_id;
  1475. $touserInfo = $userModel->where($where)->find();
  1476. if($is_back == 1) {
  1477. $b=0;
  1478. foreach($giftList as $k => $v) {
  1479. for($a=1;$a<=$v["number"];$a++) {
  1480. $b++;
  1481. $num = $v["number"] - $a;
  1482. if($num > 0) {
  1483. $res1 = \app\common\model\GiftBack::where(["id"=>$v["id"]])->setDec("number");
  1484. } else {
  1485. $res1 = \app\common\model\GiftBack::update(["is_use"=>1,"use_time"=>time()],["id"=>$v["id"]]);
  1486. }
  1487. if($b == $number) break;
  1488. }
  1489. }
  1490. $res2 = true;
  1491. } else {
  1492. $res1 = true;
  1493. $res2 = true;
  1494. // 扣除当前用户钻石余额
  1495. $rs_wallet = model('wallet')->lockChangeAccountRemain($userauthid, $giftValue, '-', $userInfo["jewel"], "赠送礼物:'" . $giftInfo["name"] . "',扣除" . $giftValue . "钻石!", 3,'jewel');
  1496. if($rs_wallet['status'] == false){
  1497. $this->error($rs_wallet['msg']);
  1498. Db::rollback();
  1499. }
  1500. }
  1501. $giftuserpartyModel = new \app\common\model\GiftUserParty();
  1502. // 添加礼物赠送记录表
  1503. $data = [];
  1504. $data["user_id"] = $userauthid;
  1505. $data["user_to_id"] = $user_id;
  1506. $data["party_id"] = $party_id;
  1507. if($boxgiftInfo){
  1508. $data["gift_id"] = $boxgiftInfo['gift_id'];
  1509. $data["gift_give_type"] = 2;
  1510. $data["gift_name"] = $boxgiftInfo["gift_name"];
  1511. $data["gift_gif_image"] = $boxgiftInfo["image"];
  1512. $data["number"] = $number;
  1513. $data["price"] = $boxgiftInfo["price"];
  1514. $data["value"] = $boxgiftInfo["price"] * $number;
  1515. }else{
  1516. $data["gift_id"] = $backGiftId > 0 ? $backGiftId : $gift_id;
  1517. $data["gift_give_type"] = $is_back ? 1 : 2;
  1518. $data["gift_name"] = $giftInfo["name"];
  1519. $data["gift_gif_image"] = $giftInfo["image"];
  1520. $data["number"] = $number;
  1521. $data["price"] = $giftInfo["value"];
  1522. $data["value"] = $giftValue;
  1523. }
  1524. //每个礼物都要计算平台抽成和房主抽成
  1525. $data['platvalue'] = bcmul($platRate/100,$data["value"],2);
  1526. $data['guildervalue'] = bcmul($guilderRate/100,$data["value"],2);
  1527. $data['guildermoney'] = bcdiv($data['guildervalue'],$money_to_jewel,2);
  1528. $data["createtime"] = time();
  1529. $res5 = $giftuserpartyModel->allowField(true)->save($data);
  1530. $this->bigGiftNotice($giftuserpartyModel);
  1531. // 添加赠送用户余额
  1532. if($getValue > 0){
  1533. $getMoney = bcdiv($getValue,$money_to_jewel,2);
  1534. if($getMoney > 0){
  1535. $rs_wallet = model('wallet')->lockChangeAccountRemain($user_id,$getMoney,'+',0,"{$this->auth->nickname}送你{$giftInfo['name']}x{$number}",101,'money');
  1536. if($rs_wallet['status'] == false){
  1537. $this->error($rs_wallet['msg']);
  1538. Db::rollback();
  1539. }
  1540. }
  1541. }
  1542. // 增加房主抽成
  1543. if ($partyInfo && $guilderValue > 0) {
  1544. $guilderMoney = bcdiv($guilderValue,$money_to_jewel,2);
  1545. if($guilderMoney > 0){
  1546. $rs_wallet = model('wallet')->lockChangeAccountRemain($partyInfo->user_id,$guilderMoney,'+',0,"{$this->auth->nickname}送礼物{$giftInfo['name']}x{$number}给{$touserInfo['nickname']},房间礼物抽成",102,'money');
  1547. if($rs_wallet['status'] == false){
  1548. $this->error($rs_wallet['msg']);
  1549. Db::rollback();
  1550. }
  1551. }
  1552. }
  1553. if ($res1 && $res2 && $res5) {
  1554. $i++;
  1555. if($party_id > 0) {
  1556. // 添加redis记录做财富排行榜日榜用
  1557. $redis->zIncrBy($this->roomTypeArr[$room_type] . "_jewel_get_" . $party_id . ":" . $day . "d", $hotValue, $user_id);
  1558. // 添加redis记录做财富排行榜周榜用
  1559. $redis->zIncrBy($this->roomTypeArr[$room_type] . "_jewel_get_" . $party_id . ":" . $weekday . "w", $hotValue, $user_id);
  1560. // 添加redis记录做财富排行榜月榜用
  1561. $redis->zIncrBy($this->roomTypeArr[$room_type] . "_jewel_get_" . $party_id . ":" . $monthday . "m", $hotValue, $user_id);
  1562. // 添加redis记录做贡献排行榜日榜用
  1563. $redis->zIncrBy($this->roomTypeArr[$room_type] . "_jewel_to_" . $party_id . ":" . $day . "d", $giftValue, $userauthid);
  1564. // 添加redis记录做贡献排行榜周榜用
  1565. $redis->zIncrBy($this->roomTypeArr[$room_type] . "_jewel_to_" . $party_id . ":" . $weekday . "w", $giftValue, $userauthid);
  1566. // 添加redis记录做贡献排行榜月榜用
  1567. $redis->zIncrBy($this->roomTypeArr[$room_type] . "_jewel_to_" . $party_id . ":" . $monthday . "m", $giftValue, $userauthid);
  1568. // tcp 更新用户魅力值
  1569. $this->updateUserCharm($party_id, $user_id, $hotValue);
  1570. // 如果是主播,则添加魅力值记录做榜单统计
  1571. if($room_type == 2) {
  1572. $data = [];
  1573. $data["user_id"] = $user_id;
  1574. $data["party_id"] = $party_id;
  1575. $data["charm"] = $hotValue;
  1576. $data["createtime"] = time();
  1577. \app\common\model\UserCharmRank::insert($data);
  1578. }
  1579. }
  1580. $getempirical = config("site.getempirical");
  1581. $getempirical = $getempirical * $hotValue;
  1582. // 获取用户贵族信息
  1583. $noble = \app\common\model\User::getUserNoble($this->auth->id);
  1584. if(isset($noble["noble_on"]) && $noble["noble_on"] == 1) {
  1585. $getempirical = $getempirical + $getempirical * ($noble["explain"]/100);
  1586. }
  1587. // 增加用户经验值
  1588. $res = \app\common\model\User::addEmpirical($this->auth->id,$getempirical);
  1589. if ($res){
  1590. $this->auth->level = $res->level;
  1591. }
  1592. // +exp
  1593. \app\common\model\TaskLog::tofinish($this->auth->id,"OBHqCX4g",$number);
  1594. //贵族升级处理
  1595. //$this->checkBeNoble($redis,$this->auth->id,$giftCountValue);
  1596. // +message
  1597. \app\common\model\Message::addMessage($user_id,"礼物通知","收到 ".$this->auth->nickname." 赠送的".$giftInfo["name"]." x".$number." 价值 ".$giftValue ." 钻石");
  1598. $allVal = $allVal + $hotValue;
  1599. // // 剪掉背包礼物
  1600. // if($is_back == 1) {
  1601. // \app\common\model\GiftBack::update(["is_use"=>1],["id"=>$gift_id]);
  1602. // }
  1603. }
  1604. }
  1605. // 获取用户魅力值
  1606. $users = $redis->zRange("hourCharm_".$party_id,0,-1,true);
  1607. $u = [];
  1608. if($users) {
  1609. foreach($users as $k => $v) $u[] = [
  1610. "user_id"=>$k,
  1611. "charm"=>$this->changeW($v)
  1612. ];
  1613. }
  1614. $userCharm = $u;
  1615. // tcp 更新房间热度
  1616. $partyHot = $this->updatePartyHot($party_id, $allVal, $room_type);
  1617. // 如果是派对,则添加派对热度值记录做榜单统计
  1618. if($room_type == 1) {
  1619. $data = [];
  1620. $data["party_id"] = $party_id;
  1621. $data["hot"] = $allVal;
  1622. $data["createtime"] = time();
  1623. \app\common\model\PartyHot::insert($data);
  1624. }
  1625. // tcp 获取房间用户周前三名
  1626. $partyUserTop = $this->getPartyUserTop($party_id, $room_type);
  1627. if($i == $userCount) {
  1628. $returnData["userCharm"] = $userCharm;
  1629. $returnData["partyHot"] = $this->changeW($partyHot);
  1630. $returnData["partyUserTop"] = $partyUserTop;
  1631. if($is_back != 1) {
  1632. if($giftInfo->box_type > 0) { // 不是背包,宝箱中赠送
  1633. $returnData["box_type"] = $giftInfo->box_type;
  1634. $returnData["box_image"] = $giftInfo->image;
  1635. $returnData["image"] = $boxgiftInfo["image"];
  1636. $returnData["name"] = $boxgiftInfo["gift_name"];
  1637. $returnData["gif_image"] = $boxgiftInfo["special"];
  1638. } else {
  1639. $returnData["image"] = $giftInfo["image"];
  1640. $returnData["gif_image"] = $giftInfo["special"];
  1641. }
  1642. } else {
  1643. $returnData["image"] = $giftInfo["image"];
  1644. $returnData["gif_image"] = $giftInfo["gif_image"];
  1645. }
  1646. // 增加抽点记录
  1647. $data = [];
  1648. $data["user_id"] = $user_ids;
  1649. $data["party_id"] = $party_id?$party_id:0;
  1650. $data["gift_value"] = $giftValue;
  1651. $data["plat_value"] = $platValue;
  1652. $data["guilder_value"] = $guilderValue;
  1653. $data["createtime"] = time();
  1654. \app\common\model\UserProfitLog::insert($data);
  1655. Db::commit();
  1656. $this->success("赠送成功!",$returnData);
  1657. } else {
  1658. $this->success("赠送失败!");
  1659. }
  1660. } catch (ValidateException $e) {
  1661. Db::rollback();
  1662. $this->error($e->getMessage());
  1663. } catch (PDOException $e) {
  1664. Db::rollback();
  1665. $this->error($e->getMessage());
  1666. } catch (Exception $e) {
  1667. Db::rollback();
  1668. $this->error($e->getMessage());
  1669. }
  1670. }
  1671. //送礼完成之后,大礼物飘屏
  1672. private function bigGiftNotice($giftUserParty){
  1673. if ($giftUserParty->party_id > 0) {
  1674. $is_big = Db::name('gift')->where('id',$giftUserParty->gift_id)->value('is_big');
  1675. if ($is_big == 1) {
  1676. $partyInfo = $giftUserParty->party;
  1677. $notice = new GatewayworkerTools();
  1678. $notice->sendBigGiftInParty($giftUserParty->user->nickname,$giftUserParty->toUser->nickname,$partyInfo,$giftUserParty);
  1679. }
  1680. }
  1681. }
  1682. //某房间内礼物列表
  1683. public function getPartyGiftLog(){
  1684. $party_id = input('party_id',0);
  1685. $list = Db::name('gift_user_party')->alias('log')->field('log.gift_name,log.gift_gif_image,log.number,log.value,log.guildermoney,log.createtime,user.nickname as give_nickname,b.nickname as get_nickname')
  1686. ->join('user','log.user_id = user.id','LEFT')
  1687. ->join('user b','log.user_to_id = b.id','LEFT')
  1688. ->where('log.party_id',$party_id)->order('log.id desc')->autopage()->select();
  1689. $list = list_domain_image($list,['gift_gif_image']);
  1690. foreach($list as $key => &$val){
  1691. $val['createtime'] = get_last_time($val['createtime']);
  1692. }
  1693. $this->success('success',$list);
  1694. }
  1695. // /**
  1696. // * 播放动效
  1697. // */
  1698. // public function play($party_id,$type,$value,$number) {
  1699. // // 发送tcp
  1700. // $tcpArr = [];
  1701. // $tcpArr['type'] = "play";
  1702. // $tcpArr['data'] = [
  1703. // 'party_id' => $party_id,
  1704. // 'type' => $type,
  1705. // 'value' => $value,
  1706. // 'number' => $number,
  1707. // ];
  1708. // $tcpJson = json_encode($tcpArr);
  1709. // $client = stream_socket_client(config("tcp"));
  1710. // $buffer2 = base64_encode($tcpJson)."****";
  1711. // fwrite($client, $buffer2);
  1712. // }
  1713. /**
  1714. * 更新派对信息(热度等)
  1715. */
  1716. private function updatePartyHot($party_id,$hotValue,$room_type) {
  1717. $partyInfo = \app\common\model\Party::where(['id'=>$party_id])->find();
  1718. if(!$partyInfo) return $hotValue;
  1719. $party_hot = $partyInfo->party_hot > 0 ? $partyInfo->party_hot:0;
  1720. $party_hot_value = $party_hot + $hotValue;
  1721. $party_hot_value = $party_hot_value > 0 ? $party_hot_value : 0;
  1722. if($party_hot_value != $party_hot) {
  1723. // 保存数据
  1724. $partyInfo->party_hot = $party_hot_value;
  1725. $partyInfo->save();
  1726. // 更新redis 加入缓存排序
  1727. $redis = new Redis();
  1728. $redisconfig = config("redis");
  1729. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  1730. if ($redisconfig['redis_pwd']) {
  1731. $redis->auth($redisconfig['redis_pwd']);
  1732. }
  1733. if($redisconfig['redis_selectdb'] > 0){
  1734. $redis->select($redisconfig['redis_selectdb']);
  1735. }
  1736. $redis->zAdd($this->roomTypeArr[$room_type]."Rank", $partyInfo['party_hot'], $partyInfo["id"]);
  1737. // 更新redis 加入缓存
  1738. $redPartyInfo = $redis->get($this->roomTypeArr[$room_type]."_".$partyInfo["id"]);
  1739. if($redPartyInfo) {
  1740. $redPartyInfo = json_decode($redPartyInfo,true);
  1741. $redPartyInfo["party_hot"] = $party_hot_value;
  1742. $redis->set($this->roomTypeArr[$room_type]."_".$partyInfo["id"],json_encode($redPartyInfo));
  1743. }
  1744. // // 发送tcp
  1745. // $tcpArr = [];
  1746. // $tcpArr['type'] = "changeRoomHot";
  1747. // $tcpArr['data'] = [
  1748. // 'room_id' => $party_id,
  1749. // 'value' => $party_hot_value,
  1750. // ];
  1751. // $tcpJson = json_encode($tcpArr);
  1752. // $client = stream_socket_client(config("tcp"));
  1753. // $buffer2 = base64_encode($tcpJson)."****";
  1754. // fwrite($client, $buffer2);
  1755. }
  1756. return $party_hot_value;
  1757. }
  1758. /**
  1759. * 用户赠送礼物后房间内用户排行,贡献榜前三名
  1760. */
  1761. private function getPartyUserTop($party_id,$room_type) {
  1762. $redis = new Redis();
  1763. $redisconfig = config("redis");
  1764. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  1765. if ($redisconfig['redis_pwd']) {
  1766. $redis->auth($redisconfig['redis_pwd']);
  1767. }
  1768. if($redisconfig['redis_selectdb'] > 0){
  1769. $redis->select($redisconfig['redis_selectdb']);
  1770. }
  1771. // 获取本周第一天
  1772. $weekday = $this->firstOfWeek(date("Y-m-d H:i:s"));
  1773. // 获取当天零点
  1774. $day = date("Ymd");
  1775. $userModel = new \app\common\model\User();
  1776. // 获取条数
  1777. $num = 3;
  1778. // 获取3条财富排行周记录
  1779. $getweek = $redis->zRevRange($this->roomTypeArr[$room_type]."_jewel_to_".$party_id.":".$day."d",0,$num-1,true);
  1780. $userList = $userModel->rankList($getweek);
  1781. $avatarArr = [];
  1782. if($userList) {
  1783. foreach($userList as $k => $v) {
  1784. $v["jewel"] > 0 && $avatarArr[] = $v["avatar"];
  1785. }
  1786. // 加入缓存做备份
  1787. $redis->hSet("user_jewel_top3",$party_id,json_encode($avatarArr));
  1788. // // 发送tcp
  1789. // $tcpArr = [];
  1790. // $tcpArr['type'] = "changeRoomUserTop";
  1791. // $tcpArr['data'] = [
  1792. // 'room_id' => $party_id,
  1793. // 'user_avatar' => $avatarArr,
  1794. // ];
  1795. // $tcpJson = json_encode($tcpArr);
  1796. // $client = stream_socket_client(config("tcp"));
  1797. // $buffer2 = base64_encode($tcpJson)."****";
  1798. // fwrite($client, $buffer2);
  1799. }
  1800. return $avatarArr;
  1801. }
  1802. /**
  1803. * 用户赠送礼物后房间内用户魅力值增加
  1804. */
  1805. private function updateUserCharm($party_id,$user_id,$giftValue) {
  1806. $redis = new Redis();
  1807. $redisconfig = config("redis");
  1808. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  1809. if ($redisconfig['redis_pwd']) {
  1810. $redis->auth($redisconfig['redis_pwd']);
  1811. }
  1812. if($redisconfig['redis_selectdb'] > 0){
  1813. $redis->select($redisconfig['redis_selectdb']);
  1814. }
  1815. // 获取用户魅力值
  1816. $users = $redis->zRange("hourCharm_".$party_id,0,-1,true);
  1817. if(!$users) $users[$user_id] = 0;
  1818. if(isset($users[$user_id])) {
  1819. $value = $users[$user_id] + $giftValue;
  1820. } else {
  1821. $value = $giftValue;
  1822. }
  1823. $redis->zAdd("hourCharm_".$party_id,$value,$user_id);
  1824. return true;
  1825. }
  1826. /**
  1827. * 单个房间魅力值清零
  1828. */
  1829. public function partyClearCharm() {
  1830. $party_id = $this->request->request("party_id");// 派对ID
  1831. $userId = $this->request->request("user_id", 0);// 用户ID
  1832. if($party_id <= 0) {
  1833. $this->error("请输入派对ID");
  1834. }
  1835. $redis = new Redis();
  1836. $redisconfig = config("redis");
  1837. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  1838. if ($redisconfig['redis_pwd']) {
  1839. $redis->auth($redisconfig['redis_pwd']);
  1840. }
  1841. if($redisconfig['redis_selectdb'] > 0){
  1842. $redis->select($redisconfig['redis_selectdb']);
  1843. }
  1844. if ($userId) {
  1845. $redis->zRem("hourCharm_" . $party_id, $userId);
  1846. } else {
  1847. $redis->del("hourCharm_" . $party_id);
  1848. }
  1849. $this->success("操作成功!");
  1850. }
  1851. /**
  1852. * 获取音乐列表
  1853. */
  1854. public function getMusicList() {
  1855. $this->success("获取成功!",\app\common\model\Music::select());
  1856. }
  1857. //============================定时任务==========================//
  1858. /**
  1859. * redis清理排行榜 并数据库备份
  1860. */
  1861. public function updateTops() {
  1862. // 前一天日期
  1863. $yestaday = date("Ymd",bcsub(time(),86400));
  1864. // 上个周一
  1865. $preweek = $this->firstOfWeek(date("Y-m-d H:i:s",bcsub(time(),604800)));
  1866. // 上个月一号
  1867. $monty = bcsub(date("m"),1);
  1868. if($monty < 10) $monty = "0".$monty;
  1869. $premonth = date("Y").$monty."01";
  1870. $redis = new Redis();
  1871. $redisconfig = config("redis");
  1872. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  1873. if ($redisconfig['redis_pwd']) {
  1874. $redis->auth($redisconfig['redis_pwd']);
  1875. }
  1876. if($redisconfig['redis_selectdb'] > 0){
  1877. $redis->select($redisconfig['redis_selectdb']);
  1878. }
  1879. // 获取所有派对ID
  1880. $party_ids = \app\common\model\Party::where(["status"=>1])->column("id");
  1881. // 获取数据
  1882. $time = time();
  1883. if($party_ids) foreach($party_ids as $k => $v) {
  1884. $keys = [
  1885. "party_jewel_get_".$v.":".$yestaday."d",
  1886. "party_jewel_to_".$v.":".$yestaday."d",
  1887. "party_jewel_get_".$v.":".$preweek."w",
  1888. "party_jewel_to_".$v.":".$preweek."w",
  1889. "party_jewel_get_".$v.":".$premonth."m",
  1890. "party_jewel_to_".$v.":".$premonth."m",
  1891. ];
  1892. foreach($keys as $key) {
  1893. // 备份数据
  1894. $redisData = $redis->zRevRange($key,0,-1,true);
  1895. if($redisData) {
  1896. $keyInfo = \app\common\model\RedisTops::where(["key"=>$key])->find();
  1897. $data = ["party_id"=>$v,"key"=>$key,"value"=>json_encode($redisData),"createtime" => $time];
  1898. if(!$keyInfo) {
  1899. $res = \app\common\model\RedisTops::insert($data);
  1900. // 清理数据
  1901. $res && $redis->zRemRangeByRank($key,0,-1);
  1902. }
  1903. }
  1904. }
  1905. }
  1906. }
  1907. public function handleParty() {
  1908. return false;
  1909. $partyList = \app\common\model\Party::where('is_online',1)->select();
  1910. $redis = new Redis();
  1911. $redisconfig = config("redis");
  1912. $redis->connect($redisconfig["host"], $redisconfig["port"]);
  1913. if ($redisconfig['redis_pwd']) {
  1914. $redis->auth($redisconfig['redis_pwd']);
  1915. }
  1916. if($redisconfig['redis_selectdb'] > 0){
  1917. $redis->select($redisconfig['redis_selectdb']);
  1918. }
  1919. // $redis->del("online_" . 3);die;
  1920. // $redis->hSet("online_" . 3, 4, 4);die;
  1921. foreach ($partyList as $party){
  1922. $userId = $party['user_id'];
  1923. $roomId = $party['id'];
  1924. $redis->HDel("online_" . $roomId, $userId);
  1925. // 扣除在线用户在房间情况
  1926. $redis->hDel("livingUser",$userId);
  1927. // // 更新房间在线状态
  1928. $partyInfo = $redis->get("party_" . $roomId);
  1929. if ($partyInfo) {
  1930. $partyInfo = json_decode($partyInfo, true);
  1931. $memCount = count($redis->hGetAll("online_" . $roomId));
  1932. if ($memCount <= 0) {
  1933. dump($roomId.'--1---');
  1934. $partyInfo["is_online"] = 0;
  1935. $redis->set("party_" . $roomId, json_encode($partyInfo));
  1936. \app\common\model\Party::update(["is_online" => 0], ["id" => $roomId]);
  1937. }
  1938. }
  1939. $liveInfo = $redis->get("live_" . $roomId);
  1940. if ($liveInfo) {
  1941. $liveInfo = json_decode($liveInfo, true);
  1942. $memCount = count($redis->hGetAll("online_" . $roomId));
  1943. if ($memCount <= 0) {
  1944. dump($roomId.'---2--');
  1945. $liveInfo["is_online"] = 0;
  1946. $redis->set("live_" . $roomId, json_encode($liveInfo));
  1947. \app\common\model\Party::update(["is_online" => 0], ["id" => $roomId]);
  1948. }else{
  1949. dump($roomId.'---3--');
  1950. $redis->del("online_" . $roomId);
  1951. $liveInfo["is_online"] = 0;
  1952. $redis->set("live_" . $roomId, json_encode($liveInfo));
  1953. \app\common\model\Party::update(["is_online" => 0], ["id" => $roomId]);
  1954. }
  1955. }
  1956. }
  1957. $this->success("获取成功!");
  1958. }
  1959. }