得到的

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

@@ -55,67 +55,6 @@ import java.util.stream.Collectors;
 @XService
 public class ThirdDataAccessCloudServiceImpl implements IThirdDataAccessCloudService {
 
-    public XServiceResult test(XContext context) {
-        //条件查询实际功率
-        IThirdActivePowerCloudService service = context.getBean(IThirdActivePowerCloudService.class);
-        XListResult<pps.cloud.middle.service.data.third_active_power.GetThirdActivePowerViewOutput> result = service.getThirdActivePowerList(context, GetThirdActivePowerViewInput.builder()
-                .build());
-        result.throwIfFail();
-        List<GetThirdActivePowerViewOutput> outputs = XCopyUtils.copyNewList(result.getResult(), GetThirdActivePowerViewOutput.class);
-        //数据处理
-        if (CollUtil.isEmpty(outputs)) {
-            return XServiceResult.OK;
-        }
-        Map<String, String> collect = this.getPhotovoltaicPlantMap(context);
-        List<ThirdActivePowerView> dtoList = new ArrayList<>(outputs.size());
-        List<ThirdActivePowerDailyUpdateView> dtoDailyList = new ArrayList<>(outputs.size());
-        DateTime now = DateTime.now();
-        DateTime saveDate = DateUtil.beginOfDay(now);
-        DateTime saveHour = DateUtil.beginOfHour(now);
-        LambdaQueryWrapper<ThirdActivePowerEnt> queryWrapper = new LambdaQueryWrapper<ThirdActivePowerEnt>()
-                .select(ThirdActivePowerEnt::getId);
-        for (GetThirdActivePowerViewOutput o : outputs) {
-            BigDecimal photovoltaicPower = Optional.ofNullable(o.getPhotovoltaicPower())
-                    .orElse(BigDecimal.ZERO)
-                    .abs();
-            BigDecimal meterPower = Optional.ofNullable(o.getMeterPower())
-                    .orElse(BigDecimal.ZERO)
-                    .abs();
-            dtoList.add(
-                    ThirdActivePowerView.builder()
-                            .id(BaseUtils.randomUUIDString())
-                            .stationName(o.getStationName())
-                            .stationId(collect.get(o.getStationName()))
-                            .createDate(o.getCreateDate())
-                            .photovoltaicPower(photovoltaicPower)
-                            .meterPower(meterPower)
-                            .systemSource("SY")
-                            .inputTime(now)
-                            .build()
-            );
-            queryWrapper.or(w -> w.eq(ThirdActivePowerEnt::getStationName, o.getStationName())
-                    .eq(ThirdActivePowerEnt::getCreateDate, o.getCreateDate())
-                    .eq(ThirdActivePowerEnt::getPhotovoltaicPower, photovoltaicPower)
-                    .eq(ThirdActivePowerEnt::getMeterPower, meterPower)
-                    .eq(ThirdActivePowerEnt::getSystemSource, "SY")
-            );
-            dtoDailyList.add(
-                    ThirdActivePowerDailyUpdateView.builder()
-                            .id(BaseUtils.randomUUIDString())
-                            .stationName(o.getStationName())
-                            .stationId(collect.get(o.getStationName()))
-                            .createDate(o.getCreateDate())
-                            .photovoltaicPower(photovoltaicPower)
-                            .meterPower(meterPower)
-                            .systemSource("SY")
-                            .saveDate(saveDate)
-                            .saveHour(saveHour)
-                            .build()
-            );
-        }
-        return this.batchInsertThirdActive(context, queryWrapper, saveHour, dtoList, dtoDailyList);
-    }
-
     /**
      * 第三方有功功率定时任务
      *