const logger = require('../../utils/request-logger');
var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://10.1.2.155:27017/";
const database = "spw"

var connection = {};

connection.reqMongo = async function (req, query, collection) {

    console.log(req.id)

    var result = await mongoReq(req, query, collection);
    
    return result;
}


function mongoReq(req, query, collection){

    logger.logSqlQuery({id : "session", reqId : req.id}, query);

    return new Promise((resolve, reject) => {
        MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
            if (err) {
                console.log(err)
                logger.logSqlResult({id : "session", reqId : req.id}, err.errmsg);
                resolve({
                    resultCode : "50001",
                    message : err.errmsg
                });
            }

            var dbo = db.db(database);
            dbo.collection(collection).find(query, { projection: { _id: 0 } }).toArray(function(err, result) {
                db.close();

                if (err) {
                    console.log(err)
                    logger.logSqlResult({id : "session", reqId : req.id}, err.errmsg);
                    resolve({
                        resultCode : "50001",
                        message : err.errmsg
                    });
                }
                logger.logSqlResult({id : "session", reqId : req.id}, result);
                resolve({
                    resultCode : "20000",
                    resultDescription : "Success",
                    resultData : result
                });
            });
        });
    });
}


module.exports = connection;