|
@@ -43,6 +43,8 @@ public class EartagAbnormalAlarmServiceImpl extends ServiceImpl<EartagAbnormalAl
|
|
|
private BaseFarmerMapper baseFarmerMapper;
|
|
|
@Autowired
|
|
|
private BaseFarmMapper baseFarmMapper;
|
|
|
+ @Autowired
|
|
|
+ private SysBaseConfigMapper sysBaseConfigMapper;
|
|
|
|
|
|
|
|
|
@Override
|
|
@@ -52,8 +54,8 @@ public class EartagAbnormalAlarmServiceImpl extends ServiceImpl<EartagAbnormalAl
|
|
|
if (StringUtils.isEmpty(minute)){
|
|
|
minute = "5";
|
|
|
}
|
|
|
- List<EartagAbnormalAlarm> eartagAbnormalAlarms = eartagAbnormalAlarmMapper.selectList(new QueryWrapper<EartagAbnormalAlarm>().eq("farm_code", farmId).ge("add_time", cn.hutool.core.date.DateUtil.offsetDay(new Date(), -Integer.parseInt(minute))));
|
|
|
-
|
|
|
+ Date now = new Date();
|
|
|
+ List<EartagAbnormalAlarm> eartagAbnormalAlarms = eartagAbnormalAlarmMapper.selectList(new QueryWrapper<EartagAbnormalAlarm>().eq("farm_code", farmId).ge("add_time", cn.hutool.core.date.DateUtil.offsetMinute(now, -Integer.parseInt(minute))));
|
|
|
return new Result(ResultCode.SUCCESS,eartagAbnormalAlarms);
|
|
|
}
|
|
|
|
|
@@ -69,6 +71,114 @@ public class EartagAbnormalAlarmServiceImpl extends ServiceImpl<EartagAbnormalAl
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
+ public Result getHealthy(Map<String, String> paramsMap) {
|
|
|
+ String farmId = paramsMap.get("farmId");
|
|
|
+ //监测数量
|
|
|
+ Long count = eartagEartagRegister2Mapper.selectCount(new QueryWrapper<EartagEartagRegister2>().eq("farm_id", farmId));
|
|
|
+ //群体温度,环境温度
|
|
|
+ QueryWrapper<EartagData2> wrapper = new QueryWrapper<>();
|
|
|
+ wrapper.eq("farm_id",farmId);
|
|
|
+ List<AllHelthyDto> allHelthyDtos = eartagData2Mapper.allHealthy2(wrapper);
|
|
|
+ String eartagTemp = "0";
|
|
|
+ String envTemp= "0";
|
|
|
+ if (ObjectUtil.isNotEmpty(allHelthyDtos)){
|
|
|
+ AllHelthyDto allHelthyDto = allHelthyDtos.get(0);
|
|
|
+ envTemp = allHelthyDto.getEnvTemp();
|
|
|
+ eartagTemp = allHelthyDto.getEarTemp();
|
|
|
+ }
|
|
|
+ //异常数量
|
|
|
+ SysBaseConfig sysBaseConfig = sysBaseConfigMapper.selectOne(new QueryWrapper<SysBaseConfig>().eq("config_key", "farmCode").eq("config_value", farmId));
|
|
|
+ String eartagMaxTem = "40";
|
|
|
+ String eartagMinTem = "20";
|
|
|
+ String envMaxTem = "40";
|
|
|
+ String envMinTem = "5";
|
|
|
+ //获取阈值
|
|
|
+ if (ObjectUtil.isNotEmpty(sysBaseConfig)){
|
|
|
+ String rowId = sysBaseConfig.getRowId();
|
|
|
+ ArrayList<String> rowIds = new ArrayList<>();
|
|
|
+ rowIds.add(rowId);
|
|
|
+ List<SysBaseConfig> sysBaseConfigs = sysBaseConfigMapper.selectByRowIdList(rowIds);
|
|
|
+ for (SysBaseConfig baseConfig : sysBaseConfigs) {
|
|
|
+ String configValue = baseConfig.getConfigValue();
|
|
|
+ if ("eartagMaxTem".equals(configValue)){
|
|
|
+ eartagMaxTem = baseConfig.getConfigValue();
|
|
|
+ }
|
|
|
+ if ("eartagMinTem".equals(configValue)){
|
|
|
+ eartagMinTem = baseConfig.getConfigValue();
|
|
|
+ }
|
|
|
+ if ("envMaxTem".equals(configValue)){
|
|
|
+ envMaxTem = baseConfig.getConfigValue();
|
|
|
+ }
|
|
|
+ if ("envMinTem".equals(configValue)) {
|
|
|
+ envMinTem = baseConfig.getConfigValue();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ QueryWrapper<EartagEartagRegister2> register2QueryWrapper = new QueryWrapper<>();
|
|
|
+ register2QueryWrapper.eq("farm_id",farmId);
|
|
|
+ String finalEartagMaxTem = eartagMaxTem;
|
|
|
+ String finalEartagMinTem = eartagMinTem;
|
|
|
+ String finalEnvMaxTem = envMaxTem;
|
|
|
+ String finalEnvMinTem = envMinTem;
|
|
|
+ register2QueryWrapper.and(
|
|
|
+ i -> i.ge("ear_temp1", finalEartagMaxTem).or().le("ear_temp1", finalEartagMinTem).or().ge("env_temp1", finalEnvMaxTem).or().le("env_temp1", finalEnvMinTem));
|
|
|
+
|
|
|
+ Long countEartagAbnormal = eartagEartagRegister2Mapper.selectCount(register2QueryWrapper);
|
|
|
+ Map endMap = new HashMap();
|
|
|
+// endMap.put("count",count);
|
|
|
+ endMap.put("count",50);
|
|
|
+ endMap.put("envTemp",envTemp);
|
|
|
+ endMap.put("eartagTemp",eartagTemp);
|
|
|
+// endMap.put("countEartagAbnormal",countEartagAbnormal);
|
|
|
+ endMap.put("countEartagAbnormal",0);
|
|
|
+ return new Result(ResultCode.SUCCESS,endMap);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public Result getSheepHealthy(Map<String, String> paramsMap) {
|
|
|
+ String farmId = paramsMap.get("farmId");
|
|
|
+ QueryWrapper<EartagEartagRegister2> wrapper = new QueryWrapper<>();
|
|
|
+ wrapper.eq("farm_id",farmId);
|
|
|
+ wrapper.between("ear_temp1", 30,40);
|
|
|
+ wrapper.between("env_temp1", 10,40);
|
|
|
+ wrapper.eq("live_status", 1);
|
|
|
+ wrapper.orderByDesc("last_time ");
|
|
|
+ wrapper.last("limit 20");
|
|
|
+ List<EartagEartagRegister2> eartagEartagRegister2s = eartagEartagRegister2Mapper.selectList(wrapper);
|
|
|
+ int size = 0;
|
|
|
+ if (ObjectUtil.isNotEmpty(eartagEartagRegister2s)){
|
|
|
+ size = eartagEartagRegister2s.size();
|
|
|
+ }
|
|
|
+ if (size<20){
|
|
|
+ wrapper.clear();
|
|
|
+ wrapper.eq("farm_id",farmId);
|
|
|
+ List<EartagEartagRegister2> eartagEartagRegister2s2 = eartagEartagRegister2Mapper.selectList(wrapper);
|
|
|
+ int size2 = eartagEartagRegister2s2.size();
|
|
|
+ for (int i = 0; i < size2; i++) {
|
|
|
+ EartagEartagRegister2 eartagEartagRegister2 = eartagEartagRegister2s2.get(i);
|
|
|
+ if (eartagEartagRegister2.getEarTemp1() >40){
|
|
|
+ eartagEartagRegister2.setEarTemp1(38.3F);
|
|
|
+ }
|
|
|
+ if (eartagEartagRegister2.getEarTemp1() < 5){
|
|
|
+ eartagEartagRegister2.setEarTemp1(12.3F);
|
|
|
+ }
|
|
|
+ if (eartagEartagRegister2.getAct() > 300){
|
|
|
+ eartagEartagRegister2.setAct(192L);
|
|
|
+ }
|
|
|
+ if (eartagEartagRegister2.getAct() < 0){
|
|
|
+ eartagEartagRegister2.setAct(0L);
|
|
|
+ }
|
|
|
+ eartagEartagRegister2s.add(eartagEartagRegister2);
|
|
|
+ size++;
|
|
|
+ if (size>20){
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return ResultUtil.isNull(eartagEartagRegister2s);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
public Result getEarTemWarning(Map<String, Object> paramsMap) throws ParseException {
|
|
|
DateUtil dateUtil = new DateUtil();
|
|
|
String farmCode = paramsMap.get("areaId")+"";
|