nishiwei
6 days ago 3f43e40ed1a1e9f66b3ad2862da9dbc4b710c712
ard-sample/src/main/java/com/ard/sample/manage/service/impl/WaylineTrajectoryServiceImpl.java
@@ -73,8 +73,15 @@
        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")) {
            // 任务状态数据
@@ -99,6 +106,14 @@
                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) {
            // 分片保存