From 54b40e6e56b260ec2236aab4c82fe9aeb17e4e98 Mon Sep 17 00:00:00 2001
From: Guoqs <123@jsowell.com>
Date: Fri, 8 Nov 2024 16:47:34 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AF=B9=E6=8E=A5=E5=86=85=E8=92=99=E5=8F=A4?=
 =?UTF-8?q?=E5=B9=B3=E5=8F=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/NeiMengGuPlatformServiceImpl.java    | 59 ++++++++++++++++++-
 1 file changed, 56 insertions(+), 3 deletions(-)

diff --git a/jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/impl/NeiMengGuPlatformServiceImpl.java b/jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/impl/NeiMengGuPlatformServiceImpl.java
index 81b6d13c3..c2ee1c796 100644
--- a/jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/impl/NeiMengGuPlatformServiceImpl.java
+++ b/jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/impl/NeiMengGuPlatformServiceImpl.java
@@ -35,6 +35,7 @@ import com.jsowell.pile.vo.base.ThirdPartyStationInfoVO;
 import com.jsowell.pile.vo.base.ThirdPartyStationRelationVO;
 import com.jsowell.pile.vo.uniapp.customer.BillingPriceVO;
 import com.jsowell.pile.vo.web.PileConnectorInfoVO;
+import com.jsowell.pile.vo.web.PileMerchantInfoVO;
 import com.jsowell.pile.vo.web.PileStationVO;
 import com.jsowell.thirdparty.lianlian.domain.ConnectorChargeStatusInfo;
 import com.jsowell.thirdparty.lianlian.domain.ConnectorStatusInfo;
@@ -339,12 +340,11 @@ public class NeiMengGuPlatformServiceImpl implements ThirdPartyPlatformService {
      * @param dto 查询站点信息dto
      * @throws UnsupportedOperationException 未实现异常
      */
-    @Override
-    public Map<String, String> queryStationStatus(QueryStationInfoDTO dto) {
+
+    public Map<String, String> queryStationStatusOld(QueryStationInfoDTO dto) {
         List<String> stationIds = dto.getStationIds();
         List<StationStatusInfo> StationStatusInfos = new ArrayList<>();
         List<Object> connectorStatusInfos = new ArrayList<>();
-        // ThirdPartyPlatformConfig configInfo = thirdPartyPlatformConfigService.getInfoByOperatorId(dto.getOperatorId());
         ThirdPartySecretInfoVO thirdPartySecretInfoVO = thirdpartySecretInfoService.queryByThirdPlatformType(thirdPlatformType);
         if (thirdPartySecretInfoVO == null) {
             return null;
@@ -412,6 +412,59 @@ public class NeiMengGuPlatformServiceImpl implements ThirdPartyPlatformService {
         return resultMap;
     }
 
+    @Override
+    public Map<String, String> queryStationStatus(QueryStationInfoDTO dto) {
+        List<String> stationIds = dto.getStationIds();
+        List<SupStationStatusInfo> stationStatusInfos = Lists.newArrayList();
+        ThirdPartySecretInfoVO thirdPartySecretInfoVO = thirdpartySecretInfoService.queryByThirdPlatformType(thirdPlatformType);
+        if (thirdPartySecretInfoVO == null) {
+            return null;
+        }
+        for (String stationId : stationIds) {
+            // 查询站点的运营商信息
+            PileMerchantInfoVO pileMerchantInfoVO = pileMerchantInfoService.queryMerchantInfoByStationId(stationId);
+            if (pileMerchantInfoVO == null) {
+                continue;
+            }
+            String operatorID = Constants.OPERATORID_JIANG_SU;
+            String organizationCode = pileMerchantInfoVO.getOrganizationCode();
+            String equipmentOwnerId = StringUtils.substring(organizationCode, organizationCode.length() - 10, organizationCode.length() - 1);
+            SupStationStatusInfo stationStatusInfo = new SupStationStatusInfo();
+            stationStatusInfo.setStationID(stationId);
+            stationStatusInfo.setEquipmentOwnerID(equipmentOwnerId);
+            stationStatusInfo.setOperatorID(operatorID);
+            // 根据站点id查询充电桩列表
+            List<ConnectorInfoVO> connectorInfoVOList = pileConnectorInfoService.getConnectorListForLianLian(Long.parseLong(stationId));
+            List<SupConnectorStatusInfo> connectorStatusInfos = Lists.newArrayList();
+            // 遍历充电桩列表
+            for (ConnectorInfoVO connectorInfoVO : connectorInfoVOList) {
+                SupConnectorStatusInfo connectorStatusInfo = new SupConnectorStatusInfo();
+                connectorStatusInfo.setOperatorID(operatorID);
+                connectorStatusInfo.setEquipmentOwnerID(equipmentOwnerId);
+                connectorStatusInfo.setStationID(stationId);
+                connectorStatusInfo.setEquipmentID(connectorInfoVO.getPileSn());
+                connectorStatusInfo.setConnectorID(connectorInfoVO.getPileConnectorCode());
+                connectorStatusInfo.setEquipmentClassification(Constants.ONE);
+                String connectorStatus = connectorInfoVO.getConnectorStatus();
+                connectorStatusInfo.setStatus(Integer.parseInt(connectorStatus));
+                connectorStatusInfo.setStatusDesc(PileConnectorDataBaseStatusEnum.getStatusDescription(connectorStatus));
+                // connectorStatusInfo.setParkStatus();
+                // connectorStatusInfo.setLockStatus();
+                connectorStatusInfo.setBatteryStatus(Constants.ZERO);
+                connectorStatusInfo.setBatteryPackID("");
+                connectorStatusInfo.setLastChangeTime(DateUtils.getDateTime());
+                connectorStatusInfos.add(connectorStatusInfo);
+            }
+            stationStatusInfo.setConnectorStatusInfos(connectorStatusInfos);
+            stationStatusInfos.add(stationStatusInfo);
+        }
+        // 结果集
+        Map<String, Object> map = Maps.newHashMap();
+        map.put("StationStatusInfos", stationStatusInfos);
+        Map<String, String> resultMap = ThirdPartyPlatformUtils.generateResultMap(map, thirdPartySecretInfoVO);
+        return resultMap;
+    }
+
     /**
      * 设备状态变化推送  notification_stationStatus
      * 推送充电设备接口状态信息 supervise_notification_station_status