This commit is contained in:
yangduo 2024-10-17 15:36:44 +08:00
parent 3b1bbffc6c
commit 1216a7d741

View File

@ -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)})