|
@@ -93,13 +93,14 @@ public class SaticSchedulePgTask {
|
|
|
|
|
|
@Resource
|
|
|
private StationPowerService powerService;
|
|
|
+
|
|
|
/**
|
|
|
* 缓存Redis散点图数据
|
|
|
* 每天执行一次
|
|
|
*/
|
|
|
|
|
|
@XxlJob("initialRedis_PG")
|
|
|
- public void initialRedis_PG() {
|
|
|
+ public void initialRedis_PG() {
|
|
|
|
|
|
|
|
|
XxlJobHelper.log("缓存Redis散点图数据调度程序执行开始!........");
|
|
@@ -119,7 +120,7 @@ public class SaticSchedulePgTask {
|
|
|
*/
|
|
|
|
|
|
@XxlJob("calFailRate_PG")
|
|
|
- public void calFailRate_PG() {
|
|
|
+ public void calFailRate_PG() {
|
|
|
|
|
|
|
|
|
XxlJobHelper.log("故障转换率记录调度程序执行开始!........");
|
|
@@ -132,13 +133,14 @@ public class SaticSchedulePgTask {
|
|
|
}
|
|
|
|
|
|
//3.添加定时任务
|
|
|
+
|
|
|
/**
|
|
|
* 15分钟数据统计
|
|
|
* 每15分钟执行一次
|
|
|
*/
|
|
|
|
|
|
@XxlJob("calEquipmentInfo15minute_PG")
|
|
|
- public void calEquipmentInfo15minute_PG() {
|
|
|
+ public void calEquipmentInfo15minute_PG() {
|
|
|
|
|
|
|
|
|
XxlJobHelper.log("15分钟数据统计记录调度程序执行开始!........");
|
|
@@ -151,13 +153,14 @@ public class SaticSchedulePgTask {
|
|
|
}
|
|
|
|
|
|
//3.添加定时任务
|
|
|
+
|
|
|
/**
|
|
|
* 切入切出统计
|
|
|
* 每5分钟执行一次
|
|
|
*/
|
|
|
|
|
|
@XxlJob("inputOrOutPutSpeed_PG")
|
|
|
- public void inputOrOutPutSpeed_PG() {
|
|
|
+ public void inputOrOutPutSpeed_PG() {
|
|
|
|
|
|
|
|
|
XxlJobHelper.log("切入切出状态切换记录调度程序执行开始!........");
|
|
@@ -170,13 +173,14 @@ public class SaticSchedulePgTask {
|
|
|
}
|
|
|
|
|
|
//3.添加定时任务
|
|
|
+
|
|
|
/**
|
|
|
* 切入切出统计
|
|
|
* 每天1点执行一次
|
|
|
*/
|
|
|
|
|
|
@XxlJob("inputOrOutPut_PG")
|
|
|
- public void inputOrOutPut_PG() {
|
|
|
+ public void inputOrOutPut_PG() {
|
|
|
|
|
|
|
|
|
XxlJobHelper.log("切入切出统计调度程序执行开始!........");
|
|
@@ -193,7 +197,7 @@ public class SaticSchedulePgTask {
|
|
|
* 每5分钟执行一次
|
|
|
*/
|
|
|
@XxlJob("shutdown_PG")
|
|
|
- public void shutdown_PG() {
|
|
|
+ public void shutdown_PG() {
|
|
|
|
|
|
XxlJobHelper.log("停机记录调度程序执行开始!........");
|
|
|
|
|
@@ -211,7 +215,7 @@ public class SaticSchedulePgTask {
|
|
|
* 每5分钟执行一次
|
|
|
*/
|
|
|
@XxlJob("brownouts_PG")
|
|
|
- public void brownouts_PG() {
|
|
|
+ public void brownouts_PG() {
|
|
|
|
|
|
XxlJobHelper.log("限电停机记录调度程序执行开始!........");
|
|
|
|
|
@@ -228,29 +232,316 @@ public class SaticSchedulePgTask {
|
|
|
* 日、月、年功率曲线拟合
|
|
|
* 每天执行一次
|
|
|
*/
|
|
|
- @XxlJob("powerCurveFittingnew_PG")
|
|
|
- public void powerCurveFittingnew_PG() {
|
|
|
+// @XxlJob("powerCurveFittingnew_PG")
|
|
|
+// public void powerCurveFittingnew_PG() {
|
|
|
+//
|
|
|
+// XxlJobHelper.log("日、月、年功率曲线拟合调度程序执行开始!........");
|
|
|
+//
|
|
|
+// Date date=new Date();
|
|
|
+// try {
|
|
|
+// XxlJobHelper.log("日序执行开始!........");
|
|
|
+// powerCurveFittingByTimeService.cureFittingDay(date);
|
|
|
+// XxlJobHelper.log("日处理完成!........");
|
|
|
+//
|
|
|
+// XxlJobHelper.log("月序执行开始!........");
|
|
|
+// powerCurveFittingByTimeService.cureFittingMonth(date,"0");
|
|
|
+// XxlJobHelper.log("月处理完成!........");
|
|
|
+//
|
|
|
+// XxlJobHelper.log("年序执行开始!........");
|
|
|
+// powerCurveFittingByTimeService.cureFittingYear(date);
|
|
|
+// XxlJobHelper.log("年处理完成!........");
|
|
|
+//
|
|
|
+//// powerCurveFittingByTimeGfService.cureFittingDay(date);
|
|
|
+//// powerCurveFittingByTimeGfService.cureFittingMonth(date,"0");
|
|
|
+//// powerCurveFittingByTimeGfService.cureFittingYear(date);
|
|
|
+//
|
|
|
+//
|
|
|
+//
|
|
|
+// } catch (Exception e) {
|
|
|
+// e.printStackTrace();
|
|
|
+// XxlJobHelper.log(e.getMessage());
|
|
|
+// }
|
|
|
+//
|
|
|
+// XxlJobHelper.log("日、月、年功率曲线拟合调度任务处理完成!........");
|
|
|
+// }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 平遥朱坑风电场功率预测
|
|
|
+ * 每天一次
|
|
|
+ */
|
|
|
+ @XxlJob("shutdown_SXJ_KGDL_ZK_FDC_STA")
|
|
|
+ public void shutdown_SXJ_KGDL_ZK_FDC_STA() {
|
|
|
+
|
|
|
+ XxlJobHelper.log("平遥朱坑风电场功率预测调度程序执行开始!........");
|
|
|
+
|
|
|
+ Date date = new Date();
|
|
|
+ try {
|
|
|
+ XxlJobHelper.log("日序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingDay(date, "SXJ_KGDL_ZK_FDC_STA");
|
|
|
+ XxlJobHelper.log("日处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("月序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingMonth(date, "0", "SXJ_KGDL_ZK_FDC_STA");
|
|
|
+ XxlJobHelper.log("月处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("年序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingYear(date, "SXJ_KGDL_ZK_FDC_STA");
|
|
|
+ XxlJobHelper.log("年处理完成!........");
|
|
|
+
|
|
|
+
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ XxlJobHelper.log(e.getMessage());
|
|
|
+ }
|
|
|
+
|
|
|
+ XxlJobHelper.log("平遥朱坑风电场功率预测调度任务处理完成!........");
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 平鲁高家堰风电场功率预测
|
|
|
+ * 每天一次
|
|
|
+ */
|
|
|
+ @XxlJob("shutdown_SXJ_KGDL_GJY_FDC_STA")
|
|
|
+ public void shutdown_SXJ_KGDL_GJY_FDC_STA() {
|
|
|
+
|
|
|
+ XxlJobHelper.log("平鲁高家堰风电场功率预测调度程序执行开始!........");
|
|
|
+
|
|
|
+ Date date = new Date();
|
|
|
+ try {
|
|
|
+ XxlJobHelper.log("日序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingDay(date, "SXJ_KGDL_GJY_FDC_STA");
|
|
|
+ XxlJobHelper.log("日处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("月序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingMonth(date, "0", "SXJ_KGDL_GJY_FDC_STA");
|
|
|
+ XxlJobHelper.log("月处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("年序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingYear(date, "SXJ_KGDL_GJY_FDC_STA");
|
|
|
+ XxlJobHelper.log("年处理完成!........");
|
|
|
+
|
|
|
+
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ XxlJobHelper.log(e.getMessage());
|
|
|
+ }
|
|
|
+
|
|
|
+ XxlJobHelper.log("平鲁高家堰风电场功率预测调度任务处理完成!........");
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 平鲁败虎堡风电场功率预测
|
|
|
+ * 每天一次
|
|
|
+ */
|
|
|
+ @XxlJob("shutdown_SXJ_KGDL_BHB_FDC_STA")
|
|
|
+ public void shutdown_SXJ_KGDL_BHB_FDC_STA() {
|
|
|
+
|
|
|
+ XxlJobHelper.log("平鲁败虎堡风电场功率预测调度程序执行开始!........");
|
|
|
+
|
|
|
+ Date date = new Date();
|
|
|
+ try {
|
|
|
+ XxlJobHelper.log("日序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingDay(date, "SXJ_KGDL_BHB_FDC_STA");
|
|
|
+ XxlJobHelper.log("日处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("月序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingMonth(date, "0", "SXJ_KGDL_BHB_FDC_STA");
|
|
|
+ XxlJobHelper.log("月处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("年序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingYear(date, "SXJ_KGDL_BHB_FDC_STA");
|
|
|
+ XxlJobHelper.log("年处理完成!........");
|
|
|
+
|
|
|
+
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ XxlJobHelper.log(e.getMessage());
|
|
|
+ }
|
|
|
+ XxlJobHelper.log("平鲁败虎堡风电场功率预测调度任务处理完成!........");
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 平鲁红石峁风电场功率预测
|
|
|
+ * 每天一次
|
|
|
+ */
|
|
|
+ @XxlJob("shutdown_SXJ_KGDL_HSM_FDC_STA")
|
|
|
+ public void shutdown_SXJ_KGDL_HSM_FDC_STA() {
|
|
|
+
|
|
|
+ XxlJobHelper.log("平鲁红石峁风电场功率预测调度程序执行开始!........");
|
|
|
+
|
|
|
+ Date date = new Date();
|
|
|
+ try {
|
|
|
+ XxlJobHelper.log("日序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingDay(date, "SXJ_KGDL_HSM_FDC_STA");
|
|
|
+ XxlJobHelper.log("日处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("月序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingMonth(date, "0", "SXJ_KGDL_HSM_FDC_STA");
|
|
|
+ XxlJobHelper.log("月处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("年序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingYear(date, "SXJ_KGDL_HSM_FDC_STA");
|
|
|
+ XxlJobHelper.log("年处理完成!........");
|
|
|
+
|
|
|
+
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ XxlJobHelper.log(e.getMessage());
|
|
|
+ }
|
|
|
+ XxlJobHelper.log("平鲁红石峁风电场功率预测调度任务处理完成!........");
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 寿阳羊头崖风电场功率预测
|
|
|
+ * 每天一次
|
|
|
+ */
|
|
|
+ @XxlJob("shutdown_SXJ_KGDL_YTY_FDC_STA")
|
|
|
+ public void shutdown_SXJ_KGDL_YTY_FDC_STA() {
|
|
|
+
|
|
|
+ XxlJobHelper.log("寿阳羊头崖风电场功率预测调度程序执行开始!........");
|
|
|
+
|
|
|
+ Date date = new Date();
|
|
|
+ try {
|
|
|
+ XxlJobHelper.log("日序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingDay(date, "SXJ_KGDL_YTY_FDC_STA");
|
|
|
+ XxlJobHelper.log("日处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("月序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingMonth(date, "0", "SXJ_KGDL_YTY_FDC_STA");
|
|
|
+ XxlJobHelper.log("月处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("年序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingYear(date, "SXJ_KGDL_YTY_FDC_STA");
|
|
|
+ XxlJobHelper.log("年处理完成!........");
|
|
|
+
|
|
|
+
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ XxlJobHelper.log(e.getMessage());
|
|
|
+ }
|
|
|
+ XxlJobHelper.log("寿阳羊头崖风电场功率预测调度任务处理完成!........");
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 平鲁败虎堡三期风电场功率预测
|
|
|
+ * 每天一次
|
|
|
+ */
|
|
|
+ @XxlJob("shutdown_SXJ_KGDL_BHB3_FDC_STA")
|
|
|
+ public void shutdown_SXJ_KGDL_BHB3_FDC_STA() {
|
|
|
+
|
|
|
+ XxlJobHelper.log("平鲁败虎堡三期风电场功率预测调度程序执行开始!........");
|
|
|
+
|
|
|
+ Date date = new Date();
|
|
|
+ try {
|
|
|
+ XxlJobHelper.log("日序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingDay(date, "SXJ_KGDL_BHB3_FDC_STA");
|
|
|
+ XxlJobHelper.log("日处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("月序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingMonth(date, "0", "SXJ_KGDL_BHB3_FDC_STA");
|
|
|
+ XxlJobHelper.log("月处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("年序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingYear(date, "SXJ_KGDL_BHB3_FDC_STA");
|
|
|
+ XxlJobHelper.log("年处理完成!........");
|
|
|
+
|
|
|
+
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ XxlJobHelper.log(e.getMessage());
|
|
|
+ }
|
|
|
+ XxlJobHelper.log("平鲁败虎堡三期风电场功率预测调度任务处理完成!........");
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 宁武盘道梁风电场功率预测
|
|
|
+ * 每天一次
|
|
|
+ */
|
|
|
+ @XxlJob("shutdown_SXJ_KGDL_PDL_FDC_STA")
|
|
|
+ public void shutdown_SXJ_KGDL_PDL_FDC_STA() {
|
|
|
+
|
|
|
+ XxlJobHelper.log("宁武盘道梁风电场功率预测调度程序执行开始!........");
|
|
|
+
|
|
|
+ Date date = new Date();
|
|
|
+ try {
|
|
|
+ XxlJobHelper.log("日序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingDay(date, "SXJ_KGDL_PDL_FDC_STA");
|
|
|
+ XxlJobHelper.log("日处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("月序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingMonth(date, "0", "SXJ_KGDL_PDL_FDC_STA");
|
|
|
+ XxlJobHelper.log("月处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("年序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingYear(date, "SXJ_KGDL_PDL_FDC_STA");
|
|
|
+ XxlJobHelper.log("年处理完成!........");
|
|
|
+
|
|
|
+
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ XxlJobHelper.log(e.getMessage());
|
|
|
+ }
|
|
|
+ XxlJobHelper.log("宁武盘道梁风电场功率预测调度任务处理完成!........");
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 朔城区牛家岭风电场功率预测
|
|
|
+ * 每天一次
|
|
|
+ */
|
|
|
+ @XxlJob("shutdown_SXJ_KGDL_NJL_FDC_STA")
|
|
|
+ public void shutdown_SXJ_KGDL_NJL_FDC_STA() {
|
|
|
|
|
|
- XxlJobHelper.log("日、月、年功率曲线拟合调度程序执行开始!........");
|
|
|
+ XxlJobHelper.log("朔城区牛家岭风电场功率预测调度程序执行开始!........");
|
|
|
|
|
|
- Date date=new Date();
|
|
|
+ Date date = new Date();
|
|
|
try {
|
|
|
XxlJobHelper.log("日序执行开始!........");
|
|
|
- powerCurveFittingByTimeService.cureFittingDay(date);
|
|
|
+ powerCurveFittingByTimeService.cureFittingDay(date, "SXJ_KGDL_NJL_FDC_STA");
|
|
|
XxlJobHelper.log("日处理完成!........");
|
|
|
|
|
|
XxlJobHelper.log("月序执行开始!........");
|
|
|
- powerCurveFittingByTimeService.cureFittingMonth(date,"0");
|
|
|
+ powerCurveFittingByTimeService.cureFittingMonth(date, "0", "SXJ_KGDL_NJL_FDC_STA");
|
|
|
XxlJobHelper.log("月处理完成!........");
|
|
|
|
|
|
XxlJobHelper.log("年序执行开始!........");
|
|
|
- powerCurveFittingByTimeService.cureFittingYear(date);
|
|
|
+ powerCurveFittingByTimeService.cureFittingYear(date, "SXJ_KGDL_NJL_FDC_STA");
|
|
|
XxlJobHelper.log("年处理完成!........");
|
|
|
|
|
|
-// powerCurveFittingByTimeGfService.cureFittingDay(date);
|
|
|
-// powerCurveFittingByTimeGfService.cureFittingMonth(date,"0");
|
|
|
-// powerCurveFittingByTimeGfService.cureFittingYear(date);
|
|
|
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ XxlJobHelper.log(e.getMessage());
|
|
|
+ }
|
|
|
+ XxlJobHelper.log("朔城区牛家岭风电场功率预测调度任务处理完成!........");
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 寿阳尹灵芝风电场功率预测
|
|
|
+ * 每天一次
|
|
|
+ */
|
|
|
+ @XxlJob("shutdown_SXJ_KGDL_YLZ_FDC_STA")
|
|
|
+ public void shutdown_SXJ_KGDL_YLZ_FDC_STA() {
|
|
|
+
|
|
|
+ XxlJobHelper.log("寿阳尹灵芝风电场功率预测调度程序执行开始!........");
|
|
|
+
|
|
|
+ Date date = new Date();
|
|
|
+ try {
|
|
|
+ XxlJobHelper.log("日序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingDay(date, "SXJ_KGDL_YLZ_FDC_STA");
|
|
|
+ XxlJobHelper.log("日处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("月序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingMonth(date, "0", "SXJ_KGDL_YLZ_FDC_STA");
|
|
|
+ XxlJobHelper.log("月处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("年序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingYear(date, "SXJ_KGDL_YLZ_FDC_STA");
|
|
|
+ XxlJobHelper.log("年处理完成!........");
|
|
|
|
|
|
|
|
|
} catch (Exception e) {
|
|
@@ -258,21 +549,145 @@ public class SaticSchedulePgTask {
|
|
|
XxlJobHelper.log(e.getMessage());
|
|
|
}
|
|
|
|
|
|
- XxlJobHelper.log("日、月、年功率曲线拟合调度任务处理完成!........");
|
|
|
+ XxlJobHelper.log("寿阳尹灵芝风电场功率预测调度任务处理完成!........");
|
|
|
}
|
|
|
|
|
|
|
|
|
/**
|
|
|
+ * 平鲁禹丰风电场功率预测
|
|
|
+ * 每天一次
|
|
|
+ */
|
|
|
+ @XxlJob("shutdown_SXJ_KGDL_YF_FDC_STA")
|
|
|
+ public void shutdown_SXJ_KGDL_YF_FDC_STA() {
|
|
|
+
|
|
|
+ XxlJobHelper.log("平鲁禹丰风电场功率预测调度程序执行开始!........");
|
|
|
+
|
|
|
+ Date date = new Date();
|
|
|
+ try {
|
|
|
+ XxlJobHelper.log("日序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingDay(date, "SXJ_KGDL_YF_FDC_STA");
|
|
|
+ XxlJobHelper.log("日处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("月序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingMonth(date, "0", "SXJ_KGDL_YF_FDC_STA");
|
|
|
+ XxlJobHelper.log("月处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("年序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingYear(date, "SXJ_KGDL_YF_FDC_STA");
|
|
|
+ XxlJobHelper.log("年处理完成!........");
|
|
|
+
|
|
|
+
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ XxlJobHelper.log(e.getMessage());
|
|
|
+ }
|
|
|
+ XxlJobHelper.log("平鲁禹丰风电场功率预测调度任务处理完成!........");
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 寿阳平头镇风电场功率预测
|
|
|
+ * 每天一次
|
|
|
+ */
|
|
|
+ @XxlJob("shutdown_SXJ_KGDL_PTZ_FDC_STA")
|
|
|
+ public void shutdown_SXJ_KGDL_PTZ_FDC_STA() {
|
|
|
+
|
|
|
+ XxlJobHelper.log("寿阳平头镇风电场功率预测调度程序执行开始!........");
|
|
|
+
|
|
|
+ Date date = new Date();
|
|
|
+ try {
|
|
|
+ XxlJobHelper.log("日序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingDay(date, "SXJ_KGDL_PTZ_FDC_STA");
|
|
|
+ XxlJobHelper.log("日处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("月序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingMonth(date, "0", "SXJ_KGDL_PTZ_FDC_STA");
|
|
|
+ XxlJobHelper.log("月处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("年序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingYear(date, "SXJ_KGDL_PTZ_FDC_STA");
|
|
|
+ XxlJobHelper.log("年处理完成!........");
|
|
|
+
|
|
|
+
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ XxlJobHelper.log(e.getMessage());
|
|
|
+ }
|
|
|
+ XxlJobHelper.log("寿阳平头镇风电场功率预测调度任务处理完成!........");
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 右玉小五台风电场功率预测
|
|
|
+ * 每天一次
|
|
|
+ */
|
|
|
+ @XxlJob("shutdown_SXJ_KGDL_XWT_FDC_STA")
|
|
|
+ public void shutdown_SXJ_KGDL_XWT_FDC_STA() {
|
|
|
+
|
|
|
+ XxlJobHelper.log("右玉小五台风电场功率预测调度程序执行开始!........");
|
|
|
+
|
|
|
+ Date date = new Date();
|
|
|
+ try {
|
|
|
+ XxlJobHelper.log("日序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingDay(date, "SXJ_KGDL_XWT_FDC_STA");
|
|
|
+ XxlJobHelper.log("日处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("月序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingMonth(date, "0", "SXJ_KGDL_XWT_FDC_STA");
|
|
|
+ XxlJobHelper.log("月处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("年序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingYear(date, "SXJ_KGDL_XWT_FDC_STA");
|
|
|
+ XxlJobHelper.log("年处理完成!........");
|
|
|
+
|
|
|
+
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ XxlJobHelper.log(e.getMessage());
|
|
|
+ }
|
|
|
+ XxlJobHelper.log("右玉小五台风电场功率预测调度任务处理完成!........");
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 右玉丁家窑风电场功率预测
|
|
|
+ * 每天一次
|
|
|
+ */
|
|
|
+ @XxlJob("shutdown_SXJ_KGDL_DJY_FDC_STA")
|
|
|
+ public void shutdown_SXJ_KGDL_DJY_FDC_STA() {
|
|
|
+
|
|
|
+ XxlJobHelper.log("右玉丁家窑风电场功率预测调度程序执行开始!........");
|
|
|
+
|
|
|
+ Date date = new Date();
|
|
|
+ try {
|
|
|
+ XxlJobHelper.log("日序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingDay(date, "SXJ_KGDL_DJY_FDC_STA");
|
|
|
+ XxlJobHelper.log("日处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("月序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingMonth(date, "0", "SXJ_KGDL_DJY_FDC_STA");
|
|
|
+ XxlJobHelper.log("月处理完成!........");
|
|
|
+
|
|
|
+ XxlJobHelper.log("年序执行开始!........");
|
|
|
+ powerCurveFittingByTimeService.cureFittingYear(date, "SXJ_KGDL_DJY_FDC_STA");
|
|
|
+ XxlJobHelper.log("年处理完成!........");
|
|
|
+
|
|
|
+
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ XxlJobHelper.log(e.getMessage());
|
|
|
+ }
|
|
|
+ XxlJobHelper.log("右玉丁家窑风电场功率预测调度任务处理完成!........");
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
* 场站1表
|
|
|
- * 15分钟只执行一次
|
|
|
- *
|
|
|
+ * 15分钟只执行一次
|
|
|
*/
|
|
|
@XxlJob("windPowerInfo1_PG")
|
|
|
public void windPowerInfo1_PG() throws Exception {
|
|
|
|
|
|
XxlJobHelper.log("场站指标1调度程序执行开始!........");
|
|
|
|
|
|
- Date date=new Date();
|
|
|
+ Date date = new Date();
|
|
|
|
|
|
windPowerInfo1Service.calLineInfoDay(date);
|
|
|
windPowerInfo1Service.calProjectInfoDay(date);
|
|
@@ -286,15 +701,14 @@ public class SaticSchedulePgTask {
|
|
|
|
|
|
/**
|
|
|
* 场站2表
|
|
|
- * 15分钟只执行一次
|
|
|
- *
|
|
|
+ * 15分钟只执行一次
|
|
|
*/
|
|
|
@XxlJob("windPowerInfo2_PG")
|
|
|
public void windPowerInfo2_PG() throws Exception {
|
|
|
|
|
|
XxlJobHelper.log("场站指标2调度程序执行开始!........");
|
|
|
|
|
|
- Date date=new Date();
|
|
|
+ Date date = new Date();
|
|
|
|
|
|
windPowerInfo2Service.calLineInfoDay(date);
|
|
|
windPowerInfo2Service.calProjectInfoDay(date);
|
|
@@ -309,15 +723,14 @@ public class SaticSchedulePgTask {
|
|
|
|
|
|
/**
|
|
|
* 场站3表
|
|
|
- * 15分钟只执行一次
|
|
|
- *
|
|
|
+ * 15分钟只执行一次
|
|
|
*/
|
|
|
@XxlJob("windPowerInfo3_PG")
|
|
|
public void windPowerInfo3_PG() throws Exception {
|
|
|
|
|
|
XxlJobHelper.log("场站指标3调度程序执行开始!........");
|
|
|
|
|
|
- Date date=new Date();
|
|
|
+ Date date = new Date();
|
|
|
|
|
|
windPowerInfo3Service.calLineInfoDay(date);
|
|
|
windPowerInfo3Service.calProjectInfoDay(date);
|
|
@@ -331,15 +744,14 @@ public class SaticSchedulePgTask {
|
|
|
|
|
|
/**
|
|
|
* 场站4表
|
|
|
- * 15分钟只执行一次
|
|
|
- *
|
|
|
+ * 15分钟只执行一次
|
|
|
*/
|
|
|
@XxlJob("windPowerInfo4_PG")
|
|
|
public void windPowerInfo4_PG() throws Exception {
|
|
|
|
|
|
XxlJobHelper.log("场站指标4调度程序执行开始!........");
|
|
|
|
|
|
- Date date=new Date();
|
|
|
+ Date date = new Date();
|
|
|
|
|
|
windPowerInfo4Service.calLineInfoDay(date);
|
|
|
windPowerInfo4Service.calProjectInfoDay(date);
|
|
@@ -350,17 +762,17 @@ public class SaticSchedulePgTask {
|
|
|
XxlJobHelper.log("场站指标4指标调度程序执行完成!........");
|
|
|
|
|
|
}
|
|
|
+
|
|
|
/**
|
|
|
* 场站5表
|
|
|
- * 15分钟只执行一次
|
|
|
- *
|
|
|
+ * 15分钟只执行一次
|
|
|
*/
|
|
|
@XxlJob("windPowerInfo5_PG")
|
|
|
public void windPowerInfo5_PG() throws Exception {
|
|
|
|
|
|
XxlJobHelper.log("场站指标5调度程序执行开始!........");
|
|
|
|
|
|
- Date date=new Date();
|
|
|
+ Date date = new Date();
|
|
|
|
|
|
windPowerInfo5Service.calLineInfoDay(date);
|
|
|
windPowerInfo5Service.calProjectInfoDay(date);
|
|
@@ -375,15 +787,14 @@ public class SaticSchedulePgTask {
|
|
|
|
|
|
/**
|
|
|
* 场站6表
|
|
|
- * 15分钟只执行一次
|
|
|
- *
|
|
|
+ * 15分钟只执行一次
|
|
|
*/
|
|
|
@XxlJob("windPowerInfo6_PG")
|
|
|
public void windPowerInfo6_PG() throws Exception {
|
|
|
|
|
|
XxlJobHelper.log("场站指标6调度程序执行开始!........");
|
|
|
|
|
|
- Date date=new Date();
|
|
|
+ Date date = new Date();
|
|
|
|
|
|
windPowerInfo6Service.calLineInfoDay(date);
|
|
|
windPowerInfo6Service.calProjectInfoDay(date);
|
|
@@ -397,21 +808,19 @@ public class SaticSchedulePgTask {
|
|
|
|
|
|
/**
|
|
|
* 设备1-5表
|
|
|
- * 15分钟只执行一次
|
|
|
- *
|
|
|
+ * 15分钟只执行一次
|
|
|
*/
|
|
|
@XxlJob("equipment_PowerInfo1_PG")
|
|
|
public void equipment_PowerInfo1_PG() throws Exception {
|
|
|
|
|
|
XxlJobHelper.log("设备指标1调度程序执行开始!........");
|
|
|
|
|
|
- Date date=new Date();
|
|
|
+ Date date = new Date();
|
|
|
|
|
|
|
|
|
equipmentInfo1Service.calEquipmentInfoDay(date);
|
|
|
|
|
|
|
|
|
-
|
|
|
XxlJobHelper.log("设备指标1调度程序执行完成!........");
|
|
|
|
|
|
}
|
|
@@ -419,15 +828,14 @@ public class SaticSchedulePgTask {
|
|
|
|
|
|
/**
|
|
|
* 设备2表
|
|
|
- * 15分钟只执行一次
|
|
|
- *
|
|
|
+ * 15分钟只执行一次
|
|
|
*/
|
|
|
@XxlJob("equipment_PowerInfo2_PG")
|
|
|
public void equipment_PowerInfo2_PG() throws Exception {
|
|
|
|
|
|
XxlJobHelper.log("设备指标2调度程序执行开始!........");
|
|
|
|
|
|
- Date date=new Date();
|
|
|
+ Date date = new Date();
|
|
|
|
|
|
equipmentInfo2Service.calEquipmentInfoDay(date);
|
|
|
|
|
@@ -438,15 +846,14 @@ public class SaticSchedulePgTask {
|
|
|
|
|
|
/**
|
|
|
* 设备3表
|
|
|
- * 15分钟只执行一次
|
|
|
- *
|
|
|
+ * 15分钟只执行一次
|
|
|
*/
|
|
|
@XxlJob("equipment_PowerInfo3_PG")
|
|
|
public void equipment_PowerInfo3_PG() throws Exception {
|
|
|
|
|
|
XxlJobHelper.log("设备指标3调度程序执行开始!........");
|
|
|
|
|
|
- Date date=new Date();
|
|
|
+ Date date = new Date();
|
|
|
|
|
|
|
|
|
equipmentInfo3Service.calEquipmentInfoDay(date);
|
|
@@ -459,16 +866,14 @@ public class SaticSchedulePgTask {
|
|
|
|
|
|
/**
|
|
|
* 设备3表
|
|
|
- * 15分钟只执行一次
|
|
|
- *
|
|
|
+ * 15分钟只执行一次
|
|
|
*/
|
|
|
@XxlJob("equipment_PowerInfo4_PG")
|
|
|
public void equipment_PowerInfo4_PG() throws Exception {
|
|
|
|
|
|
XxlJobHelper.log("设备指标4调度程序执行开始!........");
|
|
|
|
|
|
- Date date=new Date();
|
|
|
-
|
|
|
+ Date date = new Date();
|
|
|
|
|
|
|
|
|
equipmentInfo4Service.calEquipmentInfoDay(date);
|
|
@@ -480,15 +885,14 @@ public class SaticSchedulePgTask {
|
|
|
|
|
|
/**
|
|
|
* 设备5表
|
|
|
- * 15分钟只执行一次
|
|
|
- *
|
|
|
+ * 15分钟只执行一次
|
|
|
*/
|
|
|
@XxlJob("equipment_PowerInfo5_PG")
|
|
|
public void equipment_PowerInfo5_PG() throws Exception {
|
|
|
|
|
|
XxlJobHelper.log("设备指标5调度程序执行开始!........");
|
|
|
|
|
|
- Date date=new Date();
|
|
|
+ Date date = new Date();
|
|
|
|
|
|
|
|
|
equipmentInfo5Service.calEquipmentInfoDay(date);
|
|
@@ -497,13 +901,14 @@ public class SaticSchedulePgTask {
|
|
|
XxlJobHelper.log("设备指标调度5程序执行完成!........");
|
|
|
|
|
|
}
|
|
|
+
|
|
|
/**
|
|
|
* 等级评估统计
|
|
|
* 每天执行一次
|
|
|
*/
|
|
|
|
|
|
@XxlJob("equipmentInfoDayTop_PG")
|
|
|
- public void equipmentInfoDayTop_PG() {
|
|
|
+ public void equipmentInfoDayTop_PG() {
|
|
|
|
|
|
|
|
|
XxlJobHelper.log("等级评估统计调度程序执行开始!........");
|
|
@@ -523,7 +928,7 @@ public class SaticSchedulePgTask {
|
|
|
*/
|
|
|
|
|
|
@XxlJob("windturbineGoodness_PG")
|
|
|
- public void windturbineGoodness_PG() {
|
|
|
+ public void windturbineGoodness_PG() {
|
|
|
|
|
|
|
|
|
XxlJobHelper.log("功率一致性系数和拟合优度统计调度程序执行开始!........");
|
|
@@ -537,7 +942,7 @@ public class SaticSchedulePgTask {
|
|
|
|
|
|
|
|
|
@XxlJob("wtAlysisDay_PG")
|
|
|
- public void wtAlysisDay_PG() {
|
|
|
+ public void wtAlysisDay_PG() {
|
|
|
|
|
|
|
|
|
XxlJobHelper.log("分析数据统计调度程序执行开始!........");
|
|
@@ -554,7 +959,7 @@ public class SaticSchedulePgTask {
|
|
|
* 每天2点执行一次
|
|
|
*/
|
|
|
@XxlJob("wtwindDayInfo_PG")
|
|
|
- public void wtwindDayInfo_PG() {
|
|
|
+ public void wtwindDayInfo_PG() {
|
|
|
|
|
|
|
|
|
XxlJobHelper.log("设备风资源统计调度程序执行开始!........");
|
|
@@ -571,7 +976,7 @@ public class SaticSchedulePgTask {
|
|
|
* 每天2点执行一次
|
|
|
*/
|
|
|
@XxlJob("wpwindDayInfo_PG")
|
|
|
- public void wpwindDayInfo_PG() {
|
|
|
+ public void wpwindDayInfo_PG() {
|
|
|
|
|
|
|
|
|
XxlJobHelper.log("场站风资源统计调度程序执行开始!........");
|
|
@@ -589,13 +994,13 @@ public class SaticSchedulePgTask {
|
|
|
*/
|
|
|
|
|
|
@XxlJob("calWindDeviation_PG")
|
|
|
- public void calWindDeviation_PG() {
|
|
|
+ public void calWindDeviation_PG() {
|
|
|
|
|
|
|
|
|
XxlJobHelper.log("对风偏差率调度程序执行开始!........");
|
|
|
String yesterdayStr = DateUtils.getYesterdayStr("yyyy-MM-dd");
|
|
|
try {
|
|
|
- windDeviationService.save(yesterdayStr,yesterdayStr);
|
|
|
+ windDeviationService.save(yesterdayStr, yesterdayStr);
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -1040,12 +1445,12 @@ public class SaticSchedulePgTask {
|
|
|
// XxlJobHelper.log("屯留吾元光伏电站停机记录调度任务处理完成!........");
|
|
|
// }
|
|
|
|
|
|
- /**
|
|
|
+ /**
|
|
|
* 短期功率预测精度计算
|
|
|
* 每两秒执行一次
|
|
|
*/
|
|
|
@XxlJob("shorttermpowerpredictionaccuracycalculator")
|
|
|
- public void shorttermpowerpredictionaccuracycalculator() {
|
|
|
+ public void shorttermpowerpredictionaccuracycalculator() {
|
|
|
|
|
|
XxlJobHelper.log("短期功率预测精度计算调度程序执行开始!........");
|
|
|
|
|
@@ -1053,9 +1458,14 @@ public class SaticSchedulePgTask {
|
|
|
|
|
|
|
|
|
// 输入数据
|
|
|
- double[] predictedPower ={}; { /* 96个点的预测功率值 */ };
|
|
|
- double[] actualPower ={}; { /* 96个点的实际功率值 */ };
|
|
|
- double installedCapacity=0 ; /* 装机容量 */;
|
|
|
+ double[] predictedPower = {};
|
|
|
+ { /* 96个点的预测功率值 */ }
|
|
|
+ ;
|
|
|
+ double[] actualPower = {};
|
|
|
+ { /* 96个点的实际功率值 */ }
|
|
|
+ ;
|
|
|
+ double installedCapacity = 0; /* 装机容量 */
|
|
|
+ ;
|
|
|
|
|
|
// 计算准确率
|
|
|
double accuracy = shortTermPowerPredictionAccuracyCalculator.calculateAccuracy(predictedPower, actualPower, installedCapacity);
|
|
@@ -1111,9 +1521,12 @@ public class SaticSchedulePgTask {
|
|
|
try {
|
|
|
|
|
|
// 输入数据
|
|
|
- double actualGeneration =0; /* 当日新能源场站非限电时段实际发电量 */;
|
|
|
- double availablePower =0; /* 当日新能源场站非限电时段可用电量 */;
|
|
|
- double installedCapacity = 0;/* 全场装机容量 */;
|
|
|
+ double actualGeneration = 0; /* 当日新能源场站非限电时段实际发电量 */
|
|
|
+ ;
|
|
|
+ double availablePower = 0; /* 当日新能源场站非限电时段可用电量 */
|
|
|
+ ;
|
|
|
+ double installedCapacity = 0;/* 全场装机容量 */
|
|
|
+ ;
|
|
|
|
|
|
// 计算日准确率
|
|
|
double accuracy = AvailablePowerAccuracyCalculator.calculateAccuracy(actualGeneration, availablePower);
|
|
@@ -1128,7 +1541,6 @@ public class SaticSchedulePgTask {
|
|
|
System.out.println("考核分数: " + score + "分/万千瓦");
|
|
|
|
|
|
|
|
|
-
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
@@ -1136,12 +1548,12 @@ public class SaticSchedulePgTask {
|
|
|
}
|
|
|
|
|
|
@XxlJob("PredictedPowerccuracy")
|
|
|
- public void Powerccuracy() {
|
|
|
+ public void Powerccuracy() {
|
|
|
|
|
|
|
|
|
XxlJobHelper.log("预测功率准确率计算执行开始!........");
|
|
|
try {
|
|
|
- powerService.predictedPower();
|
|
|
+ powerService.predictedPower();
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|