| @@ -22,6 +22,7 @@ import org.springframework.beans.factory.annotation.Autowired; | |||||
| import org.springframework.stereotype.Service; | import org.springframework.stereotype.Service; | ||||
| import java.util.*; | import java.util.*; | ||||
| import java.util.stream.Collectors; | |||||
| @Service | @Service | ||||
| public class WxCouponChannelServiceImpl implements WxCouponChannelService { | public class WxCouponChannelServiceImpl implements WxCouponChannelService { | ||||
| @@ -144,9 +145,15 @@ public class WxCouponChannelServiceImpl implements WxCouponChannelService { | |||||
| record.setCouponId(null); | record.setCouponId(null); | ||||
| } | } | ||||
| Long finalCouponId = couponId; | Long finalCouponId = couponId; | ||||
| return wxCouponChannelMapper.findVoList(record).parallelStream() | |||||
| List<WxCouponChannelVo> voList = wxCouponChannelMapper.findVoList(record).stream() | |||||
| .filter(wxCouponChannelVo -> !wxCouponChannelVo.getCouponId().equals(finalCouponId)) | .filter(wxCouponChannelVo -> !wxCouponChannelVo.getCouponId().equals(finalCouponId)) | ||||
| .findAny().orElse(null); | |||||
| .collect(Collectors.toList()); | |||||
| if (!voList.isEmpty()) { | |||||
| int size = voList.size() - 1; | |||||
| Random random = new Random(); | |||||
| return voList.get(random.nextInt(size)); | |||||
| } | |||||
| return null; | |||||
| } | } | ||||
| private boolean isCouponMerchantValid(Long couponId) { | private boolean isCouponMerchantValid(Long couponId) { | ||||