...
|
...
|
@@ -9,14 +9,20 @@ |
|
|
const rp = require('request-promise');
|
|
|
const _ = require('lodash');
|
|
|
const log = require('./logger');
|
|
|
const api = require('../config/common').domains.service;
|
|
|
const api = require('../config/common').domains.api;
|
|
|
const serviceApi = require('../config/common').domains.service;
|
|
|
const searchApi = require('../config/common').domains.search;
|
|
|
const Timer = require('./timer');
|
|
|
|
|
|
|
|
|
const ApiUrl = api;
|
|
|
let ApiUrl;
|
|
|
|
|
|
class API {
|
|
|
|
|
|
constructor() {
|
|
|
ApiUrl = api;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* get
|
|
|
* @param url String
|
...
|
...
|
@@ -30,16 +36,20 @@ class API { |
|
|
};
|
|
|
|
|
|
let timer = new Timer();
|
|
|
|
|
|
timer.put('getApi');// 统计时间开始
|
|
|
|
|
|
let ret = rp(options);
|
|
|
|
|
|
ret.then((body)=>{
|
|
|
let duration = timer.put('getApi');// 接口返回
|
|
|
|
|
|
log.info('API GET: %s, parms: %j , durationMs: %d ms , body: %s', options.url, options.qs, duration, body);
|
|
|
}).catch((error)=>{
|
|
|
let duration = timer.put('getApi');// 接口返回
|
|
|
log.error('API GET: %s, parms: %j , durationMs: %d ms error: %s , statusCode: %d', options.url, options.qs, duration, error.message, error.statusCode);
|
|
|
|
|
|
log.error('API GET: %s, parms: %j , durationMs: %d ms error: %s , statusCode: %d',
|
|
|
options.url, options.qs, duration, error.message, error.statusCode);
|
|
|
});
|
|
|
|
|
|
return ret;
|
...
|
...
|
@@ -78,4 +88,20 @@ class API { |
|
|
}
|
|
|
}
|
|
|
|
|
|
module.exports = API; |
|
|
class ServiceAPI extends API {
|
|
|
constructor() {
|
|
|
super();
|
|
|
ApiUrl = serviceApi;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
class SearchAPI extends API {
|
|
|
constructor() {
|
|
|
super();
|
|
|
ApiUrl = searchApi;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
exports.API = API;
|
|
|
exports.ServiceAPI = ServiceAPI;
|
|
|
exports.SearchAPI = SearchAPI; |
...
|
...
|
|