企业应用(阿里商旅)集成 钉钉 与 微信 实现SSO单点登陆

1.钉钉准备工作

(1) 创建应用

https://open-dev.dingtalk.com/fe/app#/corp/app

img

(2)获取应用凭证

记录 AgentId AppKey AppSecret

img

(3)开通权限

开通需要的权限,并指定范围

img

(4)设置应用首页

构建单点登陆连接可参考 https://open.dingtalk.com/document/orgapp-server/logon-free-third-party-websites

img

(5)发布应用

img

2.微信准备工作

(1)添加应用

img

(2)获取应用凭证

img

并在我的企业中记录企业的CorpIDID

img

(3)设置可信域名

img

(4)设置工作台应用主页

此处设置的即为跳转的连接,将会携带当前授权的用户code

img

3.代码

(1)项目依赖

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <groupId>com.example</groupId>
  <artifactId>Alibtrip_Sso</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <name>Alibtrip_Sso</name>
  <description>Alibtrip_Sso</description>

  <properties>
    <java.version>1.8</java.version>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    <spring-boot.version>2.3.7.RELEASE</spring-boot.version>
  </properties>

  <dependencies>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
      <groupId>com.baomidou</groupId>
      <artifactId>mybatis-plus-boot-starter</artifactId>
      <version>3.4.2</version>
    </dependency>
    <dependency>
      <groupId>org.slf4j</groupId>
      <artifactId>slf4j-api</artifactId>
    </dependency>
    <dependency>
      <groupId>org.projectlombok</groupId>
      <artifactId>lombok</artifactId>
      <optional>true</optional>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-test</artifactId>
      <scope>test</scope>
      <exclusions>
        <exclusion>
          <groupId>org.junit.vintage</groupId>
          <artifactId>junit-vintage-engine</artifactId>
        </exclusion>
      </exclusions>
    </dependency>

    <dependency>
      <groupId>com.aliyun</groupId>
      <artifactId>btripopen20220520</artifactId>
      <version>1.0.13</version>
    </dependency>

    <dependency>
      <groupId>com.aliyun</groupId>
      <artifactId>dingtalk</artifactId>
      <version>1.4.43</version>
    </dependency>
    <dependency>
      <groupId>com.aliyun</groupId>
      <artifactId>alibaba-dingtalk-service-sdk</artifactId>
      <version>2.0.0</version>
    </dependency>
    <dependency>
      <groupId>com.github.ben-manes.caffeine</groupId>
      <artifactId>caffeine</artifactId>
      <version>2.9.3</version>
    </dependency>

    <dependency>
      <groupId>commons-httpclient</groupId>
      <artifactId>commons-httpclient</artifactId>
      <version>3.1</version>
    </dependency>
    <dependency>
      <groupId>org.apache.httpcomponents</groupId>
      <artifactId>httpclient</artifactId>
      <version>4.5.13</version>
    </dependency>
    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>fastjson</artifactId>
      <version>2.0.13</version>
    </dependency>
    </dependencies>

      <dependencyManagement>
      <dependencies>
      <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-dependencies</artifactId>
      <version>${spring-boot.version}</version>
      <type>pom</type>
      <scope>import</scope>
    </dependency>
    </dependencies>
    </dependencyManagement>

    </project>

(2)application.properties 配置文件

# 应用名称
spring.application.name=alibtrip_sso

spring.profiles.active=dev

logging.level.root=INFO
logging.level.org.springframework=WARN
logging.level.org.spring.springboot.dao=DEBUG
logging.level.com.accenture.fssc.hdl.mapper=DEBUG
logging.config=classpath:logback-dev.xml
logging.path=./log/alitrip

# 应用服务 WEB 访问端口
server.port=9712

#阿里商旅配置
alibtrip.appKey=
alibtrip.appSecret=
#类型，0-自营 1-分销
alibtrip.corpTokenType=
#企业代理id，值可以在开放平台中的关联企业查看企业代理id。
alibtrip.corpTokenCorpId=


#钉钉配置
dingding.url=
#应用id
dingding.app.agentid=
#应用key
dingding.app.key=
#应用秘钥
dingding.app.secret=


#微信配置
wechat.corpid=
wechat.corpsecret=
wechat.getTokenUri=
wechat.getUserIdUri=
wechat.readUserUri=

(3)Controller 层

AlibtripController

@Slf4j
@RequestMapping("/alibtrip")
@Controller
public class AlibtripController {

    private static final String URL_GET_USERINFO_BY_CODE = "https://oapi.dingtalk.com/sns/getuserinfo_bycode";


