FrontCommunityServiceSMOImpl.java
9.2 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
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
package com.java110.api.smo.impl;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.api.smo.DefaultAbstractComponentSMO;
import com.java110.api.smo.ICommunityServiceSMO;
import com.java110.core.context.IPageData;
import com.java110.core.log.LoggerFactory;
import com.java110.utils.cache.MappingCache;
import com.java110.utils.constant.AttrCdConstant;
import com.java110.utils.constant.MappingConstant;
import com.java110.utils.constant.PrivilegeCodeConstant;
import com.java110.utils.util.Assert;
import com.java110.utils.util.StringUtil;
import org.slf4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
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;
import java.util.HashMap;
import java.util.Map;
/**
* 小区服务类
*/
@Service("frontCommunityServiceSMOImpl")
public class FrontCommunityServiceSMOImpl extends DefaultAbstractComponentSMO implements ICommunityServiceSMO {
private static Logger logger = LoggerFactory.getLogger(FrontCommunityServiceSMOImpl.class);
@Autowired
private RestTemplate restTemplate;
@Override
public ResponseEntity<String> listMyCommunity(IPageData pd) {
ResponseEntity<String> responseEntity = null;
JSONObject _paramObj = JSONObject.parseObject(pd.getReqData());
//权限校验
checkUserHasPrivilege(pd, restTemplate, PrivilegeCodeConstant.PRIVILEGE_ENTER_COMMUNITY);
responseEntity = super.getStoreInfo(pd, restTemplate);
if (responseEntity.getStatusCode() != HttpStatus.OK) {
return responseEntity;
}
Assert.jsonObjectHaveKey(responseEntity.getBody().toString(), "storeId", "根据用户ID查询商户ID失败，未包含storeId节点");
String storeId = JSONObject.parseObject(responseEntity.getBody().toString()).getString("storeId");
String storeTypeCd = JSONObject.parseObject(responseEntity.getBody().toString()).getString("storeTypeCd");
Map paramIn = new HashMap();
paramIn.put("memberId", storeId);
paramIn.put("memberTypeCd", MappingCache.getValue(MappingConstant.DOMAIN_STORE_TYPE_2_COMMUNITY_MEMBER_TYPE, storeTypeCd));
paramIn.putAll(_paramObj);
responseEntity = this.callCenterService(restTemplate, pd, "",
"/communitys/queryStoreCommunitys" + mapToUrlParam(paramIn),
HttpMethod.GET);
if (responseEntity.getStatusCode() != HttpStatus.OK) {
return responseEntity;
}
JSONArray tmpCommunitys = JSONObject.parseObject(responseEntity.getBody().toString()).getJSONArray("data");
freshCommunityAttr(tmpCommunitys);
responseEntity = new ResponseEntity<String>(tmpCommunitys.toJSONString(),
HttpStatus.OK);
return responseEntity;
}
/**
* 查询未入驻的小区
*
* @param pd
* @return
*/
@Override
public ResponseEntity<String> listNoEnterCommunity(IPageData pd) {
ResponseEntity<String> responseEntity = null;
JSONObject _paramObj = JSONObject.parseObject(pd.getReqData());
//权限校验
checkUserHasPrivilege(pd, restTemplate, PrivilegeCodeConstant.PRIVILEGE_ENTER_COMMUNITY);
responseEntity = super.getStoreInfo(pd, restTemplate);
if (responseEntity.getStatusCode() != HttpStatus.OK) {
return responseEntity;
}
Assert.jsonObjectHaveKey(responseEntity.getBody().toString(), "storeId", "根据用户ID查询商户ID失败，未包含storeId节点");
String storeId = JSONObject.parseObject(responseEntity.getBody().toString()).getString("storeId");
String storeTypeCd = JSONObject.parseObject(responseEntity.getBody().toString()).getString("storeTypeCd");
String communityName = !_paramObj.containsKey("communityName") ? "" : _paramObj.getString("communityName");
//修改用户信息
if (StringUtil.isEmpty(communityName)) {
responseEntity = this.callCenterService(restTemplate, pd, "",
"query.noEnterCommunity.byMember?"
+ "memberTypeCd=" + MappingCache.getValue(MappingConstant.DOMAIN_STORE_TYPE_2_COMMUNITY_MEMBER_TYPE, storeTypeCd),
HttpMethod.GET);
} else {
responseEntity = this.callCenterService(restTemplate, pd, "",
"query.noEnterCommunity.byMemberAndName?"
+ "memberTypeCd=" + MappingCache.getValue(MappingConstant.DOMAIN_STORE_TYPE_2_COMMUNITY_MEMBER_TYPE, storeTypeCd)
+ "&name=" + communityName,
HttpMethod.GET);
}
if (responseEntity.getStatusCode() != HttpStatus.OK) {
return responseEntity;
}
JSONArray tmpCommunitys = JSONObject.parseObject(responseEntity.getBody().toString()).getJSONArray("communitys");
freshCommunityAttr(tmpCommunitys);
responseEntity = new ResponseEntity<String>(tmpCommunitys.toJSONString(),
HttpStatus.OK);
return responseEntity;
}
/**
* 商户入驻申请接口
*
* @param pd
* @return
*/
@Override
public ResponseEntity<String> _saveEnterCommunity(IPageData pd) {
ResponseEntity<String> responseEntity = null;
Assert.jsonObjectHaveKey(pd.getReqData(), "communityId", "请求信息中未包含communityId");
JSONObject _paramObj = JSONObject.parseObject(pd.getReqData());
String communityId = _paramObj.getString("communityId");
//权限校验
checkUserHasPrivilege(pd, restTemplate, PrivilegeCodeConstant.PRIVILEGE_ENTER_COMMUNITY);
responseEntity = super.getStoreInfo(pd, restTemplate);
if (responseEntity.getStatusCode() != HttpStatus.OK) {
return responseEntity;
}
Assert.jsonObjectHaveKey(responseEntity.getBody().toString(), "storeId", "根据用户ID查询商户ID失败，未包含storeId节点");
String storeId = JSONObject.parseObject(responseEntity.getBody().toString()).getString("storeId");
String storeTypeCd = JSONObject.parseObject(responseEntity.getBody().toString()).getString("storeTypeCd");
_paramObj.put("memberId", storeId);
_paramObj.put("memberTypeCd", MappingCache.getValue(MappingConstant.DOMAIN_STORE_TYPE_2_COMMUNITY_MEMBER_TYPE, storeTypeCd));
responseEntity = this.callCenterService(restTemplate, pd, _paramObj.toJSONString(),
"member.join.community",
HttpMethod.POST);
return responseEntity;
}
/**
* 退出小区
*
* @param pd
* @return
*/
@Override
public ResponseEntity<String> exitCommunity(IPageData pd) {
ResponseEntity<String> responseEntity = null;
Assert.jsonObjectHaveKey(pd.getReqData(), "communityId", "请求信息中未包含communityId");
JSONObject _paramObj = JSONObject.parseObject(pd.getReqData());
String communityId = _paramObj.getString("communityId");
Assert.hasLength(communityId, "请求报文中communityId为空");
//权限校验
checkUserHasPrivilege(pd, restTemplate, PrivilegeCodeConstant.PRIVILEGE_ENTER_COMMUNITY);
responseEntity = super.getStoreInfo(pd, restTemplate);
if (responseEntity.getStatusCode() != HttpStatus.OK) {
return responseEntity;
}
Assert.jsonObjectHaveKey(responseEntity.getBody().toString(), "storeId", "根据用户ID查询商户ID失败，未包含storeId节点");
String storeId = JSONObject.parseObject(responseEntity.getBody().toString()).getString("storeId");
String storeTypeCd = JSONObject.parseObject(responseEntity.getBody().toString()).getString("storeTypeCd");
JSONObject paramInObj = new JSONObject();
paramInObj.put("communityId", communityId);
paramInObj.put("memberId", storeId);
paramInObj.put("memberTypeCd", MappingCache.getValue(MappingConstant.DOMAIN_STORE_TYPE_2_COMMUNITY_MEMBER_TYPE, storeTypeCd));
responseEntity = this.callCenterService(restTemplate, pd, paramInObj.toJSONString(),
"member.quit.community",
HttpMethod.POST);
return responseEntity;
}
private void freshCommunityAttr(JSONArray community) {
for (int _communityIndex = 0; _communityIndex < community.size(); _communityIndex++) {
JSONObject _community = community.getJSONObject(_communityIndex);
if (!_community.containsKey("attrs")) {
continue;
}
JSONArray _attrs = _community.getJSONArray("attrs");
for (int _cAttrIndex = 0; _cAttrIndex < _attrs.size(); _cAttrIndex++) {
if (AttrCdConstant.SPEC_CD_COMMUNITY_TEL.equals(_attrs.getJSONObject(_cAttrIndex).getString("specCd"))) {
_community.put("tel", _attrs.getJSONObject(_cAttrIndex).getString("value"));
}
}
}
}
public RestTemplate getRestTemplate() {
return restTemplate;
}
public void setRestTemplate(RestTemplate restTemplate) {
this.restTemplate = restTemplate;
}
}