添加报警功能

huimv-ql-farm/huimv-ql-environment/src/main/java/com/huimv/environment/controller/EnvironmentControlController.java

@@ -4,6 +4,7 @@ package com.huimv.environment.controller;
 import com.huimv.common.result.Result;
 import com.huimv.environment.service.IEnvironmentControlService;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.web.bind.annotation.*;
 
 /**
@@ -53,4 +54,9 @@ public class EnvironmentControlController {
     }
 
 
+    //定时检测数据库中是否有数据
+    @Scheduled(cron = "0 0 23 1 * ? ")
+    public void examine(){
+        envControlService.examine();
+    }
 }

huimv-ql-farm/huimv-ql-environment/src/main/java/com/huimv/environment/controller/SetTemperature.java

@@ -0,0 +1,56 @@
+package com.huimv.environment.controller;
+
+import com.huimv.common.result.Result;
+import com.huimv.environment.entity.SttTemperatureEntity;
+import com.huimv.environment.entity.SysAccountEntity;
+import com.huimv.environment.repo.SttTemperatureEntityRepo;
+import com.huimv.environment.session.AccessToken;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.persistence.Column;
+import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
+import javax.persistence.Id;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpSession;
+import java.util.Date;
+import java.util.Optional;
+
+/**
+ * @Project : huimv.shiwan
+ * @Package : com.huimv.environment.controller
+ * @Description : TODO
+ * @Author : yuxuexuan
+ * @Create : 2021/5/28 0028 8:37
+ **/
+@RestController
+@RequestMapping("/set")
+public class SetTemperature {
+
+
+    @Autowired
+    private SttTemperatureEntityRepo sttTemperatureEntityRepo;
+
+    @RequestMapping(value = "/temperature", method = RequestMethod.POST)
+    public Result login(HttpSession session,
+                             @RequestParam(name = "high_temperature", required = true) String high_temperature,
+                             @RequestParam(name = "low_temperature", required = true) String low_temperature,
+                             @RequestParam(name = "create", required = true) String create,
+                             @RequestParam(name = "updata", required = true) String updata,
+                             @RequestParam(name = "remark", required = true) String remark,
+                             HttpServletRequest req)  {
+
+
+        Optional<SttTemperatureEntity> byId = sttTemperatureEntityRepo.findById(2);
+        byId.get().setHighTemperature(high_temperature);
+        byId.get().setLowTemperature(low_temperature);
+        byId.get().setRemark(remark);
+        byId.get().setUpdata(new Date());
+        sttTemperatureEntityRepo.save(byId.get());
+        return  new Result(10000,"设置成功", true);
+    }
+}

huimv-ql-farm/huimv-ql-environment/src/main/java/com/huimv/environment/controller/WarningParameterController.java

@@ -0,0 +1,37 @@
+package com.huimv.environment.controller;
+
+import com.huimv.environment.entity.WarningParameter;
+import com.huimv.environment.result.Result;
+import com.huimv.environment.service.WarningParameterService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.CrossOrigin;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@CrossOrigin
+@RequestMapping("/WarningParameter")
+public class WarningParameterController {
+
+	@Autowired
+	private WarningParameterService service;
+
+	@RequestMapping("/add")
+	public Result add(WarningParameter entity){ return service.add(entity); }
+
+	@RequestMapping("/remove")
+	public Result remove(Integer[] ids){ return service.remove(ids); }
+
+	@RequestMapping("/update")
+	public Result update(WarningParameter entity){ return service.update(entity); }
+
+	@RequestMapping("/findAllById")
+	public Result findAllById(Integer id){ return service.findAllById(id); }
+
+
+	@RequestMapping("/findAll")
+	public Result findAll(String name ,Integer pageNum , Integer pageSize){
+		return service.findAll(name,pageNum,pageSize);
+	}
+
+}

huimv-ql-farm/huimv-ql-environment/src/main/java/com/huimv/environment/entity/SttTemperatureEntity.java

