From 0f7a3ab809746bfd9415cb71a17f81aec7498072 Mon Sep 17 00:00:00 2001 From: gazebo Date: Wed, 13 Mar 2019 16:45:43 +0800 Subject: [PATCH] - fk --- business/jxstore/tempop/tempop.go | 2 +- business/partner/purchase/ebai/order_comment.go | 3 +++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index cabf3ae2d..5ef97d22a 100644 --- a/business/jxstore/tempop/tempop.go +++ b/business/jxstore/tempop/tempop.go @@ -858,7 +858,7 @@ func RefreshEbaiBadComment(ctx *jxcontext.Context, fromTime, toTime time.Time, i globals.SugarLogger.Debugf("RefreshEbaiBadComment fromTime:%s, toTime:%s, days:%d", utils.Time2Str(fromTime), utils.Time2Str(toTime), days) rootTask := tasksch.NewSeqTask("RefreshEbaiBadComment", ctx.GetUserName(), func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) { batchFromTime := fromTime.Add(time.Duration(step) * 24 * time.Hour) - batchToTime := batchFromTime.Add(24 * time.Hour) + batchToTime := batchFromTime.Add(24*time.Hour - time.Second) if batchToTime.Sub(toTime) > 0 { batchToTime = toTime } diff --git a/business/partner/purchase/ebai/order_comment.go b/business/partner/purchase/ebai/order_comment.go index 2474ad0ca..4795a2ccf 100644 --- a/business/partner/purchase/ebai/order_comment.go +++ b/business/partner/purchase/ebai/order_comment.go @@ -34,6 +34,9 @@ func (c *PurchaseHandler) RefreshComment(fromTime, toTime time.Time) (err error) if stepToTime.Sub(toTime) > 0 { stepToTime = toTime } + if stepToTime.Sub(stepFromTime) == 0 { + break + } resultList, err2 := api.EbaiAPI.GetEleCommentList(stepFromTime, stepToTime, "", "", ebaiapi.ReplyStatusAll, ebaiapi.CommentLevelAll, ebaiapi.CommentContentAll) if err = err2; err == nil { for _, result := range resultList {