Commit 2ffe574c authored by pengjun's avatar pengjun

#627 update coll & issuance query result

parent af89673b
...@@ -584,6 +584,7 @@ func (action *Action) CollateralizeBorrow(borrow *pty.CollateralizeBorrow) (*typ ...@@ -584,6 +584,7 @@ func (action *Action) CollateralizeBorrow(borrow *pty.CollateralizeBorrow) (*typ
// 构造借出记录 // 构造借出记录
borrowRecord := &pty.BorrowRecord{} borrowRecord := &pty.BorrowRecord{}
borrowRecord.RecordId = common.ToHex(action.txhash) borrowRecord.RecordId = common.ToHex(action.txhash)
borrowRecord.CollateralizeId = coll.CollateralizeId
borrowRecord.AccountAddr = action.fromaddr borrowRecord.AccountAddr = action.fromaddr
borrowRecord.CollateralValue = btyFrozen borrowRecord.CollateralValue = btyFrozen
borrowRecord.StartTime = action.blocktime borrowRecord.StartTime = action.blocktime
......
...@@ -25,6 +25,7 @@ func (c *Collateralize) Query_CollateralizeInfoByID(req *pty.ReqCollateralizeInf ...@@ -25,6 +25,7 @@ func (c *Collateralize) Query_CollateralizeInfoByID(req *pty.ReqCollateralizeInf
CreateAddr: coll.CreateAddr, CreateAddr: coll.CreateAddr,
Balance: coll.Balance, Balance: coll.Balance,
Period: coll.Period, Period: coll.Period,
CollateralizeId: coll.CollateralizeId,
}, nil }, nil
} }
...@@ -46,6 +47,7 @@ func (c *Collateralize) Query_CollateralizeInfoByIDs(req *pty.ReqCollateralizeIn ...@@ -46,6 +47,7 @@ func (c *Collateralize) Query_CollateralizeInfoByIDs(req *pty.ReqCollateralizeIn
CreateAddr: coll.CreateAddr, CreateAddr: coll.CreateAddr,
Balance: coll.Balance, Balance: coll.Balance,
Period: coll.Period, Period: coll.Period,
CollateralizeId: coll.CollateralizeId,
}) })
} }
...@@ -100,6 +102,18 @@ func (c *Collateralize) Query_CollateralizeRecordByAddr(req *pty.ReqCollateraliz ...@@ -100,6 +102,18 @@ func (c *Collateralize) Query_CollateralizeRecordByAddr(req *pty.ReqCollateraliz
return ret, nil return ret, nil
} }
func (c *Collateralize) Query_CollateralizeRecordByStatus(req *pty.ReqCollateralizeRecordByStatus) (types.Message, error) {
ret := &pty.RepCollateralizeRecords{}
records, err := queryCollateralizeRecordByStatus(c.GetStateDB(), c.GetLocalDB(), req.Status, req.Index)
if err != nil {
clog.Error("Query_CollateralizeRecordByStatus", "get collateralize record error", err)
return nil, err
}
ret.Records = records
return ret, nil
}
func (c *Collateralize) Query_CollateralizeConfig(req *pty.ReqCollateralizeRecordByAddr) (types.Message, error) { func (c *Collateralize) Query_CollateralizeConfig(req *pty.ReqCollateralizeRecordByAddr) (types.Message, error) {
config, err := getCollateralizeConfig(c.GetStateDB()) config, err := getCollateralizeConfig(c.GetStateDB())
if err != nil { if err != nil {
......
...@@ -2,15 +2,15 @@ syntax = "proto3"; ...@@ -2,15 +2,15 @@ syntax = "proto3";
package types; package types;
// 贷信息 // 贷信息
message Collateralize { message Collateralize {
string collateralizeId = 1; //借贷ID,一期借贷对应一个ID string collateralizeId = 1; //放贷ID,一期放贷对应一个ID
int64 totalBalance = 2; //当期可借贷的总金额(ccny) int64 totalBalance = 2; //当期贷的总金额(ccny)
int64 debtCeiling = 3; //单用户可借出的限额(ccny) int64 debtCeiling = 3; //单用户可借出的限额(ccny)
float liquidationRatio = 4; //清算比例 float liquidationRatio = 4; //清算比例
float stabilityFeeRatio = 5; //稳定费率 float stabilityFeeRatio = 5; //稳定费率
string createAddr = 6; //创建人地址 string createAddr = 6; //创建人地址
int64 balance = 7; //剩余可借贷金额(ccny) int64 balance = 7; //放贷剩余金额(ccny)
repeated BorrowRecord borrowRecords = 8; //借贷记录 repeated BorrowRecord borrowRecords = 8; //借贷记录
repeated BorrowRecord InvalidRecords = 9; //失效的借贷记录 repeated BorrowRecord InvalidRecords = 9; //失效的借贷记录
int32 status = 10;//当期借贷的状态,是否关闭 int32 status = 10;//当期借贷的状态,是否关闭
...@@ -33,9 +33,10 @@ message BorrowRecord { ...@@ -33,9 +33,10 @@ message BorrowRecord {
int64 liquidateTime = 8; //清算时间 int64 liquidateTime = 8; //清算时间
int64 expireTime = 9; //超时清算时间 int64 expireTime = 9; //超时清算时间
int32 preStatus = 10;//上一次抵押状态,用于告警恢复 int32 preStatus = 10;//上一次抵押状态,用于告警恢复
string recordId = 11;//借出id,标识一次借出记录 string recordId = 11;//借贷id,标识一次借出记录
int64 index = 12;//当前索引 string collateralizeId = 12;//放贷id
int64 preIndex = 13;//上级索引 int64 index = 13;//当前索引
int64 preIndex = 14;//上级索引
} }
// 资产价格记录 // 资产价格记录
...@@ -71,7 +72,7 @@ message CollateralizeManage { ...@@ -71,7 +72,7 @@ message CollateralizeManage {
message CollateralizeAddr { message CollateralizeAddr {
repeated string superAddrs = 1; //大户地址 repeated string superAddrs = 1; //大户地址
} }
// 创建 // 创建
message CollateralizeCreate { message CollateralizeCreate {
int64 totalBalance = 1; //可借贷总金额 int64 totalBalance = 1; //可借贷总金额
} }
...@@ -102,12 +103,12 @@ message CollateralizeFeed { ...@@ -102,12 +103,12 @@ message CollateralizeFeed {
repeated int64 volume = 3; //成交量 repeated int64 volume = 3; //成交量
} }
// 贷关闭 // 贷关闭
message CollateralizeClose { message CollateralizeClose {
string collateralizeId = 1; //借贷期数ID string collateralizeId = 1; //借贷期数ID
} }
// exec_local 贷信息 // exec_local 贷信息
message ReceiptCollateralize { message ReceiptCollateralize {
string collateralizeId = 1; string collateralizeId = 1;
string createAddr = 2; string createAddr = 2;
...@@ -119,7 +120,7 @@ message ReceiptCollateralize { ...@@ -119,7 +120,7 @@ message ReceiptCollateralize {
int64 preIndex = 8; int64 preIndex = 8;
} }
// exec_local 贷记录信息 // exec_local 贷记录信息
message CollateralizeRecord { message CollateralizeRecord {
string collateralizeId = 1; string collateralizeId = 1;
string addr = 2; string addr = 2;
...@@ -127,17 +128,17 @@ message CollateralizeRecord { ...@@ -127,17 +128,17 @@ message CollateralizeRecord {
int64 index = 4; int64 index = 4;
} }
// exec_local 贷记录信息列表 // exec_local 贷记录信息列表
message CollateralizeRecords { message CollateralizeRecords {
repeated CollateralizeRecord records = 1; repeated CollateralizeRecord records = 1;
} }
// 根据ID查询一期贷信息 // 根据ID查询一期贷信息
message ReqCollateralizeInfo { message ReqCollateralizeInfo {
string collateralizeId = 1; string collateralizeId = 1;
} }
// 返回一期贷信息 // 返回一期贷信息
message RepCollateralizeCurrentInfo { message RepCollateralizeCurrentInfo {
int32 status = 1;//当期借贷的状态,是否关闭 int32 status = 1;//当期借贷的状态,是否关闭
int64 totalBalance = 2; //当期可借贷的总金额(ccny) int64 totalBalance = 2; //当期可借贷的总金额(ccny)
...@@ -147,19 +148,20 @@ message RepCollateralizeCurrentInfo { ...@@ -147,19 +148,20 @@ message RepCollateralizeCurrentInfo {
string createAddr = 6; //创建人地址 string createAddr = 6; //创建人地址
int64 balance = 7; //剩余可借贷金额(ccny) int64 balance = 7; //剩余可借贷金额(ccny)
int64 period = 8; //合约期限 int64 period = 8; //合约期限
string collateralizeId = 9; //放贷ID
} }
// 根据ID列表查询多期贷信息 // 根据ID列表查询多期贷信息
message ReqCollateralizeInfos { message ReqCollateralizeInfos {
repeated string collateralizeIds = 1; repeated string collateralizeIds = 1;
} }
// 返回多期贷信息 // 返回多期贷信息
message RepCollateralizeCurrentInfos { message RepCollateralizeCurrentInfos {
repeated RepCollateralizeCurrentInfo infos = 1; repeated RepCollateralizeCurrentInfo infos = 1;
} }
// 根据贷状态查询 // 根据贷状态查询
message ReqCollateralizeByStatus { message ReqCollateralizeByStatus {
int32 status = 1; int32 status = 1;
int64 index = 2; int64 index = 2;
...@@ -171,7 +173,7 @@ message ReqCollateralizeByAddr { ...@@ -171,7 +173,7 @@ message ReqCollateralizeByAddr {
int64 index = 2; int64 index = 2;
} }
// 返回贷ID列表 // 返回贷ID列表
message RepCollateralizeIDs { message RepCollateralizeIDs {
repeated string IDs = 1; repeated string IDs = 1;
} }
...@@ -201,7 +203,7 @@ message ReqCollateralizeRecord { ...@@ -201,7 +203,7 @@ message ReqCollateralizeRecord {
string recordId = 2; string recordId = 2;
} }
// 返回记录 // 返回借贷记录
message RepCollateralizeRecord { message RepCollateralizeRecord {
BorrowRecord record = 1; BorrowRecord record = 1;
} }
......
...@@ -594,6 +594,7 @@ func (action *Action) IssuanceDebt(debt *pty.IssuanceDebt) (*types.Receipt, erro ...@@ -594,6 +594,7 @@ func (action *Action) IssuanceDebt(debt *pty.IssuanceDebt) (*types.Receipt, erro
debtRecord := &pty.DebtRecord{} debtRecord := &pty.DebtRecord{}
debtRecord.AccountAddr = action.fromaddr debtRecord.AccountAddr = action.fromaddr
debtRecord.DebtId = common.ToHex(action.txhash) debtRecord.DebtId = common.ToHex(action.txhash)
debtRecord.IssuId = issu.IssuanceId
debtRecord.CollateralValue = btyFrozen debtRecord.CollateralValue = btyFrozen
debtRecord.StartTime = action.blocktime debtRecord.StartTime = action.blocktime
debtRecord.CollateralPrice = lastPrice debtRecord.CollateralPrice = lastPrice
......
...@@ -25,6 +25,7 @@ func (c *Issuance) Query_IssuanceInfoByID(req *pty.ReqIssuanceInfo) (types.Messa ...@@ -25,6 +25,7 @@ func (c *Issuance) Query_IssuanceInfoByID(req *pty.ReqIssuanceInfo) (types.Messa
CollateralValue: issu.CollateralValue, CollateralValue: issu.CollateralValue,
DebtValue: issu.DebtValue, DebtValue: issu.DebtValue,
Period: issu.Period, Period: issu.Period,
IssuId: issu.IssuanceId,
}, nil }, nil
} }
...@@ -46,6 +47,7 @@ func (c *Issuance) Query_IssuanceInfoByIDs(req *pty.ReqIssuanceInfos) (types.Mes ...@@ -46,6 +47,7 @@ func (c *Issuance) Query_IssuanceInfoByIDs(req *pty.ReqIssuanceInfos) (types.Mes
CollateralValue: issu.CollateralValue, CollateralValue: issu.CollateralValue,
DebtValue: issu.DebtValue, DebtValue: issu.DebtValue,
Period: issu.Period, Period: issu.Period,
IssuId: issu.IssuanceId,
}) })
} }
......
...@@ -2,19 +2,19 @@ syntax = "proto3"; ...@@ -2,19 +2,19 @@ syntax = "proto3";
package types; package types;
// 借贷信息 // 发行信息
message Issuance { message Issuance {
string issuanceId = 1; //借贷ID,一期借贷对应一个ID string issuanceId = 1; //发行ID,一期发行对应一个ID
int64 totalBalance = 2; //当期可借贷的总金额(ccny) int64 totalBalance = 2; //当期发行的总金额(ccny)
int64 debtCeiling = 3; //单用户可借出的限额(ccny) int64 debtCeiling = 3; //单用户可借出的限额(ccny)
float liquidationRatio = 4; //清算比例 float liquidationRatio = 4; //清算比例
int64 collateralValue = 5; //抵押物总数量(bty) int64 collateralValue = 5; //抵押物总数量(bty)
int64 debtValue = 6; //产生的ccny数量 int64 debtValue = 6; //产生的ccny数量
repeated DebtRecord debtRecords = 7; //大户抵押记录 repeated DebtRecord debtRecords = 7; //大户抵押记录
repeated DebtRecord invalidRecords = 8; //大户抵押记录 repeated DebtRecord invalidRecords = 8; //大户抵押记录
int32 status = 9; //当期借贷的状态,是否关闭 int32 status = 9; //当期发行的状态,是否关闭
float latestLiquidationPrice = 10; //最高清算价格 float latestLiquidationPrice = 10;//最高清算价格
int64 period = 11;//借贷最大期限 int64 period = 11;//发行最大期限
int64 latestExpireTime = 12;//最近超期时间 int64 latestExpireTime = 12;//最近超期时间
int64 createTime = 13;//创建时间 int64 createTime = 13;//创建时间
int64 balance = 14;//剩余可发行ccny int64 balance = 14;//剩余可发行ccny
...@@ -25,8 +25,8 @@ message Issuance { ...@@ -25,8 +25,8 @@ message Issuance {
// 抵押记录 // 抵押记录
message DebtRecord { message DebtRecord {
string accountAddr = 1; //借贷人地址 string accountAddr = 1; //抵押人地址
int64 startTime = 2; //借贷时间 int64 startTime = 2; //抵押时间
int64 collateralValue = 3; //抵押物价值(bty) int64 collateralValue = 3; //抵押物价值(bty)
float collateralPrice = 4; //抵押物价格 float collateralPrice = 4; //抵押物价格
int64 debtValue = 5; //债务价值(ccny) int64 debtValue = 5; //债务价值(ccny)
...@@ -36,8 +36,9 @@ message DebtRecord { ...@@ -36,8 +36,9 @@ message DebtRecord {
int64 expireTime = 9; //超时清算时间 int64 expireTime = 9; //超时清算时间
int32 preStatus = 10;//上一次抵押状态,用于告警恢复 int32 preStatus = 10;//上一次抵押状态,用于告警恢复
string debtId = 11;//借贷id string debtId = 11;//借贷id
int64 index = 12;//当前索引 string issuId = 12;//发行id
int64 preIndex = 13;//上级索引 int64 index = 13;//当前索引
int64 preIndex = 14;//上级索引
} }
// 资产价格记录 // 资产价格记录
...@@ -49,8 +50,8 @@ message IssuanceAssetPriceRecord { ...@@ -49,8 +50,8 @@ message IssuanceAssetPriceRecord {
// action // action
message IssuanceAction { message IssuanceAction {
oneof value { oneof value {
IssuanceCreate create = 1; //创建一期借贷 IssuanceCreate create = 1; //创建一期发行
IssuanceDebt debt = 2; //借贷 IssuanceDebt debt = 2; //抵押
IssuanceRepay repay = 3; //清算 IssuanceRepay repay = 3; //清算
IssuanceFeed feed = 4; //喂价 IssuanceFeed feed = 4; //喂价
IssuanceClose close = 5; //关闭 IssuanceClose close = 5; //关闭
...@@ -63,24 +64,24 @@ message IssuanceManage { ...@@ -63,24 +64,24 @@ message IssuanceManage {
repeated string superAddrs = 1; //大户地址 repeated string superAddrs = 1; //大户地址
} }
// 创建借贷 // 创建发行
message IssuanceCreate { message IssuanceCreate {
int64 totalBalance = 1; //可借贷总金额 int64 totalBalance = 1; //发行总金额
int64 debtCeiling = 2; //单用户可借出的限额(ccny) int64 debtCeiling = 2; //单用户可借出的限额(ccny)
float liquidationRatio = 3; //清算比例 float liquidationRatio = 3; //清算比例
int64 period = 4;//借贷最大期限 int64 period = 4; //发行最大期限
} }
// 质押借出 // 抵押
message IssuanceDebt { message IssuanceDebt {
string issuanceId = 1; //借贷期数ID string issuanceId = 1; //发行ID
int64 value = 2; //借贷价值(ccny) int64 value = 2; //借贷金额(ccny)
} }
// 质押清算 // 质押清算
message IssuanceRepay { message IssuanceRepay {
string issuanceId = 1; //借贷期数ID string issuanceId = 1; //发行ID
string debtId = 2; //借贷ID string debtId = 2; //抵押ID
} }
// 喂价 // 喂价
...@@ -92,10 +93,10 @@ message IssuanceFeed { ...@@ -92,10 +93,10 @@ message IssuanceFeed {
// 借贷关闭 // 借贷关闭
message IssuanceClose { message IssuanceClose {
string issuanceId = 1; //借贷期数ID string issuanceId = 1; //发行ID
} }
// exec_local 借贷信息 // exec_local 发行信息
message ReceiptIssuance { message ReceiptIssuance {
string issuanceId = 1; string issuanceId = 1;
string accountAddr = 2; string accountAddr = 2;
...@@ -108,7 +109,7 @@ message ReceiptIssuance { ...@@ -108,7 +109,7 @@ message ReceiptIssuance {
float btyPrice = 9; //bty价格 float btyPrice = 9; //bty价格
} }
// exec_local 借贷记录信息 // exec_local 抵押记录信息
message IssuanceRecord { message IssuanceRecord {
string issuanceId = 1; string issuanceId = 1;
string addr = 2; string addr = 2;
...@@ -116,34 +117,35 @@ message IssuanceRecord { ...@@ -116,34 +117,35 @@ message IssuanceRecord {
int64 index = 4; int64 index = 4;
} }
// exec_local 借贷记录信息列表 // exec_local 抵押记录信息列表
message IssuanceRecords { message IssuanceRecords {
repeated IssuanceRecord records = 1; repeated IssuanceRecord records = 1;
} }
// 根据ID查询一期借贷信息 // 根据ID查询发行信息
message ReqIssuanceInfo { message ReqIssuanceInfo {
string issuanceId = 1; string issuanceId = 1;
} }
// 返回一期借贷信息 // 返回一期发行信息
message RepIssuanceCurrentInfo { message RepIssuanceCurrentInfo {
int32 status = 1;//当期借贷的状态,是否关闭 int32 status = 1; //当期发行的状态,是否关闭
int64 totalBalance = 2; //当期可借贷的总金额(ccny) int64 totalBalance = 2; //当期发行总金额(ccny)
int64 debtCeiling = 3; //单用户可借出的限额(ccny) int64 debtCeiling = 3; //单用户可借出的限额(ccny)
float liquidationRatio = 4; //清算比例 float liquidationRatio = 4; //清算比例
int64 balance = 5; //剩余可借贷金额(ccny) int64 balance = 5; //剩余可借贷金额(ccny)
int64 collateralValue = 6; //抵押物总数量(bty) int64 collateralValue = 6; //抵押物总数量(bty)
int64 debtValue = 7; //产生的ccny数量 int64 debtValue = 7; //产生的ccny数量
int64 period = 8;//借贷最大期限 int64 period = 8; //发行最大期限
string issuId = 9; //发行ID
} }
// 根据ID列表查询多期借贷信息 // 根据ID列表查询多期发行信息
message ReqIssuanceInfos { message ReqIssuanceInfos {
repeated string issuanceIds = 1; repeated string issuanceIds = 1;
} }
// 返回多期借贷信息 // 返回多期发行信息
message RepIssuanceCurrentInfos { message RepIssuanceCurrentInfos {
repeated RepIssuanceCurrentInfo infos = 1; repeated RepIssuanceCurrentInfo infos = 1;
} }
...@@ -154,19 +156,19 @@ message ReqIssuanceByStatus { ...@@ -154,19 +156,19 @@ message ReqIssuanceByStatus {
int64 index = 2; int64 index = 2;
} }
// 返回借贷ID列表 // 返回发行ID列表
message RepIssuanceIDs { message RepIssuanceIDs {
repeated string IDs = 1; repeated string IDs = 1;
} }
// 根据用户地址查询发行记录 // 根据用户地址查询抵押记录
message ReqIssuanceRecordsByAddr { message ReqIssuanceRecordsByAddr {
string issuanceId = 1; string issuanceId = 1;
string addr = 2; string addr = 2;
int64 index = 3; int64 index = 3;
} }
// 根据状态查询发行记录 // 根据状态查询抵押记录
message ReqIssuanceRecordsByStatus { message ReqIssuanceRecordsByStatus {
string issuanceId = 1; string issuanceId = 1;
int32 status = 2; int32 status = 2;
...@@ -178,7 +180,7 @@ message RepIssuanceRecords { ...@@ -178,7 +180,7 @@ message RepIssuanceRecords {
repeated DebtRecord records = 1; repeated DebtRecord records = 1;
} }
// 精确查找发行记录 // 精确查找抵押记录
message ReqIssuanceDebtInfo { message ReqIssuanceDebtInfo {
string issuanceId = 1; string issuanceId = 1;
string debtId = 2; string debtId = 2;
......
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