package com.fzzy.igds.utils;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.fzzy.igds.data.ConfigData;
|
import com.fzzy.igds.data.Template;
|
import com.fzzy.igds.data.TemplateParam;
|
import com.ruoyi.common.core.redis.RedisCache;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.http.ResponseEntity;
|
import org.springframework.stereotype.Component;
|
import org.springframework.web.client.RestTemplate;
|
|
import javax.annotation.Resource;
|
import java.util.HashMap;
|
import java.util.Map;
|
import java.util.concurrent.TimeUnit;
|
|
|
@Slf4j
|
@Component
|
public class WxUtil {
|
|
/**
|
* 公众号调用全局接口的标识ACCESS_TOKEN缓存key
|
*/
|
public static final String ACCESS_TOKEN = "ACCESS_TOKEN";
|
|
/**
|
* 模板消息发送url
|
*/
|
public static final String TEMPLATE_URL =
|
"https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=ACCESS_TOKEN";
|
|
/**
|
* 获取access_token的接口地址(GET , 2000次/天)
|
*/
|
public static final String ACCESS_TOKEN_URL =
|
"https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=APPID&secret=APPSECRET";
|
|
@Autowired
|
private RestTemplate restTemplate;
|
|
@Autowired
|
private ConfigData configData;
|
|
@Resource
|
private RedisCache redisCache;
|
|
|
|
/**
|
* 发送模板消息
|
* @param openid 用户openid
|
* @param warnId 警告id
|
* @param companyId 组织id
|
* @param title 警告标题
|
* @param keyword1 警告对象
|
* @param keyword2 警告类型
|
* @param keyword3 警告时间
|
* @param keyword4 警告内容
|
* @param remark 警告详情
|
* @return
|
*/
|
public boolean sendMessage(String openid, String warnId, String companyId, String title,
|
String keyword1, String keyword2, String keyword3,
|
String keyword4,String remark, String userName){
|
|
Template tem = new Template();
|
tem.setTemplate_id(configData.getWxTempId());
|
tem.setTopcolor("#FF0000");
|
|
tem.setTouser(openid);
|
tem.setUrl(configData.getWxServeUrl() + "/wx/view-gateway?state=warn-detail1&id=" + warnId + "&companyId=" + companyId + "&userName=" + userName);
|
|
Map<String, TemplateParam> params = new HashMap<>();
|
params.put("first",new TemplateParam(title,"#173177"));
|
//警告对象
|
params.put("keyword1",new TemplateParam( keyword1, "#173177"));
|
//警告类型
|
params.put("keyword2",new TemplateParam( keyword2, "#173177"));
|
//警告时间
|
params.put("keyword3",new TemplateParam( keyword3, "#173177"));
|
//警告内容
|
params.put("keyword4",new TemplateParam( keyword4, "#173177"));
|
params.put("remark",new TemplateParam( remark, "#173177"));
|
|
tem.setData(params);
|
log.debug("------微信通知开始推送------");
|
//推送消息
|
return sendTemplateMsg(tem);
|
}
|
|
|
|
/**
|
* 推送模板消息
|
*
|
* @param template
|
* @return
|
*/
|
public boolean sendTemplateMsg(Template template) {
|
//获取AccessToken
|
String accessToken = getAccessToken();
|
if(StringUtils.isEmpty(accessToken)){
|
log.debug("------获取AccessToken失败------");
|
return false;
|
}
|
|
boolean flag = false;
|
String url = WxUtil.TEMPLATE_URL.replace("ACCESS_TOKEN",accessToken);
|
String str = JSONObject.toJSONString(template);
|
JSONObject jsonObject = doPost(url, str);
|
if (jsonObject != null) {
|
int errorCode = jsonObject.getIntValue("errcode");
|
String errorMessage = jsonObject.getString("errmsg");
|
if (errorCode == 0) {
|
log.debug("推送微信消息成功：" + str);
|
flag = true;
|
} else {
|
log.info("模板消息发送失败{},{}", errorCode, errorMessage);
|
log.error("ACCESS_TOKEN:" + accessToken);
|
flag = false;
|
}
|
}
|
|
log.debug("推送微信消息失败！" );
|
return flag;
|
}
|
|
/**
|
* 获取全局AccessToken
|
*
|
* @return
|
*/
|
public String getAccessToken() {
|
|
//先从缓存获取，若不存在则通过接口获取
|
String accessToken = (String)redisCache.getCacheObject(WxUtil.ACCESS_TOKEN);
|
if(StringUtils.isNotEmpty(accessToken)){
|
return accessToken;
|
}
|
|
//请求获取AccessToken的微信接口
|
String resp = doGet(WxUtil.ACCESS_TOKEN_URL.replace("APPID",
|
configData.getWxAppId()).replace("APPSECRET", configData.getWxSecret()));
|
JSONObject json = JSONObject.parseObject(resp);
|
if (json != null) {
|
//获取accessToken
|
accessToken = json.getString("access_token");
|
//获取accessToken有效时长，为7200s
|
int expiresIn = json.getIntValue("expires_in");
|
//将accessToken存入缓存，有效时长为expiresIn，即2小时
|
redisCache.setCacheObject(WxUtil.ACCESS_TOKEN, accessToken,expiresIn, TimeUnit.SECONDS);
|
return accessToken;
|
}
|
log.error("获取access_token失败");
|
return null;
|
}
|
/**
|
* post请求
|
* @param url
|
* @param data
|
* @return
|
*/
|
public JSONObject doPost(String url, String data){
|
ResponseEntity<JSONObject> jsonObject = restTemplate.postForEntity(url, data, JSONObject.class);
|
return jsonObject.getBody();
|
}
|
|
/**
|
* get请求
|
*
|
* @param url
|
* @return
|
*/
|
public String doGet(String url) {
|
return restTemplate.getForObject(url, String.class);
|
}
|
}
|
