From ff859437dd9d18d9d7411bafc4c31038f940b9f2 Mon Sep 17 00:00:00 2001 From: zhibing.pu <393733352@qq.com> Date: 星期五, 09 八月 2024 18:53:56 +0800 Subject: [PATCH] 添加管理员和非管理员的站点权限功能 --- ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/controller/SiteController.java | 128 +++++++++++++++++++++++++++++++++++++++++- 1 files changed, 125 insertions(+), 3 deletions(-) diff --git a/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/controller/SiteController.java b/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/controller/SiteController.java index 1bf5768..1af8a88 100644 --- a/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/controller/SiteController.java +++ b/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/controller/SiteController.java @@ -1,11 +1,33 @@ package com.ruoyi.chargingPile.controller; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.ruoyi.chargingPile.api.dto.GetSiteListDTO; +import com.ruoyi.chargingPile.api.model.Site; +import com.ruoyi.chargingPile.api.query.GetSiteList; +import com.ruoyi.chargingPile.api.query.SiteDetailQuery; +import com.ruoyi.chargingPile.api.query.SiteQuery; +import com.ruoyi.chargingPile.api.vo.SiteDetailVO; +import com.ruoyi.chargingPile.api.vo.SiteVO; +import com.ruoyi.chargingPile.domain.SiteMenu; +import com.ruoyi.chargingPile.service.IPartnerService; import com.ruoyi.chargingPile.service.ISiteService; import com.ruoyi.common.core.web.domain.AjaxResult; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RestController; +import com.ruoyi.common.core.web.page.PageInfo; +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 io.swagger.annotations.ApiImplicitParam; +import io.swagger.annotations.ApiImplicitParams; +import io.swagger.annotations.ApiOperation; +import org.springframework.validation.annotation.Validated; +import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; +import java.util.HashSet; +import java.util.List; +import java.util.Set; /** * @author zhibing.pu @@ -18,9 +40,109 @@ @Resource private ISiteService siteService; + @Resource + private IPartnerService partnerService; + + @Resource + private SysUserClient sysUserClient; + + @Resource + private UserSiteClient userSiteClient; + + @Resource + private RoleSiteClient roleSiteClient; - public AjaxResult<> getSiteList(){ + + + + + @ResponseBody + @GetMapping("/getSiteList") + @ApiOperation(value = "获取站点列表", tags = {"管理后台-站点管理"}) + public AjaxResult<PageInfo<GetSiteListDTO>> getSiteList(@RequestBody GetSiteList siteList){ + PageInfo<GetSiteListDTO> list = siteService.getSiteList(siteList); + return AjaxResult.success(list); + } + + @ApiOperation(value = "获取站点分页列表", tags = {"小程序-站点管理"}) + @PostMapping("/pageList") + public AjaxResult<PageInfo<SiteVO>> pageList(@Validated @RequestBody SiteQuery query){ + return AjaxResult.success(siteService.pageList(query)); + } + + @ApiOperation(value = "获取站点详细信息", tags = {"小程序-站点管理"}) + @GetMapping("/getDetailById") + public AjaxResult<SiteDetailVO> getDetailById(@Validated @RequestBody SiteDetailQuery query){ + SiteDetailVO siteDetailVO = siteService.getDetailById(query.getSiteId()); + + // TODO 查询绑定车牌提示文案 + return AjaxResult.success(siteDetailVO); + } + + + @ResponseBody + @PostMapping("/getSiteList") + @ApiOperation(value = "添加站点", tags = {"管理后台-站点管理"}) + public AjaxResult addSite(@RequestBody Site site){ + return siteService.addSite(site); + } + + @ResponseBody + @PostMapping("/editSite") + @ApiOperation(value = "编辑站点", tags = {"管理后台-站点管理"}) + public AjaxResult editSite(@RequestBody Site site){ + return siteService.editSite(site); + } + + @ResponseBody + @DeleteMapping("/delSite/{id}") + @ApiOperation(value = "删除站点", tags = {"管理后台-站点管理"}) + @ApiImplicitParams({ + @ApiImplicitParam(value = "站点id", name = "id", dataTypeClass = Integer.class, required = true) + }) + public AjaxResult delSite(@PathVariable Integer id){ + return siteService.delSite(id); + } + + + @ResponseBody + @PostMapping("/setAccountingStrategy/{id}") + @ApiOperation(value = "设置站点计费策略", tags = {"管理后台-站点管理"}) + @ApiImplicitParams({ + @ApiImplicitParam(value = "站点id", name = "id", dataTypeClass = Integer.class, required = true), + @ApiImplicitParam(value = "计费策略id", name = "accountingStrategyId", dataTypeClass = Integer.class, required = true) + }) + public AjaxResult setAccountingStrategy(@PathVariable("id") Integer id, @RequestParam("accountingStrategyId") Integer accountingStrategyId){ + siteService.setAccountingStrategy(id, accountingStrategyId); + return AjaxResult.success(); + } + + + @ResponseBody + @GetMapping("/getAllSiteList") + @ApiOperation(value = "获取所有站点数据", tags = {"管理后台-充电桩信息"}) + public AjaxResult<List<Site>> getAllSiteList(){ + //校验当前账户站点权限 + SysUser sysUser = sysUserClient.getSysUser(SecurityUtils.getUserId()).getData(); + Integer roleType = sysUser.getRoleType(); + Integer objectId = sysUser.getObjectId(); + LambdaQueryWrapper<Site> wrapper = new LambdaQueryWrapper<Site>().eq(Site::getDelFlag, 0); + if(2 == roleType){ + Set<Integer> list = partnerService.authSite(objectId, SiteMenu.SITE_LIST); + wrapper.in(Site::getId, list); + }else{ + //非管理员需要根据角色和用户配置查询允许的站点数据 + if(!SecurityUtils.isAdmin(SecurityUtils.getUserId())){ + List<Integer> data = userSiteClient.getSiteIds(sysUser.getUserId()).getData(); + List<Integer> data1 = roleSiteClient.getSiteIds(sysUser.getRoleId()).getData(); + data.addAll(data1); + Set<Integer> list = new HashSet<>(data); + wrapper.in(Site::getId, list); + } + } + List<Site> list = siteService.list(wrapper.orderByDesc(Site::getCreateTime)); + return AjaxResult.success(list); } } -- Gitblit v1.7.1