salix/modules/worker/back/models/operator.js

module.exports = function(Self) {
    Self.observe('after save', async ctx => {
        const instance = ctx.data || ctx.instance;
        const models = Self.app.models;
        const options = ctx.options;
        const notification = 'backup-printer-selected';

        if (!instance?.sectorFk || !instance?.labelerFk) return;

        const sector = await models.Sector.findById(instance.sectorFk, {
            fields: ['backupPrinterFk']
        }, options);

        if (sector.backupPrinterFk && sector.backupPrinterFk == instance.labelerFk) {
            const {userId} = ctx.options.accessToken;
            const {delay} = await models.Notification.findOne({
                where: {name: notification}
            }, options);
            const hasNotified = await models.NotificationQueue.findOne({
                where: {
                    notificationFk: notification,
                    and: [
                        {params: {like: '%\"labelerId\":' + instance.labelerFk + '%'}},
                        {params: {like: '%\"sectorId\":' + instance.sectorFk + '%'}}
                    ]
                },
                order: 'created DESC',
            }, options);

            if (hasNotified?.created - Date.now() > delay || !hasNotified?.created || !delay) {
                await models.NotificationQueue.create({
                    notificationFk: notification,
                    authorFk: userId,
                    params: JSON.stringify(
                        {
                            'labelerId': instance.labelerFk,
                            'sectorId': instance.sectorFk,
                            'workerId': userId
                        }
                    )
                }, options);
            }
        }
    });
};