Commit 2c40773b authored by jiaorz's avatar jiaorz

订单库存bug

parent fc7b66fb
...@@ -63,9 +63,14 @@ public class ActivityProductBiz extends BaseBiz<ActivityProductMapper, ActivityP ...@@ -63,9 +63,14 @@ public class ActivityProductBiz extends BaseBiz<ActivityProductMapper, ActivityP
ActivityProduct oldValue = selectById(activityProduct.getId()); ActivityProduct oldValue = selectById(activityProduct.getId());
if (oldValue != null) { //增加销量,减少库存 if (oldValue != null) { //增加销量,减少库存
oldValue.setSales(oldValue.getSales() + activityProduct.getSales()); oldValue.setSales(oldValue.getSales() + activityProduct.getSales());
if (oldValue.getStock() > 0) {
oldValue.setStock(oldValue.getStock() - activityProduct.getSales()); oldValue.setStock(oldValue.getStock() - activityProduct.getSales());
updateSelectiveByIdRe(oldValue); updateSelectiveByIdRe(oldValue);
return ObjectRestResponse.succ(oldValue); return ObjectRestResponse.succ(oldValue);
} else {
return ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE, "库存不足");
}
} else { } else {
return ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE, "商品不存在!"); return ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE, "商品不存在!");
} }
......
...@@ -57,10 +57,15 @@ public class ActivityProductSpecsBiz extends BaseBiz<ActivityProductSpecsMapper, ...@@ -57,10 +57,15 @@ public class ActivityProductSpecsBiz extends BaseBiz<ActivityProductSpecsMapper,
} }
ActivityProductSpecs oldValue = selectById(activityProductSpecs.getId()); ActivityProductSpecs oldValue = selectById(activityProductSpecs.getId());
if (oldValue != null) { //增加销量,减少库存 if (oldValue != null) { //增加销量,减少库存
if (oldValue.getStock() > 0) {
oldValue.setSales(oldValue.getSales() + activityProductSpecs.getSales()); oldValue.setSales(oldValue.getSales() + activityProductSpecs.getSales());
oldValue.setStock(oldValue.getStock() - activityProductSpecs.getSales()); oldValue.setStock(oldValue.getStock() - activityProductSpecs.getSales());
updateSelectiveByIdRe(oldValue); updateSelectiveByIdRe(oldValue);
return ObjectRestResponse.succ(oldValue); return ObjectRestResponse.succ(oldValue);
} else {
return ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE, "库存不足");
}
} else { } else {
return ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE, "商品不存在!"); return ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE, "商品不存在!");
} }
......
...@@ -68,6 +68,7 @@ public class OrderActivityService extends AbstractOrderHandle<OrderActivityDetai ...@@ -68,6 +68,7 @@ public class OrderActivityService extends AbstractOrderHandle<OrderActivityDetai
if (activityProductSpecs != null) { if (activityProductSpecs != null) {
bo.getOrder().setGoodsAmount(activityProductSpecs.getGoodsPrice()); bo.getOrder().setGoodsAmount(activityProductSpecs.getGoodsPrice());
//修改规格库存 //修改规格库存
if (activityProductSpecs.getStock() > 0) {
activityProductSpecs.setSales(bo.getNumber()); activityProductSpecs.setSales(bo.getNumber());
activityFeign.update(activityProductSpecs); activityFeign.update(activityProductSpecs);
...@@ -78,6 +79,8 @@ public class OrderActivityService extends AbstractOrderHandle<OrderActivityDetai ...@@ -78,6 +79,8 @@ public class OrderActivityService extends AbstractOrderHandle<OrderActivityDetai
activityFeign.updateProduct(activityProduct); activityFeign.updateProduct(activityProduct);
} }
}
//发送定时取消订单(30分钟) //发送定时取消订单(30分钟)
rabbitProduct.sendDelayMessage(bo.getOrder(), autoCancelTime); rabbitProduct.sendDelayMessage(bo.getOrder(), autoCancelTime);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment