Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
P
plugin
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
JIRA
JIRA
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
link33
plugin
Commits
965a5070
Commit
965a5070
authored
Feb 28, 2019
by
陈德海
Browse files
Options
Browse Files
Download
Plain Diff
Merge remote-tracking branch 'upstream/master'
parents
cdfb9303
0f29c24b
Hide whitespace changes
Inline
Side-by-side
Showing
5 changed files
with
5 additions
and
10 deletions
+5
-10
ticket.go
plugin/dapp/ticket/wallet/ticket.go
+1
-1
localdb.go
vendor/github.com/33cn/chain33/blockchain/localdb.go
+1
-0
proc.go
vendor/github.com/33cn/chain33/blockchain/proc.go
+1
-2
query_tx.go
vendor/github.com/33cn/chain33/blockchain/query_tx.go
+0
-5
queueprotocol.go
vendor/github.com/33cn/chain33/client/queueprotocol.go
+2
-2
No files found.
plugin/dapp/ticket/wallet/ticket.go
View file @
965a5070
...
@@ -338,7 +338,7 @@ func (policy *ticketPolicy) getTickets(addr string, status int32) ([]*ty.Ticket,
...
@@ -338,7 +338,7 @@ func (policy *ticketPolicy) getTickets(addr string, status int32) ([]*ty.Ticket,
api
:=
policy
.
getAPI
()
api
:=
policy
.
getAPI
()
msg
,
err
:=
api
.
Query
(
ty
.
TicketX
,
"TicketList"
,
reqaddr
)
msg
,
err
:=
api
.
Query
(
ty
.
TicketX
,
"TicketList"
,
reqaddr
)
if
err
!=
nil
{
if
err
!=
nil
{
bizlog
.
Error
(
"getTickets"
,
"Query error"
,
err
)
bizlog
.
Error
(
"getTickets"
,
"
addr"
,
addr
,
"status"
,
status
,
"
Query error"
,
err
)
return
nil
,
err
return
nil
,
err
}
}
reply
:=
msg
.
(
*
ty
.
ReplyTicketList
)
reply
:=
msg
.
(
*
ty
.
ReplyTicketList
)
...
...
vendor/github.com/33cn/chain33/blockchain/localdb.go
View file @
965a5070
...
@@ -7,6 +7,7 @@ import (
...
@@ -7,6 +7,7 @@ import (
"github.com/33cn/chain33/types"
"github.com/33cn/chain33/types"
)
)
func
(
chain
*
BlockChain
)
procLocalDB
(
msgtype
int64
,
msg
*
queue
.
Message
,
reqnum
chan
struct
{})
bool
{
func
(
chain
*
BlockChain
)
procLocalDB
(
msgtype
int64
,
msg
*
queue
.
Message
,
reqnum
chan
struct
{})
bool
{
switch
msgtype
{
switch
msgtype
{
case
types
.
EventLocalGet
:
case
types
.
EventLocalGet
:
...
...
vendor/github.com/33cn/chain33/blockchain/proc.go
View file @
965a5070
...
@@ -137,10 +137,9 @@ func (chain *BlockChain) queryTx(msg *queue.Message) {
...
@@ -137,10 +137,9 @@ func (chain *BlockChain) queryTx(msg *queue.Message) {
txhash
:=
(
msg
.
Data
)
.
(
*
types
.
ReqHash
)
txhash
:=
(
msg
.
Data
)
.
(
*
types
.
ReqHash
)
TransactionDetail
,
err
:=
chain
.
ProcQueryTxMsg
(
txhash
.
Hash
)
TransactionDetail
,
err
:=
chain
.
ProcQueryTxMsg
(
txhash
.
Hash
)
if
err
!=
nil
{
if
err
!=
nil
{
chainlog
.
Error
(
"ProcQueryTxMsg"
,
"err"
,
err
.
Error
())
chainlog
.
Debug
(
"ProcQueryTxMsg"
,
"err"
,
err
.
Error
())
msg
.
Reply
(
chain
.
client
.
NewMessage
(
"rpc"
,
types
.
EventTransactionDetail
,
err
))
msg
.
Reply
(
chain
.
client
.
NewMessage
(
"rpc"
,
types
.
EventTransactionDetail
,
err
))
}
else
{
}
else
{
//chainlog.Debug("ProcQueryTxMsg", "success", "ok")
msg
.
Reply
(
chain
.
client
.
NewMessage
(
"rpc"
,
types
.
EventTransactionDetail
,
TransactionDetail
))
msg
.
Reply
(
chain
.
client
.
NewMessage
(
"rpc"
,
types
.
EventTransactionDetail
,
TransactionDetail
))
}
}
}
}
...
...
vendor/github.com/33cn/chain33/blockchain/query_tx.go
View file @
965a5070
...
@@ -164,13 +164,8 @@ func (chain *BlockChain) ProcQueryTxMsg(txhash []byte) (proof *types.Transaction
...
@@ -164,13 +164,8 @@ func (chain *BlockChain) ProcQueryTxMsg(txhash []byte) (proof *types.Transaction
if
err
!=
nil
{
if
err
!=
nil
{
return
nil
,
err
return
nil
,
err
}
}
TransactionDetail
.
Proofs
=
proofs
TransactionDetail
.
Proofs
=
proofs
chainlog
.
Debug
(
"ProcQueryTxMsg"
,
"proofs"
,
TransactionDetail
.
Proofs
)
setTxDetailFromTxResult
(
&
TransactionDetail
,
txresult
)
setTxDetailFromTxResult
(
&
TransactionDetail
,
txresult
)
chainlog
.
Debug
(
"ProcQueryTxMsg"
,
"TransactionDetail"
,
TransactionDetail
.
String
())
return
&
TransactionDetail
,
nil
return
&
TransactionDetail
,
nil
}
}
...
...
vendor/github.com/33cn/chain33/client/queueprotocol.go
View file @
965a5070
...
@@ -171,12 +171,12 @@ func (q *QueueProtocol) GetBlocks(param *types.ReqBlocks) (*types.BlockDetails,
...
@@ -171,12 +171,12 @@ func (q *QueueProtocol) GetBlocks(param *types.ReqBlocks) (*types.BlockDetails,
func
(
q
*
QueueProtocol
)
QueryTx
(
param
*
types
.
ReqHash
)
(
*
types
.
TransactionDetail
,
error
)
{
func
(
q
*
QueueProtocol
)
QueryTx
(
param
*
types
.
ReqHash
)
(
*
types
.
TransactionDetail
,
error
)
{
if
param
==
nil
{
if
param
==
nil
{
err
:=
types
.
ErrInvalidParam
err
:=
types
.
ErrInvalidParam
log
.
Error
(
"QueryTx"
,
"Error"
,
err
)
log
.
Debug
(
"QueryTx"
,
"Error"
,
err
)
return
nil
,
err
return
nil
,
err
}
}
msg
,
err
:=
q
.
query
(
blockchainKey
,
types
.
EventQueryTx
,
param
)
msg
,
err
:=
q
.
query
(
blockchainKey
,
types
.
EventQueryTx
,
param
)
if
err
!=
nil
{
if
err
!=
nil
{
log
.
Error
(
"QueryTx"
,
"Error"
,
err
.
Error
())
log
.
Debug
(
"QueryTx"
,
"Error"
,
err
.
Error
())
return
nil
,
err
return
nil
,
err
}
}
if
reply
,
ok
:=
msg
.
GetData
()
.
(
*
types
.
TransactionDetail
);
ok
{
if
reply
,
ok
:=
msg
.
GetData
()
.
(
*
types
.
TransactionDetail
);
ok
{
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment