dsfsdfsdf

ipfcst/ipfcst-console/src/main/java/com/jiayue/ipfcst/console/service/FileAnalysisService.java

@@ -154,11 +154,11 @@ public class FileAnalysisService extends BaseService {
 				boolean sfqbxf = false;
 				boolean startConsole = false;
 				String fileName = file.getName();
-				if (fileName.indexOf(dayStr) < 0) {
-					file.delete();
-					log.warn(fileName + "不是当天的文件，删除！");
-					break;
-				}
+//				if (fileName.indexOf(dayStr) < 0) {
+//					file.delete();
+//					log.warn(fileName + "不是当天的文件，删除！");
+//					break;
+//				}
 				if (fileName.length() < 30) {
 					//假期文件
 					if (file.getName().startsWith("JH")) {
@@ -201,15 +201,15 @@ public class FileAnalysisService extends BaseService {
                 List<ForecastPowerShortTerm> listDq = fileAnalysisShortTerm(file, currentDate);
                 ForecastPowerShortTerm forecastPowerShortTerm = null;
                 if (listDq != null && listDq.size() > 0) {
-                  //如果数据不全，进行补入
-                  while (listDq.get(listDq.size() - 1).getForecastTime() < DateTimeUtil.getMillisecondsSubDay() + 4 * 24 * 60 * 60 * 1000 - timeD) {
-                    forecastPowerShortTerm = new ForecastPowerShortTerm();
-                    forecastPowerShortTerm.setFpValue(listDq.get(listDq.size() - 96).getFpValue());//修正前值
-                    forecastPowerShortTerm.setGenDate(new Date()); //装机容量
-                    forecastPowerShortTerm.setForecastTime(currentDate);
-                    forecastPowerShortTerm.setPredictionModelEnum(PredictionModelEnum.E1);
-                    listDq.add(forecastPowerShortTerm);
-                  }
+//                  //如果数据不全，进行补入
+//                  while (listDq.get(listDq.size() - 1).getForecastTime() < DateTimeUtil.getMillisecondsSubDay() + 4 * 24 * 60 * 60 * 1000 - timeD) {
+//                    forecastPowerShortTerm = new ForecastPowerShortTerm();
+//                    forecastPowerShortTerm.setFpValue(listDq.get(listDq.size() - 96).getFpValue());//修正前值
+//                    forecastPowerShortTerm.setGenDate(new Date()); //装机容量
+//                    forecastPowerShortTerm.setForecastTime(currentDate);
+//                    forecastPowerShortTerm.setPredictionModelEnum(PredictionModelEnum.E1);
+//                    listDq.add(forecastPowerShortTerm);
+//                  }
                   try {
                     //短期数据修正
                     Long startTime = listDq.get(0).getForecastTime();
@@ -231,14 +231,14 @@ public class FileAnalysisService extends BaseService {
                 ForecastPowerShortTermOne forecastPowerShortTermOne = null;
                 if (listDq != null && listDq.size() > 0) {
                   //如果数据不全，进行补入
-                  while (listDq.get(listDq.size() - 1).getForecastTime() < DateTimeUtil.getMillisecondsSubDay() + 4 * 24 * 60 * 60 * 1000 - timeD) {
-                    forecastPowerShortTermOne = new ForecastPowerShortTermOne();
-                    forecastPowerShortTermOne.setFpValue(listDq.get(listDq.size() - 96).getFpValue());//修正前值
-                    forecastPowerShortTermOne.setGenDate(new Date()); //装机容量
-                    forecastPowerShortTermOne.setForecastTime(currentDate);
-                    forecastPowerShortTermOne.setPredictionModelEnum(PredictionModelEnum.E1);
-                    listDq.add(forecastPowerShortTermOne);
-                  }
+//                  while (listDq.get(listDq.size() - 1).getForecastTime() < DateTimeUtil.getMillisecondsSubDay() + 4 * 24 * 60 * 60 * 1000 - timeD) {
+//                    forecastPowerShortTermOne = new ForecastPowerShortTermOne();
+//                    forecastPowerShortTermOne.setFpValue(listDq.get(listDq.size() - 96).getFpValue());//修正前值
+//                    forecastPowerShortTermOne.setGenDate(new Date()); //装机容量
+//                    forecastPowerShortTermOne.setForecastTime(currentDate);
+//                    forecastPowerShortTermOne.setPredictionModelEnum(PredictionModelEnum.E1);
+//                    listDq.add(forecastPowerShortTermOne);
+//                  }
                   try {
                     //短期数据修正
                     Long startTime = listDq.get(0).getForecastTime();
@@ -330,48 +330,48 @@ public class FileAnalysisService extends BaseService {
                 Nwp nwpData = null;
                 SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
                 if (listNwp != null && listNwp.size() > 0) {
-                  while (listNwp.get(listNwp.size() - 1).getPreTime() < DateTimeUtil.getMillisecondsSubDay() + 4 * 24 * 60 * 60 * 1000 - timeD) {
-                    nwpData = new Nwp();
-                    long time = 0;
-                    try {
-                      time = sdf.parse(listNwp.get(listNwp.size() - 96).getPreDate()).getTime() + 24 * 60 * 60 * 1000;
-                    } catch (ParseException e) {
-                      e.printStackTrace();
-                    }
-                    nwpData.setFarmId(listNwp.get(listNwp.size() - 96).getFarmId());
-                    nwpData.setScDate(listNwp.get(listNwp.size() - 96).getScDate());
-                    nwpData.setScTime(listNwp.get(listNwp.size() - 96).getScTime());
-                    nwpData.setPreDate(sdf.format(time));
-                    nwpData.setPreTime(listNwp.get(listNwp.size() - 1).getPreTime() + timeD);
-                    nwpData.setT(listNwp.get(listNwp.size() - 96).getT());//温度
-                    nwpData.setRh(listNwp.get(listNwp.size() - 96).getRh());//湿度
-                    nwpData.setPressure(listNwp.get(listNwp.size() - 96).getPressure());//气压
-                    nwpData.setSwr(listNwp.get(listNwp.size() - 96).getSwr());//辐射
-                    nwpData.setLwr(listNwp.get(listNwp.size() - 96).getLwr());//辐射
-                    nwpData.setDiffuseRadiation(listNwp.get(listNwp.size() - 96).getDiffuseRadiation());//散接辐射
-                    nwpData.setDirectRadiation(listNwp.get(listNwp.size() - 96).getDirectRadiation());//直接辐射
-
-                    nwpData.setSenf(listNwp.get(listNwp.size() - 96).getSenf());//热感通量
-
-                    nwpData.setWs10(listNwp.get(listNwp.size() - 96).getWs10());//10 m 风速
-                    nwpData.setWs30(listNwp.get(listNwp.size() - 96).getWs30());//30 m 风速
-                    nwpData.setWs50(listNwp.get(listNwp.size() - 96).getWs50());//50 m 风速
-                    nwpData.setWs70(listNwp.get(listNwp.size() - 96).getWs70());//70 m 风速
-                    nwpData.setWs80(listNwp.get(listNwp.size() - 96).getWs80());//80 m 风速
-                    nwpData.setWs90(listNwp.get(listNwp.size() - 96).getWs90());//90 m 风速
-                    nwpData.setWs100(listNwp.get(listNwp.size() - 96).getWs100());//100 m 风速
-                    nwpData.setWs170(listNwp.get(listNwp.size() - 96).getWs170());//170 m 风速
-
-                    nwpData.setWd10(listNwp.get(listNwp.size() - 96).getWd10());//10 m 风向
-                    nwpData.setWd30(listNwp.get(listNwp.size() - 96).getWd30());//30 m 风向
-                    nwpData.setWd50(listNwp.get(listNwp.size() - 96).getWd50());//50 m 风向
-                    nwpData.setWd70(listNwp.get(listNwp.size() - 96).getWd70());//70 m 风向
-                    nwpData.setWd80(listNwp.get(listNwp.size() - 96).getWd80());//80 m 风向
-                    nwpData.setWd90(listNwp.get(listNwp.size() - 96).getWd90());//90 m 风向
-                    nwpData.setWd100(listNwp.get(listNwp.size() - 96).getWd100());//100 m 风向
-                    nwpData.setWd170(listNwp.get(listNwp.size() - 96).getWd170());//170 m 风向
-                    listNwp.add(nwpData);
-                  }
+//                  while (listNwp.get(listNwp.size() - 1).getPreTime() < DateTimeUtil.getMillisecondsSubDay() + 4 * 24 * 60 * 60 * 1000 - timeD) {
+//                    nwpData = new Nwp();
+//                    long time = 0;
+//                    try {
+//                      time = sdf.parse(listNwp.get(listNwp.size() - 96).getPreDate()).getTime() + 24 * 60 * 60 * 1000;
+//                    } catch (ParseException e) {
+//                      e.printStackTrace();
+//                    }
+//                    nwpData.setFarmId(listNwp.get(listNwp.size() - 96).getFarmId());
+//                    nwpData.setScDate(listNwp.get(listNwp.size() - 96).getScDate());
+//                    nwpData.setScTime(listNwp.get(listNwp.size() - 96).getScTime());
+//                    nwpData.setPreDate(sdf.format(time));
+//                    nwpData.setPreTime(listNwp.get(listNwp.size() - 1).getPreTime() + timeD);
+//                    nwpData.setT(listNwp.get(listNwp.size() - 96).getT());//温度
+//                    nwpData.setRh(listNwp.get(listNwp.size() - 96).getRh());//湿度
+//                    nwpData.setPressure(listNwp.get(listNwp.size() - 96).getPressure());//气压
+//                    nwpData.setSwr(listNwp.get(listNwp.size() - 96).getSwr());//辐射
+//                    nwpData.setLwr(listNwp.get(listNwp.size() - 96).getLwr());//辐射
+//                    nwpData.setDiffuseRadiation(listNwp.get(listNwp.size() - 96).getDiffuseRadiation());//散接辐射
+//                    nwpData.setDirectRadiation(listNwp.get(listNwp.size() - 96).getDirectRadiation());//直接辐射
+//
+//                    nwpData.setSenf(listNwp.get(listNwp.size() - 96).getSenf());//热感通量
+//
+//                    nwpData.setWs10(listNwp.get(listNwp.size() - 96).getWs10());//10 m 风速
+//                    nwpData.setWs30(listNwp.get(listNwp.size() - 96).getWs30());//30 m 风速
+//                    nwpData.setWs50(listNwp.get(listNwp.size() - 96).getWs50());//50 m 风速
+//                    nwpData.setWs70(listNwp.get(listNwp.size() - 96).getWs70());//70 m 风速
+//                    nwpData.setWs80(listNwp.get(listNwp.size() - 96).getWs80());//80 m 风速
+//                    nwpData.setWs90(listNwp.get(listNwp.size() - 96).getWs90());//90 m 风速
+//                    nwpData.setWs100(listNwp.get(listNwp.size() - 96).getWs100());//100 m 风速
+//                    nwpData.setWs170(listNwp.get(listNwp.size() - 96).getWs170());//170 m 风速
+//
+//                    nwpData.setWd10(listNwp.get(listNwp.size() - 96).getWd10());//10 m 风向
+//                    nwpData.setWd30(listNwp.get(listNwp.size() - 96).getWd30());//30 m 风向
+//                    nwpData.setWd50(listNwp.get(listNwp.size() - 96).getWd50());//50 m 风向
+//                    nwpData.setWd70(listNwp.get(listNwp.size() - 96).getWd70());//70 m 风向
+//                    nwpData.setWd80(listNwp.get(listNwp.size() - 96).getWd80());//80 m 风向
+//                    nwpData.setWd90(listNwp.get(listNwp.size() - 96).getWd90());//90 m 风向
+//                    nwpData.setWd100(listNwp.get(listNwp.size() - 96).getWd100());//100 m 风向
+//                    nwpData.setWd170(listNwp.get(listNwp.size() - 96).getWd170());//170 m 风向
+//                    listNwp.add(nwpData);
+//                  }
                 } else {
                   flag = false;
                   log.info(file.getName() + "文件数据内容为空、不能正常解析 、移除该文件、执行数据修正功能");
@@ -389,48 +389,48 @@ public class FileAnalysisService extends BaseService {
                 NwpOne nwpData = null;
                 SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
                 if (listNwp != null && listNwp.size() > 0) {
-                  while (listNwp.get(listNwp.size() - 1).getPreTime() < DateTimeUtil.getMillisecondsSubDay() + 4 * 24 * 60 * 60 * 1000 - timeD) {
-                    nwpData = new NwpOne();
-                    long time = 0;
-                    try {
-                      time = sdf.parse(listNwp.get(listNwp.size() - 96).getPreDate()).getTime() + 24 * 60 * 60 * 1000;
-                    } catch (ParseException e) {
-                      e.printStackTrace();
-                    }
-                    nwpData.setFarmId(listNwp.get(listNwp.size() - 96).getFarmId());
-                    nwpData.setScDate(listNwp.get(listNwp.size() - 96).getScDate());
-                    nwpData.setScTime(listNwp.get(listNwp.size() - 96).getScTime());
-                    nwpData.setPreDate(sdf.format(time));
-                    nwpData.setPreTime(listNwp.get(listNwp.size() - 1).getPreTime() + timeD);
-                    nwpData.setT(listNwp.get(listNwp.size() - 96).getT());//温度
-                    nwpData.setRh(listNwp.get(listNwp.size() - 96).getRh());//湿度
-                    nwpData.setPressure(listNwp.get(listNwp.size() - 96).getPressure());//气压
-                    nwpData.setSwr(listNwp.get(listNwp.size() - 96).getSwr());//辐射
-                    nwpData.setLwr(listNwp.get(listNwp.size() - 96).getLwr());//辐射
-                    nwpData.setDiffuseRadiation(listNwp.get(listNwp.size() - 96).getDiffuseRadiation());//散接辐射
-                    nwpData.setDirectRadiation(listNwp.get(listNwp.size() - 96).getDirectRadiation());//直接辐射
-
-                    nwpData.setSenf(listNwp.get(listNwp.size() - 96).getSenf());//热感通量
-
-                    nwpData.setWs10(listNwp.get(listNwp.size() - 96).getWs10());//10 m 风速
-                    nwpData.setWs30(listNwp.get(listNwp.size() - 96).getWs30());//30 m 风速
-                    nwpData.setWs50(listNwp.get(listNwp.size() - 96).getWs50());//50 m 风速
-                    nwpData.setWs70(listNwp.get(listNwp.size() - 96).getWs70());//70 m 风速
-                    nwpData.setWs80(listNwp.get(listNwp.size() - 96).getWs80());//80 m 风速
-                    nwpData.setWs90(listNwp.get(listNwp.size() - 96).getWs90());//90 m 风速
-                    nwpData.setWs100(listNwp.get(listNwp.size() - 96).getWs100());//100 m 风速
-                    nwpData.setWs170(listNwp.get(listNwp.size() - 96).getWs170());//170 m 风速
-
-                    nwpData.setWd10(listNwp.get(listNwp.size() - 96).getWd10());//10 m 风向
-                    nwpData.setWd30(listNwp.get(listNwp.size() - 96).getWd30());//30 m 风向
-                    nwpData.setWd50(listNwp.get(listNwp.size() - 96).getWd50());//50 m 风向
-                    nwpData.setWd70(listNwp.get(listNwp.size() - 96).getWd70());//70 m 风向
-                    nwpData.setWd80(listNwp.get(listNwp.size() - 96).getWd80());//80 m 风向
-                    nwpData.setWd90(listNwp.get(listNwp.size() - 96).getWd90());//90 m 风向
-                    nwpData.setWd100(listNwp.get(listNwp.size() - 96).getWd100());//100 m 风向
-                    nwpData.setWd170(listNwp.get(listNwp.size() - 96).getWd170());//170 m 风向
-                    listNwp.add(nwpData);
-                  }
+//                  while (listNwp.get(listNwp.size() - 1).getPreTime() < DateTimeUtil.getMillisecondsSubDay() + 4 * 24 * 60 * 60 * 1000 - timeD) {
+//                    nwpData = new NwpOne();
+//                    long time = 0;
+//                    try {
+//                      time = sdf.parse(listNwp.get(listNwp.size() - 96).getPreDate()).getTime() + 24 * 60 * 60 * 1000;
+//                    } catch (ParseException e) {
+//                      e.printStackTrace();
+//                    }
+//                    nwpData.setFarmId(listNwp.get(listNwp.size() - 96).getFarmId());
+//                    nwpData.setScDate(listNwp.get(listNwp.size() - 96).getScDate());
+//                    nwpData.setScTime(listNwp.get(listNwp.size() - 96).getScTime());
+//                    nwpData.setPreDate(sdf.format(time));
+//                    nwpData.setPreTime(listNwp.get(listNwp.size() - 1).getPreTime() + timeD);
+//                    nwpData.setT(listNwp.get(listNwp.size() - 96).getT());//温度
+//                    nwpData.setRh(listNwp.get(listNwp.size() - 96).getRh());//湿度
+//                    nwpData.setPressure(listNwp.get(listNwp.size() - 96).getPressure());//气压
+//                    nwpData.setSwr(listNwp.get(listNwp.size() - 96).getSwr());//辐射
+//                    nwpData.setLwr(listNwp.get(listNwp.size() - 96).getLwr());//辐射
+//                    nwpData.setDiffuseRadiation(listNwp.get(listNwp.size() - 96).getDiffuseRadiation());//散接辐射
+//                    nwpData.setDirectRadiation(listNwp.get(listNwp.size() - 96).getDirectRadiation());//直接辐射
+//
+//                    nwpData.setSenf(listNwp.get(listNwp.size() - 96).getSenf());//热感通量
+//
+//                    nwpData.setWs10(listNwp.get(listNwp.size() - 96).getWs10());//10 m 风速
+//                    nwpData.setWs30(listNwp.get(listNwp.size() - 96).getWs30());//30 m 风速
+//                    nwpData.setWs50(listNwp.get(listNwp.size() - 96).getWs50());//50 m 风速
+//                    nwpData.setWs70(listNwp.get(listNwp.size() - 96).getWs70());//70 m 风速
+//                    nwpData.setWs80(listNwp.get(listNwp.size() - 96).getWs80());//80 m 风速
+//                    nwpData.setWs90(listNwp.get(listNwp.size() - 96).getWs90());//90 m 风速
+//                    nwpData.setWs100(listNwp.get(listNwp.size() - 96).getWs100());//100 m 风速
+//                    nwpData.setWs170(listNwp.get(listNwp.size() - 96).getWs170());//170 m 风速
+//
+//                    nwpData.setWd10(listNwp.get(listNwp.size() - 96).getWd10());//10 m 风向
+//                    nwpData.setWd30(listNwp.get(listNwp.size() - 96).getWd30());//30 m 风向
+//                    nwpData.setWd50(listNwp.get(listNwp.size() - 96).getWd50());//50 m 风向
+//                    nwpData.setWd70(listNwp.get(listNwp.size() - 96).getWd70());//70 m 风向
+//                    nwpData.setWd80(listNwp.get(listNwp.size() - 96).getWd80());//80 m 风向
+//                    nwpData.setWd90(listNwp.get(listNwp.size() - 96).getWd90());//90 m 风向
+//                    nwpData.setWd100(listNwp.get(listNwp.size() - 96).getWd100());//100 m 风向
+//                    nwpData.setWd170(listNwp.get(listNwp.size() - 96).getWd170());//170 m 风向
+//                    listNwp.add(nwpData);
+//                  }
                 } else {
                   flag = false;
                   log.info(file.getName() + "风电NWP文件数据内容为空、不能正常解析 、移除该文件、执行数据修正功能");