发送企业微信群报警信息
查询
监听
否
推送dm_channel_settle_adjustment表 (有数据推送)推送dm_channel_settle_detail表数据dm_data_state插入2 条推送记录
是
BI导数开始
遍历完成保存数据dm_channel_settle_adjustment表的数据变更已处理状态
推送dm_channel_settle_adjustment表 0 条数据(无数据推送)推送dm_channel_settle_detail表数据dm_data_state插入2条推送记录
结算服务导数逻辑处理
根据当前日期转换成最后一天检查dm_data_state是否有dm_channel_settle_adjustment表的导入记录
没有
根据 channelid+\":\"+month判断map中是否包含key
有
gac_pay.channel_settle_period
结算接口发布结算事件
BI导数
List<DmChannelSettleAdjustment> dmList
检查period该周期是否已结算
遍历
生成ChannelSettleAdjustDetail数据添加到details中
gac_pay.channel_settle_adjust_detail
某个周期是否需要调整 ?
推送dm_channel_settle_adjustment表 0 条数据(无数据推送) 否则业务中台服务处理数据会报警提示BI未推送数据
