Commit 310bafc3 authored by linj's avatar linj

原有的查询接口查询新的数据

parent e15d4414
...@@ -81,7 +81,7 @@ func (t *trade) GetOnesOrderWithStatus(req *pty.ReqAddrAssets) (types.Message, e ...@@ -81,7 +81,7 @@ func (t *trade) GetOnesOrderWithStatus(req *pty.ReqAddrAssets) (types.Message, e
if len(req.FromKey) > 0 { if len(req.FromKey) > 0 {
order.TxIndex = req.FromKey order.TxIndex = req.FromKey
} }
rows, err := list(t.GetLocalDB(), "owner_isFinished", &order, req.Count, req.Direction) rows, err := listV2(t.GetLocalDB(), "owner_isFinished", &order, req.Count, req.Direction)
if err != nil { if err != nil {
tradelog.Error("GetOnesOrderWithStatus", "err", err) tradelog.Error("GetOnesOrderWithStatus", "err", err)
return nil, err return nil, err
...@@ -131,7 +131,7 @@ func fmtReply(cfg *types.Chain33Config, order *pty.LocalOrder) *pty.ReplyTradeOr ...@@ -131,7 +131,7 @@ func fmtReply(cfg *types.Chain33Config, order *pty.LocalOrder) *pty.ReplyTradeOr
} }
func (t *trade) GetOneOrder(req *pty.ReqAddrAssets) (types.Message, error) { func (t *trade) GetOneOrder(req *pty.ReqAddrAssets) (types.Message, error) {
query := NewOrderTable(t.GetLocalDB()) query := NewOrderTableV2(t.GetLocalDB())
tradelog.Debug("query GetData dbg", "primary", req.FromKey) tradelog.Debug("query GetData dbg", "primary", req.FromKey)
row, err := query.GetData([]byte(req.FromKey)) row, err := query.GetData([]byte(req.FromKey))
if err != nil { if err != 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