为多业务平台提供数据支撑的方法及装置、介质、设备

摘要

本发明提供一种为多业务平台提供数据支撑的方法及装置、介质、设备。方法包括：判断人员在配置页面中是否配置公司编码；若是，则判断人员在所述配置页面中配置的各个公司编码中的第一个公司编码属于省级编码还是市级编码；若属于省级编码，则获取每一个公司编码的所属省级和该所属省级下各个地级市的各个公司编码作为目标公司编码；若属于市级编码，则将人员在所述配置页面配置的各个公司编码作为目标公司编码；针对每一个目标公司编码，创建一个对应的线程；通过各个目标公司编码对应的各个线程执行汇总任务，得到汇总数据，并将所述汇总数据存放至分区表中，以供多个业务平台进行调用。本发明实施例可以为各个业务平台提供数据支撑。

说明书

技术领域

本发明涉及数据处理技术领域，尤其是涉及一种为多业务平台提供数据支撑的方法及装置、介质、设备。

背景技术

各个业务平台在需要使用数据时，通常需要对数据进行汇总计算，而多次调用时，需要重复进行汇总计算，这样会导致冗余计算，数据平台的数量越多，冗余计算越多，因此有必要提供一种可以为多个业务平台提供数据支撑服务的方案。

发明内容

针对以上至少一个技术问题，本发明实施例提供一种为多业务平台提供数据支撑的方法及装置、介质、设备。

根据第一方面，本发明实施例提供的为多业务平台提供数据支撑的方法，包括：

判断人员在配置页面中是否配置公司编码；

若是，则判断人员在所述配置页面中配置的各个公司编码中的第一个公司编码属于省级编码还是市级编码；

若属于省级编码，则获取每一个公司编码的所属省级和该所属省级下各个地级市的各个公司编码作为目标公司编码；若属于市级编码，则将人员在所述配置页面配置的各个公司编码作为目标公司编码；

针对每一个目标公司编码，创建一个对应的线程；

通过各个目标公司编码对应的各个线程执行汇总任务，得到汇总数据，并将所述汇总数据存放至分区表中，以供多个业务平台进行调用。

根据第二方面，本发明实施例提供的为多业务平台提供数据支撑的装置，包括：

第一判断模块，用于判断人员在配置页面中是否配置公司编码；

第二判断模块，用于若是，则判断人员在所述配置页面中配置的各个公司编码中的第一个公司编码属于省级编码还是市级编码；

第一确定模块，用于若属于省级编码，则获取每一个公司编码的所属省级和该所属省级下各个地级市的各个公司编码作为目标公司编码；若属于市级编码，则将人员在所述配置页面配置的各个公司编码作为目标公司编码；

第一创建模块，用于针对每一个目标公司编码，创建一个对应的线程；

第一汇总模块，用于通过各个目标公司编码对应的各个线程执行汇总任务，得到汇总数据，并将所述汇总数据存放至分区表中，以供多个业务平台进行调用。

根据第三方面，本发明实施例提供计算机可读存储介质，其上存储有计算机程序，当所述计算机程序在计算机中执行时，令计算机执行实现第一方面提供的方法。

根据第四方面，本发明实施例提供的计算设备，包括存储器和处理器，所述存储器中存储有可执行代码，所述处理器执行所述可执行代码时，实现第一方面提供的方法。

本发明实施例提供的为多业务平台提供数据支撑的方法及装置、介质、设备，判断人员在配置页面中是否配置公司编码；若是，则判断人员在所述配置页面中配置的各个公司编码中的第一个公司编码属于省级编码还是市级编码；若属于省级编码，则获取每一个公司编码的所属省级和该所属省级下各个地级市的各个公司编码作为目标公司编码；若属于市级编码，则将人员在所述配置页面配置的各个公司编码作为目标公司编码；针对每一个目标公司编码，创建一个对应的线程；通过各个目标公司编码对应的各个线程执行汇总任务，得到汇总数据，并将所述汇总数据存放至分区表中，以供多个业务平台进行调用。通过本发明实施例提供的方法，可以为业务平台提供数据支撑，减少数据冗余计算的代码，各业务平台可使用参数调用汇总数据，对结果简易计算或无需计算即可使用。

