增加天擎返回数据的种类

data/txt/data.txt

@@ -0,0 +1,136 @@
+{
+  "returnCode": "0",
+  "returnMessage": "Query Succeed",
+  "rowCount": "2",
+  "colCount": "59",
+  "requestParams": "timerange\u003d[20241125000000,20241125010000]\u0026staids\u003d54511\u0026elements\u003dStation_Id_C,Station_levl,Lat,Lon,Alti,Admin_Code_CHN,V_ACODE_4SEARCH,Town_code,City,Station_Name,Cnty,COUNTRYCODE,Country,NetCode,Province,REGIONCODE,Town,D_RETAIN_ID,D_SOURCE_ID,DATA_ID,IYMDHM,RYMDHM,UPDATE_TIME,Datetime,REP_CORR_ID,Station_Id_d,Year,Mon,Day,Hour,Min,V14311,V14312,V14313,V14314,V14315,V14316,V14320,QRA_Max,QRA_Max_OTime,V14308,NRA_Max,NRA_Max_OTime,NRA_Min,NRA_Min_OTime,V14322,DRA_Max,DRA_Max_OTime,V14309,SRA_Max,SRA_Max_OTime,V14306,RRA_Max,RRA_Max_OTime,V14307,V14316_05,UV_Max_OTime,SSH,API\u0026datacode\u003dRADI_CHN_MUL_HOR",
+  "requestTime": "2024-11-27 03:22:07",
+  "responseTime": "2024-11-27 03:22:07",
+  "takeTime": "0.052",
+  "fieldNames": "区站号(字符),测站级别,纬度,经度,测站高度,行政编码,行政编码2,镇编码,地市名,站名,区县名,国家代码,国家名称,站网代码,省名,区域代码,乡镇名,记录标识,数据来源,资料标识,入库时间,收到时间,更新时间,资料时间,更正报标志,区站号/观测平台标识(数字),年,月,日,时,分,总辐射辐照度,净辐射辐照度,直接辐射辐照度,散射辐射辐照度,反射辐射辐照度,紫外辐射辐照度,总辐射曝辐量,总辐射辐照度最大值,总辐射辐照度最大出现时间,净辐射曝辐量,净辐射辐照度最大值,净辐射辐照度最大出现时间,净辐射辐照度最小值,净辐射辐照度最小出现时间,直接辐射曝辐量,直接辐射辐照度最大值,直接辐射辐照度最大出现时间,散射辐射曝辐量,散射辐射辐照度最大值,散射辐射辐照度最大出现时间,反射辐射曝辐量,反射辐射辐照度最大值,反射辐射辐照度最大出现时间,紫外辐射曝辐量,紫外辐射辐照度最大值,紫外辐射辐照度最大出现时间,日照时数（直接辐射计算值）,大气浑浊度",
+  "fieldUnits": "null",
+  "DS": [
+    {
+      "Station_Id_C": "54511",
+      "Station_levl": "999999",
+      "Lat": "39.8061",
+      "Lon": "116.4694",
+      "Alti": "32.8",
+      "Admin_Code_CHN": "999999",
+      "V_ACODE_4SEARCH": "999999",
+      "Town_code": "",
+      "City": "",
+      "Station_Name": "",
+      "Cnty": "",
+      "COUNTRYCODE": "",
+      "Country": "",
+      "NetCode": "",
+      "Province": "",
+      "REGIONCODE": "",
+      "Town": "",
+      "D_RETAIN_ID": "",
+      "D_SOURCE_ID": "D.0001.0007.R001_Z_RADI_C_BEPK_20241124161521_O_ARS_FTM_PQC.BIN",
+      "DATA_ID": "D.0003.0001.S001",
+      "IYMDHM": "2024-11-24 16:15:47",
+      "RYMDHM": "2024-11-24 16:15:46",
+      "UPDATE_TIME": "2024-11-24 16:15:46",
+      "Datetime": "2024-11-25 00:00:00",
+      "REP_CORR_ID": "000",
+      "Station_Id_d": "54511",
+      "Year": "2024",
+      "Mon": "11",
+      "Day": "25",
+      "Hour": "0",
+      "Min": "0",
+      "V14311": "0",
+      "V14312": "-49",
+      "V14313": "0",
+      "V14314": "0",
+      "V14315": "0",
+      "V14316": "999999",
+      "V14320": "0",
+      "QRA_Max": "0",
+      "QRA_Max_OTime": "2301",
+      "V14308": "-0.18",
+      "NRA_Max": "-48",
+      "NRA_Max_OTime": "2312",
+      "NRA_Min": "-52",
+      "NRA_Min_OTime": "2351",
+      "V14322": "0",
+      "DRA_Max": "0",
+      "DRA_Max_OTime": "2301",
+      "V14309": "0",
+      "SRA_Max": "0",
+      "SRA_Max_OTime": "2301",
+      "V14306": "0",
+      "RRA_Max": "0",
+      "RRA_Max_OTime": "2301",
+      "V14307": "999999",
+      "V14316_05": "999999",
+      "UV_Max_OTime": "999999",
+      "SSH": "999999",
+      "API": "999999"
+    },
+    {
+      "Station_Id_C": "54511",
+      "Station_levl": "999999",
+      "Lat": "39.8061",
+      "Lon": "116.4694",
+      "Alti": "32.8",
+      "Admin_Code_CHN": "999999",
+      "V_ACODE_4SEARCH": "999999",
+      "Town_code": "",
+      "City": "",
+      "Station_Name": "",
+      "Cnty": "",
+      "COUNTRYCODE": "",
+      "Country": "",
+      "NetCode": "",
+      "Province": "",
+      "REGIONCODE": "",
+      "Town": "",
+      "D_RETAIN_ID": "",
+      "D_SOURCE_ID": "D.0001.0007.R001_Z_RADI_C_BEPK_20241124171528_O_ARS_FTM_PQC.BIN",
+      "DATA_ID": "D.0003.0001.S001",
+      "IYMDHM": "2024-11-24 17:15:47",
+      "RYMDHM": "2024-11-24 17:15:46",
+      "UPDATE_TIME": "2024-11-26 02:00:52",
+      "Datetime": "2024-11-25 01:00:00",
+      "REP_CORR_ID": "000",
+      "Station_Id_d": "54511",
+      "Year": "2024",
+      "Mon": "11",
+      "Day": "25",
+      "Hour": "1",
+      "Min": "0",
+      "V14311": "0",
+      "V14312": "-44",
+      "V14313": "0",
+      "V14314": "0",
+      "V14315": "0",
+      "V14316": "999999",
+      "V14320": "0",
+      "QRA_Max": "0",
+      "QRA_Max_OTime": "1",
+      "V14308": "-0.17",
+      "NRA_Max": "-44",
+      "NRA_Max_OTime": "100",
+      "NRA_Min": "-49",
+      "NRA_Min_OTime": "1",
+      "V14322": "0",
+      "DRA_Max": "0",
+      "DRA_Max_OTime": "1",
+      "V14309": "0",
+      "SRA_Max": "0",
+      "SRA_Max_OTime": "1",
+      "V14306": "0",
+      "RRA_Max": "0",
+      "RRA_Max_OTime": "1",
+      "V14307": "999999",
+      "V14316_05": "999999",
+      "UV_Max_OTime": "999999",
+      "SSH": "999999",
+      "API": "999999"
+    }
+  ]
+}

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

