| | |
|---|
| | | // 解析入库工作档 |
|---|
| | | public synchronized void analyzeInBoundTask() { |
|---|
| | | for (Task task : taskService.selectWaitAnalyzeInBoundTask()) { |
|---|
| | | // BasConveyorSta basConveyorSta = basConveyorStaService.getOne(new LambdaQueryWrapper<BasConveyorSta>().eq(BasConveyorSta::getSiteNo, task.getDestSite())); |
|---|
| | | // if (basConveyorSta == null) { |
|---|
| | | // continue; |
|---|
| | | // } |
|---|
| | | // DeviceBarcode deviceBarcode = deviceBarcodeService.getById(basConveyorSta.getBarcodeId()); |
|---|
| | | // if (deviceBarcode == null) { |
|---|
| | | // continue; |
|---|
| | | // } |
|---|
| | | // BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, Integer.parseInt(deviceBarcode.getDeviceId())); |
|---|
| | | // if (barcodeThread == null) { |
|---|
| | | // continue; |
|---|
| | | // } |
|---|
| | | BasConveyorSta basConveyorSta = basConveyorStaService.getOne(new LambdaQueryWrapper<BasConveyorSta>().eq(BasConveyorSta::getSiteNo, task.getDestSite())); |
|---|
| | | if (basConveyorSta == null) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | BasConveyor basConveyor = basConveyorService.getById(basConveyorSta.getConveyorId()); |
|---|
| | | if (basConveyor == null) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | DeviceBarcode deviceBarcode = deviceBarcodeService.getById(basConveyorSta.getBarcodeId()); |
|---|
| | | if (deviceBarcode == null) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, Integer.parseInt(deviceBarcode.getDeviceId())); |
|---|
| | | if (barcodeThread == null) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | if (!barcodeThread.getBarcode().equals(task.getZpallet())) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Conveyor, basConveyor.getDeviceId().intValue()); |
|---|
| | | if (devpThread == null) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | StaProtocol staProtocol = devpThread.getStation().get(basConveyorSta.getSiteNo()); |
|---|
| | | if (staProtocol == null) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | if (!(staProtocol.isAutoing() |
|---|
| | | && staProtocol.isLoading() |
|---|
| | | && staProtocol.isInEnable())) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | if (Cools.isEmpty(task.getShuttleNo())) { |
|---|
