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