交通气象检测接口

zc-business/src/main/java/com/zc/business/controller/DcWeatherMonitoringController.java

@@ -0,0 +1,41 @@
+package com.zc.business.controller;
+
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.zc.business.service.IDcWeatherMonitoringService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @Description 交通气象检测
+ *
+ * @author liuwenge
+ * @date 2024/2/1 9:41
+ */
+@Api(tags = "交通气象检测")
+@RestController
+@RequestMapping("/business/weatherMonitoring")
+public class DcWeatherMonitoringController {
+
+    @Autowired
+    private IDcWeatherMonitoringService weatherMonitoringService;
+
+    /**
+     * @Description 路网交通状况
+     *
+     * @author liuwenge
+     * @date 2024/2/1 10:10
+     * @param
+     * @return com.ruoyi.common.core.domain.AjaxResult
+     */
+    @ApiOperation("路网交通状况")
+    @GetMapping("/getTrafficConditions")
+    public AjaxResult getTrafficConditions(){
+        return weatherMonitoringService.getTrafficConditions();
+    }
+
+
+}

zc-business/src/main/java/com/zc/business/domain/DcMeteorologicalDetectorData.java

@@ -0,0 +1,331 @@
+package com.zc.business.domain;
+
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+import com.ruoyi.common.annotation.Excel;
+import com.ruoyi.common.core.domain.BaseEntity;
+
+/**
+ * 气象检测器数据对象 dc_meteorological_detector_data
+ * 
+ * @author ruoyi
+ * @date 2024-02-01
+ */
+public class DcMeteorologicalDetectorData extends BaseEntity
+{
+    private static final long serialVersionUID = 1L;
+
+    /** 主键 */
+    private Long id;
+
+    /** 物联设备id */
+    @Excel(name = "物联设备id")
+    private String iotDeviceId;
+
+    /** 降雨量毫米 */
+    @Excel(name = "降雨量毫米")
+    private String rainfall;
+
+    /** 能见度类型 */
+    @Excel(name = "能见度类型")
+    private String visibilityType;
+
+    /** 能见度 */
+    @Excel(name = "能见度")
+    private String visibility;
+
+    /** 路面状况 */
+    @Excel(name = "路面状况")
+    private String roadSurfaceStatus;
+
+    /** 气压 */
+    @Excel(name = "气压")
+    private String atmosphericPressure;
+
+    /** 气温 */
+    @Excel(name = "气温")
+    private String temperature;
+
+    /** 湿度 */
+    @Excel(name = "湿度")
+    private String humidity;
+
+    /** 风向 */
+    @Excel(name = "风向")
+    private String windDirection;
+
+    /** 风速 */
+    @Excel(name = "风速")
+    private String windSpeed;
+
+    /** 冰点温度 */
+    @Excel(name = "冰点温度")
+    private String freezingPointTemperature;
+
+    /** 盐度值 */
+    @Excel(name = "盐度值")
+    private String salinityValue;
+
+    /** 路面温度 */
+    @Excel(name = "路面温度")
+    private String roadSurfaceTemperature;
+
+    /** 水膜厚度(GS1) */
+    @Excel(name = "水膜厚度(GS1)")
+    private String waterFilmThickness;
+
+    /** 降水类型 */
+    @Excel(name = "降水类型")
+    private String precipitationType;
+
+    /** 湿滑系数 */
+    @Excel(name = "湿滑系数")
+    private String wetSlipperyCoefficient;
+
+    /** 传感器温度 */
+    @Excel(name = "传感器温度")
+    private String sensorTemperature;
+
+    /** 远程路面温度 */
+    @Excel(name = "远程路面温度")
+    private String remoteRoadSurfaceTemperature;
+
+    /** 远程路面状态 */
+    @Excel(name = "远程路面状态")
+    private String remoteRoadSurfaceStatus;
+
+    /** 路基温度 */
+    @Excel(name = "路基温度")
+    private String subSurfaceTemperature;
+
+    /** 水膜厚度(GS2) */
+    @Excel(name = "水膜厚度(GS2)")
+    private String waterFilmIceSnowValue;
+
+    public void setId(Long id) 
+    {
+        this.id = id;
+    }
+
+    public Long getId() 
+    {
+        return id;
+    }
+    public void setIotDeviceId(String iotDeviceId) 
+    {
+        this.iotDeviceId = iotDeviceId;
+    }
+
+    public String getIotDeviceId() 
+    {
+        return iotDeviceId;
+    }
+    public void setRainfall(String rainfall) 
+    {
+        this.rainfall = rainfall;
+    }
+
+    public String getRainfall() 
+    {
+        return rainfall;
+    }
+    public void setVisibilityType(String visibilityType) 
+    {
+        this.visibilityType = visibilityType;
+    }
+
+    public String getVisibilityType() 
+    {
+        return visibilityType;
+    }
+    public void setVisibility(String visibility) 
+    {
+        this.visibility = visibility;
+    }
+
+    public String getVisibility() 
+    {
+        return visibility;
+    }
+    public void setRoadSurfaceStatus(String roadSurfaceStatus) 
+    {
+        this.roadSurfaceStatus = roadSurfaceStatus;
+    }
+
+    public String getRoadSurfaceStatus() 
+    {
+        return roadSurfaceStatus;
+    }
+    public void setAtmosphericPressure(String atmosphericPressure) 
+    {
+        this.atmosphericPressure = atmosphericPressure;
+    }
+
+    public String getAtmosphericPressure() 
+    {
+        return atmosphericPressure;
+    }
+    public void setTemperature(String temperature) 
+    {
+        this.temperature = temperature;
+    }
+
+    public String getTemperature() 
+    {
+        return temperature;
+    }
+    public void setHumidity(String humidity) 
+    {
+        this.humidity = humidity;
+    }
+
+    public String getHumidity() 
+    {
+        return humidity;
+    }
+    public void setWindDirection(String windDirection) 
+    {
+        this.windDirection = windDirection;
+    }
+
+    public String getWindDirection() 
+    {
+        return windDirection;
+    }
+    public void setWindSpeed(String windSpeed) 
+    {
+        this.windSpeed = windSpeed;
+    }
+
+    public String getWindSpeed() 
+    {
+        return windSpeed;
+    }
+    public void setFreezingPointTemperature(String freezingPointTemperature) 
+    {
+        this.freezingPointTemperature = freezingPointTemperature;
+    }
+
+    public String getFreezingPointTemperature() 
+    {
+        return freezingPointTemperature;
+    }
+    public void setSalinityValue(String salinityValue) 
+    {
+        this.salinityValue = salinityValue;
+    }
+
+    public String getSalinityValue() 
+    {
+        return salinityValue;
+    }
+    public void setRoadSurfaceTemperature(String roadSurfaceTemperature) 
+    {
+        this.roadSurfaceTemperature = roadSurfaceTemperature;
+    }
+
+    public String getRoadSurfaceTemperature() 
+    {
+        return roadSurfaceTemperature;
+    }
+    public void setWaterFilmThickness(String waterFilmThickness) 
+    {
+        this.waterFilmThickness = waterFilmThickness;
+    }
+
+    public String getWaterFilmThickness() 
+    {
+        return waterFilmThickness;
+    }
+    public void setPrecipitationType(String precipitationType) 
+    {
+        this.precipitationType = precipitationType;
+    }
+
+    public String getPrecipitationType() 
+    {
+        return precipitationType;
+    }
+    public void setWetSlipperyCoefficient(String wetSlipperyCoefficient) 
+    {
+        this.wetSlipperyCoefficient = wetSlipperyCoefficient;
+    }
+
+    public String getWetSlipperyCoefficient() 
+    {
+        return wetSlipperyCoefficient;
+    }
+    public void setSensorTemperature(String sensorTemperature) 
+    {
+        this.sensorTemperature = sensorTemperature;
+    }
+
+    public String getSensorTemperature() 
+    {
+        return sensorTemperature;
+    }
+    public void setRemoteRoadSurfaceTemperature(String remoteRoadSurfaceTemperature) 
+    {
+        this.remoteRoadSurfaceTemperature = remoteRoadSurfaceTemperature;
+    }
+
+    public String getRemoteRoadSurfaceTemperature() 
+    {
+        return remoteRoadSurfaceTemperature;
+    }
+    public void setRemoteRoadSurfaceStatus(String remoteRoadSurfaceStatus) 
+    {
+        this.remoteRoadSurfaceStatus = remoteRoadSurfaceStatus;
+    }
+
+    public String getRemoteRoadSurfaceStatus() 
+    {
+        return remoteRoadSurfaceStatus;
+    }
+    public void setSubSurfaceTemperature(String subSurfaceTemperature) 
+    {
+        this.subSurfaceTemperature = subSurfaceTemperature;
+    }
+
+    public String getSubSurfaceTemperature() 
+    {
+        return subSurfaceTemperature;
+    }
+    public void setWaterFilmIceSnowValue(String waterFilmIceSnowValue)
+    {
+        this.waterFilmIceSnowValue = waterFilmIceSnowValue;
+    }
+
+    public String getWaterFilmIceSnowValue()
+    {
+        return waterFilmIceSnowValue;
+    }
+
+    @Override
+    public String toString() {
+        return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
+            .append("id", getId())
+            .append("iotDeviceId", getIotDeviceId())
+            .append("rainfall", getRainfall())
+            .append("visibilityType", getVisibilityType())
+            .append("visibility", getVisibility())
+            .append("roadSurfaceStatus", getRoadSurfaceStatus())
+            .append("atmosphericPressure", getAtmosphericPressure())
+            .append("temperature", getTemperature())
+            .append("humidity", getHumidity())
+            .append("windDirection", getWindDirection())
+            .append("windSpeed", getWindSpeed())
+            .append("freezingPointTemperature", getFreezingPointTemperature())
+            .append("salinityValue", getSalinityValue())
+            .append("roadSurfaceTemperature", getRoadSurfaceTemperature())
+            .append("waterFilmThickness", getWaterFilmThickness())
+            .append("precipitationType", getPrecipitationType())
+            .append("wetSlipperyCoefficient", getWetSlipperyCoefficient())
+            .append("sensorTemperature", getSensorTemperature())
+            .append("remoteRoadSurfaceTemperature", getRemoteRoadSurfaceTemperature())
+            .append("remoteRoadSurfaceStatus", getRemoteRoadSurfaceStatus())
+            .append("subSurfaceTemperature", getSubSurfaceTemperature())
+            .append("waterFilmIceSnowValue", getWaterFilmIceSnowValue())
+            .toString();
+    }
+}

