需求背景
查找出符合低价佣金Listing的服务,分布式维度需要更换,以减轻ERP库压力和提高性能。
需求内容
1、MQ生产端:将低价佣金配置表的站点下所有来源渠道ID,去重后推送MQ队列,队列属性字段为来源渠道ID+站点。调度时间为每小时一次,防止发版中断。
2、MQ消费端:按来源渠道ID分布式锁定,根据站点取出低价佣金配置,再根据来源渠道ID取出状态表(记录不存在时插入一条新记录:lastId为0,startTime为当前时间),如果startTime为当天,则接着上次的lastId从ERP库龄表遍历,依据低价佣金配置过滤Listing,存入低价佣金Listing表;如果startTime为不是当天,则重置lastId为0且startTime为当前时间。