From 9e223b67754bbc0e2661d13c00e7ad06d8b84009 Mon Sep 17 00:00:00 2001
From: Administrator <pjb>
Date: 星期三, 22 十月 2025 18:32:59 +0800
Subject: [PATCH] 侧面需要码盘才下发码盘信息

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |    8 ++++++++
 1 files changed, 8 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
index ed84434..ddf611e 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -182,6 +182,7 @@
                         storageEscalationParam.setBarcode(BoxNo);
                         storageEscalationParam.setMatIdList(staProtocol.getMatIdList());
                         storageEscalationParam.setFullPlt(staProtocol.isFullPlt() ? 1 : 0);
+                        storageEscalationParam.setMpHigh((short) (staProtocol.getSiteId() < 200 ? 1 :staProtocol.isHigh() ? 2 : staProtocol.isLow() ? 1 : 0));    // 楂樺害锛屼晶闈㈢爜鐩樼殑楂樺害 浣�1锛岄珮2
                         log.info("缁勬墭鍏ュ簱={}", storageEscalationParam);
                         TaskWrk taskWrk = toWmsService.getLocNoFromWms(storageEscalationParam);
                         if (taskWrk == null) {
@@ -247,12 +248,19 @@
                             log.info("涓嬪彂杈撻�佺嚎浠诲姟锛歵askWrk:" + JSON.toJSONString(taskWrk));
                             staProtocol.setWorkNo(taskWrk.getWrkNo().shortValue());
                             staProtocol.setStaNo(Short.valueOf(taskWrk.getTargetPoint()));
+                            staProtocol.setBarcode(taskWrk.getBarcode());
                             if (!Cools.isEmpty(taskWrk.getType())) {
                                 staProtocol.setHeight(taskWrk.getType());
                             }
                             boolean offer = false;
                             try {
                                 offer = MessageQueue.offer(SlaveType.Devp, 1, new Task(2, staProtocol));
+                                if(taskWrk.getMp() == 1) {
+                                    staProtocol.setMp(taskWrk.getMp());
+                                    staProtocol.setLx(taskWrk.getLx());
+                                    staProtocol.setLev(taskWrk.getLev());
+                                    MessageQueue.offer(SlaveType.Devp, 1, new Task(3, staProtocol));
+                                }
                             } catch (Exception e) {
                                 log.error("涓嬪彂杈撻�佺嚎浠诲姟澶辫触锛氬紓甯�:" + e);
                                 log.error("涓嬪彂杈撻�佺嚎浠诲姟澶辫触锛氬紓甯�:offer:" + offer);

--
Gitblit v1.9.1