| | |
|---|
| | | public List<CloudWmsNotifyLog> listPending(int limit, int maxRetry) { |
|---|
| | | Page<CloudWmsNotifyLog> page = new Page<>(1, Math.max(1, limit)); |
|---|
| | | LambdaQueryWrapper<CloudWmsNotifyLog> wrapper = new LambdaQueryWrapper<CloudWmsNotifyLog>() |
|---|
| | | .eq(CloudWmsNotifyLog::getNotifyStatus, getNotifyStatusPending()) |
|---|
| | | .lt(CloudWmsNotifyLog::getRetryCount, maxRetry) |
|---|
| | | // 仅查询数据库配置状态：待通知 + 失败（可重试） |
|---|
| | | .in(CloudWmsNotifyLog::getNotifyStatus, getNotifyStatusPending(), getNotifyStatusFail()) |
|---|
| | | // 仅查询可重试数据：无限重试、未配置上限、或未达到上限 |
|---|
| | | .apply("(max_retry_count IS NULL OR max_retry_count = -1 OR retry_count < max_retry_count)") |
|---|
| | | .orderByAsc(CloudWmsNotifyLog::getId); |
|---|
| | | if (maxRetry >= 0) { |
|---|
| | | wrapper.lt(CloudWmsNotifyLog::getRetryCount, maxRetry); |
|---|
| | | } |
|---|
| | | return page(page, wrapper).getRecords(); |
|---|
| | | } |
|---|
| | | |
|---|
| | |
|---|
| | | public void fillFromConfig(CloudWmsNotifyLog log) { |
|---|
| | | Integer maxRetry = getConfigInt(GlobalConfigCode.CLOUD_WMS_NOTIFY_MAX_RETRY); |
|---|
| | | Integer interval = getConfigInt(GlobalConfigCode.CLOUD_WMS_NOTIFY_RETRY_INTERVAL_SECONDS); |
|---|
| | | log.setNotifyStatus(getNotifyStatusPending()); |
|---|
| | | log.setMaxRetryCount(maxRetry); |
|---|
| | | log.setRetryIntervalSeconds(interval); |
|---|
| | | } |
|---|
