java/mx_charging_pile.git

			@@ -18,6 +18,8 @@
			import com.ruoyi.order.api.model.TChargingBill;
			import com.ruoyi.order.api.model.TChargingOrder;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.boot.web.context.WebServerInitializedEvent;
			import org.springframework.context.ApplicationListener;
			import org.springframework.scheduling.annotation.Scheduled;
			import org.springframework.stereotype.Component;

			@@ -36,7 +38,7 @@
			* @date 2023/7/11 8:39
			*/
			@Component
			public class TaskUtil {
			public class TaskUtil implements ApplicationListener<WebServerInitializedEvent> {


			@Resource
			@@ -53,9 +55,20 @@
			@Resource
			private ChargingPileClient chargingPileClient;

			private Integer port = null;


			@Override
			public void onApplicationEvent(WebServerInitializedEvent event) {
			port = event.getWebServer().getPort();
			System.out.println("端口号：" + port);
			}


			// 每天凌晨12点30执行推送充电用能统计
			@Scheduled(cron = "0 30 0 * * ?")
			public void superviseNotificationOperationStatsInfo() {
			if(null != port && port == 5701){
			StationStatsInfoResult res = new StationStatsInfoResult();
			int dayOfMonth1 = LocalDateTime.now().getYear();
			int dayOfMonth2 = LocalDateTime.now().getMonthValue();
			@@ -136,11 +149,13 @@
			res.setStationStatsInfos(stationStatsInfos);
			tcecSuperviseUtil.superviseNotificationOperationStatsInfo(res);
			}
			}
			// 每15分钟执行一次的定时任务
			@Scheduled(cron = "0 0/15 * * * ?")
			public void supervise_notification_realtime_power_info() {
			if(null != port && port == 5701){
			List<Site> data = siteClient.getSiteAll().getData();
			List<Integer> siteIds = data.stream().map(Site::getId).collect(Collectors.toList());
			List<Integer> siteIds = data.stream().filter(s->s.getStatus() == 1).map(Site::getId).collect(Collectors.toList());
			List<TChargingPile> tChargingPiles = chargingPileClient.getChargingPileBySiteIds(siteIds).getData();
			List<Integer> collect1 = tChargingPiles.stream().map(TChargingPile::getId).collect(Collectors.toList());
			List<TChargingGun> chargingGunList = chargingGunClient.getChargingGunByChargingPileIds(collect1).getData();
			@@ -153,22 +168,21 @@
			chargingStatisticeDTO.setEndTime(now);
			List<TChargingOrder> data1 = chargingOrderClient.getChargingStatistics(chargingStatisticeDTO).getData();
			for (Site datum : data) {
			List<TChargingOrder> collect = data1.stream().filter(e -> e.getSiteId().equals(datum.getId())
			&&e.getChargingPower()!=null).collect(Collectors.toList());
			List<TChargingOrder> collect = data1.stream().filter(e -> e.getSiteId().equals(datum.getId()) && e.getChargingPower()!=null).collect(Collectors.toList());
			SupStationPowerInfo supStationPowerInfo = new SupStationPowerInfo();
			supStationPowerInfo.setOperatorID("906171535");
			supStationPowerInfo.setEquipmentOwnerID("906171535");
			supStationPowerInfo.setStationID(datum.getId().toString());
			supStationPowerInfo.setStationClassification(1);
			supStationPowerInfo.setDataTime(DateUtils.localDateTimeToString(LocalDateTime.now()));
			BigDecimal divide = collect.stream().map(TChargingOrder::getChargingPower).reduce(BigDecimal::add).get().divide(new BigDecimal(collect.size()).setScale(4, BigDecimal.ROUND_DOWN));
			BigDecimal divide = collect.stream().map(TChargingOrder::getChargingPower).reduce(BigDecimal.ZERO, BigDecimal::add).divide(new BigDecimal(collect.size()).setScale(4, BigDecimal.ROUND_DOWN));
			supStationPowerInfo.setStationRealTimePower(divide);
			supStationPowerInfo.setEquipmentPowerInfos(buildEquipmentPowerInfo(datum.getId(), tChargingPiles, chargingGunList));
			stationStatsInfos.add(supStationPowerInfo);
			}
			supStationPowerInfoResult.setSupStationPowerInfos(stationStatsInfos);
			tcecSuperviseUtil.superviseNotificationRealtimePowerInfo(supStationPowerInfoResult);

			}
			}
			/**
			* 构建桩数据