Browse Source

feat: 调整网关接口

master_tdsql
hxh 7 months ago
parent
commit
fce759f449
  1. 105
      shuili-admin/src/main/java/com/kms/web/utils/WaterRequestUtil.java

105
shuili-admin/src/main/java/com/kms/web/utils/WaterRequestUtil.java

@ -23,21 +23,22 @@ public class WaterRequestUtil {
private static final Logger log = LoggerFactory.getLogger(WaterRequestUtil.class); private static final Logger log = LoggerFactory.getLogger(WaterRequestUtil.class);
@Value("${water.paasToken:}") //网关
public String paasToken; @Value("${water.gateway.paasToken:}")
@Value("${water.paasId:}") public String gatewayPaasToken;
public String paasId; @Value("${water.gateway.paasId:}")
public String gatewayPaasId;
//应用中台
@Value("${water.center.paasToken:}")
public String centerPaasToken;
@Value("${water.center.paasId:}")
public String centerPaasId;
//网关 //网关
@Value("${water.url:}") @Value("${water.url:}")
public String url; public String url;
//单点登录id
@Value("${water.singOnServiceId:}")
public String singOnServiceId;
//单点登录密钥
@Value("${water.singOnAppsecret:}")
public String singOnAppsecret;
@Value("${water.singOnUrl:}") @Value("${water.singOnUrl:}")
public String singOnUrl; public String singOnUrl;
@Value("${water.logoutUrl:}") @Value("${water.logoutUrl:}")
@ -45,18 +46,12 @@ public class WaterRequestUtil {
@Value("${water.accessTokenUrl:}") @Value("${water.accessTokenUrl:}")
public String accessTokenUrl; public String accessTokenUrl;
@Value("${water.accessTokenServiceId:}")
public String accessTokenServiceId;
@Value("${water.accessTokenAppsecret:}")
public String accessTokenAppsecret;
//验证用户登录 //验证用户登录
@Value("${water.userUrl:}") @Value("${water.userUrl:}")
public String userUrl; public String userUrl;
@Value("${water.authUserServiceId:}")
public String authUserServiceId;
@Value("${water.authUserAppsecret:}")
public String authUserAppsecret;
@Value("${water.systemCode:}") @Value("${water.systemCode:}")
public String systemCode; public String systemCode;
@Value("${water.systemName:}") @Value("${water.systemName:}")
@ -65,79 +60,61 @@ public class WaterRequestUtil {
//获取部门信息 //获取部门信息
@Value("${water.orgUrl:}") @Value("${water.orgUrl:}")
public String orgUrl; public String orgUrl;
@Value("${water.orgServiceId:}")
public String orgServiceId;
@Value("${water.orgAppsecret:}")
public String orgAppsecret;
//业务角色 //业务角色
@Value("${water.roleUrl:}") @Value("${water.roleUrl:}")
public String roleUrl; public String roleUrl;
@Value("${water.roleServiceId:}")
public String roleServiceId;
@Value("${water.roleAppsecret:}")
public String roleAppsecret;
@Value("${water.systemUrl:}") @Value("${water.systemUrl:}")
public String systemUrl; public String systemUrl;
@Value("${water.systemServiceId:}")
public String systemServiceId;
@Value("${water.systemAppsecret:}")
public String systemAppsecret;
@Value("${water.usersUrl:}") @Value("${water.usersUrl:}")
public String usersUrl; public String usersUrl;
@Value("${water.usersServiceId:}")
public String usersServiceId;
@Value("${water.usersAppsecret:}")
public String usersAppsecret;
@Value("${water.resourceUrl:}") @Value("${water.resourceUrl:}")
public String resourceUrl; public String resourceUrl;
@Value("${water.resourceServiceId:}")
public String resourceServiceId;
@Value("${water.resourceAppsecret:}")
public String resourceAppsecret;
/** /**
* 设置 * 设置
* *
* @param httpRequest * @param httpRequest
* @param serviceId
* @param appsecret
*/ */
private void setHead(HttpRequest httpRequest, String serviceId, String appsecret) { private void setHead(HttpRequest httpRequest) {
String timestamp = String.valueOf(new Date().getTime()); String timestamp = String.valueOf(new Date().getTime());
String nonce = IdUtil.fastSimpleUUID(); String nonce = IdUtil.fastSimpleUUID();
String signature = timestamp + paasToken + nonce + timestamp; String gatewaySignature = timestamp + gatewayPaasToken + nonce + timestamp;
String centerSignature = timestamp + centerPaasToken + nonce + timestamp;
try { try {
signature = SHACoder.encodeSHA256Hex(signature).toUpperCase(); gatewaySignature = SHACoder.encodeSHA256Hex(gatewaySignature).toUpperCase();
centerSignature = SHACoder.encodeSHA256Hex(centerSignature).toUpperCase();
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
httpRequest httpRequest
.header("x-tsp-paasid", paasId) .header("x-tif-paasid", gatewayPaasId)
.header("x-tsp-signature", signature) .header("x-tif-signature", gatewaySignature)
.header("x-tif-timestamp", timestamp)
.header("x-tif-nonce", nonce)
.header("x-tsp-paasid", centerPaasId)
.header("x-tsp-signature", centerSignature)
.header("x-tsp-timestamp", timestamp) .header("x-tsp-timestamp", timestamp)
.header("x-tsp-nonce", nonce) .header("x-tsp-nonce", nonce);
.header("x-tsp-serviceid", serviceId)
.header("x-tsp-appsecret", appsecret);
} }
public HttpRequest createGet(String url, String serviceId, String appsecret) { public HttpRequest createGet(String url) {
HttpRequest httpRequest = HttpRequest.get(url); HttpRequest httpRequest = HttpRequest.get(url);
setHead(httpRequest, serviceId, appsecret); setHead(httpRequest);
return httpRequest; return httpRequest;
} }
public HttpRequest createPost(String url, String serviceId, String appsecret) { public HttpRequest createPost(String url) {
HttpRequest httpRequest = HttpRequest.post(url); HttpRequest httpRequest = HttpRequest.post(url);
setHead(httpRequest, serviceId, appsecret); setHead(httpRequest);
return httpRequest; return httpRequest;
} }
@ -148,7 +125,7 @@ public class WaterRequestUtil {
*/ */
public WaterResult systemPage() { public WaterResult systemPage() {
log.info("查询业务系统-----------------"); log.info("查询业务系统-----------------");
HttpRequest post = createPost(systemUrl, systemServiceId, systemAppsecret); HttpRequest post = createPost(systemUrl);
HashMap<String, String> query = new HashMap<>(); HashMap<String, String> query = new HashMap<>();
query.put("code", systemCode); query.put("code", systemCode);
query.put("name", systemName); query.put("name", systemName);
@ -193,9 +170,9 @@ public class WaterRequestUtil {
* @return * @return
*/ */
public WaterResult signOn(String userId) { public WaterResult signOn(String userId) {
HttpRequest get = createGet(userUrl, singOnServiceId, singOnAppsecret); HttpRequest get = createGet(userUrl);
String body; String body;
try (HttpResponse response = get.header("x-tsp-target", paasId) try (HttpResponse response = get.header("x-tsp-target", gatewayPaasId)
.header("x-tsp-uid-type", "id") .header("x-tsp-uid-type", "id")
.header("x-tsp-uid", userId) .header("x-tsp-uid", userId)
.execute()) { .execute()) {
@ -207,7 +184,7 @@ public class WaterRequestUtil {
public WaterResultV2<String> logout(String authorization) { public WaterResultV2<String> logout(String authorization) {
long startTime = System.currentTimeMillis(); long startTime = System.currentTimeMillis();
log.info("--------请求统一门户用户注销登陆,请求地址为:{}", logoutUrl); log.info("--------请求统一门户用户注销登陆,请求地址为:{}", logoutUrl);
HttpRequest get = createGet(logoutUrl, authUserServiceId, authUserAppsecret); HttpRequest get = createGet(logoutUrl);
String body; String body;
try (HttpResponse response = get.header("Authorization", authorization) try (HttpResponse response = get.header("Authorization", authorization)
.execute()) { .execute()) {
@ -230,7 +207,7 @@ public class WaterRequestUtil {
public WaterResultV2<WaterUser> authUser(String authorization) { public WaterResultV2<WaterUser> authUser(String authorization) {
long startTime = System.currentTimeMillis(); long startTime = System.currentTimeMillis();
log.info("--------请求统一门户用户验证,请求地址为:{}", userUrl); log.info("--------请求统一门户用户验证,请求地址为:{}", userUrl);
HttpRequest get = createGet(userUrl, authUserServiceId, authUserAppsecret); HttpRequest get = createGet(userUrl);
String body; String body;
try (HttpResponse response = get.header("Authorization", authorization) try (HttpResponse response = get.header("Authorization", authorization)
.execute()) { .execute()) {
@ -247,7 +224,7 @@ public class WaterRequestUtil {
public String getToken(String code) { public String getToken(String code) {
long startTime = System.currentTimeMillis(); long startTime = System.currentTimeMillis();
log.info("--------请求统一门户获取token,请求地址为:{}", accessTokenUrl); log.info("--------请求统一门户获取token,请求地址为:{}", accessTokenUrl);
HttpRequest get = createGet(accessTokenUrl, accessTokenServiceId, accessTokenAppsecret); HttpRequest get = createGet(accessTokenUrl);
String body; String body;
try (HttpResponse response = get.header("Authorization", code) try (HttpResponse response = get.header("Authorization", code)
.execute()) { .execute()) {
@ -288,7 +265,7 @@ public class WaterRequestUtil {
hashMap.put("page", 1); hashMap.put("page", 1);
hashMap.put("size", 100); hashMap.put("size", 100);
hashMap.put("systemCode", systemCode); hashMap.put("systemCode", systemCode);
HttpRequest get = createPost(orgUrl, orgServiceId, orgAppsecret); HttpRequest get = createPost(orgUrl);
String body; String body;
try (HttpResponse response = get.body(JSONObject.toJSONString(hashMap)) try (HttpResponse response = get.body(JSONObject.toJSONString(hashMap))
.execute()) { .execute()) {
@ -315,7 +292,7 @@ public class WaterRequestUtil {
//计算请求消耗的时间 //计算请求消耗的时间
long startTime = System.currentTimeMillis(); long startTime = System.currentTimeMillis();
log.info("--------请求获取门户用户资源信息,请求地址为:{}", resourceUrl); log.info("--------请求获取门户用户资源信息,请求地址为:{}", resourceUrl);
HttpRequest get = createPost(resourceUrl + "?systemCode=" + systemCode, resourceServiceId, resourceAppsecret); HttpRequest get = createPost(resourceUrl + "?systemCode=" + systemCode);
get.header("Authorization", authorization); get.header("Authorization", authorization);
String body; String body;
try (HttpResponse response = get.execute()) { try (HttpResponse response = get.execute()) {
@ -338,7 +315,7 @@ public class WaterRequestUtil {
hashMap.put("page", 1); hashMap.put("page", 1);
hashMap.put("size", 1000); hashMap.put("size", 1000);
hashMap.put("systemCode", systemCode); hashMap.put("systemCode", systemCode);
HttpRequest get = createPost(roleUrl, roleServiceId, roleAppsecret); HttpRequest get = createPost(roleUrl);
String body; String body;
try (HttpResponse response = get.body(JSONObject.toJSONString(hashMap)) try (HttpResponse response = get.body(JSONObject.toJSONString(hashMap))
.execute()) { .execute()) {
@ -358,7 +335,7 @@ public class WaterRequestUtil {
hashMap.put("page", 1); hashMap.put("page", 1);
hashMap.put("size", 100); hashMap.put("size", 100);
hashMap.put("systemCode", systemCode); hashMap.put("systemCode", systemCode);
HttpRequest get = createPost(usersUrl, usersServiceId, usersAppsecret); HttpRequest get = createPost(usersUrl);
String body; String body;
try (HttpResponse response = get.body(JSONObject.toJSONString(hashMap)) try (HttpResponse response = get.body(JSONObject.toJSONString(hashMap))
.execute()) { .execute()) {

Loading…
Cancel
Save