From 3b4bd94a21864b9b638395c95c467bb82a2f157e Mon Sep 17 00:00:00 2001
From: 无关风月 <443237572@qq.com>
Date: 星期三, 26 三月 2025 21:25:22 +0800
Subject: [PATCH] 监管平台
---
ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/drainage/TCECController.java | 97 ++++++++++++++++++++++++++++++++++++++++++------
1 files changed, 84 insertions(+), 13 deletions(-)
diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/drainage/TCECController.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/drainage/TCECController.java
index 9e28bdf..9eaf611 100644
--- a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/drainage/TCECController.java
+++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/drainage/TCECController.java
@@ -25,6 +25,7 @@
import com.ruoyi.other.api.feignClient.SystemConfigurationClient;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.CollectionUtils;
import org.springframework.web.bind.annotation.*;
@@ -84,7 +85,8 @@
@Resource
private SystemConfigurationClient systemConfigurationClient;
-
+ @Autowired
+ private TCECSuperviseUtil tcecSuperviseUtil;
private final static String operatorId = "906171535";
/**
@@ -1840,13 +1842,13 @@
for (Integer stationID : stationIDList) {
StationStatusInfo stationStatusInfo = new StationStatusInfo();
stationStatusInfo.setOperatorID(operatorID);
- stationStatusInfo.setEquipmentOwnerID("999999999");
+ stationStatusInfo.setEquipmentOwnerID(operatorId);
stationStatusInfo.setStationID(String.valueOf(stationID));
List<ConnectorStatusInfo> connectorStatusInfos = new ArrayList<>();
for (TChargingGun chargingGun : chargingGuns) {
ConnectorStatusInfo connectorStatusInfo = new ConnectorStatusInfo();
connectorStatusInfo.setOperatorID(operatorId);
- connectorStatusInfo.setEquipmentOwnerID("999999999");
+ connectorStatusInfo.setEquipmentOwnerID(operatorId);
connectorStatusInfo.setStationID(String.valueOf(chargingGun.getSiteId()));
connectorStatusInfo.setEquipmentID(String.valueOf(chargingGun.getChargingPileId()));
connectorStatusInfo.setConnectorID(chargingGun.getFullNumber());
@@ -1902,7 +1904,7 @@
public R pushSuperviseNotificationStationStatus(TChargingGun chargingGun){
ConnectorStatusInfo connectorStatusInfo = new ConnectorStatusInfo();
connectorStatusInfo.setOperatorID(operatorId);
- connectorStatusInfo.setEquipmentOwnerID("999999999");
+ connectorStatusInfo.setEquipmentOwnerID(operatorId);
connectorStatusInfo.setStationID(String.valueOf(chargingGun.getSiteId()));
connectorStatusInfo.setEquipmentID(String.valueOf(chargingGun.getChargingPileId()));
connectorStatusInfo.setConnectorID(chargingGun.getFullNumber());
@@ -1933,7 +1935,7 @@
connectorStatusInfo.setUpdateTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
List<Operator> operators = operatorClient.getAllOperator().getData();
for (Operator operator : operators) {
- TCECSuperviseUtil.notificationStationStatus(operator, connectorStatusInfo);
+ tcecSuperviseUtil.notificationStationStatus(operator, connectorStatusInfo);
}
return R.ok();
}
@@ -1945,7 +1947,7 @@
public R pushSuperviseNotificationEquipChargeStatus(TChargingOrder chargingOrder){
SupEquipChargeStatus supEquipChargeStatus = new SupEquipChargeStatus();
supEquipChargeStatus.setOperatorID(operatorId);
- supEquipChargeStatus.setEquipmentOwnerID("999999999");
+ supEquipChargeStatus.setEquipmentOwnerID(operatorId);
supEquipChargeStatus.setStationID(String.valueOf(chargingOrder.getSiteId()));
supEquipChargeStatus.setEquipmentID(String.valueOf(chargingOrder.getChargingPileId()));
supEquipChargeStatus.setOrderNo(operatorId+chargingOrder.getCode());
@@ -1997,7 +1999,7 @@
supEquipChargeStatus.setTotalPower(chargingOrder.getElectrovalence());
List<Operator> operators = operatorClient.getAllOperator().getData();
for (Operator operator : operators) {
- TCECSuperviseUtil.notificationSupEquipChargeStatus(operator, supEquipChargeStatus);
+ tcecSuperviseUtil.notificationSupEquipChargeStatus(operator, supEquipChargeStatus);
}
return R.ok();
}
@@ -2009,7 +2011,7 @@
public R pushSuperviseNotificationChargeOrderInfo(TChargingOrder chargingOrder){
SupChargeOrderInfo supChargeOrderInfo = new SupChargeOrderInfo();
supChargeOrderInfo.setOperatorID(operatorId);
- supChargeOrderInfo.setEquipmentOwnerID("999999999");
+ supChargeOrderInfo.setEquipmentOwnerID(operatorId);
supChargeOrderInfo.setStationID(String.valueOf(chargingOrder.getSiteId()));
supChargeOrderInfo.setEquipmentID(String.valueOf(chargingOrder.getChargingPileId()));
supChargeOrderInfo.setOrderNo(operatorId+chargingOrder.getCode());
@@ -2044,21 +2046,90 @@
List<Operator> operators = operatorClient.getAllOperator().getData();
for (Operator operator : operators) {
- TCECSuperviseUtil.notificationChargeOrderInfo(operator, supChargeOrderInfo);
+ tcecSuperviseUtil.notificationChargeOrderInfo(operator, supChargeOrderInfo);
}
return R.ok();
}
+
/**
* 推送充换电站信息
- * @param site
+ * @param id
* @return
*/
@PostMapping("/supervise_notification_station_info")
- public BaseResult superviseNotificationStationInfo(@RequestBody Site site){
- BaseResult baseResult = new BaseResult();
+ public R superviseNotificationStationInfo(@RequestParam Integer id){
+ String serviceTel = systemConfigurationClient.getServerPhone().getData();
+ Site site = siteClient.getSiteAll().getData().stream().filter(e -> e.getId().equals(id)).findFirst().orElse(new Site());
- return baseResult;
+ List<TChargingPile> tChargingPiles = chargingPileClient.getChargingPileBySiteIds(Collections.singletonList(site.getId())).getData();
+ List<Integer> collect1 = tChargingPiles.stream().map(TChargingPile::getId).collect(Collectors.toList());
+ List<TChargingGun> chargingGunList = chargingGunClient.getChargingGunByChargingPileIds(collect1).getData();
+ SupStationInfo supStationInfo = new SupStationInfo();
+ supStationInfo.setStationID(site.getId().toString());
+ supStationInfo.setStationUniqueNumber(site.getDistrictsCode() + "906171535" + site.getId());
+ supStationInfo.setOperatorID("906171535");
+ supStationInfo.setEquipmentOwnerID("906171535");
+ supStationInfo.setStationName(site.getName());
+ supStationInfo.setCountryCode(site.getCountryCode());
+ supStationInfo.setAreaCode(site.getCityCode());
+ supStationInfo.setAddress(site.getAddress());
+ supStationInfo.setAreaCodeCountryside(site.getAreaCodeCountryside());
+ supStationInfo.setStationTel(site.getPhone());
+
+ supStationInfo.setServiceTel(serviceTel);
+ supStationInfo.setStationClassification(site.getStationClassification());
+ supStationInfo.setGeneralApplicationType(site.getGeneralApplicationType());
+ supStationInfo.setStationType(site.getSiteType());
+ supStationInfo.setStationStatus(site.getStatus());
+ supStationInfo.setParkNums(site.getParkingSpace());
+ supStationInfo.setStationLat(new BigDecimal(site.getLat()).setScale(6, RoundingMode.DOWN));
+ supStationInfo.setStationLng(new BigDecimal(site.getLon()).setScale(6, RoundingMode.DOWN));
+ supStationInfo.setSiteGuide(site.getGuide());
+ supStationInfo.setConstruction(site.getConstructionSite() == 0 ? ConstructionEnum.OTHER.getType() : site.getConstructionSite());
+ supStationInfo.setPictures(StringUtils.isNotEmpty(site.getImgUrl()) ? Arrays.asList(site.getImgUrl().split(",")) : new ArrayList<>());
+
+ supStationInfo.setMatchCars(site.getVehicleDescription());
+ if (org.springframework.util.StringUtils.hasLength(site.getSwapMatchCars())){
+ supStationInfo.setSwapMatchCars(Arrays.asList(site.getSwapMatchCars().split(",")));
+ }
+ supStationInfo.setBusineHours(site.getStartServiceTime());
+ supStationInfo.setRoundTheClock(site.getRoundTheClock());
+ supStationInfo.setParkType(site.getParkType());
+ supStationInfo.setParkFee("{\"rules\":"+site.getParkFee()+","+"\"freeDuration\":"+site.getParkFeeFree()+"}");
+ supStationInfo.setElectricityType(site.getElectricityType());
+ supStationInfo.setBusinessExpandType(site.getBusinessExpandType());
+ supStationInfo.setCapacity(site.getCapacity());
+ supStationInfo.setRatedPower(site.getRatedPower());
+ supStationInfo.setPeriodFee(site.getPeriodFee());
+ supStationInfo.setOfficialRunTime(site.getOfficialRunTime());
+ supStationInfo.setStationOrientation(site.getStationOrientation());
+ supStationInfo.setStationArea(site.getStationArea());
+ supStationInfo.setHavePerson(site.getHavePerson());
+ supStationInfo.setVideoMonitor(site.getVideoMonitor());
+ if (StringUtils.isNotEmpty(site.getSupportingFacilities())){
+ String[] split = site.getSupportingFacilities().split(",");
+ List<Integer> collect = Arrays.stream(split).map(Integer::parseInt).collect(Collectors.toList());
+ supStationInfo.setSupportingFacilities(collect);
+ }
+ supStationInfo.setPrinterFlag(site.getPrinterFlag());
+ supStationInfo.setBarrierFlag(site.getBarrierFlag());
+ supStationInfo.setParkingLockFlag(site.getParkingLockFlag());
+ supStationInfo.setEquipmentInfos(buildEquipmentInfo(site.getId(), tChargingPiles, chargingGunList));
+// supStationInfo.setSwapEquipmentInfos();
+ supStationInfo.setElectricityFee("{"+site.getElectricityFee()+"}");
+ supStationInfo.setEquipmentOwnerName(site.getEquipmentOwnerName());
+ supStationInfo.setResidentNo(site.getResidentNo());
+ supStationInfo.setSupplyType(site.getSupplyType());
+ supStationInfo.setWattHourMeterNo(site.getWattHourMeterNo());
+ supStationInfo.setForwardPower(site.getForwardPower());
+ supStationInfo.setServiceFee("{"+site.getServiceFee()+"}");
+ supStationInfo.setRecordUniqueNo(site.getRecordUniqueNo());
+ BaseResult baseResult = new BaseResult();
+ SupStationInfoResult supStationInfoResult = new SupStationInfoResult();
+ supStationInfoResult.setSupStationInfo(supStationInfo);
+ tcecSuperviseUtil.superviseNotificationStationInfo(supStationInfoResult);
+ return R.ok(baseResult);
}
//
//
--
Gitblit v1.7.1