From e6756c74da2920cb303a826a8a16f610d825e6df Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=9B=B7=E9=9B=A8?= <leiy36@chinaunicom.cn>
Date: Fri, 24 Oct 2025 17:32:38 +0800
Subject: [PATCH] =?UTF-8?q?feat:=E4=BF=AE=E6=94=B9=E9=97=AE=E7=AD=94?=
 =?UTF-8?q?=E7=A4=BA=E4=BE=8B=E9=94=99=E8=AF=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 main_service.py  |  5 +++--
 util/q_a_next.py | 22 ++++++++++++++++++++--
 2 files changed, 23 insertions(+), 4 deletions(-)

diff --git a/main_service.py b/main_service.py
index 4681deb..1a21776 100644
--- a/main_service.py
+++ b/main_service.py
@@ -58,9 +58,10 @@ def create_vana():
 def init_vn(vn):
     logger.info("--------------init vana-----connect to datasouce db----")
     connect_database(vn)
-    load_ddl_doc.add_ddl(vn)
-    load_ddl_doc.add_documentation(vn)
+
     if config('IS_FIRST_LOAD', default=False, cast=bool):
+        load_ddl_doc.add_ddl(vn)
+        load_ddl_doc.add_documentation(vn)
         load_train_data_ddl(vn)
     return vn
 
diff --git a/util/q_a_next.py b/util/q_a_next.py
index a2bf68c..2d6d609 100644
--- a/util/q_a_next.py
+++ b/util/q_a_next.py
@@ -120,7 +120,7 @@ org_and_attend_q_a = [
                          COUNT(ps.id) AS "late_count"
                   FROM "YJOA_APPSERVICE_DB"."t_pr3rl2oj_yj_person_database" p
                            JOIN "IUAP_APDOC_BASEDOC"."org_orgs" o ON p.internal_dept = o.id
-                           JOIN "YJOA_APPSERVICE_DB"."t_yj_person_status" ps ON p.id = ps.person_id
+                           JOIN "YJOA_APPSERVICE_DB"."t_yj_person_status" ps ON p.code = ps.person_id
                   WHERE p.dr = 0
                     AND ps.dr = 0
                     AND ps.status = '1006'
@@ -217,6 +217,24 @@ org_and_attend_q_a = [
                          ''',
         "tags": ["员工", "部门", "考勤", "迟到","人数","最值"],
         "category": "考勤管理"
-    }
+    },
+    {
+        "question": "XX中心在藏最长时间的人是谁",
+        "answer": '''
+                  SELECT p."name" AS "姓名", p."code" AS "工号", COUNT(ps."id") AS "在藏天数"
+                  FROM YJOA_APPSERVICE_DB."t_yj_person_status" ps
+                           JOIN YJOA_APPSERVICE_DB."t_pr3rl2oj_yj_person_database" p ON ps."person_id" = p."code"
+                  WHERE ps."is_in_tibet" = 1
+                    AND ps."dr" = 0
+                    AND p."dr" = 0
+                    and p.internal_dept in (SELECT "id"
+                                            FROM "IUAP_APDOC_BASEDOC"."org_orgs" START
+                  WITH "name"||"shortname" LIKE '%xx中心%' AND "dr"=0 AND "enable"=1 AND "code" LIKE '%CYJ%'
+                  CONNECT BY PRIOR "id" = "parentid"
+                      )
+                  GROUP BY p."name", p."code"
+                  ORDER BY COUNT (ps."id") DESC LIMIT 1
+                  '''
+    },
 
 ]