队列推送贡献值-未完成

app/common/model/store/order/StoreOrderContribute.php

@@ -0,0 +1,47 @@
+<?php
+
+// +----------------------------------------------------------------------
+// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
+// +----------------------------------------------------------------------
+// | Copyright (c) 2016~2022 https://www.crmeb.com All rights reserved.
+// +----------------------------------------------------------------------
+// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
+// +----------------------------------------------------------------------
+// | Author: CRMEB Team <admin@crmeb.com>
+// +----------------------------------------------------------------------
+
+
+namespace app\common\model\store\order;
+
+
+use app\common\model\BaseModel;
+
+/**
+ * Class StoreOrderStatus
+ * @package app\common\model\store\order
+ * @author xaboy
+ * @day 2020/6/12
+ */
+class StoreOrderContribute extends BaseModel
+{
+
+    /**
+     * @return string|null
+     * @author xaboy
+     * @day 2020/6/12
+     */
+    public static function tablePk(): ?string
+    {
+        return 'id';
+    }
+
+    /**
+     * @return string
+     * @author xaboy
+     * @day 2020/6/12
+     */
+    public static function tableName(): string
+    {
+        return 'store_order_contribute';
+    }
+}

app/common/repositories/store/order/StoreOrderCreateRepository.php

@@ -49,11 +49,11 @@ class StoreOrderCreateRepository extends StoreOrderRepository
         //检查购物车失效数据
         if (count($fail)) {
             if ($fail[0]['is_fail'])
-                throw new ValidateException('[已失效]' . mb_substr($fail[0]['product']['store_name'],0,10).'...');
+                throw new ValidateException('[已失效]' . mb_substr($fail[0]['product']['store_name'], 0, 10) . '...');
             if (in_array($fail[0]['product_type'], [1, 2, 3]) && !$fail[0]['userPayCount']) {
-                throw new ValidateException('[超出限购数]' . mb_substr($fail[0]['product']['store_name'],0,10).'...');
+                throw new ValidateException('[超出限购数]' . mb_substr($fail[0]['product']['store_name'], 0, 10) . '...');
             }
-            throw new ValidateException('[已失效]' . mb_substr($fail[0]['product']['store_name'],0,10).'...');
+            throw new ValidateException('[已失效]' . mb_substr($fail[0]['product']['store_name'], 0, 10) . '...');
         }
 
         $svip_status = $user->is_svip > 0 && systemConfig('svip_switch_status') == '1';
