<?php

namespace app\api\model;


use think\Db;
use think\Model;
use think\facade\Env;

class DatingRoom extends Model
{
    
    /*********************************心动连线***************************************/
    
    //开启心动连线
    public function open_heartbeat_line($uid, $rid){
        $config = get_uncache_system_config();
        
        $user_info = db::name('user')->field('uid')->find($uid);
        if(!$user_info){
            return ['code' => 201, 'msg' => '参数错误', 'data' => null];
        }
        
        $room_info = db::name('room')->find($rid);
        if(!$room_info){
            return ['code' => 201, 'msg' => '该房间不存在', 'data' => null];
        }
        
        // $room_admin_uid_arr = explode(',', $room_info['room_admin_uid']);
        // if ($uid != $room_info['room_owner_uid'] && !in_array($uid, $room_admin_uid_arr)) {
        //     return ['code' => 201, 'msg' => '无权限操作', 'data' => null];
        // }
        if($uid != $room_info['room_host_uid']){
            return ['code' => 201, 'msg' => '仅限主持麦操作', 'data' => null];
        }
        
        //是否已有未结束阶段
        $map = [];
        $map[] = ['rid', '=', $rid];
        $map[] = ['is_delete', '=', 1];
        $room_dating_log = db::name('room_dating_log')->where($map)->find();
        if($room_dating_log){
            return ['code' => 201, 'msg' => '无法重复开启', 'data' => null];
        }
        
        Db::startTrans();
        try {
            // $room_micro_data = explode(',', $room_info['room_micro']);
            $room_micro_data = db::name('room_micro')->where('rid', $rid)->order('micro_id asc')->column('uid');
            $left_micro_num = 0;
            $right_micro_num = 0;
            $micro_uid_data = '';
            foreach($room_micro_data as $a => $b){
                
                if(in_array($a, [0,2,4]) && $b > 0){
                    $left_micro_num += 1;
                    $micro_uid_data .= $b.',';
                }else if(in_array($a, [1,3,5]) && $b > 0){
                    $right_micro_num += 1;
                    $micro_uid_data .= $b.',';
                }
            }
            
            // if($left_micro_num < 1 && $right_micro_num < 1){
            //     return ['code' => 201, 'msg' => '双方人数不能为0人', 'data' => null];
            // }
            // if($left_micro_num != $right_micro_num){
            //     return ['code' => 201, 'msg' => '双方人数必须一致才能开始', 'data' => null];
            // }
            
            if(($left_micro_num + $right_micro_num) < 1){
                return ['code' => 201, 'msg' => '当前交友麦上没有人无法开启', 'data' => null];
            }
            
            
            $insert = [];
            $insert['rid'] = $rid;
            $insert['participate_uid'] = $micro_uid_data;
            $insert['stage'] = 2;
            $insert['duration'] = $config['heartbeat_line_time'];
            $insert['add_time'] = time();
            $insert['end_time'] = time() + $config['heartbeat_line_time'];
            $reslut = db::name('room_dating_log')->insert($insert);
            if(!$reslut){
                Db::rollback();
                return ['code' => 201, 'msg' => '操作失败', 'data' => null];
            }
            
            Db::commit();
            model('api/room')->push_room_micro_data($rid);
            return ['code' => 200, 'msg' => '操作成功', 'data' => null];
        } catch (\Exception $e) {
            // 回滚事务
            dump($e);
            Db::rollback();
            return ['code' => 201, 'msg' => '操作失败', 'data' => null];
        }
        
    }
    
    //生成心动连线
    public function user_send_gift_heartbeat_line($uid, $receive_uid, $rid, $change_value, $help_uid){
        // $user_info = db::name('user')->field('uid')->find($uid);
        // if(!$user_info){
        //     return ['code' => 201, 'msg' => '参数错误', 'data' => null];
        // }
        
        $room_info = db::name('room')->find($rid);
        if(!$room_info){
            return ['code' => 201, 'msg' => '该房间信息不存在', 'data' => null];
        }
        
        Db::startTrans();
        try {
            $micro_uid_7 = 0;
            $room_micro_datas = [];
            // $room_micro_data = explode(',', $room_info['room_micro']);
            $room_micro_data = db::name('room_micro')->where('rid', $rid)->order('micro_id asc')->column('uid');
            foreach ($room_micro_data as $a => $b){
                if($a < 6){
                    $room_micro_datas[] = $b;
                }
                $micro_uid_7 = $room_micro_data[6];
            }
            $is_push = 2;
            //是否有未结束的第二阶段
            $map = [];
            $map[] = ['rid', '=', $rid];
            $map[] = ['stage', '=', 2];
            $map[] = ['is_delete', '=', 1];
            $room_dating_log = db::name('room_dating_log')->where($map)->find();
            if($room_dating_log){
                // if(!in_array($uid, $room_micro_datas) && in_array($receive_uid, $room_micro_datas)){//普通用户送麦上，助力
                if(!empty($help_uid)){//助力
                    //助力所在的麦位及对应麦位
                    $micro_id_1 = db::name('room_micro')->where('rid', $rid)->where('uid', $help_uid)->value('micro_id');
                    if($micro_id_1 == 1){
                        $help_receive_uid = db::name('room_micro')->where('rid', $rid)->where('micro_id', 2)->value('uid');
                    }else if($micro_id_1 == 2){
                        $help_receive_uid = db::name('room_micro')->where('rid', $rid)->where('micro_id', 1)->value('uid');
                    }else if($micro_id_1 == 3){
                        $help_receive_uid = db::name('room_micro')->where('rid', $rid)->where('micro_id', 4)->value('uid');
                    }else if($micro_id_1 == 4){
                        $help_receive_uid = db::name('room_micro')->where('rid', $rid)->where('micro_id', 3)->value('uid');
                    }else if($micro_id_1 == 5){
                        $help_receive_uid = db::name('room_micro')->where('rid', $rid)->where('micro_id', 6)->value('uid');
                    }else if($micro_id_1 == 6){
                        $help_receive_uid = db::name('room_micro')->where('rid', $rid)->where('micro_id', 5)->value('uid');
                    }
                    $map = [];
                    $map[] = ['pid', '=', $room_dating_log['id']];
                    $map[] = ['uid|receive_uid', '=', $help_uid];//需更改help_uid
                    $map[] = ['uid|receive_uid', '=', $help_receive_uid];
                    // $user_room_dating_line = db::name('user_room_dating_line')->where($map)->select();
                    $user_room_dating_line = db::name('user_room_dating_line')->where($map)->order('rank_value desc')->find();
                    if(!empty($user_room_dating_line)){
                        //增加数值
                        $update = [];
                        $update['update_time'] = time();
                        $reslut = db::name('user_room_dating_line')->where('id', $user_room_dating_line['id'])->inc('rank_value', $change_value)->inc('subjoin_value', $change_value)->update($update);
                        // $reslut = db::name('user_room_dating_line')->where($map)->inc('rank_value', $change_value)->inc('subjoin_value', $change_value)->update($update);
                        
                        // if(!$reslut){
                        //     Db::rollback();
                        //     return ['code' => 201, 'msg' => '失败', 'data' => null];
                        // }
                        
                        //添加记录
                        $map = [];
                        $map[] = ['pid', '=', $room_dating_log['id']];
                        $map[] = ['line_id', '=', $user_room_dating_line['id']];
                        $map[] = ['uid', '=', $uid];
                        $map[] = ['receive_uid', '=', $help_uid];//需更改help_uid
                        $user_room_dating_help = db::name('user_room_dating_help')->where($map)->find();
                        if($user_room_dating_help){
                            $reslut = db::name('user_room_dating_help')->where($map)->inc('subjoin_value', $change_value)->update($update);
                        }else{
                            $insert = [];
                            $insert['pid'] = $room_dating_log['id'];
                            $insert['line_id'] = $user_room_dating_line['id'];
                            $insert['uid'] = $uid;
                            $insert['receive_uid'] = $help_uid;
                            $insert['subjoin_value'] = $change_value;
                            $insert['add_time'] = time();
                            $reslut = db::name('user_room_dating_help')->insert($insert);
                        }
                        // if(!$reslut){
                        //     Db::rollback();
                        //     return ['code' => 201, 'msg' => '失败', 'data' => null];
                        // }
                        $is_push = 1;
                    }
                    
                    
                    // $map = [];
                    // $map[] = ['uid|receive_uid', '=', $help_uid];//需更改help_uid
                    // $map[] = ['uid|receive_uid', '=', $help_receive_uid];
                    // $map[] = ['r_date', '=', date('Y-m-d')];
                    // $dating_mt_wheel = db::name('dating_mt_wheel')->where($map)->find(); 
                    // if(!empty($dating_mt_wheel)){
                    //     db::name('dating_mt_wheel')->where(['id'=>$dating_mt_wheel['id']])->inc('rank_value', $change_value)->update(['update_time'=>time()]);
                    // }

                // }else if(in_array($uid, $room_micro_datas) && in_array($receive_uid, $room_micro_datas)){//同是麦上用户连线或增加心动值
                }else{//非助力，连线
                    if($uid == $room_info['room_host_uid'] || $uid == $micro_uid_7 || $receive_uid == $room_info['room_host_uid'] || $receive_uid == $micro_uid_7){
                        //用户为主持麦和嘉宾麦无法参与
                    }else{
                        //是否有连线
                        $map = [];
                        $map[] = ['pid', '=', $room_dating_log['id']];
                        $map[] = ['uid|receive_uid', '=', $uid];
                        $map[] = ['uid|receive_uid', '=', $receive_uid];
                        $user_room_dating_line = db::name('user_room_dating_line')->where($map)->find();
                        if($user_room_dating_line){
                            $update = [];
                            $update['update_time'] = time();
                            $reslut = db::name('user_room_dating_line')->where('id', $user_room_dating_line['id'])->inc('rank_value', $change_value)->update($update);
                            // if(!$reslut){
                            //     Db::rollback();
                            //     return ['code' => 201, 'msg' => '失败', 'data' => null];
                            // }
                            
                        }else{//没有记录连线
                            //绑定连线
                            $insert = [];
                            $insert['pid'] = $room_dating_log['id'];
                            $insert['uid'] = $uid;
                            $insert['receive_uid'] = $receive_uid;
                            $insert['add_time'] = time();
                            $insert['rank_value'] = $change_value;
                            $reslut = db::name('user_room_dating_line')->insert($insert);
                            // if(!$reslut){
                            //     Db::rollback();
                            //     return ['code' => 201, 'msg' => '失败', 'data' => null];
                            // }
                            
                            //uid是否在参与人员中
                            $participate_uid_array = trim($room_dating_log['participate_uid'], ',');
                            $participate_uid_array = explode(',', $participate_uid_array);
                            $participate_uid_data = '';
                            if(!in_array($uid, $participate_uid_array)){
                                $participate_uid_data = $room_dating_log['participate_uid'].$uid.',';
                            }
                            //receive_uid是否在参与人员中
                            if(!in_array($receive_uid, $participate_uid_array)){
                                if(empty($participate_uid_data)){
                                    $participate_uid_data = $room_dating_log['participate_uid'].$receive_uid.',';
                                }else{
                                    $participate_uid_data = $participate_uid_data.$receive_uid.',';
                                }
                            }
                            
                            if(!empty($participate_uid_data)){
                                $update = [];
                                $update['participate_uid'] = $participate_uid_data;
                                $update['update_time'] = time();
                                $reslut = db::name('room_dating_log')->where('id', $room_dating_log['id'])->update($update);
                                // if(!$reslut){
                                //     Db::rollback();
                                //     return ['code' => 201, 'msg' => '失败', 'data' => null];
                                // }
                            }
                        }
                        
                        
                        //增加建立关系后的心动连线值
                        // $map = [];
                        // $map[] = ['uid|receive_uid', '=', $uid];//需更改help_uid
                        // $map[] = ['uid|receive_uid', '=', $receive_uid];
                        // $map[] = ['r_date', '=', date('Y-m-d')];
                        // $dating_mt_wheel = db::name('dating_mt_wheel')->where($map)->find(); 
                        // if(!empty($dating_mt_wheel)){
                        //     db::name('dating_mt_wheel')->where(['id'=>$dating_mt_wheel['id']])->inc('rank_value', $change_value)->update(['update_time'=>time()]);
                        // }
                                            
                
                        $is_push = 1;
                    }
                }
            }
            
            if($is_push == 1){
                $reslut =  $this->update_dating_room_micro($rid);
                if($reslut['code'] == 201){
                    Db::rollback();
                    return ['code' => 201, 'msg' => '操作失败', 'data' => null];
                }
            }
            
            Db::commit();
            return ['code' => 200, 'msg' => '操作成功', 'data' => null];
        } catch (\Exception $e) {
            // 回滚事务
            dump($e);
            Db::rollback();
            return ['code' => 201, 'msg' => '操作失败', 'data' => null];
        }
    }
    
