Nattapon Wongpaet / Hospital

Blame view

utils/mongoDB.js 4.18 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
 
const stat = require('./stats');
var constants = require('./constants');
var MongoClient = require('mongodb').MongoClient;
var config = require('./config');

var connection = {};
connection.reqMongo = async function (req,method, query, collection) {
49559b6c   sumatek   merge 
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
 
    // console.log(req.id)
    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 = {
0b6272e0   sumatek   update template 
25
 
        detailSqlQuery : function(query){
57d157f6   sumatek   add stats post 
26
 
            log.detailSqlQuery(req,method,collection,query);
0b6272e0   sumatek   update template 
27
28
 
            stat.sendQuery(method,collection);
        },
57d157f6   sumatek   add stats post 
29
 
        detailSqlResult : function(result, err){
2853a670   sumatek   update log 
30
31
 
            log.detailSqlResult(req,collection,result || err);
            if(result)
57d157f6   sumatek   add stats post 
32
33
34
35
 
                stat.receiveQuery(method,collection);
            else
                stat.receiveBadQuery(method,collection);   
        },
2853a670   sumatek   update log 
36
 
        addSuccessSummary : function(result){log.addSuccessSummary(req,nodeName,collection,result);},
57d157f6   sumatek   add stats post 
37
 
        addErrorSummary : function(result){log.addErrorSummary(req,nodeName,collection,result);}
2853a670   sumatek   update log 
38
 
    };
57d157f6   sumatek   add stats post 
39
0b6272e0   sumatek   update template 
40
41
42
43
44
 
   

    return new Promise((resolve, reject) => {
        MongoClient.connect(url, { useNewUrlParser: true }, function(err, db) {
            if (err) {
49559b6c   sumatek   merge 
45
46
47
48
 
                console.log(err)                
                resolve(constants.RESPONSECONN.MESSAGE.DBERROR);
            }
            funStats.detailSqlQuery(query);
0b6272e0   sumatek   update template 
49
50
 
            var dbInstant = db.db(database).collection(collection);
            switch (method) {
49559b6c   sumatek   merge 
51
 
                case constants.METHOD.GET:
0b6272e0   sumatek   update template 
52
53
 
                    dbInstant.find(query, { projection: { _id: 0 } }).toArray(function(err, result) {                   
                    resolve(checkResponse(method,result,err,funStats));
49559b6c   sumatek   merge 
54
 
                    });
0b6272e0   sumatek   update template 
55
56
 
                    break;
                case constants.METHOD.POST:
30fb6c36   sumatek   update fixbug post 
57
 
                    db.db(database).collection(collection).insertOne(query, function(err, result) {
49559b6c   sumatek   merge 
58
59
 
                    var response = checkResponse(method,result,err,funStats);
                    delete response.resultData;
0b6272e0   sumatek   update template 
60
61
 
                    resolve(response);
                    });
30fb6c36   sumatek   update fixbug post 
62
 
                    break;
0b6272e0   sumatek   update template 
63
64
 
                case "PUT":
                    // 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;
                case "DELETE":
                    // db.db(database).collection(collection).find(query, { projection: { _id: 0 } }).toArray(function(err, result) {
                    // db.close();
49559b6c   sumatek   merge 
77
78
 
    
                    // if (err) {
0b6272e0   sumatek   update template 
79
80
 
                    //     console.log(err)                    
                    //     resolve(checkResponse(req,{err:err}));
49559b6c   sumatek   merge 
81
 
                    // }else
0b6272e0   sumatek   update template 
82
83
84
85
86
87
 
                    //     resolve(checkResponse(req,result));
                    // });
                    break;
                
            }
            db.close();
49559b6c   sumatek   merge 
88
89
90
 
        });
    });
0b6272e0   sumatek   update template 
91
 
}
49559b6c   sumatek   merge 
92
93
94
95
96
 

function checkResponse(method,result,err,funStats)
{    
   
    funStats.detailSqlResult(result, err);
30fb6c36   sumatek   update fixbug post 
97
 
    if(err)
0b6272e0   sumatek   update template 
98
99
100
101
 
    {
        var returnData = constants.RESPONSECONN.MESSAGE.DBERROR;
        funStats.addErrorSummary(returnData);        
    }
49559b6c   sumatek   merge 
102
 
    else
0b6272e0   sumatek   update template 
103
104
105
106
107
 
    {        
        if(result.length == 0 && constants.METHOD.GET == method )
        {
            var returnData = constants.RESPONSERESULT.DATA_NOT_FOUND;
            funStats.addErrorSummary(returnData);
30fb6c36   sumatek   update fixbug post 
108
109
110
111
112
113
114
 
            
        }else
        {
            var returnData = constants.RESPONSERESULT.SUCCESS;
            returnData.resultData = result;
            funStats.addSuccessSummary(returnData);
        }
5a3cfae2   sumatek   update log 
115
116
117
 
    }

    return returnData
5a3cfae2   sumatek   update log 
118
 
}
49559b6c   sumatek   merge 
119
120
121
 


module.exports = connection;