fix:发送公众号消息模板

pom.xml

@@ -222,6 +222,13 @@
                 <version>${weixin-java.version}</version>
                 <version>${weixin-java.version}</version>
             </dependency>
             </dependency>
 
 
+            <dependency>
+                <groupId>com.github.binarywang</groupId>
+                <artifactId>weixin-java-mp</artifactId>
+                <version>${weixin-java.version}</version>
+            </dependency>
+
+
             <!--工作流模块使用-->
             <!--工作流模块使用-->
             <dependency>
             <dependency>
                 <groupId>com.alibaba.fastjson2</groupId>
                 <groupId>com.alibaba.fastjson2</groupId>

server-common/pom.xml

@@ -173,6 +173,12 @@
             <artifactId>weixin-java-miniapp</artifactId>
             <artifactId>weixin-java-miniapp</artifactId>
         </dependency>
         </dependency>
 
 
+        <!--微信公众号-->
+        <dependency>
+            <groupId>com.github.binarywang</groupId>
+            <artifactId>weixin-java-mp</artifactId>
+        </dependency>
+
     </dependencies>
     </dependencies>
 
 
     <profiles>
     <profiles>

server-common/src/main/java/com/makeit/utils/msg/config/WxConfig.java

+package com.makeit.utils.msg.config;
+
+import cn.binarywang.wx.miniapp.api.WxMaService;
+import cn.binarywang.wx.miniapp.api.impl.WxMaServiceImpl;
+import cn.binarywang.wx.miniapp.config.WxMaConfig;
+import cn.binarywang.wx.miniapp.config.impl.WxMaRedissonConfigImpl;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.api.impl.WxMpServiceImpl;
+import me.chanjar.weixin.mp.config.WxMpConfigStorage;
+import me.chanjar.weixin.mp.config.impl.WxMpRedissonConfigImpl;
+import org.redisson.api.RedissonClient;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class WxConfig {
+
+    @Value("${wx.miniapp.config.appid}")
+    private String appId;
+    @Value("${wx.miniapp.config.secret}")
+    private String appSecret;
+
+    @Value("${wx.mp.config.appid}")
+    private String mpAppId;
+    @Value("${wx.mp.config.secret}")
+    private String mpSecret;
+
+    @Autowired
+    private RedissonClient redissonClient;
+
+    @Bean
+    public WxMaService wxMaService(){
+        WxMaServiceImpl wxMaService = new WxMaServiceImpl();
+
+
+        wxMaService.setWxMaConfig(wxMaConfig());
+        return wxMaService;
+    }
+
+    public WxMaConfig wxMaConfig(){
+        WxMaRedissonConfigImpl wxMaRedissonConfig = new WxMaRedissonConfigImpl(redissonClient);
+        wxMaRedissonConfig.setAppid(appId);
+        wxMaRedissonConfig.setSecret(appSecret);
+        return wxMaRedissonConfig;
+    }
+
+    @Bean
+    public WxMpService wxMpService(){
+        WxMpServiceImpl wxMpService = new WxMpServiceImpl();
+        wxMpService.setWxMpConfigStorage(wxMpConfigStorage());
+        return wxMpService;
+
+    }
+
+    public WxMpConfigStorage wxMpConfigStorage(){
+        WxMpRedissonConfigImpl wxMpRedissonConfig = new WxMpRedissonConfigImpl(redissonClient);
+        wxMpRedissonConfig.setAppId(mpAppId);
+        wxMpRedissonConfig.setSecret(mpSecret);
+        return wxMpRedissonConfig;
+    }
+}

server-common/src/main/java/com/makeit/utils/msg/sender/WxSpSender.java