    //麦位变更
    public function update_dating_room_micro($rid){
        $map = [];
        $map[] = ['rid', '=', $rid];
        $map[] = ['stage', '=', 2];
        $map[] = ['is_delete', '=', 1];
        $room_dating_log = db::name('room_dating_log')->where($map)->find();
        if($room_dating_log){
            $room_micro_uid_array = trim($room_dating_log['participate_uid'], ',');
            $room_micro_uid_array = explode(',', $room_micro_uid_array);
            $map = [];
            $map[] = ['pid', '=', $room_dating_log['id']];
            $map[] = ['uid|receive_uid', 'in', $room_micro_uid_array];
            $user_room_dating_line = db::name('user_room_dating_line')->where($map)->order('rank_value desc,add_time asc')->find();
            
            if(!empty($user_room_dating_line)){
                // $room_micro = db::name('room')->where('rid',$rid)->value('room_micro');
                // $room_micro_data = explode(',', $room_micro);
                $room_micro_data_s = db::name('room_micro')->where('rid', $rid)->order('micro_id asc')->field('uid,is_online,micro_id')->select();
                $room_micro_data_u = [];
                foreach ($room_micro_data_s as $val) {
                    if($val['uid'] > 0) {
                        $room_micro_data_u[$val['uid']] = $val;
                    }
                    
                }
                $room_micro_data = db::name('room_micro')->where('rid', $rid)->order('micro_id asc')->column('uid');
                $room_micro_datas = $room_micro_data;
                //第一的麦位
                $user_sex = db::name('user')->where('uid', $user_room_dating_line['uid'])->value('sex');
                if($user_sex == 1){
                    if($room_micro_data[2] != $user_room_dating_line['uid']){
                        $room_micro_data[2] = $user_room_dating_line['uid'];
                    }
                    if($room_micro_data[3] != $user_room_dating_line['receive_uid']){
                        $room_micro_data[3] = $user_room_dating_line['receive_uid'];
                    }
                }else{
                    if($room_micro_data[3] != $user_room_dating_line['uid']){
                        $room_micro_data[3] = $user_room_dating_line['uid'];
                    }
                    if($room_micro_data[2] != $user_room_dating_line['receive_uid']){
                        $room_micro_data[2] = $user_room_dating_line['receive_uid'];
                    }
                }
                $room_micro_uid_1 = [$user_room_dating_line['uid'], $user_room_dating_line['receive_uid']];
                $room_micro_uid_array_1 = array_diff($room_micro_uid_array, $room_micro_uid_1);
                
                $map = [];
                $map[] = ['pid', '=', $room_dating_log['id']];
                $map[] = ['uid|receive_uid', 'in', $room_micro_uid_1];
                $user_room_dating_line_data = db::name('user_room_dating_line')->where($map)->column('id');
                
                if(!empty($room_micro_uid_array_1)){
                    //第二的麦位连线
                    $map = [];
                    $map[] = ['pid', '=', $room_dating_log['id']];
                    $map[] = ['uid|receive_uid', 'in', $room_micro_uid_array_1];
                    $map[] = ['id', 'not in', $user_room_dating_line_data];
                    $user_room_dating_line_1 = db::name('user_room_dating_line')->where($map)->order('rank_value desc,add_time asc')->find();
                    
                    if(!empty($user_room_dating_line_1)){
                        $user_sex_1 = db::name('user')->where('uid', $user_room_dating_line_1['uid'])->value('sex');
                        if($user_sex_1 == 1){
                            if($room_micro_data[0] != $user_room_dating_line_1['uid']){
                                $room_micro_data[0] = $user_room_dating_line_1['uid'];
                            }
                            if($room_micro_data[1] != $user_room_dating_line_1['receive_uid']){
                                $room_micro_data[1] = $user_room_dating_line_1['receive_uid'];
                            }
                        }else{
                            if($room_micro_data[0] != $user_room_dating_line_1['receive_uid']){
                                $room_micro_data[0] = $user_room_dating_line_1['receive_uid'];
                            }
                            if($room_micro_data[1] != $user_room_dating_line_1['uid']){
                                $room_micro_data[1] = $user_room_dating_line_1['uid'];
                            }
                        }
                        
                        $room_micro_uid_2 = [$user_room_dating_line_1['uid'], $user_room_dating_line_1['receive_uid']];
                        $room_micro_uid_array_2 = array_diff($room_micro_uid_array_1, $room_micro_uid_2);
                        $room_micro_uid_3 = [$user_room_dating_line['uid'], $user_room_dating_line['receive_uid'],$user_room_dating_line_1['uid'], $user_room_dating_line_1['receive_uid']];
                        $map = [];
                        $map[] = ['pid', '=', $room_dating_log['id']];
                        $map[] = ['uid|receive_uid', 'in', $room_micro_uid_3];
                        $user_room_dating_line_data_1 = db::name('user_room_dating_line')->where($map)->column('id');
                        
                        if(!empty($room_micro_uid_array_2)){
                            //第三的麦位连线
                            $map = [];
                            $map[] = ['pid', '=', $room_dating_log['id']];
                            $map[] = ['uid|receive_uid', 'in', $room_micro_uid_array_2];
                            $map[] = ['id', 'not in', $user_room_dating_line_data_1];
                            $user_room_dating_line_2 = db::name('user_room_dating_line')->where($map)->order('rank_value desc,add_time asc')->find();
                            if(!empty($user_room_dating_line_2)){
                                $user_sex_2 = db::name('user')->where('uid', $user_room_dating_line_2['uid'])->value('sex');
                                if($user_sex_2 == 1){
                                    if($room_micro_data[4] != $user_room_dating_line_2['uid']){
                                        $room_micro_data[4] = $user_room_dating_line_2['uid'];
                                    }
                                    if($room_micro_data[5] != $user_room_dating_line_2['receive_uid']){
                                        $room_micro_data[5] = $user_room_dating_line_2['receive_uid'];
                                    }
                                }else{
                                    if($room_micro_data[4] != $user_room_dating_line_2['receive_uid']){
                                        $room_micro_data[4] = $user_room_dating_line_2['receive_uid'];
                                    }
                                    if($room_micro_data[5] != $user_room_dating_line_2['uid']){
                                        $room_micro_data[5] = $user_room_dating_line_2['uid'];
                                    }
                                }
                            }else{
                                $room_micro_uid_array_2 = array_values($room_micro_uid_array_2);
                                $room_micro_data[4] = 0;
                                $room_micro_data[5] = 0;
                                foreach ($room_micro_uid_array_2 as $a => $b){
                                    if($a == 0){
                                        $room_micro_data[4] = $b;
                                    }else if($a == 1){
                                        $room_micro_data[5] = $b;
                                    }
                                }
                            }
                        }else{
                            $room_micro_data[4] = 0;
                            $room_micro_data[5] = 0;
                        }
                    }else{
                        $room_micro_uid_array_1 = array_values($room_micro_uid_array_1);
                        $room_micro_data[0] = 0;
                        $room_micro_data[1] = 0;
                        $room_micro_data[4] = 0;
                        $room_micro_data[5] = 0;
                        foreach ($room_micro_uid_array_1 as $a => $b){
                            if($a == 0){
                                $room_micro_data[0] = $b;
                            }else if($a == 1){
                                $room_micro_data[1] = $b;
                            }else if($a == 2){
                                $room_micro_data[4] = $b;
                            }else if($a == 3){
                                $room_micro_data[5] = $b;
                            }
                        }
                    }
                }else{
                    $room_micro_data[0] = 0;
                    $room_micro_data[1] = 0;
                    $room_micro_data[4] = 0;
                    $room_micro_data[5] = 0;
                }
                
                
                if($room_micro_datas != $room_micro_data){
                    //改变麦位
                    foreach ($room_micro_data as $i => $j){
                        $update_data = ['uid' => $j, 'frame_gid' => 0, 'centre_gid' => 0, 'above_gid' => 0, 'below_gid' => 0, 'left_gid'=> 0, 'right_gid' => 0, 'update_time' => time()];
                        if(isset($room_micro_data_u[$j])) {
                            $update_data['is_online'] = $room_micro_data_u[$j]['is_online'];
                        }
                        $reslut = db::name('room_micro')->where('rid', $rid)->where('micro_id', ($i+1))->update($update_data);
                        // if(!$reslut){
                        //     return ['code' => 201, 'msg' => '失败', 'data' => null];
                        // }
                    }
                    
                }
            }
        }
        
        return ['code' => 200, 'msg' => '成功', 'data' => null];
    }
    
    
    //增加心动连线时长
    public function add_heartbeat_line_duration($uid, $rid, $duration){
        $config = get_uncache_system_config();
        
        $user_info = db::name('user')->field('uid')->find($uid);
        if(!$user_info){
            return ['code' => 201, 'msg' => '参数错误', 'data' => null];
        }
        
        $room_info = db::name('room')->find($rid);
        if(!$room_info){
            return ['code' => 201, 'msg' => '该房间不存在', 'data' => null];
        }
        
        $duration_time = $duration * 60;
        if($duration < 1){
            return ['code' => 201, 'msg' => '添加时间最低不能小于1分钟', 'data' => null];
        }
        
        if($duration > 60){
            return ['code' => 201, 'msg' => '单次添加时间不能大于60分钟', 'data' => null];
        }
        
        if(ceil($duration) != $duration){
            return ['code' => 201, 'msg' => '添加时间必须为整数', 'data' => null];
        }
        
        // $room_admin_uid_arr = explode(',', $room_info['room_admin_uid']);
        $room_admin_uid_arr = db::name('room_admin')->where('rid', $rid)->where('is_delete', 1)->column('uid');
        if ($uid != $room_info['room_owner_uid'] && $uid != $room_info['room_host_uid']) {
            return ['code' => 201, 'msg' => '无权限操作', 'data' => null];
        }
        
        //是否已有未结束阶段
        $map = [];
        $map[] = ['rid', '=', $rid];
        $map[] = ['stage', '=', 2];
        $map[] = ['is_delete', '=', 1];
        $room_dating_log = db::name('room_dating_log')->where($map)->find();
        if(!$room_dating_log){
            return ['code' => 201, 'msg' => '当前未有心动连线阶段', 'data' => null];
        }
        if($room_dating_log['end_time'] < time()){
            return ['code' => 201, 'msg' => '当前未有心动连线阶段', 'data' => null];
        }
        
        $surplus_time = $room_dating_log['end_time'] - time();
        $total_time = $duration_time + $surplus_time;
        if($total_time > 10800){
            return ['code' => 201, 'msg' => '添加总时长不能大于3小时', 'data' => null];
        }
        
        Db::startTrans();
        try {
            $update = [];
            $update['duration'] = $room_dating_log['duration'] + $duration_time;
            $update['end_time'] = $room_dating_log['end_time'] + $duration_time;
            $update['update_time'] = time();
            $reslut = db::name('room_dating_log')->where('id', $room_dating_log['id'])->update($update);
            if(!$reslut){
                Db::rollback();
                return ['code' => 201, 'msg' => '操作失败', 'data' => null];
            }
            
            //添加记录
            $insert = [];
            $insert['user_id'] = $uid;
            $insert['pid'] = $room_dating_log['id'];
            $insert['rid'] = $rid;
            $insert['duration'] = $duration;
            $insert['add_time'] = time();
            $reslut = db::name('room_dating_duration_log')->insert($insert);
            if(!$reslut){
                Db::rollback();
                return ['code' => 201, 'msg' => '操作失败', 'data' => null];
            }
            
            Db::commit();
            model('api/room')->push_room_micro_data($rid);
            return ['code' => 200, 'msg' => '操作成功', 'data' => null];
        } catch (\Exception $e) {
            // 回滚事务
            dump($e);
            Db::rollback();
            return ['code' => 201, 'msg' => '操作失败', 'data' => null];
        }
        
    }
    
