src/main/java/com/cuit/solarenergy/controller/DataController.java

@@ -2,12 +2,14 @@ package com.cuit.solarenergy.controller;
 
 import com.cuit.solarenergy.base.annotation.AopLog;
 import com.cuit.solarenergy.base.annotation.AuthToken;
-import com.cuit.solarenergy.entity.*;
+import com.cuit.solarenergy.entity.BaseMapVoRet;
-import com.cuit.solarenergy.entity.vo.ret.ElementValueRet;
+import com.cuit.solarenergy.entity.MonitorRet;
+import com.cuit.solarenergy.entity.TGeoserverinfo;
 import com.cuit.solarenergy.entity.vo.ret.RetResponse;
 import com.cuit.solarenergy.entity.vo.ret.RetResult;
 import com.cuit.solarenergy.exception.ParamsException;
 import com.cuit.solarenergy.service.DataImportService;
+import com.cuit.solarenergy.utils.ErrorMessage;
 import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
 import com.github.xiaoymin.knife4j.annotations.ApiSupport;
 import io.swagger.annotations.Api;
@@ -19,7 +21,9 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestPart;
 import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
 
 import java.util.List;
 
@@ -161,10 +165,10 @@ public class DataController {
             @ApiResponse(code = 500, message = "服务器内部错误"),
             @ApiResponse(code = 900, message = "失败")
     })
