diff --git a/src/main/java/com/docus/server/collection/infrastructure/dao/mapper/TBasicMapper.java b/src/main/java/com/docus/server/collection/infrastructure/dao/mapper/TBasicMapper.java
index 7977dc5..bf48bd8 100644
--- a/src/main/java/com/docus/server/collection/infrastructure/dao/mapper/TBasicMapper.java
+++ b/src/main/java/com/docus/server/collection/infrastructure/dao/mapper/TBasicMapper.java
@@ -23,4 +23,6 @@ public interface TBasicMapper{
     Integer update(@Param("tBasic") TBasic tBasic);
 
     String getPatientIdByJzh(@Param("jzh") String jzh);
+
+    List<String> getPatientIdByMomJzh(@Param("momJzh") String momJzh);
 }
diff --git a/src/main/java/com/docus/server/collection/service/impl/MzZyHisServiceImpl.java b/src/main/java/com/docus/server/collection/service/impl/MzZyHisServiceImpl.java
index a4d5f75..47a03ce 100644
--- a/src/main/java/com/docus/server/collection/service/impl/MzZyHisServiceImpl.java
+++ b/src/main/java/com/docus/server/collection/service/impl/MzZyHisServiceImpl.java
@@ -19,10 +19,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.stream.Collectors;
 
 /**
@@ -43,7 +40,6 @@ public class MzZyHisServiceImpl implements MzZyHisService {
 
     @Override
     public void firstPageCheckout(FirstPageCheckoutInDTO dto) {
-        System.out.println(dto);
         PatientInfoDTO patientInfo = dto.getPatientInfo();
         //验证基础数据是否存在
         String patientId = tBasicMapper.getPatientIdByJzh(patientInfo.getInpatientNo());
@@ -67,6 +63,27 @@ public class MzZyHisServiceImpl implements MzZyHisService {
         if (result.getCode().equals(ResultCode.FAILED.getCode())) {
             throw new RuntimeException(commonResult.getMsg());
         }
+        babyTaskCompensate(patientInfo.getInpatientNo(),collectorIds);
+    }
+
+    /**
+     * 根据母亲的住院流水号，查询宝宝的病案主键，进行任务补偿
+     * @param momJzh 母亲住院流水号
+     * @param collectorIds 采集器id
+     */
+    private void babyTaskCompensate(String momJzh, List<String> collectorIds) {
+        List<String> babyPatientIds=tBasicMapper.getPatientIdByMomJzh(momJzh);
+        if(Func.isNotEmpty(babyPatientIds)){
+            // 进行任务补偿
+            CompensateTasRequest request = new CompensateTasRequest();
+            request.setPatientIds(babyPatientIds);
+            request.setPriority(4);
+            request.setCollectorIds(collectorIds);
+            collectTaskService.compensateTask(request);
+            for (String babyPatientId : babyPatientIds) {
+                medicalrecordService.signOutOrBackRepair(babyPatientId);
+            }
+        }
     }
 
     private List<String> systemMappingCollectorIds(FirstPageCheckoutInDTO dto) {
diff --git a/src/main/resources/mapper/TBasicMapper.xml b/src/main/resources/mapper/TBasicMapper.xml
index 83d0fc8..3a92f97 100644
--- a/src/main/resources/mapper/TBasicMapper.xml
+++ b/src/main/resources/mapper/TBasicMapper.xml
@@ -88,5 +88,8 @@
     <select id="getPatientIdByJzh" resultType="java.lang.String">
         select patient_id from `docus_medicalrecord`.`t_basic` where jzh=#{jzh}
     </select>
+    <select id="getPatientIdByMomJzh" resultType="java.lang.String">
+        select patient_id from `docus_medicalrecord`.`t_basic` where mother_inpatient_no=#{momJzh}
+    </select>
 
 </mapper>