计步和血氧数据接口

common/common_utils/src/main/java/com/founder/commonutils/ZdryApiEntity/BloodMessage.java

+package com.founder.commonutils.ZdryApiEntity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author yangyang
+ * @since 2021-06-16
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value="BloodMessage对象", description="BloodMessage对象")
+@TableName("gk_blood")
+public class BloodMessage implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "信息主键编号自增长")
+    @TableId(type = IdType.AUTO)
+    private Integer id;
+
+    @ApiModelProperty(value = "设备Imei")
+    @TableField(value = "sb_imei")
+    private String sbImei;
+
+    @ApiModelProperty(value = "发生时间YYYY-MM-DD HH:mm:SS")
+    @TableField(value = "time_begin")
+    private String timeBegin;
+
+    @ApiModelProperty(value = "血氧百分比")
+    @TableField(value = "bloodoxygen")
+    private int  bloodoxygen;
+
+    @ApiModelProperty(value = "血氧报警上限")
+    @TableField(value = "bloodoxygen_h")
+    private int  bloodoxygenH;
+
+    @ApiModelProperty(value = "血氧报警下限")
+    @TableField(value = "bloodoxygen_l")
+    private int bloodoxygenL;
+
+    @ApiModelProperty(value = "登记时间")
+    @TableField(fill = FieldFill.INSERT)
+    private Date djsj;
+
+    @ApiModelProperty(value = "改写时间")
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private Date gxsj;
+}

common/common_utils/src/main/java/com/founder/commonutils/ZdryApiEntity/StepMessage.java

+package com.founder.commonutils.ZdryApiEntity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author yangyang
+ * @since 2021-06-16
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value="StepMessage对象", description="StepMessage对象")
+@TableName("gk_stepNumber")
+public class StepMessage implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "信息主键编号自增长")
+    @TableId(type = IdType.AUTO)
+    private Integer id;
+
+    @ApiModelProperty(value = "设备Imei")
+    @TableField(value = "sb_imei")
+    private String sbImei;
+
+    @ApiModelProperty(value = "发生时间YYYY-MM-DD HH:mm:SS")
+    @TableField(value = "time_begin")
+    private String timeBegin;
+
+
+    @ApiModelProperty(value = "步数")
+    @TableField(value = "value")
+    private int  value;
+
+    @ApiModelProperty(value = "登记时间")
+    @TableField(fill = FieldFill.INSERT)
+    private Date djsj;
+
+    @ApiModelProperty(value = "改写时间")
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private Date gxsj;
+}

serviceapi/zdryapi/src/main/java/com/founder/zdryapi/controller/ZdryPushDataController.java

@@ -101,5 +101,32 @@ public class ZdryPushDataController {
     ) {
         zdryPushDataService.dbpMessage(imei,time_begin,dbp,dbp_l,sbp,sbp_h);
     }
+
+    @ApiOperation(value = "血氧数据发送接口")
+    @PostMapping(value = "/bloodMessage")
+    public void bloodMessage(@ApiParam(name = "imei", value = "设备IMEI", required = true)
+                           @RequestParam(value = "imei")  String imei,
+                           @ApiParam(name = "time_begin", value = "发生时间YYYY-MM-DD HH:mm:SS", required = true)
+                           @RequestParam(value = "time_begin") String time_begin,
+                           @ApiParam(name = "bloodoxygen", value = "血氧百分比", required = true)
+                           @RequestParam(value = "bloodoxygen") int bloodoxygen,
+                           @ApiParam(name = "bloodoxygen_h", value = "血氧报警上限")
+                           @RequestParam(required = false) int bloodoxygen_h,
+                           @ApiParam(name = "bloodoxygen_l", value = "血氧报警下限")
+                           @RequestParam(required = false) int bloodoxygen_l
+    ) {
+        zdryPushDataService.bloodMessage(imei,time_begin,bloodoxygen,bloodoxygen_h,bloodoxygen_l);
+    }
+
+    @ApiOperation(value = "计步数据发送接口")
+    @PostMapping(value = "/stepMessage")
+    public void stepMessage(@ApiParam(name = "imei", value = "设备IMEI", required = true)
+                           @RequestParam(value = "imei")  String imei,
+                           @ApiParam(name = "time_begin", value = "发生时间YYYY-MM-DD HH:mm:SS", required = true)
+                           @RequestParam(value = "time_begin") String time_begin,
+                           @ApiParam(name = "value", value = "步数", required = true)
+                           @RequestParam(value = "value") int value){
+        zdryPushDataService.stepMessage(imei,time_begin,value);
+    }
 }
 

serviceapi/zdryapi/src/main/java/com/founder/zdryapi/mapper/ZdryBloodMessageMapper.java

+package com.founder.zdryapi.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.founder.commonutils.ZdryApiEntity.BloodMessage;
+import com.founder.commonutils.ZdryApiEntity.StepMessage;
+import org.apache.ibatis.annotations.Mapper;
+import org.springframework.stereotype.Component;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author yangyang
+ * @since 2021-06-16
+ */
+@Mapper
+@Component
+public interface ZdryBloodMessageMapper extends BaseMapper<BloodMessage> {
+
+}

serviceapi/zdryapi/src/main/java/com/founder/zdryapi/mapper/ZdryStepMessageMapper.java

+package com.founder.zdryapi.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.founder.commonutils.ZdryApiEntity.BloodMessage;
+import com.founder.commonutils.ZdryApiEntity.StepMessage;
+import org.apache.ibatis.annotations.Mapper;
+import org.springframework.stereotype.Component;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author yangyang
+ * @since 2021-06-16
+ */
+@Mapper
+@Component
+public interface ZdryStepMessageMapper extends BaseMapper<StepMessage> {
+
+}

serviceapi/zdryapi/src/main/java/com/founder/zdryapi/mapper/xml/ZdryBloodMessageMapper.xml

+<?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.founder.zdryapi.mapper.ZdryBloodMessageMapper">
+
+</mapper>

serviceapi/zdryapi/src/main/java/com/founder/zdryapi/mapper/xml/ZdryStepMessageMapper.xml

+<?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.founder.zdryapi.mapper.ZdryStepMessageMapper">
+
+</mapper>

serviceapi/zdryapi/src/main/java/com/founder/zdryapi/service/ZdryPushDataService.java

@@ -19,4 +19,8 @@ public interface ZdryPushDataService {
     void heartrateMessage(String imei, String time_begin, int heartrate, int theshold_heartrate_h, int theshold_heartrate_l);
 
     void dbpMessage(String imei, String time_begin,int dbp,int dbp_l, int sbp,int sbp_h);
+
+    void bloodMessage(String imei,String time_begin,int bloodoxygen, int bloodoxygen_h,int bloodoxygen_l);
+
+    void stepMessage(String imei, String time_begin, int value);
 }

serviceapi/zdryapi/src/main/java/com/founder/zdryapi/service/impl/ZdryPushDataServiceImpl.java

 package com.founder.zdryapi.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.founder.commonutils.ZdryApiEntity.DbpMessage;
