Nattapon Wongpaet / Hospital

Blame view

utils/mongoDB.js 3.83 KB
Edit Raw Normal View History
49559b6c   sumatek   merge 
1
 
const log = require('./log');
6fc87409   sumatek   update structure 
2
3
4
5
6
7
8
9
 
var constants = require('./constants');
var MongoClient = require('mongodb').MongoClient;
var config = require('./config');

var connection = {};
connection.reqMongo = async function (req,method, query, collection) {
    
    // console.log(req.id)
49559b6c   sumatek   merge 
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
 
    var mongoData = config.get('mongoDB');
    var url = "mongodb://"+mongoData.hopitalIp;
    var database = mongoData.hopitalName;
    var result = await mongoReq(req,url,database,method, query, collection);
    
    return result;
}


function mongoReq(req,url,database,method, query, collection){
    
    var nodeName = "MongoDB"; 
    var funStats = {
        detailSqlQuery : function(query){log.detailSqlQuery(req,collection,query);},
        detailSqlResult : function(result, err){log.detailSqlResult(req,collection,result || err);},
0b6272e0   sumatek   update template 
25
 
        addSuccessSummary : function(result){log.addSuccessSummary(req,nodeName,collection,result);},
57d157f6   sumatek   add stats post 
26
 
        addErrorSummary : function(result){log.addErrorSummary(req,nodeName,collection,result);}
0b6272e0   sumatek   update template 
27
28
 
    };
57d157f6   sumatek   add stats post 
29
2853a670   sumatek   update log 
30
31
 

    return new Promise((resolve, reject) => {
57d157f6   sumatek   add stats post 
32
33
34
35
 
        MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
            if (err) {
                console.log(err)                
                resolve(constants.RESPONSECONN.MESSAGE.DBERROR);
2853a670   sumatek   update log 
36
 
            }
57d157f6   sumatek   add stats post 
37
 
            funStats.detailSqlQuery(query);
2853a670   sumatek   update log 
38
 
            var dbInstant = db.db(database).collection(collection);
57d157f6   sumatek   add stats post 
39
 
            switch (method) {
0b6272e0   sumatek   update template 
40
41
42
43
44
 
                case constants.METHOD.GET:                
                    dbInstant.find(query, { projection: { _id: 0 } }).toArray(function(err, result) {                   
                    resolve(checkResponse(result,err,funStats));                        
                    });
                    break;
49559b6c   sumatek   merge 
45
46
47
48
 
                case constants.METHOD.POST:
                    db.db(database).collection(collection).insertOne(query, function(err, result) {
                    var response = checkResponse(result,err,funStats);
                    delete response.resultData;
0b6272e0   sumatek   update template 
49
50
 
                    resolve(response);
                    });
49559b6c   sumatek   merge 
51
 
                    break;
0b6272e0   sumatek   update template 
52
53
 
                case "PUT":
                    // db.db(database).collection(collection).find(query, { projection: { _id: 0 } }).toArray(function(err, result) {
49559b6c   sumatek   merge 
54
 
                    // db.close();
0b6272e0   sumatek   update template 
55
56
 
    
                    // if (err) {
30fb6c36   sumatek   update fixbug post 
57
 
                    //     console.log(err)
49559b6c   sumatek   merge 
58
59
 
                    //     resolve(checkResponse(req,{err:err}));
                    // }else
0b6272e0   sumatek   update template 
60
61
 
                    //     resolve(checkResponse(req,result));
                    // });
30fb6c36   sumatek   update fixbug post 
62
 
                    break;
0b6272e0   sumatek   update template 
63
64
 
                case "DELETE":
                    // db.db(database).collection(collection).find(query, { projection: { _id: 0 } }).toArray(function(err, result) {
49559b6c   sumatek   merge 
65
66
67
 
                    // db.close();
    
                    // if (err) {
0b6272e0   sumatek   update template 
68
69
 
                    //     console.log(err)                    
                    //     resolve(checkResponse(req,{err:err}));
49559b6c   sumatek   merge 
70
 
                    // }else
0b6272e0   sumatek   update template 
71
72
73
74
75
76
 
                    //     resolve(checkResponse(req,result));
                    // });
                    break;
                
            }
            db.close();
49559b6c   sumatek   merge 
77
78
 
        });
    });
0b6272e0   sumatek   update template 
79
80
 
    
}
49559b6c   sumatek   merge 
81
0b6272e0   sumatek   update template 
82
83
84
85
86
87
 
function checkResponse(result,err,funStats)
{    
   
    funStats.detailSqlResult(result, err); 
    if(err)
    {
49559b6c   sumatek   merge 
88
89
90
 
        var returnData = constants.RESPONSECONN.MESSAGE.DBERROR;
        funStats.addErrorSummary(returnData);        
    }
0b6272e0   sumatek   update template 
91
 
    else
49559b6c   sumatek   merge 
92
93
94
95
96
 
    {        
        if(result.length > 1)
        {    
            var returnData = constants.RESPONSERESULT.SUCCESS;
            returnData.resultData = result;
30fb6c36   sumatek   update fixbug post 
97
 
            funStats.addSuccessSummary(returnData);
0b6272e0   sumatek   update template 
98
99
100
101
 
        }else
        {
            var returnData = constants.RESPONSERESULT.DATA_NOT_FOUND;
            funStats.addErrorSummary(returnData);
49559b6c   sumatek   merge 
102
 
        }
0b6272e0   sumatek   update template 
103
104
105
106
107
 
    }

    return returnData
}
30fb6c36   sumatek   update fixbug post 
108
109
 

module.exports = connection;
5a3cfae2   sumatek   update log 












5a3cfae2
 
 sumatek
 
update log
















49559b6c
 
 sumatek
 
merge