query = new BmobQuery<>();
+ query.addWhereEqualTo("installationId", installId);
mPushManager.setQuery(query);
mPushManager.pushMessage(json, pushListener);
}
-
/**
* 发送建群消息
*
@@ -660,10 +693,10 @@ public void sendJsonMessage(String installId,String json,PushListener pushListen
* @param contacts 群组成员(还没包括群主)
*/
public void sendCreateGroupMessage(String groupName, final String groupDescription, final List contacts, final OnCreateGroupTableListener listener) {
-// 这里要把群主消息加进来
+ // 这里要把群主消息加进来
contacts.add(0, UserManager.getInstance().getCurrentUser().getObjectId());
GroupTableMessage message = createGroupTableMessage(groupName, groupDescription, contacts);
- message.setReadStatus(Constant.READ_STATUS_READED);
+ message.setReadStatus(ConstantUtil.READ_STATUS_READED);
message.save(new SaveListener() {
@Override
public void done(String s, BmobException e) {
@@ -675,7 +708,7 @@ public void done(String s, BmobException e) {
public void done(BmobException e) {
if (e == null) {
UserDBManager.getInstance().addOrUpdateGroupTable(message);
-// 这里先上传再推送，因为对方可能接收到推送信息的时候无法即时获取到服务器上的群结构消息,也就查询信息失败
+ // 这里先上传再推送，因为对方可能接收到推送信息的时候无法即时获取到服务器上的群结构消息,也就查询信息失败
// todo 群结构的解决
uploadChatTableMessage(message, new QueryListListener() {
@Override
@@ -683,10 +716,10 @@ public void done(List list, BmobException e) {
if (e == null) {
LogUtil.e("批量保存群结构消息成功");
- MessageContent messageContent=new MessageContent();
+ MessageContent messageContent = new MessageContent();
messageContent.setContent("大家好");
sendGroupChatMessage(createGroupChatMessage(gson.toJson(messageContent)
- , message.getGroupId(), Constant.TAG_MSG_TYPE_TEXT), new OnCreateChatMessageListener() {
+ , message.getGroupId(), ConstantUtil.TAG_MSG_TYPE_TEXT), new OnCreateChatMessageListener() {
@Override
public void onSuccess(BaseMessage baseMessage) {
UserDBManager.getInstance().addOrUpdateGroupChatMessage((GroupChatMessage) baseMessage);
@@ -703,7 +736,8 @@ public void onSuccess(BaseMessage baseMessage) {
public void onFailed(String errorMsg, BaseMessage baseMessage) {
UserDBManager
.getInstance().addOrUpdateGroupTable(message);
- listener.done(message, null); }
+ listener.done(message, null);
+ }
});
} else {
listener.done(null, e);
@@ -721,7 +755,7 @@ public void onFailed(String errorMsg, BaseMessage baseMessage) {
});
} else {
LogUtil.e("保存群主所建的群结构消息到服务器上失败" + e.toString());
- listener.done(null,e);
+ listener.done(null, e);
}
}
@@ -740,8 +774,8 @@ private void uploadChatTableMessage(final GroupTableMessage groupTableMessage, Q
List groupTableMessageList = new ArrayList<>();
for (int i = 0; i < copy.size(); i++) {
message = new GroupTableMessage();
- message.setSendStatus(Constant.SEND_STATUS_SUCCESS);
- message.setReadStatus(Constant.READ_STATUS_UNREAD);
+ message.setSendStatus(ConstantUtil.SEND_STATUS_SUCCESS);
+ message.setReadStatus(ConstantUtil.READ_STATUS_UNREAD);
message.setGroupDescription(groupTableMessage.getGroupDescription());
message.setGroupId(groupTableMessage.getGroupId());
message.setCreatedTime(groupTableMessage.getCreatedTime());
@@ -766,8 +800,8 @@ private GroupTableMessage createGroupTableMessage(String groupName, String group
message.setCreatorId(UserManager.getInstance().getCurrentUserObjectId());
message.setGroupNumber(contacts);
message.setCreatedTime(System.currentTimeMillis());
- message.setReadStatus(Constant.READ_STATUS_UNREAD);
- message.setSendStatus(Constant.SEND_STATUS_SUCCESS);
+ message.setReadStatus(ConstantUtil.READ_STATUS_UNREAD);
+ message.setSendStatus(ConstantUtil.SEND_STATUS_SUCCESS);
message.setToId(UserManager.getInstance().getCurrentUserObjectId());
message.setNotification("");
message.setRemind(Boolean.TRUE);
@@ -775,10 +809,9 @@ private GroupTableMessage createGroupTableMessage(String groupName, String group
}
-
public void queryGroupTableMessage(String uid, FindListener findListener) {
BmobQuery query = new BmobQuery<>();
- query.addWhereEqualTo(Constant.TAG_TO_ID, uid);
+ query.addWhereEqualTo(ConstantUtil.TAG_TO_ID, uid);
query.findObjects(findListener);
}
@@ -786,20 +819,15 @@ public GroupChatMessage createGroupChatMessage(String content, String groupId, i
GroupChatMessage message = new GroupChatMessage();
message.setGroupId(groupId);
message.setContent(content);
- message.setReadStatus(Constant.READ_STATUS_UNREAD);
+ message.setReadStatus(ConstantUtil.READ_STATUS_UNREAD);
message.setContentType(contentType);
message.setBelongId(UserManager.getInstance().getCurrentUserObjectId());
- message.setSendStatus(Constant.SEND_STATUS_SUCCESS);
+ message.setSendStatus(ConstantUtil.SEND_STATUS_SUCCESS);
message.setCreateTime(System.currentTimeMillis());
return message;
}
-
-
-
-
-
public GroupTableMessage createReceiveGroupTableMsg(String json) {
GroupTableMessage message = gson.fromJson(json, GroupTableMessage.class);
LogUtil.e("实时监听到的群结构消息如下1");
@@ -810,8 +838,6 @@ public GroupTableMessage createReceiveGroupTableMsg(String json) {
}
-
-
public User createUserFromJsonObject(JSONObject jsonObject) {
User user;
user = gson.fromJson(jsonObject.toString(), User.class);
@@ -820,8 +846,6 @@ public User createUserFromJsonObject(JSONObject jsonObject) {
}
-
-
private void findReadTag(String conversationId, long createTime, FindListener findListener) {
BmobQuery query = new BmobQuery<>();
query.addWhereEqualTo("conversationId", conversationId);
@@ -869,26 +893,26 @@ public void done(JSONArray jsonArray, BmobException e) {
public void updateGroupMessage(final String groupId, final String name, final String content, final UpdateListener listener) {
- GroupTableMessage groupTableMessage=new GroupTableMessage();
+ GroupTableMessage groupTableMessage = new GroupTableMessage();
groupTableMessage.setObjectId(groupId);
- switch (name){
- case Constant.GROUP_AVATAR:
- groupTableMessage.setGroupAvatar(content);
- break;
- case Constant.GROUP_NOTIFICATION:
+ switch (name) {
+ case ConstantUtil.GROUP_AVATAR:
+ groupTableMessage.setGroupAvatar(content);
+ break;
+ case ConstantUtil.GROUP_NOTIFICATION:
groupTableMessage.setNotification(content);
break;
- case Constant.GROUP_DESCRIPTION:
+ case ConstantUtil.GROUP_DESCRIPTION:
groupTableMessage.setGroupDescription(content);
break;
- case Constant.GROUP_NAME:
+ case ConstantUtil.GROUP_NAME:
groupTableMessage.setGroupName(content);
break;
- case Constant.GROUP_REMIND:
+ case ConstantUtil.GROUP_REMIND:
groupTableMessage.setRemind(Boolean.parseBoolean(content));
break;
- default:
- break;
+ default:
+ break;
}
groupTableMessage.update(listener);
}
@@ -970,9 +994,6 @@ public void done(JSONArray jsonArray, BmobException e) {
}
-
-
-
public Subscription getAllPostData(boolean isPublic, boolean isRefresh, String uid, String time, FindListener findCallback) {
BmobQuery query = new BmobQuery<>();
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@@ -986,19 +1007,19 @@ public Subscription getAllPostData(boolean isPublic, boolean isRefresh, String u
BmobDate bmobDate;
if (isRefresh) {
bmobDate = new BmobDate(new Date(currentTime));
- String key=Constant.UPDATE_TIME_SHARE+uid;
+ String key = ConstantUtil.UPDATE_TIME_SHARE + uid;
if (isPublic) {
- key+=Constant.PUBLIC;
+ key += ConstantUtil.PUBLIC;
}
- String updateTime=BaseApplication
+ String updateTime = BaseApplication
.getAppComponent()
.getSharedPreferences()
- .getString(key,null);
- if (updateTime != null&&!time.equals("0000-00-00 01:00:00")) {
-// 这里有个Bug,WhereGreaterThan 也查出相等时间的消息,所以在这里加上一秒的时间
- long resultTime=TimeUtil.getTime(updateTime,"yyyy-MM-dd HH:mm:ss")+1000;
+ .getString(key, null);
+ if (updateTime != null && !time.equals("0000-00-00 01:00:00")) {
+ // 这里有个Bug,WhereGreaterThan 也查出相等时间的消息,所以在这里加上一秒的时间
+ long resultTime = TimeUtil.getTime(updateTime, "yyyy-MM-dd HH:mm:ss") + 1000;
query.addWhereGreaterThan("updatedAt", new BmobDate(new Date(resultTime)));
- }else {
+ } else {
query.addWhereGreaterThan("updatedAt", bmobDate);
}
query.addWhereGreaterThanOrEqualTo("createdAt", bmobDate);
@@ -1009,42 +1030,42 @@ public Subscription getAllPostData(boolean isPublic, boolean isRefresh, String u
query.addWhereLessThan("createdAt", bmobDate);
}
if (!isPublic) {
- User user=new User();
+ User user = new User();
user.setObjectId(uid);
- query.addWhereEqualTo("author",new BmobPointer(user));
+ query.addWhereEqualTo("author", new BmobPointer(user));
}
query.order("-createdAt");
query.include("author");
query.setLimit(10);
query.setCachePolicy(BmobQuery.CachePolicy.NETWORK_ONLY);
- return query.findObjects(findCallback);
+ return query.findObjects(findCallback);
}
- public Subscription sendPublicPostMessage(int type, String content, String location, final ArrayList imageList,
+ public Subscription sendPublicPostMessage(int type, String content, String location, final ArrayList imageList,
String videoPath, String shotScreen, final PublicPostBean postBean, final OnCreatePublicPostListener listener) {
final PublicPostBean publicPostBean = new PublicPostBean();
publicPostBean.setMsgType(type);
- publicPostBean.setSendStatus(Constant.SEND_STATUS_SUCCESS);
+ publicPostBean.setSendStatus(ConstantUtil.SEND_STATUS_SUCCESS);
final PostDataBean postDataBean = new PostDataBean();
postDataBean.setContent(content);
publicPostBean.setLocation(location);
publicPostBean.setAuthor(UserManager.getInstance().getCurrentUser());
final Gson gson = BaseApplication
.getAppComponent().getGson();
- if (type==Constant.EDIT_TYPE_SHARE) {
+ if (type == ConstantUtil.EDIT_TYPE_SHARE) {
postDataBean.setShareContent(gson.toJson(MsgManager.getInstance().cover(postBean)));
- }else if (type==Constant.EDIT_TYPE_IMAGE) {
+ } else if (type == ConstantUtil.EDIT_TYPE_IMAGE) {
List photoUrls = new ArrayList<>();
if (imageList != null && imageList.size() > 0) {
CommonLogger.e("发送的全部path为:");
- for (ImageItem imageItem :
+ for (SystemUtil.ImageItem imageItem :
imageList) {
photoUrls.add(SystemUtil.sizeCompress(imageItem.getPath(), 1080, 1920));
CommonLogger.e(imageItem.getPath());
}
postDataBean.setImageList(photoUrls);
}
- }else if (type==Constant.EDIT_TYPE_VIDEO){
+ } else if (type == ConstantUtil.EDIT_TYPE_VIDEO) {
List photoUrls = new ArrayList<>();
photoUrls.add(shotScreen);
photoUrls.add(videoPath);
@@ -1059,19 +1080,19 @@ public Subscription getCommentListData(String postId, FindListener query = new BmobQuery<>();
- query.addWhereEqualTo(Constant.POST, publicPostBean);
- long currentTime=TimeUtil.getTime(time);
- BmobDate bmobDate=new BmobDate(new Date(currentTime));
+ query.addWhereEqualTo(ConstantUtil.POST, publicPostBean);
+ long currentTime = TimeUtil.getTime(time);
+ BmobDate bmobDate = new BmobDate(new Date(currentTime));
if (isPullRefresh) {
- String key = Constant.UPDATE_TIME_COMMENT + postId;
+ String key = ConstantUtil.UPDATE_TIME_COMMENT + postId;
String updateTime = BaseApplication
.getAppComponent().getSharedPreferences()
.getString(key, null);
- if (updateTime != null&&!time.equals("0000-00-00 01:00:00")) {
-// 这里有个Bug,WhereGreaterThan 也查出相等时间的消息,所以在这里加上一秒的时间
- long resultTime=TimeUtil.getTime(updateTime,"yyyy-MM-dd HH:mm:ss")+1000;
+ if (updateTime != null && !time.equals("0000-00-00 01:00:00")) {
+ // 这里有个Bug,WhereGreaterThan 也查出相等时间的消息,所以在这里加上一秒的时间
+ long resultTime = TimeUtil.getTime(updateTime, "yyyy-MM-dd HH:mm:ss") + 1000;
query.addWhereGreaterThan("updatedAt", new BmobDate(new Date(resultTime)));
- }else {
+ } else {
query.addWhereGreaterThan("updatedAt", bmobDate);
}
query.addWhereGreaterThanOrEqualTo("createdAt", bmobDate);
@@ -1096,7 +1117,7 @@ public void getCommentListDetailData(String publicId, FindListener imageList = bean.getImageList();
if (imageList != null && imageList.size() > 0) {
@@ -1173,7 +1194,7 @@ public void onSuccess(List list2, List list1) {
CommonLogger.e("11全部上传图片成功");
bean.setImageList(list1);
data.setContent(BaseApplication.getAppComponent().getGson().toJson(bean));
- data.setSendStatus(Constant.SEND_STATUS_SUCCESS);
+ data.setSendStatus(ConstantUtil.SEND_STATUS_SUCCESS);
data.save(new SaveListener() {
@Override
public void done(String s, BmobException e) {
@@ -1210,7 +1231,7 @@ public void onError(int i, String s) {
});
return null;
}
- } else if (data.getMsgType() == Constant.EDIT_TYPE_VIDEO) {
+ } else if (data.getMsgType() == ConstantUtil.EDIT_TYPE_VIDEO) {
List stringList = new ArrayList<>(bean.getImageList());
BmobFile.uploadBatch(bean.getImageList().toArray(new String[]{}), new UploadBatchListener() {
@Override
@@ -1219,7 +1240,7 @@ public void onSuccess(List list2, List list1) {
CommonLogger.e("全部上传视频成功");
bean.setImageList(list1);
data.setContent(BaseApplication.getAppComponent().getGson().toJson(bean));
- data.setSendStatus(Constant.SEND_STATUS_SUCCESS);
+ data.setSendStatus(ConstantUtil.SEND_STATUS_SUCCESS);
data.save(new SaveListener() {
@Override
public void done(String s, BmobException e) {
@@ -1256,9 +1277,9 @@ public void onError(int i, String s) {
});
return null;
- } else if (data.getMsgType() == Constant.EDIT_TYPE_TEXT
+ } else if (data.getMsgType() == ConstantUtil.EDIT_TYPE_TEXT
) {
- data.setSendStatus(Constant.SEND_STATUS_SUCCESS);
+ data.setSendStatus(ConstantUtil.SEND_STATUS_SUCCESS);
return data.save(new SaveListener() {
@Override
public void done(String s, BmobException e) {
@@ -1269,15 +1290,15 @@ public void done(String s, BmobException e) {
}
}
});
- } else if (data.getMsgType() == Constant.EDIT_TYPE_SHARE) {
- data.setSendStatus(Constant.SEND_STATUS_SUCCESS);
+ } else if (data.getMsgType() == ConstantUtil.EDIT_TYPE_SHARE) {
+ data.setSendStatus(ConstantUtil.SEND_STATUS_SUCCESS);
return data.save(new SaveListener() {
@Override
public void done(String s, BmobException e) {
if (e == null) {
PublicPostBean temp = new PublicPostBean();
temp.increment("shareCount");
- PublicPostEntity publicPostEntity=gson.fromJson(bean.getShareContent(),PublicPostEntity.class);
+ PublicPostEntity publicPostEntity = gson.fromJson(bean.getShareContent(), PublicPostEntity.class);
temp.update(publicPostEntity.getPid(), new UpdateListener() {
@Override
public void done(BmobException e) {
@@ -1285,12 +1306,12 @@ public void done(BmobException e) {
CommonLogger.e("更新转发个数失败");
} else {
CommonLogger.e("更新转发个数成功");
- publicPostEntity.setShareCount(publicPostEntity.getShareCount()+1);
+ publicPostEntity.setShareCount(publicPostEntity.getShareCount() + 1);
bean.setShareContent(gson.toJson(publicPostEntity));
data.setContent(BaseApplication.getAppComponent().getGson().toJson(bean));
}
- MsgManager.getInstance().sendPostNotifyInfo(Constant.TYPE_SHARE,data.getObjectId(),UserManager.getInstance()
- .getCurrentUserObjectId(),getUidForShareContent(bean.getShareContent()));
+ MsgManager.getInstance().sendPostNotifyInfo(ConstantUtil.TYPE_SHARE, data.getObjectId(), UserManager.getInstance()
+ .getCurrentUserObjectId(), getUidForShareContent(bean.getShareContent()));
listener.onSuccess(data);
}
});
@@ -1314,15 +1335,15 @@ private String getUidForShareContent(String shareContent) {
public Subscription updatePublicPostBean(PublicPostBean data, OnCreatePublicPostListener listener) {
PostDataBean bean = BaseApplication.getAppComponent().getGson().fromJson(data.getContent(), PostDataBean.class);
- if (data.getMsgType() == Constant.EDIT_TYPE_IMAGE
+ if (data.getMsgType() == ConstantUtil.EDIT_TYPE_IMAGE
) {
int size = bean.getImageList().size();
List upLoad = new ArrayList<>();
for (int i = 0; i < size; i++) {
String item = bean.getImageList().get(i);
if (item.startsWith("http")
- || item.startsWith(Constant.IMAGE_COMPRESS_DIR)) {
-// 没有改变
+ || item.startsWith(ConstantUtil.IMAGE_COMPRESS_DIR)) {
+ // 没有改变
} else {
upLoad.add(bean.getImageList().get(i));
}
@@ -1343,8 +1364,8 @@ public void onSuccess(List list, List list1) {
}
}
}
- if (!data.getSendStatus().equals(Constant.SEND_STATUS_SUCCESS)) {
- data.setSendStatus(Constant.SEND_STATUS_SUCCESS);
+ if (!data.getSendStatus().equals(ConstantUtil.SEND_STATUS_SUCCESS)) {
+ data.setSendStatus(ConstantUtil.SEND_STATUS_SUCCESS);
}
data.setContent(BaseApplication.getAppComponent().getGson().toJson(bean));
data.update(new UpdateListener() {
@@ -1376,8 +1397,8 @@ public void onError(int i, String s) {
return null;
} else {
data.setContent(BaseApplication.getAppComponent().getGson().toJson(bean));
- if (!data.getSendStatus().equals(Constant.SEND_STATUS_SUCCESS)) {
- data.setSendStatus(Constant.SEND_STATUS_SUCCESS);
+ if (!data.getSendStatus().equals(ConstantUtil.SEND_STATUS_SUCCESS)) {
+ data.setSendStatus(ConstantUtil.SEND_STATUS_SUCCESS);
}
return data.update(new UpdateListener() {
@Override
@@ -1390,13 +1411,13 @@ public void done(BmobException e) {
}
});
}
- } else if (data.getMsgType() == Constant.EDIT_TYPE_TEXT
- || data.getMsgType() == Constant.EDIT_TYPE_SHARE
- || data.getMsgType() == Constant.EDIT_TYPE_VIDEO) {
+ } else if (data.getMsgType() == ConstantUtil.EDIT_TYPE_TEXT
+ || data.getMsgType() == ConstantUtil.EDIT_TYPE_SHARE
+ || data.getMsgType() == ConstantUtil.EDIT_TYPE_VIDEO) {
data.setContent(BaseApplication.getAppComponent().getGson().toJson(bean)
);
- if (!data.getSendStatus().equals( Constant.SEND_STATUS_SUCCESS)) {
- data.setSendStatus(Constant.SEND_STATUS_SUCCESS);
+ if (!data.getSendStatus().equals(ConstantUtil.SEND_STATUS_SUCCESS)) {
+ data.setSendStatus(ConstantUtil.SEND_STATUS_SUCCESS);
}
return data.update(new UpdateListener() {
@Override
@@ -1414,7 +1435,7 @@ public void done(BmobException e) {
}
public GroupTableEntity cover(GroupTableMessage groupTableMessage) {
- GroupTableEntity groupTableEntity=new GroupTableEntity();
+ GroupTableEntity groupTableEntity = new GroupTableEntity();
groupTableEntity.setCreatedTime(groupTableMessage.getCreatedTime());
groupTableEntity.setCreatorId(groupTableMessage.getCreatorId());
groupTableEntity.setGroupAvatar(groupTableMessage.getGroupAvatar());
@@ -1430,7 +1451,7 @@ public GroupTableEntity cover(GroupTableMessage groupTableMessage) {
}
public ChatMessageEntity cover(ChatMessage message) {
- ChatMessageEntity chatMessageEntity=new ChatMessageEntity();
+ ChatMessageEntity chatMessageEntity = new ChatMessageEntity();
chatMessageEntity.setBelongId(message.getBelongId());
chatMessageEntity.setContent(message.getContent());
chatMessageEntity.setContentType(message.getContentType());
@@ -1444,13 +1465,13 @@ public ChatMessageEntity cover(ChatMessage message) {
}
public RecentMessageEntity coverRecentMessage(BaseMessage message) {
- RecentMessageEntity recentMessageEntity=new RecentMessageEntity();
+ RecentMessageEntity recentMessageEntity = new RecentMessageEntity();
if (message instanceof ChatMessage) {
recentMessageEntity.setType(RecentMessageEntity.TYPE_PERSON);
if (message.getBelongId().equals(UserManager.getInstance()
- .getCurrentUserObjectId())) {
+ .getCurrentUserObjectId())) {
recentMessageEntity.setId(((ChatMessage) message).getToId());
- }else {
+ } else {
recentMessageEntity.setId(message.getBelongId());
}
} else if (message instanceof GroupChatMessage) {
@@ -1465,7 +1486,7 @@ public RecentMessageEntity coverRecentMessage(BaseMessage message) {
}
public GroupChatEntity cover(GroupChatMessage groupChatMessage) {
- GroupChatEntity groupChatEntity=new GroupChatEntity();
+ GroupChatEntity groupChatEntity = new GroupChatEntity();
groupChatEntity.setBelongId(groupChatMessage.getBelongId());
groupChatEntity.setContent(groupChatMessage.getContent());
groupChatEntity.setCreatedTime(groupChatMessage.getCreateTime());
@@ -1477,13 +1498,13 @@ public GroupChatEntity cover(GroupChatMessage groupChatMessage) {
}
public void refreshGroupChatMessage(FindListener findListener) {
- MsgManager.getInstance().queryGroupChatMessage(UserDBManager.getInstance().getAllGroupId(),findListener);
+ MsgManager.getInstance().queryGroupChatMessage(UserDBManager.getInstance().getAllGroupId(), findListener);
}
public ChatMessage cover(ChatMessageEntity chatMessageEntity) {
- ChatMessage chatMessage=new ChatMessage();
+ ChatMessage chatMessage = new ChatMessage();
chatMessage.setReadStatus(chatMessageEntity.getReadStatus());
chatMessage.setContentType(chatMessageEntity.getContentType());
chatMessage.setContent(chatMessageEntity.getContent());
@@ -1497,7 +1518,7 @@ public ChatMessage cover(ChatMessageEntity chatMessageEntity) {
}
public GroupChatMessage cover(GroupChatEntity item) {
- GroupChatMessage groupChatMessage=new GroupChatMessage();
+ GroupChatMessage groupChatMessage = new GroupChatMessage();
groupChatMessage.setContentType(item.getContentType());
groupChatMessage.setContent(item.getContent());
groupChatMessage.setGroupId(item.getGroupId());
@@ -1509,16 +1530,16 @@ public GroupChatMessage cover(GroupChatEntity item) {
}
public Subscription sendChatMessage(ChatMessage message, OnCreateChatMessageListener listener) {
- MessageContent messageContent=gson.fromJson(message.getContent(),MessageContent.class);
- int contentType=message.getContentType();
- if (contentType!=Constant.TAG_MSG_TYPE_TEXT){
- List urlList=messageContent.getUrlList();
+ MessageContent messageContent = gson.fromJson(message.getContent(), MessageContent.class);
+ int contentType = message.getContentType();
+ if (contentType != ConstantUtil.TAG_MSG_TYPE_TEXT) {
+ List urlList = messageContent.getUrlList();
BmobFile.uploadBatch(urlList.toArray(new String[]{}), new UploadBatchListener() {
@Override
public void onSuccess(List list, List list1) {
- if (urlList.size()==list1.size()){
+ if (urlList.size() == list1.size()) {
messageContent.setUrlList(list1);
- message.setSendStatus(Constant.SEND_STATUS_SUCCESS);
+ message.setSendStatus(ConstantUtil.SEND_STATUS_SUCCESS);
message.setContent(gson.toJson(messageContent));
message.save(new SaveListener() {
@Override
@@ -1531,14 +1552,14 @@ public void done(String s, BmobException e) {
public void done(List list, BmobException e) {
if (e == null && list != null
&& list.size() > 0) {
- sendJsonMessage(list.get(0).getInstallationId(), createJsonMessage(message),null);
+ sendJsonMessage(list.get(0).getInstallationId(), createJsonMessage(message), null);
}
}
});
listener.onSuccess(message);
-//
- }else {
- listener.onFailed(e.toString(),message);
+ //
+ } else {
+ listener.onFailed(e.toString(), message);
}
}
});
@@ -1552,12 +1573,12 @@ public void onProgress(int i, int i1, int i2, int i3) {
@Override
public void onError(int i, String s) {
- listener.onFailed(s+i,message);
+ listener.onFailed(s + i, message);
}
});
return null;
- }else {
- message.setSendStatus(Constant.SEND_STATUS_SUCCESS);
+ } else {
+ message.setSendStatus(ConstantUtil.SEND_STATUS_SUCCESS);
return message.save(new SaveListener() {
@Override
public void done(String s, BmobException e) {
@@ -1567,13 +1588,13 @@ public void done(String s, BmobException e) {
public void done(List list, BmobException e) {
if (e == null && list != null
&& list.size() > 0) {
- sendJsonMessage(list.get(0).getInstallationId(), createJsonMessage(message),null);
+ sendJsonMessage(list.get(0).getInstallationId(), createJsonMessage(message), null);
}
}
});
listener.onSuccess(message);
- }else {
- listener.onFailed(e.toString(),message);
+ } else {
+ listener.onFailed(e.toString(), message);
}
}
});
@@ -1581,18 +1602,18 @@ public void done(List list, BmobException e) {
}
public Subscription sendGroupChatMessage(GroupChatMessage message, OnCreateChatMessageListener listener) {
- MessageContent messageContent=gson.fromJson(message.getContent(),MessageContent.class);
- int contentType=message.getContentType();
- if (contentType!=Constant.TAG_MSG_TYPE_TEXT){
- List urlList=messageContent.getUrlList();
+ MessageContent messageContent = gson.fromJson(message.getContent(), MessageContent.class);
+ int contentType = message.getContentType();
+ if (contentType != ConstantUtil.TAG_MSG_TYPE_TEXT) {
+ List urlList = messageContent.getUrlList();
BmobFile.uploadBatch(urlList.toArray(new String[]{}), new UploadBatchListener() {
@Override
public void onSuccess(List list, List list1) {
- if (urlList.size()==list1.size()){
+ if (urlList.size() == list1.size()) {
messageContent.setUrlList(list1);
- message.setSendStatus(Constant.SEND_STATUS_SUCCESS);
+ message.setSendStatus(ConstantUtil.SEND_STATUS_SUCCESS);
message.setContent(gson.toJson(messageContent));
- message.setTableName("g"+message.getGroupId());
+ message.setTableName("g" + message.getGroupId());
message.save(new SaveListener() {
@Override
public void done(String s, BmobException e) {
@@ -1600,8 +1621,8 @@ public void done(String s, BmobException e) {
message.setContent(gson.toJson(messageContent));
if (e == null) {
listener.onSuccess(message);
- }else {
- listener.onFailed(e.toString(),message);
+ } else {
+ listener.onFailed(e.toString(), message);
}
}
});
@@ -1615,30 +1636,30 @@ public void onProgress(int i, int i1, int i2, int i3) {
@Override
public void onError(int i, String s) {
- listener.onFailed(s+i,message);
+ listener.onFailed(s + i, message);
}
});
return null;
- }else {
- message.setTableName("g"+message.getGroupId());
- message.setSendStatus(Constant.SEND_STATUS_SUCCESS);
+ } else {
+ message.setTableName("g" + message.getGroupId());
+ message.setSendStatus(ConstantUtil.SEND_STATUS_SUCCESS);
return message.save(new SaveListener() {
@Override
public void done(String s, BmobException e) {
if (e == null) {
listener.onSuccess(message);
- }else {
- listener.onFailed(e.toString(),message);
+ } else {
+ listener.onFailed(e.toString(), message);
}
}
});
}
}
- public void exitGroup(String groupId,String uid,UpdateListener updateListener) {
- GroupTableEntity groupTableEntity= UserDBManager.getInstance()
+ public void exitGroup(String groupId, String uid, UpdateListener updateListener) {
+ GroupTableEntity groupTableEntity = UserDBManager.getInstance()
.getGroupTableEntity(groupId);
- GroupTableMessage groupTableMessage=new GroupTableMessage();
+ GroupTableMessage groupTableMessage = new GroupTableMessage();
groupTableMessage.setObjectId(groupTableEntity.getGroupId());
groupTableEntity.setGroupNumber(groupTableEntity.getGroupNumber());
groupTableMessage.getGroupNumber().remove(uid);
@@ -1647,7 +1668,7 @@ public void exitGroup(String groupId,String uid,UpdateListener updateListener) {
}
public GroupTableMessage cover(GroupTableEntity
- entity) {
+ entity) {
return null;
}
@@ -1668,37 +1689,37 @@ public PublicCommentBean createPostCommentBean(PublicCommentBean publicCommentBe
commentDetailBean.setContent(content);
if (publicCommentBean != null) {
CommentDetailBean originBean = gson.fromJson(publicCommentBean.getContent(), CommentDetailBean.class);
- String publicId=publicCommentBean.getUser().getObjectId() + "&" +
+ String publicId = publicCommentBean.getUser().getObjectId() + "&" +
UserManager.getInstance().getCurrentUserObjectId();
- List list=originBean.getConversationList().get(publicId);
+ List list = originBean.getConversationList().get(publicId);
if (list == null) {
- publicId=UserManager.getInstance().getCurrentUserObjectId()+"&"+publicCommentBean.getUser().getObjectId();
- list=originBean.getConversationList().get(publicId);
+ publicId = UserManager.getInstance().getCurrentUserObjectId() + "&" + publicCommentBean.getUser().getObjectId();
+ list = originBean.getConversationList().get(publicId);
}
- Map> map=new HashMap<>();
+ Map> map = new HashMap<>();
if (list == null) {
-// 首次双方对话
- List replyDetailContents=new ArrayList<>();
- ReplyDetailContent one=new ReplyDetailContent();
+ // 首次双方对话
+ List replyDetailContents = new ArrayList<>();
+ ReplyDetailContent one = new ReplyDetailContent();
one.setTime(TimeUtil.severToLocalTime(publicCommentBean.getCreatedAt()));
one.setContent(originBean.getContent());
one.setUid(publicCommentBean.getUser().getObjectId());
replyDetailContents.add(one);
- ReplyDetailContent two=new ReplyDetailContent();
+ ReplyDetailContent two = new ReplyDetailContent();
two.setTime(System.currentTimeMillis());
two.setUid(UserManager.getInstance().getCurrentUserObjectId());
two.setContent(content);
replyDetailContents.add(two);
- map.put(publicId,replyDetailContents);
- }else {
- ReplyDetailContent two=new ReplyDetailContent();
+ map.put(publicId, replyDetailContents);
+ } else {
+ ReplyDetailContent two = new ReplyDetailContent();
two.setTime(System.currentTimeMillis());
two.setContent(content);
two.setUid(UserManager.getInstance().getCurrentUserObjectId());
- List other=new ArrayList<>();
+ List other = new ArrayList<>();
other.addAll(list);
other.add(two);
- map.put(publicId,other);
+ map.put(publicId, other);
}
commentDetailBean.setConversationList(map);
commentDetailBean.setPublicId(publicId);
@@ -1714,98 +1735,95 @@ public PublicCommentBean createPostCommentBean(PublicCommentBean publicCommentBe
}
public Subscription sendNotifyCommentInfo(PublicCommentBean newBean) {
- CommentDetailBean commentDetailBean=gson.fromJson(newBean.getContent()
- ,CommentDetailBean.class);
+ CommentDetailBean commentDetailBean = gson.fromJson(newBean.getContent()
+ , CommentDetailBean.class);
- StringBuilder stringBuilder=new StringBuilder();
+ StringBuilder stringBuilder = new StringBuilder();
if (!newBean.getPost().getAuthor().getObjectId().equals(UserManager.getInstance()
- .getCurrentUserObjectId())){
+ .getCurrentUserObjectId())) {
stringBuilder.append(newBean.getPost().getAuthor().getObjectId());
}
if (commentDetailBean.getPublicId() != null) {
-// 回复评论
- String[] str=commentDetailBean.getPublicId().split("&");
+ // 回复评论
+ String[] str = commentDetailBean.getPublicId().split("&");
String otherUid;
if (str[0].equals(newBean.getPost().getAuthor().getObjectId())) {
- otherUid=str[1];
- }else {
- otherUid=str[0];
+ otherUid = str[1];
+ } else {
+ otherUid = str[0];
}
stringBuilder.append("&");
stringBuilder.append(otherUid);
}
- return MsgManager.getInstance().sendPostNotifyInfo(Constant.TYPE_COMMENT,newBean.getObjectId(),UserManager.getInstance().getCurrentUserObjectId()
- ,stringBuilder.toString());
+ return MsgManager.getInstance().sendPostNotifyInfo(ConstantUtil.TYPE_COMMENT, newBean.getObjectId(), UserManager.getInstance().getCurrentUserObjectId()
+ , stringBuilder.toString());
}
- private String createNotifyInfo(Integer type,String id) {
- PostNotifyInfo postNotifyInfo=new PostNotifyInfo();
+ private String createNotifyInfo(Integer type, String id) {
+ PostNotifyInfo postNotifyInfo = new PostNotifyInfo();
postNotifyInfo.setId(id);
postNotifyInfo.setType(type);
- postNotifyInfo.setReadStatus(Constant.READ_STATUS_UNREAD);
+ postNotifyInfo.setReadStatus(ConstantUtil.READ_STATUS_UNREAD);
return gson.toJson(postNotifyInfo);
}
-
-
-
public void getCommentBean(String commentId, FindListener findListener) {
- BmobQuery bmobQuery=new BmobQuery<>();
- bmobQuery.addWhereEqualTo("objectId",commentId);
+ BmobQuery