TaskPerformance.java 2.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546
  1. package com.gyee.sampleimpala.schdule;
  2. import com.gyee.sampleimpala.common.constant.Constants;
  3. import com.gyee.sampleimpala.common.feign.RemoteServiceBuilder;
  4. import com.gyee.sampleimpala.common.util.DateUtil;
  5. import com.gyee.sampleimpala.model.custom.TsPointData;
  6. import com.gyee.sampleimpala.model.kudu.Windturbinepoint;
  7. import com.gyee.sampleimpala.service.kudu.WindpowerstationService;
  8. import com.gyee.sampleimpala.service.kudu.WindturbineService;
  9. import com.gyee.sampleimpala.service.kudu.WindturbinepointService;
  10. import lombok.extern.slf4j.Slf4j;
  11. import org.springframework.beans.factory.annotation.Autowired;
  12. import org.springframework.scheduling.annotation.Scheduled;
  13. import org.springframework.stereotype.Component;
  14. import java.util.List;
  15. @Component
  16. @Slf4j
  17. public class TaskPerformance {
  18. @Autowired
  19. private RemoteServiceBuilder remoteServiceBuilder;
  20. @Autowired
  21. private WindturbinepointService windturbinepointService;
  22. /**
  23. * 性能下降统计
  24. * 延时30s执行
  25. * 每隔60s执行一次
  26. */
  27. // @Scheduled(initialDelay = 30 * 1000, fixedRate = 60 * 1000)
  28. public void performanceDown(){
  29. // List<Windturbinepoint> nssFdc = windturbinepointService.getAllByStationAndUniformCode("NSS_FDC", Constants.FDJZS);
  30. // List<Windturbinepoint> ztFdc = windturbinepointService.getAllByStationAndUniformCode("NSS_FDC", Constants.FJMXZT);
  31. String point_nss_zs = "NSSFJ.NX_GD_NSSF_FJ_P1_L1_001_AI0012";
  32. String point_nss_zt = "NSSFJJSFW.NX_GD_NSSF_FJ_P1_L1_001_CI0169";
  33. List<TsPointData> zsData = remoteServiceBuilder.ShardingService().getHistoryRaw(point_nss_zs,
  34. DateUtil.covertDateTimestamp("2021-11-01 00:00:00"), DateUtil.covertDateTimestamp("2021-11-01 00:30:00"));
  35. List<TsPointData> ztData = remoteServiceBuilder.ShardingService().getHistoryRaw(point_nss_zt,
  36. DateUtil.covertDateTimestamp("2021-11-01 00:00:00"), DateUtil.covertDateTimestamp("2021-11-01 00:30:00"));
  37. }
  38. }