    //结束心动连线阶段
    public function end_heartbeat_line($uid, $rid){
        $config = get_uncache_system_config();
        
        $user_info = db::name('user')->field('uid')->find($uid);
        if(!$user_info){
            return ['code' => 201, 'msg' => '参数错误', 'data' => null];
        }
        
        $room_info = db::name('room')->find($rid);
        if(!$room_info){
            return ['code' => 201, 'msg' => '该房间不存在', 'data' => null];
        }
        
        // $room_admin_uid_arr = explode(',', $room_info['room_admin_uid']);
        $room_admin_uid_arr = db::name('room_admin')->where('rid', $rid)->where('is_delete', 1)->column('uid');
        if ($uid != $room_info['room_owner_uid'] && $uid != $room_info['room_host_uid']) {
            return ['code' => 201, 'msg' => '无权限操作', 'data' => null];
        }
        if(empty($room_info['room_host_uid'])){
            return ['code' => 201, 'msg' => '当前没有主持，无法结束', 'data' => null];
        }
        
        //是否已有未结束阶段
        $map = [];
        $map[] = ['rid', '=', $rid];
        $map[] = ['stage', '=', 2];
        $map[] = ['is_delete', '=', 1];
        $room_dating_log = db::name('room_dating_log')->where($map)->find();
        if(!$room_dating_log){
            return ['code' => 201, 'msg' => '当前未有心动连线阶段', 'data' => null];
        }
        
        Db::startTrans();
        try {
            $map = [];
            $map[] = ['pid', '=', $room_dating_log['id']];
            $map[] = ['rank_value', '>', 99];
            $user_room_dating_line = db::name('user_room_dating_line')->where($map)->order('rank_value desc')->find();
            if(!empty($user_room_dating_line)){
                $update = [];
                $update['stage'] = 3;
                $update['update_time'] = time();
                $reslut = db::name('room_dating_log')->where('id', $room_dating_log['id'])->update($update);
                if(!$reslut){
                    Db::rollback();
                    return ['code' => 201, 'msg' => '操作失败', 'data' => null];
                }
            }else{//为空则直接跳回第一阶段
                //结束第三阶段
                $update = [];
                $update['is_delete'] = 2;
                $update['update_time'] = time();
                $reslut = db::name('room_dating_log')->where('id', $room_dating_log['id'])->update($update);
                if(!$reslut){
                    Db::rollback();
                    return ['code' => 201, 'msg' => '操作失败', 'data' => null];
                }
                
                //清空麦位
                $map = [];
                $map[] = ['rid', '=', $rid];
                $map[] = ['micro_id', 'in', [1,2,3,4,5,6]];
                $update = [];
                $update['uid'] = 0;
                $update['frame_gid'] = 0;
                $update['centre_gid'] = 0;
                $update['above_gid'] = 0;
                $update['below_gid'] = 0;
                $update['left_gid'] = 0;
                $update['right_gid'] = 0;
                $update['update_time'] = time();
                $reslut = db::name('room_micro')->where($map)->update($update);
                if(!$reslut){
                    Db::rollback();
                    return ['code' => 201, 'msg' => '操作失败', 'data' => null];
                }
                
            }
            
            
            Db::commit();
            model('api/room')->push_room_micro_data($rid);
            
            //推送主持麦绑定关系
            // $where = [];
            // $where[] = ['pid', '=', $room_dating_log['id']];
            // $user_room_dating_line = db::name('user_room_dating_line')->where($where)->order('rank_value desc')->find();
            $push_room_dating_data = [];
            if(!empty($room_info['room_host_uid']) && !empty($user_room_dating_line)){
                $users_info = db::name('user')->where('uid', $user_room_dating_line['uid'])->field('uid,nick_name,base64_nick_name,head_pic,sex')->find();
                $receive_info = db::name('user')->where('uid', $user_room_dating_line['receive_uid'])->field('uid,nick_name,base64_nick_name,head_pic,sex')->find();
                
                
                $push_room_dating_data['user_info']['uid'] = $user_room_dating_line['uid'];
                $push_room_dating_data['user_info']['nick_name'] = mb_convert_encoding(base64_decode($users_info['base64_nick_name']), 'UTF-8', 'UTF-8');
                $push_room_dating_data['user_info']['head_pic'] = localpath_to_netpath($users_info['head_pic']);
                $push_room_dating_data['user_info']['sex'] = $users_info['sex'];
                $push_room_dating_data['receive_info']['uid'] = $user_room_dating_line['receive_uid'];
                $push_room_dating_data['receive_info']['nick_name'] = mb_convert_encoding(base64_decode($receive_info['base64_nick_name']), 'UTF-8', 'UTF-8');
                $push_room_dating_data['receive_info']['head_pic'] = localpath_to_netpath($receive_info['head_pic']);
                $push_room_dating_data['receive_info']['sex'] = $receive_info['sex'];
                
                $push_data = [];
                $push_data['code'] = 341;
                $push_data['msg'] = "推送主持麦绑定关系";
                $push_data['data'] = $push_room_dating_data;
                model('api/WebSocketPush')->send_to_one($room_info['room_host_uid'], $push_data);
                // dump($res);exit;
            }
            
            
            return ['code' => 200, 'msg' => '操作成功', 'data' => $push_room_dating_data];
        } catch (\Exception $e) {
            // 回滚事务
            dump($e);
            Db::rollback();
            return ['code' => 201, 'msg' => '操作失败', 'data' => null];
        }
    }
    