zc-business/src/main/java/com/zc/business/mapper/DcMeteorologicalDetectorDataMapper.java

@@ -0,0 +1,61 @@
+package com.zc.business.mapper;
+
+import java.util.List;
+import com.zc.business.domain.DcMeteorologicalDetectorData;
+
+/**
+ * 气象检测器数据Mapper接口
+ * 
+ * @author ruoyi
+ * @date 2024-02-01
+ */
+public interface DcMeteorologicalDetectorDataMapper 
+{
+    /**
+     * 查询气象检测器数据
+     * 
+     * @param id 气象检测器数据主键
+     * @return 气象检测器数据
+     */
+    public DcMeteorologicalDetectorData selectDcMeteorologicalDetectorDataById(Long id);
+
+    /**
+     * 查询气象检测器数据列表
+     * 
+     * @param dcMeteorologicalDetectorData 气象检测器数据
+     * @return 气象检测器数据集合
+     */
+    List<DcMeteorologicalDetectorData> selectDcMeteorologicalDetectorDataList(DcMeteorologicalDetectorData dcMeteorologicalDetectorData);
+
+    /**
+     * 新增气象检测器数据
+     * 
+     * @param dcMeteorologicalDetectorData 气象检测器数据
+     * @return 结果
+     */
+    int insertDcMeteorologicalDetectorData(DcMeteorologicalDetectorData dcMeteorologicalDetectorData);
+
+    /**
+     * 修改气象检测器数据
+     * 
+     * @param dcMeteorologicalDetectorData 气象检测器数据
+     * @return 结果
+     */
+    int updateDcMeteorologicalDetectorData(DcMeteorologicalDetectorData dcMeteorologicalDetectorData);
+
+    /**
+     * 删除气象检测器数据
+     * 
+     * @param id 气象检测器数据主键
+     * @return 结果
+     */
+    int deleteDcMeteorologicalDetectorDataById(Long id);
+
+    /**
+     * 批量删除气象检测器数据
+     * 
+     * @param ids 需要删除的数据主键集合
+     * @return 结果
+     */
+    int deleteDcMeteorologicalDetectorDataByIds(Long[] ids);
+}

