Java实现库存报警提醒方法详解

public class Product {
    private Long id;
    private String name;
    private int stock;
    private int minStock; // 最低库存警戒线

    // 构造函数
    public Product(Long id, String name, int stock, int minStock) {
        this.id = id;
        this.name = name;
        this.stock = stock;
        this.minStock = minStock;
    }

    // Getter 和 Setter 方法
    public Long getId() { return id; }
    public String getName() { return name; }
    public int getStock() { return stock; }
    public int getMinStock() { return minStock; }
}

import java.util.List;
import java.util.ArrayList;

public class StockAlertService {

    // 模拟数据库中的商品列表
    private List products = new ArrayList<>();

    public StockAlertService() {
        // 初始化测试数据
        products.add(new Product(1L, "手机", 5, 10));
        products.add(new Product(2L, "耳机", 15, 10));
        products.add(new Product(3L, "充电器", 3, 8));
    }

    // 检查库存并发出报警
    public void checkStockAndAlert() {
        for (Product product : products) {
            if (product.getStock() < product.getMinStock()) {
                sendAlert(product);
            }
        }
    }

    // 发送报警信息（可扩展为邮件、短信等）
    private void sendAlert(Product product) {
        System.out.println("【库存报警】商品：" + product.getName() +
            " 当前库存：" + product.getStock() +
            " 已低于最低库存：" + product.getMinStock());
    }
}

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

public class StockMonitor {

    public static void main(String[] args) {
        ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
        StockAlertService alertService = new StockAlertService();

        // 延迟1秒开始，每隔60秒执行一次检查
        scheduler.scheduleAtFixedRate(alertService::checkStockAndAlert,
            1, 60, TimeUnit.SECONDS);
    }
}

    com.sun.mail
    javax.mail
    1.6.2

private void sendEmailAlert(Product product) {
    try {
        Properties props = new Properties();
        props.put("mail.smtp.host", "smtp.qq.com");
        props.put("mail.smtp.port", "587");
        props.put("mail.smtp.auth", "true");
        props.put("mail.smtp.starttls.enable", "true");

        Session session = Session.getInstance(props, new Authenticator() {
            protected PasswordAuthentication getPasswordAuthentication() {
                return new PasswordAuthentication("your-email@qq.com", "your-app-password");
            }
        });

        Message message = new MimeMessage(session);
        message.setFrom(new InternetAddress("your-email@qq.com"));
        message.setRecipient(Message.RecipientType.TO, new InternetAddress("admin@example.com"));
        message.setSubject("库存不足警告");
        message.setText("商品：" + product.getName() + " 库存不足！当前：" + 
                        product.getStock() + "，阈值：" + product.getMinStock());

        Transport.send(message);
    } catch (Exception e) {
        e.printStackTrace();
    }
}