Reload97 / sate24-to-sc

1

var fs = require('fs');

1

var fs = require('fs');

2

var https = require('https');

2

var https = require('https');

3

var http = require('http');

3

var http = require('http');

4

var url = require('url');

4

var url = require('url');

5

var request = require('request');

5

var request = require('request');

6

var xml2js = require('xml2js').parseString;

6

var xml2js = require('xml2js').parseString;

7

var strftime = require('strftime');

7

var strftime = require('strftime');

8

var math = require('mathjs');

8

var math = require('mathjs');

9

var winston = require('winston');

9

var winston = require('winston');

10

var cekstatus = require('./cekstatus.js');

10

var cekstatus = require('./cekstatus.js');

11

var mongoClient = require('mongodb').MongoClient;

11

var mongoClient = require('mongodb').MongoClient;

12

var LRU = require('lru-cache');

12

var LRU = require('lru-cache');

13

14

var config;

14

var config;

15

var httpServer;

15

var httpServer;

16

var aaa;

16

var aaa;

17

var logger;

17

var logger;

18

var callbackReport;

18

var callbackReport;

19

var mongodb;

19

var mongodb;

20

21

var tasks = LRU(10000);

21

var tasks = LRU(10000);

22

23

process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0';

23

process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0';

24

25

var sleep_before_retry = 30000;

25

var sleep_before_retry = 30000;

26

var pendingResultCode = ['0005', '0012', '0068', '0090', '0063', '0018', '0096'];

26

27

var logTag = __filename.split('/').reverse()[0];

28

var logTag = __filename.split('/').reverse()[0];

28

29

function initMongoClient() {

30

function initMongoClient() {

30

if (!config.mongodbstruk || !config.mongodbstruk.url) {

31

if (!config.mongodbstruk || !config.mongodbstruk.url) {

31

return;

32

return;

32

}

33

}

33

34

try {

35

try {

35

var url = config.mongodbstruk.url;

36

var url = config.mongodbstruk.url;

36

37

mongoClient.connect(url, function(err, db) {

38

mongoClient.connect(url, function(err, db) {

38

if (err) {

39

if (err) {

39

logger.warn('Failed to connect to mongodb', {err: err});

40

logger.warn('Failed to connect to mongodb', {err: err});

40

return;

41

return;

41

}

42

}

42

mongodb = db;

43

mongodb = db;

43

logger.info('MongoDB connected');

44

logger.info('MongoDB connected');

44

});

45

});

45

}

46

}

46

catch(err) {

47

catch(err) {

47

logger.warn('Exception when connecting to mongodb', {err: err, url: url});

48

logger.warn('Exception when connecting to mongodb', {err: err, url: url});

48

}

49

}

49

50

}

51

}

51

52

function prepareResultData(result) {

53

function prepareResultData(result) {

53

var task;

54

var task;

54

55

var data = {};

56

var data = {};

56

data.gateway = config.globals.gateway_name;

57

data.gateway = config.globals.gateway_name;

57

58

try {

59

try {

59

data.requestId = result.reffid[0].trim();

60

data.requestId = result.reffid[0].trim();

60

61

var key = config.globals.gateway_name + '.rid:' + data.requestId;

62

var key = config.globals.gateway_name + '.rid:' + data.requestId;

62

task = tasks.get(key);

63

task = tasks.get(key);

63

}

64

}

64

catch(err) { data.requestId = null; }

65

catch(err) { data.requestId = null; }

65

66

try {

67

try {

67

data.status = result.ResultCode[0].trim();

68

data.status = result.ResultCode[0].trim();

68

}

69

}

69

catch(err) { data.status = '68' }

70

catch(err) { data.status = '68' }

70

71

try {

72

try {

72

data.rcmessage = result.ErrorMsg[0].trim();

73

data.rcmessage = result.ErrorMsg[0].trim();

73

}

74

}

74

catch(err) { data.rcmessage = ''; }

75

catch(err) { data.rcmessage = ''; }

75

76

try {

77

try {

77

data.resptext = '';

78

data.resptext = '';

78

}

79

}

79

catch(err) { data.resptext = ''; }

80

catch(err) { data.resptext = ''; }

80

81

try {

82

try {

82

var ts = moment(task.timestamp, 'YYYYMMDDHHmmss').format('YYYY-MM-DD HH:mm:ss')

83

var ts = moment(task.timestamp, 'YYYYMMDDHHmmss').format('YYYY-MM-DD HH:mm:ss')

83

data.dt = ts;

84

data.dt = ts;

84

}

85

}

85

catch(err) {

86

catch(err) {

86

logger.warn('Exception when getting timestamp data, using current timestamp', {err: err, result: result, task: task});

87

logger.warn('Exception when getting timestamp data, using current timestamp', {err: err, result: result, task: task});

87

data.dt = strftime('%Y-%m-%d %H:%M:%S', new Date());

88

data.dt = strftime('%Y-%m-%d %H:%M:%S', new Date());

88

}

89

}

89

90

try {

91

try {

91

data.namapel = result.nama_pel[0].trim();

92

data.namapel = result.nama_pel[0].trim();

92

}

93

}

93

catch(err) { data.namapel = 'UNKNOWN'; }

94

catch(err) { data.namapel = 'UNKNOWN'; }

94

95

try {

96

try {

96

data.msn = result.nsm[0].trim();

97

data.msn = result.nsm[0].trim();

97

}

98

}

98

catch(err) { data.msn = 'UNKNOWN'; }

99

catch(err) { data.msn = 'UNKNOWN'; }

99

100

try {

101

try {

101

data.idpel = result.idpel[0].trim();

102

data.idpel = result.idpel[0].trim();

102

}

103

}

103

catch(err) { data.idpel = 'UNKNOWN'; }

104

catch(err) { data.idpel = 'UNKNOWN'; }

104

105

try {

106

try {

106

data.tarifdaya = result.tarif[0].trim();

107

data.tarifdaya = result.tarif[0].trim();

107

}

108

}

108

catch(err) { data.tarifdaya = 'UNKNOWN'; }

109

catch(err) { data.tarifdaya = 'UNKNOWN'; }

109

110

try {

111

try {

111

data.admin = parseInt(result.adminfee[0].trim());

112

data.admin = parseInt(result.adminfee[0].trim());

112

}

113

}

113

catch(err) { data.admin = 0; }

114

catch(err) { data.admin = 0; }

114

115

try {

116

try {

116

data.adm = parseInt(result.admin_fee[0].trim());

117

data.adm = parseInt(result.admin_fee[0].trim());

117

}

118

}

118

catch(err) { data.adm = 0; }

119

catch(err) { data.adm = 0; }

119

120

try {

121

try {

121

data.hargapelanggan = parseInt(result.amount_trx[0].trim());

122

data.hargapelanggan = parseInt(result.amount_trx[0].trim());

122

}

123

}

123

catch(err) { data.hargapelanggan = 0; }

124

catch(err) { data.hargapelanggan = 0; }

124

125

try {

126

try {

126

data.jumlahkwh = result.jml_daya[0].trim();

127

data.jumlahkwh = result.jml_daya[0].trim();

127

}

128

}

128

catch(err) { data.jumlahkwh = 0; }

129

catch(err) { data.jumlahkwh = 0; }

129

130

try {

131

try {

131

data.token = result.token[0].trim();

132

data.token = result.token[0].trim();

132

}

133

}

133

catch(err) { data.token = 0; }

134

catch(err) { data.token = 0; }

134

135

try {

136

try {

136

data.ppn = result.ppn_fee[0].trim();

137

data.ppn = result.ppn_fee[0].trim();

137

}

138

}

138

catch(err) { data.ppn_fee = 0; }

139

catch(err) { data.ppn_fee = 0; }

139

140

try {

141

try {

141

data.ppj = result.ppj_fee[0].trim();

142

data.ppj = result.ppj_fee[0].trim();

142

}

143

}

143

catch(err) { data.ppj = 0; }

144

catch(err) { data.ppj = 0; }

144

145

try {

146

try {

146

data.angsuran = result.angsuran_fee[0].trim();

147

data.angsuran = result.angsuran_fee[0].trim();

147

}

148

}

148

catch(err) { data.angsuran = 0; }

149

catch(err) { data.angsuran = 0; }

149

150

try {

151

try {

151

data.meterai = result.materai_fee[0].trim();

152

data.meterai = result.materai_fee[0].trim();

152

}

153

}

153

catch(err) { data.materai_fee = 0; }

154

catch(err) { data.materai_fee = 0; }

154

155

return data;

156

return data;

156

}

157

}

