大气设备

zhanzhiqin

2021-12-01 6e183bdc82e2c47919ae9414038c53d5c95ab3bf

大气设备

 dao/src/main/java/com/sandu/ximon/dao/domain/AirData.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,43 @@
package com.sandu.ximon.dao.domain;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import lombok.Data;

import java.io.Serializable;
import java.time.LocalDateTime;

@Data
public class AirData implements Serializable {
    @TableId(type = IdType.AUTO)
    private Long id;

    //所属灯杆
    private String belongTo;
    //大气设备状态:在线:1/离线:0
    private int equipmentState;
    //接入时间
    private LocalDateTime createTime;
    //温度
    private String temperature;
    //湿度
    private String humidity;
    //PM2.5
    private String PM25;
    //亮度
    private int brightness;
    //PM10
    private String PM10;
    //甲醛
    private String formaldehyde;
    //二氧化碳CO2
    private String CO2;
    //室内有机气态物质
    private int tVoc;
    //风速
    private String windSpeed;
    //上报时间
    private LocalDateTime updateTime;
    //所属人
    private Long userId;
}

 dao/src/main/java/com/sandu/ximon/dao/mapper/AirDataMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,15 @@
package com.sandu.ximon.dao.mapper;

import com.sandu.common.domain.BaseMapper;
import com.sandu.ximon.dao.domain.AirData;
import org.apache.ibatis.annotations.Mapper;

import java.io.Serializable;
import java.util.Collection;
import java.util.List;

@Mapper
public interface AirDataMapper extends BaseMapper<AirData> {
   //Long userId
    List<AirData> laitAirData();
}

 dao/src/main/resources/mapper/AirDataMapper.xml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,25 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.sandu.ximon.dao.mapper.AirDataMapper">

    <resultMap id="BaseResultMap" type="com.sandu.ximon.dao.domain.AirData">
        <id property="id" column="id" jdbcType="BIGINT"/>
        <result property="belongTo" column="belong_to" jdbcType="VARCHAR"/>
        <result property="equipmentState" column="equipment_state" jdbcType="INTEGER"/>
        <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
        <result property="temperature" column="temperature" jdbcType="VARCHAR"/>
        <result property="humidity" column="humidity" jdbcType="VARCHAR"/>
        <result property="PM25" column="p_m25" jdbcType="VARCHAR"/>
        <result property="brightness" column="brightness" jdbcType="INTEGER"/>
        <result property="PM10" column="p_m10" jdbcType="VARCHAR"/>
        <result property="formaldehyde" column="formaldehyde" jdbcType="VARCHAR"/>
        <result property="CO2" column="c_o2" jdbcType="VARCHAR"/>
        <result property="tVoc" column="t_voc" jdbcType="INTEGER"/>
        <result property="windSpeed" column="wind_speed" jdbcType="VARCHAR"/>
        <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
        <result property="userId" column="user_id" jdbcType="BIGINT"/>
    </resultMap>

</mapper>

 ximon-admin/src/main/java/com/sandu/ximon/admin/controller/AirDataController.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,47 @@
package com.sandu.ximon.admin.controller;

import com.sandu.common.domain.ResponseVO;
import com.sandu.common.util.ResponseUtil;
import com.sandu.ximon.admin.param.MonitorParam;
import com.sandu.ximon.admin.service.AirDataService;
import com.sandu.ximon.admin.service.MonitorService;
import com.sandu.ximon.dao.domain.AirData;
import com.sandu.ximon.dao.domain.Monitor;
import lombok.AllArgsConstructor;
import org.springframework.web.bind.annotation.*;

import java.util.List;

@RestController
@AllArgsConstructor
@RequestMapping("/v1/admin/airdata")
public class AirDataController {
    private final AirDataService airDataService;

    @GetMapping
    public ResponseVO<Object> listMonitor() {
        List<AirData> list = airDataService.listAirData();
        return ResponseUtil.successPage(list);
    }

    /**
     * æ¨¡ç³ŠæŸ¥è¯¢
     *
     * @return
     */
    @GetMapping("/listAirDataByKeyword/{keyword}")
    public ResponseVO<Object> listMonitorByKeyword(@PathVariable String keyword) {
        List<AirData> list = airDataService.listAirDataByKeyword(keyword);
        return ResponseUtil.successPage(list);
    }

    @PostMapping("/delete/{id}")
    public ResponseVO<Object> deleteMonitor(@PathVariable Long id) {
        boolean result = airDataService.deleteAirData(id);
        if (result) {
            return ResponseUtil.success(null);
        } else {
            return ResponseUtil.fail("操作失败");
        }
    }
}

 ximon-admin/src/main/java/com/sandu/ximon/admin/service/AirDataService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,55 @@
package com.sandu.ximon.admin.service;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.sandu.common.execption.BusinessException;
import com.sandu.common.service.impl.BaseServiceImpl;
import com.sandu.ximon.dao.domain.AirData;
import com.sandu.ximon.dao.domain.Monitor;
import com.sandu.ximon.dao.mapper.AirDataMapper;
import lombok.AllArgsConstructor;
import org.springframework.stereotype.Service;

import java.util.List;

@Service
@AllArgsConstructor
public class AirDataService extends BaseServiceImpl<AirDataMapper, AirData> {

    /**
     * æŸ¥è¯¢å…¨éƒ¨å¤§æ°”设备数据
     */
    public List<AirData> listAirData() {
        LambdaQueryWrapper<AirData> wrapper = Wrappers.lambdaQuery(AirData.class);
        List<AirData> list = list(wrapper);

        return list;
    }

    /**
     * æ¨¡ç³ŠæŸ¥è¯¢
     */
    public List<AirData> listAirDataByKeyword(String keyword) {

        LambdaQueryWrapper<AirData> wrapper = Wrappers.lambdaQuery(AirData.class);
        if(keyword != null){
            wrapper.like(AirData::getBelongTo,keyword);
        }
        List<AirData> airDataList = list(wrapper);
        return airDataList;
    }

    /**
     * åˆ é™¤å¤§æ°”设备
     *
     * @param Id
     * @return
     */
    public boolean deleteAirData(Long Id) {
        AirData airData = getById(Id);
        if (airData == null) {
            throw new BusinessException("找不到大气设备");
        }
        return removeById(Id);
    }
}