提交 脚本

liquidnet-bus-common/liquidnet-common-base/src/main/java/com/liquidnet/commons/lang/util/IDGenerator.java

@@ -85,6 +85,15 @@ public class IDGenerator {
         return "QR" + qrCode.substring(5) + "" + qrCode.substring(0, 4);
     }
 
+    /**
+     * 获得活动 spu sku
+     * @param marketId
+     * @return
+     */
+    public static String marketGoodId(String marketId) {
+        return StringUtil.right(marketId,5);
+    }
+
     public static void main(String[] args) {
         System.out.println(""+IDGenerator.payCode());
         System.out.println(""+IDGenerator.refundCode());

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/service/impl/manage/GoblinStorePurchasingServiceImpl.java

@@ -3,10 +3,14 @@ package com.liquidnet.service.goblin.service.impl.manage;
 import com.github.pagehelper.PageInfo;
 import com.liquidnet.commons.lang.util.DateUtil;
 import com.liquidnet.commons.lang.util.IDGenerator;
+import com.liquidnet.commons.lang.util.StringUtil;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.base.SqlMapping;
 import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.goblin.constant.GoblinStatusConst;
 import com.liquidnet.service.goblin.dto.manage.GoblinStorePurchaseItemParam;
+import com.liquidnet.service.goblin.dto.vo.GoblinGoodsInfoVo;
+import com.liquidnet.service.goblin.dto.vo.GoblinGoodsSkuInfoVo;
 import com.liquidnet.service.goblin.dto.vo.GoblinStoreMarketVo;
 import com.liquidnet.service.goblin.entity.GoblinStoreMarketPurchasing;
 import com.liquidnet.service.goblin.entity.GoblinStoreMarketing;
@@ -14,6 +18,7 @@ import com.liquidnet.service.goblin.service.manage.IGoblinStorePurchasingService
 import com.liquidnet.service.goblin.util.GoblinMongoUtils;
 import com.liquidnet.service.goblin.util.GoblinRedisUtils;
 import com.liquidnet.service.goblin.util.QueueUtils;
+import io.github.classgraph.json.Id;
 import me.chanjar.weixin.common.util.DataUtils;
 import org.apache.commons.lang.time.DateUtils;
 import org.springframework.beans.BeanUtils;
@@ -168,6 +173,9 @@ public class GoblinStorePurchasingServiceImpl implements IGoblinStorePurchasingS
     public ResponseDto<Boolean> purchasingSkuInsert(List<GoblinStorePurchaseItemParam> params) {
         String purchaseId = IDGenerator.nextMilliId2();
         LocalDateTime now = LocalDateTime.now();
+        String marketId = params.get(0).getStoreMarketId();
+        String spuId = params.get(0).getStoreMarketId();
+        String marketSpuId = spuId.concat(GoblinStatusConst.MarketPreStatus.MARKET_PRE_PURCHASE.getValue()).concat(IDGenerator.marketGoodId(marketId));
         for (GoblinStorePurchaseItemParam item : params) {
             GoblinStoreMarketPurchasing bean = GoblinStoreMarketPurchasing.getNew();
             bean.setPurchaseId(purchaseId);
@@ -182,10 +190,20 @@ public class GoblinStorePurchasingServiceImpl implements IGoblinStorePurchasingS
             bean.setDelFlag(0);
             bean.setCreatedAt(now);
             //mongo
-            goblinRedisUtils.getGoodsInfoVo(item.getSpuId());
-            goblinRedisUtils.getGoodsSkuInfoVo(item.getSkuId());
+            GoblinGoodsSkuInfoVo skuVo = goblinRedisUtils.getGoodsSkuInfoVo(item.getSkuId());
+            skuVo.setSpuId(marketSpuId);
+            skuVo.setPrice(bean.getPriceMarketing());
+            skuVo.setSkuStock(bean.getStockMarketing());
+//            skuVo.setBuyLimit(item.getBuyLimit().toString());//限购 ， 限量
             //redis
+            goblinRedisUtils.setGoodsSkuInfoVo(skuVo);
         }
+        //mongo
+        GoblinGoodsInfoVo spuVo = goblinRedisUtils.getGoodsInfoVo(spuId);
+        spuVo.setSpuId(marketSpuId);
+        goblinMongoUtils.setGoodsInfoVo(spuVo);
+        //redis
+        goblinRedisUtils.setGoodsInfoVo(spuVo);
 
         //mysql
         return null;