RedPocket类

  1. import java.math.BigDecimal;
  2. import java.math.RoundingMode;
  4. public class RedPacket {
  5.     final BigDecimal MIN = new BigDecimal("0.01");
  6.     final BigDecimal MAX = new BigDecimal("200");
  7.     private BigDecimal amount;
  8.     private int count;
  10.     public RedPacket(BigDecimal amount, int count) {
  11.         this.amount = amount;
  12.         this.count = count;
  13.     }
  15.     public synchronized BigDecimal getRandomMoney() {
  16.         if (count == 1) {
  17.             BigDecimal temp = amount;
  18.             //将总金额全给第十位玩家，然后把总金额置为零
  19.             amount = BigDecimal.ZERO;
  20.             return temp;
  21.         } else {
  22.             //经过本线程抢红包后最多允许剩下的钱数
  23.             BigDecimal maxRemind = new BigDecimal(count - 1).multiply(MAX);
  24.             //经过本线程抢红包后最少允许剩下的钱数
  25.             BigDecimal minRemind = new BigDecimal(count - 1).multiply(MIN);
  27.             //本线程抢红包金额的最小值
  28.             BigDecimal minAmount = MIN.max(amount.subtract(maxRemind));
  29.             BigDecimal maxAmount = MAX.min(amount.subtract(minRemind));
  30.             BigDecimal curAmount = maxAmount.subtract(minAmount)
  31.                     .multiply(BigDecimal.valueOf(Math.random()))
  32.                     .add(minAmount)
  33.                     .setScale(2, RoundingMode.HALF_UP);
  35.             amount = amount.subtract(curAmount);
  36.             count--;
  38.             return curAmount;
  39.         }
  40.     }
  41. }

UserTherd类

  1. import java.math.BigDecimal;
  2. import java.util.HashMap;
  3. import java.util.Map;
  5. public class UserThread implements Runnable {
  6.     private final RedPacket rePacket;
  8.     public UserThread(RedPacket rePacket) {
  9.         this.rePacket = rePacket;
  10.     }
  12.     Map<String, BigDecimal> map = new HashMap<>();
  14.     @Override
  15.     public void run() {
  16.         BigDecimal money = rePacket.getRandomMoney();
  18.         if (money.equals(BigDecimal.ZERO)) {
  19.             System.out.println(Thread.currentThread().getName() + "不好意思，您手慢了！");
  20.         } else {
  21.             System.out.println(Thread.currentThread().getName() + "抢到了" + money + "元");
  23.             map.put(Thread.currentThread().getName(), money);
  24.         }
  25.     }
  27.     public Map<String, BigDecimal> getMap() {
  28.         return map;
  29.     }
  30. }

sale类

  1. public class Sale {
  2.     private String saleVolume;
  3.     private String saleMoney;
  5.     public Sale(String saleVolume, String saleMoney) {
  6.         this.saleVolume = saleVolume;
  7.         this.saleMoney = saleMoney;
  8.     }
  10.     public String getSaleVolume() {
  11.         return saleVolume;
  12.     }
  14.     public void setSaleVolume(String saleVolume) {
  15.         this.saleVolume = saleVolume;
  16.     }
  18.     public String getSaleMoney() {
  19.         return saleMoney;
  20.     }
  22.     public void setSaleMoney(String saleMoney) {
  23.         this.saleMoney = saleMoney;
  24.     }
  25. }

