| | |
| | | * @param warnMsg |
| | | */ |
| | | public void up_warn_msg_adpt_info(ChannelHandlerContext ctx, int inferiorPlatformId, WarnMsg warnMsg) { |
| | | log.info("上报报警信息cz0({}):{}",inferiorPlatformId,warnMsg); |
| | | // log.info("上报报警信息cz0({}):{}",inferiorPlatformId,warnMsg); |
| | | UPWarnMsgAdptInfo upWarnMsgAdptInfo = enterprise.contains(inferiorPlatformId) ? new UPWarnMsgAdptInfo().decode2(warnMsg) : new UPWarnMsgAdptInfo().decode1(warnMsg); |
| | | upWarnMsgAdptInfo.setResult(0x00); |
| | | upWarnMsgAdptInfo.setInferiorPlatformId(inferiorPlatformId); |
| | |
| | | } |
| | | break; |
| | | case 17235341: |
| | | log.info("上报报警信息cz88888({}):{}:{}", DataType.UP_WARN_MSG_ADPT_INFO.getCode(), JSON.toJSONString(upWarnMsgAdptInfo),upWarnMsgAdptInfo.getWarnType()); |
| | | // log.info("上报报警信息cz88888({}):{}:{}", DataType.UP_WARN_MSG_ADPT_INFO.getCode(), JSON.toJSONString(upWarnMsgAdptInfo),upWarnMsgAdptInfo.getWarnType()); |
| | | if(!cz_warnType.contains(upWarnMsgAdptInfo.getWarnType())){ |
| | | log.info("上报报警信息czcontains({}):{}:{}", DataType.UP_WARN_MSG_ADPT_INFO.getCode(), JSON.toJSONString(upWarnMsgAdptInfo),upWarnMsgAdptInfo.getWarnType()); |
| | | // log.info("上报报警信息czcontains({}):{}:{}", DataType.UP_WARN_MSG_ADPT_INFO.getCode(), JSON.toJSONString(upWarnMsgAdptInfo),upWarnMsgAdptInfo.getWarnType()); |
| | | return; |
| | | } |
| | | break; |
| | | case 82296583: |
| | | log.info("上报报警信息cz88888({}):{}:{}", DataType.UP_WARN_MSG_ADPT_INFO.getCode(), JSON.toJSONString(upWarnMsgAdptInfo),upWarnMsgAdptInfo.getWarnType()); |
| | | // log.info("上报报警信息cz88888({}):{}:{}", DataType.UP_WARN_MSG_ADPT_INFO.getCode(), JSON.toJSONString(upWarnMsgAdptInfo),upWarnMsgAdptInfo.getWarnType()); |
| | | if(!cz_warnType.contains(upWarnMsgAdptInfo.getWarnType())){ |
| | | log.info("上报报警信息czcontains({}):{}:{}", DataType.UP_WARN_MSG_ADPT_INFO.getCode(), JSON.toJSONString(upWarnMsgAdptInfo),upWarnMsgAdptInfo.getWarnType()); |
| | | // log.info("上报报警信息czcontains({}):{}:{}", DataType.UP_WARN_MSG_ADPT_INFO.getCode(), JSON.toJSONString(upWarnMsgAdptInfo),upWarnMsgAdptInfo.getWarnType()); |
| | | |
| | | return; |
| | | } |
| | |
| | | } |
| | | break; |
| | | } |
| | | log.info("上报报警信息555555({}):{}:{}", DataType.UP_WARN_MSG_ADPT_INFO.getCode(), JSON.toJSONString(upWarnMsgAdptInfo),upWarnMsgAdptInfo.getWarnType()); |
| | | // log.info("上报报警信息555555({}):{}:{}", DataType.UP_WARN_MSG_ADPT_INFO.getCode(), JSON.toJSONString(upWarnMsgAdptInfo),upWarnMsgAdptInfo.getWarnType()); |
| | | try { |
| | | if(0 == upWarnMsgAdptInfo.getLongitude()){ |
| | | log.info("上报报警信息6666666({}):{}:{}", DataType.UP_WARN_MSG_ADPT_INFO.getCode(), JSON.toJSONString(upWarnMsgAdptInfo),upWarnMsgAdptInfo.getWarnType()); |
| | | // log.info("上报报警信息6666666({}):{}:{}", DataType.UP_WARN_MSG_ADPT_INFO.getCode(), JSON.toJSONString(upWarnMsgAdptInfo),upWarnMsgAdptInfo.getWarnType()); |
| | | UPExgMsgRealLocation upExgMsgRealLocation = upExgMsgRealLocationDao.findByVehicleNoOrderByCreateTimeDesc(upWarnMsgAdptInfo.getVehicleNo()); |
| | | if (null != upExgMsgRealLocation) { |
| | | GnssData gnssData = upExgMsgRealLocation.getGnssData(); |
| | |
| | | upWarnMsgAdptInfo.setLatitude(gnssData.getLat()); |
| | | } |
| | | } |
| | | log.info("上报报警信息333333"); |
| | | // log.info("上报报警信息333333"); |
| | | |
| | | upWarnMsgAdptInfoDao.save(upWarnMsgAdptInfo); |
| | | }catch (Exception e){ |
| | |
| | | log.info("上报报警信息保存失败{}",e.getMessage()); |
| | | } |
| | | |
| | | log.info("上报报警信息2({}):{}", DataType.UP_WARN_MSG_ADPT_INFO.getCode(), JSON.toJSONString(upWarnMsgAdptInfo)); |
| | | |
| | | // log.info("上报报警信息2({}):{}", DataType.UP_WARN_MSG_ADPT_INFO.getCode(), JSON.toJSONString(upWarnMsgAdptInfo)); |
| | | |
| | | //请求报警附件(川标协议) |
| | | if(enterprise.contains(inferiorPlatformId)){ |
| | | DOWNWarnMsgFileListReq downWarnMsgFileListReq = new DOWNWarnMsgFileListReq(); |