    @RequestMapping("/dingding2TripCode")
    public void dingding2TripCode(@RequestParam("code")String code,HttpServletResponse response) {

        try {
            AlibTripService dingdingAlibTrip = (AlibTripService) SpringBeanUtils.getBean("dingdingAlibTrip");
            String redirectUrl = dingdingAlibTrip.invokeAddressGet(code);
            response.sendRedirect(redirectUrl);
        } catch (Exception e) {
            log.error("dingding  重定向 trip出错 {}", e);
        }
    }

    @RequestMapping("/dingding2TripWX")
    public void dingding2TripWX(@RequestParam("code")String code,HttpServletResponse response) {
        try {
            AlibTripService wxAlibTrip = (AlibTripService) SpringBeanUtils.getBean("wxAlibTrip");
            String redirectUrl = wxAlibTrip.invokeAddressGet(code);
            response.sendRedirect(redirectUrl);
        } catch (Exception e) {
            log.error("WX  重定向 trip出错 {}", e);
        }
    }

}

(4)Service层

AbstractDingDing

public abstract class AbstractDingDing {

    public abstract String getAccessToken(String code);

    public abstract String getUserId(String token, String code);
}

AlibTripService

public interface AlibTripService {
    String invokeAddressGet(String param);
}

AlibTripServiceAbstract

@Slf4j
@Component
public abstract class AlibTripServiceAbstract implements AlibTripService{


    @Autowired
    private ClientUtils clientUtils;
    @Autowired
    private CorpTokenUtils corpTokenUtils;

    public abstract String getUserId(String param);

    @Override
    public String invokeAddressGet(String param) {
        String empId = getUserId(param);
        String addressGetUrl = null;
        Client client = clientUtils.getClient();
        String cropToken = corpTokenUtils.getToken();
        AddressGetHeaders addressGetHeaders = new AddressGetHeaders();
        addressGetHeaders.setXAcsBtripSoCorpToken(cropToken);
        AddressGetRequest addressGetRequest = new AddressGetRequest();
        addressGetRequest.setUserId(empId);
        addressGetRequest.setActionType(4);
        try {
            AddressGetResponse addressGetResponse = client.addressGetWithOptions(addressGetRequest, addressGetHeaders, new RuntimeOptions());
            AddressGetResponseBody body = addressGetResponse.body;
            //success的场景
            addressGetUrl = body.module.getUrl();
        } catch (
                TeaException e) {
            String code = e.getCode();
            String msg = e.getMessage();
            Map<String, Object> data = e.getData();
            //failed的场景
        } catch (Exception e) {
            //其他异常处理
            log.error("invokeAddressGet 出错 {}",e);
        }
        return addressGetUrl;
    }
}

AlibTripServiceImpl

@Slf4j
@Service
public class AlibTripServiceImpl implements AlibTripService {

    @Autowired
    private ClientUtils clientUtils;
    @Autowired
    private CorpTokenUtils corpTokenUtils;
    @Autowired
    private WeChatUtil weChatUtil;

    @Autowired
    @Qualifier("oldDingDing")
    private AbstractDingDing abstractDingDing;



    public String dingding2Trip(String code) {
        String accessToken = abstractDingDing.getAccessToken(code);
        String userId = abstractDingDing.getUserId(accessToken, code);
        String addressGet = invokeAddressGet(userId);
        return addressGet;
    }

    public String dingding2TripWX(String code) {
        String accessToekn = weChatUtil.getAccessToekn();
        String userId = weChatUtil.getUserId(accessToekn, code);
        String empId = weChatUtil.getEmpId(accessToekn, userId);
        String addressGet = invokeAddressGet(empId);
        return addressGet;
    }


    @Override
    public String invokeAddressGet(String empId) {
        String addressGetUrl = null;
        Client client = clientUtils.getClient();
        String cropToken = corpTokenUtils.getToken();

        AddressGetHeaders addressGetHeaders = new AddressGetHeaders();
        addressGetHeaders.setXAcsBtripSoCorpToken(cropToken);
        AddressGetRequest addressGetRequest = new AddressGetRequest();
        addressGetRequest.setUserId(empId);
        addressGetRequest.setActionType(4);
        try {
            AddressGetResponse addressGetResponse = client.addressGetWithOptions(addressGetRequest, addressGetHeaders, new RuntimeOptions());
            AddressGetResponseBody body = addressGetResponse.body;
            //success的场景
            addressGetUrl = body.module.getUrl();
        } catch (
                TeaException e) {
            String code = e.getCode();
            String msg = e.getMessage();
            Map<String, Object> data = e.getData();
            //failed的场景
        } catch (Exception e) {
            //其他异常处理
            log.error("invokeAddressGet 出错 {}",e);
        }
        return addressGetUrl;
    }

}

