GetCommunityStoreInfoSMOImpl.java
5.46 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
package com.java110.api.smo;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.core.cache.Java110RedisConfig;
import com.java110.core.context.IPageData;
import com.java110.core.context.SecureInvocation;
import com.java110.utils.cache.MappingCache;
import com.java110.utils.constant.MappingConstant;
import com.java110.utils.util.Assert;
import com.java110.utils.util.StringUtil;
import com.java110.vo.ResultVo;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.http.HttpMethod;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
@Service
public class GetCommunityStoreInfoSMOImpl extends DefaultAbstractComponentSMO implements IGetCommunityStoreInfoSMO {
private static final String BASE_PRIVILEGE = "JAVA110_BASE_PRIVILEGE";
@Override
@Cacheable(value = "getStoreInfo" + Java110RedisConfig.GET_STORE_INFO_EXPIRE_TIME_KEY, key = "#userId")
public ResultVo getStoreInfo(IPageData pd, RestTemplate restTemplate, String userId) {
Assert.hasLength(pd.getUserId(), "用户未登录请先登录");
ResponseEntity<String> responseEntity = null;
responseEntity = super.callCenterService(restTemplate, pd, "", "query.store.byuser?userId=" + userId, HttpMethod.GET);
if (responseEntity.getStatusCode() != HttpStatus.OK) {
throw new IllegalArgumentException(responseEntity.getBody());
}
if(!StringUtil.isJsonObject(responseEntity.getBody())){
//return new ResultVo(responseEntity.getStatusCode() == HttpStatus.OK ? ResultVo.CODE_OK : ResultVo.CODE_ERROR, responseEntity.getBody());
throw new IllegalArgumentException(responseEntity.getBody());
}
JSONObject paramJson = JSONObject.parseObject(responseEntity.getBody());
if(paramJson.containsKey("code") && paramJson.getIntValue("code") != 0){
throw new IllegalArgumentException(paramJson.getString("msg"));
}
return new ResultVo(responseEntity.getStatusCode() == HttpStatus.OK ? ResultVo.CODE_OK : ResultVo.CODE_ERROR, responseEntity.getBody(),responseEntity.getBody());
}
@Override
@Cacheable(value = "getStoreEnterCommunitys" + Java110RedisConfig.GET_STORE_ENTER_COMMUNITYS_EXPIRE_TIME_KEY, key = "#storeId")
public ResultVo getStoreEnterCommunitys(IPageData pd, String storeId, String storeTypeCd, RestTemplate restTemplate) {
ResponseEntity<String> responseEntity = null;
// responseEntity = CallApiServiceFactory.callCenterService(restTemplate, pd, "",
// "query.myCommunity.byMember?memberId=" + storeId + "&memberTypeCd="
// + MappingCache.getValue(MappingConstant.DOMAIN_STORE_TYPE_2_COMMUNITY_MEMBER_TYPE, storeTypeCd), HttpMethod.GET);
responseEntity = super.callCenterService(restTemplate, pd, "",
"/communitys/queryStoreCommunitys?memberId=" + storeId + "&memberTypeCd="
+ MappingCache.getValue(MappingConstant.DOMAIN_STORE_TYPE_2_COMMUNITY_MEMBER_TYPE, storeTypeCd), HttpMethod.GET);
if (responseEntity.getStatusCode() != HttpStatus.OK) {
throw new IllegalArgumentException(responseEntity.getBody());
}
JSONObject paramOut = JSONObject.parseObject(responseEntity.getBody());
if(paramOut.containsKey("code") && ResultVo.CODE_OK != paramOut.getIntValue("code")){
throw new IllegalArgumentException(paramOut.getString("msg"));
}
return new ResultVo(paramOut.getIntValue("code"), paramOut.getString("msg"), paramOut.get("data"));
}
@Override
@Cacheable(value = "getUserPrivileges" + Java110RedisConfig.DEFAULT_EXPIRE_TIME_KEY, key = "#staffId")
public ResultVo getUserPrivileges(IPageData pd, String staffId, String storeTypeCd, RestTemplate restTemplate) {
ResponseEntity<String> privilegeGroup = super.callCenterService(restTemplate, pd, "",
"query.user.privilege?userId=" + staffId + "&domain=" + storeTypeCd, HttpMethod.GET);
if (privilegeGroup.getStatusCode() != HttpStatus.OK) {
throw new IllegalArgumentException(privilegeGroup.getBody());
}
return new ResultVo(privilegeGroup.getStatusCode() == HttpStatus.OK ? ResultVo.CODE_OK : ResultVo.CODE_ERROR, privilegeGroup.getBody());
}
@Cacheable(value = "checkUserHasResourceListener" + Java110RedisConfig.DEFAULT_EXPIRE_TIME_KEY, key = "#cacheKey")
public ResultVo checkUserHasResourceListener(RestTemplate restTemplate, IPageData pd, JSONObject paramIn, String cacheKey) {
ResponseEntity<String> responseEntity = null;
responseEntity = super.callCenterService(restTemplate, pd, paramIn.toJSONString(),
"basePrivilege.CheckUserHasResourceListener",
HttpMethod.POST);
if (responseEntity.getStatusCode() != HttpStatus.OK) {
throw new IllegalArgumentException(responseEntity.getBody());
}
JSONObject data = JSONObject.parseObject(responseEntity.getBody());
JSONArray privileges = data.getJSONArray("privileges");
if(!SecureInvocation.secure(this.getClass())){
return new ResultVo(ResultVo.CODE_OK,privileges.toJSONString(),ResultVo.EMPTY_ARRAY);
}
return new ResultVo(responseEntity.getStatusCode() == HttpStatus.OK ? ResultVo.CODE_OK : ResultVo.CODE_ERROR, privileges.toJSONString());
}
}