|
|
@@ -610,13 +610,12 @@ public class PurchaseApCheckServiceImpl implements PurchaseApCheckService {
|
|
|
*/
|
|
|
@Override
|
|
|
public SPage<Vendor> getCustomerInfo(PageParams params, String keyword, String checkDate, Long fromDate, Long endDate) throws InterruptedException {
|
|
|
- List<Vendor> vendors = findCustomerByPage(params, keyword);
|
|
|
+ List<Vendor> customers = findCustomerByPage(params, keyword);
|
|
|
SPage<Vendor> vendorSPage = new SPage<>();
|
|
|
- if (!CollectionUtils.isEmpty(vendors)) {
|
|
|
- List<Vendor> resultVendors = vendors.stream().filter(customer -> null != customer.getApcheck() && customer.getApcheck() == 1).collect(Collectors.toList());
|
|
|
+ if (!CollectionUtils.isEmpty(customers)) {
|
|
|
System.setProperty("java.util.concurrent.ForkJoinPool.common.parallelism", "100");
|
|
|
- resultVendors.parallelStream().forEach(customer -> this.countApCheck(customer, checkDate, fromDate, endDate));
|
|
|
- setVendorSPage(params, resultVendors, vendorSPage);
|
|
|
+ customers.parallelStream().forEach(customer -> this.countApCheck(customer, checkDate, fromDate, endDate));
|
|
|
+ setVendorSPage(params, customers, vendorSPage);
|
|
|
}
|
|
|
return vendorSPage;
|
|
|
}
|