package chat.handler;
|
|
import static chat.consts.UserSettingScope.kUserSettingMyChannels;
|
|
import java.io.UnsupportedEncodingException;
|
import java.net.URLDecoder;
|
import java.nio.charset.StandardCharsets;
|
import java.sql.Timestamp;
|
import java.util.ArrayList;
|
import java.util.Base64;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.concurrent.ConcurrentHashMap;
|
import java.util.concurrent.Executors;
|
import java.util.concurrent.ScheduledExecutorService;
|
import java.util.concurrent.ThreadFactory;
|
import java.util.concurrent.TimeUnit;
|
|
import org.apache.log4j.Logger;
|
import org.json.JSONObject;
|
|
import com.google.gson.Gson;
|
|
import com.vdurmont.emoji.EmojiParser;
|
|
import chat.consts.RestResult;
|
import chat.handler.data.DataList;
|
import chat.handler.data.FriendData;
|
import chat.module.Bucket;
|
import chat.module.FriendRequstBucket;
|
import chat.module.ModuleLoader;
|
import chat.module.entity.ChatSpaceType;
|
import chat.module.entity.FriendShip;
|
import chat.module.entity.MessageRecord;
|
import chat.security.AES;
|
import chat.server.call.CallObject;
|
import chat.server.im.IMDispatcher;
|
import chat.server.im.IMTopic;
|
import chat.server.moquette.message.MqttFixedHeader;
|
import chat.server.moquette.message.MqttMessageType;
|
import chat.server.moquette.message.MqttPublishMessage;
|
import chat.server.moquette.message.MqttPublishVariableHeader;
|
import chat.server.moquette.message.MqttQoS;
|
import chat.sms.OneClickLogin;
|
import chat.sms.Record;
|
import chat.sms.SmsService;
|
import chat.tools.Utils;
|
import chat.user.Client;
|
import chat.user.ClientStore;
|
import chat.user.Notify;
|
import chat.user.NotifyContent;
|
import chat.user.NotifyContentDetail;
|
import chat.user.NotifyStore;
|
import chat.user.NotifySubject;
|
import chat.user.ResultMessage;
|
import chat.user.Session;
|
import chat.user.Token;
|
import chat.user.User;
|
import chat.user.UserStore;
|
import chat.util.I18n;
|
import chat.util.MessageShardingUtil;
|
import cn.wildfirechat.common.ErrorCode;
|
import cn.wildfirechat.proto.ProtoConstants;
|
import cn.wildfirechat.proto.WFCMessage;
|
import cn.wildfirechat.proto.WFCMessage.IMHttpWrapper;
|
import frame.object.data.ID;
|
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.Unpooled;
|
import io.netty.channel.Channel;
|
import io.netty.util.internal.StringUtil;
|
|
public class ClientHandler extends CallObject {
|
|
private static FriendRequstBucket friendRequstBucket;
|
private ScheduledExecutorService mScheduledExecutorService = Executors.newScheduledThreadPool(4);
|
private static ConcurrentHashMap<String, Record> mRecords = new ConcurrentHashMap<String, Record>();
|
private static ConcurrentHashMap<String, String> mOneLoginPhone = new ConcurrentHashMap<String, String>();;
|
private static String clientType;
|
protected static Logger logger;
|
|
static {
|
friendRequstBucket = FriendRequstBucket.getInstance();
|
logger = Logger.getLogger(IMDispatcher.class);
|
}
|
|
@Override
|
protected void publishMethod() {
|
addOneMethod("login");
|
addOneMethod("sendSMSCode");
|
addOneMethod("oneLogin");
|
addOneMethod("getUser");
|
addOneMethod("pullMessage");
|
addOneMethod("notifyMessage");
|
|
addOneMethod("pullFriend");
|
addOneMethod("pullRequestFriend");
|
addOneMethod("addFriend");
|
addOneMethod("handleFriend");
|
addOneMethod("setFriendAlias");
|
addOneMethod("notifyFriend");
|
addOneMethod("notifyMesage");
|
|
addOneMethod("loadRemoteMessage");
|
addOneMethod("getClient");
|
addOneMethod("getUserSetting");
|
addOneMethod("putUserSetting");
|
addOneMethod("getUserInfo");
|
addOneMethod("setUserInfo");
|
addOneMethod("getBlacklist");
|
addOneMethod("blackListUser");
|
addOneMethod("userSearch");
|
addOneMethod("getToken");
|
addOneMethod("broadCastMessage");
|
addOneMethod("channelListen");
|
addOneMethod("channelSearch");
|
addOneMethod("createChannel");
|
addOneMethod("deleteFriend");
|
addOneMethod("destoryUser");
|
addOneMethod("dismissGroup");
|
addOneMethod("destoryChannel");
|
addOneMethod("pullChannel");
|
addOneMethod("chatRoomInfo");
|
addOneMethod("getChatRoomMember");
|
addOneMethod("joinChatRoom");
|
addOneMethod("quitChatRoom");
|
|
addOneMethod("kickOffGroup");
|
addOneMethod("kickoffPCClient");
|
addOneMethod("modifyChannel");
|
addOneMethod("transferChannel");
|
}
|
|
//接收从医视无忧发过来的新增用户信息
|
public ResultMessage createOneUser(NotifyContentDetail contentDetail) throws Exception {
|
ResultMessage resultMessage;
|
|
User user = User.setUserInfo(contentDetail);
|
|
if (UserStore.getByExtra(contentDetail.getDoctorId()) != null) {
|
resultMessage = new ResultMessage(false, "用户信息已添加过，此次不添加!");
|
return resultMessage;
|
}
|
|
User resultUser = UserStore.createOneUser(user);
|
|
resultPool.setNeedReturnCode(false);
|
if (resultUser != null) {
|
//保存到内存中
|
UserStore.addOne(user);
|
resultMessage = new ResultMessage(true, "用户信息添加成功!");
|
}
|
else {
|
resultMessage = new ResultMessage(false, "用户信息添加失败!");
|
}
|
|
return resultMessage;
|
}
|
|
//接收从医视无忧发过来的修改用户信息
|
public ResultMessage modifyOneUser(NotifyContentDetail contentDetail) throws Exception {
|
ResultMessage resultMessage;
|
User user = User.setUserInfo(contentDetail);
|
|
//更新第二个参数:确定唯一记录的字段;第三个参数:更新排除的字段;
|
Map<String, String> excludeColumn = new HashMap<String, String>();
|
excludeColumn.put("id", "id");
|
int resultRecord = UserStore.modifyUser(user, "extra", excludeColumn);
|
|
resultPool.setNeedReturnCode(false);
|
if (resultRecord > 0) {
|
//修改内存中的数据
|
User modifyUser = UserStore.getByExtra(user.getExtra());
|
modifyUser.reLoad(user);
|
|
resultMessage = new ResultMessage(true, "用户信息修改成功!");
|
}
|
else if (resultRecord == -1){
|
resultMessage = new ResultMessage(false, "用户唯一记录的字段ID值为空");
|
}
|
else {
|
resultMessage = new ResultMessage(false, "用户信息修改失败!");
|
}
|
|
return resultMessage;
|
}
|
|
//接收从医视无忧发过来的消息 增加JSON解析
|
public void notifyMesage() throws Exception {
|
ResultMessage resultMessage = null;
|
|
if (dataPool != null) {
|
if (dataPool.getBody() == null || dataPool.getBody().equals("")) {
|
return;
|
}
|
}
|
else {
|
return;
|
}
|
|
NotifySubject notifySubject = new Gson().fromJson(dataPool.getBody(), NotifySubject.class);
|
|
//1.判断是否是增加、修改、基础消息
|
if (notifySubject.getMsgtitle().contains("addUser") || notifySubject.getMsgtitle().contains("modifyUser")) {//增加
|
NotifyContentDetail contentDetail = notifySubject.getMsgcontent().getContent();
|
if (notifySubject.getMsgtitle().contains("addUser")) {
|
resultMessage = createOneUser(contentDetail);
|
} else if (notifySubject.getMsgtitle().contains("modifyUser")) {
|
resultMessage = modifyOneUser(contentDetail);
|
}
|
}
|
else {//基础消息
|
Notify notify = new Notify();
|
notify.setId(ID.newValue());
|
notify.setSender(notifySubject.getSender());
|
notify.setRoletype(notifySubject.getMsgcontent().getContent().getRoletype());
|
notify.setTarget(notifySubject.getMsgcontent().getContent().getDoctorId());
|
notify.setMsgtitle(notifySubject.getMsgcontent().getTitle());
|
notify.setMsgcontent(notifySubject.getMsgtitle());
|
notify.setMsgtime(notifySubject.getMsgtime());
|
notify.setIsread("F");
|
|
boolean result = Notify.saveNotify(notify);
|
if (result) {
|
//保存内存
|
NotifyStore.addOne(notify);
|
resultMessage = new ResultMessage(true, "通知接收成功!");
|
} else {
|
resultMessage = new ResultMessage(false, "通知接收失败!");
|
}
|
}
|
|
resultPool.setNeedReturnCode(false);
|
|
resultPool.add("success", resultMessage.isFlag());
|
resultPool.add("msg", resultMessage.getMessage(), false);
|
resultPool.add("timestamp", System.currentTimeMillis());
|
}
|
|
public void login() throws Exception {
|
//0. load client type
|
clientType = dataPool.getString("roletype");
|
//1. load client
|
Client client = ClientStore.getOrCreate(dataPool);
|
//2. load user
|
client.createSession();
|
|
//3. write back
|
User user = client.getUser();
|
Session session = client.getSession();
|
Token token = session.getToken();
|
|
String mobile = "";
|
String code = "";
|
|
//如果，不是一键登陆
|
if(dataPool.getString("token") == null || mOneLoginPhone.get(dataPool.getString("token")) == null) {
|
//短信验证码
|
mobile = dataPool.getString("mobile");
|
code = dataPool.getString("code");
|
//短信验证
|
if (mRecords.get(mobile) != null) {
|
if (mRecords.get(mobile).getCode().equalsIgnoreCase(code)) {
|
mRecords.remove(mobile);
|
} else {
|
return;
|
}
|
}
|
else if (!"66666".equals(code)) {//超级密码错误
|
return;
|
}
|
} else {
|
mobile = mOneLoginPhone.get(dataPool.getString("token"));
|
mOneLoginPhone.remove(dataPool.getString("token"));
|
}
|
|
byte[] tokenByte = token.getFullValue();
|
tokenByte = AES.AESEncrypt(tokenByte, "");
|
String tokenValue = Base64.getEncoder().encodeToString(tokenByte);
|
|
resultPool.add("userId", user.getId());
|
resultPool.add("username", user.getName());
|
resultPool.add("token", tokenValue, false);
|
resultPool.add("portrait", user.getPortrait());
|
resultPool.add("isregister", true);
|
resultPool.add("doctorId", user.getExtra() == null ? "" : user.getExtra());
|
}
|
|
public void oneLogin() throws Exception {
|
String token = dataPool.getString("token");
|
OneClickLogin oneLogin = new OneClickLogin();
|
String phone = oneLogin.mobileLogin(token);
|
mOneLoginPhone.put(token, phone);
|
dataPool.setPhone(phone);
|
login();
|
}
|
|
public void sendSMSCode() throws Exception {
|
RestResult result = null;
|
String message = "";
|
String mobile = dataPool.getString("mobile");
|
String code = Utils.getRandomCode(4);
|
SmsService smsService = new SmsService();
|
Record record = mRecords.get(mobile);
|
if(record != null) {
|
resultPool.add("code", 0);
|
resultPool.add("message", "ERROR_SEND_SMS_OVER_FREQUENCY");
|
resultPool.add("result", result);
|
return;
|
}
|
mRecords.put(mobile, new Record(code, mobile));
|
|
RestResult.RestCode restCode = smsService.sendAliyunCode(mobile, code);
|
if (restCode == RestResult.RestCode.SUCCESS) {
|
result = RestResult.ok(restCode);
|
message = "SUCCESS";
|
} else {
|
result = RestResult.error(restCode);
|
message = "ERROR_NOT_LOGIN";
|
}
|
|
resultPool.add("code", 0);
|
resultPool.add("message", message);
|
resultPool.add("result", result);
|
}
|
|
//用户登陆加载好友列表
|
public void pullFriend() {
|
//1.得到对应用户所有的朋友
|
List<FriendData> friendDataList = new ArrayList<FriendData>();
|
|
List<FriendShip> checkUser = user.getFriendship(user.getId());
|
|
if (checkUser == null) {
|
resultPool.setBytes(null);
|
return;
|
}
|
|
for (FriendShip friendShip : user.getFriendship(user.getId())) {
|
friendDataList.add(new FriendData(friendShip.getUserid(), friendShip.getFriendid(),
|
UserStore.getById(friendShip.getFriendid()).getDisplayName(), "", 0, 0, System.currentTimeMillis()));
|
}
|
|
// List<FriendData> friendDataList = DataList.getFriendList();
|
|
WFCMessage.GetFriendsResult.Builder builder = WFCMessage.GetFriendsResult.newBuilder();
|
for (FriendData data : friendDataList) {
|
WFCMessage.Friend.Builder builder1 = WFCMessage.Friend.newBuilder();
|
|
builder1.setState(data.getState());
|
builder1.setBlacked(data.getBlacked());
|
builder1.setUid(data.getFriendUid());
|
builder1.setUpdateDt(data.getTimestamp());
|
|
if (!StringUtil.isNullOrEmpty(data.getAlias())) {
|
builder1.setAlias(data.getAlias());
|
}
|
if (!StringUtil.isNullOrEmpty(data.getExtra())) {
|
builder1.setExtra(data.getExtra());
|
}
|
|
builder.addEntry(builder1.build());
|
}
|
|
byte[] bytes = builder.build().toByteArray();
|
resultPool.setBytes(bytes);
|
}
|
|
//用户登陆添加好友请求
|
public void pullRequestFriend() {
|
//WFCMessage.Version request = (WFCMessage.Version) dataPool.getWFCMessage(WFCMessage.Version.class);
|
|
List<WFCMessage.FriendRequest> friendDatas = new ArrayList<WFCMessage.FriendRequest>();
|
List<FriendShip> friendShipList = user.getApplyFriendShip(user.getId());
|
|
if (friendShipList != null) {
|
for (FriendShip friendShip : friendShipList) {
|
friendDatas.add(friendShip.getFriendRequest());
|
}
|
}
|
|
WFCMessage.GetFriendRequestResult.Builder builder = WFCMessage.GetFriendRequestResult.newBuilder();
|
builder.addAllEntry(friendDatas);
|
|
byte[] bytes = builder.build().toByteArray();
|
resultPool.setBytes(bytes);
|
}
|
|
//MN
|
public void notifyMessage() {
|
//
|
System.out.println("触发MN消息");
|
}
|
|
//MP
|
public void pullMessage() throws Exception {
|
//1.输入参数
|
WFCMessage.PullMessageRequest request = (WFCMessage.PullMessageRequest) dataPool.getWFCMessage(WFCMessage.PullMessageRequest.class);
|
|
if (request == null) {
|
return;
|
}
|
|
WFCMessage.PullMessageResult.Builder builder = WFCMessage.PullMessageResult.newBuilder();
|
|
List<WFCMessage.Message> messageList = user.getUnreceivedMessageList();
|
|
for (WFCMessage.Message message: messageList) {
|
builder.addMessage(message);
|
}
|
|
//2.
|
builder.setCurrent(DataList.timestamp);
|
builder.setHead(DataList.timestamp);
|
|
//3.
|
byte[] bytes = builder.build().toByteArray();
|
resultPool.setBytes(bytes);
|
}
|
|
//FAR
|
public void addFriend() {
|
try {
|
// String userId = dataPool.getString("userId");
|
//
|
// WFCMessage.AddFriendRequest.Builder addFriendRequestBuild = WFCMessage.AddFriendRequest.newBuilder();
|
// addFriendRequestBuild.setReason(dataPool.getString("reason"));
|
// addFriendRequestBuild.setTargetUid(dataPool.getString("friendUid"));
|
//
|
// WFCMessage.AddFriendRequest addFriendRequest = addFriendRequestBuild.build();
|
WFCMessage.AddFriendRequest friendRequest = (WFCMessage.AddFriendRequest) dataPool.getWFCMessage(WFCMessage.AddFriendRequest.class);
|
|
//将用户请求消息挂到请求的user下面
|
user.addUserFriendShip(user.getId(), friendRequest);
|
|
//增加用户验证请求
|
//friendRequstBucket.createFriendRequest(userId, addFriendRequest, head);
|
resultPool.setBytes(null);
|
//发通知 String NotifyFriendRequestTopic = "FRN";
|
//publisher.publishNotification(IMTopic.NotifyFriendRequestTopic, addFriendRequest.getTargetUid(), head[0], userId, addFriendRequest.getReason());
|
// mScheduledExecutorService.schedule(threadFactory.newThread(new Runnable() {
|
// @Override
|
// public void run() {
|
// exeMessage(IMTopic.NotifyFriendRequestTopic, addFriendRequest.getTargetUid(), head[0], userId, addFriendRequest.getReason());
|
// }
|
// }), 100, TimeUnit.MILLISECONDS);
|
|
}
|
catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
//加朋友的对方，接受请求
|
public void handleFriend() throws Exception {
|
//头
|
WFCMessage.HandleFriendRequest request = (WFCMessage.HandleFriendRequest) dataPool.getWFCMessage(WFCMessage.HandleFriendRequest.class);
|
|
//尾
|
long[] heads = new long[2];
|
WFCMessage.Message.Builder builder = WFCMessage.Message.newBuilder();
|
builder.setFromUser(request.getTargetUid());
|
|
user.handleFriendRequest(user.getId(), request, builder, heads);
|
|
//6.发通知消息
|
long messageId = MessageShardingUtil.generateId();
|
long timestamp = System.currentTimeMillis();
|
builder.setMessageId(messageId);
|
builder.setServerTimestamp(timestamp);
|
ChatSpaceType spaceType = ChatSpaceType.pase(builder.build().getConversation().getType());
|
Bucket<?> bucket = Bucket.getInstance(spaceType);
|
bucket.pushOneMessage(builder.build(), UserStore.getById(request.getTargetUid()), false);
|
|
//7.发问候语消息
|
String language = "zh";
|
WFCMessage.MessageContent.Builder contentBuilder = WFCMessage.MessageContent.newBuilder();
|
contentBuilder.setType(90).setContent(I18n.getString(language, "Above_Greeting_Message"));
|
|
builder = WFCMessage.Message.newBuilder();
|
builder.setFromUser(request.getTargetUid());
|
builder.setConversation(WFCMessage.Conversation.newBuilder().setTarget(user.getId()).setLine(0).setType(ProtoConstants.ConversationType.ConversationType_Private).build());
|
builder.setContent(contentBuilder);
|
timestamp = System.currentTimeMillis();
|
builder.setServerTimestamp(timestamp);
|
|
messageId = MessageShardingUtil.generateId();
|
builder.setMessageId(messageId);
|
bucket.pushOneMessage(builder.build(), UserStore.getById(request.getTargetUid()), false);
|
|
//8.开始聊天消息
|
contentBuilder.setContent(I18n.getString(language, "Friend_Can_Start_Chat"));
|
builder.setContent(contentBuilder);
|
messageId = MessageShardingUtil.generateId();
|
builder.setMessageId(messageId);
|
timestamp = System.currentTimeMillis();
|
builder.setServerTimestamp(timestamp);
|
bucket.pushOneMessage(builder.build(), UserStore.getById(request.getTargetUid()));
|
|
//9.self消息
|
ModuleLoader.getImBusinessScheduler().execute(() -> bucket.getOne(user.getId()).notifyOneFriend(IMTopic.NotifyFriendTopic, request.getTargetUid(), heads[0]));
|
|
//10.target消息
|
ModuleLoader.getImBusinessScheduler().execute(() -> bucket.getOne(user.getId()).notifyOneFriend(IMTopic.NotifyFriendTopic, user.getId(), heads[1]));
|
|
resultPool.setBytes(null);
|
}
|
|
public void exeMessage(String topic, String receiver, long head, String fromUser, String pushContent) {
|
try {
|
ByteBuf payload = Unpooled.buffer();
|
payload.writeLong(head);
|
MqttPublishMessage publishMsg;
|
publishMsg = notRetainedPublish(topic, MqttQoS.AT_MOST_ONCE, payload);
|
|
Client client = user.getClient(user.getId());
|
Session sessionC = client.getSession();
|
if (sessionC != null) {
|
Channel channel = sessionC.getChannel();
|
if (publishMsg != null) {
|
channel.writeAndFlush(publishMsg);
|
}
|
}
|
} catch(Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
public static MqttPublishMessage notRetainedPublish(String topic, MqttQoS qos, ByteBuf message) {
|
return notRetainedPublishWithMessageId(topic, qos, message, 0);
|
}
|
|
private static MqttPublishMessage notRetainedPublishWithMessageId(String topic, MqttQoS qos, ByteBuf message,
|
int messageId) {
|
MqttFixedHeader fixedHeader = new MqttFixedHeader(MqttMessageType.PUBLISH, false, qos, false, 0);
|
MqttPublishVariableHeader varHeader = new MqttPublishVariableHeader(topic, messageId);
|
return new MqttPublishMessage(fixedHeader, varHeader, message);
|
}
|
|
private ThreadFactory threadFactory = new ThreadFactory() {
|
@Override
|
public Thread newThread(final Runnable r) {
|
return new Thread() {
|
@Override
|
public void run() {
|
r.run();
|
}
|
};
|
}
|
};
|
|
public void getUserInfo() {
|
String userId = dataPool.getString("userId");
|
User user = UserStore.getById(userId);
|
if (user == null) {
|
return;
|
}
|
WFCMessage.User.Builder userBuilder = WFCMessage.User.newBuilder();
|
userBuilder.setUid(user.getId());
|
userBuilder.setName(user.getName());
|
userBuilder.setDisplayName(user.getDisplayName());
|
|
userBuilder.setPortrait(user.getPortrait());
|
userBuilder.setMobile(user.getMobile());
|
String extra = user.getExtra();
|
if (extra != null && !extra.equals("")) {
|
userBuilder.setExtra(extra);
|
} else {
|
userBuilder.setExtra("");
|
}
|
|
WFCMessage.User wfcUser = userBuilder.build();
|
|
resultPool.add(wfcUser);
|
}
|
|
public void getUser() {
|
try {
|
IMHttpWrapper httpWrapper = dataPool.getHttpWrapper();
|
byte[] bytes = null;
|
|
if (httpWrapper == null) {
|
if (dataPool.getBody() == null) {
|
logger.debug(dataPool);
|
return;
|
}
|
bytes = dataPool.getBody().getBytes();
|
} else {
|
bytes = httpWrapper.getData().toByteArray();
|
}
|
|
WFCMessage.PullUserRequest request = WFCMessage.PullUserRequest.parseFrom(bytes);
|
|
List<WFCMessage.UserRequest> requestList = request.getRequestList();
|
|
WFCMessage.PullUserResult.Builder builder = WFCMessage.PullUserResult.newBuilder();
|
logger.debug("requestList: " + requestList.size());
|
for (WFCMessage.UserRequest userRequest: requestList) {
|
String uid = userRequest.getUid();
|
|
User usr = UserStore.getById(uid);
|
logger.debug("UID====>: " + usr.getId());
|
logger.debug("Mobile====>: " + usr.getMobile());
|
logger.debug("Extra====>: " + usr.getExtra());
|
|
WFCMessage.UserResult userResult = usr.toWFCUserResult();//DataList.getUser(uid);
|
|
builder.addResult(userResult);
|
}
|
|
byte[] resBytes = builder.build().toByteArray();
|
resultPool.setBytes(resBytes);
|
}
|
catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
public void loadRemoteMessage() throws Exception {
|
// //头
|
// WFCMessage.LoadRemoteMessages request = (WFCMessage.LoadRemoteMessages) dataPool.getWFCMessage(WFCMessage.LoadRemoteMessages.class);
|
//
|
// //尾
|
// WFCMessage.PullMessageResult result = null;
|
// byte[] bytes = result.toByteArray();
|
//
|
// resultPool.setBytes(bytes);
|
}
|
|
public void getClient() {
|
Client client = session.getClient();
|
resultPool.add(client);
|
}
|
|
public void getUserSetting() {
|
WFCMessage.GetUserSettingResult.Builder builder = WFCMessage.GetUserSettingResult.newBuilder();
|
|
byte[] resBytes = builder.build().toByteArray();
|
resultPool.setBytes(ErrorCode.ERROR_CODE_NOT_MODIFIED.getCode(), resBytes);
|
}
|
|
public void putUserSetting() throws Exception {
|
WFCMessage.ModifyUserSettingReq settingRequest = (WFCMessage.ModifyUserSettingReq) dataPool.getWFCMessage(WFCMessage.ModifyUserSettingReq.class);
|
//System.out.println("aaa");
|
//WFCMessage.ModifyUserSettingReq settingRequest = dataPool.getWFCMessage(WFCMessage.ModifyUserSettingReq.class).getClass();
|
//IMHttpWrapper wrapper = dataPool.getHttpWrapper();
|
//byte[] bytes = wrapper.getData().toByteArray();
|
//WFCMessage.ModifyUserSettingReq settingRequest = WFCMessage.ModifyUserSettingReq.parseFrom(bytes);
|
|
resultPool.setBytes(null);
|
}
|
|
public void setUserInfo() {
|
|
}
|
|
public void getBlacklist() {
|
|
}
|
|
public void blackListUser() {
|
long[] head = new long[1];
|
|
try {
|
//输入
|
WFCMessage.BlackUserRequest.Builder blackUserBuilder = WFCMessage.BlackUserRequest.newBuilder();
|
blackUserBuilder.setUid(dataPool.getString("targetUid"));
|
blackUserBuilder.setStatus(dataPool.getInteger("status", 0));
|
WFCMessage.BlackUserRequest blackUserRequest = blackUserBuilder.build();
|
|
//输出
|
resultPool.setBytes(null);
|
//发通知 String NotifyFriendRequestTopic = "FRN";
|
//publisher.publishNotification(IMTopic.NotifyFriendRequestTopic, addFriendRequest.getTargetUid(), head[0], userId, addFriendRequest.getReason());
|
}
|
catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
public void broadCastMessage() throws Exception {
|
//头
|
WFCMessage.Message broadCastMessage = (WFCMessage.Message) dataPool.getWFCMessage(WFCMessage.Message.class);
|
|
//尾
|
ByteBuf payload = Unpooled.buffer();
|
long messageId = MessageRecord.newMessageId();
|
payload.ensureWritable(20).writeLong(messageId).writeLong(10L);
|
|
byte[] resBytes = payload.array();
|
resultPool.setBytes(resBytes);
|
}
|
|
public void channelListen() throws Exception {
|
//头
|
WFCMessage.ListenChannel listenChannel = (WFCMessage.ListenChannel) dataPool.getWFCMessage(WFCMessage.ListenChannel.class);
|
|
//尾
|
resultPool.setBytes(null);
|
}
|
|
public void channelSearch() throws Exception {
|
//头
|
WFCMessage.SearchUserRequest listenChannel = (WFCMessage.SearchUserRequest) dataPool.getWFCMessage(WFCMessage.SearchUserRequest.class);
|
|
//尾
|
List<WFCMessage.ChannelInfo> users = null;
|
WFCMessage.SearchChannelResult.Builder builder = WFCMessage.SearchChannelResult.newBuilder();
|
builder.addAllChannel(users);
|
builder.setKeyword(listenChannel.getKeyword());
|
byte[] resBytes = builder.build().toByteArray();
|
resultPool.setBytes(resBytes);
|
}
|
|
public void createChannel() throws Exception {
|
//头
|
WFCMessage.ChannelInfo request = (WFCMessage.ChannelInfo) dataPool.getWFCMessage(WFCMessage.ChannelInfo.class);
|
|
//尾
|
WFCMessage.ChannelInfo.Builder builder = request.toBuilder();
|
long update = System.currentTimeMillis();
|
request = builder.setUpdateDt(update).build();
|
|
WFCMessage.ModifyUserSettingReq modifyUserSettingReq = WFCMessage.ModifyUserSettingReq.newBuilder().setScope(kUserSettingMyChannels).setKey(request.getTargetId()).setValue("1").build();
|
|
byte[] resBytes = request.getTargetId().getBytes();
|
|
resultPool.setBytes(resBytes);
|
}
|
|
public void deleteFriend() throws Exception {
|
long[] head = new long[2];
|
//头
|
WFCMessage.IDBuf request = (WFCMessage.IDBuf) dataPool.getWFCMessage(WFCMessage.IDBuf.class);
|
|
//尾
|
resultPool.setBytes(null);
|
}
|
|
public void destoryUser() throws Exception {
|
//头
|
WFCMessage.IDBuf request = (WFCMessage.IDBuf) dataPool.getWFCMessage(WFCMessage.IDBuf.class);
|
WFCMessage.IDBuf.Builder requestBuilder = request.toBuilder();
|
WFCMessage.IDBuf idBuf = requestBuilder.setId(dataPool.getString("userId")).build();
|
|
//尾
|
resultPool.setBytes(null);
|
}
|
|
public void dismissGroup() throws Exception {
|
//头
|
WFCMessage.DismissGroupRequest request = (WFCMessage.DismissGroupRequest) dataPool.getWFCMessage(WFCMessage.DismissGroupRequest.class);
|
|
//尾
|
resultPool.setBytes(null);
|
}
|
|
public void destoryChannel() throws Exception {
|
//头
|
WFCMessage.IDBuf request = (WFCMessage.IDBuf) dataPool.getWFCMessage(WFCMessage.IDBuf.class);
|
|
//尾
|
resultPool.setBytes(null);
|
}
|
|
public void kickOffGroup() throws Exception {
|
//头
|
WFCMessage.RemoveGroupMemberRequest request = (WFCMessage.RemoveGroupMemberRequest) dataPool.getWFCMessage(WFCMessage.RemoveGroupMemberRequest.class);
|
|
//尾
|
resultPool.setBytes(null);
|
}
|
|
public void kickoffPCClient() throws Exception {
|
//头
|
WFCMessage.IDBuf request = (WFCMessage.IDBuf) dataPool.getWFCMessage(WFCMessage.IDBuf.class);
|
|
//尾
|
resultPool.setBytes(null);
|
}
|
|
public void modifyChannel() throws Exception {
|
//头
|
WFCMessage.ModifyChannelInfo request = (WFCMessage.ModifyChannelInfo) dataPool.getWFCMessage(WFCMessage.ModifyChannelInfo.class);
|
|
//尾
|
resultPool.setBytes(null);
|
}
|
|
public void quitChatRoom() throws Exception {
|
//头
|
WFCMessage.IDBuf request = (WFCMessage.IDBuf) dataPool.getWFCMessage(WFCMessage.IDBuf.class);
|
|
//尾
|
resultPool.setBytes(null);
|
}
|
|
public void setFriendAlias() throws Exception {
|
//头
|
WFCMessage.AddFriendRequest request = (WFCMessage.AddFriendRequest) dataPool.getWFCMessage(WFCMessage.AddFriendRequest.class);
|
|
//尾
|
resultPool.setBytes(null);
|
}
|
|
public void transferChannel() throws Exception {
|
//头
|
WFCMessage.TransferChannel request = (WFCMessage.TransferChannel) dataPool.getWFCMessage(WFCMessage.TransferChannel.class);
|
|
//尾
|
resultPool.setBytes(null);
|
}
|
|
public void userSearch() throws Exception {
|
//头
|
WFCMessage.SearchUserRequest request = (WFCMessage.SearchUserRequest) dataPool.getWFCMessage(WFCMessage.SearchUserRequest.class);
|
|
//尾
|
List<WFCMessage.User> users = user.searchUser(request.getKeyword(), request.getFuzzy(), request.getPage());
|
WFCMessage.SearchUserResult.Builder builder = WFCMessage.SearchUserResult.newBuilder();
|
builder.addAllEntry(users);
|
byte[] bytes = builder.build().toByteArray();
|
|
resultPool.setBytes(bytes);
|
}
|
|
public void getToken() {
|
Token token = session.getToken();
|
byte[] value = token.getFullValue();
|
|
resultPool.add(value);
|
}
|
|
public static void main(String[] args) throws Exception {
|
String dataStr = "\\344\\275\\240\\344\\273\\254\\345\\267\\262\\347\\273\\217\\346\\210\\220\\344\\270\\272\\345\\245\\275\\345\\217\\213\\344\\272\\206\\357\\274\\214\\347\\216\\260\\345\\234\\250\\345\\217\\257\\344\\273\\245\\345\\274\\200\\345\\247\\213\\350\\201\\212\\345\\244\\251\\344\\272\\206";
|
if (! dataStr.contains("\\")) {
|
System.out.println("1:" + dataStr);;
|
}
|
//不属于八进制内容的字符
|
StringBuilder oldBuffer = new StringBuilder();
|
//属于八进制的内容，转成十六进制后缓存在这里
|
StringBuilder hexBuffer = new StringBuilder();
|
for (int i = 0; i < dataStr.length(); i ++) {
|
char c = dataStr.charAt(i);
|
if (c != '\\') {
|
oldBuffer.append(c);
|
}
|
//反斜杠往后3个为一组，组成了一个八进制数。例如\20710,其实是207组成了一个八进制数
|
else {
|
char c1 = dataStr.charAt(i + 1);
|
char c2 = dataStr.charAt(i + 2);
|
char c3 = dataStr.charAt(i + 3);
|
i += 3;
|
//将八进制转换为十进制，再转换为十六进制
|
String hex = Integer.toHexString((Integer.valueOf("" + c1 + c2 + c3, 8)));
|
//先缓存住，直到凑够三个字节
|
hexBuffer.append(hex);
|
String hexString = hexBuffer.toString();
|
//utf8编码中，三个字节为一个汉字
|
if (hexString.length() == 6) {
|
//凑够三个字节了，转成汉字后放入oldBuffer中
|
oldBuffer.append(hexStr2Str(hexString));
|
//凑够一个汉字了，清空缓存
|
hexBuffer = new StringBuilder();
|
}
|
}
|
}
|
System.out.println("2:" + oldBuffer.toString());
|
System.out.println("3:" + EmojiParser.parseToHtmlDecimal(oldBuffer.toString()));
|
|
// String str = "Here is a boy: :boy|type_6:!";
|
// System.out.println("原始字符为：\n" + str);
|
//
|
// System.out.println("to html：");
|
// String s = EmojiParser.parseToHtmlDecimal(str);
|
// System.out.println(s);
|
//
|
// System.out.println("还原：");
|
// System.out.println(EmojiParser.parseToUnicode(s));
|
|
String str = "苍天厚土\uD83D\uDE01 \uD83D\uDC36 \uD83E\uDD14 \uD83D\uDC7B \uD83D\uDE92";
|
System.out.println("原始字符为：\n" + str);
|
|
System.out.println("to aliases 之后：");
|
System.out.println(EmojiParser.parseToAliases(str));
|
System.out.println(EmojiParser.parseToAliases(str, EmojiParser.FitzpatrickAction.PARSE));
|
System.out.println(EmojiParser.parseToAliases(str, EmojiParser.FitzpatrickAction.REMOVE));
|
System.out.println(EmojiParser.parseToAliases(str, EmojiParser.FitzpatrickAction.IGNORE));
|
System.out.println(EmojiParser.parseToAliases(str, EmojiParser.FitzpatrickAction.IGNORE));
|
System.out.println(EmojiParser.parseToUnicode(str));
|
}
|
|
private static String hexStr2Str(String hexStr) {
|
String str = "0123456789abcdef";
|
char[] hexs = hexStr.toCharArray();
|
byte[] bytes = new byte[hexStr.length() / 2];
|
int n;
|
for (int i = 0; i < bytes.length; i++) {
|
n = str.indexOf(hexs[2 * i]) * 16;
|
n += str.indexOf(hexs[2 * i + 1]);
|
bytes[i] = (byte) (n & 0xff);
|
}
|
return new String(bytes, StandardCharsets.UTF_8);
|
}
|
|
}
|