DingDingAlibTripService

@Service("dingdingAlibTrip")
public class DingDingAlibTripService extends AlibTripServiceAbstract {


    @Autowired
    @Qualifier("oldDingDing")
    private AbstractDingDing abstractDingDing;


    @Override
    public String getUserId(String code) {
        String accessToken = abstractDingDing.getAccessToken(code);
        String userId = abstractDingDing.getUserId(accessToken, code);
        return userId;
    }
}

WXAlibTripSevice

@Service("wxAlibTrip")
public class WXAlibTripSevice extends AlibTripServiceAbstract {

    @Autowired
    private WeChatUtil weChatUtil;

    @Override
    public String getUserId(String code) {
        String accessToekn = weChatUtil.getAccessToekn();
        String userId = weChatUtil.getUserId(accessToekn, code);
        String empId = weChatUtil.getEmpId(accessToekn, userId);
        return empId;
    }

}

(5)工具类

AccessTokenUtils

@Slf4j
@Component
public class AccessTokenUtils {

    @Value("${alibtrip.appKey}")
    private String appKey;
    @Value("${alibtrip.appSecret}")
    private String appSecret;

    @Autowired
    private ClientUtils clientUtils;

    private AccessTokenUtils() {
    }

    ;

    private final String key = CacheKeyEnum.ACCESS_TOKEN_KEY.key;

    public String getToken() {
        Object ifPresent = accessTokenCache.getIfPresent(key);
        if (ifPresent == null) {
            synchronized (AccessTokenUtils.class) {
                if (ifPresent == null) {
                    String accessToken = initAccessToken();
                    accessTokenCache.put(key, accessToken);
                    return accessToken;
                }
            }
        }
        return (String) ifPresent;
    }

    private Cache<Object, Object> accessTokenCache = Caffeine.newBuilder().refreshAfterWrite(
            7000000, TimeUnit.MILLISECONDS
    ).build(new CacheLoader<Object, Object>() {
        @Override
        public @Nullable Object reload(@NonNull Object key, @NonNull Object oldValue) throws Exception {
            String corpToken = initAccessToken();
            if (corpToken == null) {
                return accessTokenCache.get(key, null);
            }
            return corpToken;
        }

        @Override
        public @Nullable Object load(Object key) throws Exception {
            String corpToken = initAccessToken();
            if (corpToken == null) {
                return accessTokenCache.get(key, null);
            }
            return corpToken;
        }
    });


    private String initAccessToken() {
        Client client = clientUtils.getClient();
        try {
            AccessTokenRequest accessTokenCache = new AccessTokenRequest();
            accessTokenCache.setAppKey(appKey);
            accessTokenCache.setAppSecret(appSecret);
            AccessTokenResponse accessTokenResponse = client.accessToken(accessTokenCache);
            AccessTokenResponseBody body = accessTokenResponse.body;
            String token = body.getData().token;
            return token;
        } catch (
                TeaException e) {
            String code = e.getCode();
            String msg = e.getMessage();
            Map<String, Object> data = e.getData();
            //failed的场景
            StringBuffer sb = new StringBuffer();
            sb.append(" code : ")
                    .append(code)
                    .append(" msg : ")
                    .append(msg)
                    .append(" data : ")
                    .append(data);
            log.error(sb.toString(), e);
        } catch (Exception e) {
            //其他异常处理
             log.error(LocalDateTime.now() + " initCorpToken ", e);
        }
        return null;
    }

}

ClientUtils

@Component
@Slf4j
public class ClientUtils {

    public  Client client;
    @Value("${alibtrip.appKey}")
    private String appKey;
    @Value("${alibtrip.appSecret}")
    private String appSecret;

    private ClientUtils() {
    }

    private void instanceClient() {
        Config config = new Config();
        config.setAccessKeyId(appKey);
        config.setAccessKeySecret(appSecret);
        config.setProtocol("https");
        config.setEndpoint("btripopen.aliyuncs.com");

        try {
            client = new Client(config);
        } catch (Exception e) {
            e.printStackTrace();
            log.error(LocalDateTime.now() + " initCorpToken ", e);
        }
        //设置签名算法
        client._signatureAlgorithm = "ACS3-HMAC-SHA256";

    }

    public Client getClient()
    {
       if (client==null){
           synchronized (Object.class){
               if (client==null){
                   instanceClient();
               }
           }
       }
       return client;
    }

}

CorpTokenUtils

