Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
I
im-common
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
陈永峰
im-common
Commits
1c96c19a
Unverified
Commit
1c96c19a
authored
Nov 19, 2021
by
Yang Libin
Committed by
GitHub
Nov 19, 2021
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
docs: add code comments (#68)
parent
784a12cf
Show whitespace changes
Inline
Side-by-side
Showing
8 changed files
with
559 additions
and
0 deletions
+559
-0
Account.java
src/main/java/io/github/doocs/im/core/Account.java
+50
-0
Group.java
src/main/java/io/github/doocs/im/core/Group.java
+176
-0
Member.java
src/main/java/io/github/doocs/im/core/Member.java
+78
-0
Message.java
src/main/java/io/github/doocs/im/core/Message.java
+57
-0
Operation.java
src/main/java/io/github/doocs/im/core/Operation.java
+43
-0
Profile.java
src/main/java/io/github/doocs/im/core/Profile.java
+22
-0
RecentContact.java
src/main/java/io/github/doocs/im/core/RecentContact.java
+22
-0
Sns.java
src/main/java/io/github/doocs/im/core/Sns.java
+111
-0
No files found.
src/main/java/io/github/doocs/im/core/Account.java
View file @
1c96c19a
...
@@ -8,13 +8,21 @@ import io.github.doocs.im.util.HttpUtil;
...
@@ -8,13 +8,21 @@ import io.github.doocs.im.util.HttpUtil;
import
java.io.IOException
;
import
java.io.IOException
;
/**
/**
* 帐号管理
*
* @author hyh
* @author hyh
* @since 2021/07/29 14:52
* @since 2021/07/29 14:52
*/
*/
public
class
Account
{
public
class
Account
{
/**
* 帐号管理服务名
*/
private
static
final
String
SERVICE_NAME
=
"im_open_login_svc"
;
private
static
final
String
SERVICE_NAME
=
"im_open_login_svc"
;
private
static
final
String
SERVICE_NAME_OPEN_IM
=
"openim"
;
private
static
final
String
SERVICE_NAME_OPEN_IM
=
"openim"
;
/**
* 帐号管理相关命令字
*/
private
static
final
String
ACCOUNT_IMPORT_COMMAND
=
"account_import"
;
private
static
final
String
ACCOUNT_IMPORT_COMMAND
=
"account_import"
;
private
static
final
String
MULTI_ACCOUNT_IMPORT_COMMAND
=
"multiaccount_import"
;
private
static
final
String
MULTI_ACCOUNT_IMPORT_COMMAND
=
"multiaccount_import"
;
private
static
final
String
ACCOUNT_DELETE_COMMAND
=
"account_delete"
;
private
static
final
String
ACCOUNT_DELETE_COMMAND
=
"account_delete"
;
...
@@ -28,31 +36,73 @@ public class Account {
...
@@ -28,31 +36,73 @@ public class Account {
this
.
imClient
=
imClient
;
this
.
imClient
=
imClient
;
}
}
/**
* 导入单个帐号
*
* @param accountImportRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
AccountImportResult
accountImport
(
AccountImportRequest
accountImportRequest
)
throws
IOException
{
public
AccountImportResult
accountImport
(
AccountImportRequest
accountImportRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
ACCOUNT_IMPORT_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
ACCOUNT_IMPORT_COMMAND
);
return
HttpUtil
.
post
(
url
,
accountImportRequest
,
AccountImportResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
accountImportRequest
,
AccountImportResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 导入多个帐号
*
* @param multiAccountImportRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
MultiAccountImportResult
multiAccountImport
(
MultiAccountImportRequest
multiAccountImportRequest
)
throws
IOException
{
public
MultiAccountImportResult
multiAccountImport
(
MultiAccountImportRequest
multiAccountImportRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
MULTI_ACCOUNT_IMPORT_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
MULTI_ACCOUNT_IMPORT_COMMAND
);
return
HttpUtil
.
post
(
url
,
multiAccountImportRequest
,
MultiAccountImportResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
multiAccountImportRequest
,
MultiAccountImportResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 删除帐号
*
* @param accountDeleteRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
AccountDeleteResult
accountDelete
(
AccountDeleteRequest
accountDeleteRequest
)
throws
IOException
{
public
AccountDeleteResult
accountDelete
(
AccountDeleteRequest
accountDeleteRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
ACCOUNT_DELETE_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
ACCOUNT_DELETE_COMMAND
);
return
HttpUtil
.
post
(
url
,
accountDeleteRequest
,
AccountDeleteResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
accountDeleteRequest
,
AccountDeleteResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 查询帐号
*
* @param accountCheckRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
AccountCheckResult
accountCheck
(
AccountCheckRequest
accountCheckRequest
)
throws
IOException
{
public
AccountCheckResult
accountCheck
(
AccountCheckRequest
accountCheckRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
ACCOUNT_CHECK_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
ACCOUNT_CHECK_COMMAND
);
return
HttpUtil
.
post
(
url
,
accountCheckRequest
,
AccountCheckResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
accountCheckRequest
,
AccountCheckResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 失效帐号登录状态
*
* @param kickRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
KickResult
kick
(
KickRequest
kickRequest
)
throws
IOException
{
public
KickResult
kick
(
KickRequest
kickRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
KICK_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
KICK_COMMAND
);
return
HttpUtil
.
post
(
url
,
kickRequest
,
KickResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
kickRequest
,
KickResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 查询帐号在线状态
*
* @param queryOnlineStatusRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
QueryOnlineStatusResult
queryOnlineStatus
(
QueryOnlineStatusRequest
queryOnlineStatusRequest
)
throws
IOException
{
public
QueryOnlineStatusResult
queryOnlineStatus
(
QueryOnlineStatusRequest
queryOnlineStatusRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME_OPEN_IM
,
QUERY_ONLINE_STATUS_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME_OPEN_IM
,
QUERY_ONLINE_STATUS_COMMAND
);
return
HttpUtil
.
post
(
url
,
queryOnlineStatusRequest
,
QueryOnlineStatusResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
queryOnlineStatusRequest
,
QueryOnlineStatusResult
.
class
,
imClient
.
getConfig
());
...
...
src/main/java/io/github/doocs/im/core/Group.java
View file @
1c96c19a
...
@@ -8,12 +8,20 @@ import io.github.doocs.im.util.HttpUtil;
...
@@ -8,12 +8,20 @@ import io.github.doocs.im.util.HttpUtil;
import
java.io.IOException
;
import
java.io.IOException
;
/**
/**
* 群组管理
*
* @author bingo
* @author bingo
* @since 2021/7/31 20:45
* @since 2021/7/31 20:45
*/
*/
public
class
Group
{
public
class
Group
{
/**
* 群组管理服务名
*/
private
static
final
String
SERVICE_NAME
=
"group_open_http_svc"
;
private
static
final
String
SERVICE_NAME
=
"group_open_http_svc"
;
/**
* 群组管理相关命令字
*/
private
static
final
String
GET_APPID_GROUP_LIST_COMMAND
=
"get_appid_group_list"
;
private
static
final
String
GET_APPID_GROUP_LIST_COMMAND
=
"get_appid_group_list"
;
private
static
final
String
CREATE_GROUP_COMMAND
=
"create_group"
;
private
static
final
String
CREATE_GROUP_COMMAND
=
"create_group"
;
private
static
final
String
GET_GROUP_INFO_COMMAND
=
"get_group_info"
;
private
static
final
String
GET_GROUP_INFO_COMMAND
=
"get_group_info"
;
...
@@ -45,121 +53,289 @@ public class Group {
...
@@ -45,121 +53,289 @@ public class Group {
this
.
imClient
=
imClient
;
this
.
imClient
=
imClient
;
}
}
/**
* 获取 App 中的所有群组
*
* @param getAppidGroupListRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
GetAppidGroupListResult
getAppIdGroupList
(
GetAppidGroupListRequest
getAppidGroupListRequest
)
throws
IOException
{
public
GetAppidGroupListResult
getAppIdGroupList
(
GetAppidGroupListRequest
getAppidGroupListRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GET_APPID_GROUP_LIST_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GET_APPID_GROUP_LIST_COMMAND
);
return
HttpUtil
.
post
(
url
,
getAppidGroupListRequest
,
GetAppidGroupListResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
getAppidGroupListRequest
,
GetAppidGroupListResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 创建群组
*
* @param createGroupRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
CreateGroupResult
createGroup
(
CreateGroupRequest
createGroupRequest
)
throws
IOException
{
public
CreateGroupResult
createGroup
(
CreateGroupRequest
createGroupRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
CREATE_GROUP_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
CREATE_GROUP_COMMAND
);
return
HttpUtil
.
post
(
url
,
createGroupRequest
,
CreateGroupResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
createGroupRequest
,
CreateGroupResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 获取群详细资料
*
* @param getGroupInfoRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
GetGroupInfoResult
getGroupInfo
(
GetGroupInfoRequest
getGroupInfoRequest
)
throws
IOException
{
public
GetGroupInfoResult
getGroupInfo
(
GetGroupInfoRequest
getGroupInfoRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GET_GROUP_INFO_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GET_GROUP_INFO_COMMAND
);
return
HttpUtil
.
post
(
url
,
getGroupInfoRequest
,
GetGroupInfoResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
getGroupInfoRequest
,
GetGroupInfoResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 获取群成员详细资料
*
* @param getGroupMemberInfoRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
GetGroupMemberInfoResult
getGroupMemberInfo
(
GetGroupMemberInfoRequest
getGroupMemberInfoRequest
)
throws
IOException
{
public
GetGroupMemberInfoResult
getGroupMemberInfo
(
GetGroupMemberInfoRequest
getGroupMemberInfoRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GET_GROUP_MEMBER_INFO_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GET_GROUP_MEMBER_INFO_COMMAND
);
return
HttpUtil
.
post
(
url
,
getGroupMemberInfoRequest
,
GetGroupMemberInfoResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
getGroupMemberInfoRequest
,
GetGroupMemberInfoResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 修改群基础资料
*
* @param modifyGroupBaseInfoRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
ModifyGroupBaseInfoResult
modifyGroupBaseInfo
(
ModifyGroupBaseInfoRequest
modifyGroupBaseInfoRequest
)
throws
IOException
{
public
ModifyGroupBaseInfoResult
modifyGroupBaseInfo
(
ModifyGroupBaseInfoRequest
modifyGroupBaseInfoRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
MODIFY_GROUP_BASE_INFO_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
MODIFY_GROUP_BASE_INFO_COMMAND
);
return
HttpUtil
.
post
(
url
,
modifyGroupBaseInfoRequest
,
ModifyGroupBaseInfoResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
modifyGroupBaseInfoRequest
,
ModifyGroupBaseInfoResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 增加群成员
*
* @param addGroupMemberRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
AddGroupMemberResult
addGroupMember
(
AddGroupMemberRequest
addGroupMemberRequest
)
throws
IOException
{
public
AddGroupMemberResult
addGroupMember
(
AddGroupMemberRequest
addGroupMemberRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
ADD_GROUP_MEMBER_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
ADD_GROUP_MEMBER_COMMAND
);
return
HttpUtil
.
post
(
url
,
addGroupMemberRequest
,
AddGroupMemberResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
addGroupMemberRequest
,
AddGroupMemberResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 删除群成员
*
* @param deleteGroupMemberRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
DeleteGroupMemberResult
deleteGroupMember
(
DeleteGroupMemberRequest
deleteGroupMemberRequest
)
throws
IOException
{
public
DeleteGroupMemberResult
deleteGroupMember
(
DeleteGroupMemberRequest
deleteGroupMemberRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
DELETE_GROUP_MEMBER_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
DELETE_GROUP_MEMBER_COMMAND
);
return
HttpUtil
.
post
(
url
,
deleteGroupMemberRequest
,
DeleteGroupMemberResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
deleteGroupMemberRequest
,
DeleteGroupMemberResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 修改群成员资料
*
* @param modifyGroupMemberInfoRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
ModifyGroupMemberInfoResult
modifyGroupMemberInfo
(
ModifyGroupMemberInfoRequest
modifyGroupMemberInfoRequest
)
throws
IOException
{
public
ModifyGroupMemberInfoResult
modifyGroupMemberInfo
(
ModifyGroupMemberInfoRequest
modifyGroupMemberInfoRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
MODIFY_GROUP_MEMBER_INFO_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
MODIFY_GROUP_MEMBER_INFO_COMMAND
);
return
HttpUtil
.
post
(
url
,
modifyGroupMemberInfoRequest
,
ModifyGroupMemberInfoResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
modifyGroupMemberInfoRequest
,
ModifyGroupMemberInfoResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 解散群组
*
* @param destroyGroupRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
DestroyGroupResult
destroyGroup
(
DestroyGroupRequest
destroyGroupRequest
)
throws
IOException
{
public
DestroyGroupResult
destroyGroup
(
DestroyGroupRequest
destroyGroupRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
DESTROY_GROUP_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
DESTROY_GROUP_COMMAND
);
return
HttpUtil
.
post
(
url
,
destroyGroupRequest
,
DestroyGroupResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
destroyGroupRequest
,
DestroyGroupResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 获取用户所加入的群组
*
* @param getJoinedGroupListRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
GetJoinGroupListResult
getJoinGroupList
(
GetJoinedGroupListRequest
getJoinedGroupListRequest
)
throws
IOException
{
public
GetJoinGroupListResult
getJoinGroupList
(
GetJoinedGroupListRequest
getJoinedGroupListRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GET_JOINED_GROUP_LIST_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GET_JOINED_GROUP_LIST_COMMAND
);
return
HttpUtil
.
post
(
url
,
getJoinedGroupListRequest
,
GetJoinGroupListResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
getJoinedGroupListRequest
,
GetJoinGroupListResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 查询用户在群组中的身份
*
* @param getRoleInGroupRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
GetRoleInGroupResult
getRoleInGroup
(
GetRoleInGroupRequest
getRoleInGroupRequest
)
throws
IOException
{
public
GetRoleInGroupResult
getRoleInGroup
(
GetRoleInGroupRequest
getRoleInGroupRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GET_ROLE_IN_GROUP_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GET_ROLE_IN_GROUP_COMMAND
);
return
HttpUtil
.
post
(
url
,
getRoleInGroupRequest
,
GetRoleInGroupResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
getRoleInGroupRequest
,
GetRoleInGroupResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 批量禁言和取消禁言
*
* @param forbidSendMsgRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
ForbidSendMsgResult
forbidSendMsg
(
ForbidSendMsgRequest
forbidSendMsgRequest
)
throws
IOException
{
public
ForbidSendMsgResult
forbidSendMsg
(
ForbidSendMsgRequest
forbidSendMsgRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
FORBID_SEND_MSG_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
FORBID_SEND_MSG_COMMAND
);
return
HttpUtil
.
post
(
url
,
forbidSendMsgRequest
,
ForbidSendMsgResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
forbidSendMsgRequest
,
ForbidSendMsgResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 获取被禁言群成员列表
*
* @param getGroupShuttedUinRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
GetGroupShuttedUinResult
getGroupShuttedUin
(
GetGroupShuttedUinRequest
getGroupShuttedUinRequest
)
throws
IOException
{
public
GetGroupShuttedUinResult
getGroupShuttedUin
(
GetGroupShuttedUinRequest
getGroupShuttedUinRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GET_GROUP_SHUTTED_UIN_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GET_GROUP_SHUTTED_UIN_COMMAND
);
return
HttpUtil
.
post
(
url
,
getGroupShuttedUinRequest
,
GetGroupShuttedUinResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
getGroupShuttedUinRequest
,
GetGroupShuttedUinResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 在群组中发送普通消息
*
* @param sendGroupMsgRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
SendGroupMsgResult
sendGroupMsg
(
SendGroupMsgRequest
sendGroupMsgRequest
)
throws
IOException
{
public
SendGroupMsgResult
sendGroupMsg
(
SendGroupMsgRequest
sendGroupMsgRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
SEND_GROUP_MSG_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
SEND_GROUP_MSG_COMMAND
);
return
HttpUtil
.
post
(
url
,
sendGroupMsgRequest
,
SendGroupMsgResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
sendGroupMsgRequest
,
SendGroupMsgResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 在群组中发送系统消息
*
* @param sendGroupSystemNotificationRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
SendGroupSystemNotificationResult
sendGroupSystemNotification
(
SendGroupSystemNotificationRequest
sendGroupSystemNotificationRequest
)
throws
IOException
{
public
SendGroupSystemNotificationResult
sendGroupSystemNotification
(
SendGroupSystemNotificationRequest
sendGroupSystemNotificationRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
SEND_GROUP_SYSTEM_NOTIFICATION_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
SEND_GROUP_SYSTEM_NOTIFICATION_COMMAND
);
return
HttpUtil
.
post
(
url
,
sendGroupSystemNotificationRequest
,
SendGroupSystemNotificationResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
sendGroupSystemNotificationRequest
,
SendGroupSystemNotificationResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 转让群主
*
* @param changeGroupOwnerRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
ChangeGroupOwnerResult
changeGroupOwner
(
ChangeGroupOwnerRequest
changeGroupOwnerRequest
)
throws
IOException
{
public
ChangeGroupOwnerResult
changeGroupOwner
(
ChangeGroupOwnerRequest
changeGroupOwnerRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
CHANGE_GROUP_OWNER_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
CHANGE_GROUP_OWNER_COMMAND
);
return
HttpUtil
.
post
(
url
,
changeGroupOwnerRequest
,
ChangeGroupOwnerResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
changeGroupOwnerRequest
,
ChangeGroupOwnerResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 撤回群消息
*
* @param groupMsgRecallRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
GroupMsgRecallResult
groupMsgRecall
(
GroupMsgRecallRequest
groupMsgRecallRequest
)
throws
IOException
{
public
GroupMsgRecallResult
groupMsgRecall
(
GroupMsgRecallRequest
groupMsgRecallRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GROUP_MSG_RECALL_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GROUP_MSG_RECALL_COMMAND
);
return
HttpUtil
.
post
(
url
,
groupMsgRecallRequest
,
GroupMsgRecallResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
groupMsgRecallRequest
,
GroupMsgRecallResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 导入群基础资料
*
* @param importGroupRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
ImportGroupResult
importGroup
(
ImportGroupRequest
importGroupRequest
)
throws
IOException
{
public
ImportGroupResult
importGroup
(
ImportGroupRequest
importGroupRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IMPORT_GROUP_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IMPORT_GROUP_COMMAND
);
return
HttpUtil
.
post
(
url
,
importGroupRequest
,
ImportGroupResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
importGroupRequest
,
ImportGroupResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 导入群消息
*
* @param importGroupMsgRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
ImportGroupMsgResult
importGroupMsg
(
ImportGroupMsgRequest
importGroupMsgRequest
)
throws
IOException
{
public
ImportGroupMsgResult
importGroupMsg
(
ImportGroupMsgRequest
importGroupMsgRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IMPORT_GROUP_MSG_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IMPORT_GROUP_MSG_COMMAND
);
return
HttpUtil
.
post
(
url
,
importGroupMsgRequest
,
ImportGroupMsgResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
importGroupMsgRequest
,
ImportGroupMsgResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 导入群成员
*
* @param importGroupMemberRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
ImportGroupMemberResult
importGroupMember
(
ImportGroupMemberRequest
importGroupMemberRequest
)
throws
IOException
{
public
ImportGroupMemberResult
importGroupMember
(
ImportGroupMemberRequest
importGroupMemberRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IMPORT_GROUP_MEMBER_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IMPORT_GROUP_MEMBER_COMMAND
);
return
HttpUtil
.
post
(
url
,
importGroupMemberRequest
,
ImportGroupMemberResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
importGroupMemberRequest
,
ImportGroupMemberResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 设置成员未读消息计数
*
* @param setUnreadMsgNumRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
SetUnreadMsgNumResult
setUnreadMsgNum
(
SetUnreadMsgNumRequest
setUnreadMsgNumRequest
)
throws
IOException
{
public
SetUnreadMsgNumResult
setUnreadMsgNum
(
SetUnreadMsgNumRequest
setUnreadMsgNumRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
SET_UNREAD_MSG_NUM_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
SET_UNREAD_MSG_NUM_COMMAND
);
return
HttpUtil
.
post
(
url
,
setUnreadMsgNumRequest
,
SetUnreadMsgNumResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
setUnreadMsgNumRequest
,
SetUnreadMsgNumResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 撤回指定用户发送的消息
*
* @param deleteGroupMsgBySenderRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
DeleteGroupMsgBySenderResult
deleteGroupMsgBySender
(
DeleteGroupMsgBySenderRequest
deleteGroupMsgBySenderRequest
)
throws
IOException
{
public
DeleteGroupMsgBySenderResult
deleteGroupMsgBySender
(
DeleteGroupMsgBySenderRequest
deleteGroupMsgBySenderRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
DELETE_GROUP_MSG_BY_SENDER_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
DELETE_GROUP_MSG_BY_SENDER_COMMAND
);
return
HttpUtil
.
post
(
url
,
deleteGroupMsgBySenderRequest
,
DeleteGroupMsgBySenderResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
deleteGroupMsgBySenderRequest
,
DeleteGroupMsgBySenderResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 拉取群成员
*
* @param groupMsgGetSimpleRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
GroupMsgGetSimpleResult
groupMsgGetSimple
(
GroupMsgGetSimpleRequest
groupMsgGetSimpleRequest
)
throws
IOException
{
public
GroupMsgGetSimpleResult
groupMsgGetSimple
(
GroupMsgGetSimpleRequest
groupMsgGetSimpleRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GROUP_MSG_GET_SIMPLE_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GROUP_MSG_GET_SIMPLE_COMMAND
);
return
HttpUtil
.
post
(
url
,
groupMsgGetSimpleRequest
,
GroupMsgGetSimpleResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
groupMsgGetSimpleRequest
,
GroupMsgGetSimpleResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 获取直播群在线人数
*
* @param getOnlineMemberNumRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
GetOnlineMemberNumResult
getOnlineMemberNum
(
GetOnlineMemberNumRequest
getOnlineMemberNumRequest
)
throws
IOException
{
public
GetOnlineMemberNumResult
getOnlineMemberNum
(
GetOnlineMemberNumRequest
getOnlineMemberNumRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GET_ONLINE_MEMBER_NUM_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GET_ONLINE_MEMBER_NUM_COMMAND
);
return
HttpUtil
.
post
(
url
,
getOnlineMemberNumRequest
,
GetOnlineMemberNumResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
getOnlineMemberNumRequest
,
GetOnlineMemberNumResult
.
class
,
imClient
.
getConfig
());
...
...
src/main/java/io/github/doocs/im/core/Member.java
View file @
1c96c19a
...
@@ -8,12 +8,20 @@ import io.github.doocs.im.util.HttpUtil;
...
@@ -8,12 +8,20 @@ import io.github.doocs.im.util.HttpUtil;
import
java.io.IOException
;
import
java.io.IOException
;
/**
/**
* 全员推送
*
* @author bingo
* @author bingo
* @since 2021/7/31 16:19
* @since 2021/7/31 16:19
*/
*/
public
class
Member
{
public
class
Member
{
/**
* 全员推送服务名
*/
private
static
final
String
SERVICE_NAME
=
"all_member_push"
;
private
static
final
String
SERVICE_NAME
=
"all_member_push"
;
/**
* 全员推送相关命令字
*/
private
static
final
String
IM_PUSH_COMMAND
=
"im_push"
;
private
static
final
String
IM_PUSH_COMMAND
=
"im_push"
;
private
static
final
String
IM_SET_ATTR_NAME_COMMAND
=
"im_set_attr_name"
;
private
static
final
String
IM_SET_ATTR_NAME_COMMAND
=
"im_set_attr_name"
;
private
static
final
String
IM_GET_ATTR_NAME_COMMAND
=
"im_get_attr_name"
;
private
static
final
String
IM_GET_ATTR_NAME_COMMAND
=
"im_get_attr_name"
;
...
@@ -31,51 +39,121 @@ public class Member {
...
@@ -31,51 +39,121 @@ public class Member {
this
.
imClient
=
imClient
;
this
.
imClient
=
imClient
;
}
}
/**
* 全员推送
*
* @param imPushRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
ImPushResult
imPush
(
ImPushRequest
imPushRequest
)
throws
IOException
{
public
ImPushResult
imPush
(
ImPushRequest
imPushRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IM_PUSH_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IM_PUSH_COMMAND
);
return
HttpUtil
.
post
(
url
,
imPushRequest
,
ImPushResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
imPushRequest
,
ImPushResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 设置应用属性名称
*
* @param imSetAttrNameRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
ImSetAttrNameResult
imSetAttrName
(
ImSetAttrNameRequest
imSetAttrNameRequest
)
throws
IOException
{
public
ImSetAttrNameResult
imSetAttrName
(
ImSetAttrNameRequest
imSetAttrNameRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IM_SET_ATTR_NAME_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IM_SET_ATTR_NAME_COMMAND
);
return
HttpUtil
.
post
(
url
,
imSetAttrNameRequest
,
ImSetAttrNameResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
imSetAttrNameRequest
,
ImSetAttrNameResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 获取应用属性名称
*
* @param imGetAttrNameRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
ImGetAttrNameResult
imGetAttrName
(
ImGetAttrNameRequest
imGetAttrNameRequest
)
throws
IOException
{
public
ImGetAttrNameResult
imGetAttrName
(
ImGetAttrNameRequest
imGetAttrNameRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IM_GET_ATTR_NAME_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IM_GET_ATTR_NAME_COMMAND
);
return
HttpUtil
.
post
(
url
,
imGetAttrNameRequest
,
ImGetAttrNameResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
imGetAttrNameRequest
,
ImGetAttrNameResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 获取用户属性
*
* @param imGetAttrRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
ImGetAttrResult
imGetAttr
(
ImGetAttrRequest
imGetAttrRequest
)
throws
IOException
{
public
ImGetAttrResult
imGetAttr
(
ImGetAttrRequest
imGetAttrRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IM_GET_ATTR_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IM_GET_ATTR_COMMAND
);
return
HttpUtil
.
post
(
url
,
imGetAttrRequest
,
ImGetAttrResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
imGetAttrRequest
,
ImGetAttrResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 设置用户属性
*
* @param imSetAttrRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
ImSetAttrResult
imSetAttr
(
ImSetAttrRequest
imSetAttrRequest
)
throws
IOException
{
public
ImSetAttrResult
imSetAttr
(
ImSetAttrRequest
imSetAttrRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IM_SET_ATTR_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IM_SET_ATTR_COMMAND
);
return
HttpUtil
.
post
(
url
,
imSetAttrRequest
,
ImSetAttrResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
imSetAttrRequest
,
ImSetAttrResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 删除用户属性
*
* @param imRemoveAttrRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
ImRemoveAttrResult
imRemoveAttr
(
ImRemoveAttrRequest
imRemoveAttrRequest
)
throws
IOException
{
public
ImRemoveAttrResult
imRemoveAttr
(
ImRemoveAttrRequest
imRemoveAttrRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IM_REMOVE_ATTR_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IM_REMOVE_ATTR_COMMAND
);
return
HttpUtil
.
post
(
url
,
imRemoveAttrRequest
,
ImRemoveAttrResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
imRemoveAttrRequest
,
ImRemoveAttrResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 获取用户标签
*
* @param imGetTagRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
ImGetTagResult
imGetTag
(
ImGetTagRequest
imGetTagRequest
)
throws
IOException
{
public
ImGetTagResult
imGetTag
(
ImGetTagRequest
imGetTagRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IM_GET_TAG_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IM_GET_TAG_COMMAND
);
return
HttpUtil
.
post
(
url
,
imGetTagRequest
,
ImGetTagResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
imGetTagRequest
,
ImGetTagResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 添加用户标签
*
* @param imAddTagRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
ImAddTagResult
imAddTag
(
ImAddTagRequest
imAddTagRequest
)
throws
IOException
{
public
ImAddTagResult
imAddTag
(
ImAddTagRequest
imAddTagRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IM_ADD_TAG_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IM_ADD_TAG_COMMAND
);
return
HttpUtil
.
post
(
url
,
imAddTagRequest
,
ImAddTagResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
imAddTagRequest
,
ImAddTagResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 删除用户标签
*
* @param imRemoveTagRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
ImRemoveTagResult
imRemoveTag
(
ImRemoveTagRequest
imRemoveTagRequest
)
throws
IOException
{
public
ImRemoveTagResult
imRemoveTag
(
ImRemoveTagRequest
imRemoveTagRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IM_REMOVE_TAG_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IM_REMOVE_TAG_COMMAND
);
return
HttpUtil
.
post
(
url
,
imRemoveTagRequest
,
ImRemoveTagResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
imRemoveTagRequest
,
ImRemoveTagResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 删除用户所有标签
*
* @param imRemoveAllTagsRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
ImRemoveAllTagsResult
imRemoveAllTags
(
ImRemoveAllTagsRequest
imRemoveAllTagsRequest
)
throws
IOException
{
public
ImRemoveAllTagsResult
imRemoveAllTags
(
ImRemoveAllTagsRequest
imRemoveAllTagsRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IM_REMOVE_ALL_TAGS_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IM_REMOVE_ALL_TAGS_COMMAND
);
return
HttpUtil
.
post
(
url
,
imRemoveAllTagsRequest
,
ImRemoveAllTagsResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
imRemoveAllTagsRequest
,
ImRemoveAllTagsResult
.
class
,
imClient
.
getConfig
());
...
...
src/main/java/io/github/doocs/im/core/Message.java
View file @
1c96c19a
...
@@ -8,12 +8,20 @@ import io.github.doocs.im.util.HttpUtil;
...
@@ -8,12 +8,20 @@ import io.github.doocs.im.util.HttpUtil;
import
java.io.IOException
;
import
java.io.IOException
;
/**
/**
* 单聊消息
*
* @author hyh
* @author hyh
* @since 2021/07/29 10:28
* @since 2021/07/29 10:28
*/
*/
public
class
Message
{
public
class
Message
{
/**
* 单聊消息服务名
*/
private
static
final
String
SERVICE_NAME
=
"openim"
;
private
static
final
String
SERVICE_NAME
=
"openim"
;
/**
* 单聊消息相关命令字
*/
private
static
final
String
SEND_MSG_COMMAND
=
"sendmsg"
;
private
static
final
String
SEND_MSG_COMMAND
=
"sendmsg"
;
private
static
final
String
IMPORT_MSG_COMMAND
=
"importmsg"
;
private
static
final
String
IMPORT_MSG_COMMAND
=
"importmsg"
;
private
static
final
String
BATCH_SEND_MSG_COMMAND
=
"batchsendmsg"
;
private
static
final
String
BATCH_SEND_MSG_COMMAND
=
"batchsendmsg"
;
...
@@ -28,36 +36,85 @@ public class Message {
...
@@ -28,36 +36,85 @@ public class Message {
this
.
imClient
=
imClient
;
this
.
imClient
=
imClient
;
}
}
/**
* 单发单聊消息
*
* @param sendMsgRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
SendMsgResult
sendMsg
(
SendMsgRequest
sendMsgRequest
)
throws
IOException
{
public
SendMsgResult
sendMsg
(
SendMsgRequest
sendMsgRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
SEND_MSG_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
SEND_MSG_COMMAND
);
return
HttpUtil
.
post
(
url
,
sendMsgRequest
,
SendMsgResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
sendMsgRequest
,
SendMsgResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 批量发单聊消息
*
* @param batchSendMsgRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
BatchSendMsgResult
batchSendMsg
(
BatchSendMsgRequest
batchSendMsgRequest
)
throws
IOException
{
public
BatchSendMsgResult
batchSendMsg
(
BatchSendMsgRequest
batchSendMsgRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
BATCH_SEND_MSG_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
BATCH_SEND_MSG_COMMAND
);
return
HttpUtil
.
post
(
url
,
batchSendMsgRequest
,
BatchSendMsgResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
batchSendMsgRequest
,
BatchSendMsgResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 导入单聊消息
*
* @param importMsgRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
ImportMsgResult
importMsg
(
ImportMsgRequest
importMsgRequest
)
throws
IOException
{
public
ImportMsgResult
importMsg
(
ImportMsgRequest
importMsgRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IMPORT_MSG_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
IMPORT_MSG_COMMAND
);
return
HttpUtil
.
post
(
url
,
importMsgRequest
,
ImportMsgResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
importMsgRequest
,
ImportMsgResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 查询单聊消息
*
* @param adminGetRoamMsgRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
AdminRoamMsgResult
getRoamMsg
(
AdminGetRoamMsgRequest
adminGetRoamMsgRequest
)
throws
IOException
{
public
AdminRoamMsgResult
getRoamMsg
(
AdminGetRoamMsgRequest
adminGetRoamMsgRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
ADMIN_GET_ROAM_MSG_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
ADMIN_GET_ROAM_MSG_COMMAND
);
return
HttpUtil
.
post
(
url
,
adminGetRoamMsgRequest
,
AdminRoamMsgResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
adminGetRoamMsgRequest
,
AdminRoamMsgResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 撤回单聊消息
*
* @param adminMsgWithdrawRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
AdminMsgWithdrawResult
msgWithdraw
(
AdminMsgWithdrawRequest
adminMsgWithdrawRequest
)
throws
IOException
{
public
AdminMsgWithdrawResult
msgWithdraw
(
AdminMsgWithdrawRequest
adminMsgWithdrawRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
ADMIN_MSG_WITHDRAW_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
ADMIN_MSG_WITHDRAW_COMMAND
);
return
HttpUtil
.
post
(
url
,
adminMsgWithdrawRequest
,
AdminMsgWithdrawResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
adminMsgWithdrawRequest
,
AdminMsgWithdrawResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 设置单聊消息已读
*
* @param adminSetMsgReadRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
AdminSetMsgReadResult
setMsgRead
(
AdminSetMsgReadRequest
adminSetMsgReadRequest
)
throws
IOException
{
public
AdminSetMsgReadResult
setMsgRead
(
AdminSetMsgReadRequest
adminSetMsgReadRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
ADMIN_SET_MSG_READ_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
ADMIN_SET_MSG_READ_COMMAND
);
return
HttpUtil
.
post
(
url
,
adminSetMsgReadRequest
,
AdminSetMsgReadResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
adminSetMsgReadRequest
,
AdminSetMsgReadResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 查询单聊未读消息计数
*
* @param getC2cUnreadMsgRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
C2cUnreadMsgNumResult
getC2cUnreadMsgNum
(
GetC2cUnreadMsgRequest
getC2cUnreadMsgRequest
)
throws
IOException
{
public
C2cUnreadMsgNumResult
getC2cUnreadMsgNum
(
GetC2cUnreadMsgRequest
getC2cUnreadMsgRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GET_C2C_UNREAD_MSG_NUM_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GET_C2C_UNREAD_MSG_NUM_COMMAND
);
return
HttpUtil
.
post
(
url
,
getC2cUnreadMsgRequest
,
C2cUnreadMsgNumResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
getC2cUnreadMsgRequest
,
C2cUnreadMsgNumResult
.
class
,
imClient
.
getConfig
());
...
...
src/main/java/io/github/doocs/im/core/Operation.java
View file @
1c96c19a
...
@@ -8,14 +8,22 @@ import io.github.doocs.im.util.HttpUtil;
...
@@ -8,14 +8,22 @@ import io.github.doocs.im.util.HttpUtil;
import
java.io.IOException
;
import
java.io.IOException
;
/**
/**
* 运营管理、全局禁言管理
*
* @author xy
* @author xy
* @since 2021/07/31 11:17
* @since 2021/07/31 11:17
*/
*/
public
class
Operation
{
public
class
Operation
{
/**
* 运营管理、全局禁言管理服务名
*/
private
static
final
String
SERVICE_NAME_OPEN_CONFIG
=
"openconfigsvr"
;
private
static
final
String
SERVICE_NAME_OPEN_CONFIG
=
"openconfigsvr"
;
private
static
final
String
SERVICE_NAME_OPEN_MSG
=
"open_msg_svc"
;
private
static
final
String
SERVICE_NAME_OPEN_MSG
=
"open_msg_svc"
;
private
static
final
String
SERVICE_NAME_CONFIG
=
"ConfigSvc"
;
private
static
final
String
SERVICE_NAME_CONFIG
=
"ConfigSvc"
;
/**
* 运营管理、全局禁言管理相关命令字
*/
private
static
final
String
SET_NO_SPEAKING_COMMAND
=
"setnospeaking"
;
private
static
final
String
SET_NO_SPEAKING_COMMAND
=
"setnospeaking"
;
private
static
final
String
GET_NO_SPEAKING_COMMAND
=
"getnospeaking"
;
private
static
final
String
GET_NO_SPEAKING_COMMAND
=
"getnospeaking"
;
private
static
final
String
GET_APP_INFO_COMMAND
=
"getappinfo"
;
private
static
final
String
GET_APP_INFO_COMMAND
=
"getappinfo"
;
...
@@ -29,26 +37,61 @@ public class Operation {
...
@@ -29,26 +37,61 @@ public class Operation {
this
.
imClient
=
imClient
;
this
.
imClient
=
imClient
;
}
}
/**
* 设置全局禁言
*
* @param setNoSpeakingRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
SetNoSpeakingResult
setNoSpeaking
(
SetNoSpeakingRequest
setNoSpeakingRequest
)
throws
IOException
{
public
SetNoSpeakingResult
setNoSpeaking
(
SetNoSpeakingRequest
setNoSpeakingRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME_OPEN_CONFIG
,
SET_NO_SPEAKING_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME_OPEN_CONFIG
,
SET_NO_SPEAKING_COMMAND
);
return
HttpUtil
.
post
(
url
,
setNoSpeakingRequest
,
SetNoSpeakingResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
setNoSpeakingRequest
,
SetNoSpeakingResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 查询全局禁言
*
* @param getNoSpeakingRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
GetNoSpeakingResult
getNoSpeaking
(
GetNoSpeakingRequest
getNoSpeakingRequest
)
throws
IOException
{
public
GetNoSpeakingResult
getNoSpeaking
(
GetNoSpeakingRequest
getNoSpeakingRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME_OPEN_CONFIG
,
GET_NO_SPEAKING_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME_OPEN_CONFIG
,
GET_NO_SPEAKING_COMMAND
);
return
HttpUtil
.
post
(
url
,
getNoSpeakingRequest
,
GetNoSpeakingResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
getNoSpeakingRequest
,
GetNoSpeakingResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 拉取运营数据
*
* @param getAppInfoRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
GetAppInfoResult
getAppInfo
(
GetAppInfoRequest
getAppInfoRequest
)
throws
IOException
{
public
GetAppInfoResult
getAppInfo
(
GetAppInfoRequest
getAppInfoRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME_OPEN_CONFIG
,
GET_APP_INFO_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME_OPEN_CONFIG
,
GET_APP_INFO_COMMAND
);
return
HttpUtil
.
post
(
url
,
getAppInfoRequest
,
GetAppInfoResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
getAppInfoRequest
,
GetAppInfoResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 下载最近消息记录
*
* @param getHistoryRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
GetHistoryResult
getHistory
(
GetHistoryRequest
getHistoryRequest
)
throws
IOException
{
public
GetHistoryResult
getHistory
(
GetHistoryRequest
getHistoryRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME_OPEN_MSG
,
GET_HISTORY_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME_OPEN_MSG
,
GET_HISTORY_COMMAND
);
return
HttpUtil
.
post
(
url
,
getHistoryRequest
,
GetHistoryResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
getHistoryRequest
,
GetHistoryResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 获取服务器 IP 地址
*
* @param getIpListRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
GetIpListResult
getIpList
(
GetIpListRequest
getIpListRequest
)
throws
IOException
{
public
GetIpListResult
getIpList
(
GetIpListRequest
getIpListRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME_CONFIG
,
GET_IP_LIST_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME_CONFIG
,
GET_IP_LIST_COMMAND
);
return
HttpUtil
.
post
(
url
,
getIpListRequest
,
GetIpListResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
getIpListRequest
,
GetIpListResult
.
class
,
imClient
.
getConfig
());
...
...
src/main/java/io/github/doocs/im/core/Profile.java
View file @
1c96c19a
...
@@ -10,12 +10,20 @@ import io.github.doocs.im.util.HttpUtil;
...
@@ -10,12 +10,20 @@ import io.github.doocs.im.util.HttpUtil;
import
java.io.IOException
;
import
java.io.IOException
;
/**
/**
* 资料管理
*
* @author hyh
* @author hyh
* @since 2021/07/29 15:11
* @since 2021/07/29 15:11
*/
*/
public
class
Profile
{
public
class
Profile
{
/**
* 资料管理服务名
*/
private
static
final
String
SERVICE_NAME
=
"profile"
;
private
static
final
String
SERVICE_NAME
=
"profile"
;
/**
* 资料管理相关命令字
*/
private
static
final
String
PORTRAIT_SET_COMMAND
=
"portrait_set"
;
private
static
final
String
PORTRAIT_SET_COMMAND
=
"portrait_set"
;
private
static
final
String
PORTRAIT_GET_COMMAND
=
"portrait_get"
;
private
static
final
String
PORTRAIT_GET_COMMAND
=
"portrait_get"
;
...
@@ -25,11 +33,25 @@ public class Profile {
...
@@ -25,11 +33,25 @@ public class Profile {
this
.
imClient
=
imClient
;
this
.
imClient
=
imClient
;
}
}
/**
* 设置资料
*
* @param portraitSetRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
PortraitSetResult
portraitSet
(
PortraitSetRequest
portraitSetRequest
)
throws
IOException
{
public
PortraitSetResult
portraitSet
(
PortraitSetRequest
portraitSetRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
PORTRAIT_SET_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
PORTRAIT_SET_COMMAND
);
return
HttpUtil
.
post
(
url
,
portraitSetRequest
,
PortraitSetResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
portraitSetRequest
,
PortraitSetResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 拉取资料
*
* @param portraitGetRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
PortraitGetResult
portraitGet
(
PortraitGetRequest
portraitGetRequest
)
throws
IOException
{
public
PortraitGetResult
portraitGet
(
PortraitGetRequest
portraitGetRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
PORTRAIT_GET_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
PORTRAIT_GET_COMMAND
);
return
HttpUtil
.
post
(
url
,
portraitGetRequest
,
PortraitGetResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
portraitGetRequest
,
PortraitGetResult
.
class
,
imClient
.
getConfig
());
...
...
src/main/java/io/github/doocs/im/core/RecentContact.java
View file @
1c96c19a
...
@@ -10,12 +10,20 @@ import io.github.doocs.im.util.HttpUtil;
...
@@ -10,12 +10,20 @@ import io.github.doocs.im.util.HttpUtil;
import
java.io.IOException
;
import
java.io.IOException
;
/**
/**
* 最近联系人
*
* @author bingo
* @author bingo
* @since 2021/10/11 10:25
* @since 2021/10/11 10:25
*/
*/
public
class
RecentContact
{
public
class
RecentContact
{
/**
* 最近联系人服务名
*/
private
static
final
String
SERVICE_NAME
=
"recentcontact"
;
private
static
final
String
SERVICE_NAME
=
"recentcontact"
;
/**
* 最近联系人相关命令字
*/
private
static
final
String
GET_RECENT_CONTACT_LIST
=
"get_list"
;
private
static
final
String
GET_RECENT_CONTACT_LIST
=
"get_list"
;
private
static
final
String
DELETE_RECENT_CONTACT
=
"delete"
;
private
static
final
String
DELETE_RECENT_CONTACT
=
"delete"
;
...
@@ -25,11 +33,25 @@ public class RecentContact {
...
@@ -25,11 +33,25 @@ public class RecentContact {
this
.
imClient
=
imClient
;
this
.
imClient
=
imClient
;
}
}
/**
* 拉取会话列表
*
* @param recentContactListRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
GetRecentContactListResult
recentContactList
(
GetRecentContactListRequest
recentContactListRequest
)
throws
IOException
{
public
GetRecentContactListResult
recentContactList
(
GetRecentContactListRequest
recentContactListRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GET_RECENT_CONTACT_LIST
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GET_RECENT_CONTACT_LIST
);
return
HttpUtil
.
post
(
url
,
recentContactListRequest
,
GetRecentContactListResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
recentContactListRequest
,
GetRecentContactListResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 删除单个会话
*
* @param deleteRecentContactRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
DeleteRecentContactResult
deleteRecentContact
(
DeleteRecentContactRequest
deleteRecentContactRequest
)
throws
IOException
{
public
DeleteRecentContactResult
deleteRecentContact
(
DeleteRecentContactRequest
deleteRecentContactRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
DELETE_RECENT_CONTACT
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
DELETE_RECENT_CONTACT
);
return
HttpUtil
.
post
(
url
,
deleteRecentContactRequest
,
DeleteRecentContactResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
deleteRecentContactRequest
,
DeleteRecentContactResult
.
class
,
imClient
.
getConfig
());
...
...
src/main/java/io/github/doocs/im/core/Sns.java
View file @
1c96c19a
...
@@ -12,8 +12,14 @@ import java.io.IOException;
...
@@ -12,8 +12,14 @@ import java.io.IOException;
* @since 2021/07/29 15:11
* @since 2021/07/29 15:11
*/
*/
public
class
Sns
{
public
class
Sns
{
/**
* 关系链管理服务名
*/
private
static
final
String
SERVICE_NAME
=
"sns"
;
private
static
final
String
SERVICE_NAME
=
"sns"
;
/**
* 关系链管理相关命令字
*/
private
static
final
String
FRIEND_ADD_COMMAND
=
"friend_add"
;
private
static
final
String
FRIEND_ADD_COMMAND
=
"friend_add"
;
private
static
final
String
FRIEND_IMPORT_COMMAND
=
"friend_import"
;
private
static
final
String
FRIEND_IMPORT_COMMAND
=
"friend_import"
;
private
static
final
String
FRIEND_UPDATE_COMMAND
=
"friend_update"
;
private
static
final
String
FRIEND_UPDATE_COMMAND
=
"friend_update"
;
...
@@ -36,76 +42,181 @@ public class Sns {
...
@@ -36,76 +42,181 @@ public class Sns {
this
.
imClient
=
imClient
;
this
.
imClient
=
imClient
;
}
}
/**
* 添加好友
*
* @param friendAddRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
FriendAddResult
friendAdd
(
FriendAddRequest
friendAddRequest
)
throws
IOException
{
public
FriendAddResult
friendAdd
(
FriendAddRequest
friendAddRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
FRIEND_ADD_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
FRIEND_ADD_COMMAND
);
return
HttpUtil
.
post
(
url
,
friendAddRequest
,
FriendAddResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
friendAddRequest
,
FriendAddResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 导入好友
*
* @param friendImportRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
FriendImportResult
friendImport
(
FriendImportRequest
friendImportRequest
)
throws
IOException
{
public
FriendImportResult
friendImport
(
FriendImportRequest
friendImportRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
FRIEND_IMPORT_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
FRIEND_IMPORT_COMMAND
);
return
HttpUtil
.
post
(
url
,
friendImportRequest
,
FriendImportResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
friendImportRequest
,
FriendImportResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 更新好友
*
* @param friendUpdateRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
FriendUpdateResult
friendUpdate
(
FriendUpdateRequest
friendUpdateRequest
)
throws
IOException
{
public
FriendUpdateResult
friendUpdate
(
FriendUpdateRequest
friendUpdateRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
FRIEND_UPDATE_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
FRIEND_UPDATE_COMMAND
);
return
HttpUtil
.
post
(
url
,
friendUpdateRequest
,
FriendUpdateResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
friendUpdateRequest
,
FriendUpdateResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 删除好友
*
* @param friendDeleteRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
FriendDeleteResult
friendDelete
(
FriendDeleteRequest
friendDeleteRequest
)
throws
IOException
{
public
FriendDeleteResult
friendDelete
(
FriendDeleteRequest
friendDeleteRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
FRIEND_DELETE_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
FRIEND_DELETE_COMMAND
);
return
HttpUtil
.
post
(
url
,
friendDeleteRequest
,
FriendDeleteResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
friendDeleteRequest
,
FriendDeleteResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 删除所有好友
*
* @param friendDeleteAllRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
FriendDeleteAllResult
friendDeleteAll
(
FriendDeleteAllRequest
friendDeleteAllRequest
)
throws
IOException
{
public
FriendDeleteAllResult
friendDeleteAll
(
FriendDeleteAllRequest
friendDeleteAllRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
FRIEND_DELETE_ALL_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
FRIEND_DELETE_ALL_COMMAND
);
return
HttpUtil
.
post
(
url
,
friendDeleteAllRequest
,
FriendDeleteAllResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
friendDeleteAllRequest
,
FriendDeleteAllResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 校验好友
*
* @param friendCheckRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
FriendCheckResult
friendCheck
(
FriendCheckRequest
friendCheckRequest
)
throws
IOException
{
public
FriendCheckResult
friendCheck
(
FriendCheckRequest
friendCheckRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
FRIEND_CHECK_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
FRIEND_CHECK_COMMAND
);
return
HttpUtil
.
post
(
url
,
friendCheckRequest
,
FriendCheckResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
friendCheckRequest
,
FriendCheckResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 拉取好友
*
* @param friendGetRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
FriendGetResult
friendGet
(
FriendGetRequest
friendGetRequest
)
throws
IOException
{
public
FriendGetResult
friendGet
(
FriendGetRequest
friendGetRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
FRIEND_GET_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
FRIEND_GET_COMMAND
);
return
HttpUtil
.
post
(
url
,
friendGetRequest
,
FriendGetResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
friendGetRequest
,
FriendGetResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 拉取指定好友
*
* @param friendGetListRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
FriendGetListResult
friendGetList
(
FriendGetListRequest
friendGetListRequest
)
throws
IOException
{
public
FriendGetListResult
friendGetList
(
FriendGetListRequest
friendGetListRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
FRIEND_GET_LIST_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
FRIEND_GET_LIST_COMMAND
);
return
HttpUtil
.
post
(
url
,
friendGetListRequest
,
FriendGetListResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
friendGetListRequest
,
FriendGetListResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 添加黑名单
*
* @param blackListAddRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
BlackListAddResult
blackListAdd
(
BlackListAddRequest
blackListAddRequest
)
throws
IOException
{
public
BlackListAddResult
blackListAdd
(
BlackListAddRequest
blackListAddRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
BLACK_LIST_ADD_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
BLACK_LIST_ADD_COMMAND
);
return
HttpUtil
.
post
(
url
,
blackListAddRequest
,
BlackListAddResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
blackListAddRequest
,
BlackListAddResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 删除黑名单
*
* @param blackListDeleteRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
BlackListDeleteResult
blackListDelete
(
BlackListDeleteRequest
blackListDeleteRequest
)
throws
IOException
{
public
BlackListDeleteResult
blackListDelete
(
BlackListDeleteRequest
blackListDeleteRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
BLACK_LIST_DELETE_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
BLACK_LIST_DELETE_COMMAND
);
return
HttpUtil
.
post
(
url
,
blackListDeleteRequest
,
BlackListDeleteResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
blackListDeleteRequest
,
BlackListDeleteResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 拉取黑名单
*
* @param blackListGetRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
BlackListGetResult
blackListGet
(
BlackListGetRequest
blackListGetRequest
)
throws
IOException
{
public
BlackListGetResult
blackListGet
(
BlackListGetRequest
blackListGetRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
BLACK_LIST_GET_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
BLACK_LIST_GET_COMMAND
);
return
HttpUtil
.
post
(
url
,
blackListGetRequest
,
BlackListGetResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
blackListGetRequest
,
BlackListGetResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 校验黑名单
*
* @param blackListCheckRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
BlackListCheckResult
blackListCheck
(
BlackListCheckRequest
blackListCheckRequest
)
throws
IOException
{
public
BlackListCheckResult
blackListCheck
(
BlackListCheckRequest
blackListCheckRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
BLACK_LIST_CHECK_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
BLACK_LIST_CHECK_COMMAND
);
return
HttpUtil
.
post
(
url
,
blackListCheckRequest
,
BlackListCheckResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
blackListCheckRequest
,
BlackListCheckResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 添加分组
*
* @param groupAddRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
GroupAddResult
groupAdd
(
GroupAddRequest
groupAddRequest
)
throws
IOException
{
public
GroupAddResult
groupAdd
(
GroupAddRequest
groupAddRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GROUP_ADD_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GROUP_ADD_COMMAND
);
return
HttpUtil
.
post
(
url
,
groupAddRequest
,
GroupAddResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
groupAddRequest
,
GroupAddResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 删除分组
*
* @param groupDeleteRequest 请求参数
* @return 结果
* @throws IOException 异常
*/
public
GroupDeleteResult
groupDelete
(
GroupDeleteRequest
groupDeleteRequest
)
throws
IOException
{
public
GroupDeleteResult
groupDelete
(
GroupDeleteRequest
groupDeleteRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GROUP_DELETE_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GROUP_DELETE_COMMAND
);
return
HttpUtil
.
post
(
url
,
groupDeleteRequest
,
GroupDeleteResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
groupDeleteRequest
,
GroupDeleteResult
.
class
,
imClient
.
getConfig
());
}
}
/**
* 拉取分组 结果
*
* @param groupGetRequest 请求参数
* @return
* @throws IOException 异常
*/
public
GroupGetResult
groupGet
(
GroupGetRequest
groupGetRequest
)
throws
IOException
{
public
GroupGetResult
groupGet
(
GroupGetRequest
groupGetRequest
)
throws
IOException
{
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GROUP_GET_COMMAND
);
String
url
=
imClient
.
getUrl
(
SERVICE_NAME
,
GROUP_GET_COMMAND
);
return
HttpUtil
.
post
(
url
,
groupGetRequest
,
GroupGetResult
.
class
,
imClient
.
getConfig
());
return
HttpUtil
.
post
(
url
,
groupGetRequest
,
GroupGetResult
.
class
,
imClient
.
getConfig
());
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment