| package com.zy.asrs.task; | 
|   | 
| import com.baomidou.mybatisplus.mapper.EntityWrapper; | 
| import com.zy.asrs.entity.BasDevp; | 
| import com.zy.asrs.service.BasDevpService; | 
| import com.zy.asrs.task.handler.AgvHandler; | 
| import org.springframework.scheduling.annotation.Scheduled; | 
| import org.springframework.stereotype.Component; | 
|   | 
| import javax.annotation.Resource; | 
| import java.util.List; | 
|   | 
| /** | 
|  * @author pang.jiabao | 
|  * @description AGV相关定时任务 | 
|  * @createDate 2024/10/19 9:30 | 
|  */ | 
| @Component | 
| public class AgvScheduler { | 
|   | 
|     @Resource | 
|     private BasDevpService basDevpService; | 
|   | 
|     @Resource | 
|     private AgvHandler agvHandller; | 
|   | 
|     // 出库呼叫agv接货 | 
|     // 223或123有出库的任务则呼叫agv接货 | 
|     @Scheduled(cron = "0/3 * * * * ? ") | 
|     private void outboundCallAgvScheduler() { | 
|   | 
|         // 获取两个站点有物,有工作号 | 
|         List<BasDevp> basDevps = basDevpService.selectList(new EntityWrapper<BasDevp>().in("dev_no", 223, 123).eq("loading", "Y").ne("wrk_no", 0)); | 
|   | 
|         for (BasDevp basDevp : basDevps) { | 
|             agvHandller.outboundCallAgvHandller(basDevp.getWrkNo()); | 
|         } | 
|   | 
|     } | 
|   | 
| } |