@Slf4j
@Component
public class CorpTokenUtils {

    @Value("${alibtrip.corpTokenType}")
    private Integer corpTokenType;
    @Value("${alibtrip.corpTokenCorpId}")
    private String corpTokenCorpId;

    @Autowired
    private ClientUtils clientUtils;
    @Autowired
    private AccessTokenUtils accessTokenUtils;

    private CorpTokenUtils() {
    }

    private final String key = CacheKeyEnum.CROP_TOKEN_KEY.key;

    public String getToken() {
        Object ifPresent = corpTokenCache.getIfPresent(key);
        if (ifPresent == null) {
            synchronized (CorpTokenUtils.class) {
                if (ifPresent == null) {
                    String corpToken = initCorpToken();
                    corpTokenCache.put(key, corpToken);
                    return corpToken;
                }
            }
        }
        return (String) ifPresent;
    }

    private Cache<Object, Object> corpTokenCache = Caffeine.newBuilder().refreshAfterWrite(
            7000000, TimeUnit.MILLISECONDS
    ).build(new CacheLoader<Object, Object>() {
        @Override
        public @Nullable Object reload(@NonNull Object key, @NonNull Object oldValue) throws Exception {
            String corpToken = initCorpToken();
            if (corpToken == null) {
                return corpTokenCache.get(key, null);
            }
            return corpToken;
        }

        @Override
        public @Nullable Object load(Object key) throws Exception {
            String corpToken = initCorpToken();
            if (corpToken == null) {
                return corpTokenCache.get(key, null);
            }
            return corpToken;
        }
    });


    private String initCorpToken() {
        Client client = clientUtils.getClient();
        try {
            CorpTokenHeaders corpTokenHeaders = new CorpTokenHeaders();
            String accessTokenUtilsToken = accessTokenUtils.getToken();
            corpTokenHeaders.setXAcsBtripAccessToken(accessTokenUtilsToken);
            CorpTokenRequest corpTokenRequest = new CorpTokenRequest();
            corpTokenRequest.setType(corpTokenType);
            corpTokenRequest.setCorpId(corpTokenCorpId);
            CorpTokenResponse corpTokenResponse = client.corpTokenWithOptions(corpTokenRequest, corpTokenHeaders, new RuntimeOptions());
            CorpTokenResponseBody body = corpTokenResponse.body;
            String token = body.getData().token;
            return token;
        } catch (
                TeaException e) {
            String code = e.getCode();
            String msg = e.getMessage();
            Map<String, Object> data = e.getData();
            //failed的场景
            StringBuffer sb = new StringBuffer();
            sb.append(" code : ")
                    .append(code)
                    .append(" msg : ")
                    .append(msg)
                    .append(" data : ")
                    .append(data);
            log.error(sb.toString(), e);
        } catch (Exception e) {
            //其他异常处理
            log.error(LocalDateTime.now() + " initCorpToken ", e);
        }
        return "";
    }
}

DingDingUtils

@Slf4j
@Component("newDingDing")
public class DingDingUtils extends AbstractDingDing {

    @Value("${dingding.url}")
    private String DING_URL ;
    @Value("${dingding.app.agentid}")
    private String AGENT_ID;
    @Value("${dingding.app.key}")
    private String APP_KEY; // 应用的Key
    @Value("${dingding.app.secret}")
    private String APP_SECRET ; // 应用的密码

    com.aliyun.dingtalkcontact_1_0.Client client1 = null;
    com.aliyun.dingtalkoauth2_1_0.Client client2 = null;


    public static com.aliyun.dingtalkcontact_1_0.Client createClient1() throws Exception {
        Config config = new Config();
        config.protocol = "https";
        config.regionId = "oapi.dingtalk.com";
        return new com.aliyun.dingtalkcontact_1_0.Client(config);
    }


    public static com.aliyun.dingtalkoauth2_1_0.Client createClient2() throws Exception {
        Config config = new Config();
        config.protocol = "https";
        config.regionId = "oapi.dingtalk.com";
        return new com.aliyun.dingtalkoauth2_1_0.Client(config);
    }


