liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
邹宗楠
2024-09-13 11:51:24 +08:00
parent a8a52e52bc
commit ff807865bf
1 changed files with 16 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
business/partner/purchase/mtwm/order_comment.go
View File

@@ -52,14 +52,10 @@ func (c *PurchaseHandler) RefreshComment(fromTime, toTime time.Time) (err error)
task := tasksch.NewParallelTask("mtwm RefreshComment", nil, jxcontext.AdminCtx, task := tasksch.NewParallelTask("mtwm RefreshComment", nil, jxcontext.AdminCtx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
storeID := batchItemList[0].(int) storeID := batchItemList[0].(int)
var orderCommentList []*model.OrderComment
storeDetail, _ := dao.GetStoreDetail(dao.GetDB(), storeID, model.VendorIDMTWM, "") 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) 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 { if len(commentList) == model.NO || commentList == nil {
return nil, nil return nil, nil
} }
@@ -110,8 +106,6 @@ func (c *PurchaseHandler) RefreshComment(fromTime, toTime time.Time) (err error)
if len(foodNameList) > 0 { if len(foodNameList) > 0 {
vendorOrderID, _ := dao.GetBadCommentOrderId(storeDetail.ID, time.Now().Add(-RefreshCommentTime), startTime, nameList) 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 != "" { if vendorOrderID != "" {
orderComment.VendorOrderID2 = 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 return orderCommentList, nil
}, storeIDs) }, storeIDs)
task.Run() task.Run()
resultList, err2 := task.GetResult(0) _, err2 := task.GetResult(0)
globals.SugarLogger.Debugf("-----------err2 := %v", err)
globals.SugarLogger.Debugf("-----------resultList1 := %s", utils.Format4Output(resultList, false))
if err = err2; err != nil { if err = err2; err != nil {
return err return err
} }
globals.SugarLogger.Debugf("--------------resultList2 := %d", len(resultList)) //var orderCommentList []*model.OrderComment
var orderCommentList []*model.OrderComment //for _, result := range resultList {
for _, result := range resultList { // orderComment := result.(*model.OrderComment)
orderComment := result.(*model.OrderComment) // orderCommentList = append(orderCommentList, orderComment)
orderCommentList = append(orderCommentList, orderComment) //}
} //
//if len(orderCommentList) > 0 {
if len(orderCommentList) > 0 { // err = partner.CurOrderManager.OnOrderComments(orderCommentList)
globals.SugarLogger.Debugf("--------------orderCommentList := %d", len(orderCommentList)) //}
err = partner.CurOrderManager.OnOrderComments(orderCommentList) //
}
return err return err
} }