【feat】 添加报警配置

huimv-eartag2-platform/huimv-eartag2-manage2/src/main/java/com/huimv/eartag2/manage2/HuimvManageApplication.java

@@ -22,7 +22,7 @@ import org.springframework.web.client.RestTemplate;
 @SpringBootApplication
 @EnableScheduling
 @MapperScan("com.huimv.eartag2.manage2.mapper")
-//@Import(InterceptorConfig.class)
+@Import(InterceptorConfig.class)
 public class HuimvManageApplication {
     public static void main(String[] args) throws InterruptedException {
 

huimv-eartag2-platform/huimv-eartag2-manage2/src/main/java/com/huimv/eartag2/manage2/controller/SysBaseConfigController.java

@@ -92,4 +92,13 @@ public class SysBaseConfigController {
         return sysBaseConfigService.syncCong(paramsMap);
     }
 
+    @PostMapping("/listWarning")
+    public Result listWarning(@RequestBody Map<String,String> paramsMap){
+        return sysBaseConfigService.listWarning(paramsMap);
+    }
+    @PostMapping("/updateWarning")
+    public Result updateWarning(@RequestBody Map<String,String> paramsMap){
+        return sysBaseConfigService.updateWarning(paramsMap);
+    }
+
 }

huimv-eartag2-platform/huimv-eartag2-manage2/src/main/java/com/huimv/eartag2/manage2/service/SysBaseConfigService.java

@@ -29,4 +29,7 @@ public interface SysBaseConfigService extends IService<SysBaseConfig> {
 
     Result syncCong(Map<String,String> paramsMap);
 
+    Result listWarning(Map<String, String> paramsMap);
+
+    Result updateWarning(Map<String, String> paramsMap);
 }

huimv-eartag2-platform/huimv-eartag2-manage2/src/main/java/com/huimv/eartag2/manage2/service/impl/SysBaseConfigServiceImpl.java

@@ -1,5 +1,6 @@
 package com.huimv.eartag2.manage2.service.impl;
 
+import cn.hutool.core.util.ObjectUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.huimv.eartag2.common.utils.DateUtil;
 import com.huimv.eartag2.common.utils.Result;
@@ -224,6 +225,147 @@ public class SysBaseConfigServiceImpl extends ServiceImpl<SysBaseConfigMapper, S
         return new Result(ResultCode.SUCCESS);
     }
 
