This commit is contained in:
邹宗楠
2023-09-06 15:22:42 +08:00
parent 805df01d42
commit 5ec09063e6
2 changed files with 3 additions and 3 deletions

View File

@@ -210,7 +210,7 @@ func Init() {
// 每分钟轮询一次,推送骑手信息(假的订单) // 每分钟轮询一次,推送骑手信息(假的订单)
ScheduleTimerFuncByInterval(func() { ScheduleTimerFuncByInterval(func() {
delivery.UpdateFakeWayBillToTiktok() delivery.UpdateFakeWayBillToTiktok()
}, 10*time.Second, 5*time.Minute) }, 10*time.Second, 1*time.Minute)
// 每五分钟轮询一次推送骑手信息坐标给美团(真的订单) // 每五分钟轮询一次推送骑手信息坐标给美团(真的订单)
ScheduleTimerFuncByInterval(func() { ScheduleTimerFuncByInterval(func() {

View File

@@ -1521,10 +1521,10 @@ func GetWayBillFakeOrder() (waybills []*model.Waybill, err error) {
sql := ` sql := `
SELECT * SELECT *
FROM waybill FROM waybill
WHERE waybill_vendor_id = ? AND status < ? AND waybill_created_at>= ? AND waybill_created_at< ? WHERE waybill_vendor_id IN (` + GenQuestionMarks(2) + `) AND status < ? AND waybill_created_at>= ? AND waybill_created_at< ?
` `
sqlParams := []interface{}{model.VendorJXFakeWL, model.WaybillStatusFailed, time.Now().Add(-2 * 24 * time.Hour), time.Now()} sqlParams := []interface{}{model.VendorJXFakeWL, model.VendorIDUnknown, model.WaybillStatusFailed, time.Now().Add(-2 * 24 * time.Hour), time.Now()}
err = GetRows(GetDB(), &waybills, sql, sqlParams) err = GetRows(GetDB(), &waybills, sql, sqlParams)
return waybills, err return waybills, err
} }