| | |
| | | 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; |
| | | } |
| | | |
| | | } |
| | | |
| | | /** |