[go: up one dir, main page]

CN105931066A - Transaction data processing method and device - Google Patents

Transaction data processing method and device Download PDF

Info

Publication number
CN105931066A
CN105931066A CN201510617766.9A CN201510617766A CN105931066A CN 105931066 A CN105931066 A CN 105931066A CN 201510617766 A CN201510617766 A CN 201510617766A CN 105931066 A CN105931066 A CN 105931066A
Authority
CN
China
Prior art keywords
user
described user
transaction
commodity type
tradable commodity
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Pending
Application number
CN201510617766.9A
Other languages
Chinese (zh)
Inventor
王文柏
冯哲
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
China Unionpay Co Ltd
Original Assignee
China Unionpay Co Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by China Unionpay Co Ltd filed Critical China Unionpay Co Ltd
Priority to CN201510617766.9A priority Critical patent/CN105931066A/en
Publication of CN105931066A publication Critical patent/CN105931066A/en
Priority to PCT/CN2016/099224 priority patent/WO2017050188A1/en
Pending legal-status Critical Current

Links

Classifications

    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06QINFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
    • G06Q30/00Commerce
    • G06Q30/02Marketing; Price estimation or determination; Fundraising

Landscapes

  • Business, Economics & Management (AREA)
  • Engineering & Computer Science (AREA)
  • Accounting & Taxation (AREA)
  • Development Economics (AREA)
  • Strategic Management (AREA)
  • Finance (AREA)
  • Game Theory and Decision Science (AREA)
  • Entrepreneurship & Innovation (AREA)
  • Economics (AREA)
  • Marketing (AREA)
  • Physics & Mathematics (AREA)
  • General Business, Economics & Management (AREA)
  • General Physics & Mathematics (AREA)
  • Theoretical Computer Science (AREA)
  • Management, Administration, Business Operations System, And Electronic Commerce (AREA)

Abstract

本发明公开了一种交易数据处理方法及装置,包括:获取用户的历史交易信息,所述历史交易信息包括交易金额、交易商品类型;根据所述交易金额确定所述用户的交易金额平均值,并根据所述用户的交易金额平均值以及交易商品类型确定所述用户的加权交易金额平均值,并根据加权交易金额平均值确定所述用户的消费等级;从用户的交易商品类型中确定所述用户的特征交易商品类型,特征交易商品类型为该交易商品类型对应的交易次数大于该交易商品类型对应的阈值且该交易商品类型属于消费阶段中预设的交易商品类型;根据用户的特征交易商品类型确定用户所处的消费阶段;根据用户的消费等级和所述用户所处的消费阶段,确定与用户相匹配的商品信息。

The invention discloses a transaction data processing method and device, comprising: acquiring historical transaction information of a user, the historical transaction information including transaction amount and transaction commodity type; determining the average value of the user's transaction amount according to the transaction amount, And determine the user's weighted average transaction amount according to the user's average transaction amount and transaction commodity type, and determine the user's consumption level according to the weighted transaction amount average; determine the user's transaction commodity type The user's characteristic trading commodity type, the characteristic trading commodity type is that the number of transactions corresponding to the trading commodity type is greater than the threshold corresponding to the trading commodity type and the trading commodity type belongs to the preset trading commodity type in the consumption stage; the trading commodity is based on the user's characteristics The type determines the consumption stage of the user; according to the consumption level of the user and the consumption stage of the user, the product information matching the user is determined.

Description

一种交易数据处理方法及装置A transaction data processing method and device

技术领域technical field

本发明涉及数据处理技术领域,尤其涉及一种交易数据处理方法及其装置。The invention relates to the technical field of data processing, in particular to a transaction data processing method and device thereof.

背景技术Background technique

随着网络支付业务的安全性越来越高,越来越多的消费行为是通过网络完成的。一些电商平台便根据消费者的网络搜索以及消费行为消费者建立消费行为模型,并为消费者推送相应的商品信息。As the security of online payment services is getting higher and higher, more and more consumer behaviors are completed through the network. Some e-commerce platforms establish consumer behavior models based on consumers' online searches and consumer behaviors, and push corresponding product information for consumers.

但是,由于网络环境的局限性,有些商品消费者并不会在网络中购买,例如,汽车,同时,消费者的消费账号可以被多个人同时使用。因此,基于消费者在网络中的消费行建立的消费行为模型为并不能体现消费者的真正的消费行为。However, due to the limitations of the network environment, consumers of some commodities will not purchase on the network, for example, cars, and at the same time, the consumption account of the consumer can be used by multiple people at the same time. Therefore, the consumption behavior model established based on the consumption behavior of consumers in the network cannot reflect the real consumption behavior of consumers.

因此,根据消费者在网络中的消费行建立的消费模型去推送商品信息的效果不是很好。Therefore, the effect of pushing product information based on the consumption model established by the consumer in the network is not very good.

发明内容Contents of the invention

本发明实施例提供一种交易数据处理方法及其装置,用以实现建立准确的消费行为模型。Embodiments of the present invention provide a transaction data processing method and device thereof, so as to establish an accurate consumption behavior model.

本发明实施例提供一种交易数据处理方法,包括:An embodiment of the present invention provides a transaction data processing method, including:

获取用户的历史交易信息,所述历史交易信息包括交易金额、交易商品类型;Obtain the user's historical transaction information, the historical transaction information includes the transaction amount, transaction commodity type;

根据所述交易金额确定所述用户的交易金额平均值,并根据所述用户的交易金额平均值以及交易商品类型确定所述用户的加权交易金额平均值,并根据所述加权交易金额平均值确定所述用户的消费等级;Determine the average transaction amount of the user according to the transaction amount, determine the average weighted transaction amount of the user according to the average transaction amount of the user and the type of transaction commodity, and determine the average value of the transaction amount based on the weighted average amount the consumption level of said user;

从所述用户的交易商品类型中确定所述用户的特征交易商品类型,所述特征交易商品类型为该交易商品类型对应的交易次数大于该交易商品类型对应的阈值、且该交易商品类型属于消费阶段中预设的交易商品类型;Determine the user's characteristic transaction commodity type from the user's transaction commodity type, the characteristic transaction commodity type is that the transaction times corresponding to the transaction commodity type is greater than the threshold value corresponding to the transaction commodity type, and the transaction commodity type belongs to consumption The type of trading commodity preset in the stage;

根据所述用户的特征交易商品类型确定所述用户所处的消费阶段;Determining the consumption stage of the user according to the type of commodity traded according to the characteristics of the user;

根据所述用户的消费等级和所述用户所处的消费阶段,确定与所述用户相匹配的商品信息。According to the consumption level of the user and the consumption stage of the user, product information matching the user is determined.

优选的,所述获取用户的历史交易信息,包括:Preferably, the acquisition of the user's historical transaction information includes:

在分布式存储系统中确定存储所述用户的历史交易信息的数据库节点;Determining a database node storing the user's historical transaction information in the distributed storage system;

根据数据库节点的状态标识确定所述存储所述用户的历史交易信息的数据库节点中处于活跃状态的数据库节点;determining an active database node among the database nodes storing the user's historical transaction information according to the status identifier of the database node;

通过所述处于活跃状态的数据库节点获取所述用户的历史交易信息。The historical transaction information of the user is obtained through the active database node.

优选的,通过以下方式确定数据库节点的状态标识:Preferably, the state identifier of the database node is determined in the following manner:

向数据库节点发送检测报文,若在预设时间段内未接收到所述数据库节点的响应报文,则确定所述数据库节点处于失效状态,并将所述数据库节点的状态标识确定为失效状态,否则将所述数据库节点的状态标识确定为活跃状态。Send a detection message to the database node, if the response message of the database node is not received within the preset time period, then determine that the database node is in an invalid state, and determine the state identifier of the database node as an invalid state , otherwise, determine the state identifier of the database node as an active state.

优选的,所述将所述数据库节点的状态标识确定为失效状态之后,还包括:Preferably, after the state identification of the database node is determined as a failure state, it further includes:

确定与所述处于失效状态的数据库节点中存储的数据相同、且处于活跃状态的数据库节点;Determining a database node that has the same data stored in the database node in the failure state and is in an active state;

对所述与所述处于失效状态的数据库节点中存储的数据相同、且处于活跃状态的数据库节点中存储的数据备份至其他处于活跃状态的数据库节点。The data stored in the active database node that is the same as the data stored in the failed database node is backed up to other active database nodes.

优选的,所述根据所述交易金额确定所述用户的交易金额平均值,并根据所述用户的交易金额平均值以及交易商品类型确定所述用户的加权交易金额平均值,并根据所述加权交易金额平均值确定所述用户的消费等级,包括:Preferably, the average transaction amount of the user is determined according to the transaction amount, and the weighted average transaction amount of the user is determined according to the average transaction amount of the user and the type of commodity traded, and according to the weighted The average transaction amount determines the consumption level of the user, including:

根据以下公式确定用户的加权交易金额平均值:The average weighted transaction amount of a user is determined according to the following formula:

