diff --git a/server/tasks/lark/chat.py b/server/tasks/lark/chat.py
index 16e72f55..64e08ae6 100644
--- a/server/tasks/lark/chat.py
+++ b/server/tasks/lark/chat.py
@@ -5,15 +5,23 @@
 from urllib.parse import urlparse
 
 from celery_app import app, celery
-from model.schema import ChatGroup, CodeApplication, Repo, Team, db
+from model.schema import (
+    ChatGroup,
+    CodeApplication,
+    CodeUser,
+    IMUser,
+    Repo,
+    Team,
+    TeamMember,
+    db,
+)
 from model.team import get_code_users_by_openid
-from tasks.github.issue import on_issue_opened
-from tasks.github.pull_request import on_pull_request_opened
+from sqlalchemy.orm import aliased
 from tasks.lark.issue import replace_im_name_to_github_name
-from tasks.lark.manage import send_manage_fail_message
 from utils.github.repo import GitHubAppRepo
 from utils.lark.chat_manual import ChatManual, ChatView
 from utils.lark.chat_tip_failed import ChatTipFailed
+from utils.lark.issue_card import IssueCard
 from utils.lark.post_message import post_content_to_markdown
 
 from .base import (
@@ -284,10 +292,12 @@ def create_issue(
     # 这里连三个表查询，所以一次性都查出来
     code_users = get_code_users_by_openid([openid] + users)
 
+    import tasks
+
     if openid not in code_users:
         host = os.environ.get("DOMAIN")
 
-        return send_manage_fail_message(
+        return tasks.send_manage_fail_message(
             f"[请点击绑定 GitHub 账号后重试]({host}/api/github/oauth)",
             app_id,
             message_id,
@@ -445,10 +455,12 @@ def sync_issue(
     # 这里连三个表查询，所以一次性都查出来
     code_users = get_code_users_by_openid([openid])
 
+    import tasks
+
     if openid not in code_users:
         host = os.environ.get("DOMAIN")
 
-        return send_manage_fail_message(
+        return tasks.send_manage_fail_message(
             f"[请点击绑定 GitHub 账号后重试]({host}/api/github/oauth)",
             app_id,
             message_id,
@@ -470,7 +482,7 @@ def sync_issue(
     if is_pr:
         pull_request = github_app.get_one_pull_request(team.name, repo.name, issue_id)
         logging.debug("get_one_pull_requrst %r", pull_request)
-        return on_pull_request_opened(
+        return tasks.on_pull_request_opened(
             {
                 "action": "opened",
                 "sender": pull_request["user"],
@@ -481,7 +493,7 @@ def sync_issue(
     else:
         issue = github_app.get_one_issue(team.name, repo.name, issue_id)
         logging.debug("get_one_issue %r", issue)
-        return on_issue_opened(
+        return tasks.on_issue_opened(
             {
                 "action": "opened",
                 "sender": issue["user"],