-    public RetResult<List<ElementRet>> getElementInfo() {
+    public RetResult<List<String>> getElementInfo() {
         try {
             log.info("查询要素详情");
-            List<ElementRet> element = dataImportService.getElementInfo();
+            List<String> element = dataImportService.getElementInfo();
             return RetResponse.makeOKRsp(element);
         }catch (ParamsException e){
             return RetResponse.makeErrRsp("查询要素失败！"+e.getMessage());
@@ -183,10 +187,10 @@ public class DataController {
             @ApiResponse(code = 500, message = "服务器内部错误"),
             @ApiResponse(code = 900, message = "失败")
     })
-    public RetResult<List<ElementValue>> getValueByElement(String Element) {
+    public RetResult<List<String>> getValueByElement(String Element) {
         try {
             log.info("根据要素详情查询具体值");
-            List<ElementValue> value = dataImportService.getValueByElement(Element);
+            List<String> value = dataImportService.getValueByElement(Element);
             return RetResponse.makeOKRsp(value);
         }catch (ParamsException e){
             return RetResponse.makeErrRsp("查询数据失败！"+e.getMessage());
@@ -214,7 +218,7 @@ public class DataController {
             return RetResponse.makeErrRsp("查询监测点详情失败！"+e.getMessage());
         }
     }
-    @AopLog
+         @AopLog
     @AuthToken
     @ApiOperation("9、获取数据时间")
     @PreAuthorize("hasAuthority('minio:upload')")
@@ -236,26 +240,4 @@ public class DataController {
             return RetResponse.makeErrRsp("获取当前时间失败！"+e.getMessage());
         }
     }
-        @AopLog
-    @AuthToken
-    @ApiOperation("10、获取要素状态")
-    @PreAuthorize("hasAuthority('minio:upload')")
-    @RequestMapping(value = "/dataimport/getElementStatus", method = {RequestMethod.GET})
-    @ApiResponses({
-            @ApiResponse(code = 200, message = "成功"),
-            @ApiResponse(code = 401, message = "访问未经授权"),
-            @ApiResponse(code = 403, message = "访问被禁止的"),
-            @ApiResponse(code = 404, message = "未找到访问接口"),
-            @ApiResponse(code = 500, message = "服务器内部错误"),
-            @ApiResponse(code = 900, message = "失败")
-    })
-    public RetResult<List<ElementValueRet>> getElementStatus(String element) {
-        try {
-            log.info("获取当前要素状态");
-            List<ElementValueRet> currentTime = dataImportService.getElementStatus(element);
-            return RetResponse.makeOKRsp(currentTime);
-        }catch (ParamsException e){
-            return RetResponse.makeErrRsp("获取当前时间失败！"+e.getMessage());
-        }
-    }
 }

src/main/java/com/cuit/solarenergy/entity/ElementRet.java

@@ -1,52 +0,0 @@
-package com.cuit.solarenergy.entity;
-
-import com.baomidou.mybatisplus.annotation.TableField;
-import io.swagger.annotations.ApiModel;
-import io.swagger.annotations.ApiModelProperty;
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-@Data
-@Builder
-@AllArgsConstructor
-@NoArgsConstructor
-@ApiModel(description = "要素返回类")
-public class ElementRet {
-    /**
-     * 总辐射辐照度 W.m-2
-     */
-    @ApiModelProperty(value = "总辐射辐照度 W.m-2")
-    @TableField(value = "V14311")
-    private String 总辐射辐照度;
-
-    /**
-     * 净辐射辐照度 W.m-2
-     */
-    @ApiModelProperty(value = "净辐射辐照度 W.m-2")
-    @TableField(value = "V14312")
-    private String 净辐射辐照度 ;
-
-    /**
-     * 直接辐射辐照度 W.m-2
-     */
-    @ApiModelProperty(value = "直接辐射辐照度 W.m-2")
-    @TableField(value = "V14313")
-    private String 直接辐射辐照度;
-
-    /**
-     * 散射辐射辐照度 W.m-2
-     */
-    @ApiModelProperty(value = "散射辐射辐照度 W.m-2")
-    @TableField(value = "V14314")
-    private String 散射辐射辐照度;
-
-    /**
-     * 反射辐射辐照度 W.m-2
-     */
-    @ApiModelProperty(value = "反射辐射辐照度 W.m-2")
-    @TableField(value = "V14315")
-    private String 反射辐射辐照度;
-
-}

src/main/java/com/cuit/solarenergy/entity/ElementValue.java

@@ -1,38 +0,0 @@
-package com.cuit.solarenergy.entity;
-
-import com.baomidou.mybatisplus.annotation.TableField;
-import io.swagger.annotations.ApiModel;
-import io.swagger.annotations.ApiModelProperty;
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-@Data
-@Builder
-@AllArgsConstructor
-@NoArgsConstructor
-@ApiModel(description = "要素值返回类")
-public class ElementValue {
-    /**
-     * 区站号
-     */
-    @TableField(value = "Station_Id_C")
-    private String stationIdC;
-    /**
-     * 纬度 °
-     */
-    @TableField(value = "Lat")
-    private String lat;
-
-    /**
-     * 经度 °
-     */
-    @TableField(value = "Lon")
-    private String lon;
-     /**
-     * 要素值
-     */
-    @ApiModelProperty(value = "要素值")
-    private String elementvalue;
-}

src/main/java/com/cuit/solarenergy/entity/vo/ret/ElementValueRet.java

@@ -1,47 +0,0 @@
-package com.cuit.solarenergy.entity.vo.ret;
-
-
-import com.baomidou.mybatisplus.annotation.TableField;
-import io.swagger.annotations.ApiModel;
-import io.swagger.annotations.ApiModelProperty;
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-@Data
-@Builder
-@AllArgsConstructor
-@NoArgsConstructor
-@ApiModel(description = "要素值状态返回类")
-public class ElementValueRet {
-    /**
-     * 区站号
-     */
-    @ApiModelProperty(value = "站点名")
-    @TableField(value = "Station_Id_C")
-    private String stationIdC;
-    /**
-     * 纬度 °
-     */
-    @ApiModelProperty(value = "纬度")
-    @TableField(value = "Lat")
-    private String lat;
-
-    /**
-     * 经度 °
-     */
-    @ApiModelProperty(value = "经度")
-    @TableField(value = "Lon")
-    private String lon;
-     /**
-     * 要素值
-     */
-    @ApiModelProperty(value = "要素值")
-    private String elementvalue;
-    /**
-     * 状态
-     */
-    @ApiModelProperty(value = "状态")
-    private String status;
-}

src/main/java/com/cuit/solarenergy/mapper/TSamplingDataDetailsMapper.java

@@ -2,7 +2,6 @@ package com.cuit.solarenergy.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import com.cuit.solarenergy.entity.ElementValue;
 import com.cuit.solarenergy.entity.MapService;
 import com.cuit.solarenergy.entity.TSamplingDataDetails;
 import com.cuit.solarenergy.entity.vo.req.MultiRSDetectionReq;
@@ -106,20 +105,6 @@ public interface TSamplingDataDetailsMapper extends BaseMapper<TSamplingDataDeta
 
 
     List<YearAndCountVoRet> getAllInfoForThreeYear(String streamName);
-
-    /**
-     * @Description: 根据元素名称查询元素值
-     * @param element
-     * @return
-     */
-    List<ElementValue> getValueByElement(String element);
-
-    /**
-     * @Description: 根据元素名称查询元素值状态
-     * @param mappedElementCode
-     * @return
-     */
-    List<ElementValueRet> getElementStatus(String mappedElementCode);
 }
 
 

src/main/java/com/cuit/solarenergy/mapper/radi_chn_mul_horMapper.java

@@ -2,26 +2,18 @@ package com.cuit.solarenergy.mapper;
 
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.cuit.solarenergy.entity.ElementRet;
+import generator.domain.radi_chn_mul_hor;
-import com.cuit.solarenergy.entity.radi_chn_mul_hor;
 import org.apache.ibatis.annotations.Mapper;
 
-import java.util.List;
-
 /**
 * @author 田俊彪
 * @description 针对表【radi_chn_mul_hor】的数据库操作Mapper
 * @createDate 2024-11-27 14:23:48
-* @Entity com.cuit.solarenergy.entity.radi_chn_mul_hor
+* @Entity generator.domain.radi_chn_mul_hor
 */
 @Mapper
 public interface radi_chn_mul_horMapper extends BaseMapper<radi_chn_mul_hor> {
 
-    /**
-     * 查询要素详情
-     * @return
-     */
-    List<ElementRet> getElementInfo();
 }
 
 

src/main/java/com/cuit/solarenergy/service/DataImportService.java

@@ -1,8 +1,9 @@
 package com.cuit.solarenergy.service;
 
 
-import com.cuit.solarenergy.entity.*;
+import com.cuit.solarenergy.entity.BaseMapVoRet;
-import com.cuit.solarenergy.entity.vo.ret.ElementValueRet;
+import com.cuit.solarenergy.entity.MonitorRet;
+import com.cuit.solarenergy.entity.TGeoserverinfo;
 import org.springframework.stereotype.Service;
 import org.springframework.web.multipart.MultipartFile;
 
@@ -102,17 +103,16 @@ public interface DataImportService {
 
     /**
      * 获取要素信息
-     *
      * @return
      */
-    List<ElementRet> getElementInfo();
+    List<String> getElementInfo();
 
     /**
      * 根据要素详情查询具体值
      * @param element
      * @return
      */
-    List<ElementValue> getValueByElement(String element);
+    List<String> getValueByElement(String element);
 
     /**
      * 监测排序
@@ -132,11 +132,4 @@ public interface DataImportService {
      * @return
      */
     List<BaseMapVoRet> getBaseMapList();
-
-    /**
-     * 获取要素状态
-     * @return
-     */
-    List<ElementValueRet> getElementStatus(String element);
-
 }

src/main/java/com/cuit/solarenergy/service/impl/DataImportServiceImpl.java

@@ -8,15 +8,15 @@ import com.alibaba.excel.read.metadata.ReadSheet;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
 import com.baomidou.mybatisplus.core.toolkit.StringUtils;
+import com.beust.jcommander.internal.Nullable;
+import com.cuit.mete.geoserver.GeoServerConfig;
 import com.cuit.solarenergy.config.LayerDispConfig;
 import com.cuit.solarenergy.config.MyGeoServerConfig;
 import com.cuit.solarenergy.entity.*;
-import com.cuit.solarenergy.entity.vo.ret.ElementValueRet;
 import com.cuit.solarenergy.exception.ParamsException;
 import com.cuit.solarenergy.mapper.TGeoserverinfoMapper;
 import com.cuit.solarenergy.mapper.TSamplingDataDetailsMapper;
 import com.cuit.solarenergy.mapper.TSiteBaseInfoMapper;
-import com.cuit.solarenergy.mapper.radi_chn_mul_horMapper;
 import com.cuit.solarenergy.model.poi.listener.ExcelUtil;
 import com.cuit.solarenergy.model.poi.listener.ImportExcelListener;
 import com.cuit.solarenergy.model.poi.listener.head.DataManageExcelModel;
@@ -67,9 +67,6 @@ public class DataImportServiceImpl implements DataImportService {
     LayerDispConfig layerDispConfig;
     @Autowired
     MyGeoServerConfig mygeoServerConfig;
-    @Autowired
-    radi_chn_mul_horMapper radichnmulhorMapper;
-
 
 
 
@@ -464,10 +461,14 @@ public class DataImportServiceImpl implements DataImportService {
     }
 
     @Override
-    public List<ElementRet> getElementInfo() {
+    public List<String> getElementInfo() {
         try {
-            List<ElementRet> elementInfo = new ArrayList<>();
+            List<String> elementInfo = new ArrayList<>();
-            elementInfo = radichnmulhorMapper.getElementInfo();
+            elementInfo.add("辐射最大值");
+            elementInfo.add("辐射最小值");
+            elementInfo.add("紫外线最大值");
+            elementInfo.add("紫外线最小值");
+            elementInfo.add("日辐射量");
             return elementInfo;
         }catch (ParamsException e){
             return null;
@@ -475,30 +476,34 @@ public class DataImportServiceImpl implements DataImportService {
     }
 
     @Override
-    public List<ElementValue> getValueByElement(String element) {
+    public List<String> getValueByElement(String element) {
-       Map<String, String> elementMap = new HashMap<String, String>() {{
+        List retValue;
-        put("总辐射辐照度", "V14311");
+        try {
-        put("净辐射辐照度", "V14312");
+            retValue = new ArrayList<>();
-        put("直接辐射辐照度", "V14313");
+            switch (element) {
-        put("散射辐射辐照度", "V14314");
+                case "辐射最大值":
-        put("反射辐射辐照度", "V14315");
+                    retValue.add(10);
-    }};
+                    break;
-
+                case "辐射最小值":
-   try {
+                    retValue.add(1);
-        List<ElementValue> retValue = new ArrayList<>();
+                    break;
-        // 检查传入的中文element是否在映射关系中
+                case "紫外线最大值":
-        String mappedElementCode = elementMap.get(element);
+                    retValue.add(20);
-        if (mappedElementCode != null) {
+                    break;
-            // 如果在映射关系中，使用对应的英文代码去查询数据库
+                case "紫外线最小值":
-            retValue = tSamplingDataDetailsMapper.getValueByElement(element); // 这里传入的是中文元素名称
+                    retValue.add(2);
-        }
+                    break;
-        if (retValue != null && !retValue.isEmpty()) {
+                case "日辐射量":
-            return retValue;
+                    retValue.add(5);
+                    break;
+                default:
+                    retValue = null;
+                    break;
+            }
+        } catch (ParamsException e) {
+            return null;
         }
-    } catch (ParamsException e) {
+        return retValue;
-        throw new RuntimeException("Failed to get element info", e);
-    }
-    return null;
     }
 
     @Override
@@ -584,41 +589,6 @@ public class DataImportServiceImpl implements DataImportService {
         return baseMapVoRetList;
     }
 
-    @Override
-    public List<ElementValueRet> getElementStatus(String element) {
-     Map<String, String> elementMap = new HashMap<String, String>() {{
-        put("总辐射辐照度", "V14311");
-        put("净辐射辐照度", "V14312");
-        put("直接辐射辐照度", "V14313");
-        put("散射辐射辐照度", "V14314");
-        put("反射辐射辐照度", "V14315");
-    }};
-
-    try {
-        List<ElementValueRet> retValue = new ArrayList<>();
-        // 检查传入的中文element是否在映射关系中
-        String mappedElementCode = elementMap.get(element);
-        if (mappedElementCode == null) {
-            // 如果映射关系中没有对应的代码，返回空列表或者抛出异常
-            return retValue; // 或者抛出一个自定义异常
-        }
-        // 如果在映射关系中，使用对应的英文代码去查询数据库
-        List<ElementValueRet> dbValues = tSamplingDataDetailsMapper.getElementStatus(mappedElementCode);
-        if (dbValues != null) {
-            for (ElementValueRet value : dbValues) {
-                if (value != null) {
-                    // 设置status为"正常"
-                    value.setStatus("正常");
-                    retValue.add(value);
-                }
-            }
-        }
-        return retValue;
-    } catch (ParamsException e) {
-        throw new RuntimeException("Failed to get element info", e);
-    }
-    }
-
     private String getURL(TGeoserverinfo geoBasedatageoserverinfo) {
         String url = "";
         String geoServerURL = "";

src/main/java/com/cuit/solarenergy/service/impl/radi_chn_mul_horServiceImpl.java

@@ -1,7 +1,7 @@
 package com.cuit.solarenergy.service.impl;
 
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.cuit.solarenergy.entity.radi_chn_mul_hor;
+import generator.domain.radi_chn_mul_hor;
 import com.cuit.solarenergy.service.radi_chn_mul_horService;
 import com.cuit.solarenergy.mapper.radi_chn_mul_horMapper;
 import org.springframework.stereotype.Service;

src/main/java/com/cuit/solarenergy/service/radi_chn_mul_horService.java

@@ -1,6 +1,6 @@
 package com.cuit.solarenergy.service;
 
-import com.cuit.solarenergy.entity.radi_chn_mul_hor;
+import generator.domain.radi_chn_mul_hor;
 import com.baomidou.mybatisplus.extension.service.IService;
 
 /**

src/main/java/generator/domain/radi_chn_mul_hor.java

@@ -1,4 +1,4 @@
-package com.cuit.solarenergy.entity;
+package generator.domain;
 
 import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableField;

src/main/resources/mapper/TSamplingDataDetailsMapper.xml

@@ -339,52 +339,6 @@
         ORDER BY
             year;
     </select>
-    <select id="getValueByElement" resultType="com.cuit.solarenergy.entity.ElementValue">
-     <choose>
-        <when test="_parameter == '总辐射辐照度'">
-            SELECT Station_Id_C, Lat, Lon, V14311 AS ElementValue
-        </when>
-        <when test="_parameter == '净辐射辐照度'">
-            SELECT Station_Id_C, Lat, Lon, V14312 AS ElementValue
-        </when>
-        <when test="_parameter == '直接辐射辐照度'">
-            SELECT Station_Id_C, Lat, Lon, V14313 AS ElementValue
-        </when>
-        <when test="_parameter == '散射辐射辐照度'">
-            SELECT Station_Id_C, Lat, Lon, V14314 AS ElementValue
-        </when>
-        <when test="_parameter == '反射辐射辐照度'">
-            SELECT Station_Id_C, Lat, Lon, V14315 AS ElementValue
-        </when>
-        <otherwise>
-            SELECT Station_Id_C, Lat, Lon, V14311 AS ElementValue, V14312 AS ElementValue, V14313 AS ElementValue, V14314 AS ElementValue, V14315 AS ElementValue
-        </otherwise>
-    </choose>
-    FROM radi_chn_mul_hor
-    </select>
-    <select id="getElementStatus" resultType="com.cuit.solarenergy.entity.vo.ret.ElementValueRet">
-        <choose>
-        <when test="_parameter == '总辐射辐照度'">
-            SELECT Station_Id_C, Lat, Lon, V14311 AS ElementValue
-        </when>
-        <when test="_parameter == '净辐射辐照度'">
-            SELECT Station_Id_C, Lat, Lon, V14312 AS ElementValue
-        </when>
-        <when test="_parameter == '直接辐射辐照度'">
-            SELECT Station_Id_C, Lat, Lon, V14313 AS ElementValue
-        </when>
-        <when test="_parameter == '散射辐射辐照度'">
-            SELECT Station_Id_C, Lat, Lon, V14314 AS ElementValue
-        </when>
-        <when test="_parameter == '反射辐射辐照度'">
-            SELECT Station_Id_C, Lat, Lon, V14315 AS ElementValue
-        </when>
-        <otherwise>
-            SELECT Station_Id_C, Lat, Lon, V14311 AS ElementValue, V14312 AS ElementValue, V14313 AS ElementValue, V14314 AS ElementValue, V14315 AS ElementValue
-        </otherwise>
-    </choose>
-    FROM radi_chn_mul_hor
-    </select>
 
 
     <!-- 数据管理模块编辑接口-->

src/main/resources/mapper/radi_chn_mul_horMapper.xml

@@ -4,7 +4,7 @@
         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.cuit.solarenergy.mapper.radi_chn_mul_horMapper">
 
-    <resultMap id="BaseResultMap" type="com.cuit.solarenergy.entity.radi_chn_mul_hor">
+    <resultMap id="BaseResultMap" type="generator.domain.radi_chn_mul_hor">
             <id property="id" column="id" jdbcType="INTEGER"/>
             <result property="station_Id_C" column="Station_Id_C" jdbcType="VARCHAR"/>
             <result property="station_levl" column="Station_levl" jdbcType="VARCHAR"/>
@@ -89,8 +89,4 @@
         RRA_Max_OTime,V14307,V14316_05,
         UV_Max_OTime,SSH,API
     </sql>
-    <select id="getElementInfo" resultType="com.cuit.solarenergy.entity.ElementRet">
-        SELECT V14311 AS '总辐射辐照度', V14312 AS '净辐射辐照度', V14313 AS '直接辐射辐照度', V14314 AS '散射辐射辐照度', V14315 AS '反射辐射辐照度'
-        FROM radi_chn_mul_hor LIMIT 1
-    </select>
 </mapper>

src/test/java/com/cuit/solarenergy/SolarenergyApplicationTests.java

@@ -2,13 +2,16 @@ package com.cuit.solarenergy;
 
 import com.cuit.solarenergy.service.radi_chn_mul_horService;
 import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.DeserializationFeature;
+import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.cuit.gis.analysis.solarradiation.RasterSolarRadiationOperation;
 import com.cuit.mete.musicutil.MusicQueryParameters;
 import com.cuit.mete.musicutil.RadifEleInterface;
+import com.cuit.mete.musicutil.SurfEleInterface;
 import com.cuit.mete.musicutil.exception.*;
 import com.cuit.solarenergy.service.SolarenergyService;
-import com.cuit.solarenergy.entity.radi_chn_mul_hor;
+import generator.domain.radi_chn_mul_hor;
 import lombok.extern.slf4j.Slf4j;
 import org.junit.jupiter.api.Test;
 import org.springframework.beans.factory.annotation.Autowired;