Mm == ΣΣ ee == 11 NN CC ee ×× DD. // NN

其中,M表示用户的加权交易金额平均值,D表示用户的交易金额平均值,Ce表示第e次交易的交易商品类型的加权值,e大于等于1且小于等于N,N表示交易次数;Among them, M represents the average value of the weighted transaction amount of the user, D represents the average value of the transaction amount of the user, C e represents the weighted value of the transaction commodity type of the e-th transaction, e is greater than or equal to 1 and less than or equal to N, and N represents the number of transactions;

将所述用户的加权交易金额平均值对应的等级确定所述用户的消费等级。The consumption level of the user is determined by the level corresponding to the average weighted transaction amount of the user.

优选的,所述根据所述用户的消费等级和所述用户所处的消费阶段,确定与所述用户相匹配的商品信息,包括:Preferably, the determining the commodity information matching the user according to the consumption level of the user and the consumption stage of the user includes:

确定与所述用户的消费等级一致的其他用户;Identify other users who are consistent with the user's consumption level;

确定所述其他用户的历史交易信息中的交易商品类型;Determine the transaction commodity type in the other user's historical transaction information;

在所述其他用户的历史交易信息中的交易商品类型中,确定与所述用户所处的消费阶段相匹配的交易商品类型,并将与所述用户所处的消费阶段相匹配的交易商品类型对应的交易商品信息确定为与所述用户相匹配的商品信息。Among the transaction commodity types in the historical transaction information of the other users, determine the transaction commodity types that match the consumption stage of the user, and determine the transaction commodity types that match the consumption stage of the user The corresponding transaction commodity information is determined as the commodity information matching the user.

优选的,所述根据所述用户的消费等级和所述用户所处的消费阶段,确定与所述用户相匹配的商品信息,包括:Preferably, the determining the commodity information matching the user according to the consumption level of the user and the consumption stage of the user includes:

获取商家的商家属性信息以及商家的历史交易信息,所述商家属性信息中包括交易商品类型,所述商家的历史交易信息中包括交易金额;Obtaining merchant attribute information and merchant historical transaction information of the merchant, the merchant attribute information including the transaction commodity type, and the merchant historical transaction information including the transaction amount;

将商家的交易金额平均值在同一范围内、且商家的交易商品类型相同的商家划分为一个商家聚类;Merchants with the average transaction amount of merchants within the same range and merchants with the same type of transaction commodities are divided into a merchant cluster;

将商家的交易金额平均值与所述用户的消费等级相匹配、且商家的交易商品类型属于所述用户所处的消费阶段的商家聚类,确定为与所述用户相匹配的商家聚类;Matching the average transaction amount of the merchant with the consumption level of the user, and the merchant cluster whose transaction commodity type belongs to the consumption stage of the user is determined as the merchant cluster matching the user;

将所述与所述用户相匹配的商家聚类对应的商品信息确定为与所述用户相匹配的商品信息。The product information corresponding to the merchant cluster matching the user is determined as the product information matching the user.

优选的,该方法还包括:Preferably, the method also includes:

获取用户的实时交易信息;Obtain real-time transaction information of users;

在所述用户相匹配的商品信息对应的交易商品类型中,确定与所述实时交易的交易商品类型相匹配的交易商品类型,并将与所述实时交易的交易商品类型相匹配的交易商品类型对应的交易商品信息推送给所述用户。Among the transaction commodity types corresponding to the commodity information matched by the user, determine the transaction commodity types that match the real-time transaction transaction commodity types, and match the transaction commodity types that match the real-time transaction transaction commodity types The corresponding transaction commodity information is pushed to the user.

本发明实施例提供一种交易数据处理装置,该装置包括:An embodiment of the present invention provides a transaction data processing device, which includes:

获取单元,用于获取用户的历史交易信息,所述历史交易信息包括交易金额、交易商品类型;An acquisition unit, configured to acquire historical transaction information of the user, the historical transaction information including transaction amount and transaction commodity type;

确定单元,用于根据所述交易金额确定所述用户的交易金额平均值,并根据所述用户的交易金额平均值以及交易商品类型确定所述用户的加权交易金额平均值,并根据所述加权交易金额平均值确定所述用户的消费等级;从所述用户的交易商品类型中确定所述用户的特征交易商品类型,所述特征交易商品类型为该交易商品类型对应的交易次数大于该交易商品类型对应的阈值、且该交易商品类型属于消费阶段中预设的交易商品类型;根据所述用户的特征交易商品类型确定所述用户所处的消费阶段;A determining unit, configured to determine the average transaction amount of the user according to the transaction amount, and determine the weighted average transaction amount of the user according to the average transaction amount of the user and the type of commodity to be traded, and determine the average transaction amount of the user according to the weighted The average transaction amount determines the user's consumption level; the user's characteristic transaction commodity type is determined from the user's transaction commodity type, and the characteristic transaction commodity type is that the transaction times corresponding to the transaction commodity type is greater than the transaction commodity type The threshold value corresponding to the type, and the transaction commodity type belongs to the preset transaction commodity type in the consumption stage; according to the user's characteristic transaction commodity type, the consumption stage of the user is determined;

匹配单元,用于根据所述用户的消费等级和所述用户所处的消费阶段,确定与所述用户相匹配的商品信息。The matching unit is configured to determine commodity information matching the user according to the consumption level of the user and the consumption stage of the user.

优选的,所述获取单元具体用于:Preferably, the acquisition unit is specifically used for:

在分布式存储系统中确定存储所述用户的历史交易信息的数据库节点;Determining a database node storing the user's historical transaction information in the distributed storage system;

根据数据库节点的状态标识确定所述存储所述用户的历史交易信息的数据库节点中处于活跃状态的数据库节点;determining an active database node among the database nodes storing the user's historical transaction information according to the status identifier of the database node;

通过所述处于活跃状态的数据库节点获取所述用户的历史交易信息。The historical transaction information of the user is obtained through the active database node.

优选的,该装置还包括检测单元,所述检测单元通过以下方式确定数据库节点的状态标识:Preferably, the device further includes a detection unit, and the detection unit determines the state identifier of the database node in the following manner:

向数据库节点发送检测报文,若在预设时间段内未接收到所述数据库节点的响应报文,则确定所述数据库节点处于失效状态,并将所述数据库节点的状态标识确定为失效状态,否则将所述数据库节点的状态标识确定为活跃状态。Send a detection message to the database node, if the response message of the database node is not received within the preset time period, then determine that the database node is in an invalid state, and determine the state identifier of the database node as an invalid state , otherwise, determine the state identifier of the database node as an active state.

优选的,该装置还包括备份单元,所述备份单元用于:Preferably, the device also includes a backup unit, the backup unit is used for:

确定与所述处于失效状态的数据库节点中存储的数据相同、且处于活跃状态的数据库节点;Determining a database node that has the same data stored in the database node in the failure state and is in an active state;

对所述与所述处于失效状态的数据库节点中存储的数据相同、且处于活跃状态的数据库节点中存储的数据备份至其他处于活跃状态的数据库节点。The data stored in the active database node that is the same as the data stored in the failed database node is backed up to other active database nodes.

优选的,所述确定单元具体用于:Preferably, the determining unit is specifically used for:

根据以下公式确定用户的加权交易金额平均值:The average weighted transaction amount of a user is determined according to the following formula:

Mm == ΣΣ ee == 11 NN CC ee ×× DD. // NN

其中,M表示用户的加权交易金额平均值,D表示用户的交易金额平均值,Ce表示第e次交易的交易商品类型的加权值,e大于等于1且小于等于N,N表示交易次数;Among them, M represents the average value of the weighted transaction amount of the user, D represents the average value of the transaction amount of the user, C e represents the weighted value of the transaction commodity type of the e-th transaction, e is greater than or equal to 1 and less than or equal to N, and N represents the number of transactions;

将所述用户的加权交易金额平均值对应的等级确定所述用户的消费等级。The consumption level of the user is determined by the level corresponding to the average weighted transaction amount of the user.

优选的,所述匹配单元具体用于:Preferably, the matching unit is specifically used for:

确定与所述用户的消费等级一致的其他用户;Identify other users who are consistent with the user's consumption level;

确定所述其他用户的历史交易信息中的交易商品类型;Determine the transaction commodity type in the other user's historical transaction information;

在所述其他用户的历史交易信息中的交易商品类型中,确定与所述用户所处的消费阶段相匹配的交易商品类型,并将与所述用户所处的消费阶段相匹配的交易商品类型对应的交易商品信息确定为与所述用户相匹配的商品信息。Among the transaction commodity types in the historical transaction information of the other users, determine the transaction commodity types that match the consumption stage of the user, and determine the transaction commodity types that match the consumption stage of the user The corresponding transaction commodity information is determined as the commodity information matching the user.

优选的,所述匹配单元具体用于:Preferably, the matching unit is specifically used for:

