|
@@ -22,14 +22,11 @@ import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
import javax.servlet.http.HttpServletRequest;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
-import java.util.Calendar;
|
|
|
|
-import java.util.Date;
|
|
|
|
-import java.util.List;
|
|
|
|
-import java.util.Map;
|
|
|
|
|
|
+import java.util.*;
|
|
|
|
|
|
/**
|
|
/**
|
|
* <p>
|
|
* <p>
|
|
- * 服务实现类
|
|
|
|
|
|
+ * 服务实现类
|
|
* </p>
|
|
* </p>
|
|
*
|
|
*
|
|
* @author author
|
|
* @author author
|
|
@@ -44,6 +41,7 @@ public class EnergyFeedServiceImpl extends ServiceImpl<EnergyFeedMapper, EnergyF
|
|
private BasePigpenMapper basePigpenMapper;
|
|
private BasePigpenMapper basePigpenMapper;
|
|
@Autowired
|
|
@Autowired
|
|
private EnergyDataMapper dataMapper;
|
|
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");
|
|
@@ -53,15 +51,49 @@ public class EnergyFeedServiceImpl extends ServiceImpl<EnergyFeedMapper, EnergyF
|
|
if (id == null || id == "") {
|
|
if (id == null || id == "") {
|
|
QueryWrapper<BasePigpen> queryWrapper = new QueryWrapper<>();
|
|
QueryWrapper<BasePigpen> queryWrapper = new QueryWrapper<>();
|
|
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) {
|
|
|
|
+
|
|
|
|
+ QueryWrapper<BasePigpen> basePigpenQueryWrapper1 = new QueryWrapper<>();
|
|
|
|
+ basePigpenQueryWrapper1.like("other2", basePigpen.getId()).eq("farm_id", farmId);
|
|
|
|
+ List<BasePigpen> basePigpens2 = basePigpenMapper.selectList(basePigpenQueryWrapper1);//得到所有的单元
|
|
|
|
+ for (BasePigpen pigpen : basePigpens2) {
|
|
|
|
+ JSONObject jsonObject = new JSONObject();
|
|
|
|
+ QueryWrapper<EnergyData> queryWrapper1 = new QueryWrapper<>();
|
|
|
|
+ queryWrapper1.eq("unit_id", pigpen.getId()).eq("farm_id", farmId)
|
|
|
|
+ .orderByDesc("create_date").last(" limit 1");
|
|
|
|
+ EnergyData energyFeed = dataMapper.selectOne(queryWrapper1);
|
|
|
|
+ if (ObjectUtil.isEmpty(energyFeed)) {
|
|
|
|
+ jsonObject.put("buildName", basePigpen.getBuildName());
|
|
|
|
+ jsonObject.put("value", 0);
|
|
|
|
+ jsonObject.put("id", basePigpen.getId());
|
|
|
|
+ } else {
|
|
|
|
+ jsonObject.put("buildName", basePigpen.getBuildName());
|
|
|
|
+ jsonObject.put("value", energyFeed.getFeedValue());
|
|
|
|
+ jsonObject.put("id", basePigpen.getId());
|
|
|
|
+ }
|
|
|
|
+ jsonArray.add(jsonObject);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ } else {
|
|
|
|
+ QueryWrapper<BasePigpen> queryWrapper = new QueryWrapper<>();
|
|
|
|
+ queryWrapper.eq("farm_id", farmId).eq("parent_id", id);
|
|
|
|
+ List<BasePigpen> basePigpens = basePigpenMapper.selectList(queryWrapper);//所有层
|
|
|
|
+ for (BasePigpen basePigpen : basePigpens) {
|
|
|
|
+ QueryWrapper<BasePigpen> basePigpenQueryWrapper = new QueryWrapper<>();
|
|
|
|
+ basePigpenQueryWrapper.like("other2", basePigpen.getId()).eq("farm_id", farmId);
|
|
|
|
+ List<BasePigpen> basePigpens1 = basePigpenMapper.selectList(basePigpenQueryWrapper);//得到所有的单元
|
|
|
|
+ for (BasePigpen pigpen : basePigpens1) {
|
|
JSONObject jsonObject = new JSONObject();
|
|
JSONObject jsonObject = new JSONObject();
|
|
QueryWrapper<EnergyData> queryWrapper1 = new QueryWrapper<>();
|
|
QueryWrapper<EnergyData> queryWrapper1 = new QueryWrapper<>();
|
|
- queryWrapper1.eq("unit_id", basePigpen.getId()).eq("farm_id", farmId)
|
|
|
|
|
|
+ queryWrapper1.eq("unit_id", pigpen.getId()).eq("farm_id", farmId)
|
|
.orderByDesc("create_date").last(" limit 1");
|
|
.orderByDesc("create_date").last(" limit 1");
|
|
EnergyData energyFeed = dataMapper.selectOne(queryWrapper1);
|
|
EnergyData energyFeed = dataMapper.selectOne(queryWrapper1);
|
|
if (ObjectUtil.isEmpty(energyFeed)) {
|
|
if (ObjectUtil.isEmpty(energyFeed)) {
|
|
@@ -73,33 +105,13 @@ public class EnergyFeedServiceImpl extends ServiceImpl<EnergyFeedMapper, EnergyF
|
|
jsonObject.put("value", energyFeed.getFeedValue());
|
|
jsonObject.put("value", energyFeed.getFeedValue());
|
|
jsonObject.put("id", basePigpen.getId());
|
|
jsonObject.put("id", basePigpen.getId());
|
|
}
|
|
}
|
|
|
|
+
|
|
jsonArray.add(jsonObject);
|
|
jsonArray.add(jsonObject);
|
|
}
|
|
}
|
|
- }
|
|
|
|
- } else {
|
|
|
|
- QueryWrapper<BasePigpen> queryWrapper = new QueryWrapper<>();
|
|
|
|
- queryWrapper.eq("farm_id", farmId).eq("parent_id", id);
|
|
|
|
- List<BasePigpen> basePigpens = basePigpenMapper.selectList(queryWrapper);
|
|
|
|
- for (BasePigpen basePigpen : basePigpens) {
|
|
|
|
- JSONObject jsonObject = new JSONObject();
|
|
|
|
- QueryWrapper<EnergyData> queryWrapper1 = new QueryWrapper<>();
|
|
|
|
- queryWrapper1.eq("unit_id", basePigpen.getId()).eq("farm_id", farmId)
|
|
|
|
- .orderByDesc("create_date").last(" limit 1");
|
|
|
|
- EnergyData energyFeed = dataMapper.selectOne(queryWrapper1);
|
|
|
|
- if (ObjectUtil.isEmpty(energyFeed)) {
|
|
|
|
- jsonObject.put("buildName", basePigpen.getBuildName());
|
|
|
|
- jsonObject.put("value", 0);
|
|
|
|
- jsonObject.put("id", basePigpen.getId());
|
|
|
|
- } else {
|
|
|
|
- jsonObject.put("buildName", basePigpen.getBuildName());
|
|
|
|
- jsonObject.put("value", energyFeed.getFeedValue());
|
|
|
|
- jsonObject.put("id", basePigpen.getId());
|
|
|
|
- }
|
|
|
|
|
|
|
|
- jsonArray.add(jsonObject);
|
|
|
|
}
|
|
}
|
|
}
|
|
}
|
|
- return new Result(ResultCode.SUCCESS,jsonArray);
|
|
|
|
|
|
+ return new Result(ResultCode.SUCCESS, jsonArray);
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
@@ -110,24 +122,34 @@ 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<EnergyFeedDataVo> energyGasList=null;
|
|
|
|
|
|
+ List<EnergyFeedDataVo> energyGasList = null;
|
|
//默认显示本年
|
|
//默认显示本年
|
|
if (type == null || type == "") {
|
|
if (type == null || type == "") {
|
|
type = "3";
|
|
type = "3";
|
|
}
|
|
}
|
|
|
|
+
|
|
|
|
+ QueryWrapper<BasePigpen> pigpenQueryWrapper = new QueryWrapper<>();
|
|
|
|
+ pigpenQueryWrapper.eq("farm_id", farmId).like("other2", id);
|
|
|
|
+ List<BasePigpen> basePigpens = basePigpenMapper.selectList(pigpenQueryWrapper);//单元的集合
|
|
|
|
+ List<Integer> unitIds = new ArrayList<>();
|
|
|
|
+ basePigpens.forEach(item -> {
|
|
|
|
+ unitIds.add(item.getId());
|
|
|
|
+ });
|
|
|
|
+
|
|
QueryWrapper<EnergyData> queryWrapper = new QueryWrapper<>();
|
|
QueryWrapper<EnergyData> queryWrapper = new QueryWrapper<>();
|
|
- queryWrapper.eq("farm_id", farmId).eq("unit_id",id);
|
|
|
|
|
|
+ queryWrapper.eq("farm_id", farmId).in("unit_id", unitIds);
|
|
//自定义查询
|
|
//自定义查询
|
|
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);
|
|
queryWrapper.between("create_date", startTime, endTime);
|
|
- energyGasList = dataMapper.listDay2(queryWrapper);;
|
|
|
|
|
|
+ energyGasList = dataMapper.listDay2(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> energyFeedDataVos = dataMapper.listYear2(queryWrapper);
|
|
List<EnergyFeedDataVo> energyFeedDataVos = dataMapper.listYear2(queryWrapper);
|
|
for (EnergyFeedDataVo energyFeedDataVo : energyFeedDataVos) {
|
|
for (EnergyFeedDataVo energyFeedDataVo : energyFeedDataVos) {
|
|
if (energyFeedDataVo.getFeedValue() == null || energyFeedDataVo.getFeedValue() == "") {
|
|
if (energyFeedDataVo.getFeedValue() == null || energyFeedDataVo.getFeedValue() == "") {
|
|
@@ -140,7 +162,7 @@ public class EnergyFeedServiceImpl extends ServiceImpl<EnergyFeedMapper, EnergyF
|
|
else if ("2".equals(type)) {
|
|
else if ("2".equals(type)) {
|
|
Date timesMonthmorning = DataUill.getTimesMonthmorning();
|
|
Date timesMonthmorning = DataUill.getTimesMonthmorning();
|
|
queryWrapper.ge("create_date", timesMonthmorning);
|
|
queryWrapper.ge("create_date", timesMonthmorning);
|
|
- energyGasList =dataMapper.listDay2(queryWrapper);
|
|
|
|
|
|
+ energyGasList = dataMapper.listDay2(queryWrapper);
|
|
}
|
|
}
|
|
//本周
|
|
//本周
|
|
else if ("1".equals(type)) {
|
|
else if ("1".equals(type)) {
|
|
@@ -155,7 +177,8 @@ public class EnergyFeedServiceImpl extends ServiceImpl<EnergyFeedMapper, EnergyF
|
|
}
|
|
}
|
|
energyGasList = energyFeedDataVos;
|
|
energyGasList = energyFeedDataVos;
|
|
}
|
|
}
|
|
- return new Result(ResultCode.SUCCESS,energyGasList);
|
|
|
|
|
|
+
|
|
|
|
+ return new Result(ResultCode.SUCCESS, energyGasList);
|
|
|
|
|
|
}
|
|
}
|
|
}
|
|
}
|