8221da7a
Nattapon Wongpaet
update flow membe...
|
1
2
3
4
5
6
7
8
9
10
11
|
var parseJson = require('xml-js');
var stats = require('../helper/stats.js');
var messageSOAP = require('../helper/messageSOAP.js');
var validatorHelper = require('../helper/validator.js');
var connection = require('../helper/connection.js');
var responseMsg = require('../helper/responseMsg.js');
var log = require('../helper/log.js');
var constant = require('../helper/constants.js')
exports.getMembership = async function (req, res, next) {
|
818cf50b
Nattapon Wongpaet
update get custom...
|
12
13
14
15
|
var getCmd = "CustomerMembership";
var sendCusCmd = "Customer";
var sendMemCmd = "MemberCard";
var d01 = "D01";
|
8221da7a
Nattapon Wongpaet
update flow membe...
|
16
17
|
var method = constant.METHOD.GET;
|
818cf50b
Nattapon Wongpaet
update get custom...
|
18
19
20
21
22
23
24
|
if(req.params.customerId){
var customerId = req.params.customerId
} else if(req.params.userData && req.params.userType){
var customerId = req.params.userData+"@"+req.params.userType
} else if(req.query.clientName && req.query.commandId){
var customerId = req.query.clientName+"@"+req.query.commandId;
}
|
8221da7a
Nattapon Wongpaet
update flow membe...
|
25
|
|
1f123eb1
Nattapon Wongpaet
update post membe...
|
26
27
|
log.startlog(method+"_"+getCmd,req.query.commandId,customerId);
log.logDetail.addInput(req.query.clientName,method+"_"+getCmd,constant.REQUEST,req,req.body);
|
8221da7a
Nattapon Wongpaet
update flow membe...
|
28
|
|
b77690fa
Nattapon Wongpaet
update post custo...
|
29
|
var err = validator(req,getCmd);
|
8221da7a
Nattapon Wongpaet
update flow membe...
|
30
31
32
|
if(err.length > 0)
{
|
1f123eb1
Nattapon Wongpaet
update post membe...
|
33
|
log.addErrorSummary(req.query.clientName,method+"_"+getCmd,"null","Fail");
|
8221da7a
Nattapon Wongpaet
update flow membe...
|
34
35
|
log.log(err,'error');
var response = responseMsg.error(req,getCmd,40300);
|
8221da7a
Nattapon Wongpaet
update flow membe...
|
36
37
|
}else
{
|
1f123eb1
Nattapon Wongpaet
update post membe...
|
38
|
log.addSuccessSummary(req.query.clientName,method+"_"+getCmd,"null","Success");
|
818cf50b
Nattapon Wongpaet
update get custom...
|
39
|
var objectData = Object.assign(req.query,req.params);
|
03f3be38
Nattapon Wongpaet
fix bugs
|
40
|
const result = await connection.requestJsonToD01(objectData,sendCusCmd,method);
|
1f123eb1
Nattapon Wongpaet
update post membe...
|
41
|
log.logDetail.addInput(d01,method+"_"+sendCusCmd,constant.RESPONSE,result,result.response);
|
887b2ec5
Nattapon Wongpaet
update put customer
|
42
|
|
9a512329
Nattapon Wongpaet
no flow membership
|
43
44
|
//Get Customer
if(typeof result.err === 'undefined'){
|
8221da7a
Nattapon Wongpaet
update flow membe...
|
45
|
var resultObj = result.response;
|
818cf50b
Nattapon Wongpaet
update get custom...
|
46
47
48
49
50
|
if(resultObj.resultCode.startsWith("2"))
{
if(resultObj.resultData && resultObj.resultData.length>0)
{
log.addSuccessSummary(d01,method+"_"+sendCusCmd,resultObj.resultCode,resultObj.resultDescription);
|
887b2ec5
Nattapon Wongpaet
update put customer
|
51
|
var cusIdArr = [];
|
818cf50b
Nattapon Wongpaet
update get custom...
|
52
|
stats.receiveRestResponse(d01,method,sendCusCmd,constant.SUCCESS);
|
887b2ec5
Nattapon Wongpaet
update put customer
|
53
|
for(var i = 0; i < resultObj.resultData.length; i++){
|
818cf50b
Nattapon Wongpaet
update get custom...
|
54
55
56
|
cusIdArr.push(resultObj.resultData[i].customerId)
}
objectData = {customerId : cusIdArr}
|
03f3be38
Nattapon Wongpaet
fix bugs
|
57
58
|
const resultMemberCard = await connection.requestJsonToD01(objectData,sendMemCmd,method);
|
818cf50b
Nattapon Wongpaet
update get custom...
|
59
|
//Get MemberCard handler
|
9a512329
Nattapon Wongpaet
no flow membership
|
60
61
|
if(typeof resultMemberCard.err === 'undefined'){
if(resultObj.resultCode.startsWith("2")){
|
b77690fa
Nattapon Wongpaet
update post custo...
|
62
63
64
|
if(resultObj.resultData && resultObj.resultData.length>0){
stats.receiveRestResponse(d01,method,sendMemCmd,constant.SUCCESS);
log.logDetail.addInput(d01,method+"_"+sendCusCmd,constant.RESPONSE,resultMemberCard,resultMemberCard.response);
|
887b2ec5
Nattapon Wongpaet
update put customer
|
65
66
67
|
var resultMemberCardObj = resultMemberCard.response;
log.addSuccessSummary(d01,method+"_"+sendMemCmd,resultMemberCardObj.resultCode,resultMemberCardObj.resultDescription);
|
a0638777
Nattapon Wongpaet
add try catch and...
|
68
69
70
71
72
73
74
|
for(var i = 0; i < resultObj.resultData.length; i++){
for(var j = 0; j < resultMemberCardObj.resultData.length; j++){
if(resultMemberCardObj.resultData[j].cardOwnerIdList.includes(resultObj.resultData[i].customerId)){
resultObj.resultData[i] = Object.assign(resultObj.resultData[i],{cardId : resultMemberCardObj.resultData[j].cardId});
}
}
}
|
9a512329
Nattapon Wongpaet
no flow membership
|
75
76
|
var response = responseMsg.success(req,getCmd,resultObj);
} else {
|
a0638777
Nattapon Wongpaet
add try catch and...
|
77
|
stats.receiveRestResponse(d01,method,sendCusCmd,constant.RESPONSERESULT.DATA_NOT_FOUND.developerMessage);
|
9a512329
Nattapon Wongpaet
no flow membership
|
78
|
var response = responseMsg.error(req,getCmd,40401);
|
a0638777
Nattapon Wongpaet
add try catch and...
|
79
80
81
82
|
log.addErrorSummary(d01,method+"_"+sendCusCmd,response.resultCode,response.developerMessage);
}
} else if(resultObj.resultCode.startsWith("404")){
stats.receiveRestResponse(d01,method,sendCmd,constant.RESPONSERESULT.DATA_NOT_FOUND.developerMessage);
|
887b2ec5
Nattapon Wongpaet
update put customer
|
83
|
var response = responseMsg.direct(req,getCmd,resultObj);
|
a0638777
Nattapon Wongpaet
add try catch and...
|
84
85
86
87
|
log.addErrorSummary(d01,method+"_"+sendCmd,resultObj.resultCode,resultObj.developerMessage);
} else if(resultObj.resultCode.startsWith("5")){
stats.receiveRestResponse(d01,method,sendCmd,constant.ERROR);
var response = responseMsg.direct(req,getCmd,resultObj);
|
9a512329
Nattapon Wongpaet
no flow membership
|
88
|
log.addErrorSummary(d01,method+"_"+sendCmd,resultObj.resultCode,resultObj.developerMessage);
|
887b2ec5
Nattapon Wongpaet
update put customer
|
89
|
} else {
|
cf541103
Nattapon Wongpaet
update post custo...
|
90
|
stats.receiveRestResponse(d01,method,sendCmd,constant.ERROR);
|
887b2ec5
Nattapon Wongpaet
update put customer
|
91
|
var response = responseMsg.error(req,getCmd,50000);
|
818cf50b
Nattapon Wongpaet
update get custom...
|
92
|
}
|
9a512329
Nattapon Wongpaet
no flow membership
|
93
|
} else {
|
887b2ec5
Nattapon Wongpaet
update put customer
|
94
|
stats.receiveRestResponse(d01,method,sendCusCmd,constant.ERROR);
|
9a512329
Nattapon Wongpaet
no flow membership
|
95
|
var response = responseMsg.direct(req,getCmd,resultObj);
|
887b2ec5
Nattapon Wongpaet
update put customer
|
96
|
log.addErrorSummary(d01,method+"_"+sendCusCmd,resultObj.resultCode,resultObj.developerMessage);
|
9a512329
Nattapon Wongpaet
no flow membership
|
97
|
}//End get MemberCard
|
887b2ec5
Nattapon Wongpaet
update put customer
|
98
|
|
9a512329
Nattapon Wongpaet
no flow membership
|
99
|
|
887b2ec5
Nattapon Wongpaet
update put customer
|
100
|
}else
|
9a512329
Nattapon Wongpaet
no flow membership
|
101
|
{
|
887b2ec5
Nattapon Wongpaet
update put customer
|
102
|
stats.receiveRestResponse(d01,method,sendCusCmd,constant.RESPONSERESULT.DATA_NOT_FOUND.developerMessage);
|
9a512329
Nattapon Wongpaet
no flow membership
|
103
|
var response = responseMsg.error(req,getCmd,40300);
|
818cf50b
Nattapon Wongpaet
update get custom...
|
104
|
log.addErrorSummary(d01,method+"_"+sendCusCmd,response.resultCode,response.developerMessage);
|
9a512329
Nattapon Wongpaet
no flow membership
|
105
|
}
|
887b2ec5
Nattapon Wongpaet
update put customer
|
106
|
} else if(resultObj.resultCode.startsWith("404")){
|
27aed231
Nattapon Wongpaet
update post membe...
|
107
108
|
stats.receiveRestResponse(d01,method,sendCmd,constant.ERROR);
var response = responseMsg.direct(req,getCmd,resultObj);
|
9a512329
Nattapon Wongpaet
no flow membership
|
109
110
111
|
log.addErrorSummary(d01,method+"_"+sendCmd,resultObj.resultCode,resultObj.developerMessage);
} else if(resultObj.resultCode.startsWith("5")){
stats.receiveRestResponse(d01,method,sendCmd,constant.ERROR);
|
27aed231
Nattapon Wongpaet
update post membe...
|
112
|
var response = responseMsg.direct(req,getCmd,resultObj);
|
887b2ec5
Nattapon Wongpaet
update put customer
|
113
|
log.addErrorSummary(d01,method+"_"+sendCmd,resultObj.resultCode,resultObj.developerMessage);
|
818cf50b
Nattapon Wongpaet
update get custom...
|
114
|
} else {
|
887b2ec5
Nattapon Wongpaet
update put customer
|
115
|
stats.receiveRestResponse(d01,method,sendCmd,constant.ERROR);
|
818cf50b
Nattapon Wongpaet
update get custom...
|
116
|
var response = responseMsg.error(req,getCmd,50000);
|
9a512329
Nattapon Wongpaet
no flow membership
|
117
|
}
|
887b2ec5
Nattapon Wongpaet
update put customer
|
118
|
} else {
|
818cf50b
Nattapon Wongpaet
update get custom...
|
119
|
stats.receiveRestResponse(d01,method,sendCusCmd,constant.ERROR);
|
887b2ec5
Nattapon Wongpaet
update put customer
|
120
|
var response = responseMsg.error(req,getCmd,50000);
|
9a512329
Nattapon Wongpaet
no flow membership
|
121
|
// log.addErrorSummary(d01,method+"_"+sendCmd,response.resultCode,response.developerMessage);
|
887b2ec5
Nattapon Wongpaet
update put customer
|
122
|
}
|
9a512329
Nattapon Wongpaet
no flow membership
|
123
|
}
|
887b2ec5
Nattapon Wongpaet
update put customer
|
124
|
|
9a512329
Nattapon Wongpaet
no flow membership
|
125
|
// console.log(response);
|
887b2ec5
Nattapon Wongpaet
update put customer
|
126
|
log.logDetail.addOutput(req.query.clientName,method+"_"+getCmd,constant.RESPONSE,response,response);
|
9a512329
Nattapon Wongpaet
no flow membership
|
127
|
res.status(200).json(response);
|
8221da7a
Nattapon Wongpaet
update flow membe...
|
128
|
next();
|
8221da7a
Nattapon Wongpaet
update flow membe...
|
129
|
};
|
887b2ec5
Nattapon Wongpaet
update put customer
|
130
|
|
818cf50b
Nattapon Wongpaet
update get custom...
|
131
132
|
function validator(req,cmd)
|
8221da7a
Nattapon Wongpaet
update flow membe...
|
133
|
{
|
8221da7a
Nattapon Wongpaet
update flow membe...
|
134
135
136
|
var list = [];
list.push([true,"queryStr","commandId","int"]);
list.push([true,"queryStr","clientName","string"]);
|
1f123eb1
Nattapon Wongpaet
update post membe...
|
137
|
// list.push([true,"queryStr","lastName","string"]);
|
8221da7a
Nattapon Wongpaet
update flow membe...
|
138
139
140
141
142
143
144
145
146
147
148
149
|
// list.push([true,"queryStr","emailAddress","string"]);
// list.push([true,"queryStr","mobileNo","string"]);
// list.push([false,"queryStr","mobileNo","string"]);
var err = validatorHelper(req,list);
if(err.length > 0)
stats.receiveBadRequest(req.method,cmd);
else
stats.receiveRequest(req.method,cmd);
return err;
}
|