create_bargain($params); } elseif($type == proto_type::sroom_chat) { return $this->create_chat($params,$fnew); } elseif($type == proto_type::sroom_shake_bonus) { return $this->create_shake_bonus($params); } else { return false; } } public function build($room_id) { $mod_room = Model('room'); $room_params = $mod_room->getRoom($room_id); if(empty($room_params)) return false; $participants = self::participants($room_id); $rinfo = new room_info($room_params); if($rinfo->type() == proto_type::room_bargain) { return new bargain_room($room_params,$participants); } elseif ($rinfo->type() == proto_type::room_chat) { return new chat_room($room_params,$participants); } elseif($rinfo->type() == proto_type::room_shake_bonus) { return new shake_room($room_params,$participants); } else { return false; } } //////////////////////////////////////////////////////////////////////////////////////////////////////////////////// private function create_bargain($params) { $creator = intval($params['creator']); $good_id = intval($params['goods_id']); $usable_days = intval($params['usable_days']); $lowest_price = $params['lowest_price']; $type = $params['random']; $total_num = $params['total_num']; if($creator <= 0 || $good_id <= 0) return false; $mod_bargain = Model('room_bargain'); $ret = $mod_bargain->getBargainByUserGoods($creator,$good_id,true); if(!empty($ret)) { $bargain = new bargain($ret); return ['bargain_id' => $bargain->bargain_id(),'room' => $bargain->room(),'creator' => $bargain->creator()]; } $minfo = new member_info($creator); $room_id = $this->create_room(proto_type::room_bargain,"bargain",$minfo); if($room_id === false) return false; $helper = new goods_helper(new bonus\account($creator,false)); $summarys = $helper->summary([$good_id],$related_goods); if(empty($summarys) || empty($summarys['summary'])) return false; $summary = $summarys['summary'][0]; $bargain_id = $mod_bargain->create($room_id,$creator,$good_id,$summary['goods_price'],$lowest_price,$usable_days,$type,$total_num); if($bargain_id > 0) { QueueClient::async_push('onAsyncBargain',['type' => "close", 'bargain_id' => $bargain_id],$usable_days * 86400); } return ['bargain_id' => $bargain_id,'room' => $room_id,'creator' => $creator]; } private function create_chat($params,&$fnew) { try { $fnew = false; $user = intval($params['creator']); if($user <= 0) return false; $creator = new member_info($user); $room_type = proto_type::room_chat; $room_id = $this->create_room($room_type,'',$creator); $fnew = true; return ['room' => $room_id,'creator' => $user]; } catch (Exception $ex) { Log::record(__METHOD__ . " {$ex->getMessage()}",Log::ERR); return false; } } private function create_shake_bonus($params) { try { $user = intval($params['creator']); if($user <= 0) return false; $mod_room = Model('room'); $room = $mod_room->getRoomByType(proto_type::room_shake_bonus,$user); if(empty($room)) { $creator = new member_info($user); $room_type = proto_type::room_shake_bonus; $room_id = $this->create_room($room_type,'shake_bonus',$creator); } else { $room_id = intval($room['room_id']); } return ['room' => $room_id,'creator' => $user]; } catch (Exception $ex) { Log::record(__METHOD__ . " {$ex->getMessage()}",Log::ERR); return false; } } private function create_room($room_type,$name,member_info $creator) { $mod_room = Model('room'); $ret = $mod_room->create_room($room_type,$name,$creator->member_id(),$creator->member_id(),$creator->nickname()); return $ret; } public static function participants($roomid) { $roomid = intval($roomid); if($roomid <= 0) return false; $mod_room = Model('room'); $items = $mod_room->participants($roomid); $uids = []; $member_nick = []; foreach ($items as $item) { $uid = intval($item['member_id']); $uids[] = $uid; $member_nick[$uid] = $item['member_nick']; } $uids = array_unique($uids,SORT_NUMERIC); if(!empty($uids)) { $members = Model('member')->getMemberList(['member_id' => ['in',$uids]]); } else { $members = []; } $uid_infos = []; foreach ($members as $member) { $uinfo = new member_info($member); $user = $uinfo->member_id(); $nickname = empty($member_nick[$user]) ? $uinfo->nickname() : $member_nick[$user]; $item = ['avatar' => $uinfo->avatar(),'nickname' => $nickname,'userid' => $uinfo->member_id()]; $uid_infos[$user] = $item; } $result = []; foreach ($items as $item) { $uid = intval($item['member_id']); if(array_key_exists($uid,$uid_infos)){ $result[$uid] = $uid_infos[$uid]; } } return $result; } }