Flowable钉钉对接001-人员同步

小学生05101

已于 2023-03-30 17:04:46 修改

阅读量768

点赞数 1

分类专栏： Flowable高级文章标签：钉钉 java 数据库 flowable

于 2023-03-30 16:59:38 首次发布

本文链接：https://blog.csdn.net/liuwenjun05101/article/details/129861221

版权

Flowable高级专栏收录该内容

15 篇文章

订阅专栏

文章讲述了在企业业务系统中，如何通过集成钉钉SDK获取访问令牌，获取并同步用户信息，以实现在业务系统和钉钉上进行统一的待办任务审批。代码示例展示了获取用户ID和信息的方法，以及全量同步钉钉ID到用户表的过程。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

企业中有自己的业务系统，审批都在业务系统中审批，如何结合移动办公的开放平台实现统一审批至关重要。

场景很简单，自己的系统中可以审批，钉钉上也可以审批，使用H5来适配，统一待办任务

目标：人员统一

实现相互之间可以创建待办，更新待办，删除待办

第一、集成钉钉的sdk

public OapiGettokenResponse getAccessToken() {
        Object accessToken = PlatformLocalCache.get(ACCESS_TOKEN);
        if (accessToken != null) {
            return (OapiGettokenResponse) accessToken;
        }
        DefaultDingTalkClient client = new DefaultDingTalkClient(DingtalkUrlConstant.URL_GET_TOKEN);
        OapiGettokenRequest request = new OapiGettokenRequest();
        request.setAppkey(dingtalkProperties.getAppKey());
        request.setAppsecret(dingtalkProperties.getAppSecret());
        request.setHttpMethod("GET");
        OapiGettokenResponse response = null;
        try {
            response = client.execute(request);
            if (response.isSuccess()) {
                PlatformLocalCache.put(ACCESS_TOKEN, response);
            }
        } catch (ApiException e) {
            log.error("getAccessToken failed", e);
        }
        return response;
    }

    @Override
    public OapiV2UserGetbymobileResponse getUserIdByMobile(String mobile) {
        OapiGettokenResponse accessToken = this.getAccessToken();
        DingTalkClient client = new DefaultDingTalkClient(DingtalkUrlConstant.URL_GETBY_MOBILE);
        OapiV2UserGetbymobileRequest req = new OapiV2UserGetbymobileRequest();
        req.setMobile(mobile);
        OapiV2UserGetbymobileResponse rsp = null;
        try {
            rsp = client.execute(req, accessToken.getAccessToken());
        } catch (ApiException e) {
            log.error("getUserIdByMobile failed", e);
        }
        return rsp;
    }

    @Override
    public OapiV2UserGetResponse getUserInfoByMobile(String mobile) {
        OapiV2UserGetbymobileResponse response = this.getUserIdByMobile(mobile);
        if (response.isSuccess()) {
            String userid = response.getResult().getUserid();
            OapiV2UserGetResponse userInfo = this.getUserInfoByUserId(userid);
            return userInfo;
        }
        return null;
    }

    @Override
    public OapiV2UserGetResponse getUserInfoByUserId(String userId) {
        OapiGettokenResponse accessToken = this.getAccessToken();
        DingTalkClient client = new DefaultDingTalkClient(DingtalkUrlConstant.URL_GETUSERINFOBY_USERID);
        OapiV2UserGetRequest req = new OapiV2UserGetRequest();
        req.setUserid(userId);
        OapiV2UserGetResponse rsp = null;
        try {
            rsp = client.execute(req, accessToken.getAccessToken());
        } catch (ApiException e) {
            log.error("getUserInfoByUserId failed", e);
        }
        return rsp;
    }

第二、全量同步钉钉的id到用户表中

public void syncUserInfo() {
        List<User> users = userService.getAll(null);
        users.forEach(user -> {
            if (StringUtils.isNotBlank(user.getMobile())) {
                OapiV2UserGetResponse response = dingtalkSdkService.getUserInfoByMobile(user.getMobile());
                if (response.isSuccess()) {
                    String unionid = response.getResult().getUnionid();
                    //TODO 更新用户的这个字段
                }
                try {
                    Thread.sleep(500);
                } catch (Exception e) {
                    log.error("休眠失败", e);
                }
            }
        });
    }