diff --git a/app/task/svc/svc_cinema5bms_order.go b/app/task/svc/svc_cinema5bms_order.go index 55f5562..a4f585f 100644 --- a/app/task/svc/svc_cinema5bms_order.go +++ b/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 }