附图说明

图1为本发明一实施例中为多业务平台提供数据支撑的方法的流程示意图。

具体实施方式

第一方面，本发明实施例提供一种为多业务平台提供数据支撑的方法，参见图1，该方法包括如下步骤S110～S150：

S110、判断人员在配置页面中是否配置公司编码；

也就是说，人员在计算设备的配置页面上会配置一些信息，例如，公司编码、是否传入时间、是否传入指标等。

其中，公司编码是指一个公司的编码参数，不同的公司具有不同的编码。在配置页面中人员配置了多个公司编码的情况下，如果第一个公司编码为省级编码，则其它的公司编码也是省级编码，如果第一个公司编码是市级编码，则其它的公司编码也是市级编码。

可理解的是，如果人员在配置页面未配置公司编码，则可以进行报错，进而结束本方法。

S120、若是，则判断人员在所述配置页面中配置的各个公司编码中的第一个公司编码属于省级编码还是市级编码；

即，如果人员在配置页面中配置了公司编码，则判断这些公司编码中的第一个公司编码是省级编码还是市级编码。

其中，省级编码和市级编码的区分可以依据公司编码的编码方式而确定。

S130、若属于省级编码，则获取每一个公司编码的所属省级和该所属省级下各个地级市的各个公司编码作为目标公司编码；若属于市级编码，则将人员在所述配置页面配置的各个公司编码作为目标公司编码；

可理解的是，如果是第一个公司编码属于省级编码，则说明在配置页面配置的各个公司编码均为省级编码，则针对每一个公司编码，将该公司编码所属的省级以及该省级下各个市级中的各个公司编码作为目标公司编码。如果第一个公司编码为市级编码，则说明在配置页面的各个公司编码均为市级编码，则将在配置页面配置的各个公司编码作为目标公司编码。

可见，这种方式可以大大减少在配置页面需要输入的省级编码的数量。

S140、针对每一个目标公司编码，创建一个对应的线程；

例如，在S130中确定了10个目标公司编码，则可以创建10个线程。

S150、通过各个目标公司编码对应的各个线程执行汇总任务，得到汇总数据，并将所述汇总数据存放至分区表中，以供多个业务平台进行调用。

即，一个线程执行一个公司编码对应的公司的汇总任务，每一个公司的汇总任务完成后，得到这个公司的汇总数据，然后将各个公司的汇总数据分区存储，这样各个业务平台在需要使用汇总数据时，直接进行调用即可。

在实际场景中，可以通过for循环的方式，对各个公司编码对应的各个公司的待汇总数据逐个执行汇总任务，每一个公司的汇总任务可以称之为一个子流程。

在一个实施例中，每一个目标公司编码对应的汇总任务的执行过程可以包括如下步骤a1～a8：

a1、判断人员在所述配置页面中是否选择传入时间；

其中，如果人员在配置页面中选择传入时间，则传入的时间可以为上一次执行失败的时间或者其它自定义的时间。

a2、若是，则将传入的时间作为目标时间；否则，将当前时间作为目标时间；

即，如果人员在配置页面中选择传入时间，则将传入的时间作为目标时间。如果人员在配置页面中没有选择传入时间，则将当前时间作为目标时间。

其中，目标时间的意义在于确定需要进行汇总的数据，即确定待汇总数据。因为不可能对所有的数据进行汇总，只能是选择某个时间段的数据来进行汇总。

a3、判断所述预设库中是否存在该目标公司编码在所述目标时间对应的标志位；若不存在，则在所述预设库中添加该标志位；

其中，预设库可以为redis。

例如，判断在redis中是否存在当前的这个目标公司编码在目标时间对应的标志位，如果不存在，则需要在预设库中添加这个目标公司编码在目标时间对应的标志位。

a4、判断人员在所述配置页面中是否选择传入指标；

