迁移环境警报数据

huimv-farm-receiver/src/main/java/com/huimv/receiver/farm/controller/AlarmController.java

@@ -0,0 +1,31 @@
+package com.huimv.receiver.farm.controller;
+
+import com.huimv.receiver.farm.service.IAlarm;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * @Project : huimv.shiwan
+ * @Package : com.huimv.biosafety.uface.controller
+ * @Description : TODO
+ * @Version : 1.0
+ * @Author : ZhuoNing
+ * @Create : 2020-12-25
+ **/
+@CrossOrigin
+@RestController
+@Slf4j
+@RequestMapping(value = "/receiver/alarm")
+public class AlarmController {
+    @Autowired
+    private IAlarm iAlarm;
+
+    //发送环境警报信息
+    @RequestMapping(value = "/environ/putEnvironAlarm",method = RequestMethod.POST)
+    public void putEnvironAlarm(@RequestParam(value = "data",required = true) String alarmInfo){
+        System.out.println(">>>>>>>>>>>>>>> 接收"+alarmInfo);
+        //处理环境警报
+        iAlarm.handleEnvironAlarm(alarmInfo);
+    }
+}

huimv-farm-receiver/src/main/java/com/huimv/receiver/farm/dao/entity/BaseWarningInfoEntity.java

@@ -0,0 +1,137 @@
+package com.huimv.receiver.farm.dao.entity;
+
+import javax.persistence.*;
+import java.io.Serializable;
+import java.sql.Timestamp;
+
+@Entity
+@Table(name = "base_warning_info")
+public class BaseWarningInfoEntity implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "id", nullable = false)
+    private Integer id;
+
+    @Column(name = "farm_id")
+    private Integer farmId;
+
+    @Column(name = "level")
+    private Integer level;
+
+    @Column(name = "msg")
+    private String msg;
+
+    @Column(name = "level_name")
+    private String levelName;
+
+    @Column(name = "warning_name")
+    private String warningName;
+
+    @Column(name = "warning_time")
+    private Timestamp warningTime;
+
+    @Column(name = "upload_time")
+    private Timestamp uploadTime;
+
+    /**
+     * 警报类型
+     */
+    @Column(name = "alarm_type")
+    private Integer alarmType;
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setFarmId(Integer farmId) {
+        this.farmId = farmId;
+    }
+
+    public Integer getFarmId() {
+        return farmId;
+    }
+
+    public void setLevel(Integer level) {
+        this.level = level;
+    }
+
+    public Integer getLevel() {
+        return level;
+    }
+
+    public void setMsg(String msg) {
+        this.msg = msg;
+    }
+
+    public String getMsg() {
+        return msg;
+    }
+
+    public void setLevelName(String levelName) {
+        this.levelName = levelName;
+    }
+
+    public String getLevelName() {
+        return levelName;
+    }
+
+    public void setWarningName(String warningName) {
+        this.warningName = warningName;
+    }
+
+    public String getWarningName() {
+        return warningName;
+    }
+
+    public void setWarningTime(Timestamp warningTime) {
+        this.warningTime = warningTime;
+    }
+
+    public Timestamp getWarningTime() {
+        return warningTime;
+    }
+
+    public void setUploadTime(Timestamp uploadTime) {
+        this.uploadTime = uploadTime;
+    }
+
+    public Timestamp getUploadTime() {
+        return uploadTime;
+    }
+
+    /**
+     * 警报类型
+     */
+    public void setAlarmType(Integer alarmType) {
+        this.alarmType = alarmType;
+    }
+
+    /**
+     * 警报类型
+     */
+    public Integer getAlarmType() {
+        return alarmType;
+    }
+
+    @Override
+    public String toString() {
+        return "BaseWarningInfoEntity{" +
+                "id=" + id + '\'' +
+                "farmId=" + farmId + '\'' +
+                "level=" + level + '\'' +
+                "msg=" + msg + '\'' +
+                "levelName=" + levelName + '\'' +
+                "warningName=" + warningName + '\'' +
+                "warningTime=" + warningTime + '\'' +
+                "uploadTime=" + uploadTime + '\'' +
+                "alarmType=" + alarmType + '\'' +
+                '}';
+    }
+}

huimv-farm-receiver/src/main/java/com/huimv/receiver/farm/dao/repo/BaseWarningInfoRepo.java

@@ -0,0 +1,9 @@
+package com.huimv.receiver.farm.dao.repo;
+
+import com.huimv.receiver.farm.dao.entity.BaseWarningInfoEntity;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+
+public interface BaseWarningInfoRepo extends JpaRepository<BaseWarningInfoEntity, Integer>, JpaSpecificationExecutor<BaseWarningInfoEntity> {
+
+}

huimv-farm-receiver/src/main/java/com/huimv/receiver/farm/service/IAlarm.java

@@ -0,0 +1,5 @@
+package com.huimv.receiver.farm.service;
+
+public interface IAlarm {
+    void handleEnvironAlarm(String alarmInfo);
+}

huimv-farm-receiver/src/main/java/com/huimv/receiver/farm/service/impl/AlarmImpl.java

@@ -0,0 +1,45 @@
+package com.huimv.receiver.farm.service.impl;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.huimv.receiver.farm.dao.entity.BaseWarningInfoEntity;
+import com.huimv.receiver.farm.dao.repo.BaseWarningInfoRepo;
+import com.huimv.receiver.farm.service.IAlarm;
+import com.huimv.receiver.utils.DateUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.sql.Timestamp;
+import java.util.Date;
+
+/**
+ * @Project : huimv.shiwan
+ * @Package : com.huimv.biosafety.uface.controller
+ * @Description : TODO
+ * @Version : 1.0
+ * @Author : ZhuoNing
+ * @Create : 2020-12-25
+ **/
+@Service
+public class AlarmImpl implements IAlarm {
+    @Autowired
+    private BaseWarningInfoRepo warningInfoRepo;
+    @Autowired
+    private DateUtil dateUtil;
+
+    @Override
+    public void handleEnvironAlarm(String alarmInfo){
+        JSONObject alarmJo = JSON.parseObject(alarmInfo);
+        BaseWarningInfoEntity warningInfoEntity  = new BaseWarningInfoEntity();
+        warningInfoEntity.setFarmId(alarmJo.getInteger("farmId"));
+        warningInfoEntity.setAlarmType(alarmJo.getInteger("alarmType"));
+        warningInfoEntity.setMsg(alarmJo.getString("info"));
+        warningInfoEntity.setLevel(alarmJo.getInteger("level"));
+        warningInfoEntity.setLevelName(alarmJo.getString("levelName"));
+        warningInfoEntity.setWarningName(alarmJo.getString("warningName"));
+        warningInfoEntity.setWarningTime(new Timestamp(alarmJo.getLong("alarmTime")));
+        warningInfoEntity.setUploadTime(new Timestamp(new Date().getTime()));
+        //
+        warningInfoRepo.saveAndFlush(warningInfoEntity);
+    }
+}