package com.matrix.component.dingding;
|
|
import com.dingtalk.api.DefaultDingTalkClient;
|
import com.dingtalk.api.DingTalkClient;
|
import com.dingtalk.api.request.OapiMessageCorpconversationAsyncsendV2Request;
|
import com.dingtalk.api.response.OapiMessageCorpconversationAsyncsendV2Response;
|
import com.matrix.core.tools.LogUtil;
|
import com.taobao.api.ApiException;
|
|
|
/**
|
* @author jiangyouyao
|
* @description 钉钉消息发送封装工具
|
*/
|
public class MessageSendUtil {
|
|
public static void sendOAMsg(String accessToken, String userList, OapiMessageCorpconversationAsyncsendV2Request.Msg msg) {
|
DingTalkClient client = new DefaultDingTalkClient(
|
"https://oapi.dingtalk.com/topapi/message/corpconversation/asyncsend_v2");
|
OapiMessageCorpconversationAsyncsendV2Request request = new OapiMessageCorpconversationAsyncsendV2Request();
|
request.setUseridList(userList);
|
request.setAgentId(DDEnvConfig.AGENT_ID);
|
request.setToAllUser(false);
|
request.setMsg(msg);
|
try {
|
OapiMessageCorpconversationAsyncsendV2Response response = client.execute(request, accessToken);
|
} catch (ApiException e) {
|
LogUtil.error("钉钉消息发送失败",e);
|
}
|
}
|
|
}
|