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 nssFdc = windturbinepointService.getAllByStationAndUniformCode("NSS_FDC", Constants.FDJZS); // List 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 zsData = remoteServiceBuilder.ShardingService().getHistoryRaw(point_nss_zs, DateUtil.covertDateTimestamp("2021-11-01 00:00:00"), DateUtil.covertDateTimestamp("2021-11-01 00:30:00")); List ztData = remoteServiceBuilder.ShardingService().getHistoryRaw(point_nss_zt, DateUtil.covertDateTimestamp("2021-11-01 00:00:00"), DateUtil.covertDateTimestamp("2021-11-01 00:30:00")); } }