| | |
|---|
| | | |
|---|
| | | 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); |
|---|
| | | |
|---|
| | | AgvPackage pathAckPac = AckMsgBuilder.ofSuccess(pac, ProtocolType.PATH_ACK_RESPONSE); |
|---|
| | | |
|---|
| | | AGV_B1_DOWN agv_b1_down = (AGV_B1_DOWN) pathAckPac.getBody().getMessageBody(); |
|---|
| | | agv_b1_down.setSerialNo(agv_01_up.getSerialNo()); |
|---|
| | | agv_b1_down.setPathLen(agv_01_up.getPathLen()); |
|---|
| | | ctx.writeAndFlush(pathAckPac); |
|---|
| | | |
|---|
| | | break label; |
|---|
| | | |
|---|
| | | case COMMAND_ACK: // 命令包 ack |
|---|
