package com.yuanchu.mom.utils;
|
|
import cn.hutool.http.HttpRequest;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.yuanchu.mom.exception.ErrorException;
|
import com.yuanchu.mom.vo.Result;
|
import lombok.Data;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Component;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
@Data
|
@Slf4j
|
@Component
|
//企业微信对接接口
|
public class QYWXApi {
|
|
|
public static final String WWA_423654_B_975441_AC = "wwa423654b975441ac";
|
final String ip = "https://qyapi.weixin.qq.com/";
|
final String corpid = WWA_423654_B_975441_AC;
|
final String corpsecret = "rQ1_ddKBVW5qVSMNK_p0EnR3Z2OHrAMxGahBKTKWYxE";
|
|
|
/**
|
* 企业微信获取token
|
*
|
* @return
|
*/
|
public String getToken() {
|
try {
|
Map<String, Object> map = new HashMap<>();
|
map.put("corpid", corpid);
|
map.put("corpsecret", corpsecret);
|
String result = HttpRequest.get(ip + "cgi-bin/gettoken")
|
.contentType("application/x-www-form-urlencoded")
|
.form(map).execute().body();
|
JSONObject jsonObject = JSONObject.parseObject(result);
|
return jsonObject.getString("access_token");
|
} catch (Exception e) {
|
throw new RuntimeException("token获取异常");
|
}
|
}
|
|
/**
|
* 发送应用卡片消息
|
*
|
* @param map
|
* @return
|
*/
|
public void send(Map map) {
|
try {
|
String result = HttpRequest.post(ip + "cgi-bin/message/send?access_token=" + getToken())
|
.contentType("application/json")
|
.body(JSONArray.toJSONString(map)).execute().body();
|
JSONObject jsonObject = JSONObject.parseObject(result);
|
if (jsonObject.getInteger("errcode") == 0) {
|
} else {
|
throw new ErrorException("企业微信推送消息失败" + jsonObject.getString("errmsg"));
|
}
|
} catch (Exception e) {
|
throw new ErrorException("企业微信推送消息失败,获取异常:" + e.getMessage());
|
}
|
}
|
}
|