+    @Override
+    public Result listWarning(Map<String, String> paramsMap) {
+        String farmId = paramsMap.get("farmId");
+        QueryWrapper<SysBaseConfig> wrapper = new QueryWrapper<>();
+        SysBaseConfig baseConfig = sysBaseConfigMapper.selectOne(wrapper.eq("config_value", farmId));
+        Map endMap = new HashMap();
+
+        if (ObjectUtil.isNotEmpty(baseConfig)){
+            wrapper.clear();
+            wrapper.eq("row_id",baseConfig.getRowId()).eq("config_key","eartagOfflineTime");
+            SysBaseConfig eartagOfflineTime = sysBaseConfigMapper.selectOne(wrapper);
+            endMap.put("eartagOfflineTime",eartagOfflineTime.getConfigValue());
+
+            wrapper.clear();
+            wrapper.eq("row_id",baseConfig.getRowId()).eq("config_key","deviceOfflineTime");
+            SysBaseConfig deviceOfflineTime = sysBaseConfigMapper.selectOne(wrapper);
+            endMap.put("deviceOfflineTime",deviceOfflineTime.getConfigValue());
+
+            wrapper.clear();
+            wrapper.eq("row_id",baseConfig.getRowId()).eq("config_key","eartagMaxTem");
+            SysBaseConfig eartagMaxTem = sysBaseConfigMapper.selectOne(wrapper);
+            endMap.put("eartagMaxTem",eartagMaxTem.getConfigValue());
+
+            wrapper.clear();
+            wrapper.eq("row_id",baseConfig.getRowId()).eq("config_key","eartagMinxTem");
+            SysBaseConfig eartagMinxTem = sysBaseConfigMapper.selectOne(wrapper);
+            endMap.put("eartagMinxTem",eartagMinxTem.getConfigValue());
+        }else {
+            endMap.put("eartagOfflineTime",0);
+            endMap.put("deviceOfflineTime",0);
+            endMap.put("eartagMaxTem",0);
+            endMap.put("eartagMinxTem",0);
+        }
+
+
+
+
+        return new Result(ResultCode.SUCCESS,endMap);
+    }
+
+    @Override
+    public Result updateWarning(Map<String, String> paramsMap) {
+        String farmId = paramsMap.get("farmId");
+        String eartagMaxTem = paramsMap.get("eartagMaxTem");
+        String eartagMinxTem = paramsMap.get("eartagMinxTem");
+        String eartagOfflineTime = paramsMap.get("eartagOfflineTime");
+        String deviceOfflineTime = paramsMap.get("deviceOfflineTime");
+
+        QueryWrapper<SysBaseConfig> wrapper = new QueryWrapper<>();
+        SysBaseConfig baseConfig = sysBaseConfigMapper.selectOne(wrapper.eq("config_value", farmId));
+        String  rowId ="";
+        if (ObjectUtil.isEmpty(baseConfig)){
+             rowId = UUID.randomUUID().toString();
+            SysBaseConfig sysBaseConfigEntity = new SysBaseConfig();
+            sysBaseConfigEntity.setConfigName("牧场编码");
+            sysBaseConfigEntity.setConfigKey("farmCode");
+            sysBaseConfigEntity.setConfigValue(farmId);
+            sysBaseConfigEntity.setRowId(rowId);
+            sysBaseConfigMapper.insert(sysBaseConfigEntity);
+        }else {
+            rowId  =baseConfig.getRowId();
+        }
+
+
+
+        wrapper.clear();
+        wrapper.eq("config_key","eartagMaxTem");
+        wrapper.eq("row_id",rowId);
+        SysBaseConfig eartagMaxTemSys = sysBaseConfigMapper.selectOne(wrapper);
+
+        if (ObjectUtil.isNotEmpty(eartagMaxTemSys)){
+            eartagMaxTemSys.setConfigValue(eartagMaxTem);
+            sysBaseConfigMapper.updateById(eartagMaxTemSys);
+        }else {
+            SysBaseConfig newBaseConfig = new SysBaseConfig();
+            newBaseConfig.setConfigKey("eartagMaxTem");
+            newBaseConfig.setConfigName("耳标温度超过温度报警");
+            newBaseConfig.setConfigValue(eartagMaxTem);
+            newBaseConfig.setRowId(rowId);
+            sysBaseConfigMapper.insert(newBaseConfig);
+        }
+
+
+        wrapper.clear();
+        wrapper.eq("config_key","eartagMinxTem");
+        wrapper.eq("row_id",rowId);
+        SysBaseConfig eartagMinxTemSys = sysBaseConfigMapper.selectOne(wrapper);
+
+        if (ObjectUtil.isNotEmpty(eartagMinxTemSys)){
+            eartagMinxTemSys.setConfigValue(eartagMinxTem);
+            sysBaseConfigMapper.updateById(eartagMinxTemSys);
+        }else {
+            SysBaseConfig newBaseConfig = new SysBaseConfig();
+            newBaseConfig.setConfigKey("eartagMinxTem");
+            newBaseConfig.setConfigName("耳标温度低于温度报警");
+            newBaseConfig.setConfigValue(eartagMinxTem);
+            newBaseConfig.setRowId(rowId);
+            sysBaseConfigMapper.insert(newBaseConfig);
+        }
+
+        wrapper.clear();
+        wrapper.eq("config_key","eartagOfflineTime");
+        wrapper.eq("row_id",rowId);
+        SysBaseConfig eartagOfflineTimeSys = sysBaseConfigMapper.selectOne(wrapper);
+
+        if (ObjectUtil.isNotEmpty(eartagOfflineTimeSys)){
+            eartagOfflineTimeSys.setConfigValue(eartagOfflineTime);
+            sysBaseConfigMapper.updateById(eartagOfflineTimeSys);
+        }else {
+            SysBaseConfig newBaseConfig = new SysBaseConfig();
+            newBaseConfig.setConfigKey("eartagOfflineTime");
+            newBaseConfig.setConfigName("耳标离线时间（分钟）");
+            newBaseConfig.setConfigValue(eartagOfflineTime);
+            newBaseConfig.setRowId(rowId);
+            sysBaseConfigMapper.insert(newBaseConfig);
+        }
+
+
+        wrapper.clear();
+        wrapper.eq("config_key","deviceOfflineTime");
+        wrapper.eq("row_id",rowId);
+        SysBaseConfig deviceOfflineTimeSys = sysBaseConfigMapper.selectOne(wrapper);
+
+        if (ObjectUtil.isNotEmpty(deviceOfflineTimeSys)){
+            deviceOfflineTimeSys.setConfigValue(deviceOfflineTime);
+            sysBaseConfigMapper.updateById(deviceOfflineTimeSys);
+        }else {
+            SysBaseConfig newBaseConfig = new SysBaseConfig();
+            newBaseConfig.setConfigKey("deviceOfflineTime");
+            newBaseConfig.setConfigName("采集器离线时间（分钟）");
+            newBaseConfig.setConfigValue(deviceOfflineTime);
+            newBaseConfig.setRowId(rowId);
+            sysBaseConfigMapper.insert(newBaseConfig);
+        }
+
+        return new Result(10000,"修改成功",true);
+
+    }
+
+
+
     private SysBaseConfigVo convertSysBaseConfigVo(List<SysBaseConfig> list){
         Map<String, String> map = list.stream().collect(Collectors.toMap(SysBaseConfig::getConfigKey, SysBaseConfig::getConfigValue,(item1,item2) ->item1));
         SysBaseConfigVo sysBaseConfigVo = new SysBaseConfigVo();