zy-wcs.git - Gitblit

			@@ -121,7 +121,7 @@
			default:
			break;
			}
			Thread.sleep(400);
			// Thread.sleep(400);
			} catch (Exception e) {
			e.printStackTrace();
			}
			@@ -185,190 +185,222 @@

			ArrayList<Integer> staNos = getStaNo();
			int staNoSize = staNos.size();
			OperateResultExOne<byte[]> result;
			if (slave.getId() == 1) {
			// 读正面货位信息反馈
			result = siemensS7Net.Read("DB101.0", (short) (16 * 8));
			if (result.IsSuccess) {
			for (int i = 0; i < 16; i++) {
			Integer siteId = staNos.get(i); // 站点编号
			StaProtocol staProtocol = station.get(siteId);
			if (null == staProtocol) {
			staProtocol = new StaProtocol();
			staProtocol.setSiteId(siteId);
			station.put(siteId, staProtocol);
			}
			staProtocol.setWorkNo((short) siemensS7Net.getByteTransform().TransInt32(result.Content, i * 8)); // 工作号

			// 读正面货位信息反馈
			OperateResultExOne<byte[]> result = siemensS7Net.Read("DB101.0", (short) (16 * 8));
			if (result.IsSuccess) {
			for (int i = 0; i < 16; i++) {
			Integer siteId = staNos.get(i); // 站点编号
			StaProtocol staProtocol = station.get(siteId);
			if (null == staProtocol) {
			staProtocol = new StaProtocol();
			staProtocol.setSiteId(siteId);
			station.put(siteId, staProtocol);
			}
			staProtocol.setWorkNo((short) siemensS7Net.getByteTransform().TransInt32(result.Content, i * 8)); // 工作号
			staProtocol.setStaNo(siemensS7Net.getByteTransform().TransInt16(result.Content, i * 8 + 4)); // 目标站

			staProtocol.setStaNo(siemensS7Net.getByteTransform().TransInt16(result.Content, i * 8 + 4)); // 目标站
			boolean[] status = siemensS7Net.getByteTransform().TransBool(result.Content, i * 8 + 6, 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]); // 低库位

			boolean[] status = siemensS7Net.getByteTransform().TransBool(result.Content, i * 8 + 6, 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]); // 低库位

			if (!staProtocol.isPakMk() && !staProtocol.isLoading()) {
			staProtocol.setPakMk(true);
			if (!staProtocol.isPakMk() && !staProtocol.isLoading()) {
			staProtocol.setPakMk(true);
			}
			}
			}
			}
			// 读侧面货位信息反馈
			OperateResultExOne<byte[]> resultCm = siemensS7Net.Read("DB101.800", (short) (12 * 8));
			if (resultCm.IsSuccess) {
			for (int i = 16; i < staNoSize; i++) {
			Integer siteId = staNos.get(i); // 站点编号
			StaProtocol staProtocol = station.get(siteId);
			if (null == staProtocol) {
			staProtocol = new StaProtocol();
			staProtocol.setSiteId(siteId);
			station.put(siteId, staProtocol);
			}
			staProtocol.setWorkNo((short) siemensS7Net.getByteTransform().TransInt32(resultCm.Content, (i - 16) * 8)); // 工作号

			// 读侧面货位信息反馈
			OperateResultExOne<byte[]> resultCm = siemensS7Net.Read("DB101.800", (short) (12 * 8));
			if (resultCm.IsSuccess) {
			for (int i = 16; i < staNoSize; i++) {
			Integer siteId = staNos.get(i); // 站点编号
			StaProtocol staProtocol = station.get(siteId);
			if (null == staProtocol) {
			staProtocol = new StaProtocol();
			staProtocol.setSiteId(siteId);
			station.put(siteId, staProtocol);
			}
			staProtocol.setWorkNo((short) siemensS7Net.getByteTransform().TransInt32(resultCm.Content, (i-16) * 8)); // 工作号
			staProtocol.setStaNo(siemensS7Net.getByteTransform().TransInt16(resultCm.Content, (i - 16) * 8 + 4)); // 目标站

			staProtocol.setStaNo(siemensS7Net.getByteTransform().TransInt16(resultCm.Content, (i-16) * 8 + 4)); // 目标站
			boolean[] status = siemensS7Net.getByteTransform().TransBool(resultCm.Content, (i - 16) * 8 + 6, 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]); // 低库位

			boolean[] status = siemensS7Net.getByteTransform().TransBool(resultCm.Content, (i-16) * 8 + 6, 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]); // 低库位

			if (!staProtocol.isPakMk() && !staProtocol.isLoading()) {
			staProtocol.setPakMk(true);
			if (!staProtocol.isPakMk() && !staProtocol.isLoading()) {
			staProtocol.setPakMk(true);
			}
			}
			}
			}

			// 读取正面条码
			OperateResultExOne<byte[]> result2 = siemensS7Net.Read("DB101.1404", (short) (16 * 8));
			if (result2.IsSuccess) {
			for (int i = 0; i < 16; i++) {
			int barcodeId = 0;
			switch (i) {
			case 1:
			barcodeId = 1;
			break;
			case 4:
			barcodeId = 2;
			break;
			case 7:
			barcodeId = 3;
			break;
			case 10:
			barcodeId = 4;
			break;
			case 13:
			barcodeId = 5;
			break;
			default:
			// 读取正面条码
			OperateResultExOne<byte[]> result2 = siemensS7Net.Read("DB101.1404", (short) (16 * 8));
			if (result2.IsSuccess) {
			for (int i = 0; i < 16; i++) {
			int barcodeId = 0;
			switch (i) {
			case 1:
			barcodeId = 1;
			break;
			case 4:
			barcodeId = 2;
			break;
			case 7:
			barcodeId = 3;
			break;
			case 10:
			barcodeId = 4;
			break;
			case 13:
			barcodeId = 5;
			break;
			default:
			}
			if (barcodeId != 0) {
			String barcode = siemensS7Net.getByteTransform().TransString(result2.Content, i * 8, 6, "UTF-8");
			BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, barcodeId);
			if (!Cools.isEmpty(barcodeThread) && !barcodeThread.getBarcode().equals(barcode)) {
			barcodeThread.setBarcode(barcode);
			}
			}
			}
			if (barcodeId != 0) {
			String barcode = siemensS7Net.getByteTransform().TransString(result2.Content, i * 8, 6, "UTF-8");
			BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, barcodeId);
			}

			// 读取侧面条码
			OperateResultExOne<byte[]> resultCM2 = siemensS7Net.Read("DB101.2574", (short) (3 * 4 * 6));
			if (resultCM2.IsSuccess) {
			for (int i = 8; i >= 6; i--) {
			BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, i);
			List<String> barcodes = new ArrayList<>();
			for (int j = 0; j < 4; j++) {
			String barcode1 = siemensS7Net.getByteTransform().TransString(resultCM2.Content, (8 - i) * 24 + j * 6, 6, "UTF-8");
			if (!Cools.isEmpty(barcode1) && !barcode1.equals("000000") && !barcode1.equals("NoRead")) {
			barcodes.add(barcode1);
			}
			}
			String barcode = String.join("#", barcodes);
			if (!Cools.isEmpty(barcodeThread) && !barcodeThread.getBarcode().equals(barcode)) {
			barcodeThread.setBarcode(barcode);
			}
			}
			}
			}

			// 读取侧面条码
			OperateResultExOne<byte[]> resultCM2 = siemensS7Net.Read("DB101.2574", (short) (3 * 4 * 6));
			if (resultCM2.IsSuccess) {
			for (int i= 8; i >= 6; i --) {
			BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, i);
			List<String> barcodes = new ArrayList<>();
			for(int j = 0; j < 4; j ++) {
			String barcode1 = siemensS7Net.getByteTransform().TransString(resultCM2.Content, (8-i) * 24 + j *6, 6, "UTF-8");
			if (!Cools.isEmpty(barcode1)&&!barcode1.equals("000000")&& !barcode1.equals("NoRead")) {
			barcodes.add(barcode1);
			// 读取正面外形检测
			OperateResultExOne<byte[]> resultErr1 = siemensS7Net.Read("DB101.936", (short) (16 * 8));
			if (resultErr1.IsSuccess) {
			for (int i = 0; i < 16; i++) {
			Integer siteId = staNos.get(i); // 站点编号
			StaProtocol staProtocol = station.get(siteId);
			boolean[] status1 = siemensS7Net.getByteTransform().TransBool(resultErr1.Content, i * 2, 1);
			staProtocol.setFrontErr(status1[0]);
			staProtocol.setBackErr(status1[1]);
			staProtocol.setHighErr(status1[2]);
			staProtocol.setLeftErr(status1[3]);
			staProtocol.setRightErr(status1[4]);
			staProtocol.setWeightErr(status1[5]);
			staProtocol.setBarcodeErr(status1[6]);
			}
			}

			// 读取侧面外形检测
			OperateResultExOne<byte[]> resultErrCM1 = siemensS7Net.Read("DB101.1336", (short) (12 * 8));
			if (resultErrCM1.IsSuccess) {
			for (int i = 16; i < staNoSize; i++) {
			Integer siteId = staNos.get(i); // 站点编号
			StaProtocol staProtocol = station.get(siteId);
			boolean[] status1 = siemensS7Net.getByteTransform().TransBool(resultErrCM1.Content, (i - 16) * 2, 1);
			staProtocol.setFrontErr(status1[0]);
			staProtocol.setBackErr(status1[1]);
			staProtocol.setHighErr(status1[2]);
			staProtocol.setLeftErr(status1[3]);
			staProtocol.setRightErr(status1[4]);
			staProtocol.setWeightErr(status1[5]);
			staProtocol.setBarcodeErr(status1[6]);
			}
			}

			// 读正面故障反馈
			OperateResultExOne<byte[]> resultErr = siemensS7Net.Read("DB101.922.0", (short) (16 * 4));
			if (resultErr.IsSuccess) {
			for (int i = 0; i < 16; i++) {
			Integer siteId = staNos.get(i); // 站点编号
			boolean[] status = siemensS7Net.getByteTransform().TransBool(resultErr.Content, i * 4, 1);
			StaProtocol staProtocol = station.get(siteId);
			staProtocol.setBreakerErr(status[0]);
			staProtocol.setInfraredErr(status[1]);
			staProtocol.setOutTimeErr(status[2]);
			staProtocol.setSeizeSeatErr(status[3]);
			staProtocol.setWrkYgoodsN(status[4]);
			staProtocol.setInverterErr(status[5]);
			staProtocol.setContactErr(status[6]);
			staProtocol.setUpcontactErr(status[7]);

			}
			}

			// 读侧面故障反馈
			OperateResultExOne<byte[]> resultErrCM = siemensS7Net.Read("DB101.2540.0", (short) (12 * 4));
			if (resultErrCM.IsSuccess) {
			for (int i = 16; i < staNoSize; i++) {
			Integer siteId = staNos.get(i); // 站点编号
			boolean[] status = siemensS7Net.getByteTransform().TransBool(resultErrCM.Content, (i - 16) * 4, 1);
			StaProtocol staProtocol = station.get(siteId);
			staProtocol.setBreakerErr(status[0]);
			staProtocol.setInfraredErr(status[1]);
			staProtocol.setOutTimeErr(status[2]);
			staProtocol.setSeizeSeatErr(status[3]);
			staProtocol.setWrkYgoodsN(status[4]);
			staProtocol.setInverterErr(status[5]);
			staProtocol.setContactErr(status[6]);
			staProtocol.setUpcontactErr(status[7]);

			}
			}
			} else {
			// 读外置输送线货位信息反馈
			result = siemensS7Net.Read("DB101.0", (short) (staNoSize * 8));
			if (result.IsSuccess) {
			for (int i = 0; i < staNoSize; i++) {
			Integer siteId = staNos.get(i); // 站点编号
			StaProtocol staProtocol = station.get(siteId);
			if (null == staProtocol) {
			staProtocol = new StaProtocol();
			staProtocol.setSiteId(siteId);
			station.put(siteId, staProtocol);
			}
			staProtocol.setWorkNo((short) 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);
			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]); // 低库位

			if (!staProtocol.isPakMk() && !staProtocol.isLoading()) {
			staProtocol.setPakMk(true);
			}
			}
			String barcode = String.join("#",barcodes);
			if (!Cools.isEmpty(barcodeThread) && !barcodeThread.getBarcode().equals(barcode)) {
			barcodeThread.setBarcode(barcode);
			}
			}
			}

			// 读取正面外形检测
			OperateResultExOne<byte[]> resultErr1 = siemensS7Net.Read("DB101.936", (short) (16 * 8));
			if (resultErr1.IsSuccess) {
			for (int i = 0; i < 16; i++) {
			Integer siteId = staNos.get(i); // 站点编号
			StaProtocol staProtocol = station.get(siteId);
			boolean[] status1 = siemensS7Net.getByteTransform().TransBool(resultErr1.Content, i * 2, 1);
			staProtocol.setFrontErr(status1[0]);
			staProtocol.setBackErr(status1[1]);
			staProtocol.setHighErr(status1[2]);
			staProtocol.setLeftErr(status1[3]);
			staProtocol.setRightErr(status1[4]);
			staProtocol.setWeightErr(status1[5]);
			staProtocol.setBarcodeErr(status1[6]);
			}
			}

			// 读取侧面外形检测
			OperateResultExOne<byte[]> resultErrCM1 = siemensS7Net.Read("DB101.1336", (short) (12 * 8));
			if (resultErrCM1.IsSuccess) {
			for (int i = 16; i < staNoSize; i++) {
			Integer siteId = staNos.get(i); // 站点编号
			StaProtocol staProtocol = station.get(siteId);
			boolean[] status1 = siemensS7Net.getByteTransform().TransBool(resultErrCM1.Content, (i-16) * 2, 1);
			staProtocol.setFrontErr(status1[0]);
			staProtocol.setBackErr(status1[1]);
			staProtocol.setHighErr(status1[2]);
			staProtocol.setLeftErr(status1[3]);
			staProtocol.setRightErr(status1[4]);
			staProtocol.setWeightErr(status1[5]);
			staProtocol.setBarcodeErr(status1[6]);
			}
			}

			// 读正面故障反馈
			OperateResultExOne<byte[]> resultErr = siemensS7Net.Read("DB101.922.0", (short) (16 * 4));
			if (resultErr.IsSuccess) {
			for (int i = 0; i < 16; i++) {
			Integer siteId = staNos.get(i); // 站点编号
			boolean[] status = siemensS7Net.getByteTransform().TransBool(resultErr.Content, i * 4, 1);
			StaProtocol staProtocol = station.get(siteId);
			staProtocol.setBreakerErr(status[0]);
			staProtocol.setInfraredErr(status[1]);
			staProtocol.setOutTimeErr(status[2]);
			staProtocol.setSeizeSeatErr(status[3]);
			staProtocol.setWrkYgoodsN(status[4]);
			staProtocol.setInverterErr(status[5]);
			staProtocol.setContactErr(status[6]);
			staProtocol.setUpcontactErr(status[7]);

			}
			}

			// 读侧面故障反馈
			OperateResultExOne<byte[]> resultErrCM = siemensS7Net.Read("DB101.2540.0", (short) (12 * 4));
			if (resultErrCM.IsSuccess) {
			for (int i = 16; i < staNoSize; i++) {
			Integer siteId = staNos.get(i); // 站点编号
			boolean[] status = siemensS7Net.getByteTransform().TransBool(resultErrCM.Content, (i-16) * 4, 1);
			StaProtocol staProtocol = station.get(siteId);
			staProtocol.setBreakerErr(status[0]);
			staProtocol.setInfraredErr(status[1]);
			staProtocol.setOutTimeErr(status[2]);
			staProtocol.setSeizeSeatErr(status[3]);
			staProtocol.setWrkYgoodsN(status[4]);
			staProtocol.setInverterErr(status[5]);
			staProtocol.setContactErr(status[6]);
			staProtocol.setUpcontactErr(status[7]);

			}
			}

			@@ -461,7 +493,7 @@
			slave.getId(), JSON.toJSON(staProtocol), writeCount));
			log.error("写入输送线命令失败。输送线plc编号={}，站点数据={},写入次数={}", slave.getId(), JSON.toJSON(staProtocol), writeCount);
			}
			Thread.sleep(200);
			// Thread.sleep(200);
			}

			//写命令尝试了5次还是失败了