From 1216a7d7412ea59ba07cd313c802f5524f1a1a70 Mon Sep 17 00:00:00 2001 From: yangduo Date: Thu, 17 Oct 2024 15:36:44 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- server/light_backtask/service/vip.go | 53 ++++++++++------------------ 1 file changed, 18 insertions(+), 35 deletions(-) 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)})