package com.stylefeng.guns.modular.system.util.redisqueue;

import org.springframework.stereotype.Component;
import redis.clients.jedis.Jedis;

import java.util.Collections;
import java.util.List;

@Component
public class RedisFifoQueue {

    private final Jedis jedis;
    private final String queueKey;

    private String host="127.0.0.1";

    private int port=10644;

    private String password="JiXiChuXing2026!Redis@";

    private String queueKeyFromConfig ="my_queue";

    public RedisFifoQueue() {
        this.jedis = new Jedis(host, port);
        if (password != null && !password.isEmpty()) {
            this.jedis.auth(password);
        }
        this.queueKey = queueKeyFromConfig;
    }
    public RedisFifoQueue(String host, int port, String queueKey) {
        this.jedis = new Jedis(host, port);
        this.queueKey = queueKey;
    }

    // 入队：添加元素到队列末尾
    public void enqueue(String item) {
        jedis.rpush(queueKey, item);
        System.out.println("入队: " + item);
    }

    // 出队：从队列头部取出元素（阻塞可选）
    public String dequeue() {
        String item = jedis.lpop(queueKey);
        if (item != null) {
            System.out.println("出队: " + item);
        } else {
            System.out.println("队列为空");
        }
        return item;
    }
    public void removeOrderById(String orderId) {

        jedis.lrem(queueKey, 0, orderId);
    }
    public RedisFifoQueue(String host, int port, String password, String queueKey) {
        this.jedis = new Jedis(host, port);
        this.jedis.auth(password);  // 添加密码认证
        this.queueKey = queueKey;
    }
    /**
     * 获取队列中所有元素（按 FIFO 顺序）
     * @return 队列中的所有元素列表
     */
    public List<String> getAllItems() {
        Long size = jedis.llen(queueKey);
        if (size == 0) {
            return Collections.emptyList();
        }
        // LRANGE key start stop，0 表示第一个元素，-1 表示最后一个元素
        return jedis.lrange(queueKey, 0, -1);
    }
    /**
     * 清空整个队列
     */
    public void clearQueue() {
        jedis.del(queueKey);
        System.out.println("队列已清空");
    }

    // 查看队列大小
    public long size() {
        return jedis.llen(queueKey);
    }

    // 关闭连接
    public void close() {
        jedis.close();
    }
}