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