Forráskód Böngészése

增加根据equipmentId、connectorId查询站点信息接口

zuypeng 11 hónapja
szülő
commit
444c2bba76

+ 24 - 0
miniapp/src/main/java/com/kym/miniapp/controller/ChargeController.java

@@ -109,6 +109,30 @@ public class ChargeController {
     }
 
 
+    /**
+     * 根据设备短ID获取站点信息(包含充电枪信息)
+     *
+     * @return
+     */
+    @GetMapping("/stationInfoByConnectorId/{connectorId}")
+    @SaIgnore
+    R<?> stationInfoByConnectorId(@PathVariable String connectorId) {
+        return R.success(stationService.stationInfoByConnectorId(connectorId));
+    }
+
+
+    /**
+     * 根据设备短ID获取站点信息(包含充电枪信息)
+     *
+     * @return
+     */
+    @GetMapping("/stationInfoByEquipmentId/{equipmentId}")
+    @SaIgnore
+    R<?> stationInfoByEquipmentId(@PathVariable String equipmentId) {
+        return R.success(stationService.stationInfoByEquipmentId(equipmentId));
+    }
+
+
     /**
      * 充电站状态
      *

+ 2 - 0
service/src/main/java/com/kym/service/admin/EquipmentRelationService.java

@@ -18,4 +18,6 @@ public interface EquipmentRelationService extends MyBaseService<EquipmentRelatio
     EquipmentRelation getByConnectorId(String connectorId);
 
     void batchBind(BatchBindEquipmentRelation equipmentRelation);
+
+    EquipmentRelation getByEquipmentId(String equipmentId);
 }

+ 4 - 0
service/src/main/java/com/kym/service/admin/StationService.java

@@ -57,4 +57,8 @@ public interface StationService extends MPJBaseService<Station> {
     PageBean<SimpleStationVo> listStationForApp(StationQueryParam params);
 
     DetailStationVo stationInfoByShortId(String shortId);
+
+    DetailStationVo stationInfoByConnectorId(String connectorId);
+
+    DetailStationVo stationInfoByEquipmentId(String equipmentId);
 }

+ 7 - 0
service/src/main/java/com/kym/service/admin/impl/EquipmentRelationServiceImpl.java

@@ -37,6 +37,11 @@ public class EquipmentRelationServiceImpl extends MyBaseServiceImpl<EquipmentRel
     }
 
 
+    @Override
+    public EquipmentRelation getByEquipmentId(String equipmentId) {
+        return lambdaQuery().eq(EquipmentRelation::getEquipmentId, equipmentId).one();
+    }
+
     /**
      * 对同一站点的设备批量绑定平台
      *
@@ -60,4 +65,6 @@ public class EquipmentRelationServiceImpl extends MyBaseServiceImpl<EquipmentRel
                 Map.of(KymCache.INSTANCE.getStationIdByEquipmentIdOrConnectorId(equipmentRelation.getConnectorIds().get(0)), equipmentRelation.getPlatformName())
         );
     }
+
+
 }

+ 14 - 0
service/src/main/java/com/kym/service/admin/impl/StationServiceImpl.java

@@ -244,6 +244,20 @@ public class StationServiceImpl extends MyBaseServiceImpl<StationMapper, Station
         return stationInfo(equipmentRel.getStationId());
     }
 
+    @Override
+    public DetailStationVo stationInfoByConnectorId(String connectorId) {
+        EquipmentRelation equipmentRel = equipmentRelationService.getByConnectorId(connectorId);
+        CommUtil.assertsNonNull(equipmentRel,"该设备信息有误");
+        return stationInfo(equipmentRel.getStationId());
+    }
+
+    @Override
+    public DetailStationVo stationInfoByEquipmentId(String equipmentId) {
+        EquipmentRelation equipmentRel = equipmentRelationService.getByEquipmentId(equipmentId);
+        CommUtil.assertsNonNull(equipmentRel,"该设备信息有误");
+        return stationInfo(equipmentRel.getStationId());
+    }
+
     /**
      * 站点详情
      *