From 8ff4edca6ed7860bcbdb07180544f67288cda70e Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期五, 27 十二月 2019 01:11:12 +0800
Subject: [PATCH] 修改对接 token
---
Api/src/main/java/com/java110/api/listener/owner/AppUserBindingOwnerListener.java | 92 +++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 90 insertions(+), 2 deletions(-)
diff --git a/Api/src/main/java/com/java110/api/listener/owner/AppUserBindingOwnerListener.java b/Api/src/main/java/com/java110/api/listener/owner/AppUserBindingOwnerListener.java
index 0519a73..b8164d1 100644
--- a/Api/src/main/java/com/java110/api/listener/owner/AppUserBindingOwnerListener.java
+++ b/Api/src/main/java/com/java110/api/listener/owner/AppUserBindingOwnerListener.java
@@ -9,8 +9,11 @@
import com.java110.core.factory.GenerateCodeFactory;
import com.java110.core.smo.community.ICommunityInnerServiceSMO;
import com.java110.core.smo.file.IFileInnerServiceSMO;
+import com.java110.core.smo.owner.IOwnerAppUserInnerServiceSMO;
+import com.java110.core.smo.owner.IOwnerInnerServiceSMO;
import com.java110.dto.community.CommunityDto;
import com.java110.dto.file.FileDto;
+import com.java110.dto.owner.OwnerDto;
import com.java110.entity.center.AppService;
import com.java110.event.service.api.ServiceDataFlowEvent;
import com.java110.utils.constant.*;
@@ -24,6 +27,8 @@
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
import org.springframework.http.ResponseEntity;
+
+import java.util.List;
/**
* @ClassName AppUserBindingOwnerListener
@@ -45,6 +50,12 @@
@Autowired
private ICommunityInnerServiceSMO communityInnerServiceSMOImpl;
+
+ @Autowired
+ private IOwnerInnerServiceSMO ownerInnerServiceSMOImpl;
+
+ @Autowired
+ private IOwnerAppUserInnerServiceSMO ownerAppUserInnerServiceSMOImpl;
private static Logger logger = LoggerFactory.getLogger(AppUserBindingOwnerListener.class);
@@ -72,13 +83,81 @@
logger.debug("ServiceDataFlowEvent : {}", event);
+
+
+
//鏌ヨ灏忓尯鏄惁瀛樺湪
CommunityDto communityDto = new CommunityDto();
- //communityInnerServiceSMOImpl.queryCommunitys();
- //
+ communityDto.setCityCode(reqJson.getString("areaCode"));
+ communityDto.setName(reqJson.getString("communityName"));
+ communityDto.setState("1100");
+ List<CommunityDto> communityDtos = communityInnerServiceSMOImpl.queryCommunitys(communityDto);
+
+ Assert.listOnlyOne(communityDtos, "濉啓灏忓尯淇℃伅閿欒");
+
+ CommunityDto tmpCommunityDto = communityDtos.get(0);
+
+ OwnerDto ownerDto = new OwnerDto();
+ ownerDto.setCommunityId(tmpCommunityDto.getCommunityId());
+ ownerDto.setIdCard(reqJson.getString("idCard"));
+ ownerDto.setName(reqJson.getString("appUserName"));
+ ownerDto.setLink(reqJson.getString("link"));
+ List<OwnerDto> ownerDtos = ownerInnerServiceSMOImpl.queryOwnerMembers(ownerDto);
+
+ Assert.listOnlyOne(ownerDtos, "濉啓涓氫富淇℃伅閿欒");
+
+ OwnerDto tmpOwnerDto = ownerDtos.get(0);
+
+ DataFlowContext dataFlowContext = event.getDataFlowContext();
+ AppService service = event.getAppService();
+ String paramIn = dataFlowContext.getReqData();
+ JSONObject paramObj = JSONObject.parseObject(paramIn);
+ HttpHeaders header = new HttpHeaders();
+ dataFlowContext.getRequestCurrentHeaders().put(CommonConstant.HTTP_ORDER_TYPE_CD, "D");
+ JSONArray businesses = new JSONArray();
+ //娣诲姞灏忓尯妤�
+ businesses.add(addOwnerAppUser(paramObj, tmpCommunityDto, tmpOwnerDto));
+
+ JSONObject paramInObj = super.restToCenterProtocol(businesses, dataFlowContext.getRequestCurrentHeaders());
+
+ //灏� rest header 淇℃伅浼犻�掑埌涓嬪眰鏈嶅姟涓幓
+ super.freshHttpHeader(header, dataFlowContext.getRequestCurrentHeaders());
+
+
+ ResponseEntity<String> responseEntity = this.callService(dataFlowContext, service.getServiceCode(), paramInObj);
+
+ dataFlowContext.setResponseEntity(responseEntity);
+
}
+ /**
+ * 娣诲姞涓氫富搴旂敤鐢ㄦ埛鍏崇郴
+ *
+ * @param paramInJson
+ * @return
+ */
+ private JSONObject addOwnerAppUser(JSONObject paramInJson, CommunityDto communityDto, OwnerDto ownerDto) {
+
+ JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
+ business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_SAVE_OWNER_APP_USER);
+ business.put(CommonConstant.HTTP_SEQ, DEFAULT_SEQ);
+ business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S);
+ JSONObject businessOwnerAppUser = new JSONObject();
+ businessOwnerAppUser.putAll(paramInJson);
+ //鐘舵�佺被鍨嬶紝10000 瀹℃牳涓紝12000 瀹℃牳鎴愬姛锛�13000 瀹℃牳澶辫触
+ businessOwnerAppUser.put("state", "10000");
+ businessOwnerAppUser.put("appTypeCd", "10010");
+ businessOwnerAppUser.put("appUserId", "-1");
+ businessOwnerAppUser.put("memberId", ownerDto.getMemberId());
+ businessOwnerAppUser.put("communityName", communityDto.getName());
+ businessOwnerAppUser.put("communityId", communityDto.getCommunityId());
+ businessOwnerAppUser.put("appUserName", ownerDto.getName());
+ businessOwnerAppUser.put("idCard", ownerDto.getIdCard());
+ businessOwnerAppUser.put("link",ownerDto.getLink());
+ business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessOwnerAppUser", businessOwnerAppUser);
+ return business;
+ }
@Override
@@ -103,4 +182,13 @@
public void setCommunityInnerServiceSMOImpl(ICommunityInnerServiceSMO communityInnerServiceSMOImpl) {
this.communityInnerServiceSMOImpl = communityInnerServiceSMOImpl;
}
+
+
+ public IOwnerInnerServiceSMO getOwnerInnerServiceSMOImpl() {
+ return ownerInnerServiceSMOImpl;
+ }
+
+ public void setOwnerInnerServiceSMOImpl(IOwnerInnerServiceSMO ownerInnerServiceSMOImpl) {
+ this.ownerInnerServiceSMOImpl = ownerInnerServiceSMOImpl;
+ }
}
--
Gitblit v1.8.0