From 3ee0aee46457c3ec5546e077a91b290c0e0d15e8 Mon Sep 17 00:00:00 2001
From: chengf <2156125618@qq.com>
Date: 星期五, 01 八月 2025 18:16:19 +0800
Subject: [PATCH] 修复查询车位sql、查询业主账户等bug2025/07/31
---
service-api/src/main/java/com/java110/api/smo/DefaultAbstractComponentSMO.java | 71 +++++++++++++++++------------------
1 files changed, 34 insertions(+), 37 deletions(-)
diff --git a/service-api/src/main/java/com/java110/api/smo/DefaultAbstractComponentSMO.java b/service-api/src/main/java/com/java110/api/smo/DefaultAbstractComponentSMO.java
index 739afe5..f6a1c2d 100644
--- a/service-api/src/main/java/com/java110/api/smo/DefaultAbstractComponentSMO.java
+++ b/service-api/src/main/java/com/java110/api/smo/DefaultAbstractComponentSMO.java
@@ -3,13 +3,17 @@
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.api.properties.WechatAuthProperties;
+import com.java110.api.smo.IApiServiceSMO;
+import com.java110.api.smo.IGetCommunityStoreInfoSMO;
import com.java110.core.component.AbstractComponentSMO;
import com.java110.core.context.IPageData;
-import com.java110.core.context.SecureInvocation;
+import com.java110.core.factory.AuthenticationFactory;
import com.java110.core.factory.GenerateCodeFactory;
-import com.java110.dto.basePrivilege.BasePrivilegeDto;
+import com.java110.core.log.LoggerFactory;
+import com.java110.dto.privilege.BasePrivilegeDto;
+import com.java110.dto.store.StoreDto;
import com.java110.dto.user.UserDto;
-import com.java110.entity.component.ComponentValidateResult;
+import com.java110.dto.system.ComponentValidateResult;
import com.java110.intf.user.IUserInnerServiceSMO;
import com.java110.utils.cache.PrivilegeCache;
import com.java110.utils.constant.CommonConstant;
@@ -20,7 +24,6 @@
import com.java110.utils.util.*;
import com.java110.vo.ResultVo;
import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpMethod;
import org.springframework.http.HttpStatus;
@@ -88,20 +91,18 @@
headers.put(CommonConstant.USER_ID, StringUtil.isEmpty(pd.getUserId()) ? "-1" : pd.getUserId());
- if (!headers.containsKey(CommonConstant.HTTP_USER_ID)) {
- headers.put(CommonConstant.HTTP_USER_ID, StringUtil.isEmpty(pd.getUserId()) ? "-1" : pd.getUserId());
- }
if (!headers.containsKey(CommonConstant.HTTP_APP_ID)) {
headers.put(CommonConstant.HTTP_APP_ID, pd.getAppId());
}
+ if (!headers.containsKey(CommonConstant.APP_ID)) {
+ headers.put(CommonConstant.APP_ID, pd.getAppId());
+ }
+
if (!headers.containsKey(CommonConstant.HTTP_TRANSACTION_ID)) {
headers.put(CommonConstant.HTTP_TRANSACTION_ID, GenerateCodeFactory.getUUID());
}
if (!headers.containsKey(CommonConstant.HTTP_REQ_TIME)) {
headers.put(CommonConstant.HTTP_REQ_TIME, DateUtil.getNowDefault());
- }
- if (!headers.containsKey(CommonConstant.HTTP_SIGN)) {
- headers.put(CommonConstant.HTTP_SIGN, "");
}
if (url.indexOf("?") > -1) {
@@ -109,13 +110,14 @@
}
headers.put(CommonConstant.HTTP_SERVICE, url);
headers.put(CommonConstant.HTTP_METHOD, CommonConstant.getHttpMethodStr(httpMethod));
-
if (HttpMethod.GET == httpMethod) {
initUrlParam(JSONObject.parseObject(param), headers);
- }
- if (HttpMethod.GET == httpMethod) {
headers.put("REQUEST_URL", "http://127.0.0.1:8008/" + url + mapToUrlParam(JSONObject.parseObject(param)));
+ } else {
+ headers.put("REQUEST_URL", "http://127.0.0.1:8008/" + url);
}
+ AuthenticationFactory.createSign(headers, httpMethod, headers.get("REQUEST_URL"), param);
+
try {
responseEntity = apiServiceSMOImpl.service(param, headers);
} catch (HttpStatusCodeException e) { //杩欓噷spring 妗嗘灦 鍦�4XX 鎴� 5XX 鏃舵姏鍑� HttpServerErrorException 寮傚父锛岄渶瑕侀噸鏂板皝瑁呬竴涓�
@@ -144,19 +146,14 @@
headers.put(CommonConstant.HTTP_USER_ID, "-1");
}
- headers.put(CommonConstant.USER_ID, "-1");
-
- if (!headers.containsKey(CommonConstant.HTTP_USER_ID)) {
- headers.put(CommonConstant.HTTP_USER_ID, "-1");
+ if (!headers.containsKey(CommonConstant.USER_ID)) {
+ headers.put(CommonConstant.USER_ID, headers.get(CommonConstant.HTTP_USER_ID));
}
if (!headers.containsKey(CommonConstant.HTTP_TRANSACTION_ID)) {
headers.put(CommonConstant.HTTP_TRANSACTION_ID, GenerateCodeFactory.getUUID());
}
if (!headers.containsKey(CommonConstant.HTTP_REQ_TIME)) {
headers.put(CommonConstant.HTTP_REQ_TIME, DateUtil.getNowDefault());
- }
- if (!headers.containsKey(CommonConstant.HTTP_SIGN)) {
- headers.put(CommonConstant.HTTP_SIGN, "");
}
if (url.indexOf("?") > -1) {
@@ -170,7 +167,11 @@
}
if (HttpMethod.GET == httpMethod) {
headers.put("REQUEST_URL", "http://127.0.0.1:8008/" + url + mapToUrlParam(JSONObject.parseObject(param)));
+ }else {
+ headers.put("REQUEST_URL", "http://127.0.0.1:8008/" + url);
}
+ AuthenticationFactory.createSign(headers, httpMethod, headers.get("REQUEST_URL"), param);
+
try {
responseEntity = apiServiceSMOImpl.service(param, headers);
} catch (HttpStatusCodeException e) { //杩欓噷spring 妗嗘灦 鍦�4XX 鎴� 5XX 鏃舵姏鍑� HttpServerErrorException 寮傚父锛岄渶瑕侀噸鏂板皝瑁呬竴涓�
@@ -383,10 +384,6 @@
return new ResponseEntity<String>(resultVo.getMsg(), resultVo.getCode() == ResultVo.CODE_OK ? HttpStatus.OK : HttpStatus.BAD_REQUEST);
}
- private ResponseEntity<String> getStoreEnterCommunitys(IPageData pd, String storeId, String storeTypeCd, RestTemplate restTemplate) {
- ResultVo resultVo = getCommunityStoreInfoSMOImpl.getStoreEnterCommunitys(pd, storeId, storeTypeCd, restTemplate);
- return new ResponseEntity<String>(resultVo.getMsg(), resultVo.getCode() == ResultVo.CODE_OK ? HttpStatus.OK : HttpStatus.BAD_REQUEST);
- }
/**
* 鏌ヨ鍟嗘埛淇℃伅
@@ -395,17 +392,12 @@
*/
protected void checkStoreEnterCommunity(IPageData pd, String storeId, String storeTypeCd, String communityId, RestTemplate restTemplate) {
Assert.hasLength(pd.getUserId(), "鐢ㄦ埛鏈櫥褰曡鍏堢櫥褰�");
- ResponseEntity<String> responseEntity = null;
- responseEntity = getStoreEnterCommunitys(pd, storeId, storeTypeCd, restTemplate);
- if (responseEntity.getStatusCode() != HttpStatus.OK) {
+ ResultVo resultVo = getCommunityStoreInfoSMOImpl.getStoreEnterCommunitys(pd, storeId, storeTypeCd, restTemplate);
+ if (resultVo.getCode() != ResultVo.CODE_OK) {
throw new SMOException(ResponseConstant.RESULT_CODE_ERROR, "杩樻湭鍏ラ┗灏忓尯锛岃鍏堝叆椹诲皬鍖�");
}
- Assert.jsonObjectHaveKey(responseEntity.getBody().toString(), "data", "杩樻湭鍏ラ┗灏忓尯锛岃鍏堝叆椹诲皬鍖�");
-
- JSONObject community = JSONObject.parseObject(responseEntity.getBody().toString());
-
- JSONArray communitys = community.getJSONArray("data");
+ JSONArray communitys = JSONArray.parseArray(resultVo.getData().toString());
if (communitys == null || communitys.size() == 0) {
throw new SMOException(ResponseConstant.RESULT_CODE_ERROR, "杩樻湭鍏ラ┗灏忓尯锛岃鍏堝叆椹诲皬鍖�");
@@ -467,7 +459,12 @@
JSONObject paramIn = JSONObject.parseObject(pd.getReqData());
String communityId = "";
- if (paramIn.containsKey("communityId") && !StringUtil.isEmpty(paramIn.getString("communityId"))) {
+ if (paramIn.containsKey("communityId")
+ && !StringUtil.isEmpty(paramIn.getString("communityId"))
+ && !"-1".equals(paramIn.getString("communityId"))
+ && !StoreDto.STORE_TYPE_ADMIN.equals(storeTypeCd)
+ && !StoreDto.STORE_TYPE_DEV.equals(storeTypeCd)
+ ) {
communityId = paramIn.getString("communityId");
checkStoreEnterCommunity(pd, storeId, storeTypeCd, communityId, restTemplate);
}
@@ -565,16 +562,16 @@
ResponseEntity<String> responseEntity = callCenterService(restTemplate, pd, JSONObject.toJSONString(param), url, HttpMethod.POST);
- if (responseEntity.getStatusCode() != HttpStatus.OK) {
- throw new SMOException("璋冪敤" + serviceCode + "澶辫触锛�" + responseEntity.getBody());
- }
-
JSONObject resultVo = JSONObject.parseObject(responseEntity.getBody());
if (ResultVo.CODE_MACHINE_OK != resultVo.getInteger("code")) {
throw new SMOException(resultVo.getString("msg"));
}
+ if (responseEntity.getStatusCode() != HttpStatus.OK) {
+ throw new SMOException(resultVo.getString("msg"));
+ }
+
Object bObj = resultVo.get("data");
JSONArray datas = null;
if (bObj instanceof JSONObject) {
--
Gitblit v1.8.0