From dc600db1211ba96302c2f75b4dd224512aad89cf Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期五, 19 一月 2024 15:32:09 +0800
Subject: [PATCH] 修改bug

---
 ruoyi-modules/ruoyi-shop/src/main/java/com/ruoyi/shop/service/impl/shop/ShopServiceImpl.java |  126 ++++++++++++++++++++++++++++++++++--------
 1 files changed, 102 insertions(+), 24 deletions(-)

diff --git a/ruoyi-modules/ruoyi-shop/src/main/java/com/ruoyi/shop/service/impl/shop/ShopServiceImpl.java b/ruoyi-modules/ruoyi-shop/src/main/java/com/ruoyi/shop/service/impl/shop/ShopServiceImpl.java
index b22a058..4877a1c 100644
--- a/ruoyi-modules/ruoyi-shop/src/main/java/com/ruoyi/shop/service/impl/shop/ShopServiceImpl.java
+++ b/ruoyi-modules/ruoyi-shop/src/main/java/com/ruoyi/shop/service/impl/shop/ShopServiceImpl.java
@@ -18,6 +18,7 @@
 import com.ruoyi.common.core.domain.R;
 import com.ruoyi.common.core.exception.ServiceException;
 import com.ruoyi.common.core.utils.DateUtils;
+import com.ruoyi.common.core.utils.ExceptionUtil;
 import com.ruoyi.common.core.utils.StringUtils;
 import com.ruoyi.common.core.utils.bean.BeanUtils;
 import com.ruoyi.common.core.utils.uuid.IdUtils;
@@ -555,8 +556,21 @@
         if (StringUtils.isNotBlank(mgtShopPageDto.getShopTags())) {
             mgtShopPageDto.setShopTags(mgtShopPageDto.getShopTags().replace(",", "|"));
         }
+        List<Long> belongUserIds = null;
+        if(null != mgtShopPageDto.getDeptId()){
+            if(null != mgtShopPageDto.getBelongUserId()){
+                belongUserIds = new ArrayList<>();
+                belongUserIds.add(mgtShopPageDto.getBelongUserId());
+            }else{
+                R<List<SysUser>> r = sysUserService.getUsersByDeptId(mgtShopPageDto.getDeptId());
+                if(r.getCode() != 200){
+                    throw new RuntimeException(r.getMsg());
+                }
+                belongUserIds = r.getData().stream().map(SysUser::getUserId).collect(Collectors.toList());
+            }
+        }
         // 分页查询商铺信息
-        List<MgtShopPageVo> mgtShopPageVoList = shopMapper.pageMgtShop(page, mgtShopPageDto);
+        List<MgtShopPageVo> mgtShopPageVoList = shopMapper.pageMgtShop(page, mgtShopPageDto, belongUserIds);
         // 如果查询结果不为空
         if (!mgtShopPageVoList.isEmpty()) {
             // 创建签约用户ID集合和所属用户ID集合
@@ -598,8 +612,9 @@
                     shopPageVo.setSignUser(signUserMap.get(shopPageVo.getSignUserId()).getNickName());
                 }
                 if (belongUserMap!=null&&!belongUserMap.isEmpty()&&shopPageVo.getBelongUserId() != null) {
-                    shopPageVo.setBelongUser(belongUserMap.get(shopPageVo.getBelongUserId()).getNickName());
-                    shopPageVo.setBelongDept(belongUserMap.get(shopPageVo.getBelongUserId()).getDeptName());
+                    MgtSysSimpleUserVo mgtSysSimpleUserVo = belongUserMap.get(shopPageVo.getBelongUserId());
+                    shopPageVo.setBelongUser(null == mgtSysSimpleUserVo ? "" : mgtSysSimpleUserVo.getNickName());
+                    shopPageVo.setBelongDept(null == mgtSysSimpleUserVo ? "" : mgtSysSimpleUserVo.getDeptName());
                 }
             }
         }
