|
|
@ -52,7 +52,8 @@ public class InstantViewModel extends ToolbarViewModel<InstantActivity>{ |
|
|
|
PushService pushService; |
|
|
|
PushService pushService; |
|
|
|
|
|
|
|
|
|
|
|
public User user = CacheDiskUtils.getInstance().getParcelable(CacheConstant.USER_INFO, User.CREATOR, new User()); |
|
|
|
public User user = CacheDiskUtils.getInstance().getParcelable(CacheConstant.USER_INFO, User.CREATOR, new User()); |
|
|
|
public LocalPushChatMsg adverseData; // 对方用户基础信息
|
|
|
|
|
|
|
|
|
|
|
|
public LocalPushChatMsg localPushChatMsg; |
|
|
|
|
|
|
|
|
|
|
|
public String cursor = ""; |
|
|
|
public String cursor = ""; |
|
|
|
|
|
|
|
|
|
|
@ -104,11 +105,11 @@ public class InstantViewModel extends ToolbarViewModel<InstantActivity>{ |
|
|
|
return; |
|
|
|
return; |
|
|
|
} |
|
|
|
} |
|
|
|
PushChatMessage chatMessage = new PushChatMessage(); |
|
|
|
PushChatMessage chatMessage = new PushChatMessage(); |
|
|
|
if ("1".equals(adverseData.getFocusType())) chatMessage.setConcernFanStatus("1"); // 从关注列表中进入聊天页界面则需要做特殊处理
|
|
|
|
if ("1".equals(localPushChatMsg.getFocusType())) chatMessage.setConcernFanStatus("1"); // 从关注列表中进入聊天页界面则需要做特殊处理
|
|
|
|
chatMessage.setText(msg); |
|
|
|
chatMessage.setText(msg); |
|
|
|
chatMessage.setRemarks("普通消息"); |
|
|
|
chatMessage.setRemarks("普通消息"); |
|
|
|
chatMessage.setTitle("APP端消息发送-" + user.getNickName() + "到" + adverseData.getUserName()); |
|
|
|
chatMessage.setTitle("APP端消息发送-" + user.getNickName() + "到" + localPushChatMsg.getUserName()); |
|
|
|
chatMessage.setAlias(adverseData.getId()); |
|
|
|
chatMessage.setAlias(localPushChatMsg.getId()); |
|
|
|
chatMessage.setUserId(user.getId()); |
|
|
|
chatMessage.setUserId(user.getId()); |
|
|
|
pushService.concernFanSend(chatMessage) |
|
|
|
pushService.concernFanSend(chatMessage) |
|
|
|
.compose(RxUtil.schedulersTransformer()) |
|
|
|
.compose(RxUtil.schedulersTransformer()) |
|
|
@ -134,7 +135,7 @@ public class InstantViewModel extends ToolbarViewModel<InstantActivity>{ |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void onError(Throwable e) { |
|
|
|
public void onError(Throwable e) { |
|
|
|
if ("1".equals(adverseData.getFocusType())) { |
|
|
|
if ("1".equals(localPushChatMsg.getFocusType())) { |
|
|
|
ToastUtil.show("对方还未关注你,你只能发送一条消息,发送失败"); |
|
|
|
ToastUtil.show("对方还未关注你,你只能发送一条消息,发送失败"); |
|
|
|
}else ExceptionHandle.baseExceptionMsg(e); |
|
|
|
}else ExceptionHandle.baseExceptionMsg(e); |
|
|
|
} |
|
|
|
} |
|
|
@ -151,7 +152,7 @@ public class InstantViewModel extends ToolbarViewModel<InstantActivity>{ |
|
|
|
pushService.listFriendHistoryMessage( |
|
|
|
pushService.listFriendHistoryMessage( |
|
|
|
MapUtils.newHashMap( |
|
|
|
MapUtils.newHashMap( |
|
|
|
Pair.create("size", pageSize), |
|
|
|
Pair.create("size", pageSize), |
|
|
|
Pair.create("alias", adverseData.getId()), |
|
|
|
Pair.create("alias", localPushChatMsg.getId()), |
|
|
|
Pair.create("userId", user.getId()) |
|
|
|
Pair.create("userId", user.getId()) |
|
|
|
)) |
|
|
|
)) |
|
|
|
.compose(RxUtil.schedulersTransformer()) |
|
|
|
.compose(RxUtil.schedulersTransformer()) |
|
|
@ -188,7 +189,7 @@ public class InstantViewModel extends ToolbarViewModel<InstantActivity>{ |
|
|
|
MapUtils.newHashMap( |
|
|
|
MapUtils.newHashMap( |
|
|
|
Pair.create("size", pageSize), |
|
|
|
Pair.create("size", pageSize), |
|
|
|
Pair.create("current", pageCurrent += 1), |
|
|
|
Pair.create("current", pageCurrent += 1), |
|
|
|
Pair.create("alias", adverseData.getId()), |
|
|
|
Pair.create("alias", localPushChatMsg.getId()), |
|
|
|
Pair.create("userId", user.getId()) |
|
|
|
Pair.create("userId", user.getId()) |
|
|
|
)) |
|
|
|
)) |
|
|
|
.compose(RxUtil.schedulersTransformer()) |
|
|
|
.compose(RxUtil.schedulersTransformer()) |
|
|
|