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")