@@ -764,6 +779,7 @@
         }else if(StringUtils.isNotBlank(appNearbyShopDto.getLatitude())&&StringUtils.isNotBlank(appNearbyShopDto.getLongitude())){
             List<AppNearShopVo> appNearShopVos = shopMapper.getNearbyShops(appNearbyShopDto);
             if(appNearShopVos.size() > 0){
+                log.info("候选店铺:{}", JSON.toJSONString(appNearShopVos));
                 StringBuffer to = new StringBuffer();
                 for (AppNearShopVo appNearShopVo : appNearShopVos) {
                     to.append(appNearShopVo.getLatitude() + "," + appNearShopVo.getLongitude() + ";");
@@ -780,7 +796,7 @@
                 List<TencentDistanceMatrixElements> elements = data.get(0).getElements();
                 for (int i = 0; i < elements.size(); i++) {
                     TencentDistanceMatrixElements matrix = elements.get(i);
-                    if(dis.compareTo(BigDecimal.ZERO) == 0 || dis.compareTo(new BigDecimal(matrix.getDistance())) > 0){
+                    if(i == 0 || dis.compareTo(new BigDecimal(matrix.getDistance())) > 0){
                         dis = new BigDecimal(matrix.getDistance());
                         appNearShopVo = appNearShopVos.get(i);
                     }
@@ -843,7 +859,43 @@
         List<Long> userIds = new ArrayList<>();
         List<Long> shopIds = new ArrayList<>();
         //如果是leader 查询leader下面所有的员工下的所有shopId
-        if(remoteSysStaffService.isLeader()){
+//        if(remoteSysStaffService.isLeader()){
+//            userIds = sysUserService.getUserIdsByDept(userId).getData();
+//            //根据用户所有id查询关联的商户id
+//            MgtBasePlatformDto mgtBasePlatformDto = new MgtBasePlatformDto();
+//            mgtBasePlatformDto.setUserIdList(userIds);
+//            shopIds = shopMapper.listShopIdByTotal(mgtBasePlatformDto);
+//            List<Shop> shopList = this.getShopByBelongUserId(userId);
+//            if(shopList!=null&&!shopList.isEmpty()){
+//                for(Shop shop : shopList){
+//                    shopIds.add(shop.getShopId());
+//                }
+//                userIds.add(userId);
+//            }
+//        }else {
+//            //普通员工查询商户归属的shopId
+//            List<Shop> shopList = this.getShopByBelongUserId(userId);
+//            if(shopList!=null&&!shopList.isEmpty()){
+//                for(Shop shop : shopList){
+//                    shopIds.add(shop.getShopId());
+//                }
+//                userIds.add(userId);
+//            }
+//        }
+
+        // TODO: 2023/12/5 统一改成使用权限来控制数据
+        R<SysUser> sysUser = sysUserService.getSysUser(userId);
+        if(sysUser.getCode() != 200){
+            throw new RuntimeException(sysUser.getMsg());
+        }
+        //员工端数据权限(1:所有数据权限;2:自定义数据权限;3:本部门数据权限;4:本部门及以下数据权限;5:仅本人数据权限)
+        //2/4暂未使用
+        String dataScopeEmployee = sysUser.getData().getDataScopeEmployee();
+        if(dataScopeEmployee.equals("1")){
+            userIds = null;
+            shopIds = null;
+        }
+        if(dataScopeEmployee.equals("3")){
             userIds = sysUserService.getUserIdsByDept(userId).getData();
             //根据用户所有id查询关联的商户id
             MgtBasePlatformDto mgtBasePlatformDto = new MgtBasePlatformDto();
@@ -856,8 +908,8 @@
                 }
                 userIds.add(userId);
             }
-        }else {
-            //普通员工查询商户归属的shopId
+        }
+        if(dataScopeEmployee.equals("5")){
             List<Shop> shopList = this.getShopByBelongUserId(userId);
             if(shopList!=null&&!shopList.isEmpty()){
                 for(Shop shop : shopList){
@@ -866,19 +918,10 @@
                 userIds.add(userId);
             }
         }
+
         //分别查询
-        StaffHomeShopTotalVo staffHomeShopTotalVo = new StaffHomeShopTotalVo();
-        if(userIds!=null&&!userIds.isEmpty()){
-            staffHomeShopTotalVo = shopMapper.getStaffHomeTotal(userIds);
-        }else{
-            staffHomeShopTotalVo.setShopTotal(0);
-            staffHomeShopTotalVo.setAgencyTotal(0);
-            staffHomeShopTotalVo.setDealerTotal(0);
-        }
-        Integer shopTaskCount = 0;
-        if(shopIds!=null&&!shopIds.isEmpty()){
-            shopTaskService.getShopIngTotal(shopIds);
-        }
+        StaffHomeShopTotalVo staffHomeShopTotalVo = shopMapper.getStaffHomeTotal(userIds);
+        Integer shopTaskCount = shopTaskService.getShopIngTotal(shopIds);
         staffHomeShopTotalVo.setFollowMember(0);
         staffHomeShopTotalVo.setNewMember(0);
         staffHomeShopTotalVo.setShopTask(shopTaskCount);
@@ -1122,8 +1165,9 @@
      */
     @Override
     public void mgtShopHFTXAuth(MgtShopHFTXAuthDto mgtShopHFTXAuthDto) {
-        ShopAuthenticationHftx shopAuthenticationHftx = shopAuthenticationHftxService.getOne(new QueryWrapper<ShopAuthenticationHftx>().eq("shop_id", mgtShopHFTXAuthDto.getShopId()));
-        if(null != shopAuthenticationHftx && "U".equals(shopAuthenticationHftx.getAuditStatus())){
+        ShopAuthenticationHftx shopAuthenticationHftx = shopAuthenticationHftxService.getOne(new QueryWrapper<ShopAuthenticationHftx>()
+                .eq("shop_id", mgtShopHFTXAuthDto.getShopId()).eq("is_delete", 0));
+        if(null != shopAuthenticationHftx && Arrays.asList("U", "Y").contains(shopAuthenticationHftx.getAuditStatus())){
             throw new ServiceException("不能重复进件");
         }
         if(null == shopAuthenticationHftx){
@@ -1446,17 +1490,37 @@
     @Override
     public StaffShopSimpleTotalVo getStaffSimpleTotal(Long userId){
         List<Long> userIdList = new ArrayList<>();
-        if(remoteSysStaffService.isLeader()){
+//        if(remoteSysStaffService.isLeader()){
+//            userIdList = sysUserService.getUserIdsByDept(userId).getData();
+//            userIdList.add(userId);
+//        }else {
+//            userIdList.add(userId);
+//        }
+
+        // TODO: 2023/12/5 统一改成使用权限来控制数据
+        R<SysUser> sysUser = sysUserService.getSysUser(userId);
+        if(sysUser.getCode() != 200){
+            throw new RuntimeException(sysUser.getMsg());
+        }
+        //员工端数据权限(1:所有数据权限;2:自定义数据权限;3:本部门数据权限;4:本部门及以下数据权限;5:仅本人数据权限)
+        //2/4暂未使用
+        String dataScopeEmployee = sysUser.getData().getDataScopeEmployee();
+        if(dataScopeEmployee.equals("1")){
+            userIdList = null;
+        }
+        if(dataScopeEmployee.equals("3")){
             userIdList = sysUserService.getUserIdsByDept(userId).getData();
             userIdList.add(userId);
-        }else {
+        }
+        if(dataScopeEmployee.equals("5")){
             userIdList.add(userId);
         }
+
         StaffShopSimpleTotalVo shopTotal = shopMapper.getStaffSimpleTotal(1,userIdList);
         StaffShopSimpleTotalVo agencyTotal = shopMapper.getStaffSimpleTotal(2,userIdList);
         shopTotal.setAgencyTotal(agencyTotal.getShopTotal());
         shopTotal.setOpenAgencyTotal(agencyTotal.getOpenShopTotal());
-        shopTotal.setCloseAgencyTotal(agencyTotal.getCloseAgencyTotal());
+        shopTotal.setCloseAgencyTotal(agencyTotal.getCloseShopTotal());
         return shopTotal;
     }
 
@@ -1850,4 +1914,18 @@
         Integer pageSize = merchantBasicdataSettlementDto.getPageSize();
         return HuiFuTianXiaUtil.getMerchantBasicdataSettlement(IdUtils.simpleUUID(), huifuId, startTime, endTime, pageNum.toString(), pageSize.toString());
     }
+
+
+
+    /**
+     * @description
+     * @author  jqs
+     * @date    2023/8/10 22:53
+     * @param cityCodes
+     * @return  List<Long>
+     */
+    @Override
+    public List<Shop> listShopByCityCode(List<String> cityCodes){
+        return shopMapper.listShopByCityCode(cityCodes);
+    }
 }

--
Gitblit v1.7.1