1

business/jxstore/misc/misc.go

@@ -64,26 +64,27 @@ var (
 		"04:00:00",
 	}
 	refreshPageActTimeList = []string{
-		"05:00:00",
+		"7:00:00",
-		//"08:00:00",
+		"8:00:00",
-		//"09:00:00",
+		"9:00:00",
-		//"10:00:00",
+		"10:00:00",
-		//"11:00:00",
+		"11:00:00",
-		//"12:00:00",
+		"12:00:00",
-		//"13:00:00",
+		"13:00:00",
-		//"14:00:00",
+		"14:00:00",
-		//"15:00:00",
+		"15:00:00",
-		//"16:00:00",
+		"16:00:00",
-		//"17:00:00",
+		"17:00:00",
-		//"18:00:00",
+		"18:00:00",
-		//"19:00:00",
+		"19:00:00",
-		//"22:00:00", 检查七牛云流量使用情况
+		"22:00:00",
 	}
+	// 七牛云流量检查
 	ChangeStoreSkuSaleStatusList = []string{
-		"7:20:00",
+		//"7:00:00",
-		"8:20:00",
+		//"8:00:00",
-		"9:20:00", // 检查七牛云流量使用情况 7:00,8:00,9:00
+		//"9:00:00",
-		//"10:00:00",
+		/*	//"10:00:00",
 			//"11:00:00",
 			//"12:00:00",
 			//"13:00:00",
@@ -93,7 +94,7 @@ var (
 			//"17:00:00",
 			//"18:00:00",
 			//"19:00:00",
-		//"20:00:00",
+			//"20:00:00",*/
 	}
 	openRemoteStoreTimeList = []string{
 		"04:30:00",
@@ -328,15 +329,14 @@ func Init() {
 		ScheduleTimerFunc("RefreshPageActs", func() {
 			act.RefreshPageActs(jxcontext.AdminCtx, []int{model.VendorIDEBAI}, time.Now().Add(-30*24*time.Hour), false)
 		}, refreshPageActTimeList)
-
 		ScheduleTimerFunc("UpdateActStatusByTime", func() {
 			dao.UpdateActStatusByTime(dao.GetDB(), time.Now())
 		}, updateActStatusTimeList)
 		ScheduleScoreStore()
 		// ScheduleCheckStoreAlert()
-		ScheduleTimerFunc("ChangeStoreSkuSaleStatus", func() {
+		//ScheduleTimerFunc("ChangeStoreSkuSaleStatus", func() {
-			cms.CurVendorSync.ChangeStoreSkuSaleStatus(jxcontext.AdminCtx, 0, true, true)
+		//	cms.CurVendorSync.ChangeStoreSkuSaleStatus(jxcontext.AdminCtx, 0, true, true)
-		}, ChangeStoreSkuSaleStatusList)
+		//}, ChangeStoreSkuSaleStatusList)
 		ScheduleTimerFunc("BeginSavePriceRefer", func() {
 			report.BeginSavePriceRefer(jxcontext.AdminCtx, nil, nil, true, true)
 		}, priceReferTimeList)

business/partner/purchase/tiktok_store/order_afs_utils.go

@@ -123,13 +123,30 @@ func (c *PurchaseHandler) onAfsOrderMsg(msgId string, msg interface{}) (retVal *
 			err = partner.CurOrderManager.OnAfsOrderNew(afsOrder, orderStatus)
 		}
 	} else {
-		err = partner.CurOrderManager.OnAfsOrderStatusChanged(orderStatus)
+		if err2 := partner.CurOrderManager.OnAfsOrderStatusChanged(orderStatus); err2 == nil {
-		if err == nil && msgId == tiktokShop.CallbackReturnRefundAgreedMsgTagId {
+			if msgId == tiktokShop.CallbackRefundOrderSuccessMsgTagId {
+				skuList, _ := dao.GetSimpleOrderSkus(db, orderStatus.RefVendorOrderID, nil)
+				totalSkuCount := 0
+				for _, v := range skuList {
+					totalSkuCount += v.Count
+				}
+
+				financialSku, _ := dao.GetOrderRefundSkuList(db, []string{orderStatus.RefVendorOrderID})
+				refundSkuCount := 0
+				for _, v := range financialSku {
+					refundSkuCount += v.Count
+				}
+				if totalSkuCount == refundSkuCount {
 					goodsOrder, _ := partner.CurOrderManager.LoadOrder(orderStatus.RefVendorOrderID, orderStatus.VendorID)
 					goodsOrder.Status = model.OrderStatusCanceled
 					goodsOrder.VendorStatus = orderStatus.VendorStatus
 					dao.UpdateEntity(db, goodsOrder, "Status", "VendorStatus")
+					// 取消三方运单
 				}
+
+			}
+		}
+
 	}
 
 	return tiktokShop.Err2CallbackResponse(err, "")