From e161101976b78703a5edd389540281843ac6faa4 Mon Sep 17 00:00:00 2001
From: yinzijian <yinzijian@haomozhixing.onaliyun.com>
Date: Mon, 23 Mar 2026 16:38:44 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E6=9F=A5=E8=AF=A2=E6=97=B6?=
 =?UTF-8?q?=E9=97=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Signed-off-by: yinzijian <yinzijian@haomozhixing.onaliyun.com>
---
 app/phase_db_func.py | 17 +++++++++++++++++
 1 file changed, 17 insertions(+)

diff --git a/app/phase_db_func.py b/app/phase_db_func.py
index f2fcbca..cb586b8 100644
--- a/app/phase_db_func.py
+++ b/app/phase_db_func.py
@@ -830,6 +830,23 @@ class PhaseTableDbHelper(TableDbHelperBase):
             return None, e
         finally:
             self.close(conn, cursor)
+    
+    def query_cross_phase_update_time(self, crossids, citycode):
+        conn, cursor = self.connect()
+        try:
+            sql = f"""select xl_crossid, max(update_time) max_update_time
+                        from phase_record
+                      where xl_crossid in %s
+                        and nodeid = %s
+                      group by xl_crossid"""
+            print(cursor.mogrify(sql, (crossids,citycode)))
+            cursor.execute(sql, (crossids,citycode))
+            result = cursor.fetchall()
+            return result, None
+        except Exception as error:
+            return None, error
+        finally:
+            self.close(conn, cursor)
 # if __name__ == '__main__':
 #     tt_5min = get_latest_5min_timestamp()
 #     print(tt_5min)