From deea59fdbf830e2b40cccea2d1301bc7eccd631e Mon Sep 17 00:00:00 2001 From: WrBug Date: Thu, 15 Jan 2026 15:21:29 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=20OrderStatusUpdateSe?= =?UTF-8?q?rvice=20=E7=9A=84=E4=BA=8B=E5=8A=A1=E5=92=8C=E5=B9=B6=E5=8F=91?= =?UTF-8?q?=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 1. 解决 @Transactional 自调用问题 - 实现 ApplicationContextAware 接口 - 通过代理对象调用 @Transactional 方法，确保事务生效 2. 防止定时任务并发执行 - 添加 updateJob 跟踪上一次任务状态 - 如果上一次任务还在执行，跳过本次执行 - 避免多个更新任务同时运行导致的数据竞争 修改的方法： - updateOrderStatus(): 添加并发控制 - cleanupDeletedAccountOrders(): 通过代理对象调用 - checkAndDeleteUnfilledOrders(): 通过代理对象调用 - updatePendingSellOrderPrices(): 通过代理对象调用 - updatePendingBuyOrders(): 通过代理对象调用 --- .../statistics/OrderStatusUpdateService.kt | 54 +++++++++++++++---- 1 file changed, 44 insertions(+), 10 deletions(-) diff --git a/backend/src/main/kotlin/com/wrbug/polymarketbot/service/copytrading/statistics/OrderStatusUpdateService.kt b/backend/src/main/kotlin/com/wrbug/polymarketbot/service/copytrading/statistics/OrderStatusUpdateService.kt index cae9855..6d4ebcf 100644 --- a/backend/src/main/kotlin/com/wrbug/polymarketbot/service/copytrading/statistics/OrderStatusUpdateService.kt +++ b/backend/src/main/kotlin/com/wrbug/polymarketbot/service/copytrading/statistics/OrderStatusUpdateService.kt @@ -12,6 +12,8 @@ import com.wrbug.polymarketbot.util.multi import kotlinx.coroutines.* import org.slf4j.LoggerFactory import org.springframework.boot.context.event.ApplicationReadyEvent +import org.springframework.context.ApplicationContext +import org.springframework.context.ApplicationContextAware import org.springframework.context.event.EventListener import org.springframework.context.i18n.LocaleContextHolder import org.springframework.scheduling.annotation.Scheduled @@ -37,11 +39,29 @@ class OrderStatusUpdateService( private val trackingService: CopyOrderTrackingService, private val marketService: MarketService, // 市场信息服务 private val telegramNotificationService: TelegramNotificationService? -) { +) : ApplicationContextAware { private val logger = LoggerFactory.getLogger(OrderStatusUpdateService::class.java) private val updateScope = CoroutineScope(Dispatchers.IO + SupervisorJob()) + + // 跟踪上一次更新任务的 Job，防止并发执行 + @Volatile + private var updateJob: Job? = null + + private var applicationContext: ApplicationContext? = null + + override fun setApplicationContext(applicationContext: ApplicationContext) { + this.applicationContext = applicationContext + } + + /** + * 获取代理对象，用于解决 @Transactional 自调用问题 + */ + private fun getSelf(): OrderStatusUpdateService { + return applicationContext?.getBean(OrderStatusUpdateService::class.java) + ?: throw IllegalStateException("ApplicationContext not initialized") + } // 缓存首次检测到订单详情为 null 的时间戳（订单ID -> 首次检测时间） private val orderNullDetectionTime = ConcurrentHashMap() @@ -60,24 +80,38 @@ class OrderStatusUpdateService( /** * 定时更新订单状态 * 每5秒执行一次 + * 如果上一次任务还在执行，则跳过本次执行，避免并发问题 */ @Scheduled(fixedDelay = 5000) fun updateOrderStatus() { - updateScope.launch { + // 检查上一次任务是否还在执行 + val previousJob = updateJob + if (previousJob != null && previousJob.isActive) { + logger.debug("上一次订单状态更新任务还在执行，跳过本次执行") + return + } + + // 启动新任务并记录 Job + updateJob = updateScope.launch { try { - // 1. 清理已删除账户的订单 - cleanupDeletedAccountOrders() + val self = getSelf() + + // 1. 清理已删除账户的订单（通过代理对象调用，确保事务生效） + self.cleanupDeletedAccountOrders() - // 2. 检查30秒前创建的订单，如果未成交则删除 - checkAndDeleteUnfilledOrders() + // 2. 检查30秒前创建的订单，如果未成交则删除（通过代理对象调用，确保事务生效） + self.checkAndDeleteUnfilledOrders() - // 3. 更新卖出订单的实际成交价并发送通知（priceUpdated 共用字段） - updatePendingSellOrderPrices() + // 3. 更新卖出订单的实际成交价并发送通知（priceUpdated 共用字段）（通过代理对象调用，确保事务生效） + self.updatePendingSellOrderPrices() - // 4. 更新买入订单的实际数据并发送通知 - updatePendingBuyOrders() + // 4. 更新买入订单的实际数据并发送通知（通过代理对象调用，确保事务生效） + self.updatePendingBuyOrders() } catch (e: Exception) { logger.error("订单状态更新异常: ${e.message}", e) + } finally { + // 任务完成后清除 Job 引用 + updateJob = null } } }