update saveSell

plugin/dapp/trade/executor/exec_local.go

@@ -35,6 +35,7 @@ func (t *trade) ExecLocal_RevokeBuy(revoke *pty.TradeForRevokeBuy, tx *types.Tra
 
 func (t *trade) localAddLog(tx *types.Transaction, receipt *types.ReceiptData, index int) (*types.LocalDBSet, error) {
 	var set types.LocalDBSet
+	//table := NewOrderTable(t.GetLocalDB())
 
 	for i := 0; i < len(receipt.Logs); i++ {
 		item := receipt.Logs[i]
@@ -44,17 +45,16 @@ func (t *trade) localAddLog(tx *types.Transaction, receipt *types.ReceiptData, i
 			if err != nil {
 				panic(err) //数据错误了，已经被修改了
 			}
-			kv := t.saveSell([]byte(receipt.Base.SellID), item.Ty)
+			kv := t.saveSell(receipt.Base, item.Ty)
 			set.KV = append(set.KV, kv...)
 		} else if item.Ty == pty.TyLogTradeSellRevoke {
 			var receipt pty.ReceiptTradeSellRevoke
 			err := types.Decode(item.Log, &receipt)
 			if err != nil {
-			panic(err) //数据错误了，已经被修改了
+				panic(err) //数据错误了，已经被修改了
 			}
-			kv := t.saveSell([]byte(receipt.Base.SellID), item.Ty)
+			kv := t.saveSell(receipt.Base, item.Ty)
 			set.KV = append(set.KV, kv...)
-
 		} else if item.Ty == pty.TyLogTradeBuyMarket {
 			var receipt pty.ReceiptTradeBuyMarket
 			err := types.Decode(item.Log, &receipt)

plugin/dapp/trade/executor/trade.go

@@ -22,6 +22,7 @@ import (
 	drivers "github.com/33cn/chain33/system/dapp"
 	"github.com/33cn/chain33/types"
 	pty "github.com/33cn/plugin/plugin/dapp/trade/types"
+	"github.com/33cn/chain33/common/db/table"
 )
 
 var (
@@ -81,8 +82,14 @@ func genSaveSellKv(sellorder *pty.SellOrder) []*types.KeyValue {
 	return kv
 }
 
-func (t *trade) saveSell(sellID []byte, ty int32) []*types.KeyValue {
-	sellorder := t.getSellOrderFromDb(sellID)
+func (t *trade) saveSell(base *pty.ReceiptSellBase, ty int32) []*types.KeyValue {
+	sellorder := t.getSellOrderFromDb([]byte(base.SellID))
+	//t.genSell(tx, nil, sellorder)
+	//if ty == pty.TyLogTradeSellLimit && sellorder.SoldBoardlot == 0 {
+	//	ldb.Add()
+	//} else {
+	//	ldb.Update()
+	//}
 	return genSaveSellKv(sellorder)
 }