Reload97 / sate24-to-kospinjasa

Compare View

switch
from
...
to
 
Commits (2)

Changes

Showing 1 changed file Side-by-side Diff

partner-kospinjasa.js
Diff comments   View file @ 89c3eca
... ... @@ -21,7 +21,6 @@ var logger;
21 21 var options;
22 22 var mongodb;
23 23  
24   -
25 24 function start(_config, _callbackReport, options) {
26 25 config = _config;
27 26 callbackReport = _callbackReport
... ... @@ -140,12 +139,29 @@ function isMongoReady() {
140 139 }
141 140  
142 141 function topupRequest(task, retry) {
143   - if (config && config.globals && config.globals.reject_on_pending_count && matrix && matrix.strikeStatus && matrix.strikeStatus.pending) {
144   - if (parseInt(config.globals.reject_on_pending_count) <= matrix.strikeStatus.pending) {
145   - callbackReport(task.requestId, '13', 'Reject trx karena pending terlalu banyak');
146   - return;
  142 +
  143 + try {
  144 + if (config && config.globals && config.globals.reject_on_pending_count && matrix && matrix.strikeStatus && matrix.strikeStatus.pending) {
  145 +
  146 + var pendingCount = matrix.strikeStatus.pending;
  147 + var pendingLimitCount = parseInt(config.globals.reject_on_pending_count);
  148 +
  149 + if (pendingLimitCount <= matrix.strikeStatus.pending) {
  150 +
  151 + logger.warn(
  152 + 'Reject trx karena pending terlalu banyak',
  153 + {pendingCount: pendingCount, pendingLimitCount: pendingLimitCount}
  154 + );
  155 +
  156 + callbackReport(task.requestId, '13', 'Reject trx karena pending terlalu banyak');
  157 + return;
  158 + }
147 159 }
148 160 }
  161 + catch(err) {
  162 + logger.warn("Exception saat periksa pendingLimit: " + err);
  163 + }
  164 +
149 165  
150 166 task.ts = moment(task.timestamp, 'YYYYMMDDHHmmss').format('YYYY-MM-DD HH:mm:ss');
151 167 task.ts_date = moment(task.timestamp, 'YYYYMMDDHHmmss').format('YYYY-MM-DD');
... ... @@ -265,6 +281,7 @@ function billpayment(task, balance) {
265 281 lastRequest: soapClient.lastRequest,
266 282 lastMessage: soapClient.lastMessage,
267 283 lastResponse: soapClient.lastResponse,
  284 + lastElapsedTime: soapClient.lastElapsedTime,
268 285 }
269 286 );
270 287  
... ... @@ -279,7 +296,7 @@ function billpayment(task, balance) {
279 296 }
280 297  
281 298 topupResponseHandler(task, result, balance, soapClient.lastResponse);
282   - });
  299 + }, , {timeout: 120000, time: true});
283 300 });
284 301 }
285 302