|
def save_history(conn, user_id, query, response, symptoms): |
|
cur = conn.cursor() |
|
cur.execute(""" |
|
INSERT INTO mb_history (user_id, query, response, symptoms) |
|
VALUES (%s, %s, %s, %s) |
|
""", (user_id, query, response, symptoms)) |
|
conn.commit() |
|
|
|
def get_user_history(conn, user_id): |
|
cur = conn.cursor() |
|
cur.execute(""" |
|
SELECT query, response, symptoms, created_at |
|
FROM mb_history |
|
WHERE user_id = %s |
|
ORDER BY created_at DESC |
|
""", (user_id,)) |
|
rows = cur.fetchall() |
|
return [{"query": r[0], "response": r[1], "symptoms": r[2], "created_at": r[3]} for r in rows] |
|
|