修复bug
parent
5b1ab08a77
commit
6f1ce5ffd9
|
|
@ -32,7 +32,7 @@ DATABASE_CONFIG = {
|
||||||
'host': os.getenv('DB_HOST', '10.100.51.161'),
|
'host': os.getenv('DB_HOST', '10.100.51.161'),
|
||||||
'user': os.getenv('DB_USER', 'root'),
|
'user': os.getenv('DB_USER', 'root'),
|
||||||
'password': os.getenv('DB_PASSWORD', 'sagacity'),
|
'password': os.getenv('DB_PASSWORD', 'sagacity'),
|
||||||
'database': os.getenv('DB_NAME', 'imeeting_dev'),
|
'database': os.getenv('DB_NAME', 'imeeting'),
|
||||||
'port': int(os.getenv('DB_PORT', '3306')),
|
'port': int(os.getenv('DB_PORT', '3306')),
|
||||||
'charset': 'utf8mb4'
|
'charset': 'utf8mb4'
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -411,12 +411,12 @@ class AsyncTranscriptionService:
|
||||||
try:
|
try:
|
||||||
with get_db_connection() as connection:
|
with get_db_connection() as connection:
|
||||||
cursor = connection.cursor()
|
cursor = connection.cursor()
|
||||||
|
|
||||||
# 清除该会议的现有转录分段
|
# 清除该会议的现有转录分段(防止重复插入)
|
||||||
# delete_query = "DELETE FROM transcript_segments WHERE meeting_id = %s"
|
delete_query = "DELETE FROM transcript_segments WHERE meeting_id = %s"
|
||||||
# cursor.execute(delete_query, (meeting_id,))
|
cursor.execute(delete_query, (meeting_id,))
|
||||||
# print(f"Deleted existing segments for meeting_id: {meeting_id}")
|
print(f"Deleted existing segments for meeting_id: {meeting_id}")
|
||||||
|
|
||||||
# 插入新的转录分段
|
# 插入新的转录分段
|
||||||
insert_query = '''
|
insert_query = '''
|
||||||
INSERT INTO transcript_segments (meeting_id, speaker_id, speaker_tag, start_time_ms, end_time_ms, text_content)
|
INSERT INTO transcript_segments (meeting_id, speaker_id, speaker_tag, start_time_ms, end_time_ms, text_content)
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue