本技术涉及大数据处理,特别是涉及一种评级数据处理方法、装置、计算机设备、存储介质和计算机程序产品。
背景技术:
1、随着互联网技术的发展,用户个性化的需求也越来越多,更好地获客和留存成为迫切需要,用户成长体系会员等级平台可以较好地解决这一问题。会员等级平台的会员评级是根据用户在应用程序上的账户数据、交易数据、行为数据等对用户进行综合评级,为用户等级保留一定的有效期,在等级到期日进行降级或者保级。
2、传统技术中,在进行用户等级评定时,通常是确定本周期内的账户数据、交易数据、行为数据对用户等级进行评定,但是由于数据传输异常,例如数据传输延迟,会出现用户等级已经计算完成,但该等级计算周期的数据才会到达,这样的数据则无法参与等级计算,从而出现异常情况。因此急需一种能够针对上述数据传输异常情况的解决方案。
技术实现思路
1、基于此,有必要针对上述技术问题,提供一种能够修正数据传输异常带来的评级错误的评级数据处理方法、装置、计算机设备、计算机可读存储介质和计算机程序产品。
2、第一方面,本技术提供一种评级数据处理方法,所述方法包括:
3、获取初始变动评级数据以及等级有效周期;
4、在所述初始变动评级数据对应的目标处理周期位于所述等级有效周期之前时,获取所述目标处理周期的第一等级变动类型;
5、在所述第一等级变动类型为等级保留或等级降低时,获取所述目标处理周期的总变动评级数据,并基于所述初始变动评级数据,更新所述目标处理周期的总变动评级数据;
6、基于更新的所述目标处理周期的总变动评级数据,得到所述目标处理周期的目标变动类型;
7、基于所述目标变动类型以及所述初始变动评级数据,更新所述等级有效周期的总变动评级数据。
8、在其中一个实施例中,所述基于所述目标变动类型以及所述初始变动评级数据,更新所述等级有效周期的总变动评级数据,包括:
9、在所述目标变动类型为等级保留或等级降低时,将所述初始变动评级数据增加至所述等级有效周期的总变动评级数据;
10、在所述目标变动类型为等级提升时,将所述目标处理周期的等级变动评级数据以及所述初始变动评级数据增加至所述等级有效周期的总变动评级数据。
11、在其中一个实施例中,所述方法还包括:
12、在所述第一等级变动类型为等级提升时,将所述初始变动评级数据增加至所述等级有效周期的总变动评级数据。
13、在其中一个实施例中,所述获取初始变动评级数据以及等级有效期之前,包括:
14、获取待处理原数据,并将所述待处理原始数据存储至中间件;
15、在所述待处理原数据存在异常时,基于所述中间件中存储的前后两次获取的所述待处理原数据计算得到差异数据;
16、通过实时计算引擎,基于所述差异数据得到待处理评级数据。
17、在其中一个实施例中,所述获取初始变动评级数据以及等级有效期之后,还包括:
18、在所述初始变动评级数据处理周期位于所述等级有效周期之后时,确定所述初始变动评级数据的数据方向;
19、基于所述数据方向对临时变动字段中的临时评级数据进行更新;
20、在更新后的所述临时评级数据小于目标值时,将目标值缓存至所述临时变动字段,否则将更新后的所述临时评级数据缓存至所述临时变动字段。
21、在其中一个实施例中,所述基于所述目标变动类型以及所述初始变动评级数据,更新所述等级有效周期的总变动评级数据之后,包括:
22、基于所述总变动评级数据确定所述等级有效周期的第二等级变动类型;
23、基于所述第二等级变动类型更新等级变动表中各业务字段,得到等级变更流水记录;
24、基于所述第二等级变动类型更新等级表中第一业务字段,且基于所述临时变动字段的临时评级数据得到所述等级表中的变动评级数据的初始值。
25、第二方面,本技术还提供一种评级数据处理装置,所述装置包括:
26、数据获取模块,用于获取初始变动评级数据以及等级有效期;
27、第一等级变动类型确定模块,用于在所述初始变动评级数据对应的目标处理周期位于所述等级有效周期之前时,获取所述目标处理周期的第一等级变动类型;
28、更新模块,用于在所述第一等级变动类型为等级保留或等级降低时,获取所述目标处理周期的总变动评级数据,并基于所述初始变动评级数据,更新所述目标处理周期的总变动评级数据;
29、目标变动类型确定模块,用于基于更新的所述目标处理周期的总变动评级数据,得到所述目标处理周期的目标变动类型;
30、评级数据更新模块,用于基于所述目标变动类型以及所述初始变动评级数据,更新所述等级有效周期的总变动评级数据。
31、在其中一个实施例中,所述评级数据更新模块具体用于在所述目标变动类型为等级保留或等级降低时,将所述初始变动评级数据增加至所述等级有效周期的总变动评级数据;在所述目标变动类型为等级提升时,将所述目标处理周期的等级变动评级数据以及所述初始变动评级数据增加至所述等级有效周期的总变动评级数据。
32、在其中一个实施例中,所述评级数据更新模块具体用于在所述第一等级变动类型为等级提升时,将所述初始变动评级数据增加至所述等级有效周期的总变动评级数据。
33、在其中一个实施例中,所述装置还包括:
34、原始数据获取模块,用于获取待处理原数据,并将所述待处理原始数据存储至中间件;
35、差异数据确定模块,用于在所述待处理原数据存在异常时,基于所述中间件中存储的前后两次获取的所述待处理原数据计算得到差异数据;
36、评级数据计算模块,用于通过实时计算引擎基于所述差异数据得到待处理评级数据。
37、在其中一个实施例中,所述装置还包括:
38、数据方向确定模块,用于在所述初始变动评级数据处理周期位于所述等级有效周期之后时,确定所述初始变动评级数据的数据方向;
39、临时评级数据更新模块,用于基于所述数据方向对临时变动字段中的临时评级数据进行更新;
40、缓存模块,用于在更新后的所述临时评级数据小于目标值时,将目标值缓存至所述临时变动字段,否则将更新后的所述临时评级数据缓存至所述临时变动字段。
41、在其中一个实施例中,所述装置还包括:
42、等级更新模块,用于基于所述总变动评级数据确定所述等级有效周期的第二等级变动类型;基于所述第二等级变动类型更新等级变动表中各业务字段,得到等级变更流水记录;基于所述第二等级变动类型更新等级表中第一业务字段,且基于所述临时变动字段的临时评级数据得到所述等级表中的变动评级数据的初始值。
43、第三方面,本技术还提供一种计算机设备,包括存储器和处理器,所述存储器存储有计算机程序,所述处理器执行所述计算机程序时实现上述的任意一个实施例中的方法的步骤。
44、第四方面,本技术还提供一种计算机可读存储介质,其上存储有计算机程序,所述计算机程序被处理器执行时实现上述的任意一个实施例中的方法的步骤。
45、第五方面,本技术还提供一种计算机程序产品,包括计算机程序,该计算机程序被处理器执行时实现上述的任意一个实施例中的方法的步骤。
46、上述评级数据处理方法、装置、计算机设备、存储介质和计算机程序产品,获取初始变动评级数据以及等级有效期;在初始变动评级数据对应的目标处理周期位于所述等级有效周期之前时,即数据延迟时,获取目标处理周期的第一等级变动类型,且确定等级变动类型为保留级别或降级时,基于目标周期的总变动评级数据以及初始变动评级数据确定目标周期实际的目标变动类型,进而基于目标变动类型以及初始变动评级数据,更新等级有效周期的总变动评级数据,这样通过对延迟数据进行处理,使得迟到的数据也可以参与等级的计算,从而可以修正数据传输异常带来的评级错误。
1.一种评级数据处理方法,其特征在于,所述方法包括:
2.根据权利要求1所述的方法,其特征在于,所述基于所述目标变动类型以及所述初始变动评级数据,更新所述等级有效周期的总变动评级数据,包括:
3.根据权利要求1所述的方法,其特征在于,所述方法还包括:
4.根据权利要求1所述的方法,其特征在于,所述获取初始变动评级数据以及等级有效期之前,包括:
5.根据权利要求1至4任意一项所述的方法,其特征在于,所述获取初始变动评级数据以及等级有效期之后,还包括:
6.根据权利要求5所述的方法,其特征在于,所述基于所述目标变动类型以及所述初始变动评级数据,更新所述等级有效周期的总变动评级数据之后,包括:
7.一种评级数据处理装置,其特征在于,所述装置包括:
8.根据权利要求7所述的装置,其特征在于,所述评级数据更新模块具体用于在所述目标变动类型为等级保留或等级降低时,将所述初始变动评级数据增加至所述等级有效周期的总变动评级数据;在所述目标变动类型为等级提升时,将所述目标处理周期的等级变动评级数据以及所述初始变动评级数据增加至所述等级有效周期的总变动评级数据。
9.根据权利要求7所述的装置,其特征在于,所述评级数据更新模块具体用于在所述第一等级变动类型为等级提升时,将所述初始变动评级数据增加至所述等级有效周期的总变动评级数据。
10.根据权利要求7所述的装置,其特征在于,所述装置还包括:
11.根据权利要求7至10任意一项所述的装置,其特征在于,所述装置还包括:
12.根据权利要求11所述的装置,其特征在于,所述装置还包括:
13.一种计算机设备,包括存储器和处理器,所述存储器存储有计算机程序,其特征在于,所述处理器执行所述计算机程序时实现权利要求1至6中任一项所述的方法的步骤。
14.一种计算机可读存储介质,其上存储有计算机程序,其特征在于,所述计算机程序被处理器执行时实现权利要求1至6中任一项所述的方法的步骤。
15.一种计算机程序产品,包括计算机程序,其特征在于,该计算机程序被处理器执行时实现权利要求1至6中任一项所述的方法的步骤。
