-

Author: greensheng

models/mysql/bill_store.go

@@ -44,8 +44,8 @@ func (s *Store) AddBills(bills []*models.Bill) error {
 }
 var valueStrings []string
 for _, bill := range bills {
-valueString := fmt.Sprintf("('%v',%v, '%v', %v, %v, '%v', %v, '%v')",
-time.Now(), bill.UserId, bill.Currency, bill.Available, bill.Hold, bill.Type, bill.Settled, bill.Notes)
+valueString := fmt.Sprintf("(NOW(),%v, '%v', %v, %v, '%v', %v, '%v')",
+bill.UserId, bill.Currency, bill.Available, bill.Hold, bill.Type, bill.Settled, bill.Notes)
 valueStrings = append(valueStrings, valueString)
 }
 sql := fmt.Sprintf("INSERT INTO g_bill (created_at, user_id,currency,available,hold, type,settled,notes) VALUES %s", strings.Join(valueStrings, ","))

models/mysql/fill_store.go

@@ -19,7 +19,6 @@ import (
 "github.com/gitbitex/gitbitex-spot/models"
 "github.com/jinzhu/gorm"
 "strings"
-"time"
 )
 
 func (s *Store) GetLastFillByProductId(productId string) (*models.Fill, error) {
@@ -58,8 +57,8 @@ func (s *Store) AddFills(fills []*models.Fill) error {
 }
 var valueStrings []string
 for _, fill := range fills {
-valueString := fmt.Sprintf("('%v', '%v', %v, %v, %v, %v,%v, %v,'%v',%v,%v,'%v',%v,'%v',%v,%v)",
-time.Now(), fill.ProductId, fill.TradeId, fill.OrderId, fill.MessageSeq, fill.Size, fill.Price, fill.Funds,
+valueString := fmt.Sprintf("(NOW(), '%v', %v, %v, %v, %v,%v, %v,'%v',%v,%v,'%v',%v,'%v',%v,%v)",
+fill.ProductId, fill.TradeId, fill.OrderId, fill.MessageSeq, fill.Size, fill.Price, fill.Funds,
 fill.Liquidity, fill.Fee, fill.Settled, fill.Side, fill.Done, fill.DoneReason, fill.LogOffset, fill.LogSeq)
 valueStrings = append(valueStrings, valueString)
 }

models/mysql/tick_store.go

@@ -19,7 +19,6 @@ import (
 "github.com/gitbitex/gitbitex-spot/models"
 "github.com/jinzhu/gorm"
 "strings"
-"time"
 )
 
 func (s *Store) GetTicksByProductId(productId string, granularity int64, limit int) ([]*models.Tick, error) {
@@ -46,8 +45,8 @@ func (s *Store) AddTicks(ticks []*models.Tick) error {
 }
 var valueStrings []string
 for _, tick := range ticks {
-valueString := fmt.Sprintf("('%v','%v', %v, %v, %v, %v, %v, %v, %v,%v,%v)",
-time.Now(), tick.ProductId, tick.Granularity, tick.Time, tick.Open, tick.Low, tick.High, tick.Close,
+valueString := fmt.Sprintf("(NOW(),'%v', %v, %v, %v, %v, %v, %v, %v,%v,%v)",
+tick.ProductId, tick.Granularity, tick.Time, tick.Open, tick.Low, tick.High, tick.Close,
 tick.Volume, tick.LogOffset, tick.LogSeq)
 valueStrings = append(valueStrings, valueString)
 }