157

158

function saveTokenToMongoDb(result) {

159

function saveTokenToMongoDb(result) {

159

if (!mongodb) {

160

if (!mongodb) {

160

return;

161

return;

161

}

162

}

162

163

if (!config.mongodbstruk) {

164

if (!config.mongodbstruk) {

164

return;

165

return;

165

}

166

}

166

167

if (!config.mongodbstruk.collection) {

168

if (!config.mongodbstruk.collection) {

168

return;

169

return;

169

}

170

}

170

171

data = prepareResultData(result);

172

data = prepareResultData(result);

172

173

try {

174

try {

174

mongodb.collection(config.mongodbstruk.collection).insertOne(data);

175

mongodb.collection(config.mongodbstruk.collection).insertOne(data);

175

}

176

}

176

catch(err) {

177

catch(err) {

177

logger.warn('Error when inserting data to mongodb', {err: err, data: data});

178

logger.warn('Error when inserting data to mongodb', {err: err, data: data});

178

}

179

}

179

}

180

}

180

181

function putTaskToCache(task) {

182

function putTaskToCache(task) {

182

var key = config.globals.gateway_name + '.rid:' + task.requestId;

183

var key = config.globals.gateway_name + '.rid:' + task.requestId;

183

184

try {

185

try {

185

tasks.set(key, task);

186

tasks.set(key, task);

186

}

187

}

187

catch(err) {

188

catch(err) {

188

logger.warn('Error writing to task to cache', {err: err, key: key, task: task});

189

logger.warn('Error writing to task to cache', {err: err, key: key, task: task});

189

}

190

}

190

}

191

}

191

192

