补充提交

snowy-plugin/snowy-plugin-coldchain/src/main/java/vip/xiaonuo/coldchain/modular/push/param/PushParam.java

@@ -4,13 +4,15 @@ import lombok.Getter;
 import lombok.Setter;
 
 import java.util.Date;
+import java.util.HashSet;
 import java.util.List;
+import java.util.Set;
 
 @Getter
 @Setter
 public class PushParam {
     /** 用户openId */
-    private List<String> userIdList;
+    private Set<String> userIdList = new HashSet<String>();
     /** 设备名 */
     private String deviceName;
     /** 告警内容 */

snowy-plugin/snowy-plugin-coldchain/src/main/java/vip/xiaonuo/coldchain/modular/push/utils/PushUtil.java

@@ -15,6 +15,7 @@ import vip.xiaonuo.coldchain.modular.push.config.PushConfigure;
 import vip.xiaonuo.coldchain.modular.push.param.PushParam;
 
 import java.util.Date;
+import java.util.Objects;
 
 /**
  * 推送类
@@ -31,6 +32,10 @@ public class PushUtil {
      * 消息推送主要业务代码
      */
     public static String push(PushParam pushParam) {
+        // 数据校验
+        if (Objects.isNull(pushParam) || Objects.isNull(pushParam.getUserIdList()) || pushParam.getUserIdList().isEmpty()) {
+            return null;
+        }
         //1，配置
         WxMpService wxMpService = new WxMpServiceImpl();
         wxMpService.setWxMpConfigStorage(wxMpConfigStorage());
@@ -53,14 +58,12 @@ public class PushUtil {
             templateMessage.addData(new WxMpTemplateData("thing25", pushParam.getContext()));
             templateMessage.addData(new WxMpTemplateData("time3", dateFormat));
 
-            System.out.println(templateMessage.toJson());
             try {
                 return wxMpService.getTemplateMsgService().sendTemplateMsg(templateMessage);
             } catch (Exception e) {
-                System.out.println("推送失败：" + e.getMessage());
-                return "推送失败：" + e.getMessage();
+                e.printStackTrace();
             }
         }
-        return "推送成功!";
+        return null;
     }
 }