feat: 更新延迟队列

delay/redis_produce.go

@@ -9,12 +9,12 @@ package delay
 
 import (
 	"context"
-	"encoding/json"
 	"sync"
 	"time"
 
-	"git.zhangdeman.cn/zhangdeman/util"
-	"github.com/go-redis/redis/v8"
+	"git.zhangdeman.cn/zhangdeman/serialize"
+	"git.zhangdeman.cn/zhangdeman/wrapper/op_string"
+	"github.com/redis/go-redis/v9"
 )
 
 // NewRedisQueue 获取redis队列实例
@@ -65,15 +65,14 @@ func (rp *redisProduce) Produce(ctx context.Context, data ...*Queue) error {
 // Author : go_developer@163.com<白茶清欢>
 //
 // Date : 18:22 2022/7/6
-func (rp *redisProduce) buildAddMember(queueData *Queue) *redis.Z {
-	byteData, _ := json.Marshal(&ProduceData{
-		MsgID:     util.String.Md5(util.String.GenRandom("", 16)),
-		Timestamp: time.Now().UnixNano() / 1e6,
-		Host:      util.IP.GetHostIP(),
-		Data:      queueData.Data,
-	})
-	return &redis.Z{
-		Score:  float64(time.Now().Unix() + queueData.DelayTime),
-		Member: string(byteData),
+func (rp *redisProduce) buildAddMember(queueData *Queue) redis.Z {
+	return redis.Z{
+		Score: float64(time.Now().Unix() + queueData.DelayTime),
+		Member: serialize.JSON.MarshalForStringIgnoreError(&ProduceData{
+			MsgID:     op_string.RandomMd5().Value,
+			Timestamp: time.Now().UnixNano() / 1e6,
+			Host:      "",
+			Data:      queueData.Data,
+		}),
 	}
 }