| | |
| | | import com.zy.acs.gateway.constant.ProtocolType; |
| | | import com.zy.acs.gateway.domain.AgvPackage; |
| | | import com.zy.acs.gateway.process.AckMsgBuilder; |
| | | import com.zy.acs.rpc.gateway.control.AgvDataFeignApi; |
| | | import io.netty.channel.ChannelHandler; |
| | | import io.netty.channel.ChannelHandlerContext; |
| | | import org.slf4j.Logger; |
| | |
| | | |
| | | @Autowired |
| | | private Executors executors; |
| | | @Autowired |
| | | private AgvDataFeignApi agvDataFeignApi; |
| | | |
| | | @Override |
| | | @SuppressWarnings("all") |
| | |
| | | |
| | | AGV_01_UP agv_01_up = (AGV_01_UP) pac.getBody().getMessageBody(); |
| | | |
| | | redis.setObject(RedisConstant.AGV_CMD_UP_FLAG |
| | | redis.setObject(RedisConstant.AGV_PATH_UP_FLAG |
| | | , pac.getHeader().getUniqueNo() + "_" + agv_01_up.getSerialNo() |
| | | , agv_01_up); |
| | | |