1:羽声新版本
This commit is contained in:
@@ -0,0 +1,281 @@
|
||||
package com.xscm.moduleutil.utils;
|
||||
|
||||
import android.os.Handler;
|
||||
import android.os.Looper;
|
||||
import com.blankj.utilcode.util.LogUtils;
|
||||
import com.xscm.moduleutil.bean.RedPacketInfo;
|
||||
import lombok.Getter;
|
||||
import lombok.Setter;
|
||||
|
||||
import java.util.*;
|
||||
import java.util.concurrent.ConcurrentHashMap;
|
||||
|
||||
/**
|
||||
* 红包管理器单例类
|
||||
*/
|
||||
public class QXRedPacketManager {
|
||||
private static QXRedPacketManager instance;
|
||||
private final Map<String, RedPacketInfo> redPackets;
|
||||
private Handler checkTimerHandler;
|
||||
private Runnable checkTimerRunnable;
|
||||
|
||||
// 私有构造函数，防止外部实例化
|
||||
private QXRedPacketManager() {
|
||||
this.redPackets = new ConcurrentHashMap<>();
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取单例实例
|
||||
*
|
||||
* @return QXRedPacketManager 单例
|
||||
*/
|
||||
public static QXRedPacketManager getInstance() {
|
||||
if (instance == null) {
|
||||
synchronized (QXRedPacketManager.class) {
|
||||
if (instance == null) {
|
||||
instance = new QXRedPacketManager();
|
||||
}
|
||||
}
|
||||
}
|
||||
return instance;
|
||||
}
|
||||
public List<RedPacketInfo> getSortedUserListLambda(Map<String, RedPacketInfo> userMap) {
|
||||
List<RedPacketInfo> redPacketInfoList = new ArrayList<>(userMap.values());
|
||||
redPacketInfoList.sort((user1, user2) -> Long.compare(user1.getStart_time(), user2.getStart_time()));
|
||||
return redPacketInfoList;
|
||||
}
|
||||
|
||||
/**
|
||||
* 添加红包列表
|
||||
*
|
||||
* @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);
|
||||
}
|
||||
|
||||
// 在添加数据后启动定时器（如果尚未启动）
|
||||
startCheckTimer();
|
||||
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);
|
||||
|
||||
// 在添加数据后启动定时器（如果尚未启动）
|
||||
startCheckTimer();
|
||||
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 getSortedUserListLambda(redPackets);
|
||||
}
|
||||
|
||||
/**
|
||||
* 根据ID获取红包
|
||||
*
|
||||
* @param packetId 红包ID
|
||||
* @return 红包模型
|
||||
*/
|
||||
public RedPacketInfo getRedPacket(String packetId) {
|
||||
return this.redPackets.get(packetId);
|
||||
}
|
||||
|
||||
/**
|
||||
* 开始检查定时器
|
||||
*/
|
||||
public void startCheckTimer() {
|
||||
// 如果定时器已经在运行，直接返回
|
||||
if (checkTimerRunnable != null && checkTimerHandler != null) {
|
||||
return;
|
||||
}
|
||||
if (checkTimerRunnable == null) {
|
||||
checkTimerRunnable = new Runnable() {
|
||||
@Override
|
||||
public void run() {
|
||||
checkAndUpdateRedPackets();
|
||||
}
|
||||
};
|
||||
|
||||
checkTimerHandler = new Handler(Looper.getMainLooper());
|
||||
checkTimerHandler.post(checkTimerRunnable);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 检查并更新红包状态
|
||||
*/
|
||||
private void checkAndUpdateRedPackets() {
|
||||
// 添加空值检查
|
||||
if (this.redPackets == null || this.redPackets.isEmpty()) {
|
||||
return;
|
||||
}
|
||||
List<RedPacketInfo> packets = getAllRedPackets();
|
||||
|
||||
for (RedPacketInfo packet : packets) {
|
||||
long packetTime = packet.remainingTime();
|
||||
LogUtils.e("红包剩余时间：" + packet.getRedpacket_time());
|
||||
long redpacketTime = 0;
|
||||
try {
|
||||
if (packet.getRedpacket_time() != null) {
|
||||
redpacketTime = Long.parseLong(packet.getRedpacket_time());
|
||||
}
|
||||
} catch (NumberFormatException e) {
|
||||
LogUtils.e("红包时间格式错误: " + packet.getRedpacket_time());
|
||||
}
|
||||
if (packetTime <= -redpacketTime) {
|
||||
|
||||
removeRedPacket(packet.getRedpacket_id());
|
||||
}
|
||||
if (packet.getCountdown()==0){
|
||||
continue;
|
||||
}
|
||||
|
||||
if (this.delegate != null && this.delegate instanceof QXRedPacketManagerDelegate) {
|
||||
((QXRedPacketManagerDelegate) this.delegate).didUpdateRedPacketTime(packet, packetTime);
|
||||
}
|
||||
|
||||
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());
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// 继续执行定时任务
|
||||
// 修复：增加空值检查避免 NullPointerException
|
||||
if (checkTimerHandler != null && checkTimerRunnable != null) {
|
||||
// 继续执行定时任务
|
||||
checkTimerHandler.postDelayed(checkTimerRunnable, 1000);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 移除所有红包
|
||||
*/
|
||||
public void removeAllRedPackets() {
|
||||
this.redPackets.clear();
|
||||
endCheckTimer();
|
||||
}
|
||||
|
||||
/**
|
||||
* 结束检查定时器
|
||||
*/
|
||||
public void endCheckTimer() {
|
||||
if (checkTimerHandler != null) {
|
||||
checkTimerHandler.removeCallbacks(checkTimerRunnable);
|
||||
checkTimerHandler = null;
|
||||
checkTimerRunnable = null;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 销毁红包信息
|
||||
*/
|
||||
public void destroyRedpacketInfo() {
|
||||
removeAllRedPackets();
|
||||
endCheckTimer();
|
||||
this.delegate = null;
|
||||
}
|
||||
|
||||
/**
|
||||
* 委托接口
|
||||
*/
|
||||
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);
|
||||
|
||||
/**
|
||||
* 更新红包时间回调
|
||||
*
|
||||
* @param packet 红包模型
|
||||
* @param packetTime 红包剩余时间
|
||||
*/
|
||||
void didUpdateRedPacketTime(RedPacketInfo packet, long packetTime);
|
||||
}
|
||||
|
||||
/**
|
||||
* -- SETTER --
|
||||
* 设置委托对象
|
||||
*
|
||||
*
|
||||
* -- GETTER --
|
||||
* 获取委托对象
|
||||
*
|
||||
@param delegate 委托对象
|
||||
* @return 委托对象
|
||||
*/
|
||||
@Getter
|
||||
@Setter
|
||||
private QXRedPacketManagerDelegate delegate;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user