1
This commit is contained in:
昔念
417
modules/config/service/peak_tianxuan.go
Normal file
417
modules/config/service/peak_tianxuan.go
Normal file
@@ -0,0 +1,417 @@
|
||||
package service
|
||||
|
||||
import (
|
||||
"context"
|
||||
|
||||
"blazing/common/data/xmlres"
|
||||
"blazing/cool"
|
||||
"blazing/modules/config/model"
|
||||
"slices"
|
||||
"sort"
|
||||
|
||||
"github.com/gogf/gf/v2/errors/gerror"
|
||||
"github.com/gogf/gf/v2/frame/g"
|
||||
"github.com/gogf/gf/v2/util/gconv"
|
||||
)
|
||||
|
||||
type PeakTianxuanService struct {
|
||||
*cool.Service
|
||||
}
|
||||
|
||||
func NewPeakTianxuanService() *PeakTianxuanService {
|
||||
return &PeakTianxuanService{
|
||||
&cool.Service{
|
||||
Model: model.NewPeakTianxuan(),
|
||||
PageQueryOp: &cool.QueryOp{
|
||||
KeyWordField: []string{"preset_name", "remark"},
|
||||
FieldEQ: []string{"week_index", "pet_id", "is_enable"},
|
||||
AddOrderby: g.MapStrStr{
|
||||
"week_index": "desc",
|
||||
"display_order": "asc",
|
||||
"id": "desc",
|
||||
},
|
||||
},
|
||||
ListQueryOp: &cool.QueryOp{
|
||||
KeyWordField: []string{"preset_name", "remark"},
|
||||
FieldEQ: []string{"week_index", "pet_id", "is_enable"},
|
||||
AddOrderby: g.MapStrStr{
|
||||
"week_index": "desc",
|
||||
"display_order": "asc",
|
||||
"id": "desc",
|
||||
},
|
||||
},
|
||||
},
|
||||
}
|
||||
}
|
||||
|
||||
func (s *PeakTianxuanService) ModifyBefore(ctx context.Context, method string, param g.MapStrAny) (err error) {
|
||||
if method == "Delete" {
|
||||
return nil
|
||||
}
|
||||
|
||||
var (
|
||||
weekIndex = gconv.Uint32(param["week_index"])
|
||||
petID = gconv.Uint32(param["pet_id"])
|
||||
level = gconv.Uint32(param["level"])
|
||||
hp = gconv.Uint32(param["hp"])
|
||||
maxHp = gconv.Uint32(param["max_hp"])
|
||||
recordID = gconv.Uint32(param["id"])
|
||||
)
|
||||
|
||||
if weekIndex == 0 {
|
||||
return gerror.New("周序号不能为空")
|
||||
}
|
||||
if petID == 0 {
|
||||
return gerror.New("天选精灵ID不能为空")
|
||||
}
|
||||
if level == 0 {
|
||||
return gerror.New("预设等级不能为空")
|
||||
}
|
||||
if maxHp > 0 && hp > maxHp {
|
||||
return gerror.New("当前生命不能大于最大生命")
|
||||
}
|
||||
|
||||
var currentCount int
|
||||
query := cool.DBM(s.Model).Where("week_index", weekIndex).Where("pet_id", petID)
|
||||
if recordID > 0 {
|
||||
query = query.WhereNot("id", recordID)
|
||||
}
|
||||
if currentCount, err = query.Count(); err != nil {
|
||||
return err
|
||||
}
|
||||
if currentCount > 0 {
|
||||
return gerror.New("同一周不能重复配置同一只天选精灵")
|
||||
}
|
||||
|
||||
prevPetIDs, err := s.ListWeekPetIDs(weekIndex - 1)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if _, ok := prevPetIDs[petID]; ok {
|
||||
return gerror.New("本周天选精灵不能和上一周重复")
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
func (s *PeakTianxuanService) LatestWeekIndex() (uint32, error) {
|
||||
var result struct {
|
||||
WeekIndex uint32 `json:"week_index"`
|
||||
}
|
||||
|
||||
if err := dbm_nocache_noenable(s.Model).
|
||||
Fields("COALESCE(MAX(week_index), 0) AS week_index").
|
||||
Scan(&result); err != nil {
|
||||
return 0, err
|
||||
}
|
||||
|
||||
return result.WeekIndex, nil
|
||||
}
|
||||
|
||||
func (s *PeakTianxuanService) ListWeekPetIDs(weekIndex uint32) (map[uint32]struct{}, error) {
|
||||
ret := make(map[uint32]struct{})
|
||||
if weekIndex == 0 {
|
||||
return ret, nil
|
||||
}
|
||||
|
||||
var list []model.PeakTianxuan
|
||||
if err := dbm_enable(s.Model).Where("week_index", weekIndex).Scan(&list); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
for _, item := range list {
|
||||
ret[item.PetID] = struct{}{}
|
||||
}
|
||||
|
||||
return ret, nil
|
||||
}
|
||||
|
||||
func (s *PeakTianxuanService) GetWeekList(weekIndex uint32) ([]model.PeakTianxuan, error) {
|
||||
var list []model.PeakTianxuan
|
||||
if weekIndex == 0 {
|
||||
return list, nil
|
||||
}
|
||||
|
||||
err := dbm_enable(s.Model).
|
||||
Where("week_index", weekIndex).
|
||||
Order("display_order asc,id asc").
|
||||
Scan(&list)
|
||||
return list, err
|
||||
}
|
||||
|
||||
func (s *PeakTianxuanService) GetCurrentWeekList() ([]model.PeakTianxuan, uint32, error) {
|
||||
weekIndex, err := s.LatestWeekIndex()
|
||||
if err != nil || weekIndex == 0 {
|
||||
return nil, weekIndex, err
|
||||
}
|
||||
|
||||
list, err := s.GetWeekList(weekIndex)
|
||||
return list, weekIndex, err
|
||||
}
|
||||
|
||||
func (s *PeakTianxuanService) NormalizeVotePetIDs(petIDs []uint32) ([]uint32, error) {
|
||||
candidateList, _, _, err := s.BuildVoteCandidatePoolPayload()
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
allowed := make(map[uint32]struct{}, len(candidateList))
|
||||
for _, item := range candidateList {
|
||||
allowed[gconv.Uint32(item["pet_id"])] = struct{}{}
|
||||
}
|
||||
|
||||
ret := make([]uint32, 0, len(petIDs))
|
||||
for _, petID := range petIDs {
|
||||
if petID == 0 {
|
||||
continue
|
||||
}
|
||||
if _, ok := allowed[petID]; !ok {
|
||||
continue
|
||||
}
|
||||
if slices.Contains(ret, petID) {
|
||||
continue
|
||||
}
|
||||
ret = append(ret, petID)
|
||||
}
|
||||
|
||||
return ret, nil
|
||||
}
|
||||
|
||||
func (s *PeakTianxuanService) SaveVote(playerID uint32, petID uint32) (uint32, error) {
|
||||
normalize, err := s.NormalizeVotePetIDs([]uint32{petID})
|
||||
if err != nil {
|
||||
return 0, err
|
||||
}
|
||||
if len(normalize) == 0 {
|
||||
return 0, gerror.New("投票精灵不在候选池中")
|
||||
}
|
||||
|
||||
currentWeekIndex, err := s.LatestWeekIndex()
|
||||
if err != nil {
|
||||
return 0, err
|
||||
}
|
||||
if currentWeekIndex == 0 {
|
||||
currentWeekIndex = 1
|
||||
}
|
||||
|
||||
voteModel := model.NewPeakTianxuanVote()
|
||||
data := model.PeakTianxuanVote{
|
||||
WeekIndex: currentWeekIndex,
|
||||
PlayerID: playerID,
|
||||
PetID: normalize[0],
|
||||
}
|
||||
|
||||
var count int
|
||||
count, err = cool.DBM(voteModel).
|
||||
Where("week_index", currentWeekIndex).
|
||||
Where("player_id", playerID).
|
||||
Count()
|
||||
if err != nil {
|
||||
return 0, err
|
||||
}
|
||||
if count > 0 {
|
||||
_, err = cool.DBM(voteModel).
|
||||
Where("week_index", currentWeekIndex).
|
||||
Where("player_id", playerID).
|
||||
Data(data).
|
||||
Update()
|
||||
} else {
|
||||
_, err = cool.DBM(voteModel).Data(data).Insert()
|
||||
}
|
||||
if err != nil {
|
||||
return 0, err
|
||||
}
|
||||
|
||||
return normalize[0], nil
|
||||
}
|
||||
|
||||
func (s *PeakTianxuanService) BuildCurrentTianxuanPayload() ([]g.Map, uint32, error) {
|
||||
list, weekIndex, err := s.GetCurrentWeekList()
|
||||
if err != nil {
|
||||
return nil, 0, err
|
||||
}
|
||||
|
||||
ret := make([]g.Map, 0, len(list))
|
||||
for _, item := range list {
|
||||
name := item.PresetName
|
||||
if name == "" {
|
||||
if pet, ok := xmlres.PetMAP[int(item.PetID)]; ok {
|
||||
name = pet.DefName
|
||||
}
|
||||
}
|
||||
ret = append(ret, g.Map{
|
||||
"id": item.ID,
|
||||
"week_index": item.WeekIndex,
|
||||
"display_order": item.DisplayOrder,
|
||||
"pet_id": item.PetID,
|
||||
"petId": item.PetID,
|
||||
"name": name,
|
||||
"preset_name": item.PresetName,
|
||||
"level": item.Level,
|
||||
"nature": item.Nature,
|
||||
"hp": item.Hp,
|
||||
"max_hp": item.MaxHp,
|
||||
"attack": item.Attack,
|
||||
"defence": item.Defence,
|
||||
"sp_attack": item.SpAttack,
|
||||
"sp_defence": item.SpDefence,
|
||||
"speed": item.Speed,
|
||||
"skin_id": item.SkinID,
|
||||
"effect_ids": item.EffectIDs,
|
||||
"skill_ids": item.SkillIDs,
|
||||
"vote_count": item.VoteCount,
|
||||
"is_enable": item.IsEnable,
|
||||
"remark": item.Remark,
|
||||
})
|
||||
}
|
||||
|
||||
return ret, weekIndex, nil
|
||||
}
|
||||
|
||||
func (s *PeakTianxuanService) BuildVoteCandidatePoolPayload() ([]g.Map, uint32, uint32, error) {
|
||||
currentWeekIndex, err := s.LatestWeekIndex()
|
||||
if err != nil {
|
||||
return nil, 0, 0, err
|
||||
}
|
||||
|
||||
prevWeekIndex := uint32(0)
|
||||
if currentWeekIndex > 1 {
|
||||
prevWeekIndex = currentWeekIndex - 1
|
||||
}
|
||||
|
||||
prevWeekPetIDs, err := s.ListWeekPetIDs(prevWeekIndex)
|
||||
if err != nil {
|
||||
return nil, 0, 0, err
|
||||
}
|
||||
|
||||
currentWeekVoteMap := make(map[uint32]uint32)
|
||||
if currentWeekIndex > 0 {
|
||||
var voteRows []struct {
|
||||
PetID uint32 `json:"pet_id"`
|
||||
VoteCount uint32 `json:"vote_count"`
|
||||
}
|
||||
if err = cool.DBM(model.NewPeakTianxuanVote()).
|
||||
Fields("pet_id, COUNT(1) AS vote_count").
|
||||
Where("week_index", currentWeekIndex).
|
||||
Group("pet_id").
|
||||
Scan(&voteRows); err != nil {
|
||||
return nil, 0, 0, err
|
||||
}
|
||||
for _, item := range voteRows {
|
||||
currentWeekVoteMap[item.PetID] = item.VoteCount
|
||||
}
|
||||
}
|
||||
|
||||
var meleeList []model.PetBaseConfig
|
||||
if err = cool.DBM(model.NewMeettConfig()).Order("mon_id asc").Scan(&meleeList); err != nil {
|
||||
return nil, 0, 0, err
|
||||
}
|
||||
|
||||
type candidate struct {
|
||||
PetID uint32
|
||||
Level uint32
|
||||
}
|
||||
|
||||
unique := make(map[uint32]candidate)
|
||||
for _, item := range meleeList {
|
||||
petID := gconv.Uint32(item.MonID)
|
||||
if petID == 0 {
|
||||
continue
|
||||
}
|
||||
if _, ok := prevWeekPetIDs[petID]; ok {
|
||||
continue
|
||||
}
|
||||
if _, ok := unique[petID]; ok {
|
||||
continue
|
||||
}
|
||||
unique[petID] = candidate{
|
||||
PetID: petID,
|
||||
Level: gconv.Uint32(item.Lv),
|
||||
}
|
||||
}
|
||||
|
||||
keys := make([]int, 0, len(unique))
|
||||
for petID := range unique {
|
||||
keys = append(keys, int(petID))
|
||||
}
|
||||
sort.Ints(keys)
|
||||
|
||||
ret := make([]g.Map, 0, len(keys))
|
||||
for _, key := range keys {
|
||||
item := unique[uint32(key)]
|
||||
name := ""
|
||||
if pet, ok := xmlres.PetMAP[int(item.PetID)]; ok {
|
||||
name = pet.DefName
|
||||
}
|
||||
ret = append(ret, g.Map{
|
||||
"pet_id": item.PetID,
|
||||
"petId": item.PetID,
|
||||
"name": name,
|
||||
"level": item.Level,
|
||||
"vote_count": currentWeekVoteMap[item.PetID],
|
||||
"source": "melee_pool",
|
||||
"excluded_week": prevWeekIndex,
|
||||
})
|
||||
}
|
||||
|
||||
return ret, currentWeekIndex, prevWeekIndex, nil
|
||||
}
|
||||
|
||||
func (s *PeakTianxuanService) CurrentTianxuanPetIDs() ([]uint32, error) {
|
||||
list, _, err := s.GetCurrentWeekList()
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
ret := make([]uint32, 0, len(list))
|
||||
for _, item := range list {
|
||||
if item.PetID == 0 {
|
||||
continue
|
||||
}
|
||||
ret = append(ret, item.PetID)
|
||||
}
|
||||
return ret, nil
|
||||
}
|
||||
|
||||
func (s *PeakTianxuanService) BuildWeekTianxuanPayload(weekIndex uint32) ([]g.Map, error) {
|
||||
list, err := s.GetWeekList(weekIndex)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
ret := make([]g.Map, 0, len(list))
|
||||
for _, item := range list {
|
||||
name := item.PresetName
|
||||
if name == "" {
|
||||
if pet, ok := xmlres.PetMAP[int(item.PetID)]; ok {
|
||||
name = pet.DefName
|
||||
}
|
||||
}
|
||||
ret = append(ret, g.Map{
|
||||
"id": item.ID,
|
||||
"week_index": item.WeekIndex,
|
||||
"display_order": item.DisplayOrder,
|
||||
"pet_id": item.PetID,
|
||||
"petId": item.PetID,
|
||||
"name": name,
|
||||
"preset_name": item.PresetName,
|
||||
"level": item.Level,
|
||||
"nature": item.Nature,
|
||||
"hp": item.Hp,
|
||||
"max_hp": item.MaxHp,
|
||||
"attack": item.Attack,
|
||||
"defence": item.Defence,
|
||||
"sp_attack": item.SpAttack,
|
||||
"sp_defence": item.SpDefence,
|
||||
"speed": item.Speed,
|
||||
"skin_id": item.SkinID,
|
||||
"effect_ids": item.EffectIDs,
|
||||
"skill_ids": item.SkillIDs,
|
||||
"vote_count": item.VoteCount,
|
||||
"is_enable": item.IsEnable,
|
||||
"remark": item.Remark,
|
||||
})
|
||||
}
|
||||
|
||||
return ret, nil
|
||||
}
|
||||
@@ -26,17 +26,6 @@ func NewTaskService() *TaskService {
|
||||
func (s *TaskService) Get(id, os int) *model.TaskConfig {
|
||||
var res *model.TaskConfig
|
||||
dbm_enable(s.Model).Where("task_id", id).Where("out_state", os).Scan(&res)
|
||||
if res == nil {
|
||||
dbm_notenable(s.Model).Where("task_id", id).Where("out_state", os).Scan(&res)
|
||||
}
|
||||
// var res *model.TaskConfig
|
||||
// for _, v := range item {
|
||||
// if v.OutState == os {
|
||||
// res = &v
|
||||
|
||||
// }
|
||||
|
||||
// }
|
||||
|
||||
return res
|
||||
|
||||
|
||||
Reference in New Issue
Block a user