[update]#优化业务逻辑

es-track-common/src/main/java/cn/com/taiji/constants/TopicConstants.java

@@ -11,5 +11,5 @@ public class TopicConstants {
 
     public static final String BEIDOU_TOPIC = "taiji_ax_beidou_dynamic_ship";
 
-    public static final String GLOBAL_AIS = "taiji_ax_ztpt_dynamic_ais";
+    public static final String HLX_ONE_LEVEL = "taiji_ax_hlx_zww_dynamic_fusion_ship_gis";
 }

es-track-common/src/main/java/cn/com/taiji/entity/BeidouShipTrackDTO.java

@@ -11,22 +11,60 @@ public class BeidouShipTrackDTO implements Serializable {
 
     private static final long serialVersionUID = -8983779632713666636L;
 
-    private String time;
-    private Long trackId;
-    private String deviceId;
-    private Long shipType;
-    private Long workType;
-    private Integer workWay;
+    /**
+     * {
+     *   "id": "eaa8d1cd0cb740c1a49b6068bd6ea9c0",
+     *   "content": "118887151,15010427,255,255,255,2023-02-09 15:30:04.000,2023-02-09 15:30:02.146,1,819.1,409.5,255,109.922777,18.3985,0.0,0.0,3,陵0102016,0,CJG_SN210100,1,34,2023-02-09 15:30:07.587",
+     *   "curren_time": "2023-02-09 15:30:06",
+     *   "trackId": 118887151,
+     *   "deviceId": 15010427,
+     *   "shipType": 255,
+     *   "workType": 255,
+     *   "workWay": 255,
+     *   "sendTime": "2023-02-09 15:30:04.000",
+     *   "locationTime": "2023-02-09 15:30:02.146",
+     *   "online": 1,
+     *   "shipLength": 819.1,
+     *   "shipWidth": 409.5,
+     *   "texture": 255,
+     *   "longitude": 109.922777,
+     *   "latitude": 18.3985,
+     *   "direction": 0.0,
+     *   "speed": 0.0,
+     *   "kwh": 3,
+     *   "shipName": "陵0102016",
+     *   "isPatrol": "0",
+     *   "gisShipPort": "CJG_SN210100",
+     *   "gisShipMaterial": "1",
+     *   "gisShipUse": "34",
+     *   "receiveTime": "2023-02-09 15:30:07.587"
+     * }
+     */
+
+    private String id;
+    private String content = "CJG_SN210089,1,12,2023-02-09 15:13:41.633";
+    private String curren_time;
+    private Integer trackId;
+    private Integer deviceId;
+    private Integer shipType = 255;
+    private Integer workType = 255;
+    private Integer workWay = 255;
     private String sendTime;
     private String locationTime;
-    private Integer online;
-    private Integer shipLength;
-    private Integer shipWidth;
-    private Integer texture;
-    private Double longitude;
-    private Double latitude;
-    private Double direction;
-    private Double speed;
-    private Integer kwh;
+    private Integer online = 1;
+    private Double shipLength = 819.1;
+    private Double shipWidth = 409.5;
+    private Integer texture = 255;
+    private Double longitude = 110.48175;
+    private Double latitude = 18.775388;
+    private Double direction = 0.0;
+    private Double speed = 0.0;
+    private Integer kwh = 1;
     private String shipName;
+    private String isPatrol = "0";
+    private String gisShipPort = "CJG_SN210089";
+    private String gisShipMaterial = "1";
+    private String gisShipUse = "12";
+    private String receiveTime;
+
 }

es-track-common/src/main/java/cn/com/taiji/entity/HlxOneLevelTrackDTO.java

@@ -0,0 +1,51 @@
+package cn.com.taiji.entity;
+
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class HlxOneLevelTrackDTO implements Serializable {
+
+    private static final long serialVersionUID = 7817585048163272316L;
+
+    /**
+     *   {
+     *         "course": 261.27075,
+     *             "gisNationality": "0",
+     *             "gisShipType": "0",
+     *             "heading": 261.0,
+     *             "latitude": 20.09806,
+     *             "length": 8,
+     *             "longitude": 110.28064,
+     *             "mmsi": "0",
+     *             "predicted": true,
+     *             "radarID": "40",
+     *             "shipClass": "0",
+     *             "shipType": "0",
+     *             "speed": 14.584931,
+     *             "targetID": "3441921594312032263",
+     *             "time": "2023-02-09 15:26:50.005",
+     *             "vesselName": ""
+     *     }
+     */
+
+    private Double course = 90.27075;
+    private String gisNationality = "0";
+    private String gisShipType = "0";
+    private Double heading = 261.0;
+    private Double latitude;
+    private Integer length = 8;
+    private Double longitude;
+    private String mmsi = "0";
+    private Boolean predicted = true;
+    private String radarID;
+    private String shipClass = "0";
+    private String shipType = "0";
+    private Double speed = 30.3544;
+    private String targetID;
+    private String time;
+    private String vesselName;
+
+}

simulation-track/src/main/java/cn/com/taiji/controller/SimulationTrackController.java

@@ -4,6 +4,7 @@ import cn.com.taiji.service.SimulationTrackService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
 /**
@@ -22,13 +23,20 @@ public class SimulationTrackController {
 
 
     @GetMapping("/beidou")
-    public void beidouTrack(){
-        simulationTrackService.beidouTrack();
+    public void beidouTrack(@RequestParam("status") Integer status){
+        simulationTrackService.beidouTrack(status);
     }
 
-    @GetMapping("/ais")
-    public void aisTrack(){
-        simulationTrackService.aisTrack();
+    @GetMapping("/hlx")
+    public void aisTrack(@RequestParam("status") Integer status){
+        simulationTrackService.aisTrack(status);
+    }
+
+
+
+    @GetMapping("/beidou/hlx")
+    public void beidouaisTrack(@RequestParam("status") Integer status){
+        simulationTrackService.beidouaisTrack(status);
     }
 
 }

simulation-track/src/main/java/cn/com/taiji/service/SimulationTrackService.java

@@ -9,7 +9,9 @@ package cn.com.taiji.service;
  */
 public interface SimulationTrackService {
 
-    void beidouTrack();
+    void beidouTrack(Integer status);
 
-    void aisTrack();
+    void aisTrack(Integer status);
+
+    void beidouaisTrack(Integer status);
 }

simulation-track/src/main/java/cn/com/taiji/service/impl/SimulationTrackImpl.java

@@ -2,16 +2,20 @@ package cn.com.taiji.service.impl;
 
 import cn.com.taiji.constants.TopicConstants;
 import cn.com.taiji.entity.BeidouShipTrackDTO;
-import cn.com.taiji.entity.GlobalAisTrackDTO;
+import cn.com.taiji.entity.HlxOneLevelTrackDTO;
 import cn.com.taiji.entity.Location;
 import cn.com.taiji.service.SimulationTrackService;
 import cn.com.taiji.utils.LocationUtils;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.json.JSONUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.poi.ss.formula.functions.T;
 import org.springframework.kafka.core.KafkaTemplate;
 import org.springframework.stereotype.Service;
+import org.springframework.web.bind.annotation.RequestParam;
 
 import javax.annotation.Resource;
+import java.util.HashSet;
 import java.util.List;
 
 /**
@@ -21,6 +25,7 @@ import java.util.List;
  * @description: TODO
  * @date 2023/2/7 5:16 PM
  */
+@Slf4j
 @Service
 public class SimulationTrackImpl implements SimulationTrackService {
 
@@ -30,58 +35,261 @@ public class SimulationTrackImpl implements SimulationTrackService {
 
 
     public static void main(String[] args) {
-        List<Location> list = LocationUtils.generateLogLat("2023-02-03 00:00:00", "2023-02-03 00:02:00", 109.287806, 19.718716, 101.287806, 19.918716);
+        List<Location> list = LocationUtils.generateLogLat("2023-02-03 00:00:00", "2023-02-03 00:00:50", 109.287806, 19.718716, 101.287806, 19.918716);
     }
 
+
+    HashSet<Thread> beidouThreads = new HashSet<>();
+
+    private Integer beidouStatus;
+
+    HashSet<Thread> hlxOneLevelTherads = new HashSet<>();
+
+    private Integer hlxOneLevelStatus;
+
+
+    HashSet<Thread> beidouhlxOneLevelTherads = new HashSet<>();
+
+    private Integer beidouhlxOneLevelStatus;
+
+
     @Override
-    public void beidouTrack() {
-        //开始位置 109.67736635192313,18.18433770855554
-        //结束位置 109.70224312757544,18.183594250301038
-        List<Location> list = LocationUtils.generateLogLat("2023-02-03 00:00:00", "2023-02-03 00:02:00", 109.67736635192313, 18.18433770855554,  109.70224312757544, 18.183594250301038);
-        for (Location location : list) {
-            BeidouShipTrackDTO beidouShipTrackDTO = new BeidouShipTrackDTO();
-            beidouShipTrackDTO.setTrackId(20236688L);
-            beidouShipTrackDTO.setTime(DateUtil.now());
-            beidouShipTrackDTO.setDeviceId("2023111,2023222");
-            beidouShipTrackDTO.setShipType(1L);
-            beidouShipTrackDTO.setWorkType(1L);
-            beidouShipTrackDTO.setWorkWay(1);
-            beidouShipTrackDTO.setSendTime(DateUtil.now());
-            beidouShipTrackDTO.setLocationTime(DateUtil.now());
-            beidouShipTrackDTO.setOnline(1);
-            beidouShipTrackDTO.setShipLength(1);
-            beidouShipTrackDTO.setShipWidth(1);
-            beidouShipTrackDTO.setTexture(1);
-            beidouShipTrackDTO.setDirection(1D);
-            beidouShipTrackDTO.setSpeed(1D);
-            beidouShipTrackDTO.setKwh(1);
-            beidouShipTrackDTO.setShipName("模拟北斗船舶");
-            beidouShipTrackDTO.setLatitude(location.getLat() * 1000000);
-            beidouShipTrackDTO.setLongitude(location.getLog() * 1000000);
-            String data = JSONUtil.toJsonStr(beidouShipTrackDTO);
-            kafkaTemplate.send(TopicConstants.BEIDOU_TOPIC,data);
+    public void beidouTrack(Integer status) {
+        //开始位置 109.67642971192785,18.18460507789732 三亚位置 西州
+        //结束位置 109.69596855881268,18.185299250953545 三亚位置 东洲
+        //模拟同船的第一个设备
+        beidouStatus = status;
+        if (0 == beidouStatus) {
+            Thread thread = new Thread(() -> {
+                while (true) {
+                    if (beidouStatus == 1) {
+                        Thread.currentThread().interrupt();
+                    } else {
+                        List<Location> list = LocationUtils.generateLogLat("2023-02-03 00:00:00", "2023-02-03 00:02:10", 109.67642971192785, 18.18460507789732, 109.69596855881268, 18.185299250953545);
+                        for (Location location : list) {
+                            BeidouShipTrackDTO beidouShipTrackDTO = new BeidouShipTrackDTO();
+                            beidouShipTrackDTO.setId("20236688");
+                            beidouShipTrackDTO.setCurren_time(DateUtil.now());
+                            beidouShipTrackDTO.setTrackId(20236688);
+                            beidouShipTrackDTO.setDeviceId(20236688);
+                            beidouShipTrackDTO.setSendTime(DateUtil.now());
+                            beidouShipTrackDTO.setLocationTime(DateUtil.now());
+                            beidouShipTrackDTO.setShipName("20236688测试船舶");
+                            beidouShipTrackDTO.setReceiveTime(DateUtil.now());
+                            beidouShipTrackDTO.setLongitude(location.getLog());
+                            beidouShipTrackDTO.setLatitude(location.getLat());
+                            String data = JSONUtil.toJsonStr(beidouShipTrackDTO);
+                            try {
+                                Thread.sleep(1000);
+                                kafkaTemplate.send(TopicConstants.BEIDOU_TOPIC, data);
+                                log.info(DateUtil.now() + "模拟北斗船舶:20236688测试船舶,终端号为20236688完成");
+                            } catch (InterruptedException e) {
+                                Thread.currentThread().interrupt();
+                                e.printStackTrace();
+                            }
+                        }
+                    }
+                }
+            });
+            Thread thread1 = new Thread(() -> {
+                while (true) {
+                    if (beidouStatus == 1) {
+                        Thread.currentThread().interrupt();
+                    } else {
+                        /**
+                         * 开始位置 109.67638187069215,18.184651060263896 三亚位置 西州偏北一点
+                         * 结束位置 109.69603272744908,18.18548237188056 三亚位置 东洲偏北一点
+                         */
+                        //模拟同船的第二个设备
+                        List<Location> list1 = LocationUtils.generateLogLat("2023-02-03 00:00:00", "2023-02-03 00:02:10", 109.67638187069215, 18.184651060263896, 109.69603272744908, 18.18548237188056);
+                        for (Location location : list1) {
+                            BeidouShipTrackDTO beidouShipTrackDTO = new BeidouShipTrackDTO();
+                            beidouShipTrackDTO.setId("20236699");
+                            beidouShipTrackDTO.setCurren_time(DateUtil.now());
+                            beidouShipTrackDTO.setTrackId(20236699);
+                            beidouShipTrackDTO.setDeviceId(20236699);
+                            beidouShipTrackDTO.setSendTime(DateUtil.now());
+                            beidouShipTrackDTO.setLocationTime(DateUtil.now());
+                            beidouShipTrackDTO.setShipName("20236688测试船舶");
+                            beidouShipTrackDTO.setReceiveTime(DateUtil.now());
+                            beidouShipTrackDTO.setLongitude(location.getLog());
+                            beidouShipTrackDTO.setLatitude(location.getLat());
+                            String data = JSONUtil.toJsonStr(beidouShipTrackDTO);
+                            try {
+                                Thread.sleep(1000);
+                                kafkaTemplate.send(TopicConstants.BEIDOU_TOPIC, data);
+                                log.info(DateUtil.now() + "模拟北斗船舶:20236688测试船舶,终端号为20236699完成");
+                            } catch (InterruptedException e) {
+                                Thread.currentThread().interrupt();
+                                e.printStackTrace();
+                            }
+                        }
+                    }
+                }
+            });
+            thread.start();
+            thread1.start();
+            beidouThreads.add(thread);
+            beidouThreads.add(thread1);
+        }
+        if (1 == beidouStatus) {
+            for (Thread item : beidouThreads) {
+                item.interrupt();
+            }
         }
     }
 
     @Override
-    public void aisTrack() {
-        List<Location> list = LocationUtils.generateLogLat("2023-02-03 00:00:00", "2023-02-03 00:02:00", 109.67736635192313, 18.18433770855554,  109.70224312757544, 18.183594250301038);
-        for (Location location : list) {
-            GlobalAisTrackDTO globalAisTrackDTO = new GlobalAisTrackDTO();
-            globalAisTrackDTO.setUserid("2023111,2023222");
-            globalAisTrackDTO.setReceiveTime(DateUtil.now());
-            globalAisTrackDTO.setMessageid("2023");
-            globalAisTrackDTO.setNavStatus("1");
-            globalAisTrackDTO.setRot("1");
-            globalAisTrackDTO.setSog("1");
-            globalAisTrackDTO.setCog("1");
-            globalAisTrackDTO.setTrueHeading("1");
-            globalAisTrackDTO.setDsource("1");
-            globalAisTrackDTO.setLongitude(location.getLog());
-            globalAisTrackDTO.setLatitude(location.getLat());
-            String data = JSONUtil.toJsonStr(globalAisTrackDTO);
-            kafkaTemplate.send(TopicConstants.GLOBAL_AIS,data);
+    public void aisTrack(Integer status) {
+        //开始位置 109.67642971192785,18.18460507789732
+        //结束位置 109.69596855881268,18.185299250953545
+        //模拟同船的第一个设备
+        hlxOneLevelStatus = status;
+        if (hlxOneLevelStatus == 0) {
+            Thread thread = new Thread(() -> {
+                while (true) {
+                    if (hlxOneLevelStatus == 1) {
+                        Thread.currentThread().interrupt();
+                    } else {
+                        List<Location> list = LocationUtils.generateLogLat("2023-02-03 00:00:00", "2023-02-03 00:02:10", 109.67642971192785, 18.18460507789732, 109.69596855881268, 18.185299250953545);
+                        for (Location location : list) {
+                            HlxOneLevelTrackDTO hlxOneLevelTrack = new HlxOneLevelTrackDTO();
+                            hlxOneLevelTrack.setLatitude(location.getLat());
+                            hlxOneLevelTrack.setLongitude(location.getLog());
+                            hlxOneLevelTrack.setRadarID("20236666");
+                            hlxOneLevelTrack.setTargetID("20236666");
+                            hlxOneLevelTrack.setTime(DateUtil.now());
+                            hlxOneLevelTrack.setVesselName("测试船舶20236666");
+                            String data = JSONUtil.toJsonStr(hlxOneLevelTrack);
+                            try {
+                                Thread.sleep(1000);
+                                kafkaTemplate.send(TopicConstants.HLX_ONE_LEVEL, data);
+                                log.info(DateUtil.now() + "模拟海兰信一级融合船舶:测试船舶20236666,终端号为20236666完成");
+                            } catch (InterruptedException e) {
+                                Thread.currentThread().interrupt();
+                                e.printStackTrace();
+                            }
+                        }
+                    }
+                }
+            });
+            Thread thread1 = new Thread(() -> {
+                while (true) {
+                    if (hlxOneLevelStatus == 1) {
+                        Thread.currentThread().interrupt();
+                    } else {
+                        /**
+                         * 开始位置 109.67638187069215,18.184651060263896
+                         * 结束位置 109.69603272744908,18.18548237188056
+                         */
+                        //模拟同船的第二个设备
+                        List<Location> list1 = LocationUtils.generateLogLat("2023-02-03 00:00:00", "2023-02-03 00:02:10", 109.67638187069215, 18.184651060263896, 109.69603272744908, 18.18548237188056);
+                        for (Location location : list1) {
+                            HlxOneLevelTrackDTO hlxOneLevelTrack = new HlxOneLevelTrackDTO();
+                            hlxOneLevelTrack.setLatitude(location.getLat());
+                            hlxOneLevelTrack.setLongitude(location.getLog());
+                            hlxOneLevelTrack.setRadarID("20236677");
+                            hlxOneLevelTrack.setTargetID("20236677");
+                            hlxOneLevelTrack.setTime(DateUtil.now());
+                            hlxOneLevelTrack.setVesselName("测试船舶20236666");
+                            String data = JSONUtil.toJsonStr(hlxOneLevelTrack);
+                            try {
+                                Thread.sleep(1000);
+                                kafkaTemplate.send(TopicConstants.HLX_ONE_LEVEL, data);
+                                log.info(DateUtil.now() + "模拟海兰信一级融合船舶:测试船舶20236666,终端号为20236677完成");
+                            } catch (InterruptedException e) {
+                                Thread.currentThread().interrupt();
+                                e.printStackTrace();
+                            }
+                        }
+                    }
+                }
+            });
+            thread.start();
+            thread1.start();
+            hlxOneLevelTherads.add(thread);
+            hlxOneLevelTherads.add(thread1);
+        }
+
+        if (1 == hlxOneLevelStatus) {
+            for (Thread item : hlxOneLevelTherads) {
+                item.interrupt();
+            }
         }
     }
-    
+
+    @Override
+    public void beidouaisTrack(Integer status) {
+        beidouhlxOneLevelStatus = status;
+        if (0 == beidouhlxOneLevelStatus) {
+            Thread thread = new Thread(() -> {
+                while (true) {
+                    if (beidouhlxOneLevelStatus == 1) {
+                        Thread.currentThread().interrupt();
+                    } else {
+                        List<Location> list = LocationUtils.generateLogLat("2023-02-03 00:00:00", "2023-02-03 00:02:10", 109.67642971192785, 18.18460507789732, 109.69596855881268, 18.185299250953545);
+                        for (Location location : list) {
+                            BeidouShipTrackDTO beidouShipTrackDTO = new BeidouShipTrackDTO();
+                            beidouShipTrackDTO.setId("20236688");
+                            beidouShipTrackDTO.setCurren_time(DateUtil.now());
+                            beidouShipTrackDTO.setTrackId(20236688);
+                            beidouShipTrackDTO.setDeviceId(20236688);
+                            beidouShipTrackDTO.setSendTime(DateUtil.now());
+                            beidouShipTrackDTO.setLocationTime(DateUtil.now());
+                            beidouShipTrackDTO.setShipName("20236688测试船舶");
+                            beidouShipTrackDTO.setReceiveTime(DateUtil.now());
+                            beidouShipTrackDTO.setLongitude(location.getLog());
+                            beidouShipTrackDTO.setLatitude(location.getLat());
+                            String data = JSONUtil.toJsonStr(beidouShipTrackDTO);
+                            try {
+                                Thread.sleep(1000);
+                                kafkaTemplate.send(TopicConstants.BEIDOU_TOPIC, data);
+                                log.info(DateUtil.now() + "模拟北斗船舶:20236688测试船舶,终端号为20236688完成");
+                            } catch (InterruptedException e) {
+                                Thread.currentThread().interrupt();
+                                e.printStackTrace();
+                            }
+                        }
+                    }
+                }
+            });
+            Thread thread1 = new Thread(() -> {
+                while (true) {
+                    if (beidouhlxOneLevelStatus == 1) {
+                        Thread.currentThread().interrupt();
+                    } else {
+                        List<Location> list1 = LocationUtils.generateLogLat("2023-02-03 00:00:00", "2023-02-03 00:02:10", 109.67642971192785, 18.18460507789732, 109.69596855881268, 18.185299250953545);
+                        for (Location location : list1) {
+                            HlxOneLevelTrackDTO hlxOneLevelTrack = new HlxOneLevelTrackDTO();
+                            hlxOneLevelTrack.setLatitude(location.getLat());
+                            hlxOneLevelTrack.setLongitude(location.getLog());
+                            hlxOneLevelTrack.setRadarID("20236666");
+                            hlxOneLevelTrack.setTargetID("20236666");
+                            hlxOneLevelTrack.setTime(DateUtil.now());
+                            hlxOneLevelTrack.setVesselName("20236688测试船舶");
+                            String data = JSONUtil.toJsonStr(hlxOneLevelTrack);
+                            try {
+                                Thread.sleep(1000);
+                                kafkaTemplate.send(TopicConstants.HLX_ONE_LEVEL, data);
+                                log.info(DateUtil.now() + "模拟海兰信一级融合船舶:20236688测试船舶,终端号为20236666完成");
+                            } catch (InterruptedException e) {
+                                Thread.currentThread().interrupt();
+                                e.printStackTrace();
+                            }
+                        }
+                    }
+                }
+            });
+            thread.start();
+            thread1.start();
+            beidouhlxOneLevelTherads.add(thread);
+            beidouhlxOneLevelTherads.add(thread1);
+        }
+        if (1 == beidouhlxOneLevelStatus) {
+            for (Thread item : beidouhlxOneLevelTherads) {
+                item.interrupt();
+            }
+        }
+    }
+
 }

simulation-track/src/main/resources/application-prod.yml

@@ -45,14 +45,14 @@ taiji:
       expiry: 70
       topic: taiji_ax_beidou_dynamic_ship
       group: taiji_ax_beidou_dynamic_ship—${random.uuid}
-    global-ais:
+    hlx-one-level-ais:
       enable: false
       expiry: 10
-      topic: taiji_ax_ztpt_dynamic_ais
+      topic: taiji_ax_hlx_zww_dynamic_fusion_ship_gis
     prefix:
       trake_user_prefix: trake_user_prefix_
       trake_dept_prefix: trake_dept_prefix_
       ship_borne_terminal_redis_key_prefix: ship_borne_terminal_
       static_beidou_law_enforcement_ship_redis_key_prefix: STATIC_BEIDOU_LAW_ENFORCEMENT_SHIP_
       static_police_man_track_redis_key_prefix: STATIC_POLICE_MAN_TRACK_REDIS_
-      static_law_enforcement_car_redis_key_prefix: STATIC_LAW_ENFORCEMENT_CAR_
+      static_law_enforcement_car_redis_key_prefix: STATIC_LAW_ENFORCEMENT_CAR_