DataProcess(范型接口)
+ process(spuBo):void+ getData():Object
ThreadPoolUtil
MerchaniseClassGoodsProcessor
- mapper:Mapper- jmfClient:JMFClient
+ process(spuBo):spuDto+ getData():Object
IMessageConsumer
+ consumer(Message message) : void
......
SkuMapper
+ selectPageList(params):List<SpuPo>
SpuMapper
ProductService（基础商品同步）
- lastSpuId : int- rabbitTemplate: AmqpTemplate- messageCount:int
+ synSpu() : void+ synSku() : void- checkmessage(param): void()
SkuEditorConsumer
FlashSaleGoodsMapper
GoodsClassGoodsProcessor
SkuSynConsumer
ProductProcessService
- processesList:List<DataProcess>
+ process(spuBo):void
实时数据处理类
活动系统数据处理类
SpuSynConsumer
JobHandler
ActivityMapper
非实时数据处理类
BaseGoodsProcessor(抽象类)
- spuBo:spuBo
SpuSynJob（基础商品同步任务）
- jobLockKey : String
+ doJob() : String
SpuEditorConsumer
获取队列的mq消息数量，当数量大于阀值时发出警告
SalesGoodsProcessor
BaseProductService（基础商品同步）
- rabbitTemplate: AmqpTemplate- productProcessService:ProductProcessService- restHighLevelClient: RestHighLevelClient- redisTemplate:RedisTemplate
+ synSpu() : void+ synSku() : void
SkuSynJob
关联类目数据处理类
