Explorar o código

fix:公众号修改批量推送

黄渊昊 hai 6 meses
pai
achega
8ac51c28c3

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

@@ -10,13 +10,9 @@ import java.util.List;
 @Setter
 public class PushParam {
     /** 用户openId */
-    private String userId;
-    /** 用户名 */
-    private String userName;
+    private List<String> userIdList;
     /** 设备名 */
     private String deviceName;
-    /** 告警值 */
-    private String value;
     /** 告警内容 */
     private String context;
     /** 告警时间 */

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

@@ -41,25 +41,25 @@ public class PushUtil {
         miniProgram.setUsePath(true);
         miniProgram.setPagePath(PushConfigure.getPagePath());//用户点击时需要跳转的小程序页面
         // 推送消息
-        WxMpTemplateMessage templateMessage = WxMpTemplateMessage.builder()
-                .toUser(pushParam.getUserId())
-                .templateId(PushConfigure.getTemplateId())
-                .miniProgram(miniProgram)
-                .build();
-        // 配置你的信息
-        String dateFormat = DateUtil.format(pushParam.getNoticeTime(), "yyyy-MM-dd HH:mm:ss");
-        templateMessage.addData(new WxMpTemplateData("thing23", pushParam.getDeviceName()));
-        templateMessage.addData(new WxMpTemplateData("thing5", pushParam.getUserName()));
-        templateMessage.addData(new WxMpTemplateData("character_string28", pushParam.getValue()));
-        templateMessage.addData(new WxMpTemplateData("thing25", pushParam.getContext()));
-        templateMessage.addData(new WxMpTemplateData("time3", dateFormat));
+        for (String userId : pushParam.getUserIdList()) {
+            WxMpTemplateMessage templateMessage = WxMpTemplateMessage.builder()
+                    .toUser(userId)
+                    .templateId(PushConfigure.getTemplateId())
+                    .miniProgram(miniProgram)
+                    .build();
+            // 配置你的信息
+            String dateFormat = DateUtil.format(pushParam.getNoticeTime(), "yyyy-MM-dd HH:mm:ss");
+            templateMessage.addData(new WxMpTemplateData("thing23", pushParam.getDeviceName()));
+            templateMessage.addData(new WxMpTemplateData("thing25", pushParam.getContext()));
+            templateMessage.addData(new WxMpTemplateData("time3", dateFormat));
 
-        System.out.println(templateMessage.toJson());
-        try {
-            wxMpService.getTemplateMsgService().sendTemplateMsg(templateMessage);
-        } catch (Exception e) {
-            System.out.println("推送失败:" + e.getMessage());
-            return "推送失败:" + e.getMessage();
+            System.out.println(templateMessage.toJson());
+            try {
+                return wxMpService.getTemplateMsgService().sendTemplateMsg(templateMessage);
+            } catch (Exception e) {
+                System.out.println("推送失败:" + e.getMessage());
+                return "推送失败:" + e.getMessage();
+            }
         }
         return "推送成功!";
     }