From bcc076d63c5c2ff473adb5ac15ea242559086000 Mon Sep 17 00:00:00 2001
From: cjl <909710561@qq.com>
Date: Tue, 08 Sep 2026 17:00:13 +0800
Subject: [PATCH] fix:雷达调整

---
 screen-job/src/main/java/com/moral/api/service/impl/HistorySecondCruiserServiceImpl.java |   28 ++++++++++++++++++----------
 1 files changed, 18 insertions(+), 10 deletions(-)

diff --git a/screen-job/src/main/java/com/moral/api/service/impl/HistorySecondCruiserServiceImpl.java b/screen-job/src/main/java/com/moral/api/service/impl/HistorySecondCruiserServiceImpl.java
index a9df6df..06e0037 100644
--- a/screen-job/src/main/java/com/moral/api/service/impl/HistorySecondCruiserServiceImpl.java
+++ b/screen-job/src/main/java/com/moral/api/service/impl/HistorySecondCruiserServiceImpl.java
@@ -9,7 +9,6 @@
 
 import java.math.BigDecimal;
 import java.util.ArrayList;
-import java.util.Arrays;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -21,13 +20,11 @@
 import com.moral.api.entity.DustldDTO;
 import com.moral.api.entity.HistorySecondCruiser;
 import com.moral.api.entity.SecondCruiserSort;
-import com.moral.api.entity.SysDictData;
 import com.moral.api.mapper.HistorySecondCruiserMapper;
 import com.moral.api.mapper.ManageCoordinateDetailMapper;
 import com.moral.api.mapper.OrganizationMapper;
 import com.moral.api.mapper.SecondCruiserSortMapper;
 import com.moral.api.service.HistorySecondCruiserService;
-import com.moral.api.service.SysDictTypeService;
 import com.moral.util.DateUtils;
 
 /**
@@ -66,25 +63,31 @@
         //
         ArrayList<SecondCruiserSort> list1 = new ArrayList<>();
         if (!ObjectUtils.isEmpty(result)){
+
             for (HistorySecondCruiser historySecondCruiser : result) {
                 String mac = historySecondCruiser.getMac();
                 Integer organizationId = historySecondCruiser.getOrganizationId();
                 List<Integer> orgList = organizationMapper.orgIdSpecialDevList(organizationId, mac);
                 if(CollectionUtils.isEmpty(orgList)){
-                    return;
+                    continue;
                 }
-
                 HashMap<String, Object> params = new HashMap<>();
                 params.put("mac",mac);
                 params.put("startTime",startTime);
                 params.put("endTime",endTime);
                 List<Map<String, Object>> dusts = historySecondCruiserMapper.getDusts(params);
+                if (ObjectUtils.isEmpty(dusts)){
+                    continue;
+                }
                 Map<String, List<DustldDTO>> collect = manageCoordinateDetailMapper.CompareTo(orgList.get(0)).stream().collect(Collectors.groupingBy(o -> o.getName()));
-                if (ObjectUtils.isEmpty(dusts) || ObjectUtils.isEmpty(collect)){
-                    return;
+                if (ObjectUtils.isEmpty(collect)){
+                    continue;
                 }
                 Set<String> strings = collect.keySet();
+                int i = 1;
                 for (String string : strings) {
+                    log.info("������������>>>>>>>>>  "+i+"/"+strings.size()+"    >>>>>>>>    "+string+"      >>>>>>");
+                    i++;
                     SecondCruiserSort secondCruiserSort = new SecondCruiserSort();
                     ArrayList<Double> doubleArrayList = new ArrayList<>();
                     List<DustldDTO> dustldDTOS = collect.get(string);
@@ -96,7 +99,9 @@
                         }
                         double latDouble1 = Double.parseDouble(flyLat);
                         double lonDouble1 = Double.parseDouble(flyLon);
-                        for (Map<String, Object> dust : dusts) {
+                        //for (Map<String, Object> dust : dusts) {
+                       for( int ii=0;ii<dusts.size();ii++){
+                           Map<String, Object> dust = dusts.get(ii);
                             String flyLat1 = Objects.nonNull(dust.get("flyLat")) ? dust.get("flyLat").toString() :"0";
                             String flyLon1 = Objects.nonNull(dust.get("flyLon")) ? dust.get("flyLon").toString() :"0";
                             double latDouble = Double.parseDouble(flyLat1);
@@ -105,7 +110,9 @@
                             if (latDouble1==latDouble && lonDouble1==lonDouble){
                                 Double dustld = Objects.nonNull(dust.get("dustld"))?Double.parseDouble(dust.get("dustld").toString()):0d;
                                 doubleArrayList.add(dustld);
-                                break;
+//                                break;
+                                dusts.remove(ii);
+                                ii--;
                             }
                         }
                     }
@@ -118,13 +125,14 @@
                     secondCruiserSort.setValue(rsAvg);
                     secondCruiserSort.setMac(mac);
                     secondCruiserSort.setOrganizationId(organizationId);
+                    secondCruiserSort.setTime(startTime);
                     list1.add(secondCruiserSort);
                 }
             }
         }
         if (!ObjectUtils.isEmpty(list1)){
-//            log.info(list1.size()+"");
             secondCruiserSortMapper.insertAll(list1);
+            log.info("������������������>>>>>>>> "+list1.size()+" >>>>>>>>>���");
         }
 
     }

--
Gitblit v1.8.0