diff --git a/business/jxstore/misc/misc.go b/business/jxstore/misc/misc.go index 5f6c1ba88..da8d1f729 100644 --- a/business/jxstore/misc/misc.go +++ b/business/jxstore/misc/misc.go @@ -341,6 +341,17 @@ func Init() { //刷新饿百平台活动 act.RrefreshEbaiVendorAct(jxcontext.AdminCtx) }, dailyWorkTimeList2) + // 每五分钟轮询一次推送骑手信息坐标给美团 + ScheduleTimerFuncByInterval(func() { + delivery.GetOrderRiderInfoToPlatform("") + }, 10*time.Second, 5*time.Minute) + + // 轮询每天更新当前时间一个月 + ScheduleTimerFunc("UpdateOrder2Complete", func() { + delivery.UpdateOrder2Complete() + }, []string{ + "04:00:00", + }) } //update xuhang 2022/04/06用于同步京东数据以取代爬取订单 但由于京东的v2API已不支持手机号 因此以下代码暂时注释 后续接入虚拟号可再次open /* ScheduleTimerFuncByInterval(func() { @@ -390,10 +401,6 @@ func Init() { }, []string{ "20:00:00", }) - // 每五分钟轮询一次推送骑手信息坐标给美团 - ScheduleTimerFuncByInterval(func() { - delivery.GetOrderRiderInfoToPlatform("") - }, 10*time.Second, 5*time.Minute) } if configs, err := dao.QueryConfigs(dao.GetDB(), "ebaiStorePageCookie", model.ConfigTypeCookie, ""); err == nil { ebaiStorePageCookie = configs[0].Value diff --git a/business/partner/delivery/rider.go b/business/partner/delivery/rider.go index 19c2c7c8d..fb0434d96 100644 --- a/business/partner/delivery/rider.go +++ b/business/partner/delivery/rider.go @@ -80,3 +80,16 @@ func GetOrderRiderInfoToPlatform(orderId string) { } return } + +//将以过期订单状态为配送中的订单修改为完成状态 +func UpdateOrder2Complete() { + sql := `UPDATE goods_order g SET g.status=110 WHERE g.status=20 AND g.order_created_at < ?` + sqlParams := []interface{}{ + time.Now().AddDate(0, 1, 0), + } + if num, err := dao.ExecuteSQL(dao.GetDB(), sql, sqlParams); err != nil { + globals.SugarLogger.Errorf("Update Order Status 20 To 110 Fail") + globals.SugarLogger.Debug("Update Order Status 20 To 110 Time,Count", time.Now(), num) + } + return +}