记得上下班打卡 | git大法好，push需谨慎

Skip to content

L
liquidnet-bus-v1
Commit 88c6d28a authored by jiangxiulong's avatar jiangxiulong
Browse files
Options

Merge remote-tracking branch 'origin/hjc_goblin_list' into hjc_goblin_list

parents 7893e34b 3555dae8
Hide whitespace changes
Inline Side-by-side
Showing with 53 additions and 22 deletions
liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/util/GoblinRedisUtils.java
View file @ 88c6d28a
......@@ -927,27 +927,42 @@ public class GoblinRedisUtils {
}
} else if (vo != null && type == 1) {
LocalDateTime st = vo.getTimeStart().minusSeconds(1);
GoblinListCollectVo collectVo = null;
GoblinListCollectVo collectTemp = null;
// GoblinListCollectVo collectVo = null;
// GoblinListCollectVo collectTemp = null;
//获取上个分配购的vo
List<GoblinListCollectVo> collectVosList = ObjectUtil.getGoblinListCollectVo();
for (GoblinListCollectVo collectVoItem : collectVos) {
if (st.isAfter(collectVoItem.getTimeStart()) && collectVoItem.getTimeEnd() == null) {
collectTemp = collectVoItem;
// collectTemp = collectVoItem;
collectVosList.add(collectVoItem);
} else if (st.isAfter(collectVoItem.getTimeStart()) && st.isBefore(collectVoItem.getTimeEnd())) {
collectVo = collectVoItem;
// collectVo = collectVoItem;
collectVosList.add(collectVoItem);
break;
}
}
if (collectVo == null) {
collectVo = collectTemp;
}
if (collectVo != null) {
// if (collectVo == null) {
// collectVo = collectTemp;
// }
// if (collectVo != null) {
// //减少上个时间段sku库存
// int lastStock = getSkuStock(collectVo.getListId(), skuId);
// int restStock = decrSkuStock(collectVo.getListId(), skuId, lastStock);
// if (restStock < 0) {
// //库存超过销售量 操作失败回滚库存
// incrSkuStock(collectVo.getListId(), skuId, lastStock);
// } else {
// //上个时间段的库存增加到当前时间段
// incrSkuStock(vo.getListId(), skuId, lastStock);
// }
// }
for (GoblinListCollectVo itemVo : collectVosList){
//减少上个时间段sku库存
int lastStock = getSkuStock(collectVo.getListId(), skuId);
int restStock = decrSkuStock(collectVo.getListId(), skuId, lastStock);
int lastStock = getSkuStock(itemVo.getListId(), skuId);
int restStock = decrSkuStock(itemVo.getListId(), skuId, lastStock);
if (restStock < 0) {
//库存超过销售量 操作失败回滚库存
incrSkuStock(collectVo.getListId(), skuId, lastStock);
incrSkuStock(itemVo.getListId(), skuId, lastStock);
} else {
//上个时间段的库存增加到当前时间段
incrSkuStock(vo.getListId(), skuId, lastStock);
......
liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/utils/GoblinRedisUtils.java
View file @ 88c6d28a
......@@ -295,27 +295,42 @@ public class GoblinRedisUtils {
}
} else if (vo != null && type == 1) {
LocalDateTime st = vo.getTimeStart().minusSeconds(1);
GoblinListCollectVo collectVo = null;
GoblinListCollectVo collectTemp = null;
// GoblinListCollectVo collectVo = null;
// GoblinListCollectVo collectTemp = null;
//获取上个分配购的vo
List<GoblinListCollectVo> collectVosList = ObjectUtil.getGoblinListCollectVo();
for (GoblinListCollectVo collectVoItem : collectVos) {
if (st.isAfter(collectVoItem.getTimeStart()) && collectVoItem.getTimeEnd() == null) {
collectTemp = collectVoItem;
// collectTemp = collectVoItem;
collectVosList.add(collectVoItem);
} else if (st.isAfter(collectVoItem.getTimeStart()) && st.isBefore(collectVoItem.getTimeEnd())) {
collectVo = collectVoItem;
// collectVo = collectVoItem;
collectVosList.add(collectVoItem);
break;
}
}
if (collectVo == null) {
collectVo = collectTemp;
}
if (collectVo != null) {
// if (collectVo == null) {
// collectVo = collectTemp;
// }
// if (collectVo != null) {
// //减少上个时间段sku库存
// int lastStock = getSkuStock(collectVo.getListId(), skuId);
// int restStock = decrSkuStock(collectVo.getListId(), skuId, lastStock);
// if (restStock < 0) {
// //库存超过销售量 操作失败回滚库存
// incrSkuStock(collectVo.getListId(), skuId, lastStock);
// } else {
// //上个时间段的库存增加到当前时间段
// incrSkuStock(vo.getListId(), skuId, lastStock);
// }
// }
for (GoblinListCollectVo itemVo : collectVosList){
//减少上个时间段sku库存
int lastStock = getSkuStock(collectVo.getListId(), skuId);
int restStock = decrSkuStock(collectVo.getListId(), skuId, lastStock);
int lastStock = getSkuStock(itemVo.getListId(), skuId);
int restStock = decrSkuStock(itemVo.getListId(), skuId, lastStock);
if (restStock < 0) {
//库存超过销售量 操作失败回滚库存
incrSkuStock(collectVo.getListId(), skuId, lastStock);
incrSkuStock(itemVo.getListId(), skuId, lastStock);
} else {
//上个时间段的库存增加到当前时间段
incrSkuStock(vo.getListId(), skuId, lastStock);
......@@ -324,6 +339,7 @@ public class GoblinRedisUtils {
}
}
/**
* 分段购获取
*
......
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