修改分佣逻辑

Pu Zhibing

2025-02-25 49e96cc15baf35d710fe3a049fb97aff6a1af132

 ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/ShoppingCartServiceImpl.java

@@ -41,6 +41,9 @@
import java.time.LocalDateTime;
import java.time.ZoneOffset;
import java.util.*;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;

@Slf4j
@@ -1431,8 +1434,16 @@
         orderBalancePayment.setDistributionAmount(distributionAmount);
         orderBalancePaymentService.save(orderBalancePayment);
      }

      commissionService.calculationCommissionCopy(order);
		
      //异步线程执行分佣临时数据构建
      ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<Runnable>(1), new ThreadPoolExecutor.DiscardPolicy());
      threadPoolExecutor.execute(new Runnable() {
         @Override
         public void run() {
            commissionService.calculationCommissionUser();
            commissionService.calculationCommissionShop();
         }
      });
      return R.ok(order.getId().toString());
   }

@@ -1536,6 +1547,16 @@
      for (Integer goodsId : goodsIds) {
         goodsClient.editGoodsNum(goodsId, 1);
      }
		
      //异步线程执行分佣临时数据构建
      ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<Runnable>(1), new ThreadPoolExecutor.DiscardPolicy());
      threadPoolExecutor.execute(new Runnable() {
         @Override
         public void run() {
            commissionService.calculationCommissionUser();
            commissionService.calculationCommissionShop();
         }
      });
      return R.ok();
   }