diff --git a/server/light_backtask/task/stacking_go.go b/server/light_backtask/task/stacking_go.go index 980e6542..b967aff0 100644 --- a/server/light_backtask/task/stacking_go.go +++ b/server/light_backtask/task/stacking_go.go @@ -151,17 +151,17 @@ func (this *stackingCec) apply(idx int64, eventName string, if dbErr != nil { return false } + srcAmount := "0" if ds.Next() { if idx <= q5.ToInt64(ds.GetByName("last_apply_record_idx")) { return true } - bnNewAmount, ok := new(big.Int).SetString(ds.GetByName("amount"), 10) - if !ok { - return false - } - bnNewAmount.Add(bnNewAmount, bnAmount) - } else { - + srcAmount = ds.GetByName("amount") } + bnNewAmount, ok := new(big.Int).SetString(srcAmount, 10) + if !ok { + return false + } + bnNewAmount.Add(bnNewAmount, bnAmount) return true }