浏览代码

拉取新消息限制5分钟内

liuzhenxing1118 2 年之前
父节点
当前提交
c317a33fbe
共有 1 个文件被更改,包括 6 次插入5 次删除
  1. 6 5
      app/src/main/java/com/xplora/xpchat/activity/PagerActivity.java

+ 6 - 5
app/src/main/java/com/xplora/xpchat/activity/PagerActivity.java

@@ -938,10 +938,12 @@ public class PagerActivity extends BaseActivity implements Listener.PlayListener
         if (arrayList == null || arrayList.size() <= 0)
             return;
         new Thread(()->{
-            for (Integer i : arrayList) {
-                if (i == null)
+            for (int i = 0; i < arrayList.size(); i++) {
+                Object value = arrayList.get(i);
+                if (value == null)
                     continue;
-                MessageBean bean = DataManager.instance().getMessageBean(i);
+                int index = (int)value;
+                MessageBean bean = DataManager.instance().getMessageBean(index);
                 if (bean == null)
                     continue;
                 if (bean.owner == Constant.OWNER_ME)
@@ -950,7 +952,6 @@ public class PagerActivity extends BaseActivity implements Listener.PlayListener
                     continue;
                 if (bean.localState != Constant.MESSAGE_STATE_UNREAD)
                     continue;
-
                 bean.localState = Constant.MESSAGE_STATE_READ;
                 new DatabaseUtils().modifyMessageState(bean._id, Constant.MESSAGE_STATE_READ);
             }
@@ -1142,7 +1143,7 @@ public class PagerActivity extends BaseActivity implements Listener.PlayListener
         MessageBean bean = DataManager.instance().getLastVaildMassageBean();
         if (bean != null) {
             int interval = ToolsUtils.getCurrentTime() - bean.create;
-            if (interval < 0 || interval > 15 * 60) {
+            if (interval < 0 || interval > 5 * 60) {
                 broadcastRequestMessage(bean.msgId);
             }
         }