package com.doumee.core.wx.wxPlat;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.doumee.biz.system.SystemDictDataBiz;
|
import com.doumee.core.haikang.model.HKConstants;
|
import com.doumee.core.haikang.model.param.BaseResponse;
|
import com.doumee.core.haikang.service.HKService;
|
import com.doumee.core.utils.Constants;
|
import com.doumee.core.utils.DateUtil;
|
import com.doumee.core.utils.HttpsUtil;
|
import com.doumee.dao.business.WxNoticeConfigMapper;
|
import com.doumee.dao.business.model.*;
|
import com.doumee.dao.system.model.SystemDictData;
|
import com.doumee.service.business.third.model.ApiResponse;
|
import com.github.xiaoymin.knife4j.core.util.CollectionUtils;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.stereotype.Component;
|
|
import java.util.*;
|
|
/**
|
* 微信公众号通知
|
*
|
* @Author : Rk
|
* @create 2023/12/27 9:19
|
*/
|
@Slf4j
|
@Component
|
public class WxPlatNotice {
|
|
public void testSendNotice(List<String> openIds,String token){
|
if(CollectionUtils.isNotEmpty(openIds)){
|
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","皖AP12345");
|
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"));
|
}
|
}
|
// log.warn("·==++--·推送微信模板信息：{}·--++==·", msgId != null ? "成功" : "失败");
|
}
|
}
|
|
|
|
public String getToken (SystemDictDataBiz systemDictDataBiz){
|
String token = null;
|
BaseResponse<String> result = HKService.wxAccessToken(systemDictDataBiz.queryByCode(Constants.HK_PARAM,Constants.HK_WXTOKEN_CONFIGID).getCode(),
|
systemDictDataBiz.queryByCode(Constants.HK_PARAM,Constants.HK_WXTOKEN_TAGID).getCode());
|
log.warn("获取海康微信token信息", JSONObject.toJSONString(result));
|
if(StringUtils.equals(result.getCode(), HKConstants.RESPONSE_SUCCEE) ){
|
token= result.getData();
|
}
|
return token;
|
}
|
|
|
/**
|
* 访客申请/报备业务通知
|
* @param wxNoticeConfigMapper
|
* @param visits
|
* @param objCode visitUpload,visitAuditSuccess,visitWaitAudit，visitWaitAudit,visitReportUpload，visitReportAuditSuccess，visitReportAuditFail, visitReportAuditSuccess
|
* @param openIds
|
*/
|
public void sendVisitTemplateNotice(SystemDictDataBiz systemDictDataBiz,WxNoticeConfigMapper wxNoticeConfigMapper, Visits visits, String objCode, List<String> openIds){
|
String token = this.getToken(systemDictDataBiz);
|
if(StringUtils.isBlank(token)){
|
return;
|
}
|
try{
|
if(CollectionUtils.isNotEmpty(openIds)){
|
WxNoticeConfig wxNoticeConfig = wxNoticeConfigMapper.selectOne(new QueryWrapper<WxNoticeConfig>().lambda()
|
.in(WxNoticeConfig::getObjType,WxPlatConstants.visit,WxPlatConstants.visitReport)
|
.eq(WxNoticeConfig::getObjCode,objCode)
|
.eq(WxNoticeConfig::getStatus, Constants.ZERO)
|
.last(" limit 1")
|
);
|
if(Objects.isNull(wxNoticeConfig)){
|
return;
|
}
|
Constants.WxUrlParams wxUrlParams = Constants.WxUrlParams.VISIT_REPORT_RECORD_USER;
|
if(!Constants.equalsInteger(visits.getType(),Constants.TWO)){
|
if(!objCode.equals(WxPlatConstants.visitContent.visitWaitAudit)){
|
wxUrlParams = Constants.WxUrlParams.VISIT_RECORD_VISIT;
|
}else{
|
wxUrlParams = Constants.WxUrlParams.VISIT_RECORD_USER;
|
}
|
}
|
String jumpUrl = Constants.getWxUrl(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.WX_REDIRECT_URL).getCode(),
|
wxUrlParams
|
,visits.getId().toString());
|
|
|
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():"无");
|
dataMap.put("car_number7",car_number7);
|
Map<String, Object> character_string6 = new HashMap<String,Object>();
|
character_string6.put("value",Constants.equalsInteger(visits.getType(),Constants.TWO)?visits.getMemberNum()+"":"1");
|
Map<String, Object> thing4 = new HashMap<String,Object>();
|
thing4.put("value",visits.getReason());
|
dataMap.put("const9",const9);
|
dataMap.put("thing1",thing1);
|
dataMap.put("character_string6",character_string6);
|
dataMap.put("thing4",thing4);
|
paramMap.put("data", dataMap);
|
for (String openId:openIds) {
|
paramMap.clear();
|
paramMap.put("url", jumpUrl);
|
paramMap.put("template_id", wxNoticeConfig.getTempId());
|
paramMap.put("touser", openId);
|
paramMap.put("data", dataMap);
|
String response = HttpsUtil.postJson(postUrL, JSONObject.toJSONString(paramMap));
|
log.warn("·==++--·推送微信模板信息跳转地址：{}·--++==·", jumpUrl);
|
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(SystemDictDataBiz systemDictDataBiz,WxNoticeConfigMapper wxNoticeConfigMapper, HiddenDanger hiddenDanger, String objCode,String token, List<String> openIds){
|
token = this.getToken(systemDictDataBiz);
|
if(StringUtils.isBlank(token)){
|
return;
|
}
|
try{
|
if(CollectionUtils.isNotEmpty(openIds)){
|
WxNoticeConfig wxNoticeConfig = wxNoticeConfigMapper.selectOne(new QueryWrapper<WxNoticeConfig>().lambda().eq(WxNoticeConfig::getObjType,WxPlatConstants.hiddenDanger)
|
.eq(WxNoticeConfig::getObjCode,objCode)
|
.eq(WxNoticeConfig::getStatus, Constants.ZERO)
|
.last(" limit 1")
|
);
|
if(Objects.isNull(wxNoticeConfig)){
|
return;
|
}
|
String jumpUrl = Constants.getWxUrl(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.WX_REDIRECT_URL).getCode(),
|
Constants.WxUrlParams.HIDDEN_DANGER,hiddenDanger.getId().toString());
|
|
|
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.getFomartDate(hiddenDanger.getCreateDate(),"yyyy年MM月dd日 HH:mm:ss") );
|
dataMap.put("thing9",thing9);
|
dataMap.put("thing1",thing1);
|
dataMap.put("thing12",thing12);
|
dataMap.put("time11",time11);
|
for (String openId:openIds) {
|
paramMap.clear();
|
paramMap.put("template_id", wxNoticeConfig.getTempId());
|
paramMap.put("url", jumpUrl);
|
paramMap.put("touser", openId);
|
paramMap.put("data", dataMap);
|
String response = HttpsUtil.postJson(postUrL, JSONObject.toJSONString(paramMap));
|
log.warn("·==++--·推送微信模板信息跳转地址：{}", jumpUrl);
|
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 hiddenDanger
|
* @param objCode hiddenDangerDeal
|
* @param openIds
|
*/
|
public void sendHiddenDangerDealTemplateNotice(SystemDictDataBiz systemDictDataBiz,WxNoticeConfigMapper wxNoticeConfigMapper, HiddenDanger hiddenDanger, String objCode,String token, List<String> openIds){
|
token = this.getToken(systemDictDataBiz);
|
if(StringUtils.isBlank(token)){
|
return;
|
}
|
try{
|
if(CollectionUtils.isNotEmpty(openIds)){
|
WxNoticeConfig wxNoticeConfig = wxNoticeConfigMapper.selectOne(new QueryWrapper<WxNoticeConfig>().lambda().eq(WxNoticeConfig::getObjType,WxPlatConstants.hiddenDanger)
|
.eq(WxNoticeConfig::getObjCode,objCode)
|
.eq(WxNoticeConfig::getStatus, Constants.ZERO)
|
.last(" limit 1")
|
);
|
if(Objects.isNull(wxNoticeConfig)){
|
return;
|
}
|
String jumpUrl = Constants.getWxUrl(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.WX_REDIRECT_URL).getCode(),
|
Constants.WxUrlParams.HIDDEN_DANGER,hiddenDanger.getId().toString());
|
|
|
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.getMemberName());
|
//通知时间
|
Map<String, Object> time16 = new HashMap<String,Object>();
|
time16.put("value", DateUtil.getFomartDate(hiddenDanger.getDealTime(),"yyyy年MM月dd日 HH:mm:ss") );
|
dataMap.put("thing17",thing17);
|
dataMap.put("thing3",thing3);
|
dataMap.put("thing13",thing13);
|
dataMap.put("thing10",thing10);
|
dataMap.put("time16",time16);
|
for (String openId:openIds) {
|
paramMap.clear();
|
paramMap.put("url", jumpUrl);
|
paramMap.put("template_id", wxNoticeConfig.getTempId());
|
paramMap.put("touser", openId);
|
paramMap.put("data", dataMap);
|
String response = HttpsUtil.postJson(postUrL, JSONObject.toJSONString(paramMap));
|
log.warn("·==++--·推送微信模板信息跳转地址：{}", jumpUrl);
|
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，meetingCancel,meetingBeginA，meetingEndA
|
* @param openIds
|
* @param sendType 0=申请人；1=审批人
|
*/
|
public void sendCarUseBookTemplateNotice(SystemDictDataBiz systemDictDataBiz,WxNoticeConfigMapper wxNoticeConfigMapper, CarUseBook carUseBook, String objCode,
|
List<String> openIds,Integer sendType){
|
String token = this.getToken(systemDictDataBiz);
|
if(StringUtils.isBlank(token)){
|
return;
|
}
|
try {
|
if(CollectionUtils.isNotEmpty(openIds)){
|
WxNoticeConfig wxNoticeConfig = wxNoticeConfigMapper.selectOne(new QueryWrapper<WxNoticeConfig>().lambda().eq(WxNoticeConfig::getObjType,WxPlatConstants.carUse)
|
.eq(WxNoticeConfig::getObjCode,objCode)
|
.eq(WxNoticeConfig::getStatus, Constants.ZERO)
|
.last(" limit 1")
|
);
|
if(Objects.isNull(wxNoticeConfig)){
|
return;
|
}
|
String jumpUrl = Constants.getWxUrl(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.WX_REDIRECT_URL).getCode(),
|
Constants.WxUrlParams.CAR_USE,carUseBook.getId().toString());
|
|
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(sendType,Constants.ZERO)){
|
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","申请已被驳回");
|
}
|
}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("data", dataMap);
|
for (String openId:openIds) {
|
paramMap.clear();
|
paramMap.put("url", jumpUrl);
|
paramMap.put("template_id", wxNoticeConfig.getTempId());
|
paramMap.put("touser", openId);
|
paramMap.put("data", dataMap);
|
String response = HttpsUtil.postJson(postUrL, JSONObject.toJSONString(paramMap));
|
log.warn("·==++--·推送微信模板信息：{}", jumpUrl);
|
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，platformBookAuditSuccess,platformBookAuditFail，platformBookWaitAudit
|
* @param token
|
* @param openIds
|
* @param sendType 0=申请人；1=审批人
|
*/
|
public void sendPlatformBookTemplateNotice(SystemDictDataBiz systemDictDataBiz, WxNoticeConfigMapper wxNoticeConfigMapper, PlatformBooks platformBooks, String objCode,
|
List<String> openIds, Integer sendType){
|
String token = this.getToken(systemDictDataBiz);
|
if(StringUtils.isBlank(token)){
|
return;
|
}
|
try{
|
if(CollectionUtils.isNotEmpty(openIds)){
|
WxNoticeConfig wxNoticeConfig = wxNoticeConfigMapper.selectOne(new QueryWrapper<WxNoticeConfig>().lambda().eq(WxNoticeConfig::getObjType,WxPlatConstants.platformBook)
|
.eq(WxNoticeConfig::getObjCode,objCode)
|
.eq(WxNoticeConfig::getStatus, Constants.ZERO)
|
.last(" limit 1")
|
);
|
if(Objects.isNull(wxNoticeConfig)){
|
return;
|
}
|
Constants.WxUrlParams wxUrlParams = Constants.WxUrlParams.PLATFORM_BOOK_DRIVER;
|
if(!objCode.equals(WxPlatConstants.platformBookContent.platformBookUpload)){
|
wxUrlParams = Constants.WxUrlParams.PLATFORM_BOOK;
|
}
|
String jumpUrl = Constants.getWxUrl(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.WX_REDIRECT_URL).getCode(),
|
wxUrlParams,platformBooks.getId().toString());
|
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.getFomartDate(platformBooks.getArriveDate(),"yyyy年MM月dd日 HH:mm:ss") );
|
dataMap.put("const9",const9);
|
dataMap.put("car_number3",car_number3);
|
dataMap.put("phrase4",phrase4);
|
dataMap.put("thing8",thing8);
|
dataMap.put("time2",time4);
|
for (String openId:openIds) {
|
paramMap.clear();
|
paramMap.put("url", jumpUrl);
|
paramMap.put("template_id", wxNoticeConfig.getTempId());
|
paramMap.put("touser", openId);
|
paramMap.put("data", dataMap);
|
String response = HttpsUtil.postJson(postUrL, JSONObject.toJSONString(paramMap));
|
log.warn("·==++--·推送微信模板信息：{}", 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(SystemDictDataBiz systemDictDataBiz, WxNoticeConfigMapper wxNoticeConfigMapper, PlatformJob platformJob, String objCode,
|
List<String> openIds){
|
String token = this.getToken(systemDictDataBiz);
|
if(StringUtils.isBlank(token)){
|
return;
|
}
|
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 jumpUrl = Constants.getWxUrl(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.WX_REDIRECT_URL).getCode(),
|
Constants.WxUrlParams.PLATFORM_JOB_DRIVER,platformJob.getId().toString());
|
|
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.getFomartDate(platformJob.getCreateDate(),"yyyy年MM月dd日 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("url",jumpUrl);
|
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(SystemDictDataBiz systemDictDataBiz,WxNoticeConfigMapper wxNoticeConfigMapper, PlatformJob platformJob, String objCode,
|
List<String> openIds){
|
String token = this.getToken(systemDictDataBiz);
|
if(StringUtils.isBlank(token)){
|
return;
|
}
|
try{
|
if(CollectionUtils.isNotEmpty(openIds)){
|
WxNoticeConfig wxNoticeConfig = wxNoticeConfigMapper.selectOne(new QueryWrapper<WxNoticeConfig>().lambda().eq(WxNoticeConfig::getObjType,WxPlatConstants.platformJob)
|
.eq(WxNoticeConfig::getObjCode,objCode)
|
.eq(WxNoticeConfig::getStatus, Constants.ZERO)
|
.last(" limit 1")
|
);
|
if(Objects.isNull(wxNoticeConfig)){
|
return;
|
}
|
|
String jumpUrl = Constants.getWxUrl(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.WX_REDIRECT_URL).getCode(),
|
Constants.WxUrlParams.PLATFORM_JOB_DRIVER,platformJob.getId().toString());
|
|
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.getFomartDate(new Date(),"yyyy年MM月dd日 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("url",jumpUrl);
|
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，platformJobSingIn,platformJobOverNum，platformJobWorking,platformJobFinish，platformJobLevelPower,platformJobMove，platformJobError，platformJobTimeOut,platformJobStopErr
|
* @param token
|
* @param openIds
|
*/
|
public void sendPlatformJobTemplateNotice(SystemDictDataBiz systemDictDataBiz,WxNoticeConfigMapper wxNoticeConfigMapper, PlatformJob platformJob, String objCode,
|
List<String> openIds){
|
String token = this.getToken(systemDictDataBiz);
|
if(StringUtils.isBlank(token)){
|
return;
|
}
|
try{
|
if(CollectionUtils.isNotEmpty(openIds)){
|
WxNoticeConfig wxNoticeConfig = wxNoticeConfigMapper.selectOne(new QueryWrapper<WxNoticeConfig>().lambda().eq(WxNoticeConfig::getObjType,WxPlatConstants.platformJob)
|
.eq(WxNoticeConfig::getObjCode,objCode)
|
.eq(WxNoticeConfig::getStatus, Constants.ZERO)
|
.last(" limit 1")
|
);
|
if(Objects.isNull(wxNoticeConfig)){
|
return;
|
}
|
|
String jumpUrl = Constants.getWxUrl(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.WX_REDIRECT_URL).getCode(),
|
Constants.WxUrlParams.PLATFORM_JOB_DRIVER,platformJob.getId().toString());
|
|
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> car_number3 = new HashMap<String,Object>();
|
car_number3.put("value",platformJob.getCarCodeFront());
|
//月台号
|
Map<String, Object> thing9 = new HashMap<String,Object>();
|
thing9.put("value", platformJob.getPlatformName());
|
//时间
|
Map<String, Object> time4 = new HashMap<String,Object>();
|
time4.put("value", DateUtil.getFomartDate(new Date(),"yyyy年MM月dd日 HH:mm:ss") );
|
dataMap.put("const6",const6);
|
dataMap.put("car_number3",car_number3);
|
dataMap.put("thing9",thing9);
|
dataMap.put("time4",time4);
|
for (String openId:openIds) {
|
paramMap.clear();
|
paramMap.put("url",jumpUrl);
|
paramMap.put("template_id", wxNoticeConfig.getTempId());
|
paramMap.put("touser", openId);
|
paramMap.put("data", dataMap);
|
String response = HttpsUtil.postJson(postUrL, JSONObject.toJSONString(paramMap));
|
log.error("·==++--·推送微信模板信息内容：{}", JSONObject.toJSONString(paramMap));
|
if(StringUtils.isBlank(response)){
|
log.error("·==++--·推送微信模板信息：{}·--++==·", "失败");
|
}else{
|
JSONObject json = JSONObject.parseObject(response);
|
log.error("·==++--·推送微信模板信息：{}·--++==·", Constants.equalsInteger(json.getInteger("errcode"),Constants.ZERO)?"成功":"失败"+json.getString("errmsg"));
|
}
|
}
|
}
|
}catch (Exception e){
|
e.printStackTrace();
|
}
|
}
|
|
|
/**
|
* 月台签到通知
|
* @param wxNoticeConfigMapper
|
* @param platformJob
|
* @param objCode
|
* @param token
|
* @param openIds
|
*/
|
public void sendPlatformJobSignNotice(SystemDictDataBiz systemDictDataBiz,WxNoticeConfigMapper wxNoticeConfigMapper, PlatformJob platformJob, String objCode,
|
List<String> openIds){
|
String token = this.getToken(systemDictDataBiz);
|
if(StringUtils.isBlank(token)){
|
return;
|
}
|
try{
|
if(CollectionUtils.isNotEmpty(openIds)){
|
WxNoticeConfig wxNoticeConfig = wxNoticeConfigMapper.selectOne(new QueryWrapper<WxNoticeConfig>().lambda().eq(WxNoticeConfig::getObjType,WxPlatConstants.platformJob)
|
.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> car_number1 = new HashMap<String,Object>();
|
car_number1.put("value",platformJob.getCarCodeFront());
|
//司机姓名
|
Map<String, Object> thing2 = new HashMap<String,Object>();
|
thing2.put("value",platformJob.getDriverName());
|
//签到时间
|
Map<String, Object> time5 = new HashMap<String,Object>();
|
time5.put("value", DateUtil.getFomartDate(new Date(),"yyyy年MM月dd日 HH:mm:ss"));
|
|
dataMap.put("car_number1",car_number1);
|
dataMap.put("thing2",thing2);
|
dataMap.put("time5",time5);
|
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));
|
log.error("·==++--·推送微信模板信息内容：{}", JSONObject.toJSONString(paramMap));
|
if(StringUtils.isBlank(response)){
|
log.error("·==++--·推送微信模板信息：{}·--++==·", "失败");
|
}else{
|
JSONObject json = JSONObject.parseObject(response);
|
log.error("·==++--·推送微信模板信息：{}·--++==·", Constants.equalsInteger(json.getInteger("errcode"),Constants.ZERO)?"成功":"失败"+json.getString("errmsg"));
|
}
|
}
|
}
|
}catch (Exception e){
|
|
}
|
}
|
|
|
public static void main(String[] args) {
|
String postUrL = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=90_8_a3QDclSc8HTcbgXhSVnijiQdRf4dG5wme29riDIyt3UIi7FpZ_HJyqyEIY-_e2A29jH2fLBKgtuBKtq-cy7DteFg5l9EawoxAwiRis8BMnEl-u01ITtCUVU90XCIjADASXD";
|
//整体参数map
|
Map<String, Object> paramMap = new HashMap<String, Object>();
|
//消息主题显示相关map
|
Map<String, Object> dataMap = new HashMap<String, Object>();
|
//车牌号
|
Map<String, Object> car_number1 = new HashMap<String,Object>();
|
car_number1.put("value","皖A12345");
|
//司机姓名
|
Map<String, Object> thing2 = new HashMap<String,Object>();
|
thing2.put("value","小阿武");
|
//签到时间
|
Map<String, Object> time5 = new HashMap<String,Object>();
|
time5.put("value", DateUtil.getFomartDate(new Date(),"yyyy年MM月dd日 HH:mm:ss"));
|
|
dataMap.put("car_number1",car_number1);
|
dataMap.put("thing2",thing2);
|
dataMap.put("time5",time5);
|
paramMap.clear();
|
paramMap.put("template_id", "ZYhHg5eJJim0LR3FLVaqKcVqW3p8GQk8qrTO40ffHXI");
|
paramMap.put("touser", "ovmre6RUJJZCDtCyLxWYKSMgt7u8");
|
paramMap.put("data", dataMap);
|
String response = HttpsUtil.postJson(postUrL, JSONObject.toJSONString(paramMap));
|
log.error("·==++--·推送微信模板信息内容：{}", JSONObject.toJSONString(paramMap));
|
if(StringUtils.isBlank(response)){
|
log.error("·==++--·推送微信模板信息：{}·--++==·", "失败");
|
}else{
|
JSONObject json = JSONObject.parseObject(response);
|
log.error("·==++--·推送微信模板信息：{}·--++==·", Constants.equalsInteger(json.getInteger("errcode"),Constants.ZERO)?"成功":"失败"+json.getString("errmsg"));
|
}
|
}
|
|
public void sendUnFinishNotice(SystemDictDataBiz systemDictDataBiz,WxNoticeConfigMapper wxNoticeConfigMapper,Integer unFinishNum,String objCode,
|
List<String> openIds){
|
String token = this.getToken(systemDictDataBiz);
|
if(StringUtils.isBlank(token)||Constants.equalsInteger(unFinishNum,Constants.ZERO)){
|
return;
|
}
|
try{
|
if(CollectionUtils.isNotEmpty(openIds)){
|
WxNoticeConfig wxNoticeConfig = wxNoticeConfigMapper.selectOne(new QueryWrapper<WxNoticeConfig>().lambda().eq(WxNoticeConfig::getObjType,WxPlatConstants.platformJob)
|
.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> const1 = new HashMap<String,Object>();
|
const1.put("value","作业任务未完成");
|
//司机姓名
|
Map<String, Object> thing2 = new HashMap<String,Object>();
|
thing2.put("value",unFinishNum+"个");
|
//签到时间
|
Map<String, Object> time3 = new HashMap<String,Object>();
|
time3.put("value", DateUtil.getFomartDate(new Date(),"yyyy年MM月dd日 HH:mm:ss"));
|
|
dataMap.put("const1",const1);
|
dataMap.put("thing2",thing2);
|
dataMap.put("time3",time3);
|
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));
|
log.error("·==++--·推送微信模板信息内容：{}", JSONObject.toJSONString(paramMap));
|
if(StringUtils.isBlank(response)){
|
log.error("·==++--·推送微信模板信息：{}·--++==·", "失败");
|
}else{
|
JSONObject json = JSONObject.parseObject(response);
|
log.error("·==++--·推送微信模板信息：{}·--++==·", Constants.equalsInteger(json.getInteger("errcode"),Constants.ZERO)?"成功":"失败"+json.getString("errmsg"));
|
}
|
}
|
}
|
}catch (Exception e){
|
|
}
|
}
|
|
|
public void sendMeetTemplateNotice(SystemDictDataBiz systemDictDataBiz,SmsEmail smsEmail){
|
String token = this.getToken(systemDictDataBiz);
|
if(StringUtils.isBlank(token)){
|
return;
|
}
|
try{
|
String jumpUrl = Constants.getWxUrl(systemDictDataBiz.queryByCode(Constants.PLATFORM,Constants.WX_REDIRECT_URL).getCode(),
|
Constants.WxUrlParams.MEETING,smsEmail.getObjId().toString());
|
String postUrL = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token="+token;
|
JSONObject jsonObject = JSONObject.parseObject(smsEmail.getContent());
|
jsonObject.put("url",jumpUrl);
|
String response = HttpsUtil.postJson(postUrL, JSONObject.toJSONString(jsonObject));
|
log.warn("·==++--·推送微信模板信息内容：{}", JSONObject.toJSONString(jsonObject));
|
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){
|
|
}
|
|
}
|
|
|
}
|
