1、方案设计
1.1、设计思想
- T 日间做多次增量同步
- T+N 日凌晨 全量信息同步
1.2、文件命名
1.2.1、银行信息
| 说明 |
文件名 |
备注 |
| 分支行增量数据 |
BANKINC{TIMEMILLIS}.csv |
新增、修改数据 |
| 分支行日增量数据 |
BANKINC{YYYYMMDD}.csv |
当日全量数据(新增、修改数据) |
| 分支行全量数据 |
BANK_FULL.csv |
全量数据 |
【注】需要考虑以后数据量多了如何处理,需要避免同步全量数据
1.2.2、客户经理信息
| 说明 |
文件名 |
备注 |
| 客户经理增量数据 |
MANAGERINC{TIMEMILLIS}.csv |
新增、修改数据 |
| 客户经理日增量数据 |
MANAGERINC{YYYYMMDD}.csv |
当日全量数据(新增、修改数据) |
| 客户经理全量数据 |
MANAGER_FULL.csv |
全量数据 |
【注】需要考虑以后数据量多了如何处理,需要避免同步全量数据
2、数据模型
2.1、银行信息
| 键 |
中文字段 |
英文字段 |
是否必须 |
数据类型 |
说明 |
| 是 |
ID |
bankBranchId |
是 |
String |
示例: |
| 是 |
所属银行code |
bankCode |
是 |
String |
|
|
所属银行名称 |
bankName |
是 |
String |
|
|
父分行机构号 |
parentBranchNo |
|
|
|
|
分行机构号 |
branchNo |
|
|
|
|
分行名称 |
branchName |
|
|
|
|
支行机构号 |
subBranchNo |
|
|
|
|
支行名称 |
subBranchName |
|
|
|
|
存储状态 |
delStatus |
|
|
|
|
存储状态 (描述) |
delStatusDesc |
|
|
|
|
新增时间 |
bankCrtDateTime |
|
|
|
|
更新时间 |
bankUpdDateTime |
|
|
|
|
同步时间 |
updDateTime |
|
|
2.2、客户经理信息
| 键 |
中文字段 |
英文字段 |
是否必须 |
数据类型 |
说明 |
| 是 |
年份+月份 |
yearm |
是 |
String |
示例:201908 |
| 是 |
客户经理ID |
managerId |
是 |
String |
|
|
客户经理姓名 |
managerName |
是 |
String |
|
|
客户经理手机号 |
phone |
|
|
|
|
分行机构号 |
branchNo |
|
|
|
|
分行名称 |
branchName |
|
|
|
|
吸存码 |
officer |
|
|
|
|
支行机构号 |
subBranchNo |
|
|
|
|
支行名 |
subBranchName |
|
|
|
|
状态 |
custStatus |
|
|
|
|
状态(描述) |
custStatusDesc |
|
|
|
|
新增时间 |
manCrtDateTime |
|
|
|
|
更新时间 |
manUpdDateTime |
|
|
|
|
同步时间 |
updDateTime |
|
|
3、分析库
| ids库bankinfo表字段名称 |
字段类型 |
datacount库scBankBranchInfo表字段名称 |
备注 |
字段类型 |
| _id |
String |
_id |
主键id |
String |
| bankCode |
String |
bankCode |
银行编号 |
String |
| bankName |
String |
bankName |
银行名称 |
String |
| parentBranchNo |
String |
parentBranchNo |
父(上级)银行编号 |
String |
| branchNo |
String |
branchNo |
分行号 |
String |
| branchName |
String |
branchName |
分行名称 |
String |
| subBranchNo |
String |
subBranchNo |
支行号 |
String |
| subBranchName |
String |
subBranchName |
支行名称 |
String |
| orgCategory |
String |
orgCategory |
银行等级(HEADQUARTERS:总行 FIRST:一级分行 SECOND:二级分行 BRANCH:支行 DEPARTMENT:部门 UNKNOWN:未知) |
String |
| delStatusEnum |
String(normal, delete) |
delStatus |
(0,1) |
int(normal, delete) |
|
|
delStatusDesc |
(正常,删除) |
|
| crtDateTime |
date |
bankCrtDateTime |
数据创建时间 |
date |
| updDateTime |
date |
bankUpdDateTime |
数据修改时间 |
date |
|
|
updDateTime |
数据同步时间 |
date |
| level |
String |
level |
分行级别 |
String |
|
|
processStatus |
|
String |
| _class |
String |
_class |
|
String |
| headquartersBank |
String |
headquartersBank |
总行 |
String |