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

Commit 9f259e05 authored by 胡佳晨's avatar 胡佳晨

修改 nft商品列表定时任务

parent be8d54bd
......@@ -46,6 +46,7 @@ public class GoblinNftJobServiceImpl {
IGoblinGoodsAnticipateMgService goblinGoodsAnticipateMgService;
public ResponseDto<Boolean> goodsList() {
LocalDateTime now = LocalDateTime.now();
// mongo初始条件
Query query1 = Query.query(
Criteria.where("skuType").is(1).and("delFlg").is("0")
......@@ -87,13 +88,18 @@ public class GoblinNftJobServiceImpl {
jobVoArrayList.addAll(startSkuInfoVos);
for (GoblinNftGoodsSkuListJobVo info : jobVoArrayList) {
HashMap<String, Object> mapData = goblinRedisUtils.getGoodsSkuInfoVo(now, info.getSkuId());
GoblinGoodsSkuInfoVo skuInfoVo = (GoblinGoodsSkuInfoVo) mapData.get("vo");
String listId = (String) mapData.get("listId");
info.setSaleStartTime(skuInfoVo.getSaleStartTime());
if (nowTime.compareTo(info.getSaleStartTime()) > 0) {// 已开卖
List<String> skuIdList = CollectionUtil.arrayListString();
if (info.getUnbox().equals("1")) {// 是盲盒,非盲盒少查一次spu
skuIdList = goblinRedisUtils.getGoodsInfoVo(info.getSpuId()).getSkuIdList();
}
HashMap<String, Object> map = goblinRedisUtils.getGoodsSkuInfoVo(nowTime, info.getSkuId());
String listId = (String) map.get("listId");
// HashMap<String, Object> map = goblinRedisUtils.getGoodsSkuInfoVo(nowTime, info.getSkuId());
// String listId = (String) map.get("listId");
HashMap<String, Integer> stockHashMap = goblinOrderUtils.getIsStock(listId, info.getSkuId(), info.getUnbox(), info.getSoldoutStatus(), skuIdList);
if (stockHashMap.get("isStock") == 1) {// 已开卖-未售罄
startSkuIdList.add(info.getSkuId());
......
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