获取商家的商家属性信息以及商家的历史交易信息,所述商家属性信息中包括交易商品类型,所述商家的历史交易信息中包括交易金额;Obtaining merchant attribute information and merchant historical transaction information of the merchant, the merchant attribute information including the transaction commodity type, and the merchant historical transaction information including the transaction amount;

将商家的交易金额平均值在同一范围内、且商家的交易商品类型相同的商家划分为一个商家聚类;Merchants with the average transaction amount of merchants within the same range and merchants with the same type of transaction commodities are divided into a merchant cluster;

将商家的交易金额平均值与所述用户的消费等级相匹配、且商家的交易商品类型属于所述用户所处的消费阶段的商家聚类,确定为与所述用户相匹配的商家聚类;Matching the average transaction amount of the merchant with the consumption level of the user, and the merchant cluster whose transaction commodity type belongs to the consumption stage of the user is determined as the merchant cluster matching the user;

将所述与所述用户相匹配的商家聚类对应的商品信息确定为与所述用户相匹配的商品信息。The product information corresponding to the merchant cluster matching the user is determined as the product information matching the user.

优选的,该装置还包括推送单元;所述推送单元具体用于:Preferably, the device also includes a push unit; the push unit is specifically used for:

获取用户的实时交易信息;Obtain real-time transaction information of users;

在所述用户相匹配的商品信息对应的交易商品类型中,确定与所述实时交易的交易商品类型相匹配的交易商品类型,并将与所述实时交易的交易商品类型相匹配的交易商品类型对应的交易商品信息推送给所述用户。Among the transaction commodity types corresponding to the commodity information matched by the user, determine the transaction commodity types that match the real-time transaction transaction commodity types, and match the transaction commodity types that match the real-time transaction transaction commodity types The corresponding transaction commodity information is pushed to the user.

本发明实施例具有如下有益效果:Embodiments of the present invention have the following beneficial effects:

本发明实施例中,是通过用户的线下交易记录确定用户的交易金额平均值以及交易商品类型,从而确定用户的消费等级以及消费阶段,最终确定用户的消费行为模型。由于线下交易记录更能反映消费者的真实行为,因此获得的消费行为模型更加准确。In the embodiment of the present invention, the user's average transaction amount and transaction commodity type are determined through the user's offline transaction records, thereby determining the user's consumption level and consumption stage, and finally determining the user's consumption behavior model. Since offline transaction records can better reflect the real behavior of consumers, the obtained consumption behavior model is more accurate.

附图说明Description of drawings

为了更清楚地说明本发明实施例中的技术方案,下面将对实施例描述中所需要使用的附图作简要介绍,显而易见地,下面描述中的附图仅仅是本发明的一些实施例,对于本领域的普通技术人员来讲,在不付出创造性劳动性的前提下,还可以根据这些附图获得其他的附图。In order to more clearly illustrate the technical solutions in the embodiments of the present invention, the drawings that need to be used in the description of the embodiments will be briefly introduced below. Obviously, the drawings in the following description are only some embodiments of the present invention. For Those of ordinary skill in the art can also obtain other drawings based on these drawings without any creative effort.

图1为本发明实施例提供的一种交易数据处理方法流程示意图;Fig. 1 is a schematic flow chart of a transaction data processing method provided by an embodiment of the present invention;

图2为本发明实施例提供的一种交易数据处理装置结构示意图。Fig. 2 is a schematic structural diagram of a transaction data processing device provided by an embodiment of the present invention.

具体实施方式detailed description

为了使本发明的目的、技术方案和优点更加清楚,下面将结合附图对本发明作进一步地详细描述,显然,所描述的实施例仅仅是本发明一部份实施例,而不是全部的实施例。基于本发明中的实施例,本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其它实施例,都属于本发明保护的范围。In order to make the object, technical solution and advantages of the present invention clearer, the present invention will be further described in detail below in conjunction with the accompanying drawings. Obviously, the described embodiments are only some embodiments of the present invention, rather than all embodiments . Based on the embodiments of the present invention, all other embodiments obtained by persons of ordinary skill in the art without making creative efforts belong to the protection scope of the present invention.

如图1所示,本发明实施例提供的一种交易数据处理方法流程示意图,该方法包括:As shown in Figure 1, a schematic flow chart of a transaction data processing method provided by an embodiment of the present invention, the method includes:

步骤101:获取用户的历史交易信息,所述历史交易信息包括交易金额、交易商品类型;Step 101: Acquiring the user's historical transaction information, the historical transaction information includes the transaction amount and transaction commodity type;

步骤102:根据所述交易金额确定所述用户的交易金额平均值,并根据所述用户的交易金额平均值以及交易商品类型确定所述用户的加权交易金额平均值,并根据所述加权交易金额平均值确定所述用户的消费等级;Step 102: Determine the average transaction amount of the user according to the transaction amount, and determine the average weighted transaction amount of the user according to the average transaction amount of the user and the type of commodity traded, and determine the average transaction amount of the user according to the weighted transaction amount The average value determines the consumption level of said user;

步骤103:从所述用户的交易商品类型中确定所述用户的特征交易商品类型,所述特征交易商品类型为该交易商品类型对应的交易次数大于该交易商品类型对应的阈值、且该交易商品类型属于消费阶段中预设的交易商品类型;Step 103: Determine the characteristic transaction commodity type of the user from the transaction commodity types of the user, and the characteristic transaction commodity type is that the transaction times corresponding to the transaction commodity type is greater than the threshold value corresponding to the transaction commodity type, and the transaction commodity type The type belongs to the preset transaction commodity type in the consumption stage;

步骤104:根据所述用户的特征交易商品类型确定所述用户所处的消费阶段;Step 104: Determine the consumption stage of the user according to the user's characteristic transaction commodity type;

步骤105:根据所述用户的消费等级和所述用户所处的消费阶段,确定与所述用户相匹配的商品信息。Step 105: Determine commodity information matching the user according to the consumption level of the user and the consumption stage of the user.

步骤101中,历史交易信息中的交易商品类型具体可以为餐饮、服饰、家电、消费电子等,指示出交易的商品的类型,或者指示出交易类型。In step 101, the transaction commodity type in the historical transaction information may specifically be catering, clothing, home appliances, consumer electronics, etc., indicating the type of transaction commodities, or indicating the transaction type.

本发明实施例中,用户的历史交易信息可以存储于分布式存储系统中。分布式存储系统,是将数据分散存储在多台独立的数据库节点上。传统的网络存储系统采用集中的数据库节点存放所有数据,分布式网络存储系统采用可扩展的系统结构,利用多台数据库节点分担存储负荷,它不但提高了系统的可靠性、可用性和存取效率,还易于扩展。In the embodiment of the present invention, the user's historical transaction information can be stored in a distributed storage system. Distributed storage system is to disperse and store data on multiple independent database nodes. The traditional network storage system uses centralized database nodes to store all data, and the distributed network storage system adopts a scalable system structure and uses multiple database nodes to share the storage load. It not only improves the reliability, availability and access efficiency of the system, Also easy to expand.

本发明实施例中,分布式数据存储系统有如下特征:In the embodiment of the present invention, the distributed data storage system has the following characteristics:

数据具有2份以上的冗余度,可配置成多分冗余;The data has more than 2 redundancy levels and can be configured as multi-level redundancy;

当数据库节点失效时,可以自动隔离处于失效状态的数据库节点;When the database node fails, the database node in the failed state can be automatically isolated;

当数据库节点实效时,可以自动备份处于失效状态的数据库节点的数据至其他活跃的数据库节点;When the database node becomes invalid, the data of the database node in the failed state can be automatically backed up to other active database nodes;

可以动态实时增加数据库节点;Can dynamically increase database nodes in real time;

可以动态实时减少数据库节点。Database nodes can be dynamically reduced in real time.

为了能够快速的指示出数据库节点的状态标识,本发明实施例中,对所述处于失效状态的数据库节点进行标记,并确定与所述处于失效状态的数据库节点中存储的数据相同、且处于活跃状态的数据库节点;对所述与所述处于失效状态的数据库节点中存储的数据相同、且处于活跃状态的数据库节点中存储的数据备份至其他处于活跃状态的数据库节点。In order to quickly indicate the state identification of the database node, in the embodiment of the present invention, the database node in the failure state is marked, and it is determined that the data stored in the database node in the failure state is the same and is active state database node; backing up the data stored in the active database node to other active database nodes.

综上所述,本发明实施例中,数据库节点主要包含两类关键信息:位置信息和状态标识。位置信息可以由IP(网络间互连的协议,Internet Protocol)地址和端口(port)号构成,指示出访问该数据库节点时的位置。状态标识表示出数据库节点为活跃状态或者失效状态。To sum up, in the embodiment of the present invention, the database node mainly includes two types of key information: location information and status identification. The location information may consist of an IP (Internet Protocol) address and a port number, indicating the location when accessing the database node. The status flag indicates that the database node is active or failed.

