修改公交公司的事件订阅功能

puzhibing

2025-05-30 35b0088fa28dab8a28758dcbcc056620c1ea5e2c

 ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/util/TaskUtil.java

@@ -2,6 +2,8 @@

import com.ruoyi.system.service.ICarService;
import com.ruoyi.system.service.IDriverService;
import com.ruoyi.system.service.IOrderService;
import com.ruoyi.system.service.IWarnService;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

@@ -20,6 +22,12 @@
   @Resource
   private IDriverService driverService;
   
   @Resource
   private IWarnService warnService;
	
   @Resource
   private IOrderService orderService;
	
   
   /**
    * 定时任务获取新车辆数据
@@ -27,6 +35,7 @@
   @Scheduled(fixedRate = 1000 * 60)
   public void taskSaveNewCar() {
      carService.taskSaveNewCar();
      carService.taskSaveDriverId();
   }
   
   
@@ -37,4 +46,43 @@
   public void taskSaveNewDriver() {
      driverService.taskSaveNewDriver();
   }
	
	
   /**
    * 定时任务获取新报警数据
    */
   @Scheduled(fixedRate = 1000 * 60)
   public void taskSaveNewWarn() {
      warnService.taskSaveNewWarn();
      warnService.taskSaveCarIdAndDriverId();
   }
	
	
   /**
    * 定时任务修改预警信息处理结果
    */
   @Scheduled(fixedRate = 1000 * 600)
   public void taskUpdateWarnStatus() {
      warnService.taskUpdateWarnStatus();
   }
	
	
   /**
    * 定时任务获取新订单数据
    */
   @Scheduled(fixedRate = 1000 * 60)
   public void taskSaveNewOrder() {
      orderService.taskSaveNewOrder();
      orderService.taskSaveCarIdAndDriverId();
   }
	
	
   /**
    * 定时任务修改车辆状态
    */
   @Scheduled(fixedRate = 1000 * 300)
   public void taskUpdateCarStatus() {
      carService.taskUpdateCarStatus();
      carService.taskGetCarDeviceId();
   }
}