|
@@ -12,9 +12,8 @@ import com.huimv.environment.service.IEnvironmentControlService;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
-import java.util.ArrayList;
|
|
|
-import java.util.Date;
|
|
|
-import java.util.List;
|
|
|
+import java.text.ParseException;
|
|
|
+import java.util.*;
|
|
|
|
|
|
/**
|
|
|
* @Project : huimv.shiwan
|
|
@@ -36,6 +35,8 @@ public class EnvironmentControlServiceImpl implements IEnvironmentControlService
|
|
|
private SjHkSdRepo sdRepo;
|
|
|
@Autowired
|
|
|
private SjHkWdRepo wdRepo;
|
|
|
+ @Autowired
|
|
|
+ private FarmSmRepository farmSmRepository;
|
|
|
|
|
|
@Override
|
|
|
public Result getPigpenByFarm(Integer farmId) {
|
|
@@ -89,27 +90,198 @@ public class EnvironmentControlServiceImpl implements IEnvironmentControlService
|
|
|
JSONObject envJo = new JSONObject();
|
|
|
envJo.put("lqid",lqid);
|
|
|
//--读取最新氨气
|
|
|
- SjHkAqEntity aqEntity = aqRepo.getLastAq(lqid, todayDate);
|
|
|
+ SjHkAq aqEntity = aqRepo.getLastAq(lqid, todayDate);
|
|
|
System.out.println("aqEntity>>" + aqEntity);
|
|
|
if (aqEntity != null) {
|
|
|
- envJo.put("ammonia", aqEntity.getDQAQ());
|
|
|
+ envJo.put("ammonia", aqEntity.getDqaq());
|
|
|
} else {
|
|
|
envJo.put("ammonia", "");
|
|
|
}
|
|
|
//--读取最新湿度
|
|
|
- SjHkSdEntity sdEntity = sdRepo.getLastSd(lqid, todayDate);
|
|
|
+ SjHkSd sdEntity = sdRepo.getLastSd(lqid, todayDate);
|
|
|
if (sdEntity != null) {
|
|
|
- envJo.put("humidity", sdEntity.getDQSD());
|
|
|
+ envJo.put("humidity", sdEntity.getDqsd());
|
|
|
} else {
|
|
|
envJo.put("humidity", "");
|
|
|
}
|
|
|
//--读取最新温度
|
|
|
- SjHkWdEntity wdEntity = wdRepo.getLastWd(lqid, todayDate);
|
|
|
+ SjHkWd wdEntity = wdRepo.getLastWd(lqid, todayDate);
|
|
|
if (wdEntity != null) {
|
|
|
- envJo.put("temp", wdEntity.getDQWD());
|
|
|
+ envJo.put("temp", wdEntity.getDqwd());
|
|
|
} else {
|
|
|
envJo.put("temp", "");
|
|
|
}
|
|
|
return new Result(ResultCode.SUCCESS, envJo);
|
|
|
}
|
|
|
+
|
|
|
+// @Override
|
|
|
+// public Result getAllFarm() {
|
|
|
+//
|
|
|
+//
|
|
|
+// List<FarmSm> all = farmSmRepository.findAll();
|
|
|
+//
|
|
|
+// String dateStr = "2021-03-14 00:00:00";
|
|
|
+// Date date = null;
|
|
|
+// try {
|
|
|
+// date = DateUtil.parseDateTime(dateStr);
|
|
|
+// } catch (ParseException e) {
|
|
|
+// e.printStackTrace();
|
|
|
+// }
|
|
|
+//
|
|
|
+// List endList = new ArrayList();
|
|
|
+//
|
|
|
+// for (FarmSm farmSm : all) {
|
|
|
+// Map endMap = new HashMap();
|
|
|
+// endMap.put("name",farmSm.getName());
|
|
|
+//
|
|
|
+// String lqid = farmSm.getLqid();
|
|
|
+// endMap.put("lqid",farmSm.getLqid());
|
|
|
+//
|
|
|
+//
|
|
|
+//
|
|
|
+// List<SjHkAq> allByLqidAndScsjBetween = aqRepo.findAllByLqidAndScsjBetween(lqid, date, new Date());
|
|
|
+//
|
|
|
+// List aqList = new ArrayList();
|
|
|
+// for (SjHkAq sjHkAq : allByLqidAndScsjBetween) {
|
|
|
+// Map map1 = new HashMap();
|
|
|
+// map1.put("time",(sjHkAq.getScsj()+"").substring(11,19));
|
|
|
+// map1.put("data",sjHkAq.getDqaq());
|
|
|
+// aqList.add(map1);
|
|
|
+// }
|
|
|
+//
|
|
|
+// endMap.put("aq",aqList);
|
|
|
+//
|
|
|
+// List<SjHkSd> allByLqidAndScsjBetween1 = sdRepo.findAllByLqidAndScsjBetween(lqid, date, new Date());
|
|
|
+// List sdList = new ArrayList();
|
|
|
+// for (SjHkSd sjHkAq : allByLqidAndScsjBetween1) {
|
|
|
+// Map map1 = new HashMap();
|
|
|
+// map1.put("time",(sjHkAq.getScsj()+"").substring(11,19));
|
|
|
+// map1.put("data",sjHkAq.getDqsd());
|
|
|
+// sdList.add(map1);
|
|
|
+// }
|
|
|
+// endMap.put("sd",sdList);
|
|
|
+//
|
|
|
+//
|
|
|
+// List<SjHkWd> allByLqidAndScsjBetween2 = wdRepo.findAllByLqidAndScsjBetween(lqid, date, new Date());
|
|
|
+// List wdList = new ArrayList();
|
|
|
+// for (SjHkWd sjHkAq : allByLqidAndScsjBetween2) {
|
|
|
+// Map map1 = new HashMap();
|
|
|
+// map1.put("time",(sjHkAq.getScsj()+"").substring(11,19));
|
|
|
+// map1.put("data",sjHkAq.getDqwd());
|
|
|
+// wdList.add(map1);
|
|
|
+// }
|
|
|
+// endMap.put("wd",wdList);
|
|
|
+// endList.add(endMap);
|
|
|
+//
|
|
|
+// }
|
|
|
+// return new Result(ResultCode.SUCCESS,endList);
|
|
|
+// }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public Result getAllFarm() {
|
|
|
+
|
|
|
+
|
|
|
+ List<FarmSm> all = farmSmRepository.findAll();
|
|
|
+
|
|
|
+ String dateStr = "2021-03-14 00:00:00";
|
|
|
+ String endDateStr ="2021-03-14 "+ (new Date()+"").substring(11,19);
|
|
|
+ System.out.println(endDateStr);
|
|
|
+
|
|
|
+
|
|
|
+ Date date = null;
|
|
|
+ Date endDate = null;
|
|
|
+ try {
|
|
|
+ date = DateUtil.parseDateTime(dateStr);
|
|
|
+ endDate = DateUtil.parseDateTime(endDateStr);
|
|
|
+ } catch (ParseException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+
|
|
|
+ List endList = new ArrayList();
|
|
|
+
|
|
|
+ for (FarmSm farmSm : all) {
|
|
|
+ Map endMap = new HashMap();
|
|
|
+ endMap.put("name",farmSm.getName());
|
|
|
+
|
|
|
+ String lqid = farmSm.getLqid();
|
|
|
+ endMap.put("lqid",farmSm.getLqid());
|
|
|
+
|
|
|
+ List<SjHkAq> allByLqidAndScsjBetween = aqRepo.findAllByLqidAndScsjBetween(lqid, date, endDate);
|
|
|
+ if ( allByLqidAndScsjBetween.size() >0){
|
|
|
+ SjHkAq sjHkAq1 = allByLqidAndScsjBetween.get(allByLqidAndScsjBetween.size()-1);
|
|
|
+ endMap.put("aq",sjHkAq1.getDqaq());
|
|
|
+ }
|
|
|
+
|
|
|
+ List<SjHkSd> allByLqidAndScsjBetween1 = sdRepo.findAllByLqidAndScsjBetween(lqid, date, endDate);
|
|
|
+ if ( allByLqidAndScsjBetween1.size() >0){
|
|
|
+ SjHkSd sjHkAq1 = allByLqidAndScsjBetween1.get(allByLqidAndScsjBetween1.size()-1);
|
|
|
+ endMap.put("sd",sjHkAq1.getDqsd());
|
|
|
+ }
|
|
|
+
|
|
|
+ List<SjHkWd> allByLqidAndScsjBetween2 = wdRepo.findAllByLqidAndScsjBetween(lqid, date, endDate);
|
|
|
+ if ( allByLqidAndScsjBetween2.size() >0){
|
|
|
+ SjHkWd sjHkAq2 = allByLqidAndScsjBetween2.get(allByLqidAndScsjBetween2.size()-1);
|
|
|
+ endMap.put("wd",sjHkAq2.getDqwd());
|
|
|
+ }
|
|
|
+
|
|
|
+ endList.add(endMap);
|
|
|
+
|
|
|
+ }
|
|
|
+ return new Result(ResultCode.SUCCESS,endList);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public Result getAllBylqid(String lqid) {
|
|
|
+
|
|
|
+ String dateStr = "2021-03-14 00:00:00";
|
|
|
+ String endDateStr ="2021-03-14 "+ (new Date()+"").substring(11,19);
|
|
|
+ System.out.println(endDateStr);
|
|
|
+
|
|
|
+
|
|
|
+ Date date = null;
|
|
|
+ Date endDate = null;
|
|
|
+ try {
|
|
|
+ date = DateUtil.parseDateTime(dateStr);
|
|
|
+ endDate = DateUtil.parseDateTime(endDateStr);
|
|
|
+ } catch (ParseException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ Map map =new HashMap();
|
|
|
+
|
|
|
+ List aqList = new ArrayList();
|
|
|
+ List<SjHkAq> allByLqidAndScsjBetween = aqRepo.findAllByLqidAndScsjBetween(lqid, date, endDate);
|
|
|
+ for (SjHkAq sjHkAq : allByLqidAndScsjBetween) {
|
|
|
+ Map map1 = new HashMap();
|
|
|
+ map1.put("time",(sjHkAq.getScsj()+"").substring(11,19));
|
|
|
+ map1.put("data",sjHkAq.getDqaq());
|
|
|
+ aqList.add(map1);
|
|
|
+ }
|
|
|
+ map.put("aq",aqList);
|
|
|
+
|
|
|
+
|
|
|
+ List sdList = new ArrayList();
|
|
|
+ List<SjHkSd> allByLqidAndScsjBetween1 = sdRepo.findAllByLqidAndScsjBetween(lqid, date, endDate);
|
|
|
+ for (SjHkSd sjHkSd : allByLqidAndScsjBetween1) {
|
|
|
+ Map map1 = new HashMap();
|
|
|
+ map1.put("time",(sjHkSd.getScsj()+"").substring(11,19));
|
|
|
+ map1.put("data",sjHkSd.getDqsd());
|
|
|
+ sdList.add(map1);
|
|
|
+ }
|
|
|
+ map.put("sd",sdList);
|
|
|
+
|
|
|
+
|
|
|
+ List wdList = new ArrayList();
|
|
|
+ List<SjHkWd> allByLqidAndScsjBetween2 = wdRepo.findAllByLqidAndScsjBetween(lqid, date, endDate);
|
|
|
+ for (SjHkWd sjHkWd : allByLqidAndScsjBetween2) {
|
|
|
+ Map map1 = new HashMap();
|
|
|
+ map1.put("time",(sjHkWd.getScsj()+"").substring(11,19));
|
|
|
+ map1.put("data",sjHkWd.getDqwd());
|
|
|
+ wdList.add(map1);
|
|
|
+ }
|
|
|
+ map.put("wd",wdList);
|
|
|
+
|
|
|
+ return new Result(ResultCode.SUCCESS,map);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
}
|