举例来说,当需要读取数据时,确定了数据库节点的IP地址和端口号就可以确定数据库节点的位置,并从确定出的数据库节点中读取数据。For example, when data needs to be read, the location of the database node can be determined after determining the IP address and port number of the database node, and data can be read from the determined database node.

在获取用户的历史交易信息时,需要先确定数据库节点的状态标识,并通过分布式存储系统中状态标识为活跃状态的数据库节点获取用户的历史交易信息。具体的,在分布式存储系统中确定存储所述用户的历史交易信息的数据库节点;根据数据库节点的状态标识确定所述存储所述用户的历史交易信息的数据库节点中处于活跃状态的数据库节点;通过所述处于活跃状态的数据库节点获取所述用户的历史交易信息。When obtaining the user's historical transaction information, it is necessary to first determine the status identifier of the database node, and obtain the user's historical transaction information through the database node whose status identifier is active in the distributed storage system. Specifically, the database node storing the historical transaction information of the user is determined in the distributed storage system; the database node in an active state among the database nodes storing the historical transaction information of the user is determined according to the state identifier of the database node; The historical transaction information of the user is obtained through the active database node.

其中,可以通过以下方式确定数据库节点的状态标识:Among them, the status identifier of the database node can be determined in the following ways:

向数据库节点发送检测报文,若在预设时间段内未接收到所述数据库节点的响应报文,则确定所述数据库节点处于失效状态,并将所述数据库节点的状态标识确定为失效状态,否则将所述数据库节点的状态标识确定为活跃状态。Send a detection message to the database node, if the response message of the database node is not received within the preset time period, then determine that the database node is in an invalid state, and determine the state identifier of the database node as an invalid state , otherwise, determine the state identifier of the database node as an active state.

当然,还可以通过其他检测方法确定数据库节点的状态标识,在此不再赘述。Of course, other detection methods can also be used to determine the status identifier of the database node, which will not be repeated here.

当确定数据库节点为失效状态之后,还可能需要对该失效状态的数据库节点中的数据进行备份。具体的,先确定与所述处于失效状态的数据库节点中存储的数据相同、且处于活跃状态的数据库节点;对所述与所述处于失效状态的数据库节点中存储的数据相同、且处于活跃状态的数据库节点中存储的数据备份至其他处于活跃状态的数据库节点。After it is determined that the database node is in a failure state, it may also be necessary to back up the data in the database node in the failure state. Specifically, first determine the database node that is the same as the data stored in the database node in the failure state and is in the active state; The data stored in the database node is backed up to other active database nodes.

步骤102中,获取所述用户的历史交易信息之后,可以根据用户的历史交易信息中的交易金额确定所述用户的交易金额平均值,并根据所述用户的交易金额平均值以及交易商品类型确定所述用户的消费等级。In step 102, after obtaining the historical transaction information of the user, the average transaction amount of the user may be determined according to the transaction amount in the user's historical transaction information, and determined according to the average transaction amount of the user and the type of transaction commodity The consumption level of the user.

根据所述交易金额确定所述用户的交易金额平均值,并根据所述用户的交易金额平均值以及交易商品类型确定所述用户的加权交易金额平均值,并根据所述加权交易金额平均值确定所述用户的消费等级Determine the average transaction amount of the user according to the transaction amount, determine the average weighted transaction amount of the user according to the average transaction amount of the user and the type of transaction commodity, and determine the average value of the transaction amount based on the weighted average amount The consumption level of the user

具体的,可以根据以下公式确定用户的加权交易金额平均值:Specifically, the average weighted transaction amount of a user can be determined according to the following formula:

Mm == ΣΣ ee == 11 NN CC ee ×× DD. // NN ...... (( 11 ))

其中,M表示用户的加权交易金额平均值,D表示用户的交易金额平均值,Ce表示第e次交易的交易商品类型的加权值,e大于等于1且小于等于N,N表示交易次数。Among them, M represents the average weighted transaction amount of the user, D represents the average value of the transaction amount of the user, C e represents the weighted value of the transaction commodity type of the e-th transaction, e is greater than or equal to 1 and less than or equal to N, and N represents the number of transactions.

需要说明的是,交易商品类型的加权值可以根据实际情况去设置。交易商品类型的加权值为大于0的数。交易类型对应的交易金额的值越大,该交易类型的加权值可以越大。It should be noted that the weighted value of the transaction commodity type can be set according to the actual situation. The weighted value of the transaction commodity type is a number greater than 0. The greater the value of the transaction amount corresponding to the transaction type, the greater the weighted value of the transaction type.

然后将所述用户的加权交易金额平均值对应的等级确定所述用户的消费等级。Then, the level corresponding to the average value of the weighted transaction amount of the user is used to determine the consumption level of the user.

具体的,确定所有获取到的用户的历史交易记录,并确定所有获取到的用户的加权交易金额平均值;Specifically, determine the historical transaction records of all acquired users, and determine the average weighted transaction amount of all acquired users;

针对一个用户,确定该用户的加权交易金额平均值位于所述所有获取到的用户的加权交易金额平均值中的排名,根据该用户的加权交易金额平均值的排名与消费等级的映射关系,确定所述用户的消费等级。For a user, determine the ranking of the user's weighted average transaction amount among the weighted average transaction amounts of all obtained users, and determine according to the mapping relationship between the user's weighted average transaction amount ranking and consumption level The consumption level of the user.

举例来说,可以将位于所述所有获取到的用户的加权交易金额平均值中排名前1%的所有用户的消费等级确定第一等级;将位于所述所有获取到的用户的加权交易金额平均值中排名前1%的所有用户的消费等级确定第一等级;将位于所述所有获取到的用户的加权交易金额平均值中排名前3%至1%之间的所有用户的消费等级确定第二等级;将位于所述所有获取到的用户的加权交易金额平均值中排名前15%至3%之间的所有用户的消费等级确定第三等级;将位于所述所有获取到的用户的加权交易金额平均值中排名前47%至15%之间的所有用户的消费等级确定第四等级;将位于所述所有获取到的用户的加权交易金额平均值中排名前85%至47%之间的所有用户的消费等级确定第五等级;将位于所述所有获取到的用户的加权交易金额平均值中排名前94%至85%之间的所有用户的消费等级确定第六等级;将位于所述所有获取到的用户的加权交易金额平均值中排名最后6%的所有用户的消费等级确定第七等级。当然,也可以有其他形式的用户的加权交易金额平均值的排名与消费等级的映射关系,在此不再赘述。For example, the consumption levels of all users ranked in the top 1% of the average weighted transaction amounts of all obtained users can be determined as the first level; the average weighted transaction amounts of all obtained users can be The first level is determined by the consumption levels of all users ranked in the top 1% of the value; the consumption level of all users ranked between the top 3% and 1% in the average weighted transaction amount of all obtained users is determined by the second level. The second level; determine the consumption level of all users who are between the top 15% and 3% of the average weighted transaction amount of all acquired users; determine the third level; determine the weighted value of all acquired users The consumption level of all users ranked between the top 47% and 15% of the average transaction amount determines the fourth level; it will be between the top 85% and 47% of the weighted average transaction amount of all acquired users The consumption level of all users of the above-mentioned user is determined as the fifth level; the consumption level of all users who are between the top 94% and 85% of the average weighted transaction amount of all obtained users is determined as the sixth level; The seventh grade is determined by the consumption grades of all users who rank in the last 6% of the average weighted transaction amount of all users obtained above. Of course, there may also be other forms of mapping relationship between the ranking of the user's weighted average transaction amount and the consumption level, which will not be repeated here.

当确定一个用户的加权交易金额平均值排名后,就可以根据上面的映射关系确定用户的消费等级。After determining the average ranking of a user's weighted transaction amount, the user's consumption level can be determined according to the above mapping relationship.

用户的消费等级可以表明用户的消费能力,或者表明用户的社会阶层。The consumption level of the user may indicate the consumption ability of the user, or indicate the social class of the user.

同时,在步骤103中,可以通过用户的历史交易记录确定用户的消费阶段。消费阶段中预设的交易商品类型可以有多种。Meanwhile, in step 103, the user's consumption stage can be determined through the user's historical transaction records. There can be many kinds of preset transaction commodity types in the consumption stage.

举例来说,可以将用户的消费阶段划分为以下几个阶段:单身阶段、备婚阶段、新婚阶段、育婴阶段、育儿阶段、未分阶段(未分阶段是指:抚育的孩子已经成年,但还未结婚)、空巢阶段、鰥寡阶段。For example, the user's consumption stage can be divided into the following stages: single stage, marriage preparation stage, newly married stage, baby-raising stage, child-rearing stage, unclassified stage (unclassified refers to: the child being raised has grown up, But not yet married), empty nest stage, widowhood stage.

