From 2e64c232ab6b51b2cecf1ee96e1e9b709234f326 Mon Sep 17 00:00:00 2001
From: huanghongfa <huanghongfa123456>
Date: 星期六, 21 八月 2021 16:35:14 +0800
Subject: [PATCH] 随手拍改版接口开发

---
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComCvtBusinessServiceImpl.java |   75 ++++++++++++++++++++++++++++++++-----
 1 files changed, 64 insertions(+), 11 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComCvtBusinessServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComCvtBusinessServiceImpl.java
index 31e6427..a4b315c 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComCvtBusinessServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComCvtBusinessServiceImpl.java
@@ -1,13 +1,16 @@
 package com.panzhihua.service_community.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.panzhihua.common.model.dtos.community.ComCvtBusinessDTO;
+import com.panzhihua.common.model.dtos.community.PageComCvtBusinessAppletsDTO;
 import com.panzhihua.common.model.dtos.community.PageComCvtBusinessDTO;
 import com.panzhihua.common.model.vos.R;
 import com.panzhihua.common.model.vos.community.ComActVO;
+import com.panzhihua.common.model.vos.community.ComCvtBusinessDetailVO;
 import com.panzhihua.common.model.vos.community.ComCvtBusinessVO;
 import com.panzhihua.service_community.dao.ComActDAO;
 import com.panzhihua.service_community.dao.ComCvtBusinessAreaDAO;
@@ -20,10 +23,13 @@
 import com.panzhihua.service_community.service.ComCvtBusinessAreaService;
 import com.panzhihua.service_community.service.ComCvtBusinessIntroduceService;
 import com.panzhihua.service_community.service.ComCvtBusinessService;
+import com.panzhihua.service_community.service.ComCvtServeService;
 import org.springframework.beans.BeanUtils;
+import org.springframework.boot.util.LambdaSafe;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.ObjectUtils;
+import org.springframework.util.StringUtils;
 
 import javax.annotation.Resource;
 import java.util.ArrayList;
@@ -49,6 +55,8 @@
     private ComCvtBusinessAreaService comCvtBusinessAreaService;
     @Resource
     private ComCvtBusinessIntroduceService comCvtBusinessIntroduceService;
+    @Resource
+    private ComCvtServeService comCvtServeService;
     @Resource
     private ComActDAO comActDAO;
 
@@ -145,9 +153,18 @@
         }
         ComCvtBusinessVO comCvtBusinessVO = new ComCvtBusinessVO();
         BeanUtils.copyProperties(comCvtBusinessDO, comCvtBusinessVO);
-        List<ComCvtBusinessAreaDO> comCvtBusinessAreaDOS = comCvtBusinessAreaDAO.selectList(new QueryWrapper<ComCvtBusinessAreaDO>().lambda().eq(ComCvtBusinessAreaDO::getBusinessId, comCvtBusinessDO.getId()));
-        List<Long> areaIds = comCvtBusinessAreaDOS.stream().map(comCvtBusinessAreaDO -> comCvtBusinessAreaDO.getCommunityId()).collect(Collectors.toList());
-        List<ComActDO> comActDOS = comActDAO.selectBatchIds(areaIds);
+        List<ComActDO> comActDOS = new ArrayList<>();
+
+        if(comCvtBusinessDO.getAreaFlag()==1){
+            LambdaQueryWrapper<ComActDO> lambdaQueryWrapper = new LambdaQueryWrapper<ComActDO>().eq(ComActDO::getState,0);
+            comActDOS = comActDAO.selectList(lambdaQueryWrapper);
+        }else{
+            List<Long> areaIds = comCvtBusinessAreaService.getBusinessServiceAreaIds(comCvtBusinessDO.getId());
+            if(!ObjectUtils.isEmpty(areaIds)){
+                comActDOS = comActDAO.selectBatchIds(areaIds);
+            }
+        }
+
         if (!ObjectUtils.isEmpty(comActDOS)) {
             List<ComActVO> comActVOS = new ArrayList<>();
             comActDOS.forEach(comActDO -> {
@@ -157,14 +174,8 @@
             });
             comCvtBusinessVO.setComActVOS(comActVOS);
         }
