|
@@ -23,6 +23,7 @@ public class OrderStream extends StreamConsumer<OrderStremModel> {
|
|
|
|
|
|
@Override
|
|
|
public void accept(OrderStremModel orderStremModel) {
|
|
|
+ log.info("收到商品订单消息:{}", orderStremModel);
|
|
|
switch (orderStremModel.getOrderType()) {
|
|
|
case USED:
|
|
|
goodsReceiptsService.receipts(orderStremModel.getUserId(), orderStremModel.getOrderNo(), orderStremModel.getGoodsId(), orderStremModel.getOperationTime());
|