xyzshop/test/TestTalk.php

<?php
/**
 * Created by PhpStorm.
 * User: stanley-king
 * Date: 2018/7/16
 * Time: 下午4:36
 */
define('BASE_ROOT_PATH',str_replace('/test','',dirname(__FILE__)));

require_once (BASE_ROOT_PATH . '/fooder.php');
require_once(BASE_ROOT_PATH . '/helper/search/tcp_client.php');
require_once(BASE_ROOT_PATH . '/helper/room/factory_client.php');
require_once(BASE_ROOT_PATH . '/helper/room/proto_type.php');
require_once(BASE_ROOT_PATH . '/helper/room/author.php');

class TestTalk extends PHPUnit_Framework_TestCase
{
    public static function setUpBeforeClass()
    {
        Base::run_util();
    }

    public function testGen()
    {
        global $config;
        $room_id = $config['special_rooms']['shake_bonus'];
        $webaddr = $config['access_addr'];

        $uids = [39625,39653];
        $creator = self::shake_creator($room_id);
        $ret = room\factory_client::instance()->invite($room_id,$creator,$uids);

        foreach ($uids as $uid)
        {
            $result = [];
            if($ret != false) {
                $result['addr'] = $webaddr;
                $result['token'] = room\author::sign_web($room_id,$uid);
                $result['room'] = intval($room_id);
                $result['user'] = $uid;
            }
        }
    }

    static private function shake_creator($room_id)
    {
        static $stCreator = 0;

        if($stCreator == 0) {
            $mod_room = Model('room');
            $params = $mod_room->getRoom($room_id);
            $rinfo = new room\base_info($params);
            $stCreator = $rinfo->creator();
        }

        return $stCreator;
    }

    public function testSql()
    {
        $left['from_user&to_user&msg_id'] = ['_multi' => true,1,2,['lt',100]];
        $left['to_user&from_user&msg_id'] = ['_multi' => true,1,2,['lt',100]];
        $left['_op'] = 'OR';

//        $right['msg_id'] = ['lt',100];
//
//        $cond[] = $left;
//        $cond[] = $right;
//        $cond['_op'] = 'and';


        $mod_room = Model('room');
//        $msgs = $mod_room->getRoomMsgList($cond,20);
        $msgs = $mod_room->getChatwoMsgList($left,20);
    }

    public function testLastRoomMsg(){
        $user = 39623;
        $mod_room = Model('room');

        $items =$mod_room->table('room_msg')->field("MAX(msg_id) as msg_id,room_id,member_id")->group('room_id')->having('member_id = '.$user)->select();



        $last_msg = [];
        foreach ($items as $item){
            $last_msg[$items['room_id']]= $items['msg_id'];
        }

        $room_key =array_keys($last_msg);
        $msg_key = array_values($last_msg);


        $items =$mod_room->table('room_msg')->field("msg_id,room_id,member_id")->group('room_id')->having('member_id = '.$user)->select();



        echo 1;
    }


    public function testTalk_Chats(){
        $json = [
            "rooms" =>[
                "room_id"=> "msg_id",
            ],
            "friends" =>[
                "39679" => 265,
            ]
        ];

        $user = 39623;//自己

        $mod_room = Model('room');

        $items = $mod_room->getLastChatwoMsg($user);

        $ret = $this->talk_format($items,'chatwo',$user,$json['friends']);



        if(!empty($json["friends"]))
        {
            $local_last =  $json["friends"];
            foreach ($ret as  $member_id => $last_msg){
                if(isset($local_last[$member_id]) && $local_last[$member_id]<$last_msg["msg_id"]){
                    $not_read = $mod_room->table("room_chatwo_msg")->where([
                        "from_user"=>$member_id,
                        "msg_id"=>[['gt',$local_last[$member_id]],['elt',$last_msg["msg_id"]]]
                    ])->count();
                    $ret[$member_id]["not_read"] = $not_read;
                }else{
                    $ret[$member_id]["not_read"] = 0;
                }
            }

        }


        echo 0;
    }

    public function testTalk_Rooms(){
        $json = [
            "rooms" =>[
                83=> "msg_id",
            ],
            "friends" =>[
                "39679" => 265,
            ]
        ];

        $user = 39623;//自己

        $mod_room = Model('room');

        $items = $mod_room->getLastRoomMsg($user);

        $ret = $this->talk_format($items,'room',$user,$json['rooms']);

        echo 0;
    }

    public function testTalks(){
        $arr = [
            ["type"=>'room',"room"=>83,   "msg_id"=>2550927],
            ["type"=>'chat',"user"=>39679,"msg_id"=>265],
        ];
        $post_data = json_encode($arr);

        $user = 39623;

        $post = $this->init_talk($post_data);

        $chats = $this->talk_chatwos($user,$post['local_chats']);

        $rooms = $this->talk_rooms($user,$post['local_rooms']);

        echo 0;
    }

    private function init_talk($post){
        $local_rooms = [];
        $local_chats = [];

        if(empty(trim($post))){
            return ["local_rooms"=>$local_rooms,"local_chats"=>$local_chats];
        }

        $json = json_decode($post,true);
        if(!empty($json))
        {
            foreach ($json as $v)
            {
                if($v['type'] == 'room'){
                    $local_rooms[$v['room']] = $v['msg_id'];
                }elseif($v['type'] == 'chat'){
                    $local_chats[$v['user']] = $v['msg_id'];
                }else{
                    continue;
                }
            }
        }

        return ["local_rooms"=>$local_rooms,"local_chats"=>$local_chats];
    }

    private function talk_rooms($user,$local_last)
    {
        $mod_room = Model('room');

        $items = $mod_room->getLastRoomMsg($user);

        $ret = $this->talk_format($items,'room',$user,$local_last);

        return $ret;
    }

    private function talk_chatwos($user,$local_last)
    {
        $mod_room = Model('room');

        $items = $mod_room->getLastChatwoMsg($user);

        $chats = $this->talk_format($items,'chatwo',$user,$local_last);

        return $chats;
    }

    private function talk_format($talks,$type,$user,$local_last)
    {
        $items = [];

        $mod_room = Model('room');

        foreach($talks as $last_msg)
        {
            if($type == 'room')
            {
                $id = $last_msg['room_id'];

                if(isset($local_last[$id]) && $local_last[$id]<$last_msg["msg_id"]) {
                    $not_read = $mod_room->getNotReadCnt($type,$local_last[$id],$last_msg["msg_id"],$id);
                }else{
                    $not_read = 0;
                }

                $item = [
                    "msg_id"    => $last_msg['msg_id'],
                    "msg"       => $last_msg['msg'],
                    "add_time"  => $last_msg['add_time'],
                    "not_read"  => $not_read,
                    "room_id"   => $id
                ];
            }
            elseif($type=='chatwo')
            {
                $id = $last_msg['from_user'] == $user?$last_msg['to_user']:$last_msg['from_user'];

                if(isset($local_last[$id]) && $local_last[$id]<$last_msg["msg_id"]) {
                    $not_read = $mod_room->getNotReadCnt($type,$local_last[$id],$last_msg["msg_id"],$id);
                }else{
                    $not_read = 0;
                }

                $item = [
                    "msg_id"    => $last_msg['msg_id'],
                    "msg"       => $last_msg['msg'],
                    "add_time"  => $last_msg['add_time'],
                    "not_read"  => $not_read,
                    "member_id" => $id
                ];
            }else{
                $id = 0;
                $item = [];
            }

            $items[$id] = $item;
        }
        return $items;
    }



    public function testRoom_list(){
        $_SESSION['is_login'] =1;
        $_SESSION['member_id'] = 39623;

        $user = 39623;

        $case1 = $this->room_case1($user);

        $case2 = $this->room_case2($user);

        $case3 = $this->room_case3($user);
        echo 0;
    }

