Files
bl/logic/service/fight/input/input.go

310 lines
8.0 KiB
Go
Raw Normal View History

package input
import (
2025-09-30 18:32:15 +08:00
"blazing/common/data/xmlres"
"blazing/cool"
"blazing/modules/player/model"
"fmt"
2025-11-11 05:54:24 +00:00
"blazing/logic/service/common"
2025-09-30 18:32:15 +08:00
"blazing/logic/service/fight/action"
"blazing/logic/service/fight/info"
"github.com/alpacahq/alpacadecimal"
"github.com/jinzhu/copier"
)
type Input struct {
CanChange uint32 //是否可以死亡切换CanChange
// CanAction bool //是否可以行动
2026-04-04 04:34:43 +08:00
CurPet []*info.BattlePetEntity //当前上场精灵
AllPet []*info.BattlePetEntity
Player common.PlayerI
2025-11-11 05:54:24 +00:00
Opp *Input
CanCapture int
2025-11-11 05:54:24 +00:00
Finished bool //是否加载完成
*model.AttackValue
FightC common.FightI
// info.BattleActionI
Effects []Effect //effects 实际上全局就是effect无限回合 //effects容器 技能的
EffectCache []Effect //这里是命中前执行的容器,也就是命中前执行的所有逻辑相关,理论上一个effect被激活,就应该同时将其他的effect取消激活
EffectLost []Effect
2025-11-21 05:47:51 +00:00
// 删掉伤害记录,可以在回调中记录,而不是每次调用记录
SumDamage alpacadecimal.Decimal //伤害
2026-03-29 16:38:34 +08:00
// 记录上一回合结束时的能力等级供效果727等回溯使用。
LastTurnEndProp [6]int8
2025-11-21 05:47:51 +00:00
// DamageZone struct {
// Damage decimal.Decimal //伤害
// BeforeADD decimal.Decimal //攻击伤害
// BeforeMul decimal.Decimal
// BeforeFloor decimal.Decimal
// BeforeDiv decimal.Decimal
// BeforeSUB decimal.Decimal
// BeforeLock decimal.Decimal //锁伤 先锁受击方,再锁攻击方 受击方免疫也是这么锁 免疫等于锁0
// BeforeLocked decimal.Decimal
// //BeforePost decimal.Decimal
// //OldAttack int //攻击伤害被挡前伤害记录
// } //伤害容器
2025-09-30 18:32:15 +08:00
//First bool //是否先手
}
func NewInput(c common.FightI, p common.PlayerI) *Input {
ret := &Input{FightC: c, Player: p}
ret.Effects = make([]Effect, 0)
2026-04-04 04:34:43 +08:00
ret.CurPet = make([]*info.BattlePetEntity, 0)
// t := Geteffect(EffectType.Damage, 0)
// t.Effect.SetArgs(ret)
// ret.AddEffect(t) //添加默认基类,实现继承
p.SetFightC(c) //给玩家设置战斗容器
return ret
}
2026-04-04 04:34:43 +08:00
func (our *Input) CurPetAt(index int) *info.BattlePetEntity {
if our == nil || index < 0 || index >= len(our.CurPet) {
2026-04-04 04:28:04 +08:00
return nil
}
2026-04-04 04:34:43 +08:00
return our.CurPet[index]
2026-04-04 04:28:04 +08:00
}
2026-04-04 04:34:43 +08:00
func (our *Input) PrimaryCurPet() *info.BattlePetEntity {
return our.CurPetAt(0)
2026-04-04 04:28:04 +08:00
}
2026-04-04 04:34:43 +08:00
func (our *Input) SetCurPetAt(index int, pet *info.BattlePetEntity) {
2026-04-04 04:28:04 +08:00
if our == nil || index < 0 {
return
}
2026-04-04 04:34:43 +08:00
for len(our.CurPet) <= index {
our.CurPet = append(our.CurPet, nil)
2026-04-04 04:28:04 +08:00
}
2026-04-04 04:34:43 +08:00
our.CurPet[index] = pet
2026-04-04 04:28:04 +08:00
}
// 非原地交换收集非0血量精灵 + 0血量精灵拼接后返回
func (our *Input) SortPet() {
var nonZeroHP []*info.BattlePetEntity // 收集血量>0的精灵保持原顺序
var zeroHP []*info.BattlePetEntity // 收集血量=0的精灵保持原顺序
// 线性遍历一次,分类收集
for _, s := range our.AllPet {
if s.Info.Hp > 0 {
for _, e1 := range s.Info.EffectInfo {
t := our.InitEffect(EffectType.NewSel, int(e1.EID), e1.Args...)
if t != nil {
ef := t.ID()
if cool.Config.ServerInfo.IsDebug != 0 {
fmt.Println("初始化特性", ef.Suffix())
}
ef.SetCatchTime(s.Info.CatchTime)
t.ID(ef)
t.Duration(-1)
our.AddEffect(our, t)
}
}
nonZeroHP = append(nonZeroHP, s)
} else {
zeroHP = append(zeroHP, s)
}
}
// 拼接非0血量精灵在前0血量精灵在后
our.AllPet = append(nonZeroHP, zeroHP...)
}
2025-11-11 05:54:24 +00:00
func (our *Input) GetPetInfo() *info.BattlePetEntity {
2026-04-04 04:34:43 +08:00
return our.PrimaryCurPet()
2025-11-11 05:54:24 +00:00
}
func (our *Input) SetOPP(t *Input) {
2025-11-11 05:54:24 +00:00
our.Opp = t
2025-11-10 08:25:40 +00:00
}
func (our *Input) RecoverEffect() {
//println("恢复效果",our.UserID)
//根本没释放技能,这些效果全部失效
for _, e := range our.EffectCache {
e.Alive(false)
}
//这时候将被覆盖的效果全部装回来enterturn
for _, e := range our.EffectLost {
if e.Duration() > 0 || e.Duration() == -1 {
// e.Alive(true)
our.AddEffect(e.GetInput(), e)
}
}
}
func (our *Input) ReactvieEffect() {
//根本没释放技能,这些效果全部失效
for _, e := range our.EffectLost {
e.Alive(false)
// our.AddEffect(e.GetInput(), e)
}
//这时候将被覆盖的效果全部装回来enterturn
for _, e := range our.EffectCache {
// e.Alive(true)
//因为后手方实际上是到了他出手阶段重新添加的结果,而非后手方重新激活效果
our.AddEffect(e.GetInput(), e)
}
}
2025-11-11 05:54:24 +00:00
func (our *Input) GenSataus() {
``` refactor(socket): 移除未使用的网络相关导入和注释掉的 RST 攻击检测逻辑 移除了 `ServerEvent.go` 中未使用的 `net` 和 `strings` 包导入。同时, 将原有的 RST 攻击检测及防护逻辑代码注释掉,便于后续重新设计或彻底删除。 fix(logic): 调整 fight pool 初始化与释放策略 将 `fight/action.go` 中的 `Fightpool` 类型从 `*ants.MultiPool` 改为 `*ants.Pool`,并调整其初始化方式为 `NewPool(-1)` 以适应动态扩容。 此外,在 `main.go` 中将 `ReleaseTimeout` 参数由 100 调整为 0, 确保立即清理超时任务。 feat(fight): 优化战斗输入状态重置逻辑 在 `fight/action.go` 的 `ReadyFight` 方法中提前设置 `GetInputByPlayer(c, false).Finished = true`,避免重复赋值。 同时更新了状态睡眠效果的处理流程,并简化了输入模块的状态缓存机制, 移除了冗余的 `Initeffectcache` 函数调用及相关逻辑。 perf(fight): 动态计算玩家动作等待时间 在 `loop.go` 的 `collectPlayerActions` 方法中, 将固定超时时间替换为基于 `waittime` 的动态等待时间计算公式, 提高响应灵活性。同时修复通道关闭判断条件以增强稳定性。 refactor(fight): 更新技能效果解析和状态持续逻辑 修改 `input.go` 中 `GenSataus` 方法以正确初始化状态数组; 在 `Turn.go` 中重构 `Turn_End` 方法内的执行逻辑, 确保仅在我方后手时增加回合数,提升战斗流程准确性。 chore(service): 删除废弃文件 SocketHandler_Tomee.go 完全移除已弃用的 `SocketHandler_Tomee.go` 文件及其全部内容, 减少项目冗余代码。 ```
2025-11-13 05:05:05 +08:00
our.Status = [20]int8{}
2025-11-10 08:25:40 +00:00
for i := 0; i < 20; i++ { //堆叠状态剩余回合
2025-11-11 05:54:24 +00:00
t := our.GetEffect(EffectType.Status, i)
2025-11-10 08:25:40 +00:00
if t != nil && t.Alive() { //状态都是叠层类的
2025-11-10 08:25:40 +00:00
2025-11-11 05:54:24 +00:00
our.Status[i] = int8(t.Duration())
2025-11-10 08:25:40 +00:00
}
}
}
2025-11-11 05:54:24 +00:00
func (our *Input) GenInfo() {
2026-04-04 04:34:43 +08:00
currentPet := our.PrimaryCurPet()
2026-04-04 04:28:04 +08:00
if currentPet == nil {
return
}
2025-11-10 08:25:40 +00:00
2026-04-04 04:28:04 +08:00
our.RemainHp = int32(currentPet.Info.Hp)
our.SkillList = currentPet.Info.SkillList
2026-04-04 04:34:43 +08:00
// f.Second.SkillList = f.Second.CurPet.Info.SkillList
// f.Second.RemainHp = int32(f.Second.CurPet.Info.Hp)
2025-11-10 08:25:40 +00:00
// ret.FAttack = *f.First.AttackValue
// ret.SAttack = *f.Second.AttackValue
}
2026-03-29 16:38:34 +08:00
func (our *Input) SnapshotTurnProp() {
our.LastTurnEndProp = our.AttackValue.Prop
}
2025-11-11 05:54:24 +00:00
func (our *Input) ResetAttackValue() {
our.AttackValue.SkillID = 0
our.AttackValue.IsCritical = 0
our.AttackValue.GainHp = 0
our.AttackValue.LostHp = 0
2026-01-21 20:46:05 +00:00
our.SumDamage = alpacadecimal.Zero
//our.CanUseSkill = true
}
// 这个每回合都会调用
2025-11-11 05:54:24 +00:00
func (our *Input) InitAttackValue() {
our.AttackValue = info.NewAttackValue(our.Player.GetInfo().UserID)
2026-03-29 16:38:34 +08:00
our.LastTurnEndProp = [6]int8{}
}
2025-11-11 05:54:24 +00:00
func (our *Input) GetPet(id uint32) (ii *info.BattlePetEntity, Reason info.ChangePetInfo) {
for _, v := range our.AllPet {
2026-02-05 23:44:07 +08:00
if v.Info.CatchTime == uint32(id) && v.Info.Hp > 0 {
copier.Copy(&Reason, &v.Info)
2025-11-11 05:54:24 +00:00
Reason.UserId = our.Player.GetInfo().UserID
ii = v
return ii, Reason
}
}
return
}
// GetStatusBonus 获取最高的状态倍率
// 遍历状态数组返回存在的状态中最高的倍率无状态则返回1.0
2025-11-11 05:54:24 +00:00
func (our *Input) GetStatusBonus() float64 {
// 异常状态倍率映射表(状态索引 -> 倍率)
var statusBonuses = map[info.EnumPetStatus]float64{
info.PetStatus.Paralysis: 1.5,
info.PetStatus.Poisoned: 1.5,
info.PetStatus.Sleep: 2.0,
// /info.BattleStatus.Frozen: 2.0,
}
maxBonus := 1.0 // 默认无状态倍率
for statusIdx := 0; statusIdx < 20; statusIdx++ {
t := our.InitEffect(EffectType.Status, statusIdx)
// 检查状态是否存在数组中值为1表示存在该状态
if t != nil && t.Stack() > 0 {
if bonus, exists := statusBonuses[info.EnumPetStatus(statusIdx)]; exists && bonus > maxBonus {
maxBonus = bonus
}
}
}
return maxBonus
}
2025-09-30 18:32:15 +08:00
// 解析并 施加effect
func (our *Input) Parseskill(skill *action.SelectSkillAction) {
if skill == nil {
return
}
if skill.SkillEntity == nil {
return
}
``` refactor(socket): 移除未使用的网络相关导入和注释掉的 RST 攻击检测逻辑 移除了 `ServerEvent.go` 中未使用的 `net` 和 `strings` 包导入。同时, 将原有的 RST 攻击检测及防护逻辑代码注释掉,便于后续重新设计或彻底删除。 fix(logic): 调整 fight pool 初始化与释放策略 将 `fight/action.go` 中的 `Fightpool` 类型从 `*ants.MultiPool` 改为 `*ants.Pool`,并调整其初始化方式为 `NewPool(-1)` 以适应动态扩容。 此外,在 `main.go` 中将 `ReleaseTimeout` 参数由 100 调整为 0, 确保立即清理超时任务。 feat(fight): 优化战斗输入状态重置逻辑 在 `fight/action.go` 的 `ReadyFight` 方法中提前设置 `GetInputByPlayer(c, false).Finished = true`,避免重复赋值。 同时更新了状态睡眠效果的处理流程,并简化了输入模块的状态缓存机制, 移除了冗余的 `Initeffectcache` 函数调用及相关逻辑。 perf(fight): 动态计算玩家动作等待时间 在 `loop.go` 的 `collectPlayerActions` 方法中, 将固定超时时间替换为基于 `waittime` 的动态等待时间计算公式, 提高响应灵活性。同时修复通道关闭判断条件以增强稳定性。 refactor(fight): 更新技能效果解析和状态持续逻辑 修改 `input.go` 中 `GenSataus` 方法以正确初始化状态数组; 在 `Turn.go` 中重构 `Turn_End` 方法内的执行逻辑, 确保仅在我方后手时增加回合数,提升战斗流程准确性。 chore(service): 删除废弃文件 SocketHandler_Tomee.go 完全移除已弃用的 `SocketHandler_Tomee.go` 文件及其全部内容, 减少项目冗余代码。 ```
2025-11-13 05:05:05 +08:00
// our.Initeffectcache() //这里说明是延续的效果,每次复制出来一个新的就好了
//i.NewEffects = make([]Effect, 0) //这里说明是新增的效果
temparg := skill.XML.SideEffectArgS
2025-09-30 18:32:15 +08:00
for _, v := range skill.XML.SideEffectS {
2025-09-30 18:32:15 +08:00
args := xmlres.EffectArgs[v]
t := our.InitEffect(EffectType.Skill, v, temparg[:args]...)
//这里是给双方添加buff
if t != nil {
// t.SetArgs(our, temparg[:args]...) //设置入参,施加方永远是我方
2025-09-30 18:32:15 +08:00
// if t.Owner() { //如果取反,说明是给对方添加的回合效果
// //实际上,owner永远为反,说明是对方给我添加的
// t.SetArgs(i, temparg[:args]...) //设置入参,施加方永远是我方
// //给双方添加
// defender.AddEffect(t)
// } else {
//t.SetArgs(i, temparg[:args]...) //设置入参
loste := our.AddEffect(our, t)
if loste != nil {
our.EffectLost = append(our.EffectLost, loste)
}
// }
//这里是临时缓存buff,后面确认命中后修改HIT状态
// t.Alive() //先让效果保持存活
2025-11-11 05:54:24 +00:00
our.EffectCache = append(our.EffectCache, t)
// i.NewEffects = append(i.NewEffects, t)
} else {
fmt.Println("技能效果不存在", v)
2025-09-30 18:32:15 +08:00
}
temparg = temparg[args:]
}
}