zy-wcs.git - Gitblit

			@@ -304,7 +304,7 @@
			int[] staNosRgv = {623,624,625,626};
			for (int i = 0; i < staNosRgv.length; i++) {
			OperateResultExOne<byte[]> resultRgv = siemensS7Net.Read("DB100."+(1800+i*6), (short) 5);
			OperateResultExOne<byte[]> resultRgv2 = siemensS7Net.Read("DB100."+(1824+i*4), (short) 4);
			OperateResultExOne<byte[]> resultRgv2 = siemensS7Net.Read("DB100."+(1824+i*10), (short) 8);
			if (resultRgv.IsSuccess) {
			Integer siteId = staNosRgv[i]; // 站点编号
			StaProtocol staProtocol = station.get(siteId);
			@@ -316,18 +316,25 @@
			try{
			staProtocol.setEndRow(siemensS7Net.getByteTransform().TransInt16(resultRgv2.Content, 0)); // 小车目标位

			staProtocol.setNowRow(siemensS7Net.getByteTransform().TransInt16(resultRgv.Content, 2)); // 当前位置
			staProtocol.setNowRow(siemensS7Net.getByteTransform().TransInt16(resultRgv.Content, 0)); // 当前位置

			boolean[] status = siemensS7Net.getByteTransform().TransBool(resultRgv.Content, 4, 1);
			boolean[] status2 = siemensS7Net.getByteTransform().TransBool(resultRgv2.Content, 2, 1);
			staProtocol.setRGV1(status[0]); // 自动
			staProtocol.setRGV2(status[1]); // 有物
			staProtocol.setRGV3(status[2]); // 可入
			staProtocol.setRGV4(status2[0]);//
			staProtocol.setRGV5(status2[1]); //
			staProtocol.setRGV6(status2[2]); // 满托盘
			staProtocol.setRGV1(status[0]); // 小车无货空闲
			staProtocol.setRGV2(status[1]); // 小车输送线取货到位
			staProtocol.setRGV3(status[2]); // 小车运行中

			// staProtocol.setRGV11(siemensS7Net.getByteTransform().TransInt16(resultRgv.Content, 2)); // 小车无货空闲
			// staProtocol.setRGV22(siemensS7Net.getByteTransform().TransInt16(resultRgv.Content, 2)); // 小车输送线取货到位
			// staProtocol.setRGV33(siemensS7Net.getByteTransform().TransInt16(resultRgv.Content, 2)); //小车运行中
			staProtocol.setRGV44(siemensS7Net.getByteTransform().TransInt16(resultRgv2.Content, 2));//小车改左侧货物目标站
			staProtocol.setRGV55(siemensS7Net.getByteTransform().TransInt16(resultRgv2.Content, 4)); //小车改右侧货物目标站
			staProtocol.setRGV66(siemensS7Net.getByteTransform().TransInt16(resultRgv2.Content, 6)); // 上位机清除平移车资料

			staProtocol.setRGV4(staProtocol.getRGV44() != 0 && staProtocol.getRGV44() != 2);//小车改左侧货物目标站
			staProtocol.setRGV5(staProtocol.getRGV55() != 0 && staProtocol.getRGV55() != 2); //小车改右侧货物目标站
			staProtocol.setRGV6(staProtocol.getRGV66() != 0 && staProtocol.getRGV66() != 2); // 上位机清除平移车资料
			}catch (Exception e){
			System.out.println(e.getMessage());
			log.error("读取RGV信息失败"+e.getMessage());
			}
			}
			}
			@@ -561,24 +568,27 @@
			}
			boolean rgv6 = staProtocol.isRGV6();
			OperateResult result1 = null;
			OperateResult result2 = null;
			String resultV1 = "";
			short resultS1 = 1;
			short resultS2 = 2;
			switch (staProtocol.getSiteId()){
			case 623:
			resultV1 = "DB100.1826.2";
			resultV1 = "DB100.1830";
			break;
			case 624:
			resultV1 = "DB100.1830.2";
			resultV1 = "DB100.1840";
			break;
			case 625:
			resultV1 = "DB100.1834.2";
			resultV1 = "DB100.1850";
			break;
			case 626:
			resultV1 = "DB100.1838.2";
			resultV1 = "DB100.1860";
			break;
			default:
			return;
			}
			result1 = siemensS7Net.Write(resultV1, rgv6);
			result1 = siemensS7Net.Write(resultV1, resultS1);

			//硫化罐任务写入后，回读一次，看是否成功
			try {
			@@ -592,26 +602,71 @@
			try{
			if(!result1.IsSuccess){
			log.error("写入RGV数据失败，重新下发任务写入直接失败 ===>> [id:{}],{},[写入次数:{}]", slave.getId(), JSON.toJSON(staProtocol),writeCount);
			result1 = siemensS7Net.Write(resultV1, rgv6);
			result1 = siemensS7Net.Write(resultV1, resultS1);
			Thread.sleep(100);
			writeCount++;
			continue;
			}
			OperateResultExOne<byte[]> resultRead1 = siemensS7Net.Read(resultV1, (short) 2);
			if (resultRead1.IsSuccess) {
			boolean[] status = siemensS7Net.getByteTransform().TransBool(resultRead1.Content, 0, 1);
			if (status[2]){
			short status = siemensS7Net.getByteTransform().TransInt16(resultRead1.Content, 0);
			if (status == 1){
			break;
			} else {
			log.error("写入RGV数据失败，重新下发任务写入直接失败 ===>> [id:{}],{},[写入次数:{}]", slave.getId(), JSON.toJSON(staProtocol),writeCount);
			result1 = siemensS7Net.Write(resultV1, rgv6);
			result1 = siemensS7Net.Write(resultV1, resultS1);
			Thread.sleep(100);
			writeCount++;
			continue;
			}
			} else {
			log.error("写入RGV数据失败，重新下发任务写入直接失败 ===>> [id:{}],{},[写入次数:{}]", slave.getId(), JSON.toJSON(staProtocol),writeCount);
			result1 = siemensS7Net.Write(resultV1, rgv6);
			result1 = siemensS7Net.Write(resultV1, resultS1);
			Thread.sleep(100);
			writeCount++;
			continue;
			}
			}catch (Exception e){
			log.error("写入RGV数据后回读出错,异常："+e);
			}
			writeCount++;
			} while (writeCount<6);

			result2 = siemensS7Net.Write(resultV1, resultS2);

			//硫化罐任务写入后，回读一次，看是否成功
			try {
			Thread.sleep(200);
			} catch (InterruptedException e) {
			e.printStackTrace();
			}

			writeCount = 1;
			do {
			try{
			if(!result2.IsSuccess){
			log.error("写入RGV数据失败，重新下发任务写入直接失败 ===>> [id:{}],{},[写入次数:{}]", slave.getId(), JSON.toJSON(staProtocol),writeCount);
			result2 = siemensS7Net.Write(resultV1, resultS2);

			Thread.sleep(100);
			writeCount++;
			continue;
			}
			OperateResultExOne<byte[]> resultRead1 = siemensS7Net.Read(resultV1, (short) 2);
			if (resultRead1.IsSuccess) {
			short status = siemensS7Net.getByteTransform().TransInt16(resultRead1.Content, 0);
			if (status == resultS2){
			break;
			} else {
			log.error("写入RGV数据失败，重新下发任务写入直接失败 ===>> [id:{}],{},[写入次数:{}]", slave.getId(), JSON.toJSON(staProtocol),writeCount);
			result2 = siemensS7Net.Write(resultV1, resultS2);
			Thread.sleep(100);
			writeCount++;
			continue;
			}
			} else {
			log.error("写入RGV数据失败，重新下发任务写入直接失败 ===>> [id:{}],{},[写入次数:{}]", slave.getId(), JSON.toJSON(staProtocol),writeCount);
			result2 = siemensS7Net.Write(resultV1, resultS2);
			Thread.sleep(100);
			writeCount++;
			continue;
			@@ -630,72 +685,118 @@
			boolean rgv4 = staProtocol.isRGV4();
			boolean rgv5 = staProtocol.isRGV5();
			OperateResult result1 = null;
			OperateResult result2 = null;
			String resultV1 = "";
			switch (staProtocol.getSiteId()){
			case 623:
			resultV1 = "DB100.1826";
			break;
			case 624:
			resultV1 = "DB100.1830";
			break;
			case 625:
			resultV1 = "DB100.1834";
			break;
			case 626:
			resultV1 = "DB100.1838";
			break;
			default:
			return;
			}
			short resultS1 = 1;
			short resultS2 = 2;
			if (rgv4){
			result1 = siemensS7Net.Write(resultV1+".0", rgv4);
			} else {
			result1 = siemensS7Net.Write(resultV1+".1", rgv5);
			switch (staProtocol.getSiteId()){
			case 623:
			resultV1 = "DB100.1826";
			break;
			case 624:
			resultV1 = "DB100.1836";
			break;
			case 625:
			resultV1 = "DB100.1846";
			break;
			case 626:
			resultV1 = "DB100.1856";
			break;
			default:
			return;
			}
			} else if (rgv5){
			switch (staProtocol.getSiteId()){
			case 623:
			resultV1 = "DB100.1828";
			break;
			case 624:
			resultV1 = "DB100.1838";
			break;
			case 625:
			resultV1 = "DB100.1848";
			break;
			case 626:
			resultV1 = "DB100.1858";
			break;
			default:
			return;
			}
			}
			result1 = siemensS7Net.Write(resultV1, resultS1);
			//硫化罐任务写入后，回读一次，看是否成功
			try {
			Thread.sleep(200);
			} catch (InterruptedException e) {
			e.printStackTrace();
			}

			int writeCount = 1;
			do {
			try{
			if(!result1.IsSuccess){
			log.error("写入RGV数据失败，重新下发任务写入直接失败 ===>> [id:{}],{},[写入次数:{}]", slave.getId(), JSON.toJSON(staProtocol),writeCount);
			if (rgv4){
			result1 = siemensS7Net.Write(resultV1+".0", rgv4);
			} else {
			result1 = siemensS7Net.Write(resultV1+".1", rgv5);
			}
			result1 = siemensS7Net.Write(resultV1, resultS1);
			Thread.sleep(100);
			writeCount++;
			continue;
			}
			OperateResultExOne<byte[]> resultRead1 = siemensS7Net.Read(resultV1, (short) 2);
			if (resultRead1.IsSuccess) {
			boolean[] status = siemensS7Net.getByteTransform().TransBool(resultRead1.Content, 0, 1);
			if (status[rgv4? 0:1]){
			// boolean[] status = siemensS7Net.getByteTransform().TransBool(resultRead1.Content, 0, 1);
			short statusR1 = siemensS7Net.getByteTransform().TransInt16(resultRead1.Content, 0);
			if (statusR1 == resultS1){
			break;
			} else {
			log.error("写入RGV数据失败，重新下发任务写入直接失败 ===>> [id:{}],{},[写入次数:{}]", slave.getId(), JSON.toJSON(staProtocol),writeCount);
			if (rgv4){
			result1 = siemensS7Net.Write(resultV1+".0", rgv4);
			} else {
			result1 = siemensS7Net.Write(resultV1+".1", rgv5);
			}
			result1 = siemensS7Net.Write(resultV1, resultS1);
			Thread.sleep(100);
			writeCount++;
			continue;
			}
			} else {
			log.error("写入RGV数据失败，重新下发任务写入直接失败 ===>> [id:{}],{},[写入次数:{}]", slave.getId(), JSON.toJSON(staProtocol),writeCount);
			if (rgv4){
			result1 = siemensS7Net.Write(resultV1+".0", rgv4);
			result1 = siemensS7Net.Write(resultV1, resultS1);
			Thread.sleep(100);
			writeCount++;
			continue;
			}
			}catch (Exception e){
			log.error("写入RGV数据后回读出错,异常："+e);
			}
			writeCount++;
			} while (writeCount<6);


			result2 = siemensS7Net.Write(resultV1, resultS2);

			writeCount = 1;
			do {
			try{
			if(!result2.IsSuccess){
			log.error("写入RGV数据失败，重新下发任务写入直接失败 ===>> [id:{}],{},[写入次数:{}]", slave.getId(), JSON.toJSON(staProtocol),writeCount);
			result2 = siemensS7Net.Write(resultV1, resultS2);
			Thread.sleep(100);
			writeCount++;
			continue;
			}
			OperateResultExOne<byte[]> resultRead1 = siemensS7Net.Read(resultV1, (short) 2);
			if (resultRead1.IsSuccess) {
			// boolean[] status = siemensS7Net.getByteTransform().TransBool(resultRead1.Content, 0, 1);
			short statusR1 = siemensS7Net.getByteTransform().TransInt16(resultRead1.Content, 0);
			if (statusR1 == resultS2){
			break;
			} else {
			result1 = siemensS7Net.Write(resultV1+".1", rgv5);
			log.error("写入RGV数据失败，重新下发任务写入直接失败 ===>> [id:{}],{},[写入次数:{}]", slave.getId(), JSON.toJSON(staProtocol),writeCount);
			result2 = siemensS7Net.Write(resultV1, resultS2);

			Thread.sleep(100);
			writeCount++;
			continue;
			}
			} else {
			log.error("写入RGV数据失败，重新下发任务写入直接失败 ===>> [id:{}],{},[写入次数:{}]", slave.getId(), JSON.toJSON(staProtocol),writeCount);
			result2 = siemensS7Net.Write(resultV1, resultS2);
			Thread.sleep(100);
			writeCount++;
			continue;