Data processing method, device, equipment and storage mediumTechnical Field
The present application relates to the field of internet technologies, and in particular, to the field of computer technologies, and in particular, to a data processing method, a data processing apparatus, a node device, and a computer storage medium.
Background
With the increasing number of live broadcast platforms and anchor, anchor users and live broadcast platforms often involve anchor exchange in development; the anchor exchange refers to the exchange between platforms by an anchor user on a live platform by means of a specific protocol. From the perspective of the live broadcast platform, the anchor user needs to be purchased from other live broadcast platforms or exchanged with other live broadcast platforms in different stages; from the perspective of the anchor user, the anchor user will also continuously select different live platforms at different stages of development. Due to differences in value evaluation of anchor users by different live broadcast platforms, anchor exchange cannot be objectively and reasonably performed by each live broadcast platform.
Disclosure of Invention
The embodiment of the application provides a data processing method, a data processing device, data processing equipment and a data processing storage medium, which can improve the objectivity and the rationality of anchor resource exchange and promote the flowing efficiency of resources in the live broadcast industry.
In one aspect, an embodiment of the present application provides a data processing method, where the data processing method is executed by a first node in a block chain network, and the first node is any node in the block chain network; the data processing method comprises the following steps:
acquiring anchor value information of a plurality of anchor users on a first live broadcast platform and a second live broadcast platform, wherein the anchor value information at least comprises attribute information and value evaluation data;
performing value evaluation on each anchor user according to the value evaluation data of each anchor user to obtain the identity value of each anchor user;
grouping each anchor user according to the identity value of each anchor user to obtain a value group of each anchor user;
and generating a value relation map by adopting the value group of each anchor user and the attribute information of each anchor user.
In another aspect, an embodiment of the present application provides a data processing apparatus, where the apparatus operates in a first node in a blockchain network, where the first node is any node in the blockchain network; the data processing apparatus includes:
the system comprises an acquisition unit, a processing unit and a processing unit, wherein the acquisition unit is used for acquiring anchor value information of a plurality of anchor users on a first live platform and a second live platform, and the anchor value information at least comprises attribute information and value evaluation data;
the processing unit is used for evaluating the value of each anchor user according to the value evaluation data of each anchor user to obtain the identity value of each anchor user;
the processing unit is used for grouping each anchor user according to the identity value of each anchor user to obtain the value group of each anchor user;
and the processing unit is used for generating a value relation map by adopting the value groups of the anchor users and the attribute information of the anchor users.
In another aspect, an embodiment of the present application provides a node device, where the node device includes an input interface and an output interface, and the node device further includes:
a processor adapted to implement one or more instructions; and the number of the first and second groups,
a computer storage medium storing one or more instructions adapted to be loaded by the processor and to perform the steps of:
acquiring anchor value information of a plurality of anchor users on a first live broadcast platform and a second live broadcast platform, wherein the anchor value information at least comprises attribute information and value evaluation data;
performing value evaluation on each anchor user according to the value evaluation data of each anchor user to obtain the identity value of each anchor user;
grouping each anchor user according to the identity value of each anchor user to obtain a value group of each anchor user;
and generating a value relation map by adopting the value group of each anchor user and the attribute information of each anchor user.
In yet another aspect, embodiments of the present application provide a computer storage medium having one or more instructions stored thereon, the one or more instructions being adapted to be loaded by a processor and perform the following steps:
acquiring anchor value information of a plurality of anchor users on a first live broadcast platform and a second live broadcast platform, wherein the anchor value information at least comprises attribute information and value evaluation data;
performing value evaluation on each anchor user according to the value evaluation data of each anchor user to obtain the identity value of each anchor user;
grouping each anchor user according to the identity value of each anchor user to obtain a value group of each anchor user;
and generating a value relation map by adopting the value group of each anchor user and the attribute information of each anchor user.
According to the method and the device, the attribute information and the value evaluation data of a plurality of anchor users on a first live broadcast platform and a second live broadcast platform can be obtained by a first node in a block chain network, and the value evaluation is performed on each anchor user according to the value evaluation data of each anchor user to obtain the identity value of each anchor user; therefore, the unified judgment of the anchor value is realized, the objectivity of value judgment is improved, and the malicious tampering of the identity value of each anchor user is prevented. The first node equipment can also perform grouping processing on each anchor user according to the identity value of each anchor user to obtain the value group of each anchor user; and generating a value relation map by adopting the value group of each anchor user and the attribute information of each anchor user. By generating the value relation map, the value relation map can be presented to the live broadcast platform as a reference when the live broadcast platform has the anchor exchange requirement; under the condition of avoiding commercial data (such as value evaluation data of all anchor users counted by the live broadcast platform) from being leaked, the anchor users with the same value can be exchanged among the live broadcast platforms; and then the objectivity and rationality of anchor exchange are realized, the flow efficiency of resources in the live broadcast industry is promoted, and the effective utilization rate of anchor resources in the live broadcast industry is improved.
Drawings
In order to more clearly illustrate the technical solutions of the embodiments of the present application, the drawings needed to be used in the description of the embodiments are briefly introduced below, and it is obvious that the drawings in the following description are some embodiments of the present application, and it is obvious for those skilled in the art to obtain other drawings based on these drawings without creative efforts.
FIG. 1a is a block diagram of a data processing system according to an embodiment of the present application;
FIG. 1b is a block diagram illustrating an architecture of another data processing system according to an embodiment of the present application;
fig. 2 is a schematic flowchart of a data processing method according to an embodiment of the present application;
FIG. 3a is a schematic diagram of a value relationship graph provided in an embodiment of the present application;
FIG. 3b is a schematic diagram of another value relationship graph provided in embodiments of the present application;
fig. 4 is a schematic flowchart of a data processing method according to another embodiment of the present application;
FIG. 5a is a schematic diagram of generating a first block according to an embodiment of the present disclosure;
FIG. 5b is a diagram of a query value relationship graph according to an embodiment of the present application;
fig. 5c is a schematic diagram of reporting anchor value information according to an embodiment of the present application;
FIG. 5d is a diagram of a handover value relationship graph according to an embodiment of the present application;
fig. 6 is a schematic structural diagram of a data processing apparatus according to an embodiment of the present application;
fig. 7 is a schematic structural diagram of a node device according to an embodiment of the present application.
Detailed Description
The technical solutions in the embodiments of the present application will be clearly and completely described below with reference to the drawings in the embodiments of the present application.
The live broadcast is a video stream of a development process of synchronously making and releasing an event along with the occurrence of the event on site, and has an information network releasing mode of a bidirectional circulation process. A platform with a live broadcast function may be referred to as a live broadcast platform, and generally includes at least two parts, namely a client and a platform server (or referred to as a backend server). The user side is used for providing various interfaces such as a live broadcast interface, an information query interface and the like for users (such as a main broadcast user (a user signed on a live broadcast platform and responsible for live broadcast), a management user responsible for managing the live broadcast platform and the like); it may comprise at least one of: APP (Application), web page (e.g., web page running in a browser within the terminal device for presentation to the user for browsing, H5 web page, etc.), and so forth. The platform server is used for providing various services such as live broadcast service, information query service and the like for the user side so as to support the operation of the user side; it may include any of the following: web servers, application servers, data processing servers, and the like. With the increasing number of live broadcast platforms and anchor, anchor users and live broadcast platforms often involve the exchange of anchor resources in development; in order to enable each live broadcast platform to objectively and reasonably carry out anchor exchange, the embodiment of the application provides a data processing system based on a block chain network, and provides a data processing scheme based on a block chain based on the data processing system. The blockchain network is a network formed by blockchains and a point-to-point network; the blockchain is a novel application mode of computer technologies such as distributed data storage, point-to-point transmission, a consensus mechanism, an encryption algorithm and the like, is essentially a decentralized database, and is a string of data blocks (or called blocks) which are generated by using a cryptography method in a correlation manner; a block herein refers to a data structure for recording transaction data.
The data processing system based on the blockchain network provided by the embodiment of the application can comprise: ablock chain network 11,platform servers 12 of N live broadcast platforms agreeing to relevant protocols, andclients 13 corresponding to the N live broadcast platforms. Wherein, the value of N is a positive integer; relevant protocols may include, but are not limited to: anchor exchange protocols, anchor identity value evaluation protocols, and the like; the identity value of the anchor is the commercial value comprehensively judged based on factors such as the influence, income and activity of the anchor user on the live broadcast platform. Theblockchain network 11 may include a plurality of node devices (nodes for short); a node herein refers to an infrastructure device for data processing in a blockchain network, which may include, but is not limited to: smart terminals, tablets, desktop computers, servers, and the like. In one embodiment, theplatform server 12 of each live platform may be a server outside theblockchain network 11; the data processing system in this embodiment can be seen in fig. 1a, and theplatform server 12 of each live platform can communicate with nodes in theblockchain network 11. In another embodiment, theplatform server 12 of each live broadcast platform can be used as a node in theblockchain network 11; a data processing system according to this embodiment can be seen in fig. 1 b. It should be understood that FIG. 1b merely represents an exemplary architecture for a data processing system and is not intended to limit the particular architecture of the data processing system. For example, although theblockchain network 11 shown in fig. 1b includes not only theplatform servers 12 of the live platforms but also other node devices; in practice, however, only theplatform server 12 may be included in theblockchain network 11. For ease of illustration, the data processing system described hereinafter is illustrated as the data processing system shown in FIG. 1b, unless specifically indicated otherwise.
In a specific implementation, the data processing scheme proposed in the embodiment of the present application may be executed by any node in the block chain network shown in fig. 1 b. The main principle of this data processing scheme is as follows: first, platform servers of the N live broadcast platforms can upload anchor value information of anchor users on the respective platforms to a blockchain network in a blockchain manner, so that each node in the blockchain network can acquire the anchor value information of each anchor user on the N live broadcast platforms. The anchor value information herein may include, but is not limited to: attribute information of the anchor user and value evaluation data of the anchor user; wherein, the value evaluation data refers to relevant data influencing the judgment of the anchor value. Secondly, any node in the block chain network can adopt a unified value evaluation rule to evaluate the identity value of each anchor user uniformly according to the value evaluation data of each anchor user on the N live broadcast platforms respectively, and objective rationality and uniformity of value evaluation are guaranteed. Then, a value relation graph can be generated according to the identity value of each anchor user obtained through evaluation; the value relationship map is a corresponding relationship map generated based on the relationship between the identity values of the anchor users, and the corresponding relationship between the anchor users with the same identity value can be reflected through different dimensions, such as anchor with the same welcome potential, live broadcast with the same income potential, and the like. When a live broadcast platform wants to perform anchor exchange with other live broadcast platforms, an inquiry request can be sent to the blockchain network so as to call the value relation map from the blockchain network for balance judgment. Therefore, when the live broadcast platform has the data query requirement, the value evaluation data of each anchor user is not directly output to the live broadcast platform, but the value relation graph is presented to the live broadcast platform for viewing; therefore, exchange of anchor users with the same value can be realized under the condition of avoiding commercial data leakage, the objectivity and rationality of anchor exchange are improved, the flowing efficiency of resources in the live broadcast industry is promoted, and the effective utilization rate of the anchor resources in the live broadcast industry is improved.
Based on the description of the data processing scheme, the embodiment of the present application proposes a data processing method that can be performed by the first node in the above-mentioned blockchain network. The first node is any node in the block chain network; the system can be a platform server of any live broadcast platform, and can also be any node equipment except the platform server. Referring to fig. 2, the data processing method may include the following steps S201 to S204:
s201, acquiring anchor value information of a plurality of anchor users on a first live platform and a second live platform.
In the embodiment of the present application, two live broadcast platforms, namely a first live broadcast platform and a second live broadcast platform, are taken as an example for explanation, where the first live broadcast platform and the second live broadcast platform refer to any two live broadcast platforms that have agreed on a relevant protocol (e.g., a director exchange protocol, an identity value evaluation protocol of a director, etc.). The first live broadcast platform and the second live broadcast platform can store the original data of the anchor users on the respective platforms into the local storage space of the corresponding platform server, and extract the anchor value information of the respective anchor users from the original data of the respective anchor users; then, the anchor value information of each anchor user can be reported to the corresponding platform server, so that the corresponding platform server submits the anchor value information of each anchor user to the blockchain for storage. In an embodiment, if a first platform server corresponding to a first live broadcast platform and a second platform server corresponding to a second live broadcast platform are both nodes in a block chain network, the first platform server and the second platform server may generate corresponding blocks according to received anchor value information of an anchor user to store the anchor value information, and broadcast the generated blocks to other nodes in the block chain network to synchronize block chains within each node. In another embodiment, if the first platform server and the second platform server are servers outside the blockchain network, the first platform server and the second platform server may send the anchor value information of the anchor user on each live broadcast platform to a certain node in the blockchain network, so that the node generates a block according to the anchor value information of each anchor user, adds the generated block to the blockchain, and broadcasts the generated block to other nodes in the blockchain network, thereby implementing synchronization of the blockchain inside each node.
Correspondingly, when acquiring the anchor value information of a plurality of anchor users on the first live platform and the second live platform, the first node can extract the anchor value information of the plurality of anchor users on the first live platform and the second live platform from the block chain, wherein the anchor value information at least comprises attribute information and value evaluation data. In embodiments of the present application, the anchor value information of an anchor user may include at least attribute information and value assessment data. The attribute information of the anchor user may include at least one of: the identity identification of the anchor user and the platform identification of the live broadcast platform to which the anchor user belongs. The identity of the anchor user may include, but is not limited to: the name of the anchor user, the network nickname of the anchor user, the anchor account number (i.e., the anchor ID number) of the anchor user, the personal avatar of the anchor user, etc.; the platform identification of the live platform may include, but is not limited to: a platform name of the live platform, a platform icon of the live platform, and so on. The value assessment data of the anchor user may include at least one of: historical live broadcast duration, accumulated audience numbers, audience asset values obtained from audiences through live broadcast, audience comment numbers and user attention.
The historical live broadcast duration refers to the accumulated live broadcast duration of the anchor user on the live broadcast platform. The accumulated audience number is the sum of the audience numbers of each live broadcast from the live broadcast of the anchor user; for example, a certain anchor user on the first live platform broadcasts 3 total live programs, and the corresponding audience numbers are respectively: 1000, 2500 and 5000 persons; then the cumulative audience number for the anchor user is equal to 1000+2500+ 5000-85000 people. The audience asset value may be determined from a anchor type of an anchor user, which may generally include: show sponsors (e.g., a singing sponsor, a chat sponsor), game sponsors (e.g., a game commentary sponsor, a game playing sponsor), and the like, as well as e-commerce sponsors that sell items. If the anchor user is the entertainment anchor, the audience asset value refers to the total electronic resource value corresponding to the virtual gift received by the anchor user in the live broadcast process. For example, a certain anchor user on a first live platform receives 3 virtual gifts in total in the live process, and the corresponding electronic resources are respectively: 200, 100 and 150 yuan; the audience asset value for the anchor user is equal to 200+100+ 150-450 dollars. If the anchor user is the E-business anchor, the audience asset value refers to the bargain amount of all the articles sold by the anchor user through live broadcast; for example, a certain anchor user on a first live platform has sold a total through a historical live: 100 lipstick (unit price 200 yuan) and 50 bottles of foundation (unit price 350 yuan), the audience rating of the anchor user is equal to 100 x 200+50 x 350-37500 yuan. The audience comment number is the sum of the number of audience comments of each live broadcast from the live broadcast of the anchor user; for example, a certain anchor user on the first live platform broadcasts 3 scenes in total, and the corresponding audience comment numbers are respectively: 50, 100 and 150; the audience comment count for that anchor user is equal to 50+100+ 150-300. The user attention degree refers to the number of fans of the anchor user on the live broadcast platform; for example, if the number of fans of a certain anchor user on the live platform is 1500 ten thousand, the user attention of the anchor user is 1500 ten thousand.
S202, evaluating the value of each anchor user according to the value evaluation data of each anchor user to obtain the identity value of each anchor user.
After acquiring the anchor value information of a plurality of anchor users on the first live broadcast platform and the second live broadcast platform, the first node can evaluate the value of each anchor user from different value dimensions according to the value evaluation data of each anchor user, so that the identity value of each anchor user is obtained. Among other things, value dimensions may include, but are not limited to: an asset potential dimension and a heat potential dimension. Accordingly, the identity value of the anchor user may include at least one of: asset value in the asset potential dimension, and heat value in the heat potential dimension. The asset value may be used to reflect the ability of the anchor user to obtain assets from the audience via live broadcast, with a higher asset value of the anchor user indicating a greater ability of the anchor user to obtain assets from the audience via live broadcast. The popularity value can be used for reflecting the popularity of the anchor user, namely the popularity of the anchor user; the higher the popularity value of the anchor user, the higher the popularity of the anchor user, i.e., the more popular the anchor user is to the audience.
S203, grouping each anchor user according to the identity value of each anchor user to obtain the value group of each anchor user.
And S204, generating a value relation map by adopting the value group of each anchor user and the attribute information of each anchor user.
In steps S203-S204, after the first node estimates the identity value of each anchor user, the first node may perform grouping processing on each anchor user according to the identity value of each anchor user to obtain a value group of each anchor user. In a specific implementation, the first node may determine a grouping policy first; the grouping policy may be used to instruct the division of anchor users of the same value into a group in the same dimension; or dividing the anchor users with the values belonging to the same interval range into one group in the same dimension. Then, the first node can perform grouping processing on each anchor user according to the identity value of each anchor user under each dimension according to a grouping strategy to obtain the value group of each anchor user. Wherein the value group for each anchor user may include at least one of: a value group in the asset potential dimension, and a value group in the heat potential dimension. After obtaining the value groups of the anchor users, the first node can generate a value relation map by adopting the value groups of the anchor users and the attribute information of the anchor users; the value relationship graph includes at least one of: a value relationship map in an asset potential dimension, and a value relationship map in a heat potential dimension.
The following takes an example that the grouping policy is used to instruct that anchor users with values belonging to the same interval range are divided into one group in the same dimension, and a specific implementation process of steps S203-S204 is illustrated. Specifically, a platform identifier of a first live broadcast platform is set as a live broadcast platform 1, and a platform identifier of a second live broadcast platform is set as a live broadcast platform 2; and there are 9 anchor users in total on first live platform and the second live platform, and its corresponding identity value can be seen in table 1:
TABLE 1
Under the potential dimension of the assets, setting every 50 values to form an interval range; that is, the span range under the asset potential dimension may include: [0, 50), [50, 100) … [950, 1000), [1000, 1050) …. Since the asset value of anchor user a, the asset value of anchor user b, and the asset value of anchor user c fall within the same interval range [1000, 1050), anchor user a, anchor user b, and anchor user c may be divided into one group, whose value group in the asset potential dimension may be set to "asset potential a group". Similarly, anchor user d, anchor user e, anchor user f, anchor user g, anchor user h, and anchor user i may be divided into a group, and the value group in its asset potential dimension may be set as "asset potential B group". After the value groups of the anchor users in the asset potential dimension are obtained, a value relationship map in the asset potential dimension can be generated by using the value groups of the anchor users in the asset potential dimension and the attribute information of the anchor users, as shown in fig. 3 a.
Setting every 10 numerical values to form an interval range under the heat potential dimension; that is, the range of intervals in the heat potential dimension may include: [0, 10), [10, 20) … [80, 90), [90, 100) …. Since the popularity value of anchor user a, the popularity value of anchor user d, and the popularity value of anchor user h fall within the same interval range [90, 100 ], anchor user a, anchor user d, and anchor user h may be divided into one group, and their value groups in the popularity potential dimension may be set as "popularity potential a group". Similarly, anchor user B, anchor user c, anchor user e, anchor user f, anchor user g, and anchor user i may be divided into one group, and the value group in the hot potential dimension may be set as "hot potential B group". After the value groups of the anchor users in the popularity potential dimension are obtained, a value relationship graph in the popularity potential dimension can be generated by using the value groups of the anchor users in the popularity potential dimension and the attribute information of the anchor users, as shown in fig. 3 b. It should be noted that the style of the value relationship map in the embodiment of the present application is not limited to the style shown in fig. 3a, fig. 3b, and fig. 5 d. It may be a list or a graph.
According to the method and the device, the attribute information and the value evaluation data of a plurality of anchor users on a first live broadcast platform and a second live broadcast platform can be obtained by a first node in a block chain network, and the value evaluation is performed on each anchor user according to the value evaluation data of each anchor user to obtain the identity value of each anchor user; therefore, the unified judgment of the anchor value is realized, the objectivity of value judgment is improved, and the malicious tampering of the identity value of each anchor user is prevented. The first node equipment can also perform grouping processing on each anchor user according to the identity value of each anchor user to obtain the value group of each anchor user; and generating a value relation map by adopting the value group of each anchor user and the attribute information of each anchor user. By generating the value relation map, the value relation map can be presented to the live broadcast platform as a reference when the live broadcast platform has the anchor exchange requirement; under the condition of avoiding commercial data (such as value evaluation data of all anchor users counted by the live broadcast platform) from being leaked, the anchor users with the same value can be exchanged among the live broadcast platforms; and then the objectivity and rationality of anchor exchange are realized, the flowing efficiency of assets in the live broadcast industry is promoted, and the effective utilization rate of the anchor assets in the live broadcast industry is improved.
Please refer to fig. 4, which is a flowchart illustrating another data processing method according to an embodiment of the present application. The data processing method may be performed by a first node in the above-mentioned blockchain network. Referring to fig. 4, the data processing method may include the following steps S401 to S406:
s401, acquiring anchor value information of a plurality of anchor users on a first live broadcast platform and a second live broadcast platform. The anchor value information of the plurality of anchor users is acquired from a blockchain in the first node, and the anchor value information at least comprises attribute information and value evaluation data.
Before executing step S401, if the first node receives the anchor value information of at least one anchor user that is broadcast by the first direct broadcast platform, it may check whether the first direct broadcast platform has a broadcast authority, where when the first node is a first platform server corresponding to the first direct broadcast platform, the first direct broadcast platform may directly broadcast the anchor value information to the first node, that is, the first node may directly receive the anchor value information broadcast by the first direct broadcast platform, when the first node is not the first platform server, the first direct broadcast platform may broadcast the anchor value information to the first node through the first platform server, that is, the first node may receive the anchor value information broadcast by the first direct broadcast platform through the first platform server, if the first direct broadcast platform has the broadcast authority, the first node may generate a first block carrying the anchor value information broadcast by the first direct broadcast platform, after generating the first block, the first node may add the first block to the first direct broadcast platform, and send the first broadcast value information to other broadcast nodes in the first direct broadcast platform in a network block- ④ manner, where the first node generates a first block including a first node block 85information block, where:
① the first node verifies the anchor value information reported by the first broadcast platform, after the verification is passed, the anchor value information reported by the first broadcast platform can be added to the block body of the first block, as shown in fig. 5 a. ② the first node hashes the anchor value information in the block body with Merkle Tree algorithm (Merkle Tree algorithm) to obtain Merkle hash value. ③ generates a random number with random algorithm, and uses the computed Merkle hash value, random number, version number, last block hash value, current time stamp and current difficulty value to form the block head of the first block, wherein the version number is version information of related block protocol in the block chain, the last block hash value is a feature value of the block head of the last block, the current time stamp is a system time when the block head is formed, the current difficulty value is a difficulty value calculated, the difficulty value is a fixed value in a fixed time period, and when the hash value exceeds the fixed time period, the hash value is determined again, the first time stamp is a system time when the block head is formed into a block head, the first block head is determined to be valid, if the first block head is a small block, the first block is generated by using the hash value of the hash algorithm, ④, the hash value is determined to be a target value, the first hash value of the hash value is determined.
After the anchor value information reported by the first direct broadcasting platform is disclosed, all anchor users on the first direct broadcasting platform can check the anchor value information in the block chain network. If errors (such as data errors or data omission) exist in the anchor value information of the first direct broadcasting platform, objections can be made to the first direct broadcasting platform; in this case, the first direct broadcasting platform may verify the anchor value information of the objecting anchor user, and may report the supplementary value information to the first node if it is determined that the anchor value information of the objecting anchor user has an error; the supplemental value information may carry the address location of the first block (e.g., block height, block hash value, etc.). By adding the address position of the first block in the supplementary value information, the supplementary value information and the anchor value information in the first block can be associated, so that when a value relation map is generated subsequently, the supplementary value information can be adopted to supplement the anchor value information in the first block. In particular implementations, the supplemental value information can include at least one of: newly added value information and corrected value information; the new value information is used for performing information supplement on the anchor value information extracted from the first block, and the correction value information is used for performing information correction on the anchor value information extracted from the first block.
Correspondingly, if the first node receives the supplemental value information reported by the first direct broadcasting platform, validity verification is carried out on the supplemental value information. Specifically, each time the first direct broadcasting platform submits information, the submitted information needs to be signed by adopting a certificate signature; thus, the anchor value information reported by the first direct broadcast platform may carry historical certificate signatures and the supplemental value information may carry supplemental certificate signatures. Then the specific implementation of validity check on the supplemental value information may be: verifying whether the historical certificate signature and the supplementary certificate signature are consistent; if the supplementary value information is consistent with the supplementary value information, determining that the supplementary value information is valid; otherwise, the supplemental value information is determined to be invalid. If the supplementary value information is valid, the first node can generate a supplementary block carrying the supplementary value information; and adding the supplementary blocks to the blockchain and broadcasting the supplementary blocks to other nodes in the blockchain network. If the supplemental value information is invalid, the first node may ignore the supplemental value information. Optionally, the first node may further output an invalidation notification to the first direct-broadcast platform to notify the first direct-broadcast platform that the supplemental value information is invalid.
Before executing step S401, the first node may further receive anchor value information of at least one anchor user reported by the second live broadcast platform, generate a corresponding block according to the anchor value information reported by the second live broadcast platform, and add the generated corresponding block to the block chain; and broadcasting the generated corresponding block to other nodes in the block chain network so as to disclose the anchor value information reported by the second live broadcast platform. In practical application, the second live broadcast platform can also report the anchor value information of the anchor user on the second live broadcast platform to a second node in the block network directly or through a second platform server, so that the second node generates a second block according to the anchor value information of the anchor user reported by the second live broadcast platform; the second node here is any node in the blockchain network other than the first node. In this case, the first node may receive a second block broadcast by a second node in the blockchain network and add the second block to the blockchain; the second block is generated by the second node according to the anchor value information of the anchor user reported by the second live broadcast platform.
S402, evaluating the value of each anchor user according to the value evaluation data of each anchor user to obtain the identity value of each anchor user.
In an embodiment of the present application, the value assessment data comprises at least one of: the method comprises the steps of historical live broadcast time length H, accumulated audience number M, audience asset value R obtained from audiences through live broadcast, audience comment number C and user attention D. Because the embodiment of the application adopts a uniform value evaluation mode to evaluate the value of each anchor user, the evaluation modes of the identity value of each anchor user are the same. Based on this, the multiple anchor users are set to include the target anchor user in the embodiment of the application, and the target anchor user is any anchor user in the multiple anchor users; the specific implementation of step S402 is described by taking the target anchor user as an example.
If the identity value of the target anchor user includes an asset value in an asset potential dimension, then embodiments of step S402 may include any of:
the first implementation mode comprises the following steps: the asset value of the target anchor user in a unit time may be taken as the asset value of the target anchor user in the asset potential dimension. Specifically, the ratio between the audience asset value R of the target anchor user and the historical live broadcast duration H of the target anchor user can be determined, and the asset value of the target anchor user in the asset potential dimension is obtained. That is, the asset value of the target anchor user in the asset potential dimension under this embodiment is equal to R/H.
The second embodiment: the asset value of the target anchor user in a unit audience number may be taken as the asset value of the target anchor user in an asset potential dimension. Specifically, a ratio between the audience asset value R of the target anchor user and the cumulative audience count M of the target anchor user may be determined to obtain an asset value of the target anchor user in an asset potential dimension. That is, the asset value of the target anchor user in the asset potential dimension under this embodiment is equal to R/M.
The third embodiment is as follows: the asset value of the target anchor user in a unit time and a unit audience count may be taken as the asset value of the target anchor user in an asset potential dimension. Specifically, the ratio of the audience asset value R of the target anchor user, the historical live broadcast duration H of the target anchor user, and the accumulated audience number M of the target anchor user may be determined, so as to obtain the asset value of the target anchor user in the asset potential dimension. That is, the asset value of the target anchor user in the asset potential dimension in this embodiment is equal to R/H/M or R/M/H.
(ii) if the identity value of the target anchor user includes a popularity value in the popularity potential dimension, the specific implementation of step S402 may include any one of the following:
the first implementation mode comprises the following steps: the audience number of the target anchor user in a unit time can be used as the popularity value of the target anchor user in the popularity potential dimension. Specifically, a first ratio between the accumulated viewer number M of the target anchor user and the historical live broadcast duration H of the target anchor user can be determined, and the popularity value of the target anchor user in the popularity potential dimension is obtained. Namely, the heat value of the target anchor user in the heat potential dimension is equal to M/H.
The second embodiment: the audience comment number of the target anchor user in unit time can be used as the popularity value of the target anchor user in the popularity potential dimension. Specifically, a second ratio between the audience comment number C of the target anchor user and the historical live broadcast duration H of the target anchor user can be determined, and the popularity value of the target anchor user in the popularity potential dimension is obtained. Namely, the heat value of the target anchor user in the heat potential dimension under the embodiment is equal to C/H.
The third embodiment is as follows: the user attention of the target anchor user in unit time can be used as the heat value of the target anchor user in the heat potential dimension. Specifically, a third ratio between the user attention D of the target anchor user and the historical live broadcast duration H of the target anchor user can be determined, and the popularity value of the target anchor user in the popularity potential dimension is obtained. Namely, the heat value of the target anchor user in the heat potential dimension is equal to D/H.
The fourth embodiment: the sum of the audience number, audience comment number and user attention of the target anchor user in unit time can be used as the popularity value of the target anchor user in the popularity potential dimension. Specifically, a first ratio, a second ratio and a third ratio of the target anchor user can be determined; and summing the first ratio, the second ratio and the third ratio to obtain the heat value of the target anchor user in the heat potential dimension. Namely, the heat value of the target anchor user in the heat potential dimension is equal to (M/H + C/H + D/H) in the embodiment.
It should be noted that, if there is associated supplemental value information in the anchor value information reported by the first anchor platform, the supplemental value information is reported by the first anchor platform when it is verified that there is an error in the anchor value information reported by the first anchor platform in response to an objection request sent by any anchor user; and the supplemental value information is used for performing supplemental processing on the anchor value information extracted from the first block. The first node needs to extract the supplemental value information from the supplemental blocks of the block chain and perform supplemental processing (such as information supplement and information correction processing) on the anchor value information extracted from the first block by using the supplemental value information before performing step S402. In this case, when the first node executes step S402, the first node may perform value evaluation on each anchor user according to the value evaluation data in the anchor value information after the supplementation processing, so as to obtain the identity value of each anchor user.
And S403, grouping each anchor user according to the identity value of each anchor user to obtain the value group of each anchor user.
S404, generating a value relation map by adopting the value groups of the anchor users and the attribute information of the anchor users.
It should be noted that, for specific implementation of steps S403 to S404, reference may be made to the specific implementation of steps S203 to S204 in the above application example, and details are not described here again. It should be understood that the embodiment of the present application is illustrated by taking two value dimensions, namely a heat potential dimension and an asset potential dimension as examples; for the popularity potential dimension and the asset potential dimension, value evaluation data (such as accumulated viewer numbers, historical live broadcast duration and the like) of the anchor user are directly extracted from all original data of the anchor user from broadcast. However, with the development of actual services, when the subsequent live broadcast platform reports the anchor value information, the subsequent live broadcast platform may adopt a uniform data format to extract the original data of each anchor user, so as to extract the relevant anchor data (such as the live broadcast duration of approximately 2 months, the asset value of approximately 2 months, the number of comments of approximately 2 months, etc.) in a preset time period as the value evaluation data of the anchor user. In this case, the first node may also generate a value relationship graph in other value dimensions, such as a value relationship graph in a development potential dimension. Specifically, the development value of each anchor user may be obtained according to the evaluation of the related anchor data within the preset time period, and the development value may include but is not limited to: a viewer growth rate over a preset time period, a review growth rate over a preset time period, an asset growth rate over a preset time period, a focus growth rate over a preset time period, and the like. Based on the development values of the anchor users, a value relationship graph under the development potential dimension can be generated. Therefore, the value relation graph formed based on different value evaluation data can be continuously updated and changed according to the development condition of the actual service, and therefore the identity value comparison and the transaction signing appeal of the anchor user under multiple dimensions are met.
S405, in response to the query request sent by the first direct broadcasting platform, checking whether the first direct broadcasting platform has the query authority.
S406, if the first direct playing platform has the inquiry authority, the value relation map is sent to the first direct playing platform.
In steps S405-S406, when any user (e.g., an anchor user or an administrative user) on the first live platform has a query requirement, a query request may be sent to the first node through a user side corresponding to the first live platform, as shown in fig. 5 b. If the first node is a first platform server corresponding to the first direct broadcasting platform, the user side corresponding to the first direct broadcasting platform can directly send a query request to the first node; if the first node is not the first platform server, the client corresponding to the first direct playing platform can send a query request to the first node through the first platform server. Because the embodiment of the application aims to avoid commercial data leakage, the information query is only carried out on the live broadcast platform which agrees with the relevant protocol and uploads the anchor value information. Based on the method, the first node can respond to the query request sent by the first direct-broadcasting platform and check whether the first direct-broadcasting platform has the query authority. If the first direct-playing platform has the inquiry authority, the value relation map can be sent to the first direct-playing platform, so that the first direct-playing platform displays the value relation map in the user interface. It should be understood that the first node may also receive a query request from the second live platform; if receiving the inquiry request sent by the second live broadcast platform, the second live broadcast platform can be checked whether to have the inquiry authority. And if the second live broadcast platform has the inquiry authority, sending the value relation map to the second live broadcast platform so that the second live broadcast platform displays the value relation map in the user interface.
In one embodiment, the first node may further determine a first anchor user from the first live platform according to the value relationship graph, and determine a second anchor user from the second live platform according to the value relationship graph; the value group of the first anchor user is the same as the value group of the second anchor user. Secondly, generating an anchor exchange prompt according to the attribute information of the first anchor user and the attribute information of the second anchor user; the anchor exchange cue is for prompting that the first anchor user and the second anchor user can be exchanged between the first live platform and the second live platform. A director exchange cue may then be sent to the first live platform and the second live platform. By outputting a cue of anchor exchange to the first live broadcast platform and the second live broadcast platform, anchor exchange between the two live broadcast platforms can be facilitated timely and conveniently; therefore, the flowing efficiency of the assets in the live broadcast industry is promoted, and the effective utilization rate of the anchor assets in the live broadcast industry is improved.
According to the method and the device, the attribute information and the value evaluation data of a plurality of anchor users on a first live broadcast platform and a second live broadcast platform can be obtained by a first node in a block chain network, and the value evaluation is performed on each anchor user according to the value evaluation data of each anchor user to obtain the identity value of each anchor user; therefore, the unified judgment of the anchor value is realized, the objectivity of value judgment is improved, and the malicious tampering of the identity value of each anchor user is prevented. The first node equipment can also perform grouping processing on each anchor user according to the identity value of each anchor user to obtain the value group of each anchor user; and generating a value relation map by adopting the value group of each anchor user and the attribute information of each anchor user. By generating the value relation map, the value relation map can be presented to the live broadcast platform as a reference when the live broadcast platform has the anchor exchange requirement; under the condition of avoiding commercial data (such as value evaluation data of all anchor users counted by the live broadcast platform) from being leaked, the anchor users with the same value can be exchanged among the live broadcast platforms; and then the objectivity and rationality of anchor exchange are realized, the flowing efficiency of assets in the live broadcast industry is promoted, and the effective utilization rate of the anchor assets in the live broadcast industry is improved.
It should be understood that the above mentioned application embodiments are described by taking two live broadcast platforms (i.e. a first live broadcast platform and a second live broadcast platform) as an example; however, in practical applications, the number of live platforms may not be limited to two. That is to say, the data processing method provided by the present application is not limited to being applied to application scenarios of two live broadcast platforms, but can also be applied to application scenarios of 3 live broadcast platforms, 4 live broadcast platforms, or even more live broadcast platforms. The data processing method provided by the embodiment of the present application is described below by taking an application scenario in which the data processing method is applied to 4 live broadcast platforms as an example:
as shown in fig. 5C, after the a live broadcast platform, the B live broadcast platform, the C live broadcast platform, and the D live broadcast platform agree with the relevant protocols (e.g., anchor exchange protocol, and evaluation protocol of identity value of anchor), anchor value information of anchor users on the respective live broadcast platforms may be synchronized to the blockchain for storage. A first node (any node) in the blockchain network can acquire the anchor value information of anchor users on the 4 live broadcast platforms from the blockchain, wherein the anchor value information at least comprises attribute information and value evaluation data; and evaluating the value of each anchor user according to the value evaluation data of each anchor user to obtain the identity value of each anchor user, wherein the identity value comprises at least one of the following items: asset value in the asset potential dimension, and heat value in the heat potential dimension. Secondly, grouping each anchor user according to the identity value of each anchor user under each dimension according to a grouping strategy to obtain the value group of each anchor user; the value group for each anchor user includes at least one of: a value group in the asset potential dimension, and a value group in the heat potential dimension. Then, a value relationship map in an asset potential dimension and a value relationship map in a popularity potential dimension can be generated by using the value groups of the anchor users and the attribute information of the anchor users.
After the value relationship maps in the value dimensions are generated, any user (such as a main broadcasting user or a management user) on the 4 live broadcasting platforms can view the value relationship maps in different value dimensions through the user side of the live broadcasting platform. Specifically, the user can switch the value relationship maps in different value dimensions through the navigation icon on the value relationship map, as shown in fig. 5 d. The management user of any one of the 4 live broadcast platforms can select to sign on the anchor user on the other live broadcast platform according to the value relation maps under different value dimensions, or the anchor user of the own live broadcast platform and the other live broadcast platform can carry out anchor exchange with equal value or different value. Optionally, any anchor user on the 4 live broadcast platforms may also actively initiate an anchor exchange intention to the live broadcast platform to which the anchor user belongs; accordingly, the live broadcast platform receiving the anchor exchange intention can exchange the anchor user with the anchor users of other platforms according to the anchor exchange intention initiated by any anchor user.
According to the method and the device, the attribute information and the value evaluation data of each anchor user on a plurality of live broadcast platforms can be acquired by a first node in a block chain network, and the value evaluation is performed on each anchor user according to the value evaluation data of each anchor user to obtain the identity value of each anchor user; therefore, the unified judgment of the anchor value is realized, the objectivity of value judgment is improved, and the malicious tampering of the identity value of each anchor user is prevented. The first node equipment can also perform grouping processing on each anchor user according to the identity value of each anchor user to obtain the value group of each anchor user; and generating a value relation map by adopting the value group of each anchor user and the attribute information of each anchor user. By generating the value relation map, the value relation map can be presented to the live broadcast platform as a reference when the live broadcast platform has the anchor exchange requirement; under the condition of avoiding commercial data (such as value evaluation data of all anchor users counted by the live broadcast platform) from being leaked, the anchor users with the same value can be exchanged among the live broadcast platforms; and then the objectivity and rationality of anchor exchange are realized, the flowing efficiency of assets in the live broadcast industry is promoted, and the effective utilization rate of the anchor assets in the live broadcast industry is improved.
Based on the description of the above data processing method embodiment, the embodiment of the present invention further discloses a data processing apparatus, which may be a computer program (including a program code) running in a first node in a blockchain network; the first node is any node in the blockchain network. The data processing apparatus may perform the method shown in fig. 2 or fig. 4. Referring to fig. 6, the data processing apparatus may operate the following units:
an obtainingunit 101, configured to obtain anchor value information of multiple anchor users on a first live platform and a second live platform, where the anchor value information at least includes attribute information and value evaluation data;
theprocessing unit 102 is configured to perform value evaluation on each anchor user according to value evaluation data of each anchor user to obtain an identity value of each anchor user;
theprocessing unit 102 is configured to perform grouping processing on each anchor user according to the identity value of each anchor user to obtain a value group of each anchor user;
theprocessing unit 102 is configured to generate a value relationship map by using the value groups of the anchor users and the attribute information of the anchor users.
In one embodiment, the attribute information includes at least one of: the identity identification of the anchor user and the platform identification of the live broadcast platform to which the anchor user belongs; the value assessment data includes at least one of: historical live broadcast time length, accumulated audience numbers, audience asset values, audience comment numbers and user attention degrees, which are obtained from audiences through live broadcast; the identity value comprises at least one of: asset value in the asset potential dimension, and heat value in the heat potential dimension.
In yet another embodiment, the plurality of anchor users includes a target anchor user, the target anchor user being any one of the plurality of anchor users; the identity value of the target anchor user comprises an asset value in the asset potential dimension; correspondingly, when theprocessing unit 102 is configured to perform value evaluation on each anchor user according to the value evaluation data of each anchor user to obtain the identity value of each anchor user, specifically: determining a ratio between the audience asset value of the target anchor user and the historical live broadcast duration of the target anchor user to obtain an asset value of the target anchor user in the asset potential dimension; or determining a ratio between the audience asset value of the target anchor user and the accumulated audience number of the target anchor user to obtain an asset value of the target anchor user in the asset potential dimension; or determining a ratio among the audience asset value of the target anchor user, the historical live broadcast duration of the target anchor user and the accumulated audience number of the target anchor user to obtain the asset value of the target anchor user in the asset potential dimension.
In yet another embodiment, the plurality of anchor users includes a target anchor user, the target anchor user being any one of the plurality of anchor users; the identity value of the anchor user comprises a heat value under a heat potential dimension; correspondingly, when the processing unit 102 is configured to perform value evaluation on each anchor user according to the value evaluation data of each anchor user to obtain the identity value of each anchor user, specifically: determining a first ratio between the accumulated audience number of the target anchor user and the historical live broadcast duration of the target anchor user to obtain a popularity value of the target anchor user in the popularity potential dimension; or determining a second ratio between the audience comment number of the target anchor user and the historical live broadcast duration of the target anchor user to obtain the popularity value of the target anchor user in the popularity potential dimension; or determining a third ratio between the user attention of the target anchor user and the historical live broadcast duration of the target anchor user to obtain the heat value of the target anchor user in the heat potential dimension; or, determining the first ratio, the second ratio, and the third ratio of the target anchor user; and summing the first ratio, the second ratio and the third ratio to obtain the heat value of the target anchor user in the heat potential dimension.
In another embodiment, when theprocessing unit 102 is configured to perform grouping processing on each anchor user according to the identity value of each anchor user to obtain a value group of each anchor user, the processing unit is specifically configured to: determining a grouping strategy, wherein the grouping strategy is used for indicating that anchor users with the same value are divided into a group under the same dimension; or dividing anchor users with values belonging to the same interval range into a group in the same dimension; grouping each anchor user according to the grouping strategy and the identity value of each anchor user under each dimension to obtain a value group of each anchor user; wherein the value groups of the respective anchor users include at least one of: a value group in the asset potential dimension and a value group in the heat potential dimension; the value relationship graph includes at least one of: a value relationship map in the asset potential dimension, and a value relationship map in the heat potential dimension.
In yet another embodiment, the anchor value information for the plurality of anchor users is obtained from a blockchain within the first node; theprocessing unit 102 may also be configured to: if receiving the anchor value information of at least one anchor user reported by a first direct broadcasting platform, verifying whether the first direct broadcasting platform has the reporting authority; if the first direct broadcasting platform has the broadcasting authority, generating a first block carrying the main broadcasting value information broadcasted by the first direct broadcasting platform; adding the first block to the block chain and broadcasting the first block to other nodes in the block chain network; the other node is a node other than the first node in the blockchain network.
In yet another embodiment, theprocessing unit 102 is further configured to: receiving a second block broadcasted by a second node in the block chain network, wherein the second block is generated by the second node according to the anchor value information of the anchor user reported by a second live broadcast platform; the second node is any node in the blockchain network other than the first node; adding the second block to the chain of blocks.
In yet another embodiment, theprocessing unit 102 is further configured to: if receiving the supplementary value information reported by the first direct broadcasting platform, carrying out validity check on the supplementary value information; the supplementary value information carries the address position of the first block, and is used for supplementing the anchor value information extracted from the first block; if the supplementary value information is valid, generating a supplementary block carrying the supplementary value information; adding the supplementary blocks to the block chain and broadcasting the supplementary blocks to other nodes in the block chain network.
In another embodiment, the anchor value information reported by the first direct broadcast platform carries a history certificate signature, and the supplementary value information carries a supplementary certificate signature; correspondingly, when theprocessing unit 102 is configured to perform validity check on the supplemental value information, the processing unit is specifically configured to: verifying whether the historical certificate signature and the supplementary certificate signature are consistent; if the supplementary value information is consistent with the supplementary value information, determining that the supplementary value information is valid; otherwise, determining that the supplemental value information is invalid.
In yet another embodiment, the supplemental value information is reported by the first on-demand platform upon verifying that there is an error in the on-demand value information reported by the first on-demand platform in response to an objection request sent by any one of the on-demand users; wherein the supplemental value information comprises at least one of: newly added value information and corrected value information; the new value information is used for performing information supplement on the anchor value information extracted from the first block, and the correction value information is used for performing information correction on the anchor value information extracted from the first block.
In yet another embodiment, theprocessing unit 102 is further configured to: responding to a query request sent by the first direct broadcasting platform, and verifying whether the first direct broadcasting platform has query authority; and if the first direct-playing platform has the query authority, sending the value relation map to the first direct-playing platform so that the first direct-playing platform displays the value relation map in a user interface.
In yet another embodiment, theprocessing unit 102 is further configured to: determining a first anchor user from the first live broadcast platform according to the value relation map, and determining a second anchor user from the second live broadcast platform according to the value relation map; the value group of the first anchor user is the same as the value group of the second anchor user; generating an anchor exchange prompt according to the attribute information of the first anchor user and the attribute information of the second anchor user, wherein the anchor exchange prompt is used for prompting that the first anchor user and the second anchor user can be exchanged between the first direct broadcast platform and the second direct broadcast platform; and sending a main broadcasting exchange prompt to the first live broadcasting platform and the second live broadcasting platform.
According to an embodiment of the present invention, the steps involved in the method shown in fig. 2 or fig. 4 may be performed by units in the data processing apparatus shown in fig. 6. For example, step S201 shown in fig. 2 may be performed by theacquisition unit 101 shown in fig. 6, and steps S202 to S204 may be performed by theprocessing unit 102 shown in fig. 6; as another example, step S401 shown in fig. 4 may be performed by theacquisition unit 101 shown in fig. 6, and steps S402-S406 may be performed by theprocessing unit 102 shown in fig. 6. According to another embodiment of the present invention, the units in the data processing apparatus shown in fig. 6 may be respectively or entirely combined into one or several other units to form one or several other units, or some unit(s) therein may be further split into multiple units with smaller functions to form the same operation, without affecting the achievement of the technical effect of the embodiment of the present invention. The units are divided based on logic functions, and in practical application, the functions of one unit can be realized by a plurality of units, or the functions of a plurality of units can be realized by one unit. In other embodiments of the present invention, the data processing apparatus may also include other units, and in practical applications, these functions may also be implemented by being assisted by other units, and may be implemented by cooperation of a plurality of units.
According to another embodiment of the present invention, the data processing apparatus device as shown in fig. 6 may be constructed by running a computer program (including program codes) capable of executing the steps involved in the respective methods as shown in fig. 2 or fig. 4 on a general-purpose computing device such as a computer including a processing element such as a Central Processing Unit (CPU), a random access storage medium (RAM), a read-only storage medium (ROM), and a storage element, and a data processing method according to an embodiment of the present invention may be implemented. The computer program may be recorded on a computer-readable recording medium, for example, and loaded and executed in the above-described computing apparatus via the computer-readable recording medium.
According to the method and the device, the attribute information and the value evaluation data of a plurality of anchor users on a first live broadcast platform and a second live broadcast platform can be obtained by a first node in a block chain network, and the value evaluation is performed on each anchor user according to the value evaluation data of each anchor user to obtain the identity value of each anchor user; therefore, the unified judgment of the anchor value is realized, the objectivity of value judgment is improved, and the malicious tampering of the identity value of each anchor user is prevented. The first node equipment can also perform grouping processing on each anchor user according to the identity value of each anchor user to obtain the value group of each anchor user; and generating a value relation map by adopting the value group of each anchor user and the attribute information of each anchor user. By generating the value relation map, the value relation map can be presented to the live broadcast platform as a reference when the live broadcast platform has the anchor exchange requirement; under the condition of avoiding commercial data (such as value evaluation data of all anchor users counted by the live broadcast platform) from being leaked, the anchor users with the same value can be exchanged among the live broadcast platforms; and then the objectivity and rationality of anchor exchange are realized, the flow efficiency of resources in the live broadcast industry is promoted, and the effective utilization rate of anchor resources in the live broadcast industry is improved.
Based on the description of the method embodiment and the apparatus embodiment, an embodiment of the present invention further provides a node device, where the node device is a first node in the above-mentioned block chain network. Referring to fig. 7, the node device includes at least aprocessor 201, aninput interface 202, anoutput interface 203, and acomputer storage medium 204. Theprocessor 201, theinput interface 202, theoutput interface 203, and thecomputer storage medium 204 in the terminal may be connected by a bus or other means.
Acomputer storage medium 204 may be stored in the memory of the node device, saidcomputer storage medium 204 being adapted to store a computer program comprising program instructions, saidprocessor 201 being adapted to execute the program instructions stored by saidcomputer storage medium 204. The processor 201 (or CPU) is a computing core and a control core of the node device, and is adapted to implement one or more instructions, and in particular, is adapted to load and execute the one or more instructions so as to implement a corresponding method flow or a corresponding function; in one embodiment, theprocessor 201 according to the embodiment of the present invention may be configured to perform a series of data processing, including: acquiring anchor value information of a plurality of anchor users on a first live broadcast platform and a second live broadcast platform, wherein the anchor value information at least comprises attribute information and value evaluation data; performing value evaluation on each anchor user according to the value evaluation data of each anchor user to obtain the identity value of each anchor user; grouping each anchor user according to the identity value of each anchor user to obtain a value group of each anchor user; and generating a value relation map by adopting the value groups of the anchor users and the attribute information of the anchor users, and the like.
An embodiment of the present invention further provides a computer storage medium (Memory), which is a Memory device in the node device and is used to store programs and data. It is understood that the computer storage medium herein may include both a built-in storage medium in the node device and, of course, an extended storage medium supported by the node device. The computer storage medium provides a storage space that stores an operating system of the node device. Also stored in this memory space are one or more instructions, which may be one or more computer programs (including program code), suitable for loading and execution byprocessor 201. The computer storage medium may be a high-speed RAM memory, or may be a non-volatile memory (non-volatile memory), such as at least one disk memory; and optionally at least one computer storage medium located remotely from the processor.
In one embodiment, one or more instructions stored in a computer storage medium may be loaded and executed byprocessor 201 to perform the corresponding steps of the methods described above in connection with the data processing embodiments; in particular implementations, one or more instructions in the computer storage medium are loaded byprocessor 201 and perform the following steps:
acquiring anchor value information of a plurality of anchor users on a first live broadcast platform and a second live broadcast platform, wherein the anchor value information at least comprises attribute information and value evaluation data;
performing value evaluation on each anchor user according to the value evaluation data of each anchor user to obtain the identity value of each anchor user;
grouping each anchor user according to the identity value of each anchor user to obtain a value group of each anchor user;
and generating a value relation map by adopting the value group of each anchor user and the attribute information of each anchor user.
In one embodiment, the attribute information includes at least one of: the identity identification of the anchor user and the platform identification of the live broadcast platform to which the anchor user belongs; the value assessment data includes at least one of: historical live broadcast time length, accumulated audience numbers, audience asset values, audience comment numbers and user attention degrees, which are obtained from audiences through live broadcast; the identity value comprises at least one of: asset value in the asset potential dimension, and heat value in the heat potential dimension.
In yet another embodiment, the plurality of anchor users includes a target anchor user, the target anchor user being any one of the plurality of anchor users; the identity value of the target anchor user comprises an asset value in the asset potential dimension; correspondingly, when the value evaluation is performed on each anchor user according to the value evaluation data of each anchor user to obtain the identity value of each anchor user, the one or more instructions are loaded and specifically executed by the processor 201: determining a ratio between the audience asset value of the target anchor user and the historical live broadcast duration of the target anchor user to obtain an asset value of the target anchor user in the asset potential dimension; or determining a ratio between the audience asset value of the target anchor user and the accumulated audience number of the target anchor user to obtain an asset value of the target anchor user in the asset potential dimension; or determining a ratio among the audience asset value of the target anchor user, the historical live broadcast duration of the target anchor user and the accumulated audience number of the target anchor user to obtain the asset value of the target anchor user in the asset potential dimension.
In yet another embodiment, the plurality of anchor users includes a target anchor user, the target anchor user being any one of the plurality of anchor users; the identity value of the anchor user comprises a heat value under a heat potential dimension; correspondingly, when the value evaluation is performed on each anchor user according to the value evaluation data of each anchor user to obtain the identity value of each anchor user, the one or more instructions are loaded and specifically executed by the processor 201: determining a first ratio between the accumulated audience number of the target anchor user and the historical live broadcast duration of the target anchor user to obtain a popularity value of the target anchor user in the popularity potential dimension; or determining a second ratio between the audience comment number of the target anchor user and the historical live broadcast duration of the target anchor user to obtain the popularity value of the target anchor user in the popularity potential dimension; or determining a third ratio between the user attention of the target anchor user and the historical live broadcast duration of the target anchor user to obtain the heat value of the target anchor user in the heat potential dimension; or, determining the first ratio, the second ratio, and the third ratio of the target anchor user; and summing the first ratio, the second ratio and the third ratio to obtain the heat value of the target anchor user in the heat potential dimension.
In another embodiment, when the anchor users are grouped according to the identity values of the anchor users to obtain the value groups of the anchor users, the one or more instructions are loaded and specifically executed by the processor 201: determining a grouping strategy, wherein the grouping strategy is used for indicating that anchor users with the same value are divided into a group under the same dimension; or dividing anchor users with values belonging to the same interval range into a group in the same dimension; grouping each anchor user according to the grouping strategy and the identity value of each anchor user under each dimension to obtain a value group of each anchor user; wherein the value groups of the respective anchor users include at least one of: a value group in the asset potential dimension and a value group in the heat potential dimension; the value relationship graph includes at least one of: a value relationship map in the asset potential dimension, and a value relationship map in the heat potential dimension.
In yet another embodiment, the anchor value information for the plurality of anchor users is obtained from a blockchain within the first node; the one or more instructions may also be loaded and specifically executed by processor 201: if receiving the anchor value information of at least one anchor user reported by a first direct broadcasting platform, verifying whether the first direct broadcasting platform has the reporting authority; if the first direct broadcasting platform has the broadcasting authority, generating a first block carrying the main broadcasting value information broadcasted by the first direct broadcasting platform; adding the first block to the block chain and broadcasting the first block to other nodes in the block chain network; the other node is a node other than the first node in the blockchain network.
In yet another embodiment, the one or more instructions may be further loaded and specifically executed by the processor 201: receiving a second block broadcasted by a second node in the block chain network, wherein the second block is generated by the second node according to the anchor value information of the anchor user reported by a second live broadcast platform; the second node is any node in the blockchain network other than the first node; adding the second block to the chain of blocks.
In yet another embodiment, the one or more instructions may be further loaded and specifically executed by the processor 201: if receiving the supplementary value information reported by the first direct broadcasting platform, carrying out validity check on the supplementary value information; the supplementary value information carries the address position of the first block, and is used for supplementing the anchor value information extracted from the first block; if the supplementary value information is valid, generating a supplementary block carrying the supplementary value information; adding the supplementary blocks to the block chain and broadcasting the supplementary blocks to other nodes in the block chain network.
In another embodiment, the anchor value information reported by the first direct broadcast platform carries a history certificate signature, and the supplementary value information carries a supplementary certificate signature; correspondingly, when the validity of the supplemental value information is checked, the one or more instructions are loaded and specifically executed by the processor 201: verifying whether the historical certificate signature and the supplementary certificate signature are consistent; if the supplementary value information is consistent with the supplementary value information, determining that the supplementary value information is valid; otherwise, determining that the supplemental value information is invalid.
In yet another embodiment, the supplemental value information is reported by the first on-demand platform upon verifying that there is an error in the on-demand value information reported by the first on-demand platform in response to an objection request sent by any one of the on-demand users; wherein the supplemental value information comprises at least one of: newly added value information and corrected value information; the new value information is used for performing information supplement on the anchor value information extracted from the first block, and the correction value information is used for performing information correction on the anchor value information extracted from the first block.
In yet another embodiment, the one or more instructions may be further loaded and specifically executed by the processor 201: responding to a query request sent by the first direct broadcasting platform, and verifying whether the first direct broadcasting platform has query authority; and if the first direct-playing platform has the query authority, sending the value relation map to the first direct-playing platform so that the first direct-playing platform displays the value relation map in a user interface.
In yet another embodiment, the one or more instructions may be further loaded and specifically executed by the processor 201: determining a first anchor user from the first live broadcast platform according to the value relation map, and determining a second anchor user from the second live broadcast platform according to the value relation map; the value group of the first anchor user is the same as the value group of the second anchor user; generating an anchor exchange prompt according to the attribute information of the first anchor user and the attribute information of the second anchor user, wherein the anchor exchange prompt is used for prompting that the first anchor user and the second anchor user can be exchanged between the first direct broadcast platform and the second direct broadcast platform; and sending a main broadcasting exchange prompt to the first live broadcasting platform and the second live broadcasting platform.
According to the method and the device, the attribute information and the value evaluation data of a plurality of anchor users on a first live broadcast platform and a second live broadcast platform can be obtained by a first node in a block chain network, and the value evaluation is performed on each anchor user according to the value evaluation data of each anchor user to obtain the identity value of each anchor user; therefore, the unified judgment of the anchor value is realized, the objectivity of value judgment is improved, and the malicious tampering of the identity value of each anchor user is prevented. The first node equipment can also perform grouping processing on each anchor user according to the identity value of each anchor user to obtain the value group of each anchor user; and generating a value relation map by adopting the value group of each anchor user and the attribute information of each anchor user. By generating the value relation map, the value relation map can be presented to the live broadcast platform as a reference when the live broadcast platform has the anchor exchange requirement; under the condition of avoiding commercial data (such as value evaluation data of all anchor users counted by the live broadcast platform) from being leaked, the anchor users with the same value can be exchanged among the live broadcast platforms; and then the objectivity and rationality of anchor exchange are realized, the flow efficiency of resources in the live broadcast industry is promoted, and the effective utilization rate of anchor resources in the live broadcast industry is improved.
The above disclosure is only for the purpose of illustrating the preferred embodiments of the present invention, and it is therefore to be understood that the invention is not limited by the scope of the appended claims.