    //定时任务结束第二阶段
    public function close_room_dating_stage(){
        //查询即将结束的第二阶段
        $now_time = time();
        $map = [];
        $map[] = ['stage', '=', 2];
        $map[] = ['end_time', '<', $now_time];
        $map[] = ['is_delete', '=', 1];
        $list = db::name('room_dating_log')->where($map)->select();
        
        foreach ($list as $k => $v){
            Db::startTrans();
            try {
                $room_info = db::name('room')->find($v['rid']);
                $map = [];
                $map[] = ['pid', '=', $v['id']];
                $map[] = ['rank_value', '>', 99];
                $user_room_dating_line = db::name('user_room_dating_line')->where($map)->order('rank_value desc')->find();
                if(!empty($user_room_dating_line)){
                    $update = [];
                    $update['stage'] = 3;
                    $update['update_time'] = time();
                    $reslut = db::name('room_dating_log')->where('id', $v['id'])->update($update);
                    if(!$reslut){
                        Db::rollback();
                    }
                }else{//为空则直接跳回第一阶段
                    //结束第三阶段
                    $update = [];
                    $update['is_delete'] = 2;
                    $update['update_time'] = time();
                    $reslut = db::name('room_dating_log')->where('id', $v['id'])->update($update);
                    if(!$reslut){
                        Db::rollback();
                    }
                    
                    //清空麦位
                    $map = [];
                    $map[] = ['rid', '=', $v['rid']];
                    $map[] = ['micro_id', 'in', [1,2,3,4,5,6]];
                    $update = [];
                    $update['uid'] = 0;
                    $update['frame_gid'] = 0;
                    $update['centre_gid'] = 0;
                    $update['above_gid'] = 0;
                    $update['below_gid'] = 0;
                    $update['left_gid'] = 0;
                    $update['right_gid'] = 0;
                    $update['update_time'] = time();
                    $reslut = db::name('room_micro')->where($map)->update($update);
                    if(!$reslut){
                        Db::rollback();
                    }
                    
                }
                Db::commit();
                model('api/room')->push_room_micro_data($v['rid']);
                
                if(!empty($room_info['room_host_uid']) && !empty($user_room_dating_line)){
                    $users_info = db::name('user')->where('uid', $user_room_dating_line['uid'])->field('uid,nick_name,base64_nick_name,head_pic,sex')->find();
                    $receive_info = db::name('user')->where('uid', $user_room_dating_line['receive_uid'])->field('uid,nick_name,base64_nick_name,head_pic,sex')->find();
                    
                    $push_room_dating_data = [];
                    $push_room_dating_data['user_info']['uid'] = $user_room_dating_line['uid'];
                    $push_room_dating_data['user_info']['nick_name'] = mb_convert_encoding(base64_decode($users_info['base64_nick_name']), 'UTF-8', 'UTF-8');
                    $push_room_dating_data['user_info']['head_pic'] = localpath_to_netpath($users_info['head_pic']);
                    $push_room_dating_data['user_info']['sex'] = $users_info['sex'];
                    $push_room_dating_data['receive_info']['uid'] = $user_room_dating_line['receive_uid'];
                    $push_room_dating_data['receive_info']['nick_name'] = mb_convert_encoding(base64_decode($receive_info['base64_nick_name']), 'UTF-8', 'UTF-8');
                    $push_room_dating_data['receive_info']['head_pic'] = localpath_to_netpath($receive_info['head_pic']);
                    $push_room_dating_data['receive_info']['sex'] = $receive_info['sex'];
                    
                    $push_data = [];
                    $push_data['code'] = 341;
                    $push_data['msg'] = "推送主持麦绑定关系";
                    $push_data['data'] = $push_room_dating_data;
                    model('api/WebSocketPush')->send_to_one($room_info['room_host_uid'], $push_data);
                    
                }
                
            } catch (\Exception $e) {
                // 回滚事务
                dump($e);
                Db::rollback();
                
            }
        }
    }
    
    /********************************牵手良缘**************************************/
    
    //关系列表
    public function get_relation_list($type){
        $map = [];
        $map[] = ['is_delete', '=', 1];
        $map[] = ['type', '=', $type];
        $list = db::name('relation')->where($map)->field('id, name, day, color')->select();
        
        
        return ['code' => 200, 'msg' => '获取成功', 'data' => $list];
    }
    
