diff --git a/ticket/core.py b/ticket/core.py
index 9f6d04f..32be136 100644
--- a/ticket/core.py
+++ b/ticket/core.py
@@ -545,7 +545,7 @@ async def list_staff_tickets(user_id, roles=None, queue='all', limit=100):
         if queue == 'pending':
             if not roles:
                 return []
-            ph = ','.join("'role%d'" % i for i in range(len(roles)))
+            ph = ','.join("'${role%d}$'" % i for i in range(len(roles)))
             for i, r in enumerate(roles):
                 params['role%d' % i] = r
             cond = ("status='human_pending' AND assignee_role IN (%s)" % ph)
diff --git a/ticket/todos.py b/ticket/todos.py
index 1b40c3b..54c81df 100644
--- a/ticket/todos.py
+++ b/ticket/todos.py
@@ -40,7 +40,7 @@ async def list_ticket_todos(user_id, roles=None, limit=100):
         conds.append("(assignee_id=${u}$ AND status='human_processing')")
         # ③ 角色池视角：待认领且受理角色∈我的角色
         if roles:
-            ph = ','.join("'r%d'" % i for i in range(len(roles)))
+            ph = ','.join("'${r%d}$'" % i for i in range(len(roles)))
             for i, r in enumerate(roles):
                 params['r%d' % i] = r
             conds.append("(status='human_pending' AND assignee_role IN (%s))" % ph)