#

luxiaotao1123

2025-06-28 1da741e8519e13d8f92824bf8ef15b92800b70fc

 zy-acs-gateway/src/main/java/com/zy/acs/gateway/handler/AgvPackageServerHandler.java

@@ -9,7 +9,6 @@
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;
@@ -31,8 +30,6 @@

    @Autowired
    private Executors executors;
    @Autowired
    private AgvDataFeignApi agvDataFeignApi;

    @Override
    @SuppressWarnings("all")
@@ -47,10 +44,17 @@

                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