CN111352674B - 名单流转方法、服务器及计算机可读存储介质 - Google Patents
名单流转方法、服务器及计算机可读存储介质 Download PDFInfo
- Publication number
- CN111352674B CN111352674B CN202010110379.7A CN202010110379A CN111352674B CN 111352674 B CN111352674 B CN 111352674B CN 202010110379 A CN202010110379 A CN 202010110379A CN 111352674 B CN111352674 B CN 111352674B
- Authority
- CN
- China
- Prior art keywords
- list
- circulation
- rule
- list circulation
- data
- 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.)
- Active
Links
- 238000000034 method Methods 0.000 title claims abstract description 52
- 238000003860 storage Methods 0.000 title claims abstract description 15
- 238000012545 processing Methods 0.000 claims abstract description 37
- 230000032683 aging Effects 0.000 claims description 19
- 238000012546 transfer Methods 0.000 claims description 8
- 238000005457 optimization Methods 0.000 claims description 3
- 230000002618 waking effect Effects 0.000 claims description 3
- 238000005520 cutting process Methods 0.000 claims description 2
- 238000007726 management method Methods 0.000 claims description 2
- 238000012384 transportation and delivery Methods 0.000 claims description 2
- 238000001914 filtration Methods 0.000 claims 1
- 238000005516 engineering process Methods 0.000 abstract description 2
- 230000008520 organization Effects 0.000 description 11
- 230000007246 mechanism Effects 0.000 description 9
- 238000010586 diagram Methods 0.000 description 8
- 238000012216 screening Methods 0.000 description 6
- 230000008859 change Effects 0.000 description 5
- 230000006870 function Effects 0.000 description 4
- 238000009826 distribution Methods 0.000 description 3
- 230000004048 modification Effects 0.000 description 3
- 238000012986 modification Methods 0.000 description 3
- 238000004590 computer program Methods 0.000 description 2
- 238000011161 development Methods 0.000 description 2
- 230000018109 developmental process Effects 0.000 description 2
- 230000003287 optical effect Effects 0.000 description 2
- 230000008569 process Effects 0.000 description 2
- 230000002159 abnormal effect Effects 0.000 description 1
- 238000004458 analytical method Methods 0.000 description 1
- 238000013459 approach Methods 0.000 description 1
- 238000004891 communication Methods 0.000 description 1
- 230000008094 contradictory effect Effects 0.000 description 1
- 230000008878 coupling Effects 0.000 description 1
- 238000010168 coupling process Methods 0.000 description 1
- 238000005859 coupling reaction Methods 0.000 description 1
- 238000003032 molecular docking Methods 0.000 description 1
- 238000013468 resource allocation Methods 0.000 description 1
- 230000003068 static effect Effects 0.000 description 1
- 238000011144 upstream manufacturing Methods 0.000 description 1
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/44—Arrangements for executing specific programs
- G06F9/448—Execution paradigms, e.g. implementations of programming paradigms
- G06F9/4482—Procedural
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/24—Querying
- G06F16/245—Query processing
- G06F16/2455—Query execution
- G06F16/24564—Applying rules; Deductive queries
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06Q—INFORMATION 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
- G06Q10/00—Administration; Management
- G06Q10/10—Office automation; Time management
- G06Q10/103—Workflow collaboration or project management
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Business, Economics & Management (AREA)
- Strategic Management (AREA)
- Software Systems (AREA)
- Physics & Mathematics (AREA)
- General Physics & Mathematics (AREA)
- Human Resources & Organizations (AREA)
- Entrepreneurship & Innovation (AREA)
- Data Mining & Analysis (AREA)
- General Engineering & Computer Science (AREA)
- Economics (AREA)
- Marketing (AREA)
- Operations Research (AREA)
- Quality & Reliability (AREA)
- Tourism & Hospitality (AREA)
- General Business, Economics & Management (AREA)
- Computational Linguistics (AREA)
- Databases & Information Systems (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
本发明涉及一种数据处理技术，揭露了一种名单流转方法，该方法包括：接收用户设置的名单流转规则，所述名单流转规则包括规则因子和结果值；判断当前名单的所述名单流转规则所属的类型；按照所述名单流转规则的类型，分别采用基于Java的线程池或者Oracle数据库的Job方法来执行所述名单的流转处理。本发明还提供一种服务器及计算机可读存储介质。本发明提供的名单流转方法、服务器及计算机可读存储介质能够针对不同类型的名单流转规则，采用适合该类型的方式分别执行，实现快速、高效、精准的对名单数据进行流转处理。
Description
技术领域
本发明涉及数据处理技术领域，尤其涉及一种名单流转方法、服务器及计算机可读存储介质。
背景技术
目前，对于任何一家企业，数据流转和资源分配(例如名单流转)都是企业运行中不可或缺的操作。在传统模式中通常由人员手工进行操作，但是有些数据流转拥有复杂的逻辑关系，这样不仅使得成本变高、耗时耗力，而且准确性和效率都比较低下。为了追寻更加高效、更具性价比的操作方案，如何快速、精准的对大批量大数量级的任务进行分配下发流转，已经成为一个亟待解决的技术问题。
发明内容
有鉴于此，本发明提出一种名单流转方法、服务器及计算机可读存储介质，以解决至少一个上述技术问题。
首先，为实现上述目的，本发明提出一种名单流转方法，该方法包括：
接收用户设置的名单流转规则，所述名单流转规则包括规则因子和结果值；
判断当前名单的所述名单流转规则所属的类型；及
按照所述名单流转规则的类型，分别采用基于Java的线程池或者Oracle数据库的Job方法来执行所述名单的流转处理。
可选地，该方法在所述接收用户设置的名单流转规则之前还包括：
采用规则引擎的方式提供所述名单流转规则的前端设置。
可选地，所述规则因子为对名单数据的筛选条件，所述结果值包括通过则进行流转或不通过不进行流转。
可选地，所述类型包括：第一类为设置后只执行一次且时效小于或等于预设期限的名单流转规则，第二类为设置一次后需要多次使用且时效大于预设期限的名单流转规则。
可选地，所述按照所述名单流转规则的类型，分别基于Java的线程池或者Oracle数据库的Job方法来执行所述名单的流转处理的步骤包括：
针对第一类的名单流转规则，将对应名单交由基于Java的线程池来执行；
针对第二类的名单流转规则，将对应名单交由基于Oracle数据库的Job来执行。
可选地，针对第一类的名单流转规则，所述基于Java的线程池来执行所述名单的流转处理包括：
当接收到需要执行的名单流转规则后，唤醒线程池中的消费线程；
被唤醒的消费线程执行所述名单流转规则的逻辑实体，然后将所述名单流转规则流转成不同的名单状态；
依据所述名单状态将名单数据通过不同的MQ消息进行分发，从而实现名单流转。
可选地，针对第二类的名单流转规则，所述基于Oracle数据库的Job方法来执行所述名单的流转处理包括：
根据所述名单流转规则创建数据库优化索引；
按照预设维度对所述名单流转规则对应的名单数据进行切块；
针对切块后的名单数据执行所述名单流转规则，实现数据加工流转，得到不同的名单状态；
根据所述名单状态由异步任务将名单流转给下游渠道系统。
可选地，所述名单状态包括异常单、待认领、已自留、管理转新、兜底转新。
此外，为实现上述目的，本发明还提供一种服务器，包括存储器、处理器，所述存储器上存储有可在所述处理器上运行的名单流转系统，所述名单流转系统被所述处理器执行时实现如上述的名单流转方法的步骤。
进一步地，为实现上述目的，本发明还提供一种计算机可读存储介质，所述计算机可读存储介质存储有名单流转系统，所述名单流转系统可被至少一个处理器执行，以使所述至少一个处理器执行如上述的名单流转方法的步骤。
相较于现有技术，本发明所提出的名单流转方法、服务器及计算机可读存储介质，只需在前端页面设置好相应名单流转规则后，后续繁杂的任务就可以交由系统进行精准流转，不但可以减轻员工的负担，还可以避免人为不可控的失误。并且，针对不同类型的名单流转规则，采用适合该类型的方式分别执行，可以提高处理效率，提高工作效率和工作质量，实现快速、高效、精准的对名单数据进行流转处理。
附图说明
图1是本发明服务器一可选的硬件架构的示意图；
图2是本发明名单流转系统第一实施例的程序模块示意图；
图3是本发明名单流转系统第二实施例的程序模块示意图；
图4是本发明名单流转方法第一实施例的流程示意图；
图5是图4中步骤S404的一种细化流程示意图；
图6是图4中步骤S404的另一种细化流程示意图；
图7是本发明名单流转方法第二实施例的流程示意图；
本发明目的的实现、功能特点及优点将结合实施例，参照附图做进一步说明。
具体实施方式
为了使本发明的目的、技术方案及优点更加清楚明白，以下结合附图及实施例，对本发明进行进一步详细说明。应当理解，此处所描述的具体实施例仅用以解释本发明，并不用于限定本发明。基于本发明中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例，都属于本发明保护的范围。
需要说明的是，在本发明中涉及“第一”、“第二”等的描述仅用于描述目的，而不能理解为指示或暗示其相对重要性或者隐含指明所指示的技术特征的数量。由此，限定有“第一”、“第二”的特征可以明示或者隐含地包括至少一个该特征。另外，各个实施例之间的技术方案可以相互结合，但是必须是以本领域普通技术人员能够实现为基础，当技术方案的结合出现相互矛盾或无法实现时应当认为这种技术方案的结合不存在，也不在本发明要求的保护范围之内。
参阅图1所示，是本发明服务器2一可选的硬件架构的示意图。
本实施例中，所述服务器2可包括，但不仅限于，可通过系统总线相互通信连接存储器11、处理器12、网络接口13。需要指出的是，图1仅示出了具有组件11-13的服务器2，但是应理解的是，并不要求实施所有示出的组件，可以替代的实施更多或者更少的组件。
其中，所述服务器2可以是机架式服务器、刀片式服务器、塔式服务器或机柜式服务器等计算设备，该服务器2可以是独立的服务器，也可以是多个服务器所组成的服务器集群。
所述存储器11至少包括一种类型的可读存储介质，所述可读存储介质包括闪存、硬盘、多媒体卡、卡型存储器(例如，SD或DX存储器等)、随机访问存储器(RAM)、静态随机访问存储器(SRAM)、只读存储器(ROM)、电可擦除可编程只读存储器(EEPROM)、可编程只读存储器(PROM)、磁性存储器、磁盘、光盘等。在一些实施例中，所述存储器11可以是所述服务器2的内部存储单元，例如该服务器2的硬盘或内存。在另一些实施例中，所述存储器11也可以是所述服务器2的外部存储设备，例如该服务器2上配备的插接式硬盘，智能存储卡(SmartMedia Card,SMC)，安全数字(Secure Digital,SD)卡，闪存卡(Flash Card)等。当然，所述存储器11还可以既包括所述服务器2的内部存储单元也包括其外部存储设备。本实施例中，所述存储器11通常用于存储安装于所述服务器2的操作系统和各类应用软件，例如名单流转系统200的程序代码等。此外，所述存储器11还可以用于暂时地存储已经输出或者将要输出的各类数据。
所述处理器12在一些实施例中可以是中央处理器(Central Processing Unit，CPU)、控制器、微控制器、微处理器、或其他数据处理芯片。该处理器12通常用于控制所述服务器2的总体操作。本实施例中，所述处理器12用于运行所述存储器11中存储的程序代码或者处理数据，例如运行所述的名单流转系统200等。
所述网络接口13可包括无线网络接口或有线网络接口，该网络接口13通常用于在所述服务器2与其他电子设备之间建立通信连接。
至此，己经详细介绍了本发明相关设备的硬件结构和功能。下面，将基于上述介绍提出本发明的各个实施例。
首先，本发明提出一种名单流转系统200。
参阅图2所示，是本发明名单流转系统200第一实施例的程序模块图。
本实施例中，所述名单流转系统200包括一系列的存储于存储器11上的计算机程序指令，当该计算机程序指令被处理器12执行时，可以实现本发明各实施例的名单流转操作。在一些实施例中，基于该计算机程序指令各部分所实现的特定的操作，名单流转系统200可以被划分为一个或多个模块。例如，在图2中，所述名单流转系统200可以被分割成接收模块201、判断模块202、执行模块203。其中：
所述接收模块201，用于接收用户设置的名单流转规则。
具体地，因为用户很多，不同用户有不同的层级，因此用户会拥有不同的角色权限，只有特定的角色和机构层级的用户才能设置名单流转规则。用户在申请相应角色权限后方可操作对应的规则设置页面，在页面中用户可以设置想要的规则因子以及结果值，规则因子可以设置多个。在用户设置并提交后，将接收到的所述名单流转规则保存在数据库表中。所述名单流转规则对应一个或多个名单。
其中，规则因子可以为筛选条件，即对哪一部分的数据进行处理，如名单所属机构、名单来源、所属业务员等。结果值有两种，一种是通过则进行流转，还有一种是不通过不进行流转。
例如，机构E有100个业务员，现在想将其中98个业务员对应的名单进行流转(转给新的业务员)，而剩余2个业务员对应的名单不进行流转，那么机构E设置规则时就可以设置这98个业务员对应的名单通过(也可以设置成那2个业务员对应的名单不通过)。最终就是匹配规则的名单(通过的98个业务员对应的名单)进行流转，没匹配规则的就自留或者进行其他操作。
该功能基于B/S结构，用户只需要在前端页面设置好相应的规则后，后台程序后续就会在指定的时间按照指定的规则逻辑来执行，最终将名单流转到各个渠道。
所述判断模块202，用于判断当前名单的所述名单流转规则所属的类型。
在本实施例中，所述类型主要包括两种：第一类为设置后只执行一次且时效要求较高(时效小于或等于预设期限)的流转规则，第二类为设置一次后需要多次使用及对时效要求不高(时效大于预设期限)的流转规则。
时效要求高的即是用户急着使用的数据，如用户通过前端导入的数据，还有如结算数据修改规则用户设置后只希望执行一次，这一类规则通常对应的数据量较少且用户着急使用。而有一些数据量较为庞大的数据，所设置的规则用户可能一段时间后才会应用到，且需要多次使用，例如用户设置后每月特定时间执行一次。
所述执行模块203，用于按照所述名单流转规则的类型，分别采用基于Java的线程池或者Oracle数据库的Job方法来执行所述名单的流转处理。
具体地，根据用户设置的所述名单流转规则，后台程序执行相应的规则因子，通过结果值来达到最终执行结果(流转或不流转)。针对所述第一类的名单流转规则，即设置后只执行一次且时效要求较高的，将对应名单交由基于Java的线程池来执行。针对所述第二类的名单流转规则，即设置一次后需要多次使用及对时效要求不高的，将对应名单交由基于Oracle数据库的Job来实现。
具体处理过程参见图5和图6及相关说明，在此不再赘述。
本实施例提供的名单流转系统，可以实现快速、高效、精准的对大批量大数量级的任务进行分配下发流转，打破原有的复杂的工作模式，一劳永逸。即只需在前端页面设置好相应规则后，后续繁杂的任务就可以交由系统进行精准流转，不但可以减轻员工的负担，还可以避免人为不可控的失误。并且，针对不同类型的名单流转规则，采用适合该类型的方式分别执行，可以提高处理效率，提高工作效率和工作质量。另外，也使得公司在处理分配海量级的数据时可以变得得心应手，帮助公司节省大量的人员支出，能够更好的支持公司和团队的稳健发展。
参阅图3所示，是本发明名单流转系统200第二实施例的程序模块图。本实施例中，所述的名单流转系统200除了包括第一实施例中的所述接收模块201、判断模块202、执行模块203之外，还包括设置模块204。
所述设置模块204，用于采用规则引擎的方式提供所述名单流转规则的前端设置。
具体地，对于一些经常可能会变动的规则，还可以对接规则引擎来实现即使规则发生变化底层逻辑依然可以保持不变。
采用规则引擎的方式，机构在前端设置好对应规则因子。如果名单流转规则发生变化，可以通过前端设置规则的方式，快速修改为新的规则，然后直接使用设置的新规则进行后续的名单流转处理。
如果是既定规则的方式，将规则写死在代码中，由代码直接判断，当规则调整时，系统需要再次开发。而前端设置规则的话，就可以解决该问题。规则在后台的判断是可变化的、可配的、动态的，当机构调整完所述名单流转规则后，后台规则引擎可以即刻应用新的规则进行判断，处理效率更高，且不用多次代码重新开发。
此外，本发明还提出一种名单流转方法。
参阅图4所示，是本发明名单流转方法第一实施例的流程示意图。在本实施例中，根据不同的需求，图4所示的流程图中的步骤的执行顺序可以改变，某些步骤可以省略。
该方法包括以下步骤：
步骤S400，接收用户设置的名单流转规则。
具体地，因为用户很多，不同用户有不同的层级，因此用户会拥有不同的角色权限，只有特定的角色和机构层级的用户才能设置名单流转规则。用户在申请相应角色权限后方可操作对应的规则设置页面，在页面中用户可以设置想要的规则因子以及结果值，规则因子可以设置多个。在用户设置并提交后，将接收到的所述名单流转规则保存在数据库表中。所述名单流转规则对应一个或多个名单。
其中，规则因子可以为筛选条件，即对哪一部分的数据进行处理，如名单所属机构、名单来源、所属业务员等。结果值有两种，一种是通过则进行流转，还有一种是不通过不进行流转。
例如，机构E有100个业务员，现在想将其中98个业务员对应的名单进行流转(转给新的业务员)，而剩余2个业务员对应的名单不进行流转，那么机构E设置规则时就可以设置这98个业务员对应的名单通过(也可以设置成那2个业务员对应的名单不通过)。最终就是匹配规则的名单(通过的98个业务员对应的名单)进行流转，没匹配规则的就自留或者进行其他操作。
该功能基于B/S结构，用户只需要在前端页面设置好相应的规则后，后台程序后续就会在指定的时间按照指定的规则逻辑来执行，最终将名单流转到各个渠道。
步骤S402，判断当前名单的所述名单流转规则所属的类型。
在本实施例中，所述类型主要包括两种：第一类为设置后只执行一次且时效要求较高(时效小于或等于预设期限)的流转规则，第二类为设置一次后需要多次使用及对时效要求不高(时效大于预设期限)的流转规则。
时效要求高的即是用户急着使用的数据，如用户通过前端导入的数据，还有如结算数据修改规则用户设置后只希望执行一次，这一类规则通常对应的数据量较少且用户着急使用。而有一些数据量较为庞大的数据，所设置的规则用户可能一段时间后才会应用到，且需要多次使用，例如用户设置后每月特定时间执行一次。
步骤S404，按照所述名单流转规则的类型，分别采用基于Java的线程池或者Oracle数据库的Job方法来执行所述名单的流转处理。
具体地，根据用户设置的所述名单流转规则，后台程序执行相应的规则因子，通过结果值来达到最终执行结果(流转或不流转)。针对所述第一类的名单流转规则，即设置后只执行一次且时效要求较高的，将对应名单交由基于Java的线程池来执行。针对所述第二类的名单流转规则，即设置一次后需要多次使用及对时效要求不高的，将对应名单交由基于Oracle数据库的Job来实现。
进一步参阅图5所示，在本实施例中，针对所述第一类的名单流转规则，步骤S404具体包括以下过程：
步骤S500，当接收到需要执行的名单流转规则后，唤醒线程池中的消费线程。
具体地，在没有任务或者任务量较少的时候线程池内维持最少的线程数，且处于休眠状态，当有任务为待执行状态时就会立即唤醒线程池中的消费线程来执行。
步骤S502，被唤醒的消费线程执行所述名单流转规则的逻辑实体，然后将规则流转成不同的名单状态。
具体地，被唤醒的消费线程获取到待执行的所述名单流转规则的规则ID，根据所述规则ID调用Oracle数据库的Package(包)，在数据库层执行规则的逻辑实体，然后将规则流转成不同的名单状态。也就是说，根据用户设置的所述名单流转规则，后台程序执行相应的规则因子，通过结果值来达到最终执行结果，得到不同的名单状态。其中，所述名单状态包括异常单、待认领、已自留、管理转新、兜底转新等。
步骤S504，依据名单状态将名单数据发送成不同的消息队列(Message Queue，MQ)消息进行分发，从而实现名单流转。
具体地，当得到不同的名单状态后，依据名单状态将名单数据发送成不同的MQ消息，以使下游渠道系统通过订阅相应的MQ消息即可实现名单流转。具体而言，根据上述不同的名单状态，可以发送同一topic(主题，一级分类)下不同tag(标签，二级分类)的MQ消息。下游系统就可以订阅该topic下的相应tag的MQ消息来获取想要的数据。
例如，现在有xx年xx月的百万级数据需要分发流转，这些数据属于全国各个省份机构，不同机构又想按照自己的规则来流转。因此，每个机构只需要设置好该机构对应的名单流转规则，然后后台程序就会依据所述名单流转规则将数据流转成不同的名单状态，然后依据名单状态发送不同的MQ消息，下游系统订阅相应消息获取数据即可。
这样不单可以加速名单流转的效率和准确性，还可以将不同用户不同系统进行解耦合，防止牵一发而动全身。例如，之前的模式是通过视图或者kettle等方式来将数据推送至下游系统，这样上下游两个系统之间的耦合性就很高，若一方变动基础架构另一方也必须变动，而本实施例这种方式就不需要。
针对所述第二类的名单流转规则，步骤S404具体包括以下过程：
步骤S600，根据所述名单流转规则创建数据库优化索引。
具体地，这一方式完全是在数据库层进行实现，可以减少交付和网络资源的消耗。首先，依据所述名单流转规则中的筛选条件将所述名单流转规则对应的名单数据进行数据库性能分析，然后创建最优的索引，如组合索引等。
所示索引是用来加快数据处理的速度，减少数据库资源消耗。例如从一亿条数据里面筛选某一条，如果有索引则只需要很短的时间(零点几秒)，如果没有索引则可能需要大半天时间。在本实施例中，所述索引是根据所述名单流转规则进行创建的，在后续筛选符合所述名单流转规则的名单数据和根据所述根据所述名单流转规则进行流转处理时，都可以根据所述索引快速找到相应数据。
步骤S602，按照预设维度对所述名单流转规则对应的数据进行切块。
具体地，按照预设维度对所述名单流转规则对应的数据进行数据库切块，既可以降低CPU和内存的消耗，也能加快后续处理效率。所述预设维度例如机构、月份等。按照机构和/或月份将所述名单流转规则对应的名单的一大块数据切分成多个小块。
步骤S604，针对切块后的数据执行所述名单流转规则，实现数据加工流转，得到不同的名单状态。
具体地，对数据库进行切块后即可满足大批量百万级数据的加工流转。针对每一块的数据，分别执行所述名单流转规则，执行完流转规则后名单被流转成了各个不同的名单状态。
步骤S606，根据名单状态由异步任务将名单流转给下游渠道系统。
具体地，根据不同的名单状态将名单数据分成不同的处理任务，再由异步任务将名单流转给下游渠道系统。
本实施例提供的名单流转方法，可以实现快速、高效、精准的对大批量大数量级的任务进行分配下发流转，打破原有的复杂的工作模式，一劳永逸。即只需在前端页面设置好相应规则后，后续繁杂的任务就可以交由系统进行精准流转，不但可以减轻员工的负担，还可以避免人为不可控的失误。并且，针对不同类型的名单流转规则，采用适合该类型的方式分别执行，可以提高处理效率，提高工作效率和工作质量。另外，也使得公司在处理分配海量级的数据时可以变得得心应手，帮助公司节省大量的人员支出，能够更好的支持公司和团队的稳健发展。
如图7所示，是本发明名单流转方法的第二实施例的流程示意图。本实施例中，所述应续名单跟踪方法的步骤S702-S706与第一实施例的步骤S400-S404相类似，区别在于该方法还包括步骤S700。
该方法包括以下步骤：
步骤S700，采用规则引擎的方式提供所述名单流转规则的前端设置。
具体地，对于一些经常可能会变动的规则，还可以对接规则引擎来实现即使规则发生变化底层逻辑依然可以保持不变。
采用规则引擎的方式，机构在前端设置好对应规则因子。如果名单流转规则发生变化，可以通过前端设置规则的方式，快速修改为新的规则，然后直接使用设置的新规则进行后续的名单流转处理。
如果是既定规则的方式，将规则写死在代码中，由代码直接判断，当规则调整时，系统需要再次开发。而前端设置规则的话，就可以解决该问题。规则在后台的判断是可变化的、可配的、动态的，当机构调整完所述名单流转规则后，后台规则引擎可以即刻应用新的规则进行判断，处理效率更高，且不用多次代码重新开发。
步骤S702，接收用户设置的名单流转规则。
具体地，因为用户很多，不同用户有不同的层级，因此用户会拥有不同的角色权限，只有特定的角色和机构层级的用户才能设置名单流转规则。用户在申请相应角色权限后方可操作对应的规则设置页面，在页面中用户可以设置想要的规则因子以及结果值，规则因子可以设置多个。在用户设置并提交后，将接收到的所述名单流转规则保存在数据库表中。所述名单流转规则对应一个或多个名单。
其中，规则因子可以为筛选条件，即对哪一部分的数据进行处理，如名单所属机构、名单来源、所属业务员等。结果值有两种，一种是通过则进行流转，还有一种是不通过不进行流转。
例如，机构E有100个业务员，现在想将其中98个业务员对应的名单进行流转(转给新的业务员)，而剩余2个业务员对应的名单不进行流转，那么机构E设置规则时就可以设置这98个业务员对应的名单通过(也可以设置成那2个业务员对应的名单不通过)。最终就是匹配规则的名单(通过的98个业务员对应的名单)进行流转，没匹配规则的就自留或者进行其他操作。
该功能基于B/S结构，用户只需要在前端页面设置好相应的规则后，后台程序后续就会在指定的时间按照指定的规则逻辑来执行，最终将名单流转到各个渠道。
步骤S704，判断当前名单的所述名单流转规则所属的类型。
在本实施例中，所述类型主要包括两种：第一类为设置后只执行一次且时效要求较高(时效小于或等于预设期限)的流转规则，第二类为设置一次后需要多次使用及对时效要求不高(时效大于预设期限)的流转规则。
时效要求高的即是用户急着使用的数据，如用户通过前端导入的数据，还有如结算数据修改规则用户设置后只希望执行一次，这一类规则通常对应的数据量较少且用户着急使用。而有一些数据量较为庞大的数据，所设置的规则用户可能一段时间后才会应用到，且需要多次使用，例如用户设置后每月特定时间执行一次。
步骤S706，按照所述名单流转规则的类型，分别采用基于Java的线程池或者Oracle数据库的Job方法来执行所述名单的流转处理。
具体地，根据用户设置的所述名单流转规则，后台程序执行相应的规则因子，通过结果值来达到最终执行结果(流转或不流转)。针对所述第一类的名单流转规则，即设置后只执行一次且时效要求较高的，将对应名单交由基于Java的线程池来执行。针对所述第二类的名单流转规则，即设置一次后需要多次使用及对时效要求不高的，将对应名单交由基于Oracle数据库的Job来实现。
具体处理过程参见上述第一实施例，在此不再赘述。
本实施例提供的名单流转方法，可以通过对接规则引擎，以前端设置规则的方式快速修改新规则，然后直接使用设置的新规则进行后续的名单流转处理。规则在后台的判断是可变化的、可配的、动态的，当机构调整完所述名单流转规则后，后台规则引擎可以即刻应用新规则进行判断，处理效率更高，且不用多次代码重新开发。
本发明还提供了另一种实施方式，即提供一种计算机可读存储介质，所述计算机可读存储介质存储有名单流转程序，所述名单流转程序可被至少一个处理器执行，以使所述至少一个处理器执行如上述的名单流转方法的步骤。
上述本发明实施例序号仅仅为了描述，不代表实施例的优劣。
通过以上的实施方式的描述，本领域的技术人员可以清楚地了解到上述实施例方法可借助软件加必需的通用硬件平台的方式来实现，当然也可以通过硬件，但很多情况下前者是更佳的实施方式。基于这样的理解，本发明的技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来，该计算机软件产品存储在一个存储介质(如ROM/RAM、磁碟、光盘)中，包括若干指令用以使得一台终端设备(可以是手机，计算机，服务器，空调器，或者网络设备等)执行本发明各个实施例所述的方法。
以上仅为本发明的优选实施例，并非因此限制本发明的专利范围，凡是利用本发明说明书及附图内容所作的等效结构或等效流程变换，或直接或间接运用在其他相关的技术领域，均同理包括在本发明的专利保护范围内。
Claims (6)
1.一种名单流转方法，其特征在于，所述方法包括：
接收用户设置的名单流转规则，所述名单流转规则包括规则因子和结果值；
判断当前名单的所述名单流转规则所属的类型，所述类型包括：第一类为设置后只执行一次且时效小于或等于预设期限的名单流转规则，第二类为设置一次后需要多次使用且时效大于预设期限的名单流转规则；及
按照所述名单流转规则的类型，分别采用基于Java的线程池或者Oracle数据库的Job方法来执行所述名单的流转处理，包括：针对第一类的名单流转规则，将对应名单交由基于Java的线程池来执行；针对第二类的名单流转规则，将对应名单交由基于Oracle数据库的Job来执行；
其中，所述针对第一类的名单流转规则，将对应名单交由基于Java的线程池来执行，包括：当接收到需要执行的名单流转规则后，唤醒线程池中的消费线程；被唤醒的消费线程执行所述名单流转规则的逻辑实体，然后将所述名单流转规则流转成不同的名单状态；依据所述名单状态将名单数据通过不同的MQ消息进行分发，从而实现名单流转；
所述针对第二类的名单流转规则，将对应名单交由基于Oracle数据库的Job来执行，包括：根据所述名单流转规则创建数据库优化索引；按照预设维度对所述名单流转规则对应的名单数据进行切块；针对切块后的名单数据执行所述名单流转规则，实现数据加工流转，得到不同的名单状态；根据所述名单状态由异步任务将名单流转给下游渠道系统。
2.如权利要求1所述的名单流转方法，其特征在于，该方法在所述接收用户设置的名单流转规则之前还包括：
采用规则引擎的方式提供所述名单流转规则的前端设置。
3.如权利要求1或2所述的名单流转方法，其特征在于，所述规则因子为对名单数据的筛选条件，所述结果值包括通过则进行流转或不通过不进行流转。
4.如权利要求1所述的名单流转方法，其特征在于，所述名单状态包括异常单、待认领、已自留、管理转新、兜底转新。
5.一种服务器，其特征在于，所述服务器包括存储器、处理器，所述存储器上存储有可在所述处理器上运行的名单流转系统，所述名单流转系统被所述处理器执行时实现如权利要求1-4中任一项所述的名单流转方法的步骤。
6.一种计算机可读存储介质，其特征在于，所述计算机可读存储介质存储有名单流转系统，所述名单流转系统可被至少一个处理器执行，以使所述至少一个处理器执行如权利要求1-4中任一项所述的名单流转方法的步骤。
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010110379.7A CN111352674B (zh) | 2020-02-21 | 2020-02-21 | 名单流转方法、服务器及计算机可读存储介质 |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010110379.7A CN111352674B (zh) | 2020-02-21 | 2020-02-21 | 名单流转方法、服务器及计算机可读存储介质 |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN111352674A CN111352674A (zh) | 2020-06-30 |
| CN111352674B true CN111352674B (zh) | 2023-07-07 |
Family
ID=71192356
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202010110379.7A Active CN111352674B (zh) | 2020-02-21 | 2020-02-21 | 名单流转方法、服务器及计算机可读存储介质 |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN111352674B (zh) |
Citations (9)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| WO2017076259A1 (zh) * | 2015-11-05 | 2017-05-11 | 中兴通讯股份有限公司 | 一种流程设计方法、客户机、服务器侧装置及系统 |
| CN107656819A (zh) * | 2016-07-25 | 2018-02-02 | 武汉票据交易中心有限公司 | 一种业务流程的处理方法及相关系统 |
| CN107784591A (zh) * | 2017-02-16 | 2018-03-09 | 平安科技（深圳）有限公司 | 名单数据处理方法及装置 |
| CN107886295A (zh) * | 2017-10-23 | 2018-04-06 | 东软集团股份有限公司 | 流程模板变更处理方法、装置、可读存储介质及电子设备 |
| CN109669931A (zh) * | 2018-12-29 | 2019-04-23 | 上海携程商务有限公司 | 历史数据异常分析方法、系统、设备及存储介质 |
| CN110413419A (zh) * | 2018-04-28 | 2019-11-05 | 北京京东尚科信息技术有限公司 | 一种规则执行的方法和装置 |
| CN110569258A (zh) * | 2018-05-18 | 2019-12-13 | 上海产业技术研究院 | 规则处理系统、方法、电子终端、及存储介质 |
| CN110599119A (zh) * | 2019-08-27 | 2019-12-20 | 南凌科技股份有限公司 | 一种面向业务可定制的工作流引擎算法 |
| CN110704037A (zh) * | 2019-08-28 | 2020-01-17 | 贵州医渡云技术有限公司 | 一种规则引擎实现方法及装置 |
Family Cites Families (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US8965827B2 (en) * | 2011-03-30 | 2015-02-24 | Computer Sciences Corporation | Rules execution platform system and method |
| US8935664B2 (en) * | 2011-10-05 | 2015-01-13 | International Business Machines Corporation | Method and apparatus to determine rules implementation decision |
| US9152725B2 (en) * | 2011-11-04 | 2015-10-06 | Salesforce.Com, Inc. | Computer implemented methods and apparatus for configuring and performing a custom rule to process a preference indication |
| US9858526B2 (en) * | 2013-03-01 | 2018-01-02 | Exelate, Inc. | Method and system using association rules to form custom lists of cookies |
-
2020
- 2020-02-21 CN CN202010110379.7A patent/CN111352674B/zh active Active
Patent Citations (9)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| WO2017076259A1 (zh) * | 2015-11-05 | 2017-05-11 | 中兴通讯股份有限公司 | 一种流程设计方法、客户机、服务器侧装置及系统 |
| CN107656819A (zh) * | 2016-07-25 | 2018-02-02 | 武汉票据交易中心有限公司 | 一种业务流程的处理方法及相关系统 |
| CN107784591A (zh) * | 2017-02-16 | 2018-03-09 | 平安科技（深圳）有限公司 | 名单数据处理方法及装置 |
| CN107886295A (zh) * | 2017-10-23 | 2018-04-06 | 东软集团股份有限公司 | 流程模板变更处理方法、装置、可读存储介质及电子设备 |
| CN110413419A (zh) * | 2018-04-28 | 2019-11-05 | 北京京东尚科信息技术有限公司 | 一种规则执行的方法和装置 |
| CN110569258A (zh) * | 2018-05-18 | 2019-12-13 | 上海产业技术研究院 | 规则处理系统、方法、电子终端、及存储介质 |
| CN109669931A (zh) * | 2018-12-29 | 2019-04-23 | 上海携程商务有限公司 | 历史数据异常分析方法、系统、设备及存储介质 |
| CN110599119A (zh) * | 2019-08-27 | 2019-12-20 | 南凌科技股份有限公司 | 一种面向业务可定制的工作流引擎算法 |
| CN110704037A (zh) * | 2019-08-28 | 2020-01-17 | 贵州医渡云技术有限公司 | 一种规则引擎实现方法及装置 |
Also Published As
| Publication number | Publication date |
|---|---|
| CN111352674A (zh) | 2020-06-30 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN108196961B (zh) | 一种异步消息处理方法、终端、系统及存储介质 | |
| CN108959292B (zh) | 一种数据上传方法、系统和计算机可读存储介质 | |
| US20210365421A1 (en) | Data analysis method, computer device and storage medium | |
| CN111274052A (zh) | 数据分发方法、服务器及计算机可读存储介质 | |
| US9910658B2 (en) | Optimization of distribution of over-the-air (OTA) updates to portable computing devices | |
| CN110858197A (zh) | 一种同步数据的方法和装置 | |
| CN113254457A (zh) | 一种对账方法、系统及计算机可读存储介质 | |
| CN111897643A (zh) | 线程池配置系统、方法、装置和存储介质 | |
| CN111352674B (zh) | 名单流转方法、服务器及计算机可读存储介质 | |
| CN113220342A (zh) | 中心化配置方法、装置、电子设备及存储介质 | |
| CN113220762A (zh) | 大数据应用中实现关键业务字段变更的通用记录处理的方法、装置、处理器及其存储介质 | |
| CN109600250B (zh) | 业务系统故障通知方法、装置、电子装置及存储介质 | |
| CN112130846A (zh) | 一种三微一屏发布引擎系统及发布方法 | |
| CN108830441B (zh) | 资源查询的方法和装置 | |
| CN110674119A (zh) | 数据处理方法、系统与计算机可读存储介质 | |
| CN110348805B (zh) | 一种名单查漏方法、装置、电子设备及存储介质 | |
| CN114580951A (zh) | 工作流程的配置方法、系统、电子设备和存储介质 | |
| CN111159311B (zh) | 一种数据映射集成的方法、装置、设备及存储介质 | |
| CN112633851A (zh) | 一种控制幂等的方法及装置 | |
| CN114741444A (zh) | 一种组织架构调整方法、装置、电子设备及存储介质 | |
| CN111563250A (zh) | 权限管理方法、装置、计算机设备和存储介质 | |
| CN115529271B (zh) | 业务请求分发方法、装置、设备及介质 | |
| CN112445804B (zh) | 调整运单配置参数的方法和装置 | |
| US8473419B1 (en) | Dependency resolution in publish/subscribe | |
| CN117377045A (zh) | 信息处理方法、装置、系统和计算机可读存储介质 |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |