refactor(test): 计算共富分红

app/controller/api/Test.php

@@ -4,8 +4,11 @@ namespace app\controller\api;
 
 use app\common\dao\shared\SharedProsperityUserDao;
 use app\common\enum\CommonEnum;
+use app\common\enum\shared\SharedProsperityRewardRecordEnum;
 use app\common\model\shared\SharedProsperityUser;
 use app\common\repositories\shared\SharedProsperityUserRepository;
+use app\common\repositories\store\order\StoreGroupOrderRepository;
+use app\common\repositories\store\order\StoreOrderRepository;
 use app\common\repositories\user\UserRepository;
 use app\traits\GzcApiRequest;
 use think\facade\Db;
@@ -16,46 +19,91 @@ class Test
     {
 
 
-        $title = '系统补贴';
-        $map = [
-            294 => 165,
-            186 => 860
-        ];
+        // // 1、获取订单数据
+        // /** @var StoreGroupOrderRepository $storeGroupOrderRepository */
+        // $storeGroupOrderRepository = app()->make(StoreGroupOrderRepository::class);
+        // // 获取订单组数据
+        // $groupOrderSn = 'wx177442719463317087';
+        // $storeGroupOrderEntity = $storeGroupOrderRepository->getStoreGroupOrderEntityByGroupOrderSn($groupOrderSn);
+        // /** @var StoreOrderRepository $storeOrderRepository */
+        // $storeOrderRepository = app()->make(StoreOrderRepository::class);
+        // // 获取订单集合
+        // $storeOrderEntityList = $storeOrderRepository->getStoreOrderEntityListByGroupOrderId($storeGroupOrderEntity->getGroupOrderId());
+        // try {
+        //     Db::transaction(function () use (
+        //         $storeGroupOrderRepository,
+        //         $storeGroupOrderEntity
+        //     ) {
+        //         $storeGroupOrderRepository->storeGroupOrderPaySuccess($storeGroupOrderEntity->getGroupOrderId());
+        //     });
+        // } catch (\Throwable $e) {
+        //     Db::name("log")
+        //         ->insert([
+        //             'data' => '【订单支付回调】【结算订单失败】:时间：' . date('Y-m-d H:i:s', time()) . '；订单编号：1111订单失败原因：' . json_encode([
+        //                     'error_message' => $e->getMessage(),
+        //                     'error_file' => $e->getFile(),
+        //                     'error_line' => $e->getLine(),
+        //                     'error_code' => $e->getCode(),
+        //                     'exception_class' => get_class($e),
+        //                     'trace' => $e->getTraceAsString()
+        //                 ], JSON_UNESCAPED_UNICODE)
+        //         ]);
+        //     dd($e->getMessage());
+        // }
+        //
+        //
+        // die;
+
+        //
+        // $title = '系统补贴';
+        // $map = [
+        //     294 => 165,
+        //     186 => 860
+        // ];
+        //
+        // foreach ($map as $uid => $money) {
+        //     $bill = [
+        //         'uid' => $uid,
+        //         'link_id' => 0,
+        //         'pm' => 1,
+        //         'title' => $title,
+        //         'category' => 'now_money',
+        //         'type' => 'commission',
+        //         'number' => $money,
+        //         'balance' => 0,
+        //         'mark' => $title,
+        //         'create_time' => date('Y-m-d H:i:s'),
+        //         'status' => 1,
+        //         'commission_type' => CommonEnum::COMMISSION_TYPE['SYSTEM_SUBSIDY_COMMISSION']['code'],
+        //         'order_sn' => 0,
+        //         'tripartite' => 0,
+        //         'type_shop' => 0,
+        //         'mer_id' => 0,
+        //         'source' => 0,
+        //         'order_type' => 1,
+        //         'is_red_brokerage' => 0,
+        //         'gzc' => 3,
+        //         'take_time' => time(),
+        //         'district_id' => '',
+        //         'street_id' => '',
+        //         'month' => '',
+        //     ];
+        //     $a = Db::name('user_bill')->insert($bill);
+        //
+        //     $b = Db::name('user')->where('uid', $uid)->inc('brokerage_price', $money)->update();
+        // }
+        // die;
 
-        foreach ($map as $uid => $money) {
-            $bill = [
-                'uid' => $uid,
-                'link_id' => 0,
-                'pm' => 1,
-                'title' => $title,
-                'category' => 'now_money',
-                'type' => 'commission',
-                'number' => $money,
-                'balance' => 0,
-                'mark' => $title,
-                'create_time' => date('Y-m-d H:i:s'),
-                'status' => 1,
-                'commission_type' => CommonEnum::COMMISSION_TYPE['SYSTEM_SUBSIDY_COMMISSION']['code'],
-                'order_sn' => 0,
-                'tripartite' => 0,
-                'type_shop' => 0,
-                'mer_id' => 0,
-                'source' => 0,
-                'order_type' => 1,
-                'is_red_brokerage' => 0,
-                'gzc' => 3,
-                'take_time' => time(),
-                'district_id' => '',
-                'street_id' => '',
-                'month' => '',
-            ];
-            $a = Db::name('user_bill')->insert($bill);
 
-            $b = Db::name('user')->where('uid', $uid)->inc('brokerage_price', $money)->update();
-        }
-        die;
+        // $sharedUserPvCount = Db::name('shared_prosperity_reward_record')
+        //     ->where(['type' => SharedProsperityRewardRecordEnum::TYPE['PV']['code'], 'status' => SharedProsperityRewardRecordEnum::STATUS['VALID']['code'], 'pm' => SharedProsperityRewardRecordEnum::PM['INCOME']['code']])
+        //     ->whereNotIn('user_id',$testUids)
+        //     ->sum('number'); // 共富会员专区总业绩
+        // dd($sharedUserPvCount);
+        // die;
 
-        $total = 8497.13;
+        //
+        $total = 2756.48;
         $map = [
             1 => 0.3,
             2 => 0.15,
@@ -66,8 +114,9 @@ class Test
             1 => 0.05,
             2 => 0.1
         ];
+        $testUids = Db::name('user')->where('test_user',  '1')->column('uid');
 
-        $users = Db::name('shared_prosperity_user')->group('partner_level')->field('partner_level,count(*) as num')->select()->toArray();
+        $users = Db::name('shared_prosperity_user')->whereNotIn('user_id',$testUids)->group('partner_level')->field('partner_level,count(*) as num')->select()->toArray();
 
         $res = [];
         foreach ($users as $user) {
@@ -81,7 +130,7 @@ class Test
         }
 
         $groupRes = [];
-        $groupUsers = Db::name('shared_prosperity_group_user')->group('group_id')->field('group_id,count(*)as num')->select()->toArray();
+        $groupUsers = Db::name('shared_prosperity_group_user')->whereNotIn('user_id',$testUids)->group('group_id')->field('group_id,count(*)as num')->select()->toArray();
         foreach ($groupUsers as $groupUser) {
             $groupRes[$groupUser['group_id']] = [
                 'num' => $groupUser['num'],
@@ -120,14 +169,14 @@ class Test
         // dd($res);
 
 
-        // /** @var SharedProsperityUserRepository $userRepository */
-        // $userRepository = app()->make(SharedProsperityUserRepository::class);
-        // $list = $userRepository->getUserTree(2393);
+        /** @var SharedProsperityUserRepository $userRepository */
+        $userRepository = app()->make(SharedProsperityUserRepository::class);
+        $list = $userRepository->getUserTree(294);
         // var_dump(json_encode($list));
-        $field = request()->param('field');
-        /** @var UserRepository $userRepository */
-        $userRepository = app()->make(UserRepository::class);
-        $list = $userRepository->getUserForTree($field, 0);
+        // $field = request()->param('field');
+        // /** @var UserRepository $userRepository */
+        // $userRepository = app()->make(UserRepository::class);
+        // $list = $userRepository->getUserForTree($field, 0);
         var_dump(json_encode($list));
         // return app('json')->success($list);
     }