From b7210488b6129ceb614e559d0240bf3ed3321dea Mon Sep 17 00:00:00 2001
From: k94314517 <8417338+k94314517@user.noreply.gitee.com>
Date: 星期四, 05 十二月 2024 19:36:20 +0800
Subject: [PATCH] 代码初始化
---
server/visits/dmvisit_service/src/main/java/com/doumee/core/wx/wxPlat/WxPlatNotice.java | 645 ++++++++++++++++++++++++++++++++++++++++++++++++++--------
1 files changed, 556 insertions(+), 89 deletions(-)
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/core/wx/wxPlat/WxPlatNotice.java b/server/visits/dmvisit_service/src/main/java/com/doumee/core/wx/wxPlat/WxPlatNotice.java
index 39e54a7..7fd38e9 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/core/wx/wxPlat/WxPlatNotice.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/core/wx/wxPlat/WxPlatNotice.java
@@ -1,10 +1,16 @@
package com.doumee.core.wx.wxPlat;
+import cn.emay.sdk.util.json.gson.JsonObject;
+import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.doumee.biz.system.SystemDictDataBiz;
import com.doumee.core.utils.Constants;
+import com.doumee.core.utils.DateUtil;
+import com.doumee.core.utils.Http;
+import com.doumee.core.utils.HttpsUtil;
+import com.doumee.dao.business.VisitsMapper;
import com.doumee.dao.business.WxNoticeConfigMapper;
-import com.doumee.dao.business.model.Visits;
-import com.doumee.dao.business.model.WxNoticeConfig;
+import com.doumee.dao.business.model.*;
import com.github.xiaoymin.knife4j.core.util.CollectionUtils;
import lombok.extern.slf4j.Slf4j;
import me.chanjar.weixin.common.error.WxErrorException;
@@ -12,10 +18,11 @@
import me.chanjar.weixin.mp.bean.template.WxMpTemplateData;
import me.chanjar.weixin.mp.bean.template.WxMpTemplateMessage;
import org.apache.commons.lang3.StringUtils;
+import org.apache.commons.lang3.time.DateFormatUtils;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
-import java.util.List;
-import java.util.Objects;
+import java.util.*;
/**
* 寰俊鍏紬鍙烽�氱煡
@@ -27,94 +34,160 @@
@Component
public class WxPlatNotice {
- /**
- * 寰俊鍏紬鍙稟PI鐨凷ervice
- */
- /* private final WxMpService wxMpService;
-
- public WxPlatNotice(WxMpService wxMpService) {
- this.wxMpService = wxMpService;
- }*/
-
-
- /**
- * 璁垮涓氬姟閫氱煡鎺ュ彛
- */
- public Boolean sendVisitAuditTemplateNotice(Visits visits,String prefix,String tempId){
- if(StringUtils.isBlank(visits.getOpenid())){
- return false;
- }
- WxMpTemplateMessage templateMessage = WxMpTemplateMessage.builder()
- .toUser(visits.getOpenid())
- .templateId(tempId)
- .url(prefix + visits.getId())
- .build();
-
-
- String thing1 = "寰呭鎵�";
- if(visits.getStatus()==2){
- thing1 = "瀹℃牳閫氳繃";
- }else if(visits.getStatus()==3){
- thing1 = "瀹℃牳涓嶉�氳繃";
- }else if(visits.getStatus()==5){
- thing1 = "璁惧鎺堟潈鎴愬姛";
- }else if(visits.getStatus()==6){
- thing1 = "璁惧鎺堟潈鏈垚鍔�";
- }
- // 娣诲姞妯℃澘鏁版嵁
- templateMessage.addData(new WxMpTemplateData("thing1", thing1))
- .addData(new WxMpTemplateData("thing2", visits.getName()))
- .addData(new WxMpTemplateData("phone_number6", visits.getPhone()));
- String msgId = null;
-/* try {
- // 鍙戦�佹ā鏉挎秷鎭�
- msgId = wxMpService.getTemplateMsgService().sendTemplateMsg(templateMessage);
- } catch (WxErrorException e) {
- e.printStackTrace();
- }*/
- log.warn("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", msgId != null ? "鎴愬姛" : "澶辫触");
- return msgId != null;
- }
-
-
-
- /**
- * 璁垮涓氬姟閫氱煡
- */
- public void sendVisitTemplateNotice(WxNoticeConfigMapper wxNoticeConfigMapper,Visits visits,String objCode, String prefix, String tempId, List<String> openIds){
+ public void testSendNotice(List<String> openIds,String token){
if(CollectionUtils.isNotEmpty(openIds)){
- WxNoticeConfig wxNoticeConfig = wxNoticeConfigMapper.selectOne(new QueryWrapper<WxNoticeConfig>().lambda().eq(WxNoticeConfig::getObjType,WxPlatConstants.visit)
- .eq(WxNoticeConfig::getObjCode,objCode)
- .eq(WxNoticeConfig::getStatus, Constants.ZERO)
- .last(" limit 1")
- );
- if(Objects.isNull(wxNoticeConfig)){
- return;
- }
- WxMpTemplateMessage templateMessage = WxMpTemplateMessage.builder()
- .toUser(visits.getOpenid())
- .templateId(tempId)
- .url(prefix + visits.getId())
- .build();
-
- templateMessage.addData(new WxMpTemplateData("thing1", visits.getName()))
- .addData(new WxMpTemplateData("car_number7", StringUtils.isBlank(visits.getCarNos())?visits.getCarNos():"-"))
- .addData(new WxMpTemplateData("character_string6", Constants.equalsInteger(visits.getMemberNum(),Constants.ZERO)?Constants.ONE+"":visits.getMemberNum().toString()))
- .addData(new WxMpTemplateData("const9", wxNoticeConfig.getTitile()))
- .addData(new WxMpTemplateData("thing4", visits.getReason()))
- ;
- String msgId = null;
- /* try {
- for (String openId:openIds) {
- templateMessage.setToUser(openId);
+ String postUrL = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token="+token;
+ //鏁翠綋鍙傛暟map
+ Map<String, Object> paramMap = new HashMap<String, Object>();
+ //娑堟伅涓婚鏄剧ず鐩稿叧map
+ Map<String, Object> dataMap = new HashMap<String, Object>();
+ Map<String, Object> const9 = new HashMap<String,Object>();
+ const9.put("value","鐢宠寰呮偍瀹℃壒");
+ Map<String, Object> thing1 = new HashMap<String,Object>();
+ thing1.put("value", "娴嬭瘯鍚嶇О");
+ Map<String, Object> car_number7 = new HashMap<String,Object>();
+ car_number7.put("value","鐨朅P12345");
+ Map<String, Object> character_string6 = new HashMap<String,Object>();
+ character_string6.put("value","1");
+ Map<String, Object> thing4 = new HashMap<String,Object>();
+ thing4.put("value","鐞嗙敱");
+ dataMap.put("const9",const9);
+ dataMap.put("thing1",thing1);
+ dataMap.put("car_number7",car_number7);
+ dataMap.put("character_string6",character_string6);
+ dataMap.put("thing4",thing4);
+ paramMap.put("data", dataMap);
+ for (String openId:openIds) {
+ paramMap.clear();
+ paramMap.put("template_id", "SPwvgtASkm1aMDBsYhX2wHKdL2JBEGPknDkgniSza2Y");
+ paramMap.put("touser", openId);
+ paramMap.put("data", dataMap);
+ String response = HttpsUtil.postJson(postUrL, JSONObject.toJSONString(paramMap));
+ if(StringUtils.isBlank(response)){
+ log.warn("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", "澶辫触");
+ }else{
+ JSONObject json = JSONObject.parseObject(response);
+ log.warn("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", Constants.equalsInteger(json.getInteger("errcode"),Constants.ZERO)?"鎴愬姛":"澶辫触"+json.getString("errmsg"));
}
- // 鍙戦�佹ā鏉挎秷鎭�
- msgId = wxMpService.getTemplateMsgService().sendTemplateMsg(templateMessage);
- } catch (WxErrorException e) {
- e.printStackTrace();
- }*/
- log.warn("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", msgId != null ? "鎴愬姛" : "澶辫触");
+ }
+// log.warn("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", msgId != null ? "鎴愬姛" : "澶辫触");
+ }
+ }
+ /**
+ * 璁垮鐢宠/鎶ュ涓氬姟閫氱煡
+ * @param wxNoticeConfigMapper
+ * @param visits
+ * @param objCode visitUpload,visitAuditSuccess,visitWaitAudit锛寁isitWaitAudit,visitReportUpload锛寁isitReportAuditSuccess锛寁isitReportAuditFail, visitReportAuditSuccess
+ * @param openIds
+ */
+ public void sendVisitTemplateNotice(WxNoticeConfigMapper wxNoticeConfigMapper, Visits visits, String objCode, String token, List<String> openIds){
+ try{
+ if(CollectionUtils.isNotEmpty(openIds)){
+ WxNoticeConfig wxNoticeConfig = wxNoticeConfigMapper.selectOne(new QueryWrapper<WxNoticeConfig>().lambda().eq(WxNoticeConfig::getObjType,WxPlatConstants.visit)
+ .eq(WxNoticeConfig::getObjCode,objCode)
+ .eq(WxNoticeConfig::getStatus, Constants.ZERO)
+ .last(" limit 1")
+ );
+ if(Objects.isNull(wxNoticeConfig)){
+ return;
+ }
+ String postUrL = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token="+token;
+ //鏁翠綋鍙傛暟map
+ Map<String, Object> paramMap = new HashMap<String, Object>();
+ //娑堟伅涓婚鏄剧ず鐩稿叧map
+ Map<String, Object> dataMap = new HashMap<String, Object>();
+ Map<String, Object> const9 = new HashMap<String,Object>();
+ const9.put("value",wxNoticeConfig.getTitile());
+ Map<String, Object> thing1 = new HashMap<String,Object>();
+ thing1.put("value", visits.getName());
+ Map<String, Object> car_number7 = new HashMap<String,Object>();
+ car_number7.put("value",StringUtils.isNotBlank(visits.getCarNos())?visits.getCarNos():"-");
+ Map<String, Object> character_string6 = new HashMap<String,Object>();
+ character_string6.put("value","1");
+ Map<String, Object> thing4 = new HashMap<String,Object>();
+ thing4.put("value",visits.getReason());
+ dataMap.put("const9",const9);
+ dataMap.put("thing1",thing1);
+ dataMap.put("car_number7",car_number7);
+ dataMap.put("character_string6",character_string6);
+ dataMap.put("thing4",thing4);
+ paramMap.put("data", dataMap);
+ for (String openId:openIds) {
+ paramMap.clear();
+ paramMap.put("template_id", wxNoticeConfig.getTempId());
+ paramMap.put("touser", openId);
+ paramMap.put("data", dataMap);
+ String response = HttpsUtil.postJson(postUrL, JSONObject.toJSONString(paramMap));
+ if(StringUtils.isBlank(response)){
+ log.warn("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", "澶辫触");
+ }else{
+ JSONObject json = JSONObject.parseObject(response);
+ log.warn("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", Constants.equalsInteger(json.getInteger("errcode"),Constants.ZERO)?"鎴愬姛":"澶辫触"+json.getString("errmsg"));
+ }
+ }
+// log.warn("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", msgId != null ? "鎴愬姛" : "澶辫触");
+ }
+ }catch (Exception e){
+
+ }
+ }
+
+ /**
+ * 闅愭偅涓婃姤
+ * @param wxNoticeConfigMapper
+ * @param hiddenDanger
+ * @param objCode hiddenDangerUpload
+ * @param openIds
+ */
+ public void sendHiddenDangerUploadTemplateNotice(WxNoticeConfigMapper wxNoticeConfigMapper, HiddenDanger hiddenDanger, String objCode,String token, List<String> openIds){
+ try{
+ if(CollectionUtils.isNotEmpty(openIds)){
+ WxNoticeConfig wxNoticeConfig = wxNoticeConfigMapper.selectOne(new QueryWrapper<WxNoticeConfig>().lambda().eq(WxNoticeConfig::getObjType,WxPlatConstants.visit)
+ .eq(WxNoticeConfig::getObjCode,objCode)
+ .eq(WxNoticeConfig::getStatus, Constants.ZERO)
+ .last(" limit 1")
+ );
+ if(Objects.isNull(wxNoticeConfig)){
+ return;
+ }
+ String postUrL = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token="+token;
+ //鏁翠綋鍙傛暟map
+ Map<String, Object> paramMap = new HashMap<String, Object>();
+ //娑堟伅涓婚鏄剧ず鐩稿叧map
+ Map<String, Object> dataMap = new HashMap<String, Object>();
+ //闅愭偅鍖哄煙
+ Map<String, Object> thing9 = new HashMap<String,Object>();
+ thing9.put("value",hiddenDanger.getAreaName());
+ //闅愭偅鍚嶇О
+ Map<String, Object> thing1 = new HashMap<String,Object>();
+ thing1.put("value", hiddenDanger.getCategoryName());
+ //鎻愭姤浜�
+ Map<String, Object> thing12 = new HashMap<String,Object>();
+ thing12.put("value",hiddenDanger.getMemberName());
+ //鎻愭姤鏃堕棿
+ Map<String, Object> time11 = new HashMap<String,Object>();
+ time11.put("value", DateUtil.getDate(hiddenDanger.getCreateDate(),"yyyy骞碝M鏈坉d鏃� HH:mm:ss") );
+ dataMap.put("thing9",thing9);
+ dataMap.put("thing1",thing1);
+ dataMap.put("thing12",thing12);
+ dataMap.put("time11",time11);
+ paramMap.put("template_id", wxNoticeConfig.getTempId());
+ paramMap.put("data", dataMap);
+ for (String openId:openIds) {
+ paramMap.clear();
+ paramMap.put("touser", openId);
+ paramMap.put("data", dataMap);
+ String response = HttpsUtil.postJson(postUrL, JSONObject.toJSONString(paramMap));
+ if(StringUtils.isBlank(response)){
+ log.warn("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", "澶辫触");
+ }else{
+ JSONObject json = JSONObject.parseObject(response);
+ log.warn("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", Constants.equalsInteger(json.getInteger("errcode"),Constants.ZERO)?"鎴愬姛":"澶辫触"+json.getString("errmsg"));
+ }
+ }
+ }
+ }catch (Exception e){
}
@@ -122,5 +195,399 @@
+ /**
+ * 闅愭偅鏁存敼
+ * @param wxNoticeConfigMapper
+ * @param hiddenDanger
+ * @param objCode hiddenDangerDeal
+ * @param openIds
+ */
+ public void sendHiddenDangerDealTemplateNotice(WxNoticeConfigMapper wxNoticeConfigMapper, HiddenDanger hiddenDanger, String objCode,String token, List<String> openIds){
+ try{
+ if(CollectionUtils.isNotEmpty(openIds)){
+ WxNoticeConfig wxNoticeConfig = wxNoticeConfigMapper.selectOne(new QueryWrapper<WxNoticeConfig>().lambda().eq(WxNoticeConfig::getObjType,WxPlatConstants.visit)
+ .eq(WxNoticeConfig::getObjCode,objCode)
+ .eq(WxNoticeConfig::getStatus, Constants.ZERO)
+ .last(" limit 1")
+ );
+ if(Objects.isNull(wxNoticeConfig)){
+ return;
+ }
+ String postUrL = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token="+token;
+ //鏁翠綋鍙傛暟map
+ Map<String, Object> paramMap = new HashMap<String, Object>();
+ //娑堟伅涓婚鏄剧ず鐩稿叧map
+ Map<String, Object> dataMap = new HashMap<String, Object>();
+ //闅愭偅鍖哄煙
+ Map<String, Object> thing17 = new HashMap<String,Object>();
+ thing17.put("value",hiddenDanger.getAreaName());
+ //闅愭偅鍚嶇О
+ Map<String, Object> thing3 = new HashMap<String,Object>();
+ thing3.put("value", hiddenDanger.getCategoryName());
+ //鏁存敼鏂瑰紡
+ Map<String, Object> thing13 = new HashMap<String,Object>();
+ thing13.put("value",Constants.equalsInteger(hiddenDanger.getStatus(),Constants.ONE)?"闅愭偅宸叉暣鏀�":"闅愭偅宸查��鍥�");
+ //鎻愪氦浜�
+ Map<String, Object> thing10 = new HashMap<String,Object>();
+ thing10.put("value",hiddenDanger.getCheckorName());
+ //閫氱煡鏃堕棿
+ Map<String, Object> time16 = new HashMap<String,Object>();
+ time16.put("value", DateUtil.getDate(hiddenDanger.getDealTime(),"yyyy骞碝M鏈坉d鏃� HH:mm:ss") );
+ dataMap.put("thing17",thing17);
+ dataMap.put("thing3",thing3);
+ dataMap.put("thing13",thing13);
+ dataMap.put("thing10",thing10);
+ dataMap.put("time16",time16);
+ paramMap.put("template_id", wxNoticeConfig.getTempId());
+ paramMap.put("data", dataMap);
+ for (String openId:openIds) {
+ paramMap.clear();
+ paramMap.put("touser", openId);
+ paramMap.put("data", dataMap);
+ String response = HttpsUtil.postJson(postUrL, JSONObject.toJSONString(paramMap));
+ if(StringUtils.isBlank(response)){
+ log.warn("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", "澶辫触");
+ }else{
+ JSONObject json = JSONObject.parseObject(response);
+ log.warn("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", Constants.equalsInteger(json.getInteger("errcode"),Constants.ZERO)?"鎴愬姛":"澶辫触"+json.getString("errmsg"));
+ }
+ }
+ }
+ }catch (Exception e){
+
+ }
+
+ }
+
+ /**
+ * 鐢ㄨ溅鐢宠 瀹℃壒鎯呭喌
+ * @param wxNoticeConfigMapper
+ * @param carUseBook
+ * @param objCode reservationSuccess锛宮eetingCancel,meetingBeginA锛宮eetingEndA
+ * @param openIds
+ * @param sendType 0=鐢宠浜猴紱1=瀹℃壒浜�
+ */
+ public void sendCarUseBookTemplateNotice(WxNoticeConfigMapper wxNoticeConfigMapper, CarUseBook carUseBook, String objCode,String token,
+ List<String> openIds,Integer sendType){
+ try {
+ if(CollectionUtils.isNotEmpty(openIds)){
+ WxNoticeConfig wxNoticeConfig = wxNoticeConfigMapper.selectOne(new QueryWrapper<WxNoticeConfig>().lambda().eq(WxNoticeConfig::getObjType,WxPlatConstants.visit)
+ .eq(WxNoticeConfig::getObjCode,objCode)
+ .eq(WxNoticeConfig::getStatus, Constants.ZERO)
+ .last(" limit 1")
+ );
+ if(Objects.isNull(wxNoticeConfig)){
+ return;
+ }
+ String postUrL = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token="+token;
+ //鏁翠綋鍙傛暟map
+ Map<String, Object> paramMap = new HashMap<String, Object>();
+ //娑堟伅涓婚鏄剧ず鐩稿叧map
+ Map<String, Object> dataMap = new HashMap<String, Object>();
+ //瀹℃壒杩涘害
+ Map<String, Object> thing3 = new HashMap<String,Object>();
+ if(Constants.equalsInteger(sendType,Constants.ONE)){
+ thing3.put("value","鐢宠寰呮偍瀹℃壒");
+ }else{
+ if(Constants.equalsInteger(carUseBook.getStatus(),Constants.ZERO)){
+ thing3.put("value","鐢宠鎻愪氦鎴愬姛寰呭鏍�");
+ }else if(Constants.equalsInteger(carUseBook.getStatus(),Constants.TWO)){
+ thing3.put("value","鐢宠宸插鏍搁�氳繃");
+ }else{
+ thing3.put("value","鐢宠宸茶椹冲洖");
+ }
+ }
+ //鐢宠浜�
+ Map<String, Object> thing1 = new HashMap<String,Object>();
+ thing1.put("value", carUseBook.getMemberName());
+ //杞︾墝鍙�
+ Map<String, Object> car_number2 = new HashMap<String,Object>();
+ car_number2.put("value",carUseBook.getCarCode());
+ //鐩殑鍦�
+ Map<String, Object> thing11 = new HashMap<String,Object>();
+ thing11.put("value",carUseBook.getAddr());
+ //鐢ㄨ溅鏃堕棿
+ Map<String, Object> time14 = new HashMap<String,Object>();
+ time14.put("value", carUseBook.getPlanUseDate());
+ dataMap.put("thing3",thing3);
+ dataMap.put("car_number2",car_number2);
+ dataMap.put("thing1",thing1);
+ dataMap.put("thing11",thing11);
+ dataMap.put("time14",time14);
+ paramMap.put("template_id", wxNoticeConfig.getTempId());
+ paramMap.put("data", dataMap);
+ for (String openId:openIds) {
+ paramMap.clear();
+ paramMap.put("touser", openId);
+ paramMap.put("data", dataMap);
+ String response = HttpsUtil.postJson(postUrL, JSONObject.toJSONString(paramMap));
+ if(StringUtils.isBlank(response)){
+ log.warn("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", "澶辫触");
+ }else{
+ JSONObject json = JSONObject.parseObject(response);
+ log.warn("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", Constants.equalsInteger(json.getInteger("errcode"),Constants.ZERO)?"鎴愬姛":"澶辫触"+json.getString("errmsg"));
+ }
+ }
+ }
+ }catch (Exception e){
+
+ }
+ }
+
+
+ /**
+ * 杞﹁締鍏ュ洯鐢宠 鐗╂祦杞�
+ * @param wxNoticeConfigMapper
+ * @param platformBooks
+ * @param objCode platformBookUpload锛宲latformBookAuditSuccess,platformBookAuditFail锛宲latformBookWaitAudit
+ * @param token
+ * @param openIds
+ * @param sendType 0=鐢宠浜猴紱1=瀹℃壒浜�
+ */
+ public void sendPlatformBookTemplateNotice(WxNoticeConfigMapper wxNoticeConfigMapper, PlatformBooks platformBooks, String objCode,String token,
+ List<String> openIds,Integer sendType){
+ try{
+ if(CollectionUtils.isNotEmpty(openIds)){
+ WxNoticeConfig wxNoticeConfig = wxNoticeConfigMapper.selectOne(new QueryWrapper<WxNoticeConfig>().lambda().eq(WxNoticeConfig::getObjType,WxPlatConstants.visit)
+ .eq(WxNoticeConfig::getObjCode,objCode)
+ .eq(WxNoticeConfig::getStatus, Constants.ZERO)
+ .last(" limit 1")
+ );
+ if(Objects.isNull(wxNoticeConfig)){
+ return;
+ }
+ String postUrL = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token="+token;
+ //鏁翠綋鍙傛暟map
+ Map<String, Object> paramMap = new HashMap<String, Object>();
+ //娑堟伅涓婚鏄剧ず鐩稿叧map
+ Map<String, Object> dataMap = new HashMap<String, Object>();
+ //瀹℃牳鐘舵��
+ Map<String, Object> const9 = new HashMap<String,Object>();
+ if(Constants.equalsInteger(sendType,Constants.ONE)){
+ const9.put("value","鐢宠寰呮偍瀹℃壒");
+ }else{
+ if(Constants.equalsInteger(platformBooks.getStatus(),Constants.ZERO)){
+ const9.put("value","鐢宠鎻愪氦鎴愬姛寰呭鏍�");
+ }else if(Constants.equalsInteger(platformBooks.getStatus(),Constants.TWO)){
+ const9.put("value","鐢宠宸插鏍搁�氳繃");
+ }else{
+ const9.put("value","鐢宠宸茶椹冲洖");
+ }
+ }
+ //杞︾墝鍙�
+ Map<String, Object> car_number3 = new HashMap<String,Object>();
+ car_number3.put("value", platformBooks.getCarCodeFront());
+ //涓氬姟绫诲瀷
+ Map<String, Object> phrase4 = new HashMap<String,Object>();
+ phrase4.put("value", platformBooks.getInReason());
+ //鐢宠浜�
+ Map<String, Object> thing8 = new HashMap<String,Object>();
+ thing8.put("value", platformBooks.getDriverName());
+ //鏃堕棿
+ Map<String, Object> time4 = new HashMap<String,Object>();
+ time4.put("value", DateUtil.getDate(platformBooks.getArriveDate(),"yyyy骞碝M鏈坉d鏃� HH:mm:ss") );
+ dataMap.put("const9",const9);
+ dataMap.put("car_number3",car_number3);
+ dataMap.put("phrase4",phrase4);
+ dataMap.put("thing8",thing8);
+ dataMap.put("time4",time4);
+ paramMap.put("data", dataMap);
+ for (String openId:openIds) {
+ paramMap.clear();
+ paramMap.put("template_id", wxNoticeConfig.getTempId());
+ paramMap.put("touser", openId);
+ paramMap.put("data", dataMap);
+ String response = HttpsUtil.postJson(postUrL, JSONObject.toJSONString(paramMap));
+ if(StringUtils.isBlank(response)){
+ log.warn("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", "澶辫触");
+ }else{
+ JSONObject json = JSONObject.parseObject(response);
+ log.warn("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", Constants.equalsInteger(json.getInteger("errcode"),Constants.ZERO)?"鎴愬姛":"澶辫触"+json.getString("errmsg"));
+ }
+ }
+ }
+ }catch (Exception e){
+
+ }
+ }
+
+
+
+ /**
+ * Wms 浠诲姟涓嬭揪閫氱煡
+ * @param wxNoticeConfigMapper
+ * @param platformJob
+ * @param objCode platformJobNewJob
+ * @param openIds
+ */
+ public void sendWmsTemplateNotice(WxNoticeConfigMapper wxNoticeConfigMapper, PlatformJob platformJob, String objCode,String token,
+ List<String> openIds){
+ try{
+ if(CollectionUtils.isNotEmpty(openIds)){
+ WxNoticeConfig wxNoticeConfig = wxNoticeConfigMapper.selectOne(new QueryWrapper<WxNoticeConfig>().lambda().eq(WxNoticeConfig::getObjType,WxPlatConstants.visit)
+ .eq(WxNoticeConfig::getObjCode,objCode)
+ .eq(WxNoticeConfig::getStatus, Constants.ZERO)
+ .last(" limit 1")
+ );
+ if(Objects.isNull(wxNoticeConfig)){
+ return;
+ }
+ String postUrL = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token="+token;
+ //鏁翠綋鍙傛暟map
+ Map<String, Object> paramMap = new HashMap<String, Object>();
+ //娑堟伅涓婚鏄剧ず鐩稿叧map
+ Map<String, Object> dataMap = new HashMap<String, Object>();
+ //杩愬崟缂栧彿
+ Map<String, Object> character_string1 = new HashMap<String,Object>();
+ character_string1.put("value",platformJob.getBillCode());
+ //鍙告満
+ Map<String, Object> thing3 = new HashMap<String,Object>();
+ thing3.put("value", platformJob.getDriverName());
+ //涓嬭揪鏃堕棿
+ Map<String, Object> time4 = new HashMap<String,Object>();
+ time4.put("value", DateUtil.getDate(platformJob.getCreateDate(),"yyyy骞碝M鏈坉d鏃� HH:mm:ss") );
+ dataMap.put("character_string1",character_string1);
+ dataMap.put("thing3",thing3);
+ dataMap.put("time4",time4);
+ paramMap.put("data", dataMap);
+ for (String openId:openIds) {
+ paramMap.clear();
+ paramMap.put("template_id", wxNoticeConfig.getTempId());
+ paramMap.put("touser", openId);
+ paramMap.put("data", dataMap);
+ String response = HttpsUtil.postJson(postUrL, JSONObject.toJSONString(paramMap));
+ if(StringUtils.isBlank(response)){
+ log.warn("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", "澶辫触");
+ }else{
+ JSONObject json = JSONObject.parseObject(response);
+ log.warn("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", Constants.equalsInteger(json.getInteger("errcode"),Constants.ZERO)?"鎴愬姛":"澶辫触"+json.getString("errmsg"));
+ }
+ }
+ }
+ }catch (Exception e){
+
+ }
+
+ }
+
+ /**
+ * Wms 浠诲姟鍙栨秷閫氱煡
+ * @param wxNoticeConfigMapper
+ * @param platformJob
+ * @param objCode platformJobNewJob
+ * @param openIds
+ */
+ public void sendWmsCancelTemplateNotice(WxNoticeConfigMapper wxNoticeConfigMapper, PlatformJob platformJob, String objCode,String token,
+ List<String> openIds){
+ try{
+ if(CollectionUtils.isNotEmpty(openIds)){
+ WxNoticeConfig wxNoticeConfig = wxNoticeConfigMapper.selectOne(new QueryWrapper<WxNoticeConfig>().lambda().eq(WxNoticeConfig::getObjType,WxPlatConstants.visit)
+ .eq(WxNoticeConfig::getObjCode,objCode)
+ .eq(WxNoticeConfig::getStatus, Constants.ZERO)
+ .last(" limit 1")
+ );
+ if(Objects.isNull(wxNoticeConfig)){
+ return;
+ }
+ String postUrL = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token="+token;
+ //鏁翠綋鍙傛暟map
+ Map<String, Object> paramMap = new HashMap<String, Object>();
+ //娑堟伅涓婚鏄剧ず鐩稿叧map
+ Map<String, Object> dataMap = new HashMap<String, Object>();
+ //浠诲姟鍗曞彿
+ Map<String, Object> character_string1 = new HashMap<String,Object>();
+ character_string1.put("value",platformJob.getBillCode());
+ //鍙栨秷鏃堕棿
+ Map<String, Object> time6 = new HashMap<String,Object>();
+ time6.put("value", DateUtil.getDate(new Date(),"yyyy骞碝M鏈坉d鏃� HH:mm:ss") );
+ dataMap.put("character_string1",character_string1);
+ dataMap.put("time6",time6);
+ paramMap.put("data", dataMap);
+ for (String openId:openIds) {
+ paramMap.clear();
+ paramMap.put("template_id", wxNoticeConfig.getTempId());
+ paramMap.put("touser", openId);
+ paramMap.put("data", dataMap);
+ String response = HttpsUtil.postJson(postUrL, JSONObject.toJSONString(paramMap));
+ if(StringUtils.isBlank(response)){
+ log.warn("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", "澶辫触");
+ }else{
+ JSONObject json = JSONObject.parseObject(response);
+ log.warn("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", Constants.equalsInteger(json.getInteger("errcode"),Constants.ZERO)?"鎴愬姛":"澶辫触"+json.getString("errmsg"));
+ }
+ }
+ }
+ }catch (Exception e){
+
+ }
+
+ }
+
+
+ /**
+ * 鏈堝彴浣滀笟
+ * @param wxNoticeConfigMapper
+ * @param platformJob
+ * @param objCode platformJobCallIn锛宲latformJobSingIn,platformJobOverNum锛宲latformJobWorking,platformJobFinish锛宲latformJobLevelPower,platformJobMove锛宲latformJobError锛宲latformJobTimeOut,platformJobStopErr
+ * @param token
+ * @param openIds
+ */
+ public void sendPlatformJobTemplateNotice(WxNoticeConfigMapper wxNoticeConfigMapper, PlatformJob platformJob, String objCode,String token,
+ List<String> openIds){
+ try{
+ if(CollectionUtils.isNotEmpty(openIds)){
+ WxNoticeConfig wxNoticeConfig = wxNoticeConfigMapper.selectOne(new QueryWrapper<WxNoticeConfig>().lambda().eq(WxNoticeConfig::getObjType,WxPlatConstants.visit)
+ .eq(WxNoticeConfig::getObjCode,objCode)
+ .eq(WxNoticeConfig::getStatus, Constants.ZERO)
+ .last(" limit 1")
+ );
+ if(Objects.isNull(wxNoticeConfig)){
+ return;
+ }
+ String postUrL = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token="+token;
+ //鏁翠綋鍙傛暟map
+ Map<String, Object> paramMap = new HashMap<String, Object>();
+ //娑堟伅涓婚鏄剧ず鐩稿叧map
+ Map<String, Object> dataMap = new HashMap<String, Object>();
+ //鏈堝彴閫氱煡
+ Map<String, Object> const6 = new HashMap<String,Object>();
+ const6.put("value",wxNoticeConfig.getTitile());
+ //杞︾墝鍙�
+ Map<String, Object> character_string1 = new HashMap<String,Object>();
+ character_string1.put("value",platformJob.getCarCodeFront());
+ //鏈堝彴鍙�
+ Map<String, Object> thing3 = new HashMap<String,Object>();
+ thing3.put("value", platformJob.getPlatformName());
+ //鏃堕棿
+ Map<String, Object> time4 = new HashMap<String,Object>();
+ time4.put("value", DateUtil.getDate(new Date(),"yyyy骞碝M鏈坉d鏃� HH:mm:ss") );
+ dataMap.put("const6",const6);
+ dataMap.put("character_string1",character_string1);
+ dataMap.put("thing3",thing3);
+ dataMap.put("time4",time4);
+ paramMap.put("data", dataMap);
+ for (String openId:openIds) {
+ paramMap.clear();
+ paramMap.put("template_id", wxNoticeConfig.getTempId());
+ paramMap.put("touser", openId);
+ paramMap.put("data", dataMap);
+ String response = HttpsUtil.postJson(postUrL, JSONObject.toJSONString(paramMap));
+ if(StringUtils.isBlank(response)){
+ log.warn("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", "澶辫触");
+ }else{
+ JSONObject json = JSONObject.parseObject(response);
+ log.warn("路==++--路鎺ㄩ�佸井淇℃ā鏉夸俊鎭細{}路--++==路", Constants.equalsInteger(json.getInteger("errcode"),Constants.ZERO)?"鎴愬姛":"澶辫触"+json.getString("errmsg"));
+ }
+ }
+ }
+ }catch (Exception e){
+
+ }
+
+ }
+
+
+
+
}
--
Gitblit v1.9.3