商户App+企业app 消息列表+未读点击改变状态位+消息详情完成(ui待细调)

app/src/main/java/com/xx/merchanthbh/activity/adapter/MessageListAdapter.java

+package com.xx.merchanthbh.activity.adapter;
+
+
+import android.content.Context;
+import android.util.Log;
+
+import com.xx.merchanthbh.R;
+import com.xx.merchanthbh.data.http.respons.MessageBean;
+import com.xx.merchanthbh.databinding.ItemMessageListBinding;
+import com.xx.xxviewlibrary.base.xxBaseRecyclerViewAdapter;
+
+public class MessageListAdapter extends xxBaseRecyclerViewAdapter<ItemMessageListBinding, MessageBean> {
+
+    public MessageListAdapter(Context context) {
+        super(context);
+    }
+
+    /*加载积分布局*/
+    @Override
+    public int initLayout() {
+        return R.layout.item_message_list;
+    }
+
+    @Override
+    protected void covert(ItemMessageListBinding dataBind, MessageBean data, int position) {
+        //   将接口调出来的布局遍历上去
+        dataBind.setMessageBean(data);
+        Log.v("积分订单列表的重要信息:", String.valueOf(data));
+    }
+
+}
+

app/src/main/java/com/xx/merchanthbh/data/http/requst/MessageRequest.kt

@@ -5,6 +5,7 @@ import com.xx.merchanthbh.data.http.respons.BoothBean
 import com.xx.merchanthbh.data.http.respons.MessageBean
 import com.xx.merchanthbh.data.http.respons.OrderBean
 import io.reactivex.rxjava3.core.Observable
+import me.goldze.mvvmhabit.http.ApiParams
 import me.goldze.mvvmhabit.http.BasePageResponse
 import me.goldze.mvvmhabit.http.BaseResponse
 
@@ -15,4 +16,13 @@ class MessageRequest : BaseRespons() {
     fun getMessageList(flag: String): Observable<BasePageResponse<MessageBean>> {
         return apiService.getMessageList(flag)
     }
+
+    /**
+     * 改变消息状态位
+     */
+    fun putMessageStaticUpdate(businessId:String):Observable<BaseResponse<Boolean>>
+    {
+        return apiService.putMessageStaticUpdate(ApiParams<MessageStaticUpdateBody>().setParams(MessageStaticUpdateBody(businessId,"1")))
+    }
+    data class MessageStaticUpdateBody(val businessId:String, val flag:String )
 }
\ No newline at end of file

app/src/main/java/com/xx/merchanthbh/ui/msg/MessageViewModel.java

@@ -17,6 +17,7 @@ import io.reactivex.rxjava3.annotations.NonNull;
 import io.reactivex.rxjava3.disposables.Disposable;
 import io.reactivex.rxjava3.functions.Consumer;
 import me.goldze.mvvmhabit.base.BaseViewModel;
+import me.goldze.mvvmhabit.http.ApiDisposableObserver;
 import me.goldze.mvvmhabit.http.ApiDisposablePageObserver;
 import me.goldze.mvvmhabit.utils.RxUtils;
 
@@ -24,6 +25,7 @@ public class MessageViewModel extends BaseViewModel<MessageRequest> {
 
     //    创建消息列表实体对象
     public MutableLiveData<List<MessageBean>> messageList = new MutableLiveData<>(new ArrayList<>());
+
     public MessageViewModel(@NonNull Application application) {
         super(application);
     }
@@ -31,8 +33,10 @@ public class MessageViewModel extends BaseViewModel<MessageRequest> {
     public MessageViewModel(@NonNull Application application, MessageRequest model) {
         super(application, model);
     }
+
     /*设置消息初始状态是0*/
-    public String  flag="0";
+    public String flag = "0";
+
     //调用消息列表的接口信息
     public void getMessageList() {
         model.getMessageList(flag)
@@ -60,20 +64,41 @@ public class MessageViewModel extends BaseViewModel<MessageRequest> {
                     }
                 });
     }
