fix

controller/sku_controller.go

@@ -45,7 +45,7 @@ func Synchronization(ctx *gin.Context) {
 	goodsIdArr := php2go.Explode(",", GoodsIdStr)
 	//wg := sync.WaitGroup{} //协程
 	ch := make(chan sync.Map) //管道
-    p := 0 //总共协程
+	p := 0                    //总共协程
 
 	zyGoodsId := make([]string, 0)
 	lyGoodsId := make([]string, 0)
@@ -61,7 +61,7 @@ func Synchronization(ctx *gin.Context) {
 				//wg.Add(1) //协程计数一
 				go zyService.ZyGoodsDetail(ctx, zyGoodsId, ch)
 				zyGoodsId = zyGoodsId[:0:0]
-				p ++
+				p++
 			}
 		} else { //联营
 			lyGoodsId = append(lyGoodsId, goodsId)
@@ -71,7 +71,7 @@ func Synchronization(ctx *gin.Context) {
 				//wg.Add(1)
 				go lyService.LyGoodsDetail(ctx, lyGoodsId, ch)
 				lyGoodsId = lyGoodsId[:0:0]
-				p ++
+				p++
 			}
 		}
 	}
@@ -81,7 +81,7 @@ func Synchronization(ctx *gin.Context) {
 		common.PrintDebugHtml(ctx, zyGoodsId)
 		//wg.Add(1) //协程计数一
 		go zyService.ZyGoodsDetail(ctx, zyGoodsId, ch)
-		p ++
+		p++
 	}
 
 	if len(lyGoodsId) > 0 {
@@ -89,30 +89,29 @@ func Synchronization(ctx *gin.Context) {
 		common.PrintDebugHtml(ctx, zyGoodsId)
 		//wg.Add(1)
 		go lyService.LyGoodsDetail(ctx, lyGoodsId, ch)
-		p ++
+		p++
 	}
 	//wg.Wait()
 
 	//异步map最后转成map
 	temp := make(map[string]interface{})
-	for i := 0 i < p i++ {
+	for i := 0; i < p; i++ {
 		select {
-		case GoodsRes := <- ch:
+		case GoodsRes := <-ch:
 			GoodsRes.Range(func(k, v interface{}) bool {
 				s, _ := k.(string)
 				temp[s] = v
 				return true
 			})
 
-		case <- time.After(time.Second *6):
-			logger.Log("协程超时","sku",1)
+		case <-time.After(time.Second * 6):
+			logger.Log("协程超时", "sku", 1)
 		}
 	}
 
 	common.Output(ctx, 0, "success", temp)
 }
 
-
 /*
 健康监测
 */