feat(吉林演示): 松原

1.修改部分第三方数据处理定时任务,修改系统来源,将固定来源按环境区分改为动态获取;

BREAKING CHANGE: 无

Closes 无

[skip ci]

C12-prediction/pps-core-prediction/src/main/java/pps/core/prediction/service/ThirdDataAccessCloudServiceImpl.java

@@ -246,7 +246,7 @@ public class ThirdDataAccessCloudServiceImpl implements IThirdDataAccessCloudSer
                     .powerGeneration(power.getPhotovoltaicPower())
                     .powerConsumption(collect.get(lineId))
                     .dataDate(power.getCreateDate())
-                    .systemSource(ThirdPartyApiConstant.CQ_SOURCE)
+                    .systemSource(oilFieldCode)
                     .build());
         }
         return XTransactionHelper.begin(context, () -> {
@@ -435,6 +435,7 @@ public class ThirdDataAccessCloudServiceImpl implements IThirdDataAccessCloudSer
         List<ThirdActivePowerDailyUpdateView> dtoDailyList = new ArrayList<>(cachedDataList.size());
         BigDecimal photovoltaicPower;
         BigDecimal meterPower;
+        String oilFieldCode = ServiceUtil.getOilFieldCode(context);
         for (ThirdActivePowerExcelData o : cachedDataList) {
             photovoltaicPower = Optional.ofNullable(o.getPhotovoltaicPower())
                     .orElse(BigDecimal.ZERO)
@@ -449,13 +450,13 @@ public class ThirdDataAccessCloudServiceImpl implements IThirdDataAccessCloudSer
                             .createDate(o.getCreateDate())
                             .photovoltaicPower(photovoltaicPower)
                             .meterPower(meterPower)
-                            .systemSource(ThirdPartyApiConstant.CQ_SOURCE)
+                            .systemSource(oilFieldCode)
                             .inputTime(o.getCreateDate())
                             .build()
             );
             queryWrapper.or(w -> w.eq(ThirdActivePowerEnt::getStationName, o.getStationName())
                     .eq(ThirdActivePowerEnt::getCreateDate, o.getCreateDate())
-                    .eq(ThirdActivePowerEnt::getSystemSource, ThirdPartyApiConstant.CQ_SOURCE)
+                    .eq(ThirdActivePowerEnt::getSystemSource, oilFieldCode)
             );
             dtoDailyList.add(
                     ThirdActivePowerDailyUpdateView.builder()
@@ -464,7 +465,7 @@ public class ThirdDataAccessCloudServiceImpl implements IThirdDataAccessCloudSer
                             .createDate(o.getCreateDate())
                             .photovoltaicPower(photovoltaicPower)
                             .meterPower(meterPower)
-                            .systemSource(ThirdPartyApiConstant.CQ_SOURCE)
+                            .systemSource(oilFieldCode)
                             .saveDate(DateUtil.beginOfDay(o.getCreateDate()))
                             .saveHour(DateUtil.beginOfHour(o.getCreateDate()))
                             .build()