function topupRequest(task) {

193

function topupRequest(task) {

193

aaa.insertTaskToMongoDb(task);

194

aaa.insertTaskToMongoDb(task);

194

putTaskToCache(task);

195

putTaskToCache(task);

195

196

var ts = strftime('%Y%m%d%H%M%S', new Date());

197

var ts = strftime('%Y%m%d%H%M%S', new Date());

197

198

var data =

199

var data =

199

config.h2h_out.userid

200

config.h2h_out.userid

200

+ '|' + config.h2h_out.password

201

+ '|' + config.h2h_out.password

201

+ '|' + task['remoteProduct']

202

+ '|' + task['remoteProduct']

202

+ '|' + task['destination'] + '|0';

203

+ '|' + task['destination'] + '|0';

203

204

var options = {

205

var options = {

205

url: config.h2h_out.partner,

206

url: config.h2h_out.partner,

206

qs: {

207

qs: {

207

ts: ts,

208

ts: ts,

208

data: data,

209

data: data,

209

reffid: task['requestId']

210

reffid: task['requestId']

210

}

211

}

211

};

212

};

212

logger.info('Creating http request', {options: options});

213

logger.info('Creating http request', {options: options});

213

214

request(options, function (error, response, body) {

215

request(options, function (error, response, body) {

215

var responseCode = '40';

216

var responseCode = '40';

216

var responseMessage = 'Gateway Error';

217

var responseMessage = 'Gateway Error';

217

218

if (error) {

219

if (error) {

219

220

logger.warn('HTTP REQUEST ERROR', error);

221

logger.warn('HTTP REQUEST ERROR', error);

221

callbackReport(task['requestId'], '89', 'HTTP REQUEST ERROR (' + error + ')');

222

callbackReport(task['requestId'], '89', 'HTTP REQUEST ERROR (' + error + ')');

222

223

} else if (response.statusCode != 200) {

224

} else if (response.statusCode != 200) {

224

225

var error_message = 'GATEWAY ERROR (HTTP RESPONSE CODE: ' + response.statusCode + ')';

226

var error_message = 'GATEWAY ERROR (HTTP RESPONSE CODE: ' + response.statusCode + ')';

226

logger.warn(error_message);

227

logger.warn(error_message);

227

callbackReport(task['requestId'], '91', error_message);

228

callbackReport(task['requestId'], '91', error_message);

228

229

} else {

230

} else {

230

231

logger.info('DIRECT RESPONSE', {body: body});

232

logger.info('DIRECT RESPONSE', {body: body});

232

233

xml2js(body, function (err, result) {

234

xml2js(body, function (err, result) {

234

if (err) {

235

if (err) {

235

callbackReport(task['requestId'], '40', body);

236

callbackReport(task['requestId'], '40', body);

236

} else {

237

} else {

237

var directResponse = result;

238

var directResponse = result;

238

logger.info(directResponse);

239

logger.info(directResponse);

239

240

saveTokenToMongoDb(directResponse.Result);

241

saveTokenToMongoDb(directResponse.Result);

241

242

try {

243

try {

243

var result_price;

244

var result_price;

244

try {

245

try {

245

result_price = directResponse.Result.Price[0].trim();

246

result_price = directResponse.Result.Price[0].trim();

246

}

247

}

247

catch(err) {

248

catch(err) {

248

result_price = 0;

249

result_price = 0;

249

}

250

}

250

251

var result_error_message;

252

var result_error_message;

252

try {

253

try {

253

result_error_message = directResponse.Result.ErrorMsg[0].trim();

254

result_error_message = directResponse.Result.ErrorMsg[0].trim();

254

}

255

}

255

catch(err) {

256

catch(err) {

256

result_error_message = '';

257

result_error_message = '';

257

}

258

}

258

259

var resultCode = directResponse.Result.ResultCode[0].trim();

260

var resultCode = directResponse.Result.ResultCode[0].trim();

260

261

responseMessage =

262

responseMessage =

262

'ResultCode: ' + resultCode

263

'ResultCode: ' + resultCode

263

+ ' | ErrorMsg: ' + result_error_message

264

+ ' | ErrorMsg: ' + result_error_message

264

+ ' | DateTime: ' + directResponse.Result.DateTime[0].trim()

265

+ ' | DateTime: ' + directResponse.Result.DateTime[0].trim()

265

+ ' | nsm: ' + directResponse.Result.nsm[0].trim()

266

+ ' | nsm: ' + directResponse.Result.nsm[0].trim()

266

+ ' | idpel: ' + directResponse.Result.idpel[0].trim()

267

+ ' | idpel: ' + directResponse.Result.idpel[0].trim()

267

+ ' | reffid: ' + directResponse.Result.reffid[0].trim()

268

+ ' | reffid: ' + directResponse.Result.reffid[0].trim()

268

+ ' | TransID: ' + directResponse.Result.TransID[0].trim()

269

+ ' | TransID: ' + directResponse.Result.TransID[0].trim()

269

+ ' | reff_switching: ' + directResponse.Result.reff_switching[0].trim()

270

+ ' | reff_switching: ' + directResponse.Result.reff_switching[0].trim()

270

+ ' | amount_trx: ' + directResponse.Result.amount_trx[0].trim()

271

+ ' | amount_trx: ' + directResponse.Result.amount_trx[0].trim()

271

+ ' | token: ' + directResponse.Result.token[0].trim()

272

+ ' | token: ' + directResponse.Result.token[0].trim()

272

+ ' | PrevBalance: ' + directResponse.Result.PrevBalance[0].trim()

273

+ ' | PrevBalance: ' + directResponse.Result.PrevBalance[0].trim()

273

+ ' | Price: ' + result_price

274

+ ' | Price: ' + result_price

274

+ ' | EndBalance: ' + directResponse.Result.EndBalance[0].trim()

275

+ ' | EndBalance: ' + directResponse.Result.EndBalance[0].trim()

275

;

276

;

276

277

logger.info('Response message: ' + responseMessage);

278

logger.info('Response message: ' + responseMessage);

278

279

if (aaa) {

280

if (aaa) {

280

// update balance

281

// update balance

281

aaa.updateBalance(directResponse.Result.EndBalance[0]);

282

aaa.updateBalance(directResponse.Result.EndBalance[0]);

282

}

283

}

283

284

if (resultCode == '0000') {

285

if (resultCode == '0000') {

285

var nama_pelanggan = directResponse.Result.nama_pel[0].trim();

286

var nama_pelanggan = directResponse.Result.nama_pel[0].trim();

286

nama_pelanggan = nama_pelanggan.replace(/-\/-/g, '-');

287

nama_pelanggan = nama_pelanggan.replace(/-\/-/g, '-');

287

var sn = directResponse.Result.token[0].trim() + '/' + nama_pelanggan + '/' + directResponse.Result.tarif[0].trim() + 'VA/' + directResponse.Result.jml_daya[0].trim();

288

var sn = directResponse.Result.token[0].trim() + '/' + nama_pelanggan + '/' + directResponse.Result.tarif[0].trim() + 'VA/' + directResponse.Result.jml_daya[0].trim();

288

sn = sn.replace(/\s/g, '-');

289

sn = sn.replace(/\s/g, '-');

289

290

responseMessage = 'SN=' + sn + '; ' + responseMessage;

291

responseMessage = 'SN=' + sn + '; ' + responseMessage;

291

logger.info('New response message: ' + responseMessage);

292

logger.info('New response message: ' + responseMessage);

292

}

293

}

293

294

var pendingResultCode = ['0005', '0012', '0068', '0090', '0063', '0018', '0096'];

295

if (pendingResultCode.indexOf(resultCode) != -1) {

295

if (pendingResultCode.indexOf(resultCode) != -1) {

296

callbackReport(task['requestId'], '68', responseMessage);

296

callbackReport(task['requestId'], '68', responseMessage);

297

298

logger.info('Got pending status, requesting advice from webreport in ' + sleep_before_retry + 'ms');

298

logger.info('Got pending status, requesting advice from webreport in ' + sleep_before_retry + 'ms');

299

setTimeout(function () {

299

setTimeout(function () {

300

cekstatus.advice({trxid: directResponse.Result.TransID[0].trim()}, callbackFromWebReport);

300

cekstatus.advice({trxid: directResponse.Result.TransID[0].trim()}, callbackFromWebReport);

301

}, sleep_before_retry);

301

}, sleep_before_retry);

302

303

return;

303

return;

304

}

304

}

305

306

responseCode = resultCode.replace(/^00/, "");

306

responseCode = resultCode.replace(/^00/, "");

307

308

if (result_error_message == 'Inq - APLICATION SERVER RESPONSE TIMEOUT') {

308

if (result_error_message == 'Inq - APLICATION SERVER RESPONSE TIMEOUT') {

309

responseCode = '91';

309

responseCode = '91';

310

}

310

}

311

312

}

312

}

313

catch(err) {

313

catch(err) {

314

responseCode = '40';

314

responseCode = '40';

315

responseMessage = 'Invalid response from gateway';

315

responseMessage = 'Invalid response from gateway';

316

}

316

}

317

}

317

}

318

319

callbackReport(task['requestId'], responseCode, responseMessage);

319

callbackReport(task['requestId'], responseCode, responseMessage);

320

});

320

});

321

}

321

}

322

323

//callbackReport(task['requestId'], responseCode, responseMessage);

323

//callbackReport(task['requestId'], responseCode, responseMessage);

324

});

324

});

325

}

325

}

