From 9f4eb4e4d0718df0a70d398a08bc42fa9ebe9543 Mon Sep 17 00:00:00 2001
From: zhangchenbiao <chenbiao.zhang@coolcollege.cn>
Date: Wed, 17 Apr 2024 16:40:32 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/cool/store/dao/PointInfoDAO.java |  6 +++
 .../cool/store/mapper/PointInfoMapper.java    |  8 +++
 .../com/cool/store/mapper/RegionMapper.java   |  2 +
 .../main/resources/mapper/PointInfoMapper.xml | 54 +++++++++++++++++++
 .../main/resources/mapper/RegionMapper.xml    | 11 ++++
 .../store/request/AllPointPageRequest.java    | 46 ++++++++++++++++
 .../cool/store/request/PointPageRequest.java  |  3 ++
 .../cool/store/vo/point/PointDetailVO.java    |  4 ++
 .../com/cool/store/service/PointService.java  |  7 +++
 .../com/cool/store/service/RegionService.java |  7 +++
 .../store/service/UserAuthMappingService.java |  7 +++
 .../store/service/impl/PointServiceImpl.java  | 40 ++++++++++++--
 .../store/service/impl/RegionServiceImpl.java | 13 +++++
 .../impl/UserAuthMappingServiceImpl.java      | 14 +++++
 .../controller/webb/PointController.java      |  7 +++
 15 files changed, 225 insertions(+), 4 deletions(-)
 create mode 100644 coolstore-partner-model/src/main/java/com/cool/store/request/AllPointPageRequest.java

diff --git a/coolstore-partner-dao/src/main/java/com/cool/store/dao/PointInfoDAO.java b/coolstore-partner-dao/src/main/java/com/cool/store/dao/PointInfoDAO.java
index 4d6826b49..3793d8ccd 100644
--- a/coolstore-partner-dao/src/main/java/com/cool/store/dao/PointInfoDAO.java
+++ b/coolstore-partner-dao/src/main/java/com/cool/store/dao/PointInfoDAO.java
@@ -4,6 +4,7 @@ import com.aliyun.openservices.shade.org.apache.commons.lang3.StringUtils;
 import com.cool.store.dto.point.LineCountDTO;
 import com.cool.store.entity.PointInfoDO;
 import com.cool.store.mapper.PointInfoMapper;
+import com.cool.store.request.AllPointPageRequest;
 import com.cool.store.request.PointPageRequest;
 import com.cool.store.request.RecommendPointPageRequest;
 import com.cool.store.utils.StringUtil;
@@ -90,4 +91,9 @@ public class PointInfoDAO {
         }
         return pointInfoMapper.updateSelectedDevelopmentManager(lineId, developmentManager);
     }
+
+    public Page<PointInfoDO> getTeamPointPage(AllPointPageRequest request) {
+        PageHelper.startPage(request.getPageNum(), request.getPageSize());
+        return pointInfoMapper.getTeamPointPage(request);
+    }
 }
diff --git a/coolstore-partner-dao/src/main/java/com/cool/store/mapper/PointInfoMapper.java b/coolstore-partner-dao/src/main/java/com/cool/store/mapper/PointInfoMapper.java
index f43e3f441..3ea23a509 100644
--- a/coolstore-partner-dao/src/main/java/com/cool/store/mapper/PointInfoMapper.java
+++ b/coolstore-partner-dao/src/main/java/com/cool/store/mapper/PointInfoMapper.java
@@ -2,6 +2,7 @@ package com.cool.store.mapper;
 
 import com.cool.store.dto.point.LineCountDTO;
 import com.cool.store.entity.PointInfoDO;
+import com.cool.store.request.AllPointPageRequest;
 import com.cool.store.request.PointPageRequest;
 import com.cool.store.request.RecommendPointPageRequest;
 import com.cool.store.vo.point.PointHomePageDataVO;
