From c05a14bba4b86d83918d7cdc01635785bf5694c2 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期二, 03 六月 2025 00:26:08 +0800
Subject: [PATCH] 拆分mongodb查询服务

---
 ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TParkingLotServiceImpl.java |   29 ++++++++++++++++++++---------
 1 files changed, 20 insertions(+), 9 deletions(-)

diff --git a/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TParkingLotServiceImpl.java b/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TParkingLotServiceImpl.java
index d56b2b2..4985685 100644
--- a/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TParkingLotServiceImpl.java
+++ b/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TParkingLotServiceImpl.java
@@ -1,20 +1,22 @@
 package com.ruoyi.chargingPile.service.impl;
 
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.ruoyi.chargingPile.api.dto.PageChargingPileListDTO;
 import com.ruoyi.chargingPile.api.model.TParkingLot;
 import com.ruoyi.chargingPile.api.query.TParkingLotQuery;
 import com.ruoyi.chargingPile.api.vo.TParkingLotVO;
-import com.ruoyi.chargingPile.domain.SiteMenu;
+import com.ruoyi.chargingPile.api.domain.SiteMenu;
 import com.ruoyi.chargingPile.mapper.TParkingLotMapper;
 import com.ruoyi.chargingPile.service.IPartnerService;
 import com.ruoyi.chargingPile.service.TParkingLotService;
 import com.ruoyi.common.core.web.page.PageInfo;
+import com.ruoyi.common.security.service.TokenService;
 import com.ruoyi.common.security.utils.SecurityUtils;
 import com.ruoyi.other.api.feignClient.RoleSiteClient;
 import com.ruoyi.other.api.feignClient.UserSiteClient;
 import com.ruoyi.system.api.domain.SysUser;
 import com.ruoyi.system.api.feignClient.SysUserClient;
+import com.ruoyi.system.api.feignClient.SysUserRoleClient;
+import com.ruoyi.system.api.model.SysUserRoleVo;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
@@ -34,7 +36,8 @@
 public class TParkingLotServiceImpl extends ServiceImpl<TParkingLotMapper, TParkingLot> implements TParkingLotService {
     @Resource
     private SysUserClient sysUserClient;
-
+    @Resource
+    private TokenService tokenService;
     @Resource
     private IPartnerService partnerService;
 
@@ -43,12 +46,18 @@
 
     @Resource
     private RoleSiteClient roleSiteClient;
+
+    @Resource
+    private SysUserRoleClient sysUserRoleClient;
+
+
+
     @Override
     public PageInfo<TParkingLotVO> pageList(TParkingLotQuery query) {
 
         Set<Integer> siteIds = null;
         //校验合作商权限
-        SysUser sysUser = sysUserClient.getSysUser(SecurityUtils.getUserId()).getData();
+        SysUser sysUser = sysUserClient.getSysUser(tokenService.getLoginUser().getUserid()).getData();
         Integer roleType = sysUser.getRoleType();
         Integer objectId = sysUser.getObjectId();
         //合作商
@@ -56,9 +65,10 @@
             siteIds = partnerService.authSite(objectId, SiteMenu.PARKING_LOT);
         }else{
             //非管理员需要根据角色和用户配置查询允许的站点数据
-            if(!SecurityUtils.isAdmin(SecurityUtils.getUserId())){
+            if(!SecurityUtils.isAdmin(tokenService.getLoginUser().getUserid())){
                 List<Integer> data = userSiteClient.getSiteIds(sysUser.getUserId()).getData();
-                List<Integer> data1 = roleSiteClient.getSiteIds(sysUser.getRoleId()).getData();
+                List<SysUserRoleVo> data2 = sysUserRoleClient.getRoleByUserId(sysUser.getUserId()).getData();
+                List<Integer> data1 = roleSiteClient.getSiteIds(data2.get(0).getRoleId()).getData();
                 data.addAll(data1);
                 siteIds = new HashSet<>(data);
             }
@@ -81,7 +91,7 @@
     public List<TParkingLotVO> getList(String name) {
         Set<Integer> siteIds = null;
         //校验合作商权限
-        SysUser sysUser = sysUserClient.getSysUser(SecurityUtils.getUserId()).getData();
+        SysUser sysUser = sysUserClient.getSysUser(tokenService.getLoginUser().getUserid()).getData();
         Integer roleType = sysUser.getRoleType();
         Integer objectId = sysUser.getObjectId();
         //合作商
@@ -89,9 +99,10 @@
             siteIds = partnerService.authSite(objectId, SiteMenu.PARKING_LOT);
         }else{
             //非管理员需要根据角色和用户配置查询允许的站点数据
-            if(!SecurityUtils.isAdmin(SecurityUtils.getUserId())){
+            if(!SecurityUtils.isAdmin(tokenService.getLoginUser().getUserid())){
                 List<Integer> data = userSiteClient.getSiteIds(sysUser.getUserId()).getData();
-                List<Integer> data1 = roleSiteClient.getSiteIds(sysUser.getRoleId()).getData();
+                List<SysUserRoleVo> data2 = sysUserRoleClient.getRoleByUserId(sysUser.getUserId()).getData();
+                List<Integer> data1 = roleSiteClient.getSiteIds(data2.get(0).getRoleId()).getData();
                 data.addAll(data1);
                 siteIds = new HashSet<>(data);
             }

--
Gitblit v1.7.1