|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public synchronized void generateStoreWrkFile(Integer mark) { | 
|---|
|  |  |  | String methodName = Thread.currentThread().getStackTrace()[1].getMethodName(); | 
|---|
|  |  |  | final Set<String> INVALID_BARCODES = new HashSet<>(Arrays.asList("NG", "NoRead", "00000000")); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | for (DevpSlave devp : slaveProperties.getDevp()) { | 
|---|
|  |  |  | for (DevpSlave.Sta inSta : devp.getInSta()) { | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | continue; | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | // 尺寸/重量/扫码异常检测 | 
|---|
|  |  |  | if (staProtocol == null) continue; | 
|---|
|  |  |  | 
|---|
|  |  |  | devpThread.setPakMk(staProtocol.getSiteId(), false); | 
|---|
|  |  |  | MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); | 
|---|
|  |  |  | log.error("输送线下发1:" + wrkNo + "," + inSta.getBackSta()); | 
|---|
|  |  |  | continue; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //                        // 入库条件满足,开始请求入库地址 | 
|---|