|
|
|
@ -1,5 +1,7 @@
|
|
|
|
|
package com.cuit.solarenergy;
|
|
|
|
|
|
|
|
|
|
import com.cuit.solarenergy.service.DataImportService;
|
|
|
|
|
import com.cuit.solarenergy.service.GeoServerPubService;
|
|
|
|
|
import com.cuit.solarenergy.service.radi_chn_mul_horService;
|
|
|
|
|
import com.fasterxml.jackson.core.type.TypeReference;
|
|
|
|
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
|
|
|
@ -28,6 +30,11 @@ class SolarenergyApplicationTests {
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
radi_chn_mul_horService radiChnMulHorService;
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
GeoServerPubService geoServerPubService;
|
|
|
|
|
@Autowired
|
|
|
|
|
private DataImportService dataImportService;
|
|
|
|
|
@Test
|
|
|
|
|
void contextLoads() {
|
|
|
|
|
}
|
|
|
|
@ -54,9 +61,9 @@ class SolarenergyApplicationTests {
|
|
|
|
|
//3、设置查询时间,可设置时间段
|
|
|
|
|
// musicQueryParameters.setTimes("20241126080000");
|
|
|
|
|
Calendar start = Calendar.getInstance();
|
|
|
|
|
start.set(2024,Calendar.NOVEMBER, 20,00,00,00);
|
|
|
|
|
start.set(2024,Calendar.NOVEMBER, 25,01,00,00);
|
|
|
|
|
Calendar end = Calendar.getInstance();
|
|
|
|
|
end.set(2024,Calendar.NOVEMBER, 25,01,00,00);
|
|
|
|
|
end.set(2024,Calendar.NOVEMBER, 25,23,00,00);
|
|
|
|
|
musicQueryParameters.setTimeRange(start.getTime(),"[",end.getTime(), "]");
|
|
|
|
|
musicQueryParameters.setStaIds("54511");
|
|
|
|
|
ArrayList<String> objects = new ArrayList<>();
|
|
|
|
@ -67,64 +74,64 @@ class SolarenergyApplicationTests {
|
|
|
|
|
// 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");
|
|
|
|
|
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);
|
|
|
|
|
|
|
|
|
@ -203,6 +210,140 @@ class SolarenergyApplicationTests {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// @Test
|
|
|
|
|
// public void test222222222(){
|
|
|
|
|
// SolarPredicReq solarReq = new SolarPredicReq("2024-11-10", "test");
|
|
|
|
|
// try {
|
|
|
|
|
// log.info("太阳能日总辐射实时模拟");
|
|
|
|
|
// //1.辐射出图
|
|
|
|
|
// String pathFile = solarenergyService.calSolarRadiation(RasterSolarRadiationOperation.SolarEadiationAnalysisType.DAY_TOTAL_SOLARRADIATION_AMOUNT,solarReq.getTime(), 0, 2000);
|
|
|
|
|
// //2.发布geoserverter服务并存入数据库
|
|
|
|
|
// Long aLong = geoServerPubService.pubGeoServerAndSavetoDB("style_tyn", "EPSG:3857",pathFile, solarReq.getRegionname());
|
|
|
|
|
// if (Objects.isNull(aLong)|| aLong == -1){
|
|
|
|
|
// return;
|
|
|
|
|
// }
|
|
|
|
|
// //3.查询tif
|
|
|
|
|
// log.info("Tif查询");
|
|
|
|
|
// List<TGeoserverinfo> regionInfo = dataImportService.getTifByRegion(solarReq.getRegionname());
|
|
|
|
|
// System.out.println("11111111");
|
|
|
|
|
// }catch (RuntimeException e){
|
|
|
|
|
// return;
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Test
|
|
|
|
|
public void testMusic1() throws FileNotFoundException, MusicConfigException {
|
|
|
|
|
try {
|
|
|
|
|
//1、接口实例化
|
|
|
|
|
RadifEleInterface radifEleInterface = new RadifEleInterface();
|
|
|
|
|
radifEleInterface.setUserConfig("10.194.90.120","80","BCCD_BFNA_NCGFZX", "NCgongfu123!");
|
|
|
|
|
log.debug("1---接口初始化成功");
|
|
|
|
|
//2、接口参数实例化
|
|
|
|
|
//需要传数据数据代码
|
|
|
|
|
MusicQueryParameters musicQueryParameters = new MusicQueryParameters("SURF","SURF_CHN_PRE_MIN");
|
|
|
|
|
log.debug("2---接口查询参数");
|
|
|
|
|
//3、设置查询时间,可设置时间段
|
|
|
|
|
// musicQueryParameters.setTimes("20241126080000");
|
|
|
|
|
Calendar start = Calendar.getInstance();
|
|
|
|
|
start.set(2024,Calendar.OCTOBER, 25,01,00,00);
|
|
|
|
|
Calendar end = Calendar.getInstance();
|
|
|
|
|
end.set(2024,Calendar.NOVEMBER, 25,23,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("Year");
|
|
|
|
|
objects.add("D_SOURCE_ID");
|
|
|
|
|
objects.add("Min");
|
|
|
|
|
objects.add("DATA_ID");
|
|
|
|
|
objects.add("Hour");
|
|
|
|
|
objects.add("D_RETAIN_ID");
|
|
|
|
|
objects.add("V08010");
|
|
|
|
|
objects.add("V02175");
|
|
|
|
|
objects.add("Q_PRE");
|
|
|
|
|
objects.add("PRE_Sensor_Heigh");
|
|
|
|
|
objects.add("Station_Type");
|
|
|
|
|
objects.add("Day");
|
|
|
|
|
objects.add("UPDATE_TIME");
|
|
|
|
|
objects.add("REP_CORR_ID");
|
|
|
|
|
objects.add("PRE");
|
|
|
|
|
objects.add("Mon");
|
|
|
|
|
objects.add("IYMDHM");
|
|
|
|
|
objects.add("RYMDHM");
|
|
|
|
|
objects.add("Datetime");
|
|
|
|
|
|
|
|
|
|
musicQueryParameters.setElements(objects);
|
|
|
|
|
|
|
|
|
|
log.debug("3---设置时间及区号");
|
|
|
|
|
//开始查询
|
|
|
|
|
String dataByMusic = radifEleInterface.queryDataByMusic(musicQueryParameters);
|
|
|
|
|
System.out.println("11111111111111");
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 入库
|
|
|
|
|
// int count = addDataBase(dataByMusic);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
log.debug("4---查询结束");
|
|
|
|
|
log.debug("查询结果长度:" + dataByMusic.length());
|
|
|
|
|
} catch (FileNotFoundException e) {
|
|
|
|
|
//配置文件没有找到
|
|
|
|
|
log.error("Error1:" + e.getMessage());
|
|
|
|
|
} catch (MusicConfigException e) {
|
|
|
|
|
//无效的配置文件
|
|
|
|
|
log.error("Error2:" + e.getMessage());
|
|
|
|
|
}
|
|
|
|
|
// catch (InvalidInterfaceParametersException e) {
|
|
|
|
|
// //无效的接口参数据错误
|
|
|
|
|
// log.error("Error3:" + e.getMessage());
|
|
|
|
|
// }
|
|
|
|
|
catch (InterfaceParameterMismatchException e) {
|
|
|
|
|
//查询接口参数据错误
|
|
|
|
|
log.error("Error4:" + e.getMessage());
|
|
|
|
|
} catch (MusicInterfaceException e) {
|
|
|
|
|
//接口调用异常;
|
|
|
|
|
log.error("Error7:" + e.getMessage());
|
|
|
|
|
} catch (MusicInterfaceReturnException e) {
|
|
|
|
|
//接口调用返异常;
|
|
|
|
|
log.error("Error5:接口ID为" + e.getInterfaceID());
|
|
|
|
|
log.error("Error5:接口参数为" + e.getParaMap());
|
|
|
|
|
log.error("Error5:MUSIC返回错误" + e.getErrMsg());
|
|
|
|
|
log.error("Error5:错误代码" + e.getErrcode());
|
|
|
|
|
log.error("Error5:错误信息" + e.getMessage());
|
|
|
|
|
log.error("Error5:错误处理建议" + e.getErrTips());
|
|
|
|
|
} catch (DataSetElementsInvalidExecption e) {
|
|
|
|
|
log.error("Error6:要素代码不正确" + e.getMessage());
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|