新增加管理后台接口和修改809协议中的bug

Pu Zhibing

2025-03-17 b68ac80de1daf22142886af16d36479259106065

 ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/server/ExgMsgService.java

@@ -144,26 +144,37 @@
      if (null == register) {
         upExgMsgRegisterDao.save(upExgMsgRegister);
      }
      //上报驾驶员身份识别信息请求
      UPExgMsgReportDriverInfoAck byVehicleNo = upExgMsgReportDriverInfoAckDao.findByVehicleNo(upExgMsgRegister.getVehicleNo());
      if (null == byVehicleNo) {
         down_exg_msg_report_driver_info(ctx, inferiorPlatformId, upExgMsgRegister.getVehicleNo(), upExgMsgRegister.getVehicleColor());
   }
	
	
   /**
    * 定时获取司机基础信息
    */
   public void taskReportDriverInfo() {
      Iterator<UPExgMsgRegister> iterator = upExgMsgRegisterDao.findAll().iterator();
      while (iterator.hasNext()) {
         UPExgMsgRegister register = iterator.next();
			
         //上报驾驶员身份识别信息请求
         UPExgMsgReportDriverInfoAck byVehicleNo = upExgMsgReportDriverInfoAckDao.findByVehicleNo(register.getVehicleNo());
         if (null == byVehicleNo) {
            down_exg_msg_report_driver_info(register.getInferiorPlatformId(), register.getVehicleNo(), register.getVehicleColor());
         }
      }
		
   }
   
   /**
    * 上报驾驶员身份识别信息请求
    *
    * @param ctx
    */
   public void down_exg_msg_report_driver_info(ChannelHandlerContext ctx, int inferiorPlatformId, String vehicleNo, int VehicleColor) {
   public void down_exg_msg_report_driver_info(int inferiorPlatformId, String vehicleNo, int VehicleColor) {
      DOWNExgMsgReportDriverInfo downExgMsgReportDriverInfo = new DOWNExgMsgReportDriverInfo();
      downExgMsgReportDriverInfo.setVehicleNo(vehicleNo);
      downExgMsgReportDriverInfo.setVehicleColor(VehicleColor);
      downExgMsgReportDriverInfo.setDataType(DataType.DOWN_EXG_MSG_REPORT_DRIVER_INFO.getCode());
      downExgMsgReportDriverInfo.setDataLength(0);
      byte[] body = downExgMsgReportDriverInfo.encode();
      OuterPacket out = new OuterPacket(DataType.DOWN_EXG_MSG_REPORT_DRIVER_INFO.getCode(), body);
      OuterPacket out = new OuterPacket(DataType.DOWN_EXG_MSG.getCode(), body);
      //获取从链路通道
      Channel channel = ChannelMap.getClientChannel(inferiorPlatformId);
      if (null != channel && channel.isActive()) {
@@ -215,7 +226,7 @@
      downExgMsgTakeEwaybillReq.setDataLength(0);
      
      byte[] body = downExgMsgTakeEwaybillReq.encode();
      OuterPacket out = new OuterPacket(DataType.DOWN_EXG_MSG_TAKE_EWAYBILL_REQ.getCode(), body);
      OuterPacket out = new OuterPacket(DataType.DOWN_EXG_MSG.getCode(), body);
      //获取从链路通道
      Channel channel = ChannelMap.getClientChannel(inferiorPlatformId);
      if (null != channel && channel.isActive()) {