更新

app/task/svc/svc_cinema5bms_order.go

@@ -18,9 +18,9 @@ func Cinema5bmsOrder() {
 	cinema5bmsAppsecret := offical.SysCfgByKeyStr("cinema5bms_appSecret")
 	uid := "0"
 	// 获取上次获取订单时候的时间戳
-
+	pvdTimeKey := "cinema5bms_order_time"
 	now := time.Now().Unix()
-	past := time.Now().Unix()
+	past := GetRunTime(uid, pvdTimeKey, "短剧获取订单时间")
 	var (
 		beginTime int64 = 0
 		endTime   int64 = 0
@@ -53,16 +53,28 @@ func Cinema5bmsOrder() {
 
 		count := GetNewVideoOrder(uid, cinema5bmsAppsecret, arg)
 		if count == 0 {
-			break
+			goto ChkArg
 		}
-		if count == pageSize {
+		if count <= pageSize {
 			pageNo++
 			continue
 		}
-
+	ChkArg:
+		// 查询完后重置时间, 最后查询时间
+		if endTime < now {
+			pageNo = 1
+			SetRunTime(uid, pvdTimeKey, utils.TimeToStr(endTime))
+			beginTime = endTime
+			endTime = endTime + eveTime
+			if endTime > now {
+				endTime = now
+			}
+			continue
+		}
+		break
 	}
 	// 更新最后供应商执行订单时间
-	//SetRunTime(uid, pvdTimeKey, utils.TimeToStr(now))
+	SetRunTime(uid, pvdTimeKey, utils.TimeToStr(now))
 }
 func Cinema5bmsOrderDate() {
 	cinema5bmsAppid := offical.SysCfgByKeyStr("cinema5bms_appid")
@@ -88,7 +100,7 @@ func Cinema5bmsOrderDate() {
 		if count == 0 {
 			break
 		}
-		if count == pageSize {
+		if count <= pageSize {
 			pageNo++
 			continue
 		}