|
@@ -1748,10 +1748,17 @@ public class JavaFunctionJobHandler extends IJobHandler {
|
|
|
|
|
|
QueryWrapper<ProEconReportIndicatorPool> wrapperrp = new QueryWrapper<>();
|
|
|
wrapperrp.eq("record_date", time0)
|
|
|
- .in("foreign_key_id", days.stream().map(TurbineInfoDay::getStationId).collect(Collectors.toList()));
|
|
|
+ .in("foreign_key_id", days.stream().map(TurbineInfoDay::getProjectId).collect(Collectors.toList()));
|
|
|
List<ProEconReportIndicatorPool> pools = reportIndicatorPoolService.list(wrapperrp);
|
|
|
|
|
|
|
|
|
+ ProEconReportIndicatorPool GSPJFS = new ProEconReportIndicatorPool();
|
|
|
+ GSPJFS.setRecordDate(time0.toLocalDateTime().toLocalDate());
|
|
|
+ GSPJFS.setForeignKeyId("GJNY_SXGS_DBXNY_ZGS0");
|
|
|
+ GSPJFS.setCompanyId("GJNY_SXGS_DBXNY_ZGS");
|
|
|
+ reportIndicatorPoolService.save(GSPJFS);
|
|
|
+
|
|
|
+
|
|
|
|
|
|
wrapperrp = new QueryWrapper<>();
|
|
|
wrapperrp.eq("record_date", time0).eq("foreign_key_id", "GJNY_SXGS_DBXNY_ZGS0");
|
|
@@ -1762,7 +1769,7 @@ public class JavaFunctionJobHandler extends IJobHandler {
|
|
|
|
|
|
if (!pools.isEmpty()){
|
|
|
for (ProEconReportIndicatorPool pool : pools) {
|
|
|
- projectId = pool.getProjectId();
|
|
|
+ projectId = pool.getForeignKeyId();
|
|
|
day = dayMap.get(projectId);
|
|
|
pool.setRpjfs(day.getPjfs());
|
|
|
month = monthMap.get(projectId);
|
|
@@ -1785,7 +1792,7 @@ public class JavaFunctionJobHandler extends IJobHandler {
|
|
|
for (TurbineInfoDay day2 : days) {
|
|
|
ProEconReportIndicatorPool pool = new ProEconReportIndicatorPool();
|
|
|
pool.setRecordDate(time0.toLocalDateTime().toLocalDate());
|
|
|
- pool.setForeignKeyId(day2.getStationId());
|
|
|
+ pool.setForeignKeyId(day2.getProjectId());
|
|
|
poolList.add(pool);
|
|
|
}
|
|
|
reportIndicatorPoolService.saveOrUpdateBatch(poolList);
|