Commit 91569280 authored by vipwzw's avatar vipwzw

auto ci

parent ad86eb98
...@@ -63,17 +63,17 @@ func (g *Guess) execDelLocal(receipt *types.ReceiptData) (*types.LocalDBSet, err ...@@ -63,17 +63,17 @@ func (g *Guess) execDelLocal(receipt *types.ReceiptData) (*types.LocalDBSet, err
} }
/* /*
for _, log := range receiptData.Logs { for _, log := range receiptData.Logs {
switch log.GetTy() { switch log.GetTy() {
case gty.TyLogGuessGameStart, gty.TyLogGuessGameBet, gty.TyLogGuessGameStopBet, gty.TyLogGuessGameAbort, gty.TyLogGuessGamePublish, gty.TyLogGuessGameTimeout: case gty.TyLogGuessGameStart, gty.TyLogGuessGameBet, gty.TyLogGuessGameStopBet, gty.TyLogGuessGameAbort, gty.TyLogGuessGamePublish, gty.TyLogGuessGameTimeout:
receiptGame := &gty.ReceiptGuessGame{} receiptGame := &gty.ReceiptGuessGame{}
if err := types.Decode(log.Log, receiptGame); err != nil { if err := types.Decode(log.Log, receiptGame); err != nil {
return nil, err return nil, err
}
kv := g.rollbackIndex(receiptGame)
dbSet.KV = append(dbSet.KV, kv...)
} }
kv := g.rollbackIndex(receiptGame) }*/
dbSet.KV = append(dbSet.KV, kv...)
}
}*/
table := gty.NewTable(g.GetLocalDB()) table := gty.NewTable(g.GetLocalDB())
for _, item := range receipt.Logs { for _, item := range receipt.Logs {
var gameLog gty.ReceiptGuessGame var gameLog gty.ReceiptGuessGame
...@@ -94,7 +94,6 @@ func (g *Guess) execDelLocal(receipt *types.ReceiptData) (*types.LocalDBSet, err ...@@ -94,7 +94,6 @@ func (g *Guess) execDelLocal(receipt *types.ReceiptData) (*types.LocalDBSet, err
dbSet.KV = append(dbSet.KV, kvs...) dbSet.KV = append(dbSet.KV, kvs...)
} }
return dbSet, nil return dbSet, nil
} }
......
...@@ -62,18 +62,18 @@ func (g *Guess) execLocal(receipt *types.ReceiptData) (*types.LocalDBSet, error) ...@@ -62,18 +62,18 @@ func (g *Guess) execLocal(receipt *types.ReceiptData) (*types.LocalDBSet, error)
} }
/* /*
for i := 0; i < len(receipt.Logs); i++ { for i := 0; i < len(receipt.Logs); i++ {
item := receipt.Logs[i] item := receipt.Logs[i]
if item.Ty >= gty.TyLogGuessGameStart && item.Ty <= gty.TyLogGuessGameTimeout { if item.Ty >= gty.TyLogGuessGameStart && item.Ty <= gty.TyLogGuessGameTimeout {
var Gamelog gty.ReceiptGuessGame var Gamelog gty.ReceiptGuessGame
err := types.Decode(item.Log, &Gamelog) err := types.Decode(item.Log, &Gamelog)
if err != nil { if err != nil {
panic(err) //数据错误了,已经被修改了 panic(err) //数据错误了,已经被修改了
}
kv := g.updateIndex(&Gamelog)
dbSet.KV = append(dbSet.KV, kv...)
} }
kv := g.updateIndex(&Gamelog)
dbSet.KV = append(dbSet.KV, kv...)
} }
}
*/ */
table := gty.NewTable(g.GetLocalDB()) table := gty.NewTable(g.GetLocalDB())
......
...@@ -68,7 +68,7 @@ func (tx *GuessRow) Get(key string) ([]byte, error) { ...@@ -68,7 +68,7 @@ func (tx *GuessRow) Get(key string) ([]byte, error) {
return []byte(fmt.Sprintf("%s:%2d", tx.Addr, tx.Status)), nil return []byte(fmt.Sprintf("%s:%2d", tx.Addr, tx.Status)), nil
} else if key == "admin" { } else if key == "admin" {
return []byte(tx.AdminAddr), nil return []byte(tx.AdminAddr), nil
}else if key == "admin_status" { } else if key == "admin_status" {
return []byte(fmt.Sprintf("%s:%2d", tx.AdminAddr, tx.Status)), nil return []byte(fmt.Sprintf("%s:%2d", tx.AdminAddr, tx.Status)), nil
} else if key == "category_status" { } else if key == "category_status" {
return []byte(fmt.Sprintf("%s:%2d", tx.Category, tx.Status)), nil return []byte(fmt.Sprintf("%s:%2d", tx.Category, tx.Status)), nil
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment