新增心跳接口

src/main/java/com/demo/dao/HeartBeatDao.java

+package com.demo.dao;
+
+import com.demo.entity.po.HeartBeat;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.stereotype.Repository;
+
+
+@Repository
+public class HeartBeatDao {
+    @Autowired
+    private MongoTemplate mongoTemplate;
+
+
+    public void insert(HeartBeat heartBeat){
+        mongoTemplate.insert(heartBeat);
+    }
+
+}

src/main/java/com/demo/entity/po/HeartBeat.java

+package com.demo.entity.po;
+
+import org.springframework.data.mongodb.core.mapping.Document;
+
+@Document(collection="HeartBeat")
+public class HeartBeat {
+
+    private long timestamp;
+
+    private String reyunId;
+
+    public long getTimestamp() {
+        return timestamp;
+    }
+
+    public void setTimestamp(long timestamp) {
+        this.timestamp = timestamp;
+    }
+
+    public String getReyunId() {
+        return reyunId;
+    }
+
+    public void setReyunId(String reyunId) {
+        this.reyunId = reyunId;
+    }
+
+    @Override
+    public String toString() {
+        return "HeartBeat{" +
+                "timestamp=" + timestamp +
+                ", reyunId='" + reyunId + '\'' +
+                '}';
+    }
+}

src/main/java/com/demo/mongodb/DevicecheatController.java

@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.demo.constant.ResultStatus;
 import com.demo.entity.po.BusinData;
 import com.demo.entity.po.ExceptionRecord;
+import com.demo.entity.po.HeartBeat;
 import com.demo.entity.vo.DeviceConfVo;
 import com.demo.entity.vo.DeviceIdVo;
 import com.demo.entity.vo.SensorVo;
@@ -159,6 +160,24 @@ public class DevicecheatController {
     }
 
 
+    /**
+     *
+     * 心跳接口
+     * @param heartBeat
+     * @return
+     * @throws Exception
+     */
+    @RequestMapping(value = "/heartbeat", method = RequestMethod.POST)
+    @ResponseBody
+    public ResultObject heartbeat(@RequestBody HeartBeat heartBeat) throws Exception {
+        logger.info("/heartbeat : {}" ,  heartBeat.toString());
+        if(heartBeat == null || StringUtils.isEmpty(heartBeat.getReyunId())){
+            return new ResultObject(ResultStatus.FAIL);
+        }
+        deviceService.insertHeartBeat(heartBeat);
+
+        return new ResultObject(ResultStatus.SUCCESS);
+    }
 
 
 }

src/main/java/com/demo/service/DeviceService.java

@@ -40,6 +40,8 @@ public class DeviceService {
     private SensorInfoDao sensorInfoDao;
     @Autowired
     private BusinDataDao businDataDao;
+    @Autowired
+    private HeartBeatDao heartBeatDao;
 
 //    /**
 //     *
@@ -348,6 +350,10 @@ public class DeviceService {
     }
 
 
+    public void insertHeartBeat(HeartBeat heartBeat){
+        heartBeatDao.insert(heartBeat);
+    }
+
     public String getIpAddr(HttpServletRequest request) {
         String ip = request.getHeader("x-forwarded-for");
         if (ip != null && ip.length() != 0 && !"unknown".equalsIgnoreCase(ip)) {