zy-wcs.git - Gitblit

			@@ -22,6 +22,7 @@
			import com.zy.core.enums.SlaveType;
			import com.zy.core.model.DevpSlave;
			import com.zy.core.model.Task;
			import com.zy.core.model.protocol.StaError1;
			import com.zy.core.model.protocol.StaProtocol;
			import lombok.Data;
			import lombok.extern.slf4j.Slf4j;
			@@ -45,35 +46,27 @@
			private SiemensS7Net siemensS7Net;
			private Map<Integer, StaProtocol> station = new ConcurrentHashMap<>();
			private short heartBeatVal = 1;
			private StaError1 staError1;
			// public static final ArrayList<Integer> staNos = new ArrayList<Integer>() {{
			//
			// }};
			public static final ArrayList<Integer> staNos1 = new ArrayList<Integer>() {{
			add(100);add(101);add(102);add(103);
			add(104);add(105);add(106);add(107);
			add(108);add(109);add(110);add(111);
			add(112);add(113);add(114);add(115);
			add(116);add(117);add(118);add(119);
			add(120);add(121);add(122);add(123);
			add(124);add(125);add(126);add(127);
			add(128);add(129);add(130);add(131);
			add(132);add(133);add(134);add(135);
			add(136);add(137);add(138);add(139);
			add(140);add(141);add(142);add(143);
			add(144);add(145);add(146);add(147);
			add(148);add(149);add(150);add(151);
			add(152);add(153);add(154);add(155);
			add(156);add(157);add(158);add(159);
			add(160);add(161);
			add(1);
			// add(200);add(201);add(202);
			add(1111);add(1112);add(1113);add(1114);
			add(1121);add(1122);add(1123);add(1124);
			add(1131);add(1132);add(1133);add(1134);add(1135);
			}};

			public static final ArrayList<Integer> staNos2 = new ArrayList<Integer>() {{
			add(1112);add(1114);add(1122);add(1124);add(1131);

			}};

			public static final ArrayList<Integer> BarcodeList = new ArrayList<Integer>() {{
			add(0); add(1); add(2);
			add(1112); add(1122);
			}};

			public static final ArrayList<Integer> staNosErrList = new ArrayList<Integer>() {{
			add(106); add(107); add(159);
			add(1112); add(1122);
			}};

			private Integer count=0;
			@@ -81,7 +74,7 @@
			/**
			* 条码数量
			*/
			private int barcodeSize = 6;
			private int barcodeSize = 2;

			/**
			* 入出库模式
			@@ -135,7 +128,7 @@
			}
			// 心跳
			// heartbeat();
			Thread.sleep(300);
			Thread.sleep(100);
			} catch (Exception e) {
			e.printStackTrace();
			}
			@@ -157,7 +150,7 @@
			staProtocol.setSiteId(siteId);
			station.put(siteId, staProtocol);
			}
			staProtocol.setWorkNo(0); // ID
			staProtocol.setWorkNo((short) 0); // ID
			staProtocol.setAutoing(false); // 自动
			staProtocol.setLoading(false); // 有物
			staProtocol.setInEnable(false); // 可入
			@@ -201,7 +194,7 @@
			// updateIoMode();
			ArrayList<Integer> staNos = getStaNo();
			int staNoSize = staNos.size();
			OperateResultExOne<byte[]> result = siemensS7Net.Read("DB101.0", (short) (staNoSize*8));
			OperateResultExOne<byte[]> result = siemensS7Net.Read("DB82.4", (short) (staNoSize*26));
			if (result.IsSuccess) {
			for (int i = 0; i < staNoSize; i++) {
			Integer siteId = staNos.get(i); // 站点编号
			@@ -211,92 +204,40 @@
			staProtocol.setSiteId(siteId);
			station.put(siteId, staProtocol);
			}
			staProtocol.setWorkNo(siemensS7Net.getByteTransform().TransInt32(result.Content, i*8)); // 工作号

			staProtocol.setStaNo(siemensS7Net.getByteTransform().TransInt16(result.Content, i*8 + 4)); // 目标站

			boolean[] status = siemensS7Net.getByteTransform().TransBool(result.Content, i*8 + 6, 2);
			boolean[] status = siemensS7Net.getByteTransform().TransBool(result.Content, i*26, 2);
			staProtocol.setAutoing(status[0]); // 自动
			staProtocol.setLoading(status[1]); // 有物
			staProtocol.setInEnable(status[2]); // 可入
			staProtocol.setOutEnable(status[3]);// 可出
			staProtocol.setEmptyMk(status[4]); // 空板信号
			staProtocol.setFullPlt(status[5]); // 满托盘
			staProtocol.setHigh(status[6]); // 高库位
			staProtocol.setLow(status[7]); // 低库位
			staProtocol.setIdle(status[1]); //空闲
			staProtocol.setLoading(status[2]); // 有物
			staProtocol.setIn(status[3]);
			staProtocol.setOut(status[4]);
			staProtocol.setBackErr(status[5]);
			staProtocol.setLeftErr(status[6]);
			staProtocol.setRightErr(status[7]);
			staProtocol.setHighErr(status[8]);
			staProtocol.setWeightErr(status[9]);
			staProtocol.setLow(status[10]);
			staProtocol.setHigh(status[11]);

			staProtocol.setInEnable(status[13]); // 可入
			staProtocol.setOutEnable(status[14]);// 可出


			staProtocol.setWorkNo(siemensS7Net.getByteTransform().TransInt16(result.Content, i*26+2)); // 工作号
			staProtocol.setFinishWorkNo(siemensS7Net.getByteTransform().TransInt16(result.Content, i*26+6)); //已完成工作号
			staProtocol.setBarcode(siemensS7Net.getByteTransform().TransString(result.Content,i*26+10,12, "UTF-8").trim()); //条码
			staProtocol.setWeight(siemensS7Net.getByteTransform().TransInt32(result.Content, i*26+22)); //重量




			if (!staProtocol.isPakMk() && !staProtocol.isLoading()) {
			staProtocol.setPakMk(true);
			}
			}
			}
			BasRgvMapService basRgvMapService = SpringUtils.getBean(BasRgvMapService.class);
			//RGV小车
			Thread.sleep(200);
			OperateResultExOne<byte[]> result3 = siemensS7Net.Read("DB50.200",(short)10);
			if (result3.IsSuccess) {
			BasRgvMap basRgvMap = basRgvMapService.selectByRgvNo((int) siemensS7Net.getByteTransform().TransInt16(result3.Content, 0));
			if (!Cools.isEmpty(basRgvMap) && basRgvMap.getStartRoute() == 100){
			Integer siteId = 1;
			StaProtocol staProtocol = station.get(siteId);
			if (null == staProtocol) {
			staProtocol = new StaProtocol();
			staProtocol.setSiteId(siteId);
			station.put(siteId, staProtocol);
			}
			staProtocol.setAutoing(true);
			staProtocol.setNearbySta(String.valueOf(siemensS7Net.getByteTransform().TransInt16(result3.Content, 8)));
			}
			}
			//RGV小车
			Thread.sleep(200);
			OperateResultExOne<byte[]> result4 = siemensS7Net.Read("DB50.212",(short)10);
			if (result4.IsSuccess) {
			BasRgvMap basRgvMap = basRgvMapService.selectByRgvNo((int) siemensS7Net.getByteTransform().TransInt16(result4.Content, 0));
			if (!Cools.isEmpty(basRgvMap) && (basRgvMap.getStartRoute() == 161 \|\| basRgvMap.getStartRoute() == 157)){
			Integer siteId = 2;
			StaProtocol staProtocol = station.get(siteId);
			if (null == staProtocol) {
			staProtocol = new StaProtocol();
			staProtocol.setSiteId(siteId);
			station.put(siteId, staProtocol);
			}
			staProtocol.setAutoing(true);
			staProtocol.setNearbySta(String.valueOf(siemensS7Net.getByteTransform().TransInt16(result4.Content, 8)));
			}
			}

			//条码扫描器
			ArrayList<Integer> barcodeList = BarcodeList;
			OperateResultExOne<byte[]> result2 = siemensS7Net.Read("DB101.840", (short) (barcodeList.size() * 8));
			if (result2.IsSuccess) {
			for (int i = 0; i < barcodeList.size(); i++) {
			Integer barcodeId = barcodeList.get(i);
			String barcode = siemensS7Net.getByteTransform().TransString(result2.Content,i*8,8, "UTF-8");
			BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, barcodeId + 1);
			if(!Cools.isEmpty(barcodeThread) && !barcodeThread.getBarcode().equals(barcode)) {
			barcodeThread.setBarcode(barcode);
			}
			}
			}
			//外形检测
			ArrayList<Integer> staNoErrs = staNosErrList;
			int staNoErrsSize = staNoErrs.size();
			OperateResultExOne<byte[]> resultErr = siemensS7Net.Read("DB101.800", (short) (staNoErrsSize*8));
			if (resultErr.IsSuccess){
			for (int i = 0;i<3;i++){
			Integer siteId = staNoErrs.get(i); // 站点编号
			boolean[] status = siemensS7Net.getByteTransform().TransBool(resultErr.Content, i*4+2, 1);
			StaProtocol staProtocol = station.get(siteId);
			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]);
			}
			}

			if (result.IsSuccess) {

			@@ -334,17 +275,17 @@
			if (null == staProtocol) {
			return;
			}
			ArrayList<Integer> staNos = getStaNo();
			int index = staNos.indexOf(staProtocol.getSiteId());
			int index = staNos2.indexOf(staProtocol.getSiteId());
			OperateResult write = null;
			OperateResult write1 = null;
			//任务下发次数
			int writeCount = 0;
			do {
			write = siemensS7Net.Write("DB100." + index*6, staProtocol.getWorkNo()); // 工作号
			write = siemensS7Net.Write("DB83." + (index*8+6), staProtocol.getWorkNo()); // 工作号
			Thread.sleep(200);
			write1 = siemensS7Net.Write("DB100." + (index*6+4), staProtocol.getStaNo().shortValue()); // 目标站
			write1 = siemensS7Net.Write("DB83." + (index*8+4), staProtocol.getStaNo()); // 目标站
			if(write.IsSuccess && write1.IsSuccess){
			log.error("写入输送线命令成功。输送线plc编号={}，站点数据={},写入次数={}", slave.getId(), JSON.toJSON(staProtocol), writeCount);
			break;
			}
			else {