326

327

function callbackFromWebReport(status) {

327

function callbackFromWebReport(status) {

328

if (!status) {

328

if (!status) {

329

logger.warn('Advice from webreport return empty status');

329

logger.warn('Advice from webreport return empty status');

330

return;

330

return;

331

}

331

}

332

333

logger.info('Got advice result from webreport', {status: status});

333

logger.info('Got advice result from webreport', {status: status});

334

335

var responseCode = '68';

335

var responseCode = '68';

336

337

var result_price = 0;

337

var result_price = 0;

338

try {

338

try {

339

result_price = directResponse.Result.Price[0].trim();

339

result_price = directResponse.Result.Price[0].trim();

340

}

340

}

341

catch(err) {}

341

catch(err) {}

342

343

var errorMsg = '';

343

var errorMsg = '';

344

try {

344

try {

345

errorMsg = status.response.errormsg[0];

345

errorMsg = status.response.errormsg[0];

346

}

346

}

347

catch(err) {}

347

catch(err) {}

348

349

var responseMessage = '';

349

var responseMessage = '';

350

try {

350

try {

351

responseMessage =

351

responseMessage =

352

'Hasil advice dari webreport '

352

'Hasil advice dari webreport '

353

+ 'ResultCode: ' + status.response.resultcode[0]

353

+ 'ResultCode: ' + status.response.resultcode[0]

354

}

354

}

355

catch(err) {

355

catch(err) {

356

logger.warn('Error parsing ResultCode from webreport advice.', {err: err});

356

logger.warn('Error parsing ResultCode from webreport advice.', {err: err});

357

}

357

}

358

359

try {

359

try {

360

responseMessage =

360

responseMessage =

361

responseMessage

361

responseMessage

362

+ ' | ErrorMsg: ' + errorMsg

362

+ ' | ErrorMsg: ' + errorMsg

363

}

363

}

364

catch(err) {

364

catch(err) {

365

logger.warn('Error parsing ErrorMsg from webreport advice.', {err: err});

365

logger.warn('Error parsing ErrorMsg from webreport advice.', {err: err});

366

}

366

}

367

368

try {

368

try {

369

responseMessage =

369

responseMessage =

370

responseMessage

370

responseMessage

371

+ ' | TrxDate: ' + status.trxDate;

371

+ ' | TrxDate: ' + status.trxDate;

372

}

372

}

373

catch(err) {

373

catch(err) {

374

logger.warn('Error parsing TrxDate from webreport advice.', {err: err});

374

logger.warn('Error parsing TrxDate from webreport advice.', {err: err});

375

}

375

}

376

377

try {

377

try {

378

responseMessage =

378

responseMessage =

379

responseMessage

379

responseMessage

380

+ ' | UpdateDate: ' + status.updateDate;

380

+ ' | UpdateDate: ' + status.updateDate;

381

382

}

382

}

383

catch(err) {

383

catch(err) {

384

logger.warn('Error parsing UpdateDate from webreport advice.', {err: err});

384

logger.warn('Error parsing UpdateDate from webreport advice.', {err: err});

385

}

385

}

386

387

try {

387

try {

388

responseMessage =

388

responseMessage =

389

responseMessage

389

responseMessage

390

+ ' | nsm: ' + status.response.nsm[0];

390

+ ' | nsm: ' + status.response.nsm[0];

391

}

391

}

392

catch(err) {

392

catch(err) {

393

logger.warn('Error parsing nsm from webreport advice.', {err: err});

393

logger.warn('Error parsing nsm from webreport advice.', {err: err});

394

}

394

}

395

396

try {

396

try {

397

responseMessage =

397

responseMessage =

398

responseMessage

398

responseMessage

399

+ ' | idpel: ' + status.response.idpel[0];

399

+ ' | idpel: ' + status.response.idpel[0];

400

}

400

}

401

catch(err) {

401

catch(err) {

402

logger.warn('Error parsing idpel from webreport advice.', {err: err});

402

logger.warn('Error parsing idpel from webreport advice.', {err: err});

403

}

403

}

404

405

try {

405

try {

406

responseMessage =

406

responseMessage =

407

responseMessage

407

responseMessage

408

+ ' | reffid: ' + status.response.reffid[0].trim();

408

+ ' | reffid: ' + status.response.reffid[0].trim();

409

}

409

}

410

catch(err) {

410

catch(err) {

411

logger.warn('Error parsing reffid from webreport advice.', {err: err});

411

logger.warn('Error parsing reffid from webreport advice.', {err: err});

412

}

412

}

413

414

try {

414

try {

415

responseMessage =

415

responseMessage =

416

responseMessage

416

responseMessage

417

+ ' | TransID: ' + status.response.transid[0].trim();

417

+ ' | TransID: ' + status.response.transid[0].trim();

418

}

418

}

419

catch(err) {

419

catch(err) {

420

logger.warn('Error parsing TransID from webreport advice.', {err: err});

420

logger.warn('Error parsing TransID from webreport advice.', {err: err});

421

}

421

}

422

423

try {

423

try {

424

responseMessage =

424

responseMessage =

425

responseMessage

425

responseMessage

426

+ ' | reff_switching: ' + status.response.reff_switching[0];

426

+ ' | reff_switching: ' + status.response.reff_switching[0];

427

}

427

}

428

catch(err) {

428

catch(err) {

429

logger.warn('Error parsing reff_switching from webreport advice.', {err: err});

429

logger.warn('Error parsing reff_switching from webreport advice.', {err: err});

430

}

430

}

431

432

try {

432

try {

433

responseMessage =

433

responseMessage =

434

responseMessage

434

responseMessage

435

+ ' | amount_trx: ' + status.response.amount_trx[0];

435

+ ' | amount_trx: ' + status.response.amount_trx[0];

436

}

436

}

437

catch(err) {

437

catch(err) {

438

logger.warn('Error parsing amount_trx from webreport advice.', {err: err});

438

logger.warn('Error parsing amount_trx from webreport advice.', {err: err});

439

}

439

}

440

441

try {

441

try {

442

responseMessage =

442

responseMessage =

443

responseMessage

443

responseMessage

444

+ ' | token: ' + status.response.token[0];

444

+ ' | token: ' + status.response.token[0];

445

}

445

}

446

catch(err) {

446

catch(err) {

447

logger.warn('Error parsing token from webreport advice.', {err: err});

447

logger.warn('Error parsing token from webreport advice.', {err: err});

448

}

448

}

449

450

try {

450

try {

451

responseMessage =

451

responseMessage =

452

responseMessage

452

responseMessage

453

+ ' | PrevBalance: ' + status.response.prevbalance[0];

453

+ ' | PrevBalance: ' + status.response.prevbalance[0];

454

}

454

}

455

catch(err) {

455

catch(err) {

456

logger.warn('Error parsing PrevBalance from webreport advice.', {err: err});

456

logger.warn('Error parsing PrevBalance from webreport advice.', {err: err});

457

}

457

}

458

459

try {

459

try {

460

responseMessage =

460

responseMessage =

461

responseMessage

461

responseMessage

462

+ ' | Price: ' + status.amount;

462

+ ' | Price: ' + status.amount;

463

}

463

}

464

catch(err) {

464

catch(err) {

465

logger.warn('Error parsing Price from webreport advice.', {err: err});

465

logger.warn('Error parsing Price from webreport advice.', {err: err});

466

}

466

}

467

468

try {

468

try {

469

responseMessage =

469

responseMessage =

470

responseMessage

470

responseMessage

471

+ ' | EndBalance: ' + status.response.endbalance[0];

471

+ ' | EndBalance: ' + status.response.endbalance[0];

472

}

472

}

473

catch(err) {

473

catch(err) {

474

logger.warn('Error parsing EndBalance from webreport advice.', {err: err});

474

logger.warn('Error parsing EndBalance from webreport advice.', {err: err});

475

}

475

}

476

477

478

if ((status.status == 'S') && (status.response.resultcode[0] == '0000')) {

478

if ((status.status == 'S') && (status.response.resultcode[0] == '0000')) {

479

responseCode = '00';

479

responseCode = '00';

480

481

var nama_pelanggan = status.response.nama_pel[0] ;

481

var nama_pelanggan = status.response.nama_pel[0] ;

482

nama_pelanggan = nama_pelanggan.replace(/-\/-/g, '-');

482

nama_pelanggan = nama_pelanggan.replace(/-\/-/g, '-');

483

484

var sn = status.response.token[0] + '/' + nama_pelanggan + '/' + status.response.tarif[0] + 'VA/' + status.response.jml_daya[0];

484

var sn = status.response.token[0] + '/' + nama_pelanggan + '/' + status.response.tarif[0] + 'VA/' + status.response.jml_daya[0];

485

responseMessage = 'SN=' + sn + '; ' + responseMessage;

485

responseMessage = 'SN=' + sn + '; ' + responseMessage;

486

487

} else if ((status.status == 'P') || (status.status == 'W')) {

487

} else if ((status.status == 'P') || (status.status == 'W')) {

488

489

callbackReport(status.response.reffid[0].trim(), '68', responseMessage);

489

callbackReport(status.response.reffid[0].trim(), '68', responseMessage);

490

logger.info('Got pending status, requesting advice from webreport in ' + sleep_before_retry + 'ms');

490

logger.info('Got pending status, requesting advice from webreport in ' + sleep_before_retry + 'ms');

491

492

setTimeout(function () {

492

setTimeout(function () {

493

494

cekstatus.advice({trxid: status.trxId,}, callbackFromWebReport);

494

cekstatus.advice({trxid: status.trxId,}, callbackFromWebReport);

495

496

}, sleep_before_retry);

496

}, sleep_before_retry);

497

return;

497

return;

498

499

} else {

499

} else {

500

responseCode = status.response.resultcode[0].replace(/^00/, "");

500

responseCode = status.response.resultcode[0].replace(/^00/, "");

501

if (['00', '05', '12', '68', '90', '63', '18', '96'].indexOf(responseCode) >= 0) {

501

if (['00', '05', '12', '68', '90', '63', '18', '96'].indexOf(responseCode) >= 0) {

502

responseCode = '40';

502

responseCode = '40';

503

}

503

}

504

}

504

}

505

506

507

callbackReport(status.response.reffid[0].trim(), responseCode, responseMessage);

507

callbackReport(status.response.reffid[0].trim(), responseCode, responseMessage);

508

}

508

}

