diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/send/impl/PqTypicalSourceCreatePOServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/send/impl/PqTypicalSourceCreatePOServiceImpl.java
index 312aaf386..957275725 100644
--- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/send/impl/PqTypicalSourceCreatePOServiceImpl.java
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/send/impl/PqTypicalSourceCreatePOServiceImpl.java
@@ -197,12 +197,12 @@ public class PqTypicalSourceCreatePOServiceImpl extends ServiceImpl<PqTypicalSou
                     rMpPartHarmonicDetailDS = new ArrayList<>();
                     effectiveMonitorNum = 0;
                 }
-                pqTypicalSourceCreatePO = initPqTypicalSourceCreatePO(pqTypicalSourceCreatePO,rMpPartHarmonicDetailDS,rMpSurplusHarmonicDetailDS,collect1.size());
+                pqTypicalSourceCreatePO = initPqTypicalSourceCreatePO(pqTypicalSourceCreatePO,rMpPartHarmonicDetailDS,rMpSurplusHarmonicDetailDS,monitorIds.size());
                 pqTypicalSourceCreatePO.setIndexType(temp);
                 pqTypicalSourceCreatePO.setStatisticalDate(calculatedParam.getDataDate());
                 pqTypicalSourceCreatePO.setStatisticalType("03");
-                pqTypicalSourceCreatePO.setMonitorNum(effectiveMonitorNum);
-                pqTypicalSourceCreatePO.setMonitorCount(effectiveMonitorNum);
+                pqTypicalSourceCreatePO.setMonitorNum(monitorIds.size());
+                pqTypicalSourceCreatePO.setMonitorCount(monitorIds.size());
                 pqTypicalSourceCreatePO.setMonitoringRate(divideAndRound(effectiveMonitorNum,collect1.size()));
                 if (mapCode.containsKey(deptGetChildrenMoreDTO.getUnitId())) {
                     PvTerminalTreeVO pvTerminalTreeVO = mapCode.get(deptGetChildrenMoreDTO.getUnitId());