    //绑定用户关系
    public function binding_user_relation($uid, $rid, $user_id, $receive_uid, $relation_id){
        $config = get_uncache_system_config();
        
        $user_info = db::name('user')->field('uid')->find($uid);
        if(!$user_info){
            return ['code' => 201, 'msg' => '参数错误', 'data' => null];
        }
        
        $room_info = db::name('room')->find($rid);
        if(!$room_info){
            return ['code' => 201, 'msg' => '该房间不存在', 'data' => null];
        }
        
        // $room_admin_uid_arr = explode(',', $room_info['room_admin_uid']);
        $room_admin_uid_arr = db::name('room_admin')->where('rid', $rid)->where('is_delete', 1)->column('uid');
        if ($uid != $room_info['room_owner_uid'] && $uid != $room_info['room_host_uid']) {
            return ['code' => 201, 'msg' => '无权限操作', 'data' => null];
        }
        
        $relation_info = db::name('relation')->where('is_delete', 1)->find($relation_id);
        if(!$relation_info){
            return ['code' => 201, 'msg' => '该关系不存在', 'data' => null];
        }
        
        //当前是否是第三阶段
        $map = [];
        $map[] = ['rid', '=', $rid];
        $map[] = ['stage', '=', 3];
        $map[] = ['is_delete', '=', 1];
        $room_dating_log = db::name('room_dating_log')->where($map)->find();
        if(!$room_dating_log){
            return ['code' => 201, 'msg' => '当前不是牵手良缘阶段', 'data' => null];
        }
        //计算绑定天数
        $map = [];
        $map[] = ['pid', '=', $room_dating_log['id']];
        $map[] = ['rank_value', '>', 0];
        $user_room_dating_line = db::name('user_room_dating_line')->where($map)->order('rank_value desc')->find();
        $day_num = 0;
        //最低进入私密小屋
        $min_enter_privacy_amount = $config['enter_privacy_room_min_amount'];
        $is_enter_privacy_room = 2;
        if($user_room_dating_line) {
            $relation_min_amount = $config['bind_relation_day_amount'];
            $rank_value = $user_room_dating_line['rank_value'];
            if($rank_value > $relation_min_amount) {
                $day_nums = bcdiv($rank_value, 100, 1);
                $day_num = intval($day_nums);
            }
            
            if($min_enter_privacy_amount <= $rank_value) {
                $is_enter_privacy_room = 1;
            }
        }
        if($relation_id == 36) {
            $day_num = 0;
        }
        
        $now_time = time();
        
        Db::startTrans();
        try {
            if($day_num > 0) {
                //是否已有该关系
                $map = [];
                $map[] = ['uid|receive_uid', '=', $user_id];
                $map[] = ['uid|receive_uid', '=', $receive_uid];
                $map[] = ['relation_id', '=', $relation_id];
                $map[] = ['is_delete', '=', 1];
                $user_relation = db::name('user_relation_binding')->where($map)->find();
                if($user_relation){
                    $update = [];
                    // $update['day'] = $relation_info['day'];
                    $end_time = $user_relation['end_time'] + ($day_num * 60 * 60 * 24);
                    if($end_time < 2129791740){
                        $update['end_time'] = $user_relation['end_time'] + ($day_num * 60 * 60 * 24);
                    }
                    $update['update_time'] = $now_time;
                    $reslut = db::name('user_relation_binding')->where('id', $user_relation['id'])->inc('day', $day_num)->update($update);
                }else{
                    $insert = [];
                    $insert['uid'] = $user_id;
                    $insert['receive_uid'] = $receive_uid;
                    $insert['relation_id'] = $relation_id;
                    $insert['day'] = $day_num;
                    $insert['add_time'] = $now_time;
                    $insert['end_time'] = $now_time + ($day_num * 60 * 60 *24);
                    $reslut = db::name('user_relation_binding')->insert($insert);
                }
                if(!$reslut){
                    Db::rollback();
                    return ['code' => 201, 'msg' => '操作失败7', 'data' => null];
                }
                
                //记录
                $insert = [];
                $insert['uid'] = $user_id;
                $insert['receive_uid'] = $receive_uid;
                $insert['relation_id'] = $relation_id;
                $insert['day'] = $relation_info['day'];
                $insert['add_time'] = $now_time;
                $reslut = db::name('user_relation_binding_log')->insert($insert);
                if(!$reslut){
                    Db::rollback();
                    return ['code' => 201, 'msg' => '操作失败6', 'data' => null];
                }
                
                
                $map = [];
                $map[] = ['uid|receive_uid', '=', $user_room_dating_line['uid']];//需更改help_uid
                $map[] = ['uid|receive_uid', '=', $user_room_dating_line['receive_uid']];
                $map[] = ['r_date', '=', date('Y-m-d')];
                $dating_mt_wheel = db::name('dating_mt_wheel')->where($map)->find(); 
                if(!empty($dating_mt_wheel)){
                    db::name('dating_mt_wheel')->where(['id'=>$dating_mt_wheel['id']])->inc('rank_value', $user_room_dating_line['rank_value'])->update(['update_time'=>time()]);
                }else{
                    //建立关系以后数据存储
                    db::name('dating_mt_wheel')->insert([
                            'uid' => $user_room_dating_line['uid'],
                            'receive_uid' => $user_room_dating_line['receive_uid'],
                            'rank_value' => $user_room_dating_line['rank_value'],
                            'r_date' => date('Y-m-d'),
                            'add_time' => time(),
                            'update_time' => time()
                        ]);              
                }                

            }
            
            
            //结束第三阶段
            $update = [];
            $update['is_delete'] = 2;
            $update['update_time'] = time();
            $reslut = db::name('room_dating_log')->where('id', $room_dating_log['id'])->update($update);
            if(!$reslut){
                Db::rollback();
                return ['code' => 201, 'msg' => '操作失败5', 'data' => null];
            }
            
            //清空麦位
            $map = [];
            $map[] = ['rid', '=', $rid];
            $map[] = ['micro_id', 'in', [1,2,3,4,5,6]];
            $update = [];
            $update['uid'] = 0;
            $update['frame_gid'] = 0;
            $update['centre_gid'] = 0;
            $update['above_gid'] = 0;
            $update['below_gid'] = 0;
            $update['left_gid'] = 0;
            $update['right_gid'] = 0;
            $update['update_time'] = time();
            $reslut = db::name('room_micro')->where($map)->update($update);
            if(!$reslut){
                Db::rollback();
                return ['code' => 201, 'msg' => '操作失败4', 'data' => null];
            }
            if($is_enter_privacy_room == 1) {
                $prid = 0;
                //是否有空闲的私密小屋
                $map = [];
                $map[] = ['is_use', '=', 2];
                $room_privacy = db::name('room_privacy')->where($map)->find();
                if(!empty($room_privacy)){
                    $update = [];
                    $update['rid'] = $rid;
                    $update['uid_data'] = $user_id.','.$receive_uid;
                    $update['is_use'] = 1;
                    $update['update_time'] = $now_time;
                    $update['end_time'] = $now_time + $config['privacy_room_time'];
                    $reslut = db::name('room_privacy')->where('prid', $room_privacy['prid'])->update($update);
                    if(!$reslut){
                        Db::rollback();
                        return ['code' => 201, 'msg' => '操作失败3', 'data' => null];
                    }
                    $prid = $room_privacy['prid'];
                }else{
                    $reslut = $this->create_privacy_room();
                    
                    if($reslut['code'] != 200){
                        Db::rollback();
                        return ['code' => 201, 'msg' => $reslut['msg'], 'data' => null];
                    }
                    $prid = $reslut['data'];
                    
                    $update = [];
                    $update['rid'] = $rid;
                    $update['uid_data'] = $user_id.','.$receive_uid;
                    $update['is_use'] = 1;
                    $update['update_time'] = $now_time;
                    $update['end_time'] = $now_time + $config['privacy_room_time'];
                    $reslut = db::name('room_privacy')->where('prid', $prid)->update($update);
                    if(!$reslut){
                        Db::rollback();
                        return ['code' => 201, 'msg' => '操作失败1', 'data' => null];
                    }
                }
                
                if(empty($prid)){
                    Db::rollback();
                    return ['code' => 201, 'msg' => '操作失败2', 'data' => null];
                }
            }
            
            
            Db::commit();
            model('api/room')->push_room_micro_data($rid);
            if($is_enter_privacy_room == 1) {
                if(!empty($user_id)){
                    $push_send_user_data = [];
                    $push_send_user_data['rid'] = $rid;
                    $push_send_user_data['prid'] = $prid;
                    $push_send_user_data['agora_token'] = model('api/Agora')->agora_token_info($user_id, $prid);
                    $push_send_user_data['agora_app_id'] = $config['agora_app_id'];
                    
                    $push_data = [];
                    $push_data['code'] = 351;
                    $push_data['msg'] = "推送进入私密小屋";
                    $push_data['data'] = $push_send_user_data;
                    model('api/WebSocketPush')->send_to_one($user_id, $push_data);
                }
                
                if(!empty($receive_uid)){
                    $push_send_receive_data = [];
                    $push_send_receive_data['rid'] = $rid;
                    $push_send_receive_data['prid'] = $prid;
                    $push_send_receive_data['agora_token'] = model('api/Agora')->agora_token_info($receive_uid, $prid);
                    $push_send_receive_data['agora_app_id'] = $config['agora_app_id'];
                    
                    $push_data = [];
                    $push_data['code'] = 351;
                    $push_data['msg'] = "推送进入私密小屋";
                    $push_data['data'] = $push_send_receive_data;
                    model('api/WebSocketPush')->send_to_one($receive_uid, $push_data);
                    
                }
            }
            
            
            return ['code' => 200, 'msg' => '操作成功', 'data' => null];
        } catch (\Exception $e) {
            // 回滚事务
            dump($e);
            Db::rollback();
            return ['code' => 201, 'msg' => '操作失败8', 'data' => null];
        }
    }
    
