Blame view

ais-structure/src/modules/customer/getCustomer.ctrl.js 4.53 KB
dd6ce15e   sumatek   add customer
1
2
3
4
var stats = require('../helper/stats.js'); 
var validatorHelper = require('../helper/validator.js');
var connection = require('../helper/connection.js');
var responseMsg = require('../helper/responseMsg.js');
84646faa   sumatek   update connection
5
var log = require('../helper/log.js');
3d36a443   Nattapon Wongpaet   add constant
6
var constant = require('../helper/constants.js')
dd6ce15e   sumatek   add customer
7

887b2ec5   Nattapon Wongpaet   update put customer
8
exports.getCustomer = async function (req, res, next) {    
dd6ce15e   sumatek   add customer
9
10
    var getCmd = "Customer";
    var sendCmd = "Customer";
50ad7d6d   Nattapon Wongpaet   update get vizcar...
11
    var d01 = "D01"
b253306b   Nattapon Wongpaet   update log get cu...
12
    var method = constant.METHOD.GET
818cf50b   Nattapon Wongpaet   update get custom...
13
14
    console.log(req.params);

b253306b   Nattapon Wongpaet   update log get cu...
15
    if(req.params.customerId){
9d8ce483   Nattapon Wongpaet   update url put
16
        var customerId = req.params.customerId;
b253306b   Nattapon Wongpaet   update log get cu...
17
    } else if(req.params.userData && req.params.userType){
9d8ce483   Nattapon Wongpaet   update url put
18
        var customerId = req.params.userData+"@"+req.params.userType;
818cf50b   Nattapon Wongpaet   update get custom...
19
    } else if(req.query.clientName && req.query.commandId){
b253306b   Nattapon Wongpaet   update log get cu...
20
21
        var customerId = req.query.clientName+"@"+req.query.commandId;
    }
9d8ce483   Nattapon Wongpaet   update url put
22

b253306b   Nattapon Wongpaet   update log get cu...
23

c4a567d0   sumatek   merge
24
25
    log.startlog(req,method+"_"+getCmd,req.query.commandId,customerId);
    log.logDetail.addInput(req,req.query.clientName,method+"_"+getCmd,constant.REQUEST,req,req.body);
79d9e534   Nattapon Wongpaet   update post customer
26

b77690fa   Nattapon Wongpaet   update post custo...
27
    var err = await validator(req,getCmd);
b253306b   Nattapon Wongpaet   update log get cu...
28

dd6ce15e   sumatek   add customer
29
30
    if(err.length > 0)
    {
c4a567d0   sumatek   merge
31
        log.addErrorSummary(req,req.query.clientName,method+"_"+getCmd,"null",constant.FAIL);
50ad7d6d   Nattapon Wongpaet   update get vizcar...
32
        log.log(err,'error');
dd6ce15e   sumatek   add customer
33
        var response = responseMsg.error(req,getCmd,40300);
81e85e64   sumatek   update customer
34
        // res.status(200).json(response);
dd6ce15e   sumatek   add customer
35
36
    }else
    {        
c4a567d0   sumatek   merge
37
        log.addSuccessSummary(req,req.query.clientName,method+"_"+getCmd,"null",constant.SUCCESS);
818cf50b   Nattapon Wongpaet   update get custom...
38
        var objectData = Object.assign(req.query,req.params);
c4a567d0   sumatek   merge
39
        const result = await connection.requestJsonToD01(req,objectData,sendCmd,method);
a55a3d02   Nattapon Wongpaet   update post custo...
40
        // console.log(Object.keys(result))
c4a567d0   sumatek   merge
41
        log.logDetail.addInput(req,d01,method+"_"+sendCmd,constant.RESPONSE,result,result.response);
dd6ce15e   sumatek   add customer
42
        if(typeof result.err === 'undefined'){
a1f044d9   sumatek   update parallel
43
44
            // console.log(result.response);
            var resultObj = result.response;
584b2672   Nattapon Wongpaet   update handler er...
45
            if(resultObj.resultCode.startsWith("2"))
dd6ce15e   sumatek   add customer
46
            {
f5ce0160   sumatek   update customer
47
                if(resultObj.resultData && resultObj.resultData.length>0)
dd6ce15e   sumatek   add customer
48
                {
584b2672   Nattapon Wongpaet   update handler er...
49
                    stats.receiveRestResponse(d01,method,sendCmd,constant.SUCCESS);
f5ce0160   sumatek   update customer
50
                    var response = responseMsg.success(req,getCmd,resultObj);
c4a567d0   sumatek   merge
51
                    log.addSuccessSummary(req,d01,method+"_"+sendCmd,response.resultCode,response.developerMessage);
dd6ce15e   sumatek   add customer
52
53
                }else
                {
584b2672   Nattapon Wongpaet   update handler er...
54
                    stats.receiveRestResponse(d01,method,sendCmd,constant.RESPONSERESULT.DATA_NOT_FOUND.developerMessage);
cf541103   Nattapon Wongpaet   update post custo...
55
                    var response = responseMsg.error(req,getCmd,40401);
a0638777   Nattapon Wongpaet   add try catch and...
56
                    log.addErrorSummary(req,d01,method+"_"+sendCmd,response.resultCode,response.developerMessage);
dd6ce15e   sumatek   add customer
57
                }
14b2d0f1   Nattapon Wongpaet   update handler error
58
            } else if(resultObj.resultCode.startsWith("404")){
cf541103   Nattapon Wongpaet   update post custo...
59
                stats.receiveRestResponse(d01,method,sendCmd,constant.RESPONSERESULT.DATA_NOT_FOUND.developerMessage);
14b2d0f1   Nattapon Wongpaet   update handler error
60
                var response = responseMsg.direct(req,getCmd,resultObj);
a0638777   Nattapon Wongpaet   add try catch and...
61
                log.addErrorSummary(req,d01,method+"_"+sendCmd,response.resultCode,response.developerMessage);
14b2d0f1   Nattapon Wongpaet   update handler error
62
            } else if(resultObj.resultCode.startsWith("5")){
584b2672   Nattapon Wongpaet   update handler er...
63
64
                stats.receiveRestResponse(d01,method,sendCmd,constant.ERROR);
                var response = responseMsg.direct(req,getCmd,resultObj);
a0638777   Nattapon Wongpaet   add try catch and...
65
                log.addErrorSummary(req,d01,method+"_"+sendCmd,response.resultCode,response.developerMessage);
14b2d0f1   Nattapon Wongpaet   update handler error
66
67
68
            } else {
                stats.receiveRestResponse(d01,method,sendCmd,constant.ERROR);
                var response = responseMsg.error(req,getCmd,50000);
dd6ce15e   sumatek   add customer
69
            }
53004544   Nattapon Wongpaet   update customer
70
        } else {
584b2672   Nattapon Wongpaet   update handler er...
71
72
73
            stats.receiveRestResponse(d01,method,sendCmd,constant.ERROR);
            var response = responseMsg.error(req,getCmd,50000);
            // log.addErrorSummary(d01,method+"_"+sendCmd,response.resultCode,response.developerMessage);
dd6ce15e   sumatek   add customer
74
        }
dd6ce15e   sumatek   add customer
75
    }
584b2672   Nattapon Wongpaet   update handler er...
76

c4a567d0   sumatek   merge
77
    log.logDetail.addOutput(req,req.query.clientName,method+"_"+getCmd,constant.RESPONSE,response,response); 
81e85e64   sumatek   update customer
78
    res.status(200).json(response);
dd1da2d3   sumatek   update connect
79
    next();
dd6ce15e   sumatek   add customer
80
81
82
83
84
85
};


function validator(req,api)
{
    var list = [];
b253306b   Nattapon Wongpaet   update log get cu...
86
87
    list.push([true,"queryStr","commandId","String"]);
    list.push([true,"queryStr","clientName","String"]);
dd6ce15e   sumatek   add customer
88
    var err = validatorHelper(req,list,api)
0ec6fba7   sumatek   update fix bug
89
   
b253306b   Nattapon Wongpaet   update log get cu...
90
91
92
93
94
95
96
97
    // if((typeof req.query["userType"] !== 'undefined') && (typeof req.query["userData"] === 'undefined'))
    // {
    //     var errDes = {
    //         Param : "userData",
    //         Reason : "Missing"
    //     }
    //     err.push(errDes);
    // }
dd6ce15e   sumatek   add customer
98
    
dd6ce15e   sumatek   add customer
99
    if(err.length > 0)    
a55a3d02   Nattapon Wongpaet   update post custo...
100
        stats.receiveBadRequest(req.method,api);    
dd6ce15e   sumatek   add customer
101
    else
a55a3d02   Nattapon Wongpaet   update post custo...
102
103
        stats.receiveRequest(req.method,api);
    
dd6ce15e   sumatek   add customer
104
105
    return err;
}