+package com.makeit.utils.msg.sender;
+
+import cn.binarywang.wx.miniapp.api.WxMaService;
+import cn.hutool.core.date.DateUtil;
+import com.makeit.utils.msg.SendTypeEnum;
+import com.makeit.utils.msg.dto.MsgSendDTO;
+import lombok.extern.slf4j.Slf4j;
+import me.chanjar.weixin.common.error.WxErrorException;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.bean.template.WxMpTemplateData;
+import me.chanjar.weixin.mp.bean.template.WxMpTemplateMessage;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.Arrays;
+import java.util.Date;
+import java.util.List;
+
+@Component
+@Slf4j
+public class WxSpSender implements IMsgSender{
+    @Autowired
+    private  WxMaService wxMaService;
+    @Autowired
+    private WxMpService wxMpService;
+
+    /**
+     * 小程序公众号消息
+     * zn5fBS9cqjnN5UB78tAbm53M3dXufR2b5K1a8mkhXCY
+     *
+     * 告警对象{{thing2.DATA}}
+     * 告警时间{{time3.DATA}}
+     * 告警地点{{thing4.DATA}}
+     * 事件类型{{thing8.DATA}}
+     * 跳转文案点击查看详情
+     *
+     * @param msgDTO
+     */
+    @Override
+    public void send(MsgSendDTO msgDTO) {
+
+        List<WxMpTemplateData> mpData = Arrays.asList(
+                new WxMpTemplateData("thing8", "报警内容"),
+                new WxMpTemplateData("thing4", "固定值"),
+                new WxMpTemplateData("thing2", "老人姓名"),
+                new WxMpTemplateData("time3", DateUtil.format(new Date(),"yyyy-MM-dd HH:mm:ss"))
+        );
+        try {
+            //oBmPb5o9T3q-EMsxfhPg_9OjO5k4 lixl公众号openid
+            //oM2OI67H11zTZL88X99PxL6rAS3Y
+            //WxMpUser wxMpUser = wxMpService.getUserService().userInfo("oM2OI6zZQBB-kL6_0kaMM6adVb1E");
+           //oM2OI6zZQBB-kL6_0kaMM6adVb1E 小程序openId
+//            WxMpUserList wxMpUserList = wxMpService.getUserService().userList();
+            //WxMpUser wxMpUser = wxMpService.getUserService().userInfo("oM2OI67H11zTZL88X99PxL6rAS3Y");
+            WxMpTemplateMessage wxMpTemplateMessage = WxMpTemplateMessage.builder().toUser("oM2OI67H11zTZL88X99PxL6rAS3Y")
+                    .templateId("zn5fBS9cqjnN5UB78tAbm53M3dXufR2b5K1a8mkhXCY")
+                    .data(mpData)
+                    .build();
+            wxMpService.getTemplateMsgService().sendTemplateMsg(wxMpTemplateMessage);
+            log.info("发送小程序消息成功");
+        } catch (WxErrorException e) {
+            log.error("发送小程序消息失败：",e);
+        }
+    }
+
+    @Override
+    public boolean support(SendTypeEnum sendTypeEnum) {
+        return false;
+    }
+
+
+}

server-web/src/main/resources/application-dev.yml

@@ -134,7 +134,10 @@ wx:
       token: #微信小程序消息服务器配置的token
       token: #微信小程序消息服务器配置的token
       aesKey: #微信小程序消息服务器配置的EncodingAESKey
       aesKey: #微信小程序消息服务器配置的EncodingAESKey
       msgDataFormat: JSON
       msgDataFormat: JSON
-
+  mp:
+    config:
+      appid: wx5c73cad7aeb788c6
+      secret: 7c3a0665bf2adbe67a58a4d6c8017243
 sms:
 sms:
   send:
   send:
     url: http://www.aozoneyun.com/message/message/send
     url: http://www.aozoneyun.com/message/message/send

server-web/src/main/resources/application-test.yml

@@ -130,6 +130,10 @@ wx:
       token: #微信小程序消息服务器配置的token
       token: #微信小程序消息服务器配置的token
       aesKey: #微信小程序消息服务器配置的EncodingAESKey
       aesKey: #微信小程序消息服务器配置的EncodingAESKey
       msgDataFormat: JSON
       msgDataFormat: JSON
+  mp:
+    config:
+      appid: wx5c73cad7aeb788c6
+      secret: 7c3a0665bf2adbe67a58a4d6c8017243
 
 
 sms:
 sms:
   send:
   send: