- fk

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
 		}

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 {