其中,单身阶段时,预设的交易商品类型主要为食品、书籍、电影等娱乐项目;备婚阶段时,预设的交易商品类型主要为高级时装、结婚用品等项目;新婚阶段时,预设的交易商品类型主要为娱乐、旅游等项目;育婴阶段时,预设的交易商品类型主要为奶粉、尿不湿等项目;育儿阶段时,预设的交易商品类型主要为教育支出等项目;未分阶段时,预设的交易商品类型主要为社交用品等项目;空巢阶段时,预设的交易商品类型主要是保健品等项目;鰥寡阶段时,预设的交易商品类型主要为医疗等项目。Among them, at the single stage, the preset trading commodity types are mainly food, books, movies and other entertainment items; at the marriage preparation stage, the preset trading commodity types are mainly high-end fashion, wedding supplies and other items; The types of commodities traded are mainly entertainment, travel and other items; during the baby-raising stage, the default types of transaction commodities are mainly milk powder, diapers and other items; during the child-rearing stage, the default types of transaction commodities are mainly education expenditures and other items; When there is no stage, the default trading commodity types are mainly social goods and other items; in the empty nest stage, the default trading commodity types are mainly health care products and other items; in the widow stage, the default trading commodity types are mainly medical treatment and other items.

步骤104中,可以根据人生不同阶段的不同的特点,确定用户会在不同人生阶段有着不同偏好的交易商品类型。In step 104, according to different characteristics of different stages of life, it can be determined that the user will have different preferences for trading commodity types in different stages of life.

举例来说,若用户经常购买奶粉以及尿不湿等婴儿用品,可以确定用户的特征交易商品类型为育儿产品,从而确定所述用户所处的消费阶段为育婴阶段。For example, if the user often buys baby products such as milk powder and diapers, it can be determined that the user's characteristic transaction commodity type is child care products, so as to determine that the user's consumption stage is the baby care stage.

最后在步骤105中,根据用户的消费等级以及消费阶段确定用户匹配的商品信息,并在需要时为用户推送这些商品信息。Finally, in step 105, the product information matching the user is determined according to the user's consumption level and consumption stage, and the product information is pushed to the user when necessary.

确定用户匹配的商品信息的一种可能的实现方式为:A possible implementation of determining the product information matched by the user is as follows:

确定与所述用户的消费等级一致的其他用户;Identify other users who are consistent with the user's consumption level;

确定所述其他用户的历史交易信息中的交易商品类型;Determine the transaction commodity type in the other user's historical transaction information;

在所述其他用户的历史交易信息中的交易商品类型中,确定与所述用户所处的消费阶段相匹配的交易商品类型,并将与所述用户所处的消费阶段相匹配的交易商品类型对应的交易商品信息确定为与所述用户相匹配的商品信息。Among the transaction commodity types in the historical transaction information of the other users, determine the transaction commodity types that match the consumption stage of the user, and determine the transaction commodity types that match the consumption stage of the user The corresponding transaction commodity information is determined as the commodity information matching the user.

举例来说,用户A和用户B属于同一消费等级,且用户A喜欢去第一品牌的川菜馆消费,用户B喜欢去第二品牌的川菜馆消费。此时,可以将用户B喜欢的第二品牌的川菜馆的商品信息与用户A进行匹配。相应的,也可以将用户A喜欢的第二品牌的川菜馆的商品信息与用户B进行匹配。当用户A在第一品牌的川菜馆消费时,可以将第二品牌的川菜馆的商品信息推送给用户A,从而实现精准营销。For example, user A and user B belong to the same consumption class, and user A likes to consume at the Sichuan cuisine restaurant of the first brand, and user B likes to consume at the Sichuan cuisine restaurant of the second brand. At this time, the commodity information of the second brand Sichuan cuisine restaurant that user B likes can be matched with user A. Correspondingly, it is also possible to match the commodity information of the second brand Sichuan cuisine restaurant that user A likes with user B. When user A consumes at the Sichuan cuisine restaurant of the first brand, the product information of the Sichuan cuisine restaurant of the second brand can be pushed to user A, thereby realizing precise marketing.

确定用户匹配的商品信息的另一种可能的实现方式为:Another possible implementation of determining the product information matched by the user is:

获取商家的商家属性信息以及商家的历史交易信息,所述商家属性信息中包括交易商品类型,所述商家的历史交易信息中包括交易金额;Obtaining merchant attribute information and merchant historical transaction information of the merchant, the merchant attribute information including the transaction commodity type, and the merchant historical transaction information including the transaction amount;

将商家的交易金额平均值在同一范围内、且商家的交易商品类型相同的商家划分为一个商家聚类;Merchants with the average transaction amount of merchants within the same range and merchants with the same type of transaction commodities are divided into a merchant cluster;

将商家的交易金额平均值与所述用户的消费等级相匹配、且商家的交易商品类型属于所述用户所处的消费阶段的商家聚类,确定为与所述用户相匹配的商家聚类;Matching the average transaction amount of the merchant with the consumption level of the user, and the merchant cluster whose transaction commodity type belongs to the consumption stage of the user is determined as the merchant cluster matching the user;

将所述与所述用户相匹配的商家聚类对应的商品信息确定为与所述用户相匹配的商品信息。The product information corresponding to the merchant cluster matching the user is determined as the product information matching the user.

举例来说,用户A属于第三消费等级,且用户A处于单身阶段,此时可以将与用户A匹配对应的商家聚类。当用户A购买某高档手机时,可以为用户A推送与该高档手机属于同一个商家聚类的高档数码相机,从而实现精准营销。For example, user A belongs to the third consumption level, and user A is single, at this time, merchants matching user A can be clustered. When user A buys a high-end mobile phone, user A can be pushed high-end digital cameras that belong to the same merchant cluster as the high-end mobile phone, so as to achieve precise marketing.

最后,在用户实时交易时,可以为用户推送与用户实时交易的交易商品类型相匹配的商品信息。Finally, when the user trades in real time, the user can be pushed commodity information that matches the type of traded commodity that the user trades in real time.

具体的,获取用户的实时交易信息;Specifically, obtain real-time transaction information of users;

在所述用户相匹配的商品信息对应的交易商品类型中,确定与所述实时交易的交易商品类型相匹配的交易商品类型,并将与所述实时交易的交易商品类型相匹配的交易商品类型对应的交易商品信息推送给所述用户。Among the transaction commodity types corresponding to the commodity information matched by the user, determine the transaction commodity types that match the real-time transaction transaction commodity types, and match the transaction commodity types that match the real-time transaction transaction commodity types The corresponding transaction commodity information is pushed to the user.

可以在用户交易时,将推送给所述用户的交易商品信息打印在所述用户的账单上,或者电子票据中,从而获得用户的关注。When the user trades, the trade commodity information pushed to the user can be printed on the user's bill or in the electronic bill, so as to gain the attention of the user.

还可以向用户推送与用户的消费阶段相匹配的商品。Products that match the user's consumption stage can also be pushed to the user.

具体的,获取用户的实时交易信息;Specifically, obtain real-time transaction information of users;

根据所述实时交易信息确定实时的交易商品类型,并向所述用户推送与所述用户的消费阶段相匹配的交易商品信息。Determine the real-time transaction commodity type according to the real-time transaction information, and push transaction commodity information matching the user's consumption stage to the user.

在所述用户相匹配的商品信息对应的交易商品类型中,确定与所述实时交易的交易商品类型相匹配的交易商品类型,并将与所述实时交易的交易商品类型相匹配的交易商品类型对应的交易商品信息推送给所述用户。Among the transaction commodity types corresponding to the commodity information matched by the user, determine the transaction commodity types that match the real-time transaction transaction commodity types, and match the transaction commodity types that match the real-time transaction transaction commodity types The corresponding transaction commodity information is pushed to the user.

基于相同的技术构思,本发明实施例还提供一种交易数据处理装置,该装置可执行上述方法实施例。本发明实施例提供的装置如图2所示。Based on the same technical concept, an embodiment of the present invention also provides a transaction data processing device, which can execute the above method embodiments. The device provided by the embodiment of the present invention is shown in FIG. 2 .

如图2所示,为本发明实施例提供的一种交易数据处理装置,该装置包括:As shown in Figure 2, it is a transaction data processing device provided by an embodiment of the present invention, which includes:

获取单元201,用于获取用户的历史交易信息,所述历史交易信息包括交易金额、交易商品类型;An acquisition unit 201, configured to acquire the user's historical transaction information, the historical transaction information including transaction amount and transaction commodity type;

确定单元202,用于根据所述交易金额确定所述用户的交易金额平均值,并根据所述用户的交易金额平均值以及交易商品类型确定所述用户的加权交易金额平均值,并根据所述加权交易金额平均值确定所述用户的消费等级;从所述用户的交易商品类型中确定所述用户的特征交易商品类型,所述特征交易商品类型为该交易商品类型对应的交易次数大于该交易商品类型对应的阈值、且该交易商品类型属于消费阶段中预设的交易商品类型;根据所述用户的特征交易商品类型确定所述用户所处的消费阶段;The determining unit 202 is configured to determine the average transaction amount of the user according to the transaction amount, and determine the weighted average transaction amount of the user according to the average transaction amount of the user and the type of transaction commodity, and determine the average transaction amount of the user according to the average transaction amount of the user. The average value of the weighted transaction amount determines the consumption level of the user; the characteristic transaction commodity type of the user is determined from the transaction commodity type of the user, and the characteristic transaction commodity type is that the number of transactions corresponding to the transaction commodity type is greater than the transaction The threshold value corresponding to the commodity type, and the transaction commodity type belongs to the preset transaction commodity type in the consumption stage; the consumption stage of the user is determined according to the user's characteristic transaction commodity type;

