From c71dead186101ee23310b5385007a89f7e9341c6 Mon Sep 17 00:00:00 2001
From: "YAS\\29473" <2947326429@qq.com>
Date: Wed, 13 Aug 2025 18:10:33 +0800
Subject: [PATCH] update

---
 .../com/jsowell/quartz/task/JsowellTask.java  | 29 +++++++++++++++++++
 1 file changed, 29 insertions(+)

diff --git a/jsowell-quartz/src/main/java/com/jsowell/quartz/task/JsowellTask.java b/jsowell-quartz/src/main/java/com/jsowell/quartz/task/JsowellTask.java
index a567d0904..e4cade2a5 100644
--- a/jsowell-quartz/src/main/java/com/jsowell/quartz/task/JsowellTask.java
+++ b/jsowell-quartz/src/main/java/com/jsowell/quartz/task/JsowellTask.java
@@ -28,6 +28,7 @@ import com.jsowell.pile.vo.base.StationInfoVO;
 import com.jsowell.pile.vo.web.BillingTemplateVO;
 import com.jsowell.thirdparty.amap.service.AMapService;
 import com.jsowell.thirdparty.platform.service.impl.GuiZhouPlatformServiceImpl;
+import com.jsowell.thirdparty.platform.service.impl.JiLinPlatformServiceImpl;
 import com.jsowell.thirdparty.platform.service.impl.SiChuanPlatformServiceImpl;
 import org.apache.commons.collections4.CollectionUtils;
 import org.slf4j.Logger;
@@ -295,6 +296,34 @@ public class JsowellTask {
 
     }
 
+
+    /**
+     * 定时任务,实时站点功率推送
+     */
+    public void realTimePowerPush() {
+/*        String env = SpringUtils.getActiveProfile();
+        if (StringUtils.equalsIgnoreCase(env, "pre")) {
+            log.debug("PRE环境不执行");
+            return;
+        }*/
+
+        String thirdPartyType = ThirdPlatformTypeEnum.JI_LIN_PLATFORM.getTypeCode();
+        List<StationInfoVO> stationInfoVOS = thirdPartyStationRelationService.selectStationList(thirdPartyType);
+
+        // 获取站点列表
+        List<String> stationIdList = stationInfoVOS.stream()
+                .map(StationInfoVO::getStationId)
+                .collect(Collectors.toList());
+
+        JiLinPlatformServiceImpl jilinPlatformService = new JiLinPlatformServiceImpl();
+        try {
+            jilinPlatformService.notificationPowerInfo(stationIdList);
+        }catch (Exception e){
+            log.error("实时站点功率推送失败", e);
+        }
+    }
+
+
     /**
      * 定时任务, 订单分账
      * jsowellTask.processOrderSplitting()