aa

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

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