From d6dd96af8ced239574f98b3e6e1caf1491642814 Mon Sep 17 00:00:00 2001
From: mkm <727897186@qq.com>
Date: Wed, 18 Sep 2024 18:06:35 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E4=BF=AE=E6=94=B9=E5=95=86=E5=93=81?=
 =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=92=8C=E7=BC=96=E8=BE=91=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../logic/store_product/StoreProductLogic.php |  85 ++--
 .../logic/CommissionProductLogic copy.php     | 375 ++++++++++++++++++
 app/common/logic/CommissionnLogic.php         |  50 ---
 3 files changed, 421 insertions(+), 89 deletions(-)
 create mode 100644 app/common/logic/CommissionProductLogic copy.php

diff --git a/app/admin/logic/store_product/StoreProductLogic.php b/app/admin/logic/store_product/StoreProductLogic.php
index fd1bc707..fddb50f2 100644
--- a/app/admin/logic/store_product/StoreProductLogic.php
+++ b/app/admin/logic/store_product/StoreProductLogic.php
@@ -36,15 +36,15 @@ class StoreProductLogic extends BaseLogic
      */
     public static function add(array $params): bool
     {
-        $count=count($params['cate_arr']);
-        $top_cate_id=0;
-        $two_cate_id=0;
-        if($count==3){
-            $top_cate_id=$params['cate_arr'][0];
-            $two_cate_id=$params['cate_arr'][1];
-        }elseif($count==2){
-            $top_cate_id=$params['cate_arr'][0];
-            $two_cate_id=$params['cate_arr'][0];
+        $count = count($params['cate_arr']);
+        $top_cate_id = 0;
+        $two_cate_id = 0;
+        if ($count == 3) {
+            $top_cate_id = $params['cate_arr'][0];
+            $two_cate_id = $params['cate_arr'][1];
+        } elseif ($count == 2) {
+            $top_cate_id = $params['cate_arr'][0];
+            $two_cate_id = $params['cate_arr'][0];
         }
         Db::startTrans();
         try {
@@ -62,7 +62,6 @@ class StoreProductLogic extends BaseLogic
                 'vip_price' => $params['vip_price'],
                 'cost' => $params['cost'],
                 'purchase' => $params['purchase'],
-                'rose' => $params['rose'],
                 'is_return' => $params['is_return'],
                 'manufacturer_information' => $params['manufacturer_information'] ?? '',
                 'swap' => $params['swap'] ?? 0,
@@ -71,12 +70,15 @@ class StoreProductLogic extends BaseLogic
                 'product_type' => $params['product_type'] ?? 0,
                 'is_show' => $params['is_show'] ?? 0,
             ];
-            // if ($params['rose'] > 0) {
-            //     $rose_price = bcmul($params['cost'], $params['rose'], 2);
-            //     $data['price'] = bcadd($params['cost'], $rose_price, 2);
-            // } else {
-            //     $data['price'] = 0;
-            // }
+            $rose = 0;
+            //零售-供货
+            $rose_price = bcsub($params['price'], $params['purchase'], 2);
+            if ($rose_price > 0) {
+                //利润除于零售
+                $price_div = bcdiv($rose_price, $params['price'], 2);
+                $rose=bcmul($price_div, 100, 2);
+            }
+            $data['rose']=$rose;
             $res = StoreProduct::create($data);
             StoreProductAttrValue::create([
                 "bar_code" => $params["bar_code"] ?? '',
@@ -91,7 +93,7 @@ class StoreProductLogic extends BaseLogic
                 'sales' => 0,
             ]);
             Db::commit();
-            if($data['product_type']==5){
+            if ($data['product_type'] == 5) {
                 return true;
             }
             if ($params['is_store_all'] == 1) {
@@ -117,7 +119,7 @@ class StoreProductLogic extends BaseLogic
             return true;
         } catch (\Exception $e) {
             Db::rollback();
-            throw new BusinessException('添加商品失败'.$e->getMessage());
+            throw new BusinessException('添加商品失败' . $e->getMessage());
         }
     }
 
@@ -186,15 +188,15 @@ class StoreProductLogic extends BaseLogic
     {
         Db::startTrans();
         try {
-            $count=count($params['cate_arr']);
-            $top_cate_id=0;
-            $two_cate_id=0;
-            if($count==3){
-                $top_cate_id=$params['cate_arr'][0];
-                $two_cate_id=$params['cate_arr'][1];
-            }elseif($count==2){
-                $top_cate_id=$params['cate_arr'][0];
-                $two_cate_id=$params['cate_arr'][0];
+            $count = count($params['cate_arr']);
+            $top_cate_id = 0;
+            $two_cate_id = 0;
+            if ($count == 3) {
+                $top_cate_id = $params['cate_arr'][0];
+                $two_cate_id = $params['cate_arr'][1];
+            } elseif ($count == 2) {
+                $top_cate_id = $params['cate_arr'][0];
+                $two_cate_id = $params['cate_arr'][0];
             }
             $data = [
                 'store_name' => $params['store_name'],
@@ -208,7 +210,6 @@ class StoreProductLogic extends BaseLogic
                 'stock' => $params['stock'],
                 'cost' => $params['cost'],
                 'purchase' => $params['purchase'],
-                'rose' => $params['rose'],
                 'is_return' => $params['is_return'],
                 'price' => $params['price'],
                 'vip_price' => $params['vip_price'],
@@ -218,12 +219,20 @@ class StoreProductLogic extends BaseLogic
                 'swap' => $params['swap'] ?? 0,
                 'is_show' => $params['is_show'] ?? 0,
             ];
-
-            StoreProduct::update($data,['id'=>$params['id']]);
+            $rose = 0;
+            //零售-供货
+            $rose_price = bcsub($params['price'], $params['purchase'], 2);
+            if ($rose_price > 0) {
+                //利润除于零售
+                $price_div = bcdiv($rose_price, $params['price'], 2);
+                $rose=bcmul($price_div, 100, 2);
+            }
+            $data['rose']=$rose;
+            StoreProduct::update($data, ['id' => $params['id']]);
 
             // $dealCate = self::dealChangeCate($params['cate_id']);
             //修改
-            StoreBranchProduct::where('product_id', $params['id'])->whereNotIn('store_id',[17,18])->update([
+            StoreBranchProduct::where('product_id', $params['id'])->whereNotIn('store_id', [17, 18])->update([
                 'price' => $params['price'],
                 'vip_price' => $params['vip_price'],
                 'cost' => $params['cost'],
@@ -238,7 +247,7 @@ class StoreProductLogic extends BaseLogic
                 'cate_id' => $params['cate_id'],
                 'bar_code' => $params['bar_code'],
                 'purchase' => $params['purchase'],
-                'rose' => $params['rose'] ?? 0,
+                'rose' => $rose,
                 'status' => $params['is_show'] ?? 0,
                 'image' => $params['image'],
                 'store_batch' => $params['store_batch'] ?? 1,
@@ -249,8 +258,7 @@ class StoreProductLogic extends BaseLogic
             return true;
         } catch (\Throwable $e) {
             Db::rollback();
-            throw new BusinessException('编辑商品失败'.$e->getMessage());
-
+            throw new BusinessException('编辑商品失败' . $e->getMessage());
         }
     }
 
@@ -309,8 +317,7 @@ class StoreProductLogic extends BaseLogic
             return true;
         } catch (\Exception $e) {
             Db::rollback();
-            throw new BusinessException('删除失败'.$e->getMessage());
-            
+            throw new BusinessException('删除失败' . $e->getMessage());
         }
     }
 
@@ -318,8 +325,8 @@ class StoreProductLogic extends BaseLogic
     /**普通 */
     public static function ordinary($product_arr, $store_id, $admin_id, $find)
     {
-        $res=StoreBranchProduct::where('store_id',$store_id)->where('product_id',$find['id'])->find();
-        if($res){
+        $res = StoreBranchProduct::where('store_id', $store_id)->where('product_id', $find['id'])->find();
+        if ($res) {
             return $res;
         }
         $dealCate = self::dealChangeCate($find['cate_id']);
@@ -390,7 +397,7 @@ class StoreProductLogic extends BaseLogic
                 return true;
             } catch (\Exception $e) {
                 Db::rollback();
-                throw new BusinessException('添加兑换商品失败'.$e->getMessage());
+                throw new BusinessException('添加兑换商品失败' . $e->getMessage());
             }
         }
         // else {
diff --git a/app/common/logic/CommissionProductLogic copy.php b/app/common/logic/CommissionProductLogic copy.php
new file mode 100644
index 00000000..68212629
--- /dev/null
+++ b/app/common/logic/CommissionProductLogic copy.php	
@@ -0,0 +1,375 @@
+<?php
+
+namespace app\common\logic;
+
+use app\common\model\distribution\Distribution;
+use app\common\model\store_branch_product\StoreBranchProduct;
+use app\common\model\store_finance_flow_product\StoreFinanceFlowProduct;
+use app\common\model\store_order_cart_info\StoreOrderCartInfo;
+use app\common\model\store_product\StoreProduct;
+use app\common\model\user\User;
+use PDO;
+use support\Log;
+
+/**
+ * 产品佣金计算
+ * 
+ */
+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 ($product) {
+            //活动商品
+            if ($product['product_type'] == 4) {
+                $this->c($find, $order, $village_uid, $brigade_uid, $user_ship, $product);
+                return true;
+            } else {
+                //种养殖用户判断
+                if ($user_ship == 5) {
+                    $top_cate_id = $product['top_cate_id'];
+                    if ($top_cate_id == 15189) {
+                        $this->b($find, $order, $product, $user_ship);
+                        return true;
+                    }
+                } elseif ($user_ship == 0) {
+                    //普通用户判断
+                    $this->b($find, $order, $product, $user_ship);
+                    return true;
+                } else {
+                    //会员用户入口
+                    $this->a($find, $order, $village_uid, $brigade_uid, $user_ship, $product);
+                }
+            }
+
+            return true;
+        }
+    }
+
+    /**
+     * 零售价结算
+     */
+    public function a($find, $order, $village_uid, $brigade_uid, $user_ship, $product)
+    {
+        $total_price = bcmul($product['price'], $find['cart_num'], 2);
+        $purchase_price = bcmul($product['purchase'], $find['cart_num'], 2);
+        $price = $product['purchase'];
+
+        $platform_number = 0; //平台
+        $attrition_number = 0; //损耗
+        $store_number = 0; //门店
+        $number1 = 0; //其他
+
+
+        if ($product['rose'] >= 6) {
+            $platform_number = bcmul($total_price, 0.02, 2); //平台
+        }
+        if ($product['rose'] >= 12) {
+            $attrition_number = bcmul($total_price, 0.01, 2); //损耗
+        }
+        //零售-供货价
+        $number3 = bcsub($total_price, $purchase_price, 2);
+        //会员
+        $uid = 0;
+        if ($order['spread_uid'] > 0) {
+            $uid = $order['spread_uid'];
+        }
+        if ($order['uid'] > 0) {
+            $uid = $order['uid'];
+        }
+        $user = User::where('id', $uid)->find();
+
+        if ($user) {
+            if ($user['user_ship'] == 2) {
+                $village_number = bcmul($total_price, 0.04, 2); //村长利润
+                $data[] = [
+                    'nickname' => '零售村长',
+                    'store_id' => $order['store_id'],
+                    'product_id' => $find['product_id'],
+                    'other_uid' => 0,
+                    'price' => $price,
+                    'total_price' =>  $total_price,
+                    'cart_num' =>  0,
+                    'rate' =>  0.04,
+                    'number' => $village_number,
+                    'oid' => $order['id'],
+                    'type' => 3,
+                    'status' => 1,
+                    'is_activity' => 0,
+                ];
+                $number1 = bcadd($number1, $village_number, 2);
+            } elseif ($user['user_ship'] == 3) {
+                $brigade_number = bcmul($total_price, 0.04, 2); //队长利润
+                $data[] = [
+                    'nickname' => '零售队长',
+                    'store_id' => $order['store_id'],
+                    'product_id' => $find['product_id'],
+                    'other_uid' => 0,
+                    'price' => $price,
+                    'total_price' =>  $total_price,
+                    'cart_num' =>  0,
+                    'rate' =>  0.04,
+                    'number' => $brigade_number,
+                    'oid' => $order['id'],
+                    'type' => 4,
+                    'status' => 1,
+                    'is_activity' => 0,
+                ];
+                $number1 = bcadd($number1, $brigade_number, 2);
+            } elseif ($user['user_ship'] == 1) {
+                $vip_number = bcmul($total_price, 0.06, 2); //会员利润
+                $data[] = [
+                    'nickname' => '零售会员',
+                    'store_id' => $order['store_id'],
+                    'product_id' => $find['product_id'],
+                    'other_uid' => $uid,
+                    'price' => $price,
+                    'total_price' =>  $purchase_price,
+                    'cart_num' =>  $find['cart_num'],
+                    'rate' =>  0.06,
+                    'number' =>  $vip_number,
+                    'oid' => $order['id'],
+                    'type' => 0,
+                    'status' => 1,
+                ];
+                $number1 = bcadd($number1, $vip_number, 2);
+            }
+        }
+        //门店利润
+        if ($number3 <= 0) {
+            $store_number = 0;
+        } else {
+            $number2=bcadd($platform_number, $attrition_number, 2);
+            $store_number = bcsub($number3, bcadd($number1,$number2), 2);
+        }
+        //门店
+        $data[] = [
+            'nickname' => '零售门店',
+            'store_id' => $order['store_id'],
+            'product_id' => $find['product_id'],
+            'other_uid' => 0,
+            'price' => $price,
+            'total_price' =>  $total_price,
+            'cart_num' =>  $find['cart_num'],
+            'rate' =>  0,
+            'number' =>  $store_number,
+            'oid' => $order['id'],
+            'type' => 1,
+            'status' => 1,
+            'is_activity' => 1,
+        ];
+        //平台
+        if ($product['rose'] >= 6) {
+            $data[] = [
+                'nickname' => '零售平台',
+                'store_id' => $order['store_id'],
+                'product_id' => $find['product_id'],
+                'other_uid' => 0,
+                'price' => $price,
+                'total_price' =>  $purchase_price,
+                'cart_num' =>  $find['cart_num'],
+                'rate' =>  0.02,
+                'number' => $platform_number,
+                'oid' => $order['id'],
+                'type' => 2,
+                'status' => 1,
+                'is_activity' => 1,
+            ];
+        }
+        if ($product['rose'] >= 12) {
+            $data[] = [
+                'nickname' => '零售消耗',
+                'store_id' => $order['store_id'],
+                'product_id' => $find['product_id'],
+                'other_uid' => 0,
+                'price' => $price,
+                'total_price' =>  $purchase_price,
+                'cart_num' =>  $find['cart_num'],
+                'rate' =>  0.01,
+                'number' =>  $attrition_number,
+                'oid' => $order['id'],
+                'type' => 6,
+                'status' => 1,
+            ];
+        }
+
+        (new StoreFinanceFlowProduct())->saveAll($data);
+    }
+
+    /**
+     * 商户价结算
+     */
+    public function b($find, $order, $product, $user_ship)
+    {
+        $total_price = bcmul($product['price'], $find['cart_num'], 2);
+        $purchase_price = bcmul($product['purchase'], $find['cart_num'], 2);
+        $price = $product['purchase'];
+
+        $platform_number = 0;
+        $attrition_number = 0;
+        if ($product['rose'] >= 6) {
+            $platform_number = bcmul($total_price, 0.02, 2); //平台
+        }
+        if ($product['rose'] >= 10) {
+            $attrition_number = bcmul($total_price, 0.02, 2); //损耗
+        }
+
+        //零售-供货价
+        $number3 = bcsub($total_price, $purchase_price, 2);
+
+
+        //门店利润
+        if ($number3 <= 0) {
+            $store_number = 0;
+        } else {
+            $store_number = bcsub($number3, bcadd($platform_number, $attrition_number, 2), 2);
+        }
+        //门店
+        $data[] = [
+            'nickname' => '商户价门店',
+            'store_id' => $order['store_id'],
+            'product_id' => $find['product_id'],
+            'other_uid' => 0,
+            'price' => $price,
+            'total_price' =>  $total_price,
+            'cart_num' =>  $find['cart_num'],
+            'rate' =>  0,
+            'number' =>  $store_number,
+            'oid' => $order['id'],
+            'type' => 1,
+            'status' => 1,
+            'is_activity' => 1,
+        ];
+        //平台
+        if ($product['rose'] >= 6) {
+            $data[] = [
+                'nickname' => '商户价平台',
+                'store_id' => $order['store_id'],
+                'product_id' => $find['product_id'],
+                'other_uid' => 0,
+                'price' => $price,
+                'total_price' =>  $purchase_price,
+                'cart_num' =>  $find['cart_num'],
+                'rate' =>  0.02,
+                'number' => $platform_number,
+                'oid' => $order['id'],
+                'type' => 2,
+                'status' => 1,
+                'is_activity' => 1,
+            ];
+        }
+        if ($product['rose'] >= 10) {
+            $data[] = [
+                'nickname' => '商户价消耗',
+                'store_id' => $order['store_id'],
+                'product_id' => $find['product_id'],
+                'other_uid' => 0,
+                'price' => $price,
+                'total_price' =>  $purchase_price,
+                'cart_num' =>  $find['cart_num'],
+                'rate' =>  0.02,
+                'number' =>  $attrition_number,
+                'oid' => $order['id'],
+                'type' => 6,
+                'status' => 1,
+            ];
+        }
+        (new StoreFinanceFlowProduct())->saveAll($data);
+    }
+
+    //活动商品结算
+    public function c($find, $order, $village_uid, $brigade_uid, $user_ship, $product)
+    {
+        // $rose = bcdiv($product['rose'], 100, 2);
+        $total_price = bcmul($product['price'], $find['cart_num'], 2);
+        $purchase_price = bcmul($product['purchase'], $find['cart_num'], 2);
+        $price = $product['price'];
+        $brigade_number = bcmul($total_price, 0.02, 2); //队长
+        $village_number = bcmul($brigade_number, 0.1, 2); //村长
+        $platform_number = bcmul($total_price, 0.02, 2); //平台
+
+        $number1 = bcadd($brigade_number, $village_number, 2);
+        $number2 = bcadd($number1, $platform_number, 2);
+
+        //零售-供货价
+        $number3 = bcsub($total_price, $purchase_price, 2);
+
+        //门店利润
+        if ($number3 <= 0) {
+            $store_number = 0;
+        } else {
+            $store_number = bcsub($number3, $number2, 2);
+        }
+
+        //队长
+        $data[] = [
+            'nickname' => '活动队长',
+            'store_id' => $order['store_id'],
+            'product_id' => $find['product_id'],
+            'other_uid' => $brigade_uid,
+            'price' => $price,
+            'total_price' =>  $total_price,
+            'cart_num' =>  $find['cart_num'],
+            'rate' =>  0.02,
+            'number' => $brigade_number,
+            'oid' => $order['id'],
+            'type' => 4,
+            'status' => 1,
+            'is_activity' => 1,
+        ];
+        //村长
+        $data[] = [
+            'nickname' => '活动村长',
+            'store_id' => $order['store_id'],
+            'product_id' => $find['product_id'],
+            'other_uid' => $village_uid,
+            'price' => $price,
+            'total_price' =>  $brigade_number,
+            'cart_num' =>  0,
+            'rate' =>  0.01,
+            'number' => $village_number,
+            'oid' => $order['id'],
+            'type' => 3,
+            'status' => 1,
+            'is_activity' => 1,
+        ];
+        //门店
+        $data[] = [
+            'nickname' => '活动门店',
+            'store_id' => $order['store_id'],
+            'product_id' => $find['product_id'],
+            'other_uid' => 0,
+            'price' => $price,
+            'total_price' =>  $store_number,
+            'cart_num' =>  $find['cart_num'],
+            'rate' =>  0,
+            'number' =>  $store_number,
+            'oid' => $order['id'],
+            'type' => 1,
+            'status' => 1,
+            'is_activity' => 1,
+        ];
+        //平台
+        $data[] = [
+            'nickname' => '活动平台',
+            'store_id' => $order['store_id'],
+            'product_id' => $find['product_id'],
+            'other_uid' => 0,
+            'price' => $price,
+            'total_price' =>  $platform_number,
+            'cart_num' =>  $find['cart_num'],
+            'rate' =>  0.02,
+            'number' => $platform_number,
+            'oid' => $order['id'],
+            'type' => 2,
+            'status' => 1,
+            'is_activity' => 1,
+        ];
+        (new StoreFinanceFlowProduct())->saveAll($data);
+    }
+}
diff --git a/app/common/logic/CommissionnLogic.php b/app/common/logic/CommissionnLogic.php
index d3da5fd7..44b9ae9b 100644
--- a/app/common/logic/CommissionnLogic.php
+++ b/app/common/logic/CommissionnLogic.php
@@ -10,56 +10,6 @@ use app\common\model\user\UserAddress;
 
 class CommissionnLogic extends BaseLogic
 {
-    /**
-     * 走村长分润
-     */
-    public static function setVillage($order, $village_uid = 0, $brigade_uid = 0, $transaction_id = 0)
-    {
-        self::user($order, 3, $transaction_id, $village_uid, 14); //村长
-        self::user($order, 0, $transaction_id, 0, 12); //会员、厨师
-        self::user($order, 5, $transaction_id, 0, 20); //个人店铺
-        self::user($order, 4, $transaction_id, $brigade_uid, 15); //队长
-
-        self::platform($order, 2, $transaction_id); //平台
-        self::store($order, 1, $transaction_id, 0); //门店
-        // $attrition = self::attrition($order, 0.02, $transaction_id, 16); //损耗
-        self::suppliter($order, $transaction_id);
-    }
-    /**
-     * 走队长分润
-     */
-    public static function setBrigade($order, $village_uid = 0, $brigade_uid = 0, $transaction_id = 0)
-    {
-        self::user($order, 4, $transaction_id, $brigade_uid, 15); //队长
-        self::user($order, 0, $transaction_id, 0, 12); ////会员、厨师
-        self::user($order, 5, $transaction_id, 0, 20); ////会员、厨师
-        self::user($order, 3, $transaction_id, $village_uid, 14); //村长
-
-        self::platform($order, 2, $transaction_id); //平台
-        self::store($order, 1, $transaction_id, 0); //门店
-        // $attrition = self::attrition($order, 0.02, $transaction_id, 16); //损耗
-        self::suppliter($order, $transaction_id);
-    }
-    /**
-     * 走厨师分润
-     */
-    public static function setCook($order, $village_uid = 0, $brigade_uid = 0, $transaction_id = 0)
-    {
-        if ($order['spread_uid'] <= 0) {
-            $uid = $order['uid'];
-        } else {
-            $uid = $order['spread_uid'];
-        }
-        self::user($order, 0, $transaction_id, $uid, 12); //会员、厨师
-        self::user($order, 5, $transaction_id, $uid, 20); //会员、厨师
-        self::user($order, 3, $transaction_id, $village_uid, 14); //村长
-        self::user($order, 4, $transaction_id, $brigade_uid, 15); //队长
-        self::platform($order, 2, $transaction_id); //平台
-        self::store($order, 1, $transaction_id, 0); //门店
-        // $attrition = self::attrition($order, 0.02, $transaction_id, 16); //损耗
-        // $moeny = bcadd(bcadd(bcadd(bcadd($user_1, $user_2, 2), $user_3, 2), $platform, 2), bcadd($store, 0, 2), 2);
-        self::suppliter($order, $transaction_id);
-    }
 
     /**
      * 零售分润