From 964a5ecb478a714f21c5bc75b3d32c16a626deef Mon Sep 17 00:00:00 2001
From: 101captain <237651143@qq.com>
Date: 星期一, 09 五月 2022 17:55:58 +0800
Subject: [PATCH] 花城E+防疫修改
---
springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/utlis/WxUtil.java | 75 +++++++++++++++++++++++++++++++++++--
1 files changed, 71 insertions(+), 4 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..e025609 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
@@ -1,10 +1,7 @@
package com.panzhihua.common.utlis;
import java.math.BigDecimal;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
@@ -12,6 +9,8 @@
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 com.panzhihua.common.model.vos.community.reserve.FiveCount;
import lombok.extern.slf4j.Slf4j;
@Slf4j
@@ -388,6 +387,74 @@
}
}
+ /**
+ * 预约提醒订阅消息通知
+ * @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());
+ }
+ }
+
+
+ /**
+ * 推送危险人员订阅消息通知
+ * @param openId 用户openid
+ * @param accessToken token会话标识
+ * @param fiveCount 统计数据
+ */
+ public static void sendSubscribeStatics(String openId, String accessToken, FiveCount fiveCount, String templateId){
+ WxSubscribeDTO subscribeDTO = new WxSubscribeDTO();
+ subscribeDTO.setTouser(openId);
+ subscribeDTO.setTemplate_id(templateId);
+ subscribeDTO.setPage("/packageB/pages/register/reportingStatistics/reportingStatistics");
+ List<TemplateParam> paras=new ArrayList<TemplateParam>();
+ paras.add(new TemplateParam("thing2", "报备总数"+fiveCount.getAllCount()+";"+"风险人员"+fiveCount.getDangerCount()));
+ paras.add(new TemplateParam("time3", DateUtils.getDateFormatString(DateUtils.addDay(new Date(),-1),"yyyy-MM-dd")+"0点到24点"));
+ paras.add(new TemplateParam("thing1","新冠疫情"));
+ paras.add(new TemplateParam("thing4", "社区报备数据统计"));
+ 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