joybuywork/internal/service/queue/consumer/campaignnotice/validevents/dice.go

package validevents

import (
	"joybuywork/internal/repository/model"
	"joybuywork/internal/repository/mtype"
	"joybuywork/internal/service/provider/players"
	"fmt"
)

type dice struct {
	base
}

func (s *dice) Register(helper, beHelper *model.FissionUser) (setHelp bool, err error) {
	tasks, setHelp, err := s._getRegisterTasks(helper.CampaignID)
	if err != nil || len(tasks) == 0 {
		return
	}

	err = s._fixTaskDo(beHelper, helper, tasks)
	if err != nil {
		return
	}

	return
}

func (s *dice) Install(helper, beHelper *model.FissionUser) (setHelp bool, err error) {
	tasks, setHelp, err := s._getInstallTasks(helper.CampaignID)
	if err != nil || len(tasks) == 0 {
		return
	}

	err = s._fixTaskDo(beHelper, helper, tasks)
	if err != nil {
		return
	}

	return
}

func (s *dice) Event(user *model.FissionUser) (targetNum int32, setHelp bool, err error) {
	player, err := players.NewDice(s.Ctx, user)
	if err != nil {
		return
	}

	targetData, err := s._event(user, func(user *model.FissionUser, tasks []*model.FissionCampaignTask) (err error) {
		return player.FinishTask(tasks...)
	})
	if err != nil {
		return
	}

	targetNum = targetData.targetNum

	return
}

// 用户固定事件任务
func (s *dice) _fixTaskDo(user, helper *model.FissionUser, tasks []*model.FissionCampaignTask) (err error) {
	player, err := players.NewDice(s.Ctx, user)
	if err != nil {
		return
	}

	for _, task := range tasks {
		switch task.PropMark {
		case mtype.FissionCampaignTaskPropMarkChance:
			err = s._taskEffectDo(user, task, func() (err error) {
				return player.FinishTask(task)
			})
			if err != nil {
				return
			}
		case mtype.FissionCampaignTaskPropMarkFixedRoll:
			err = s._taskEffectDo(user, task, func() (err error) {
				return player.FinishTask(task)
			}, mtype.FissionCampaignTaskPropMarkFixedRoll, fmt.Sprint(helper.ID))
			if err != nil {
				return
			}
		}
	}

	return
}