| | |
|---|
| | | import com.alibaba.fastjson.JSONObject; |
|---|
| | | import com.java110.core.annotation.Java110Cmd; |
|---|
| | | import com.java110.core.context.ICmdDataFlowContext; |
|---|
| | | import com.java110.core.event.cmd.AbstractServiceCmdListener; |
|---|
| | | import com.java110.core.event.cmd.Cmd; |
|---|
| | | import com.java110.core.event.cmd.CmdEvent; |
|---|
| | | import com.java110.dto.CommunityMemberDto; |
|---|
| | | import com.java110.dto.community.CommunityDto; |
|---|
| | | import com.java110.dto.store.StoreDto; |
|---|
| | | import com.java110.intf.community.ICommunityInnerServiceSMO; |
|---|
| | | import com.java110.intf.store.IStoreV1InnerServiceSMO; |
|---|
| | | import com.java110.utils.cache.MappingCache; |
|---|
| | | import com.java110.utils.constant.MappingConstant; |
|---|
| | | import com.java110.utils.exception.CmdException; |
|---|
| | | import com.java110.utils.util.Assert; |
|---|
| | | import com.java110.utils.util.BeanConvertUtil; |
|---|
| | | import com.java110.utils.util.StringUtil; |
|---|
| | | import com.java110.vo.ResultVo; |
|---|
| | | import org.slf4j.Logger; |
|---|
| | | import org.slf4j.LoggerFactory; |
|---|
| | | import com.java110.core.log.LoggerFactory; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | |
|---|
| | | import java.util.List; |
|---|
| | |
|---|
| | | * add by 吴学文 2021-09-18 |
|---|
| | | */ |
|---|
| | | @Java110Cmd(serviceCode = "/communitys/queryStoreCommunitys") |
|---|
| | | public class QueryStoreCommunitysCmd extends AbstractServiceCmdListener { |
|---|
| | | private final static Logger logger = LoggerFactory.getLogger(QueryStoreCommunitysCmd.class); |
|---|
| | | public class QueryStoreCommunitysCmd extends Cmd { |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private IStoreV1InnerServiceSMO storeV1InnerServiceSMOImpl; |
|---|
| | | |
|---|
| | | private final static Logger logger = LoggerFactory.getLogger(QueryStoreCommunitysCmd.class); |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private ICommunityInnerServiceSMO communityInnerServiceSMOImpl; |
|---|
| | |
|---|
| | | @Override |
|---|
| | | public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) { |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException { |
|---|
| | | String storeId = cmdDataFlowContext.getReqHeaders().get("store-id"); |
|---|
| | | |
|---|
| | | if(StringUtil.isEmpty(storeId)){ |
|---|
| | | storeId = reqJson.getString("memberId"); |
|---|
| | | } |
|---|
| | | StoreDto storeDto = new StoreDto(); |
|---|
| | | storeDto.setStoreId(storeId); |
|---|
| | | storeDto.setPage(1); |
|---|
| | | storeDto.setRow(1); |
|---|
| | | List<StoreDto> storeDtos = storeV1InnerServiceSMOImpl.queryStores(storeDto); |
|---|
| | | |
|---|
| | | Assert.listOnlyOne(storeDtos, "商户不存在"); |
|---|
| | | CommunityMemberDto communityMemberDto = BeanConvertUtil.covertBean(reqJson, CommunityMemberDto.class); |
|---|
| | | communityMemberDto.setMemberId(storeId); |
|---|
| | | communityMemberDto.setMemberTypeCd(MappingCache.getValue(MappingConstant.DOMAIN_STORE_TYPE_2_COMMUNITY_MEMBER_TYPE, storeDtos.get(0).getStoreTypeCd())); |
|---|
| | | List<CommunityDto> communityDtos = communityInnerServiceSMOImpl.getStoreCommunitys(communityMemberDto); |
|---|
| | | cmdDataFlowContext.setResponseEntity(ResultVo.createResponseEntity(communityDtos)); |
|---|
| | | } |
|---|
