const db = require('../../db/index.js');
const { v4: uuidv4 } = require('uuid');

//疫苗接种列表
exports.openaiList = async (req, res) => { 

    const question = req.query.question; // 从查询参数获取用户名
    
    // 构建查询语句和参数数组，使用占位符和适当的逻辑操作符（如 AND 和 OR）
    let query = 'select * from ev_ai_list where 1=1'; // 使用恒等式作为基础条件，便于添加额外的条件而不改变原有逻辑结构。
    let values = []; // 初始化参数数组以防止SQL注入。
    if (question) {
        query += ' AND vaccine like ?'; // 使用 AND 来添加条件。
        values.push(`%${question}%`); // 将值添加到参数数组中。
    }

    db.query(query, values, (err, results) => {
        if (err) {
            return res.rescc(err);
        }
        
        const resultAll = {
            data: results,
            total: results.length
        }

        res.rescc("获取ai对话记录列表请求成功", 200, resultAll);
    })
}

//新增疫苗接种信息
exports.saveOpaiMessage = (req, res) => { 
    console.log("req===>>>", req)
    const ailistInfo = req.body

    const sessionId = uuidv4();
    ailistInfo.sessionId = sessionId

    const sql = "insert into ev_ai_list set ?"
    db.query(sql, ailistInfo, (err, results) => { 
        if (err) { 
            return res.rescc(err);
        }
        if (results.affectedRows !== 1) { 
            return res.rescc("添加失败，请稍后再试！");
        }
        res.rescc("添加成功", 200);
    })
}

//修改疫苗接种信息
// exports.updataVaccineInfo = (req, res) => { 

//     const sql = "update ev_vaccines set ? where id=?"

//     db.query(sql, [req.body, req.body.id], (err, results) => { 
//         if (err) { 
//             return res.rescc(err);
//         }
//         if (results.affectedRows !== 1) { 
//             return res.rescc("疫苗接种信息更新失败！");
//         }
//         res.rescc("疫苗接种信息更新成功！", 200)
//     })
// }

//删除疫苗接种信息
// exports.deleteVaccineInfo = (req, res) => { 

//     console.log('req===>>>', req)

//     const sql = "delete from ev_vaccines where id=?"

//     db.query(sql, req.params.id, (err, results) => { 
//         if (err) { 
//             return res.rescc(err);
//         }
//         if (results.affectedRows !== 1) { 
//             return res.rescc("疫苗接种信息删除失败！");
//         }
//         res.rescc("疫苗接种信息删除成功！", 200)
//     })
// }