删除DataSourceMessageListener类,功能已移到RefreshDataSourceMessageImpl类

fs-danaus

2022-12-22 2101288d9ac96f3029c75ec71a810da5f5029819

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
package com.yc.im.util;
 
import com.yc.factory.FactoryBean;
import com.yc.im.api.PersonUser;
import com.yc.im.entity.GroupEntity;
 
import java.util.Map;
 
public class RedisSocket {
    public static  RedisUtil redisUtil= (RedisUtil) FactoryBean.getBean("redisUtil");//存取
    protected static  String CHANNEL_KEFU="Onbus_WSMQ";//客服消息频道名称
    public static  String REDISTKEY_CLIENTLISTS="WS_clientlists";//用户集合的key
    protected static  String REDISTKEY_GROUPLISTS="WS_grouplists";//群组集合的key
    protected static  String REDISTKEY_ONLINENUMBER="WS_onlines";//在线人数key
    protected static  String REDISTKEY_ASSOCIATEDCUSTOMERNUMBER="WS_AssociatedCustomerNumber";//客服关联客户
    public static  String CHANEL_WS_MESSAGES="Onbus_Messages";//消息频道名称
    protected static Map<String, PersonUser> getRedisClients(int dbid) {
 
        return redisUtil.getCacheMap(dbid+":"+RedisSocket.REDISTKEY_CLIENTLISTS);
    }
    protected static Map<String, PersonUser> getRedisClients() {
 
        return redisUtil.getCacheMap(RedisSocket.REDISTKEY_CLIENTLISTS);
    }
 
    protected static void setRedisClient(PersonUser personUser) {
        redisUtil.setCacheMapByOpenid(personUser.getDbId()+":"+RedisSocket.REDISTKEY_CLIENTLISTS,personUser.getDbId()+":"+personUser.getOpenId(),personUser);
 
    }
    public static Map<Long, GroupEntity> getRedisGroups(int dbid) {
        return redisUtil.getCacheMap(dbid+":"+RedisSocket.REDISTKEY_GROUPLISTS);
    }
    public static void setRedisGroups(GroupEntity group,int dbid) {
        redisUtil.setCacheMapByOpenid(dbid+":"+RedisSocket.REDISTKEY_GROUPLISTS,group.getGroupId()+"",group);
    }
}