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 8d48c471e..f9925c124 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 @@ -1,8 +1,10 @@ package com.jsowell.quartz.task; +import com.google.common.collect.Lists; import com.jsowell.common.constant.CacheConstants; import com.jsowell.common.constant.Constants; import com.jsowell.common.core.redis.RedisCache; +import com.jsowell.common.enums.thirdparty.ThirdPlatformTypeEnum; import com.jsowell.common.util.DateUtils; import com.jsowell.common.util.StringUtils; import com.jsowell.pile.domain.OrderBasicInfo; @@ -11,12 +13,17 @@ import com.jsowell.pile.domain.PileStationInfo; import com.jsowell.pile.domain.ykcCommond.PublishPileBillingTemplateCommand; import com.jsowell.pile.domain.ykcCommond.StartChargingCommand; import com.jsowell.pile.service.*; +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.ThirdPartyPlatformService; +import com.jsowell.thirdparty.platform.service.impl.GuiZhouPlatformServiceImpl; +import com.jsowell.thirdparty.service.ThirdpartySecretInfoService; import org.apache.commons.collections4.CollectionUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.stereotype.Component; import java.math.BigDecimal; @@ -25,6 +32,7 @@ import java.time.LocalDateTime; import java.util.Date; import java.util.List; import java.util.Set; +import java.util.stream.Collectors; @Component("jsowellTask") public class JsowellTask { @@ -55,6 +63,9 @@ public class JsowellTask { @Autowired private SettleOrderReportService settleOrderReportService; + @Autowired + private ThirdPartyStationRelationService thirdPartyStationRelationService; + /** * 关闭15分钟未支付的订单 * close15MinutesOfUnpaidOrders @@ -163,6 +174,22 @@ public class JsowellTask { redisCache.deleteObject(CacheConstants.PUSH_STATION_CONNECTOR); } + /** + * 贵州省平台推送充电站实时功率 + */ + public void pushStationRealTimePowerInfo(){ + // 查询出要推送的站点(贵州、) + String thirdPartyType = ThirdPlatformTypeEnum.GUI_ZHOU_PLATFORM.getTypeCode(); + List stationInfoVOS = thirdPartyStationRelationService.selectStationList(thirdPartyType); + + List stationIdList = stationInfoVOS.stream() + .map(StationInfoVO::getStationId) + .collect(Collectors.toList()); + + GuiZhouPlatformServiceImpl guiZhouPlatformService = new GuiZhouPlatformServiceImpl(); + guiZhouPlatformService.notificationPowerInfo(stationIdList); + } + /** * 定时任务,处理订单分账 * jsowellTask.processOrderSplitting()