diff --git a/services/ad-platform-source/src/main/java/com/baiye/module/dao/ClueJpa.java b/services/ad-platform-source/src/main/java/com/baiye/module/dao/ClueJpa.java
index 52c0d2ea..23c650b1 100644
--- a/services/ad-platform-source/src/main/java/com/baiye/module/dao/ClueJpa.java
+++ b/services/ad-platform-source/src/main/java/com/baiye/module/dao/ClueJpa.java
@@ -111,6 +111,9 @@ public class ClueJpa {
         if (clueQueryCriteria.getClueCallStatus() != null){
             sql.append("and cm.clue_call_status = :clueCallStatus ");
         }
+        if (clueQueryCriteria.getClueStage() != null){
+            sql.append("and cm.clue_stage = :clueStage ");
+        }
         if (newestCallTimeList != null && newestCallTimeList.size() == 2){
             sql.append("and cm.newest_call_time between :createTimeBegin and :createTimeEnd ");
         }
@@ -136,6 +139,9 @@ public class ClueJpa {
         if (clueQueryCriteria.getMemberStatus() != null) {
             query.setParameter("memberStatus", clueQueryCriteria.getMemberStatus());
         }
+        if (clueQueryCriteria.getClueStage() != null){
+            query.setParameter("clueStage", clueQueryCriteria.getClueStage());
+        }
         if (clueQueryCriteria.getLabel() != null){
             query.setParameter("sourceLabel", "%" + clueQueryCriteria.getLabel() + "%");
         }