    //结束牵手良缘阶段【重新推送】
    public function end_push_binding_relation($uid, $rid){
        $config = get_uncache_system_config();
        
        $user_info = db::name('user')->field('uid')->find($uid);
        if(!$user_info){
            return ['code' => 201, 'msg' => '参数错误', 'data' => null];
        }
        
        $room_info = db::name('room')->find($rid);
        if(!$room_info){
            return ['code' => 201, 'msg' => '该房间不存在', 'data' => null];
        }
        
        // $room_admin_uid_arr = explode(',', $room_info['room_admin_uid']);
        $room_admin_uid_arr = db::name('room_admin')->where('rid', $rid)->where('is_delete', 1)->column('uid');
        if ($uid != $room_info['room_owner_uid'] && $uid != $room_info['room_host_uid']) {
            return ['code' => 201, 'msg' => '无权限操作', 'data' => null];
        }
        if(empty($room_info['room_host_uid'])){
            return ['code' => 201, 'msg' => '当前没有主持，无法结束', 'data' => null];
        }
        
        //是否已有未结束阶段
        $map = [];
        $map[] = ['rid', '=', $rid];
        $map[] = ['stage', '=', 3];
        $map[] = ['is_delete', '=', 1];
        $room_dating_log = db::name('room_dating_log')->where($map)->find();
        if(!$room_dating_log){
            return ['code' => 201, 'msg' => '当前未有牵手良缘阶段', 'data' => null];
        }
        
        Db::startTrans();
        try {
            $map = [];
            $map[] = ['pid', '=', $room_dating_log['id']];
            $map[] = ['rank_value', '>', 0];
            $user_room_dating_line = db::name('user_room_dating_line')->where($map)->order('rank_value desc')->find();
            if(!empty($user_room_dating_line)){
                
            }else{
                //结束第三阶段
                $update = [];
                $update['is_delete'] = 2;
                $update['update_time'] = time();
                $reslut = db::name('room_dating_log')->where('id', $room_dating_log['id'])->update($update);
                if(!$reslut){
                    Db::rollback();
                    return ['code' => 201, 'msg' => '操作失败', 'data' => null];
                }
                
                //清空麦位
                $map = [];
                $map[] = ['rid', '=', $rid];
                $map[] = ['micro_id', 'in', [1,2,3,4,5,6]];
                $update = [];
                $update['uid'] = 0;
                $update['frame_gid'] = 0;
                $update['centre_gid'] = 0;
                $update['above_gid'] = 0;
                $update['below_gid'] = 0;
                $update['left_gid'] = 0;
                $update['right_gid'] = 0;
                $update['update_time'] = time();
                $reslut = db::name('room_micro')->where($map)->update($update);
                if(!$reslut){
                    Db::rollback();
                    return ['code' => 201, 'msg' => '操作失败', 'data' => null];
                }
            }
            
            Db::commit();
            model('api/room')->push_room_micro_data($rid);
            
            $push_room_dating_data = [];
            if(!empty($user_room_dating_line)){
                $users_info = db::name('user')->where('uid', $user_room_dating_line['uid'])->field('uid,nick_name,base64_nick_name,head_pic,sex')->find();
                $receive_info = db::name('user')->where('uid', $user_room_dating_line['receive_uid'])->field('uid,nick_name,base64_nick_name,head_pic,sex')->find();
                
                $push_room_dating_data['user_info']['uid'] = $user_room_dating_line['uid'];
                $push_room_dating_data['user_info']['nick_name'] = mb_convert_encoding(base64_decode($users_info['base64_nick_name']), 'UTF-8', 'UTF-8');
                $push_room_dating_data['user_info']['head_pic'] = localpath_to_netpath($users_info['head_pic']);
                $push_room_dating_data['user_info']['sex'] = $users_info['sex'];
                $push_room_dating_data['receive_info']['uid'] = $user_room_dating_line['receive_uid'];
                $push_room_dating_data['receive_info']['nick_name'] = mb_convert_encoding(base64_decode($receive_info['base64_nick_name']), 'UTF-8', 'UTF-8');
                $push_room_dating_data['receive_info']['head_pic'] = localpath_to_netpath($receive_info['head_pic']);
                $push_room_dating_data['receive_info']['sex'] = $receive_info['sex'];
                
                $push_data = [];
                $push_data['code'] = 341;
                $push_data['msg'] = "推送主持麦绑定关系";
                $push_data['data'] = $push_room_dating_data;
                model('api/WebSocketPush')->send_to_one($room_info['room_host_uid'], $push_data);
            }
                
            
            return ['code' => 200, 'msg' => '操作成功', 'data' => $push_room_dating_data];
        } catch (\Exception $e) {
            // 回滚事务
            dump($e);
            Db::rollback();
            return ['code' => 201, 'msg' => '操作失败', 'data' => null];
        }
        
    }
    
    
    /************************私密小屋*****************************/
    //真心话大冒险
    public function get_truth_or_dare_list($uid, $prid){
        $room_privacy = db::name('room_privacy')->find($prid);
        if(!$room_privacy){
            return ['code' => 201, 'msg' => '该私密小屋不存在', 'data' => null];
        }
        
        $now_time = time();
        if($room_privacy['is_use'] == 2 || $room_privacy['end_time'] < $now_time){
            return ['code' => 201, 'msg' => '该私密小屋已到期', 'data' => null];
        }
        
        $user_id_data = explode(',', $room_privacy['uid_data']);
        $user_id = $user_id_data[0];
        $receive_uid = $user_id_data[1];
        if(!in_array($uid, $user_id_data)){
            return ['code' => 201, 'msg' => '无权限操作', 'data' => null];
        }
        if($uid == $user_id){
            $push_uid = $receive_uid;
        }else if($uid == $receive_uid){
            $push_uid = $user_id;
        }
        
        $map = [];
        $map[] = ['type', '=', 1];
        $map[] = ['is_delete', '=', 1];
        $info = db::name('topic_card')->where($map)->field('id, type, content')->orderRaw('rand()')->find();
        
        if(!empty($info)){
            $push_topic_card_info = [];
            $push_topic_card_info['id'] = $info['id'];
            $push_topic_card_info['type'] = $info['type'];
            $push_topic_card_info['content'] = $info['content'];
            
            if(!empty($push_uid)){
                $push_data = [];
                $push_data['code'] = 354;
                $push_data['msg'] = "真心话大冒险推送";
                $push_data['data'] = $push_topic_card_info;
                model('api/WebSocketPush')->send_to_one($push_uid, $push_data);
            }
            
        }
        
        return ['code' => 200, 'msg' => '获取成功', 'data' => $info];
    }
    