a5、若是，则将传入的指标作为目标指标；否则，获取该目标公司编码对应的各个指标，并将该各个指标作为目标指标；

即，判断人员在配置页面中是否选择了传入指标，如果将传入的指标作为目标指标，如果人员没有选择传入指标，则需要将该目标公司编码对应的公式的各个指标作为目标指标。

a6、在日志表中插入开始执行时间；

具体的，可以在日志表的表头插入该汇总任务的开始执行时间，实现对开始执行时间的记录。

a7、对该目标公司编码对应的公司在所述目标时间的待汇总数据以每一个所述目标指标为汇总依据进行汇总处理；

即，将该目标公司编码对应的公司在目标时间的待汇总数据按照每一个目标指标进行汇总，得到每一个目标指标对应的汇总数据。在各个目标指标的汇总工作完成后，汇总结束。其中，可以通过for循环的方式执行对各个目标指标的汇总工作。

a8、在汇总结束后，在所述日志表插入结束执行时间。

即，在汇总结束后，通过向日志表的表头插入结束执行时间，从而实现对结束执行时间的记录。

可理解的是，在一个目标公司编码在一个目标时间的汇总工作结束后，可以将预设库中的对应标志位去除。

在一个实施例中，每一个目标公司编码对应的汇总任务的执行过程还包括：若所述预设库中存在该目标公司编码在所述目标时间对应的标志位，则结束该目标公司编码在所述目标时间对应的汇总任务。

也就是说，如果a3中经过判断发现，在预设库中存在该目标公司编码在所述目标时间对应的标志位，则说明之前已经执行过该目标公司编码在所述目标时间对应的汇总任务，不必执行后续的各个步骤。

在一个实施例中，a7可以具体包括a71～a78：

a71、在所述日志表中插入该目标指标；

也就是说，在针对每一个目标指标进行汇总时，需要在日志表中插入该该目标指标。

a72、判断所述预设库中是否存在该目标指标对应的标志位；

a73、若不存在，则在所述预设库中添加该目标指标对应的标志位，并获取该目标指标对应的至少一个时间维度；

可理解的是，如果在预设库中存在该目标指标对应的标志位，说明该目标指标已经进行过汇总，可以对下一个目标指标进行汇总。而如果在预设库中不存在该目标指标对应的标志位，则需要在预设库中添加该目标指标的标志位。

其中，时间维度，例如，1个月度、一个季度、半个年度、1个年度等。

可理解的是，虽然已经确定了目标时间，但是目标时间的时间长短并未确定，例如，目标时间为2023年1月3日，时间维度为1个月，则在汇总时的待汇总数据是从2023年1月1日至2023年1月31日。

a74、判断该汇总任务是否为定时任务；

其中，汇总任务分为定时任务和非定时任务，而且定时任务或非定时任务又可以分为个性化处理逻辑和标准化处理逻辑。

其中，定时任务是指在某个指定的时间才执行汇总任务，非定时任务是指在当下就执行汇总任务，不需要等到指定的时间。个性化处理逻辑是指需要按照个性化汇总方法进行汇总，标准化处理逻辑是指按照标准化的汇总方法进行汇总。

a75、若定时任务，在指定的时时间点，根据该目标公司编码、该目标时间、该目标指标和所述时间维度，查询是否存在相应的执行记录；

也就是说，如果是定时任务，则需要在指定的时间点执行，因此在执行的时间点判断在日志表中是否存在该目标公司编码、目标时间、目标指标和时间维度的执行记录。

可理解的是，由于是定时任务，有可能在指定的时间点之前，执行过相同的目标公司编码、目标时间、目标指标和时间维度的汇总任务，因此当在指定的时间点时，先检查下日志表中是否有相应的执行记录，如果有的话，且执行结果为成功，则不必再重复执行。如果没有的话，执行后续步骤。

即，a7还可以包括：若存在该目标指标对应的标志位，则跳出该目标指标的汇总过程，并以下一个所述目标指标为汇总依据进行汇总处理。

a76、若不存在执行记录或者执行结果为失败，则判断该目标指标是否对应个性化处理逻辑；

