12345678910111213141516171819202122232425262728293031323334353637383940414243444546 |
- package com.gyee.sampleimpala.schdule;
- import com.gyee.sampleimpala.common.constant.Constants;
- import com.gyee.sampleimpala.common.feign.RemoteServiceBuilder;
- import com.gyee.sampleimpala.common.util.DateUtil;
- import com.gyee.sampleimpala.model.custom.TsPointData;
- import com.gyee.sampleimpala.model.kudu.Windturbinepoint;
- import com.gyee.sampleimpala.service.kudu.WindpowerstationService;
- import com.gyee.sampleimpala.service.kudu.WindturbineService;
- import com.gyee.sampleimpala.service.kudu.WindturbinepointService;
- import lombok.extern.slf4j.Slf4j;
- import org.springframework.beans.factory.annotation.Autowired;
- import org.springframework.scheduling.annotation.Scheduled;
- import org.springframework.stereotype.Component;
- import java.util.List;
- @Component
- @Slf4j
- public class TaskPerformance {
- @Autowired
- private RemoteServiceBuilder remoteServiceBuilder;
- @Autowired
- private WindturbinepointService windturbinepointService;
- /**
- * 性能下降统计
- * 延时30s执行
- * 每隔60s执行一次
- */
- // @Scheduled(initialDelay = 30 * 1000, fixedRate = 60 * 1000)
- public void performanceDown(){
- // List<Windturbinepoint> nssFdc = windturbinepointService.getAllByStationAndUniformCode("NSS_FDC", Constants.FDJZS);
- // List<Windturbinepoint> ztFdc = windturbinepointService.getAllByStationAndUniformCode("NSS_FDC", Constants.FJMXZT);
- String point_nss_zs = "NSSFJ.NX_GD_NSSF_FJ_P1_L1_001_AI0012";
- String point_nss_zt = "NSSFJJSFW.NX_GD_NSSF_FJ_P1_L1_001_CI0169";
- List<TsPointData> zsData = remoteServiceBuilder.ShardingService().getHistoryRaw(point_nss_zs,
- DateUtil.covertDateTimestamp("2021-11-01 00:00:00"), DateUtil.covertDateTimestamp("2021-11-01 00:30:00"));
- List<TsPointData> ztData = remoteServiceBuilder.ShardingService().getHistoryRaw(point_nss_zt,
- DateUtil.covertDateTimestamp("2021-11-01 00:00:00"), DateUtil.covertDateTimestamp("2021-11-01 00:30:00"));
- }
- }
|