企业应用(阿里商旅)集成 钉钉 与 微信 实现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 山西

相关推荐

头像
10-31 11:17
北京理工大学 算法工程师
百度笔试 1019
第一题题目描述：我们可能听过“短板效应”这一说法：一只水桶能盛多少水，并不取决于最长的那块木板，而是取决于最短的那块木板。小明在完成某个小组任务时，也出现了类似的情况。小明的班级有n个人排成一行，每个人有一个能力值aᵢ，每连续i个人都在一个大小为i的组里，一个人会在很多个组。例如1,2,3,4,5，五个人依次排成一行，有1,2,3；2,3,4；3,4,5这三个大小为3的组，有1,2,3,4；2,3,4,5这两个大小为4的组。一个组的能力值为组里所有人能力值的最小值，小明作为班长想对于所有1≤x≤n求出所有大小为x的组的能力值的最大值为多少。&nbsp;输入描述：第一行一个正整数n，表示班级中的人数。(1...
投递百度等公司10个岗位
点赞 评论 收藏
分享
昨天 01:05
门头沟学院 Java
点赞 评论 收藏
分享
09-23 12:19
哈尔滨工业大学（威海） Web前端
点赞 评论 收藏
分享
09-28 22:01
已编辑
广西科技大学 IT技术支持
毕业生求职
合适才能收到offe...：找桌面运维？
点赞 评论 收藏
分享
10-27 23:35
Université d’Auvergne-Clermont-Ferrand 1 C++
cpp / c++零基础两周速成教学
前言方法说明，只能保证大家可以找到工作，一般如果不限城市找个一万五六的问题不大（根据三年辅导经验来看）。但是并不能保证大家进大厂，因为速成只能是让大家基础，项目快速达到能面试的水平，即面试官问的，口述的，能让大家都答出来，并且答的还很深，很好。但是算法这个，没办法让大家速成，可能别人有更好的办法，但是个人能力有限，确实帮不了大家。这个想成只能刷题，个人认为。每天刷个两三道，坚持一两个月也是可以补上来的。下面只讲教学步骤，对于为什么要这么做，这么做的原理到时候与大家开会的时候进行交流。1.简历制作简历统一用这个，技术栈+项目固定另外再加上个人的信息以及获奖情况（简要说明，技术栈这么写已经可以对于...
点赞 评论 收藏
分享
评论
点赞
1
分享

招聘动态

查看更多

字节跳动火山引擎

2026校园招聘

厦门银行

2026届秋季校园招聘

联想

2026届校园招聘

字节跳动

2026校园招聘

联想

26届AI专项｜内推码NK2026

快手

2026届校园招聘

中欧基金

2026届卓越之星校招

联想

2026届校园招聘

爱立信

全站热榜

更多

创作者周榜

更多
正在热议
更多
# HR问：你期望的薪资是多少？如何回答 #
67429次浏览 653人参与
# 我和mentor的爱恨情仇 #
78037次浏览 431人参与
# “vivo”个offer #
41877次浏览 288人参与
# 打工人的精神状态 #
98733次浏览 1289人参与
# 被同事甩锅了怎么办 #
24355次浏览 100人参与
# 你见过哪些工贼行为 #
28758次浏览 141人参与
# 一人一个landing小技巧 #
125752次浏览 1457人参与
# 你的秋招第一场笔试是哪家 #
258897次浏览 2026人参与
# 满帮集团求职进展汇总 #
6847次浏览 68人参与
# 考研失败就一定是坏事吗？ #
149820次浏览 1081人参与
# vivo工作体验 #
29397次浏览 125人参与
# 和mentor 1on1 都聊什么？ #
2431次浏览 21人参与
# 哪一瞬间觉得自己长大了 #
39666次浏览 494人参与
# 上班后和你想的一样吗？ #
88223次浏览 671人参与
# 校招生月薪1W算什么水平 #
43657次浏览 237人参与
# 实习吐槽大会 #
386840次浏览 2156人参与
# 如何准备秋招 #
64825次浏览 830人参与
# 你想留在一线还是回老家？ #
62896次浏览 537人参与
# 工作后明白的那些道理 #
23117次浏览 225人参与
# 数字马力求职进展汇总 #
206726次浏览 1636人参与
# 我是面试官，请用一句话让我破防 #
29186次浏览 133人参与
牛客网
牛客网在线编程
牛客网题解
牛客企业服务