From 73d769f8394036291b679e4e645d1af0a9f5db99 Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期日, 12 九月 2021 22:39:02 +0800
Subject: [PATCH] cmd 调试完成
---
service-api/src/main/java/com/java110/api/smo/DefaultAbstractComponentSMO.java | 188 +++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 183 insertions(+), 5 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 8e4555b..e422877 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
@@ -1,9 +1,13 @@
package com.java110.api.smo;
+import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.api.properties.WechatAuthProperties;
import com.java110.core.component.AbstractComponentSMO;
import com.java110.core.context.IPageData;
+import com.java110.dto.basePrivilege.BasePrivilegeDto;
+import com.java110.entity.component.ComponentValidateResult;
+import com.java110.utils.cache.PrivilegeCache;
import com.java110.utils.constant.CommonConstant;
import com.java110.utils.constant.ResponseConstant;
import com.java110.utils.constant.ServiceCodeConstant;
@@ -12,6 +16,7 @@
import com.java110.utils.util.Assert;
import com.java110.utils.util.StringUtil;
import com.java110.utils.util.UrlParamToJsonUtil;
+import com.java110.vo.ResultVo;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -21,15 +26,17 @@
import org.springframework.web.client.HttpStatusCodeException;
import org.springframework.web.client.RestTemplate;
-import java.util.HashMap;
-import java.util.Iterator;
-import java.util.Map;
-import java.util.Set;
+import java.util.*;
public class DefaultAbstractComponentSMO extends AbstractComponentSMO {
private static final Logger logger = LoggerFactory.getLogger(DefaultAbstractComponentSMO.class);
protected static final String DEFAULT_PAY_ADAPT = "wechatPayAdapt";// 榛樿寰俊閫氱敤鏀粯
+
+ @Autowired
+ private IGetCommunityStoreInfoSMO getCommunityStoreInfoSMOImpl;
+
+
@Autowired
private WechatAuthProperties wechatAuthProperties;
@@ -223,7 +230,7 @@
}
for (String privilegeCode : privilegeCodes) {
responseEntity = this.callCenterService(restTemplate, pd, "", ServiceConstant.SERVICE_API_URL
- + "/api/check.user.hasPrivilege?userId=" + pd.getUserId() + "&pId=" + privilegeCode, HttpMethod.GET);
+ + "check.user.hasPrivilege?userId=" + pd.getUserId() + "&pId=" + privilegeCode, HttpMethod.GET);
if (responseEntity.getStatusCode() == HttpStatus.OK) {
//throw new SMOException(ResponseConstant.RESULT_CODE_ERROR, "鐢ㄦ埛娌℃湁鏉冮檺鎿嶄綔鏉冮檺" + privilegeCodes);
break;
@@ -234,4 +241,175 @@
throw new SMOException(ResponseConstant.RESULT_CODE_ERROR, "鐢ㄦ埛娌℃湁鏉冮檺鎿嶄綔鏉冮檺" + privilegeCodes);
}
}
+
+ protected void hasPrivilege(RestTemplate restTemplate, IPageData pd, String resource) {
+ ResponseEntity<String> responseEntity = null;
+ //娌℃湁鐢ㄦ埛鐨勬儏鍐典笅涓嶅仛鏉冮檺鍒ゆ柇
+ if (StringUtil.isEmpty(pd.getUserId())) {
+ return;
+ }
+ JSONObject paramIn = new JSONObject();
+ //paramIn.put("resource", resource);
+ paramIn.put("userId", pd.getUserId());
+
+ //鏍￠獙璧勬簮璺姴鏄惁瀹氫箟鏉冮檺
+ List<BasePrivilegeDto> basePrivilegeDtos = PrivilegeCache.getPrivileges();
+ if (basePrivilegeDtos == null || basePrivilegeDtos.size() < 1) {
+ return;
+ }
+ String tmpResource = null;
+ boolean hasPrivilege = false;
+ for (BasePrivilegeDto privilegeDto : basePrivilegeDtos) {
+ if (resource.equals(privilegeDto.getResource())) {
+ hasPrivilege = true;
+ }
+ }
+ if (!hasPrivilege) { //鏉冮檺娌℃湁閰嶇疆锛岀洿鎺ヨ烦杩�
+ return;
+ }
+
+ ResultVo resultVo = getCommunityStoreInfoSMOImpl.checkUserHasResourceListener(restTemplate, pd, paramIn, pd.getUserId());
+ if (resultVo == null || resultVo.getCode() != ResultVo.CODE_OK) {
+ throw new UnsupportedOperationException("鐢ㄦ埛娌℃湁鏉冮檺鎿嶄綔");
+ }
+ JSONArray privileges = JSONArray.parseArray(resultVo.getMsg());
+
+ hasPrivilege = false;
+ if (privileges == null || privileges.size() < 1) {
+ throw new UnsupportedOperationException("鐢ㄦ埛娌℃湁鏉冮檺鎿嶄綔");
+ }
+ for (int privilegeIndex = 0; privilegeIndex < privileges.size(); privilegeIndex++) {
+ tmpResource = privileges.getJSONObject(privilegeIndex).getString("resource");
+ if (resource.equals(tmpResource)) {
+ hasPrivilege = true;
+ break;
+ }
+ }
+ if (!hasPrivilege) {
+ throw new UnsupportedOperationException("鐢ㄦ埛娌℃湁鏉冮檺鎿嶄綔");
+ }
+
+ }
+
+ /**
+ * 鏌ヨ鍟嗘埛淇℃伅
+ *
+ * @return
+ */
+ protected ResponseEntity<String> getStoreInfo(IPageData pd, RestTemplate restTemplate) {
+ Assert.hasLength(pd.getUserId(), "鐢ㄦ埛鏈櫥褰曡鍏堢櫥褰�");
+
+ ResultVo resultVo = getCommunityStoreInfoSMOImpl.getStoreInfo(pd, restTemplate, pd.getUserId());
+
+ 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);
+ }
+
+ /**
+ * 鏌ヨ鍟嗘埛淇℃伅
+ *
+ * @return
+ */
+ 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) {
+ 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");
+
+ if (communitys == null || communitys.size() == 0) {
+ throw new SMOException(ResponseConstant.RESULT_CODE_ERROR, "杩樻湭鍏ラ┗灏忓尯锛岃鍏堝叆椹诲皬鍖�");
+ }
+
+ JSONObject currentCommunity = getCurrentCommunity(communitys, communityId);
+
+ if (currentCommunity == null) {
+ throw new SMOException(ResponseConstant.RESULT_CODE_ERROR, "浼犲叆灏忓尯ID闈炴硶锛岃姝ｅ父鎿嶄綔");
+ }
+
+ }
+
+
+
+
+ private JSONObject getCurrentCommunity(JSONArray communitys, String communityId) {
+ for (int communityIndex = 0; communityIndex < communitys.size(); communityIndex++) {
+ if (communityId.equals(communitys.getJSONObject(communityIndex).getString("communityId"))) {
+ return communitys.getJSONObject(communityIndex);
+ }
+ }
+
+ return null;
+ }
+
+ /**
+ * 鏍￠獙 鍛樺伐 鍟嗘埛 灏忓尯 鍏崇郴
+ * <p>
+ * 鍒ゆ柇鍛樺伐鍜屽晢鎴锋槸鍚︽湁鍏崇郴锛� 鍟嗘埛鍜� 灏忓尯鏄惁鏈夊叧绯�
+ *
+ * @param pd 椤甸潰鏁版嵁灏佽
+ * @param restTemplate http璋冪敤宸ュ叿
+ * @return ComponentValidateResult 鏍￠獙瀵硅薄
+ */
+ protected ComponentValidateResult validateStoreStaffCommunityRelationship(IPageData pd, RestTemplate restTemplate) {
+
+ // 鏍￠獙 鍛樺伐鍜屽晢鎴锋槸鍚︽湁鍏崇郴
+ ResponseEntity responseEntity = getStoreInfo(pd, restTemplate);
+ if (responseEntity.getStatusCode() != HttpStatus.OK) {
+ throw new SMOException(ResponseConstant.RESULT_CODE_ERROR, responseEntity.getBody() + "");
+ }
+
+ Assert.jsonObjectHaveKey(responseEntity.getBody().toString(), "storeId", "鏍规嵁鐢ㄦ埛ID鏌ヨ鍟嗘埛ID澶辫触锛屾湭鍖呭惈storeId鑺傜偣");
+ Assert.jsonObjectHaveKey(responseEntity.getBody().toString(), "storeTypeCd", "鏍规嵁鐢ㄦ埛ID鏌ヨ鍟嗘埛绫诲瀷澶辫触锛屾湭鍖呭惈storeTypeCd鑺傜偣");
+
+ String storeId = JSONObject.parseObject(responseEntity.getBody().toString()).getString("storeId");
+ String storeTypeCd = JSONObject.parseObject(responseEntity.getBody().toString()).getString("storeTypeCd");
+
+ JSONObject paramIn = JSONObject.parseObject(pd.getReqData());
+
+ String communityId = "";
+ if (paramIn.containsKey("communityId") && !StringUtil.isEmpty(paramIn.getString("communityId"))) {
+ communityId = paramIn.getString("communityId");
+ checkStoreEnterCommunity(pd, storeId, storeTypeCd, communityId, restTemplate);
+ }
+ return new ComponentValidateResult(storeId, storeTypeCd, communityId, pd.getUserId(), pd.getUserName());
+ }
+
+ /**
+ * 鏍￠獙 鍛樺伐 鍟嗘埛 鍏崇郴
+ * <p>
+ * 鍒ゆ柇鍛樺伐鍜屽晢鎴锋槸鍚︽湁鍏崇郴锛� 鍟嗘埛鍜� 鏄惁鏈夊叧绯�
+ *
+ * @param pd 椤甸潰鏁版嵁灏佽
+ * @param restTemplate http璋冪敤宸ュ叿
+ * @return ComponentValidateResult 鏍￠獙瀵硅薄
+ */
+ protected ComponentValidateResult validateStoreStaffRelationship(IPageData pd, RestTemplate restTemplate) {
+
+ // 鏍￠獙 鍛樺伐鍜屽晢鎴锋槸鍚︽湁鍏崇郴
+ ResponseEntity responseEntity = getStoreInfo(pd, restTemplate);
+ if (responseEntity.getStatusCode() != HttpStatus.OK) {
+ throw new SMOException(ResponseConstant.RESULT_CODE_ERROR, responseEntity.getBody() + "");
+ }
+
+ Assert.jsonObjectHaveKey(responseEntity.getBody().toString(), "storeId", "鏍规嵁鐢ㄦ埛ID鏌ヨ鍟嗘埛ID澶辫触锛屾湭鍖呭惈storeId鑺傜偣");
+ Assert.jsonObjectHaveKey(responseEntity.getBody().toString(), "storeTypeCd", "鏍规嵁鐢ㄦ埛ID鏌ヨ鍟嗘埛绫诲瀷澶辫触锛屾湭鍖呭惈storeTypeCd鑺傜偣");
+
+ String storeId = JSONObject.parseObject(responseEntity.getBody().toString()).getString("storeId");
+ String storeTypeCd = JSONObject.parseObject(responseEntity.getBody().toString()).getString("storeTypeCd");
+
+ return new ComponentValidateResult(storeId, storeTypeCd, "", pd.getUserId(), pd.getUserName());
+ }
+
}
--
Gitblit v1.8.0