SaticScheduleTask.java 1.7 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162
  1. package com.gyee.regionrealtime.task;
  2. import com.gyee.regionrealtime.service.RegionRealtimeService;
  3. import com.gyee.regionrealtime.service.TheorypowerService;
  4. import com.xxl.job.core.context.XxlJobHelper;
  5. import com.xxl.job.core.handler.annotation.XxlJob;
  6. import org.slf4j.Logger;
  7. import org.slf4j.LoggerFactory;
  8. import org.springframework.stereotype.Component;
  9. import javax.annotation.Resource;
  10. /**
  11. * @ClassName : SaticScheduleTask
  12. * @Description : 调度
  13. */
  14. @Component
  15. public class SaticScheduleTask {
  16. private static Logger logger = LoggerFactory.getLogger(SaticScheduleTask.class);
  17. @Resource
  18. private RegionRealtimeService regionRealtimeService;
  19. @Resource
  20. private TheorypowerService theorypowerService;
  21. //3.添加定时任务
  22. @XxlJob("region-realtime")
  23. public void regionRealtime() {
  24. XxlJobHelper.log("区域公司实时调度程序执行开始!........");
  25. try {
  26. regionRealtimeService.regionRealtime("-1");
  27. regionRealtimeService.regionRealtime("-2");
  28. regionRealtimeService.regionRealtime("0");
  29. regionRealtimeService.groupRealtime("-1");
  30. regionRealtimeService.groupRealtime("-2");
  31. regionRealtimeService.groupRealtime("0");
  32. } catch (Exception e) {
  33. e.printStackTrace();
  34. }
  35. XxlJobHelper.log("区域公司实时调度任务处理完成!........");
  36. }
  37. @XxlJob("fittingPower")
  38. public void fittingPower() {
  39. XxlJobHelper.log("拟合功率曲线开始!........");
  40. try {
  41. theorypowerService.fittingPower();
  42. } catch (Exception e) {
  43. e.printStackTrace();
  44. }
  45. XxlJobHelper.log("拟合功率曲线结束!........");
  46. }
  47. }