@@ -57,4 +58,11 @@ public interface PointInfoMapper extends Mapper<PointInfoDO> {
      * @return
      */
     Integer updateSelectedDevelopmentManager(@Param("lineId") Long lineId, @Param("developmentManager")String developmentManager);
+
+    /**
+     * 获取团队铺位
+     * @param request
+     * @return
+     */
+    Page<PointInfoDO> getTeamPointPage(@Param("request") AllPointPageRequest request);
 }
\ No newline at end of file
diff --git a/coolstore-partner-dao/src/main/java/com/cool/store/mapper/RegionMapper.java b/coolstore-partner-dao/src/main/java/com/cool/store/mapper/RegionMapper.java
index 08c39f820..7a26596d2 100644
--- a/coolstore-partner-dao/src/main/java/com/cool/store/mapper/RegionMapper.java
+++ b/coolstore-partner-dao/src/main/java/com/cool/store/mapper/RegionMapper.java
@@ -84,6 +84,8 @@ public interface RegionMapper {
      */
     List<String> getSubIdsByRegionIds( @Param("regionPaths")List<String> regionPaths);
 
+    List<String> getSubRegionIdsByRegionIds( @Param("regionIds")List<String> regionIds);
+
     List<String> getSubIdsByRegionpaths( @Param("regionPaths")List<String> regionPaths);
 
     List<String> getRegionPathByRegionIds( @Param("regionIds")List<String> regionIds);
diff --git a/coolstore-partner-dao/src/main/resources/mapper/PointInfoMapper.xml b/coolstore-partner-dao/src/main/resources/mapper/PointInfoMapper.xml
index 9d96981b6..b0d884806 100644
--- a/coolstore-partner-dao/src/main/resources/mapper/PointInfoMapper.xml
+++ b/coolstore-partner-dao/src/main/resources/mapper/PointInfoMapper.xml
@@ -88,6 +88,12 @@
     <if test="request.createEndTime != null and request.createEndTime != ''">
       <![CDATA[and create_time <= #{request.createEndTime}]]>
     </if>
+    <if test="request.regionIds != null and request.regionIds.size() > 0">
+      and region_id in
+      <foreach collection="request.regionIds" item="regionId" index="index" open="(" separator="," close=")">
+        #{regionId}
+      </foreach>
+    </if>
   </select>
     <select id="getSelectedShopNum" resultType="com.cool.store.dto.point.LineCountDTO">
       select
@@ -131,4 +137,52 @@
       line_id = #{lineId} and select_status = '1' and deleted = 0
   </update>
 
+  <select id="getTeamPointPage" resultMap="BaseResultMap">
+    select
+      id,
+      point_name,
+      point_code,
+      address,
+      region_id,
+      point_status,
+      point_score,
+      point_area,
+      development_manager,
+      operate_user_id,
+      development_time,
+      select_status,
+      create_time,
+      update_time
+    from
+      xfsg_point_info
+    where deleted = 0 and point_status in (4,5,6,7)
+      <if test="request.keyword != null and request.keyword != ''">
+        and (point_code like concat('%', #{request.keyword}, '%') or point_name like concat('%', #{request.keyword}, '%'))
+      </if>
+      <if test="request.developmentManager != null and request.developmentManager != ''">
+        and development_manager = #{request.developmentManager}
+      </if>
+      <if test="request.pointStatus != null and request.pointStatus != ''">
+        and point_status = #{request.pointStatus}
+      </if>
+      <if test="request.createStartTime != null and request.createStartTime != ''">
+        and create_time >= #{request.createStartTime}
+      </if>
+      <if test="request.createEndTime != null and request.createEndTime != ''">
+        <![CDATA[and create_time <= #{request.createEndTime}]]>
+      </if>
+      <if test="request.regionIds != null and request.regionIds.size() > 0">
+        and region_id in
+        <foreach collection="request.regionIds" item="regionId" index="index" open="(" separator="," close=")">
+          #{regionId}
+        </foreach>
+      </if>
+      <if test="request.authRegionIds != null and request.authRegionIds.size() > 0">
+        and region_id in
+        <foreach collection="request.authRegionIds" item="regionId" index="index" open="(" separator="," close=")">
+          #{regionId}
+        </foreach>
+      </if>
+  </select>
+
 </mapper>
\ No newline at end of file
diff --git a/coolstore-partner-dao/src/main/resources/mapper/RegionMapper.xml b/coolstore-partner-dao/src/main/resources/mapper/RegionMapper.xml
index 339ca094f..dd03dd1ff 100644
--- a/coolstore-partner-dao/src/main/resources/mapper/RegionMapper.xml
+++ b/coolstore-partner-dao/src/main/resources/mapper/RegionMapper.xml
@@ -274,6 +274,17 @@
             <foreach collection="regionPaths" separator=" or " open="(" close=")" item="region" > region_path like concat(#{region}, "%")</foreach>
     </select>
 
+    <select id="getSubRegionIdsByRegionIds" resultType="string">
+        select
+            id
+        from
+            region_${enterpriseId}
+        where
+            deleted = 0
+        and
+        <foreach collection="regionIds" separator=" or " open="(" close=")" item="region" > region_path like concat("%", #{region}, "%")</foreach>
+    </select>
+
     <select id="getSubIdsByRegionpaths" resultType="string">
         select
         id
diff --git a/coolstore-partner-model/src/main/java/com/cool/store/request/AllPointPageRequest.java b/coolstore-partner-model/src/main/java/com/cool/store/request/AllPointPageRequest.java
new file mode 100644
index 000000000..2214e105f
--- /dev/null
+++ b/coolstore-partner-model/src/main/java/com/cool/store/request/AllPointPageRequest.java
@@ -0,0 +1,46 @@
+package com.cool.store.request;
+
+import com.cool.store.common.PageBasicInfo;
+import com.cool.store.enums.point.PointStatusEnum;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import javax.validation.constraints.Max;
+import javax.validation.constraints.Min;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author zhangchenbiao
+ * @FileName: PointPageRequest
+ * @Description:
+ * @date 2024-04-08 10:28
+ */
+@Data
+public class AllPointPageRequest extends PageBasicInfo {
+
+    @ApiModelProperty("铺位名称或编号")
+    private String keyword;
+
+    @ApiModelProperty("选择区域")
+    private List<String> regionIds;
+
+    @ApiModelProperty(value = "拓展专员")
+    private String developmentManager;
+
+    @ApiModelProperty("1.采集中、2.已评估、3.待审核、5.已审核、6.已签约、7.已失效")
+    private Integer pointStatus;
+
+    @ApiModelProperty("创建时间-开始")
+    private String createStartTime;
+
+    @ApiModelProperty("创建时间-结束")
+    private String createEndTime;
+
+    @ApiModelProperty(value = "当前登录用户", hidden = true)
+    private String curUserId;
+
+    @ApiModelProperty(value = "管辖区域",hidden = true)
+    private List<String> authRegionIds;
+
+}
diff --git a/coolstore-partner-model/src/main/java/com/cool/store/request/PointPageRequest.java b/coolstore-partner-model/src/main/java/com/cool/store/request/PointPageRequest.java
index cd593aea5..a776ef625 100644
--- a/coolstore-partner-model/src/main/java/com/cool/store/request/PointPageRequest.java
+++ b/coolstore-partner-model/src/main/java/com/cool/store/request/PointPageRequest.java
@@ -23,6 +23,9 @@ public class PointPageRequest extends PageBasicInfo {
     @ApiModelProperty("铺位名称或编号")
     private String keyword;
 
+    @ApiModelProperty("选择区域")
+    private List<String> regionIds;
+
     @ApiModelProperty("营运人员")
     private String operateUserId;
 
diff --git a/coolstore-partner-model/src/main/java/com/cool/store/vo/point/PointDetailVO.java b/coolstore-partner-model/src/main/java/com/cool/store/vo/point/PointDetailVO.java
index 6fa48bfed..c33417243 100644
--- a/coolstore-partner-model/src/main/java/com/cool/store/vo/point/PointDetailVO.java
+++ b/coolstore-partner-model/src/main/java/com/cool/store/vo/point/PointDetailVO.java
@@ -14,6 +14,9 @@ public class PointDetailVO {
     @ApiModelProperty("店铺id")
     private Long pointId;
 
+    @ApiModelProperty("店铺id")
+    private Long shopId;
+
     @ApiModelProperty("铺位名称")
     private String pointName;
 
@@ -231,6 +234,7 @@ public class PointDetailVO {
     public static PointDetailVO convertVO(PointInfoDO pointInfo, PointDetailInfoDO pointDetailInfo) {
         PointDetailVO result = new PointDetailVO();
         result.setPointId(pointInfo.getId());
+        result.setShopId(pointInfo.getShopId());
         result.setPointName(pointInfo.getPointName());
         result.setPointCode(pointInfo.getPointCode());
         result.setLongitude(pointInfo.getLongitude());
diff --git a/coolstore-partner-service/src/main/java/com/cool/store/service/PointService.java b/coolstore-partner-service/src/main/java/com/cool/store/service/PointService.java
index f29ef2b33..6a34ba4fb 100644
--- a/coolstore-partner-service/src/main/java/com/cool/store/service/PointService.java
+++ b/coolstore-partner-service/src/main/java/com/cool/store/service/PointService.java
@@ -137,6 +137,13 @@ public interface PointService {
      */
     PageInfo<PointPageVO> getMyPointPage(PointPageRequest request);
 
+    /**
+     * 获取团队铺位
+     * @param request
+     * @return
+     */
+    PageInfo<PointPageVO> getTeamPointPage(AllPointPageRequest request);
+
     /**
      * 获取审批记录
      * @param pointId
diff --git a/coolstore-partner-service/src/main/java/com/cool/store/service/RegionService.java b/coolstore-partner-service/src/main/java/com/cool/store/service/RegionService.java
index 5999ec489..6a4eb37f8 100644
--- a/coolstore-partner-service/src/main/java/com/cool/store/service/RegionService.java
+++ b/coolstore-partner-service/src/main/java/com/cool/store/service/RegionService.java
@@ -33,4 +33,11 @@ public interface RegionService {
 
     List<RegionDO> listByThirdRegionType(Long parentId, String thirdRegionType);
 
+    /**
+     * 获取当前区域regionId 和所有子区域regionId
+     * @param regionIds
+     * @return
+     */
+    List<String> getSubRegionIdsByRegionIds(List<String> regionIds);
+
 }
diff --git a/coolstore-partner-service/src/main/java/com/cool/store/service/UserAuthMappingService.java b/coolstore-partner-service/src/main/java/com/cool/store/service/UserAuthMappingService.java
index 69864f55c..2f3a34b6e 100644
--- a/coolstore-partner-service/src/main/java/com/cool/store/service/UserAuthMappingService.java
+++ b/coolstore-partner-service/src/main/java/com/cool/store/service/UserAuthMappingService.java
@@ -22,6 +22,13 @@ public interface UserAuthMappingService {
      */
     List<UserAuthMappingDO> listUserAuthMappingByUserId(String userId);
 
+    /**
+     * 获取用户授权的所有区域id
+     * @param userId
+     * @return
+     */
+    List<String> getAuthRegionIdAndSubRegionIdByUserId(String userId);
+
     /**
      * 提供 根据职位 意向区域  查  对应人的接口  同时返回人名字
      * @param userRoleEnum
diff --git a/coolstore-partner-service/src/main/java/com/cool/store/service/impl/PointServiceImpl.java b/coolstore-partner-service/src/main/java/com/cool/store/service/impl/PointServiceImpl.java
index eea875f67..825630aaa 100644
--- a/coolstore-partner-service/src/main/java/com/cool/store/service/impl/PointServiceImpl.java
+++ b/coolstore-partner-service/src/main/java/com/cool/store/service/impl/PointServiceImpl.java
@@ -10,10 +10,7 @@ import com.cool.store.enums.*;
 import com.cool.store.enums.point.*;
 import com.cool.store.exception.ServiceException;
 import com.cool.store.request.*;
-import com.cool.store.service.LabelService;
-import com.cool.store.service.RegionService;
-import com.cool.store.service.PointService;
-import com.cool.store.service.UserAuthMappingService;
+import com.cool.store.service.*;
 import com.cool.store.utils.RedisUtilPool;
 import com.cool.store.utils.poi.StringUtils;
 import com.cool.store.vo.AuditInfoVO;
@@ -80,6 +77,8 @@ public class PointServiceImpl implements PointService {
     private ShopRentInfoDAO shopRentInfoDAO;
     @Resource
     private LineAuditInfoDAO lineAuditInfoDAO;
+    @Resource
+    private SysRoleService sysRoleService;
     @Value("${mybatis.configuration.variables.enterpriseId}")
     private String enterpriseId;
 
@@ -416,6 +415,13 @@ public class PointServiceImpl implements PointService {
 
     @Override
     public PageInfo<PointPageVO> getMyPointPage(PointPageRequest request) {
+        if(CollectionUtils.isNotEmpty(request.getRegionIds())){
+            if(request.getRegionIds().contains(CommonConstants.ROOT_DEPT_ID_STR)){
+                request.setRegionIds(null);
+            }else{
+                request.setRegionIds(regionService.getSubRegionIdsByRegionIds(request.getRegionIds()));
+            }
+        }
         List<PointPageVO> resultList = new ArrayList();
         Page<PointInfoDO> pointPage = pointInfoDAO.getMyPointPage(request);
         if(Objects.nonNull(pointPage) && CollectionUtils.isNotEmpty(pointPage.getResult())){
@@ -430,6 +436,32 @@ public class PointServiceImpl implements PointService {
         return resultPage;
     }
 
+    @Override
+    public PageInfo<PointPageVO> getTeamPointPage(AllPointPageRequest request){
+        if(!sysRoleService.checkIsAdmin(request.getCurUserId())){
+            request.setAuthRegionIds(userAuthMappingService.getAuthRegionIdAndSubRegionIdByUserId(request.getCurUserId()));
+        }
+        if(CollectionUtils.isNotEmpty(request.getRegionIds())){
+            if(request.getRegionIds().contains(CommonConstants.ROOT_DEPT_ID_STR)){
+                request.setRegionIds(null);
+            }else{
+                request.setRegionIds(regionService.getSubRegionIdsByRegionIds(request.getRegionIds()));
+            }
+        }
+        List<PointPageVO> resultList = new ArrayList();
+        Page<PointInfoDO> pointPage = pointInfoDAO.getTeamPointPage(request);
+        if(Objects.nonNull(pointPage) && CollectionUtils.isNotEmpty(pointPage.getResult())){
+            List<Long> regionIds = pointPage.stream().map(PointInfoDO::getRegionId).distinct().collect(Collectors.toList());
+            List<String> developmentManagers = pointPage.stream().map(PointInfoDO::getDevelopmentManager).distinct().collect(Collectors.toList());
+            Map<String, String> userNameMap = enterpriseUserDAO.getUserNameMap(developmentManagers);
+            Map<Long, String> regionNameMap = regionService.getBelongWarRegionNameMap(regionIds);
+            resultList = PointPageVO.convertVO(pointPage.getResult(), userNameMap, regionNameMap);
+        }
+        PageInfo resultPage = new PageInfo(pointPage);
+        resultPage.setList(resultList);
+        return resultPage;
+    }
+
     @Override
     public List<PointAuditRecordVO> getPointAllAuditRecord(Long pointId) {
         List<PointAuditRecordDO> auditRecordList = pointAuditRecordDAO.getPointAllAuditRecord(pointId);
diff --git a/coolstore-partner-service/src/main/java/com/cool/store/service/impl/RegionServiceImpl.java b/coolstore-partner-service/src/main/java/com/cool/store/service/impl/RegionServiceImpl.java
index 27945b33f..c612a620d 100644
--- a/coolstore-partner-service/src/main/java/com/cool/store/service/impl/RegionServiceImpl.java
+++ b/coolstore-partner-service/src/main/java/com/cool/store/service/impl/RegionServiceImpl.java
@@ -15,6 +15,7 @@ import com.cool.store.utils.RedisConstantUtil;
 import com.cool.store.utils.RedisUtilPool;
 import com.cool.store.utils.poi.constant.Constants;
 import com.cool.store.vo.RegionPathNameVO;
+import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
@@ -148,4 +149,16 @@ public class RegionServiceImpl implements RegionService {
         }
         return regionDao.listByThirdRegionType(parentId, thirdRegionType);
     }
+
+    @Override
+    public List<String> getSubRegionIdsByRegionIds(List<String> regionIds) {
+        if(CollectionUtils.isEmpty(regionIds)){
+            return Lists.newArrayList();
+        }
+        List<String> subRegionIds = regionMapper.getSubRegionIdsByRegionIds(regionIds);
+        if(CollectionUtils.isNotEmpty(subRegionIds)){
+            regionIds.addAll(subRegionIds);
+        }
+        return regionIds;
+    }
 }
diff --git a/coolstore-partner-service/src/main/java/com/cool/store/service/impl/UserAuthMappingServiceImpl.java b/coolstore-partner-service/src/main/java/com/cool/store/service/impl/UserAuthMappingServiceImpl.java
index f6f810002..2d161eeab 100644
--- a/coolstore-partner-service/src/main/java/com/cool/store/service/impl/UserAuthMappingServiceImpl.java
+++ b/coolstore-partner-service/src/main/java/com/cool/store/service/impl/UserAuthMappingServiceImpl.java
@@ -65,6 +65,20 @@ public class UserAuthMappingServiceImpl implements UserAuthMappingService {
         return userAuthMappingMapper.listUserAuthMappingByUserId(userId);
     }
 
+    @Override
+    public List<String> getAuthRegionIdAndSubRegionIdByUserId(String userId){
+        List<UserAuthMappingDO> userAuthMapping = listUserAuthMappingByUserId(userId);
+        if(CollectionUtils.isEmpty(userAuthMapping)){
+            return Lists.newArrayList();
+        }
+        List<String> regionIds = userAuthMapping.stream().map(UserAuthMappingDO::getMappingId).collect(Collectors.toList());
+        List<String> subRegionIds = regionMapper.getSubRegionIdsByRegionIds(regionIds);
+        if(CollectionUtils.isNotEmpty(subRegionIds)){
+            regionIds.addAll(subRegionIds);
+        }
+        return regionIds;
+    }
+
     /**
      * 提供 根据职位 意向区域  查  对应人的接口  同时返回人名字
      * @param userRoleEnum
diff --git a/coolstore-partner-web/src/main/java/com/cool/store/controller/webb/PointController.java b/coolstore-partner-web/src/main/java/com/cool/store/controller/webb/PointController.java
index 84eae1598..f148a22bb 100644
--- a/coolstore-partner-web/src/main/java/com/cool/store/controller/webb/PointController.java
+++ b/coolstore-partner-web/src/main/java/com/cool/store/controller/webb/PointController.java
@@ -134,6 +134,13 @@ public class PointController {
         return ResponseResult.success(pointService.getMyPointPage(request));
     }
 
+    @ApiOperation("全部铺位")
+    @PostMapping("/getTeamPointPage")
+    public ResponseResult<PageInfo<PointPageVO>> getTeamPointPage(@RequestBody @Validated AllPointPageRequest request) {
+        request.setCurUserId(CurrentUserHolder.getUserId());
+        return ResponseResult.success(pointService.getTeamPointPage(request));
+    }
+
     @ApiOperation("获取单个铺位审批记录")
     @GetMapping("/getAuditRecord")
     public ResponseResult<List<PointAuditRecordVO>> getPointAllAuditRecord(@RequestParam("pointId")Long pointId) {