Commit 229e2fb2 authored by 何娜's avatar 何娜

城市

parent 576cbbae
Pipeline #6035 passed with stage
in 2 seconds
...@@ -143,13 +143,11 @@ class TaskController extends Controller { ...@@ -143,13 +143,11 @@ class TaskController extends Controller {
//任务回调接口 //任务回调接口
async handleCallback() { async handleCallback() {
const { ctx, service } = this; const { ctx, service } = this;
ctx.logger.info('---------handleCallback_into------------', ctx.request.body);
const { taskId } = ctx.request.body; const { taskId } = ctx.request.body;
const result = await service.task.fetchTask({ taskId }); const result = await service.task.fetchTask({ taskId });
ctx.logger.info('---------handleCallback_result----------', result); ctx.logger.info('【handleCallback_result】', result.code);
ctx.success(); ctx.success();
const order = await service.order.getOneByTaskId(taskId); const order = await service.order.getOneByTaskId(taskId);
// ctx.logger.info('---------handleCallback_order----------', order);
if (!order) { if (!order) {
ctx.logger.error('handleCallback', taskId, '未查询到此任务'); ctx.logger.error('handleCallback', taskId, '未查询到此任务');
return return
...@@ -197,7 +195,6 @@ class TaskController extends Controller { ...@@ -197,7 +195,6 @@ class TaskController extends Controller {
note: { code: 0, msg: '任务成功', data: { data: null, loginParam: null, cityId, orderSn: orderId } }, note: { code: 0, msg: '任务成功', data: { data: null, loginParam: null, cityId, orderSn: orderId } },
}; };
try { try {
// const insertData = await service.washData.wash(result);
result.cityId = Number(result.data.cityId); result.cityId = Number(result.data.cityId);
result.cityName = await service.scripts.fetchScriptName(result.data.cityId); result.cityName = await service.scripts.fetchScriptName(result.data.cityId);
result.data = JSON.parse(result.data.data); result.data = JSON.parse(result.data.data);
......
...@@ -63,7 +63,7 @@ class ScriptsService extends Service { ...@@ -63,7 +63,7 @@ class ScriptsService extends Service {
if (result.data && (String(result.data.id) === scriptId)) { if (result.data && (String(result.data.id) === scriptId)) {
await this.app.redis.set(redisScriptListKey + scriptId, JSON.stringify(result.data), 'EX', 60); await this.app.redis.set(redisScriptListKey + scriptId, JSON.stringify(result.data), 'EX', 60);
} }
return result.data; return result.data['hub_name'];
} }
async fetchParams(refresh = false) { async fetchParams(refresh = false) {
......
...@@ -4,10 +4,10 @@ module.exports = () => { ...@@ -4,10 +4,10 @@ module.exports = () => {
const config = exports = {}; const config = exports = {};
config.debug = true; config.debug = true;
config.logger = { config.logger = {
dir: '/jianbing/logs/tax_api', dir: '/jianbing/logs/taxh5',
}; };
config.projectRootPath = '/tax_api'; config.projectRootPath = '/taxh5';
config.redis = { config.redis = {
client: { client: {
...@@ -19,7 +19,6 @@ module.exports = () => { ...@@ -19,7 +19,6 @@ module.exports = () => {
}; };
config.taskAPI = { config.taskAPI = {
host: process.env.TASKAPI_HOST, host: process.env.TASKAPI_HOST,
newhost: 'http://tt.51gjj.com:7001',
fetchHubsUrl: '', fetchHubsUrl: '',
createTaskUrl: '/IncomeTax/createItTask', createTaskUrl: '/IncomeTax/createItTask',
fetchCodeUrl: '/IncomeTax/getItCode', fetchCodeUrl: '/IncomeTax/getItCode',
...@@ -33,26 +32,26 @@ module.exports = () => { ...@@ -33,26 +32,26 @@ module.exports = () => {
fetchTheme: '/chaos/theme', fetchTheme: '/chaos/theme',
fetchScripts: '/chaos/partners/scripts', fetchScripts: '/chaos/partners/scripts',
fetchAgreements: '/chaos/agreements', fetchAgreements: '/chaos/agreements',
redisThemePrefix: 'URANUS.HF.PARNTERS.THEME',
redisScriptsPrefix: 'URANUS.HF.PARNTERS.SCRIPTS',
redisAgreementsPrefix: 'URANUS.HF.PARNTERS.Agreements',
fetchInfo: '/chaos/partner', fetchInfo: '/chaos/partner',
redisInfoPrefix:'URANUS.HF.PARNTERS.Info', redisThemePrefix: 'URANUS.IT.PARNTERS.THEME',
redisScriptsPrefix: 'URANUS.IT.PARNTERS.SCRIPTS',
redisAgreementsPrefix: 'URANUS.IT.PARNTERS.Agreements',
redisInfoPrefix: 'URANUS.IT.PARNTERS.Info',
}; };
config.scriptsAPI = { config.scriptsAPI = {
host: 'https://dev-nginx.jianbing.com/zeus-api/v1', host: process.env.SCRIPTSAPI_HOST,
fetchScriptsUrl: '/chaos/hf/two_dimension_array/queries', fetchScriptsUrl: '/chaos/it/two_dimension_array/queries',
fetchOneScriptUrl: '/chaos/hf/two_dimension_array/info', fetchOneScriptUrl: '/chaos/it/two_dimension_array/info',
fetchParamsInfoUrl: '/chaos/hf/login_param_map', fetchParamsInfoUrl: '/chaos/it/login_param_map',
fetchQueryButtonUrl: '/chaos/hf/query_button', fetchQueryButtonUrl: '/chaos/it/query_button',
fetchHelpUrl: '/chaos/hf/help', fetchHelpUrl: '/chaos/it/help',
fetchNoticeUrl: '/chaos/hf/notice', fetchNoticeUrl: '/chaos/it/notice',
fetchHubSeriptsUrl: '/chaos/hf/hubs', fetchHubSeriptsUrl: '/chaos/it/hubs',
fetchScriptByCityNameUrl: '/chaos/hf/city_scripts', fetchScriptByCityNameUrl: '/chaos/it/city_scripts',
redisScriptsKey: 'DATA_SERVER_SHEBAO.SCRIPTS', redisScriptsKey: 'URANUS.IT.SCRIPTS',
redisParamsKey: 'DATA_SERVER_SHEBAO.PARAMS', redisParamsKey: 'URANUS.IT.PARAMS',
redisScriptListKey: 'DATA_SERVER_SHEBAO.SCRIPTLIST', redisScriptListKey: 'URANUS.IT.SCRIPTLIST',
}; };
config.storageAPI = { config.storageAPI = {
...@@ -79,11 +78,11 @@ module.exports = () => { ...@@ -79,11 +78,11 @@ module.exports = () => {
}; };
config.lockKeys = { config.lockKeys = {
fecthHub: 'NEWSB.HF.HUBS.LOCK', fecthHub: 'URANUS.IT.HUBS.LOCK',
fecteToken: 'NEWSB.HF.TOKEN.LOCK', fecteToken: 'URANUS.IT.TOKEN.LOCK',
token: 'NEWSB.HF.TOKEN', token: 'URANUS.IT.TOKEN',
fecthParnters: 'NEWSB.PARNTERS.LOCK', fecthParnters: 'URANUS.PARNTERS.LOCK',
taskPrefix: 'NEWSB.TASK', taskPrefix: 'URANUS.TASK',
}; };
config.sequelize = { config.sequelize = {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment