Commit cd09cc0b authored by 李尚科's avatar 李尚科

fix

parent 7f4477c2
Pipeline #12307 passed with stage
in 19 seconds
......@@ -24,7 +24,9 @@ class HuaYunPaas extends Subscription {
let lock = 'huayun:pass:cron:' + moment().format('MMDD');
ctx.logger.info(lock);
let redRes = await app.redis.setnx(lock, 1);
ctx.logger.info('in cron');
if (Number(redRes) === 1) {
ctx.logger.info('in redis');
await this.logic();
}
}
......@@ -33,6 +35,7 @@ class HuaYunPaas extends Subscription {
async logic() {
const { ctx } = this;
ctx.logger.info('in logic');
const accessToken = await this.getAccessToken();
const url = `http://221.194.132.83:7780/paas/Interface/${accessToken}/CallIn`;
const lastOne = await ctx.prometheusModel.HuayunPaasCallin.findOne({ order: [['id', 'desc']] });
......@@ -46,12 +49,14 @@ class HuaYunPaas extends Subscription {
ctx.logger.info(JSON.stringify({ start_time, now_time, start, limit }));
const result = await ctx.curl(url, { method: 'POST', contentType: 'json', dataType: 'json', timing: true, timeout: 300000, data: { start_time, now_time, start, limit } });
const ret = result.data;
ctx.logger.info('get result');
if (ret.status != 0 || !ret.message || ret.count == 0) {
return;
}
ctx.logger.info('in add');
const message = ret.message;
const list = message.data;
ctx.logger.info(JSON.stringify(message.count));
ctx.logger.info(message.count);
const insert_data = await this.format(list);
await ctx.prometheusModel.HuayunPaasCallin.bulkCreate(insert_data, { ignoreDuplicates: true });
......
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