-        List<ComCvtBusinessIntroduceDO> comCvtBusinessIntroduceDOS = comCvtBusinessIntroduceDAO.selectList(new QueryWrapper<ComCvtBusinessIntroduceDO>().lambda().eq(ComCvtBusinessIntroduceDO::getBusinessId, comCvtBusinessDO.getId()));
-        if (!ObjectUtils.isEmpty(comCvtBusinessIntroduceDOS)) {
-            List<String> mediaPaths = new ArrayList<>();
-            comCvtBusinessIntroduceDOS.forEach(media -> {
-                mediaPaths.add(media.getMediaPath());
-            });
-            comCvtBusinessVO.setMediaPaths(mediaPaths);
-        }
+        List<String> mediaPaths = comCvtBusinessIntroduceService.getBusinessMediaPaths(id);
+        comCvtBusinessVO.setMediaPaths(mediaPaths);
         return R.ok(comCvtBusinessVO);
     }
 
@@ -181,4 +192,46 @@
         comCvtBusinessIntroduceDAO.delete(new QueryWrapper<ComCvtBusinessIntroduceDO>().lambda().eq(ComCvtBusinessIntroduceDO::getBusinessId, id));
         return R.ok();
     }
+
+    @Override
+    public R pageComCvtBusinessByServiceArea(PageComCvtBusinessAppletsDTO comCvtBusinessAppletsDTO) {
+        Page page = new Page<>();
+        Long pageNum = comCvtBusinessAppletsDTO.getPageNum();
+        Long pageSize = comCvtBusinessAppletsDTO.getPageSize();
+        if (null == pageNum || 0 == pageNum) {
+            pageNum = 1l;
+        }
+        if (null == pageSize || 0 == pageSize) {
+            pageSize = 10l;
+        }
+        page.setSize(pageSize);
+        page.setCurrent(pageNum);
+        IPage<ComCvtBusinessVO> iPage = comCvtBusinessDAO.pageComCvtBusinessByServiceArea(page, comCvtBusinessAppletsDTO);
+        return R.ok(iPage);
+    }
+
+    @Override
+    public R getComCvtBusinessServeDetail(Long id) {
+        ComCvtBusinessDO comCvtBusinessDO = comCvtBusinessDAO.selectById(id);
+        if (null == comCvtBusinessDO) {
+            return R.fail("商家不存在");
+        }
+        ComCvtBusinessDetailVO comCvtBusinessDetailVO = new ComCvtBusinessDetailVO();
+        BeanUtils.copyProperties(comCvtBusinessDO, comCvtBusinessDetailVO);
+        if(comCvtBusinessDO.getAreaFlag()!=1){
+            List<Long> areaIds = comCvtBusinessAreaService.getBusinessServiceAreaIds(comCvtBusinessDO.getId());
+            List<ComActDO> comActDOS = comActDAO.selectBatchIds(areaIds);
+            if (!ObjectUtils.isEmpty(comActDOS)) {
+                List<String> comActVOS = new ArrayList<>();
+                comActDOS.forEach(comActDO -> {
+                    comActVOS.add(comActDO.getName());
+                });
+                comCvtBusinessDetailVO.setComActVOS(comActVOS);
+            }
+        }
+        List<String> mediaPaths = comCvtBusinessIntroduceService.getBusinessMediaPaths(id);
+        comCvtBusinessDetailVO.setMediaPaths(mediaPaths);
+        comCvtBusinessDetailVO.setCategoryServeVOS(comCvtServeService.getBusinessCategoryServeVOS(id));
+        return R.ok(comCvtBusinessDetailVO);
+    }
 }

--
Gitblit v1.7.1