匹配单元203,用于根据所述用户的消费等级和所述用户所处的消费阶段,确定与所述用户相匹配的商品信息。The matching unit 203 is configured to determine commodity information matching the user according to the consumption level of the user and the consumption stage of the user.

优选的,所述获取单元201具体用于:Preferably, the acquisition unit 201 is specifically configured to:

在分布式存储系统中确定存储所述用户的历史交易信息的数据库节点;Determining a database node storing the user's historical transaction information in the distributed storage system;

根据数据库节点的状态标识确定所述存储所述用户的历史交易信息的数据库节点中处于活跃状态的数据库节点;determining an active database node among the database nodes storing the user's historical transaction information according to the status identifier of the database node;

通过所述处于活跃状态的数据库节点获取所述用户的历史交易信息。The historical transaction information of the user is obtained through the active database node.

优选的,该装置还包括检测单元204,所述检测单元204通过以下方式确定数据库节点的状态标识:Preferably, the device further includes a detection unit 204, and the detection unit 204 determines the state identifier of the database node in the following manner:

向数据库节点发送检测报文,若在预设时间段内未接收到所述数据库节点的响应报文,则确定所述数据库节点处于失效状态,并将所述数据库节点的状态标识确定为失效状态,否则将所述数据库节点的状态标识确定为活跃状态。Send a detection message to the database node, if the response message of the database node is not received within the preset time period, then determine that the database node is in an invalid state, and determine the state identifier of the database node as an invalid state , otherwise, determine the state identifier of the database node as an active state.

优选的,该装置还包括备份单元205,所述备份单元205用于:Preferably, the device also includes a backup unit 205, and the backup unit 205 is used for:

确定与所述处于失效状态的数据库节点中存储的数据相同、且处于活跃状态的数据库节点;Determining a database node that has the same data stored in the database node in the failure state and is in an active state;

对所述与所述处于失效状态的数据库节点中存储的数据相同、且处于活跃状态的数据库节点中存储的数据备份至其他处于活跃状态的数据库节点。The data stored in the active database node that is the same as the data stored in the failed database node is backed up to other active database nodes.

优选的,所述确定单元202具体用于:Preferably, the determining unit 202 is specifically configured to:

根据以下公式确定用户的加权交易金额平均值:The average weighted transaction amount of a user is determined according to the following formula:

Mm == ΣΣ ee == 11 NN CC ee ×× DD. // NN

其中,M表示用户的加权交易金额平均值,D表示用户的交易金额平均值,Ce表示第e次交易的交易商品类型的加权值,e大于等于1且小于等于N,N表示交易次数;Among them, M represents the average value of the weighted transaction amount of the user, D represents the average value of the transaction amount of the user, C e represents the weighted value of the transaction commodity type of the e-th transaction, e is greater than or equal to 1 and less than or equal to N, and N represents the number of transactions;

将所述用户的加权交易金额平均值对应的等级确定所述用户的消费等级。The consumption level of the user is determined by the level corresponding to the average weighted transaction amount of the user.

优选的,所述匹配单元203具体用于:Preferably, the matching unit 203 is specifically used for:

确定与所述用户的消费等级一致的其他用户;Identify other users who are consistent with the user's consumption level;

确定所述其他用户的历史交易信息中的交易商品类型;Determine the transaction commodity type in the other user's historical transaction information;

在所述其他用户的历史交易信息中的交易商品类型中,确定与所述用户所处的消费阶段相匹配的交易商品类型,并将与所述用户所处的消费阶段相匹配的交易商品类型对应的交易商品信息确定为与所述用户相匹配的商品信息。Among the transaction commodity types in the historical transaction information of the other users, determine the transaction commodity types that match the consumption stage of the user, and determine the transaction commodity types that match the consumption stage of the user The corresponding transaction commodity information is determined as the commodity information matching the user.

优选的,所述匹配单元203具体用于:Preferably, the matching unit 203 is specifically used for:

获取商家的商家属性信息以及商家的历史交易信息,所述商家属性信息中包括交易商品类型,所述商家的历史交易信息中包括交易金额;Obtaining merchant attribute information and merchant historical transaction information of the merchant, the merchant attribute information including the transaction commodity type, and the merchant historical transaction information including the transaction amount;

将商家的交易金额平均值在同一范围内、且商家的交易商品类型相同的商家划分为一个商家聚类;Merchants with the average transaction amount of merchants within the same range and merchants with the same type of transaction commodities are divided into a merchant cluster;

将商家的交易金额平均值与所述用户的消费等级相匹配、且商家的交易商品类型属于所述用户所处的消费阶段的商家聚类,确定为与所述用户相匹配的商家聚类;Matching the average transaction amount of the merchant with the consumption level of the user, and the merchant cluster whose transaction commodity type belongs to the consumption stage of the user is determined as the merchant cluster matching the user;

将所述与所述用户相匹配的商家聚类对应的商品信息确定为与所述用户相匹配的商品信息。The product information corresponding to the merchant cluster matching the user is determined as the product information matching the user.

优选的,该装置还包括推送单元;所述推送单元206具体用于:Preferably, the device also includes a push unit; the push unit 206 is specifically used for:

获取用户的实时交易信息;Obtain real-time transaction information of users;

在所述用户相匹配的商品信息对应的交易商品类型中,确定与所述实时交易的交易商品类型相匹配的交易商品类型,并将与所述实时交易的交易商品类型相匹配的交易商品类型对应的交易商品信息推送给所述用户。Among the transaction commodity types corresponding to the commodity information matched by the user, determine the transaction commodity types that match the real-time transaction transaction commodity types, and match the transaction commodity types that match the real-time transaction transaction commodity types The corresponding transaction commodity information is pushed to the user.

本发明实施例中,是通过用户的线下交易记录确定用户的交易金额平均值以及交易商品类型,从而确定用户的消费等级以及消费阶段,最终确定用户的消费行为模型。由于线下交易记录更能反映消费者的真实行为,因此获得的消费行为模型更加准确。In the embodiment of the present invention, the user's average transaction amount and transaction commodity type are determined through the user's offline transaction records, thereby determining the user's consumption level and consumption stage, and finally determining the user's consumption behavior model. Since offline transaction records can better reflect the real behavior of consumers, the obtained consumption behavior model is more accurate.

