|  | @@ -141,7 +141,7 @@ public class PartitionCrashServiceImpl implements PartitionCrashService {
 | 
	
		
			
				|  |  |          if (duserDOS.isEmpty()) {
 | 
	
		
			
				|  |  |              return;
 | 
	
		
			
				|  |  |          }
 | 
	
		
			
				|  |  | -        List<HashMap<Long, Integer>> afterCrashMap = new ArrayList<>();
 | 
	
		
			
				|  |  | +        List<HashMap<Long, Long>> afterCrashMap = new ArrayList<>();
 | 
	
		
			
				|  |  |          // 获取当前合赢奖百分比
 | 
	
		
			
				|  |  |          OrderPercentageDO orderPercentageDO = orderPercentageService.queryStatus();
 | 
	
		
			
				|  |  |  
 | 
	
	
		
			
				|  | @@ -198,10 +198,10 @@ public class PartitionCrashServiceImpl implements PartitionCrashService {
 | 
	
		
			
				|  |  |              if (sonOrderCalcDOS.isEmpty()) {
 | 
	
		
			
				|  |  |                  // 插入空数据
 | 
	
		
			
				|  |  |                  sonBuilder = addSonEmpty(sonBuilder, k);
 | 
	
		
			
				|  |  | -                crashSaveReqVOBuilder.sonPrice(0);
 | 
	
		
			
				|  |  | +                crashSaveReqVOBuilder.sonPrice(0L);
 | 
	
		
			
				|  |  |              }
 | 
	
		
			
				|  |  |              // 合计儿子分支额度
 | 
	
		
			
				|  |  | -            Integer sonSumPrice = sonOrderCalcDOS.stream().mapToInt(OrderCalcDO::getGrossProfitBonusQuota).sum();
 | 
	
		
			
				|  |  | +            Long sonSumPrice = sonOrderCalcDOS.stream().mapToLong(OrderCalcDO::getGrossProfitBonusQuota).sum();
 | 
	
		
			
				|  |  |              sonBuilder.price(sonSumPrice);
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  |              // 获取当前用户的兄弟分区
 | 
	
	
		
			
				|  | @@ -209,11 +209,11 @@ public class PartitionCrashServiceImpl implements PartitionCrashService {
 | 
	
		
			
				|  |  |              if (brothersOrderCalcDOS.isEmpty()) {
 | 
	
		
			
				|  |  |                  // 插入空数据
 | 
	
		
			
				|  |  |                  brotherBuilder = addBrotherEmpty(brotherBuilder, k);
 | 
	
		
			
				|  |  | -                crashSaveReqVOBuilder.brotherPrice(0);
 | 
	
		
			
				|  |  | +                crashSaveReqVOBuilder.brotherPrice(0L);
 | 
	
		
			
				|  |  |              }
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  |              // 合并兄弟分支额度
 | 
	
		
			
				|  |  | -            Integer brotherSumPrice = brothersOrderCalcDOS.stream().mapToInt(OrderCalcDO::getGrossProfitBonusQuota).sum();
 | 
	
		
			
				|  |  | +            Long brotherSumPrice = brothersOrderCalcDOS.stream().mapToLong(OrderCalcDO::getGrossProfitBonusQuota).sum();
 | 
	
		
			
				|  |  |              brotherBuilder.price(brotherSumPrice);
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  |  
 | 
	
	
		
			
				|  | @@ -228,8 +228,8 @@ public class PartitionCrashServiceImpl implements PartitionCrashService {
 | 
	
		
			
				|  |  |                  }
 | 
	
		
			
				|  |  |              }
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  | -            int afterCrash = 0;
 | 
	
		
			
				|  |  | -            Integer smallQuota = 0;
 | 
	
		
			
				|  |  | +            Long afterCrash = 0L;
 | 
	
		
			
				|  |  | +            Long smallQuota = 0L;
 | 
	
		
			
				|  |  |              // 碰撞计算
 | 
	
		
			
				|  |  |              if (sonSumPrice >= brotherSumPrice) {
 | 
	
		
			
				|  |  |                  sonBuilder.size(1);
 | 
	
	
		
			
				|  | @@ -251,20 +251,20 @@ public class PartitionCrashServiceImpl implements PartitionCrashService {
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  |              // 积分添加 添加的时候, 需要注意当前用户是否有足够的积分可以获取
 | 
	
		
			
				|  |  |              // 碰撞后的额度的
 | 
	
		
			
				|  |  | -            Integer highQuota = integralDO.getHighQuota();
 | 
	
		
			
				|  |  | -            Integer parentHighQuota = parentIntegralDo.getHighQuota();
 | 
	
		
			
				|  |  | +            Long highQuota = integralDO.getHighQuota();
 | 
	
		
			
				|  |  | +            Long parentHighQuota = parentIntegralDo.getHighQuota();
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  |              BigDecimal smallBigDecimal = new BigDecimal(String.valueOf(smallQuota));
 | 
	
		
			
				|  |  |              BigDecimal multiply = smallBigDecimal.divide(new BigDecimal("2.0"), 4, RoundingMode.DOWN);
 | 
	
		
			
				|  |  |              if (compare(highQuota, multiply)) {
 | 
	
		
			
				|  |  | -                Integer currentQuota = integralDO.getCurrentQuota();
 | 
	
		
			
				|  |  | +                Long currentQuota = integralDO.getCurrentQuota();
 | 
	
		
			
				|  |  |                  integralDO.setCurrentQuota(currentQuota + multiply.intValue());
 | 
	
		
			
				|  |  |                  // 碰撞后的额度添加到日志中 增加日志模块
 | 
	
		
			
				|  |  |                  integralService.updateIntegral(BeanUtils.toBean(integralDO, IntegralSaveReqVO.class));
 | 
	
		
			
				|  |  |                  ptProfitLogService.addMessage(k.getUserId(), CaclEnum.SMALL_QUOTA_CRASH, currentQuota, integralDO.getCurrentQuota(), JsonUtils.toJsonString(orderPercentageDO));
 | 
	
		
			
				|  |  |              }
 | 
	
		
			
				|  |  |              if (compare(parentHighQuota, multiply)) {
 | 
	
		
			
				|  |  | -                Integer currentQuota = parentIntegralDo.getCurrentQuota();
 | 
	
		
			
				|  |  | +                Long currentQuota = parentIntegralDo.getCurrentQuota();
 | 
	
		
			
				|  |  |                  parentIntegralDo.setCurrentQuota(currentQuota + multiply.intValue());
 | 
	
		
			
				|  |  |                  // 碰撞后的额度添加到日志中 增加日志模块
 | 
	
		
			
				|  |  |                  integralService.updateIntegral(BeanUtils.toBean(parentIntegralDo, IntegralSaveReqVO.class));
 | 
	
	
		
			
				|  | @@ -279,13 +279,13 @@ public class PartitionCrashServiceImpl implements PartitionCrashService {
 | 
	
		
			
				|  |  |              }
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  |              // 获取计算后积分, Long为userId, Integer为碰撞后额度
 | 
	
		
			
				|  |  | -            HashMap<Long, Integer> map = new HashMap<>();
 | 
	
		
			
				|  |  | +            HashMap<Long, Long> map = new HashMap<>();
 | 
	
		
			
				|  |  |              // 如果为当前用户为平台,则不需要存入这个地方
 | 
	
		
			
				|  |  |              if (!k.getUserId().equals(PT_ID)){
 | 
	
		
			
				|  |  | -                map.put(k.getUserId(), multiply.intValue());
 | 
	
		
			
				|  |  | +                map.put(k.getUserId(), multiply.longValue());
 | 
	
		
			
				|  |  |              }
 | 
	
		
			
				|  |  |              if (!parentIntegralDo.getUserId().equals(PT_ID)){
 | 
	
		
			
				|  |  | -                map.put(parentIntegralDo.getUserId(), multiply.intValue());
 | 
	
		
			
				|  |  | +                map.put(parentIntegralDo.getUserId(), multiply.longValue());
 | 
	
		
			
				|  |  |              }
 | 
	
		
			
				|  |  |              afterCrashMap.add(map);
 | 
	
		
			
				|  |  |  
 | 
	
	
		
			
				|  | @@ -309,8 +309,8 @@ public class PartitionCrashServiceImpl implements PartitionCrashService {
 | 
	
		
			
				|  |  |          // 获取当前平台的额度
 | 
	
		
			
				|  |  |          PtProfitDO ptProfit = ptProfitService.getPtProfit();
 | 
	
		
			
				|  |  |          // 遍历hashMap
 | 
	
		
			
				|  |  | -        for (HashMap<Long, Integer> longIntegerHashMap : afterCrashMap) {
 | 
	
		
			
				|  |  | -            for (Map.Entry<Long, Integer> entry : longIntegerHashMap.entrySet()) {
 | 
	
		
			
				|  |  | +        for (HashMap<Long, Long> longIntegerHashMap : afterCrashMap) {
 | 
	
		
			
				|  |  | +            for (Map.Entry<Long, Long> entry : longIntegerHashMap.entrySet()) {
 | 
	
		
			
				|  |  |                  if (ptProfit.getPtGrossAdd() <= 0) {
 | 
	
		
			
				|  |  |                      break;
 | 
	
		
			
				|  |  |                  }
 | 
	
	
		
			
				|  | @@ -334,7 +334,7 @@ public class PartitionCrashServiceImpl implements PartitionCrashService {
 | 
	
		
			
				|  |  |                  .ptTotalAdd(ptProfit.getPtTotalAdd()).build());
 | 
	
		
			
				|  |  |      }
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  | -    public Boolean compare(Integer highQuota, BigDecimal afterCrash) {
 | 
	
		
			
				|  |  | +    public Boolean compare(Long highQuota, BigDecimal afterCrash) {
 | 
	
		
			
				|  |  |          BigDecimal high = new BigDecimal(String.valueOf(highQuota));
 | 
	
		
			
				|  |  |          int i = high.compareTo(afterCrash);
 | 
	
		
			
				|  |  |          return i >= 0;
 | 
	
	
		
			
				|  | @@ -351,8 +351,8 @@ public class PartitionCrashServiceImpl implements PartitionCrashService {
 | 
	
		
			
				|  |  |          return brotherBuilder.name(duserDO.getName())
 | 
	
		
			
				|  |  |                  .nickName(duserDO.getNickName())
 | 
	
		
			
				|  |  |                  .size(0)
 | 
	
		
			
				|  |  | -                .price(0)
 | 
	
		
			
				|  |  | -                .afterHitQuota(0)
 | 
	
		
			
				|  |  | +                .price(0L)
 | 
	
		
			
				|  |  | +                .afterHitQuota(0L)
 | 
	
		
			
				|  |  |                  .hasHit(0);
 | 
	
		
			
				|  |  |      }
 | 
	
		
			
				|  |  |  
 | 
	
	
		
			
				|  | @@ -362,8 +362,8 @@ public class PartitionCrashServiceImpl implements PartitionCrashService {
 | 
	
		
			
				|  |  |          return sonBuilder.name(duserDO.getName())
 | 
	
		
			
				|  |  |                  .nickName(duserDO.getNickName())
 | 
	
		
			
				|  |  |                  .size(0)
 | 
	
		
			
				|  |  | -                .price(0)
 | 
	
		
			
				|  |  | -                .afterHitQuota(0)
 | 
	
		
			
				|  |  | +                .price(0L)
 | 
	
		
			
				|  |  | +                .afterHitQuota(0L)
 | 
	
		
			
				|  |  |                  .hasHit(0);
 | 
	
		
			
				|  |  |      }
 | 
	
		
			
				|  |  |  
 |