From 43f0578e80af82ecae6c61b51bd0539c6b960603 Mon Sep 17 00:00:00 2001 From: puhanshu <a9236326> Date: 星期二, 16 八月 2022 19:08:32 +0800 Subject: [PATCH] 服务范围优化 --- springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ConvenientMerchantServiceImpl.java | 77 ++++++++++++++++++++++++++++++++------ 1 files changed, 65 insertions(+), 12 deletions(-) diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ConvenientMerchantServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ConvenientMerchantServiceImpl.java index 86fd04c..4d1984f 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ConvenientMerchantServiceImpl.java +++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ConvenientMerchantServiceImpl.java @@ -5,7 +5,6 @@ import static org.apache.commons.lang3.StringUtils.isNotBlank; import java.text.SimpleDateFormat; -import java.time.Instant; import java.util.ArrayList; import java.util.Date; import java.util.List; @@ -13,7 +12,7 @@ import javax.annotation.Resource; -import lombok.extern.slf4j.Slf4j; +import com.panzhihua.common.utlis.Snowflake; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -56,6 +55,8 @@ import com.panzhihua.service_community.model.dos.ConvenientViewStatisticsDO; import com.panzhihua.service_community.service.ConvenientMerchantService; +import lombok.extern.slf4j.Slf4j; + /** * @title: ConvenientMerchantServiceImpl * @projectName: 成都呐喊信息技术有限公司-智慧社区项目 @@ -80,15 +81,28 @@ @Resource private ConvenientViewStatisticsDAO convenientViewStatisticsDAO; + private static final String DQ="510402"; + private static final String RHQ="510411"; + @Override @Transactional(rollbackFor = Exception.class) public R addMerchant(ConvenientMerchantDTO convenientMerchantDTO) { - log.error("catTimeStamp开始执行addMerchant", Instant.now().toEpochMilli()); - ComActDO comActDO = comActDAO.selectById(convenientMerchantDTO.getCommunityId()); ConvenientMerchantDO convenientMerchantDO = new ConvenientMerchantDO(); BeanUtils.copyProperties(convenientMerchantDTO, convenientMerchantDO); + if(convenientMerchantDTO.getCommunityId()==0){ + if(DQ.equals(convenientMerchantDTO.getAreaCode())){ + convenientMerchantDO.setCommunityName("东区社区"); + }else if(RHQ.equals(convenientMerchantDTO.getAreaCode())){ + convenientMerchantDO.setCommunityName("仁和区社区"); + }else{ + convenientMerchantDO.setCommunityName("西区社区"); + } + } + else { + ComActDO comActDO = comActDAO.selectById(convenientMerchantDTO.getCommunityId()); + convenientMerchantDO.setCommunityName(comActDO.getName()); + } convenientMerchantDO.setUserId(0L); - convenientMerchantDO.setCommunityName(comActDO.getName()); convenientMerchantDO.setCreatedAt(new Date()); int insertResult = this.baseMapper.insert(convenientMerchantDO); if (insertResult > 0) { @@ -98,22 +112,20 @@ List<Long> serviceIds = convenientMerchantDTO.getServiceIds(); serviceIds.forEach(serviceId -> { ConvenientServiceCategoryDO convenientServiceCategoryDO = convenientServiceCategoryDAO.selectById(serviceId); - convenientServiceCategoryDAO.createMerchantServiceRelation(merchantId, serviceId, + convenientServiceCategoryDAO.createMerchantServiceRelation(Snowflake.getId(),merchantId, serviceId, convenientServiceCategoryDO.getName(), convenientMerchantDTO.getCreatedBy()); }); } } - log.error("catTimeStamp商家创建完成开始添加用户", Instant.now().toEpochMilli()); //添加user R addUserResult = userService.addConvenientMerchantUser(convenientMerchantDTO); if (R.isOk(addUserResult)) { - Long merchantUserId = ((Integer) addUserResult.getData()).longValue(); + Long merchantUserId =Long.parseLong(addUserResult.getData().toString()); convenientMerchantDO.setUserId(merchantUserId); this.baseMapper.updateById(convenientMerchantDO); } else { throw new ServiceException("406", addUserResult.getMsg()); } - log.error("catTimeStamp全部完成", Instant.now().toEpochMilli()); return R.ok(); } @@ -128,7 +140,12 @@ Long communityId = convenientMerchantDTO.getCommunityId(); if (nonNull(communityId)) { ComActDO comActDO = comActDAO.selectById(communityId); - convenientMerchantDO.setCommunityName(comActDO.getName()); + if(comActDO!=null){ + convenientMerchantDO.setCommunityName(comActDO.getName()); + } + else { + convenientMerchantDO.setCommunityName("西区社区"); + } } String account = convenientMerchantDTO.getAccount(); if (isNotBlank(account)) { @@ -143,7 +160,7 @@ convenientServiceCategoryDAO.deleteMerchantServiceRelation(merchantId); serviceIds.forEach(serviceId -> { ConvenientServiceCategoryDO convenientServiceCategoryDO = convenientServiceCategoryDAO.selectById(serviceId); - convenientServiceCategoryDAO.createMerchantServiceRelation(merchantId, serviceId, + convenientServiceCategoryDAO.createMerchantServiceRelation(Snowflake.getId(),merchantId, serviceId, convenientServiceCategoryDO.getName(), convenientMerchantDTO.getCreatedBy()); }); } @@ -281,7 +298,27 @@ Page page = new Page<>(); page.setSize(pagePopularMerchantDTO.getPageSize()); page.setCurrent(pagePopularMerchantDTO.getPageNum()); - IPage<ConvenientMerchantVO> merchantVOList = this.baseMapper.getPopularMerchants(page, pagePopularMerchantDTO.getCommunityId(), currentMon); + IPage<ConvenientMerchantVO> merchantVOList = this.baseMapper.getPopularMerchants(page, pagePopularMerchantDTO.getCommunityId(), currentMon,pagePopularMerchantDTO.getAreaCode()); + if(pagePopularMerchantDTO.getPageNum().equals(1L)){ + //金沙江默认第一个 + List<ConvenientMerchantVO> merchantVOS=new ArrayList<>(); + ConvenientMerchantVO merchantVO=new ConvenientMerchantVO(); + merchantVO.setName("金沙江智慧物流商贸城"); + merchantVO.setLogo("https://www.psciio.com//idcard/0694d975ed4d4c49bcfb728a678518f2.jpg"); + merchantVO.setIntroduction("农产直销、综合商贸、冷链储运、中央厨房、检验检疫、农博会展、总部商务、综合服务。"); + merchantVO.setServiceScope(""); + merchantVO.setConsultationVolume(0); + merchantVO.setMonthConsultationVolume(0); + merchantVOS.add(merchantVO); + //第一页默认把犇师傅维修中心加载到第一个 + List<ConvenientMerchantVO> merchantList = this.baseMapper.selectMerchantByName(pagePopularMerchantDTO.getCommunityId(), currentMon); + if(merchantList != null && merchantList.size() > 0){ + merchantVOS.addAll(merchantList); + merchantVOS.addAll(merchantVOList.getRecords()); + merchantVOList.setRecords(merchantVOS); + } + + } return R.ok(merchantVOList); } @@ -416,4 +453,20 @@ this.baseMapper.batchUpdateMerchantViewNum(viewVOList); return R.ok(); } + + /** + * check商家/店铺是否有效 + * @param userId + * @return + */ + @Override + public Boolean checkStoreIsValid(Long userId) { + R<LoginUserInfoVO> loginUserInfo = userService.getUserInfoByUserId(userId.toString()); + LoginUserInfoVO loginUserInfoVO = + JSONObject.parseObject(JSONObject.toJSONString(loginUserInfo.getData()), LoginUserInfoVO.class); + if (isNull(loginUserInfoVO) || !loginUserInfoVO.getType().equals(10) || loginUserInfoVO.getStatus() != 1) { + return false; + } + return true; + } } -- Gitblit v1.7.1