package com.gs.dingtalk.service;
|
|
|
import com.aliyun.dingtalkoauth2_1_0.Client;
|
import com.aliyun.dingtalkoauth2_1_0.models.GetAccessTokenRequest;
|
import com.aliyun.dingtalkoauth2_1_0.models.GetAccessTokenResponse;
|
import com.aliyun.tea.TeaException;
|
import com.aliyun.teaopenapi.models.Config;
|
import com.aliyun.teautil.Common;
|
import com.dingtalk.api.DefaultDingTalkClient;
|
import com.dingtalk.api.DingTalkClient;
|
import com.dingtalk.api.request.OapiMessageCorpconversationAsyncsendV2Request;
|
import com.dingtalk.api.request.OapiRobotSendRequest;
|
import com.dingtalk.api.request.OapiV2UserGetbymobileRequest;
|
import com.dingtalk.api.response.OapiMessageCorpconversationAsyncsendV2Response;
|
import com.dingtalk.api.response.OapiRobotSendResponse;
|
import com.dingtalk.api.response.OapiV2UserGetbymobileResponse;
|
import com.google.gson.Gson;
|
import com.gs.dingtalk.config.DataAcquisitionConfiguration;
|
import com.gs.dingtalk.dto.DingTalkMessage;
|
import com.gs.dingtalk.dto.DingTalkResponse;
|
import com.gs.dingtalk.entity.SendDingtalk;
|
import com.taobao.api.ApiException;
|
import lombok.RequiredArgsConstructor;
|
import org.apache.commons.codec.binary.Base64;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.crypto.Mac;
|
import javax.crypto.spec.SecretKeySpec;
|
import java.io.UnsupportedEncodingException;
|
import java.net.URLEncoder;
|
import java.security.InvalidKeyException;
|
import java.security.NoSuchAlgorithmException;
|
|
|
/**
|
* 发送个人消息
|
*
|
* @author tjx
|
* @date 2024/11/17 16:18
|
*/
|
@Service
|
@RequiredArgsConstructor
|
@Transactional(rollbackFor = Exception.class)
|
public class SimpleExample {
|
|
/**
|
* 群里机器人发送消息
|
*
|
* @author tjx
|
* @date 2024/11/18 08:54
|
*/
|
public DingTalkResponse chatSendMessage(String message) throws Exception {
|
try {
|
Long timestamp = System.currentTimeMillis();
|
System.out.println(timestamp);
|
String secret = DataAcquisitionConfiguration.SECRET;
|
String stringToSign = timestamp + "\n" + secret;
|
Mac mac = Mac.getInstance("HmacSHA256");
|
mac.init(new SecretKeySpec(secret.getBytes("UTF-8"), "HmacSHA256"));
|
byte[] signData = mac.doFinal(stringToSign.getBytes("UTF-8"));
|
String sign = URLEncoder.encode(new String(Base64.encodeBase64(signData)), "UTF-8");
|
System.out.println(sign);
|
|
//sign字段和timestamp字段必须拼接到请求URL上，否则会出现 310000 的错误信息
|
DingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/robot/send?sign=" + sign + "×tamp=" + timestamp);
|
OapiRobotSendRequest req = new OapiRobotSendRequest();
|
/**
|
* 发送文本消息
|
*/
|
//定义文本内容
|
OapiRobotSendRequest.Text text = new OapiRobotSendRequest.Text();
|
text.setContent(message);
|
//定义 @ 对象
|
OapiRobotSendRequest.At at = new OapiRobotSendRequest.At();
|
at.setIsAtAll(true);
|
//设置消息类型
|
req.setMsgtype("text");
|
req.setText(text);
|
req.setAt(at);
|
OapiRobotSendResponse rsp = client.execute(req, DataAcquisitionConfiguration.CUSTOM_ROBOT_TOKEN);
|
|
Gson gson = new Gson();
|
|
return gson.fromJson(rsp.getBody(), DingTalkResponse.class);
|
} catch (ApiException e) {
|
e.printStackTrace();
|
} catch (UnsupportedEncodingException e) {
|
throw new RuntimeException(e);
|
} catch (NoSuchAlgorithmException e) {
|
throw new RuntimeException(e);
|
} catch (InvalidKeyException e) {
|
throw new RuntimeException(e);
|
}
|
|
return null;
|
}
|
|
/**
|
* 发送消息
|
*/
|
public DingTalkMessage sendMessage(String userIdList, String message) throws Exception {
|
|
String accessToken = getAccessToken();
|
|
DingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/message/corpconversation/asyncsend_v2");
|
OapiMessageCorpconversationAsyncsendV2Request request = new OapiMessageCorpconversationAsyncsendV2Request();
|
request.setAgentId(DataAcquisitionConfiguration.AGENT_ID);
|
request.setUseridList(userIdList);
|
request.setToAllUser(false);
|
|
OapiMessageCorpconversationAsyncsendV2Request.Msg msg = new OapiMessageCorpconversationAsyncsendV2Request.Msg();
|
msg.setMsgtype("text");
|
msg.setText(new OapiMessageCorpconversationAsyncsendV2Request.Text());
|
msg.getText().setContent(message);
|
request.setMsg(msg);
|
|
OapiMessageCorpconversationAsyncsendV2Response rsp = client.execute(request, accessToken);
|
|
Gson gson = new Gson();
|
|
return gson.fromJson(rsp.getBody(), DingTalkMessage.class);
|
}
|
|
/**
|
* 获取 AccessToken
|
*
|
* @return AccessToken
|
* @throws Exception
|
*/
|
public String getAccessToken() throws Exception {
|
Client client = createClient();
|
GetAccessTokenRequest getAccessTokenRequest = new GetAccessTokenRequest()
|
.setAppKey(DataAcquisitionConfiguration.APP_KEY)
|
.setAppSecret(DataAcquisitionConfiguration.APP_SECRET);
|
try {
|
GetAccessTokenResponse accessToken = client.getAccessToken(getAccessTokenRequest);
|
return accessToken.body.getAccessToken();
|
|
} catch (TeaException err) {
|
if (!Common.empty(err.code) && !Common.empty(err.message)) {
|
// err 中含有 code 和 message 属性，可帮助开发定位问题
|
System.out.println(err.code);
|
System.out.println(err.message);
|
}
|
} catch (Exception exception) {
|
TeaException err = new TeaException(exception.getMessage(), exception);
|
if (!Common.empty(err.code) && !Common.empty(err.message)) {
|
// err 中含有 code 和 message 属性，可帮助开发定位问题
|
System.out.println(err.code);
|
System.out.println(err.message);
|
}
|
}
|
return null;
|
}
|
|
/**
|
* 使用 Token 初始化账号Client
|
*
|
* @return Client
|
* @throws Exception
|
*/
|
public Client createClient() throws Exception {
|
Config config = new Config();
|
config.protocol = "https";
|
config.regionId = "central";
|
return new Client(config);
|
}
|
|
public OapiV2UserGetbymobileResponse getOapiV2UserGetbymobileResponse(SendDingtalk s, String accessToken) {
|
DingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/user/getbymobile");
|
OapiV2UserGetbymobileRequest req = new OapiV2UserGetbymobileRequest();
|
req.setMobile(s.getTelephone());
|
req.setSupportExclusiveAccountSearch(true);
|
OapiV2UserGetbymobileResponse rsp = null;
|
|
try {
|
rsp = client.execute(req, accessToken);
|
} catch (ApiException e) {
|
throw new RuntimeException(e);
|
}
|
return rsp;
|
}
|
}
|