@@ -67,17 +67,17 @@ class StoreOrderCreateRepository extends StoreOrderRepository
         //检查商品类型, 活动商品只能单独购买
         foreach ($merchantCartList as $merchantCart) {
             foreach ($merchantCart['list'] as $cart) {
-                if ($cart['product_type']==0) {
+                if ($cart['product_type'] == 0) {
-                    if ($cart['product']['once_min_count'] > 0 &&  $cart['product']['once_min_count'] > $cart['cart_num'])
+                    if ($cart['product']['once_min_count'] > 0 && $cart['product']['once_min_count'] > $cart['cart_num'])
-                        throw new ValidateException('[低于起购数:'.$cart['product']['once_min_count'].']'.mb_substr($cart['product']['store_name'],0,10).'...');
+                        throw new ValidateException('[低于起购数:' . $cart['product']['once_min_count'] . ']' . mb_substr($cart['product']['store_name'], 0, 10) . '...');
                     if ($cart['product']['pay_limit'] == 1 && $cart['product']['once_max_count'] < $cart['cart_num'])
-                        throw new ValidateException('[超出单次限购数：'.$cart['product']['once_max_count'].']'.mb_substr($cart['product']['store_name'],0,10).'...');
+                        throw new ValidateException('[超出单次限购数：' . $cart['product']['once_max_count'] . ']' . mb_substr($cart['product']['store_name'], 0, 10) . '...');
-                    if ($cart['product']['pay_limit'] == 2){
+                    if ($cart['product']['pay_limit'] == 2) {
                         //如果长期限购
                         //已购买数量
-                        $count = app()->make(StoreOrderRepository::class)->getMaxCountNumber($cart['uid'],$cart['product_id']);
+                        $count = app()->make(StoreOrderRepository::class)->getMaxCountNumber($cart['uid'], $cart['product_id']);
                         if (($cart['cart_num'] + $count) > $cart['product']['once_max_count'])
-                            throw new ValidateException('[超出限购总数：'. $cart['product']['once_max_count'].']'.mb_substr($cart['product']['store_name'],0,10).'...');
+                            throw new ValidateException('[超出限购总数：' . $cart['product']['once_max_count'] . ']' . mb_substr($cart['product']['store_name'], 0, 10) . '...');
                     }
                 }
 
@@ -385,7 +385,7 @@ class StoreOrderCreateRepository extends StoreOrderRepository
                     $coupon['disabled'] = true;
                     continue;
                 }
-                if($svip_coupon_merge != '1' && $use_svip){
+                if ($svip_coupon_merge != '1' && $use_svip) {
                     $coupon['disabled'] = true;
                     continue;
                 }
@@ -440,7 +440,7 @@ class StoreOrderCreateRepository extends StoreOrderRepository
                 $coupon['checked'] = false;
                 $coupon['disabled'] = $pay_price <= 0;
                 if ($use_store_coupon || $pay_price <= 0) continue;
-                if($svip_coupon_merge != '1' && $use_svip){
+                if ($svip_coupon_merge != '1' && $use_svip) {
                     $coupon['disabled'] = true;
                     continue;
                 }
@@ -527,7 +527,7 @@ class StoreOrderCreateRepository extends StoreOrderRepository
             }
             unset($cart, $_k);
             $total_true_price = bcadd($_pay_price, $total_true_price, 2);
-            if(count($merchantCartList) > 1 || count($merchantCart['list']) > 1){
+            if (count($merchantCartList) > 1 || count($merchantCart['list']) > 1) {
                 $orderDeliveryStatus = $orderDeliveryStatus && $deliveryStatus;
             }
             $merchantCart['order'] = [
@@ -762,7 +762,7 @@ class StoreOrderCreateRepository extends StoreOrderRepository
                     $integralRate = $cart['product']['integral_rate'];
                     if ($integralRate < 0) {
                         $integralRate = $merIntegralConfig['mer_integral_rate'];
-                    } else if($integralRate > 0){
+                    } else if ($integralRate > 0) {
                         $integralRate = min(bcdiv($integralRate, 100, 4), 1);
                     }
                     if ($integralRate > 0) {
@@ -1092,7 +1092,8 @@ class StoreOrderCreateRepository extends StoreOrderRepository
                 'mark' => $mark[$merchantCart['mer_id']] ?? '',
                 'coupon_price' => bcadd($merchantCart['order']['coupon_price'], $merchantCart['order']['platform_coupon_price'], 2),
                 'platform_coupon_price' => $merchantCart['order']['platform_coupon_price'],
-                'pay_type' => $pay_type
+                'pay_type' => $pay_type,
+                'user_address_id' => $user_address['address_id'] ?? 0,
             ];
             $allUseCoupon = array_merge($allUseCoupon, $merchantCart['order']['useCouponIds']);
             $orderList[] = $_order;

app/common/repositories/store/order/StoreOrderRepository.php

@@ -744,9 +744,11 @@ class StoreOrderRepository extends BaseRepository
             $order->save();
             $storeOrderStatusRepository->{$func}($orderStatus);
         });
-        event('order.take', compact('order'));
         //推送到贡献值结算队列
         Queue::push(OrderPartnerJob::class, compact('order'));
+
+        event('order.take', compact('order'));
+
     }
 
 

crmeb/jobs/OrderPartnerJob.php

@@ -14,22 +14,251 @@
 namespace crmeb\jobs;
 
 use crmeb\interfaces\JobInterface;
+use think\Exception;
 use think\facade\Log;
 use think\queue\Job;
-use crmeb\services\ExcelService;
+use app\common\model\store\order\StoreOrderProduct;
+use app\common\model\store\product\Product;
+use app\common\model\store\StoreBrand;
+use app\common\model\store\StoreBrandCategory;
+use app\common\model\system\admin\Partner;
+use app\common\model\user\User;
+use app\common\model\user\UserPartner;
+use app\common\model\store\product\Spu;
+use app\common\model\user\ValueContributionLog;
+use app\common\model\store\order\StoreOrderContribute;
+use app\common\repositories\user\UserAddressRepository;
 
 class OrderPartnerJob implements JobInterface
 {
 
     public function fire($job, $data)
     {
-        try{
+        try {
-            //查询商品类型 -报单区 100%  其他 66.7%
+            //初始化贡献值
-            //查询合作人角色是否包含此商品品牌
+            $bao_price = $mian_price = $ping_price = $total_price = 0;
-            //查询合作人橘色是否包含此商品行业
+            $brand_ids = $trade_ids = $user_log_data = [];
+            //查询商品类型 -报单区 100%  免单区66.7%  平价区66.7%
+            $order_product = StoreOrderProduct::getDB()
+                ->where('order_id', $data['order_id'])
+                ->select()->toArray();
+            $product_ids = array_column($order_product, null, $order_product['product_id']);
+            $prodcut_temp = [];
+            foreach ($order_product as $pk => $pv) {
+                $prodcut_temp[$pv['product_id']] = $pv;
+            }
+            $product_list = Product::getDB()->alias('a')
+                ->leftJoin('Spu b', 'a.product_id = b.product_id')
+                ->field('a.*,b.mer_labels')
+                ->whereIn('product_id', $product_ids)
+                ->select()->toArray();
+            $has_contribute = false;
+            if (!empty($product_list)) {
+                foreach ($product_list as $k => $v) {
+                    if ($v['mer_labels'] == ',1,') {
+                        $brand_ids[] = $v['brand_id'];
+                        $has_contribute = true;
+                        //计算报单区  100%金额
+                        $bao_price = $prodcut_temp[$v['product_id']]['product_price'];
+                        $total_price = bcadd($total_price, $bao_price, 2);
+                    } elseif ($v['mer_labels'] == ',2,') {
+                        $brand_ids[] = $v['brand_id'];
+                        //计算免单区 订单毛利的66.7%
+                        if ($prodcut_temp[$v['product_id']]['product_price'] > 0 && $data['commission_rate'] > 0) {
+                            //计算当前商品的毛利占比
+                            $has_contribute = true;
+                            $mian_rate = bcdiv($prodcut_temp[$v['product_id']]['product_price'], $data['pay_price'], 3);
+                            $mian_price = bcmul($data['commission_rate'], $mian_rate, 2);
+                            $mian_price = bcmul($mian_price, 0.667, 2);
+                            $total_price = bcadd($total_price, $mian_price, 2);
+                        }
+                    } elseif ($v['mer_labels'] == ',3,') {
+                        $brand_ids[] = $v['brand_id'];
+                        if ($prodcut_temp[$v['product_id']]['product_price'] > 0 && $data['commission_rate'] > 0) {
+                            $has_contribute = true;
+                            $ping_rate = bcdiv($prodcut_temp[$v['product_id']]['product_price'], $data['pay_price'], 3);
+                            $ping_price = bcmul($data['commission_rate'], $ping_rate, 2);
+                            $ping_price = bcmul($ping_price, 0.667, 2);
+                            $total_price = bcadd($total_price, $ping_price, 2);
+                        }
+
+                    }
+                }
+            }
+            //如果商品未包含指定的三种类型，则不计入贡献值记录
+            if ($has_contribute == false) {
+                throw new Exception('订单没有指定三种类型商品，不计入贡献值统计');
+            }
+            //读取品牌所属分类
+            if (!empty($brand_ids)) {
+                $cat_ids = StoreBrand::getDB()->whereIn('brand_id', $brand_ids)->column('brand_category_id');
+                $trade_ids = $cat_ids;
+                $all_cat_ids = StoreBrandCategory::getDB()->whereIn('store_brand_category_id', $cat_ids)->column('path');
+                foreach ($all_cat_ids as $ck => $cv) {
+                    $temp_ids = explode('/', $cv);
+                    if (!empty($temp_ids)) {
+                        foreach ($temp_ids as $tk => $tv) {
+                            $trade_ids[] = $tv;
+                        }
+                    }
+                }
+                $trade_ids = array_unique($trade_ids);
+            }
+
+            //读取订单所属地区
+            $addressRepository = app()->make(UserAddressRepository::class);
+            $address = $addressRepository->getWhere(['uid' => $data['uid'], 'address_id' => $data['user_address_id']]);
+            //生成订单贡献值记录
+            $contribute_insert = [
+                'order_id' => $data['order_id'],
+                'order_sn' => $data['order_sn'],
+                'order_profit' => $total_price,
+                'order_price' => $data['pay_price'],
+                'bao_price' => $bao_price,
+                'mian_price' => $mian_price,
+                'ping_price' => $ping_price,
+                'uid' => $data['uid'],
+                'brand_ids' => implode(',', $brand_ids),
+                'trade_ids' => implode(',', $trade_ids),
+                'province_id' => $address['province_id'] ?? '',
+                'city_id' => $address['city_id'] ?? '',
+                'district_id' => $address['district_id'] ?? '',
+                'street_id' => $address['street_id'] ?? '',
+                'created_time' => date('Y-m-d H:i:s'),
+            ];
+            StoreOrderContribute::getDB()->insert($contribute_insert);
+            //订单角色贡献值-30%
+            $user_value = bcmul($total_price, 0.3, 2);
+            $user = User::getDB()->where('uid', $data['uid'])->find();
+            $user->all_value = bcadd($user->all_value, $user_value, 2);
+            $user->save();
+            $user_log_data[] = [
+                'type' => 6,
+                'types_of' => 1,
+                'num' => $user_value,
+                'ctime' => date('Y-m-d H:i:s'),
+                'memo' => '订单消费贡献值',
+                'user_id' => $data['uid'],
+            ];
+
+            //处理合作人角色是否包含此商品品牌
+            if (!empty($brand_ids)) {
+                $brand_roles = Partner::getDB()
+                    ->where('type', 3)
+                    ->where('status', 1)
+                    ->whereIn('brand_id', $brand_ids)
+                    ->select()->toArray();
+                $role_ids = array_column($brand_roles, null, 'id');
+                $brand_brand_data = array_column($brand_roles, 'id');
+                $user_list = User::getDB()->alias('u')
+                    ->leftJoin('UserPartner p', 'u.uid = p.uid')
+                    ->whereIn('p.partner_id', $role_ids)
+                    ->where('uid', '<>', $data['uid'])
+                    ->field('u.*,p.partner_id')
+                    ->select()->toArray();
+                $user_count = count($user_list);
+                foreach ($user_list as $buk => $buv) {
+                    $role_data = $brand_brand_data[$buv['partner_id']] ?? [];
+                    if (!empty($role_data)) {
+                        $role_value = bcmul($total_price, $role_data['ratio'] / 100, 2);
+                        $role_value = bcdiv($role_value, $user_count, 2);
+                        $user = User::getDB()->where('uid', $buv['uid'])->find();
+                        $user->all_value = bcadd($user->all_value, $role_value, 2);
+                        $user->save();
+                        $user_log_data[] = [
+                            'type' => 5,
+                            'types_of' => 1,
+                            'num' => $role_value,
+                            'ctime' => date('Y-m-d H:i:s'),
+                            'memo' => '订单消费品牌贡献值',
+                            'user_id' => $buv['uid'],
+                        ];
+                    }
+                }
+            }
+            //处理合作人角色是否包含此商品行业
+            if (!empty($trade_ids)) {
+                $trade_roles = Partner::getDB()
+                    ->where('type', 4)
+                    ->where('status', 1)
+                    ->whereIn('trade_id', $trade_ids)
+                    ->select()->toArray();
+                $role_ids = array_column($trade_roles, null, 'id');
+                $trade_trade_data = array_column($trade_roles, 'id');
+                $user_list = User::getDB()->alias('u')
+                    ->leftJoin('UserPartner p', 'u.uid = p.uid')
+                    ->whereIn('p.partner_id', $role_ids)
+                    ->where('uid', '<>', $data['uid'])
+                    ->field('u.*,p.partner_id')
+                    ->select()->toArray();
+                $user_count = count($user_list);
+                foreach ($user_list as $tuk => $tuv) {
+                    $role_data = $trade_trade_data[$tuv['partner_id']] ?? [];
+                    if (!empty($role_data)) {
+                        $role_value = bcmul($total_price, $role_data['ratio'] / 100, 2);
+                        $role_value = bcdiv($role_value, $user_count, 2);
+                        $user = User::getDB()->where('uid', $tuv['uid'])->find();
+                        $user->all_value = bcadd($user->all_value, $role_value, 2);
+                        $user->save();
+                        $user_log_data[] = [
+                            'type' => 5,
+                            'types_of' => 1,
+                            'num' => $role_value,
+                            'ctime' => date('Y-m-d H:i:s'),
+                            'memo' => '订单消费行业贡献值',
+                            'user_id' => $tuv['uid'],
+                        ];
+                    }
+                }
+            }
             //查询所属区域角色
+            if (!empty($address)) {
+                $province_id = $address['province_id'] ?? '';
+                $city_id = $address['city_id'] ?? '';
+                $district_id = $address['district_id'] ?? '';
+                $street_id = $address['street_id'] ?? '';
+                $area_ids = [$province_id, $city_id, $district_id, $street_id];
+                $area_ids = array_values(array_filter($area_ids));
+                $area_roles = Partner::getDB()
+                    ->where('is_area', 1)
+                    ->where('status', 1)
+                    ->whereNotIn('type', [3, 4])
+                    ->whereIn('area_id', $area_ids)
+                    ->select()->toArray();
+                $role_ids = array_column($area_roles, null, 'id');
+                $trade_trade_data = array_column($area_roles, 'id');
+                $user_list = User::getDB()->alias('u')
+                    ->leftJoin('UserPartner p', 'u.uid = p.uid')
+                    ->whereIn('p.partner_id', $role_ids)
+                    ->where('uid', '<>', $data['uid'])
+                    ->field('u.*,p.partner_id')
+                    ->select()->toArray();
+                $user_count = count($user_list);
+                foreach ($user_list as $auk => $auv) {
+                    $role_data = $trade_trade_data[$auv['partner_id']] ?? [];
+                    if (!empty($role_data)) {
+                        $role_value = bcmul($total_price, $role_data['ratio'] / 100, 2);
+                        $role_value = bcdiv($role_value, $user_count, 2);
+                        $user = User::getDB()->where('uid', $auv['uid'])->find();
+                        $user->all_value = bcadd($user->all_value, $role_value, 2);
+                        $user->save();
+                        $user_log_data[] = [
+                            'type' => 5,
+                            'types_of' => 1,
+                            'num' => $role_value,
+                            'ctime' => date('Y-m-d H:i:s'),
+                            'memo' => '订单消费行业贡献值',
+                            'user_id' => $auv['uid'],
+                        ];
+                    }
+                }
+            }
+
             //查询通用角色
-        }catch (\Exception $e){
+
+            //批量增加用户贡献值日志
+            ValueContributionLog::getDB()->insertAll($user_log_data);
+        } catch (\Exception $e) {
             Log::info('订单角色贡献值处理失败; error : ' . $e->getMessage());
         }
         $job->delete();