一种基于多表复制和实时监听的客户回单生成方法

1.一种基于多表复制和实时监听的客户回单生成方法，其特征在于，包括以下步骤：
(1)各渠道交易流水和登记簿数据通过Q复制技术实时同步到ODS系统；在各渠道进行的每项动账类交易过程中，都会在核心账务系统产生相应的账务流水，在其渠道登记簿中产生相对应的业务数据，其中渠道登记簿数据包含：业务编号、交易日期、交易类型、交易编码、收付款账号、收付款户名、收付款行号、收付款行名、交易币种、交易金额、手续费、交易状态、操作员、备注、附言字段；
(2)客户回单系统启动3台应用服务器的7*24小时实时监听程序，3台应用服务器分别定义为应用A、应用B、应用C，其中应用A和应用B监听除柜面业务以外的所有交易流水，定义该流水表名为tableLS；应用C监听柜面业务交易流水，定义该流水表名为tableTellerLS；
每个应用服务器通过定时器每隔10秒启动一个主线程，主线程对核心账务系统交易流水表进行监听，核心账务系统交易流水表主要包括：主机流水号、交易流水笔次、交易日期、账号、币种、发生额、借贷标志、科目号、分录交易码、代理行机构码、操作员、机器时间、流水状态、备注、备用字段，每次获取30笔交易流水数据，通过线程并发技术，每一笔流水均起一个单独的线程进行对应渠道的匹配和回单数据的生成；具体为：
(2.1)应用A和应用B读取的是同一张核心账务系统交易流水表tableLS，采用带锁读操作，对于需要生成客户回单的交易流水，通过匹配规则，关联相应的渠道登记簿，获取渠道登记簿中相应的交易信息，并对数据进行加工处理后，形成客户回单系统登记簿数据，具体步骤如下：
(2.1.1)将事务提交模式置为不自动提交；
(2.1.2)带锁读取tableLS表中的30笔数据，遍历每一笔流水，同时做如下操作：通过流水数据中的科目号和账号规则，判断是否属于特定科目参数或属于特定配置的账号，如果是，则需将该流水数据进行删除操作；通过流水数据中的业务编号和机器操作员规则，判断该流水是否属于柜面业务系统发起，如果是，则将该流水从表tableLS转移到表tableTellerLS；将流水数据中的特定字段打上已读取标识；
(2.1.3)事务手动提交，并将事务提交模式置为自动提交；
(2.1.4)循环遍历每一笔交易流水，并做如下处理：
a)首先判断该笔交易流水是否已经生成回单，如果已经生成了，则进一步判断该流水状态是否发生变化，如果状态变化，则需要同步更新回单状态，最后统一删除已生成回单的流水数据；
b)获取该笔流水的分录，判断该笔流水的分录是否在系统参数表中配置成需要直接生成收付款方只有一边的客户回单，如果是，则不需要进行后续渠道登记簿的查找匹配处理，直接生成默认回单；
c)根据交易流水数据中的部分特征值的规则，或者通过将交易流水数据与各个渠道登记簿数据做关联查找，来确定该笔交易流水属于的渠道及登记簿；
d)如果交易流水能够确认渠道登记簿或没有匹配到任何渠道登记簿且要生成默认回单的交易流水，均单独创建子线程，并通过渠道对应的处理程序，将交易流水数据和渠道登记簿数据加工为生成客户回单需要的数据；如果没有匹配到任何渠道登记簿且由于Q复制延迟，需要将流水已读取标识恢复为初始值，暂不进行生成客户回单的操作；
e)判断各渠道生成客户回单数据中的金额、借贷方向、账号是否和流水中一致，若一致，则继续进行其他要素的统一加工处理，若不一致，则按默认回单生成；
f)将加工后的回单数据登记在客户回单系统登记簿中，子线程结束；
(2.1.5)释放资源，主线程结束；
(2.2)应用C负责处理tableTellerLS表中的所有流水，具体步骤如下：
(2.2.1)优先查找已经超过设定的等待时间的交易流水，如果这类数据没有达到一个批次处理的数据量，则继续按照查找次数和交易时间顺序靠前的数据进行处理，即对于被查找次数越少和交易时间越早的数据优先级越高；
(2.2.2)循环遍历每一笔交易流水，并做如下处理：
a)将流水数据中的特定字段打上已读取标识，同时记录查找次数加1；
b)判断柜面业务系统登记簿中是否已经产生对应的登记簿数据，如果已产生，则单独创建子线程，并通过柜面渠道对应的处理程序，将交易流水数据和柜面登记簿数据加工为生成客户回单需要的数据；
c)判断各渠道生成客户回单数据中的金额、借贷方向、账号是否和流水中一致，若一致，则继续进行其他要素的统一加工处理，若不一致，则按默认回单生成；
d)将加工后的回单数据登记在客户回单系统登记簿中，子线程结束；
(2.2.3)释放资源，主线程结束。

