|
...
|
...
|
@@ -88,7 +88,7 @@ public class SellerOrderPriceChangeHandler implements IEventHandler<SellerOrderP |
|
|
|
}
|
|
|
|
//用map保证，一个uid只有一条,防止消息多发
|
|
|
|
Map<Integer,SellerOrderGoods> noticeSellerMap = noticeList.stream().collect(Collectors.toMap(SellerOrderGoods::getUid, r -> r,(value1, value2 )->value2));
|
|
|
|
logger.info("Subscribe SellerOrderPriceChangeEvent begin send msg, event {},noticeSellerMap {} ", event,noticeSellerMap);
|
|
|
|
logger.info("Subscribe SellerOrderPriceChangeEvent begin send msg, event {},sog {},noticeSellerMap {} ", event,sog,noticeSellerMap);
|
|
|
|
//发消息 and push
|
|
|
|
if(noticeSellerMap.size()>0){
|
|
|
|
//记录redis
|
...
|
...
|
|
