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
|
||
|
|