| | |
|---|
| | | @Override |
|---|
| | | public List<CloudWmsNotifyLog> listPending(int limit, int maxRetry) { |
|---|
| | | Page<CloudWmsNotifyLog> page = new Page<>(1, Math.max(1, limit)); |
|---|
| | | // .lt(CloudWmsNotifyLog::getRetryCount, maxRetry) |
|---|
| | | LambdaQueryWrapper<CloudWmsNotifyLog> wrapper = new LambdaQueryWrapper<CloudWmsNotifyLog>() |
|---|
| | | .eq(CloudWmsNotifyLog::getNotifyStatus, getNotifyStatusPending()) |
|---|
| | | .lt(CloudWmsNotifyLog::getRetryCount, maxRetry) |
|---|
| | | .orderByAsc(CloudWmsNotifyLog::getId); |
|---|
| | | if (maxRetry >= 0) { |
|---|
| | | wrapper.lt(CloudWmsNotifyLog::getRetryCount, maxRetry); |
|---|
| | | } |
|---|
| | | return page(page, wrapper).getRecords(); |
|---|
| | | } |
|---|
| | | |
|---|
