From ff807865bf77201cb131cfa41f4e5a549b326327 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= Date: Fri, 13 Sep 2024 11:51:24 +0800 Subject: [PATCH] 1 --- .../partner/purchase/mtwm/order_comment.go | 38 ++++++++----------- 1 file changed, 16 insertions(+), 22 deletions(-) diff --git a/business/partner/purchase/mtwm/order_comment.go b/business/partner/purchase/mtwm/order_comment.go index ab4b3bcd0..64c4b0a9a 100644 --- a/business/partner/purchase/mtwm/order_comment.go +++ b/business/partner/purchase/mtwm/order_comment.go @@ -52,14 +52,10 @@ func (c *PurchaseHandler) RefreshComment(fromTime, toTime time.Time) (err error) task := tasksch.NewParallelTask("mtwm RefreshComment", nil, jxcontext.AdminCtx, func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { storeID := batchItemList[0].(int) - var orderCommentList []*model.OrderComment storeDetail, _ := dao.GetStoreDetail(dao.GetDB(), storeID, model.VendorIDMTWM, "") - if storeDetail.VendorStoreID == "" { - return nil, nil - } - // 查询门店差评 commentList, _ := getAPI(storeDetail.VendorOrgCode, storeID, storeDetail.VendorStoreID).CommentQuery(storeDetail.VendorStoreID, startDateStr, endDateStr, 0, 0, mtwmapi.CommentReplyStatusNotReplied) + var orderCommentList []*model.OrderComment if len(commentList) == model.NO || commentList == nil { return nil, nil } @@ -110,8 +106,6 @@ func (c *PurchaseHandler) RefreshComment(fromTime, toTime time.Time) (err error) if len(foodNameList) > 0 { vendorOrderID, _ := dao.GetBadCommentOrderId(storeDetail.ID, time.Now().Add(-RefreshCommentTime), startTime, nameList) - globals.SugarLogger.Debugf("-----------vendorOrderID := %s", vendorOrderID) - globals.SugarLogger.Debugf("-----------vendorOrderID := %s", utils.Format4Output(startTime, false)) if vendorOrderID != "" { orderComment.VendorOrderID2 = vendorOrderID } @@ -120,29 +114,29 @@ func (c *PurchaseHandler) RefreshComment(fromTime, toTime time.Time) (err error) } } - globals.SugarLogger.Debugf("-----------vendorOrderID storeID:= %d,orderCommentList --- :%d", storeID, len(orderCommentList)) + if len(orderCommentList) > 0 { + err = partner.CurOrderManager.OnOrderComments(orderCommentList) + } + return orderCommentList, nil }, storeIDs) task.Run() - resultList, err2 := task.GetResult(0) - globals.SugarLogger.Debugf("-----------err2 := %v", err) - globals.SugarLogger.Debugf("-----------resultList1 := %s", utils.Format4Output(resultList, false)) + _, err2 := task.GetResult(0) if err = err2; err != nil { return err } - globals.SugarLogger.Debugf("--------------resultList2 := %d", len(resultList)) - var orderCommentList []*model.OrderComment - for _, result := range resultList { - orderComment := result.(*model.OrderComment) - orderCommentList = append(orderCommentList, orderComment) - } - - if len(orderCommentList) > 0 { - globals.SugarLogger.Debugf("--------------orderCommentList := %d", len(orderCommentList)) - err = partner.CurOrderManager.OnOrderComments(orderCommentList) - } + //var orderCommentList []*model.OrderComment + //for _, result := range resultList { + // orderComment := result.(*model.OrderComment) + // orderCommentList = append(orderCommentList, orderComment) + //} + // + //if len(orderCommentList) > 0 { + // err = partner.CurOrderManager.OnOrderComments(orderCommentList) + //} + // return err }