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:
邹宗楠
2023-07-18 10:33:18 +08:00
parent 4815f3909d
commit d32e9dd2db
1 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -55,12 +55,10 @@ func (c *PurchaseHandler) RefreshComment(fromTime, toTime time.Time) (err error)
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)
storeDetail, _ := dao.GetStoreDetail(dao.GetDB(), storeID, model.VendorIDMTWM, "") storeDetail, _ := dao.GetStoreDetail(dao.GetDB(), storeID, model.VendorIDMTWM, "")
commentList, err2 := 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= :%s", utils.Format4Output(commentList, false))
globals.SugarLogger.Debugf("========commentList= :%s", utils.Format4Output(err2, false))
var orderCommentList []*model.OrderComment var orderCommentList []*model.OrderComment
if err2 != nil || len(commentList) == model.NO { if len(commentList) == model.NO || commentList == nil {
return nil, err2 return nil, nil
} }
for _, mtwmComment := range commentList { for _, mtwmComment := range commentList {
createdTime, err := utils.TryStr2Time(mtwmComment.CommentTime) createdTime, err := utils.TryStr2Time(mtwmComment.CommentTime)
@@ -93,10 +91,11 @@ func (c *PurchaseHandler) RefreshComment(fromTime, toTime time.Time) (err error)
}, storeIDs) }, storeIDs)
task.Run() task.Run()
resultList, err2 := task.GetResult(0) resultList, err2 := task.GetResult(0)
globals.SugarLogger.Debugf("resultList := %s", utils.Format4Output(resultList, false))
globals.SugarLogger.Debugf("err2 := %s", utils.Format4Output(err2, false))
if err = err2; err != nil { if err = err2; err != nil {
return err return err
} }
globals.SugarLogger.Debugf("resultList := %s", utils.Format4Output(resultList, false))
var orderCommentList []*model.OrderComment var orderCommentList []*model.OrderComment
for _, result := range resultList { for _, result := range resultList {
orderComment := result.(*model.OrderComment) orderComment := result.(*model.OrderComment)