feat:job
This commit is contained in:
@@ -687,7 +687,7 @@ public class XxlJobHandler {
|
||||
int pageSize = CommonConstants.BATCH_SIZE;
|
||||
while (hasNext) {
|
||||
PageHelper.startPage(pageNum, pageSize);
|
||||
List<WalletTradeDO> walletTradeDOS = walletTradeDAO.transferTradeList(WalletTradeModuleEnum.STANDARD_STORE.getModule(), 1);
|
||||
List<WalletTradeDO> walletTradeDOS = walletTradeDAO.transferTradeList(WalletTradeModuleEnum.TRANSFER.getModule(), 1);
|
||||
hasNext = walletTradeDOS.size() >= pageSize;
|
||||
if (CollectionUtils.isEmpty(walletTradeDOS)) {
|
||||
break;
|
||||
@@ -713,7 +713,7 @@ public class XxlJobHandler {
|
||||
int pageSize = CommonConstants.BATCH_SIZE;
|
||||
while (hasNext) {
|
||||
PageHelper.startPage(pageNum, pageSize);
|
||||
List<WalletTradeDO> walletTradeDOS = walletTradeDAO.transferTradeList(WalletTradeModuleEnum.STANDARD_STORE.getModule(), 2);
|
||||
List<WalletTradeDO> walletTradeDOS = walletTradeDAO.transferTradeList(WalletTradeModuleEnum.TRANSFER.getModule(), 2);
|
||||
hasNext = walletTradeDOS.size() >= pageSize;
|
||||
if (CollectionUtils.isEmpty(walletTradeDOS)) {
|
||||
break;
|
||||
|
||||
Reference in New Issue
Block a user