zc-business/src/main/java/com/zc/business/mapper/DcWeatherMonitoringMapper.java

@@ -0,0 +1,26 @@
+package com.zc.business.mapper;
+
+import com.zc.business.domain.DcMeteorologicalDetectorData;
+
+import java.util.List;
+
+/**
+ * @Description 交通气象检测Mapper接口
+ *
+ * @author liuwenge
+ * @date 2024/2/1 9:46
+ */
+public interface DcWeatherMonitoringMapper {
+
+
+    /**
+     * @Description 查询当天每个设备最新的数据
+     *
+     * @author liuwenge
+     * @date 2024/2/4 9:33
+     * @param
+     * @return java.util.List<com.zc.business.domain.DcMeteorologicalDetectorData>
+     */
+    List<DcMeteorologicalDetectorData> selectMeteorologicalDetectorData();
+
+}

zc-business/src/main/java/com/zc/business/service/IDcMeteorologicalDetectorDataService.java

@@ -0,0 +1,61 @@
+package com.zc.business.service;
+
+import java.util.List;
+import com.zc.business.domain.DcMeteorologicalDetectorData;
+
+/**
+ * 气象检测器数据Service接口
+ * 
+ * @author ruoyi
+ * @date 2024-02-01
+ */
+public interface IDcMeteorologicalDetectorDataService 
+{
+    /**
+     * 查询气象检测器数据
+     * 
+     * @param id 气象检测器数据主键
+     * @return 气象检测器数据
+     */
+    public DcMeteorologicalDetectorData selectDcMeteorologicalDetectorDataById(Long id);
+
+    /**
+     * 查询气象检测器数据列表
+     * 
+     * @param dcMeteorologicalDetectorData 气象检测器数据
+     * @return 气象检测器数据集合
+     */
+    List<DcMeteorologicalDetectorData> selectDcMeteorologicalDetectorDataList(DcMeteorologicalDetectorData dcMeteorologicalDetectorData);
+
+    /**
+     * 新增气象检测器数据
+     * 
+     * @param dcMeteorologicalDetectorData 气象检测器数据
+     * @return 结果
+     */
+    int insertDcMeteorologicalDetectorData(DcMeteorologicalDetectorData dcMeteorologicalDetectorData);
+
+    /**
+     * 修改气象检测器数据
+     * 
+     * @param dcMeteorologicalDetectorData 气象检测器数据
+     * @return 结果
+     */
+    int updateDcMeteorologicalDetectorData(DcMeteorologicalDetectorData dcMeteorologicalDetectorData);
+
+    /**
+     * 批量删除气象检测器数据
+     * 
+     * @param ids 需要删除的气象检测器数据主键集合
+     * @return 结果
+     */
+    int deleteDcMeteorologicalDetectorDataByIds(Long[] ids);
+
+    /**
+     * 删除气象检测器数据信息
+     * 
+     * @param id 气象检测器数据主键
+     * @return 结果
+     */
+    int deleteDcMeteorologicalDetectorDataById(Long id);
+}

