Merge branch 'refs/heads/dev-1.6-shouqianba' into container-test

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/controller/GoblinFrontController.java

@@ -76,8 +76,13 @@ public class GoblinFrontController {
 
     @GetMapping("getGoodsDetail")
     @ApiOperation("获得商品详情")
-    public ResponseDto<GoblinFrontGoodDetailVo> getGoodsDetail(@RequestParam(name = "spuId", required = true) String spuId) throws ParseException {
-        GoblinFrontGoodDetailVo vo = goblinFrontService.getGoodsDetail(spuId);
+    @ApiImplicitParams({
+            @ApiImplicitParam(paramType = "query", required = false, dataType = "String", name = "performancesId", value = "演出ID，可选；收钱吧商品(spuType=33)时传入则仅返回该演出已关联的 SKU")
+    })
+    public ResponseDto<GoblinFrontGoodDetailVo> getGoodsDetail(
+            @RequestParam(name = "spuId", required = true) String spuId,
+            @RequestParam(name = "performancesId", required = false) String performancesId) throws ParseException {
+        GoblinFrontGoodDetailVo vo = goblinFrontService.getGoodsDetail(spuId, performancesId);
         if(vo==null){
             return ResponseDto.failure("商品不存在");
         }

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

@@ -10,7 +10,9 @@ import com.liquidnet.service.base.ErrorMapping;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.goblin.dto.manage.GoblinStoreMgtGoodsSqbAddParam;
 import com.liquidnet.service.goblin.dto.vo.*;
+import com.liquidnet.service.goblin.entity.GoblinGoods;
 import com.liquidnet.service.goblin.entity.GoblinSqbGoodsExt;
+import com.liquidnet.service.goblin.mapper.GoblinGoodsMapper;
 import com.liquidnet.service.goblin.mapper.GoblinSqbGoodsExtMapper;
 import com.liquidnet.service.goblin.service.manage.IGoblinStoreMgtSqbGoodsService;
 import com.liquidnet.service.goblin.util.GoblinRedisUtils;
@@ -48,6 +50,8 @@ public class GoblinStoreMgtSqbGoodsController {
     @Autowired
     private GoblinSqbGoodsExtMapper goblinSqbGoodsExtMapper;
     @Autowired
+    private GoblinGoodsMapper goblinGoodsMapper;
+    @Autowired
     private SqbBiz goblinShouQianBaService;
 
     /**
@@ -188,10 +192,52 @@ public class GoblinStoreMgtSqbGoodsController {
     }
 
     private boolean existsSqbSpu(String mallSn, String sqbSpuId) {
-        return goblinSqbGoodsExtMapper.selectCount(new LambdaQueryWrapper<GoblinSqbGoodsExt>()
+        List<GoblinSqbGoodsExt> extList = goblinSqbGoodsExtMapper.selectList(new LambdaQueryWrapper<GoblinSqbGoodsExt>()
                 .eq(GoblinSqbGoodsExt::getMallSn, mallSn)
                 .eq(GoblinSqbGoodsExt::getSqbSpuId, sqbSpuId)
-                .eq(GoblinSqbGoodsExt::getDelFlg, "0")) > 0;
+                .eq(GoblinSqbGoodsExt::getDelFlg, "0")
+                .last("LIMIT 20"));
+        if (CollectionUtils.isEmpty(extList)) {
+            return false;
+        }
+
+        // 本地商品已删除但 ext 关系未清理时：允许重新同步（自动软删 ext 记录，避免“已存在”卡死）
+        boolean hasLiveLocalSpu = false;
+        for (GoblinSqbGoodsExt ext : extList) {
+            if (ext == null || StringUtils.isBlank(ext.getSpuId())) {
+                continue;
+            }
+            GoblinGoods localGoods = goblinGoodsMapper.selectOne(new LambdaQueryWrapper<GoblinGoods>()
+                    .eq(GoblinGoods::getSpuId, ext.getSpuId())
+                    .eq(GoblinGoods::getDelFlg, "0")
+                    .select(GoblinGoods::getSpuId)
+                    .last("LIMIT 1"));
+            if (localGoods != null) {
+                hasLiveLocalSpu = true;
+                break;
+            }
+        }
+        if (hasLiveLocalSpu) {
+            return true;
+        }
+
+        try {
+            LocalDateTime now = LocalDateTime.now();
+            for (GoblinSqbGoodsExt ext : extList) {
+                if (ext == null || ext.getMid() == null) {
+                    continue;
+                }
+                GoblinSqbGoodsExt upd = new GoblinSqbGoodsExt();
+                upd.setMid(ext.getMid());
+                upd.setDelFlg("1");
+                upd.setUpdatedAt(now);
+                upd.setDeletedAt(now);
+                goblinSqbGoodsExtMapper.updateById(upd);
+            }
+        } catch (Exception e) {
+            log.warn("收钱吧商品管理:清理已删除SPU的ext关系失败, mallSn={}, sqbSpuId={}", mallSn, sqbSpuId, e);
+        }
+        return false;
     }
 
     private void saveSqbExtRelations(GoblinGoodsInfoVo goodsInfoVo, GoblinSqbPerfGoodsVo sqbGoods) {

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

@@ -79,6 +79,69 @@ public class GoblinFrontServiceImpl implements GoblinFrontService {
         return vo != null && vo.getSpuType() == 33;
     }
 
+    /**
+     * 单场次演出下全部关联关系（status=1）：先读 Redis {@link GoblinRedisUtils#getSqbPerformanceGoodsListCache}，
+     * 未命中再查库并回写，与 {@link #getPerformanceSelectGoods} 一致。
+     */
+    private List<GoblinSqbPerformanceGoods> loadSqbPerformanceGoodsRelationsFromCacheOrDb(String performancesId) {
+        if (StringUtil.isBlank(performancesId)) {
+            return new ArrayList<>();
+        }
+        String pid = performancesId.trim();
+        List<GoblinSqbPerformanceGoods> relations = goblinRedisUtils.getSqbPerformanceGoodsListCache(pid);
+        if (relations == null) {
+            relations = goblinSqbPerformanceGoodsMapper.selectList(
+                    new LambdaQueryWrapper<GoblinSqbPerformanceGoods>()
+                            .eq(GoblinSqbPerformanceGoods::getPerformancesId, pid)
+                            .eq(GoblinSqbPerformanceGoods::getStatus, 1)
+                            .orderByAsc(GoblinSqbPerformanceGoods::getSort, GoblinSqbPerformanceGoods::getMid));
+            if (relations == null) {
+                relations = new ArrayList<>();
+            }
+            goblinRedisUtils.setSqbPerformanceGoodsListCache(pid, relations);
+        }
+        return relations;
+    }
+
+    /**
+     * 收钱吧演出-SKU 关联（status=1）。<br>
+     * 有 performancesId 时与列表接口共用 Redis 缓存，仅内存过滤当前 spu 的 skuId；<br>
+     * 无 performancesId 时（详情并集）当前无按 SPU 的缓存结构，仍查库。
+     */
+    private Set<String> loadSqbLinkedSkuIdSet(String spuId, String performancesId) {
+        if (StringUtil.isBlank(spuId)) {
+            return Collections.emptySet();
+        }
+        String spu = spuId.trim();
+        if (StringUtil.isNotBlank(performancesId)) {
+            List<GoblinSqbPerformanceGoods> relations = loadSqbPerformanceGoodsRelationsFromCacheOrDb(performancesId);
+            LinkedHashSet<String> ids = new LinkedHashSet<>();
+            for (GoblinSqbPerformanceGoods r : relations) {
+                if (r == null || StringUtil.isBlank(r.getSkuId())) {
+                    continue;
+                }
+                if (StringUtil.isBlank(r.getSpuId()) || !spu.equals(r.getSpuId().trim())) {
+                    continue;
+                }
+                ids.add(r.getSkuId().trim());
+            }
+            return ids;
+        }
+        LambdaQueryWrapper<GoblinSqbPerformanceGoods> w = new LambdaQueryWrapper<GoblinSqbPerformanceGoods>()
+                .eq(GoblinSqbPerformanceGoods::getSpuId, spu)
+                .eq(GoblinSqbPerformanceGoods::getStatus, 1);
+        List<GoblinSqbPerformanceGoods> rows = goblinSqbPerformanceGoodsMapper.selectList(w);
+        LinkedHashSet<String> ids = new LinkedHashSet<>();
+        if (rows != null) {
+            for (GoblinSqbPerformanceGoods r : rows) {
+                if (r != null && StringUtil.isNotBlank(r.getSkuId())) {
+                    ids.add(r.getSkuId().trim());
+                }
+            }
+        }
+        return ids;
+    }
+
     @Override
     public ArrayList<GoblinFrontBannerVo> getListBanner() {
         List<GoblinFrontBanner> list = goblinRedisUtils.getListBanner();
@@ -323,6 +386,13 @@ public class GoblinFrontServiceImpl implements GoblinFrontService {
      * 前台展示用：仅包含未删除且已上架的 SKU，并填充库存、限购可买数等（与 {@link #getGoodsDetail} 一致）
      */
     private ArrayList<GoblinGoodsSkuInfoDetailVo> buildOnShelfSkuDetailList(GoblinGoodsInfoVo goblinGoodsInfoVo) {
+        return buildOnShelfSkuDetailList(goblinGoodsInfoVo, null);
+    }
+
+    /**
+     * @param allowedSkuIds 非 null 时仅保留集合内的 SKU（用于收钱吧演出关联 SKU、spuType=33 详情）
+     */
+    private ArrayList<GoblinGoodsSkuInfoDetailVo> buildOnShelfSkuDetailList(GoblinGoodsInfoVo goblinGoodsInfoVo, Set<String> allowedSkuIds) {
         ArrayList<GoblinGoodsSkuInfoDetailVo> list = ObjectUtil.goblinGoodsSkuInfoDetailVos();
         if (goblinGoodsInfoVo == null) {
             return list;
@@ -334,6 +404,9 @@ public class GoblinFrontServiceImpl implements GoblinFrontService {
         }
         Integer buyCount = 0;
         for (String sku : skuIdList) {
+            if (allowedSkuIds != null && !allowedSkuIds.contains(sku)) {
+                continue;
+            }
             String userId = CurrentUtil.getCurrentUid();
             if (StringUtils.isNotBlank(userId)) {
                 buyCount = goblinRedisUtils.getSkuCountByUid(userId, sku);
@@ -370,6 +443,13 @@ public class GoblinFrontServiceImpl implements GoblinFrontService {
      * 获得商品详情
      */
     public GoblinFrontGoodDetailVo getGoodsDetail(String spuId) {
+        return getGoodsDetail(spuId, null);
+    }
+
+    /**
+     * @param performancesId 可选；spuType=33 时传入则只返回该演出已关联的 SKU，不传则返回该商品在任意演出下已关联 SKU 的并集
+     */
+    public GoblinFrontGoodDetailVo getGoodsDetail(String spuId, String performancesId) {
         GoblinFrontGoodDetailVo goblinFrontGoodDetailVo = GoblinFrontGoodDetailVo.getNew();
         GoblinGoodsInfoVo goblinGoodsInfoVo = goblinRedisUtils.getGoodsInfoVo(spuId);
         GoblinGoodsInfoDetailVo goblinGoodsInfoDetailVo = GoblinGoodsInfoDetailVo.getNew();
@@ -378,7 +458,11 @@ public class GoblinFrontServiceImpl implements GoblinFrontService {
             BeanUtils.copyProperties(goblinGoodsInfoVo, goblinGoodsInfoDetailVo);
             goblinFrontGoodDetailVo.setGoblinGoodsInfoVo(goblinGoodsInfoDetailVo);
             // int limit= getStockCount(goblinGoodsInfoVo.getStoreId());
-            ArrayList<GoblinGoodsSkuInfoDetailVo> list = buildOnShelfSkuDetailList(goblinGoodsInfoVo);
+            Set<String> sqbSkuAllow = null;
+            if (isSqbSpuGoods(goblinGoodsInfoVo)) {
+                sqbSkuAllow = loadSqbLinkedSkuIdSet(spuId, performancesId);
+            }
+            ArrayList<GoblinGoodsSkuInfoDetailVo> list = buildOnShelfSkuDetailList(goblinGoodsInfoVo, sqbSkuAllow);
             //goblinGoodsInfoVo
             GoblinStoreInfoVo goblinStoreInfoVo = this.getStore(goblinGoodsInfoVo.getStoreId());
             if (null != goblinStoreInfoVo) {
@@ -1150,44 +1234,37 @@ public class GoblinFrontServiceImpl implements GoblinFrontService {
             }
         }
 
-        // 1. 尝试从 Redis 缓存获取全量已关联商品关系（Raw Relations）提高性能
-        List<GoblinSqbPerformanceGoods> relations = goblinRedisUtils.getSqbPerformanceGoodsListCache(performancesId);
-
-        if (relations == null) {
-            // 2. 缓存失效，查询数据库获取“原始关联关系”
-            relations = goblinSqbPerformanceGoodsMapper.selectList(
-                    new LambdaQueryWrapper<GoblinSqbPerformanceGoods>()
-                            .eq(GoblinSqbPerformanceGoods::getPerformancesId, performancesId)
-                            .eq(GoblinSqbPerformanceGoods::getStatus, 1)
-                            .orderByAsc(GoblinSqbPerformanceGoods::getSort, GoblinSqbPerformanceGoods::getMid));
-
-            if (relations == null) {
-                relations = new ArrayList<>();
-            }
-            // 3. 将关联关系（SPU 列表及其结算价/排序等）写入 Redis 缓存
-            goblinRedisUtils.setSqbPerformanceGoodsListCache(performancesId, relations);
-        }
+        // 1. 全量关联关系：Redis → DB → 回写（与 loadSqbLinkedSkuIdSet 有演出 ID 时共用）
+        List<GoblinSqbPerformanceGoods> relations = loadSqbPerformanceGoodsRelationsFromCacheOrDb(performancesId);
 
         // 4. 每次请求都实时校验商品状态（delFlg, shelvesStatus 等）
         // 这样如果商品在 SPU 层面下架，虽然关联关系还在缓存，但这里会动态过滤掉
         ArrayList<GoblinSqbPerformanceGoodsInfoVo> allGoods = new ArrayList<GoblinSqbPerformanceGoodsInfoVo>();
         if (!CollectionUtils.isEmpty(relations)) {
-            // 说明：relations 关联的是 SKU（同一 SPU 可能多条），下单侧需要完整 SKU 关系，所以 Redis 缓存必须保留全量。
-            // 前端“推荐商品列表”展示按 SPU 去重：取排序最靠前的一条关联作为该 SPU 的展示代表。
-            LinkedHashMap<String, GoblinSqbPerformanceGoods> uniqueSpuRelMap = new LinkedHashMap<>();
+            // relations 按 SKU 关联：同一 SPU 可多条；列表按 SPU 去重展示，但 SKU 列表只保留本演出已关联的 SKU。
+            LinkedHashMap<String, GoblinSqbPerformanceGoods> firstRelBySpu = new LinkedHashMap<>();
+            LinkedHashMap<String, LinkedHashSet<String>> linkedSkusBySpu = new LinkedHashMap<>();
             for (GoblinSqbPerformanceGoods rel : relations) {
                 if (rel == null || StringUtil.isBlank(rel.getSpuId())) {
                     continue;
                 }
-                if (!uniqueSpuRelMap.containsKey(rel.getSpuId())) {
-                    uniqueSpuRelMap.put(rel.getSpuId(), rel);
+                firstRelBySpu.putIfAbsent(rel.getSpuId(), rel);
+                if (StringUtil.isNotBlank(rel.getSkuId())) {
+                    linkedSkusBySpu.computeIfAbsent(rel.getSpuId(), k -> new LinkedHashSet<>()).add(rel.getSkuId().trim());
                 }
             }
 
-            for (GoblinSqbPerformanceGoods rel : uniqueSpuRelMap.values()) {
+            for (GoblinSqbPerformanceGoods rel : firstRelBySpu.values()) {
                 if (rel == null || StringUtil.isBlank(rel.getSpuId())) {
                     continue;
                 }
+                LinkedHashSet<String> linkedSkuIds = linkedSkusBySpu.get(rel.getSpuId());
+                if (linkedSkuIds == null) {
+                    linkedSkuIds = new LinkedHashSet<>();
+                }
+                if (linkedSkuIds.isEmpty()) {
+                    continue;
+                }
                 // 从 Redis SPU 缓存获取详情（SPU 详情由其他逻辑负责更新缓存，这里始终拿最新状态）
                 GoblinGoodsInfoVo goodsInfoVo = goblinRedisUtils.getGoodsInfoVo(rel.getSpuId());
                 if (goodsInfoVo == null) {
@@ -1209,11 +1286,11 @@ public class GoblinFrontServiceImpl implements GoblinFrontService {
 
                 GoblinSqbPerformanceGoodsInfoVo frontGoods = new GoblinSqbPerformanceGoodsInfoVo();
                 BeanUtils.copyProperties(goodsInfoVo, frontGoods);
-                BigDecimal normalPrice = resolveGoodsSellPrice(goodsInfoVo);
+                BigDecimal normalPrice = resolveGoodsSellPrice(goodsInfoVo, linkedSkuIds);
                 frontGoods.setSellPrice(normalPrice);
                 frontGoods.setPrice(normalPrice);
                 frontGoods.setSettlementPrice(rel.getSettlementPrice());
-                frontGoods.setGoblinGoodsSkuInfoVolist(buildOnShelfSkuDetailList(goodsInfoVo));
+                frontGoods.setGoblinGoodsSkuInfoVolist(buildOnShelfSkuDetailList(goodsInfoVo, linkedSkuIds));
                 allGoods.add(frontGoods);
             }
         }
@@ -1233,7 +1310,7 @@ public class GoblinFrontServiceImpl implements GoblinFrontService {
         return respVo;
     }
 
-    private BigDecimal resolveGoodsSellPrice(GoblinGoodsInfoVo goodsInfoVo) {
+    private BigDecimal resolveGoodsSellPrice(GoblinGoodsInfoVo goodsInfoVo, Set<String> allowedSkuIds) {
         if (goodsInfoVo == null) {
             return null;
         }
@@ -1244,6 +1321,9 @@ public class GoblinFrontServiceImpl implements GoblinFrontService {
         BigDecimal minSkuPrice = null;
         if (!CollectionUtils.isEmpty(goodsInfoVo.getSkuIdList())) {
             for (String skuId : goodsInfoVo.getSkuIdList()) {
+                if (allowedSkuIds != null && !allowedSkuIds.contains(skuId)) {
+                    continue;
+                }
                 GoblinGoodsSkuInfoVo skuInfoVo = goblinRedisUtils.getGoodsSkuInfoVo(skuId);
                 if (skuInfoVo == null) {
                     continue;

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

@@ -13,8 +13,10 @@ import com.liquidnet.service.goblin.dto.GoblinGoodsSpecDto;
 import com.liquidnet.service.goblin.dto.manage.*;
 import com.liquidnet.service.goblin.dto.manage.vo.*;
 import com.liquidnet.service.goblin.dto.vo.*;
+import com.liquidnet.service.goblin.entity.GoblinGoods;
 import com.liquidnet.service.goblin.entity.GoblinSqbGoodsExt;
 import com.liquidnet.service.goblin.enums.GoblinStoreConf;
+import com.liquidnet.service.goblin.mapper.GoblinGoodsMapper;
 import com.liquidnet.service.goblin.mapper.GoblinSqbGoodsExtMapper;
 import com.liquidnet.service.goblin.service.manage.IGoblinStoreMgtExtraService;
 import com.liquidnet.service.goblin.service.manage.IGoblinZhengzaiService;
@@ -50,6 +52,8 @@ public class GoblinStoreMgtGoodsServiceImpl implements IGoblinstoreMgtGoodsServi
     IGoblinZhengzaiService goblinZhengzaiService;
     @Autowired
     GoblinSqbGoodsExtMapper goblinSqbGoodsExtMapper;
+    @Autowired
+    GoblinGoodsMapper goblinGoodsMapper;
 
     @Override
     public PagedResult<GoblinStoreMgtGoodsListVo> goodsList(GoblinStoreMgtGoodsFilterParam mgtGoodsFilterParam) {
@@ -538,6 +542,15 @@ public class GoblinStoreMgtGoodsServiceImpl implements IGoblinstoreMgtGoodsServi
         String spuId = storeMgtGoodsAddParam.getSpuId();
 
         GoblinGoodsInfoVo updateSpuInfoVo = storeMgtGoodsAddParam.initEditGoodsInfoVo();
+        // initEditGoodsInfoVo 固定 setSpuType(0)，全量更新 Mongo 会把 33 等类型覆盖成 0；以 MySQL 为准保持类型不变
+        LambdaQueryWrapper<GoblinGoods> spuTypeQ = new LambdaQueryWrapper<GoblinGoods>()
+                .eq(GoblinGoods::getSpuId, spuId)
+                .select(GoblinGoods::getSpuType)
+                .last("LIMIT 1");
+        GoblinGoods goodsRow = goblinGoodsMapper.selectOne(spuTypeQ);
+        if (goodsRow != null && goodsRow.getSpuType() != null) {
+            updateSpuInfoVo.setSpuType(goodsRow.getSpuType());
+        }
 
         boolean updateTagFlg = false, updateExtagFlg = false, updateArtagFlg = false;
         List<GoblinGoodsTagVo> befTagVoList = mgtGoodsInfoVo.getTagVoList();

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

@@ -17,11 +17,7 @@ import com.liquidnet.service.goblin.dto.GoblinGoodsSpecDto;
 import com.liquidnet.service.goblin.dto.manage.GoblinStoreMgtGoodsSqbAddParam;
 import com.liquidnet.service.goblin.dto.manage.vo.GoblinMgtCategorySpecVo;
 import com.liquidnet.service.goblin.dto.vo.*;
-import com.liquidnet.service.goblin.entity.GoblinGoods;
-import com.liquidnet.service.goblin.entity.GoblinGoodsSku;
 import com.liquidnet.service.goblin.entity.GoblinSqbGoodsExt;
-import com.liquidnet.service.goblin.mapper.GoblinGoodsMapper;
-import com.liquidnet.service.goblin.mapper.GoblinGoodsSkuMapper;
 import com.liquidnet.service.goblin.mapper.GoblinSqbGoodsExtMapper;
 import com.liquidnet.service.goblin.service.manage.IGoblinStoreMgtSqbGoodsService;
 import com.liquidnet.service.goblin.util.GoblinMongoUtils;
@@ -54,10 +50,6 @@ public class GoblinStoreMgtSqbGoodsServiceImpl implements IGoblinStoreMgtSqbGood
     @Autowired
     GoblinSqbGoodsExtMapper goblinSqbGoodsExtMapper;
     @Autowired
-    private GoblinGoodsMapper goblinGoodsMapper;
-    @Autowired
-    private GoblinGoodsSkuMapper goblinGoodsSkuMapper;
-    @Autowired
     private SqbBiz goblinShouQianBaService;
 
 
@@ -319,15 +311,6 @@ public class GoblinStoreMgtSqbGoodsServiceImpl implements IGoblinStoreMgtSqbGood
         GoblinStoreMgtGoodsSqbAddParam initParam = new GoblinStoreMgtGoodsSqbAddParam();
 
         GoblinGoodsInfoVo updateSpuInfoVo = initParam.initEditGoodsInfoVo(mgtGoodsAddParam, mgtGoodsInfoVo);
-        // Redis 反序列化缺 spuType 时 primitive int 为 0，全量 $set 会误覆盖 Mongo 中的 33 等类型；以 MySQL 为准回填
-        LambdaQueryWrapper<GoblinGoods> spuTypeQ = new LambdaQueryWrapper<GoblinGoods>()
-                .eq(GoblinGoods::getSpuId, spuId)
-                .select(GoblinGoods::getSpuType)
-                .last("LIMIT 1");
-        GoblinGoods goodsRow = goblinGoodsMapper.selectOne(spuTypeQ);
-        if (goodsRow != null && goodsRow.getSpuType() != null) {
-            updateSpuInfoVo.setSpuType(goodsRow.getSpuType());
-        }
 
         boolean updateImageFlg = false;
         List<String> paramImageList = mgtGoodsAddParam.getConverImages();
@@ -415,19 +398,6 @@ public class GoblinStoreMgtSqbGoodsServiceImpl implements IGoblinStoreMgtSqbGood
                 .filter(ext -> StringUtils.isNotBlank(ext.getSqbSkuId()) && StringUtils.isNotBlank(ext.getSkuId()))
                 .collect(Collectors.toMap(GoblinSqbGoodsExt::getSqbSkuId, GoblinSqbGoodsExt::getSkuId, (a, b) -> a));
 
-        List<String> localSkuIdsForType = new ArrayList<>(new LinkedHashSet<>(sqbSkuToLocalSkuMap.values()));
-        Map<String, Integer> skuTypeByLocalId = new HashMap<>();
-        if (!localSkuIdsForType.isEmpty()) {
-            LambdaQueryWrapper<GoblinGoodsSku> typeQ = new LambdaQueryWrapper<GoblinGoodsSku>()
-                    .in(GoblinGoodsSku::getSkuId, localSkuIdsForType)
-                    .select(GoblinGoodsSku::getSkuId, GoblinGoodsSku::getSkuType);
-            for (GoblinGoodsSku row : goblinGoodsSkuMapper.selectList(typeQ)) {
-                if (row.getSkuId() != null && row.getSkuType() != null) {
-                    skuTypeByLocalId.put(row.getSkuId(), row.getSkuType());
-                }
-            }
-        }
-
         boolean updated = false;
         LinkedList<Object[]> updateGoodsSkuObjs = CollectionUtil.linkedListObjectArr();
         for (MallProductsQueryData.Sku sqbSku : skuResults) {
@@ -443,10 +413,6 @@ public class GoblinStoreMgtSqbGoodsServiceImpl implements IGoblinStoreMgtSqbGood
             if (skuInfoVo == null || !"0".equals(skuInfoVo.getDelFlg())) {
                 continue;
             }
-            Integer persistedSkuType = skuTypeByLocalId.get(localSkuId);
-            if (persistedSkuType != null) {
-                skuInfoVo.setSkuType(persistedSkuType);
-            }
             skuInfoVo.setName(sqbSku.getSkuName());
             if (sqbSku.getPrice() != null) {
                 skuInfoVo.setPrice(SqbAmountUtils.fenToYuan(sqbSku.getPrice()));