| | |
|---|
| | | import com.ruoyi.chargingPile.api.query.TMonitoringEquipmentQuery; |
|---|
| | | import com.ruoyi.chargingPile.api.vo.TMonitoringEquipmentVO; |
|---|
| | | import com.ruoyi.chargingPile.api.vo.TParkingLotVO; |
|---|
| | | import com.ruoyi.chargingPile.domain.SiteMenu; |
|---|
| | | import com.ruoyi.chargingPile.mapper.TMonitoringEquipmentMapper; |
|---|
| | | import com.ruoyi.chargingPile.service.IPartnerService; |
|---|
| | | import com.ruoyi.chargingPile.service.TMonitoringEquipmentService; |
|---|
| | | import com.ruoyi.chargingPile.service.TParkingLotService; |
|---|
| | | 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 org.springframework.stereotype.Service; |
|---|
| | | |
|---|
| | | import javax.annotation.Resource; |
|---|
| | | import java.util.HashSet; |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.Set; |
|---|
| | | import java.util.stream.Collectors; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * <p> |
|---|
| | |
|---|
| | | */ |
|---|
| | | @Service |
|---|
| | | public class TMonitoringEquipmentServiceImpl extends ServiceImpl<TMonitoringEquipmentMapper, TMonitoringEquipment> implements TMonitoringEquipmentService { |
|---|
| | | @Resource |
|---|
| | | private SysUserClient sysUserClient; |
|---|
| | | |
|---|
| | | @Resource |
|---|
| | | private IPartnerService partnerService; |
|---|
| | | |
|---|
| | | @Resource |
|---|
| | | private TParkingLotService parkingLotService; |
|---|
| | | @Override |
|---|
| | | public PageInfo<TMonitoringEquipmentVO> pageList(TMonitoringEquipmentQuery query) { |
|---|
| | | |
|---|
| | | //校验合作商权限 |
|---|
| | | SysUser sysUser = sysUserClient.getSysUser(SecurityUtils.getUserId()).getData(); |
|---|
| | | Integer roleType = sysUser.getRoleType(); |
|---|
| | | Integer objectId = sysUser.getObjectId(); |
|---|
| | | // 查询管理站点下的停车场 |
|---|
| | | List<TParkingLotVO> parkingLotVOS = parkingLotService.getList(null); |
|---|
| | | List<Integer> parkingLotIds = parkingLotVOS.stream().map(TParkingLotVO::getId).collect(Collectors.toList()); |
|---|
| | | |
|---|
| | | PageInfo<TMonitoringEquipmentVO> pageInfo = new PageInfo<>(query.getPageCurr(),query.getPageSize()); |
|---|
| | | List<TMonitoringEquipmentVO> list = this.baseMapper.pageList(query,pageInfo); |
|---|
| | | List<TMonitoringEquipmentVO> list = this.baseMapper.pageList(query,pageInfo,parkingLotIds); |
|---|
| | | for (TMonitoringEquipmentVO monitoringEquipmentVO : list) { |
|---|
| | | Integer siteId = parkingLotVOS.stream().filter(park->park.getId().equals(monitoringEquipmentVO.getParkingLotId())).findFirst().get().getSiteId(); |
|---|
| | | monitoringEquipmentVO.setAuthQueryInfo(roleType == 1 ? true : partnerService.authMenu(objectId, siteId, SiteMenu.PARKING_LOT_MONITOR)); |
|---|
| | | } |
|---|
| | | pageInfo.setRecords(list); |
|---|
| | | return pageInfo; |
|---|
| | | } |
|---|
