45 lines
1.2 KiB
Python
45 lines
1.2 KiB
Python
from sqlalchemy.orm import Session
|
|
from sqlalchemy import text
|
|
from db import models, schemas
|
|
from process.logger import logger
|
|
from db.base import get_db
|
|
|
|
|
|
#==================================================================================================
|
|
# 문의 관련
|
|
#==================================================================================================
|
|
|
|
# 문의 저장
|
|
async def insert_inquiry(inquiry, db):
|
|
try:
|
|
query = text("""
|
|
INSERT INTO inquiry (
|
|
user_seq,
|
|
user_email,
|
|
nickname,
|
|
title,
|
|
contents
|
|
)
|
|
VALUES (
|
|
:user_seq,
|
|
(select user_email from manage_user where user_seq = :user_seq),
|
|
(select nickname from manage_user where user_seq = :user_seq),
|
|
:title,
|
|
:contents
|
|
)
|
|
""")
|
|
params = {
|
|
"user_seq": inquiry['user_seq'],
|
|
"title": inquiry['title'],
|
|
"contents": inquiry['contents']
|
|
}
|
|
|
|
db.execute(query, params)
|
|
|
|
db.commit()
|
|
return True
|
|
except Exception as e:
|
|
logger.error(f"sql error: {e}")
|
|
return False
|
|
|