    private function room_case2($user)
    {
        $mod_room = Model("room");
        $chats_rooms = $mod_room->getChatsRoom($user);

        $rooms = [];
        $uids_total = [];
        if(!empty($chats_rooms))
        {
            foreach ($chats_rooms as $room)
            {
                $uids = [];
                $paticipates = $mod_room->getRoomMember($room['room_id']);
                if(!empty($paticipates))
                {
                    foreach ($paticipates as $one)
                    {
                        $uids[] = $one['member_id'];
                    }

                    $uids_total = array_merge($uids_total,$uids);
                }


                $rooms[] = [
                    "room_id"=>$room['room_id'],
                    "room_name"=>$room['room_name'],
                    "avatar"=>"",
                    "room_members"=>$uids
                ];
            }

            $members = [];
            if(!empty($uids_total))
            {
                $uids_total = array_unique($uids_total);
                $items = Model('member')->getMemberList(['member_id' => ['in',$uids_total]]);

                foreach ($items as $item){
                    try
                    {
                        $info = new member_info($item);
                        $members[$item['member_id']] = $info->filter();
                    }
                    catch (Exception $ex) {
                        Log::record($ex->getMessage(),Log::ERR);
                    }
                }
            }


            if(!empty($members))
            {
                foreach ($rooms as $index => $room){
                    $room_members = [];
                    if(!empty($room['room_members']))
                    {
                        foreach ($room['room_members'] as $uid)
                        {
                            if(isset($members[$uid])){
                                $room_members[] = $members[$uid];
                            }

                        }
                    }
                    $rooms[$index]['room_members'] = $room_members;
                }
            }
        }

        return $rooms;
    }

    private function room_case1($user)
    {
        $mod_room = Model('room');
        $chat_rooms = $mod_room->getJoinedChatRoom($user);

        $rooms = [];
        if(!empty($chat_rooms))
        {
            foreach ($chat_rooms as $item)
            {
                $rooms[] = $this->room_info($item);
            }
        }

        return $rooms;
    }

    private function room_info($room)
    {
        $mod_room = Model("room");
        $paticipates = $mod_room->getRoomMember($room['room_id']);

        $uids = [];
        if(!empty($paticipates))
        {
            foreach ($paticipates as $one){
                $uids[] = $one['member_id'];
            }
        }

        if(empty($uids)){
            $items = [];
        }else{
            $items = Model('member')->getMemberList(['member_id' => ['in',$uids]]);
        }

        $members = [];
        foreach ($items as $item){
            try
            {
                $info = new member_info($item);
                $members[] = $info->filter();
            }
            catch (Exception $ex) {
                Log::record($ex->getMessage(),Log::ERR);
            }
        }

        $ret = [
            "room_id"=>$room['room_id'],
            "room_name"=>$room["room_name"],
            "avatar"=> "", //头像和member查询维度太高
            "room_members"=>$members,
        ];
        return $ret;
    }

    private function room_case3($user){
        $mod_room = Model("room");
        $chats_rooms = $mod_room->getChatsRoom($user);

        $rooms = [];
        if(!empty($chats_rooms))
        {

            $roomids = [];
            foreach ($chats_rooms as $room)
            {
                $rooms[] = [
                    "room_id"=>$room['room_id'],
                    "room_name"=>$room['room_name'],
                    "avatar"=>"",
                    "room_members"=>[]
                ];
                $roomids[] = intval($room['room_id']);
            }

            $room_members = [];
            $uids_total = [];
            $roomTouser = $mod_room->table('room_msg')
                ->field('room_id,group_concat(DISTINCT member_id) as uidstr')
                ->where(['room_id'=>['in',$roomids]])
                ->group('room_id')
                ->select();
            if(!empty($roomTouser))
            {
                foreach ($roomTouser as $index => $item)
                {
                    $uids = explode(',',$item['uidstr']);
                    $uids_total = array_merge($uids_total,$uids);
                    $room_members[$item['room_id']] = $uids;
                }
            }

            $members = [];
            if(!empty($uids_total))
            {
                $uids_total = array_unique($uids_total);
                $items = Model('member')->getMemberList(['member_id' => ['in',$uids_total]]);

                foreach ($items as $item){
                    try
                    {
                        $info = new member_info($item);
                        $members[$item['member_id']] = $info->filter();
                    }
                    catch (Exception $ex) {
                        Log::record($ex->getMessage(),Log::ERR);
                    }
                }
            }

            if(!empty($members))
            {
                foreach ($rooms as $index => $room)
                {
                    $room_id = $room['room_id'];
                    if(isset($room_members[$room_id]))
                    {
                        $user_list = [];
                        foreach ($room_members[$room_id] as $i=>$uid)
                        {
                            if(isset($members[$uid])) $user_list[$i] = $members[$uid];
                        }
                        $rooms[$index]['room_members'] = $user_list;
                    }
                }
            }
        }

        return $rooms;
    }

}