-import com.founder.commonutils.ZdryApiEntity.HeartrateMessage;
-import com.founder.commonutils.ZdryApiEntity.LocationMessage;
-import com.founder.commonutils.ZdryApiEntity.Message;
-import com.founder.zdryapi.mapper.ZdryDbpMessageMapper;
-import com.founder.zdryapi.mapper.ZdryHeartrateMessageMapper;
-import com.founder.zdryapi.mapper.ZdryLocationMessageMapper;
-import com.founder.zdryapi.mapper.ZdryMessageMapper;
+import com.founder.commonutils.ZdryApiEntity.*;
+import com.founder.zdryapi.mapper.*;
 import com.founder.zdryapi.service.ZdryPushDataService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+
 /*
  *
  * <p>
@@ -34,6 +31,10 @@ public class ZdryPushDataServiceImpl implements ZdryPushDataService {
     private ZdryHeartrateMessageMapper zdryHeartrateMessageMapper;
     @Autowired
     private ZdryDbpMessageMapper zdryDbpMessageMapper;
+    @Autowired
+    private ZdryBloodMessageMapper zdryBloodMessageMapper;
+    @Autowired
+    private ZdryStepMessageMapper zdryStepMessageMapper;
 
     @Override
     public void message(int type, String deviceid, String communityid, String url, String name) {
@@ -115,55 +116,55 @@ public class ZdryPushDataServiceImpl implements ZdryPushDataService {
 
     @Override
     public void heartrateMessage(String imei, String time_begin, int heartrate, int theshold_heartrate_h, int theshold_heartrate_l) {
-        QueryWrapper<HeartrateMessage> wrapper = new QueryWrapper<>();
-        wrapper.eq("sb_imei",imei);
-        // 查询
-        HeartrateMessage heartrateMessage = zdryHeartrateMessageMapper.selectOne(wrapper);
-        if(null != heartrateMessage){
-            heartrateMessage.setSbImei(imei);
-            heartrateMessage.setTimeBegin(time_begin);
-            heartrateMessage.setHeartrate(heartrate);
-            heartrateMessage.setTheshold_heartrate_h(theshold_heartrate_h);
-            heartrateMessage.setTheshold_heartrate_l(theshold_heartrate_l);
-            // 执行更新
-            zdryHeartrateMessageMapper.updateById(heartrateMessage);
-        }else{
-            HeartrateMessage HeartrateMessage1 = new HeartrateMessage();
-            HeartrateMessage1.setSbImei(imei);
-            HeartrateMessage1.setTimeBegin(time_begin);
-            HeartrateMessage1.setHeartrate(heartrate);
-            HeartrateMessage1.setTheshold_heartrate_h(theshold_heartrate_h);
-            HeartrateMessage1.setTheshold_heartrate_l(theshold_heartrate_l);
-            // 插入数据
-            zdryHeartrateMessageMapper.insert(HeartrateMessage1);
-        }
+        HeartrateMessage HeartrateMessage1 = new HeartrateMessage();
+        HeartrateMessage1.setSbImei(imei);
+        HeartrateMessage1.setTimeBegin(time_begin);
+        HeartrateMessage1.setHeartrate(heartrate);
+        HeartrateMessage1.setTheshold_heartrate_h(theshold_heartrate_h);
+        HeartrateMessage1.setTheshold_heartrate_l(theshold_heartrate_l);
+        zdryHeartrateMessageMapper.insert(HeartrateMessage1);
     }
 
     @Override
     public void dbpMessage(String imei, String time_begin, int dbp, int dbp_l, int sbp, int sbp_h) {
-        QueryWrapper<DbpMessage> wrapper = new QueryWrapper<>();
-        wrapper.eq("sb_imei",imei);
-        // 查询
-        DbpMessage dbpMessage = zdryDbpMessageMapper.selectOne(wrapper);
-        if(null != dbpMessage){
-            dbpMessage.setSbImei(imei);
-            dbpMessage.setTimeBegin(time_begin);
-            dbpMessage.setDbp(dbp);
-            dbpMessage.setDbp_l(dbp_l);
-            dbpMessage.setSbp(sbp);
-            dbpMessage.setSbp_h(sbp_h);
-            // 执行更新
-            zdryDbpMessageMapper.updateById(dbpMessage);
-        }else{
-            DbpMessage dbpMessage1 = new DbpMessage();
-            dbpMessage1.setSbImei(imei);
-            dbpMessage1.setTimeBegin(time_begin);
-            dbpMessage1.setDbp(dbp);
-            dbpMessage1.setDbp_l(dbp_l);
-            dbpMessage1.setSbp(sbp);
-            dbpMessage1.setSbp_h(sbp_h);
-            // 插入数据
-            zdryDbpMessageMapper.insert(dbpMessage1);
+        DbpMessage dbpMessage = new DbpMessage();
+        dbpMessage.setSbImei(imei);
+        dbpMessage.setTimeBegin(time_begin);
+        dbpMessage.setDbp(dbp);
+        dbpMessage.setDbp_l(dbp_l);
+        dbpMessage.setSbp(sbp);
+        dbpMessage.setSbp_h(sbp_h);
+        zdryDbpMessageMapper.insert(dbpMessage);
         }
+
+    @Override
+    public void bloodMessage(String imei, String time_begin, int bloodoxygen, int bloodoxygen_h, int bloodoxygen_l) {
+        BloodMessage bloodMessage = new BloodMessage();
+        bloodMessage.setSbImei(imei);
+        bloodMessage.setTimeBegin(time_begin);
+        bloodMessage.setBloodoxygen(bloodoxygen);
+        bloodMessage.setBloodoxygenH(bloodoxygen_h);
+        bloodMessage.setBloodoxygenL(bloodoxygen_l);
+        zdryBloodMessageMapper.insert(bloodMessage);
+    }
+
+    @Override
+    public void stepMessage(String imei, String time_begin, int value) {
+            QueryWrapper<StepMessage> wrapper = new QueryWrapper<>();
+            wrapper.eq("sb_imei",imei);
+            wrapper.apply("STR_TO_DATE(time_begin,'%Y-%m-%d') = STR_TO_DATE('"+time_begin+"','%Y-%m-%d')");
+            // 查询
+            StepMessage stepMessage = zdryStepMessageMapper.selectOne(wrapper);
+            if(null != stepMessage){
+                stepMessage.setValue(value);
+                stepMessage.setTimeBegin(time_begin);
+                zdryStepMessageMapper.updateById(stepMessage);
+            }else{
+                StepMessage stepMessage1 = new StepMessage();
+                stepMessage1.setSbImei(imei);
+                stepMessage1.setTimeBegin(time_begin);
+                stepMessage1.setValue(value);
+                zdryStepMessageMapper.insert(stepMessage1);
+            }
     }
 }