SM_业务表数据变更需求 - shenliuyang/development GitHub Wiki

业务表binlog监听及处理用例

扣费前净值表(p_fund_nav)新增修改删除监听

  • 说明: 监听p_fund_nav表的新增修改删除事件并调用python服务
  • 优先级: 紧急
  • 功能需求:
  • 主执行者: 系统本身
  • 层次: 系统目标
  • 前置条件: 无
  • 触发事件: 监听到p_fund_nav表发生改变
  • 主成功场景:
  1. 系统监听到p_fund_nav表数据有变动,并确认字段: | nav | add_nav | adj_nav | 有修改.
  2. 系统根据version字段来判定执行符合条件的算法包(一次执行多个算法包),每个分支都走一次匹配
    • 当版本为:管理人版本. 执行复权算法包
    • 当版本是其中之一:私募排排版本、通联版本、管理人版本. 执行 拼接算法包
    • 当版本是其中之一:私募排排版本、通联版本、管理人版本、拼接版本. 执行 降频算法包、补齐算法包
    • 当版本是其中之一:私募排排版本、通联版本、管理人版本、拼接版本 字段变动(add_nav|adj_nav). 执行 扣费算法包
    • 系统通过http方式调用python算法服务并输入参数: fund_id trade_date version
    • 系统记录算法服务返回数据到日志中

扣费后净值表(p_fund_nav_after_fee)新增修改删除监听

  • 说明: 监听p_fund_nav_after_fee表的新增修改删除事件并调用python服务
  • 优先级: 紧急
  • 功能需求:
  • 主执行者: 系统本身
  • 层次: 系统目标
  • 前置条件: 无
  • 触发事件: 监听到 p_fund_nav_after_fee表发生改变
  • 主成功场景:
  1. 系统监听到p_fund_nav_after_fee表数据有变动,并确认字段: before_fee_nav 有修改. 并且version是其中之一: 私募排排版本、通联版本、管理人版本、拼接版本
  2. 系统通过http方式调用python(降频算法包、补齐算法包)算法服务并输入参数: fund_id trade_date version
  3. 系统记录算法服务返回数据到日志中

分红拆分表(p_fund_distribution)新增修改删除监听

  • 说明: 监听p_fund_distribution表的新增修改删除事件并调用python服务
  • 优先级: 紧急
  • 功能需求:
  • 主执行者: 系统本身
  • 层次: 系统目标
  • 前置条件: 无
  • 触发事件: 监听到 p_fund_distribution 表发生改变
  • 主成功场景:
  1. 系统监听到p_fund_distribution表数据有变动.并确认version 为两者其一 通联版本、私募排排版本.
  2. 系统通过http方式调用python(复权算法包)算法服务并输入参数: fund_id
  3. 系统记录算法服务返回数据到日志中

私募基金获奖信息表(p_fund_awards)新增修改删除监听

  • 说明: 监听p_fund_awards表的新增修改删除事件并调用python服务
  • 优先级: 紧急
  • 功能需求:
  • 主执行者: 系统本身
  • 层次: 系统目标
  • 前置条件: 无
  • 触发事件: 监听到 p_fund_awards表发生改变
  • 主成功场景:
  1. 系统监听到p_fund_awards表数据有变动.
  2. 系统通过http方式调用python(获奖信息统计代码)算法服务并输入参数: object_id|prize_code|object_type
  3. 系统记录算法服务返回数据到日志中

协会管理人高管信息表(p_amac_comp_info)新增修改删除监听

  • 说明: 监听p_amac_comp_info表的新增修改删除事件并调用python服务
  • 优先级: 紧急
  • 功能需求:
  • 主执行者: 系统本身
  • 层次: 系统目标
  • 前置条件: 无
  • 触发事件: 监听到 p_amac_comp_info表发生改变
  • 主成功场景:
  1. 系统监听到p_amac_comp_info表数据有变动.
  2. 系统通过http方式调用python(最早从业时间统计代码)算法服务并输入参数: company_id|company_name|
  3. 系统记录算法服务返回数据到日志中
⚠️ **GitHub.com Fallback** ⚠️