From 4910288c94f8ebf088b988a821e08dfe40eaaa15 Mon Sep 17 00:00:00 2001 From: suyl <770236076@qq.com> Date: Mon, 21 Jun 2021 11:45:10 +0800 Subject: [PATCH] aa --- business/jxcallback/orderman/order.go | 20 ++++++++++++++++++++ business/jxstore/misc/misc.go | 4 ++++ 2 files changed, 24 insertions(+) diff --git a/business/jxcallback/orderman/order.go b/business/jxcallback/orderman/order.go index a8b1c8512..a74b9099a 100644 --- a/business/jxcallback/orderman/order.go +++ b/business/jxcallback/orderman/order.go @@ -2133,3 +2133,23 @@ func buildOrderTo102919(order *model.GoodsOrder) { // } order.DeliveryFlag = model.OrderDeliveryFlagMaskScheduleDisabled } + +func RefreshJdAfsOrderTotalShopMoney() { + var ( + db = dao.GetDB() + afsOrders []*model.AfsOrder + ) + sql := ` + SELECT * FROM afs_order WHERE afs_created_at > ? AND vendor_id = ? AND status = ? AND afs_total_shop_money = 0 + ` + sqlParams := []interface{}{time.Now().AddDate(0, 0, -3), model.VendorIDJD, model.AfsOrderStatusFinished} + dao.GetRows(db, &afsOrders, sql, sqlParams) + for _, v := range afsOrders { + if handler := partner.GetPurchaseOrderHandlerFromVendorID(v.VendorID); handler != nil { + if orderAfsInfo, err := handler.GetOrderAfsInfo(nil, v.VendorOrderID, v.AfsOrderID); err == nil && orderAfsInfo.AfsTotalShopMoney != 0 { + v.AfsTotalShopMoney = orderAfsInfo.AfsTotalShopMoney + } + } + dao.UpdateEntity(db, v, "AfsTotalShopMoney") + } +} diff --git a/business/jxstore/misc/misc.go b/business/jxstore/misc/misc.go index 9646f9798..5e25cf37e 100644 --- a/business/jxstore/misc/misc.go +++ b/business/jxstore/misc/misc.go @@ -272,6 +272,10 @@ func Init() { ScheduleTimerFunc("SendQywxPeopleCount", func() { cms.SendQywxPeopleCount(jxcontext.AdminCtx) }, dailyHeartbeat) + //刷新京东售后单结算价 + ScheduleTimerFunc("RefreshJdAfsOrderTotalShopMoney", func() { + orderman.RefreshJdAfsOrderTotalShopMoney() + }, openRemoteStoreTimeList) ScheduleTimerFunc("doDailyWork", func() { globals.SugarLogger.Debug("doDailyWork")