增加小区楼信息开发中

吴学文

2019-04-25 2a2bc2abf283784151fe1c15047ff65d41ce5583

 WebService/src/main/java/com/java110/web/core/BaseComponentSMO.java

@@ -1,7 +1,10 @@
package com.java110.web.core;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.common.cache.MappingCache;
import com.java110.common.constant.CommonConstant;
import com.java110.common.constant.MappingConstant;
import com.java110.common.constant.ServiceConstant;
import com.java110.common.exception.SMOException;
import com.java110.common.factory.ApplicationContextFactory;
@@ -23,10 +26,11 @@
 */
public class BaseComponentSMO extends BaseServiceSMO {

    private final static Logger logger = LoggerFactory.getLogger(BaseComponentSMO.class);
    private static Logger logger = LoggerFactory.getLogger(BaseComponentSMO.class);

    /**
     * 调用组件
     *
     * @param componentCode 组件编码
     * @param componentMethod 组件方法
     * @param pd
@@ -62,6 +66,7 @@

    /**
     * 获取用户信息
     *
     * @param pd
     * @param restTemplate
     * @return
@@ -79,6 +84,7 @@

    /**
     * 查询商户信息
     *
     * @return
     */
    protected ResponseEntity<String> getStoreInfo(IPageData pd, RestTemplate restTemplate){
@@ -90,7 +96,51 @@
    }

    /**
     * 查询商户信息
     *
     * @return
     */
    protected void checkStoreEnterCommunity(IPageData pd, String storeId, String storeTypeCd, String communityId, RestTemplate restTemplate) {
        Assert.hasLength(pd.getUserId(), "用户未登录请先登录");
        ResponseEntity<String> responseEntity = null;
        responseEntity = this.callCenterService(restTemplate, pd, "",
                ServiceConstant.SERVICE_API_URL + "/api/query.myCommunity.byMember?memberId=" + storeId + "&memberTypeCd="
                        + MappingCache.getValue(MappingConstant.DOMAIN_STORE_TYPE_2_COMMUNITY_MEMBER_TYPE,storeTypeCd), HttpMethod.GET);
        if (responseEntity.getStatusCode() != HttpStatus.OK) {
            throw new SMOException(1999, "还未入驻小区，请先入驻小区");
        }

        Assert.jsonObjectHaveKey(responseEntity.getBody().toString(), "communitys", "还未入驻小区，请先入驻小区");

        JSONObject community = JSONObject.parseObject(responseEntity.getBody().toString());

        JSONArray communitys = community.getJSONArray("communitys");

        if (communitys == null || communitys.size() == 0) {
            throw new SMOException(1999, "还未入驻小区，请先入驻小区");
        }

        JSONObject currentCommunity = getCurrentCommunity(communitys,communityId);

        if(currentCommunity == null){
            throw new SMOException(1999, "传入小区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;
    }

    /**
     * 检查用户是否有权限
     *
     * @param pd
     * @param restTemplate
     * @param privilegeCode