明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
huliguo
2025-05-23 71e051cddfba05a4e7876a92650cc8d7b5fabf28 
 ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/controller/TChargingGunController.java


@@ -9,10 +9,7 @@


import com.ruoyi.chargingPile.api.model.TChargingGun;


import com.ruoyi.chargingPile.api.model.TChargingPile;


import com.ruoyi.chargingPile.api.query.TChargingGunQuery;


import com.ruoyi.chargingPile.api.vo.GetChargingGunByCode;


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.api.vo.*;


import com.ruoyi.chargingPile.config.FileUploadConfig;


import com.ruoyi.chargingPile.service.ISiteService;


import com.ruoyi.chargingPile.service.TChargingGunService;


@@ -24,6 +21,8 @@


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.annotation.Logical;


import com.ruoyi.common.security.annotation.RequiresPermissions;


import com.ruoyi.common.security.service.TokenService;


import com.ruoyi.common.security.utils.SecurityUtils;


import com.ruoyi.order.api.feignClient.ChargingOrderClient;


@@ -40,6 +39,7 @@


import java.util.ArrayList;


import java.util.Arrays;


import java.util.List;


import java.util.stream.Collectors;




/**


 * <p>


@@ -67,9 +67,26 @@


    @Autowired


    private FileUploadConfig fileUploadConfig;






    /**


     * 查询所有枪


     */


    @PostMapping(value = "/getAllGun")


    public R<List<TChargingGun>> getAllGun() {


        return R.ok(chargingGunService.list());


    }


    /**


     * 查询所有桩


     */


    @PostMapping(value = "/getAllPile")


    public R<List<TChargingPile>> getAllPile() {


        return R.ok(chargingPileService.list());


    }




    /**


     * 查询充电枪列表


     */


    @RequiresPermissions(value = {"/chargingPile", "/chargingGun"}, logical = Logical.OR)


    @ApiOperation(tags = {"后台-充电枪", "管理后台-充电桩信息"},value = "查询充电枪分页列表")


    @PostMapping(value = "/pageList")


    public AjaxResult<PageInfo<TChargingGunVO>> pageList(@RequestBody TChargingGunQuery query) {


@@ -79,6 +96,7 @@


    /**


     * 添加充电枪管理


     */


    @RequiresPermissions(value = {"/chargingPile/add_charging_gun"}, logical = Logical.OR)


    @Log(title = "【充电桩信息】添加充电枪", businessType = BusinessType.INSERT,operatorType = OperatorType.MANAGE)


    @ApiOperation(tags = {"管理后台-充电桩信息"},value = "添加充电枪")


    @PostMapping(value = "/add")


@@ -89,6 +107,7 @@


    /**


     * 修改充电枪


     */


    @RequiresPermissions(value = {"/chargingGun/update"}, logical = Logical.OR)


    @Log(title = "【充电桩信息】修改充电枪", businessType = BusinessType.UPDATE,operatorType = OperatorType.MANAGE)


    @ApiOperation(tags = {"管理后台-充电桩信息"},value = "修改充电枪")


    @PostMapping(value = "/update")


@@ -99,6 +118,7 @@


    /**


     * 查看充电枪详情


     */


    @RequiresPermissions(value = {"/chargingGun/update", "/chargingGun/select"}, logical = Logical.OR)


    @ApiOperation(tags = {"后台-充电枪", "管理后台-充电桩信息"},value = "查看充电枪详情")


    @GetMapping(value = "/getDetailById")


    public AjaxResult<TChargingGun> getDetailById(@RequestParam("id") Integer id) {


@@ -108,6 +128,7 @@


    /**


     * 删除充电枪


     */


    @RequiresPermissions(value = {"/chargingGun/del"}, logical = Logical.OR)


    @Log(title = "【充电桩信息】删除充电枪", businessType = BusinessType.DELETE,operatorType = OperatorType.MANAGE)


    @ApiOperation(tags = {"管理后台-充电桩信息"},value = "删除充电枪")


    @DeleteMapping(value = "/deleteById")


@@ -120,6 +141,7 @@


    /**


     * 批量删除充电枪


     */


    @RequiresPermissions(value = {"/chargingGun/del"}, logical = Logical.OR)


    @Log(title = "【充电桩信息】批量删除充电枪", businessType = BusinessType.DELETE,operatorType = OperatorType.MANAGE)


    @ApiOperation(tags = {"后台-充电枪"},value = "批量删除充电枪")


    @DeleteMapping(value = "/deleteByIds")


@@ -131,6 +153,7 @@


    /**


     * 结束充电


     */


    @RequiresPermissions(value = {"/chargingGun/end_charging"}, logical = Logical.OR)


    @Log(title = "【充电桩信息】结束充电", businessType = BusinessType.OTHER,operatorType = OperatorType.MANAGE)


    @ApiOperation(tags = {"后台-充电枪"},value = "结束充电")


    @PutMapping(value = "/stopCharging")


@@ -144,6 +167,7 @@


    


    


    


    @RequiresPermissions(value = {"/chargingGun/download_qr_code"}, logical = Logical.OR)


    @ApiOperation(tags = {"管理后台-充电桩信息"},value = "下载二维码")


    @GetMapping(value = "/downloadQRCode/{id}")


    @Log(title = "【充电桩信息】下载二维码", businessType = BusinessType.OTHER,operatorType = OperatorType.MANAGE)


@@ -196,6 +220,7 @@


    /**


     * 设备状态统计


     */


    @RequiresPermissions(value = {"/workbench"}, logical = Logical.OR)


    @ApiOperation(tags = {"后台-工作台"},value = "设备状态统计")


    @PutMapping(value = "/gunStatusStatistics")


    public R<GunStatusStatisticsVO> gunStatusStatistics() {


@@ -283,5 +308,92 @@


        chargingGunService.updateById(chargingGun);


        return R.ok();


    }


    


    


    


    /**


     * 根据充电桩id获取枪


     * @param chargingPileId


     * @return


     */


    @PostMapping("/getChargingGunByChargingPileId")


    public R<List<TChargingGun>> getChargingGunByChargingPileId(@RequestParam("chargingPileId") Integer chargingPileId){


        List<TChargingGun> list = chargingGunService.list(new LambdaQueryWrapper<TChargingGun>().eq(TChargingGun::getChargingPileId, chargingPileId)


                .eq(TChargingGun::getDelFlag, 0));


        return R.ok(list);


    }


    


    


    /**


     * 根据充电桩ids获取枪


     * @param chargingPileIds


     * @return


     */


    @PostMapping("/getChargingGunByChargingPileIds")


    public R<List<TChargingGun>> getChargingGunByChargingPileIds(@RequestParam("chargingPileIds") List<Integer> chargingPileIds){


        List<TChargingGun> list = chargingGunService.list(new LambdaQueryWrapper<TChargingGun>().in(TChargingGun::getChargingPileId, chargingPileIds)


                .eq(TChargingGun::getDelFlag, 0));


        return R.ok(list);


    }






    /**


     * 根据枪唯一码查询信息


     * @return


     */


    @PostMapping("/getChargingGunByFullNumber")


    public R<TChargingGun> getChargingGunByFullNumber(@RequestParam("fullNumber") String fullNumber){


        TChargingGun chargingGun = chargingGunService.getOne(new LambdaQueryWrapper<TChargingGun>().eq(TChargingGun::getDelFlag, 0).eq(TChargingGun::getFullNumber, fullNumber));


        return R.ok(chargingGun);


    }












    /**


     * 根据枪唯一码查询信息


     * @return


     */


    @ApiOperation(tags = {"大屏-对外开放区车位使用情况"},value = "对外开放区车位使用情况")


    @GetMapping("/getLargeScreenGun")


    public R<LargeScreenGunVo> getLargeScreenGun(){


        LargeScreenGunVo largeScreenGunVo = new LargeScreenGunVo();


        List<TChargingGun> tChargingGuns = chargingGunService.list(new LambdaQueryWrapper<TChargingGun>().eq(TChargingGun::getDelFlag, 0).in(TChargingGun::getSiteId,25,26).in(TChargingGun::getChargeMode, 1,2,4));


        if(tChargingGuns.isEmpty()){


            return R.ok(largeScreenGunVo);


        }


        List<TChargingGun> supperFast = tChargingGuns.stream().filter(e -> e.getChargeMode() == 1).collect(Collectors.toList());


        largeScreenGunVo.setSuperFast(supperFast.size());


        int supperFastSize = supperFast.stream().filter(e -> e.getStatus() != 2).collect(Collectors.toList()).size();


        largeScreenGunVo.setUseSuperFast(supperFastSize);


        List<TChargingGun> fast = tChargingGuns.stream().filter(e -> e.getChargeMode() == 2).collect(Collectors.toList());


        largeScreenGunVo.setFast(fast.size());


        int fastSize = fast.stream().filter(e -> e.getStatus() != 2).collect(Collectors.toList()).size();


        largeScreenGunVo.setUseFast(fastSize);


        List<TChargingGun> v2g = tChargingGuns.stream().filter(e -> e.getChargeMode() == 4).collect(Collectors.toList());


        largeScreenGunVo.setV2g(v2g.size());


        int v2gSize = v2g.stream().filter(e -> e.getStatus() != 2).collect(Collectors.toList()).size();


        largeScreenGunVo.setUseV2g(v2gSize);




        return R.ok(largeScreenGunVo);


    }














    /**


     * 大屏 根据站点ids和充电模式集合查询充电枪集合 没有过滤del_flag


     */


    @GetMapping("/getGunIdsBySiteIdsAndChargeModels")


    public R<List<Integer>> getGunIdsBySiteIdsAndChargeModels(@RequestParam("siteIds") List<Integer> siteIds ,@RequestParam("chargeModels") List<Integer> chargeModels){


        List<TChargingGun> list = chargingGunService.list(new LambdaQueryWrapper<TChargingGun>()


                .select(TChargingGun::getId).in(TChargingGun::getSiteId, siteIds)


                .in(TChargingGun::getChargeMode, chargeModels));


        return R.ok(list.stream().map(TChargingGun::getId).collect(Collectors.toList()));


    }




}