You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
83 lines
2.5 KiB
Go
83 lines
2.5 KiB
Go
package producer
|
|
|
|
import (
|
|
"context"
|
|
"joybuywork/internal/service/queue/types"
|
|
)
|
|
|
|
type CampaignNotice struct {
|
|
ctx context.Context
|
|
topic string
|
|
}
|
|
|
|
func NewCampaignNotice(ctx context.Context) CampaignNotice {
|
|
return CampaignNotice{
|
|
ctx: ctx,
|
|
topic: types.CampaignNoticeTopic,
|
|
}
|
|
}
|
|
|
|
func (p CampaignNotice) CampaignNotice(data types.CampaignNotice) {
|
|
_ = AP.Produce(p.ctx, p.topic, types.CampaignNoticeKey, data)
|
|
}
|
|
|
|
func (p CampaignNotice) CampaignOtherStat(data types.CampaignOtherStat) {
|
|
_ = AP.Produce(p.ctx, p.topic, types.CampaignOtherStatKey, data)
|
|
}
|
|
|
|
func (p CampaignNotice) CampaignRewardNotify(data types.CampaignRewardNotify) {
|
|
_ = AP.Produce(p.ctx, p.topic, types.CampaignRewardNotifyKey, data)
|
|
}
|
|
|
|
func (p CampaignNotice) CampaignTargetStat(data types.CampaignTargetStat) {
|
|
_ = AP.Produce(p.ctx, p.topic, types.CampaignTargetStatKey, data)
|
|
}
|
|
|
|
func (p CampaignNotice) CampaignCondStat(data types.CampaignCondStat) {
|
|
_ = AP.Produce(p.ctx, p.topic, types.CampaignCondStatKey, data)
|
|
}
|
|
|
|
func (p CampaignNotice) CampaignBehavior(data types.CampaignBehavior) {
|
|
_ = AP.Produce(p.ctx, p.topic, types.CampaignBehaviorKey, data)
|
|
}
|
|
|
|
func (p CampaignNotice) CampaignDiceMap(data types.CampaignDiceMap) {
|
|
_ = AP.Produce(p.ctx, p.topic, types.CampaignDiceMapKey, data)
|
|
}
|
|
|
|
func (p CampaignNotice) Download(data types.Download) {
|
|
_ = AP.Produce(p.ctx, p.topic, types.DownloadKey, data)
|
|
}
|
|
|
|
func (p CampaignNotice) ValidEvents(data types.ValidEvents) {
|
|
_ = AP.Produce(p.ctx, p.topic, types.ValidEventsKey, data)
|
|
}
|
|
|
|
func (p CampaignNotice) ProjectUser(data types.ProjectUser) {
|
|
_ = AP.Produce(p.ctx, p.topic, types.ProjectUserKey, data)
|
|
}
|
|
|
|
func (p CampaignNotice) RewardLimitUp(data types.RewardLimitUp) {
|
|
_ = AP.Produce(p.ctx, p.topic, types.RewardLimitUpKey, data)
|
|
}
|
|
|
|
func (p CampaignNotice) CampaignChildInvite(data types.CampaignChildInvite) {
|
|
_ = AP.Produce(p.ctx, p.topic, types.CampaignChildInviteKey, data)
|
|
}
|
|
|
|
func (p CampaignNotice) ProjectUserCoinDeduct(data types.ProjectUserCoinDeduct) {
|
|
_ = AP.Produce(p.ctx, p.topic, types.ProjectUserCoinDeductKey, data)
|
|
}
|
|
|
|
func (p CampaignNotice) CampaignVsSettlement(data types.CampaignVsSettlement) {
|
|
_ = AP.Produce(p.ctx, p.topic, types.CampaignVsSettlementKey, data)
|
|
}
|
|
|
|
func (p CampaignNotice) CampaignSettlementReward(data types.CampaignSettlementReward) {
|
|
_ = AP.Produce(p.ctx, p.topic, types.CampaignSettlementRewardKey, data)
|
|
}
|
|
|
|
func (p CampaignNotice) GameAction(data types.GameAction) {
|
|
_ = AP.Produce(p.ctx, p.topic, types.GameActionKey, data)
|
|
}
|