diff --git a/app/common/logic/CommissionProductLogic.php b/app/common/logic/CommissionProductLogic.php
index 42772ac12..98dfd9c80 100644
--- a/app/common/logic/CommissionProductLogic.php
+++ b/app/common/logic/CommissionProductLogic.php
@@ -23,7 +23,11 @@ class CommissionProductLogic extends BaseLogic
      */
     function calculate_product_flow($find, $order, $village_uid = 0, $brigade_uid = 0, $user_ship = 0, $spread_user_ship = 0)
     {
-        $product = StoreProduct::where('id', $find['product_id'])->find();
+        if(isset($order['source']) && $order['source'] == 2){
+            $product = StoreBranchProduct::where('product_id', $find['product_id'])->where('store_id', $order['store_id'])->find();
+        }else{
+            $product = StoreProduct::where('id', $find['product_id'])->find();
+        }
         if ($product) {
             //活动商品
             if ($product['product_type'] == 4) {