Commit 9e94bc15 authored by linj's avatar linj

fix local db

parent 8674bcad
...@@ -97,6 +97,9 @@ func (t *trade) localDelLog(tx *types.Transaction, receipt *types.ReceiptData, i ...@@ -97,6 +97,9 @@ func (t *trade) localDelLog(tx *types.Transaction, receipt *types.ReceiptData, i
return nil, err return nil, err
} }
set.KV = append(set.KV, newKvs...) set.KV = append(set.KV, newKvs...)
for _, kv := range set.KV {
t.GetLocalDB().Set(kv.Key, kv.Value)
}
return &set, nil return &set, nil
} }
...@@ -99,6 +99,10 @@ func (t *trade) localAddLog(tx *types.Transaction, receipt *types.ReceiptData, i ...@@ -99,6 +99,10 @@ func (t *trade) localAddLog(tx *types.Transaction, receipt *types.ReceiptData, i
tradelog.Error("trade table.Save failed", "error", err) tradelog.Error("trade table.Save failed", "error", err)
return nil, err return nil, err
} }
set.KV = append(set.KV, newKvs...) set.KV = append(set.KV, newKvs...)
for _, kv := range set.KV {
t.GetLocalDB().Set(kv.Key, kv.Value)
}
return &set, nil return &set, 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