|  |  | 
 |  |  | import com.core.common.Cools; | 
 |  |  | import com.core.common.DateUtils; | 
 |  |  | import com.core.common.SpringUtils; | 
 |  |  | import com.sun.org.apache.bcel.internal.generic.IF_ACMPEQ; | 
 |  |  | import com.zy.asrs.entity.BasDevp; | 
 |  |  | import com.zy.asrs.service.BasDevpService; | 
 |  |  | import com.zy.common.utils.CommonUtils; | 
 |  |  | import com.zy.core.DevpThread; | 
 |  |  | import com.zy.core.News; | 
 |  |  | import com.zy.core.cache.MessageQueue; | 
 |  |  | 
 |  |  |                         break; | 
 |  |  |                     // 出入库模式 | 
 |  |  |                     case 3: | 
 |  |  |                         write3((int)task.getData()); | 
 |  |  |                         write3((StaProtocol)task.getData()); | 
 |  |  |                         break; | 
 |  |  |                     default: | 
 |  |  |                         break; | 
 |  |  | 
 |  |  |         OperateResultExOne<byte[]> result2 = siemensS7Net.Read("DB100.200",(short)24); | 
 |  |  |         if (result2.IsSuccess) { | 
 |  |  |             for (int i = 0; i <= barcodeSize; i++) { | 
 |  |  |                 String barcode = siemensS7Net.getByteTransform().TransString(result2.Content,i*8,8, "UTF-8"); | 
 |  |  |                 byte[] bytes = siemensS7Net.getByteTransform().TransByte(result2.Content, i * 8, 8); | 
 |  |  |                 String barcode = CommonUtils.bytesToBarcode(bytes); | 
 |  |  | //                String barcode = siemensS7Net.getByteTransform().TransString(result2.Content,i*8,8, "UTF-8"); | 
 |  |  |                 BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, i + 1); | 
 |  |  |                 if(!Cools.isEmpty(barcodeThread) && !barcodeThread.getBarcode().equals(barcode)) { | 
 |  |  |                     barcodeThread.setBarcode(barcode); | 
 |  |  | 
 |  |  |  | 
 |  |  |         // 外形检测 - 102 | 
 |  |  |         Thread.sleep(50); | 
 |  |  |         OperateResultExOne<byte[]> result102 = siemensS7Net.Read("DB102.110", (short)1); | 
 |  |  |         OperateResultExOne<byte[]> result102 = siemensS7Net.Read("DB100.100", (short)2); | 
 |  |  |         if (result102.IsSuccess) { | 
 |  |  |             boolean[] status = siemensS7Net.getByteTransform().TransBool(result102.Content, 0, 1); | 
 |  |  |             //出入库模式 | 
 |  |  |             short outInModel = siemensS7Net.getByteTransform().TransInt16(result102.Content, 0); | 
 |  |  |             StaProtocol staProtocol = station.get(102); | 
 |  |  |             staProtocol.setFrontErr(status[0]);// 前超限 | 
 |  |  |             staProtocol.setBackErr(status[1]);// 后超限 | 
 |  |  |             staProtocol.setHighErr(status[2]);// 高超限 | 
 |  |  |             staProtocol.setLeftErr(status[3]);// 左超限 | 
 |  |  |             staProtocol.setRightErr(status[4]);// 右超限 | 
 |  |  |             staProtocol.setWeightErr(status[5]); // 超重 | 
 |  |  |             staProtocol.setBarcodeErr(status[6]);// 扫码失败 | 
 |  |  |             staProtocol.setOutInModel(outInModel); | 
 |  |  |         } | 
 |  |  | //        // 外形检测 - 201 | 
 |  |  | //        Thread.sleep(50); | 
 |  |  | 
 |  |  |     /** | 
 |  |  |      * 写入 ID+目标站 =====> 单站点写入 | 
 |  |  |      */ | 
 |  |  |     private void write3(int outAndIn) throws InterruptedException{ | 
 |  |  |         if (Cools.isEmpty(outAndIn)) { | 
 |  |  |     private void write3(StaProtocol staProtocol) throws InterruptedException { | 
 |  |  |         if (Cools.isEmpty(staProtocol)) { | 
 |  |  |             return; | 
 |  |  |         } | 
 |  |  |         if (outAndIn==666){ | 
 |  |  |             siemensS7Net.Write("DB100.200", (short) 1); | 
 |  |  |         }else if (outAndIn==999){ | 
 |  |  |             siemensS7Net.Write("DB100.200", (short) 0); | 
 |  |  |         }else { | 
 |  |  |             String Db=null; | 
 |  |  |             if (outAndIn<20){ | 
 |  |  |                 Db="DB100.180"; | 
 |  |  |             }else if (outAndIn<30){ | 
 |  |  |                 Db="DB100.182"; | 
 |  |  |             }else { | 
 |  |  |                 Db="DB100.184"; | 
 |  |  |             } | 
 |  |  |             if (outAndIn == 11 || outAndIn == 21 || outAndIn == 31){ | 
 |  |  |                 siemensS7Net.Write(Db, (byte) 1);    // 入库 | 
 |  |  |             }else if (outAndIn == 12 || outAndIn == 22 || outAndIn == 32){ | 
 |  |  |                 siemensS7Net.Write(Db, (byte) 2);    // 出库 | 
 |  |  |             }else if (outAndIn == 10 || outAndIn == 20 || outAndIn == 30){ | 
 |  |  |                 siemensS7Net.Write(Db, (byte) 0);    // 出库 | 
 |  |  |             } | 
 |  |  |         Short outAndIn = staProtocol.getOutInModel(); | 
 |  |  |         Integer siteId = staProtocol.getSiteId(); | 
 |  |  |         Short run = 1;//正转 | 
 |  |  |         if (outAndIn == 1) {//入库 | 
 |  |  |             run = 1;//正转 | 
 |  |  |         } else { | 
 |  |  |             run = 2;//反转 | 
 |  |  |         } | 
 |  |  |         switch (siteId) { | 
 |  |  |             case 102: | 
 |  |  |                 siemensS7Net.Write("DB100.300", run); | 
 |  |  |                 break; | 
 |  |  |             case 105: | 
 |  |  |                 siemensS7Net.Write("DB100.302", run); | 
 |  |  |                 break; | 
 |  |  |             case 106: | 
 |  |  |                 siemensS7Net.Write("DB100.304", run); | 
 |  |  |                 break; | 
 |  |  |             case 107: | 
 |  |  |                 siemensS7Net.Write("DB100.306", run); | 
 |  |  |                 break; | 
 |  |  |             case 108: | 
 |  |  |                 siemensS7Net.Write("DB100.308", run); | 
 |  |  |                 break; | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** |