    //话题卡
    public function get_topic_card_list($uid, $prid){
        $room_privacy = db::name('room_privacy')->find($prid);
        if(!$room_privacy){
            return ['code' => 201, 'msg' => '该私密小屋不存在', 'data' => null];
        }
        
        $now_time = time();
        if($room_privacy['is_use'] == 2 || $room_privacy['end_time'] < $now_time){
            return ['code' => 201, 'msg' => '该私密小屋已到期', 'data' => null];
        }
        
        $user_id_data = explode(',', $room_privacy['uid_data']);
        $user_id = $user_id_data[0];
        $receive_uid = $user_id_data[1];
        if(!in_array($uid, $user_id_data)){
            return ['code' => 201, 'msg' => '无权限操作', 'data' => null];
        }
        if($uid == $user_id){
            $push_uid = $receive_uid;
        }else if($uid == $receive_uid){
            $push_uid = $user_id;
        }
        
        $map = [];
        $map[] = ['type', '=', 2];
        $map[] = ['is_delete', '=', 1];
        $info = db::name('topic_card')->where($map)->field('id, type, content')->orderRaw('rand()')->find();
        if(!empty($info)){
            $push_topic_card_info = [];
            $push_topic_card_info['id'] = $info['id'];
            $push_topic_card_info['type'] = $info['type'];
            $push_topic_card_info['content'] = $info['content'];
            
            if(!empty($push_uid)){
                $push_data = [];
                $push_data['code'] = 354;
                $push_data['msg'] = "话题卡推送";
                $push_data['data'] = $push_topic_card_info;
                model('api/WebSocketPush')->send_to_one($push_uid, $push_data);
            }
            
        }
        return ['code' => 200, 'msg' => '获取成功', 'data' => $info];
    }
    
    //用户关系列表
    public function get_user_relation_list($uid, $user_id, $page, $page_limit){
        $page = intval($page);
        $page_limit = $page_limit < 20 ? $page_limit : 20;
        
        if(empty($user_id)){
            $user_id = $uid;
        }
        
        $user_info = db::name('user')->find($user_id);
        if(!$user_info){
            return ['code' => 201, 'msg' => '参数错误', 'data' => null];
        }
        
        $map = [];
        $map[] = ['a.uid|a.receive_uid', '=', $user_id];
        $map[] = ['a.end_time','>', time()];
        $map[] = ['a.is_delete', '=', 1];
        $list = db::name('user_relation_binding')->alias('a')->join('yy_relation b', 'a.relation_id = b.id')->field('a.id, a.uid, a.receive_uid, a.relation_id, a.end_time, b.name, b.color')->where($map)->order('id desc')->page($page, $page_limit)->select();
        foreach ($list as $k => &$v){
            if($v['uid'] == $user_id){
                $receive_uid = $v['receive_uid'];
            }else if($v['receive_uid'] == $user_id){
                $receive_uid = $v['uid'];
            }
            $receive_info = db::name('user')->field('uid,base64_nick_name,head_pic,sex')->find($receive_uid);
            
            $v['uid'] = $receive_uid;
            $v['nick_name'] = mb_convert_encoding(base64_decode($receive_info['base64_nick_name']), 'UTF-8', 'UTF-8');
            $v['head_pic'] = localpath_to_netpath($receive_info['head_pic']);
            $v['sex'] = $receive_info['sex'];
            $v['surplus_time'] = ceil(($v['end_time'] - time()) / (60*60*24));
            unset($v['receive_uid']);
        }
        
        $data = [];
        $data['list'] = $list;
        $data['count'] = count($list);
        
        return ['code' => 200, 'msg' => '获取成功', 'data'=> $data];
    }
    
    //生成私密小屋
    public function create_privacy_room(){
        $config = get_uncache_system_config();
        
        Db::startTrans();
        try {
            $prid = $this->get_available_prid();
            
            $insert = [];
            $insert['prid'] = $prid;
            $insert['add_time'] = time();
            $reslut = db::name('room_privacy')->insert($insert);
            if(!$reslut){
                Db::rollback();
                return ['code' => 201, 'msg' => '操作失败9', 'data' => null];
            }
            
            //创建腾讯IM群组
            $reslut = model('Tencent')->create_group($prid);
            
            if($reslut['code'] != 200){
                Db::rollback();
                return['code' => 201, 'msg' => $reslut['msg'], 'data' => null];
            }
            
            Db::commit();
            
            return ['code' => 200, 'msg' => '操作成功', 'data' => $prid];
        } catch (\Exception $e) {
            // 回滚事务
            dump($e);
            Db::rollback();
            return ['code' => 201, 'msg' => '操作失败', 'data' => null];
        }
        
    }
    
    
    //过滤私密房间ID
    private function get_available_prid($prid = 0)
    {
        if (empty($prid)) {
            $prid = db::name('room_privacy')->order('prid desc')->value('prid');
            if(empty($prid)){
                $prid = 1000001;
            }
        }
        $prid = $prid + 1;
        $user_info = db::name('room_privacy')->field('prid')->where('prid', $prid)->find();
        if (!empty($user_info)) {
            $this->get_available_prid($user_info['prid']);
        } else {
            return $prid;
        }
    }
    
    //私密小屋详情
    public function get_privacy_room_info($uid, $prid){
        $now_time = time();
        $privacy_room = db::name('room_privacy')->find($prid);
        if(!$privacy_room){
            return ['code' => 201, 'msg' => '该私密小屋不存在', 'data' => null];
        }
        
        if($privacy_room['is_use'] == 2 || $privacy_room['end_time'] < $now_time){
            return ['code' => 201, 'msg' => '该私密小屋已到期', 'data' => null];
        }
        
        $surplus_time = $privacy_room['end_time'] - time();
        $user_id_data = explode(',', $privacy_room['uid_data']);
        $user_id = $user_id_data[0];
        $receive_uid = $user_id_data[1];
        
        $users_info = db::name('user')->field('uid,nick_name,base64_nick_name,head_pic')->find($user_id);
        $receive_info = db::name('user')->field('uid, nick_name, base64_nick_name, head_pic')->find($receive_uid);
        
        $map = [];
        $map[] = ['a.is_delete', '=', 1];
        $map[] = ['b.is_delete', '=', 1];
        $map[] = ['b.is_show', '=', 1];
        $list = db::name('room_privacy_gift')->alias('a')->join('yy_gift b', 'a.gid = b.gid')->field('a.gid,a.duration,b.gift_name,b.base_image,b.gift_price')->where($map)->order('b.gift_price asc')->select();
        foreach ($list as $k => &$v){
            $v['base_image'] = localpath_to_netpath($v['base_image']);
        }
        
        $map = [];
        $map[] = ['type', '=', 1];
        $map[] = ['is_delete', '=', 1];
        $topic_card_info = db::name('topic_card')->where($map)->field('id, type, content')->order('id asc')->find();
        
        
        $data = [];
        $data['surplus_time'] = $surplus_time;
        $data['user_info']['uid'] = $user_id;
        $data['user_info']['nick_name'] = mb_convert_encoding(base64_decode($users_info['base64_nick_name']), 'UTF-8', 'UTF-8');
        $data['user_info']['head_pic'] = localpath_to_netpath($users_info['head_pic']);
        $data['receive_info']['uid'] = $receive_uid;
        $data['receive_info']['nick_name'] = mb_convert_encoding(base64_decode($receive_info['base64_nick_name']), 'UTF-8', 'UTF-8');
        $data['receive_info']['head_pic'] = localpath_to_netpath($receive_info['head_pic']);
        $data['gift_list'] = $list;
        $data['topic_card_info'] = $topic_card_info;
        
        return ['code' => 200, 'msg' => '获取成功', 'data' => $data];
    }
    
    //私密小屋结束
    public function end_room_privacy($uid, $prid){
        $user_info = db::name('user')->field('uid')->find($uid);
        if(!$user_info){
            return ['code' => 201, 'msg' => '参数错误', 'data' => null];
        }
        
        $room_privacy = db::name('room_privacy')->find($prid);
        if(!$room_privacy){
            return ['code' => 201, 'msg' => '该私密小屋不存在', 'data' => null];
        }
        
        $now_time = time();
        if($room_privacy['is_use'] == 2 || $room_privacy['end_time'] < $now_time){
            return ['code' => 201, 'msg' => '该私密小屋已到期', 'data' => null];
        }
        
        $user_id_data = explode(',', $room_privacy['uid_data']);
        $user_id = $user_id_data[0];
        $receive_uid = $user_id_data[1];
        if(!in_array($uid, $user_id_data)){
            return ['code' => 201, 'msg' => '无权限操作', 'data' => null];
        }
        
        Db::startTrans();
        try {
            $update = [];
            $update['rid'] = 0;
            $update['uid_data'] = '';
            $update['is_use'] = 2;
            $update['update_time'] = time();
            $update['end_time'] = 0;
            $reslut = db::name('room_privacy')->where('prid', $prid)->update($update);
            if(!$reslut){
                Db::rollback();
                return ['code' => 201, 'msg' => '操作失败', 'data' => null];
            }
            
            Db::commit();
            
            $push_room_privacy_data = [];
            $push_room_privacy_data['prid'] = $prid;
            
            if(!empty($user_id)){
                $push_data = [];
                $push_data['code'] = 353;
                $push_data['msg'] = "退出私密小屋";
                $push_data['data'] = $push_room_privacy_data;
                model('api/WebSocketPush')->send_to_one($user_id, $push_data);
            }
            
            if(!empty($receive_uid)){
                $push_data = [];
                $push_data['code'] = 353;
                $push_data['msg'] = "退出私密小屋";
                $push_data['data'] = $push_room_privacy_data;
                model('api/WebSocketPush')->send_to_one($receive_uid, $push_data);
            }
            
            return ['code' => 200, 'msg' => '操作成功', 'data' => $push_room_privacy_data];
        } catch (\Exception $e) {
            // 回滚事务
            dump($e);
            Db::rollback();
            return ['code' => 201, 'msg' => '操作失败', 'data' => null];
        }
        
    }
    
