...
|
...
|
@@ -84,7 +84,7 @@ public class SellerOrderPriceChangeHandler implements IEventHandler<SellerOrderP |
|
|
noticeList = noticeList.stream().filter(r->!members.contains(getValueForSet(r))).collect(Collectors.toList());
|
|
|
}
|
|
|
//用map保证,一个uid只有一条,防止消息多发
|
|
|
Map<Integer,SellerOrderGoods> noticeSellerMap = noticeList.stream().collect(Collectors.toMap(SellerOrderGoods::getUid, r -> r));
|
|
|
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);
|
|
|
//发消息 and push
|
|
|
if(noticeSellerMap.size()>0){
|
...
|
...
|
|