From e6bc229252e42c7b919317d1c032764efea82a41 Mon Sep 17 00:00:00 2001 From: "pref_mail@163.com" Date: Mon, 5 Aug 2024 12:05:27 +0800 Subject: [PATCH] =?UTF-8?q?fix:=E4=BF=AE=E5=A4=8D=E6=AC=A7=E6=B4=BE?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E9=87=8D=E6=8E=A8=E6=9F=A5=E8=AF=A2=E5=A4=B1?= =?UTF-8?q?=E8=B4=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/logpm/factory/jobhandler/OpFailPackageRetryJob.java | 5 ++++- .../factory/oupai/mapper/OpFailRetryPushPackageMapper.xml | 2 +- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/OpFailPackageRetryJob.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/OpFailPackageRetryJob.java index a6ce75355..b40f1c260 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/OpFailPackageRetryJob.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/OpFailPackageRetryJob.java @@ -51,8 +51,11 @@ public class OpFailPackageRetryJob { private void batchHandleData(Long startId, Integer quantity) { List batchData = opFailRetryPushPackageMapper.selectWaitData(quantity, startId); - opFailRetryPushPackageService.retry(batchData); + log.info("OpFailPackageRetryJob batchHandleData startId:{},quantity:{}",startId,quantity); +// opFailRetryPushPackageService.retry(batchData); + log.info("OpFailPackageRetryJob batchHandleData end"); + log.info("batchData.size {}",batchData.size()); if (batchData.size()== quantity) { batchHandleData(batchData.get(quantity - 1).getId(), quantity); } diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/mapper/OpFailRetryPushPackageMapper.xml b/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/mapper/OpFailRetryPushPackageMapper.xml index 825e5078b..6edbdc657 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/mapper/OpFailRetryPushPackageMapper.xml +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/mapper/OpFailRetryPushPackageMapper.xml @@ -24,7 +24,7 @@ SELECT * FROM logpm_factory.op_fail_retry_push_package WHERE push_status = 1 - id > #{startId} + and id > #{startId} ORDER BY id LIMIT #{limit}