    //定时任务关闭到期私密小屋
    public function close_room_privacy_status(){
        //查询即将结束的私密小屋
        $now_time = time();
        $map = [];
        $map[] = ['end_time', '<', $now_time];
        $map[] = ['is_use', '=', 1];
        $list = db::name('room_privacy')->where($map)->select();
        foreach ($list as $k => $v){
            Db::startTrans();
            try {
                $update = [];
                $update['rid'] = 0;
                $update['uid_data'] = '';
                $update['is_use'] = 2;
                $update['update_time'] = time();
                $update['end_time'] = 0;
                $reslut = db::name('room_privacy')->where('prid', $v['prid'])->update($update);
                if(!$reslut){
                    Db::rollback();
                }
                
                $user_id_data = explode(',', $v['uid_data']);
                $user_id = $user_id_data[0];
                $receive_uid = $user_id_data[1];
                
                Db::commit();
                
                $push_room_privacy_data = [];
                $push_room_privacy_data['prid'] = $v['prid'];
                
                if(!empty($user_id)){
                    $push_data = [];
                    $push_data['code'] = 353;
                    $push_data['msg'] = "退出私密小屋";
                    $push_data['data'] = $push_room_privacy_data;
                    model('api/WebSocketPush')->send_to_one($user_id, $push_data);
                }
                
                if(!empty($receive_uid)){
                    $push_data = [];
                    $push_data['code'] = 353;
                    $push_data['msg'] = "退出私密小屋";
                    $push_data['data'] = $push_room_privacy_data;
                    model('api/WebSocketPush')->send_to_one($receive_uid, $push_data);
                }
                
                
            } catch (\Exception $e) {
                // 回滚事务
                Db::rollback();
                
            }
        }
    }
    
    //清除过期关系
    public function close_user_relation(){
        
        $map = [];
        $map[] = ['end_time', '<', time()];
        $map[] = ['is_delete', '=', 1];
        $info = db::name('user_relation_binding')->where($map)->find();
        if(!empty($info)){
            db::name('user_relation_binding')->where($map)->update(['is_delete' => 2, 'update_time' => time()]);
        }
        
        echo date('Y-m-d H:i:s').'清除过期关系  执行成功';
    }
    
    
    public function  del_user_relation($uid,$user_relation_id=0){
        $user_relation_binding  = db::name('user_relation_binding')->where(['id'=>$user_relation_id,"uid|receive_uid"=>$uid])->find();
        if(empty($user_relation_binding)){
             return ['code' => 201, 'msg' => '关系不存在', 'data' => null];
        }
        
        $del_user_relation_money = get_uncache_system_config('del_user_relation_money');
        if($del_user_relation_money <= 0){
             return ['code' => 201, 'msg' => '价格有误!', 'data' => null];
        }
        
        
        $user_zijin = db::name('user')->where(['uid'=>$uid])->field('money')->find();
        if(empty($user_zijin)){
             return ['code' => 201, 'msg' => '参数有误!', 'data' => null];
        } 
        
        if($user_zijin['money'] < $del_user_relation_money){
              return ['code' => 201, 'msg' => '账户余额不足!', 'data' => null];
        }
    
       
        try {
            Db::startTrans();
            $reslut = model('admin/User')->change_user_money_by_uid($uid, -$del_user_relation_money, 1, 53, "删除用户关系", $uid, $user_relation_binding['id']);
            if ($reslut['code'] == 201) {
                Db::rollback();
                return ['code' => 201, 'msg' => $reslut['msg'], 'data' => null];
            } 
            
            
            //删除用户关系
            db::name('user_relation_binding')->where(['id'=>$user_relation_binding['id']])->update(['is_delete' => 2, 'update_time' => time(),'remarks'=>"{$uid}删除用户关系"]);            
            Db::commit();
            return ['code' => 200, 'msg' => '删除成功!', 'data' => null];
        }catch (\Exception $e) {
            // 回滚事务
            Db::rollback();
            return ['code' => 200, 'msg' => '删除失败!', 'data' => null];  
        }
        
    }
    
    
    //房间挂件礼物信息
    public function get_room_pendant_gift_info($uid, $rid){
        $room_info = db::name('room')->field('rid')->find($rid);
        if(!$room_info){
            return ['code' => 201, 'msg' => '该房间不存在', 'data' => null];
        }
        $data = [];
        $data['user_info']['uid'] = 0;
        $data['user_info']['nick_name'] = '';
        $data['user_info']['head_pic'] = '';
        $data['receive_info']['uid'] = 0;
        $data['receive_info']['nick_name'] = '';
        $data['receive_info']['head_pic'] = '';
        
        $map = [];
        $map[] = ['rid', '=', $rid];
        $map[] = ['end_time', '>', time()];
        $map[] = ['is_show', '=', 1];
        $info = db::name('room_pendant_gift_log')->where($map)->order('id desc')->find();
        if($info){
            $user_info = db::name('user')->field('uid, base64_nick_name, head_pic')->find($info['uid']);
            $receive_info = db::name('user')->field('uid, base64_nick_name, head_pic')->find($info['receive_uid']);
            
            $data['user_info']['uid'] = $info['uid'];
            $data['user_info']['nick_name'] = mb_convert_encoding(base64_decode($user_info['base64_nick_name']), 'UTF-8', 'UTF-8');
            $data['user_info']['head_pic'] = localpath_to_netpath($user_info['head_pic']);
            $data['receive_info']['uid'] = $info['receive_uid'];
            $data['receive_info']['nick_name'] = mb_convert_encoding(base64_decode($receive_info['base64_nick_name']), 'UTF-8', 'UTF-8');
            $data['receive_info']['head_pic'] = localpath_to_netpath($receive_info['head_pic']);
            
            $gift_info = db::name('gift')->where('gid', $info['gid'])->find();
            $data['pendant_image'] = localpath_to_netpath($gift_info['pendant_image']);
        }
        
        
        return ['code' => 200, 'msg' => '获取成功', 'data' => $data];
    }
    
    
     public function get_motian_rank($type=1){
        if($type == 1){
              $r_date =  date('Y-m-d', strtotime('-1 day'));
              $limit = 5;       
        }else{
              $r_date =  date('Y-m-d');
              $limit = 20;               
        }
        
        $list = db::name('dating_mt_wheel')
               ->alias('dw')     
               ->where(['r_date'=>$r_date])
               ->join('yy_user u1','u1.uid = dw.uid')
               ->join('yy_user u2','u2.uid = dw.receive_uid')
               ->field('dw.uid,u1.base64_nick_name as nick_name,u1.head_pic,dw.receive_uid,u2.base64_nick_name as receive_nick_name,u2.head_pic as receive_head_pic,rank_value')
               ->order(['rank_value'=>'desc'])
               ->limit(0,$limit)
               ->select();   
        if(!empty($list)){
            foreach ($list as &$v){
                $v['nick_name'] = mb_convert_encoding(base64_decode($v['nick_name']), 'UTF-8', 'UTF-8');
                $v['head_pic'] = localpath_to_netpath($v['head_pic']);    
                
                $v['receive_nick_name'] = mb_convert_encoding(base64_decode($v['receive_nick_name']), 'UTF-8', 'UTF-8');
                $v['receive_head_pic'] = localpath_to_netpath($v['receive_head_pic']);  
                if($v['rank_value'] >= 1000){
                    $v['rank_value'] = del_coin_num($v['rank_value']/1000,1).'k';
                }elseif ($v['rank_value'] >= 10000) {
                    $v['rank_value'] = del_coin_num($v['rank_value']/10000,1).'w';
                }
                
            }            
        }       
       return ['code' => 200, 'msg' => '获取成功', 'data' => $list];
    }   
    
    
}