mirror of https://github.com/jeecgboot/jeecg-boot
cleanup
parent
3030a527c2
commit
7d1bfbe03c
|
@ -491,10 +491,6 @@ public class SkuListMabangServiceImpl extends ServiceImpl<SkuListMabangMapper, S
|
||||||
List<SkuAddResponse> results = futures.stream().map(CompletableFuture::join).collect(toList());
|
List<SkuAddResponse> results = futures.stream().map(CompletableFuture::join).collect(toList());
|
||||||
long successCount = results.stream().filter(SkuAddResponse::success).count();
|
long successCount = results.stream().filter(SkuAddResponse::success).count();
|
||||||
log.info("{}/{} skus published successfully.", successCount, skuDataList.size());
|
log.info("{}/{} skus published successfully.", successCount, skuDataList.size());
|
||||||
List<String> successes = results.stream()
|
|
||||||
.filter(SkuAddResponse::success)
|
|
||||||
.map(SkuAddResponse::getStockSku)
|
|
||||||
.collect(toList());
|
|
||||||
results.forEach(response -> {
|
results.forEach(response -> {
|
||||||
if(response.success()) {
|
if(response.success()) {
|
||||||
responses.addSuccess(response.getStockSku());
|
responses.addSuccess(response.getStockSku());
|
||||||
|
|
Loading…
Reference in New Issue