1
This commit is contained in:
@@ -189,7 +189,7 @@ func Init() {
|
|||||||
// 每分钟轮询一次,推送抖店骑手信息
|
// 每分钟轮询一次,推送抖店骑手信息
|
||||||
ScheduleTimerFuncByInterval(func() {
|
ScheduleTimerFuncByInterval(func() {
|
||||||
delivery.UpdateFakeWayBillToTiktok()
|
delivery.UpdateFakeWayBillToTiktok()
|
||||||
}, 10*time.Second, 1*time.Minute)
|
}, 10*time.Second, 10*time.Minute)
|
||||||
|
|
||||||
// 定时任务更新负责人信息
|
// 定时任务更新负责人信息
|
||||||
ScheduleTimerFunc("RefreshStoreOperator", func() {
|
ScheduleTimerFunc("RefreshStoreOperator", func() {
|
||||||
|
|||||||
@@ -278,7 +278,7 @@ func UpdateFakeWayBillToTiktok() {
|
|||||||
}
|
}
|
||||||
// 更新运单为完成状态
|
// 更新运单为完成状态
|
||||||
if fakeWayBill[i].Status == model.WaybillStatusDelivered {
|
if fakeWayBill[i].Status == model.WaybillStatusDelivered {
|
||||||
sql := `UPDATE goods_order g SET g.status = ?,g.vendor_status = ? WHERE g.vendor_order_id = ? `
|
sql := `UPDATE goods_order g SET g.status = ?,g.vendor_status = ? WHERE g.vendor_order_id = ? `
|
||||||
_, err := dao.ExecuteSQL(dao.GetDB(), sql, []interface{}{model.OrderStatusFinished, model.OrderStatusFinished, fakeWayBill[i].VendorOrderID}...)
|
_, err := dao.ExecuteSQL(dao.GetDB(), sql, []interface{}{model.OrderStatusFinished, model.OrderStatusFinished, fakeWayBill[i].VendorOrderID}...)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
globals.SugarLogger.Debugf("UPDATA goods_order Err :%s", err.Error())
|
globals.SugarLogger.Debugf("UPDATA goods_order Err :%s", err.Error())
|
||||||
|
|||||||
Reference in New Issue
Block a user