Blockchain-based recording and querying operations
Implementations of this specification provide blockchain-based recording and querying methods and apparatuses. An example method includes operations performed by an access gateway, including receiving, from a first service system, user data including a user identifier of a user; transmitting, to an identifier hash system, a first hash request for the user identifier; receiving, from the identifier hash system, a hash digest of the user identifier; replacing the user identifier in the user data with the hash digest of the user identifier, and packaging the user data into a storage transaction; transmitting, to a blockchain, the storage transaction; receiving, from the blockchain, a result of the storage transaction having been performed by a smart contract published by the first service system on the blockchain; and providing, to the first service system, the result of the storage transaction.
1. A method comprising:
receiving, by a node device of a blockchain and from an access gateway, a storage transaction including user data of a target user, the user data having been provided by a first service system;
in response to receiving the storage transaction, (i) invoking, by the node device, a first calculation logic declared in a first smart contract published by the first service system on the blockchain, (ii) calculating a user score of the target user based on the user data, and (iii) storing the user score of the target user in association with the first service system;
receiving, by the node device of the blockchain and from the access gateway, a query transaction, the query transaction being based on a user data query for the target user provided by a second service system, wherein the query transaction comprises, for each service system of a plurality of different service systems, a respective hash digest generated for a user identifier of the target user;
in response to receiving the query transaction, (i) invoking, by the node device, a second calculation logic declared in a second smart contract published on the blockchain, (ii) searching the blockchain for respective user scores of the target user stored in association with respective different service systems, based on the respective hash digests generated for the user identifier of the target user, and (iii) calculating an aggregated user score of the target user, according to the respective user scores of the target user; and
providing, by the node device of the blockchain and to the access gateway, the aggregated user score of the target user.
2. The method according to claim 1 , wherein the user data comprises a hash digest, and wherein the hash digest is generated by performing a hash digest calculation on the user identifier of the target user.
3. The method according to claim 2 , wherein performing the hash digest calculation on the user identifier of the target user comprises:
performing a reversible conversion on the user identifier based on a reversible conversion function; and
performing the hash digest calculation on a converted user identifier to generate the hash digest.
4. The method according to claim 2 , further comprising:
adding a check code to the hash digest.
5. The method according to claim 1 ,
wherein each respective hash digest is a hash value acquired by performing a hash calculation on the user identifier of the target user for a respective service system, and
wherein searching the blockchain for the respective user scores of the target user comprises searching for user scores corresponding to the respective hash digests in the blockchain.
6. The method according to claim 1 , wherein calculating the aggregated user score for the target user comprises aggregating weighted user scores of the target user, the weighted user scores being set according to weights of the respective different service systems.
7. A computer-implemented system, comprising:
one or more computers; and
one or more computer memory devices interoperably coupled with the one or more computers and having tangible, non-transitory, machine-readable media storing one or more instructions that, when executed by the one or more computers, cause the one or more computers to perform operations comprising:
receiving, by a node device of a blockchain and from an access gateway, a storage transaction including user data of a target user, the user data having been provided by a first service system;
in response to receiving the storage transaction, (i) invoking, by the node device, a first calculation logic declared in a first smart contract published by the first service system on the blockchain, (ii) calculating a user score of the target user based on the user data, and (iii) storing the user score of the target user in association with the first service system;
receiving, by the node device of the blockchain and from the access gateway, a query transaction, the query transaction being based on a user data query for the target user provided by a second service system, wherein the query transaction comprises, for each service system of a plurality of different service systems, a respective hash digest generated for a user identifier of the target user;
in response to receiving the query transaction, (i) invoking, by the node device, a second calculation logic declared in a second smart contract published on the blockchain, (ii) searching the blockchain for respective user scores of the target user stored in association with respective different service systems, based on the respective hash digests generated for the user identifier of the target user, and (iii) calculating an aggregated user score of the target user, according to the respective user scores of the target user; and
providing, by the node device of the blockchain and to the access gateway, the aggregated user score of the target user.
8. The system according to claim 7 , wherein the user data comprises a hash digest, and wherein the hash digest is generated by performing a hash digest calculation on the user identifier of the target user.
9. The system according to claim 8 , wherein performing the hash digest calculation on the user identifier of the target user comprises:
performing a reversible conversion on the user identifier based on a reversible conversion function; and
performing the hash digest calculation on a converted user identifier to generate the hash digest.
10. The system according to claim 8 , the operations further comprising:
adding a check code to the hash digest.
11. The system according to claim 7 ,
wherein each respective hash digest is a hash value acquired by performing a hash calculation on the user identifier of the target user for a respective service system, and
wherein searching the blockchain for the respective user scores of the target user comprises searching for user scores corresponding to the respective hash digests in the blockchain.
12. The system according to claim 7 , wherein calculating the aggregated user score for the target user comprises aggregating weighted user scores of the target user, the weighted user scores being set according to weights of the respective different service systems.
13. A non-transitory, computer-readable medium storing one or more instructions executable by a computer system to perform operations comprising:
receiving, by a node device of a blockchain and from an access gateway, a storage transaction including user data of a target user, the user data having been provided by a first service system;
in response to receiving the storage transaction, (i) invoking, by the node device, a first calculation logic declared in a first smart contract published by the first service system on the blockchain, (ii) calculating a user score of the target user based on the user data, and (iii) storing the user score of the target user in association with the first service system;
receiving, by the node device of the blockchain and from the access gateway, a query transaction, the query transaction being based on a user data query for the target user provided by a second service system, wherein the query transaction comprises, for each service system of a plurality of different service systems, a respective hash digest generated for a user identifier of the target user;
in response to receiving the query transaction, (i) invoking, by the node device, a second calculation logic declared in a second smart contract published on the blockchain, (ii) searching the blockchain for respective user scores of the target user stored in association with respective different service systems, based on the respective hash digests generated for the user identifier of the target user, and (iii) calculating an aggregated user score of the target user, according to the respective user scores of the target user; and
providing, by the node device of the blockchain and to the access gateway, the aggregated user score of the target user.
14. The computer-readable medium according to claim 13 , wherein the user data comprises a hash digest, and wherein the hash digest is generated by performing a hash digest calculation on the user identifier of the target user.
15. The computer-readable medium according to claim 14 , wherein performing the hash digest calculation on the user identifier of the target user comprises:
performing a reversible conversion on the user identifier based on a reversible conversion function; and
performing the hash digest calculation on a converted user identifier to generate the hash digest.
16. The computer-readable medium according to claim 14 , the operations further comprising:
adding a check code to the hash digest.
17. The computer-readable medium according to claim 13 ,
wherein each respective hash digest is a hash value acquired by performing a hash calculation on the user identifier of the target user for a respective service system, and
wherein searching the blockchain for the respective user scores of the target user comprises searching for user scores corresponding to the respective hash digests in the blockchain.
18. The computer-readable medium according to claim 13 , wherein calculating the aggregated user score for the target user comprises aggregating weighted user scores of the target user, the weighted user scores being set according to weights of the respective different service systems.