zc-business/src/main/java/com/zc/business/service/IDcWeatherMonitoringService.java

@@ -0,0 +1,24 @@
+package com.zc.business.service;
+
+import com.ruoyi.common.core.domain.AjaxResult;
+
+/**
+ * @Description 交通气象检测Service接口
+ *
+ * @author liuwenge
+ * @date 2024/2/1 9:42
+ */
+public interface IDcWeatherMonitoringService {
+
+    /**
+     * @Description 路网交通状况
+     *
+     * @author liuwenge
+     * @date 2024/2/1 10:36
+     * @param
+     * @return com.ruoyi.common.core.domain.AjaxResult
+     */
+    AjaxResult getTrafficConditions();
+
+
+}

zc-business/src/main/java/com/zc/business/service/impl/DcMeteorologicalDetectorDataServiceImpl.java

@@ -0,0 +1,93 @@
+package com.zc.business.service.impl;
+
+import java.util.List;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import com.zc.business.mapper.DcMeteorologicalDetectorDataMapper;
+import com.zc.business.domain.DcMeteorologicalDetectorData;
+import com.zc.business.service.IDcMeteorologicalDetectorDataService;
+
+/**
+ * 气象检测器数据Service业务层处理
+ *
+ * @author ruoyi
+ * @date 2024-02-01
+ */
+@Service
+public class DcMeteorologicalDetectorDataServiceImpl implements IDcMeteorologicalDetectorDataService
+{
+    @Autowired
+    private DcMeteorologicalDetectorDataMapper dcMeteorologicalDetectorDataMapper;
+
+    /**
+     * 查询气象检测器数据
+     *
+     * @param id 气象检测器数据主键
+     * @return 气象检测器数据
+     */
+    @Override
+    public DcMeteorologicalDetectorData selectDcMeteorologicalDetectorDataById(Long id)
+    {
+        return dcMeteorologicalDetectorDataMapper.selectDcMeteorologicalDetectorDataById(id);
+    }
+
+    /**
+     * 查询气象检测器数据列表
+     *
+     * @param dcMeteorologicalDetectorData 气象检测器数据
+     * @return 气象检测器数据
+     */
+    @Override
+    public List<DcMeteorologicalDetectorData> selectDcMeteorologicalDetectorDataList(DcMeteorologicalDetectorData dcMeteorologicalDetectorData)
+    {
+        return dcMeteorologicalDetectorDataMapper.selectDcMeteorologicalDetectorDataList(dcMeteorologicalDetectorData);
+    }
+
+    /**
+     * 新增气象检测器数据
+     *
+     * @param dcMeteorologicalDetectorData 气象检测器数据
+     * @return 结果
+     */
+    @Override
+    public int insertDcMeteorologicalDetectorData(DcMeteorologicalDetectorData dcMeteorologicalDetectorData)
+    {
+        return dcMeteorologicalDetectorDataMapper.insertDcMeteorologicalDetectorData(dcMeteorologicalDetectorData);
+    }
+
+    /**
+     * 修改气象检测器数据
+     *
+     * @param dcMeteorologicalDetectorData 气象检测器数据
+     * @return 结果
+     */
+    @Override
+    public int updateDcMeteorologicalDetectorData(DcMeteorologicalDetectorData dcMeteorologicalDetectorData)
+    {
+        return dcMeteorologicalDetectorDataMapper.updateDcMeteorologicalDetectorData(dcMeteorologicalDetectorData);
+    }
+
+    /**
+     * 批量删除气象检测器数据
+     *
+     * @param ids 需要删除的气象检测器数据主键
+     * @return 结果
+     */
+    @Override
+    public int deleteDcMeteorologicalDetectorDataByIds(Long[] ids)
+    {
+        return dcMeteorologicalDetectorDataMapper.deleteDcMeteorologicalDetectorDataByIds(ids);
+    }
+
+    /**
+     * 删除气象检测器数据信息
+     *
+     * @param id 气象检测器数据主键
+     * @return 结果
+     */
+    @Override
+    public int deleteDcMeteorologicalDetectorDataById(Long id)
+    {
+        return dcMeteorologicalDetectorDataMapper.deleteDcMeteorologicalDetectorDataById(id);
+    }
+}

