Commit d4c38318 authored by pengjun's avatar pengjun

Merge branch 'master' of https://github.com/jpeng-go/plugin

parents f302a0e2 af0948e2
...@@ -383,7 +383,7 @@ func CollateralizeQueryUserBalance(cmd *cobra.Command, args []string) { ...@@ -383,7 +383,7 @@ func CollateralizeQueryUserBalance(cmd *cobra.Command, args []string) {
params.Execer = pkt.CollateralizeX params.Execer = pkt.CollateralizeX
params.FuncName = "CollateralizeUserBalance" params.FuncName = "CollateralizeUserBalance"
req := &pkt.ReqCollateralizeRecordByAddr{ req := &pkt.ReqCollateralizeRecordByAddr{
Addr: addr, Addr: addr,
} }
params.Payload = types.MustPBToJSON(req) params.Payload = types.MustPBToJSON(req)
......
...@@ -19,10 +19,10 @@ import ( ...@@ -19,10 +19,10 @@ import (
// List control // List control
const ( const (
ListDESC = int32(0) // list降序 ListDESC = int32(0) // list降序
ListASC = int32(1) // list升序 ListASC = int32(1) // list升序
DefaultCount = int32(20) // 默认一次取多少条记录 DefaultCount = int32(20) // 默认一次取多少条记录
MaxCount = int32(100) // 最多取100条 MaxCount = int32(100) // 最多取100条
) )
const ( const (
...@@ -1338,8 +1338,8 @@ func queryCollateralizeUserBalanceStatus(db dbm.KV, localdb dbm.KVDB, addr strin ...@@ -1338,8 +1338,8 @@ func queryCollateralizeUserBalanceStatus(db dbm.KV, localdb dbm.KVDB, addr strin
query := pty.NewRecordTable(localdb).GetQuery(localdb) query := pty.NewRecordTable(localdb).GetQuery(localdb)
var primary []byte var primary []byte
var data = &pty.ReceiptCollateralize{ var data = &pty.ReceiptCollateralize{
AccountAddr: addr, AccountAddr: addr,
Status: status, Status: status,
} }
var rows []*table.Row var rows []*table.Row
...@@ -1367,7 +1367,7 @@ func queryCollateralizeUserBalanceStatus(db dbm.KV, localdb dbm.KVDB, addr strin ...@@ -1367,7 +1367,7 @@ func queryCollateralizeUserBalanceStatus(db dbm.KV, localdb dbm.KVDB, addr strin
primary = []byte(rows[DefaultCount-1].Data.(*pty.ReceiptCollateralize).RecordId) primary = []byte(rows[DefaultCount-1].Data.(*pty.ReceiptCollateralize).RecordId)
} }
return totalBalance,nil return totalBalance, nil
} }
func queryCollateralizeUserBalance(db dbm.KV, localdb dbm.KVDB, addr string) (int64, error) { func queryCollateralizeUserBalance(db dbm.KV, localdb dbm.KVDB, addr string) (int64, error) {
...@@ -1378,7 +1378,7 @@ func queryCollateralizeUserBalance(db dbm.KV, localdb dbm.KVDB, addr string) (in ...@@ -1378,7 +1378,7 @@ func queryCollateralizeUserBalance(db dbm.KV, localdb dbm.KVDB, addr string) (in
clog.Error("queryCollateralizeUserBalance", "err", err) clog.Error("queryCollateralizeUserBalance", "err", err)
} else { } else {
totalBalance += balance totalBalance += balance
} }
balance, err = queryCollateralizeUserBalanceStatus(db, localdb, addr, pty.CollateralizeUserStatusWarning) balance, err = queryCollateralizeUserBalanceStatus(db, localdb, addr, pty.CollateralizeUserStatusWarning)
if err != nil { if err != nil {
...@@ -1395,4 +1395,4 @@ func queryCollateralizeUserBalance(db dbm.KV, localdb dbm.KVDB, addr string) (in ...@@ -1395,4 +1395,4 @@ func queryCollateralizeUserBalance(db dbm.KV, localdb dbm.KVDB, addr string) (in
} }
return totalBalance, nil return totalBalance, nil
} }
\ No newline at end of file
...@@ -175,5 +175,5 @@ func (c *Collateralize) Query_CollateralizeUserBalance(req *pty.ReqCollateralize ...@@ -175,5 +175,5 @@ func (c *Collateralize) Query_CollateralizeUserBalance(req *pty.ReqCollateralize
return nil, err return nil, err
} }
return &pty.RepCollateralizeUserBalance{Balance:balance}, nil return &pty.RepCollateralizeUserBalance{Balance: balance}, nil
} }
...@@ -314,7 +314,7 @@ func IssuanceQueryUserBalance(cmd *cobra.Command, args []string) { ...@@ -314,7 +314,7 @@ func IssuanceQueryUserBalance(cmd *cobra.Command, args []string) {
params.Execer = pkt.IssuanceX params.Execer = pkt.IssuanceX
params.FuncName = "IssuanceUserBalance" params.FuncName = "IssuanceUserBalance"
req := &pkt.ReqIssuanceRecords{ req := &pkt.ReqIssuanceRecords{
Addr: addr, Addr: addr,
} }
params.Payload = types.MustPBToJSON(req) params.Payload = types.MustPBToJSON(req)
......
...@@ -295,7 +295,7 @@ func TestIssuance(t *testing.T) { ...@@ -295,7 +295,7 @@ func TestIssuance(t *testing.T) {
res, err = exec.Query("IssuanceUserBalance", res, err = exec.Query("IssuanceUserBalance",
types.Encode(&pkt.ReqIssuanceRecords{Addr: string(Nodes[1]), Status: 1})) types.Encode(&pkt.ReqIssuanceRecords{Addr: string(Nodes[1]), Status: 1}))
assert.Nil(t, err) assert.Nil(t, err)
assert.Equal(t, 100 * types.Coin, res.(*pkt.RepIssuanceUserBalance).Balance) assert.Equal(t, 100*types.Coin, res.(*pkt.RepIssuanceUserBalance).Balance)
// issuance repay // issuance repay
p5 := &pkt.IssuanceRepayTx{ p5 := &pkt.IssuanceRepayTx{
......
...@@ -17,10 +17,10 @@ import ( ...@@ -17,10 +17,10 @@ import (
// List control // List control
const ( const (
ListDESC = int32(0) // list降序 ListDESC = int32(0) // list降序
ListASC = int32(1) // list升序 ListASC = int32(1) // list升序
DefaultCount = int32(20) // 默认一次取多少条记录 DefaultCount = int32(20) // 默认一次取多少条记录
MaxCount = int32(100) // 最多取100条 MaxCount = int32(100) // 最多取100条
) )
const ( const (
...@@ -1087,8 +1087,8 @@ func queryIssuanceUserBalanceStatus(db dbm.KV, localdb dbm.KVDB, addr string, st ...@@ -1087,8 +1087,8 @@ func queryIssuanceUserBalanceStatus(db dbm.KV, localdb dbm.KVDB, addr string, st
query := pty.NewRecordTable(localdb).GetQuery(localdb) query := pty.NewRecordTable(localdb).GetQuery(localdb)
var primary []byte var primary []byte
var data = &pty.ReceiptIssuance{ var data = &pty.ReceiptIssuance{
AccountAddr: addr, AccountAddr: addr,
Status: status, Status: status,
} }
var rows []*table.Row var rows []*table.Row
...@@ -1116,7 +1116,7 @@ func queryIssuanceUserBalanceStatus(db dbm.KV, localdb dbm.KVDB, addr string, st ...@@ -1116,7 +1116,7 @@ func queryIssuanceUserBalanceStatus(db dbm.KV, localdb dbm.KVDB, addr string, st
primary = []byte(rows[DefaultCount-1].Data.(*pty.ReceiptIssuance).DebtId) primary = []byte(rows[DefaultCount-1].Data.(*pty.ReceiptIssuance).DebtId)
} }
return totalBalance,nil return totalBalance, nil
} }
func queryIssuanceUserBalance(db dbm.KV, localdb dbm.KVDB, addr string) (int64, error) { func queryIssuanceUserBalance(db dbm.KV, localdb dbm.KVDB, addr string) (int64, error) {
...@@ -1144,4 +1144,4 @@ func queryIssuanceUserBalance(db dbm.KV, localdb dbm.KVDB, addr string) (int64, ...@@ -1144,4 +1144,4 @@ func queryIssuanceUserBalance(db dbm.KV, localdb dbm.KVDB, addr string) (int64,
} }
return totalBalance, nil return totalBalance, nil
} }
\ No newline at end of file
...@@ -130,5 +130,5 @@ func (c *Issuance) Query_IssuanceUserBalance(req *pty.ReqIssuanceRecords) (types ...@@ -130,5 +130,5 @@ func (c *Issuance) Query_IssuanceUserBalance(req *pty.ReqIssuanceRecords) (types
return nil, err return nil, err
} }
return &pty.RepIssuanceUserBalance{Balance:balance}, nil return &pty.RepIssuanceUserBalance{Balance: balance}, nil
} }
\ No newline at end of file
This diff is collapsed.
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