Authored by LUOXC

fixbug

... ... @@ -677,8 +677,6 @@ public class SkupListService {
private final static int secondsOf2Hours = 2*3600;
private List<SellerOrderGoods> getSellerOrderGoodsBySellerChangePriceRecords(List<SellerChangePriceRecord> needChangePriceRecords){
int dtOf2Hours = DateUtil.getCurrentTimeSecond() - secondsOf2Hours;
List<SellerOrderGoods> result = null;
List<Integer> skups = null;
Iterator<SellerChangePriceRecord> ncprIter = needChangePriceRecords.iterator();
SellerChangePriceRecord scpr;
while (ncprIter.hasNext()){
... ... @@ -691,13 +689,15 @@ public class SkupListService {
ncprIter.remove();
}
}
if(needChangePriceRecords.isEmpty()){
return Lists.newArrayList();
}
skups = needChangePriceRecords.parallelStream()
List<Integer> skups = needChangePriceRecords.parallelStream()
.map(SellerChangePriceRecord::getSkup)
.collect(Collectors.toList());
skups.add(needChangePriceRecords.get(0).getPreSkup());
result = sellerOrderGoodsMapper.selectBySkups(skups);
return result;
return sellerOrderGoodsMapper.selectBySkups(skups);
}
... ...