zc-business/src/main/java/com/zc/business/service/impl/DcWeatherMonitoringServiceImpl.java

@@ -0,0 +1,88 @@
+package com.zc.business.service.impl;
+
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.common.utils.StringUtils;
+import com.zc.business.domain.DcMeteorologicalDetectorData;
+import com.zc.business.mapper.DcWeatherMonitoringMapper;
+import com.zc.business.service.IDcWeatherMonitoringService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @Description 交通气象检测Service业务层处理
+ *
+ * @author liuwenge
+ * @date 2024/2/1 9:45
+ */
+@Service
+public class DcWeatherMonitoringServiceImpl implements IDcWeatherMonitoringService {
+
+
+    @Autowired
+    private DcWeatherMonitoringMapper weatherMonitoringMapper;
+
+
+    /**
+     * @Description 路网交通状况
+     *
+     * @author liuwenge
+     * @date 2024/2/1 10:37
+     * @param
+     * @return com.ruoyi.common.core.domain.AjaxResult
+     */
+    @Override
+    public AjaxResult getTrafficConditions(){
+
+
+        //正常路段里程
+        BigDecimal normalMileage = new BigDecimal("154.585");
+        //降水里程
+        BigDecimal rainfallMileage = BigDecimal.ZERO;
+        //团雾路段(处)
+        int heavyFogNum = 0;
+        //团雾里程
+        BigDecimal heavyFogMileage = BigDecimal.ZERO;
+        //异常数量
+        int anomalies = 0;
+        //设备数量
+        int deviceNum = 10;
+
+        //每个设备的检测范围
+        BigDecimal detectionRange = new BigDecimal("15.4585");
+
+        List<DcMeteorologicalDetectorData> dataList = weatherMonitoringMapper.selectMeteorologicalDetectorData();
+        for (DcMeteorologicalDetectorData meteorologicalDetectorData : dataList) {
+            //
+            if (StringUtils.isNotEmpty(meteorologicalDetectorData.getRainfall()) || StringUtils.isNotEmpty(meteorologicalDetectorData.getVisibilityType())){
+                BigDecimal rainfall = new BigDecimal(meteorologicalDetectorData.getRainfall());
+                if (rainfall.compareTo(BigDecimal.ZERO) > 0 || !"4".equals(meteorologicalDetectorData.getVisibilityType())){
+                    normalMileage = normalMileage.subtract(detectionRange);
+                    anomalies ++;
+                    if (rainfall.compareTo(BigDecimal.ZERO) > 0){
+                        rainfallMileage = rainfallMileage.add(detectionRange);
+                    }
+                    if (!"4".equals(meteorologicalDetectorData.getVisibilityType())){
+                        heavyFogNum ++;
+                        heavyFogMileage = heavyFogMileage.add(detectionRange);
+                    }
+                }
+            }
+        }
+
+        Map<String,Object> result = new HashMap<>();
+        result.put("normalMileage",normalMileage);
+        result.put("rainfallMileage",rainfallMileage);
+        result.put("heavyFogNum",heavyFogNum);
+        result.put("heavyFogMileage",heavyFogMileage);
+        result.put("anomalies",anomalies);
+        result.put("deviceNum",deviceNum);
+
+        return AjaxResult.success(result);
+    }
+
+}

