| | |
|---|
| | | |
|---|
| | | private List<List<UserDto>> splitUsersIntoBatches(List<UserDto> users, int batchSize,Integer keywordId) { |
|---|
| | | |
|---|
| | | /* Keyword keyword = keywordService.getById(keywordId); |
|---|
| | | Keyword keyword = keywordService.getById(keywordId); |
|---|
| | | if (null==keyword.getNum()){ |
|---|
| | | keyword.setNum(0); |
|---|
| | | } |
|---|
| | | keyword.setNum(keyword.getNum()+1); |
|---|
| | | keywordService.updateById(keyword);*/ |
|---|
| | | keywordService.updateById(keyword); |
|---|
| | | |
|---|
| | | List<List<UserDto>> batches = new ArrayList<>(); |
|---|
| | | for (int i = 0; i < users.size(); i += batchSize) { |
|---|
| | |
|---|
| | | keywordService.update(updateWrapper); |
|---|
| | | //设置轮数 |
|---|
| | | Keyword keyword = keywordService.getById(batchRequest.getKeyword_id()); |
|---|
| | | if (null==keyword.getNum()){ |
|---|
| | | keyword.setNum(0); |
|---|
| | | } |
|---|
| | | keyword.setNum(keyword.getNum()+1); |
|---|
| | | keywordService.updateById(keyword); |
|---|
| | | |
|---|
| | | //设置订单进入采集状态 |
|---|
| | | LambdaUpdateWrapper<Orders> updateOrderWrapper = new LambdaUpdateWrapper<>(); |
|---|
| | | updateOrderWrapper.eq(Orders::getOrder_id, keyword.getOrder_id()) // 确保字段名正确 |
|---|