@@ -14,6 +14,7 @@ import org.springframework.boot.test.context.SpringBootTest;
 import java.io.FileNotFoundException;
 import java.util.ArrayList;
 import java.util.Calendar;
+import java.util.Date;
 
 @SpringBootTest
 @Slf4j
@@ -28,7 +29,7 @@ class SolarenergyApplicationTests {
 
     @Test
     public void cal(){
-        String s = solarenergyService.calSolarRadiation(RasterSolarRadiationOperation.SolarEadiationAnalysisType.DAY_TOTAL_SOLARRADIATION_AMOUNT, Calendar.getInstance(), 0, 2000);
+        String s = solarenergyService.calSolarRadiation(RasterSolarRadiationOperation.SolarEadiationAnalysisType.DAY_TOTAL_SOLARRADIATION_AMOUNT, Calendar.getInstance(), 0, 1000);
         System.out.println(s);
     }
 
@@ -44,18 +45,93 @@ class SolarenergyApplicationTests {
             MusicQueryParameters musicQueryParameters = new MusicQueryParameters("RADI","RADI_CHN_MUL_HOR");
             log.debug("2---接口查询参数");
             //3、设置查询时间，可设置时间段
-            musicQueryParameters.setTimes("20241126080000");
+//            musicQueryParameters.setTimes("20241126080000");
+            Calendar start = Calendar.getInstance();
+            start.set(2024,Calendar.NOVEMBER, 25,00,00,00);
+            Calendar end = Calendar.getInstance();
+            end.set(2024,Calendar.NOVEMBER, 25,01,00,00);
+            musicQueryParameters.setTimeRange(start.getTime(),"[",end.getTime(), "]");
+            musicQueryParameters.setStaIds("54511");
             ArrayList<String> objects = new ArrayList<>();
+//            objects.add("Station_Id_C");
+//            objects.add("Lat");
+//            objects.add("Lon");
+//            objects.add("V14311");
+//            objects.add("SSH");
+
             objects.add("Station_Id_C");
+            objects.add("Station_levl");
             objects.add("Lat");
             objects.add("Lon");
+            objects.add("Alti");
+            objects.add("Admin_Code_CHN");
+            objects.add("V_ACODE_4SEARCH");
+            objects.add("Town_code");
+            objects.add("City");
+            objects.add("Station_Name");
+            objects.add("Cnty");
+            objects.add("COUNTRYCODE");
+            objects.add("Country");
+            objects.add("NetCode");
+            objects.add("Province");
+            objects.add("REGIONCODE");
+            objects.add("Town");
+            objects.add("D_RETAIN_ID");
+            objects.add("D_SOURCE_ID");
+            objects.add("DATA_ID");
+            objects.add("IYMDHM");
+            objects.add("RYMDHM");
+            objects.add("UPDATE_TIME");
+            objects.add("Datetime");
+            objects.add("REP_CORR_ID");
+            objects.add("Station_Id_d");
+            objects.add("Year");
+            objects.add("Mon");
+            objects.add("Day");
+            objects.add("Hour");
+            objects.add("Min");
             objects.add("V14311");
+            objects.add("V14312");
+            objects.add("V14313");
+            objects.add("V14314");
+            objects.add("V14315");
+            objects.add("V14316");
+            objects.add("V14320");
+            objects.add("QRA_Max");
+            objects.add("QRA_Max_OTime");
+            objects.add("V14308");
+            objects.add("NRA_Max");
+            objects.add("NRA_Max_OTime");
+            objects.add("NRA_Min");
+            objects.add("NRA_Min_OTime");
+            objects.add("V14322");
+            objects.add("DRA_Max");
+            objects.add("DRA_Max_OTime");
+            objects.add("V14309");
+            objects.add("SRA_Max");
+            objects.add("SRA_Max_OTime");
+            objects.add("V14306");
+            objects.add("RRA_Max");
+            objects.add("RRA_Max_OTime");
+            objects.add("V14307");
+            objects.add("V14316_05");
+            objects.add("UV_Max_OTime");
             objects.add("SSH");
+            objects.add("API");
+
             musicQueryParameters.setElements(objects);
 
             log.debug("3---设置时间及区号");
             //开始查询
             String dataByMusic = radifEleInterface.queryDataByMusic(musicQueryParameters);
+
+
+
+            // 入库
+            int count = addDataBase(dataByMusic);
+
+
+
             log.debug("4---查询结束");
             log.debug("查询结果长度：" + dataByMusic.length());
         } catch (FileNotFoundException e) {
@@ -64,10 +140,12 @@ class SolarenergyApplicationTests {
         } catch (MusicConfigException e) {
             //无效的配置文件
             log.error("Error2:" + e.getMessage());
-        } catch (InvalidInterfaceParametersException e) {
+        }
-            //无效的接口参数据错误
+//        catch (InvalidInterfaceParametersException e) {
-            log.error("Error3:" + e.getMessage());
+//            //无效的接口参数据错误
-        } catch (InterfaceParameterMismatchException e) {
+//            log.error("Error3:" + e.getMessage());
+//        }
+        catch (InterfaceParameterMismatchException e) {
             //查询接口参数据错误
             log.error("Error4:" + e.getMessage());
         } catch (MusicInterfaceException e) {
@@ -85,4 +163,21 @@ class SolarenergyApplicationTests {
             log.error("Error6:要素代码不正确" + e.getMessage());
         }
     }
+
+    private int addDataBase(String dataByMusic) {
+        // 将 dataByMusic 转换成对应的类
+        // 将所有数据写入数据库
+
+        return 0;
+    }
+
+
 }
+
+
+
+
+
+
+
+