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 10:22:47 +08:00
parent 6532479b1a
commit 5ac899e36d
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -49,7 +49,6 @@ func (c *PurchaseHandler) RefreshComment(fromTime, toTime time.Time) (err error)
endDateStr := startTime.Format("20060102") endDateStr := startTime.Format("20060102")
startDateStr := time.Now().Add(-RefreshCommentTime).Format("20060102") startDateStr := time.Now().Add(-RefreshCommentTime).Format("20060102")
storeIDs, _ := dao.GetOrderStoreIDs(dao.GetDB(), fromTime, toTime, model.VendorIDMTWM) storeIDs, _ := dao.GetOrderStoreIDs(dao.GetDB(), fromTime, toTime, model.VendorIDMTWM)
storeIDs = append(storeIDs, 804697)
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)
@@ -60,7 +59,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) commentList, _ := getAPI(storeDetail.VendorOrgCode, storeID, storeDetail.VendorStoreID).CommentQuery(storeDetail.VendorStoreID, startDateStr, endDateStr, 0, 0, mtwmapi.CommentReplyStatusNotReplied)
globals.SugarLogger.Debugf("--------------commentList := %d", len(commentList))
var orderCommentList []*model.OrderComment var orderCommentList []*model.OrderComment
if len(commentList) == model.NO || commentList == nil { if len(commentList) == model.NO || commentList == nil {
return nil, nil return nil, nil
@@ -119,13 +117,17 @@ func (c *PurchaseHandler) RefreshComment(fromTime, toTime time.Time) (err error)
orderCommentList = append(orderCommentList, orderComment) orderCommentList = append(orderCommentList, orderComment)
} }
} }
globals.SugarLogger.Debugf("----------orderCommentList := %s", utils.Format4Output(orderCommentList, false))
return orderCommentList, nil return orderCommentList, nil
}, storeIDs) }, storeIDs)
task.Run() task.Run()
resultList, err2 := task.GetResult(0) resultList, err2 := task.GetResult(0)
if err = err2; err != nil { if err = err2; err != nil {
globals.SugarLogger.Debugf("-------------err := %v", err)
return err return err
} }
var orderCommentList []*model.OrderComment var orderCommentList []*model.OrderComment
for _, result := range resultList { for _, result := range resultList {
orderComment := result.(*model.OrderComment) orderComment := result.(*model.OrderComment)