package cn.iocoder.yudao.module.mes.service.energy;

import cn.iocoder.yudao.framework.tenant.core.util.TenantUtils;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import org.springframework.transaction.event.*;

@Component @Slf4j
public class EnergyAlertListener {
    @Resource private EnergyAlertService energyAlertService;

    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
    public void onRecordChanged(EnergyRecordChangedEvent event) {
        TenantUtils.execute(event.tenantId(), () -> {
            for (var date : event.dates()) {
                try { energyAlertService.check(date); }
                catch (Exception e) { log.error("能耗预警检查失败 tenant={} date={}", event.tenantId(), date, e); }
            }
        });
    }
}