| | |
| | | package com.zy.core; |
| | | |
| | | import com.zy.asrs.service.impl.MainServiceImpl; |
| | | import com.core.common.SpringUtils; |
| | | import com.zy.core.plugin.MainProcessPluginApi; |
| | | import com.zy.core.properties.SystemProperties; |
| | | import lombok.Data; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.beans.factory.annotation.Value; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import javax.annotation.PreDestroy; |
| | | |
| | | /** |
| | | * WCS主流程 |
| | | * Created by vincent on 2020/8/6 |
| | | */ |
| | | @Data |
| | | @Slf4j |
| | | @Component |
| | | public class MainProcess { |
| | | |
| | | @Autowired |
| | | private MainServiceImpl mainService; |
| | | @Value("${mainProcessPlugin}") |
| | | private String mainProcessPlugin; |
| | | private MainProcessPluginApi mainProcessPluginApi; |
| | | // 所属线程 |
| | | private Thread thread; |
| | | // 频率 |
| | | private int i = 0; |
| | | |
| | | /** |
| | | * =====>> 开始工作 |
| | |
| | | thread = new Thread(() -> { |
| | | while (!Thread.currentThread().isInterrupted()) { |
| | | try { |
| | | |
| | | // 间隔 |
| | | Thread.sleep(300); |
| | | if (mainProcessPluginApi == null) { |
| | | String className = mainProcessPlugin.contains(".") ? mainProcessPlugin : "com.zy.core.plugin." + mainProcessPlugin; |
| | | Class<? extends MainProcessPluginApi> clazz = Class.forName(className).asSubclass(MainProcessPluginApi.class); |
| | | mainProcessPluginApi = SpringUtils.getBean(clazz); |
| | | } |
| | | |
| | | // 系统运行状态判断 |
| | | if (!SystemProperties.WCS_RUNNING_STATUS.get()) { |
| | | continue; |
| | | } |
| | | |
| | | // 入库 ===>> 入库站到堆垛机站,根据条码扫描生成入库工作档 |
| | | mainService.generateStoreWrkFile(); // 组托 |
| | | // mainService.generateStoreWrkFile0(); // WMS入库 |
| | | |
| | | // 间隔 |
| | | Thread.sleep(500); |
| | | |
| | | //初始化实时地图 |
| | | mainService.initRealtimeBasMap(); |
| | | // 拣料、并板、盘点再入库 |
| | | mainService.stnToCrnStnPick(); |
| | | // 入库 ===>> 四向穿梭车入库作业下发 |
| | | mainService.shuttleInExecute(); |
| | | // 出库 ===>> 四向穿梭车出库作业下发 |
| | | mainService.shuttleOutExecute(); |
| | | //四向穿梭车任务完成 |
| | | mainService.shuttleFinished(); |
| | | //提升机任务 |
| | | mainService.liftIoExecute(); |
| | | //提升机任务完成 |
| | | mainService.liftFinished(); |
| | | //库位移转 |
| | | mainService.locToLocExecute(); |
| | | //执行小车移库任务 |
| | | mainService.shuttleMoveExecute(); |
| | | // 异常信息记录 |
| | | mainService.recErr(); |
| | | // 入库 ===>> 空栈板初始化入库,叉车入库站放货 |
| | | mainService.storeEmptyPlt(); |
| | | // AGV补货(机械臂拣料) |
| | | mainService.agvRestockByRobot(); |
| | | // AGV补货(通知AGV取货) |
| | | mainService.agvRestockInto(); |
| | | // 300站拣料 |
| | | mainService.pick300(); |
| | | // 出库 ===>> 工作档信息写入led显示器 |
| | | mainService.ledExecute(); |
| | | // 其他 ===>> LED显示器复位,显示默认信息 |
| | | mainService.ledReset(); |
| | | // 穿梭车 ===>> 小车电量检测充电 |
| | | mainService.loopShuttleCharge(); |
| | | mainService.executeShuttleCharge(); |
| | | |
| | | mainProcessPluginApi.run(); |
| | | // 间隔 |
| | | Thread.sleep(200); |
| | | } catch (Exception e) { |