即，如果在日志表中不存在相应的执行记录或者执行记录的执行结果为失败，则需要继续执行该汇总任务，故判断该目标指标的汇总是个性化处理逻辑还是标准化处理逻辑。

a77、若对应个性化处理逻辑，则按照个性化执行逻辑，在指定的时时间点，对该目标公司编码在该目标时间对应的待汇总数据在每一个所述时间维度进行汇总，得到每一个所述时间维度对应的汇总数据；

即，如果是个性化处理逻辑，则在指定的时间点，按照个性化处理逻辑，将该目标公司编码对应的公司在目标时间所在的时间维度的数据按照该目标指标进行汇总，得到汇总数据。

a78、若未对应个性化处理逻辑，则按照标准化执行逻辑，在指定的时时间点，对该目标公司编码在该目标时间对应的待汇总数据在每一个所述时间维度进行汇总，得到每一个所述时间维度对应的汇总数据。

即，如果是标准化处理逻辑，则在指定的时间点，按照标准化处理逻辑，将该目标公司编码对应的公司在目标时间所在的时间维度的数据按照该目标指标进行汇总，得到汇总数据。

在一个实施例中，a7还可以包括：

若该汇总任务不是定时任务，则判断该目标指标是否对应个性化处理逻辑；

若对应个性化处理逻辑，则按照个性化执行逻辑，对该目标公司编码在该目标时间对应的待汇总数据在每一个所述时间维度进行汇总，得到每一个所述时间维度对应的汇总数据；

若未对应个性化处理逻辑，则按照标准化执行逻辑，对该目标公司编码在该目标时间对应的待汇总数据在每一个所述时间维度进行汇总，得到每一个所述时间维度对应的汇总数据。

也就是说，如果不是定时任务，则不必在日志表中查询是否存在相应的执行记录，而是直接判断该目标指标的汇总逻辑是个性化处理逻辑还是标准化处理逻辑。如果是个性化处理逻辑，在当下就按照个性化处理逻辑，将该目标公司编码对应的公司在目标时间所在的时间维度按照该目标指标进行汇总处理，得到汇总数据。如果是标准化处理逻辑，在当下就按照标准化处理逻辑，将该目标公司编码对应的公司在目标时间所在的时间维度按照该目标指标进行汇总处理，得到汇总数据。其中，标准化处理逻辑可以采用标准SQL语句实现。

在一个实施例中，a7还可以包括：

根据每一个时间维度生成对应的周期参数；

在汇总结束后，根据周期参数，计算对比分析结果。

例如，在确定了时间维度之后，还可以将该时间维度转化成相应的时间参数，进而根据时间参数生成本期、同期、上期等周期参数。在汇总完毕之后，可以根据周期参数计算同比、环比等对比分析结果。

可理解的是，在汇总完毕后，对日志表中的执行结束时间进行记录，还可以将预设库中该目标指标对应的标志位去除。

在一个实施例中，可以将原有的待汇总数据所在的数据表中的数据清除，在汇总完成后，将汇总数据插入到数据表中。

其中，前端可以使用vue，后端可以使用spring+spring mvc+mybatis，数据库可以使用db2、oracle或mysql等数据库。

其中，可以通过大数据平台来维护上述各种配置信息，可以为各个业务平台提供数据接口服务及数据直连服务，以供各个业务平台进行数据调用，从而简化各个业务平台的运算占用，减少重复数据重复计算的代码冗余。

可见，本发明实施例提供的方法旨在减少各业务平台对相同数据的重复汇总计算，提高计算汇总效率，对各个业务平台的数据进行统计，通过录入的各业务平台的需求信息进行汇总计算，保存计算结果，在各个业务平台使用该数据时，可以随时取用，无需经过长时间计算，减少业务系统的运算。

具体的，当各个业务平台使用数据时，业务平台可以选择某个指标及相应的时间维度，系统根据各业务平台配置的参数，从分区表中获取，将数据通过接口或数据直接传输方式以固定的格式给对应的业务平台。若各业务平台对数据质量产生疑问，可以对使用指标的指定维度或整个指标进行重新计算。当计算结果与原始数据结果一致，则数据质量无问题；若结果不一致，则对分区表中的数据进行更新，并对各个调用该数据的业务平台重新推送新的汇总数据。

