|
|
@ -43,8 +43,10 @@ func NewPushDatabase(cache cache.ThirdCache, kafkaConf *config.Kafka) PushDataba
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|
return nil
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return &pushDataBase{cache: cache,
|
|
|
|
return &pushDataBase{
|
|
|
|
producerToOfflinePush: producerToOfflinePush}
|
|
|
|
cache: cache,
|
|
|
|
|
|
|
|
producerToOfflinePush: producerToOfflinePush,
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
func (p *pushDataBase) DelFcmToken(ctx context.Context, userID string, platformID int) error {
|
|
|
|
func (p *pushDataBase) DelFcmToken(ctx context.Context, userID string, platformID int) error {
|
|
|
|