im加前缀，去掉用不到的im接口

application/api/controller/Tenim.php

@@ -0,0 +1,1166 @@
+<?php
+
+namespace app\api\controller;
+
+use app\common\controller\Api;
+use app\utils\RedisUtil;
+use think\Request;
+use getusersig\Getusersig;
+use tencentim\Tencentim;
+use think\Db;
+
+/**
+ * 腾讯im接口
+ */
+class Tenim extends Api
+{
+    protected $noNeedLogin = ['trtc_callback','callback','test','createIMGroup','updateRoomInfo','setImManage','sendMessageToUser','outMemberFromRoom','selectstatus','loginoutim', 'tencentcall'];
+    protected $noNeedRight = ['*'];
+
+
+    public function test() {
+        $groupinfo = $this->getGroupInfo("112");
+        print_r($groupinfo);
+        exit;
+        // 获取所有派对信息
+        $partyList = \app\common\model\Party::field("id,user_id,party_name")->where(["status"=>1])->order("id","asc")->select();
+        foreach($partyList as $k => $v) {
+            if($k>=140 && $k<180) {
+                $groupinfo = $this->getGroupInfo((string)$v["id"]);
+                print_r($groupinfo);
+//                $groupinfo = json_encode($groupinfo);
+//                Db::table("hx_aaaa")->insert(["party_id"=>$v["id"],"user_id"=>$v["user_id"],"party_name"=>$v["party_name"],"json"=>$groupinfo]);
+            }
+
+        }
+exit;
+//        $this->success("",$partyList);
+    }
+
+    public function loginoutim($uid){
+        /*
+         * https://console.tim.qq.com/v4/im_open_login_svc/kick?sdkappid=88888888&identifier=admin&usersig=xxx&random=99999999&contenttype=json
+         */
+        $random = rand(10000000, 99999999);
+        $usersig = $this->usersig("administrator");
+        // 获取配置信息
+        $config = config("tencent_im");
+        $url = "https://console.tim.qq.com/v4/im_open_login_svc/kick";
+        $url .= "?sdkappid=" . $config["sdkappid"];
+        $url .= "&identifier=administrator";
+        $url .= "&usersig=" . $usersig;
+        $url .= "&random=" . $random;
+        $url .= "&contenttype=json";
+
+        $data = [
+            'Identifier' => "".$uid."",
+        ];
+
+        $rs = curl_post($url,json_encode($data));
+        //dump($rs);
+//        exit;
+
+    }
+    public function selectstatus(){
+        /*
+         * https://console.tim.qq.com/v4/openim/query_online_status?sdkappid=88888888&identifier=admin&usersig=xxx&random=99999999&contenttype=json
+         */
+        $random = rand(10000000, 99999999);
+        $usersig = $this->usersig("administrator");
+        // 获取配置信息
+        $config = config("tencent_im");
+        $url = "https://console.tim.qq.com/v4/openim/query_online_status";
+        $url .= "?sdkappid=" . $config["sdkappid"];
+        $url .= "&identifier=administrator";
+        $url .= "&usersig=" . $usersig;
+        $url .= "&random=" . $random;
+        $url .= "&contenttype=json";
+
+        $data = [
+            'To_Account' => ["34"],
+        ];
+
+        $rs = curl_post($url,json_encode($data));
+        //$rs = curl_post($url,'{"IsNeedDetail":1,"To_Account":["32"]}');
+        dump($rs);
+        exit;
+
+    }
+
+    /**
+     * 创建im群组
+     */
+    public function createIMGroup() {
+
+
+
+        $random = rand(10000000,99999999);
+        $usersig = $this->usersig("administrator");
+        // 获取配置信息
+        $config = config("tencent_im");
+        $url = "https://console.tim.qq.com/v4/group_open_http_svc/create_group";
+        $url .= "?sdkappid=".$config["sdkappid"];
+        $url .= "&identifier=administrator";
+        $url .= "&usersig=".$usersig;
+        $url .= "&random==".$random;
+        $url .= "&contenttype=json";
+        $tencentObj = new tencentim($url);
+
+        // 获取群im信息
+        $imInfo = Db::table("hx_aaaa")->where(["party_id"=>112])->select();
+        if($imInfo) foreach($imInfo as $k => $v) {
+//            if($k>=160 && $k<200) {
+                $grouparr = json_decode($v["json"], true);
+
+                $grouparr = $grouparr["GroupInfo"][0];
+                $AppDefinedData = $grouparr["AppDefinedData"];
+                $data = [];
+                $data["Owner_Account"] = (string)$v["user_id"];
+                $data["Type"] = "AVChatRoom";
+                $data["GroupId"] = (string)$v["party_id"];
+                $data["Name"] = $this->substr((string)$v["party_name"],0,7);
+                $AppDefinedDataNew = [
+                    [
+                        "Key" => "roomInfo",
+                        "Value" => "sssssss"
+                    ],
+                    [
+                        "Key" => "seat0",
+                        "Value" => '{"mute":false,"status":0,"user":""}'
+                    ],
+                    [
+                        "Key" => "seat1",
+                        "Value" => $AppDefinedData[2]["Value"]
+                    ],
+                    [
+                        "Key" => "seat2",
+                        "Value" => $AppDefinedData[3]["Value"]
+                    ],
+                    [
+                        "Key" => "seat3",
+                        "Value" => $AppDefinedData[4]["Value"]
+                    ],
+                    [
+                        "Key" => "seat4",
+                        "Value" => $AppDefinedData[5]["Value"]
+                    ],
+                    [
+                        "Key" => "seat5",
+                        "Value" => $AppDefinedData[6]["Value"]
+                    ],
+                    [
+                        "Key" => "seat6",
+                        "Value" => $AppDefinedData[7]["Value"]
+                    ],
+                    [
+                        "Key" => "seat7",
+                        "Value" => $AppDefinedData[8]["Value"]
+                    ],
+                    [
+                        "Key" => "seat8",
+                        "Value" => $AppDefinedData[9]["Value"]
+                    ]
+                ];
+                $data["AppDefinedData"] = json_encode($AppDefinedDataNew);
+
+                $groupInfo = $tencentObj->toSend($data);
+
+                if($groupInfo["ActionStatus"] != 'OK') {
+                    echo $v["party_id"];
+                    break;
+                }
+//            }
+        }
+
+        print_r($groupInfo);exit;
+    }
+
+    public function substr(string $string, int $start, int $length = null)
+    {
+        return mb_substr($string, $start, $length, 'UTF-8');
+    }
+
+
+    /**
+     * 更新房间信息
+     */
+    public function updateRoomInfo() {
+        $random = rand(10000000, 99999999);
+        $usersig = $this->usersig("administrator");
+        // 获取配置信息
+        $config = config("tencent_im");
+        $url = "https://console.tim.qq.com/v4/group_open_http_svc/modify_group_base_info";
+        $url .= "?sdkappid=" . $config["sdkappid"];
+        $url .= "&identifier=administrator";
+        $url .= "&usersig=" . $usersig;
+        $url .= "&random=" . $random;
+        $url .= "&contenttype=json";
+        $tencentObj = new tencentim($url);
+
+        // 获取群im信息
+        $imInfo = Db::table("hx_aaaa")->select();
+        if($imInfo) foreach($imInfo as $k => $v) {
+            if($k>=120 && $k<180) {
+                $grouparr = json_decode($v["json"], true);
+                $groupsites = $grouparr["GroupInfo"];
+
+                // 循环房间
+                if ($groupsites) foreach ($groupsites as $k => $v) {
+                    // 循环座位
+                    $data = [];
+                    foreach ($v["AppDefinedData"] as $m => $n) {
+                        // 解析字段信息
+                        $siteInfo = json_decode($n["Value"], true);
+                        $data["AppDefinedData"][] = [
+                            "Key" => $n["Key"],
+                            "Value" => $n["Value"],
+                        ];
+
+                    }
+                    if (!empty($data)) {
+                        $data["GroupId"] = $v["GroupId"];
+                        $res = $tencentObj->toSend($data);
+                    } else {
+                        echo "error!";
+                        break;
+                    }
+                }
+            }
+        }
+        print_r($res);
+        exit;
+    }
+
+    /**
+     * 获取群组信息
+     */
+    public function getGroupInfo($party_id) {
+        $random = rand(10000000,99999999);
+        $usersig = $this->usersig("administrator");
+        // 获取配置信息
+        $config = config("tencent_im");
+        $url = "https://console.tim.qq.com/v4/group_open_http_svc/get_group_info";
+        $url .= "?sdkappid=".$config["sdkappid"];
+        $url .= "&identifier=administrator";
+        $url .= "&usersig=".$usersig;
+        $url .= "&random==".$random;
+        $url .= "&contenttype=json";
+        $tencentObj = new tencentim($url);
+        $data = [];
+        $data["GroupIdList"] = [$party_id];
+        $data["ResponseFilter"] = ["AppDefinedDataFilter_Group"=>[]];
+        $groupInfo = $tencentObj->toSend($data);
+        return $groupInfo;
+    }
+
+    /**
+     * 获取用户所加入的群组
+     */
+    public function getJoindGroupList($user_id) {
+        $random = rand(10000000,99999999);
+        $usersig = $this->usersig("administrator");
+        // 获取配置信息
+        $config = config("tencent_im");
+        $url = "https://console.tim.qq.com/v4/group_open_http_svc/get_joined_group_list";
+        $url .= "?sdkappid=".$config["sdkappid"];
+        $url .= "&identifier=administrator";
+        $url .= "&usersig=".$usersig;
+        $url .= "&random=".$random;
+        $url .= "&contenttype=json";
+
+        $tencentObj = new tencentim($url);
+        $data = [];
+        $data["Member_Account"] = $user_id;
+        $data["WithHugeGroups"] = 1;
+        $data["GroupType"] = 'AVChatRoom';
+        $data["ResponseFilter"] = ["GroupBaseInfoFilter" => ['GroupId'] ];
+        $groupInfo = $tencentObj->toSend($data);
+//        \app\common\model\Test::update(["content"=>json_encode($groupInfo)],["id"=>1]);
+        return $groupInfo;
+    }
+//"https:\/\/console.tim.qq.com\/v4\/group_open_http_svc\/get_joined_group_list?sdkappid=1400458032&identifier=administrator&usersig=eJyrVgrxCdYrSy1SslIy0jNQ0gHzM1NS80oy0zLBwqamUNHilOzEgoLMFCUrQxMDAxNTCwNjI4hMakVBZlEqUNzU1NTIwMAAIlqSmQsSMzO0MDY0NDOwhJqSmQ40NNwowsvMzzXKw8wsLNIwRr9S28giPKjMPSkpKLPcLcfFPd3TO7swz9fXOdLTVqkWADrXLzo_&random=73931990&contenttype=json"
+//    /**
+//     * 删除群成员
+//     */
+//    public function delMemberFromGroup($user_id,$party_id) {
+//        $random = rand(10000000,99999999);
+//        $usersig = $this->usersig($user_id);
+//        // 获取配置信息
+//        $config = config("tencent_im");
+//        $url = "https://console.tim.qq.com/v4/group_open_http_svc/delete_group_member";
+//        $url .= "?sdkappid=".$config["sdkappid"];
+//        $url .= "&identifier=administrator";
+//        $url .= "&usersig=".$usersig;
+//        $url .= "&random=".$random;
+//        $url .= "&contenttype=json";
+//        $tencentObj = new tencentim($url);
+//        $data = [];
+//        $data["GroupId"] = $party_id;
+//        $data["Silence"] = 1;
+//        $data["MemberToDel_Account"] = [$user_id];
+//        $res = $tencentObj->toSend($data);
+//        \app\common\model\Test::update(["content"=>json_encode($res)],["id"=>1]);
+//        return $res;
+//    }
+
+    /**
+     * 设置管理员(自定义消息)
+     */
+    public function setImManage($manage_user_id,$party_id,$status=0) {
+        $random = rand(10000000,99999999);
+        $usersig = $this->usersig("administrator");
+        // 获取配置信息
+        $config = config("tencent_im");
+        $url = "https://console.tim.qq.com/v4/group_open_http_svc/modify_group_base_info";
+        $url .= "?sdkappid=".$config["sdkappid"];
+        $url .= "&identifier=administrator";
+        $url .= "&usersig=".$usersig;
+        $url .= "&random=".$random;
+        $url .= "&contenttype=json";
+        $tencentObj = new tencentim($url);
+        // 获取群组信息
+        $groupInfo = $this->getGroupInfo($party_id);
+        if($groupInfo["GroupInfo"][0]["ErrorCode"] > 0) return false;
+        $roomInfoData = $groupInfo["GroupInfo"][0]["AppDefinedData"];
+        $roomInfo = [];
+        if($roomInfoData) foreach($roomInfoData as $k => $v) {
+            if($v["Key"] == "roomInfo") $roomInfo = $v["Value"];
+        }
+        $roomInfo = json_decode($roomInfo,true);
+        // 更新的信息
+        if(isset($roomInfo["managers"])) {
+            if(!$roomInfo["managers"]) $roomInfo["managers"] = [];
+        }
+        if ($status==1){
+            array_push($roomInfo["managers"],$manage_user_id);
+            $roomInfo["managers"] = array_unique($roomInfo["managers"]);
+        }else{
+            foreach ($roomInfo["managers"] as $k => $v){
+                if ($v == $manage_user_id) {
+                    unset($roomInfo["managers"][$k]);
+                    break;
+                }
+            }
+        }
+
+        $data = [];
+        $data["GroupId"] = $party_id;
+        $data["AppDefinedData"][0] = [
+            "Key" => "roomInfo",
+            "Value" => json_encode($roomInfo),
+//            "Value" => json_encode(json_decode('{"bg":"","cover":"","isScreen":0,"managers":["14","29"],"needRequest":0,"onMode":2,"ownerId":"55","ownerName":"过户手续","pwd":"","roomName":"告白气球~满眼是✨✨","seatSize":9,"silencers":[]}',true)),
+        ];
+        if(isset($roomInfo["ownerId"]) && isset($roomInfo["roomName"])) {
+            $tencentObj->toSend($data);
+        }
+
+    }
+    /**
+     * 强制下线
+     */
+    public function downSite($user_id,$groupsites) {
+        $random = rand(10000000,99999999);
+        $usersig = $this->usersig("administrator");
+        // 获取配置信息
+        $config = config("tencent_im");
+        $url = "https://console.tim.qq.com/v4/group_open_http_svc/modify_group_base_info";
+        $url .= "?sdkappid=".$config["sdkappid"];
+        $url .= "&identifier=administrator";
+        $url .= "&usersig=".$usersig;
+        $url .= "&random=".$random;
+        $url .= "&contenttype=json";
+        $tencentObj = new tencentim($url);
+
+        // 先更新下麦时间
+        $update = [];
+        $update["offsite_time"] = time();
+        $update["status"] = 2;
+        \app\common\model\UserOnsiteTime::update($update,["user_id"=>$user_id,"status"=>1]);
+
+        // 循环房间
+        if($groupsites) foreach($groupsites as $k => $v) {
+            // 循环座位
+            $data = [];
+            foreach($v["AppDefinedData"] as $m => $n) {
+                // 解析字段信息
+                $siteInfo = json_decode($n["Value"],true);
+                if($m != 0 && isset($siteInfo["status"]) && $siteInfo["status"] == 1 && isset($siteInfo["status"]) && $siteInfo["user"] == $user_id) {
+                    $data["AppDefinedData"][] = [
+                        "Key" => $n["Key"],
+                        "Value" => '{"mute":false,"status":0,"user":""}',
+                    ];
+                }
+            }
+            if(!empty($data)) {
+                $data["GroupId"] = $v["GroupId"];
+                return $tencentObj->toSend($data);
+            }
+        }
+    }
+
+    /**
+     * 踢出房间内所有用户
+     */
+    public function outMemberFromRoom($party_id) {
+        if($party_id <= 0) return false;
+        $message = [];
+        $message["type"] = "91";
+        $message["content"] = "房间已被管理员关闭！详情请联系客服！";
+
+        $msgData = [];
+        $msgData["version"] = "1.0";
+        $msgData["action"] = 301;
+        $msgData["command"] = "";
+        $msgData["message"] = json_encode($message);
+
+
+        $random = rand(10000000,99999999);
+        $usersig = $this->usersig("administrator");
+        // 获取配置信息
+        $config = config("tencent_im");
+        $url = "https://console.tim.qq.com/v4/group_open_http_svc/send_group_msg";
+        $url .= "?sdkappid=".$config["sdkappid"];
+        $url .= "&identifier=administrator";
+        $url .= "&usersig=".$usersig;
+        $url .= "&random=".$random;
+        $url .= "&contenttype=json";
+        $tencentObj = new tencentim($url);
+
+        $data = [];
+        $data["GroupId"] = $party_id;
+        $data["Random"] = rand(1000000,9999999);
+
+        $data["MsgBody"][] = [
+            "MsgType" => "TIMCustomElem",
+            "MsgContent" => [
+                "Data"=> json_encode($msgData)
+            ],
+        ];
+        $tencentObj->toSend($data);
+    }
+
+    /**
+     * 获取usersig签名
+     */
+    public function getUsersig() {
+        $user_id = $this->auth->id;
+        $this->success("获取成功！",$this->usersig($user_id));
+    }
+
+
+    /**
+     * 获取usersig签名-具体操作
+     */
+    private function usersig($user_id) {
+        // 获取配置信息
+        $config = config("tencent_im");
+        $usersigObj = new getusersig($config["sdkappid"],$config["key"]);
+        $usersig = $usersigObj->genUserSig($user_id);
+        return $usersig;
+    }
+
+
+    /**
+     * 强制下麦
+     */
+    public function updateSiteInfo() {
+        $user_id = $this->request->request("user_id");// 用户ID
+        if(!$user_id) $this->error("参数缺失！");
+
+        // 更新用户在线状态为离线
+        \app\common\model\User::update(["is_online"=>0],["id"=>$user_id]);
+//        \app\common\model\User::update(["is_live"=>0],["id"=>$user_id]);
+        \app\common\model\Party::update(["is_online"=>0],["user_id"=>$user_id]);
+
+        // 获取用户所在群信息
+        $groupids = $this->getJoindGroupList($user_id);
+
+        if($groupids["ErrorCode"] == 0) {
+            $grouplist = $groupids["GroupIdList"];
+            $groupsites = [];
+            if($grouplist) foreach($grouplist as $k => $v) {
+                // 获取群组消息
+                $groupInfo = $this->getGroupInfo($v["GroupId"]);
+
+                if($groupInfo["ErrorCode"] == 0) $groupsites[] = $groupInfo["GroupInfo"][0];
+
+                // 踢出用户在线组
+                RedisUtil::getInstance('online',$v["GroupId"])->HDel($user_id);
+            }
+            // 强制下麦
+            $this->downSite($user_id,$groupsites);
+        }
+
+        $this->success("状态更新成功！");
+
+    }
+
+    /**
+     * 更新麦位前四
+     */
+    public function updatePosition($user_id,$party_id) {
+        // 获取用户头像
+        $userInfo = \app\common\model\User::field("avatar")->where(["id"=>$user_id])->find();
+        $userAvatar = isset($userInfo["avatar"])?$userInfo["avatar"]:"";
+
+        $redisData = RedisUtil::getInstance('party',$party_id)->get();
+        if(!$redisData) {
+            return true;
+        }
+        $partyInfo = json_decode($redisData,true);
+
+        // 遍历已有头像
+        $partyuser = isset($partyInfo["party_user"])?$partyInfo["party_user"]:"";
+        if(is_array($partyuser)) foreach($partyuser as $k => $v) if($v === $userAvatar) unset($partyInfo["party_user"][$k]);
+
+        RedisUtil::getInstance('party',$party_id)->set(json_encode($partyInfo));
+    }
+
+
+    /**
+     * 取消排麦
+     */
+    public function cancelLineUp($user_id,$party_id) {
+        if (!$party_id || !$user_id) {
+            return false;
+        }
+        $data=unserialize(RedisUtil::getInstance('party_lineup')->hGet($party_id));
+        // 更改红点排麦数量
+        $num = 0;
+        $send = false;
+        if($data) foreach($data as $k => $v) {
+            if($v["user_id"] == $user_id) {
+                $send = true;
+                unset($data[$k]);
+                break;
+            }
+        }
+        RedisUtil::getInstance('party_lineup')->hSet($party_id,serialize($data));
+
+        if($send) {
+            is_array($data) &&  $num = count($data);
+
+            $random = rand(10000000,99999999);
+            $usersig = $this->usersig("administrator");
+            // 获取配置信息
+            $config = config("tencent_im");
+            $url = "https://console.tim.qq.com/v4/group_open_http_svc/send_group_msg";
+            $url .= "?sdkappid=".$config["sdkappid"];
+            $url .= "&identifier=administrator";
+            $url .= "&usersig=".$usersig;
+            $url .= "&random=".$random;
+            $url .= "&contenttype=json";
+            $tencentObj = new tencentim($url);
+
+            $data = [];
+            $data["GroupId"] = $party_id;
+            $data["Random"] = rand(1000000,9999999);
+            $message = [
+                "message" => json_encode(["type"=>23,"content"=>$num]),
+                "version" => "1.0",
+                "action" => 301,
+                "command" => ""
+            ];
+            $data["MsgBody"][] = [
+                "MsgType" => "TIMCustomElem",
+                "MsgContent" => [
+                    "Data"=> json_encode($message)
+                ],
+            ];
+            $tencentObj->toSend($data);
+        }
+
+    }
+
+    //trtc_callback,直播callback
+    //https://cloud.tencent.com/document/product/647/51586#eventId
+    /*
+     2021-12-24 15:34:22 start2:{
+            "EventGroupId":	1,
+            "EventType":	103,
+            "CallbackTs":	1640331262241,
+            "EventInfo":	{
+                "RoomId":	1604,
+                "EventTs":	1640331262,
+                "EventMsTs":	1640331262238,
+                "UserId":	"26",
+                "Role":	20,
+                "TerminalType":	2,
+                "UserType":	3,
+                "Reason":	1
+            }
+        }
+        2021-12-24 15:34:22 start2:{
+            "EventGroupId":	1,
+            "EventType":	101,
+            "CallbackTs":	1640331262247,
+            "EventInfo":	{
+                "RoomId":	1604,
+                "EventTs":	1640331262,
+                "EventMsTs":	1640331262238,
+                "UserId":	"26"
+            }
+        }
+        2021-12-24 15:34:55 start2:{
+            "EventGroupId":	1,
+            "EventType":	102,
+            "CallbackTs":	1640331295244,
+            "EventInfo":	{
+                "RoomId":	1604,
+                "EventTs":	1640331295,
+                "EventMsTs":	1640331295239
+            }
+        }
+        2021-12-24 15:34:55 start2:{
+            "EventGroupId":	1,
+            "EventType":	104,
+            "CallbackTs":	1640331295244,
+            "EventInfo":	{
+                "RoomId":	1604,
+                "EventTs":	1640331295,
+                "EventMsTs":	1640331295239,
+                "UserId":	"26",
+                "Role":	20,
+                "Reason":	1
+            }
+        }
+     */
+    public function trtc_callback(){
+
+        $input = file_get_contents("php://input");
+        filePut('start:'.$input,'callback.txt');
+
+        /*$input = '{
+            "EventGroupId":	1,
+            "EventType":	104,
+            "CallbackTs":	1640331295244,
+            "EventInfo":	{
+                "RoomId":	1604,
+                "EventTs":	1640331295,
+                "EventMsTs":	1640331295239,
+                "UserId":	"26",
+                "Role":	20,
+                "Reason":	1
+            }
+        }';*/
+
+        $input = json_decode($input,true);
+        $roomId = $input['EventInfo']['RoomId'];
+        //房间事件组
+        if($input['EventGroupId'] == 1){
+            if($input['EventType'] == 101){
+                //创建房间,第一个进来的
+            }elseif($input['EventType'] == 102){
+                //解散房间,最后一个走的
+                //没有UserId
+            }elseif($input['EventType'] == 103){
+                //进入房间,主播role=20 观众role=21
+                $userId = $input['EventInfo']['UserId'];
+                RedisUtil::getInstance('online',$roomId)->hSet($userId, $userId);
+
+                // 记录在线用户在房间情况
+                RedisUtil::getInstance('livingUser')->hSet($userId,$roomId);
+
+                // 更新房间在线状态
+                $partyInfo = $redis->get("party_" . $roomId);
+                if ($partyInfo) {
+                    $partyInfo = json_decode($partyInfo, true);
+                    if ($partyInfo["is_online"] != 1) {
+                        $partyInfo["is_online"] = 1;
+                        $redis->set("party_" . $roomId, json_encode($partyInfo));
+                        \app\common\model\Party::update(["is_online" => 1], ["id" => $roomId]);
+                    }
+                }
+
+                // 更新房间在线状态
+                $liveInfo = $redis->get("livebc_" . $roomId);
+                if ($liveInfo) {
+                    $liveInfo = json_decode($liveInfo, true);
+                    if ($input['EventInfo']['Role'] == 20) {
+                        $liveInfo["is_online"] = 1;
+                        $redis->set("livebc_" . $roomId, json_encode($liveInfo));
+                        \app\common\model\Party::update(["is_online" => 1], ["id" => $roomId]);
+                        $rs_user = Db::name('user')->where('id',$userId)->update(['is_livebc'=>1]);
+                    }
+                }
+
+            }elseif($input['EventType'] == 104){
+                //退出房间,主播role=20 观众role=21
+                $userId = $input['EventInfo']['UserId'];
+                RedisUtil::getInstance('online',$roomId)->HDel($userId);
+
+                // 扣除在线用户在房间情况
+                RedisUtil::getInstance('livingUser')->hDel($userId);
+
+                // 更新房间在线状态
+                $partyInfo = RedisUtil::getInstance('party',$roomId)->get();
+                if ($partyInfo) {
+                    $partyInfo = json_decode($partyInfo, true);
+                    $memCount = count(RedisUtil::getInstance('online',$roomId)->hGetAll());
+                    if ($memCount <= 0) {
+                        $partyInfo["is_online"] = 0;
+                        RedisUtil::getInstance('party',$roomId)->set(json_encode($partyInfo));
+                        \app\common\model\Party::update(["is_online" => 0], ["id" => $roomId]);
+                    }
+                }
+                //
+                $liveInfo = RedisUtil::getInstance('livebc',$roomId)->get();
+                if ($liveInfo) {
+                    $liveInfo = json_decode($liveInfo, true);
+                    if($input['EventInfo']['Role'] == 20){
+                        $liveInfo["is_online"] = 0;
+                        RedisUtil::getInstance('livebc',$roomId)->set(json_encode($liveInfo));
+                        \app\common\model\Party::update(["is_online" => 0], ["id" => $roomId]);
+                        $rs_user = Db::name('user')->where('id',$userId)->update(['is_livebc'=>0]);
+                    }
+                }
+
+            }
+        }elseif($input['EventGroupId'] == 2){
+
+        }
+
+        //结束
+        echo json_encode(['code' => 0]);exit;
+    }
+
+    /**
+     * 回调
+     */
+    public function callback() {
+        $input = file_get_contents("php://input"); // 主题信息
+        if(!$input)  {
+            echo '无数据';exit;
+        }
+        $input = json_decode($input,true);
+        $CallbackCommand = $input["CallbackCommand"];
+        switch ($CallbackCommand) {
+            case 'State.StateChange': // 用户在线状态变更
+                $info = $input["Info"];
+                if($info["Action"] == "Login") { // 用户登录
+                    $loginToday = Db::name('user')->where('id',$info["To_Account"])->whereTime('onlinetime', 'today')->find();
+                    if ($loginToday){
+                        \app\common\model\User::update(["is_online"=>1,"onlinetime"=>time()],["id"=>$info["To_Account"]]);
+                    }else{
+                        \app\common\model\User::update(["is_online"=>1,"onlinetime"=>time()],["id"=>$info["To_Account"]]);
+                    }
+
+                    $res = [];
+                    $res["ActionStatus"] = "OK";
+                    $res["ErrorCode"] = 0;
+                    $res["ErrorInfo"] = "";
+                    echo json_encode($res);exit;
+                } elseif($info["Action"] == "Logout" || $info["Action"] == "Disconnect") { // 用户退出 不需要管什么原因
+                    // 更新用户在线状态为离线
+                    $updateData['is_online'] = 0;
+                    $user = Db::name('user')->where('id',$info["To_Account"])->find();
+                    if (!empty($user)) {
+                        // 客户觉得实时判断导致在线用户数量过少，此处，不再根据IM处理用户在线状态，已在API父类中做接口访问频率处理用户在线状态
+                        // if ($user['gender'] == 1) {
+                        //     $updateData['is_active'] = 0;
+                        // }
+                    }
+                    \app\common\model\User::update($updateData,["id"=>$info["To_Account"]]);
+                    //\app\common\model\User::update(["is_live"=>0],["id"=>$info["To_Account"]]);
+
+                    // 获取用户在派对直播间情况信息
+                    $livingUserPartyId = RedisUtil::getInstance('livingUser')->hGet($info["To_Account"]);
+                    if ($livingUserPartyId) {
+                        // 扣除在线用户在房间情况
+                        RedisUtil::getInstance('livingUser')->hDel( $info["To_Account"]);
+                        RedisUtil::getInstance('online',$livingUserPartyId)->HDel($info["To_Account"]);
+                    }
+
+                    // 获取用户所在群信息
+                    $groupids = $this->getJoindGroupList($info["To_Account"]);
+//                    \app\common\model\Test::update(["content"=>json_encode($groupids)],["id"=>1]);
+                    if($groupids["ErrorCode"] == 0) {
+                        $grouplist = $groupids["GroupIdList"];
+                        $groupsites = [];
+                        if($grouplist) foreach($grouplist as $k => $v) {
+                            // 获取群组消息
+                            $groupInfo = $this->getGroupInfo($v["GroupId"]);
+
+                            if($groupInfo["ErrorCode"] == 0) $groupsites[] = $groupInfo["GroupInfo"][0];
+
+                            // 踢出用户在线组
+                            RedisUtil::getInstance('online',$v["GroupId"])->HDel($info["To_Account"]);
+
+                            // 更新麦位前四
+                            $this->updatePosition($info["To_Account"],$v["GroupId"]);
+
+                            // 取消排麦
+                            $this->cancelLineup($info["To_Account"],$v["GroupId"]);
+
+                            // 房间状态变更
+                            $partyInfo = RedisUtil::getInstance('party',$v["GroupId"])->get();
+                            if($partyInfo) {
+                                $partyInfo = json_decode($partyInfo,true);
+                                $memCount = count(RedisUtil::getInstance('online',$v["GroupId"])->hGetAll());
+                                if($memCount <= 0) {
+                                    $partyInfo["is_online"] = 0;
+                                    RedisUtil::getInstance('party',$v["GroupId"])->set(json_encode($partyInfo));
+                                    \app\common\model\Party::update(["is_online"=>0],["id"=>$v["GroupId"]]);
+                                }
+                            }
+
+                            $liveInfo = RedisUtil::getInstance('live',$v["GroupId"])->get();
+                            if($liveInfo) {
+                                $liveInfo = json_decode($liveInfo,true);
+                                $memCount = count(RedisUtil::getInstance('online',$v["GroupId"])->hGetAll());
+                                if($memCount <= 0) {
+                                    $liveInfo["is_online"] = 0;
+                                    RedisUtil::getInstance('live',$v["GroupId"])->set(json_encode($liveInfo));
+                                    \app\common\model\Party::update(["is_online"=>0],["id"=>$v["GroupId"]]);
+                                }
+                            }
+                        }
+                        // 强制下麦
+                        print_r($this->downSite($info["To_Account"],$groupsites));
+
+                    }
+
+                }
+                break;
+//            case 'Group.CallbackAfterNewMemberJoin': // 新成员入群
+//                $members = $input["NewMemberList"];
+//                if($members) foreach($members as $k => $v) {
+//                    RedisUtil::getInstance('online',$input["GroupId"])->hSet($v["Member_Account"],$v["Member_Account"]);
+//                    // 更新房间在线状态
+//                    $party_id = $input["GroupId"];
+//                    $partyInfo = $redis->get("party_".$party_id);
+//                    if($partyInfo) {
+//                        $partyInfo = json_decode($partyInfo,true);
+//                        if($partyInfo["is_online"] != 1) {
+//                            $partyInfo["is_online"] = 1;
+//                            $redis->set("party_".$party_id,json_encode($partyInfo));
+//                            \app\common\model\Party::update(["is_online"=>1],["id"=>$party_id]);
+//                        }
+//                    }
+//                }
+//                $res = [];
+//                $res["ActionStatus"] = "OK";
+//                $res["ErrorCode"] = 0;
+//                $res["ErrorInfo"] = "";
+//                echo json_encode($res);
+//                break;
+//            case 'Group.CallbackAfterMemberExit': // 成员离开
+//                $members = $input["ExitMemberList"];
+//                if($members) foreach($members as $k => $v) {
+//                    RedisUtil::getInstance('online',$input["GroupId"])->HDel($v["Member_Account"]);
+//                }
+//                // 更新房间在线状态
+//                $party_id = $input["GroupId"];
+//                $partyInfo = RedisUtil::getInstance('party',$party_id)->get();
+//                if($partyInfo) {
+//                    $partyInfo = json_decode($partyInfo,true);
+//                    $memCount = count(RedisUtil::getInstance('online',$party_id)->hGetAll());
+//                    if($memCount <= 0) {
+//                        $partyInfo["is_online"] = 0;
+//                        RedisUtil::getInstance('party',$party_id)->set(json_encode($partyInfo));
+//                        \app\common\model\Party::update(["is_online"=>0],["id"=>$party_id]);
+//                    }
+//                }
+//
+//                $liveInfo = RedisUtil::getInstance('live',$party_id)->get();
+//                if($liveInfo) {
+//                    $liveInfo = json_decode($liveInfo,true);
+//                    $memCount = count(RedisUtil::getInstance('online',$party_id)->hGetAll());
+//                    if($memCount <= 0) {
+//                        $liveInfo["is_online"] = 0;
+//                        RedisUtil::getInstance('live',$party_id)->set(json_encode($liveInfo));
+//                        \app\common\model\Party::update(["is_online"=>0],["id"=>$party_id]);
+//                    }
+//                }
+//
+//                $res = [];
+//                $res["ActionStatus"] = "OK";
+//                $res["ErrorCode"] = 0;
+//                $res["ErrorInfo"] = "";
+//                echo json_encode($res);
+//                break;
+            /*case 'Group.CallbackBeforeSendMsg': // 群内发送消息之前
+
+                $config = config("wxMiniProgram");
+                $access_token_url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=".$config["appid"]."&secret=".$config["secret"];
+                $access_token_arr = $this->getJson($access_token_url);
+                $access_token = isset($access_token_arr["access_token"])?$access_token_arr["access_token"]:"";
+                if(!$access_token) {
+                    $res = [];
+                    $res["ActionStatus"] = "OK";
+                    $res["ErrorInfo"] = "";
+                    $res["ErrorCode"] = 0;
+                    echo json_encode($res);
+                    break;
+                }
+//                \app\common\model\Test::update(["content"=>json_encode($access_token)],["id"=>1]);
+                $infoMessage = $input["MsgBody"];
+                $badMessage = false;
+                if($infoMessage) foreach($infoMessage as $k => $v) {
+                    if(isset($v["MsgContent"]["Text"])) {
+                        $message = json_decode($v["MsgContent"]["Text"],true);
+                        $content = isset($message["content"])?$message["content"]:"";
+                        $message_check_url ='https://api.weixin.qq.com/wxa/msg_sec_check?access_token='.$access_token;
+                        $tencentObj = new tencentim($message_check_url);
+                        $content_json = '{"content": "'.$content.'"}';
+                        $body = $tencentObj->messageCheck($content_json);
+                        if($body["errcode"] == 87014) {
+//                        \app\common\model\Test::update(["content"=>$body["errcode"]],["id"=>1]);
+//                        $res = [];
+//                        $res["ActionStatus"] = "OK";
+//                        $res["ErrorInfo"] = "检测到敏感词汇！";
+//                        $res["ErrorCode"] = 1;
+//                        echo json_encode($res);exit;
+                            $message["content"] = "*******";
+                            $infoMessage[$k]["MsgContent"]["Text"] = json_encode($message);
+                            $badMessage = true;
+                        }
+                    }
+                }
+                if($badMessage) {
+                    $res = [];
+                    $res["ActionStatus"] = "OK";
+                    $res["ErrorInfo"] = "检测到敏感词汇！";
+                    $res["ErrorCode"] = 10102;
+                    $res["MsgBody"] = $infoMessage;
+                } else {
+                    $res = [];
+                    $res["ActionStatus"] = "OK";
+                    $res["ErrorInfo"] = "";
+                    $res["ErrorCode"] = 0;
+                }
+//                \app\common\model\Test::update(["content"=>json_encode($res)],["id"=>1]);
+                echo json_encode($res);exit;
+                break;*/
+            default:
+                break;
+        }
+        exit;
+    }
+
+    private function getJson($url){
+        $ch = curl_init();
+        curl_setopt($ch, CURLOPT_URL, $url);
+        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
+        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, FALSE);
+        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
+        $output = curl_exec($ch);
+        curl_close($ch);
+        return json_decode($output, true);
+    }
+
+    /**
+     * 发送消息给某人
+     * type:0普通消息 1自定义消息
+     */
+    public function sendMessageToUser($from_user,$to_user,$message, $type = 0) {
+//        $from_user = 54;
+//        $to_user = 6;
+//        $message = "sdsd";
+        $random = rand(10000000,99999999);
+        $usersig = $this->usersig("administrator");
+        // 获取配置信息
+        $config = config("tencent_im");
+        $url = "https://console.tim.qq.com/v4/openim/sendmsg";
+        $url .= "?sdkappid=".$config["sdkappid"];
+        $url .= "&identifier=administrator";
+        $url .= "&usersig=".$usersig;
+        $url .= "&random=".$random;
+        $url .= "&contenttype=json";
+        $tencentObj = new tencentim($url);
+
+        $data = [];
+        $data["SyncOtherMachine"] = 1;
+        $data["From_Account"] = (string)$from_user;
+        $data["To_Account"] = (string)$to_user;
+        $data["MsgRandom"] = rand(1000000,9999999);
+        $data["MsgTimeStamp"] = time();
+
+        if ($type == 1) { //自定义消息
+            $body_message = '{"businessID":"custom_tips_message","receiverShow":true,"senderId":"'.$from_user.'","text":"'.$message.'","tipType":257,"version":0}';
+            $data["MsgBody"][] = [
+                "MsgType" => "TIMCustomElem",
+                "MsgContent" => [
+                    "Data" => $body_message,
+                    "Desc" => $body_message,
+                    "Ext" => 'custom_tips_message',
+                    "Sound" => ''
+                ],
+            ];
+        } else {
+            $data["MsgBody"][] = [
+                "MsgType" => "TIMTextElem",
+                "MsgContent" => [
+                    "Text" => $message
+                ],
+            ];
+        }
+        $rs = $tencentObj->toSend($data);//p($rs);
+    }
+
+    /**
+     * 发送消息给某人-接口调用
+     */
+    public function sendToUser() {
+        $from_user = $this->request->request("from_user");// 发送者
+        $to_user = $this->request->request("to_user");// 接收者
+        $message = $this->request->request("message");// 接收者
+        if(!$from_user || !$to_user || !$message) $this->error("参数缺失！");
+        $this->sendMessageToUser($from_user,$to_user,$message, 1);
+    }
+
+    //请求的基础参数
+    private function baseTencentObj($url)
+    {
+        $random = rand(10000000,99999999);
+        $usersig = $this->usersig("administrator");
+        // 获取配置信息
+        $config = config("tencent_im");
+        $url = "$url";
+        $url .= "?sdkappid=".$config["sdkappid"];
+        $url .= "&identifier=administrator";
+        $url .= "&usersig=".$usersig;
+        $url .= "&random=".$random;
+        $url .= "&contenttype=json";
+        return new tencentim($url);
+    }
+
+    /** 设置管理员(im端的改变)
+     * @param $user_id
+     * @param $party_id
+     * @param int $status 1:yes 0:no
+     * @return array|false|mixed
+     */
+    public function setUpIMAdmin($user_id, $party_id, int $status=0) {
+        $url = "https://console.tim.qq.com/v4/group_open_http_svc/modify_group_member_info";
+        $tencentObj = $this->baseTencentObj($url);
+
+        $groupInfo = $this->getGroupInfo($party_id);
+        if($groupInfo["GroupInfo"][0]["ErrorCode"] > 0) return false;
+        // 更新的信息
+        $data = [];
+        $data["GroupId"] = $party_id;
+        if ($status==1){
+            $data['Role'] = 'Admin';
+        }else{
+            $data['Role'] = 'Member';
+        }
+        $data['Member_Account'] = $user_id;
+        return $tencentObj->toSend($data);
+    }
+
+
+    //获取群成员详细资料(目前没用到)
+    private function getGroupMemberDetails($party_id)
+    {
+        $url = "https://console.tim.qq.com/v4/group_open_http_svc/get_group_member_info";
+        $tencentObj = $this->baseTencentObj($url);
+        // 获取群组信息
+        $groupInfo = $this->getGroupInfo($party_id);
+        if($groupInfo["GroupInfo"][0]["ErrorCode"] > 0) return false;
+
+        // 更新的信息
+        $data = [];
+        $data["GroupId"] = $party_id;
+        return  $tencentObj->toSend($data);
+    }
+
+    //IM管理员维护，同步本地管理员
+    public function imAdminMaintenance()
+    {
+        $partyIds = \app\admin\model\party\Party::column('id');
+        foreach ($partyIds as $party_id){
+            $groupInfo = $this->getGroupInfo($party_id);
+
+            if($groupInfo["GroupInfo"][0]["ErrorCode"] > 0) continue;
+            $roomInfoData = $groupInfo["GroupInfo"][0]["AppDefinedData"];
+            $roomInfo = [];
+            if($roomInfoData) foreach($roomInfoData as $k => $v) {
+                if($v["Key"] == "roomInfo") $roomInfo = $v["Value"];
+            }
+            $roomInfo = json_decode($roomInfo,true);
+
+            // 更新管理员
+            if(isset($roomInfo["managers"]) && !empty($roomInfo['managers'])) {
+               foreach ($roomInfo['managers'] as $v){
+                    $this->setUpIMAdmin($v,$party_id,1);
+               }
+            }
+        }
+        $this->success("成功！");
+    }
+
+    //拉黑
+    public function black_one($from_user = '',$to_user = '') {
+        $from_user = (string)$from_user;
+        $to_user = (string)$to_user;
+        $random = rand(10000000,99999999);
+        $usersig = $this->usersig("administrator");
+        // 获取配置信息
+        $config = config("tencent_im");
+        $url = "https://console.tim.qq.com/v4/sns/black_list_add";
+        $url .= "?sdkappid=".$config["sdkappid"];
+        $url .= "&identifier=administrator";
+        $url .= "&usersig=".$usersig;
+        $url .= "&random=".$random;
+        $url .= "&contenttype=json";
+        $tencentObj = new tencentim($url);
+
+        $data = [];
+        $data["From_Account"] = $from_user;
+        $data["To_Account"] = [$to_user];
+
+        $rs = $tencentObj->toSend($data);
+        return $rs;
+    }
+
+    //取消拉黑
+    public function un_black_one($from_user = '',$to_user = '') {
+        $from_user = (string)$from_user;
+        $to_user = (string)$to_user;
+        $random = rand(10000000,99999999);
+        $usersig = $this->usersig("administrator");
+        // 获取配置信息
+        $config = config("tencent_im");
+        $url = "https://console.tim.qq.com/v4/sns/black_list_delete";
+        $url .= "?sdkappid=".$config["sdkappid"];
+        $url .= "&identifier=administrator";
+        $url .= "&usersig=".$usersig;
+        $url .= "&random=".$random;
+        $url .= "&contenttype=json";
+        $tencentObj = new tencentim($url);
+
+        $data = [];
+        $data["From_Account"] = $from_user;
+        $data["To_Account"] = [$to_user];
+
+        $rs = $tencentObj->toSend($data);
+        return $rs;
+    }
+
+    //撤回单聊消息
+    public function withdraw_message($from_user = '', $to_user = '',$msgkey = '') {
+//        $from_user = 54;
+//        $to_user = 6;
+//        $message = "sdsd";
+        $random = rand(10000000,99999999);
+        $usersig = $this->usersig("administrator");
+        // 获取配置信息
+        $config = config("tencent_im");
+        $url = "https://console.tim.qq.com/v4/openim/admin_msgwithdraw";
+        $url .= "?sdkappid=".$config["sdkappid"];
+        $url .= "&identifier=administrator";
+        $url .= "&usersig=".$usersig;
+        $url .= "&random=".$random;
+        $url .= "&contenttype=json";
+        $tencentObj = new tencentim($url);
+
+        $data = [];
+        $data["From_Account"] = (string)$from_user;
+        $data["To_Account"] = (string)$to_user;
+        $data["MsgKey"] = (string)$msgkey;
+
+        $rs = $tencentObj->toSend($data);//p($rs);
+        return $rs;
+    }
+}