@@ -0,0 +1,39 @@
+package com.huimv.environment.entity;
+
+import lombok.Data;
+
+import javax.persistence.*;
+import java.io.Serializable;
+import java.util.Date;
+
+@Entity
+@Table(name = "stt_temperature")
+@Data
+public class SttTemperatureEntity implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * id
+     */
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "id", nullable = false)
+    private Integer id;
+
+    @Column(name = "high_temperature")
+    private String highTemperature;
+
+    @Column(name = "low_temperature")
+    private String lowTemperature;
+
+    @Column(name = "create", nullable = false)
+    private Date create;
+
+    @Column(name = "updata", nullable = false)
+    private Date updata;
+
+    @Column(name = "remark")
+    private String remark;
+
+}

huimv-ql-farm/huimv-ql-environment/src/main/java/com/huimv/environment/entity/WarningParameter.java

@@ -0,0 +1,24 @@
+package com.huimv.environment.entity;
+
+import lombok.Data;
+
+import javax.persistence.*;
+import java.io.Serializable;
+
+@Data
+@Entity
+@Table(name = "warning_parameter")
+public class WarningParameter implements Serializable {
+
+	@Id
+	@GeneratedValue(strategy = GenerationType.IDENTITY)
+	@Column(name = "id")
+	private Integer id;
+
+	@Column(name = "parameter_name")
+	private String parameterName;
+
+	@Column(name = "threshold_value")
+	private Double thresholdValue;
+
+}

huimv-ql-farm/huimv-ql-environment/src/main/java/com/huimv/environment/repo/DeviceUpDataEntityRepo.java

@@ -24,4 +24,6 @@ public interface DeviceUpDataEntityRepo extends JpaRepository<DeviceUpDataEntity
             "WHERE DATE_FORMAT(TIMESTAMP,'%Y-%m-%d')=DATE_FORMAT(?3,'%Y-%m-%d')  ")
     List<DeviceUpDataEntity> findAllByTimestampBetween(Double minTemp,Double maxTemp, String today );
 
+
+
 }

huimv-ql-farm/huimv-ql-environment/src/main/java/com/huimv/environment/repo/SttTemperatureEntityRepo.java

@@ -0,0 +1,9 @@
+package com.huimv.environment.repo;
+
+import com.huimv.environment.entity.SttTemperatureEntity;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+
+public interface SttTemperatureEntityRepo extends JpaRepository<SttTemperatureEntity, Integer>, JpaSpecificationExecutor<SttTemperatureEntity> {
+
+}

huimv-ql-farm/huimv-ql-environment/src/main/java/com/huimv/environment/repo/WarningParameterRepository.java

@@ -0,0 +1,14 @@
+package com.huimv.environment.repo;
+
+import com.huimv.environment.entity.WarningParameter;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+import org.springframework.data.jpa.repository.Query;
+
+import java.util.List;
+
+public interface WarningParameterRepository extends JpaRepository<WarningParameter, Integer>,JpaSpecificationExecutor<WarningParameter>{
+	
+	@Query(nativeQuery = true ,value = "select * from warning_parameter where parameterName like %?1% limit ?2 , ?3")
+	List<WarningParameter> findAll(String name, Integer startPage, Integer pageSize);
+}

huimv-ql-farm/huimv-ql-environment/src/main/java/com/huimv/environment/result/Result.java

@@ -0,0 +1,22 @@
+package com.huimv.environment.result;
+
+import lombok.Data;
+
+
+@Data
+public class Result {
+	private Integer  status;
+	private String msg;
+	private Object data;
+
+	public Result(Integer status, String msg, Object data) {
+		this.status = status;
+		this.msg = msg;
+		this.data = data;
+	}
+
+	public Result(Integer status, String msg) {
+		this.status = status;
+		this.msg = msg;
+	}
+}

huimv-ql-farm/huimv-ql-environment/src/main/java/com/huimv/environment/result/ResultStatus.java

@@ -0,0 +1,15 @@
+package com.huimv.environment.result;
+
+public  class ResultStatus {
+	public  final static String addNull = "没有输入参数";
+	public  final static String addSuccess = "添加成功";
+	public  final static String addFailed = "添加失败";
+	public  final static String deleteNull = "没有要删除的数据";
+	public  final static String deleteSuccess = "删除成功";
+	public  final static String deleteFailed = "删除失败";
+	public  final static String updateNull = "没有要修改的数据";
+	public  final static String updateSuccess = "修改成功";
+	public  final static String updateFailed = "修改失败";
+	public  final static String findSuccess = "查询成功";
+	public  final static String findFailed = "查询失败";
+}

