优化

zhanghua

2024-01-21 bc8074c56893eac3eb5002dcefeacd644d827a29

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
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);
            }
        }
    }
 
}