一种基于多表复制和实时监听的客户回单生成方法\n技术领域\n[0001] 本发明涉及客户回单生成技术领域，尤其涉及一种利用DB2(关系型数据库管理系统)的Q复制技术，通过多线程并发实时监听交易流水的方式，产生客户所需的交易回单的方法。\n背景技术\n[0002] 近年来，银行机构数据分散存储在各业务系统中，形成信息孤岛，相互之间信息不能共享。特别是对于客户回单数据，缺乏一个公共数据处理平台，而且各个业务系统回单打印格式不统一、回单打印交易不集中。如何将客户回单统一生成，如何提供给客户和柜员一个高效、完整和集中的回单生命周期管理系统，成为我们亟需解决的问题。\n[0003] 目前，柜面业务系统提供的联机交易回单，只是针对通过柜面渠道发起的业务，而像网银、自助终端发起的业务，无法通过柜面交易集中获取和打印，而且网银和自助终端本身提供的回单打印交易，打印的回单数据不完整、甚至收付款方信息不全，给柜员和客户带来了诸多不便。\n[0004] 另外，客户对于交易回单生成的实时性要求也是越来越高，如何在交易高峰期，在产生大量交易流水的情况下，还能保证实时生成客户回单，也是我们亟需解决的问题。\n发明内容\n[0005] 本发明的目的在于针对现有技术的不足，提供一种基于多表复制和实时监听的客户回单生成方法，将柜面系统和其它渠道产生的客户交易流水，通过多线程并发的实时监听技术产生客户所需的交易回单。\n[0006] 本发明的目的是通过以下技术方案来实现的：一种基于多表复制和实时监听的客户回单生成方法，该方法包括以下步骤：\n[0007] (1)各渠道交易流水和登记簿数据通过Q复制技术实时同步到ODS系统；在各渠道进行的每项动账类交易过程中，都会在核心账务系统产生相应的账务流水，在其渠道登记簿中产生相对应的业务数据，其中渠道登记簿数据包含：业务编号、交易日期、交易类型、交易编码、收付款账号、收付款户名、收付款行号、收付款行名、交易币种、交易金额、手续费、交易状态、操作员、备注、附言字段；\n[0008] (2)客户回单系统启动3台应用服务器的7*24小时实时监听程序，3台应用服务器分别定义为应用A、应用B、应用C，其中应用A和应用B监听除柜面业务以外的所有交易流水，定义该流水表名为tableLS；应用C监听柜面业务交易流水，定义该流水表名为tableTellerLS；每个应用服务器通过定时器每隔10秒启动一个主线程，主线程对核心账务系统交易流水表进行监听，核心账务系统交易流水表主要包括：主机流水号、交易流水笔次、交易日期、账号、币种、发生额、借贷标志、科目号、分录交易码、代理行机构码、操作员、机器时间、流水状态、备注、备用字段，每次获取30笔交易流水数据，通过线程并发技术，每一笔流水均起一个单独的线程进行对应渠道的匹配和回单数据的生成；具体为：\n[0009] (2.1)应用A和应用B读取的是同一张核心账务系统交易流水表tableLS，采用带锁读操作，对于需要生成客户回单的交易流水，通过匹配规则，关联相应的渠道登记簿，获取渠道登记簿中相应的交易信息，并对数据进行加工处理后，形成客户回单系统登记簿数据，具体步骤如下：\n[0010] (2.1.1)将事务提交模式置为不自动提交；\n[0011] (2.1.2)带锁读取tableLS表中的30笔数据，遍历每一笔流水，同时做如下操作：通过流水数据中的科目号和账号规则，判断是否属于特定科目参数或属于特定配置的账号，如果是，则需将该流水数据进行删除操作；通过流水数据中的业务编号和机器操作员规则，判断该流水是否属于柜面业务系统发起，如果是，则将该流水从表tableLS转移到表tableTellerLS；将流水数据中的特定字段打上已读取标识；\n[0012] (2.1.3)事务手动提交，并将事务提交模式置为自动提交；\n[0013] (2.1.4)循环遍历每一笔交易流水，并做如下处理：\n[0014] a)首先判断该笔交易流水是否已经生成回单，如果已经生成了，则进一步判断该流水状态是否发生变化，如果状态变化，则需要同步更新回单状态，最后统一删除已生成回单的流水数据；\n[0015] b)获取该笔流水的分录，判断该笔流水的分录是否在系统参数表中配置成需要直接生成收付款方只有一边的客户回单，如果是，则不需要进行后续渠道登记簿的查找匹配处理，直接生成默认回单；\n[0016] c)根据交易流水数据中的部分特征值的规则，或者通过将交易流水数据与各个渠道登记簿数据做关联查找，来确定该笔交易流水属于的渠道及登记簿；\n[0017] d)如果交易流水能够确认渠道登记簿或没有匹配到任何渠道登记簿且要生成默认回单的交易流水，均单独创建子线程，并通过渠道对应的处理程序，将交易流水数据和渠道登记簿数据加工为生成客户回单需要的数据；如果没有匹配到任何渠道登记簿且由于Q复制延迟，需要将流水已读取标识恢复为初始值，暂不进行生成客户回单的操作；\n[0018] e)判断各渠道生成客户回单数据中的金额、借贷方向、账号是否和流水中一致，若一致，则继续进行其他要素的统一加工处理，若不一致，则按默认回单生成；\n[0019] f)将加工后的回单数据登记在客户回单系统登记簿中，子线程结束；\n[0020] (2.1.5)释放资源，主线程结束；\n[0021] (2.2)应用C负责处理tableTellerLS表中的所有流水，具体步骤如下：\n[0022] (2.2.1)优先查找已经超过设定的等待时间的交易流水，如果这类数据没有达到一个批次处理的数据量，则继续按照查找次数和交易时间顺序靠前的数据进行处理，即对于被查找次数越少和交易时间越早的数据优先级越高；\n[0023] (2.2.2)循环遍历每一笔交易流水，并做如下处理：\n[0024] a)将流水数据中的特定字段打上已读取标识，同时记录查找次数加1；\n[0025] b)判断柜面业务系统登记簿中是否已经产生对应的登记簿数据，如果已产生，则单独创建子线程，并通过柜面渠道对应的处理程序，将交易流水数据和柜面登记簿数据加工为生成客户回单需要的数据；\n[0026] c)判断各渠道生成客户回单数据中的金额、借贷方向、账号是否和流水中一致，若一致，则继续进行其他要素的统一加工处理，若不一致，则按默认回单生成；\n[0027] d)将加工后的回单数据登记在客户回单系统登记簿中，子线程结束。\n[0028] (2.2.3)释放资源，主线程结束\n[0029] 本发明的有益效果是，实现了各渠道、各系统对于动账业务的客户回单数据统一生成、实时生成和集中管理，又借助了DB2的实时Q复制技术，使得客户回单的生成效率大大提高；通过本发明可以实时查询到相关账户所有动账交易的客户回单信息，极大的方便了客户和柜员。\n附图说明\n[0030] 图1为本发明客户回单生成结构框图；\n[0031] 图2为本发明客户回单实时生成的方法流程图。\n具体实施方式\n[0032] 下面结合附图对本发明作进一步描述。\n[0033] 本发明将柜面系统和其它渠道产生的客户交易流水，通过多线程并发的实时监听技术产生客户所需的交易回单，其中交易流水数据和各渠道业务系统登记簿数据均通过DB2的Q复制技术实时复制到实时ODS系统，而客户回单系统通过在本地建立联邦的形式，远程访问实时ODS系统中的相关数据库表，实现了客户回单数据的集中处理和实时生成。\n[0034] 本发明是一种基于多表复制和实时监听的客户回单生成方法，包括以下步骤：\n[0035] (1)各渠道(包括柜面业务系统、网银系统、自助终端系统及大小额支付系统等)交易流水和登记簿数据通过Q复制技术实时同步到实时ODS系统；在各渠道进行的每项动账类交易过程中，都会在核心账务系统产生相应的账务流水，在其渠道登记簿中产生相对应的业务数据，其中渠道登记簿数据包含：业务编号、交易日期、交易类型、交易编码、收付款账号、收付款户名、收付款行号、收付款行名、交易币种、交易金额、手续费、交易状态、操作员、备注、附言等字段，图1示出了基于多表复制和实时监听的客户回单生成系统方框图；\n[0036] 柜面业务系统提供统一的客户回单打印交易，可以通过渠道、账号、日期、客户类型、打印方式(首次或补打)等查询方式，实现对客户回单的单笔或批量打印；\n[0037] 网银系统提供根据客户账号的相关流水信息，单笔或者批量查询和打印相关业务回单，比如客户可以通过登录网银，查询到自己账号近期所有动账类交易的回单信息；\n[0038] 自助回单打印机提供了客户、客户经理、大堂经理等入口，通过这些入口，客户可以自助打印相关业务回单，切实减少了柜面工作量；\n[0039] (2)客户回单系统启动3台应用服务器的7*24小时实时监听程序，3台应用服务器分别定义为应用A、应用B、应用C，其中应用A和应用B监听除柜面业务以外的所有交易流水，定义该流水表名为tableLS；应用C监听柜面业务交易流水，定义该流水表名为tableTellerLS；每个应用服务器通过定时器每隔10秒启动一个主线程，主线程对核心账务系统交易流水表(主要包括：主机流水号、交易流水笔次、交易日期、账号、币种、发生额、借贷标志、科目号、分录交易码、代理行机构码、操作员、机器时间、流水状态、备注、备用等字段)进行监听，每次获取30笔交易流水数据，通过线程并发技术，每一笔流水均起一个单独的线程进行对应渠道的匹配和回单数据的生成；具体为：\n[0040] (2.1)应用A和应用B读取的是同一张核心账务系统交易流水表tableLS，采用带锁读操作，即应用A在读取表tableLS时，应用B不得对tableLS进行读取，只有当应用A将锁释放后，应用B才能获得读取tableLS的权限，这样处理可以避免两个应用对同一张表进行重复读取的可能，对于需要生成客户回单的交易流水，通过匹配规则，关联相应的渠道登记簿，获取渠道登记簿中相应的交易信息，并对数据进行加工处理后，形成客户回单系统登记簿数据，如图2所示，具体步骤如下：\n[0041] (2.1.1)将事务提交模式置为不自动提交；\n[0042] (2.1.2)带锁读取tableLS表中的30笔数据，遍历每一笔流水，同时做如下操作：通过流水数据中的科目号和账号规则，判断是否属于特定科目参数或属于特定配置的账号，如果是，则需将该流水数据进行删除操作；通过流水数据中的业务编号和机器操作员规则，判断该流水是否属于柜面业务系统发起，如果是，则将该流水从表tableLS转移到表tableTellerLS；将流水数据中的特定字段打上已读取标识；\n[0043] (2.1.3)事务手动提交，并将事务提交模式置为自动提交；\n[0044] (2.1.4)循环遍历每一笔交易流水，并做如下处理：\n[0045] a)首先判断该笔交易流水是否已经生成回单，如果已经生成了，则进一步判断该流水状态是否发生变化，如果状态变化，则需要同步更新回单状态，最后统一删除已生成回单的流水数据；\n[0046] b)获取该笔流水的分录，判断该笔流水的分录是否在系统参数表中配置成需要直接生成收付款方只有一边的客户回单(定义为默认回单)，如果是，则不需要进行后续渠道登记簿的查找匹配处理，直接生成默认回单；\n[0047] c)根据交易流水数据中的部分特征值(比如分录交易码、业务编号、机器操作员等)的规则，或者通过将交易流水数据与各个渠道登记簿数据做关联查找，来确定该笔交易流水属于的渠道及登记簿；\n[0048] d)如果交易流水能够确认渠道登记簿或没有匹配到任何渠道登记簿且要生成默认回单的交易流水，均单独创建子线程，并通过渠道对应的处理程序，将交易流水数据和渠道登记簿数据加工为生成客户回单需要的数据；如果没有匹配到任何渠道登记簿且由于其他特殊原因(比如因Q复制延迟)，需要将流水已读取标识恢复为初始值，暂不进行生成客户回单的操作；\n[0049] e)判断各渠道生成客户回单数据中的金额、借贷方向、账号是否和流水中一致，若一致，则继续进行其他要素的统一加工处理，若不一致，则按默认回单生成；\n[0050] f)将加工后的回单数据登记在客户回单系统登记簿中，子线程结束；\n[0051] (2.1.5)释放资源，主线程结束；\n[0052] (2.2)应用C只负责处理tableTellerLS表中的所有流水，由于tableTellerLS表中的流水都是柜面业务的交易流水，而柜面交易很多都是流程化业务，即一笔流程化的柜面交易需要经过多个岗位、多个环节，主要有：前台要素处理、业务审查处理、业务要素处理、后台要素核对、系统账务处理、输出处理结果及事中监督控制，其特殊性在于先进行账务处理，而后才记录登记簿，所以监听这类交易流水，如果当时没有登记簿数据，并且是在系统设定的等待时间范围内，则暂不进行处理，具体步骤如下：\n[0053] (2.2.1)优先查找已经超过设定的等待时间的交易流水，如果这类数据没有达到一个批次处理的数据量，则继续按照查找次数和交易时间顺序靠前的数据进行处理，即对于被查找次数越少和交易时间越早的数据优先级越高，这样做既提高了晚到的交易流水被优先获取的概率，又不会让早到的交易流水被长期积压；\n[0054] (2.2.2)循环遍历每一笔交易流水，并做如下处理：\n[0055] a)将流水数据中的特定字段打上已读取标识，同时记录查找次数加1；\n[0056] b)判断柜面业务系统登记簿中是否已经产生对应的登记簿数据，如果已产生，则单独创建子线程，并通过柜面渠道对应的处理程序，将交易流水数据和柜面登记簿数据加工为生成客户回单需要的数据；\n[0057] c)判断各渠道生成客户回单数据中的金额、借贷方向、账号是否和流水中一致，若一致，则继续进行其他要素的统一加工处理，若不一致，则按默认回单生成；\n[0058] d)将加工后的回单数据登记在客户回单系统登记簿中，子线程结束。\n[0059] (2.2.3)释放资源，主线程结束。