56 lines
1.5 KiB
Python
56 lines
1.5 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_survey_update_survey_yn(survey, db):
|
||
|
|
try:
|
||
|
|
for question, answer in zip(survey['question_list'], survey['answer_list']):
|
||
|
|
query = text("""
|
||
|
|
INSERT INTO survey (
|
||
|
|
user_seq,
|
||
|
|
question_msg,
|
||
|
|
answer_msg
|
||
|
|
)
|
||
|
|
VALUES (
|
||
|
|
:user_seq,
|
||
|
|
:question,
|
||
|
|
:answer
|
||
|
|
)
|
||
|
|
""")
|
||
|
|
|
||
|
|
# :user_seq, :question, :answer 자리에 들어갈 파라미터 정의
|
||
|
|
params = {
|
||
|
|
"user_seq": survey['user_seq'],
|
||
|
|
"question": question,
|
||
|
|
"answer": answer
|
||
|
|
}
|
||
|
|
db.execute(query, params)
|
||
|
|
|
||
|
|
query = text("""
|
||
|
|
update manage_user
|
||
|
|
set
|
||
|
|
survey_yn = 'Y'
|
||
|
|
where
|
||
|
|
user_seq = :user_seq
|
||
|
|
""")
|
||
|
|
params = {
|
||
|
|
"user_seq": survey['user_seq'],
|
||
|
|
}
|
||
|
|
|
||
|
|
db.execute(query, params)
|
||
|
|
|
||
|
|
db.commit()
|
||
|
|
return True
|
||
|
|
except Exception as e:
|
||
|
|
logger.error(f"sql error: {e}")
|
||
|
|
return False
|
||
|
|
|