huimv-ql-farm/huimv-ql-environment/src/main/java/com/huimv/environment/service/IEnvironmentControlService.java

@@ -16,4 +16,6 @@ public interface IEnvironmentControlService {
     Result warningInfor();
 
     Result findByZSID();
+
+    void examine();
 }

huimv-ql-farm/huimv-ql-environment/src/main/java/com/huimv/environment/service/WarningParameterService.java

@@ -0,0 +1,23 @@
+package com.huimv.environment.service;
+
+
+import com.huimv.environment.entity.WarningParameter;
+import com.huimv.environment.result.Result;
+
+public interface WarningParameterService {
+
+   //添加
+   Result add(WarningParameter entity);
+
+   //添加
+   Result remove(Integer[] ids);
+
+   //添加
+   Result update(WarningParameter entity);
+
+   //查询
+  Result findAll(String name, Integer pageNum, Integer pageSize);
+
+   //根据id查找
+   Result findAllById(Integer id);
+}

huimv-ql-farm/huimv-ql-environment/src/main/java/com/huimv/environment/service/impl/EnvironmentControlServiceImpl.java

@@ -230,6 +230,12 @@ public class EnvironmentControlServiceImpl implements IEnvironmentControlService
         return null;
     }
 
+    @Override
+    @DS("slave")
+    public void examine() {
+//        deviceUpDataEntityRepo.
+    }
+
   /*  @Override
     public Result getAllFarm() {
 

huimv-ql-farm/huimv-ql-environment/src/main/java/com/huimv/environment/service/impl/WarningParameterServiceImpl.java

@@ -0,0 +1,88 @@
+package com.huimv.environment.service.impl;
+
+import com.huimv.environment.entity.WarningParameter;
+import com.huimv.environment.repo.WarningParameterRepository;
+import com.huimv.environment.result.Result;
+import com.huimv.environment.result.ResultStatus;
+import com.huimv.environment.service.WarningParameterService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class WarningParameterServiceImpl implements WarningParameterService {
+
+	@Autowired
+	private WarningParameterRepository rep;
+
+	@Override
+	public Result add(WarningParameter entity){
+		if (entity == null){
+			return new Result(10002, ResultStatus.addNull);
+		}
+		try {
+			rep.save(entity);
+			return new Result(10000,ResultStatus.addSuccess);
+		}catch (Exception e){
+			return new Result(10001,ResultStatus.addFailed);
+		}
+	}
+
+	@Override
+	public Result remove(Integer[] ids) {
+		if (ids == null || ids.length==0){
+			return new Result(10002,ResultStatus.deleteNull);
+		}
+		try {
+			for (Integer id : ids) {
+				rep.deleteById(id);
+			}
+			return new Result(10000,ResultStatus.deleteSuccess);
+		}catch (Exception e){
+			return new Result(10001,ResultStatus.deleteFailed);
+		}
+	}
+
+	@Override
+	public Result update(WarningParameter entity) {
+		if (entity == null){
+			return new Result(10002,ResultStatus.updateNull);
+		}
+		try {
+			rep.save(entity);
+			return new Result(10000,ResultStatus.updateSuccess);
+		}catch (Exception e){
+			return new Result(10001,ResultStatus.updateFailed);
+		}
+	}
+
+	@Override
+	public Result findAll(String name ,Integer pageNum , Integer pageSize) {
+		try {
+			Map map = new HashMap();
+			int size = rep.findAll().size() ;
+			Integer startPage = (pageNum-1) * pageSize;
+			List<WarningParameter> all = rep.findAll(name,startPage,pageSize);
+			map.put("total",size);
+			map.put("totalPageNum",(size  +  pageSize  - 1) / pageSize);
+			map.put("data",all);
+			
+			return new Result(10000,ResultStatus.findSuccess,map);
+		}catch (Exception e){
+			return new Result(10001,ResultStatus.findFailed,null);
+		}
+	}
+
+	@Override
+	public Result findAllById(Integer id) {
+		try {
+			WarningParameter entity = rep.findById(id).get();
+			return new Result(10000,ResultStatus.findSuccess,entity);
+		}catch (Exception e){
+			return new Result(10001,ResultStatus.findFailed,null);
+		}
+	}
+}