'use strict';

module.exports = async app => {
    app.models = {};
app.beforeStart(async () => {
    const ctx = app.createAnonymousContext();
    if (app.config.report_data_type === 'kafka') {
        // kafka消费者
        ctx.service.web.reportTask.saveWebReportDatasForKafka();
        ctx.service.wx.reportTask.saveWxReportDatasForKafka();
    } else if (app.config.report_data_type === 'redisPubSub') {
        ctx.service.wx.reportTask.saveWxReportDatasForRedisPubSub();
    }
});
};