| | |
| | | String isOK = ""; |
| | | if (type.equals("0")) { |
| | | // 飞行轨迹数据 |
| | | listTrajectory.add(dataJson); |
| | | log.info("SN:{} 轨迹点数据添加到列表缓存,当前列表数量:{}", sn, listTrajectory.size()); |
| | | if(!listTask.isEmpty()) { |
| | | listTrajectory.add(dataJson); |
| | | log.info("SN:{} 轨迹点数据添加到列表缓存,当前列表数量:{}", sn, listTrajectory.size()); |
| | | } |
| | | else { |
| | | cacheTrajectoryMap.put(sn, new ArrayList<>()); |
| | | log.info("SN:{} 任务状态数据为空,当前无任务,不保存轨迹点数据", sn); |
| | | } |
| | | // log.info("SN:{} 轨迹点数据:{}", sn, dataJson); |
| | | } |
| | | if (type.equals("1")) { |
| | | // 任务状态数据 |
| | |
| | | log.error("SN:{} JSON内容: {}", sn, json); |
| | | } |
| | | } |
| | | else { |
| | | // 当前任务状态数据为空时,清空缓存 |
| | | log.info("SN:{} 任务状态数据为空,当前无任务清空缓存", sn); |
| | | // 清空缓存 |
| | | cacheTrajectoryMap.put(sn, new ArrayList<>()); |
| | | cacheTaskMap.put(sn, new ArrayList<>()); |
| | | return; |
| | | } |
| | | // listTrajectory.size() >= CHUNK_SIZE || |
| | | if (listTask.size() >= CHUNK_SIZE) { |
| | | // 分片保存 |