更新

consume/canal_user_virtual_coin_flow_consume.go

@@ -88,7 +88,7 @@ func handleCanalOneOrengeUserVirtualCoinFlow(msg []byte) error {
 			return errors.New("失败")
 		}
 		amountUser.Amount = utils.Float64ToStrByPrec(utils.StrToFloat64(canalMsg.Data[0].Amout)+utils.StrToFloat64(amountUser.Amount), 8)
-		update, err = sess.Where("id=?", amountDate.Id).Cols("amount").Update(amountUser)
+		update, err = sess.Where("id=?", amountUser.Id).Cols("amount").Update(amountUser)
 		if update == 0 || err != nil {
 			sess.Rollback()
 			return errors.New("失败")