yunxi
/
mes-majoys
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

【需求】chanjet 简化对接

Browse Source
dev
zengchenxi 6 months ago
parent 04df80554b
commit a002799de5
6 changed files with 75 additions and 23 deletions
Show Stats Download Patch File Download Diff File

4
mes-module-majoys/mes-module-majoys-biz/src/main/java/com/chanko/yunxi/mes/module/majoys/config/ChanjetClientConfig.java
Unescape View File

@ -13,7 +13,7 @@ import org.springframework.context.annotation.Configuration;
@Configuration
public class ChanjetClientConfig {
@Bean
public ChanjetClient chanjetClient(OpenApiConfig openApiConfig) {
return new DefaultChanjetClient(openApiConfig.getGatewayUrl(), openApiConfig.getSecret());
public ChanjetClient chanjetClient(ChanjetOpenApiConfig chanjetOpenApiConfig) {
return new DefaultChanjetClient(chanjetOpenApiConfig.getGatewayUrl(), chanjetOpenApiConfig.getSecret());
}
}

2
mes-module-majoys/mes-module-majoys-biz/src/main/java/com/chanko/yunxi/mes/module/majoys/config/OpenApiConfig.java → mes-module-majoys/mes-module-majoys-biz/src/main/java/com/chanko/yunxi/mes/module/majoys/config/ChanjetOpenApiConfig.java
Unescape View File

@ -12,7 +12,7 @@ import org.springframework.context.annotation.Configuration;
@Data
@Configuration
@ConfigurationProperties("chanjet.openapi")
public class OpenApiConfig {
public class ChanjetOpenApiConfig {
/**
* 开放平台网关地址
*/

37
mes-module-majoys/mes-module-majoys-biz/src/main/java/com/chanko/yunxi/mes/module/majoys/controller/admin/chanjet/ChanjetSpi.java
Unescape View File

@ -8,23 +8,20 @@ import com.chanjet.openapi.sdk.java.domain.GetTokenByPermanentCodeContent;
import com.chanjet.openapi.sdk.java.exception.ChanjetApiException;
import com.chanjet.openapi.sdk.java.request.*;
import com.chanjet.openapi.sdk.java.response.*;
import com.chanko.yunxi.mes.module.majoys.config.OpenApiConfig;
import com.chanko.yunxi.mes.module.majoys.config.ChanjetOpenApiConfig;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
/**
* 封装畅捷通SDK的spi
*
* @author: zsc
* @create: 2020/11/6 2:41 下午
**/
* @author chenxi
* @date 2024-04-16 04:17
*/
@Component
public class ChanjetSpi {
public static final String TOKEN = "";
@Autowired
private OpenApiConfig openApiConfig;
private ChanjetOpenApiConfig chanjetOpenApiConfig;
@Autowired
private ChanjetClient chanjetClient;
@ -37,8 +34,8 @@ public class ChanjetSpi {
*/
public GetAppAccessTokenResponse getAppAccessToken(GetAppAccessTokenContent getAppAccessTokenContent) throws ChanjetApiException {
GetAppAccessTokenRequest getAppAccessTokenRequest = new GetAppAccessTokenRequest();
getAppAccessTokenRequest.setAppKey(openApiConfig.getAppKey());
getAppAccessTokenRequest.setAppSecret(openApiConfig.getAppSecret());
getAppAccessTokenRequest.setAppKey(chanjetOpenApiConfig.getAppKey());
getAppAccessTokenRequest.setAppSecret(chanjetOpenApiConfig.getAppSecret());
getAppAccessTokenRequest.setRequestUri("/auth/appAuth/getAppAccessToken");
getAppAccessTokenRequest.setBizContent(getAppAccessTokenContent);
return chanjetClient.execute(getAppAccessTokenRequest);
@ -53,8 +50,8 @@ public class ChanjetSpi {
*/
public GetPermanentAuthCodeResponse getPermanentAuthCode(GetPermanentAuthCodeContent getPermanentAuthCodeContent) throws ChanjetApiException {
GetPermanentAuthCodeRequest getPermanentAuthCodeRequest = new GetPermanentAuthCodeRequest();
getPermanentAuthCodeRequest.setAppKey(openApiConfig.getAppKey());
getPermanentAuthCodeRequest.setAppSecret(openApiConfig.getAppSecret());
getPermanentAuthCodeRequest.setAppKey(chanjetOpenApiConfig.getAppKey());
getPermanentAuthCodeRequest.setAppSecret(chanjetOpenApiConfig.getAppSecret());
getPermanentAuthCodeRequest.setRequestUri("/auth/orgAuth/getPermanentAuthCode");
getPermanentAuthCodeRequest.setBizContent(getPermanentAuthCodeContent);
return chanjetClient.execute(getPermanentAuthCodeRequest);
@ -69,8 +66,8 @@ public class ChanjetSpi {
*/
public GetOrgAccessTokenResponse getOrgAccessToken(GetOrgAccessTokenContent getOrgAccessTokenContent) throws ChanjetApiException {
GetOrgAccessTokenRequest getOrgAccessTokenRequest = new GetOrgAccessTokenRequest();
getOrgAccessTokenRequest.setAppKey(openApiConfig.getAppKey());
getOrgAccessTokenRequest.setAppSecret(openApiConfig.getAppSecret());
getOrgAccessTokenRequest.setAppKey(chanjetOpenApiConfig.getAppKey());
getOrgAccessTokenRequest.setAppSecret(chanjetOpenApiConfig.getAppSecret());
getOrgAccessTokenRequest.setRequestUri("/auth/orgAuth/getOrgAccessToken");
getOrgAccessTokenRequest.setBizContent(getOrgAccessTokenContent);
return chanjetClient.execute(getOrgAccessTokenRequest);
@ -85,10 +82,10 @@ public class ChanjetSpi {
*/
public GetTokenResponse getToken(String code) throws ChanjetApiException {
GetTokenRequest getTokenRequest = new GetTokenRequest();
getTokenRequest.addQueryParam("appKey", openApiConfig.getAppKey());
getTokenRequest.addQueryParam("appKey", chanjetOpenApiConfig.getAppKey());
getTokenRequest.addQueryParam("grantType", "authorization_code");
//填写开发者的真实OAuth回调地址
getTokenRequest.addQueryParam("redirectUri", openApiConfig.getRedirectUri());
getTokenRequest.addQueryParam("redirectUri", chanjetOpenApiConfig.getRedirectUri());
getTokenRequest.addQueryParam("code", code);
getTokenRequest.setRequestUri("/auth/getToken");
@ -104,8 +101,8 @@ public class ChanjetSpi {
*/
public RefreshTokenResponse refreshToken(String refreshToken) throws ChanjetApiException {
RefreshTokenRequest getTokenRequest = new RefreshTokenRequest();
getTokenRequest.addQueryParam("appKey", openApiConfig.getAppKey());
getTokenRequest.addQueryParam("appSecret", openApiConfig.getAppSecret());
getTokenRequest.addQueryParam("appKey", chanjetOpenApiConfig.getAppKey());
getTokenRequest.addQueryParam("appSecret", chanjetOpenApiConfig.getAppSecret());
getTokenRequest.addQueryParam("grantType", "refresh_token");
//填写开发者的真实OAuth回调地址
getTokenRequest.addQueryParam("refreshToken", refreshToken);
@ -123,8 +120,8 @@ public class ChanjetSpi {
*/
public GetTokenByPermanentCodeResponse getTokenByPermanentCode(GetTokenByPermanentCodeContent getTokenByPermanentCodeContent) throws ChanjetApiException {
GetTokenByPermanentCodeRequest getTokenByPermanentCodeRequest = new GetTokenByPermanentCodeRequest();
getTokenByPermanentCodeRequest.setAppKey(openApiConfig.getAppKey());
getTokenByPermanentCodeRequest.setAppSecret(openApiConfig.getAppSecret());
getTokenByPermanentCodeRequest.setAppKey(chanjetOpenApiConfig.getAppKey());
getTokenByPermanentCodeRequest.setAppSecret(chanjetOpenApiConfig.getAppSecret());
getTokenByPermanentCodeRequest.setRequestUri("/auth/token/getTokenByPermanentCode");
getTokenByPermanentCodeRequest.setBizContent(getTokenByPermanentCodeContent);
return chanjetClient.execute(getTokenByPermanentCodeRequest);

12
mes-module-majoys/mes-module-majoys-biz/src/main/java/com/chanko/yunxi/mes/module/majoys/controller/admin/chanjet/ChanjetTokenHolder.java
Unescape View File

@ -4,11 +4,13 @@ import com.alibaba.fastjson.JSON;
import com.chanjet.openapi.sdk.java.exception.ChanjetApiException;
import com.chanjet.openapi.sdk.java.response.GetTokenResponse;
import com.chanjet.openapi.sdk.java.response.RefreshTokenResponse;
import com.chanko.yunxi.mes.module.majoys.config.ChanjetOpenApiConfig;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;
import javax.annotation.Resource;
/**
@ -23,9 +25,19 @@ public class ChanjetTokenHolder {
public static String TOKEN = null;
public static String REFRESH_TOKEN = null;
public static String APP_KEY = null;
public static String APP_SECRET = null;
@Resource
private ChanjetSpi chanjetSpi;
@Resource
private ChanjetOpenApiConfig chanjetOpenApiConfig;
@PostConstruct
public void init(){
APP_KEY = chanjetOpenApiConfig.getAppKey();
APP_SECRET = chanjetOpenApiConfig.getAppSecret();
}
public static void setToken(GetTokenResponse response) {
log.debug("ChanjetTokenHolder.setToken: {}", JSON.toJSONString(response));

31
mes-module-majoys/mes-module-majoys-biz/src/main/java/com/chanko/yunxi/mes/module/majoys/controller/admin/chanjet/vo/SimpleChanjetRequest.java
Unescape View File

@ -0,0 +1,31 @@
package com.chanko.yunxi.mes.module.majoys.controller.admin.chanjet.vo;
import com.chanjet.openapi.sdk.java.AbstractChanjetRequest;
import com.chanjet.openapi.sdk.java.ChanjetResponse;
import com.chanjet.openapi.sdk.java.enums.HttpMethod;
import com.chanko.yunxi.mes.module.majoys.controller.admin.chanjet.ChanjetTokenHolder;
/**
* 简化请求
* @author chenxi
* @date 2024-04-16 16:35
*/
public class SimpleChanjetRequest<T extends ChanjetResponse> extends AbstractChanjetRequest {
public SimpleChanjetRequest(String uri, Class<T> responseClass){
this.setRequestUri(uri);
this.setAppKey(ChanjetTokenHolder.APP_KEY);
this.setAppSecret(ChanjetTokenHolder.APP_SECRET);
this.setOpenToken(ChanjetTokenHolder.TOKEN);
}
@Override
public Class<T> getResponseClass() {
return null;
}
@Override
public HttpMethod getHttpMethod() {
return HttpMethod.POST;
}
}

12
mes-module-majoys/mes-module-majoys-biz/src/main/java/com/chanko/yunxi/mes/module/majoys/controller/admin/chanjet/vo/SimpleChanjetResponse.java
Unescape View File

@ -0,0 +1,12 @@
package com.chanko.yunxi.mes.module.majoys.controller.admin.chanjet.vo;
import com.chanjet.openapi.sdk.java.AbstractChanjetResponse;
/**
* @author chenxi
* @date 2024-04-16 16:51
*/
public class SimpleChanjetResponse extends AbstractChanjetResponse {
private Object result;
}
Write Preview
Loading…
Cancel
Save