YiWuProject.git

			@@ -1,6 +1,9 @@
			package com.mes.job;

			import com.github.xingshuangs.iot.common.buff.ByteReadBuff;
			import com.github.xingshuangs.iot.common.buff.EByteBuffFormat;
			import com.github.xingshuangs.iot.protocol.modbus.service.ModbusTcp;
			import com.github.xingshuangs.iot.utils.ByteUtil;
			import com.kangaroohy.milo.model.ReadWriteEntity;
			import com.kangaroohy.milo.service.MiloService;
			import com.mes.hollow.entity.vo.HollowGlassFormulaVO;
			@@ -13,6 +16,7 @@
			import org.springframework.stereotype.Component;

			import javax.annotation.Resource;
			import java.nio.charset.Charset;
			import java.util.ArrayList;
			import java.util.List;

			@@ -82,6 +86,26 @@
			hollowRemoveChildTask("CMJ2.CMJ2.");
			}

			public String readString(ModbusTcp modbusTcp, int address) {
			//
			byte[] bytes = new byte[20];
			for (int i = 0; i < 10; i++) {
			int res = modbusTcp.readUInt16(address + i);

			bytes[i * 2 + 1] = (byte) ((res >> 8) & 0xFF);
			bytes[i * 2] = (byte) (res & 0xFF);
			}
			int endIndex = 0;
			while (endIndex < bytes.length) {
			if (bytes[endIndex] == 0) {
			break;
			}
			endIndex++;
			}
			// 截取有效部分
			return new String(bytes, 0, endIndex);
			}

			private void hollowRemoveChildTask(String cell) throws Exception {
			ModbusTcp modbusTcp = null;
			if ("CMJ1.CMJ1.".equals(cell)) {
			@@ -93,34 +117,26 @@
			log.info("除膜机{}未连接", cell);
			return;
			}
			String glassIdEntitys = readString(modbusTcp, 42003 - offset);
			log.info("除膜{}获取当前的玻璃id：{}", cell, glassIdEntitys);
			Integer requestEntity = modbusTcp.readUInt16(42001 - offset);
			// ReadWriteEntity requestEntity = miloService.readFromOpcUa(cell + "mesControl");
			// if ("0".equals(requestEntity.getValue() + "")) {
			if (0 == requestEntity) {
			log.info("当前除膜机为单机状态");
			return;
			}
			// int request = Integer.parseInt(requestEntity.getValue() + "");
			int request = requestEntity;
			int flagRequest = request & 3;
			if (flagRequest != 3) {
			log.info("当前未收到请求玻璃id数据，结束任务");
			return;
			}
			String glassIdEntity = modbusTcp.readString(42003 - offset, 20);

			String glassIdEntity = readString(modbusTcp, 42003 - offset);
			log.info("除膜{}获取当前的信号为：{},玻璃id:{}", cell, flagRequest, glassIdEntity);
			if (null == glassIdEntity \|\| StringUtils.isBlank(glassIdEntity)) {
			// ReadWriteEntity glassIdEntity = miloService.readFromOpcUa(cell + "glassId");
			// if (null == glassIdEntity.getValue() \|\| StringUtils.isBlank(glassIdEntity.getValue() + "")) {
			log.info("当前未收到玻璃id数据，结束任务");
			return;
			}

			// log.info("除膜{}获取当前的玻璃id：{}", cell, glassIdEntity);
			// if (null == glassIdEntity.getValue() \|\| StringUtils.isBlank(glassIdEntity.getValue() + "")) {
			// log.info("当前未收到玻璃id数据，结束任务");
			// return;
			// }
			log.info("当前需要除膜的玻璃id为：{}", glassIdEntity);
			//按照玻璃id获取对应的任务id
			HollowGlassFormulaVO detailsVO = hollowFormulaDetailsService.queryFormulaDetailsByGlassId(glassIdEntity, null, null);
			@@ -130,14 +146,11 @@
			}
			//按照任务id获取对应的配方信息
			int Id = 0;
			List<ReadWriteEntity> ualist = new ArrayList<>();
			List<ReadWriteEntity> wordlist = new ArrayList<>();
			log.info("除膜{}获取玻璃{},是否除膜：{}", cell, requestEntity, detailsVO.getFilmRemove());
			if (detailsVO.getFilmRemove() == 0) {
			// 10111011
			int sendId = request & 63;
			Id = sendId + 4;
			// wordlist.add(opcPlcStorageCageHollowTask.generateReadWriteEntity(cell + "mesControl", sendId));
			modbusTcp.writeUInt16(42001 - offset, sendId);
			} else {
			// 先将对应的位置为0，获得请求的玻璃数据，然后将对应位值 110111011
			@@ -148,21 +161,11 @@
			modbusTcp.writeUInt32(42021 - offset, detailsVO.getTopRemove());
			modbusTcp.writeUInt32(42023 - offset, detailsVO.getTopRemove());
			modbusTcp.writeUInt32(42025 - offset, detailsVO.getTopRemove());
			// wordlist.add(opcPlcStorageCageHollowTask.generateReadWriteEntity(cell + "mesControl", sendId));
			// ualist.add(opcPlcStorageCageHollowTask.generateReadWriteEntity(cell + "glassTop", detailsVO.getTopRemove()));
			// ualist.add(opcPlcStorageCageHollowTask.generateReadWriteEntity(cell + "glassBottom", detailsVO.getBottomRemove()));
			// ualist.add(opcPlcStorageCageHollowTask.generateReadWriteEntity(cell + "glassLeft", detailsVO.getLeftRemove()));
			// ualist.add(opcPlcStorageCageHollowTask.generateReadWriteEntity(cell + "glassRight", detailsVO.getRightRemove()));
			}
			modbusTcp.writeUInt32(42013 - offset, (int) (detailsVO.getThickness() * 10));
			modbusTcp.writeUInt32(42015 - offset, (int) (Math.max(detailsVO.getWidth(), detailsVO.getHeight())) * 10);
			modbusTcp.writeUInt32(42017 - offset, (int) (Math.min(detailsVO.getWidth(), detailsVO.getHeight())) * 10);
			modbusTcp.writeUInt16(42001 - offset, Id);
			// ualist.add(opcPlcStorageCageHollowTask.generateReadWriteEntity(cell + "thickness", (int) (detailsVO.getThickness() * 10)));
			// ualist.add(opcPlcStorageCageHollowTask.generateReadWriteEntity(cell + "firstLength", (int) (Math.max(detailsVO.getWidth(), detailsVO.getHeight())) * 10));
			// ualist.add(opcPlcStorageCageHollowTask.generateReadWriteEntity(cell + "secondLength", (int) (Math.min(detailsVO.getWidth(), detailsVO.getHeight())) * 10));
			// miloService.writeToOpcWord(wordlist);
			// miloService.writeToOpcUa(ualist);
			return;
			}

			@@ -203,9 +206,6 @@
			//向电气发送清楚信号
			int sendId = request & 251;
			log.info("{}收到除膜机ID接收完成信号，将写入数据完成置0,发送数据为：{}", cell, sendId);
			// List<ReadWriteEntity> list = new ArrayList<>();
			// list.add(opcPlcStorageCageHollowTask.generateReadWriteEntity(cell + "mesControl", sendId));
			// miloService.writeToOpcWord(list);
			modbusTcp.writeUInt16(42001 - offset, sendId);
			}