车轨接口修改

serviceapi/peopleapi/src/main/java/com/founder/peopleapi/service/impl/PhoneServiceImpl.java

@@ -20,9 +20,7 @@ import java.time.LocalDateTime;
 import java.time.ZoneId;
 import java.time.format.DateTimeFormatter;
 import java.util.*;
-import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
+import java.util.concurrent.*;
 import java.util.stream.Collectors;
 
 @Service
@@ -39,16 +37,47 @@ public class PhoneServiceImpl implements PhoneService {
 
     @Override
     public MapRestResult getSjGjInfo(String objectType, String objectValue, String kssj, String jssj) {
-        Map resMap = getSjgjXx(objectType, objectValue, kssj, jssj);
-        List childrenList = (List) resMap.get("rows");
-        Map resulMap = new HashMap();
-        resulMap.put("phone", objectValue);
-        resulMap.put("dataList", childrenList);
-        resulMap.put("count", childrenList.size());
-
-        Map dataMap = new HashMap();
+        int total = 0;
+        String[] array = objectValue.split(",");
         List dataList = new ArrayList();
-        dataList.add(resulMap);
+        if (array != null && array.length > 0) {
+            //翻译并封装成实体返回---使用200并发
+            ExecutorService executorService = Executors.newCachedThreadPool();
+            //信号量，此处用于控制并发的线程数
+            final Semaphore semaphore = new Semaphore(50);
+            //闭锁，可实现计数器递减
+            final CountDownLatch countDownLatch = new CountDownLatch(array.length);
+            for (int i = 0; i < array.length; i++) {
+                String val = array[i];
+                executorService.execute(() -> {
+                    try {
+                        //执行此方法用于获取执行许可，当总计未释放的许可数不超过200时，
+                        //允许通行，否则线程阻塞等待，直到获取到许可。
+                        semaphore.acquire();
+                        Map resMap = getSjgjXx(objectType, val, kssj, jssj);
+                        List childrenList = (List) resMap.get("rows");
+                        Map resulMap = new HashMap();
+                        resulMap.put("phone", val);
+                        resulMap.put("dataList", childrenList);
+                        resulMap.put("count", childrenList.size());
+                        dataList.add(resulMap);
+                        //释放许可
+                        semaphore.release();
+                    } catch (Exception e) {
+                        e.printStackTrace();
+                    }
+                    //闭锁减一
+                    countDownLatch.countDown();
+                });
+            }
+            try {
+                countDownLatch.await();//线程阻塞，直到闭锁值为0时，阻塞才释放，继续往下执行
+                executorService.shutdown();
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
+        Map dataMap = new HashMap();
         dataMap.put("data", dataList);
         return MapRestResult.build(200, "成功获取手机轨迹信息！", dataMap);
     }
@@ -483,7 +512,7 @@ public class PhoneServiceImpl implements PhoneService {
                     LinkedHashMap resultJson = (LinkedHashMap) jsonObject.getBody().get("data");//获取返回的数据结果
                     List<LinkedHashMap> array = (List<LinkedHashMap>) resultJson.get("rows");
                     System.out.println(array.toString());
-                    if ( array!=null &&array.size()!=0) {
+                    if (array != null && array.size() != 0) {
                         LinkedHashMap object = array.get(0);
                         String bshxx = p.getObjectValue();
                         String xm = (String) object.get("xm");
@@ -707,8 +736,8 @@ public class PhoneServiceImpl implements PhoneService {
     }
 
     @Override
-    public MapRestResult selectJzXx(String qsjd,String qswd,String jsjd,String jswd){
-        List<JzXxResult> kkList = phoneInfoMapper.getJzInfoByQsJwd(qsjd,qswd,jsjd,jswd);
-        return  MapRestResult.build(200,"获取基站信息",kkList.size(),kkList);
+    public MapRestResult selectJzXx(String qsjd, String qswd, String jsjd, String jswd) {
+        List<JzXxResult> kkList = phoneInfoMapper.getJzInfoByQsJwd(qsjd, qswd, jsjd, jswd);
+        return MapRestResult.build(200, "获取基站信息", kkList.size(), kkList);
     }
 }