| | |
| | | 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; |
| | | import com.mes.hollow.service.HollowFormulaDetailsService; |
| | |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.nio.charset.Charset; |
| | | import java.util.ArrayList; |
| | | import java.util.List; |
| | | |
| | | /** |
| | | * @author SNG-015 |
| | |
| | | } |
| | | String glassIdEntitys = readString(modbusTcp, 42003 - offset); |
| | | log.info("除膜{}获取当前的玻璃id:{}", cell, glassIdEntitys); |
| | | // byte[] res = CMJ1ModbusTcp.readHoldRegister(1, 42003, 14); |
| | | // String glassId1 = ByteReadBuff.newInstance(res, 0, false, EByteBuffFormat.CD_AB).getString(10); |
| | | // String glassId2 = ByteReadBuff.newInstance(res, 0, false, EByteBuffFormat.AB_CD).getString(10); |
| | | // String glassId3 = ByteReadBuff.newInstance(res, 0, false, EByteBuffFormat.BA_DC).getString(10); |
| | | // String glassId4 = ByteReadBuff.newInstance(res, 0, false, EByteBuffFormat.DC_BA).getString(10); |
| | | // log.info("获取{}当前的玻璃id1:{}", cell, glassId1); |
| | | // log.info("获取{}当前的玻璃id2:{}", cell, glassId2); |
| | | // log.info("获取{}当前的玻璃id3:{}", cell, glassId3); |
| | | // log.info("获取{}当前的玻璃id4:{}", cell, glassId4); |
| | | 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) { |
| | |
| | | return; |
| | | } |
| | | |
| | | |
| | | // String glassIdEntity = modbusTcp.readString(42003 - offset, 20); |
| | | String glassIdEntity = readString(modbusTcp, 42003 - offset); |
| | | // String glassIdEntity = ByteReadBuff.newInstance(res, 0, false, EByteBuffFormat.CD_AB).getString(10); |
| | | //你删了? |
| | | 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); |
| | |
| | | } |
| | | //按照任务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 |
| | |
| | | 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; |
| | | } |
| | | |
| | |
| | | //向电气发送清楚信号 |
| | | 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); |
| | | } |
| | | |