+
     /*跳转消息详情页面*/
     public void goMessageDetail(MessageListAdapter messageListAdapter, int position) {
         /*创建bundle*/
         Bundle bundle = new Bundle();
         /*将要传的createTime传过去*/
-        bundle.putString("createTime",  messageListAdapter.mList.get(position).getCreateTime());
+        bundle.putString("createTime", messageListAdapter.mList.get(position).getCreateTime());
         /*将要传的messageType传过去*/
-        bundle.putString("messageType",  messageListAdapter.mList.get(position).getMessageType());
+        bundle.putString("messageType", messageListAdapter.mList.get(position).getMessageType());
         /*将要传的messageContent传过去*/
-        bundle.putString("messageContent",  messageListAdapter.mList.get(position).getMessageContent());
+        bundle.putString("messageContent", messageListAdapter.mList.get(position).getMessageContent());
         /*连带参数一块跳转到详情页*/
         startActivity(MessageDetailActivity.class, bundle);
+        /*未读的状态点进去调取接口改变状态位*/
+        if (messageListAdapter.mList.get(position).getFlag().equals("0")) {
+            model.putMessageStaticUpdate(messageListAdapter.mList.get(position).getBusinessId()).compose(RxUtils.schedulersTransformer()) //线程调度
+//                        .compose(RxUtils.exceptionTransformer()) // 网络错误的异常转换, 这里可以换成自己的ExceptionHandle
+                    .doOnSubscribe(MessageViewModel.this)
+                    .doOnSubscribe(new Consumer<Disposable>() {
+                        @Override
+                        public void accept(Disposable disposable) throws Exception {
+                        }
+                    }).subscribe(new ApiDisposableObserver<Boolean>() {
+                        @Override
+                        public void onSuccess(Boolean resultBean) {
+
+                        }
+
+                        @Override
+                        public void onError(String Error) {
+
+                        }
+                    });
+        }
     }
 
 
-
 }

hbhbcompany/src/main/java/com/xx/hbhbcompany/data/http/requst/MessageRequest.kt

@@ -3,7 +3,9 @@ package com.xx.hbhbcompany.data.http.requst
 import com.xx.hbhbcompany.data.http.BaseRespons
 import com.xx.hbhbcompany.data.http.respons.MessageBean
 import io.reactivex.rxjava3.core.Observable
+import me.goldze.mvvmhabit.http.ApiParams
 import me.goldze.mvvmhabit.http.BasePageResponse
+import me.goldze.mvvmhabit.http.BaseResponse
 
 class MessageRequest : BaseRespons() {
     /**
@@ -12,4 +14,12 @@ class MessageRequest : BaseRespons() {
     fun getMessageList(flag: String): Observable<BasePageResponse<MessageBean>> {
         return apiService.getMessageList(flag)
     }
+    /**
+     * 改变消息状态位
+     */
+    fun putMessageStaticUpdate(businessId:String):Observable<BaseResponse<Boolean>>
+    {
+        return apiService.putMessageStaticUpdate(ApiParams<MessageStaticUpdateBody>().setParams(MessageStaticUpdateBody(businessId,"1")))
+    }
+    data class MessageStaticUpdateBody(val businessId:String, val flag:String )
 }
\ No newline at end of file

hbhbcompany/src/main/java/com/xx/hbhbcompany/ui/msg/MessageViewModel.java

@@ -16,6 +16,7 @@ import java.util.List;
 import io.reactivex.rxjava3.disposables.Disposable;
 import io.reactivex.rxjava3.functions.Consumer;
 import me.goldze.mvvmhabit.base.BaseViewModel;
+import me.goldze.mvvmhabit.http.ApiDisposableObserver;
 import me.goldze.mvvmhabit.http.ApiDisposablePageObserver;
 import me.goldze.mvvmhabit.utils.RxUtils;
 
@@ -72,6 +73,27 @@ public class MessageViewModel extends BaseViewModel<MessageRequest> {
         bundle.putString("messageContent",  messageListAdapter.mList.get(position).getMessageContent());
         /*连带参数一块跳转到详情页*/
         startActivity(MessageDetailActivity.class, bundle);
+        /*未读的状态点进去调取接口改变状态位*/
+        if (messageListAdapter.mList.get(position).getFlag().equals("0")) {
+            model.putMessageStaticUpdate(messageListAdapter.mList.get(position).getBusinessId()).compose(RxUtils.schedulersTransformer()) //线程调度
+//                        .compose(RxUtils.exceptionTransformer()) // 网络错误的异常转换, 这里可以换成自己的ExceptionHandle
+                    .doOnSubscribe(MessageViewModel.this)
+                    .doOnSubscribe(new Consumer<Disposable>() {
+                        @Override
+                        public void accept(Disposable disposable) throws Exception {
+                        }
+                    }).subscribe(new ApiDisposableObserver<Boolean>() {
+                        @Override
+                        public void onSuccess(Boolean resultBean) {
+
+                        }
+
+                        @Override
+                        public void onError(String Error) {
+
+                        }
+                    });
+        }
     }