package com.ruoyi.chargingPile.controller; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.ruoyi.chargingPile.api.dto.GetSiteListDTO; import com.ruoyi.chargingPile.api.feignClient.ParkingLotClient; import com.ruoyi.chargingPile.api.model.*; 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.*; import com.ruoyi.chargingPile.domain.SiteMenu; import com.ruoyi.chargingPile.dto.ChargingPercentBack; import com.ruoyi.common.core.dto.ChargingOrderGroup; import com.ruoyi.common.core.dto.ChargingPercentProvinceDto; import com.ruoyi.chargingPile.service.*; import com.ruoyi.common.core.domain.R; import com.ruoyi.common.core.utils.StringUtils; import com.ruoyi.common.core.web.domain.AjaxResult; import com.ruoyi.common.core.web.page.PageInfo; import com.ruoyi.common.log.annotation.Log; import com.ruoyi.common.log.enums.BusinessType; import com.ruoyi.common.security.utils.SecurityUtils; import com.ruoyi.order.api.feignClient.ChargingOrderClient; import com.ruoyi.order.api.model.TChargingOrder; 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 io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiParam; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import java.math.BigDecimal; import java.time.LocalDate; import java.time.LocalTime; import java.time.temporal.ChronoUnit; import java.util.*; import java.util.stream.Collectors; /** * @author zhibing.pu * @Date 2024/8/7 19:56 */ @RestController @RequestMapping("/site") public class SiteController { @Resource private ISiteService siteService; @Resource private IPartnerService partnerService; @Resource private SysUserClient sysUserClient; @Resource private UserSiteClient userSiteClient; @Resource private RoleSiteClient roleSiteClient; @Resource private ParkingLotClient parkingLotClient; @Resource private TChargingPileService chargingPileService; @Resource private TChargingGunService chargingGunService; @Autowired private TParkingLotService parkingLotService; @Autowired private TAccountingStrategyService accountingStrategyService; @Autowired private TAccountingStrategyDetailService accountingStrategyDetailService; @Resource private ChargingOrderClient chargingOrderClient; @Resource private SysUserRoleClient userRoleClient; /** * 根据站点id 查询所有充电桩 * @param siteId * @return */ @GetMapping("/getPileListBySiteId/{siteId}") public R> getPileListBySiteId(@PathVariable("siteId")Integer siteId){ return R.ok(chargingPileService.lambdaQuery().eq(TChargingPile::getSiteId, siteId).list()); } /** * 小程序扫一扫 * @param number * @return */ @GetMapping("/getSiteInfoByNumber") @ApiOperation(value = "扫一扫后通过桩编号获取电站信息", tags = {"小程序-扫一扫"}) public R getSiteInfoByNumber(@RequestParam("number") String number){ SiteInfoVO siteInfoVO = new SiteInfoVO(); String chargingPileCode = number.substring(0, number.length() - 2); String chargingGunCode = number.substring(number.length() - 2); TChargingPile one = chargingPileService.lambdaQuery().eq(TChargingPile::getCode, chargingPileCode).one(); TChargingGun chargingGun = chargingGunService.getOne(new LambdaQueryWrapper().eq(TChargingGun::getCode, chargingGunCode).eq(TChargingGun::getChargingPileId, one.getId())); Site byId = siteService.getById(one.getSiteId()); TAccountingStrategy byId1 = accountingStrategyService.getById(byId.getAccountingStrategyId()); List list = accountingStrategyDetailService.lambdaQuery().eq(TAccountingStrategyDetail::getAccountingStrategyId, byId1.getId()).list(); for (TAccountingStrategyDetail tAccountingStrategyDetail : list) { // 当前时间属于那个阶段 取哪个阶段的电价 if(LocalTime.now().isAfter(LocalTime.parse(tAccountingStrategyDetail.getStartTime())) && LocalTime.now().isBefore(LocalTime.parse(tAccountingStrategyDetail.getEndTime()))){ siteInfoVO.setElectrovalence(tAccountingStrategyDetail.getElectrovalence()); if(null != byId1.getDiscount()){ siteInfoVO.setVipElectrovalence(tAccountingStrategyDetail.getElectrovalence().multiply(byId1.getDiscount()).setScale(4, BigDecimal.ROUND_HALF_UP)); }else{ siteInfoVO.setVipElectrovalence(tAccountingStrategyDetail.getElectrovalence()); } } } siteInfoVO.setChargingGunId(chargingGun.getId()); siteInfoVO.setChargingPileId(one.getId()); siteInfoVO.setName(byId.getName()); siteInfoVO.setNumber(one.getNumber().toString()); siteInfoVO.setSpaceChargeExplain(byId.getSpaceChargeExplain()); return R.ok(siteInfoVO); } /** * 通过桩编号获取电站信息 遠程調用 * @param number * @return */ @PostMapping("/getSiteInfoByNumber1") public R getSiteInfoByNumber1(@RequestParam("number") String number){ SiteInfoVO siteInfoVO = new SiteInfoVO(); TChargingPile one = chargingPileService.lambdaQuery().eq(TChargingPile::getCode, number).one(); Site byId = siteService.getById(one.getSiteId()); TAccountingStrategy byId1 = accountingStrategyService.getById(byId.getAccountingStrategyId()); List list = accountingStrategyDetailService.lambdaQuery().eq(TAccountingStrategyDetail::getAccountingStrategyId, byId1.getId()).list(); for (TAccountingStrategyDetail tAccountingStrategyDetail : list) { // 当前时间属于那个阶段 取哪个阶段的电价 if(LocalTime.now().isAfter(LocalTime.parse(tAccountingStrategyDetail.getStartTime())) && LocalTime.now().isBefore(LocalTime.parse(tAccountingStrategyDetail.getEndTime()))){ siteInfoVO.setElectrovalence(tAccountingStrategyDetail.getElectrovalence()); if(null != byId1.getDiscount()){ siteInfoVO.setVipElectrovalence(tAccountingStrategyDetail.getElectrovalence().multiply(byId1.getDiscount()).setScale(4, BigDecimal.ROUND_HALF_UP)); }else{ siteInfoVO.setVipElectrovalence(tAccountingStrategyDetail.getElectrovalence()); } } } siteInfoVO.setChargingPileId(one.getId()); siteInfoVO.setName(byId.getName()); siteInfoVO.setNumber(one.getNumber().toString()); siteInfoVO.setSpaceChargeExplain(byId.getSpaceChargeExplain()); return R.ok(siteInfoVO); } @GetMapping("/getSiteList") @ApiOperation(value = "获取站点列表", tags = {"管理后台-站点管理"}) public AjaxResult> getSiteList(GetSiteList siteList){ PageInfo list = siteService.getSiteList(siteList); return AjaxResult.success(list); } @GetMapping("/getSiteList/byUserId") @ApiOperation(value = "获取站点列表", tags = {"管理后台-站点管理"}) public R> getSiteListByUserId(@RequestParam("userId") Long userId){ PageInfo list = siteService.getSiteList1(userId); return R.ok(list.getRecords()); } @GetMapping("/map/getSiteList") @ApiOperation(value = "获取站点", tags = {"管理后台-数据分析-电站分析"}) public R> getMapSiteList(GetSiteList siteList){ siteList.setPageCurr(1); siteList.setPageSize(99999); PageInfo list = siteService.getSiteList(siteList); for (GetSiteListDTO record : list.getRecords()) { Long count = chargingGunService.lambdaQuery().eq(TChargingGun::getChargingPileId, record.getId()).eq(TChargingGun::getChargeMode, 1).eq(TChargingGun::getStatus, new int[]{3, 4, 5, 6}).count(); record.setC1(count); Long count1 = chargingGunService.lambdaQuery().eq(TChargingGun::getChargingPileId, record.getId()).eq(TChargingGun::getChargeMode, 1).eq(TChargingGun::getStatus, 2).count(); record.setC2(count1); Long count2 = chargingGunService.lambdaQuery().eq(TChargingGun::getChargingPileId, record.getId()).eq(TChargingGun::getChargeMode, 2).eq(TChargingGun::getStatus, new int[]{3, 4, 5, 6}).count(); record.setK1(count2); Long count3 = chargingGunService.lambdaQuery().eq(TChargingGun::getChargingPileId, record.getId()).eq(TChargingGun::getChargeMode, 2).eq(TChargingGun::getStatus, 2).count(); record.setK2(count3); Long count4 = chargingGunService.lambdaQuery().eq(TChargingGun::getChargingPileId, record.getId()).eq(TChargingGun::getChargeMode, 3).eq(TChargingGun::getStatus, new int[]{3, 4, 5, 6}).count(); record.setM1(count4); Long count5 = chargingGunService.lambdaQuery().eq(TChargingGun::getChargingPileId, record.getId()).eq(TChargingGun::getChargeMode, 3).eq(TChargingGun::getStatus, 2).count(); record.setM2(count5); //利用率 BigDecimal bigDecimal = new BigDecimal("0"); //获取该站点的总充电度数 List chargingOrders = chargingOrderClient.getList(record.getId()).getData(); for (TChargingOrder chargingOrder : chargingOrders) { bigDecimal = bigDecimal.add(chargingOrder.getChargingCapacity()); } //获取该站点的所有充电桩 List chargingPiles = chargingPileService.lambdaQuery().eq(TChargingPile::getSiteId, record.getId()).list(); BigDecimal bigDecimal1 = new BigDecimal("0"); for (TChargingPile chargingPile : chargingPiles) { bigDecimal1 = bigDecimal1.add(chargingPile.getRatedPower()); } BigDecimal multiply = bigDecimal1.multiply(new BigDecimal("24")); BigDecimal divide = bigDecimal.divide(multiply, 0, BigDecimal.ROUND_HALF_UP); record.setP1(divide); } return R.ok(list.getRecords()); } @GetMapping("/map/getPercent") @ApiOperation(value = "获取该充电站的利用率", tags = {"管理后台-数据分析-电站分析"}) public R getPercent(Integer siteId){ BigDecimal bigDecimal = new BigDecimal("0"); //获取该站点的总充电度数 List chargingOrders = chargingOrderClient.getList(siteId).getData(); for (TChargingOrder chargingOrder : chargingOrders) { bigDecimal = bigDecimal.add(chargingOrder.getChargingCapacity()); } //获取该站点的所有充电桩 List chargingPiles = chargingPileService.lambdaQuery().eq(TChargingPile::getSiteId, siteId).list(); BigDecimal bigDecimal1 = new BigDecimal("0"); for (TChargingPile chargingPile : chargingPiles) { bigDecimal1 = bigDecimal1.add(chargingPile.getRatedPower()); } BigDecimal multiply = bigDecimal1.multiply(new BigDecimal("24")); BigDecimal divide = bigDecimal.divide(multiply, 0, BigDecimal.ROUND_HALF_UP); return R.ok(divide); } @PostMapping("/map/getPercentByprovinceCode") @ApiOperation(value = "获取该充电站的利用率", tags = {"管理后台-数据分析-电站分析"}) public R getPercentByCityCode(@RequestBody ChargingPercentProvinceDto chargingPercentProvinceDto){ if (chargingPercentProvinceDto.getDate1()==null){ LocalDate today = LocalDate.now(); LocalDate lastMonth = today.minusMonths(1); LocalDate firstDayOfLastMonth = lastMonth.withDayOfMonth(1); LocalDate lastDayOfLastMonth =lastMonth.withDayOfMonth(lastMonth.lengthOfMonth()); chargingPercentProvinceDto.setDate1(firstDayOfLastMonth); chargingPercentProvinceDto.setDate2(lastDayOfLastMonth); } GetSiteList siteList = new GetSiteList(); siteList.setProvinceCode(chargingPercentProvinceDto.getProvinceCode()); siteList.setPageCurr(1); siteList.setPageCurr(9999); ChargingPercentBack chargingPercentBack = new ChargingPercentBack(); //通过省编码获取充电站id List records = siteService.getSiteList(siteList).getRecords(); List collect = records.stream().map(GetSiteListDTO::getId).collect(Collectors.toList()); // 通过时间段获取和充电桩id获取各个充电站的充电订单 List data = chargingOrderClient.getBySiteIdAndTime(chargingPercentProvinceDto).getData(); // 计算利用率展示 for (ChargingOrderGroup datum : data) { List chargingPiles = chargingPileService.lambdaQuery().eq(TChargingPile::getSiteId, datum.getSiteId()).list(); BigDecimal bigDecimal1 = new BigDecimal("0"); for (TChargingPile chargingPile : chargingPiles) { bigDecimal1 = bigDecimal1.add(chargingPile.getRatedPower()); } long daysBetween = ChronoUnit.DAYS.between(chargingPercentProvinceDto.getDate1(), chargingPercentProvinceDto.getDate2()) + 1; BigDecimal multiply = bigDecimal1.multiply(new BigDecimal("24")).multiply(BigDecimal.valueOf(daysBetween)); //得到利用率 BigDecimal divide = datum.getChargingCapacity().divide(multiply, 0, BigDecimal.ROUND_HALF_UP); //如果利用率大于等于10 if (divide.compareTo(BigDecimal.valueOf(10))>=0){ chargingPercentBack.setCount1(chargingPercentBack.getCount1()+1); } //如果利用率大于等于5小于10 if (divide.compareTo(BigDecimal.valueOf(5))>=0 && divide.compareTo(BigDecimal.valueOf(10))<0){ chargingPercentBack.setCount2(chargingPercentBack.getCount2()+1); } //如果利用率大于等于1小于5 if (divide.compareTo(BigDecimal.valueOf(1))>=0 && divide.compareTo(BigDecimal.valueOf(5))<0){ chargingPercentBack.setCount3(chargingPercentBack.getCount3()+1); } //如果利用率小于1 if (divide.compareTo(BigDecimal.valueOf(1))<0){ chargingPercentBack.setCount4(chargingPercentBack.getCount4()+1); } } return R.ok(chargingPercentBack); } @GetMapping("/getSiteList1") @ApiOperation(value = "获取站点列表 不分页", tags = {"管理后台-活动费用统计"}) public AjaxResult> getSiteList1(){ return AjaxResult.success(siteService.list(new QueryWrapper<>())); } @GetMapping("/getSiteListGun") @ApiOperation(value = "获取站点列表 不分页", tags = {"管理后台-接口信息使用"}) public AjaxResult> getSiteListGun(){ return AjaxResult.success(siteService.getSiteListGun()); } @GetMapping("/getSiteListParkLot") @ApiOperation(value = "获取站点列表不分页", tags = {"管理后台-停车场绑定"}) public AjaxResult> getSiteListParkLot(){ return AjaxResult.success(siteService.getSiteListParkLot()); } @ApiOperation(value = "获取站点分页列表", tags = {"小程序-站点管理-首页"}) @PostMapping("/pageList") public AjaxResult> pageList(@Validated @RequestBody SiteQuery query, HttpServletRequest request){ int isLogin = StringUtils.isEmpty(SecurityUtils.getToken(request)) ? 0 : 1; return AjaxResult.success(siteService.pageList(query,isLogin)); } @ApiOperation(value = "获取站点列表", tags = {"小程序-站点管理-地图导航站点"}) @PostMapping("/getMapSiteList") public AjaxResult> getMapSiteList(@Validated @RequestBody SiteQuery query){ return AjaxResult.success(siteService.getMapSiteList(query)); } @ApiOperation(value = "获取站点详细信息", tags = {"小程序-站点管理-站点详情"}) @PostMapping("/getDetailById") public AjaxResult getDetailById(@Validated @RequestBody SiteDetailQuery query){ SiteDetailVO siteDetailVO = siteService.getDetailById(query); // 查询合作商名称 Partner partner = partnerService.getById(siteDetailVO.getPartnerId()); if(Objects.nonNull(partner)){ siteDetailVO.setPartnerName(partner.getName()); } // 计算距离 // Map distance = GeodesyUtil.getDistance(query.getLat() + "," + query.getLon(), siteDetailVO.getLat() + "," + siteDetailVO.getLon()); // siteDetailVO.setDistance(distance.get("WGS84")); // 查询绑定车牌提示文案 TParkingLot parkingLot = parkingLotService.getOne(Wrappers.lambdaQuery(TParkingLot.class) .eq(TParkingLot::getSiteId, query.getSiteId())); if(Objects.nonNull(parkingLot)){ siteDetailVO.setRemark(parkingLot.getRemark()); } return AjaxResult.success(siteDetailVO); } @ApiOperation(value = "获取站点下充电桩及充电枪列表", tags = {"小程序-站点管理-站点详情"}) @GetMapping("/getChargingGunList") public AjaxResult> getChargingGunList(@RequestParam(value = "siteId")@ApiParam(value = "站点id", required = true)Integer siteId, @RequestParam(value = "type",required = false)@ApiParam(value = "类型 1=超充,2=快充,3=慢充")Integer type){ return AjaxResult.success(chargingPileService.getChargingGunList(siteId,type)); } @ApiOperation(value = "获取站点下充电枪数量统计", tags = {"小程序-站点管理-站点详情","管理后台-数据分析-电站分析"}) @GetMapping("/getChargingGunCount") public AjaxResult> getChargingGunCount(@RequestParam(value = "siteId")@ApiParam(value = "站点id", required = true)Integer siteId){ return AjaxResult.success(chargingGunService.getChargingGunCount(siteId)); } @ResponseBody @PostMapping("/addSite") @ApiOperation(value = "添加站点", tags = {"管理后台-站点管理"}) @Log(title = "【站点管理】添加站点", businessType = BusinessType.INSERT) public AjaxResult addSite(@RequestBody Site site){ return siteService.addSite(site); } @ResponseBody @PostMapping("/getSiteInfo/{id}") @ApiOperation(value = "获取站点详情", tags = {"管理后台-站点管理"}) public AjaxResult getSiteInfo(@PathVariable Integer id){ Site site = siteService.getById(id); return AjaxResult.success(site); } @ResponseBody @PostMapping("/editSite") @ApiOperation(value = "编辑站点", tags = {"管理后台-站点管理"}) @Log(title = "【站点管理】编辑站点", businessType = BusinessType.UPDATE) public AjaxResult editSite(@RequestBody Site site){ return siteService.editSite(site); } @ResponseBody @DeleteMapping("/delSite") @ApiOperation(value = "删除站点", tags = {"管理后台-站点管理"}) @ApiImplicitParams({ @ApiImplicitParam(value = "站点id", name = "id", dataTypeClass = Integer.class, required = true) }) @Log(title = "【站点管理】删除站点", businessType = BusinessType.DELETE) public AjaxResult delSite(@RequestParam("id") 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) }) @Log(title = "【站点管理】设置站点计费策略", businessType = BusinessType.OTHER) 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> getAllSiteList(){ //校验当前账户站点权限 SysUser sysUser = sysUserClient.getSysUser(SecurityUtils.getUserId()).getData(); Integer roleType = sysUser.getRoleType(); Integer objectId = sysUser.getObjectId(); LambdaQueryWrapper wrapper = new LambdaQueryWrapper().eq(Site::getDelFlag, 0); if(2 == roleType){ Set list = partnerService.authSite(objectId, SiteMenu.SITE_LIST); wrapper.in(Site::getId, list); }else{ //非管理员需要根据角色和用户配置查询允许的站点数据 if(!SecurityUtils.isAdmin(SecurityUtils.getUserId())){ List data = userSiteClient.getSiteIds(sysUser.getUserId()).getData(); List data2 = userRoleClient.getRoleByUserId(sysUser.getUserId()).getData(); List data1 = roleSiteClient.getSiteIds(data2.get(0).getRoleId()).getData(); data.addAll(data1); Set list = new HashSet<>(data); wrapper.in(Site::getId, list); } } List list = siteService.list(wrapper.orderByDesc(Site::getCreateTime)); return AjaxResult.success(list); } /** * 获取站点数据集合 * @param ids * @return */ @ResponseBody @PostMapping("/getSiteByIds") public R> getSiteByIds(@RequestBody List ids){ List sites = siteService.list(new LambdaQueryWrapper().in(Site::getId, ids).eq(Site::getDelFlag, 0)); return R.ok(sites); } /** * 获取所有站点数据 * @return */ @ResponseBody @PostMapping("/getSiteAll") public R> getSiteAll(){ List list = siteService.list(new LambdaQueryWrapper().eq(Site::getDelFlag, 0)); return R.ok(list); } }