From e050a2ab2fa176ebd0d2461681a41df34838c028 Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期三, 07 六月 2023 11:11:17 +0800
Subject: [PATCH] add comment
---
springboot/src/main/java/com/java110/boot/smo/impl/ApiServiceSMOImpl.java | 50 +++++++++++++++++++++++++++++++-------------------
1 files changed, 31 insertions(+), 19 deletions(-)
diff --git a/springboot/src/main/java/com/java110/boot/smo/impl/ApiServiceSMOImpl.java b/springboot/src/main/java/com/java110/boot/smo/impl/ApiServiceSMOImpl.java
index 2b51f56..bef9672 100644
--- a/springboot/src/main/java/com/java110/boot/smo/impl/ApiServiceSMOImpl.java
+++ b/springboot/src/main/java/com/java110/boot/smo/impl/ApiServiceSMOImpl.java
@@ -85,21 +85,21 @@
String resJson = "";
try {
- //鍦╬ost鍜� put 鏃舵墠瀛樺湪鎶ユ枃鍔犲瘑鐨勬儏鍐�
+ //todo 鍦╬ost鍜� put 鏃舵墠瀛樺湪鎶ユ枃鍔犲瘑鐨勬儏鍐�
if ("POST,PUT".contains(headers.get(CommonConstant.HTTP_METHOD))) {
reqJson = decrypt(reqJson, headers);
}
- //1.0 鍒涘缓鏁版嵁娴� appId serviceCode
+ //todo 1.0 鍒涘缓鏁版嵁娴� appId serviceCode
dataFlow = DataFlowFactory.newInstance(ApiDataFlow.class).builder(reqJson, headers);
- //2.0 鍔犺浇閰嶇疆淇℃伅
+ //todo 2.0 鍔犺浇閰嶇疆淇℃伅
initConfigData(dataFlow);
- //3.0 鏍￠獙 APPID鏄惁鏈夋潈闄愭搷浣渟erviceCode
+ //todo 3.0 鏍￠獙 APPID鏄惁鏈夋潈闄愭搷浣渟erviceCode
judgeAuthority(dataFlow);
- //6.0 璋冪敤涓嬫父绯荤粺
+ //todo 6.0 璋冪敤涓嬫父绯荤粺
invokeBusinessSystem(dataFlow);
responseEntity = dataFlow.getResponseEntity();
@@ -328,13 +328,13 @@
DataFlowFactory.addCostTime(dataFlow, "judgeAuthority", "閴存潈鑰楁椂", startDate);
throw new NoAuthorityException(ResponseConstant.RESULT_CODE_NO_AUTHORITY_ERROR, "requestTime 鏍煎紡涓嶅锛岄伒寰獃yyyMMddHHmmss鏍煎紡");
}
- //鐢ㄦ埛ID鏍￠獙
+ //todo 鐢ㄦ埛ID鏍￠獙
if (StringUtil.isNullOrNone(dataFlow.getUserId())) {
throw new NoAuthorityException(ResponseConstant.RESULT_CODE_NO_AUTHORITY_ERROR, "USER_ID 涓嶈兘涓虹┖");
}
- //鍒ゆ柇 AppId 鏄惁鏈夋潈闄愭搷浣滅浉搴旂殑鏈嶅姟
+ //todo 鍒ゆ柇 AppId 鏄惁鏈夋潈闄愭搷浣滅浉搴旂殑鏈嶅姟
AppService appService = DataFlowFactory.getService(dataFlow, dataFlow.getRequestHeaders().get(CommonConstant.HTTP_SERVICE));
//杩欓噷璋冪敤缂撳瓨 鏌ヨ缂撳瓨淇℃伅
@@ -373,9 +373,9 @@
*/
private void invokeBusinessSystem(ApiDataFlow dataFlow) throws BusinessException {
Date startDate = DateUtil.getCurrentDate();
- //鎷垮埌褰撳墠鏈嶅姟
+ //todo 鎷垮埌褰撳墠鏈嶅姟
AppService appService = DataFlowFactory.getService(dataFlow, dataFlow.getRequestHeaders().get(CommonConstant.HTTP_SERVICE));
- //杩欓噷瀵归�忎紶绫诲鐞�
+ //todo 杩欓噷瀵归�忎紶绫诲鐞�,鐩墠寰堝皯鐢ㄥ埌锛屽彲浠ヤ笉鐢ㄥ叧娉�
if ("NT".equals(appService.getIsInstance())) {
//濡傛灉鏄�忎紶绫� 璇锋眰鏂瑰紡蹇呴』涓庢帴鍙ｆ彁渚涙柟璋冪敤鏂瑰紡涓�鑷�
String httpMethod = dataFlow.getRequestCurrentHeaders().get(CommonConstant.HTTP_METHOD);
@@ -386,8 +386,8 @@
//dataFlow.setApiCurrentService(ServiceCodeConstant.SERVICE_CODE_DO_SERVICE_TRANSFER);
doNT(appService, dataFlow, dataFlow.getReqJson());
return;
- } else if ("T".equals(appService.getIsInstance())) {
- //濡傛灉鏄�忎紶绫� 璇锋眰鏂瑰紡蹇呴』涓庢帴鍙ｆ彁渚涙柟璋冪敤鏂瑰紡涓�鑷�
+ } else if ("T".equals(appService.getIsInstance())) { // todo 閫氳繃閫忎紶鏂瑰紡 璋冪敤 鐩墠寰堝皯鐢ㄥ埌锛屽彲浠ヤ笉鐢ㄥ叧娉�
+ //todo 濡傛灉鏄�忎紶绫� 璇锋眰鏂瑰紡蹇呴』涓庢帴鍙ｆ彁渚涙柟璋冪敤鏂瑰紡涓�鑷�
String httpMethod = dataFlow.getRequestCurrentHeaders().get(CommonConstant.HTTP_METHOD);
if (!appService.getMethod().equals(httpMethod)) {
throw new ListenerExecuteException(ResponseConstant.RESULT_CODE_ERROR,
@@ -395,13 +395,14 @@
}
doTransfer(appService, dataFlow, dataFlow.getReqJson());
return;
- } else if ("CMD".equals(appService.getIsInstance())) {
+ } else if ("CMD".equals(appService.getIsInstance())) { // todo 寰湇鍔¤皟鐢ㄦ柟寮忥紝鐩墠涓昏鐢ㄨ繖绉嶆柟寮忚皟搴﹀垎鍙� 鍒颁笉鍚岀殑寰湇鍔★紝杩欓噷鏄�氳繃c_service 涓厤缃� 璋冪敤鍒颁笉鍚岀殑寰湇鍔�
//濡傛灉鏄�忎紶绫� 璇锋眰鏂瑰紡蹇呴』涓庢帴鍙ｆ彁渚涙柟璋冪敤鏂瑰紡涓�鑷�
String httpMethod = dataFlow.getRequestCurrentHeaders().get(CommonConstant.HTTP_METHOD);
if (!appService.getMethod().equals(httpMethod)) {
throw new ListenerExecuteException(ResponseConstant.RESULT_CODE_ERROR,
"鏈嶅姟銆�" + appService.getServiceCode() + "銆戣皟鐢ㄦ柟寮忎笉瀵硅妫�鏌�,褰撳墠璇锋眰鏂瑰紡涓猴細" + httpMethod);
}
+ // todo 鏍规嵁鎺ュ彛缂栫爜鎵惧埌 appService 涔熷氨鏄痗_service 琛ㄤ腑鐨勫唴瀹�
dealCmd(appService, dataFlow, dataFlow.getReqJson());
return;
} else {
@@ -503,11 +504,11 @@
oId = headers.get(OrderDto.O_ID).get(0);
}
- //杩涘叆databus
- if (!CommonConstant.HTTP_METHOD_GET.equals(appService.getMethod())) {
-
- // dealDatabus(serviceCode, reqJson, oId);
- }
+// //杩涘叆databus
+// if (!CommonConstant.HTTP_METHOD_GET.equals(appService.getMethod())) {
+//
+// // dealDatabus(serviceCode, reqJson, oId);
+// }
} catch (HttpStatusCodeException e) { //杩欓噷spring 妗嗘灦 鍦�4XX 鎴� 5XX 鏃舵姏鍑� HttpServerErrorException 寮傚父锛岄渶瑕侀噸鏂板皝瑁呬竴涓�
@@ -545,12 +546,20 @@
dataFlow.setResponseEntity(responseEntity);
}
+ /**
+ * 寮�濮嬭皟搴﹀井鏈嶅姟
+ * @param appService
+ * @param dataFlow
+ * @param reqJson
+ */
private void dealCmd(AppService appService, ApiDataFlow dataFlow, JSONObject reqJson) {
Map<String, String> reqHeader = dataFlow.getRequestCurrentHeaders();
HttpHeaders header = new HttpHeaders();
+ //todo 瀵瑰ご淇℃伅閲嶆柊鍖呰
for (String key : dataFlow.getRequestCurrentHeaders().keySet()) {
header.add(key, reqHeader.get(key));
}
+ //todo 鐢ㄦ埛淇℃伅鍐嶆鍖呰
if (reqHeader.containsKey(CommonConstant.USER_ID)
&& (!reqJson.containsKey("userId") || StringUtil.isEmpty(reqJson.getString("userId")))) {
reqJson.put("userId", reqHeader.get(CommonConstant.USER_ID));
@@ -570,14 +579,18 @@
serviceCode = serviceCode.startsWith("/") ? serviceCode : ("/" + serviceCode);
+ //todo 缁勮璋冪敤寰湇鍔＄殑鍦板潃
String requestUrl = "http://127.0.0.1:8008/cmd" + serviceCode;
//
ResponseEntity responseEntity = null;
+ //todo url 甯︿簡鍦板潃杩欓噷 鎷兼帴
if (!StringUtil.isNullOrNone(orgRequestUrl)) {
String param = orgRequestUrl.contains("?") ? orgRequestUrl.substring(orgRequestUrl.indexOf("?") + 1, orgRequestUrl.length()) : "";
requestUrl += ("?" + param);
}
try {
+ //todo http鐨勬柟寮忚皟鐢ㄥ井鏈嶅姟锛岀浉搴旂殑java绫诲彲浠ュ埌鐩稿簲寰湇鍔′笅鐨刢md涓嬫牴鎹畇erviceCode 鐨勫鎵�
+ //todo 杩欓噷浼氳皟鐢ㄥ埌 java110-service 妯″潡涓嬬殑 CmdApi 绫伙紝杩欎釜绫诲悇涓井鏈嶅姟閮戒細闆嗘垚
responseEntity = outRestTemplate.exchange(requestUrl, HttpMethod.POST, httpEntity, String.class);
HttpHeaders headers = responseEntity.getHeaders();
String oId = "-1";
@@ -585,7 +598,7 @@
oId = headers.get(OrderDto.O_ID).get(0);
}
- } catch (HttpStatusCodeException e) { //杩欓噷spring 妗嗘灦 鍦�4XX 鎴� 5XX 鏃舵姏鍑� HttpServerErrorException 寮傚父锛岄渶瑕侀噸鏂板皝瑁呬竴涓�
+ } catch (HttpStatusCodeException e) { //todo 杩欓噷spring 妗嗘灦 鍦�4XX 鎴� 5XX 鏃舵姏鍑� HttpServerErrorException 寮傚父锛岄渶瑕侀噸鏂板皝瑁呬竴涓�
logger.error("璇锋眰涓嬫父鏈嶅姟銆�" + requestUrl + "銆戝紓甯革紝鍙傛暟涓�" + httpEntity + e.getResponseBodyAsString(), e);
String body = e.getResponseBodyAsString();
@@ -603,7 +616,6 @@
if (responseEntity.getStatusCode() != HttpStatus.OK) {
responseEntity = ResultVo.createResponseEntity(ResultVo.CODE_ERROR, String.valueOf(responseEntity.getBody()));
dataFlow.setResponseEntity(responseEntity);
-
return;
}
if (StringUtils.isEmpty(responseEntity.getBody() + "")) {
--
Gitblit v1.8.0