收钱 商品同步

liquidnet-bus-api/liquidnet-service-goblin-api/src/main/java/com/liquidnet/service/goblin/dto/manage/GoblinStoreMgtGoodsSqbAddParam.java

@@ -182,7 +182,7 @@ public class GoblinStoreMgtGoodsSqbAddParam implements Serializable {
         List<String> skuIdList = CollectionUtil.arrayListString();
         for (MallProductsQueryData.Sku sku : addSkuParamSqb) {
             GoblinGoodsSkuInfoVo skuInfoVo = GoblinGoodsSkuInfoVo.getNew();
-            String systemSkuId = IDGenerator.nextMilliId2();
+            String systemSkuId = IDGenerator.nextSnowId();
             skuInfoVo.setSpuId(goodsInfoVo.getSpuId());
             // 主表使用系统SKU_ID，收钱吧SKU_ID仅通过`goblin_sqb_goods_ext`映射
             skuInfoVo.setSkuId(systemSkuId);

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

@@ -422,7 +422,7 @@ public class GoblinStoreMgtSqbGoodsServiceImpl implements IGoblinStoreMgtSqbGood
             if (goblinMongoUtils.updateGoodsSkuInfoVo(skuInfoVo)) {
                 goblinRedisUtils.delGoodsSkuInfoVo(localSkuId);
                 updateGoodsSkuObjs.add(new Object[] {
-                        skuInfoVo.getPrice(), skuInfoVo.getPriceMember(), skuInfoVo.getStock(),
+                        sqbSku.getSkuName(), skuInfoVo.getPrice(), skuInfoVo.getPriceMember(), skuInfoVo.getStock(),
                         skuInfoVo.getSkuStock(),
                         skuInfoVo.getBuyLimit(), skuInfoVo.getUpdatedBy(), skuInfoVo.getUpdatedAt(), localSkuId
                 });
@@ -431,7 +431,7 @@ public class GoblinStoreMgtSqbGoodsServiceImpl implements IGoblinStoreMgtSqbGood
         }
         if (updated) {
             LinkedList<String> toMqSqls = CollectionUtil.linkedListString();
-            toMqSqls.add(SqlMapping.get("goblin_goods_sku.update_by_edit_for_coupon"));
+            toMqSqls.add(SqlMapping.get("goblin_goods_sku.update_by_edit_for_sqb"));
             queueUtils.sendMsgByRedis(MQConst.GoblinQueue.SQL_GOODS.getKey(),
                     SqlMapping.gets(toMqSqls, updateGoodsSkuObjs));
         }

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/resources/sqlmap.properties

@@ -71,6 +71,7 @@ goblin_goods_sku.update_by_edit_coupon_spu=UPDATE goblin_goods_sku SET sku_no=?,
 goblin_goods_sku.update_by_shelves=UPDATE goblin_goods_sku SET shelves_status=?,shelves_at=?,updated_by=?,updated_at=? WHERE sku_id=? AND store_id=? AND del_flg='0' 
 goblin_goods_sku.update_by_soldout=UPDATE goblin_goods_sku SET soldout_status=?,updated_by=?,updated_at=? WHERE sku_id=? AND del_flg='0' 
 goblin_goods_sku.update_by_edit_for_coupon=UPDATE goblin_goods_sku SET price=?,price_member=?,stock=?,sku_stock=?,buy_limit=?,updated_by=?,updated_at=? WHERE sku_id=? AND del_flg='0' 
+goblin_goods_sku.update_by_edit_for_sqb=UPDATE goblin_goods_sku SET name=?,price=?,price_member=?,stock=?,sku_stock=?,buy_limit=?,updated_by=?,updated_at=? WHERE sku_id=? AND del_flg='0' 
 goblin_goods_sku.update_by_del_store=UPDATE goblin_goods_sku SET del_flg='1',updated_by=?,updated_at=?,deleted_by=?,deleted_at=? WHERE store_id=? AND del_flg='0' 
 goblin_goods_sku.update_by_del_spu=UPDATE goblin_goods_sku SET del_flg='1',updated_by=?,updated_at=?,deleted_by=?,deleted_at=? WHERE spu_id=? AND del_flg='0' 
 goblin_goods_sku.update_by_del=UPDATE goblin_goods_sku SET del_flg='1',updated_by=?,updated_at=?,deleted_by=?,deleted_at=? WHERE sku_id=? AND del_flg='0'