主函数

  1. import java.io.IOException;
  2. import java.math.BigDecimal;
  3. import java.nio.file.Files;
  4. import java.nio.file.Paths;
  5. import java.util.HashMap;
  6. import java.util.List;
  7. import java.util.Map;
  8. import java.util.stream.Collectors;
  9. import java.util.stream.Stream;
  11. public class Demo {
  12.     public static void redEnvelope(BigDecimal amount) {
  13.         final BigDecimal MIN = new BigDecimal("0.01");
  14.         final BigDecimal MAX = new BigDecimal("200");
  16.         if (amount == null
  17.                 || amount.compareTo(MIN.multiply(new BigDecimal("10"))) < 0
  18.                 || amount.compareTo(MAX.multiply(new BigDecimal("10"))) > 0) {
  19.             throw new IllegalArgumentException("每人最多抢200元，最少抢0.01元");
  20.         }
  22.         RedPacket rePacket = new RedPacket(amount, 10);
  23.         UserThread userThread = new UserThread(rePacket);
  25.         Thread t1 = new Thread(userThread);
  26.         Thread t2 = new Thread(userThread);
  27.         Thread t3 = new Thread(userThread);
  28.         Thread t4 = new Thread(userThread);
  29.         Thread t5 = new Thread(userThread);
  30.         Thread t6 = new Thread(userThread);
  31.         Thread t7 = new Thread(userThread);
  32.         Thread t8 = new Thread(userThread);
  33.         Thread t9 = new Thread(userThread);
  34.         Thread t10 = new Thread(userThread);
  35.         Thread t11 = new Thread(userThread);
  36.         Thread t12 = new Thread(userThread);
  38.         t1.start();
  39.         t2.start();
  40.         t3.start();
  41.         t4.start();
  42.         t5.start();
  43.         t6.start();
  44.         t7.start();
  45.         t8.start();
  46.         t9.start();
  47.         t10.start();
  48.         t11.start();
  49.         t12.start();
  51.         try {
  52.             t1.join();
  53.             t2.join();
  54.             t3.join();
  55.             t4.join();
  56.             t5.join();
  57.             t6.join();
  58.             t7.join();
  59.             t8.join();
  60.             t9.join();
  61.             t10.join();
  62.             t11.join();
  63.             t12.join();
  64.         } catch (InterruptedException e) {
  65.             e.printStackTrace();
  66.         }
  68.         //找出最大值赋值给maxMoney
  69.         BigDecimal maxMoney = BigDecimal.ZERO;
  70.         Map<String, BigDecimal> map = userThread.getMap();
  71.         for (Map.Entry<String, BigDecimal> entry : map.entrySet()) {
  72.             if (maxMoney.compareTo(entry.getValue()) < 0) {
  73.                 maxMoney = entry.getValue();
  74.             }
  75.         }
  77.         //找到最大值对应key,输出最大值
  78.         for (Map.Entry<String, BigDecimal> entry : map.entrySet()) {
  79.             if (entry.getValue().equals(maxMoney)) {
  80.                 System.out.println(entry.getKey() + "手气最佳，抢了" + maxMoney + "元");
  81.             }
  82.         }
  83.     }
  85.     public static void statistic(String path) throws IOException {
  86.         Map<String, Double> moneyMap = new HashMap<>();
  87.         double num1, num2, num3;
  89.         /*
  90.         统计第一季度销售额最高的产品占比
  91.          */
  92.         try (Stream<String> lines = Files.lines(Paths.get(path))) {
  93.             num1 = lines.filter(x -> x.startsWith("2020年01月|SKU03|") ||
  94.                     x.startsWith("2020年02月|SKU03|") || x.startsWith("2020年03月|SKU03|"))
  95.                     .map(x -> x.substring(x.indexOf("￥") + 1).replaceAll(",", ""))
  96.                     .mapToDouble(Double::valueOf)
  97.                     .sum();
  99.             num1 = num1 / 10000.0;
  100.             moneyMap.put("小米手机", num1);
  101.         }
  103.         try (Stream<String> lines = Files.lines(Paths.get(path))) {
  104.             num2 = lines.filter(x -> x.startsWith("2020年01月|SKU02|") ||
  105.                     x.startsWith("2020年02月|SKU02|") || x.startsWith("2020年03月|SKU02|"))
  106.                     .map(x -> x.substring(x.indexOf("￥") + 1).replaceAll(",", ""))
  107.                     .mapToDouble(Double::valueOf)
  108.                     .sum();
  110.             num2 = num2 / 10000.0;
  111.             moneyMap.put("苹果电脑", num2);
  112.         }
  114.         try (Stream<String> lines = Files.lines(Paths.get(path))) {
  115.             num3 = lines.filter(x -> x.startsWith("2020年01月|SKU01|") ||
  116.                     x.startsWith("2020年02月|SKU01|") || x.startsWith("2020年03月|SKU01|"))
  117.                     .map(x -> x.substring(x.indexOf("￥") + 1).replaceAll(",", ""))
  118.                     .mapToDouble(Double::valueOf)
  119.                     .sum();
  121.             num3 = num3 / 10000.0;
  122.             moneyMap.put("樱桃键盘", num3);
  123.         }
  125.         double maxNum = 0;
  126.         for (Map.Entry<String, Double> entry : moneyMap.entrySet()) {
  127.             if (maxNum < entry.getValue()) {
  128.                 maxNum = entry.getValue();
  129.             }
  130.         }
  132.         for (Map.Entry<String, Double> entry : moneyMap.entrySet()) {
  133.             if (maxNum == entry.getValue()) {
  134.                 System.out.print("第一季度销量最多的是" + entry.getKey() + "：" + entry.getValue() + "万元。");
  135.             }
  136.         }
  138.         double result = (maxNum / (num1 + num2 + num3)) * 100.0;
  139.         System.out.println("占比" + result + "%");
  141.         /*
  142.         第二季度苹果电脑的销售额环比第一季度销售额的增幅（%）
  143.         */
  144.         double dummy = 0;
  145.         try (Stream<String> lines = Files.lines(Paths.get(path))) {
  146.             dummy = lines.filter(x -> x.startsWith("2020年04月|SKU02|") ||
  147.                     x.startsWith("2020年05月|SKU02|") || x.startsWith("2020年06月|SKU02|"))
  148.                     .map(x -> x.substring(x.indexOf("￥") + 1).replaceAll(",", ""))
  149.                     .mapToDouble(Double::valueOf)
  150.                     .sum();
  152.             dummy = dummy / 10000.0;
  154.             double growthMoney = ((dummy - num2) / num2) * 100;
  155.             System.out.println("第二季度苹果电脑的销售额环比第一季度销售额的增幅: " + growthMoney + "%");
  156.         }
  157.     }
  159.     public static void main(String[] args) throws IOException {
  160.         redEnvelope(new BigDecimal("600"));
  161.         statistic("D:\\WorkSpace\\IDEA\\Test\\src\\月度销量统计.txt");
  162.     }
  163. }