diff --git a/business/partner/purchase/mtwm/order_comment.go b/business/partner/purchase/mtwm/order_comment.go index 60113d1e7..ab4b3bcd0 100644 --- a/business/partner/purchase/mtwm/order_comment.go +++ b/business/partner/purchase/mtwm/order_comment.go @@ -52,6 +52,7 @@ 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 == "" { @@ -59,7 +60,6 @@ func (c *PurchaseHandler) RefreshComment(fromTime, toTime time.Time) (err error) } // 查询门店差评 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,6 +110,8 @@ 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 } @@ -117,17 +119,20 @@ func (c *PurchaseHandler) RefreshComment(fromTime, toTime time.Time) (err error) orderCommentList = append(orderCommentList, orderComment) } } - globals.SugarLogger.Debugf("------lem := %d", len(orderCommentList)) + + globals.SugarLogger.Debugf("-----------vendorOrderID storeID:= %d,orderCommentList --- :%d", storeID, len(orderCommentList)) return orderCommentList, nil }, storeIDs) task.Run() - resultList, _ := task.GetResult(0) - //if err = err2; err != nil { - // return err - //} + resultList, err2 := task.GetResult(0) + globals.SugarLogger.Debugf("-----------err2 := %v", err) + globals.SugarLogger.Debugf("-----------resultList1 := %s", utils.Format4Output(resultList, false)) + if err = err2; err != nil { + return err + } - globals.SugarLogger.Debugf("--------------resultList := %d", len(resultList)) + globals.SugarLogger.Debugf("--------------resultList2 := %d", len(resultList)) var orderCommentList []*model.OrderComment for _, result := range resultList { orderComment := result.(*model.OrderComment)