    @Override
    public  String getAccessToken(String code) {

        if (client2==null){
            try {
                client2 = DingDingUtils.createClient2();
            } catch (Exception e) {
                log.error("getAccessToken {}",e);
            }
        }
        GetUserTokenRequest getUserTokenRequest = new GetUserTokenRequest()
                .setClientId(APP_KEY)
                .setClientSecret(APP_SECRET)
                .setCode(code)
                .setRefreshToken(code)
                .setGrantType("authorization_code");

        try {
            GetUserTokenResponse userToken = client2.getUserToken(getUserTokenRequest);
            return userToken.getBody().getAccessToken();
        } catch (TeaException err) {
            if (!com.aliyun.teautil.Common.empty(err.code) && !com.aliyun.teautil.Common.empty(err.message)) {
                // err 中含有 code 和 message 属性，可帮助开发定位问题
                log.error("getAccessToken {}",err);
            }

        } catch (Exception _err) {
            TeaException err = new TeaException(_err.getMessage(), _err);
            if (!com.aliyun.teautil.Common.empty(err.code) && !com.aliyun.teautil.Common.empty(err.message)) {
                // err 中含有 code 和 message 属性，可帮助开发定位问题
                log.error("getAccessToken {}",err);
            }

        }
        return "";
    }


    @Override
    public String getUserId(String accessToken, String code) {
        if (client1==null){
            try {
                client1 = DingDingUtils.createClient1();
            } catch (Exception e) {
                log.error("getAccessToken {}",e);
            }
        }

        try {
            GetUserHeaders headers = new GetUserHeaders();
            headers.setXAcsDingtalkAccessToken(accessToken);
            GetUserResponse userWithOptions = client1.getUserWithOptions("me", headers, new RuntimeOptions());
            GetUserResponseBody userWithOptionsBody = userWithOptions.getBody();
            String unionId = userWithOptions.body.unionId;
        } catch (TeaException err) {
            if (!Common.empty(err.code) && !Common.empty(err.message)) {
                // err 中含有 code 和 message 属性，可帮助开发定位问题
                log.error("getAccessToken {}",err);
            }

        } catch (Exception _err) {
            TeaException err = new TeaException(_err.getMessage(), _err);
            if (!Common.empty(err.code) && !Common.empty(err.message)) {
                // err 中含有 code 和 message 属性，可帮助开发定位问题
                log.error("getAccessToken {}",err);
            }
        }
        return "";
    }


}

HttpClientUtil

@Component
@Slf4j
public class HttpClientUtil {

    CloseableHttpClient httpclient = null;
    CloseableHttpResponse response = null;

    HttpRequestRetryHandler requestRetryHandler=new HttpRequestRetryHandler() {

        @Override
        public boolean retryRequest(IOException exception, int executionCount, HttpContext context) {
            if (executionCount > 3) //超过重试次数，就放弃
                return false;
            if (exception instanceof NoHttpResponseException) {//没有响应，重试
                return true;
            }else if (exception instanceof ConnectTimeoutException) {//连接超时，重试
                return true;
            } else if (exception instanceof SocketTimeoutException) {//连接或读取超时，重试
                return true;
            }else if (exception instanceof SSLHandshakeException) {//本地证书异常
                return false;
            } else if (exception instanceof InterruptedIOException) {//被中断
                return false;
            } else if (exception instanceof UnknownHostException) {//找不到服务器
                return false;
            }  else if (exception instanceof SSLException) {//SSL异常
                return false;
            } else {
                log.info("出现异常");
            }
            HttpClientContext clientContext = HttpClientContext.adapt(context);
            HttpRequest request = clientContext.getRequest();
            // 如果请求是幂等的，则重试
            if (!(request instanceof HttpEntityEnclosingRequest)) return true;
            return false;
        }
    };

    public String doGet(String url, Map<String, String> map) {
        String returnJson = "";
        try {
            RequestConfig globalConfig = RequestConfig.custom()
                    .setSocketTimeout(10000)
                    .setConnectTimeout(10000)
                    .setCookieSpec(CookieSpecs.IGNORE_COOKIES).build();
            httpclient = HttpClients.custom()
                    .setRetryHandler(requestRetryHandler)
                    .setDefaultRequestConfig(globalConfig).build();
            HttpGet httpGet = new HttpGet(url);
//            httpGet.setProtocolVersion(HttpVersion.HTTP_1_0);
//            httpGet.addHeader(HTTP.CONN_DIRECTIVE, HTTP.CONN_CLOSE);
            // httpGet.addHeader(HTTP.CONTENT_TYPE,
            // "application/x-www-form-urlencoded;charset=UTF-8");
            for (String key : map.keySet()) {
                httpGet.addHeader(key, map.get(key));
            }

            response = httpclient.execute(httpGet);

            HttpEntity entity = response.getEntity();
            if (entity != null) {
                returnJson = "" + EntityUtils.toString(entity, "UTF-8");
            }
            log.info(returnJson);
        } catch (Exception e) {
            log.error("连接超时",e);
            throw new RuntimeException(e);
        }
        finally {
            closeHttp();
        }
        return returnJson;
    }

