|
@@ -10,8 +10,12 @@ import com.huimv.management.dao.FarmDao;
|
|
|
import com.huimv.management.dao.PigstyDao;
|
|
|
import com.huimv.management.entity.FarmEntity;
|
|
|
import com.huimv.management.entity.IndoorEnvironmentEntity;
|
|
|
+import com.huimv.management.entity.vo.DrinkingWaterVo;
|
|
|
import com.huimv.management.entity.vo.IndoorEnvironmentVo;
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
+import org.jeecgframework.poi.excel.def.NormalExcelConstants;
|
|
|
+import org.jeecgframework.poi.excel.entity.ExportParams;
|
|
|
+import org.jeecgframework.poi.excel.view.JeecgEntityExcelView;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
@@ -25,10 +29,11 @@ import com.huimv.common.utils.Query;
|
|
|
|
|
|
import com.huimv.management.dao.IndoorEnvironmentDao;
|
|
|
import com.huimv.management.service.IndoorEnvironmentService;
|
|
|
+import org.springframework.web.servlet.ModelAndView;
|
|
|
|
|
|
/**
|
|
|
* <p>
|
|
|
- * 室内环境ServiceImpl
|
|
|
+ * 室内环境ServiceImpl
|
|
|
* </p>
|
|
|
*
|
|
|
* @author yinhao
|
|
@@ -38,30 +43,47 @@ import com.huimv.management.service.IndoorEnvironmentService;
|
|
|
@Service("indoorEnvironmentService")
|
|
|
public class IndoorEnvironmentServiceImpl extends ServiceImpl<IndoorEnvironmentDao, IndoorEnvironmentEntity> implements IndoorEnvironmentService {
|
|
|
|
|
|
- @Autowired
|
|
|
- private FarmDao farmDao;
|
|
|
-
|
|
|
- @Autowired
|
|
|
- private PigstyDao pigstyDao;
|
|
|
|
|
|
@Override
|
|
|
public PageUtils queryPage(Map<String, Object> params) {
|
|
|
+ QueryWrapper<IndoorEnvironmentVo> queryWrapper = buildQueryWrapper(params);
|
|
|
+
|
|
|
+ //mapper文件sql编写并返回分页结果
|
|
|
+ IPage<IndoorEnvironmentVo> page = baseMapper.page(new Query<>().getPage(params), queryWrapper);
|
|
|
+ return new PageUtils(page);
|
|
|
+ }
|
|
|
|
|
|
+ @Override
|
|
|
+ public ModelAndView exportXls(Map<String, Object> params) {
|
|
|
+ QueryWrapper<IndoorEnvironmentVo> queryWrapper = buildQueryWrapper(params);
|
|
|
+ List<IndoorEnvironmentVo> list = baseMapper.page(queryWrapper);
|
|
|
+
|
|
|
+ //构建auto-poi mv对象,导出数据
|
|
|
+ ModelAndView mv = new ModelAndView(new JeecgEntityExcelView());
|
|
|
+ mv.addObject(NormalExcelConstants.FILE_NAME,"室内环境");
|
|
|
+ mv.addObject(NormalExcelConstants.CLASS, IndoorEnvironmentVo.class);
|
|
|
+ mv.addObject(NormalExcelConstants.PARAMS, new ExportParams("室内环境列表数据", "导出信息"));
|
|
|
+ mv.addObject(NormalExcelConstants.DATA_LIST, list);
|
|
|
+
|
|
|
+ return mv;
|
|
|
+ }
|
|
|
+
|
|
|
+ private QueryWrapper<IndoorEnvironmentVo> buildQueryWrapper(Map<String, Object> params) {
|
|
|
//构建条件wrapper
|
|
|
QueryWrapper<IndoorEnvironmentVo> queryWrapper = new QueryWrapper<>();
|
|
|
-
|
|
|
//异常状态
|
|
|
String abnormalStatus = (String) params.get("abnormalStatus");
|
|
|
- if (StringUtils.isNotEmpty(abnormalStatus)) {
|
|
|
- queryWrapper.eq("env.abnormal_status", Boolean.parseBoolean(abnormalStatus));
|
|
|
+ if (StringUtils.isBlank(abnormalStatus)) {
|
|
|
+ throw new RRException("请选择正常/异常状态!");
|
|
|
}
|
|
|
-
|
|
|
+ queryWrapper.eq("env.abnormal_status", Boolean.parseBoolean(abnormalStatus));
|
|
|
+ //牧场id
|
|
|
String farmId = (String) params.get("formFarmId");
|
|
|
- if (StringUtils.isNotBlank(farmId)) {
|
|
|
- queryWrapper.eq("env.farm_id",Integer.parseInt(farmId));
|
|
|
+ if (StringUtils.isBlank(farmId)) {
|
|
|
+ throw new RRException("牧场id为必传参数!");
|
|
|
}
|
|
|
-
|
|
|
-
|
|
|
+ queryWrapper.eq("env.farm_id", Integer.parseInt(farmId));
|
|
|
+ //猪舍id
|
|
|
String pigstyId = (String) params.get("pigstyId");
|
|
|
if (StringUtils.isNotBlank(pigstyId)) {
|
|
|
if (StringUtils.isBlank(farmId)) {
|
|
@@ -70,46 +92,20 @@ public class IndoorEnvironmentServiceImpl extends ServiceImpl<IndoorEnvironmentD
|
|
|
int val = Integer.parseInt(pigstyId);
|
|
|
queryWrapper.eq("env.pigsty_id", val);
|
|
|
}
|
|
|
-
|
|
|
- //牧场名称
|
|
|
-// String farmName = (String) params.get("farmName");
|
|
|
-// if (farmName != null) {
|
|
|
-// LambdaQueryWrapper<FarmEntity> query = Wrappers.<FarmEntity>lambdaQuery().like(FarmEntity::getName, farmName);
|
|
|
-// List<Integer> idList = farmDao.selectIdList(query);
|
|
|
-// if (CollUtil.isNotEmpty(idList)) {
|
|
|
-// queryWrapper.in("env.farm_id", idList);
|
|
|
-// }
|
|
|
-// }
|
|
|
-
|
|
|
- //猪舍名称
|
|
|
-// String pigstyName = (String) params.get("pigstyName");
|
|
|
-// if (StringUtils.isNotEmpty(pigstyName)) {
|
|
|
-// List<Integer> idList = pigstyDao.selectIdListByPigstyName(pigstyName);
|
|
|
-// if (CollUtil.isNotEmpty(idList)) {
|
|
|
-// queryWrapper.in("env.pigsty_id", idList);
|
|
|
-// }
|
|
|
-// }
|
|
|
-
|
|
|
//时间区间(前)
|
|
|
String startTime = (String) params.get("startTime");
|
|
|
if (StringUtils.isNotEmpty(startTime)) {
|
|
|
queryWrapper.ge("env.collect_time", startTime);
|
|
|
}
|
|
|
-
|
|
|
//时间区间(后)
|
|
|
String endTime = (String) params.get("endTime");
|
|
|
if (StringUtils.isNotEmpty(endTime)) {
|
|
|
queryWrapper.le("env.collect_time", endTime);
|
|
|
}
|
|
|
-
|
|
|
//排除逻辑删除
|
|
|
queryWrapper.apply(" env.deleted = 0 AND farm.deleted = 0 AND pigsty.deleted = 0");
|
|
|
//根据采集时间倒序查询
|
|
|
queryWrapper.orderByDesc("env.collect_time");
|
|
|
-
|
|
|
- //mapper文件sql编写并返回分页结果
|
|
|
- IPage<IndoorEnvironmentVo> page = baseMapper.page(new Query<>().getPage(params), queryWrapper);
|
|
|
- return new PageUtils(page);
|
|
|
+ return queryWrapper;
|
|
|
}
|
|
|
-
|
|
|
}
|