本申请涉及数据处理,尤其涉及一种交易数据处理方法、装置、电子设备及存储介质。
背景技术:
1、计费规则和价格是创新产品占领市场的关键要素。在与重点机构合作过程中,出现了一种新的商务定价:基于商户维度、按照交易时序累计交易金额,根据累计金额进行层级划分,不同层级采用不同的计费方式。
2、现有技术方案是将交易先按照主体分组(例如商户),然后合并同一个主体发生的关联交易,如消费及后续撤销交易。再按照交易发生时间排序后,按时间先后开始层级计费运算。例如某商户先后发生了a,b,c,d四笔交易,其中d是a交易的撤销交易。按照商户的交易时序,在计算c之后,发现a交易对应的撤销交易d发生了,那需要对a,b,c交易都进行重算。另外,实际交易数据中,经常出现间隔时间较大的反向交易,如a是上午发生的消费交易,d是晚上发生成的撤销交易。这样就会导致同一商户重新计算交易累计金额的严重拖尾,交易层级划分的效率较低。
技术实现思路
1、本申请提供了一种交易数据处理方法、装置、电子设备及存储介质,用以解决现有技术重新计算交易累计金额存在严重拖尾,交易层级划分的效率较低的问题。
2、第一方面,本申请提供了一种交易数据处理方法,所述方法包括:
3、将设定时间段内的各条交易数据,按照交易时间顺序,根据预设的时间步长划分至各个数据块中;
4、针对各个商户,确定所述各个数据块中所述商户的第一交易累计金额;
5、根据所述各条交易数据的交易关联值,确定关联交易数据;根据所述关联交易数据对所属的数据块中,所述关联交易数据对应的商户的第一交易累计金额进行修正,得到所述各个数据块中所述商户的第二交易累计金额;
6、根据所述各个数据块中所述商户的第二交易累计金额,确定所述商户的各交易数据各自对应的计费层级和计费方式。
7、第二方面,本申请提供了一种交易数据处理装置,所述装置包括:
8、划分模块,用于将设定时间段内的各条交易数据,按照交易时间顺序,根据预设的时间步长划分至各个数据块中;
9、确定模块,用于针对各个商户,确定所述各个数据块中所述商户的第一交易累计金额;
10、修正模块,用于根据所述各条交易数据的交易关联值,确定关联交易数据;根据所述关联交易数据对所属的数据块中,所述关联交易数据对应的商户的第一交易累计金额进行修正,得到所述各个数据块中所述商户的第二交易累计金额;
11、计费模块,用于根据所述各个数据块中所述商户的第二交易累计金额,确定所述商户的各交易数据各自对应的计费层级和计费方式。
12、第三方面,本申请提供了一种电子设备,包括处理器、通信接口、存储器和通信总线,其中,处理器,通信接口,存储器通过通信总线完成相互间的通信;
13、存储器,用于存放计算机程序;
14、处理器,用于执行存储器上所存放的程序时,实现所述的方法步骤。
15、第四方面,本申请提供了一种计算机可读存储介质,所述计算机可读存储介质内存储有计算机程序,所述计算机程序被处理器执行时实现所述的方法步骤。
16、本申请提供了一种交易数据处理方法、装置、电子设备及存储介质,所述方法包括:将设定时间段内的各条交易数据,按照交易时间顺序,根据预设的时间步长划分至各个数据块中;针对各个商户,确定所述各个数据块中所述商户的第一交易累计金额;根据所述各条交易数据的交易关联值,确定关联交易数据;根据所述关联交易数据对所属的数据块中,所述关联交易数据对应的商户的第一交易累计金额进行修正,得到所述各个数据块中所述商户的第二交易累计金额;根据所述各个数据块中所述商户的第二交易累计金额,确定所述商户的各交易数据各自对应的计费层级和计费方式。
17、上述的技术方案具有如下优点或有益效果:
18、本申请中,对于设定时间段内的各条交易数据,按照交易时间顺序,根据预设的时间步长划分至各个数据块中;针对各个商户,可以并行地确定各个数据块中商户的第一交易累计金额;进而根据各条交易数据的交易关联值,确定关联交易数据,然后根据关联交易数据对所属的数据块中对应商户的第一交易累计金额进行修正,得到第二交易累计金额;最后根据各个数据块中商户的第二交易累计金额,确定商户的各交易数据各自对应的计费层级和计费方式。本申请将交易数据按照时间顺序划分至对应的数据块中,可以并行计算各数据块内各商户的第一交易累计金额,当出现交易修正时,也就是存在关联交易数据时,仅对关联交易数据所属的数据块中的对应商户的第一交易累计金额进行修正,得到数据块中商户的第二交易累计金额。进而根据第二交易累计金额确定商户的各交易数据各自对应的计费层级和计费方式。通过并行处理数据块内的交易数据,并且仅修正关联交易数据所属的数据块中的对应商户的第一交易累计金额的方式,提高了交易数据处理的效率,解决了现有技术重新计算交易累计金额存在严重拖尾,交易层级划分的效率较低的问题。
1.一种交易数据处理方法,其特征在于,所述方法包括:
2.如权利要求1所述的方法,其特征在于,所述将设定时间段内的各条交易数据,按照交易时间顺序,根据预设的时间步长划分至各个数据块中之后,针对各个商户,确定所述各个数据块中所述商户的第一交易累计金额之前,所述方法还包括:
3.如权利要求1所述的方法,其特征在于,根据所述关联交易数据对所属的数据块中,所述关联交易数据对应的商户的第一交易累计金额进行修正,得到所述各个数据块中所述商户的第二交易累计金额包括:
4.如权利要求3所述的方法,其特征在于,根据所述关联交易数据携带的交易金额,对所述数据块中所述商户的第一交易累计金额进行修正包括:
5.如权利要求1所述的方法,其特征在于,根据所述各个数据块中所述商户的第二交易累计金额,确定所述商户的各交易数据各自对应的计费层级和计费方式包括:
6.一种交易数据处理装置,其特征在于,所述装置包括:
7.如权利要求6所述的装置,其特征在于,所述划分模块,还用于获取所述各个数据块中的交易数据的数量信息,判断时间顺序相邻的数据块中的交易数据的数量信息之和是否大于预设的交易数量阈值,如果否,对所述时间顺序相邻的数据块进行合并。
8.如权利要求6所述的装置,其特征在于,所述修正模块,具体用于将所述关联交易数据存储至归并收集器,并获取所述关联交易数据的交易类型;其中,所述交易类型包括消费交易、消费撤销交易、消费撤销冲正交易和消费冲正交易;若所述归并收集器中包括类型为消费交易的关联交易数据和类型为消费冲正交易的关联交易数据,或所述归并收集器中包括成对的类型为消费撤销交易的关联交易数据和类型为消费撤销冲正交易的关联交易数据;针对所述归并收集器中的每笔关联交易数据,确定所述关联交易数据所属的数据块以及对应的商户;根据所述关联交易数据携带的交易金额,对所述数据块中所述商户的第一交易累计金额进行修正,得到所述数据块中所述商户的第二交易累计金额。
9.如权利要求8所述的装置,其特征在于,所述修正模块,具体用于若所述关联交易数据为消费交易的关联交易数据,根据所述消费冲正交易的关联交易数据携带的交易金额,确定所述消费交易的关联交易数据的修正交易金额;根据所述修正交易金额,对所述消费交易的关联交易数据所属的数据块中所述商户的第一交易累计金额进行修正。
10.如权利要求6所述的装置,其特征在于,所述计费模块,具体用于针对所述商户的每笔交易数据,确定所述交易数据所属的数据块;将时间顺序位于所述数据块之前的各数据块中所述商户的第二交易累计金额之和,作为基准累计金额;将所述交易数据所属的数据块中,时间顺序位于所述交易数据之前的所述商户的各交易数据的交易金额之和,作为数据块内偏移累计金额;根据所述基准累计金额、所述数据块内偏移累计金额和所述交易数据的交易金额,确定所述交易数据的层级交易金额;根据所述层级交易金额,确定所述交易数据对应的计费层级和计费方式。
11.一种电子设备,其特征在于,包括处理器、通信接口、存储器和通信总线,其中,处理器,通信接口,存储器通过通信总线完成相互间的通信;
12.一种计算机可读存储介质,其特征在于,所述计算机可读存储介质内存储有计算机程序,所述计算机程序被处理器执行时实现权利要求1-5任一项所述的方法步骤。