GasDataServiceImpl.java 7.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177
  1. package com.huimv.admin.service.impl;
  2. import cn.hutool.core.date.DateTime;
  3. import cn.hutool.core.date.DateUtil;
  4. import cn.hutool.core.util.ObjectUtil;
  5. import com.alibaba.fastjson.JSONArray;
  6. import com.alibaba.fastjson.JSONObject;
  7. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  8. import com.baomidou.mybatisplus.core.toolkit.StringUtils;
  9. import com.huimv.admin.common.utils.DataUill;
  10. import com.huimv.admin.common.utils.Result;
  11. import com.huimv.admin.common.utils.ResultCode;
  12. import com.huimv.admin.entity.GasData;
  13. import com.huimv.admin.entity.vo.GasDataVo;
  14. import com.huimv.admin.mapper.GasDataMapper;
  15. import com.huimv.admin.service.IGasDataService;
  16. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  17. import org.springframework.beans.factory.annotation.Autowired;
  18. import org.springframework.stereotype.Service;
  19. import javax.servlet.http.HttpServletRequest;
  20. import java.util.Date;
  21. import java.util.LinkedList;
  22. import java.util.List;
  23. import java.util.Map;
  24. /**
  25. * <p>
  26. * 服务实现类
  27. * </p>
  28. *
  29. * @author author
  30. * @since 2023-02-21
  31. */
  32. @Service
  33. public class GasDataServiceImpl extends ServiceImpl<GasDataMapper, GasData> implements IGasDataService {
  34. @Autowired
  35. private GasDataMapper dataMapper;
  36. @Override
  37. public Result list(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) {
  38. String farmId = paramsMap.get("farmId");
  39. String date = paramsMap.get("time");
  40. String displayType = paramsMap.get("displayType");
  41. if (StringUtils.isBlank(displayType)){
  42. displayType = "0";
  43. }
  44. QueryWrapper<GasData> queryWrapper = new QueryWrapper<>();
  45. queryWrapper.eq("display_type",Integer.parseInt(displayType));
  46. queryWrapper.eq("farm_id", farmId);
  47. if (farmId.equals("22")) {
  48. if (date == null || date == "") {
  49. queryWrapper.orderByAsc("create_time");
  50. } else {
  51. String startTime = date + " 00:00:00";
  52. String endTime = date + " 23:59:59";
  53. queryWrapper.between("create_time", startTime, endTime).orderByAsc("create_time");
  54. }
  55. List<GasData> gasData = dataMapper.selectList(queryWrapper);
  56. GasDataVo gasDataVo = new GasDataVo();
  57. List<GasData> gasDataList = new LinkedList<>();
  58. List<GasData> gasDataList1 = new LinkedList<>();
  59. List<GasData> gasDataList2 = new LinkedList<>();
  60. List<GasData> gasDataList3 = new LinkedList<>();
  61. for (GasData gasDatum : gasData) {
  62. if (gasDatum.getLoctionType() == 1) {
  63. gasDataList.add(gasDatum);
  64. } else if (gasDatum.getLoctionType() == 2) {
  65. gasDataList1.add(gasDatum);
  66. } else if (gasDatum.getLoctionType() == 3) {
  67. gasDataList2.add(gasDatum);
  68. } else if (gasDatum.getLoctionType() == 4) {
  69. gasDataList3.add(gasDatum);
  70. }
  71. }
  72. gasDataVo.setPigpen(gasDataList);
  73. gasDataVo.setAbove(gasDataList1);
  74. gasDataVo.setUnder(gasDataList2);
  75. gasDataVo.setPeople(gasDataList3);
  76. return new Result(ResultCode.SUCCESS,gasDataVo);
  77. }else {
  78. if (date == null || date == "") {
  79. DateTime dateTime = DateUtil.beginOfDay(new Date());
  80. date = dateTime.toString();
  81. queryWrapper.ge("create_time", date).orderByAsc("create_time");
  82. } else {
  83. String startTime = date + " 00:00:00";
  84. String endTime = date + " 23:59:59";
  85. queryWrapper.between("create_time", startTime, endTime).orderByAsc("create_time");
  86. }
  87. List<GasData> gasData = dataMapper.selectList(queryWrapper);
  88. GasDataVo gasDataVo = new GasDataVo();
  89. List<GasData> gasDataList = new LinkedList<>();
  90. List<GasData> gasDataList1 = new LinkedList<>();
  91. List<GasData> gasDataList2 = new LinkedList<>();
  92. List<GasData> gasDataList3 = new LinkedList<>();
  93. for (GasData gasDatum : gasData) {
  94. if (gasDatum.getLoctionType() == 1) {
  95. gasDataList.add(gasDatum);
  96. } else if (gasDatum.getLoctionType() == 2) {
  97. gasDataList1.add(gasDatum);
  98. } else if (gasDatum.getLoctionType() == 3) {
  99. gasDataList2.add(gasDatum);
  100. } else if (gasDatum.getLoctionType() == 4) {
  101. gasDataList3.add(gasDatum);
  102. }
  103. }
  104. gasDataVo.setPigpen(gasDataList);
  105. gasDataVo.setAbove(gasDataList1);
  106. gasDataVo.setUnder(gasDataList2);
  107. gasDataVo.setPeople(gasDataList3);
  108. return new Result(ResultCode.SUCCESS,gasDataVo);
  109. }
  110. }
  111. @Override
  112. public Result listArea(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) {
  113. String farmId = paramsMap.get("farmId");
  114. String displayType = paramsMap.get("displayType");
  115. JSONObject jsonObject = new JSONObject();
  116. if (StringUtils.isBlank(displayType)){
  117. displayType = "0";
  118. }
  119. QueryWrapper<GasData> queryWrapper = new QueryWrapper<>();
  120. queryWrapper.eq("display_type",Integer.parseInt(displayType));
  121. queryWrapper.eq("farm_id", farmId).eq("loction_type", 1).orderByDesc("create_time")
  122. .last(" limit 1");
  123. GasData gasData = dataMapper.selectOne(queryWrapper);
  124. if (ObjectUtil.isEmpty(gasData)){
  125. jsonObject.put("pigpen", new GasData());
  126. }else {
  127. jsonObject.put("pigpen", gasData);
  128. }
  129. QueryWrapper<GasData> queryWrapper2 = new QueryWrapper<>();
  130. queryWrapper2.eq("display_type",Integer.parseInt(displayType));
  131. queryWrapper2.eq("farm_id", farmId).eq("loction_type", 2).orderByDesc("create_time")
  132. .last(" limit 1");
  133. GasData gasData2 = dataMapper.selectOne(queryWrapper2);
  134. if (ObjectUtil.isEmpty(gasData2)){
  135. jsonObject.put("above", new GasData());
  136. }else {
  137. jsonObject.put("above", gasData2);
  138. }
  139. QueryWrapper<GasData> queryWrapper3 = new QueryWrapper<>();
  140. queryWrapper3.eq("display_type",Integer.parseInt(displayType));
  141. queryWrapper3.eq("farm_id", farmId).eq("loction_type", 3).orderByDesc("create_time")
  142. .last(" limit 1");
  143. GasData gasData3 = dataMapper.selectOne(queryWrapper3);
  144. if (ObjectUtil.isEmpty(gasData3)){
  145. jsonObject.put("under", new GasData());
  146. }else {
  147. jsonObject.put("under", gasData3);
  148. }
  149. QueryWrapper<GasData> queryWrapper4 = new QueryWrapper<>();
  150. queryWrapper4.eq("display_type",Integer.parseInt(displayType));
  151. queryWrapper4.eq("farm_id", farmId).eq("loction_type", 4).orderByDesc("create_time")
  152. .last(" limit 1");
  153. GasData gasData4 = dataMapper.selectOne(queryWrapper4);
  154. if (ObjectUtil.isEmpty(gasData4)){
  155. jsonObject.put("people", new GasData());
  156. }else {
  157. jsonObject.put("people", gasData4);
  158. }
  159. return new Result(ResultCode.SUCCESS, jsonObject);
  160. }
  161. }