| | |
| | | import com.java110.core.component.AbstractComponentSMO; |
| | | import com.java110.core.context.IPageData; |
| | | import com.java110.core.factory.GenerateCodeFactory; |
| | | import com.java110.dto.app.AppDto; |
| | | import com.java110.dto.privilege.BasePrivilegeDto; |
| | | import com.java110.dto.store.StoreDto; |
| | | import com.java110.dto.user.UserDto; |
| | |
| | | headers.put(CommonConstant.HTTP_USER_ID, StringUtil.isEmpty(pd.getUserId()) ? "-1" : pd.getUserId()); |
| | | } |
| | | |
| | | if (!headers.containsKey(CommonConstant.USER_ID)) { |
| | | headers.put(CommonConstant.USER_ID, "-1"); |
| | | } |
| | | if (!headers.containsKey(CommonConstant.HTTP_USER_ID)) { |
| | | headers.put(CommonConstant.HTTP_USER_ID, StringUtil.isEmpty(pd.getUserId()) ? "-1" : pd.getUserId()); |
| | | } |
| | | headers.put(CommonConstant.USER_ID, StringUtil.isEmpty(pd.getUserId()) ? "-1" : pd.getUserId()); |
| | | |
| | | if (!headers.containsKey(CommonConstant.HTTP_APP_ID)) { |
| | | headers.put(CommonConstant.HTTP_APP_ID, pd.getAppId()); |
| | | headers.put(CommonConstant.HTTP_APP_ID, AppDto.WEB_APP_ID); |
| | | } |
| | | if (!headers.containsKey(CommonConstant.APP_ID)) { |
| | | headers.put(CommonConstant.APP_ID, pd.getAppId()); |
| | | headers.put(CommonConstant.APP_ID, AppDto.WEB_APP_ID); |
| | | } |
| | | if (!headers.containsKey(CommonConstant.HTTP_TRANSACTION_ID)) { |
| | | headers.put(CommonConstant.HTTP_TRANSACTION_ID, GenerateCodeFactory.getUUID()); |
| | |
| | | headers.put(CommonConstant.HTTP_USER_ID, "-1"); |
| | | } |
| | | |
| | | headers.put(CommonConstant.USER_ID, "-1"); |
| | | |
| | | if (!headers.containsKey(CommonConstant.HTTP_USER_ID)) { |
| | | headers.put(CommonConstant.HTTP_USER_ID, "-1"); |
| | | if (!headers.containsKey(CommonConstant.USER_ID)) { |
| | | headers.put(CommonConstant.USER_ID, headers.get(CommonConstant.HTTP_USER_ID)); |
| | | } |
| | | if (!headers.containsKey(CommonConstant.HTTP_TRANSACTION_ID)) { |
| | | headers.put(CommonConstant.HTTP_TRANSACTION_ID, GenerateCodeFactory.getUUID()); |
| | |
| | | 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); |
| | | } |
| | | |
| | | /** |
| | | * 查询商户信息 |
| | |
| | | */ |
| | | 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) { |
| | | ResultVo resultVo = getCommunityStoreInfoSMOImpl.getStoreEnterCommunitys(pd, storeId, storeTypeCd, restTemplate); |
| | | if (resultVo.getCode() != ResultVo.CODE_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"); |
| | | JSONArray communitys = JSONArray.parseArray(resultVo.getData().toString()); |
| | | |
| | | if (communitys == null || communitys.size() == 0) { |
| | | throw new SMOException(ResponseConstant.RESULT_CODE_ERROR, "还未入驻小区,请先入驻小区"); |