huimv.farm.huatong/huimv-admin/src/main/java/com/huimv/admin/service/impl/GasDataServiceImpl.java

package com.huimv.admin.service.impl;

import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.huimv.admin.common.utils.DataUill;
import com.huimv.admin.common.utils.Result;
import com.huimv.admin.common.utils.ResultCode;
import com.huimv.admin.entity.GasData;
import com.huimv.admin.mapper.GasDataMapper;
import com.huimv.admin.service.IGasDataService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.servlet.http.HttpServletRequest;
import java.util.Date;
import java.util.List;
import java.util.Map;

/**
 * <p>
 * 服务实现类
 * </p>
 *
 * @author author
 * @since 2023-02-21
 */
@Service
public class GasDataServiceImpl extends ServiceImpl<GasDataMapper, GasData> implements IGasDataService {

    @Autowired
    private GasDataMapper dataMapper;

    @Override
    public Result list(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) {
        String farmId = paramsMap.get("farmId");
        String date = paramsMap.get("time");

        QueryWrapper<GasData> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("farm_id", farmId);
        if (date == null || date == "") {
            DateTime dateTime = DateUtil.beginOfDay(new Date());
            date = dateTime.toString();
            queryWrapper.ge("create_time", date).orderByAsc("create_time");
        } else {
            String startTime = date + " 00:00:00";
            String endTime = date + " 23:59:59";
            queryWrapper.between("create_time", startTime, endTime).orderByAsc("create_time");
        }

        List<GasData> gasData = dataMapper.selectList(queryWrapper);
        JSONArray jsonArray = new JSONArray();
        for (GasData gasDatum : gasData) {
            JSONObject jsonObject = new JSONObject();
            if (gasDatum.getLoctionType() == 1) {
                jsonObject.put("pigpen", gasDatum);
            } else if (gasDatum.getLoctionType() == 2) {
                jsonObject.put("above", gasDatum);
            } else if (gasDatum.getLoctionType() == 3) {
                jsonObject.put("under", gasDatum);
            } else if (gasDatum.getLoctionType() == 4) {
                jsonObject.put("people", gasDatum);
            }
            jsonArray.add(jsonObject);
        }
        return new Result(ResultCode.SUCCESS, jsonArray);
    }

    @Override
    public Result listArea(HttpServletRequest httpServletRequest, Map<String, String> paramsMap) {
        String farmId = paramsMap.get("farmId");
        JSONObject jsonObject = new JSONObject();

        QueryWrapper<GasData> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("farm_id", farmId).eq("loction_type", 1).orderByDesc("create_time")
                .last(" limit 1");
        GasData gasData = dataMapper.selectOne(queryWrapper);
        jsonObject.put("pigpen", gasData);

        QueryWrapper<GasData> queryWrapper2 = new QueryWrapper<>();
        queryWrapper2.eq("farm_id", farmId).eq("loction_type", 2).orderByDesc("create_time")
                .last(" limit 1");
        GasData gasData2 = dataMapper.selectOne(queryWrapper2);
        jsonObject.put("above", gasData2);

        QueryWrapper<GasData> queryWrapper3 = new QueryWrapper<>();
        queryWrapper3.eq("farm_id", farmId).eq("loction_type", 3).orderByDesc("create_time")
                .last(" limit 1");
        GasData gasData3 = dataMapper.selectOne(queryWrapper3);
        jsonObject.put("under", gasData3);

        QueryWrapper<GasData> queryWrapper4 = new QueryWrapper<>();
        queryWrapper4.eq("farm_id", farmId).eq("loction_type", 4).orderByDesc("create_time")
                .last(" limit 1");
        GasData gasData4 = dataMapper.selectOne(queryWrapper4);
        jsonObject.put("people", gasData4);

        return new Result(ResultCode.SUCCESS, jsonObject);
    }
}