1:红包发布和打开

2：抢最标准的红包
2025-10-14 17:15:09 +08:00
parent c72e2d7919
commit fcb538a621
5 changed files with 345 additions and 0 deletions
--- a/moduleUtil/src/main/java/com/xscm/moduleutil/utils/QXRedPacketManager.java
+++ b/moduleUtil/src/main/java/com/xscm/moduleutil/utils/QXRedPacketManager.java
@@ -0,0 +1,239 @@
+package com.xscm.moduleutil.utils;
+
+import android.os.Handler;
+import android.os.Looper;
+import com.xscm.moduleutil.bean.RedPacketInfo;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 红包管理器单例类
+ */
+public class QXRedPacketManager {
+    private static QXRedPacketManager instance;
+    private final Map<String, RedPacketInfo> redPackets;
+    private Handler checkTimerHandler;
+    private Runnable checkTimerRunnable;
+
+    // 私有构造函数，防止外部实例化
+    private QXRedPacketManager() {
+        this.redPackets = new HashMap<>();
+    }
+
+    /**
+     * 获取单例实例
+     *
+     * @return QXRedPacketManager 单例
+     */
+    public static QXRedPacketManager getInstance() {
+        if (instance == null) {
+            synchronized (QXRedPacketManager.class) {
+                if (instance == null) {
+                    instance = new QXRedPacketManager();
+                }
+            }
+        }
+        return instance;
+    }
+
+    /**
+     * 添加红包列表
+     *
+     * @param redPackets 红包模型列表
+     */
+    public void addRedPackets(List<RedPacketInfo> redPackets) {
+        if (redPackets == null || redPackets.isEmpty()) {
+            return;
+        }
+
+        for (RedPacketInfo model : redPackets) {
+            this.redPackets.put(model.getRedpacket_id(), model);
+        }
+
+        if (this.delegate != null && this.delegate instanceof QXRedPacketManagerDelegate) {
+            ((QXRedPacketManagerDelegate) this.delegate).onRedPacketsAdded(redPackets, this.redPackets.size());
+        }
+    }
+
+    /**
+     * 添加单个红包
+     *
+     * @param redPacket 红包模型
+     */
+    public void addRedPacket(RedPacketInfo redPacket) {
+        if (redPacket == null || redPacket.getRedpacket_id() == null) {
+            return;
+        }
+
+        this.redPackets.put(redPacket.getRedpacket_id(), redPacket);
+
+        if (this.delegate != null && this.delegate instanceof QXRedPacketManagerDelegate) {
+            ((QXRedPacketManagerDelegate) this.delegate).onRedPacketAdded(redPacket, this.redPackets.size());
+        }
+    }
+
+    /**
+     * 移除红包
+     *
+     * @param packetId 红包ID
+     */
+    public void removeRedPacket(String packetId) {
+        this.redPackets.remove(packetId);
+
+        if (this.delegate != null && this.delegate instanceof QXRedPacketManagerDelegate) {
+            ((QXRedPacketManagerDelegate) this.delegate).onRedPacketRemoved(packetId, this.redPackets.size());
+        }
+    }
+
+    /**
+     * 获取所有红包
+     *
+     * @return 红包列表
+     */
+    public List<RedPacketInfo> getAllRedPackets() {
+        return new ArrayList<>(this.redPackets.values());
+    }
+
+    /**
+     * 根据ID获取红包
+     *
+     * @param packetId 红包ID
+     * @return 红包模型
+     */
+    public RedPacketInfo getRedPacket(String packetId) {
+        return this.redPackets.get(packetId);
+    }
+
+    /**
+     * 开始检查定时器
+     */
+    public void startCheckTimer() {
+        if (checkTimerRunnable == null) {
+            checkTimerRunnable = new Runnable() {
+                @Override
+                public void run() {
+                    checkAndUpdateRedPackets();
+                }
+            };
+
+            checkTimerHandler = new Handler(Looper.getMainLooper());
+            checkTimerHandler.post(checkTimerRunnable);
+        }
+    }
+
+    /**
+     * 检查并更新红包状态
+     */
+    private void checkAndUpdateRedPackets() {
+        List<RedPacketInfo> packets = new ArrayList<>(this.redPackets.values());
+
+        for (RedPacketInfo packet : packets) {
+            boolean wasAvailable = packet.isAvailable();
+            packet.setAvailable(packet.canOpenNow());
+
+            // 状态发生变化时通知
+            if (wasAvailable != packet.isAvailable()) {
+                if (this.delegate != null && this.delegate instanceof QXRedPacketManagerDelegate) {
+                    ((QXRedPacketManagerDelegate) this.delegate).onRedPacketUpdated(packet, this.redPackets.size());
+                }
+            }
+
+            // 倒计时结束的红包可以设置自动移除
+            if (packet.getCountdown() > 0 && packet.remainingTime() <= -(Long.getLong(packet.getRedpacket_time()))) {
+                // 倒计时结束10秒后自动移除
+                removeRedPacket(packet.getRedpacket_id());
+            }
+        }
+
+        // 继续执行定时任务
+        checkTimerHandler.postDelayed(checkTimerRunnable, 1000);
+    }
+
+    /**
+     * 移除所有红包
+     */
+    public void removeAllRedPackets() {
+        this.redPackets.clear();
+    }
+
+    /**
+     * 结束检查定时器
+     */
+    public void endCheckTimer() {
+        if (checkTimerHandler != null) {
+            checkTimerHandler.removeCallbacks(checkTimerRunnable);
+            checkTimerHandler = null;
+            checkTimerRunnable = null;
+        }
+    }
+
+    /**
+     * 销毁红包信息
+     */
+    public void destroyRedpacketInfo() {
+        removeAllRedPackets();
+        endCheckTimer();
+        this.delegate = null;
+    }
+
+    /**
+     * 设置委托对象
+     *
+     * @param delegate 委托对象
+     */
+    public void setDelegate(QXRedPacketManagerDelegate delegate) {
+        this.delegate = delegate;
+    }
+
+    /**
+     * 获取委托对象
+     *
+     * @return 委托对象
+     */
+    public QXRedPacketManagerDelegate getDelegate() {
+        return this.delegate;
+    }
+
+    /**
+     * 委托接口
+     */
+    public interface QXRedPacketManagerDelegate {
+        /**
+         * 添加红包列表回调
+         *
+         * @param redPackets 红包列表
+         * @param remainingCount 剩余数量
+         */
+        void onRedPacketsAdded(List<RedPacketInfo> redPackets, int remainingCount);
+
+        /**
+         * 添加单个红包回调
+         *
+         @param redPacket 红包模型
+          * @param remainingCount 剩余数量
+         */
+        void onRedPacketAdded(RedPacketInfo redPacket, int remainingCount);
+
+        /**
+         * 移除红包回调
+         *
+         * @param packetId 红包ID
+         * @param remainingCount 剩余数量
+         */
+        void onRedPacketRemoved(String packetId, int remainingCount);
+
+        /**
+         * 更新红包状态回调
+         *
+         * @param packet 红包模型
+         * @param remainingCount 剩余数量
+         */
+        void onRedPacketUpdated(RedPacketInfo packet, int remainingCount);
+    }
+
+    private QXRedPacketManagerDelegate delegate;
+}
+