Java推送钉钉应用消息实现过程

目录

• 前言：
• 一、创建钉钉应用
• 二、应用相关凭证
• 三、申请钉钉接口权限
• 四、钉钉官方接口
• 1、获取token
• 2、根据手机号获取用户ID
• 3、发送通知
• 五、工具类
• 六、MAVEN引入
• 总结 

前言：

本文的目的是通过手机号获取钉钉成员的userid，实现钉钉应用的消息推送。

一、创建钉钉应用

登录钉钉开放平台

二、应用相关凭证

需要获取

Client ID (原 AppKey 和 SuiteKey)

Client Secret (原 AppSecret 和 SuiteSecret)

App ID 

原企业内部应用AgentId

三、申请钉钉接口权限

需要先申请对应的接口权限才能调用接口。

但是钉钉的接口太多了，一时半会也找不到对应的接口，推荐直接全勾选。

四、钉钉官方接口

1、获取token

请求方式：GET

参数：appKey，appSecret，reqMethod

url：https://oapi.dingtalk.com/gettoken

2、根据手机号获取用户ID

参数：Access_token，mobileNum

url：https://oapi.dingtalk.com/topapi/v2/user/getbymobile

3、发送通知

参数：access_token，msgType，content，userId

url：https://oapi.dingtalk.com/topapi/message/corpconversation/asyncsend_v2

五、工具类

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.dingtalk.api.DefaultDingTalkClient;
import comkOCox.dingtalk.api.DingTalkClient;
import com.dingtalk.api.request.OapiGettokenRequest;
import com.dingtalk.api.request.OapiMessageCorpconversationAsyncsendV2Request;
import com.dingtalk.api.request.OapiV2UserGetbymobileRequest;
import com.dingtalk.api.response.OapiGettokenResponse;
import com.dingtalk.api.response.OapiMessageCorpconversationAsyncsendV2Response;
import com.dingtalk.api.response.OapiV2UserGetbymobileResponse;
import com.taobao.api.ApiException;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import Java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

@Slf4j
@Component
public class DingTalkUtil {

    private static final String GET_TOKEN_URL = "https://oapi.dingtalk.com/gettoken";
    private static final String GET_BY_MOBILE = "https://oapi.dingtalk.com/topapi/v2/user/getbymobile";
    private static final String ASYNC_SEND_V2_URL = "https://oapi.dingtalk.com/topapi/message/corpconversation/asyncsend_v2";
    private static final String DEFAULT_APP_KEY = "XXX";
    private static final String DEFAULT_APP_SECRET = "XXXX";
    private static final Long DEFAULT_AGENT_ID = 123L;
    private static final String DEFAULT_REQUEST_METHOD = "GET";

    private String appKey;
    private String appSecret;
    private Long agentId;
    private String reqMethod;


    public DingTalkUtil() {
        this(DEFAULT_APP_KEY, DEFAULT_APP_SECRET, DEFAULT_AGENT_ID, DEFAULT_REQUEST_METHOD);
    }

    public DingTalkUtil(String appKey, String appSecret, Long agentId, String reqMethod) {
        this.appKey = (appKey != null && !appKey.isEmpty()) ? appKey : DEFAULT_APP_KEY;
        this.appSecret = (appSecret != null && !appSecret.isEmpty()) ? appSecret : DEFAULT_APP_SECRET;
        this.agentId = (agentId != null) ? agentId : DEFAULT_AGENT_ID;
        this.reqMethod = (reqMethod != null && !reqMethod.isEmpty()) ? reqMethod : DEFAULT_REQUEST_METHOD;
    }


    // 获取AccessToken
    public String getTokenResponse() throws ApiException {
        DingTalkClient client = new DefaultDingTalkClient(GET_TOKEN_URL);
        OapiGettokenRequest req = new OapiGettokenRequest();
        req.setAppkey(appKey);
        req.setAppsecret(appSecret);
        req.setHttpMethod(reqMethod);
php        OapiGettokenResponse rsp = client.execute(req);
        return rsp.getAccessToken();
    }

