加入判断逻辑

controller/sku_controller.go

@@ -162,6 +162,7 @@ func CommonController(ctx *gin.Context) map[string]interface{} {
 
 
 		case <-timeout:
 		case <-timeout:
 			logger.Log("协程整体处理超时", "sku", 1)
 			logger.Log("协程整体处理超时", "sku", 1)
+			panic("协程整体处理超时")
 			return temp // 超时，返回已经收到的部分数据
 			return temp // 超时，返回已经收到的部分数据
 		}
 		}
 	}
 	}

service/service_ly.go

@@ -10,6 +10,7 @@ import (
 	"sort"
 	"sort"
 	"strconv"
 	"strconv"
 	"sync"
 	"sync"
+	"time"
 
 
 	"gopkg.in/mgo.v2"
 	"gopkg.in/mgo.v2"
 	"gopkg.in/mgo.v2/bson"
 	"gopkg.in/mgo.v2/bson"
@@ -59,6 +60,12 @@ func (ls *LyService) LyGoodsDetail(ctx *gin.Context, goodsIds []string, ch chan
 	//是否展示spu额外信息
 	//是否展示spu额外信息
 	showSpuExtra := ctx.Request.FormValue("show_spu_extra")
 	showSpuExtra := ctx.Request.FormValue("show_spu_extra")
 
 
+	//是否超时
+	timeout := ctx.Request.FormValue("timeout")
+	if timeout == "1" {
+		time.Sleep(time.Second * 15)
+	}
+
 	//批量获取商品详情
 	//批量获取商品详情
 	skuArr := gredis.Hmget("default_r", "sku", goodsIds)
 	skuArr := gredis.Hmget("default_r", "sku", goodsIds)
 	//为了性能着想,这边也先去批量获取spu的信息
 	//为了性能着想,这边也先去批量获取spu的信息