const BridgeController = require( "bridge.controller" );
var ChatConst = require( "chat_const" );

var ChatController = cc.Class( {
    extends: BridgeController,

    ctor: function () {
        var ChatModel = require( "chat_model" );
        this.model = new ChatModel( this );
        this.model.initConfig();
        this.chat_time = {};
    },

    registerEvents: function () {
        this.init_role_event = gcore.GlobalEvent.bind( EventId.EVT_ROLE_CREATE_SUCCESS, function () {
            gcore.GlobalEvent.unbind( this.init_role_event )
            this.model.initPrivatreTargets();
        }.bind( this ) )
    },

    openChatPanel: function ( channel, form, data ) {
        var open_parame = {};
        open_parame.channel = form;
        if( form == "friend" ) {
            this.model.addPrivateTarget( data );
            open_parame.channel = ChatConst.Channel.Friend;
            open_parame.friend_data = data;
        }

        nx.bridge.createPanel("WndChat",open_parame);
    },

    closeChatPanel: function () {
        if( this.chat_window ) {
            this.chat_window.close();
            this.chat_window = null;
        }
    },
    initData: function () {

    },

    getModel: function () {
        return this.model
    },

    initConfig: function () {
        var ChatModel = require( "chat_model" );
        this.model = new ChatModel();
        this.model.initConfig();
        this.is_first = true;
        this.pro_12766 = true;
        this.stack_id = 0;
    },

    registerProtocals: function () {
        this.RegisterProtocal( 12720, this.handle12720 );         // 私聊
        this.RegisterProtocal( 12721, this.handle12721 );         // 推送私聊消息
        this.RegisterProtocal( 12722, this.handle12722 );         // 登陆推送私聊信息
        this.RegisterProtocal( 12725, this.handle12725 );         // 语音信息
        this.RegisterProtocal( 12726, this.handle12726 );         // 下载语音信息
        this.RegisterProtocal( 12731, this.handle12731 );
        this.RegisterProtocal( 12741, this.handle12741 );         // 提示
        this.RegisterProtocal( 12743, this.handle12743 );         // 系统提示&聊天提示
        this.RegisterProtocal( 12799, this.handle12799 );         // 消息发送

        this.RegisterProtocal( 12761, this.handle12761 );         // 接受通用聊天
        this.RegisterProtocal( 12762, this.handle12762 );         // 发送通用聊天
        this.RegisterProtocal( 12763, this.handle12763 );         // 服务端分发翻译
        this.RegisterProtocal( 12766, this.handle12766 );         // 登录聊天记录

        this.RegisterProtocal( 12767, this.handle12767 );         // 聊天@
        this.RegisterProtocal( 12768, this.handle12768 );         // 已查看
    },

    reqBaseFromServer: function( _cb ){
        // 配置加载 
        let cfgs = [
            "face_data", // 聊天表情
        ];
        this.loadConfigs( cfgs, ( _ret, _data ) => {
            nx.dt.fnInvoke( _cb, true );
        } );
    },

    sender12731() {
        var protocal = {};
        this.SendProtocal( 12731, protocal );
    },

    handle12731( data ) {

    },

    /**
     * 发送翻译后的文字消息
     * @author zhanghuxing 2019-01-03
     * @param  {[type]} msg       [description]
     * @param  {[type]} channel   [description]
     * @param  {[type]} taken_obj [description]
     * @return {[type]}           [description]
     */
    sendVoidMsg: function ( msg, channel, taken_obj ) {
        if( channel == ChatConst.Channel.Friend ) {
            this.sender12720();
        } else {
            this.sender12762();
        }
    },

    /**
     * 发送文字信息
     * @author zhanghuxing 2019-01-03
     * @param  {[type]} msg       [description]
     * @param  {[type]} channel   频道
     * @param  {[type]} taken_obj [description]
     * @param  {[type]} len       [description]
     * @return {[type]}           [description]
     */
    sendMessage: function ( channel, msg, len, to_srv_id, to_rid, name ) {
        cc.log( "chat__________", msg, channel, len, to_srv_id, to_rid )

        if( channel == ChatConst.Channel.Friend ) {
            this.sender12720( to_srv_id, to_rid, msg, len, name );
        } else {
            this.sender12762( channel, msg, len );
        }
    },


    sender12720: function ( to_srv_id, to_rid, msg, len, name ) {        // 发起私聊
        var msg_data = {};
        msg_data.to_srv_id = to_srv_id;
        msg_data.to_rid = to_rid;
        msg_data.msg = msg;
        msg_data.len = len;

        this.SendProtocal( 12720, msg_data );
        // cc.log("sl---------------",to_rid.split("_"))
        //爱微游渠道聊天监控
        if( nx.bridge.vget( "channel" ) == "AIWEIYOU_PID" ) {
            let rid = null;
            to_rid = String( to_rid );
            let arr = to_rid.split( "_" );
            rid = arr[ 1 ];
            sdk.chatMonitor( {
                to_srv_id: to_srv_id,
                to_rid: rid,
                type: 1,//1表示私聊
                name: name,
                msg: msg
            } )
        }
    },

    handle12720: function ( data ) {                               // 私聊失败提示
        cc.log( "私聊失败" );
        cc.log( data );
        if( data.code == 0 ) {
            nx.tbox( data.msg )
        }

    },

    handle12721: function ( data ) {                               // 收到私聊消息
        cc.log( "私聊消息" );
        cc.log( data );
        if( data )
            this.model.addPrivateMsg( data );
            nx.mTip.openTip("chat.players",true);
    },

    handle12722: function ( msg_datas ) {                               // 登陆推送离线私聊信息
        cc.log( "离线私聊消息" );
        cc.log( msg_datas );

        if( msg_datas && msg_datas.offline_list.length > 0 ) {
            var offline_Info = null;
            for( var offline_i = 0;offline_i < msg_datas.offline_list.length;offline_i++ ) {
                offline_Info = msg_datas.offline_list[ offline_i ];
                if( offline_Info.msg_list && offline_Info.msg_list ) {
                    for( var msg_i = 0;msg_i < offline_Info.msg_list.length;msg_i++ ) {
                        var msg_info = nx.dt.objClone( offline_Info );
                        delete msg_info.msg_list;
                        msg_info.msg = offline_Info.msg_list[ msg_i ].msg;
                        msg_info.len = offline_Info.msg_list[ msg_i ].len;
                        msg_info.tick = offline_Info.msg_list[ msg_i ].tick;
                        msg_info.offline = true;
                        msg_info.flag = 2;
                        this.model.addOutlinePrivateMsg( msg_info );
                    }
                }
            }

            nx.mTip.openTip("chat.players",true);
        }
    },

    // 通知服务端已读消息
    sender12723: function ( srv_id, rid ) {
        if( srv_id === null || rid === null ) return
        var protocal = {};
        protocal.rid = rid;
        protocal.srv_id = srv_id;
        this.SendProtocal( 12723, protocal );
    },

    handle12725: function ( data ) {                               // 语音信息

    },

    handle12726: function ( data ) {                               // 下载语音信息

    },

    handle12741: function ( data ) {                               // 提示
        // 消耗<assets=3/><div fontcolor=#ef3a3a>1600</div>，获得<div fontcolor=#c26706>荣光符石</div>
        // 消耗，获得<div fontcolor=#c26706>魔力符石</div>
        let new_msg = null;
        if( data.msg && data.msg.indexOf( "^" ) != -1 ) {
            let arr = data.msg.split( "^" );
            for( let i = 0;i < arr.length;i++ ) {
                let cfg = gitemdata( arr[ i ] );
                if( cfg ) {
                    arr[ i ] = cfg.name;
                }
            }
            new_msg = arr.join( "" );
        } else {
            new_msg = data.msg;
        }
        nx.tbox( new_msg );
    },

    handle12743: function ( data ) {                               // 系统提示&聊天提示（在聊天框显示）
        nx.tbox( data.msg );
        var sys_msg = {};
        sys_msg.len = 0;
        sys_msg.channel = ChatConst.Channel.System;
        sys_msg.role_list = {};
        sys_msg.msg = data.msg;
        this.handle12761( sys_msg, true );
    },

    handle12799: function ( data ) {                               // 消息发送

    },

    handle12761: function ( data ) {                               // 接受通用聊天
        if( !data ) return

        let new_msg = null;
        if( data.msg && data.msg.indexOf( "^" ) != -1 ) {
            let arr = data.msg.split( "^" );
            for( let i = 0;i < arr.length;i++ ) {
                let cfg = gitemdata( arr[ i ] );
                if( cfg ) {
                    arr[ i ] = cfg.name;
                }
            }
            new_msg = arr.join( "" );
        } else {
            new_msg = data.msg;
        }
        data.msg = new_msg;

        if( this.pro_12766 && !this.is_first )
            this.pro_12766 = false;

        this.is_first = false;
        if( data.channel == ChatConst.Channel.SystemTop ) {
            data.flag = 1;
        }
        this.model.addNormalChatMsg( data.channel, data );

        this.handle12761__( data )
    },
    handle12761__( data ) {

        let channel = data.channel
        if( channel == ChatConst.Channel.System ||
            channel == ChatConst.Channel.NoticeTop ||
            channel == ChatConst.Channel.System1 ||
            channel == ChatConst.Channel.SystemTop ) {
            nx.marquee( data.msg );
        }
    },


    sender12762: function ( channel, msg, len ) {                  // 发起通用聊天
        if( !channel || !msg || !len ) return;
        var sender_data = {};
        sender_data.channel = channel;
        sender_data.msg = msg;
        sender_data.len = len;

        // 判断时间
        var canSend = this.canSend( channel );

        if( canSend ) {
            this.SendProtocal( 12762, sender_data );
            this.saveChatTime( channel );
        } else {
            var cur_time = client.socket.getTime();
            var last_time = this.chat_time[ "sec_" + channel ];
            var time_index = ChatConst.ChatTimeIndex[ channel ];
            var time_info = ChatConst.SayConfig[ time_index ];
            if( time_info ) {
                let time = time_info.val + last_time - cur_time
                time = time || 1
                nx.tbox( cc.js.formatStr( nx.text.getKey( "msg_chat_controller_tip1" ), time ) );
            }

        }
    },

    canSend: function ( channel ) {
        if( !this.chat_time[ "sec_" + channel ] ) return true;

        var last_time = this.chat_time[ "sec_" + channel ];
        var cur_time = client.socket.getTime();
        var time_index = ChatConst.ChatTimeIndex[ channel ];
        var time_info = ChatConst.SayConfig[ time_index ];

        if( time_info ) {
            if( time_info.val + last_time < cur_time )
                return true
        }
        return false;
    },

    saveChatTime: function ( channel ) {
        var cur_time = client.socket.getTime();
        var chat_index = "sec_" + channel;
        // if (!this.chat_time[chat_index])
        this.chat_time[ chat_index ] = cur_time;
    },

    handle12762: function ( data ) {                               // 发送通用聊天结果
        cc.log( "发送通用聊天结果" );
        cc.log( data );
        if( data.code == 0 )
            nx.tbox( data.msg );
    },

    handle12763: function ( data ) {                               // 服务端分发翻译

    },

    sender12766() {
        var protocal = {};
        protocal.channel = 1;
        this.SendProtocal( 12766, protocal );
    },

    handle12766: function ( data ) {                               // 登录聊天记录
        if( this.pro_12766 ) {
            this.pro_12766 = false;
            for( var msg_i in data.msg_list ) {
                this.handle12761( data.msg_list[ msg_i ] );
            }
            this.pro_12766 = true;
        }
    },

    handle12767: function ( data ) {                               // 聊天@
        this.model.setAtData( data );
        // if (this.chat_window) {
        //     this.chat_window.showAtNotice(true, data);
        // }
    },

    // 已查看艾特信息
    sender12768: function ( rid, srv_id, channel, msg ) {
        var protocal = {};
        protocal.rid = rid;
        protocal.srv_id = srv_id;
        protocal.channel = channel;
        protocal.msg = msg;
        this.SendProtocal( 12768, protocal );
    },

    handle12768: function ( data ) {// 已查看@

    },

    // 聊天记录唯一ID
    getUniqueId: function () {
        if( this.stack_id == null ) {
            this.stack_id = 0;
        }
        this.stack_id = this.stack_id + 1;
        return this.stack_id;
    },

    // 打开好友信息界面
    openFriendInfo: function ( data ) {
        var FriendController = require( "friend_controller" );
        FriendController.getInstance().openFriendCheckPanel( true, data );
    },


    // 返回聊天的输入组件
    getChatInput: function () {
        if( this.chat_window ) {
            if( this.chat_window.chat_input_panel ) {
                return this.chat_window.chat_input_panel;
            }
        }
    },

    //  @人
    chatAtPeople: function ( name, srv_id ) {
        var chatInput = this.getChatInput();
        if( chatInput ) {
            chatInput.setInputText( "@" + name + " ", srv_id );
        }
    },

    // 返回信息的id
    getId: function ( channel, srv_id, rid, name, msg ) {
        var list = this.model.getChannelMsgs( channel );

        var id = 1;
        for( var i = 0, l = list.length;i < l;i++ ) {
            if( list[ i ].role_list && list[ i ].role_list[ 0 ] ) {
                var v = list[ i ].role_list[ 0 ];
                if( srv_id == v.srv_id && rid == v.rid && name == v.name && msg == list[ i ].msg ) {
                    id = list[ i ].id;
                }
            }
        }
        return id;
    }

} )
module.exports = ChatController;