可见，利用本发明实施例提供的方法可以为业务平台提供数据支撑，减少数据冗余计算的代码，各业务平台可使用参数调用汇总数据，对结果简易计算或无需计算即可使用。

第二方面，本发明实施例提供一种为多业务平台提供数据支撑的装置，包括：

第一判断模块，用于判断人员在配置页面中是否配置公司编码；

第二判断模块，用于若是，则判断人员在所述配置页面中配置的各个公司编码中的第一个公司编码属于省级编码还是市级编码；

第一确定模块，用于若属于省级编码，则获取每一个公司编码的所属省级和该所属省级下各个地级市的各个公司编码作为目标公司编码；若属于市级编码，则将人员在所述配置页面配置的各个公司编码作为目标公司编码；

第一创建模块，用于针对每一个目标公司编码，创建一个对应的线程；

第一汇总模块，用于通过各个目标公司编码对应的各个线程执行汇总任务，得到汇总数据，并将所述汇总数据存放至分区表中，以供多个业务平台进行调用。

在一个实施例中，第一汇总模块针对每一个目标公司编码对应的汇总任务设置了如下单元：

第一判断单元，用于判断人员在所述配置页面中是否选择传入时间；

第一确定单元，用于若是，则将传入的时间作为目标时间；否则，将当前时间作为目标时间；

第二判断单元，用于判断所述预设库中是否存在该目标公司编码在所述目标时间对应的标志位；若不存在，则在所述预设库中添加该标志位；

第三判断单元，用于判断人员在所述配置页面中是否选择传入指标；

第二确定单元，用于若是，则将传入的指标作为目标指标；否则，获取该目标公司编码对应的各个指标，并将该各个指标作为目标指标；

第一插入单元，用于在日志表中插入开始执行时间；

第一汇总单元，用于对该目标公司编码对应的公司在所述目标时间的待汇总数据以每一个所述目标指标为汇总依据进行汇总处理；

第二插入单元，用于在汇总结束后，在所述日志表插入结束执行时间。

在一个实施例中，第二判断单元还用于：若所述预设库中存在该目标公司编码在所述目标时间对应的标志位，则结束该目标公司编码在所述目标时间对应的汇总任务。

在一个实施例中，第一汇总单元包括：

第一插入子单元，用于在所述日志表中插入该目标指标；

第一判断子单元，用于判断所述预设库中是否存在该目标指标对应的标志位；

第一添加子单元，用于若不存在，则在所述预设库中添加该目标指标对应的标志位，并获取该目标指标对应的至少一个时间维度；

第二判断子单元，用于判断该汇总任务是否为定时任务；

第一查询子单元，用于若定时任务，在指定的时时间点，根据该目标公司编码、该目标时间、该目标指标和所述时间维度，查询是否存在相应的执行记录；

第三判断子单元，用于若不存在执行记录或者执行结果为失败，则判断该目标指标是否对应个性化处理逻辑；

第一汇总子单元，用于若对应个性化处理逻辑，则按照个性化执行逻辑，在指定的时时间点，对该目标公司编码在该目标时间对应的待汇总数据在每一个所述时间维度进行汇总，得到每一个所述时间维度对应的汇总数据；

第二汇总子单元，用于若未对应个性化处理逻辑，则按照标准化执行逻辑，在指定的时时间点，对该目标公司编码在该目标时间对应的待汇总数据在每一个所述时间维度进行汇总，得到每一个所述时间维度对应的汇总数据。

在一个实施例中，第一汇总单元还包括：

第一跳出子单元，用于若存在该目标指标对应的标志位，则跳出该目标指标的汇总过程，并以下一个所述目标指标为汇总依据进行汇总处理。

在一个实施例中，第一汇总单元还包括：

