field($this->allowFields)->where('id',$uid)->find(); if(!$userinfo){ $this->error('不存在的用户'); } if($uid != $this->auth->id){ $user_remark = Db::name('user_remark')->where('to_user_id',$uid)->where('user_id',$this->auth->id)->find(); $userinfo['nickname'] = !empty($user_remark['nickname_remark']) ? $user_remark['nickname_remark'] : $userinfo['nickname']; } //用户数据 $userinfo = info_domain_image($userinfo,['avatar','photo_images']); $new_data = [ 'age' => birthtime_to_age($userinfo['birthday']), ]; if ($this->auth->gender == 1) { $qinmi_sum = Db::name('user_intimacy')->where(['uid' => $this->auth->id, 'other_uid' => $uid])->value('value'); } elseif ($this->auth->gender == 0) { $qinmi_sum = Db::name('user_intimacy')->where(['uid' => $uid, 'other_uid' => $this->auth->id])->value('value'); } else { $qinmi_sum = 0; } $new_data['qinmi_sum'] = $qinmi_sum ? :0; //合并 $userinfo = array_merge($userinfo,$new_data); //枚举 //家乡 $userinfo['hometown_city'] = Db::name('area')->where('id',$userinfo['hometown_cityid'])->value('name'); $userinfo['hometown_city'] = ($userinfo['hometown_city'] && $userinfo['is_hideaddress'] == 0) ? $userinfo['hometown_city'] : ''; //vip $userwallet = Db::name('user_wallet')->where('user_id',$uid)->find(); $userinfo['is_vip'] = $this->is_vip($userwallet['vip_endtime'],$userwallet['vip_level']); //是否喜欢和关注 $is_follow = Db::name('user_follow')->where(['uid'=>$this->auth->id,'follow_uid'=>$uid])->find(); $userinfo['is_follow'] = $is_follow ? 1 : 0; /*$is_like = Db::name('user_like')->where(['uid'=>$this->auth->id,'like_uid'=>$uid])->find(); $userinfo['is_like'] = $is_like ? 1 : 0;*/ //是否拉黑 $is_black = Db::name('user_black')->where(['uid'=>$this->auth->id,'black_uid'=>$uid])->find(); $userinfo['is_black'] = $is_black ? 1 : 0; //关注人数,粉丝人数 $follow_num = Db::name('user_follow')->where(['uid'=>$uid])->count('id'); $fans_num = Db::name('user_follow')->where(['follow_uid'=>$uid])->count('id'); $userinfo['follow_num'] = $follow_num; $userinfo['fans_num'] = $fans_num; //访客数 $visit_num = Db::name('user_visit')->where(['to_uid'=>$uid])->count('id'); $userinfo['visit_num'] = $visit_num; //查询是否打过招呼 $count = Db::name('user_greet')->where(['user_id' => $this->auth->id, 'user_to_id' => $uid])->count('id'); if ($count) { $userinfo['is_chat'] = 1; //是否打过招呼: 1是 0否 } else { $userinfo['is_chat'] = 0; //是否打过招呼: 1是 0否 } //守护数量和是否已经守护 $userinfo['guard_num'] = Db::name('user_guard')->where(['user_to_id' => $uid])->count('id'); $userinfo['is_guard'] = Db::name('user_guard')->where(['user_id' => $this->auth->id, 'user_to_id' => $uid])->count('id'); //查询财富等级和魅力等级 $wallet_info = Db::name('user_wallet')->where(['user_id' => $uid])->find(); $wealth_level = Db::name('wealth_level')->where(['value' => ['elt', $wallet_info['pay_money']]])->order('id desc')->find(); if ($wealth_level) { $userinfo['wealth_level'] = localpath_to_netpath($wealth_level['image']); } else { $userinfo['wealth_level'] = ''; } $charm_level = Db::name('charm_level')->where(['value' => ['elt', $wallet_info['get_money']]])->order('id desc')->find(); if ($charm_level) { $userinfo['charm_level'] = localpath_to_netpath($charm_level['image']); } else { $userinfo['charm_level'] = ''; } //开通守护消耗金币数量 $userinfo['guard_price'] = config('site.guard_price') ? : 0; //男性非会员是否已开通聊天 // $vip_endtime = Db::name('user_wallet')->where('user_id',$this->auth->id)->value('vip_endtime'); // $user_chat_unlock = Db::name('user_chat_unlock')->where(['user_id' => $this->auth->id, 'user_to_id' => $uid])->count('id'); // if ($this->auth->gender == 0 || $vip_endtime > time() || $user_chat_unlock) { $userinfo['is_chat_unlock'] = 1; //已解锁 // } else { // $userinfo['is_chat_unlock'] = 0; // } //男性非会员解锁聊天所需金币数量 $userinfo['unlock_chat_gold'] = config('site.unlock_chat_gold') > 0 ? config('site.unlock_chat_gold') : 10; //动态信息 $dongtai = Db::name('topic_dongtai')->field('type, images')->where(['user_id' => $uid, 'is_hidden' => 0, 'type' => ['in', [1, 2]], 'status' => 0, 'auit_status' => 1])->order('id desc')->limit(3)->select(); if ($dongtai) { $dongtai_image = []; foreach ($dongtai as &$v) { $arr['type'] = $v['type']; if ($v['type'] == 1) { //图片 $images_url = explode(',', $v['images']); foreach ($images_url as &$value) { $arr['images'] = one_domain_image($value); array_push($dongtai_image, $arr); if (count($dongtai_image) == 4) { break 2; } } } else { //视频 $images_url = explode('.', $v['images']); unset($images_url[count($images_url) - 1]); $arr['images'] = join('.', $images_url) . '_0.jpg'; $arr['images'] = one_domain_image($arr['images']); array_push($dongtai_image, $arr); if (count($dongtai_image) == 4) { break; } } } $userinfo['dongtai_image'] = $dongtai_image; // $dongtai = join(',', $dongtai); // $dongtai = explode(',', $dongtai); // $dongtai = array_slice($dongtai, 0, 3); // $dongtai = join(',', $dongtai); // $userinfo['dongtai_image'] = one_domain_image($dongtai); // $userinfo['dongtai_image'] = explode(',', $userinfo['dongtai_image']); } else { $userinfo['dongtai_image'] = []; } if ($this->auth->id != $uid) { //查看别人信息,就要留下痕迹 $data = [ 'uid' => $this->auth->id, 'to_uid' => $uid, ]; $check = Db::name('user_visit')->where($data)->find(); if ($check) { Db::name('user_visit')->where($data)->update(['number' => $check['number'] + 1, 'updatetime' => time()]); } else { $data['number'] = 1; $data['updatetime'] = time(); Db::name('user_visit')->insertGetId($data); } } //礼物墙 $userinfo['gift_wall'] = $this->giftwall($uid); //动态数量 $userinfo['dongtai_num'] = Db::name('topic_dongtai')->where(['user_id' => $uid, 'is_hidden' => 0, 'type' => ['in', [1, 2]], 'status' => 0, 'auit_status' => 1])->count(); $this->success('success',$userinfo); } //某用户的礼物墙 private function giftwall($uid){ //$uid = $this->auth->id; //聊天礼物 $gift_user_typing = Db::name('gift_user_typing')->alias('log') ->join('gift', 'gift.id = log.gift_id', 'LEFT') ->field('log.gift_id,log.gift_name,sum(log.number) as number,gift.image') ->where(['log.user_to_id' => $uid]) ->group('log.gift_id') ->order('gift.price desc') ->column('log.gift_id,log.gift_name,sum(log.number) as number,gift.image'); $gift_user_typing = list_domain_image($gift_user_typing,['image']); //dump($gift_user_typing); //动态礼物 $gift_user_dongtai = Db::name('gift_user_dongtai')->alias('log') ->join('gift', 'gift.id = log.gift_id', 'LEFT') ->field('log.gift_id,log.gift_name,sum(log.number) as number,gift.image') ->where(['log.user_to_id' => $uid]) ->group('log.gift_id') ->order('gift.price desc') ->column('log.gift_id,log.gift_name,sum(log.number) as number,gift.image'); $gift_user_dongtai = list_domain_image($gift_user_dongtai,['image']); //dump($gift_user_dongtai); //为空 if(empty($gift_user_typing) && empty($gift_user_dongtai)){ return []; } if(empty($gift_user_typing) && !empty($gift_user_dongtai)){ foreach($gift_user_dongtai as $key => $val){ $result[] = $val; } return $result; } if(!empty($gift_user_typing) && empty($gift_user_dongtai)){ foreach($gift_user_typing as $key => $val){ $result[] = $val; } return $result; } //合并 foreach($gift_user_typing as $key => $val){ foreach($gift_user_dongtai as $k => $v){ if($key == $k){ $gift_user_typing[$key]['number'] += $v['number']; } if(!isset($gift_user_typing[$k])){ $gift_user_typing[$k] = $v; } } } //dump($gift_user_typing); //结果 $result = []; foreach($gift_user_typing as $key => $val){ $result[] = $val; } return $result; } //开通守护 public function addguard() { // 接口防并发 if (!$this->apiLimit(1, 1)) { $this->error(__('Operation frequently')); } $user_id = input('user_id', 0, 'intval');// 守护对象 if (!$user_id) { $this->error(); } // 不可以守护给自己 if($this->auth->id == $user_id) { $this->error("不可以守护自己"); } //查询是否开通守护 $count = Db::name('user_guard')->where(['user_id' => $this->auth->id, 'user_to_id' => $user_id])->count('id'); if ($count) { $this->error('已经开通守护了'); } $giftvalue = config('site.guard_price'); if ($giftvalue <= 0) { $this->error('守护金额异常~'); } //被守护人信息 $touserinfo = Db::name('user')->where('id',$user_id)->find(); if (!$touserinfo) { $this->error("不存在的用户"); } // 判断当前用户余额 $user_gold = model('wallet')->getWallet($this->auth->id,'gold'); if($user_gold < $giftvalue) { $this->error("您的金币不足"); } Db::startTrans(); // 添加礼物守护记录表 $data = [ 'user_id' => $this->auth->id, 'user_to_id' => $user_id, 'price' => $giftvalue, 'createtime' => time(), ]; $log_id = Db::name('user_guard')->insertGetId($data); if(!$log_id){ Db::rollback(); $this->error('守护失败'); } if($giftvalue > 0){ // 扣除当前用户余额 $wallet_rs = model('wallet')->lockChangeAccountRemain($this->auth->id,$user_id,'gold',-$giftvalue,81,'开通守护','user_guard',$log_id); if($wallet_rs['status'] === false){ Db::rollback(); $this->error($wallet_rs['msg']); } // 添加守护用户余额 $money_to_gold = config('site.money_to_gold'); $gift_plat_scale = config('site.gift_plat_scale'); $giftmoney = bcdiv($giftvalue,$money_to_gold,2); $money = bcdiv(bcmul($giftmoney,100 - $gift_plat_scale,2),100,2); $wallet_rs = model('wallet')->lockChangeAccountRemain($user_id,$this->auth->id,'money',$money,82,'被守护收益','user_guard',$log_id,2); if($wallet_rs['status'] === false){ Db::rollback(); $this->error($wallet_rs['msg']); } //增加赠送用户上级余额 if ($touserinfo['intro_uid']) { //获取返利比率 $agent_info = Db::name('user')->where(['id' => $touserinfo['intro_uid']])->field('is_agent,h_intro_income_rebate_rate')->find(); $intro_income_rebate_rate = ($agent_info['is_agent'] == 1) ? $agent_info['h_intro_income_rebate_rate'] : (int)config('site.intro_income_rebate_rate'); //邀请人收礼物返利比率 if ($intro_income_rebate_rate > 0 && $intro_income_rebate_rate <= 100) { //上级获得金额 $intro_uid_money = bcdiv(bcmul($money,$intro_income_rebate_rate,2),100,2); if ($intro_uid_money > 0) { $intro_result = model('Wallet')->lockChangeAccountRemain($touserinfo['intro_uid'],$user_id,'money',$intro_uid_money,68, '邀请人开通守护获赠奖励','user_guard',$log_id); if($intro_result['status']===false) { Db::rollback(); $this->error($intro_result['msg']); } } } } } //tag任务守护金币 //搭讪奖励 // $task_rs = \app\common\model\TaskLog::tofinish($this->auth->id,15); // if($task_rs === false){ // Db::rollback(); // $this->error('完成任务守护奖励失败'); // } Db::commit(); $this->success('守护成功'); } //守护列表 public function guardlist(){ $user_id = input('user_id', 0, 'intval'); if (!$user_id) { $this->error('您的网络开小差啦~'); } $list = Db::name('user_guard') ->alias('a') ->join('user','a.user_id = user.id','LEFT') ->join('user_remark ur', 'ur.to_user_id = user.id and ur.user_id = '.$this->auth->id, 'LEFT') ->field('a.createtime,user.id,user.nickname,user.avatar,user.real_status,ur.nickname_remark') ->where('a.user_to_id',$user_id)->order('a.id desc')->autopage()->select(); if (!$list) { $this->success('success', $list); } $list = list_domain_image($list,['avatar']); $time = time(); foreach ($list as &$val) { $val['createtime'] = ceil(($time - $val['createtime']) / 86400); $val['nickname'] = !empty($val['nickname_remark']) ? $val['nickname_remark'] : $val['nickname']; } $this->success('success',$list); } //我的守护 public function myguardlist(){ $type = input('type', 0, 'intval'); //类型: 1我守护的 2守护我的 if (!in_array($type, [1, 2])) { $this->error('您的网络开小差了'); } $where = []; if ($type == 1) { $join = 'a.user_to_id = user.id'; $where['a.user_id'] = $this->auth->id; } else { $join = 'a.user_id = user.id'; $where['a.user_to_id'] = $this->auth->id; } $list = Db::name('user_guard') ->alias('a') ->join('user',$join,'LEFT') ->join('user_remark ur', 'ur.to_user_id = user.id and ur.user_id = '.$this->auth->id, 'LEFT') ->field('a.createtime,user.id,user.nickname,user.avatar,user.real_status,ur.nickname_remark') ->where($where)->order('a.id desc')->autopage()->select(); if (!$list) { $this->success('success', $list); } $list = list_domain_image($list,['avatar']); $time = time(); foreach ($list as &$val) { $val['createtime'] = ceil(($time - $val['createtime']) / 86400); $val['nickname'] = !empty($val['nickname_remark']) ? $val['nickname_remark'] : $val['nickname']; } $this->success('success',$list); } //打字聊天每句话调用一次 public function chat_once(){ if ($this->auth->is_kefu == 1) { //我是客服或者对方是客服 $this->success('success',['money' => 'free']); } if ($this->auth->gender == 0) { //女生不花钱 $this->error('您的网络开小差啦~'); } //检测用户 $to_user_id = input_post('to_user_id'); $to_user_info = Db::name('user')->field('id,intro_uid,real_status,gender,free_video,free_audio,free_typing,chat_price,is_kefu')->where('id',$to_user_id)->find(); if(!$to_user_info){ $this->error('不存在的用户'); } if ($to_user_info['is_kefu'] == 1) { //我是客服或者对方是客服 $this->success('success',['money' => 'free']); } if ($to_user_info['gender'] != 0) { $this->error('同性不能聊天~'); } //验证金额 $wallet_info = Db::name('user_wallet')->where('user_id',$this->auth->id)->find(); $is_vip = $this->is_vip($wallet_info['vip_endtime'],$wallet_info['vip_level']); if ($is_vip != 0) { //会员 $price = $to_user_info['chat_price'];//config('site.typing_min_price'); //扣费金币 //获取折扣 $vip_chat_discount = config('site.vip_chat_discount'); if ($vip_chat_discount >= 0 && $vip_chat_discount <= 10) { $price = bcdiv(bcmul($price,$vip_chat_discount,2),10,0); } } else { $price = $to_user_info['chat_price'];//config('site.typing_min_price'); //扣费金币 } //正常价格 $bili = config('site.money_to_gold'); //兑换比例 $gift_plat_scale = config('site.gift_plat_scale'); //抽成比例 $money = bcdiv($price,$bili,2); //对应人民币 $money = bcdiv(bcmul($money,100 - $gift_plat_scale,2),100,2); //抽成后收益 $resArray['money'] = $money; //返回给前端的计算结果 Db::startTrans(); //记录日志 $data = [ 'user_id' => $this->auth->id, 'price' => $price, 'createtime' => time(), 'to_user_id' => $to_user_id, 'money' => $money, ]; $log_id = Db::name('user_match_typing_log')->insertGetId($data); if(!$log_id){ Db::rollback(); $this->error('扣费失败'); } //有性别差,扣费 if($price > 0){ $rs = model('wallet')->lockChangeAccountRemain($this->auth->id,$to_user_id,'gold',-$price,13,'文字聊天消费','user_match_typing_log',$log_id); if($rs['status'] === false){ Db::rollback(); $this->error($rs['msg']); } } //另一方加钱,0收费 if($money > 0){ $rs = model('wallet')->lockChangeAccountRemain($to_user_id,$this->auth->id,'money',$money,23,'文字聊天收益','user_match_typing_log',$log_id,2); if($rs['status'] === false){ Db::rollback(); $this->error($rs['msg']); } $touserinfo = $to_user_info; //增加赠送用户上级余额 if ($touserinfo['intro_uid']) { //获取返利比率 $agent_info = Db::name('user')->where(['id' => $touserinfo['intro_uid']])->field('is_agent,h_intro_income_rebate_rate')->find(); $intro_income_rebate_rate = ($agent_info['is_agent'] == 1) ? $agent_info['h_intro_income_rebate_rate'] : (int)config('site.intro_income_rebate_rate'); //邀请人收礼物返利比率 if ($intro_income_rebate_rate > 0 && $intro_income_rebate_rate <= 100) { //上级获得金额 $intro_uid_money = bcdiv(bcmul($money,$intro_income_rebate_rate,2),100,2); if ($intro_uid_money > 0) { $intro_result = model('Wallet')->lockChangeAccountRemain($touserinfo['intro_uid'],$to_user_id,'money',$intro_uid_money,68, '邀请人文字聊天获赠奖励','user_match_typing_log',$log_id); if($intro_result['status']===false) { Db::rollback(); $this->error($intro_result['msg']); } } } } } //增加亲密度 $user_intimacy_rs = addintimacy($this->auth->id, $to_user_id, $price); if (!$user_intimacy_rs['status']) { Db::rollback(); $this->error('您的网络开小差啦~'); } //tag任务赠送金币 //私信5名异性奖励 $task_rs = \app\common\model\TaskLog::tofinish($this->auth->id,23); if($task_rs === false){ Db::rollback(); $this->error('完成任务赠送奖励失败'); } $task_rs = \app\common\model\TaskLog::tofinish($to_user_id,23); if($task_rs === false){ Db::rollback(); $this->error('完成任务赠送奖励失败'); } Db::commit(); //发送消息 if (isset($user_intimacy_rs) && $user_intimacy_rs['level_remark']) { $tenim = new \app\api\controller\Tenim; $tenim->sendMessageToUser($this->auth->id, $to_user_id, $user_intimacy_rs['level_remark'], 1); } $this->success('success',$resArray); } //语音通话每分钟调用一次 public function voice_onemin(){ if ($this->auth->is_kefu == 1) { //我是客服或者对方是客服 $this->success('success',['money' => 'free']); } if ($this->auth->gender == 0) { //女生不花钱 $this->error('您的网络开小差啦~'); } //检测用户 $to_user_id = input_post('to_user_id'); $request_id = input('request_id', '', 'trim'); //唯一请求标识 $to_user_info = Db::name('user')->field('id,intro_uid,real_status,gender,free_video,free_audio,free_typing,voice_price,is_kefu')->where('id',$to_user_id)->find(); if(!$to_user_info){ $this->error('不存在的用户'); } if ($to_user_info['is_kefu'] == 1) { //我是客服或者对方是客服 $this->success('success',['money' => 'free']); } if ($to_user_info['gender'] != 0) { $this->error('同性不能聊天~'); } //验证金额 $wallet_info = Db::name('user_wallet')->where('user_id',$this->auth->id)->find(); $is_vip = $this->is_vip($wallet_info['vip_endtime'],$wallet_info['vip_level']); if($is_vip == 0){ $this->error('VIP才能语音聊天哦'); } if ($is_vip == 2) { //SVIP会员 $price = $to_user_info['voice_price'];//config('site.video_min_price'); //扣费金币 //获取折扣 $vip_voice_discount = config('site.vip_voice_discount'); if ($vip_voice_discount >= 0 && $vip_voice_discount <= 10) { $price = bcdiv(bcmul($price,$vip_voice_discount,2),10,0); } } else { $price = $to_user_info['voice_price'];//config('site.video_min_price'); //扣费金币 } //正常价格 $bili = config('site.money_to_gold'); //兑换比例 $gift_plat_scale = config('site.gift_plat_scale'); //抽成比例 $money = bcdiv($price,$bili,2); //对应人民币 $money = bcdiv(bcmul($money,100 - $gift_plat_scale,2),100,2); //抽成后收益 Db::startTrans(); //查询是否有匹配记录 $user_match_audio_log_info = []; if ($request_id) { $user_match_audio_log_info = Db::name('user_match_audio_log')->where(['user_id' => $this->auth->id, 'to_user_id' => $to_user_id, 'request_id' => $request_id])->find(); } if ($user_match_audio_log_info) { //修改记录日志 $data = [ 'price' => bcadd($user_match_audio_log_info['price'],$price,0), 'createtime' => time(), 'money' => bcadd($user_match_audio_log_info['money'],$money,2), 'call_minutes' => $user_match_audio_log_info['call_minutes'] + 1 ]; $log_rs = Db::name('user_match_audio_log')->where(['id' => $user_match_audio_log_info['id'], 'createtime' => $user_match_audio_log_info['createtime']])->setField($data); if (!$log_rs) { Db::rollback(); $this->error('扣费失败'); } $log_id = $user_match_audio_log_info['id']; } else { //添加记录日志 $data = [ 'user_id' => $this->auth->id, 'price' => $price, 'createtime' => time(), 'to_user_id' => $to_user_id, 'money' => $money, 'request_id' => $request_id, 'call_minutes' => 1 ]; $log_id = Db::name('user_match_audio_log')->insertGetId($data); if (!$log_id) { Db::rollback(); $this->error('扣费失败'); } } //有性别差,扣费 if($price > 0){ $rs = model('wallet')->lockChangeAccountRemain($this->auth->id,$to_user_id,'gold',-$price,12,'语音通话消费' . $data['call_minutes'] . '分钟','user_match_audio_log',$log_id, 0, $request_id); if($rs['status'] === false){ Db::rollback(); $this->error($rs['msg']); } } //另一方加钱,0收费 if($money > 0){ $rs = model('wallet')->lockChangeAccountRemain($to_user_id,$this->auth->id,'money',$money,22,'语音通话收益' . $data['call_minutes'] . '分钟','user_match_audio_log',$log_id,2, $request_id); if($rs['status'] === false){ Db::rollback(); $this->error($rs['msg']); } $touserinfo = $to_user_info; //增加赠送用户上级余额 if ($touserinfo['intro_uid']) { //获取返利比率 $agent_info = Db::name('user')->where(['id' => $touserinfo['intro_uid']])->field('is_agent,h_intro_income_rebate_rate')->find(); $intro_income_rebate_rate = ($agent_info['is_agent'] == 1) ? $agent_info['h_intro_income_rebate_rate'] : (int)config('site.intro_income_rebate_rate'); //邀请人收礼物返利比率 if ($intro_income_rebate_rate > 0 && $intro_income_rebate_rate <= 100) { //上级获得金额 $intro_uid_money = bcdiv(bcmul($money,$intro_income_rebate_rate,2),100,2); if ($intro_uid_money > 0) { $intro_result = model('Wallet')->lockChangeAccountRemain($touserinfo['intro_uid'],$to_user_id,'money',$intro_uid_money,68, '邀请人语音聊天获赠奖励' . $data['call_minutes'] . '分钟','user_match_audio_log',$log_id, 0, $request_id); if($intro_result['status']===false) { Db::rollback(); $this->error($intro_result['msg']); } } } } } //增加亲密度 $user_intimacy_rs = addintimacy($this->auth->id, $to_user_id, $price); if (!$user_intimacy_rs['status']) { Db::rollback(); $this->error('您的网络开小差啦~'); } //tag任务赠送金币 //与1名异性语音通话奖励 $task_rs = \app\common\model\TaskLog::tofinish($this->auth->id,25); if($task_rs === false){ Db::rollback(); $this->error('完成任务赠送奖励失败'); } $task_rs = \app\common\model\TaskLog::tofinish($to_user_id,25); if($task_rs === false){ Db::rollback(); $this->error('完成任务赠送奖励失败'); } //发送消息 if (isset($user_intimacy_rs) && $user_intimacy_rs['level_remark']) { $tenim = new \app\api\controller\Tenim; $tenim->sendMessageToUser($this->auth->id, $to_user_id, $user_intimacy_rs['level_remark'], 1); } Db::commit(); $rs = [ 'money' => $data['money'], ]; $this->success('success',$rs); } //视频通话每分钟调用一次 public function videochat_onemin(){ if ($this->auth->is_kefu == 1) { //我是客服或者对方是客服 $this->success('success',['money' => 'free']); } if ($this->auth->gender == 0) { //女生不花钱 $this->error('您的网络开小差啦~'); } //检测用户 $to_user_id = input_post('to_user_id'); $request_id = input('request_id', '', 'trim'); //唯一请求标识 $to_user_info = Db::name('user')->field('id,intro_uid,real_status,gender,free_video,free_audio,free_typing,video_price,is_kefu')->where('id',$to_user_id)->find(); if(!$to_user_info){ $this->error('不存在的用户'); } if ($to_user_info['is_kefu'] == 1) { //我是客服或者对方是客服 $this->success('success',['money' => 'free']); } if ($to_user_info['gender'] != 0) { $this->error('同性不能聊天~'); } /* //检查是否免费过 $count = Db::name('user_match_video_log_free')->where(['user_id' => $this->auth->id])->count('id'); if (!$count) { //记录日志 $data = [ 'user_id' => $this->auth->id, 'price' => 0, 'createtime' => time(), 'to_user_id' => $to_user_id, 'money' => 0, ]; $log_id = Db::name('user_match_video_log_free')->insertGetId($data); if(!$log_id){ $this->error('扣费失败'); } $this->success('success'); }*/ //验证金额 $wallet_info = Db::name('user_wallet')->where('user_id',$this->auth->id)->find(); $is_vip = $this->is_vip($wallet_info['vip_endtime'],$wallet_info['vip_level']); if($is_vip != 2){ $this->error('SVIP才能视频聊天哦'); } if ($is_vip == 2) { //SVIP会员 $price = $to_user_info['video_price'];//config('site.video_min_price'); //扣费金币 //获取折扣 $vip_video_discount = config('site.vip_video_discount'); if ($vip_video_discount >= 0 && $vip_video_discount <= 10) { $price = bcdiv(bcmul($price,$vip_video_discount,2),10,0); } } else { $price = $to_user_info['video_price'];//config('site.video_min_price'); //扣费金币 } //正常价格 $bili = config('site.money_to_gold'); //兑换比例 $gift_plat_scale = config('site.gift_plat_scale'); //抽成比例 $money = bcdiv($price,$bili,2); //对应人民币 $money = bcdiv(bcmul($money,100 - $gift_plat_scale,2),100,2); //抽成后收益 Db::startTrans(); //查询是否有匹配记录 $user_match_video_log_info = []; if ($request_id) { $user_match_video_log_info = Db::name('user_match_video_log')->where(['user_id' => $this->auth->id, 'to_user_id' => $to_user_id, 'request_id' => $request_id])->find(); } if ($user_match_video_log_info) { //修改记录日志 $data = [ 'price' => bcadd($user_match_video_log_info['price'],$price,0), 'createtime' => time(), 'money' => bcadd($user_match_video_log_info['money'],$money,2), 'call_minutes' => $user_match_video_log_info['call_minutes'] + 1 ]; $log_rs = Db::name('user_match_video_log')->where(['id' => $user_match_video_log_info['id'], 'createtime' => $user_match_video_log_info['createtime']])->setField($data); if (!$log_rs) { Db::rollback(); $this->error('扣费失败'); } $log_id = $user_match_video_log_info['id']; } else { //添加记录日志 $data = [ 'user_id' => $this->auth->id, 'price' => $price, 'createtime' => time(), 'to_user_id' => $to_user_id, 'money' => $money, 'request_id' => $request_id, 'call_minutes' => 1 ]; $log_id = Db::name('user_match_video_log')->insertGetId($data); if (!$log_id) { Db::rollback(); $this->error('扣费失败'); } } //有性别差,扣费 if($price > 0){ $rs = model('wallet')->lockChangeAccountRemain($this->auth->id,$to_user_id,'gold',-$price,11,'视频通话消费' . $data['call_minutes'] . '分钟','user_match_video_log',$log_id, 0, $request_id); if($rs['status'] === false){ Db::rollback(); $this->error($rs['msg']); } } //另一方加钱,0收费 if($money > 0){ $rs = model('wallet')->lockChangeAccountRemain($to_user_id,$this->auth->id,'money',$money,21,'视频通话收益' . $data['call_minutes'] . '分钟','user_match_video_log',$log_id,2, $request_id); if($rs['status'] === false){ Db::rollback(); $this->error($rs['msg']); } $touserinfo = $to_user_info; //增加赠送用户上级余额 if ($touserinfo['intro_uid']) { //获取返利比率 $agent_info = Db::name('user')->where(['id' => $touserinfo['intro_uid']])->field('is_agent,h_intro_income_rebate_rate')->find(); $intro_income_rebate_rate = ($agent_info['is_agent'] == 1) ? $agent_info['h_intro_income_rebate_rate'] : (int)config('site.intro_income_rebate_rate'); //邀请人收礼物返利比率 if ($intro_income_rebate_rate > 0 && $intro_income_rebate_rate <= 100) { //上级获得金额 $intro_uid_money = bcdiv(bcmul($money,$intro_income_rebate_rate,2),100,2); if ($intro_uid_money > 0) { $intro_result = model('Wallet')->lockChangeAccountRemain($touserinfo['intro_uid'],$to_user_id,'money',$intro_uid_money,68, '邀请人视频聊天获赠奖励' . $data['call_minutes'] . '分钟','user_match_video_log',$log_id, 0, $request_id); if($intro_result['status']===false) { Db::rollback(); $this->error($intro_result['msg']); } } } } } //增加亲密度 $user_intimacy_rs = addintimacy($this->auth->id, $to_user_id, $price); if (!$user_intimacy_rs['status']) { Db::rollback(); $this->error('您的网络开小差啦~'); } //tag任务赠送金币 //与1名异性视频通话奖励 $task_rs = \app\common\model\TaskLog::tofinish($this->auth->id,26); if($task_rs === false){ Db::rollback(); $this->error('完成任务赠送奖励失败'); } $task_rs = \app\common\model\TaskLog::tofinish($to_user_id,26); if($task_rs === false){ Db::rollback(); $this->error('完成任务赠送奖励失败'); } Db::commit(); //发送消息 if (isset($user_intimacy_rs) && $user_intimacy_rs['level_remark']) { $tenim = new \app\api\controller\Tenim; $tenim->sendMessageToUser($this->auth->id, $to_user_id, $user_intimacy_rs['level_remark'], 1); } $rs = [ 'money' => $data['money'], ]; $this->success('success',$rs); } //消息列表通话 public function calllist() { if ($this->auth->gender == 1) { $list = Db::name('user_gold_log')->where(['user_id' => $this->auth->id, 'log_type' => ['in', [11, 12]]])->order('id desc')->autopage()->select(); } elseif ($this->auth->gender == 0) { $list = Db::name('user_money_log')->where(['user_id' => $this->auth->id, 'log_type' => ['in', [21, 22]]])->order('id desc')->autopage()->select(); } else { $this->success('success', []); } if (!$list) { $this->success('success', $list); } $arr = []; $mt_user_match_audio_log = Db::name('user_match_audio_log'); $mt_user_match_video_log = Db::name('user_match_video_log'); $mt_user = Db::name('user'); foreach ($list as &$v) { $data = []; if ($this->auth->gender == 1) { if ($v['log_type'] == 11) { //视频通话 $log_info = $mt_user_match_video_log->field('to_user_id user_id, createtime, call_minutes')->where(['id' => $v['table_id']])->find(); $data['desc'] = '视频时长' . $log_info['call_minutes'] . '分钟'; } else { //语音通话 $log_info = $mt_user_match_audio_log->field('to_user_id user_id, createtime, call_minutes')->where(['id' => $v['table_id']])->find(); $data['desc'] = '语音时长' . $log_info['call_minutes'] . '分钟'; } } else { if ($v['log_type'] == 21) { //视频通话 $log_info = $mt_user_match_video_log->field('user_id, createtime, call_minutes')->where(['id' => $v['table_id']])->find(); $data['desc'] = '视频时长' . $log_info['call_minutes'] . '分钟'; } else { //语音通话 $log_info = $mt_user_match_audio_log->field('user_id, createtime, call_minutes')->where(['id' => $v['table_id']])->find(); $data['desc'] = '语音时长' . $log_info['call_minutes'] . '分钟'; } } $user_info = $mt_user->field('nickname, avatar,is_active')->where(['id' => $log_info['user_id']])->find(); $data['user_id'] = $log_info['user_id']; $data['nickname'] = $user_info['nickname']; $data['avatar'] = one_domain_image($user_info['avatar']); $data['createtime'] = get_last_time($log_info['createtime']); $data['is_active'] = $user_info['is_active']; $arr[] = $data; } $this->success('success', $arr); } //查询对方用户收费价格和我的余额 public function otheruserinfo(){ $user_id = input('user_id', 0, 'intval'); if (!$user_id) { $this->error('您的网络开小差啦~'); } $field = [ 'chat_price','voice_price','video_price','gender','is_kefu', 'open_match_audio', 'open_match_video' ]; $info = Db::name('user')->field($field)->where('id',$user_id)->find(); if ($info['is_kefu'] != 1 && $this->auth->is_kefu != 1) { //不是客服 if ($info['gender'] == $this->auth->gender || $info['gender'] == -1 || $this->auth->gender == -1) { $this->error('性别存在问题'); } } if ($this->auth->gender == 0) { //收费价格按照女号 $info['chat_price'] = $this->auth->chat_price; $info['voice_price'] = $this->auth->voice_price; $info['video_price'] = $this->auth->video_price; $info['open_match_audio'] = $this->auth->open_match_audio; $info['open_match_video'] = $this->auth->open_match_video; } $info['chat_price_vip'] = $info['chat_price']; //vip价格 $info['voice_price_vip'] = $info['voice_price']; $info['video_price_vip'] = $info['video_price']; //获取聊天折扣 $vip_chat_discount = config('site.vip_chat_discount'); if ($vip_chat_discount >= 0 && $vip_chat_discount <= 10) { $info['vip_chat_discount'] = $vip_chat_discount; } else { $info['vip_chat_discount'] = 10; } //获取视频折扣 $vip_video_discount = config('site.vip_video_discount'); if ($vip_video_discount >= 0 && $vip_video_discount <= 10) { $info['vip_video_discount'] = config('site.vip_video_discount'); //视频 } else { $info['vip_video_discount'] = 10; } //获取语音折扣 $vip_voice_discount = config('site.vip_voice_discount'); if ($vip_voice_discount >= 0 && $vip_voice_discount <= 10) { $info['vip_voice_discount'] = config('site.vip_voice_discount'); //语音 } else { $info['vip_voice_discount'] = 10; } //获取聊天折扣 $info['chat_price_vip'] = ceil($info['chat_price'] * $info['vip_chat_discount'] / 10); //获取语音折扣 $info['voice_price_vip'] = ceil($info['voice_price'] * $info['vip_voice_discount'] / 10); //获取视频折扣 $info['video_price_vip'] = ceil($info['video_price'] * $info['vip_video_discount'] / 10); if ($this->auth->gender == 0) { //查询男号余额和vip $wallet_info = Db::name('user_wallet')->where(['user_id' => $user_id])->find(); } else { $wallet_info = Db::name('user_wallet')->where(['user_id' => $this->auth->id])->find(); } $info['is_vip'] = $this->is_vip($wallet_info['vip_endtime'],$wallet_info['vip_level']); $info['gold'] = $wallet_info['gold']; $info['plat_scale'] = config('site.gift_plat_scale'); //平台抽成百分比 $info['money_to_gold'] = config('site.money_to_gold'); // $this->success('success',$info); } //语音视频随聊 public function getrandomuser() { $type = input('type', 0, 'intval'); //类型:1语音 2视频 if (!in_array($type, [1, 2, 3])) { $this->error('您的网络开小差了'); } $size = input('size',0,'intval');// 是否查 10 条 $size = $size > 0 ? 1 : 0; //给出备选用户 $map = [ 'gender' => $this->auth->gender == 1 ? 0 : 1, //异性 'is_active' => 1, //在线的 'status' =>1, //未封禁用户 'is_kefu' => 0, //不是客服 ]; if ($this->auth->gender == 1) { $map['real_status|idcard_status'] = 1; //真人认证或实名认证 } if ($type == 1) { $map['open_match_audio'] = 1; } elseif ($type == 2) { $map['open_match_video'] = 1; } $key = md5(json_encode($map));// 根据搜索条件做Key $lists = Cache::remember("getrandomuser_{$key}_{$size}",function () use ($map,$size){ $query = Db::name('user') ->field('id,nickname,username,avatar') ->where($map) ->order('is_active desc, logintime desc'); if ($size == 1){ $query->limit(10); }else{ $query->page($this->page,100); } $lists = $query->select(); $lists = list_domain_image($lists,['avatar,audio_bio']); $mt_user_greet_content = Db::name('user_greet_content'); foreach ($lists as &$v) { $info = $mt_user_greet_content->where(['user_id' => $v['id'], 'is_default' => 1])->find(); if ($info) { if ($info['type'] == 0) { $v['greet_content'] = $info['content']; } elseif ($info['type'] == 1) { $v['greet_content'] = '[语音]'; } elseif ($info['type'] == 2) { $v['greet_content'] = '[图片]'; } } else { $v['greet_content'] = ''; } } return $lists; },2); $count = Db::name('user')->where(['is_active' => 1])->count('id'); $return_data['count'] = config('site.randomuser_num') > 0 ? config('site.randomuser_num') + $count : $count; $return_data['list'] = $lists; $this->success('success',$return_data); } //查询免费体验视频通话用户信息 public function getfreevideouserinfo() { $to_user_id = input('to_user_id', 0, 'intval'); $to_user_info = Db::name('user')->field('id,gender,nickname,avatar,birthday,height,bio')->where(['id' => $to_user_id, 'is_kefu' => 0])->find(); if(!$to_user_info){ $this->error('不存在的用户'); } if ($to_user_info['gender'] == $this->auth->gender) { $this->error('同性不能聊天~'); } $to_user_info['desc'] = ''; $age = birthtime_to_age($to_user_info['birthday']); if ($age > 0) { $to_user_info['desc'] = $age . '岁'; } else { $to_user_info['desc'] = '18岁'; } if ($to_user_info['height']) { $to_user_info['desc'] .= ' | ' . $to_user_info['height']; } //查询是否免费过 $to_user_info['free_count'] = 1;//Db::name('user_match_video_log_free')->where(['user_id' => $this->auth->id])->count('id'); $this->success('信息', $to_user_info); } //免费体验视频通话1分钟 public function videochat_onemin_free(){ $this->success('success'); if ($this->auth->is_kefu == 1) { //我是客服或者对方是客服 $this->success('success'); } //检查是否免费过 $count = Db::name('user_match_video_log_free')->where(['user_id' => $this->auth->id])->count('id'); if ($count) { $this->error('已经免费体验过'); } //检测用户 $to_user_id = input_post('to_user_id'); $to_user_info = Db::name('user')->field('id,real_status,gender,free_video,free_audio,free_typing,video_price,is_kefu')->where('id',$to_user_id)->find(); if(!$to_user_info){ $this->error('不存在的用户'); } if ($to_user_info['is_kefu'] == 1) { //我是客服或者对方是客服 $this->success('success'); } if ($to_user_info['gender'] == $this->auth->gender) { $this->error('同性不能聊天~'); } //记录日志 $data = [ 'user_id' => $this->auth->id, 'price' => 0, 'createtime' => time(), 'to_user_id' => $to_user_id, 'money' => 0, ]; $log_id = Db::name('user_match_video_log_free')->insertGetId($data); if(!$log_id){ $this->error('扣费失败'); } $this->success('success'); } //男性非会员解锁聊天 public function unlockchat() { } /** * 是否关注 */ public function isFollows() { $user_id = $this->request->request("user_id",0,"intval"); if (!$user_id || $user_id<=0) { $this->error(__('Invalid parameters')); } $map = [ 'uid' => $this->auth->id, 'follow_uid' => $user_id, ]; $check = Db::name('user_follow')->where($map)->find(); $data = []; if($check){ $data["is_show_follow"] = 0; }else{ $data["is_show_follow"] = 1; } $this->success("获取成功!",$data); } //我的礼物榜 public function gift_ranklist(){ //日榜 $sql1 = Db::name('gift_user_typing') ->field('user_id,total_price')->where('user_to_id',$this->auth->id)->whereTime('createtime','today')->select(false); $sql2 = Db::name('gift_user_dongtai')->field('user_id,total_price')->where('user_to_id',$this->auth->id)->whereTime('createtime','today')->select(false); $sql = 'select log.user_id,sum(log.total_price) sum_price,user.nickname,user.avatar from ('.$sql1.' UNION ALL '.$sql2.') as log LEFT JOIN mt_user user on log.user_id = user.id group by log.user_id order by sum_price desc limit 10'; $rs_day = Db::query($sql); //周榜 $sql1 = Db::name('gift_user_typing') ->field('user_id,total_price')->where('user_to_id',$this->auth->id)->whereTime('createtime','week')->select(false); $sql2 = Db::name('gift_user_dongtai')->field('user_id,total_price')->where('user_to_id',$this->auth->id)->whereTime('createtime','week')->select(false); $sql = 'select log.user_id,sum(log.total_price) sum_price,user.nickname,user.avatar from ('.$sql1.' UNION ALL '.$sql2.') as log LEFT JOIN mt_user user on log.user_id = user.id group by log.user_id order by sum_price desc limit 10'; $rs_week = Db::query($sql); //月榜 $sql1 = Db::name('gift_user_typing') ->field('user_id,total_price')->where('user_to_id',$this->auth->id)->whereTime('createtime','month')->select(false); $sql2 = Db::name('gift_user_dongtai')->field('user_id,total_price')->where('user_to_id',$this->auth->id)->whereTime('createtime','month')->select(false); $sql = 'select log.user_id,sum(log.total_price) sum_price,user.nickname,user.avatar from ('.$sql1.' UNION ALL '.$sql2.') as log LEFT JOIN mt_user user on log.user_id = user.id group by log.user_id order by sum_price desc limit 10'; $rs_month = Db::query($sql); // $rs = [ 'day' => $rs_day, 'week' => $rs_week, 'month' => $rs_month, ]; $this->success(1,$rs); } ///////////////////////////////////////////////////// /** * calc_map_distance() , 根据地图上的两个点各自的x,y坐标,计算出2点之间的直线距离 * @param array $point_1 第1个点的x,y坐标 array( 101 , 202 ) * @param array $point_2 第2个点的x,y坐标 array( 101 , 202 ) * @param bool $calc_as_string 是否计算为字符串公里距离 , 如果未否返回数字 * @return float | false | string */ private function calc_map_distance( $point_1=array( ) , $point_2=array( ) , $calc_as_string=false ) { if( empty( $point_1 ) || empty( $point_2 ) ){ return false; } // 经纬度不存在,或者经纬度超过最大范围 +-180 , +-90 ,返回false $p1_x = $point_1[0]; $p1_y = $point_1[1]; $p2_x = $point_2[0]; $p2_y = $point_2[1]; if( $p1_x < -180 || $p1_x > 180 || $p2_x < -180 || $p2_x > 180 || $p1_y < -90 || $p1_y > 90 || $p2_y < -90 || $p2_y > 90 ){ return '0公里'; } // 根据2点各自的坐标,计算2点之间直线距离的公式 $distance = round(6378.138*2*asin(sqrt(pow(sin(( $p1_x *pi()/180-$p2_x*pi()/180)/2),2)+cos( $p1_x *pi()/180)*cos($p2_x*pi()/180)* pow(sin(( $p1_y *pi()/180-$p2_y*pi()/180)/2),2)))*1000); // 是否计算为字符串公里距离 if( !$calc_as_string ){ return (string)round( $distance / 1000 , 1 ) . '公里'; } // 如果计算为字符串公里距离 if( $distance / 1000 > 1 ){ $k = (string)round( $distance / 1000 , 1 ); $m = (string)$distance % 1000 ; $distance = "{$k}公里{$m}米"; } else{ $distance = "{$distance}米"; } return $distance; } //地图api,根据两地坐标,获得两地距离,打卡用的 //type=0直线,type=1开车 private function getmapjuli($start_lon,$start_lat,$end_lon,$end_lat,$type = 0){ $result = 0; $apiurl = 'https://restapi.amap.com/v3/distance?'; $param = [ 'key' => '398c424811d1a59beac2f915323d334e', 'origins' => $start_lon.','.$start_lat, 'destination' => $end_lon.','.$end_lat, 'type' => $type, 'output' => 'json', ]; $apiurl .= http_build_query($param); $request_rs = json_decode(curl_get($apiurl),true); if(isset($request_rs['status']) && $request_rs['status'] == 1){ if(isset($request_rs['results'][0]['distance'])) { $result = $request_rs['results'][0]['distance']; } } //dump($result); return $result; } public function distance() { $a = $this->calc_map_distance([118.339282,35.028445],[118.437399,35.017438]); dump($a); $a = $this->calc_map_distance([118.339282,35.028445],[118.437399,35.017438],true); dump($a); $b = $this->getmapjuli(118.339282,35.028445,118.437399,35.017438,1); dump($b); $b = $this->getmapjuli(118.339282,35.028445,118.437399,35.017438,0); dump($b); } }