liaotian/library/chat.js

import action from "./action.js"

class chat {
    push(res, fromway) {

        if (fromway != uni.getStorageSync('storeykey')) return false;
        var data = {
            id: res.data.cache_key,
            msg: res.data
        }

        let key = prefix(data.id);

        var msg_list_key = msglist_key();
        var statesource = cache(key) ? cache(key) : [];
        // console.log(statesource[statesource.length-1].msg_id,res.data.msg_id)
        if (statesource.length > 0) {
            if (statesource[statesource.length - 1].msg_id == res.data.msg_id) return false;
        }

        if (data.msg.sender_id != uni.getStorageSync('access_token')) data.msg.unread = 1;
        else data.msg.unread = 0;

        var statelist = [];
        var msglist = cache(msg_list_key) || [];

        statesource.push(data.msg);
        //  console.log(data.msg.message);
        if (data.msg.message.type != 'tips' || data.msg.message.msg_type == 'show') {
            //更新消息列表

            if (data.msg.isloading == 0 || data.msg.message.msg_type == 'show') {

                let msgindex = msglist.findIndex(v => v.key == key);
                let unreadCount = 0;
                var readtime = 0;
                if (msgindex >= 0) {
                    let tmp = msglist.splice(msgindex, 1);
                    unreadCount = tmp[0].msg.unread || 0;
                    readtime = tmp[0].msg.readtime || 0;
                }
                // console.log(data.msg);
                //  console.log(data.msg.cache_key , uni.getStorageSync('cache_key'))
                if (data.msg.self != 1 && data.msg.cache_key != uni.getStorageSync('cache_key')) {
                    var no_tip = 0;
                    var msgnotip = uni.getStorageSync('msgnotip');
                    if (!msgnotip) msgnotip = [];
                    msgnotip.map(item => {
                        if (item == data.msg.cache_key) {
                            no_tip = 1;
                        }

                    })
                    try {
                        data.msg.message.content = JSON.parse(data.msg.message.content);

                    } catch (e) {

                    }
                    if (data.msg.message.content.type == 'remind' && data.msg.message.content.remind.id == uni
                        .getStorageSync('access_token')) {
                        no_tip = 0;
                        data.msg.message.content.content = data.msg.message.content.content.replace('@{' + data.msg
                            .message.content.remind.id + '}', '有人@我');
                        cache('remid_' + key, data.msg);

                    }

                    if (no_tip == 0) {
                        try {
                            let userinfo = cache('userInfo');

                            if (parseInt(data.msg.group_id) > 0) {
                                if (parseInt(userinfo.note1) != 0) action.playVoice('/static/voice/chat.mp3');
                                if (parseInt(userinfo.note2) != 0) uni.vibrateLong();
                            } else {
                                if (parseInt(userinfo.note3) != 0) action.playVoice('/static/voice/friend.mp3');
                                if (parseInt(userinfo.note4) != 0) uni.vibrateLong();
                            }
                        } catch (e) {
                            //TODO handle the exception
                        }

                    }
                }
                //console.log(data.msg);
                if (cache('remid_' + key)) var datamsg = cache('remid_' + key)
                else
                    var datamsg = data.msg
                delete datamsg['receiver']

                msglist.push({
                    key,
                    msg: {
                        ...datamsg,
                        unread: data.msg.self ? unreadCount : unreadCount + 1,
                        readtime: 0,
                        istop: 0
                    }
                });

                uni.setStorageSync(msg_list_key, msglist);


            }

            // console.log(data.msg);

        } else {

            let list1 = statesource;


            //测回消息
            if (data.msg.message.msg_type == 'chat_back') {
                // #ifdef APP-PLUS
                /*  plus.push.clear(); */
                // #endif
                try {
                    var msg_id = data.msg.message.data.msg_id;
                } catch (e) {
                    //TODO handle the exception
                    var msg_id = data.msg.msg_id;
                }

                var list = [];
                if (msg_id > 0) {
                    var unread = 0;
                    var tempdata = '';
                    var num = 0;
                    for (var i = 0; i < statesource.length; i++) {
                        var item = statesource[i];
                        if (parseInt(item.msg_id) == parseInt(msg_id)) {


                        } else {
                            list.push(item);
                            if (item.message.type != 'tips') {
                                tempdata = item;
                                unread = unread + item.unread;
                            }

                        }
                    }


                    statesource = list;


                    let msgindex = msglist.findIndex(v => v.key == key);
                    let unreadCount = 0;
                    if (msgindex >= 0) {
                        let tmp = msglist.splice(msgindex, 1);
                        unreadCount = tmp[0].msg.unread || 0;
                    }
                    msglist.push({
                        key,
                        msg: {
                            ...tempdata,
                            unread: unread,
                            istop: set_msgtop(data.msg.cache_key)
                        }
                    });

                    cache(msg_list_key, msglist);

                }

            } else {
                // console.log(data);
            }

        }

        uni.setStorageSync(key, statesource);
        return {
            'source': statesource,
            'msglist': msglist
        };
    }

    send(data) {


        console.log(data);
    }

    //最近聊天记录
    msglist() {
        let tmp = [];

        var msg_list_key = msglist_key();

        let lists11 = cache(msg_list_key) ? cache(msg_list_key) : [];

        let lists = [];
        var userid = uni.getStorageSync('access_token');
        for (var i = 0; i < lists11.length; i++) {
            try {
                //	console.log(lists11[i]['key'],uni.getStorageSync('access_token'));
                if (lists11[i]['key'].indexOf(userid + '_chat_') > -1) lists.push(lists11[i]);
            } catch (e) {

            }

        }
        lists.forEach(v => {

            v.msg = Object.assign(v.msg, (+v.msg.group_id > 1) ? getGroupInfoById(v.msg.group_id) :
                getUserInfo(v.msg));

            try {
                v.msg.message.content = JSON.parse(v.msg.message.content);

            } catch (e) {

            }

            if (v.msg.message.content.type == 'remind') {
                if (v.msg.message.content.remind.id == uni.getStorageSync('access_token')) {

                    v.msg.message.content.content = v.msg.message.content.content.replace('@{' + v.msg
                        .message.content.remind.id + '}', "有人@我");
                } else {

                    var mem = getGroupmemebrs(v.msg.group_id, v.msg.message.content.remind.id);
                    if (mem.id == v.msg.message.content.remind.id) {
                        var atname = mem.nickname;
                    } else var atname = v.msg.message.content.remind.nickname;
                    v.msg.message.content.content = v.msg.message.content.content.replace('@{' + v.msg
                        .message.content.remind.id + '}', '@' + atname);
                }


            }

            // if (!v.msg.group_id) console.log(getUserInfoById(v.msg.id))
            if (!v.msg.none) tmp.push(v.msg);


        });
        let temp1 = [];
        let temp2 = [];
        tmp.map(item => {
            if (item.istop > 0) temp1.push(item)
            else temp2.push(item)
        })
        temp1.sort((a, b) => b.istop - a.istop);
        temp2.sort((a, b) => b.timestamp - a.timestamp);
        // tmp.sort((a, b) => b.timestamp - a.timestamp);

        action.setStatusTips();
        var res = temp1.concat(temp2);

        return res;
    }


}

export default new chat();
const cache = function(key, value) {

    try {
        if (arguments.length == 1) {
            //            console.log(key);
            return uni.getStorageSync(key)
        }
        if (arguments.length > 1) {
            if (value === null) {
                uni.removeStorageSync(key);
            } else {
                uni.setStorageSync(key, value);
            }
        }
    } catch (e) {
        uni.showToast({
            icon: 'none',
            title: '程序发生错误'
        });
    }
};
const parseDate = (str) => new Date(str.replace(/(-|年|月)/g, '/').replace('日', ''));
const dateToTime = (date) => date.getTime() / 1000;
const cutTimeStr = (str) => str.substr(0, 11);

function timestampToTime(timestamp) {
    var date = new Date(timestamp * 1000); //时间戳为10位需*1000，时间戳为13位的话不需乘1000
    var Y = date.getFullYear();
    var M = (date.getMonth() + 1 < 10 ? '0' + (date.getMonth() + 1) : date.getMonth() + 1);
    var D = date.getDate();
    var h = date.getHours();
    var m = date.getMinutes();
    var s = date.getSeconds();
    if (D < 10) D = '0' + D;
    if (h < 10) h = '0' + h;
    if (m < 10) m = '0' + m;
    if (s < 10) s = '0' + s;
    return Y + '-' + M + '-' + D + ' ' + h + ':' + m + ':' + s;
}

function setTimeShow(timestamp) {
    var time = timestampToTime(timestamp);

    var now = new Date();
    var Year = now.getFullYear();
    var month = now.getMonth() + 1;
    if (month < 10) month = '0' + month;
    var day = now.getDate();
    if (day < 10) day = '0' + day;
    var today = Year + '-' + month + '-' + day;
    if (time.substr(0, 10) == today) return time.substr(11, 8);
    if (time.substr(0, 4) == Year) return time.substr(5, 14);
    return time;
}

function prefix(id) {

    return uni.getStorageSync('access_token') + '_chat_' + id;
}

function prefixIndex(id) {
    return uni.getStorageSync('access_token') + prefix(id) + '_index';
}

function msglist_key() {
    return prefix('msglist');
}

function set_msgtop(key) {
    var msgtop = cache('msgtop');

    var istop = 0;
    for (var i = 0; i < msgtop.length; i++) {
        if (msgtop[i] == key) {
            return true;
        }
    }
    return false;
}



function set_senderlist(sender) {
    var list = uni.getStorageSync(prefix('senderlist'));

    var isin = 0;
    if (list.length > 0) {

        for (var i = 0; i < list.length; i++) {
            if (parseInt(list[i].id) == parseInt(sender.id) && isin == 0) {
                list[i].nickname = sender.nickname;
                list[i].avatar = sender.avatar;
                isin = 1;
            }

        }

    } else var list = Array();
    if (isin == 0) list.push(sender);


    uni.setStorageSync(prefix('senderlist'), list);

}

function getUserInfoById(id) {
    if (id > 0) {

        var result = {
            id,
            avatar: config.imgUri + '/uploads/avatar.jpg',
            nickname: '未知用户',
        };
        let list = uni.getStorageSync(uni.getStorageSync('access_token') + '_frienddata');
        if (!list) list = [];
        list.forEach(v => {
            if (v.id == id) {
                result.nickname = v.nickname;

                if (v.avatar.indexOf('http') > -1) {

                } else v.avatar = config.imgUri + v.avatar

                result.avatar = v.avatar;
            }

        })
    } else {
        var system = uni.getStorageSync('system');

        var result = {
            id,
            avatar: config.imgUri + system['admin_logo'],
            nickname: system['admin_nickname'],
        };
    }






    return result;
}

function getGroupInfoById(id) {
    var groups = uni.getStorageSync(uni.getStorageSync('access_token') + '_groups');
    for (var i = 0; i < groups.length; i++) {
        if (groups[i].id == id) {
            var avatar = groups[i].avatar;
            if (avatar !== null && avatar.indexOf('http') > -1) {

            } else avatar = config.imgUri + avatar
            var result = {
                id: id,
                avatar: avatar,
                nickname: groups[i].nickname,
                none: false
            };


            return result;

        }
    }

    return {
        id,
        avatar: config.imgUri + '/uploads/group.jpg',
        nickname: '未知群组',
        none: false
    };


}

function getGroupmemebrs(group_id, userid) {
    var members = uni.getStorageSync(group_id + '_group_members');
    if (!members) members = [];
    let result = [];
    members.forEach(item => {
        if (item.id == userid) result = item;

    })
    return result;
}

function get_chat_list(id) {

    try {
        var temp = cache(prefix(id)) ? cache(prefix(id)) : [];

        return temp;
    } catch (e) {
        //TODO handle the exception
        return [];
    }
}

function get_chatold_list(id) {
    try {
        var temp = cache(prefix('old' + id)) ? cache(prefix('old' + id)) : [];
        return lists;
    } catch (e) {
        //TODO handle the exception
        return [];
    }

}

function msg_vocice(data) {
    if (data.msg.self != 1 && data.msg.cache_key != uni.getStorageSync('cache_key')) {
        var no_tip = 0;
        var msgnotip = uni.getStorageSync('msgnotip');
        if (!msgnotip) msgnotip = [];
        msgnotip.map(item => {
            if (item.storekey == data.msg.cache_key) {
                no_tip = 1;

            }

        })
        if (data.msg.message.content.type == 'remind' && data.msg.message.content.remind.id == uni.getStorageSync(
                'access_token')) {
            no_tip = 0;
            data.msg.message.content.content = data.msg.message.content.content.replace('@{' + data.msg.message.content
                .remind.id + '}', '有人@我');
            cache('remid_' + key, data.msg);

        }

        if (no_tip == 0) {
            let userinfo = cache('userInfo');

            //  console.log(userinfo);
            if (parseInt(userinfo.note2) != 0) uni.vibrateLong();
            if (parseInt(userinfo.note1) != 0) action.playVoice('/static/voice/chat.mp3');

        }
    }

    return data;


}

function httpString(str) {

    var reg = /(https?|http|ftp|file):\/\/[-A-Za-z0-9+&@#/%?=~_|!:,.;]+[-A-Za-z0-9+&@#/%=~_|]/g;
    //  console.log(str);

    try {

        var s = str.match(reg);
        if (s != null) {
            return s;
        } else {
            return false;
        }
    } catch (e) {
        return false;
    }



}

function get_senderinfo(v) {


    try {
        if (v.group_id > 0) {
            var mem = getGroupmemebrs(v.group_id, v.sender_id);
            if (mem.id > 0) v.sender = mem;
            //  console.log(mem);
        }
        var avatar = v.sender.avatar;
        if (avatar.indexOf('http') > -1) {

        } else avatar = config.imgUri + avatar
        var obj = {
            id: v.sender_id,
            avatar: avatar,
            nickname: v.sender.nickname,
        };
    } catch (e) {
        //                 console.log(v);
        var obj = {
            id: v.sender_id,
            avatar: '',
            nickname: v.nickname,
        };
    }

    return obj;
}

function message_format(v) {

    try {
        v.message.content = JSON.parse(v.message.content);
        var type = v.message.content.type;

    } catch (e) {
        //TODO handle the exception

        var type = v.message.content.type;
    }


    if (type == 'remind') {

        var mem = getGroupmemebrs(v.group_id, v.message.content.remind.id);
        if (mem.id == v.message.content.remind.id) {
            var atname = mem.nickname;
        } else
            var atname = v.message.content.remind.nickname;

        v.message.content.content = v.message.content.content.replace('@{' + v.message.content.remind.id + '}', '@' +
            atname);

    }
    if (v.message.type == 'text' && v.message.content.type != 'emotion') {

        if (type == 'remind')
            var content = v.message.content.content;
        else var content = v.message.content;

        var res = httpString(content);
        if (res != false) {
            v.message.type = 'url';
            v.message.content = {};
            v.message.content.content = content;
            v.message.content.urls = res;
        }
    }

    return v;
}