diff --git a/server/light_backtask/service/vip.go b/server/light_backtask/service/vip.go index 398c6c8e..f71da68e 100644 --- a/server/light_backtask/service/vip.go +++ b/server/light_backtask/service/vip.go @@ -69,21 +69,12 @@ func (this *vip) Add(accountAddress string, val string, idx int64, valField stri } bnNewVal := bnOldVal.Add(bnOldVal, bnVal) updateKv = append(updateKv, [][]string{{valField, bnNewVal.String()}}...) - lvParams[valField] = bnNewVal.String() - - if valField != "escec_balance" { - lvParams["escec_balance"] = ds.GetByName("escec_balance") - } - - if valField != "escec_stacking" { - lvParams["escec_stacking"] = ds.GetByName("escec_stacking") - } - - if valField != "escec_convert" { - lvParams["escec_convert"] = ds.GetByName("escec_convert") - } - + + lvParams["escec_balance"] = ds.GetByName("escec_balance") + lvParams["escec_stacking"] = ds.GetByName("escec_stacking") + lvParams["escec_convert"] = ds.GetByName("escec_convert") lvParams["last_convert_time"] = ds.GetByName("last_convert_time") + lvParams[valField] = bnNewVal.String() newlv := this.calcVipLv(lvParams) updateKv = append(updateKv, []string{"vip_lv", q5.SafeToString(newlv)}) @@ -129,13 +120,14 @@ func (this *vip) Replace(accountAddress string, val string, idx int64, valField if err != nil { return false } - lvParams := map[string]string{ - valField: val, - } + lvParams := map[string]string{} - for _, sli := range extKv { - if len(sli) > 1 { - lvParams[sli[0]] = sli[1] + replaceFields:= func() { + lvParams[valField] = val + for _, sli := range extKv { + if len(sli) > 1 { + lvParams[sli[0]] = sli[1] + } } } @@ -159,21 +151,11 @@ func (this *vip) Replace(accountAddress string, val string, idx int64, valField return true } - if _, exist := lvParams["escec_balance"]; !exist { - lvParams["escec_balance"] = ds.GetByName("escec_balance") - } - - if _, exist := lvParams["escec_stacking"]; !exist { - lvParams["escec_stacking"] = ds.GetByName("escec_stacking") - } - - if _, exist := lvParams["escec_convert"]; !exist { - lvParams["escec_convert"] = ds.GetByName("escec_convert") - } - - if _, exist := lvParams["last_convert_time"]; !exist { - lvParams["last_convert_time"] = ds.GetByName("last_convert_time") - } + lvParams["escec_balance"] = ds.GetByName("escec_balance") + lvParams["escec_stacking"] = ds.GetByName("escec_stacking") + lvParams["escec_convert"] = ds.GetByName("escec_convert") + lvParams["last_convert_time"] = ds.GetByName("last_convert_time") + replaceFields() newlv := this.calcVipLv(lvParams) updateKv = append(updateKv, []string{"vip_lv", q5.SafeToString(newlv)}) @@ -189,6 +171,7 @@ func (this *vip) Replace(accountAddress string, val string, idx int64, valField return false } } else { + replaceFields() newlv := this.calcVipLv(lvParams) insertKv = append(insertKv, []string{"vip_lv", q5.SafeToString(newlv)})