第四判断子单元，用于若该汇总任务不是定时任务，则判断该目标指标是否对应个性化处理逻辑；

第三汇总子单元，用于若对应个性化处理逻辑，则按照个性化执行逻辑，对该目标公司编码在该目标时间对应的待汇总数据在每一个所述时间维度进行汇总，得到每一个所述时间维度对应的汇总数据；

第四汇总子单元，用于若未对应个性化处理逻辑，则按照标准化执行逻辑，对该目标公司编码在该目标时间对应的待汇总数据在每一个所述时间维度进行汇总，得到每一个所述时间维度对应的汇总数据。

在一个实施例中，第一汇总单元还包括：

第一生成子单元，用于根据每一个时间维度生成对应的周期参数；

第一分析子单元，用于在汇总结束后，根据周期参数，计算对比分析结果。

可理解的是，本发明实施例提供的装置中有关内容的解释、具体实施方式、有益效果、举例等内容可以参见第一方面提供的方法中的相应部分，此处不再赘述。

第三方面，本发明实施例提供一种计算机可读介质，所述计算机可读介质上存储有计算机指令，所述计算机指令在被处理器执行时，使所述处理器执行第一方面提供的方法。

具体地，可以提供配有存储介质的系统或者装置，在该存储介质上存储着实现上述实施例中任一实施例的功能的软件程序代码，且使该系统或者装置的计算机(或CPU或MPU)读出并执行存储在存储介质中的程序代码。

在这种情况下，从存储介质读取的程序代码本身可实现上述实施例中任何一项实施例的功能，因此程序代码和存储程序代码的存储介质构成了本发明的一部分。

用于提供程序代码的存储介质实施例包括软盘、硬盘、磁光盘、光盘(如CD-ROM、CD-R、CD-RW、DVD-ROM、DVD-RAM、DVD-RW、DVD+RW)、磁带、非易失性存储卡和ROM。可选择地，可以由通信网络从服务器计算机上下载程序代码。

此外，应该清楚的是，不仅可以通过执行计算机所读出的程序代码，而且可以通过基于程序代码的指令使计算机上操作的操作系统等来完成部分或者全部的实际操作，从而实现上述实施例中任意一项实施例的功能。

此外，可以理解的是，将由存储介质读出的程序代码写到插入计算机内的扩展板中所设置的存储器中或者写到与计算机相连接的扩展模块中设置的存储器中，随后基于程序代码的指令使安装在扩展板或者扩展模块上的CPU等来执行部分和全部实际操作，从而实现上述实施例中任一实施例的功能。

可理解的是，本发明实施例提供的计算机可读介质中有关内容的解释、具体实施方式、有益效果、举例等内容可以参见第一方面提供的方法中的相应部分，此处不再赘述。

第四方面，本说明书一个实施例提供了一种计算设备，包括存储器和处理器，所述存储器中存储有可执行代码，所述处理器执行所述可执行代码时，实现执行说明书中任一个实施例中的方法。

可理解的是，本发明实施例提供的计算设备中有关内容的解释、具体实施方式、有益效果、举例等内容可以参见第一方面提供的方法中的相应部分，此处不再赘述。

本说明书中的各个实施例均采用递进的方式描述，各个实施例之间相同相似的部分互相参见即可，每个实施例重点说明的都是与其他实施例的不同之处。尤其，对于装置实施例而言，由于其基本相似于方法实施例，所以描述的比较简单，相关之处参见方法实施例的部分说明即可。

本领域技术人员应该可以意识到，在上述一个或多个示例中，本发明所描述的功能可以用硬件、软件、挂件或它们的任意组合来实现。当使用软件实现时，可以将这些功能存储在计算机可读介质中或者作为计算机可读介质上的一个或多个指令或代码进行传输。

以上所述的具体实施方式，对本发明的目的、技术方案和有益效果进行了进一步详细说明，所应理解的是，以上所述仅为本发明的具体实施方式而已，并不用于限定本发明的保护范围，凡在本发明的技术方案的基础之上，所做的任何修改、等同替换、改进等，均应包括在本发明的保护范围之内。