| | |
| | | |
| | | public void up_exg_msg(ChannelHandlerContext ctx, OuterPacket out) { |
| | | if (!redisTemplate.hasKey("login:" + out.getGnsscenterId())) { |
| | | log.error("链路还未登录校验,拒绝连接"); |
| | | log.error("链路还未登录校验,拒绝连接:{}", out.getGnsscenterId()); |
| | | ctx.close(); |
| | | return; |
| | | } |
| | |
| | | */ |
| | | public void down_exg_msg_take_ewaybill_req(int inferiorPlatformId, String vehicleNo, int VehicleColor) { |
| | | if (!redisTemplate.hasKey("login:" + inferiorPlatformId)) { |
| | | log.error("链路还未登录校验,拒绝连接"); |
| | | log.error("链路还未登录校验,拒绝连接:{}", inferiorPlatformId); |
| | | return; |
| | | } |
| | | DOWNExgMsgTakeEwaybillReq downExgMsgTakeEwaybillReq = new DOWNExgMsgTakeEwaybillReq(); |
| | |
| | | */ |
| | | public void down_base_msg_vehicle_added(int inferiorPlatformId, String vehicleNo, int VehicleColor) { |
| | | if (!redisTemplate.hasKey("login:" + inferiorPlatformId)) { |
| | | log.error("链路还未登录校验,拒绝连接"); |
| | | log.error("链路还未登录校验,拒绝连接:{}", inferiorPlatformId); |
| | | return; |
| | | } |
| | | DOWNBaseMsgVehicleAdded downBaseMsgVehicleAdded = new DOWNBaseMsgVehicleAdded(); |