    // 根据手机号获取UserId
    public String getUserIdByMobile(String accessToken, String mobileNum) throws ApiException {
        DingTalkClient client = new DefaultDingTalkClient(GET_BY_MOBILE);
        OapiV2UserGetbymobileRequest req = new OapiV2UserGetbymobileRequest();
        req.setMobile(mobileNum);
        OapiV2UserGetbymobileResponse rsp = client.execute(req, accessToken);

        JSONObject jsonObject = JSON.parseobject(rsp.getBody());
        JSONObject result = jsonObject.getJSONObject("result");
        String userid = result.getString("userid");
     javascript   return userid;
    }

    // 发送工作通知消息
    public boolean sendworkNotice(String accessToken, String msgType, String content, List<String> userIds) throws ApiException {
        DingTalkClient client = new DefaultDingTalkClient(ASYNC_SEND_V2_URL);
编程
        OapiMessageCorpconversationAsyncsendV2Request req = new OapiMessageCorpconversationAsyncsendV2Request();
        req.setAgentId(agentId);
        req.setUseridList(String.join(",", userIds));

        OapiMessageCorpconversationAsyncsendV2Request.Msg msg = new OapiMessageCorpconversationAsyncsendV2Request.Msg();
        msg.setMsgtype(msgType);
        OapiMessageCorpconversationAsyncsendV2Request.Text text = new OapiMessageCorpconversationAsyncsendV2Request.Text();
        text.setContent(content);
        msg.setText(text);

        req.setMsg(msg);

        OapiMessageCorpconversationAsyncsendV2Response rsp = client.execute(req, accessToken);
        return rsp.isSuccess();
    }

    public static class Builder {
        private String msgType = "androidtext";
        private String content;
        private List<String> mobiles = new ArrayList<>();
        private List<String> userIds = new ArrayList<>();

        public Builder setMsgType(String msgType) {
            this.msgType = msgType;
            return this;
        }

        public Builder setContent(String content) {
            this.content = content;
            return this;
        }

        public Builder addUserId(String userId) {
            this.mobiles.add(userId);
            return this;
        }

        public Builder addUserIds(List<String> userIds) {
            this.mobiles = userIds;
            return this;
        }

        public boolean send(DingTalkUtil utils) throws ApiException {
            // 获取 accessToken
            String accessToken = utils.getTokenResponse();
            // 根据手机获取userId
            for (String mobileNum : mobiles) {
                String userId = utils.getUserIdByMobile(accessToken, mobileNum);
                userIds.add(userId);
            }
            // 调用 sendWorkNotice 发送消息
            return utils.sendWorkNotice(accessToken, msgType, content, userIds);
        }
    }


    // 封装的发送钉钉通知的方法
    public boolean sendDingTalkNotification(List<String> phoneList, String message) throws ApiException {
        DingTalkUtil dingTalkUtil = new DingTalkUtil();
        return new DingTalkUtil.Builder().setMsgType("text")
                .setContent(message)
                .addUserIds(phoneList)
                .send(dingTalkUtil);
    }

    // 内部测试
    public static void main(String[] args) throws ApiException {
        DingTalkUtil dingTalkUtil = new DingTalkUtil();
        List<String> phoneList = Arrays.asList("phoneNum");
        String message = "your message";
        boolean result = dingTalkUtil.sendDingTalkNotification(phoneList, message);
        System.out.println("消息发送结果: " + result);
    }

}

六、MAVEN引入

        <dependency>
            <groupId>com.aliyun</groupId>
            <artifactId>dingtalk</artifactId>
            <version>1.5.24</version>
        </dependency>

        <dependency>
            <groupId>com.aliyun</groupId>
            <artifactId>alibaba-dingtalk-service-sdk</artifactId>
            <version>2.0.0</version>
        </dependency>

总结 

到此这篇关于Java推送钉钉应用消息实现的文章就介绍到这了,更多相关Java推送钉钉应用消息内容请搜索编程客栈(www.devze.com)以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程客栈(www.devze.com)！