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

aa

Browse Source
This commit is contained in:
suyl
2021-08-19 11:03:28 +08:00
parent 0d216de9c3
commit 45bb4f84cc
1 changed files with 75 additions and 75 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
business/partner/purchase/ebai/order_comment.go
View File

@@ -37,19 +37,19 @@ func (c *PurchaseHandler) refreshCommentOnce() {
func (c *PurchaseHandler) RefreshComment(fromTime, toTime time.Time) (err error) { func (c *PurchaseHandler) RefreshComment(fromTime, toTime time.Time) (err error) {
globals.SugarLogger.Debugf("RefreshComment fromTime:%s, toTime:%s", utils.Time2Str(fromTime), utils.Time2Str(toTime)) globals.SugarLogger.Debugf("RefreshComment fromTime:%s, toTime:%s", utils.Time2Str(fromTime), utils.Time2Str(toTime))
var orderCommentList []*model.OrderComment var orderCommentList []*model.OrderComment
stepGap := 24 * time.Hour //stepGap := 24 * time.Hour
stepFromTime := fromTime //stepFromTime := fromTime
for { //for {
stepToTime := stepFromTime.Add(stepGap - time.Second) //stepToTime := stepFromTime.Add(stepGap - time.Second)
if stepToTime.Sub(toTime) > 0 { //if stepToTime.Sub(toTime) > 0 {
stepToTime = toTime // stepToTime = toTime
} //}
if stepToTime.Sub(stepFromTime) == 0 { //if stepToTime.Sub(stepFromTime) == 0 {
break // break
} //}
storeIDs, _ := dao.GetOrderStoreIDs(dao.GetDB(), stepFromTime, stepToTime, model.VendorIDEBAI) storeIDs, _ := dao.GetOrderStoreIDs(dao.GetDB(), fromTime, toTime, model.VendorIDEBAI)
for _, v := range storeIDs { for _, v := range storeIDs {
if commentList, err := api.EbaiAPI.OrderCommetGet(utils.Int2Str(v), 0, stepToTime, stepToTime, 0); err == nil { if commentList, err := api.EbaiAPI.OrderCommetGet(utils.Int2Str(v), 0, fromTime, toTime, 0); err == nil {
for _, comment := range commentList { for _, comment := range commentList {
if comment.OrderID != 0 && comment.AnonymousRating == "0" && comment.CanReply == "1" { if comment.OrderID != 0 && comment.AnonymousRating == "0" && comment.CanReply == "1" {
orderComment := &model.OrderComment{ orderComment := &model.OrderComment{
@@ -112,11 +112,11 @@ func (c *PurchaseHandler) RefreshComment(fromTime, toTime time.Time) (err error)
// orderCommentList = append(orderCommentList, orderComment) // orderCommentList = append(orderCommentList, orderComment)
// } // }
//} //}
if stepToTime.Sub(toTime) == 0 { //if stepToTime.Sub(toTime) == 0 {
break // break
} //}
stepFromTime = stepToTime.Add(time.Second) //stepFromTime = stepToTime.Add(time.Second)
} //}
if err == nil && len(orderCommentList) > 0 { if err == nil && len(orderCommentList) > 0 {
err = partner.CurOrderManager.OnOrderComments(orderCommentList) err = partner.CurOrderManager.OnOrderComments(orderCommentList)
} }