Showing
1 changed file
with
5 additions
and
7 deletions
@@ -37,16 +37,13 @@ public class SubmitOrderServiceImpl implements ISubmitOrderService { | @@ -37,16 +37,13 @@ public class SubmitOrderServiceImpl implements ISubmitOrderService { | ||
37 | public void doSumbitOrder(OrderBuilder orderBuilder){ | 37 | public void doSumbitOrder(OrderBuilder orderBuilder){ |
38 | 38 | ||
39 | // 减库存 | 39 | // 减库存 |
40 | - productProxyService.subtractStorage(orderBuilder.getProductId(), orderBuilder.getSkup()); | ||
41 | - | ||
42 | - // 创建订单 | ||
43 | - orderCreateService.createOrder(orderBuilder); | 40 | + if (productProxyService.subtractStorage(orderBuilder.getProductId(), orderBuilder.getSkup())) { |
41 | + // 创建订单 | ||
42 | + orderCreateService.createOrder(orderBuilder); | ||
43 | + } | ||
44 | } | 44 | } |
45 | 45 | ||
46 | 46 | ||
47 | - | ||
48 | - | ||
49 | - | ||
50 | @Service | 47 | @Service |
51 | public static class OrderCreateService{ | 48 | public static class OrderCreateService{ |
52 | 49 | ||
@@ -75,6 +72,7 @@ public class SubmitOrderServiceImpl implements ISubmitOrderService { | @@ -75,6 +72,7 @@ public class SubmitOrderServiceImpl implements ISubmitOrderService { | ||
75 | * @param orderBuilder | 72 | * @param orderBuilder |
76 | */ | 73 | */ |
77 | @Transactional(propagation = Propagation.REQUIRED) | 74 | @Transactional(propagation = Propagation.REQUIRED) |
75 | + @Database(ForceMaster=true, DataSource="ufo_order") | ||
78 | public void createOrder(OrderBuilder orderBuilder){ | 76 | public void createOrder(OrderBuilder orderBuilder){ |
79 | 77 | ||
80 | try{ | 78 | try{ |
-
Please register or login to post a comment