zc-business/src/main/resources/mapper/business/DcMeteorologicalDetectorDataMapper.xml

@@ -0,0 +1,159 @@
+<?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.zc.business.mapper.DcMeteorologicalDetectorDataMapper">
+    
+    <resultMap type="DcMeteorologicalDetectorData" id="DcMeteorologicalDetectorDataResult">
+        <result property="id"    column="id"    />
+        <result property="iotDeviceId"    column="iot_device_id"    />
+        <result property="rainfall"    column="rainfall"    />
+        <result property="visibilityType"    column="visibility_type"    />
+        <result property="visibility"    column="visibility"    />
+        <result property="roadSurfaceStatus"    column="road_surface_status"    />
+        <result property="atmosphericPressure"    column="atmospheric_pressure"    />
+        <result property="temperature"    column="temperature"    />
+        <result property="humidity"    column="humidity"    />
+        <result property="windDirection"    column="wind_direction"    />
+        <result property="windSpeed"    column="wind_speed"    />
+        <result property="freezingPointTemperature"    column="freezing_point_temperature"    />
+        <result property="salinityValue"    column="salinity_value"    />
+        <result property="roadSurfaceTemperature"    column="road_surface_temperature"    />
+        <result property="waterFilmThickness"    column="water_film_thickness"    />
+        <result property="precipitationType"    column="precipitation_type"    />
+        <result property="wetSlipperyCoefficient"    column="wet_slippery_coefficient"    />
+        <result property="sensorTemperature"    column="sensor_temperature"    />
+        <result property="remoteRoadSurfaceTemperature"    column="remote_road_surface_temperature"    />
+        <result property="remoteRoadSurfaceStatus"    column="remote_road_surface_status"    />
+        <result property="subSurfaceTemperature"    column="sub_surface_temperature"    />
+        <result property="waterFilmIceSnowValue"    column="water_film_ice_snow_value"    />
+        <result property="createTime"    column="create_time"    />
+    </resultMap>
+
+    <sql id="selectDcMeteorologicalDetectorDataVo">
+        select id, iot_device_id, rainfall, visibility_type, visibility, road_surface_status, atmospheric_pressure, temperature, humidity, wind_direction, wind_speed, freezing_point_temperature, salinity_value, road_surface_temperature, water_film_thickness, precipitation_type, wet_slippery_coefficient, sensor_temperature, remote_road_surface_temperature, remote_road_surface_status, sub_surface_temperature, water_film_ice_snow_value,create_time from dc_meteorological_detector_data
+    </sql>
+
+    <select id="selectDcMeteorologicalDetectorDataList" parameterType="DcMeteorologicalDetectorData" resultMap="DcMeteorologicalDetectorDataResult">
+        <include refid="selectDcMeteorologicalDetectorDataVo"/>
+        <where>  
+            <if test="iotDeviceId != null  and iotDeviceId != ''"> and iot_device_id = #{iotDeviceId}</if>
+            <if test="rainfall != null  and rainfall != ''"> and rainfall = #{rainfall}</if>
+            <if test="visibilityType != null  and visibilityType != ''"> and visibility_type = #{visibilityType}</if>
+            <if test="visibility != null  and visibility != ''"> and visibility = #{visibility}</if>
+            <if test="roadSurfaceStatus != null  and roadSurfaceStatus != ''"> and road_surface_status = #{roadSurfaceStatus}</if>
+            <if test="atmosphericPressure != null  and atmosphericPressure != ''"> and atmospheric_pressure = #{atmosphericPressure}</if>
+            <if test="temperature != null  and temperature != ''"> and temperature = #{temperature}</if>
+            <if test="humidity != null  and humidity != ''"> and humidity = #{humidity}</if>
+            <if test="windDirection != null  and windDirection != ''"> and wind_direction = #{windDirection}</if>
+            <if test="windSpeed != null  and windSpeed != ''"> and wind_speed = #{windSpeed}</if>
+            <if test="freezingPointTemperature != null  and freezingPointTemperature != ''"> and freezing_point_temperature = #{freezingPointTemperature}</if>
+            <if test="salinityValue != null  and salinityValue != ''"> and salinity_value = #{salinityValue}</if>
+            <if test="roadSurfaceTemperature != null  and roadSurfaceTemperature != ''"> and road_surface_temperature = #{roadSurfaceTemperature}</if>
+            <if test="waterFilmThickness != null  and waterFilmThickness != ''"> and water_film_thickness = #{waterFilmThickness}</if>
+            <if test="precipitationType != null  and precipitationType != ''"> and precipitation_type = #{precipitationType}</if>
+            <if test="wetSlipperyCoefficient != null  and wetSlipperyCoefficient != ''"> and wet_slippery_coefficient = #{wetSlipperyCoefficient}</if>
+            <if test="sensorTemperature != null  and sensorTemperature != ''"> and sensor_temperature = #{sensorTemperature}</if>
+            <if test="remoteRoadSurfaceTemperature != null  and remoteRoadSurfaceTemperature != ''"> and remote_road_surface_temperature = #{remoteRoadSurfaceTemperature}</if>
+            <if test="remoteRoadSurfaceStatus != null  and remoteRoadSurfaceStatus != ''"> and remote_road_surface_status = #{remoteRoadSurfaceStatus}</if>
+            <if test="subSurfaceTemperature != null  and subSurfaceTemperature != ''"> and sub_surface_temperature = #{subSurfaceTemperature}</if>
+            <if test="waterFilmIceSnowValue != null  and waterFilmIceSnowValue != ''"> and water_film_ice_snow_value = #{waterFilmIceSnowValue}</if>
+        </where>
+    </select>
+    
+    <select id="selectDcMeteorologicalDetectorDataById" parameterType="Long" resultMap="DcMeteorologicalDetectorDataResult">
+        <include refid="selectDcMeteorologicalDetectorDataVo"/>
+        where id = #{id}
+    </select>
+        
+    <insert id="insertDcMeteorologicalDetectorData" parameterType="DcMeteorologicalDetectorData" useGeneratedKeys="true" keyProperty="id">
+        insert into dc_meteorological_detector_data
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="iotDeviceId != null">iot_device_id,</if>
+            <if test="rainfall != null">rainfall,</if>
+            <if test="visibilityType != null">visibility_type,</if>
+            <if test="visibility != null">visibility,</if>
+            <if test="roadSurfaceStatus != null">road_surface_status,</if>
+            <if test="atmosphericPressure != null">atmospheric_pressure,</if>
+            <if test="temperature != null">temperature,</if>
+            <if test="humidity != null">humidity,</if>
+            <if test="windDirection != null">wind_direction,</if>
+            <if test="windSpeed != null">wind_speed,</if>
+            <if test="freezingPointTemperature != null">freezing_point_temperature,</if>
+            <if test="salinityValue != null">salinity_value,</if>
+            <if test="roadSurfaceTemperature != null">road_surface_temperature,</if>
+            <if test="waterFilmThickness != null">water_film_thickness,</if>
+            <if test="precipitationType != null">precipitation_type,</if>
+            <if test="wetSlipperyCoefficient != null">wet_slippery_coefficient,</if>
+            <if test="sensorTemperature != null">sensor_temperature,</if>
+            <if test="remoteRoadSurfaceTemperature != null">remote_road_surface_temperature,</if>
+            <if test="remoteRoadSurfaceStatus != null">remote_road_surface_status,</if>
+            <if test="subSurfaceTemperature != null">sub_surface_temperature,</if>
+            <if test="waterFilmIceSnowValue != null">water_film_ice_snow_value,</if>
+            create_time
+         </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="iotDeviceId != null">#{iotDeviceId},</if>
+            <if test="rainfall != null">#{rainfall},</if>
+            <if test="visibilityType != null">#{visibilityType},</if>
+            <if test="visibility != null">#{visibility},</if>
+            <if test="roadSurfaceStatus != null">#{roadSurfaceStatus},</if>
+            <if test="atmosphericPressure != null">#{atmosphericPressure},</if>
+            <if test="temperature != null">#{temperature},</if>
+            <if test="humidity != null">#{humidity},</if>
+            <if test="windDirection != null">#{windDirection},</if>
+            <if test="windSpeed != null">#{windSpeed},</if>
+            <if test="freezingPointTemperature != null">#{freezingPointTemperature},</if>
+            <if test="salinityValue != null">#{salinityValue},</if>
+            <if test="roadSurfaceTemperature != null">#{roadSurfaceTemperature},</if>
+            <if test="waterFilmThickness != null">#{waterFilmThickness},</if>
+            <if test="precipitationType != null">#{precipitationType},</if>
+            <if test="wetSlipperyCoefficient != null">#{wetSlipperyCoefficient},</if>
+            <if test="sensorTemperature != null">#{sensorTemperature},</if>
+            <if test="remoteRoadSurfaceTemperature != null">#{remoteRoadSurfaceTemperature},</if>
+            <if test="remoteRoadSurfaceStatus != null">#{remoteRoadSurfaceStatus},</if>
+            <if test="subSurfaceTemperature != null">#{subSurfaceTemperature},</if>
+            <if test="waterFilmIceSnowValue != null">#{waterFilmIceSnowValue},</if>
+            current_date
+         </trim>
+    </insert>
+
+    <update id="updateDcMeteorologicalDetectorData" parameterType="DcMeteorologicalDetectorData">
+        update dc_meteorological_detector_data
+        <trim prefix="SET" suffixOverrides=",">
+            <if test="iotDeviceId != null">iot_device_id = #{iotDeviceId},</if>
+            <if test="rainfall != null">rainfall = #{rainfall},</if>
+            <if test="visibilityType != null">visibility_type = #{visibilityType},</if>
+            <if test="visibility != null">visibility = #{visibility},</if>
+            <if test="roadSurfaceStatus != null">road_surface_status = #{roadSurfaceStatus},</if>
+            <if test="atmosphericPressure != null">atmospheric_pressure = #{atmosphericPressure},</if>
+            <if test="temperature != null">temperature = #{temperature},</if>
+            <if test="humidity != null">humidity = #{humidity},</if>
+            <if test="windDirection != null">wind_direction = #{windDirection},</if>
+            <if test="windSpeed != null">wind_speed = #{windSpeed},</if>
+            <if test="freezingPointTemperature != null">freezing_point_temperature = #{freezingPointTemperature},</if>
+            <if test="salinityValue != null">salinity_value = #{salinityValue},</if>
+            <if test="roadSurfaceTemperature != null">road_surface_temperature = #{roadSurfaceTemperature},</if>
+            <if test="waterFilmThickness != null">water_film_thickness = #{waterFilmThickness},</if>
+            <if test="precipitationType != null">precipitation_type = #{precipitationType},</if>
+            <if test="wetSlipperyCoefficient != null">wet_slippery_coefficient = #{wetSlipperyCoefficient},</if>
+            <if test="sensorTemperature != null">sensor_temperature = #{sensorTemperature},</if>
+            <if test="remoteRoadSurfaceTemperature != null">remote_road_surface_temperature = #{remoteRoadSurfaceTemperature},</if>
+            <if test="remoteRoadSurfaceStatus != null">remote_road_surface_status = #{remoteRoadSurfaceStatus},</if>
+            <if test="subSurfaceTemperature != null">sub_surface_temperature = #{subSurfaceTemperature},</if>
+            <if test="waterFilmIceSnowValue != null">water_film_ice_snow_value = #{waterFilmIceSnowValue},</if>
+        </trim>
+        where id = #{id}
+    </update>
+
+    <delete id="deleteDcMeteorologicalDetectorDataById" parameterType="Long">
+        delete from dc_meteorological_detector_data where id = #{id}
+    </delete>
+
+    <delete id="deleteDcMeteorologicalDetectorDataByIds" parameterType="String">
+        delete from dc_meteorological_detector_data where id in 
+        <foreach item="id" collection="array" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </delete>
+</mapper>

zc-business/src/main/resources/mapper/business/DcWeatherMinitoringMapper.xml

@@ -0,0 +1,22 @@
+<?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.zc.business.mapper.DcWeatherMonitoringMapper">
+
+
+    <select id="selectMeteorologicalDetectorData"
+            resultType="com.zc.business.domain.DcMeteorologicalDetectorData">
+        SELECT *
+        FROM
+            dc_meteorological_detector_data
+        WHERE
+            id IN (
+                SELECT
+                    MAX( id )
+                FROM dc_meteorological_detector_data
+                where DATE_FORMAT(create_time,'%Y-%m-%d') = DATE_FORMAT(now(),'%Y-%m-%d')
+                GROUP BY iot_device_id
+            )
+    </select>
+</mapper>