From 76fa702eea1f96a9d7eb3f41a852cc6db8b2aae6 Mon Sep 17 00:00:00 2001
From: 101captain <237651143@qq.com>
Date: 星期五, 06 五月 2022 13:29:20 +0800
Subject: [PATCH] 花城E+防疫修改

---
 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/utlis/WxUtil.java |   45 +++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 45 insertions(+), 0 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/utlis/WxUtil.java b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/utlis/WxUtil.java
index 23f61a1..6ec3522 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/utlis/WxUtil.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/utlis/WxUtil.java
@@ -12,6 +12,7 @@
 import com.panzhihua.common.model.dtos.wx.TemplateParam;
 import com.panzhihua.common.model.dtos.wx.WxSubscribeDTO;
 
+import com.panzhihua.common.model.vos.community.acid.ComActAcidDangerMemberVO;
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
@@ -388,6 +389,50 @@
         }
     }
 
+    /**
+     * 预约提醒订阅消息通知
+     * @param openId    用户openid
+     * @param accessToken   token会话标识
+     */
+    public static void sendSubscribeTXTZ(String openId, String accessToken, String templateId){
+        WxSubscribeDTO subscribeDTO = new WxSubscribeDTO();
+        subscribeDTO.setTouser(openId);
+        subscribeDTO.setTemplate_id(templateId);
+        List<TemplateParam> paras=new ArrayList<TemplateParam>();
+        paras.add(new TemplateParam("time2",DateUtils.getCurrentDateStr()));
+        paras.add(new TemplateParam("thing3","请尽快完善返攀报备,填报当前居住地。"));
+        subscribeDTO.setTemplateParamList(paras);
+        try {
+            sendSubscribe(accessToken,subscribeDTO);
+        }catch (Exception e){
+            log.error("预约提醒订阅消息推送失败,失败原因:" + e.getMessage());
+        }
+    }
+
+    /**
+     * 推送危险人员订阅消息通知
+     * @param openId    用户openid
+     * @param accessToken   token会话标识
+     * @param dangerMember 风险人员
+     */
+    public static void sendSubscribeDanger(String openId, String accessToken, ComActAcidDangerMemberVO dangerMember, String templateId){
+        WxSubscribeDTO subscribeDTO = new WxSubscribeDTO();
+        subscribeDTO.setTouser(openId);
+        subscribeDTO.setTemplate_id(templateId);
+        List<TemplateParam> paras=new ArrayList<TemplateParam>();
+        Integer type = dangerMember.getType();
+        paras.add(new TemplateParam("thing2", (type == 1 ? "当前风险人员 " : "当前未填住址人员 ") + dangerMember.getName()));
+        paras.add(new TemplateParam("time3", DateUtils.getCurrentDateStr()));
+        paras.add(new TemplateParam("thing1","新冠疫情"));
+        paras.add(new TemplateParam("thing4", type == 1 ? "新增风险人员" : "新增未填住址人员"));
+        subscribeDTO.setTemplateParamList(paras);
+        try {
+            sendSubscribe(accessToken,subscribeDTO);
+        }catch (Exception e){
+            log.error("危险人员订阅消息推送失败,失败原因:" + e.getMessage());
+        }
+    }
+
     public static void main(String[] args) {
 
         WxXCXTempSend util = new WxXCXTempSend();

--
Gitblit v1.7.1