eats

src/main/java/com/njyunzhi/nanyang/controller/MainController.java

@@ -7,17 +7,37 @@ import com.hikvision.ae.hatc.sdk.response.Result;
 import com.hikvision.ae.hatc.sdk.service.SDKService;
 import com.njyunzhi.nanyang.common.HatcUtil;
 import com.njyunzhi.nanyang.common.ResponseBean;
+import com.njyunzhi.nanyang.service.ITdHatcDeviceService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
 @RestController
 public class MainController {
 
+    @Autowired
+    ITdHatcDeviceService iTdHatcDeviceService;
+
     @Autowired
     HatcUtil hatcUtil;
 
+    /**
+     * 同步设备信息
+     * @return
+     */
+    @PostMapping("/syncDevice")
+    public ResponseBean syncDevice() {
+        try {
+            iTdHatcDeviceService.syncDevice();
+            return ResponseBean.success(null);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return ResponseBean.error(e.getMessage());
+        }
+    }
+
 
     /**
      * 获取预览地址

src/main/java/com/njyunzhi/nanyang/entity/TaMachineryGps.java

@@ -0,0 +1,51 @@
+package com.njyunzhi.nanyang.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 农机定位信息
+ * </p>
+ *
+ * @author yansen
+ * @since 2022-03-08
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+//@ApiModel(value="TaMachineryGps对象", description="农机定位信息")
+public class TaMachineryGps implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+//    @ApiModelProperty(value = "序号")
+    @TableId(value = "serial_no", type = IdType.AUTO)
+    private Integer serialNo;
+
+//    @ApiModelProperty(value = "设备ID,海康设备表")
+    private String deviceId;
+
+//    @ApiModelProperty(value = "农机ID")
+    private String machineryId;
+
+//    @ApiModelProperty(value = "经度")
+    private String lng;
+
+//    @ApiModelProperty(value = "维度")
+    private String lat;
+
+//    @ApiModelProperty(value = "全部GPS数据")
+    private String gpsData;
+
+//    @ApiModelProperty(value = "创建时间")
+    private LocalDateTime createDate;
+
+
+}

src/main/java/com/njyunzhi/nanyang/mapper/TaMachineryGpsMapper.java

@@ -0,0 +1,18 @@
+package com.njyunzhi.nanyang.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.njyunzhi.nanyang.entity.TaMachineryGps;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * <p>
+ * 农机定位信息 Mapper 接口
+ * </p>
+ *
+ * @author yansen
+ * @since 2022-03-08
+ */
+@Mapper
+public interface TaMachineryGpsMapper extends BaseMapper<TaMachineryGps> {
+
+}

src/main/java/com/njyunzhi/nanyang/mapper/TdHatcDeviceMapper.java

@@ -3,6 +3,7 @@ package com.njyunzhi.nanyang.mapper;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.njyunzhi.nanyang.entity.TdHatcDevice;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
 
 /**
  * <p>
@@ -15,4 +16,5 @@ import org.apache.ibatis.annotations.Mapper;
 @Mapper
 public interface TdHatcDeviceMapper extends BaseMapper<TdHatcDevice> {
 
+    int updateOnlineStatus(@Param("terminalID") String terminalID, @Param("status") Integer status);
 }

src/main/java/com/njyunzhi/nanyang/service/ITaMachineryGpsService.java

@@ -0,0 +1,16 @@
+package com.njyunzhi.nanyang.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.njyunzhi.nanyang.entity.TaMachineryGps;
+
+/**
+ * <p>
+ * 农机定位信息 服务类
+ * </p>
+ *
+ * @author yansen
+ * @since 2022-03-08
+ */
+public interface ITaMachineryGpsService extends IService<TaMachineryGps> {
+
+}

src/main/java/com/njyunzhi/nanyang/service/ITdHatcDeviceService.java

@@ -15,4 +15,6 @@ import com.njyunzhi.nanyang.entity.TdHatcDevice;
 public interface ITdHatcDeviceService extends IService<TdHatcDevice> {
 
     void syncDevice() throws Exception;
+
+    void subscribeDevice() throws Exception;
 }

src/main/java/com/njyunzhi/nanyang/service/impl/TaMachineryGpsServiceImpl.java

@@ -0,0 +1,20 @@
+package com.njyunzhi.nanyang.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.njyunzhi.nanyang.entity.TaMachineryGps;
+import com.njyunzhi.nanyang.mapper.TaMachineryGpsMapper;
+import com.njyunzhi.nanyang.service.ITaMachineryGpsService;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 农机定位信息 服务实现类
+ * </p>
+ *
+ * @author yansen
+ * @since 2022-03-08
+ */
+@Service
+public class TaMachineryGpsServiceImpl extends ServiceImpl<TaMachineryGpsMapper, TaMachineryGps> implements ITaMachineryGpsService {
+
+}

src/main/java/com/njyunzhi/nanyang/service/impl/TdHatcDeviceServiceImpl.java

@@ -1,24 +1,31 @@
 package com.njyunzhi.nanyang.service.impl;
 
+import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.hikvision.ae.hatc.enums.SubscribableMessageTypeEnum;
 import com.hikvision.ae.hatc.message.cms2sdk.DeviceChannel;
 import com.hikvision.ae.hatc.message.cms2sdk.DeviceInfo;
 import com.hikvision.ae.hatc.message.cms2sdk.DeviceModelInfo;
+import com.hikvision.ae.hatc.message.device2dsg.gpsdata.GpsData;
+import com.hikvision.ae.hatc.sdk.callback.Callback;
 import com.hikvision.ae.hatc.sdk.response.Result;
 import com.hikvision.ae.hatc.sdk.service.SDKService;
 import com.njyunzhi.nanyang.common.HatcUtil;
+import com.njyunzhi.nanyang.entity.TaMachineryGps;
 import com.njyunzhi.nanyang.entity.TdHatcDevice;
+import com.njyunzhi.nanyang.mapper.TaMachineryGpsMapper;
 import com.njyunzhi.nanyang.mapper.TdHatcDeviceMapper;
 import com.njyunzhi.nanyang.service.ITdHatcDeviceService;
-import io.netty.util.internal.StringUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
+import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Map;
 
 /**
  * <p>
@@ -35,6 +42,9 @@ public class TdHatcDeviceServiceImpl extends ServiceImpl<TdHatcDeviceMapper, TdH
     @Autowired
     HatcUtil hatcUtil;
 
+    @Autowired
+    TaMachineryGpsMapper taMachineryGpsMapper;
+
     @Async
     @Override
     public void syncDevice() throws Exception {
@@ -98,6 +108,68 @@ public class TdHatcDeviceServiceImpl extends ServiceImpl<TdHatcDeviceMapper, TdH
         }
     }
 
+    @Override
+    public void subscribeDevice() throws Exception {
+        SDKService sdkService = hatcUtil.getSdkService();
+        if (sdkService == null) {
+            throw new Exception("海康 SDK 未成功初始化");
+        }
+
+        // 先查询自己账号范围内的设备型号
+        Result<List<DeviceModelInfo>> getModelResult = sdkService.getDeviceModelList();
+
+        if(getModelResult.isSucceed() && getModelResult.getData() != null){
+            // 把需要订阅的设备型号的productKey装入列表
+            List<String> productKeyList = new ArrayList<>();
+            for(DeviceModelInfo model:getModelResult.getData()){
+                productKeyList.add(model.getProductKey());
+            }
+
+            // 订阅设备上下线消息
+            Result<Map<String, String>> subscribeOnlineStatusResult = sdkService.subscribeByProductKeys(productKeyList,
+                    SubscribableMessageTypeEnum.DEVICE_STATUS,
+                    new Callback<Integer>() {
+                        @Override
+                        public void callback(String terminalID, Integer status) {
+                            // 设备上下线消息回调函数
+                            log.info("设备 " + terminalID + " 在线状态：" + ((status == 1) ? "在线" : "离线"));
+
+                            // 更新设备状态
+                            baseMapper.updateOnlineStatus(terminalID, status);
+                        }
+            });
+            System.out.println("根据ProductKey订阅设备上下线消息结果：" + JSON.toJSONString(subscribeOnlineStatusResult));
+
+            // 订阅位置信息
+            Result<Map<String, String>> subscribeGPSResult = sdkService.subscribeByProductKeys(productKeyList,
+                    SubscribableMessageTypeEnum.GPS_DATA,
+                    new Callback<GpsData>() {
+                        @Override
+                        public void callback(String terminalID, GpsData gpsData) {
+                            // 设备GPS消息回调函数
+                            String gpsJsonData = JSON.toJSONString(gpsData);
+                            System.out.println("收到设备位置信息，终端ID：" + terminalID + "， 位置信息：" + gpsData);
+
+                            // 查询设备
+                            TdHatcDevice device = getDevice(terminalID, null);
+                            if (null == device) return;
+
+                            // 插入GPS信息
+                            TaMachineryGps taMachineryGps = new TaMachineryGps();
+                            taMachineryGps.setDeviceId(device.getDeviceId());
+                            taMachineryGps.setLat(String.valueOf(gpsData.getLatitude()));
+                            taMachineryGps.setLng(String.valueOf(gpsData.getLongitude()));
+                            taMachineryGps.setGpsData(gpsJsonData);
+                            taMachineryGps.setCreateDate(LocalDateTime.now());
+                            taMachineryGpsMapper.insert(taMachineryGps);
+                        }
+            });
+            System.out.println("根据ProductKey订阅GPS结果：" + JSON.toJSONString(subscribeGPSResult));
+        } else {
+            throw new Exception(String.format("[%s] %s", getModelResult.getErrorCode(), getModelResult.getErrorDesc()));
+        }
+    }
+
     private String getChannelList(List<DeviceChannel> channelList) {
         if (null == channelList || channelList.size() < 1) return null;
 
@@ -113,7 +185,7 @@ public class TdHatcDeviceServiceImpl extends ServiceImpl<TdHatcDeviceMapper, TdH
     public TdHatcDevice getDevice(String terminalID, String productKey) {
         QueryWrapper<TdHatcDevice> queryWrapper = new QueryWrapper<>();
         queryWrapper.eq("terminal_id", terminalID);
-        queryWrapper.eq("product_key", productKey);
+        queryWrapper.eq(null != productKey && !"".equals(productKey), "product_key", productKey);
 
         return getOne(queryWrapper);
     }

src/main/java/com/njyunzhi/nanyang/task/SubscribeDevice.java

@@ -0,0 +1,41 @@
+package com.njyunzhi.nanyang.task;
+
+import com.njyunzhi.nanyang.service.ITdHatcDeviceService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+
+/**
+ * 订阅设备数据
+ */
+
+@Slf4j
+@Component
+public class SubscribeDevice {
+    @Autowired
+    ITdHatcDeviceService iTdHatcDeviceService;
+
+    @PostConstruct
+    @Async
+    public void exec() {
+        while (true) {
+            try {
+                log.info("=================开始订阅海康设备数据==");
+                iTdHatcDeviceService.subscribeDevice();
+                break;
+            } catch (Exception e) {
+                e.printStackTrace();
+
+                try {
+                    // 如果订阅失败, 每分钟尝试重新订阅一次
+                    Thread.sleep(60 * 1000);
+                } catch (InterruptedException e1) {
+//                    e1.printStackTrace();
+                }
+            }
+        }
+    }
+}

src/main/java/com/njyunzhi/nanyang/task/SyncDevice.java

@@ -1,10 +1,12 @@
 package com.njyunzhi.nanyang.task;
 
 import com.njyunzhi.nanyang.service.ITdHatcDeviceService;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
+@Slf4j
 @Component
 public class SyncDevice {
 
@@ -14,9 +16,10 @@ public class SyncDevice {
     /**
      * 每 5 分钟 同步一次海康设备
      */
-    @Scheduled(cron = "0 0/5 * * * ?")
+    @Scheduled(cron = "0 0 1 * * ?")
     public void execute() {
         try {
+            log.info("=================开始同步海康设备==");
             iTdHatcDeviceService.syncDevice();
         } catch (Exception e) {
             e.printStackTrace();

src/main/resources/mapper/TaMachineryGpsMapper.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.njyunzhi.nanyang.mapper.TaMachineryGpsMapper">
+
+</mapper>

src/main/resources/mapper/TdHatcDeviceMapper.xml

@@ -2,4 +2,14 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.njyunzhi.nanyang.mapper.TdHatcDeviceMapper">
 
+    <update id="updateOnlineStatus">
+        UPDATE ta_machinery t
+            INNER JOIN td_device s ON t.machinery_id = s.machinery_id
+            INNER JOIN td_hatc_device m ON m.terminal_id = s.device_no
+            AND m.product_key = s.device_type
+            SET t.online_status = #{status},
+                m.device_status = #{status}
+        WHERE
+            m.terminal_id = #{terminalID}
+    </update>
 </mapper>