From 2221dc86677bb9359defa0ad8a6c35e686993b15 Mon Sep 17 00:00:00 2001
From: "YAS\\29473" <2947326429@qq.com>
Date: Mon, 9 Jun 2025 09:53:25 +0800
Subject: [PATCH] =?UTF-8?q?update=E6=8E=A8=E9=80=81=E8=AE=BE=E5=A4=87?=
 =?UTF-8?q?=E7=8A=B6=E6=80=81=E6=8E=A5=E5=8F=A3=E8=B0=83=E7=94=A8=E6=9B=B4?=
 =?UTF-8?q?=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/HuZhouPlatformServiceImpl.java       | 38 +++++++++++++++++++
 .../WeiWangKuaiDianPlatformServiceImpl.java   | 38 +++++++++++++++++++
 2 files changed, 76 insertions(+)

diff --git a/jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/impl/HuZhouPlatformServiceImpl.java b/jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/impl/HuZhouPlatformServiceImpl.java
index 613a52a9b..d64640631 100644
--- a/jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/impl/HuZhouPlatformServiceImpl.java
+++ b/jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/impl/HuZhouPlatformServiceImpl.java
@@ -389,6 +389,44 @@ public class HuZhouPlatformServiceImpl implements ThirdPartyPlatformService  {
         return result;
     }
 
+    /**
+     * 设备状态推送
+     * @param stationId 站点id
+     * @param pileConnectorCode 充电桩枪口编号
+     * @param status
+     * @param secretInfoVO
+     * @return
+     */
+    @Override
+    public String notificationStationStatus(String stationId, String pileConnectorCode, String status, ThirdPartySecretInfoVO secretInfoVO) {
+        YKCUtils.getPileSn(pileConnectorCode);
+        ThirdPartySecretInfoVO thirdPartySecretInfoVO = getHuZhouPlatformSecretInfo();
+
+        String operatorId = thirdPartySecretInfoVO.getOurOperatorId();
+        String operatorSecret = thirdPartySecretInfoVO.getTheirOperatorSecret();
+        String signSecret = thirdPartySecretInfoVO.getTheirSigSecret();
+        String dataSecret = thirdPartySecretInfoVO.getTheirDataSecret();
+        String dataSecretIv = thirdPartySecretInfoVO.getTheirDataSecretIv();
+        String urlAddress = thirdPartySecretInfoVO.getTheirUrlPrefix();
+
+        String url = urlAddress + BusinessInformationExchangeEnum.NOTIFICATION_STATION_STATUS.getValue();
+        ConnectorStatusInfo info = ConnectorStatusInfo.builder()
+                .connectorID(pileConnectorCode)
+                .status(Integer.parseInt(status))
+                .build();
+
+        JSONObject json = new JSONObject();
+        json.put("ConnectorStatusInfo", info);
+        String jsonString = JSON.toJSONString(json);
+        log.info("参数：{}", jsonString);
+        // 获取令牌
+        String token = getToken(urlAddress, operatorId, operatorSecret, dataSecretIv, signSecret, dataSecret);
+        log.info("token：{}", token);
+        String result = HttpRequestUtil.sendPost(token, jsonString, url, dataSecret, dataSecretIv, operatorId, signSecret);
+        log.info("返回结果：{}", result);
+        return result;
+    }
+
     /**
      * 设备接口状态查询  query_station_status
      * @param dto 查询站点信息dto
diff --git a/jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/impl/WeiWangKuaiDianPlatformServiceImpl.java b/jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/impl/WeiWangKuaiDianPlatformServiceImpl.java
index 8590dcd75..2a303be5c 100644
--- a/jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/impl/WeiWangKuaiDianPlatformServiceImpl.java
+++ b/jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/impl/WeiWangKuaiDianPlatformServiceImpl.java
@@ -351,6 +351,44 @@ public class WeiWangKuaiDianPlatformServiceImpl implements ThirdPartyPlatformSer
         return result;
     }
 
+    /**
+     * 设备状态推送
+     * @param stationId 站点id
+     * @param pileConnectorCode 充电桩枪口编号
+     * @param status
+     * @param secretInfoVO
+     * @return
+     */
+    @Override
+    public String notificationStationStatus(String stationId, String pileConnectorCode, String status, ThirdPartySecretInfoVO secretInfoVO) {
+        String pileSn = YKCUtils.getPileSn(pileConnectorCode);
+        // 通过站点id查询相关配置信息
+        ThirdPartySecretInfoVO thirdPartySecretInfoVO = getweiWangKuaiDianPlatformSecretInfo();
+
+        String operatorId = thirdPartySecretInfoVO.getOurOperatorId();
+        String operatorSecret = thirdPartySecretInfoVO.getTheirOperatorSecret();
+        String signSecret = thirdPartySecretInfoVO.getTheirSigSecret();
+        String dataSecret = thirdPartySecretInfoVO.getTheirDataSecret();
+        String dataSecretIv = thirdPartySecretInfoVO.getTheirDataSecretIv();
+        String urlAddress = thirdPartySecretInfoVO.getTheirUrlPrefix();
+
+        String url = urlAddress + BusinessInformationExchangeEnum.NOTIFICATION_STATION_STATUS.getValue();
+        ConnectorStatusInfo info = ConnectorStatusInfo.builder()
+                .connectorID(pileConnectorCode)
+                .status(Integer.parseInt(status))
+                .build();
+
+        JSONObject json = new JSONObject();
+        json.put("ConnectorStatusInfo", info);
+        String jsonString = JSON.toJSONString(json);
+        log.info("参数：{}", jsonString);
+        // 获取令牌
+        String token = getToken(urlAddress, operatorId, operatorSecret, dataSecretIv, signSecret, dataSecret);
+        log.info("token：{}", token);
+        String result = HttpRequestUtil.sendPost(token, jsonString, url, dataSecret, dataSecretIv, operatorId, signSecret);
+        log.info("返回结果：{}", result);
+        return result;
+    }
 
     /**
      * 设备接口状态查询  query_station_status