eagle平台业务逻辑
2022-04-12 16:25:06 3 举报平台业务逻辑
作者其他创作
大纲/内容
初始化PipelineContext的相关属性
BankConfigCheckPipeline
相关的数据处理逻辑被单独封装在了TaskBaseProvider的实现子类的extract方法中，而相关的task则是以配置信息的形式，在panda服务启动的时候加载到了OdsProperties类对象中
InitBankGroupContextPipeline
BridgePipeline
ExtractPipeline
1.获取CAS库的租户配置； 2.获取pandas的租户配置。
MQ消息幂等性处理、主从数据库同步判断
抽数逻辑完成后，向MQ中发送消息，通知下游将文件发送到对应的服务器上，即供数操作
OdsServiceImpl中的loanCoreFinishListener监听分组日切
new Thread()异步执行BankGroupExtractExecutor.execute()抽数逻辑
BankGroupExtractExecutor预加载相关的Pipeline管道逻辑，在父类AbstractOdsExecutor中循环执行每个Pipeline对象
0 条评论
下一页
