|
@@ -10,11 +10,13 @@ import com.huimv.admin.common.utils.DataUill;
|
|
import com.huimv.admin.common.utils.Result;
|
|
import com.huimv.admin.common.utils.Result;
|
|
import com.huimv.admin.common.utils.ResultCode;
|
|
import com.huimv.admin.common.utils.ResultCode;
|
|
import com.huimv.admin.entity.BasePigpen;
|
|
import com.huimv.admin.entity.BasePigpen;
|
|
|
|
+import com.huimv.admin.entity.EnergyData;
|
|
import com.huimv.admin.entity.EnergyFeed;
|
|
import com.huimv.admin.entity.EnergyFeed;
|
|
import com.huimv.admin.entity.EnergyGas;
|
|
import com.huimv.admin.entity.EnergyGas;
|
|
import com.huimv.admin.entity.vo.EnergyDataVo;
|
|
import com.huimv.admin.entity.vo.EnergyDataVo;
|
|
import com.huimv.admin.entity.vo.EnergyFeedDataVo;
|
|
import com.huimv.admin.entity.vo.EnergyFeedDataVo;
|
|
import com.huimv.admin.mapper.BasePigpenMapper;
|
|
import com.huimv.admin.mapper.BasePigpenMapper;
|
|
|
|
+import com.huimv.admin.mapper.EnergyDataMapper;
|
|
import com.huimv.admin.mapper.EnergyFeedMapper;
|
|
import com.huimv.admin.mapper.EnergyFeedMapper;
|
|
import com.huimv.admin.service.IEnergyFeedService;
|
|
import com.huimv.admin.service.IEnergyFeedService;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
@@ -41,6 +43,8 @@ public class EnergyFeedServiceImpl extends ServiceImpl<EnergyFeedMapper, EnergyF
|
|
private EnergyFeedMapper energyFeedMapper;
|
|
private EnergyFeedMapper energyFeedMapper;
|
|
@Autowired
|
|
@Autowired
|
|
private BasePigpenMapper basePigpenMapper;
|
|
private BasePigpenMapper basePigpenMapper;
|
|
|
|
+ @Autowired
|
|
|
|
+ private EnergyDataMapper dataMapper;
|
|
@Override
|
|
@Override
|
|
public Result listPigpen(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) {
|
|
public Result listPigpen(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) {
|
|
String farmId = paramsMap.get("farmId");
|
|
String farmId = paramsMap.get("farmId");
|
|
@@ -52,17 +56,15 @@ public class EnergyFeedServiceImpl extends ServiceImpl<EnergyFeedMapper, EnergyF
|
|
queryWrapper.eq("farm_id", farmId).eq("parent_id", 0);
|
|
queryWrapper.eq("farm_id", farmId).eq("parent_id", 0);
|
|
List<BasePigpen> basePigpens = basePigpenMapper.selectList(queryWrapper);
|
|
List<BasePigpen> basePigpens = basePigpenMapper.selectList(queryWrapper);
|
|
for (int i = 0; i < basePigpens.size(); i++) {
|
|
for (int i = 0; i < basePigpens.size(); i++) {
|
|
-
|
|
|
|
-
|
|
|
|
QueryWrapper<BasePigpen> basePigpenQueryWrapper = new QueryWrapper<>();
|
|
QueryWrapper<BasePigpen> basePigpenQueryWrapper = new QueryWrapper<>();
|
|
basePigpenQueryWrapper.eq("parent_id", basePigpens.get(i).getId()).eq("farm_id", farmId);
|
|
basePigpenQueryWrapper.eq("parent_id", basePigpens.get(i).getId()).eq("farm_id", farmId);
|
|
List<BasePigpen> basePigpens1 = basePigpenMapper.selectList(basePigpenQueryWrapper);
|
|
List<BasePigpen> basePigpens1 = basePigpenMapper.selectList(basePigpenQueryWrapper);
|
|
for (BasePigpen basePigpen : basePigpens1) {
|
|
for (BasePigpen basePigpen : basePigpens1) {
|
|
JSONObject jsonObject = new JSONObject();
|
|
JSONObject jsonObject = new JSONObject();
|
|
- QueryWrapper<EnergyFeed> queryWrapper1 = new QueryWrapper<>();
|
|
|
|
|
|
+ QueryWrapper<EnergyData> queryWrapper1 = new QueryWrapper<>();
|
|
queryWrapper1.eq("unit_id", basePigpen.getId()).eq("farm_id", farmId)
|
|
queryWrapper1.eq("unit_id", basePigpen.getId()).eq("farm_id", farmId)
|
|
.orderByDesc("create_date").last(" limit 1");
|
|
.orderByDesc("create_date").last(" limit 1");
|
|
- EnergyFeed energyFeed = energyFeedMapper.selectOne(queryWrapper1);
|
|
|
|
|
|
+ EnergyData energyFeed = dataMapper.selectOne(queryWrapper1);
|
|
if (ObjectUtil.isEmpty(energyFeed)) {
|
|
if (ObjectUtil.isEmpty(energyFeed)) {
|
|
jsonObject.put("buildName", basePigpen.getBuildName());
|
|
jsonObject.put("buildName", basePigpen.getBuildName());
|
|
jsonObject.put("value", 0);
|
|
jsonObject.put("value", 0);
|
|
@@ -81,10 +83,10 @@ public class EnergyFeedServiceImpl extends ServiceImpl<EnergyFeedMapper, EnergyF
|
|
List<BasePigpen> basePigpens = basePigpenMapper.selectList(queryWrapper);
|
|
List<BasePigpen> basePigpens = basePigpenMapper.selectList(queryWrapper);
|
|
for (BasePigpen basePigpen : basePigpens) {
|
|
for (BasePigpen basePigpen : basePigpens) {
|
|
JSONObject jsonObject = new JSONObject();
|
|
JSONObject jsonObject = new JSONObject();
|
|
- QueryWrapper<EnergyFeed> queryWrapper1 = new QueryWrapper<>();
|
|
|
|
|
|
+ QueryWrapper<EnergyData> queryWrapper1 = new QueryWrapper<>();
|
|
queryWrapper1.eq("unit_id", basePigpen.getId()).eq("farm_id", farmId)
|
|
queryWrapper1.eq("unit_id", basePigpen.getId()).eq("farm_id", farmId)
|
|
.orderByDesc("create_date").last(" limit 1");
|
|
.orderByDesc("create_date").last(" limit 1");
|
|
- EnergyFeed energyFeed = energyFeedMapper.selectOne(queryWrapper1);
|
|
|
|
|
|
+ EnergyData energyFeed = dataMapper.selectOne(queryWrapper1);
|
|
if (ObjectUtil.isEmpty(energyFeed)) {
|
|
if (ObjectUtil.isEmpty(energyFeed)) {
|
|
jsonObject.put("buildName", basePigpen.getBuildName());
|
|
jsonObject.put("buildName", basePigpen.getBuildName());
|
|
jsonObject.put("value", 0);
|
|
jsonObject.put("value", 0);
|
|
@@ -109,41 +111,37 @@ public class EnergyFeedServiceImpl extends ServiceImpl<EnergyFeedMapper, EnergyF
|
|
String startTime = paramsMap.get("startTime");
|
|
String startTime = paramsMap.get("startTime");
|
|
String endTime = paramsMap.get("endTime");
|
|
String endTime = paramsMap.get("endTime");
|
|
|
|
|
|
- List<EnergyFeed> energyGasList=null;
|
|
|
|
|
|
+ List<EnergyData> energyGasList=null;
|
|
//默认显示本年
|
|
//默认显示本年
|
|
if (type == null || type == "") {
|
|
if (type == null || type == "") {
|
|
type = "3";
|
|
type = "3";
|
|
}
|
|
}
|
|
- QueryWrapper<EnergyFeed> queryWrapper = new QueryWrapper<>();
|
|
|
|
|
|
+ QueryWrapper<EnergyData> queryWrapper = new QueryWrapper<>();
|
|
queryWrapper.eq("farm_id", farmId).eq("unit_id",id);
|
|
queryWrapper.eq("farm_id", farmId).eq("unit_id",id);
|
|
//自定义查询
|
|
//自定义查询
|
|
if ("4".equals(type)) {
|
|
if ("4".equals(type)) {
|
|
startTime = startTime + " 00:00:00";
|
|
startTime = startTime + " 00:00:00";
|
|
endTime = endTime + " 23:59:59";
|
|
endTime = endTime + " 23:59:59";
|
|
queryWrapper.between("create_date", startTime, endTime).orderByAsc("create_date");
|
|
queryWrapper.between("create_date", startTime, endTime).orderByAsc("create_date");
|
|
- List<EnergyFeed> energyGases = energyFeedMapper.selectList(queryWrapper);
|
|
|
|
- energyGasList = energyGases;
|
|
|
|
|
|
+ energyGasList = dataMapper.selectList(queryWrapper);;
|
|
}
|
|
}
|
|
//全年
|
|
//全年
|
|
else if ("3".equals(type)) {
|
|
else if ("3".equals(type)) {
|
|
DateTime dateTime = DateUtil.beginOfYear(new Date());
|
|
DateTime dateTime = DateUtil.beginOfYear(new Date());
|
|
queryWrapper.ge("create_date",dateTime);
|
|
queryWrapper.ge("create_date",dateTime);
|
|
- List<EnergyFeedDataVo> energyDataVos = energyFeedMapper.listYear(queryWrapper);
|
|
|
|
- return new Result(ResultCode.SUCCESS, energyDataVos);
|
|
|
|
|
|
+ return new Result(ResultCode.SUCCESS, dataMapper.listYear2(queryWrapper));
|
|
}
|
|
}
|
|
//本月
|
|
//本月
|
|
else if ("2".equals(type)) {
|
|
else if ("2".equals(type)) {
|
|
Date timesMonthmorning = DataUill.getTimesMonthmorning();
|
|
Date timesMonthmorning = DataUill.getTimesMonthmorning();
|
|
queryWrapper.ge("create_date", timesMonthmorning).orderByAsc("create_date");
|
|
queryWrapper.ge("create_date", timesMonthmorning).orderByAsc("create_date");
|
|
- List<EnergyFeed> energyGases = energyFeedMapper.selectList(queryWrapper);
|
|
|
|
- energyGasList = energyGases;
|
|
|
|
|
|
+ energyGasList =dataMapper.selectList(queryWrapper);
|
|
}
|
|
}
|
|
//本周
|
|
//本周
|
|
else if ("1".equals(type)) {
|
|
else if ("1".equals(type)) {
|
|
DateTime dateTime = DateUtil.beginOfWeek(new Date());
|
|
DateTime dateTime = DateUtil.beginOfWeek(new Date());
|
|
queryWrapper.ge("create_date", dateTime).orderByAsc("create_date");
|
|
queryWrapper.ge("create_date", dateTime).orderByAsc("create_date");
|
|
- List<EnergyFeed> energyGases = energyFeedMapper.selectList(queryWrapper);
|
|
|
|
- energyGasList = energyGases;
|
|
|
|
|
|
+ energyGasList = dataMapper.selectList(queryWrapper);
|
|
}
|
|
}
|
|
return new Result(ResultCode.SUCCESS,energyGasList);
|
|
return new Result(ResultCode.SUCCESS,energyGasList);
|
|
|
|
|