diff --git a/api/app/lib/controllers/push/config.js b/api/app/lib/controllers/push/config.js index 3feedea..21c630a 100644 --- a/api/app/lib/controllers/push/config.js +++ b/api/app/lib/controllers/push/config.js @@ -19,6 +19,7 @@ async function list (ctx) { where: { del: false }, + order: [['id', 'desc']], include: [{ model: models.ProjectCorrelation, where: projectCorrelationWhere, diff --git a/api/app/lib/schedule/alarms_push.js b/api/app/lib/schedule/alarms_push.js index 9b2c556..c7ff0ee 100644 --- a/api/app/lib/schedule/alarms_push.js +++ b/api/app/lib/schedule/alarms_push.js @@ -16,13 +16,14 @@ module.exports = function (app, opts) { const curMinOfYear = moment().diff(moment().startOf('year'), 'minutes') const configListRes = await models.AlarmPushConfig.findAll({ where: { - del: false + del: false, + disable: false }, order: ['id'], include: [{ model: models.ProjectCorrelation, where: { - del: false + del: false, }, required: true }], diff --git a/api/app/lib/service/kafka.js b/api/app/lib/service/kafka.js index 5c4cb9a..46adfbc 100644 --- a/api/app/lib/service/kafka.js +++ b/api/app/lib/service/kafka.js @@ -12,12 +12,12 @@ module.exports = async function factory(app, opts) { console.log('111111 ready 666666666666') }) - // const kafka = { - // producer: producer, - // configUpdateMessage: opts.configUpdateMessage || {} - // }; + const kafka = { + producer: producer, + configUpdateMessage: opts.configUpdateMessage || {} + }; - // app.fs.kafka = kafka; + app.fs.kafka = kafka; app.fs.logger.log('debug', "[FS-KAFKA]", "Init.Success");