fusen/fusenapi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
laodaming 2023-06-13 17:51:12 +08:00
parent d941402ef1
commit 8b85f3b6ce
2 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
server/shopping-cart-confirmation/internal/handler/cartlisthandler.go
View File

@ -18,7 +18,7 @@ import (
func CartListHandler(svcCtx *svc.ServiceContext) http.HandlerFunc { func CartListHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
return func(w http.ResponseWriter, r *http.Request) { return func(w http.ResponseWriter, r *http.Request) {
// 解析jwtToken // 解析jwtToken
/*claims, err := svcCtx.ParseJwtToken(r) claims, err := svcCtx.ParseJwtToken(r)
// 如果解析出错，则返回未授权的JSON响应并记录错误消息 // 如果解析出错，则返回未授权的JSON响应并记录错误消息
if err != nil { if err != nil {
httpx.OkJsonCtx(r.Context(), w, &basic.Response{ httpx.OkJsonCtx(r.Context(), w, &basic.Response{
@ -40,7 +40,7 @@ func CartListHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
logx.Info("unauthorized:", err.Error()) logx.Info("unauthorized:", err.Error())
return return
} }
*/
var req types.CartListReq var req types.CartListReq
// 如果端点有请求结构体，则使用httpx.Parse方法从HTTP请求体中解析请求数据 // 如果端点有请求结构体，则使用httpx.Parse方法从HTTP请求体中解析请求数据
if err := httpx.Parse(r, &req); err != nil { if err := httpx.Parse(r, &req); err != nil {
@ -53,7 +53,7 @@ func CartListHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
} }
// 创建一个业务逻辑层实例 // 创建一个业务逻辑层实例
l := logic.NewCartListLogic(r.Context(), svcCtx) l := logic.NewCartListLogic(r.Context(), svcCtx)
resp := l.CartList(&req, &auth.UserInfo{86}) resp := l.CartList(&req, userinfo)
// 如果响应不为nil，则使用httpx.OkJsonCtx方法返回JSON响应; // 如果响应不为nil，则使用httpx.OkJsonCtx方法返回JSON响应;
// 否则，发送500内部服务器错误的JSON响应并记录错误消息logx.Error。 // 否则，发送500内部服务器错误的JSON响应并记录错误消息logx.Error。
if resp != nil { if resp != nil {

5
server/shopping-cart-confirmation/internal/logic/cartlistlogic.go
View File

@ -194,9 +194,8 @@ func (l *CartListLogic) getUserCartRelativeList(ctx context.Context, userId int6
} }
//******************************协程并发开始*********************************** //******************************协程并发开始***********************************
wait := sync.WaitGroup{} wait := sync.WaitGroup{}
gorutine := 6 //注意要加协程这里要记得加 errChan := make(chan error)
errChan := make(chan error, gorutine) wait.Add(6) //注意要加协程这里要记得加
wait.Add(gorutine)
//获取产品数据1 //获取产品数据1
go func() { go func() {
defer wait.Done() defer wait.Done()