本发明是参照根据本发明实施例的方法、设备(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器指令,使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。The present invention is described with reference to flowchart illustrations and/or block diagrams of methods, apparatus (systems), and computer program products according to embodiments of the invention. It should be understood that each procedure and/or block in the flowchart and/or block diagram, and a combination of procedures and/or blocks in the flowchart and/or block diagram can be realized by computer program instructions. These computer program instructions may be provided to a processor of a general purpose computer, special purpose computer, embedded processor, or other programmable data processing device to produce a machine instruction such that the instructions executed by the processor of the computer or other programmable data processing device produce Means for realizing the functions specified in one or more procedures of the flowchart and/or one or more blocks of the block diagram.

这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的计算机可读存储器中,使得存储在该计算机可读存储器中的指令产生包括指令装置的制造品,该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。These computer program instructions may also be stored in a computer-readable memory capable of directing a computer or other programmable data processing apparatus to operate in a specific manner, such that the instructions stored in the computer-readable memory produce an article of manufacture comprising instruction means, the instructions The device realizes the function specified in one or more procedures of the flowchart and/or one or more blocks of the block diagram.

这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上,使得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理,从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。These computer program instructions can also be loaded onto a computer or other programmable data processing device, causing a series of operational steps to be performed on the computer or other programmable device to produce a computer-implemented process, thereby The instructions provide steps for implementing the functions specified in the flow diagram procedure or procedures and/or block diagram procedures or blocks.

尽管已描述了本发明的优选实施例,但本领域内的技术人员一旦得知了基本创造性概念,则可对这些实施例作出另外的变更和修改。所以,所附权利要求意欲解释为包括优选实施例以及落入本发明范围的所有变更和修改。While preferred embodiments of the invention have been described, additional changes and modifications to these embodiments can be made by those skilled in the art once the basic inventive concept is appreciated. Therefore, it is intended that the appended claims be construed to cover the preferred embodiment as well as all changes and modifications which fall within the scope of the invention.

显然,本领域的技术人员可以对本发明进行各种改动和变型而不脱离本发明的范围。这样,倘若本发明的这些修改和变型属于本发明权利要求的范围之内,则本发明也意图包含这些改动和变型在内。Obviously, those skilled in the art can make various changes and modifications to the present invention without departing from the scope of the present invention. Thus, if these modifications and variations of the present invention fall within the scope of the claims of the present invention, the present invention is also intended to include these modifications and variations.

Claims (16)

1. a transaction data processing method, it is characterised in that the method includes:
Obtaining the historical transactional information of user, described historical transactional information includes dealing money, trader's category Type;
The dealing money meansigma methods of described user is determined according to described dealing money, and according to the friendship of described user Easily amount of money meansigma methods and tradable commodity type determine the weighting dealing money meansigma methods of described user, and according to Described weighting dealing money meansigma methods determines the consumption grade of described user;
The feature tradable commodity type of described user, described spy is determined from the tradable commodity type of described user Levying tradable commodity type is that transaction count corresponding to this tradable commodity type is corresponding more than this tradable commodity type Threshold value and this tradable commodity type belong in consumer phase preset tradable commodity type;
Feature tradable commodity type according to described user determines the consumer phase residing for described user;
Consumer phase residing for consumption grade according to described user and described user, determines and described user's phase The merchandise news of coupling.
2. the method for claim 1, it is characterised in that the historical trading letter of described acquisition user Breath, including:
The database node of the historical transactional information storing described user is determined in distributed memory system;
Status indicator according to database node determines the number of the historical transactional information of the described user of described storage According to the database node being in active state in the node of storehouse;
The historical transactional information of described user is obtained by the described database node being in active state.
3. method as claimed in claim 2, it is characterised in that determine that data base saves in the following manner The status indicator of point:
Detection messages is sent, if not receiving described database node in preset time period to database node Response message, it is determined that described database node is in failure state, and by the shape of described database node State mark is defined as failure state, otherwise the status indicator of described database node is defined as active state.
4. method as claimed in claim 3, it is characterised in that the described shape by described database node After state mark is defined as failure state, also include:
Determine and in the described database node being in failure state, the data of storage are identical and be in and enliven shape The database node of state;
To in the described and described database node being in failure state, the data of storage are identical and are in active The data backup stored in the database node of state is in the database node of active state to other.
5. the method as described in any one of Claims 1-4, it is characterised in that described according to described friendship Easily the amount of money determines the dealing money meansigma methods of described user, and according to the dealing money meansigma methods of described user with And tradable commodity type determines the weighting dealing money meansigma methods of described user, and according to described weighting trade gold Volume meansigma methods determines the consumption grade of described user, including:
The weighting dealing money meansigma methods of user is determined according to below equation:
M = Σ e = 1 N C e × D / N
Wherein, M represents the weighting dealing money meansigma methods of user, and D represents the dealing money meansigma methods of user, CeRepresenting the weighted value of the tradable commodity type concluded the business the e time, e is more than or equal to 1 and less than or equal to N, N Represent transaction count;
Grade corresponding for the weighting dealing money meansigma methods of described user is determined the consumption grade of described user.
6. the method for claim 1, it is characterised in that the described consumption etc. according to described user Level and the consumer phase residing for described user, determine the merchandise news matched with described user, including:
Determine other users consistent with the consumption grade of described user;
Determine the tradable commodity type in the historical transactional information of other users described;
In tradable commodity type in the historical transactional information of other users described, determine and described user institute The tradable commodity type that the consumer phase at place matches, and will match with the consumer phase residing for described user Tradable commodity information corresponding to tradable commodity type be defined as the merchandise news that matches with described user.
7. the method for claim 1, it is characterised in that the described consumption etc. according to described user Level and the consumer phase residing for described user, determine the merchandise news matched with described user, including:
Obtain businessman's attribute information and the historical transactional information of businessman of businessman, in described businessman attribute information Including tradable commodity type, the historical transactional information of described businessman includes dealing money;
By the business that the dealing money meansigma methods of businessman is in same scope and the tradable commodity type of businessman is identical Family is divided into businessman's cluster;
The consumption grade of the dealing money meansigma methods of businessman Yu described user is matched and the trader of businessman Category type belongs to businessman's cluster of the consumer phase residing for described user, is defined as matching with described user Businessman clusters;
The businessman described and described user matched clusters corresponding merchandise news and is defined as and described user The merchandise news matched.
Method the most as claimed in claims 6 or 7, it is characterised in that the method also includes:
Obtain the real-time deal information of user;
In the tradable commodity type that the merchandise news that matches described user is corresponding, determine and described real-time friendship The tradable commodity type of easy tradable commodity type matching, and by the trader's category with described real-time deal Tradable commodity information pushing corresponding to tradable commodity type that type matches gives described user.
9. a transaction data processing means, it is characterised in that this device includes:
Acquiring unit, for obtaining the historical transactional information of user, described historical transactional information includes trade gold Volume, tradable commodity type;
Determine unit, for determining the dealing money meansigma methods of described user according to described dealing money, and root The weighting trade gold of described user is determined according to the dealing money meansigma methods of described user and tradable commodity type Volume meansigma methods, and the consumption grade of described user is determined according to described weighting dealing money meansigma methods;From described The tradable commodity type of user determines the feature tradable commodity type of described user, described feature tradable commodity Type is threshold value that transaction count corresponding to this tradable commodity type is corresponding more than this tradable commodity type and should Tradable commodity type belongs to the tradable commodity type preset in consumer phase;Feature transaction according to described user The type of merchandise determines the consumer phase residing for described user;
Matching unit, for the consumer phase residing for the consumption grade according to described user and described user, really The fixed merchandise news matched with described user.
10. device as claimed in claim 9, it is characterised in that described acquiring unit specifically for:
The database node of the historical transactional information storing described user is determined in distributed memory system;
Status indicator according to database node determines the number of the historical transactional information of the described user of described storage According to the database node being in active state in the node of storehouse;
The historical transactional information of described user is obtained by the described database node being in active state.
11. devices as claimed in claim 10, it is characterised in that this device also includes detector unit, Described detector unit determines the status indicator of database node in the following manner:
Detection messages is sent, if not receiving described database node in preset time period to database node Response message, it is determined that described database node is in failure state, and by the shape of described database node State mark is defined as failure state, otherwise the status indicator of described database node is defined as active state.
12. devices as claimed in claim 11, it is characterised in that this device also includes backup units, Described backup units is used for:
Determine and in the described database node being in failure state, the data of storage are identical and be in and enliven shape The database node of state;
To in the described and described database node being in failure state, the data of storage are identical and are in active The data backup stored in the database node of state is in the database node of active state to other.
13. devices as described in any one of claim 9 to 12, it is characterised in that described determine unit Specifically for:
The weighting dealing money meansigma methods of user is determined according to below equation:
M = Σ e = 1 N C e × D / N
Wherein, M represents the weighting dealing money meansigma methods of user, and D represents the dealing money meansigma methods of user, CeRepresenting the weighted value of the tradable commodity type concluded the business the e time, e is more than or equal to 1 and less than or equal to N, N Represent transaction count;
Grade corresponding for the weighting dealing money meansigma methods of described user is determined the consumption grade of described user.
14. devices as claimed in claim 9, it is characterised in that described matching unit specifically for:
Determine other users consistent with the consumption grade of described user;
Determine the tradable commodity type in the historical transactional information of other users described;
In tradable commodity type in the historical transactional information of other users described, determine and described user institute The tradable commodity type that the consumer phase at place matches, and will match with the consumer phase residing for described user Tradable commodity information corresponding to tradable commodity type be defined as the merchandise news that matches with described user.
15. devices as claimed in claim 9, it is characterised in that described matching unit specifically for:
Obtain businessman's attribute information and the historical transactional information of businessman of businessman, in described businessman attribute information Including tradable commodity type, the historical transactional information of described businessman includes dealing money;
By the business that the dealing money meansigma methods of businessman is in same scope and the tradable commodity type of businessman is identical Family is divided into businessman's cluster;
The consumption grade of the dealing money meansigma methods of businessman Yu described user is matched and the trader of businessman Category type belongs to businessman's cluster of the consumer phase residing for described user, is defined as matching with described user Businessman clusters;
The businessman described and described user matched clusters corresponding merchandise news and is defined as and described user The merchandise news matched.
16. devices as described in claims 14 or 15, it is characterised in that this device also includes pushing list Unit;Described push unit specifically for:
Obtain the real-time deal information of user;
In the tradable commodity type that the merchandise news that matches described user is corresponding, determine and described real-time friendship The tradable commodity type of easy tradable commodity type matching, and by the trader's category with described real-time deal Tradable commodity information pushing corresponding to tradable commodity type that type matches gives described user.
CN201510617766.9A 2015-09-24 2015-09-24 Transaction data processing method and device Pending CN105931066A (en)

Priority Applications (2)

Application Number Priority Date Filing Date Title
CN201510617766.9A CN105931066A (en) 2015-09-24 2015-09-24 Transaction data processing method and device
PCT/CN2016/099224 WO2017050188A1 (en) 2015-09-24 2016-09-18 Transaction data processing method and device

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN201510617766.9A CN105931066A (en) 2015-09-24 2015-09-24 Transaction data processing method and device

Publications (1)

Publication Number Publication Date
CN105931066A true CN105931066A (en) 2016-09-07

Family

ID=56840073

Family Applications (1)

Application Number Title Priority Date Filing Date
CN201510617766.9A Pending CN105931066A (en) 2015-09-24 2015-09-24 Transaction data processing method and device

Country Status (2)

Country Link
CN (1) CN105931066A (en)
WO (1) WO2017050188A1 (en)

Cited By (11)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
WO2017050188A1 (en) * 2015-09-24 2017-03-30 中国银联股份有限公司 Transaction data processing method and device
CN106600341A (en) * 2016-12-29 2017-04-26 江西博瑞彤芸科技有限公司 Commodity sales volume statistical method
CN106649555A (en) * 2016-11-08 2017-05-10 深圳市中博睿存科技有限公司 Memory unit state marking method and distributed memory system
CN106846132A (en) * 2017-04-12 2017-06-13 杭州纳戒科技有限公司 Merchandise news method for pushing, device and system
CN107403311A (en) * 2017-06-27 2017-11-28 阿里巴巴集团控股有限公司 The recognition methods of account purposes and device
CN108182625A (en) * 2017-12-28 2018-06-19 广州品唯软件有限公司 A kind of electric business user Method of Commodity Recommendation and device
CN109474703A (en) * 2018-12-24 2019-03-15 杭州云纪网络科技有限公司 Personalized product combines method for pushing, apparatus and system
CN109961309A (en) * 2017-12-25 2019-07-02 网智天元科技集团股份有限公司 Business recommended method and system
CN111371853A (en) * 2020-02-24 2020-07-03 中国银联股份有限公司 Resource information pushing method and device, server and storage medium
CN115392406A (en) * 2022-10-28 2022-11-25 山东智豆数字科技有限公司 User classification management method based on historical transaction information
CN116737790A (en) * 2023-05-15 2023-09-12 佛山市大迈信息科技有限公司 Method and system for processing business data of building selling

Families Citing this family (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN109492891B (en) * 2018-10-26 2022-04-29 创新先进技术有限公司 User Churn Prediction Method and Device
CN110766441A (en) * 2019-09-05 2020-02-07 口碑(上海)信息技术有限公司 Resource object processing method and device, storage medium and computer equipment
CN111159398B (en) * 2019-12-05 2023-10-31 银联智策顾问(上海)有限公司 Method and device for identifying merchant types
CN111368543B (en) * 2020-02-18 2023-06-02 银联智策顾问(上海)有限公司 Method and device for determining merchant category
CN113344665B (en) * 2021-05-31 2024-09-06 北京百度网讯科技有限公司 Method, device, electronic device and storage medium for updating product information
CN113837800A (en) * 2021-09-23 2021-12-24 中国银联股份有限公司 Transaction processing method and device

Citations (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN101960479A (en) * 2008-03-03 2011-01-26 雅虎公司 Method and apparatus for social network marketing with advocate referral
CN103325052A (en) * 2013-07-03 2013-09-25 姚明东 Commodity recommendation method based on multidimensional user consumption propensity modeling
CN103927675A (en) * 2014-04-18 2014-07-16 北京京东尚科信息技术有限公司 Method and device for judging age brackets of users
CN104835057A (en) * 2015-04-02 2015-08-12 百度在线网络技术(北京)有限公司 Method and device for obtaining consumption feature information of network user

Family Cites Families (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN101930576A (en) * 2009-06-23 2010-12-29 微析科技股份有限公司 Customer consumption analysis system
CN102254028A (en) * 2011-07-22 2011-11-23 青岛理工大学 A personalized product recommendation method and system integrating attribute and structure similarity
CN104809626A (en) * 2015-03-17 2015-07-29 徐邑江 Customized commodity recommending method based on user credit assessment
CN105931066A (en) * 2015-09-24 2016-09-07 中国银联股份有限公司 Transaction data processing method and device

Patent Citations (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN101960479A (en) * 2008-03-03 2011-01-26 雅虎公司 Method and apparatus for social network marketing with advocate referral
CN103325052A (en) * 2013-07-03 2013-09-25 姚明东 Commodity recommendation method based on multidimensional user consumption propensity modeling
CN103927675A (en) * 2014-04-18 2014-07-16 北京京东尚科信息技术有限公司 Method and device for judging age brackets of users
CN104835057A (en) * 2015-04-02 2015-08-12 百度在线网络技术(北京)有限公司 Method and device for obtaining consumption feature information of network user

Cited By (16)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
WO2017050188A1 (en) * 2015-09-24 2017-03-30 中国银联股份有限公司 Transaction data processing method and device
CN106649555A (en) * 2016-11-08 2017-05-10 深圳市中博睿存科技有限公司 Memory unit state marking method and distributed memory system
CN106600341A (en) * 2016-12-29 2017-04-26 江西博瑞彤芸科技有限公司 Commodity sales volume statistical method
CN106846132A (en) * 2017-04-12 2017-06-13 杭州纳戒科技有限公司 Merchandise news method for pushing, device and system
CN107403311B (en) * 2017-06-27 2020-04-21 阿里巴巴集团控股有限公司 Account use identification method and device
CN107403311A (en) * 2017-06-27 2017-11-28 阿里巴巴集团控股有限公司 The recognition methods of account purposes and device
CN109961309A (en) * 2017-12-25 2019-07-02 网智天元科技集团股份有限公司 Business recommended method and system
CN109961309B (en) * 2017-12-25 2021-09-28 网智天元科技集团股份有限公司 Service recommendation method and system
CN108182625A (en) * 2017-12-28 2018-06-19 广州品唯软件有限公司 A kind of electric business user Method of Commodity Recommendation and device
CN109474703A (en) * 2018-12-24 2019-03-15 杭州云纪网络科技有限公司 Personalized product combines method for pushing, apparatus and system
CN111371853A (en) * 2020-02-24 2020-07-03 中国银联股份有限公司 Resource information pushing method and device, server and storage medium
WO2021169659A1 (en) * 2020-02-24 2021-09-02 中国银联股份有限公司 Resource information pushing method and device, server, and storage medium
TWI803823B (en) * 2020-02-24 2023-06-01 大陸商中國銀聯股份有限公司 Resource information pushing method, device, server and storage medium
CN115392406A (en) * 2022-10-28 2022-11-25 山东智豆数字科技有限公司 User classification management method based on historical transaction information
CN115392406B (en) * 2022-10-28 2023-04-28 山东智豆数字科技有限公司 User classification management method based on historical transaction information
CN116737790A (en) * 2023-05-15 2023-09-12 佛山市大迈信息科技有限公司 Method and system for processing business data of building selling

Also Published As

Publication number Publication date
WO2017050188A1 (en) 2017-03-30

Similar Documents

Publication Publication Date Title
CN105931066A (en) Transaction data processing method and device
JP6152475B2 (en) Selective sharing of user information based on contextual information, such as crowdsourcing a gift that the recipient is interested in
CA2846025C (en) Recommendations based upon explicit user similarity
US10783568B1 (en) Social merchandising system
JP6440661B2 (en) Determination device, determination method, and determination program
CN108369586A (en) System and method for detecting interaction and influence in network
WO2013173799A1 (en) Reward structures
CN115170294A (en) A client classification method, device and server
CN110503466A (en) A method and device for acquiring consumer groups based on interactive activities
US20170186063A1 (en) System and method for barter support
CN110992095B (en) A method and device for generating a consumer portrait
CN108256919A (en) Electronic red envelope sharing method, first application, electronic equipment and storage medium
CN106886936B (en) Order processing method and device and server
CN107169786B (en) Data resource processing method and device
CN111292126B (en) Supply and demand analysis method, apparatus, device and readable storage medium
CN114240685A (en) High-net-value customer information processing method and system based on relational network
US20170345073A1 (en) Electronic notifications to facilitate collateralized agreements
CN108230042A (en) Demand recognition methods, device, electronic equipment and computer readable storage medium
CN105684030A (en) A real estate network transaction price statistics method and system
CN110503467B (en) A cross-platform consumer crowd acquisition method and device
CN110782325B (en) Member information recommendation method and device
CN116089737A (en) Activity recommendation method, apparatus, computer device and computer readable storage medium
US20160371757A1 (en) Free Time Monetization Exchange
CN116051201B (en) Voice outbound data processing method and device, electronic equipment and storage medium
CN111192112A (en) A multi-platform interaction method and device

Legal Events

Date Code Title Description
C06 Publication
PB01 Publication
C10 Entry into substantive examination
SE01 Entry into force of request for substantive examination
REG Reference to a national code

Ref country code: HK

Ref legal event code: DE

Ref document number: 1225141

Country of ref document: HK

RJ01 Rejection of invention patent application after publication
RJ01 Rejection of invention patent application after publication

Application publication date: 20160907

REG Reference to a national code

Ref country code: HK

Ref legal event code: WD

Ref document number: 1225141

Country of ref document: HK