|
@@ -1,16 +1,20 @@
|
|
package com.huimv.management.service.impl;
|
|
package com.huimv.management.service.impl;
|
|
|
|
|
|
import cn.hutool.core.date.DateUtil;
|
|
import cn.hutool.core.date.DateUtil;
|
|
|
|
+import com.huimv.management.dao.HealthImmuneRecordDao;
|
|
|
|
+import com.huimv.management.dao.HealthIsolationRecordDao;
|
|
|
|
+import com.huimv.management.entity.HealthImmuneRecordEntity;
|
|
import com.huimv.management.entity.HealthIsolationRecordEntity;
|
|
import com.huimv.management.entity.HealthIsolationRecordEntity;
|
|
import com.huimv.management.entity.dto.DiseaseDto;
|
|
import com.huimv.management.entity.dto.DiseaseDto;
|
|
-import com.huimv.management.entity.vo.PigBaseVo;
|
|
|
|
|
|
+import com.huimv.management.entity.dto.ImmuneCountDto;
|
|
|
|
+import com.huimv.management.entity.dto.IsolationDto;
|
|
|
|
+import com.huimv.management.entity.dto.TreatResultDto;
|
|
import org.apache.commons.lang.StringUtils;
|
|
import org.apache.commons.lang.StringUtils;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
-import java.util.Date;
|
|
|
|
-import java.util.List;
|
|
|
|
-import java.util.Map;
|
|
|
|
|
|
+import java.util.*;
|
|
|
|
+
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
@@ -28,6 +32,13 @@ public class HealthMedicalRecordServiceImpl extends ServiceImpl<HealthMedicalRec
|
|
@Autowired
|
|
@Autowired
|
|
private HealthMedicalRecordDao healthMedicalRecordDao;
|
|
private HealthMedicalRecordDao healthMedicalRecordDao;
|
|
|
|
|
|
|
|
+ @Autowired
|
|
|
|
+ private HealthImmuneRecordDao healthImmuneRecordDao;
|
|
|
|
+
|
|
|
|
+ @Autowired
|
|
|
|
+ private HealthIsolationRecordDao healthIsolationRecordDao;
|
|
|
|
+
|
|
|
|
+
|
|
@Override
|
|
@Override
|
|
public PageUtils queryPage(Map<String, Object> params) {
|
|
public PageUtils queryPage(Map<String, Object> params) {
|
|
|
|
|
|
@@ -74,10 +85,11 @@ public class HealthMedicalRecordServiceImpl extends ServiceImpl<HealthMedicalRec
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public List<DiseaseDto> diseaseCount(String type, String farmId) {
|
|
public List<DiseaseDto> diseaseCount(String type, String farmId) {
|
|
- QueryWrapper<HealthMedicalRecordEntity> wrapper = new QueryWrapper<HealthMedicalRecordEntity>();
|
|
|
|
- wrapper.eq("farm_id",Integer.parseInt(farmId));
|
|
|
|
|
|
+ Map<String,Object> resultMap = new HashMap<>();
|
|
|
|
+
|
|
Date endTime = DateUtil.date();
|
|
Date endTime = DateUtil.date();
|
|
Date startTime;
|
|
Date startTime;
|
|
|
|
+
|
|
switch (type){
|
|
switch (type){
|
|
//今日
|
|
//今日
|
|
case "1":
|
|
case "1":
|
|
@@ -92,14 +104,49 @@ public class HealthMedicalRecordServiceImpl extends ServiceImpl<HealthMedicalRec
|
|
startTime = DateUtil.beginOfWeek(endTime);
|
|
startTime = DateUtil.beginOfWeek(endTime);
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+
|
|
|
|
+ QueryWrapper<HealthMedicalRecordEntity> medicalWrapper = new QueryWrapper<HealthMedicalRecordEntity>();
|
|
|
|
+ medicalWrapper.eq("farm_id",Integer.parseInt(farmId));
|
|
//小于
|
|
//小于
|
|
- wrapper.le("create_time",endTime);
|
|
|
|
|
|
+ medicalWrapper.le("create_time",endTime);
|
|
//大于等于
|
|
//大于等于
|
|
- wrapper.ge("create_time",startTime);
|
|
|
|
|
|
+ medicalWrapper.ge("create_time",startTime);
|
|
|
|
+ //逻辑删除
|
|
|
|
+ medicalWrapper.apply("effective = 1");
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ //疾病统计
|
|
|
|
+ List<DiseaseDto> diseaseDtos = healthMedicalRecordDao.diseaseCount(medicalWrapper);
|
|
|
|
+ resultMap.put("diseaseCount",diseaseDtos);
|
|
|
|
+
|
|
|
|
+ //治愈统计
|
|
|
|
+ List<TreatResultDto> treatResultDtos = healthMedicalRecordDao.treatResultCount(medicalWrapper);
|
|
|
|
+ resultMap.put("treatResultCount",treatResultDtos);
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ //疫苗统计
|
|
|
|
+ QueryWrapper<HealthImmuneRecordEntity> immuneWrapper = new QueryWrapper<HealthImmuneRecordEntity>();
|
|
|
|
+
|
|
|
|
+ immuneWrapper.eq("farm_id",farmId);
|
|
|
|
+ immuneWrapper.le("create_time",endTime);
|
|
|
|
+ immuneWrapper.ge("create_time",startTime);
|
|
|
|
+ immuneWrapper.apply("effective = 1");
|
|
|
|
+
|
|
|
|
+ List<ImmuneCountDto> immuneCountDtos = healthImmuneRecordDao.vaccineCoount(immuneWrapper);
|
|
|
|
+ resultMap.put("imuneCount",immuneCountDtos);
|
|
|
|
+
|
|
|
|
+ //隔离统计 healthIsolationRecordDao
|
|
|
|
+ QueryWrapper<HealthIsolationRecordEntity> isolationWrapper = new QueryWrapper<HealthIsolationRecordEntity>();
|
|
|
|
+ isolationWrapper.eq("farm_id",farmId);
|
|
|
|
+ isolationWrapper.le("create_time",endTime);
|
|
|
|
+ isolationWrapper.ge("create_time",startTime);
|
|
|
|
+ isolationWrapper.apply("effective = 1");
|
|
|
|
+
|
|
|
|
+ List<IsolationDto> isolationDtos = healthIsolationRecordDao.isolationCount(isolationWrapper);
|
|
|
|
+
|
|
|
|
|
|
- wrapper.apply("effective = 1");
|
|
|
|
|
|
|
|
- List<DiseaseDto> diseaseDtos = healthMedicalRecordDao.diseaseCount(wrapper);
|
|
|
|
return diseaseDtos;
|
|
return diseaseDtos;
|
|
}
|
|
}
|
|
}
|
|
}
|