    public String doPost(String url, String data,
            Map<String, String> headermap, Map<String, String> bodymap) {
        String returnJson = "";
        try {
            RequestConfig globalConfig = RequestConfig.custom()
                    .setSocketTimeout(10000)
                    .setConnectTimeout(10000)
                    .setCookieSpec(CookieSpecs.IGNORE_COOKIES).build();
            //客户端请求
            httpclient = HttpClients.custom()
                    .setRetryHandler(requestRetryHandler)
                    .setDefaultRequestConfig(globalConfig).build();

            HttpPost httpPost = new HttpPost(url);
            // 设置header
            if (bodymap != null) {
                for (String key : headermap.keySet()) {
                    httpPost.addHeader(key, headermap.get(key));
                }
            }
            // 设置body
            if (bodymap != null) {
                List<NameValuePair> pairs = new ArrayList<NameValuePair>();
                for (Map.Entry<String, String> entry : bodymap.entrySet()) {
                    pairs.add(new BasicNameValuePair(entry.getKey(), entry
                            .getValue()));
                }
                httpPost.setEntity(new UrlEncodedFormEntity(pairs, "UTF-8"));
            }
            // 参数动态传入

            // StringEntity se = new StringEntity("data=" + json, "UTF-8");
            if (data != null && !data.equals("")) {
                StringEntity se = new StringEntity(data, "UTF-8");
                se.setContentEncoding("UTF-8");
                se.setContentType("application/json");// 发送json需要设置contentType
                httpPost.setEntity(se);
            }

            response = httpclient.execute(httpPost);

            // 解析返结果
            HttpEntity entity = response.getEntity();
            if (entity != null) {
                returnJson = "" + EntityUtils.toString(entity, "UTF-8");
            }
        } catch (Exception e) {
            log.error("连接超时",e);
            throw new RuntimeException(e);
        }
        finally {
            closeHttp();
        }
        return returnJson;
    }