509

510

function createHttpReportServer() {

510

function createHttpReportServer() {

511

var httpServer = http.createServer(function(request, response) {

511

var httpServer = http.createServer(function(request, response) {

512

var qs = url.parse(request.url, true).query;

512

var qs = url.parse(request.url, true).query;

513

var path = url.parse(request.url).pathname;

513

var path = url.parse(request.url).pathname;

514

515

logger.info('Got reverse report from partner', {path: path, qs: qs});

515

logger.info('Got reverse report from partner', {path: path, qs: qs});

516

response.end('OK');

516

response.end('OK');

517

518

var requestId = qs.reffid;

519

var resultCode = qs.rescode;

520

521

if (requestId && resultCode && resulCode != '0') {

522

if (pendingResultCode.indexOf(resultCode) >= 0) {

523

callbackReport(requestId, '68', 'Got reverse report: ' + qs.msg);

524

} else {

525

callbackReport(requestId, '40', 'Got reverse report: ' + qs.msg);

526

}

527

return;

528

}

529

518

var trxid;

530

var trxid;

519

try {

531

try {

520

trxid = qs.transid;

532

trxid = qs.transid;

521

}

533

}

522

catch(err) {

534

catch(err) {

523

}

535

}

524

536

525

if (trxid) {

537

if (trxid) {

526

logger.info('Requesting advice from webreport', {trxid: trxid})

538

logger.info('Requesting advice from webreport', {trxid: trxid})

527

cekstatus.advice({trxid: trxid}, callbackFromWebReport);

539

cekstatus.advice({trxid: trxid}, callbackFromWebReport);

528

}

540

}

529

541

530

});

542

});

531

543

532

httpServer.listen(config.h2h_out.listen_port, function() {

544

httpServer.listen(config.h2h_out.listen_port, function() {

533

logger.info('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port);

545

logger.info('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port);

534

});

546

});

535

}

547

}

536

548

537

function start(options) {

549

function start(options) {

538

if (!options) {

550

if (!options) {

539

console.log('Undefined options, terminating....');

551

console.log('Undefined options, terminating....');

540

process.exit(1);

552

process.exit(1);

541

}

553

}

542

554

543

if (options.config) {

555

if (options.config) {

544

config = options.config;

556

config = options.config;

545

} else {

557

} else {

546

console.log('Undefined options.config, terminating....')

558

console.log('Undefined options.config, terminating....')

547

process.exit(1);

559

process.exit(1);

548

}

560

}

549

561

550

if (options.aaa) {

562

if (options.aaa) {

551

aaa = options.aaa;

563

aaa = options.aaa;

552

callbackReport = options.aaa.callbackReportWithPushToMongoDb;

564

callbackReport = options.aaa.callbackReportWithPushToMongoDb;

553

} else {

565

} else {

554

console.log('Undefined options.aaa, terminating....')

566

console.log('Undefined options.aaa, terminating....')

555

process.exit(1);

567

process.exit(1);

556

}

568

}

557

569

558

if (options && options.logger) {

570

if (options && options.logger) {

559

logger = options.logger;

571

logger = options.logger;

560

} else {

572

} else {

561

logger = new winston.Logger({

573

logger = new winston.Logger({

562

transports: [

574

transports: [

563

new (winston.transports.Console)()

575

new (winston.transports.Console)()

564

]

576

]

565

});

577

});

566

}

578

}

567

579

568

createHttpReportServer();

580

createHttpReportServer();

569

initMongoClient();

581

initMongoClient();

570

}

582

}

571

583

572

exports.start = start;

584

exports.start = start;

573

exports.topupRequest = topupRequest;

585

exports.topupRequest = topupRequest;

GITLAB

Reload97 / sate24-to-sc

langsung gagal jika dapat reverse report gagal

 var fs = require('fs');
 var https = require('https');
 var http = require('http');
 var url = require('url');
 var request = require('request');
 var xml2js = require('xml2js').parseString;
 var strftime = require('strftime');
 var math = require('mathjs');
 var winston = require('winston');
 var cekstatus = require('./cekstatus.js');
 var mongoClient = require('mongodb').MongoClient;
 var LRU = require('lru-cache');
 var config;
 var httpServer;
 var aaa;
 var logger;
 var callbackReport;
 var mongodb;
 var tasks = LRU(10000);
 process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0';
 var sleep_before_retry = 30000;
+var pendingResultCode = ['0005', '0012', '0068', '0090', '0063', '0018', '0096'];
 var logTag = __filename.split('/').reverse()[0];
 function initMongoClient() {
     if (!config.mongodbstruk || !config.mongodbstruk.url) {
         return;
     }
     try {
         var url = config.mongodbstruk.url;
         mongoClient.connect(url, function(err, db) {
             if (err) {
                 logger.warn('Failed to connect to mongodb', {err: err});
                 return;
             }
             mongodb = db;
             logger.info('MongoDB connected');
         });
     }
     catch(err) {
         logger.warn('Exception when connecting to mongodb', {err: err, url: url});
     }
 }
 function prepareResultData(result) {
     var task;
     var data = {};
     data.gateway = config.globals.gateway_name;
     try {
         data.requestId = result.reffid[0].trim();
         var key = config.globals.gateway_name + '.rid:' + data.requestId;
         task = tasks.get(key);
     }
     catch(err) { data.requestId = null; }
     try {
         data.status = result.ResultCode[0].trim();
     }
     catch(err) { data.status = '68' }
     try {
         data.rcmessage = result.ErrorMsg[0].trim();
     }
     catch(err) { data.rcmessage = ''; }
     try {
         data.resptext = '';
     }
     catch(err) { data.resptext = ''; }
     try {
         var ts = moment(task.timestamp, 'YYYYMMDDHHmmss').format('YYYY-MM-DD HH:mm:ss')
         data.dt = ts;
     }
     catch(err) {
         logger.warn('Exception when getting timestamp data, using current timestamp', {err: err, result: result, task: task});
         data.dt = strftime('%Y-%m-%d %H:%M:%S', new Date());
     }
     try {
         data.namapel = result.nama_pel[0].trim();
     }
     catch(err) { data.namapel = 'UNKNOWN'; }
     try {
         data.msn = result.nsm[0].trim();
     }
     catch(err) { data.msn = 'UNKNOWN'; }
     try {
         data.idpel = result.idpel[0].trim();
     }
     catch(err) { data.idpel = 'UNKNOWN'; }
     try {
         data.tarifdaya = result.tarif[0].trim();
     }
     catch(err) { data.tarifdaya = 'UNKNOWN'; }
     try {
         data.admin = parseInt(result.adminfee[0].trim());
     }
     catch(err) { data.admin = 0; }
     try {
         data.adm = parseInt(result.admin_fee[0].trim());
     }
     catch(err) { data.adm = 0; }
     try {
         data.hargapelanggan = parseInt(result.amount_trx[0].trim());
     }
     catch(err) { data.hargapelanggan = 0; }
     try {
         data.jumlahkwh = result.jml_daya[0].trim();
     }
     catch(err) { data.jumlahkwh = 0; }
     try {
         data.token = result.token[0].trim();
     }
     catch(err) { data.token = 0; }
     try {
         data.ppn = result.ppn_fee[0].trim();
     }
     catch(err) { data.ppn_fee = 0; }
     try {
         data.ppj = result.ppj_fee[0].trim();
     }
     catch(err) { data.ppj = 0; }
     try {
         data.angsuran = result.angsuran_fee[0].trim();
     }
     catch(err) { data.angsuran = 0; }
     try {
         data.meterai = result.materai_fee[0].trim();
     }
     catch(err) { data.materai_fee = 0; }
     return data;
 }
 function saveTokenToMongoDb(result) {
     if (!mongodb) {
         return;
     }
     if (!config.mongodbstruk) {
         return;
     }
     if (!config.mongodbstruk.collection) {
         return;
     }
     data = prepareResultData(result);
     try {
         mongodb.collection(config.mongodbstruk.collection).insertOne(data);
     }
     catch(err) {
         logger.warn('Error when inserting data to mongodb', {err: err, data: data});
     }
 }
 function putTaskToCache(task) {
     var key = config.globals.gateway_name + '.rid:' + task.requestId;
     try {
         tasks.set(key, task);
     }
     catch(err) {
         logger.warn('Error writing to task to cache', {err: err, key: key, task: task});
     }
 }
 function topupRequest(task) {
     aaa.insertTaskToMongoDb(task);
     putTaskToCache(task);
     var ts = strftime('%Y%m%d%H%M%S', new Date());
     var data =
         config.h2h_out.userid
         + '|' + config.h2h_out.password
         + '|' + task['remoteProduct']
         + '|' + task['destination'] + '|0';
     var options = {
         url: config.h2h_out.partner,
         qs: {
             ts: ts,
             data: data,
             reffid: task['requestId']
         }
     };
     logger.info('Creating http request', {options: options});
     request(options, function (error, response, body) {
         var responseCode = '40';
         var responseMessage = 'Gateway Error';
         if (error) {
             logger.warn('HTTP REQUEST ERROR', error);
             callbackReport(task['requestId'], '89', 'HTTP REQUEST ERROR (' + error + ')');
         } else if (response.statusCode != 200) {
             var error_message = 'GATEWAY ERROR (HTTP RESPONSE CODE: ' + response.statusCode + ')';
             logger.warn(error_message);
             callbackReport(task['requestId'], '91', error_message);
         } else {
             logger.info('DIRECT RESPONSE', {body: body});
             xml2js(body, function (err, result) {
                 if (err) {
                     callbackReport(task['requestId'], '40', body);
                 } else {
                     var directResponse = result;
                     logger.info(directResponse);
                     saveTokenToMongoDb(directResponse.Result);
                     try {
                         var result_price;
                         try {
                             result_price = directResponse.Result.Price[0].trim();
                         }
                         catch(err) {
                             result_price = 0;
                         }
                         var result_error_message;
                         try {
                             result_error_message = directResponse.Result.ErrorMsg[0].trim();
                         }
                         catch(err) {
                             result_error_message = '';
                         }
                         var resultCode = directResponse.Result.ResultCode[0].trim();
                         responseMessage =
                             'ResultCode: ' + resultCode
                             + ' | ErrorMsg: ' + result_error_message
                             + ' | DateTime: ' + directResponse.Result.DateTime[0].trim()
                             + ' | nsm: ' + directResponse.Result.nsm[0].trim()
                             + ' | idpel: ' + directResponse.Result.idpel[0].trim()
                             + ' | reffid: ' + directResponse.Result.reffid[0].trim()
                             + ' | TransID: ' + directResponse.Result.TransID[0].trim()
                             + ' | reff_switching: ' + directResponse.Result.reff_switching[0].trim()
                             + ' | amount_trx: ' + directResponse.Result.amount_trx[0].trim()
                             + ' | token: ' + directResponse.Result.token[0].trim()
                             + ' | PrevBalance: ' + directResponse.Result.PrevBalance[0].trim()
                             + ' | Price: ' + result_price
                             + ' | EndBalance: ' + directResponse.Result.EndBalance[0].trim()
                             ;
                         logger.info('Response message: ' + responseMessage);
                         if (aaa) {
                             // update balance
                             aaa.updateBalance(directResponse.Result.EndBalance[0]);
                         }
                         if (resultCode == '0000') {
                             var nama_pelanggan = directResponse.Result.nama_pel[0].trim();
                             nama_pelanggan =  nama_pelanggan.replace(/-\/-/g, '-');
                             var sn = directResponse.Result.token[0].trim() + '/' + nama_pelanggan + '/' + directResponse.Result.tarif[0].trim() +  'VA/' + directResponse.Result.jml_daya[0].trim();
                             sn = sn.replace(/\s/g, '-');
                             responseMessage = 'SN=' + sn + '; ' + responseMessage;
                             logger.info('New response message: ' + responseMessage);
                         }
-                        var pendingResultCode = ['0005', '0012', '0068', '0090', '0063', '0018', '0096'];
                         if (pendingResultCode.indexOf(resultCode) != -1) {
                             callbackReport(task['requestId'], '68', responseMessage);
                             logger.info('Got pending status, requesting advice from webreport in ' + sleep_before_retry + 'ms');
                             setTimeout(function () {
                                 cekstatus.advice({trxid: directResponse.Result.TransID[0].trim()}, callbackFromWebReport);
                             }, sleep_before_retry);
                             return;
                         }
                         responseCode = resultCode.replace(/^00/, "");
                         if (result_error_message == 'Inq - APLICATION SERVER RESPONSE TIMEOUT') {
                             responseCode = '91';
                         }
                     }
                     catch(err) {
                         responseCode = '40';
                         responseMessage = 'Invalid response from gateway';
                     }
                 }
                 callbackReport(task['requestId'], responseCode, responseMessage);
             });
         }
         //callbackReport(task['requestId'], responseCode, responseMessage);
     });
 }
 function callbackFromWebReport(status) {
     if (!status) {
         logger.warn('Advice from webreport return empty status');
         return;
     }
     logger.info('Got advice result from webreport', {status: status});
     var responseCode = '68';
     var result_price = 0;
     try {
         result_price = directResponse.Result.Price[0].trim();
     }
     catch(err) {}
     var errorMsg = '';
     try {
         errorMsg = status.response.errormsg[0];
     }
     catch(err) {}
     var responseMessage = '';
     try {
         responseMessage =
             'Hasil advice dari webreport '
             + 'ResultCode: ' + status.response.resultcode[0]
     }
     catch(err) {
         logger.warn('Error parsing ResultCode from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | ErrorMsg: ' + errorMsg
     }
     catch(err) {
         logger.warn('Error parsing ErrorMsg from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | TrxDate: ' + status.trxDate;
     }
     catch(err) {
         logger.warn('Error parsing TrxDate from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | UpdateDate: ' + status.updateDate;
     }
     catch(err) {
         logger.warn('Error parsing UpdateDate from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | nsm: ' + status.response.nsm[0];
     }
     catch(err) {
         logger.warn('Error parsing nsm from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | idpel: ' + status.response.idpel[0];
     }
     catch(err) {
         logger.warn('Error parsing idpel from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | reffid: ' + status.response.reffid[0].trim();
     }
     catch(err) {
         logger.warn('Error parsing reffid from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | TransID: ' + status.response.transid[0].trim();
     }
     catch(err) {
         logger.warn('Error parsing TransID from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | reff_switching: ' + status.response.reff_switching[0];
     }
     catch(err) {
         logger.warn('Error parsing reff_switching from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | amount_trx: ' + status.response.amount_trx[0];
     }
     catch(err) {
         logger.warn('Error parsing amount_trx from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | token: ' + status.response.token[0];
     }
     catch(err) {
         logger.warn('Error parsing token from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | PrevBalance: ' + status.response.prevbalance[0];
     }
     catch(err) {
         logger.warn('Error parsing PrevBalance from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | Price: ' + status.amount;
     }
     catch(err) {
         logger.warn('Error parsing Price from webreport advice.', {err: err});
     }
     try {
         responseMessage =
             responseMessage
             + ' | EndBalance: ' + status.response.endbalance[0];
     }
     catch(err) {
         logger.warn('Error parsing EndBalance from webreport advice.', {err: err});
     }
     if ((status.status == 'S') && (status.response.resultcode[0] == '0000')) {
         responseCode = '00';
         var nama_pelanggan = status.response.nama_pel[0] ;
         nama_pelanggan =  nama_pelanggan.replace(/-\/-/g, '-');
         var sn = status.response.token[0] + '/' + nama_pelanggan + '/' + status.response.tarif[0] + 'VA/' + status.response.jml_daya[0];
         responseMessage = 'SN=' + sn + '; ' + responseMessage;
     } else if ((status.status == 'P') || (status.status == 'W')) {
         callbackReport(status.response.reffid[0].trim(), '68', responseMessage);
         logger.info('Got pending status, requesting advice from webreport in ' + sleep_before_retry + 'ms');
         setTimeout(function () {
             cekstatus.advice({trxid: status.trxId,}, callbackFromWebReport);
         }, sleep_before_retry);
         return;
     } else {
         responseCode = status.response.resultcode[0].replace(/^00/, "");
         if (['00', '05', '12', '68', '90', '63', '18', '96'].indexOf(responseCode) >= 0) {
             responseCode = '40';
         }
     }
     callbackReport(status.response.reffid[0].trim(), responseCode, responseMessage);
 }
 function createHttpReportServer() {
     var httpServer = http.createServer(function(request, response) {
         var qs = url.parse(request.url, true).query;
         var path = url.parse(request.url).pathname;
         logger.info('Got reverse report from partner', {path: path, qs: qs});
         response.end('OK');
+        var requestId = qs.reffid;
+        var resultCode = qs.rescode;
+        if (requestId && resultCode && resulCode != '0') {
+            if (pendingResultCode.indexOf(resultCode) >= 0) {
+                callbackReport(requestId, '68', 'Got reverse report: ' + qs.msg);
+            } else {
+                callbackReport(requestId, '40', 'Got reverse report: ' + qs.msg);
+            }
+            return;
+        }
         var  trxid;
         try {
             trxid = qs.transid;
         }
         catch(err) {
         }
         if (trxid) {
             logger.info('Requesting advice from webreport', {trxid: trxid})
             cekstatus.advice({trxid: trxid}, callbackFromWebReport);
         }
     });
     httpServer.listen(config.h2h_out.listen_port, function() {
         logger.info('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port);
     });
 }
 function start(options) {
     if (!options) {
         console.log('Undefined options, terminating....');
         process.exit(1);
     }
     if (options.config) {
         config = options.config;
     } else {
         console.log('Undefined options.config, terminating....')
         process.exit(1);
     }
     if (options.aaa) {
         aaa = options.aaa;
         callbackReport = options.aaa.callbackReportWithPushToMongoDb;
     } else {
         console.log('Undefined options.aaa, terminating....')
         process.exit(1);
     }
     if (options && options.logger) {
         logger = options.logger;
     } else {
         logger = new winston.Logger({
             transports: [
               new (winston.transports.Console)()
             ]
         });
     }
     createHttpReportServer();
     initMongoClient();
 }
 exports.start = start;
 exports.topupRequest = topupRequest;