From 06cfdb225233a2e8c67f21e130ee0bda67e2cc34 Mon Sep 17 00:00:00 2001
From: yanghui <2536613402@qq.com>
Date: 星期二, 29 十一月 2022 10:12:35 +0800
Subject: [PATCH] #feat 发送订阅消息

---
 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/R.java |   83 +++++++++++++++++++++++++----------------
 1 files changed, 51 insertions(+), 32 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/R.java b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/R.java
index a3f595b..1e17bb6 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/R.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/R.java
@@ -1,11 +1,13 @@
 package com.panzhihua.common.model.vos;
 
+import java.io.Serializable;
+import java.lang.reflect.Field;
 
-import com.panzhihua.common.constants.Constants;
-import lombok.Data;
 import org.springframework.util.ObjectUtils;
 
-import java.io.Serializable;
+import com.panzhihua.common.constants.Constants;
+
+import lombok.Data;
 
 /**
  * 响应信息主体
@@ -13,79 +15,96 @@
  * @author HUANGHONGFA
  */
 @Data
-public class R<T> implements Serializable
-{
-    private static final long serialVersionUID = 1L;
-
-    /** 成功 */
+public class R<T> implements Serializable {
+    /**
+     * 成功
+     */
     public static final int SUCCESS = Constants.SUCCESS;
-
-    /** 失败 */
+    /**
+     * 失败
+     */
     public static final int FAIL = Constants.FAIL;
-
+    private static final long serialVersionUID = 1L;
     private int code;
 
     private String msg;
 
     private T data;
 
-    public static <T> R<T> ok()
-    {
+    public static <T> R<T> ok() {
         return restResult(null, SUCCESS, "success");
     }
 
-    public static <T> R<T> ok(T data)
-    {
+    public static <T> R<T> ok(T data) {
         return restResult(data, SUCCESS, "success");
     }
 
-    public static <T> R<T> ok(T data, String msg)
-    {
+    public static <T> R<T> ok(T data, String msg) {
         return restResult(data, SUCCESS, msg);
     }
 
-    public static <T> R<T> fail()
-    {
+    public static <T> R<T> fail() {
         return restResult(null, FAIL, null);
     }
 
-    public static <T> R<T> fail(String msg)
-    {
+    public static <T> R<T> fail(String msg) {
         return restResult(null, FAIL, msg);
     }
 
-    public static <T> R<T> fail(T data)
-    {
+    public static <T> R<T> fail(T data) {
         return restResult(data, FAIL, null);
     }
 
-    public static <T> R<T> fail(T data, String msg)
-    {
+    public static <T> R<T> fail(T data, String msg) {
         return restResult(data, FAIL, msg);
     }
 
-    public static <T> R<T> fail(int code, String msg)
-    {
+    public static <T> R<T> fail(int code, String msg) {
         return restResult(null, code, msg);
     }
-    public static <T> R<T> fail(int code)
-    {
+
+    public static <T> R<T> fail(int code) {
         return restResult(null, code, null);
     }
 
-    private static <T> R<T> restResult(T data, int code, String msg)
-    {
+    private static <T> R<T> restResult(T data, int code, String msg) {
         R<T> apiResult = new R<>();
         apiResult.setCode(code);
         apiResult.setData(data);
         if (ObjectUtils.isEmpty(msg)) {
             apiResult.setMsg("失败");
-        }else{
+        } else {
             apiResult.setMsg(msg);
         }
 
         return apiResult;
     }
 
+    /**
+     * 请求是否成功
+     *
+     * @return
+     */
+    public static boolean isOk(R r) {
+        return r.code == Constants.SUCCESS.intValue();
+    }
+
+    /**
+     * code
+     *
+     * @return
+     */
+    public static Integer getCode(R r) {
+        String code = null;
+        try {
+            Field field = r.getData().getClass().getDeclaredField("code");
+            code = field.get("code").toString();
+        } catch (IllegalAccessException e) {
+            e.printStackTrace();
+        } catch (NoSuchFieldException e) {
+            e.printStackTrace();
+        }
+        return Integer.valueOf(code);
+    }
 
 }

--
Gitblit v1.7.1