    public void closeHttp() {
        try {
            if (httpclient != null) {
                httpclient.close();
            }
            if (response != null) {
                response.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

OldDingDingUtis

@Slf4j
@Component("oldDingDing")
public class OldDingDingUtis extends AbstractDingDing {

    @Value("${dingding.url}")
    private String DING_URL ;
    @Value("${dingding.app.agentid}")
    private String AGENT_ID;
    @Value("${dingding.app.key}")
    private String APP_KEY; // 应用的Key
    @Value("${dingding.app.secret}")
    private String APP_SECRET ; // 应用的密码

    // 获取钉钉token
    public String getAccessToken() {
        String result = null;
        DefaultDingTalkClient client = new DefaultDingTalkClient(DING_URL + "/gettoken");
        OapiGettokenRequest request = new OapiGettokenRequest();
        request.setAppkey(APP_KEY);
        request.setAppsecret(APP_SECRET);
        request.setHttpMethod("GET");
        try {
            OapiGettokenResponse response = client.execute(request);
            result = response.isSuccess() ? response.getAccessToken() : null;
        } catch (ApiException e) {
            log.error("获取钉钉AccessToken错误 {}" , e);
        }
        return result;
    }


    @Override
    public String getAccessToken(String code) {
        return getAccessToken();
    }

    @Override
    public String getUserId(String token, String code)
    {
        OapiV2UserGetResponse rspGetResponse = null;
        try {
            // 通过临时授权码获取授权用户的个人信息
            DefaultDingTalkClient client2 = new DefaultDingTalkClient("https://oapi.dingtalk.com/sns/getuserinfo_bycode");
            OapiSnsGetuserinfoBycodeRequest reqBycodeRequest = new OapiSnsGetuserinfoBycodeRequest();

            reqBycodeRequest.setTmpAuthCode(code);
            OapiSnsGetuserinfoBycodeResponse bycodeResponse = client2.execute(reqBycodeRequest, APP_KEY, APP_SECRET);

            // 根据unionid获取userid
            String unionid = bycodeResponse.getUserInfo().getUnionid();
            DingTalkClient clientDingTalkClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/user/getbyunionid");
            OapiUserGetbyunionidRequest reqGetbyunionidRequest = new OapiUserGetbyunionidRequest();
            reqGetbyunionidRequest.setUnionid(unionid);
            OapiUserGetbyunionidResponse oapiUserGetbyunionidResponse = clientDingTalkClient.execute(reqGetbyunionidRequest, token);

            // 根据userId获取用户信息
            String userid = oapiUserGetbyunionidResponse.getResult().getUserid();
            DingTalkClient clientDingTalkClient2 = new DefaultDingTalkClient(
                    "https://oapi.dingtalk.com/topapi/v2/user/get");
            OapiV2UserGetRequest reqGetRequest = new OapiV2UserGetRequest();
            reqGetRequest.setUserid(userid);
            reqGetRequest.setLanguage("zh_CN");
            rspGetResponse = clientDingTalkClient2.execute(reqGetRequest, token);
            return rspGetResponse.getResult().getJobNumber();
        } catch (ApiException e) {
            e.printStackTrace();
        }
        return "";
    }
}

SpringBeanUtils

@Component
public class SpringBeanUtils implements ApplicationContextAware {


    private static ApplicationContext app;


    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        if (app == null) {
            app = applicationContext;
        }
    }

    // 获得applicationContext
    public static ApplicationContext getApplicationContext() throws Exception {
        return app;
    }

    // 通过class获取Bean
    public static <T> T getBean(Class<T> clazz) throws Exception {
        return getApplicationContext().getBean(clazz);
    }

    // 通过name获取 Bean
    public static Object getBean(String name) throws Exception {
        return getApplicationContext().getBean(name);
    }


}

WeChatUtil

@Slf4j
@Component
public class WeChatUtil {


    @Autowired
    private HttpClientUtil httpClientUtil;

    @Value("${wechat.corpid}")
    private String corpid;

    @Value("${wechat.corpsecret}")
    private String corpsecret;

    @Value("${wechat.getTokenUri}")
    private String wxgetTokenUri;

    @Value("${wechat.getUserIdUri}")
    private String wxgetUserIdUri;

    @Value("${wechat.readUserUri}")
    private String wxreadUserUri;

    private static Long tokenTime = 0L;
    //2小时过期
    private final Integer invalidTime = 2;
    private String accesstToken;

    //获取登陆凭证
    public String getAccessToekn() {
        if (System.currentTimeMillis() - tokenTime > invalidTime * 1000 * 60) {
            tokenTime = System.currentTimeMillis();
            String url = wxgetTokenUri + "?corpid=" + corpid + "&corpsecret=" + corpsecret;
            String doGet = httpClientUtil.doGet(url, new HashMap<>());
            HashMap map = JSON.parseObject(doGet, HashMap.class);
            if ("ok".equals(map.get("errmsg"))) {
                accesstToken = (String) map.get("access_token");
                return accesstToken;
            } else {
                log.error("getAccessToekn 出错 {}",map.get("errmsg"));
                return "";
            }
        } else {
            return accesstToken;
        }
    }

    //获取访问用户ID
    public String getUserId(String accessToken, String code) {
        String url = wxgetUserIdUri + "?access_token=" + accessToken + "&code=" + code;
        String doGet = httpClientUtil.doGet(url, new HashMap<>());
        HashMap map = JSON.parseObject(doGet, HashMap.class);
        if ("ok".equals(map.get("errmsg"))) {
            return (String) map.get("UserId");
        } else {
            throw new RuntimeException(map.get("errcode")+"  "+(String) map.get("errmsg"));
        }
    }

    public String getEmpId(String accessToken,String userId){
        String url = wxreadUserUri + "?access_token=" + accessToken + "&userid=" + userId;
        String doGet = httpClientUtil.doGet(url, new HashMap<>());
        HashMap map = JSON.parseObject(doGet, HashMap.class);
        JSONObject jsonDoget = (JSONObject) JSONObject.parseObject(JSON.parseObject(doGet).getString("extattr")).getJSONArray("attrs").get(0);
        String empId = (String) jsonDoget.get("value");
        if ("ok".equals(map.get("errmsg"))) {
            return empId;
        } else {
            throw new RuntimeException(map.get("errcode")+"  "+(String) map.get("errmsg"));
        }
    }
}

(6) 枚举类

CacheKeyEnum

public enum CacheKeyEnum {

    ACCESS_TOKEN_KEY("accessToken"),
    CROP_TOKEN_KEY("corpToken")
    ;


    public String key;

    CacheKeyEnum(String key) {
        this.key = key;
    }

    public String getkey() {
        return key;
    }

    public void setkey(String key) {
        this.key = key;
    }

    @Override
    public String toString() {
        return super.toString();
    }
}
#java#
全部评论
楼主大神啊，厉害
点赞 回复 分享
发布于 2022-10-10 11:08 山西

相关推荐

昨天 19:00
门头沟学院 Java
钉钉秋招JAVA后端一面
一面：&nbsp;1、实习拷打（8min）&nbsp;2、谈谈研究方向&nbsp;3、谈谈图数据库和知识图谱的关系&nbsp;4、谈谈图数据库和关系型数据库的区别&nbsp;5、什么样场景适合用图数据库&nbsp;6、例如推荐系统的场景用图数据库来存储，如何支持对推荐算法做支持？&nbsp;7、图数据库是否对&nbsp;BFS、DFS、找节点之间最短路等有支持？&nbsp;8、迪杰斯特拉算法的过程&nbsp;9、知不知道&nbsp;A*&nbsp;算法？它优化了迪杰斯特拉的什么问题？&nbsp;10、自己开发用的什么&nbsp;JDK&nbsp;版本？了解哪些不同&nbsp;JDK&nbsp;版本的新特性？&nbsp;11、谈谈&nbsp;JDK25&nbsp;有些什么新特性？&nbsp;12、平时用大模型来干什么？&nbsp;13、GraphRAG&nbsp;底层是如何去构建出实体以及实体之间的关系的？&nbsp;14、如何设...
投递钉钉信息等公司10个岗位
点赞 评论 收藏
分享
10-28 20:10
天津科技大学 财务
点赞 评论 收藏
分享
10-30 22:08
北京工业大学 Java
兄弟们&nbsp;谁能刷1000道题让我看看
肥罗且玫瑰：没啥用，没人看这个，这个公司比较离谱查看图片
点赞 评论 收藏
分享
09-13 17:25
真是绷不住了
亲切的00后在笔试：我也遇到了，所以我早他一步查看图片
点赞 评论 收藏
分享
昨天 15:37
已编辑
鞑靼-美国区立学院(喀山) 机械设计/制造
26秋招总结-传统机械的求职之路
BG双九，家在南方，因此只投长江以南的东部城市。本科偏向机器学习，硕士搞增材制造，工作全找结构设计总计投递41家，主动终止流程11家，简历挂：8家进面13家，面试挂2家:厨芯（一面挂），韶音（二面挂）目前已oc（按时间顺序）：oppo（base东莞，面试体验很好，不过四面后赶上大批量线下面试，线上进度被卡了，两周后才收到座谈-留）零跑汽车（base杭州，一面是微信视频面的，技术官面了一小时，问的很深入，听得出来很专业，最后还交流了很多应届生求职的建议，很有收获；很早就oc，但是十月下旬才谈薪，究极性价比-拒）东成机电（base苏州，各方面都不错，就是公司不算大，赛道可能窄，苏州不交手机，但是每...
面试体验感最好的是哪家？
点赞 评论 收藏
分享
评论
点赞
1
分享

招聘动态

查看更多

字节跳动火山引擎

2026校园招聘

新华三

2026秋招校园招聘

厦门银行

2026届秋季校园招聘

联想

2026届校园招聘

字节跳动

2026校园招聘

联想

26届AI专项｜内推码NK2026

快手

2026届校园招聘

中欧基金

2026届卓越之星校招

联想

2026届校园招聘

爱立信

全站热榜

更多

创作者周榜

更多
正在热议
更多
# 校招生月薪1W算什么水平 #
27261次浏览 169人参与
# 硬件人的简历怎么写 #
311660次浏览 3057人参与
# “vivo”个offer #
36484次浏览 277人参与
# 我是面试官，请用一句话让我破防 #
22942次浏览 117人参与
# 工作后明白的那些道理 #
20878次浏览 220人参与
# 如果上班像打游戏，你最想解锁什么技能 #
7023次浏览 67人参与
# 中美关税战对我们有哪些影响 #
41356次浏览 350人参与
# 中美关系回暖，你会选择出海吗？ #
4818次浏览 94人参与
# AI时代，哪些岗位最容易被淘汰 #
2601次浏览 27人参与
# 华为保温 #
106035次浏览 403人参与
# 机械人，签完三方你在忙什么？ #
65582次浏览 244人参与
# 第一份工作应该只看薪资吗 #
192137次浏览 1687人参与
# 牛友们，签完三方你在忙什么？ #
119784次浏览 958人参与
# 哪些行业值得去? #
4473次浏览 46人参与
# 金融财经春招备战日记 #
38608次浏览 210人参与
# i人适合做什么工作 #
9926次浏览 88人参与
# 如果秋招能重来，我会____ #
34282次浏览 283人参与
# 美团开奖 #
208786次浏览 1101人参与
# 国央企笔面经互助 #
161037次浏览 1182人参与
# 读研or工作，哪个性价比更高？ #
77025次浏览 767人参与
# 华为池子有多大 #
109492次浏览 750人参与
牛客网
牛客网在线编程
牛客网题解
牛客企业服务