|
|
@@ -65,8 +65,13 @@ public class CreateOrderListener implements RocketMQListener<CreateOrderEvent> {
|
|
|
subOrders.add(subOrder);
|
|
|
successOrderIds.add(Long.parseLong(id));
|
|
|
} catch (Exception e) {
|
|
|
- log.info("创建子订单出错: {}", event.getId() + "collectionId:" + id);
|
|
|
-// collectionIds.remove(id);
|
|
|
+ if (e instanceof BusinessException) {
|
|
|
+ log.error("订单创建失败,id={},{}", event.getId() + "collectionId:" + id, e.getMessage());
|
|
|
+ } else {
|
|
|
+ log.error("订单创建失败", e);
|
|
|
+ }
|
|
|
+// log.info("创建子订单出错: {}", event.getId() + "collectionId:" + id);
|
|
|
+//// collectionIds.remove(id);
|
|
|
}
|
|
|
});
|
|
|
if (successOrderIds.size() < 1) {
|
|
|
@@ -76,11 +81,11 @@ public class CreateOrderListener implements RocketMQListener<CreateOrderEvent> {
|
|
|
orderService.cancel(order);
|
|
|
} else {
|
|
|
BigDecimal total = subOrders.stream().map(Order::getTotalPrice).reduce(BigDecimal::add)
|
|
|
- .orElse(BigDecimal.ZERO);
|
|
|
+ .orElse(BigDecimal.ZERO);
|
|
|
BigDecimal gas = subOrders.stream().map(Order::getGasPrice).reduce(BigDecimal::add)
|
|
|
- .orElse(BigDecimal.ZERO);
|
|
|
+ .orElse(BigDecimal.ZERO);
|
|
|
BigDecimal price = subOrders.stream().map(Order::getPrice).reduce(BigDecimal::add)
|
|
|
- .orElse(BigDecimal.ZERO);
|
|
|
+ .orElse(BigDecimal.ZERO);
|
|
|
List<FileObject> fileObjects = subOrders.get(0).getPic();
|
|
|
String collectionIdSt = StringUtils.join(successOrderIds, ",");
|
|
|
Order newOrder = orderService
|