|  |  |  | 
|---|
|  |  |  | 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); | 
|---|
|  |  |  |  | 
|---|