package com.ycl.timer;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.ycl.service.message.IMessageService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import com.ycl.entity.message.Message;

import java.util.List;

@Slf4j
@Component
public class SendMsg {
    @Value("${spring.profiles.active}")
    private String env;

    @Autowired
    IMessageService messageService;

    @Scheduled(cron = "0 0/2 * * * ?")
    public void runAction() {
        if ("online".equals(env)) {

            List<Message> messages = messageService.list(new LambdaQueryWrapper<Message>()
                    .eq(Message::getStatus, 0));

            for (Message msg : messages) {
                messageService.sendSMS(msg);
            }
        }
    }

}