package com.basic.easemob;
|
|
import java.net.URLEncoder;
|
import java.util.LinkedList;
|
import java.util.List;
|
|
import org.apache.log4j.Logger;
|
import org.json.JSONArray;
|
import org.json.JSONObject;
|
import org.json.JsonUtil;
|
|
import com.basic.easemob.mapper.IMGroup;
|
import com.basic.easemob.mapper.IMMsg;
|
|
/**
|
* 全部的环信IM服务器端接口
|
*
|
* @company 北京贝思科技术有限公司
|
* @author liuyajun, 8384503@qq.com
|
* @date 2016年1月25日
|
* @time 上午11:03:45
|
*/
|
public class IM {
|
public final static String USER_NAME_PREFIX = "EASEMOB_";
|
|
private static final Logger log = Logger.getLogger(IM.class);
|
|
/**
|
* 创建单个用户<br/>
|
* 同一个IP每秒最多可调用30次
|
* @param userName
|
* @param password
|
* @return 新建用户的uuid，为null时，表示新建失败
|
*/
|
public static String createNewUser(String userName, String password) {
|
|
JSONObject data = new JSONObject();
|
data.put("username", userName);
|
data.put("password", password);
|
|
JSONObject resNode = HttpUtil.sendRequest("/users", data);
|
|
if(resNode==null || !resNode.has("entities")
|
|| resNode.getJSONArray("entities").length()==0){
|
return null;
|
}
|
|
JSONArray enty = resNode.getJSONArray("entities");
|
|
String uuid = ((JSONObject)enty.get(0)).getString("uuid");
|
|
log.info("create a easemob user and its uuid is: "+uuid);
|
|
return uuid;
|
}
|
|
/**
|
* 检查用户是否已存在<br/>
|
* 同一个IP每秒最多可调用30次
|
*
|
* @param userName
|
* @return
|
*/
|
public static boolean isUserExists(String userName){
|
JSONObject json = HttpUtil.sendRequest("/users/" + userName,
|
HttpUtil.METHOD_GET, null);
|
|
if(json==null || !json.has("entities")
|
|| json.getJSONArray("entities").length()==0){
|
return false;
|
}
|
|
JSONArray enty = json.getJSONArray("entities");
|
|
String un = ((JSONObject)enty.get(0)).getString("username");
|
return userName.equals(un);
|
}
|
|
/**
|
* 删除用户<br/>
|
* 同一个IP每秒最多可调用30
|
*
|
* @param userName
|
* @return
|
*/
|
public static boolean deleteUser(String userName){
|
JSONObject json = HttpUtil.sendRequest("/users/" + userName,
|
HttpUtil.METHOD_DELETE, null);
|
|
if(json==null || !json.has("entities")
|
|| json.getJSONArray("entities").length()==0){
|
return false;
|
}
|
|
JSONArray enty = json.getJSONArray("entities");
|
|
String un = ((JSONObject)enty.get(0)).getString("username");
|
return userName.equals(un);
|
}
|
|
/**
|
* 获取聊天记录<br/>
|
* 同一个IP每秒最多可调用1次
|
*
|
* @param lastTimestamp 上次最后一条聊天记录的timestamp，如果为空，则使用lastCursor
|
* @param lastCursor 上次获取聊天记录返回的 cursor
|
* @return 返回的每个消息里都包含timestamp，cursor
|
*/
|
public static List<IMMsg> getMsgList(Long lastTimestamp, String lastCursor){
|
|
String url = "/chatmessages";
|
|
//如果没有最后的游标，则使用最后一次时间戳
|
if(lastTimestamp !=null){
|
String q1 = "select * where timestamp>";
|
try{
|
q1 = URLEncoder.encode(q1, IMConfig.ENCODING);
|
}catch(Throwable t){
|
|
}
|
url = url + "?q1=" + q1 + lastTimestamp;
|
|
}else if(lastCursor ==null || lastCursor.trim().length()==0){
|
//没有时间戳，也没有游标，则退出
|
return null;
|
}else if(lastCursor !=null && lastCursor.trim().length()>0){
|
//有游标，使用游标
|
url = url + "?limit=600&cursor=" + lastCursor;
|
}
|
|
JSONObject json = HttpUtil.sendRequest(url, HttpUtil.METHOD_GET, null);
|
|
if(json==null || ! json.has("entities")
|
|| json.getJSONArray("entities").length()==0){
|
return null;
|
}
|
|
String cursor = null;
|
if(json.has("cursor")){
|
cursor = json.getString("cursor");
|
}
|
|
JSONArray array = json.getJSONArray("entities");
|
|
/*
|
* {
|
"uuid" : "f1a67788-c27c-11e5-a894-7ddeedf0f37b",
|
"type" : "chatmessage",
|
"created" : 1453627759061,
|
"modified" : 1453627759061,
|
"timestamp" : 1453627758434,
|
"from" : "wangjiawan",
|
"msg_id" : "154889227023155604",
|
"to" : "153783989620965808",
|
"groupId" : "153783989620965808",
|
"chat_type" : "groupchat",
|
"payload" : {
|
"bodies" : [ {
|
"type" : "txt",
|
"msg" : "为为为为"
|
|
"type" : "img",
|
"url" : "https://a1.easemob.com/bjbasic/x01/chatfiles/397611e0-c34f-11e5-8dd9-e5c2269839ee",
|
"secret" : "OXYR6sNPEeWvSVUzEI50WD6zxCw5EXpodJcLhjxiNvESXscq",
|
"filename" : "ie7.jpg",
|
"thumb" : "https://a1.easemob.com/bjbasic/x01/chatfiles/397611e0-c34f-11e5-8dd9-e5c2269839ee",
|
"thumb_secret" : "",
|
"size" : {
|
"width" : 1372,
|
"height" : 1182
|
}
|
} ],
|
"ext" : { }
|
}
|
}
|
*/
|
List<IMMsg> list = new LinkedList<IMMsg>();
|
for(int i=0, length=array.length(); i<length; i++){
|
JSONObject row = array.getJSONObject(i);
|
String chatType = row.getString("chat_type");
|
long timestamp = row.getLong("timestamp");
|
String from = row.getString("from");
|
String msgId = row.getString("msg_id");
|
String to = row.getString("to");
|
|
JSONObject payload = row.getJSONObject("payload");
|
String ext = JsonUtil.getString(payload, "ext");
|
|
JSONObject body = payload.getJSONArray("bodies").getJSONObject(0);
|
String msgType = body.getString("type");
|
String msgContent = JsonUtil.getString(body, "msg");
|
|
String mediaUrl = JsonUtil.getString(body, "url");
|
String mediaSecret = JsonUtil.getString(body, "secret");
|
String mediaFileName = JsonUtil.getString(body, "filename");
|
|
int mediaLength = 0;
|
try{
|
mediaLength = body.getInt("length");
|
}catch(Throwable t){
|
}
|
|
String addr = "";
|
double addrLat = 0;
|
double addrLng = 0;
|
try{
|
addr = body.getString("addr");
|
}catch(Throwable t){
|
|
}
|
try{
|
addrLat = body.getDouble("lat");
|
}catch(Throwable t){
|
|
}
|
try{
|
addrLng = body.getDouble("lng");
|
}catch(Throwable t){
|
|
}
|
|
IMMsg msg = new IMMsg();
|
msg.setMsgId(msgId);
|
msg.setChatType(chatType);
|
msg.setFrom(from);
|
msg.setTo(to);
|
msg.setTimestamp(timestamp);
|
msg.setMsgType(msgType);
|
msg.setMsgContent(msgContent);
|
msg.setLength(mediaLength);
|
msg.setUrl(mediaUrl);
|
msg.setSecret(mediaSecret);
|
msg.setFileName(mediaFileName);
|
msg.setAddr(addr);
|
msg.setAddrLat(addrLat);
|
msg.setAddrLng(addrLng);
|
msg.setExt(ext);
|
msg.setCursor(cursor);
|
list.add(msg);
|
}
|
|
return list;
|
}
|
|
/**
|
* 获取群组<br/>
|
* 同一个IP每秒最多可调用30次
|
*
|
* @param groupName
|
* @return
|
*/
|
public static IMGroup getGroupById(String groupId) {
|
JSONObject json = HttpUtil.sendRequest("/chatgroups/"+groupId,
|
HttpUtil.METHOD_GET, null);
|
/*
|
* "data" : [ {
|
"membersonly" : false,
|
"allowinvites" : true,
|
"public" : false,
|
"name" : "test",
|
"description" : "test",
|
"affiliations" : [ {
|
"owner" : "liuyar"
|
}, {
|
"member" : "wangjiawan"
|
} ],
|
"id" : "153783989620965808",
|
"maxusers" : 1000,
|
"affiliations_count" : 2
|
} ]
|
*/
|
if(json==null ||
|
! json.has("data") || json.getJSONArray("data").length()==0){
|
return null;
|
}
|
|
JSONObject data = json.getJSONArray("data").getJSONObject(0);
|
|
String ownerUserName = null;
|
if(data.has("affiliations") && data.getJSONArray("affiliations").length()>0){
|
JSONArray affiliations = data.getJSONArray("affiliations");
|
for(int i=0, size=affiliations.length(); i<size; i++) {
|
JSONObject subAffi =affiliations.getJSONObject(i);
|
if(subAffi.has("owner")){
|
ownerUserName = subAffi.getString("owner");
|
break;
|
}
|
}
|
}
|
|
String id = data.getString("id");
|
String name = data.getString("name");
|
|
int maxUsers = 0;
|
try{
|
maxUsers = data.getInt("maxusers");
|
}catch(Throwable t){
|
|
}
|
|
String desc = null;
|
try{
|
desc = data.getString("description");
|
}catch(Throwable t){
|
|
}
|
|
IMGroup group = new IMGroup();
|
group.setGroupId(id);
|
group.setGroupName(name);
|
group.setGroupDesc(desc);
|
group.setMaxUsers(maxUsers);
|
group.setOwnerUserName(ownerUserName);
|
|
return group;
|
}
|
|
/**
|
* 创建群组，如果群组名称已存在，则返回已存在群组
|
*
|
* @param groupName
|
* @param groupDesc
|
* @param ownerUserName
|
* @param maxUsers
|
* @param members
|
* @return
|
*/
|
public static IMGroup createGroup(String groupName, String groupDesc,
|
String ownerUserName, int maxUsers, List<String> members) {
|
groupName = groupName.replace("/", "_");
|
groupDesc = groupDesc.replace("/", "_");
|
groupDesc = groupDesc.replace(" ", "+");
|
|
/*
|
* Path : /{org_name}/{app_name}/chatgroups
|
HTTP Method : POST
|
URL Params ： 无
|
Request Headers : {“Authorization”:”Bearer ${token}”}
|
Request Body ：
|
{
|
"groupname":"testrestgrp12", //群组名称, 此属性为必须的
|
"desc":"server create group", //群组描述, 此属性为必须的
|
"public":true, //是否是公开群, 此属性为必须的
|
"maxusers":300, //群组成员最大数(包括群主), 值为数值类型,默认值200,此属性为可选的
|
"approval":true, //加入公开群是否需要批准, 默认值是false（加如公开群不需要群主批准）, 此属性为必选的，私有群必须为true
|
"owner":"jma1", //群组的管理员, 此属性为必须的
|
"members":["jma2","jma3"] //群组成员,此属性为可选的,但是如果加了此项,数组元素至少一个（注：群主jma1不需要写入到members里面）
|
}
|
*/
|
|
JSONObject data = new JSONObject();
|
data.put("groupname", groupName);
|
data.put("desc", groupDesc);
|
data.put("public", false);
|
data.put("maxusers", maxUsers);
|
data.put("approval", true);
|
data.put("owner", ownerUserName);
|
|
if(members !=null && members.size()>0){
|
JSONArray ma = new JSONArray();
|
for(String userName : members){
|
ma.put(userName);
|
}
|
|
data.put("members", ma);
|
}
|
|
JSONObject json = HttpUtil.sendRequest("/chatgroups", data);
|
/*
|
* "data" : {
|
"groupid" : "155539808804930172"
|
},
|
*/
|
if(json ==null || ! json.has("data")
|
|| !json.getJSONObject("data").has("groupid")){
|
return null;
|
}
|
|
String groupId = json.getJSONObject("data").getString("groupid");
|
|
IMGroup group = new IMGroup();
|
group.setGroupId(groupId);
|
group.setGroupName(groupName);
|
group.setGroupDesc(groupDesc);
|
group.setMaxUsers(maxUsers);
|
group.setOwnerUserName(ownerUserName);
|
|
return group;
|
}
|
|
/**
|
* 已groupId为主键，修改群组信息
|
* @param group
|
* @return
|
*/
|
public static boolean modifyGroup(IMGroup group){
|
String groupName = group.getGroupName();
|
String groupDesc = group.getGroupDesc();
|
|
groupName = groupName==null?null:groupName.replace("/", "_");
|
groupDesc = groupDesc==null?null:groupDesc.replace("/", "_");
|
groupDesc = groupDesc==null?null:groupDesc.replace(" ", "+");
|
|
/*
|
* Path : /{org_name}/{app_name}/chatgroups/{group_id}
|
HTTP Method : PUT
|
URL Params ： 无
|
Request Headers : {“Authorization”:”Bearer ${token}”}
|
Request Body ：
|
{
|
"groupname":"testrestgrp12", //群组名称，修改时值不能包含斜杠("/")
|
"description":"update+groupinfo", //群组描述，修改时值不能包含斜杠("/")。有空格时需要用“+”代替。
|
"maxusers":300, //群组成员最大数(包括群主), 值为数值类型
|
}
|
*/
|
JSONObject data = new JSONObject();
|
if(groupName !=null && groupName.trim().length()>0){
|
data.put("groupname", groupName);
|
}
|
if(groupDesc !=null && groupDesc.trim().length()>0){
|
data.put("description", groupDesc);
|
}
|
if(group.getMaxUsers()>1){
|
data.put("maxusers", group.getMaxUsers());
|
}
|
|
JSONObject ret = HttpUtil.sendRequest(
|
"/chatgroups/"+group.getGroupId(),
|
HttpUtil.METHOD_PUT, data);
|
/*
|
* "data" : {
|
"maxusers" : true,
|
"groupname" : true,
|
"description" : true
|
},
|
|
*/
|
if(ret !=null && ret.has("data")
|
&& ret.getJSONObject("data").length()>0){
|
return true;
|
}
|
|
return false;
|
}
|
|
/**
|
* 删除群组
|
* @param groupId
|
* @return
|
*/
|
public static boolean deleteGroup(String groupId){
|
JSONObject ret = HttpUtil.sendRequest(
|
"/chatgroups/"+groupId,
|
HttpUtil.METHOD_DELETE, null);
|
/*
|
* "data" : {
|
"success" : true,
|
"groupid" : "1411527886490154"
|
},
|
|
*/
|
if(ret !=null && ret.has("data")
|
&& ret.getJSONObject("data").has("success")
|
&& ret.getJSONObject("data").getBoolean("success")){
|
return true;
|
}
|
|
return false;
|
}
|
|
/**
|
* 转让群
|
* @param groupId
|
* @param newOwnerUserName
|
* @return
|
*/
|
public static boolean changeGroupOwner(String groupId, String newOwnerUserName) {
|
/*
|
* Path : /{org_name}/{app_name}/chatgroups/{groupid}
|
HTTP Method : PUT
|
URL Params ： 无
|
Request Headers : {“Content-Type”:“application/json”,“Authorization”:“Bearer ${token}”}
|
Request Body ： {“newowner”:“${new_owner_user}”}
|
Response Body ： 详情参见示例返回值, 返回的json数据中会包含除上述属性之外的一些其他信息，均可以忽略。
|
可能的错误码：
|
*/
|
JSONObject data = new JSONObject();
|
data.put("newowner", newOwnerUserName);
|
|
JSONObject json = HttpUtil.sendRequest("/chatgroups/"+groupId,
|
HttpUtil.METHOD_PUT, data);
|
/*
|
* "data": {
|
"newowner": true
|
}
|
*/
|
if(json!=null
|
&& json.has("data")
|
&& json.getJSONObject("data").has("newowner")
|
&& json.getJSONObject("data").getBoolean("newowner")){
|
return true;
|
}
|
return false;
|
}
|
|
/**
|
* 增加群成员
|
* @param groupId
|
* @param members
|
* @return
|
*/
|
public static boolean addGroupMembers(String groupId, List<String> members){
|
if(members==null || members.size()==0){
|
return false;
|
}
|
/*
|
* Path : /{org_name}/{app_name}/chatgroups/{chatgroupid}/users
|
HTTP Method : POST
|
URL Params ： 无
|
Request Headers : {“Authorization”:”Bearer ${token}”}
|
Request Body ：{“usernames”:[“username1”,”username2”]}’ — usernames固定属性，作为json的KEY；username1/username2 要添加到群中的成员用户名，可变
|
|
*/
|
JSONArray names = new JSONArray();
|
for(String name : members){
|
names.put(name);
|
}
|
JSONObject data = new JSONObject();
|
data.put("usernames", names);
|
|
JSONObject json = HttpUtil.sendRequest("/chatgroups/"+groupId+"/users",
|
data);
|
/*
|
* "data" : {
|
"newmembers" : [ "5cxhactgdj", "mh2kbjyop1" ],
|
"action" : "add_member",
|
"groupid" : "1411816013089"
|
},
|
*/
|
if(json!=null && json.has("data")
|
&& json.getJSONObject("data").has("groupid")){
|
return true;
|
}
|
return false;
|
}
|
|
public static boolean removeGroupMembers(String groupId, List<String> members){
|
if(members==null || members.size()==0){
|
return false;
|
}
|
/*
|
* Path : /{org_name}/{app_name}/chatgroups/{group_id}/users/memeber1,member2,member3
|
HTTP Method : DELETE
|
URL Params ： 无
|
Request Headers : {“Content-Type”:“application/json”,“Authorization”:“Bearer ${token}”}
|
Request Body ： 无
|
|
*/
|
StringBuffer memStr = new StringBuffer();
|
for(String mem : members){
|
memStr.append(",").append(mem);
|
}
|
memStr.deleteCharAt(0);
|
|
JSONObject json = HttpUtil.sendRequest(
|
"/chatgroups/"+groupId+"/users/"+memStr.toString(),
|
HttpUtil.METHOD_DELETE, null);
|
/*
|
* "data": [
|
{
|
"result": false,
|
"action": "remove_member",
|
"reason": "user ttestuser0015981 doesn't exist.",
|
"user": "user1",
|
"groupid": "1433492852257879"
|
},
|
|
*/
|
if(json!=null && json.has("data")
|
&& json.getJSONArray("data").length()>0){
|
return true;
|
}
|
return false;
|
}
|
}
|
