优化补充数据

service/service_ly.go

@@ -39,7 +39,10 @@ type Power struct {
 func (ls *LyService) LyGoodsDetail(ctx *gin.Context, goodsIds []string, ch chan sync.Map) {
 	redisConn := gredis.Conn("search_r")
 	redisConnSpu := gredis.Conn("spu")
+	// 连接prev_sku MongoDB
+	prevSkuMongo := mongo.Conn("pre_sku")
 	defer func() {
+		prevSkuMongo.Close()
 		redisConn.Close()
 		redisConnSpu.Close()
 	}()
@@ -63,8 +66,6 @@ func (ls *LyService) LyGoodsDetail(ctx *gin.Context, goodsIds []string, ch chan
 	spuList := spuService.getSpuList(skuArr)
 
 	GoodsRes := sync.Map{}
-	// 连接prev_sku MongoDB
-	prevSkuMongo := mongo.Conn("pre_sku")
 	for goodsId, skuStr := range skuArr {
 		//初始化有序map，拼接data数据,就是从redis取出初始数据
 		sku := model.InitSkuData(skuStr)
@@ -78,8 +79,6 @@ func (ls *LyService) LyGoodsDetail(ctx *gin.Context, goodsIds []string, ch chan
 			}
 			var prevSku model.PrevSku
 			err = prevSkuMongo.DB("ichunt").C("prev_sku").Find(bson.M{"sku_id": skuId}).One(&prevSku)
-			prevSkuMongo.Close()
-
 			if err != nil {
 				// 如果在prev_sku中也找不到，则保持默认值
 				GoodsRes.Store(goodsId, false)
@@ -94,6 +93,7 @@ func (ls *LyService) LyGoodsDetail(ctx *gin.Context, goodsIds []string, ch chan
 				GoodsRes.Store(goodsId, false)
 				continue
 			}
+			sku.SpuId = spuIdStr
 			spu = spuStr
 		} else {
 			spu = spuList[sku.SpuId]