/**
 * 搜索功能。
 */
"use strict";

let ImDb = require('../mysql/db/im.db');
let DbUtil = require('../../util/db.util');
let log = require('../../util/log.js');
const DB_TABLES = require('../../include/commons').DB_TABLES;
class TopicRepo {
    constructor() {
    }

    /**
     *
     * 保存议题
     * @param sessionId
     */
    static saveTopic(topicName,topicId,sessionId,messageId,date,description,status) {
        let sql = "insert into topics (id,session_id,name,create_time,start_message_id,description,status) VALUES (?,?,?,?,?,?,?)";
        ImDb.execQuery({
            "sql": sql,
            "args": [topicId,sessionId,topicName,date,messageId,description,status],
            "handler": function (err, res) {
                if (err) {
                    log.error("saveTopic is fail error: " + err+"messageId:"+messageId);
                }else{
                    log.info("saveTopic is success" );
                }
            }
        });
    }

    /**
     * 结束议题
     *
     * @param sessionId
     * @param handler
     */
    static endTopic(topicId,endUser,date,messageId,status) {
        let sql = "update topics set end_by = ?,end_time=?,end_message_id=?,status = ? where  id = ?";
        ImDb.execQuery({
            "sql": sql,
            "args": [endUser,date,messageId,status ,topicId],
            "handler": function (err, res) {
                if (err) {
                    log.error("endTopic is fail error: " + err);
                }else{
                    log.info("endTopic is success" );
                }
            }
        });
    }

    static updateTopis(topicId,jsonValue){
        var values=[];
        let sql = "update topics set ";
        for(var j in jsonValue){
            sql=sql+j+"= ?,";
            values.push(jsonValue[j]);
        }
        sql =  sql.substring(0,sql.lastIndexOf(","));
        sql = sql + "where  id = ?";
        values.push(topicId);
        ImDb.execQuery({
            "sql": sql,
            "args": values,
            "handler": function (err, res) {
                if (err) {
                    log.error("updateTopis is fail error: " + err);
                }else{
                    log.info("updateTopis is success" );
                }
            }
        });
    }
}

module.exports = TopicRepo;