From e3bd1dab9944dd57ea699f5d7514b1b0b29e2bee Mon Sep 17 00:00:00 2001 From: puzhibing <393733352@qq.com> Date: 星期五, 27 九月 2024 13:32:08 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/controller/TChargingGunController.java | 59 +++++++++++++++++++++++++++++++++++++++++++---------------- 1 files changed, 43 insertions(+), 16 deletions(-) diff --git a/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/controller/TChargingGunController.java b/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/controller/TChargingGunController.java index 78c9342..76886af 100644 --- a/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/controller/TChargingGunController.java +++ b/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/controller/TChargingGunController.java @@ -4,14 +4,17 @@ import cn.hutool.core.img.ImgUtil; import cn.hutool.core.io.FileUtil; import com.baomidou.mybatisplus.core.toolkit.Wrappers; +import com.ruoyi.chargingPile.api.dto.GetSiteListDTO; import com.ruoyi.chargingPile.api.dto.TChargingGunDTO; import com.ruoyi.chargingPile.api.model.Site; import com.ruoyi.chargingPile.api.model.TChargingGun; import com.ruoyi.chargingPile.api.model.TChargingPile; import com.ruoyi.chargingPile.api.model.TFaultMessage; import com.ruoyi.chargingPile.api.query.TChargingGunQuery; +import com.ruoyi.chargingPile.api.vo.GunStatusStatisticsVO; import com.ruoyi.chargingPile.api.vo.SiteNameVO; import com.ruoyi.chargingPile.api.vo.TChargingGunVO; +import com.ruoyi.chargingPile.config.FileUploadConfig; import com.ruoyi.chargingPile.service.ISiteService; import com.ruoyi.chargingPile.service.TChargingGunService; import com.ruoyi.chargingPile.service.TChargingPileService; @@ -23,8 +26,10 @@ import com.ruoyi.common.log.annotation.Log; import com.ruoyi.common.log.enums.BusinessType; import com.ruoyi.common.log.enums.OperatorType; +import com.ruoyi.common.security.utils.SecurityUtils; import com.ruoyi.integration.api.feignClient.IntegrationClient; import com.ruoyi.integration.api.model.EndCharge; +import com.ruoyi.order.api.feignClient.ChargingOrderClient; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import org.springframework.beans.factory.annotation.Autowired; @@ -39,8 +44,10 @@ import java.io.FileReader; import java.io.PrintWriter; import java.net.URLEncoder; +import java.util.ArrayList; import java.util.Arrays; import java.util.List; +import java.util.Map; /** * <p> @@ -57,13 +64,16 @@ @Autowired private TChargingGunService chargingGunService; - @Autowired - private IntegrationClient integrationClient; + @Resource + private ChargingOrderClient chargingOrderClient; @Resource private TChargingPileService chargingPileService; @Resource private ISiteService siteService; + + @Autowired + private FileUploadConfig fileUploadConfig; /** * 查询充电枪列表 @@ -77,7 +87,7 @@ /** * 添加充电枪管理 */ - @Log(title = "添加充电枪", businessType = BusinessType.INSERT,operatorType = OperatorType.MANAGE) + @Log(title = "【充电桩信息】添加充电枪", businessType = BusinessType.INSERT,operatorType = OperatorType.MANAGE) @ApiOperation(tags = {"管理后台-充电桩信息"},value = "添加充电枪") @PostMapping(value = "/add") public AjaxResult add(@RequestBody TChargingGunDTO dto) { @@ -87,7 +97,7 @@ /** * 修改充电枪 */ - @Log(title = "修改充电枪", businessType = BusinessType.UPDATE,operatorType = OperatorType.MANAGE) + @Log(title = "【充电桩信息】修改充电枪", businessType = BusinessType.UPDATE,operatorType = OperatorType.MANAGE) @ApiOperation(tags = {"管理后台-充电桩信息"},value = "修改充电枪") @PostMapping(value = "/update") public AjaxResult update(@RequestBody TChargingGunDTO dto) { @@ -106,7 +116,7 @@ /** * 删除充电枪 */ - @Log(title = "删除充电枪", businessType = BusinessType.DELETE,operatorType = OperatorType.MANAGE) + @Log(title = "【充电桩信息】删除充电枪", businessType = BusinessType.DELETE,operatorType = OperatorType.MANAGE) @ApiOperation(tags = {"管理后台-充电桩信息"},value = "删除充电枪") @DeleteMapping(value = "/deleteById") public AjaxResult<Boolean> deleteById(@RequestParam("id") Integer id) { @@ -118,7 +128,7 @@ /** * 批量删除充电枪 */ - @Log(title = "批量删除充电枪", businessType = BusinessType.DELETE,operatorType = OperatorType.MANAGE) + @Log(title = "【充电桩信息】批量删除充电枪", businessType = BusinessType.DELETE,operatorType = OperatorType.MANAGE) @ApiOperation(tags = {"后台-充电枪"},value = "批量删除充电枪") @DeleteMapping(value = "/deleteByIds") public AjaxResult<Boolean> deleteByIds(@RequestParam String ids) { @@ -129,13 +139,12 @@ /** * 结束充电 */ - @Log(title = "结束充电", businessType = BusinessType.UPDATE,operatorType = OperatorType.MANAGE) + @Log(title = "【充电桩信息】结束充电", businessType = BusinessType.OTHER,operatorType = OperatorType.MANAGE) @ApiOperation(tags = {"后台-充电枪"},value = "结束充电") @PutMapping(value = "/stopCharging") - public AjaxResult<String> stopCharging(@RequestParam("id") Integer id) { - // TODO 硬件 结束充电 -// EndCharge endCharge = new EndCharge(); -// integrationClient.endCharge(endCharge); + public AjaxResult<String> stopCharging(@RequestParam("id") String id) { + // 硬件 结束充电 + chargingOrderClient.stopCharging(id); return AjaxResult.success(); } @@ -143,14 +152,17 @@ @ApiOperation(tags = {"管理后台-充电桩信息"},value = "下载二维码") @GetMapping(value = "/downloadQRCode/{id}") + @Log(title = "【充电桩信息】下载二维码", businessType = BusinessType.OTHER,operatorType = OperatorType.MANAGE) public void downloadQRCode(@PathVariable Integer id, HttpServletResponse response){ try { TChargingGun chargingGun = chargingGunService.getById(id); - String fileName = URLEncoder.encode(chargingGun.getCode(), "UTF-8") + ".jpg"; + TChargingPile chargingPile = chargingPileService.getById(chargingGun.getId()); + String code = chargingPile.getCode() + chargingGun.getCode(); + String fileName = URLEncoder.encode(code, "UTF-8") + ".jpg"; response.setContentType("application/force-download"); response.addHeader("Content-Disposition", "attachment;fileName=" + fileName); - String url = "https://www.baidu.com?id=" + id; - String filePath = "D:/Program Files/nginx-1.20.2/html"; + String url = "https://mxcd.zhinenganguan.com?No=" + code; + String filePath = fileUploadConfig.getLocation(); QRCodeUtils.encode(url, filePath); FileInputStream inputStream = new FileInputStream(filePath); ServletOutputStream out = response.getOutputStream(); @@ -166,7 +178,22 @@ e.printStackTrace(); } } - + + /** + * 设备状态统计 + */ + @ApiOperation(tags = {"后台-工作台"},value = "设备状态统计") + @PutMapping(value = "/gunStatusStatistics") + public R<GunStatusStatisticsVO> gunStatusStatistics() { + List<Integer> siteIds = new ArrayList<>(); + Long userId = SecurityUtils.getUserId(); + //获取当前登录的siteIds + PageInfo<GetSiteListDTO> siteList1 = siteService.getSiteList1(userId); + for (GetSiteListDTO datum : siteList1.getRecords()) { + siteIds.add(datum.getId()); + } + return R.ok(chargingGunService.gunStatusStatistics(siteIds)); + } /** * 根据id获取充电枪完整名称 @@ -235,7 +262,7 @@ */ @PostMapping("/updateChargingGunById") public R<String> updateChargingGunById(@RequestBody TChargingGun chargingGun){ - chargingGunService.updateById(chargingGun) + chargingGunService.updateById(chargingGun); return R.ok(); } } -- Gitblit v1.7.1