對接開通接口神龍送財的im消息

common/src/main/java/com/yunbao/common/bean/GuardMaturityDateRemindModel.java

@@ -0,0 +1,145 @@
+package com.yunbao.common.bean;
+
+import com.google.gson.annotations.SerializedName;
+
+public class GuardMaturityDateRemindModel extends BaseModel{
+
+   @SerializedName("_method_")
+   private String method;
+   @SerializedName("action")
+   private String action;
+   @SerializedName("is_overdue")
+   private int isOverdue;
+   @SerializedName("days")
+   private int days;
+   @SerializedName("uid")
+   private String uid;
+   @SerializedName("liveuid")
+   private String liveuid;
+   @SerializedName("user_avatar")
+   private String userAvatar;
+   @SerializedName("user_nicename")
+   private String userNicename;
+   @SerializedName("live_avatar")
+   private String liveAvatar;
+   @SerializedName("live_nicename")
+   private String liveNicename;
+   @SerializedName("ct")
+   private String ct;
+   @SerializedName("guard_type")
+   private String guardType;
+
+   public String getGuardType() {
+      return guardType;
+   }
+
+   public GuardMaturityDateRemindModel setGuardType(String guardType) {
+      this.guardType = guardType;
+      return this;
+   }
+
+   public String getMethod() {
+      return method;
+   }
+
+   public void setMethod(String method) {
+      this.method = method;
+   }
+
+   public String getAction() {
+      return action;
+   }
+
+   public void setAction(String action) {
+      this.action = action;
+   }
+
+   public int getIsOverdue() {
+      return isOverdue;
+   }
+
+   public void setIsOverdue(int isOverdue) {
+      this.isOverdue = isOverdue;
+   }
+
+   public int getDays() {
+      return days;
+   }
+
+   public void setDays(int days) {
+      this.days = days;
+   }
+
+   public String getUid() {
+      return uid;
+   }
+
+   public void setUid(String uid) {
+      this.uid = uid;
+   }
+
+   public String getLiveuid() {
+      return liveuid;
+   }
+
+   public void setLiveuid(String liveuid) {
+      this.liveuid = liveuid;
+   }
+
+   public String getUserAvatar() {
+      return userAvatar;
+   }
+
+   public void setUserAvatar(String userAvatar) {
+      this.userAvatar = userAvatar;
+   }
+
+   public String getUserNicename() {
+      return userNicename;
+   }
+
+   public void setUserNicename(String userNicename) {
+      this.userNicename = userNicename;
+   }
+
+   public String getLiveAvatar() {
+      return liveAvatar;
+   }
+
+   public void setLiveAvatar(String liveAvatar) {
+      this.liveAvatar = liveAvatar;
+   }
+
+   public String getLiveNicename() {
+      return liveNicename;
+   }
+
+   public void setLiveNicename(String liveNicename) {
+      this.liveNicename = liveNicename;
+   }
+
+   public String getCt() {
+      return ct;
+   }
+
+   public void setCt(String ct) {
+      this.ct = ct;
+   }
+
+   @Override
+   public String toString() {
+      return "GuardMaturityDateRemindModel{" +
+              "method='" + method + '\'' +
+              ", action='" + action + '\'' +
+              ", isOverdue=" + isOverdue +
+              ", days=" + days +
+              ", uid='" + uid + '\'' +
+              ", liveuid='" + liveuid + '\'' +
+              ", userAvatar='" + userAvatar + '\'' +
+              ", userNicename='" + userNicename + '\'' +
+              ", liveAvatar='" + liveAvatar + '\'' +
+              ", liveNicename='" + liveNicename + '\'' +
+              ", ct='" + ct + '\'' +
+              '}';
+   }
+}

common/src/main/java/com/yunbao/common/dialog/GuardBuyTipsDialog.java

@@ -36,7 +36,7 @@ public class GuardBuyTipsDialog {
         }
         if (!TextUtils.isEmpty(content)) {
             TextView buyTypeTextView = dialog.findViewById(R.id.buyType);
-            buyTypeTextView.setText(content);
+            buyTypeTextView.setText("【"+content+"】");
         }
         dialog.findViewById(R.id.btn_cancel).setOnClickListener(new View.OnClickListener() {
             @Override

common/src/main/java/com/yunbao/common/http/PDLiveApi.java

@@ -1167,6 +1167,10 @@ public interface PDLiveApi {
 
     @GET("/api/public/?service=Guard.getGuardUserInfo")
     Observable<ResponseModel<GuardGetGuardUserInfoModel>> getGuardUserInfo(@Query("liveuid") String liveUid);
+
     @GET("/api/public/?service=Guard.getGuardOpenInfo")
     Observable<ResponseModel<GuardGetGuardOpenInfoModel>> getGuardOpenInfo(@Query("liveuid") String liveUid);
+
+    @GET("/api/public/?service=Guard.openGuard")
+    Observable<ResponseModel<Object>> openGuard(@Query("liveuid") String liveUid, @Query("guard_type") String guardType, @Query("price_key") String priceKey);
 }

common/src/main/java/com/yunbao/common/http/live/LiveNetManager.java

@@ -2981,6 +2981,30 @@ public class LiveNetManager {
 
     }
 
+    public void openGuard(String liveUid, String guardType, String priceKey, HttpCallback<String> callback) {
+        API.get().pdLiveApi(mContext)
+                .openGuard(liveUid, guardType, priceKey)
+                .subscribeOn(Schedulers.io())
+                .observeOn(AndroidSchedulers.mainThread())
+                .subscribe(new Consumer<ResponseModel<Object>>() {
+                    @Override
+                    public void accept(ResponseModel<Object> stringResponseModel) throws Exception {
+                        if (callback != null) {
+                            callback.onSuccess(stringResponseModel.getData().getMsg());
+                        }
+                    }
+                }, new Consumer<Throwable>() {
+                    @Override
+                    public void accept(Throwable throwable) throws Exception {
+                        throwable.printStackTrace();
+                        if (callback != null) {
+                            callback.onError(mContext.getString(R.string.net_error));
+                        }
+                    }
+                }).isDisposed();
+
+    }
+
     /**
      * 直播间取消网络请求
      */

common/src/main/java/com/yunbao/common/manager/imrongcloud/RongcloudIMManager.java

@@ -66,6 +66,7 @@ public class RongcloudIMManager {
         SpeechUtility.createUtility(application.getApplicationContext(), params);
     }
 
+
     private static RongIMClient.OnReceiveMessageWrapperListener mListener;
 
     /**