fix:m-im 修复私聊列表--通知--预约提醒列表--已读红点并未消失功能

app/src/main/java/com/ydl/component/base/DemoGlobalConfig.java

@@ -20,8 +20,8 @@ import java.util.List;
 public final class DemoGlobalConfig implements IConfigModule {
     String APP_DOMAIN = "https://api.github.com/";
     //        public static String appEnv = YDLConstants.ENV_AUTO_TEST;
-    public static String appEnv = YDLConstants.ENV_TEST;
-//    public static String appEnv = YDLConstants.ENV_PROD;
+//    public static String appEnv = YDLConstants.ENV_TEST;
+    public static String appEnv = YDLConstants.ENV_PROD;
 
     @Override
     public void injectAppLifecycle(@NotNull Context context, @NotNull List<IAppLifecycles> lifecycles) {

m-im/src/main/java/com/yidianling/im/ui/adapter/MsgListAdapter.java

@@ -13,6 +13,7 @@ import com.ydl.ydlcommon.base.BaseActivity;
 import com.ydl.ydlcommon.base.lifecycle.ILifecycleable;
 import com.ydl.ydlcommon.data.http.RxUtils;
 import com.ydl.ydlcommon.data.http.ThrowableConsumer;
+import com.ydl.ydlcommon.utils.LogUtil;
 import com.ydl.ydlcommon.utils.StringUtils;
 import com.ydl.ydlcommon.utils.remind.ToastHelper;
 import com.yidianling.im.bean.MsgData;
@@ -29,7 +30,9 @@ import org.jetbrains.annotations.NotNull;
 import java.util.Map;
 
 import de.greenrobot.event.EventBus;
+import io.reactivex.android.schedulers.AndroidSchedulers;
 import io.reactivex.disposables.Disposable;
+import io.reactivex.schedulers.Schedulers;
 
 /**
  * 消息adapter
@@ -60,9 +63,7 @@ public class MsgListAdapter extends CommonAdapter<MsgData> {
             convertView = new MsgListItemView(context, type);
         }
         ((MsgListItemView) convertView).setData(mDataList.get(position));
-        convertView.setOnClickListener(new View.OnClickListener() {
-            @Override
-            public void onClick(View v) {
+        convertView.setOnClickListener(v -> {
             //动态消息暂时不需要访问以下接口
             boolean fla = false;
             //判断是否是跳转专家主页
@@ -113,8 +114,10 @@ public class MsgListAdapter extends CommonAdapter<MsgData> {
             if (fla || boo) {
                 //跟新未读
                 Disposable dis = httpHelper.getMsgDetail(new MsgDetailParam(mDataList.get(position).id))
-                            .compose(RxUtils.applySchedulers(lifecycleable))
+//                        .compose(RxUtils.applySchedulers(lifecycleable))
+                        .subscribeOn(Schedulers.io())
                         .compose(RxUtils.resultData())
+                        .observeOn(AndroidSchedulers.mainThread())
                         .subscribe(msgDetail -> {
                             mDataList.get(position).is_read = 2;
                             notifyDataSetChanged();
@@ -128,10 +131,13 @@ public class MsgListAdapter extends CommonAdapter<MsgData> {
                 //如果是动态消息则到此结束，其它消息类型走下面流程
             }else {
                 Disposable di = httpHelper.getMsgDetail(new MsgDetailParam(mDataList.get(position).id))
-                            .compose(RxUtils.applySchedulers(lifecycleable))
+//                        .compose(RxUtils.applySchedulers(lifecycleable))
+                        .subscribeOn(Schedulers.io())
                         .compose(RxUtils.resultData())
+                        .observeOn(AndroidSchedulers.mainThread())
                         .subscribe(msgDetail -> {
                             mDataList.get(position).is_read = 2;
+                            notifyDataSetChanged();
                             EventBus.getDefault().post(new UpdateTabUnreadNumEvent());
                             switch (msgDetail.type) {
                                 case 1:
@@ -183,7 +189,6 @@ public class MsgListAdapter extends CommonAdapter<MsgData> {
 
             }
 
-            }
         });
         return convertView;
     }