待完成

app/controller/api/cron/CommissionCron.php

@@ -787,11 +787,14 @@ where o.paid=1 and o.is_settlement=1 and settlement_time between '$this->startMo
                             'hf_clear_time' => $close_time
                         ]);
                     }
-                    //
+                    // 如果 当前时间 > 汇付分账成功时间
                     if (isset($res['status']) && time() > strtotime($close_time)) {
+                        // 计算 平台收支明细 金额
                         if ($store_order['mer_id'] == 496) {
+                            // 实际支付金额 - 发放的养老金 - 手续费
                             $ru_money = $store_order['pay_price'] - $yanglao - $res['fee_amt'];
                         } else {
+                            // 实际支付金额 - 发放的养老金 - 手续费  有问题，？？
                             $ru_money = $store_order['pay_price'] * (1 - $shop_bonus_setting['shop_bonus_rate'] / 100) - $res['fee_amt'] + +$store_order['pay_postage'];
                         }
                         $store_order['pay_time'] = '';//线上支付的
@@ -1151,6 +1154,420 @@ where o.paid=1 and o.is_settlement=1 and settlement_time between '$this->startMo
         return app('json')->success('获取平台收支明细成功');
     }
 
+    public function platform_income_detail_get1()
+    {
+
+        // 1、获取所有 商户 商户名称非空， 状态为正常、商户状态为开启
+        $merchant_list = Db::name('merchant')
+            ->where('status', 1)
+            ->where('mer_state', 1)
+            ->where("mer_name  != ''")
+            ->column('mer_id');
+
+        // 2、获取 已有的 平台收支明细，并创建 唯一的 key
+        $unique_list = [];
+        $enterprise_platform_income_detail_list = Db::name('enterprise_platform_income_detail')
+            ->select()
+            ->toArray();
+        foreach ($enterprise_platform_income_detail_list as $item) {
+            // deal_type : '交易类型 1自营订单入账(商户) 2佣金提现到账(商户) 3订单支付 4商户佣金提现 5用户佣金提现 6订单入账 7 创客自营订单让利 '
+            // user_extra_id : 提现表id
+            $unique_list[] = $item['deal_type'] . $item['uid'] . $item['order_sn'] . $item['order_id'] . $item['user_extra_id'] . $item['mer_id'];
+        }
+
+        // 3、获取订单信息
+        // 1自营订单入账金额=已结算订单金额-运费-养老金-汇付通道服务费； 订单结算的时候才统计
+        // 查询 该商户 所有的 平台订单（已支付、平台订单、已结算）
+        $store_order_list = Db::name('store_order')
+            ->whereIn('mer_id', $merchant_list)
+            ->where('paid', 1)
+            ->where('douhuomall', 0)
+            ->where('is_settlement', 1)
+            ->order('order_id', 'desc')
+            ->select()
+            ->toArray();
+        $store_order_map = array_reduce($store_order_list, function($result, $order) {
+            // 根据 mer_id 进行分组
+            $result[$order['mer_id']][] = $order;
+            return $result;
+        }, []);
+        // 用户订单表
+        $group_order = Db::name('store_group_order')
+            ->whereIn('group_order_id', array_column($store_order_list,'group_order_id'))
+            ->select()
+            ->toArray();
+        $group_order_map = array_column($group_order, null, 'group_order_id');
+        // // 查询分账信息
+        // $store_split_order = Db::name('store_split_order')
+        //     ->whereIn('group_order_id', array_column($group_order,'group_order_sn'))
+        //     ->where('status', 1)
+        //     ->select()
+        //     ->toArray();
+        // $store_split_order_map = array_column($store_split_order, null, 'group_order_id');
+
+        // 4、循环所有商户ID
+        /** @var OrderMerchantRepository $OrderMerchantRepository */
+        $OrderMerchantRepository = app()->make(OrderMerchantRepository::class);
+        foreach ($merchant_list as $mer_id) {
+            foreach ($store_order_map[$mer_id] as $store_order) {
+                // 判断该笔订单是否已 存在 平台收支明细表 的记录中
+                if (!in_array('1' . $store_order['uid'] . $store_order['order_sn'] . $store_order['order_id'] . '0' . $mer_id, $unique_list)) {
+                    if (empty($group_order_map[$store_order['group_order_id']])) continue;
+                    // 经过和领导确认，入账 金额为 订单金额 - 让利金额 - 手续费
+
+                    if ($store_order['mer_id'] == 496 || $store_order['mer_id'] == 496 || $store_order['mer_id'] == 496) {
+                        $ru_money = $store_order['pay_price'] - $yanglao;
+                    } else {
+                        $ru_money = $store_order['pay_price'] * (1 - $shop_bonus_setting['shop_bonus_rate'] / 100) + $store_order['pay_postage'];
+                    }
+
+                    Db::name('enterprise_platform_income_detail')
+                        ->insert([
+                            'mer_id' => $mer_id,
+                            'uid' => $store_order['uid'],
+                            'title' => '自营订单入账',
+                            'deal_order_sn' => $OrderMerchantRepository->getNewOrderId('jy2'),
+                            'deal_time' => isset($close_time) ? $close_time : ((isset($store_order['pay_time']) && $store_order['pay_time']) ? $store_order['pay_time'] : date('Y-m-d H:i:s')),
+                            'money' => $ru_money,
+                            'deal_type' => 1,
+                            'order_id' => $store_order['order_id'],
+                            'order_sn' => $store_order['order_sn'],
+                            'user_extra_id' => '',
+                            'pm' => 1,
+                            'create_time' => date('Y-m-d H:i:s'),
+                        ]);
+                    unset($close_time);
+                }
+
+            }
+            //2佣金提现到账 提现成功统计
+            //            $user_extract_list = Db::name('user_extract')
+            //                ->field('extract_id,uid,extract_type,extract_price,service_money,order_sn,status_time')
+            //                ->where('status', 1)
+            //                ->where('withdrawal_type', 3)
+            //                ->where('extract_type', '<>', 4)
+            //                ->when($uids, function ($query) use ($uids) {
+            //                    $query->whereIn('uid', $uids);
+            //                })
+            //                ->order('extract_id', 'desc')
+            ////                ->limit(100)
+            //                ->select()
+            //                ->toArray();
+            //            foreach ($user_extract_list as $user_extract) {
+            //                if (in_array('2' . $user_extract['uid'] . $user_extract['order_sn'] . '0' . $user_extract['extract_id'], $unique_list)) continue;
+            //                $enterprise_platform_income_detail = Db::name('enterprise_platform_income_detail')
+            //                    ->where('deal_type', 2)
+            //                    ->where('user_extra_id', $user_extract['extract_id'])
+            //                    ->find();
+            //                if (!$enterprise_platform_income_detail) {
+            //                    Db::name('enterprise_platform_income_detail')
+            //                        ->insert([
+            //                            'mer_id'        => $mer_id,
+            //                            'uid'           => $user_extract['uid'],
+            //                            'title'         => '佣金提现支出',
+            //                            'deal_order_sn' => $OrderMerchantRepository->getNewOrderId('jy2'),
+            //                            'deal_time'     => $user_extract['status_time'],
+            //                            'money'         => bcsub($user_extract['extract_price'], $user_extract['service_money'], 2),
+            //                            'deal_type'     => 2,
+            //                            'order_id'      => '',
+            //                            'order_sn'      => $user_extract['order_sn'],
+            //                            'user_extra_id' => $user_extract['extract_id'],
+            //                            'pm'            => 1,
+            //                            'create_time'   => date('Y-m-d H:i:s'),
+            //                        ]);
+            //                }
+            //            }
+            $start_time = '2024-04-01';
+            for ($i = 0; $i < 1000; $i++) {
+                $day = date('Y-m-d', strtotime("+{$i} days", strtotime($start_time)));
+                if (strtotime($day) > time()) {
+                    break;
+                }
+                $this->cron($day, $mer_id);
+            }
+        }
+
+        // 计算平台
+        //交易类型 1自营订单入账(商户) 2佣金提现到账(商户) 3订单支付 4商户佣金提现 5用户佣金提现 6订单入账 7 创客自营订单让利
+
+        $mer_id = 0;
+        // 3 订单支付 供应链订单结算后入账到平台的金额
+        $store_order_list = Db::name('store_order')
+            ->where('paid', 1)
+            ->order('order_id', 'desc')
+            //                    ->limit(500)
+            ->select()
+            ->toArray();
+        foreach ($store_order_list as $store_order) {
+            if (in_array('3' . $store_order['uid'] . $store_order['order_sn'] . $store_order['order_id'] . '0' . $mer_id, $unique_list)) continue;
+
+            $group_order = Db::name('store_group_order')
+                ->alias('sgo')
+                ->where('sgo.group_order_id', $store_order['group_order_id'])
+                ->find();
+            if (empty($group_order)) continue;
+
+            $store_split_order = Db::name('store_split_order')
+                ->where('group_order_id', $group_order['group_order_sn'])
+                ->where('status', 1)
+                ->find();
+            if (empty($store_split_order)) continue;
+
+            $close_time = $this->getNextWorkday(date('Y-m-d H:i:s', strtotime('+1 days', strtotime($store_order['pay_time']))));
+
+            Db::name('enterprise_platform_income_detail')
+                ->insert([
+                    'mer_id'        => $mer_id,
+                    'uid'           => $store_order['uid'],
+                    'title'         => '订单支付',
+                    'deal_order_sn' => $OrderMerchantRepository->getNewOrderId('jy4'),
+                    'deal_time'     => isset($close_time) ? $close_time : ((isset($store_order['pay_time']) && $store_order['pay_time']) ? $store_order['pay_time'] : date('Y-m-d H:i:s')),
+                    'money'         => $store_order['pay_price'] + $store_order['pay_postage'],
+                    'deal_type'     => 3,
+                    'order_id'      => $store_order['order_id'],
+                    'order_sn'      => $store_order['order_sn'],
+                    'user_extra_id' => '',
+                    'pm'            => 1,
+                    'create_time'   => date('Y-m-d H:i:s'),
+                ]);
+        }
+        //5用户佣金提现
+        $user_extract_list = Db::name('user_extract')
+            ->field('extract_id,uid,extract_type,extract_price,service_money,order_sn,status_time')
+            ->where('status', 1)
+            ->order('extract_id', 'desc')
+            //                ->limit(100)
+            ->select()
+            ->toArray();
+        foreach ($user_extract_list as $user_extract) {
+            if (in_array('5' . $user_extract['uid'] . $user_extract['order_sn'] . '0' . $user_extract['extract_id'] . $mer_id, $unique_list)) continue;
+            Db::name('enterprise_platform_income_detail')
+                ->insert([
+                    'mer_id'        => $mer_id,
+                    'uid'           => $user_extract['uid'],
+                    'title'         => '用户佣金提现',
+                    'deal_order_sn' => $OrderMerchantRepository->getNewOrderId('jy2'),
+                    'deal_time'     => $user_extract['status_time'],
+                    'money'         => bcsub($user_extract['extract_price'], $user_extract['service_money'], 2),
+                    'deal_type'     => 5,
+                    'order_id'      => '',
+                    'order_sn'      => $user_extract['order_sn'],
+                    'user_extra_id' => $user_extract['extract_id'],
+                    'pm'            => 0,
+                    'create_time'   => date('Y-m-d H:i:s'),
+                ]);
+        }
+        // 6订单入账：支付成功的订单数据 供应链订单
+        $store_order_list = Db::name('store_order')
+            ->where('paid', 1)
+            ->where('douhuomall', 1)
+            ->where('is_settlement', 1)
+            ->order('order_id', 'desc')
+            //                ->limit(500)
+            ->select()
+            ->toArray();
+
+        foreach ($store_order_list as $store_order) {
+            if (in_array('6' . $store_order['uid'] . $store_order['order_sn'] . $store_order['order_id'] . '0' . $mer_id, $unique_list)) continue;
+            $pay_type = $store_order['pay_type'];
+            if (!in_array($pay_type, [0, 1])) continue;
+
+            $group_order = Db::name('store_group_order')
+                ->alias('sgo')
+                ->where('sgo.group_order_id', $store_order['group_order_id'])
+                ->find();
+            if (empty($group_order)) continue;
+
+            $yanglao = Db::name('user_bill')
+                ->where('order_sn', $store_order['order_sn'])
+                ->where('commission_type', 5)
+                ->value('number');
+            $ru_money = 0;
+            $shop_bonus_setting = merchantConfig($store_order['mer_id'], 'shop_bonus_setting') ?: [
+                'shop_bonus_rate' => 30,
+                'yanglao_rate'    => 5,
+            ];
+            if ($pay_type != 0) {
+                $store_split_order = Db::name('store_split_order')
+                    ->where('group_order_id', $group_order['group_order_sn'])
+                    ->find();
+                if (empty($store_split_order)) continue;
+                if (!$store_order['hf_fee_amt']) {
+                    if ($pay_type == 1) {
+                        //微信
+                        if ($group_order['pay_wx'] == 3) {
+                            $api_key = 'api_live_b0a687ec-5450-4ada-a0e4-65bac0f46871';
+                        } else {
+                            $api_key = 'api_live_90ef02e4-54ac-41ee-adf1-e4927d23d58f';
+                        }
+                    } else {
+                        //支付宝
+                        $api_key = 'api_live_b23537ed-64b8-45d6-832e-fb228aa9e0a9';
+                    }
+                    $params['payment_confirm_id'] = $store_split_order['hf_pay_id'];
+                    $params['api_key'] = $api_key;
+                    //查询支付确认对象
+                    Db::name("log")->insert(array('data' => '汇付查询支付确认对象参数-----' . json_encode($params)));//日志记录
+                    $res = $this->payment_confirm_query_traits($params);
+                    Db::name("log")->insert(array('data' => '汇付查询支付确认对象返回-----' . json_encode($res)));//日志记录
+                    if (isset($res['status'])) {
+                        Db::name('store_order')->where('order_id', $store_order['order_id'])->update([
+                            'hf_fee_amt'    => $res['fee_amt'],
+                            'hf_clear_time' => $close_time
+                        ]);
+                        $store_order['hf_fee_amt'] = $res['fee_amt'];
+                    }
+                }
+                // 获取分账后一个工作日时间
+                $close_time = $this->getNextWorkday(date('Y-m-d H:i:s', strtotime('+1 days', strtotime($store_order['pay_time']))));
+
+                if (isset($res['status']) && time() > strtotime($close_time)) {
+
+                    if ($store_order['mer_id'] == 496) {
+                        $ru_money = $store_order['pay_price'] - $yanglao - $store_order['hf_fee_amt'];
+                    } else {
+                        $ru_money = $store_order['pay_price'] - $yanglao;
+                    }
+                    $store_order['pay_time'] = '';//线上支付的
+                } else {
+                    continue;
+                }
+            } else {
+                // 订单金额+运费
+                if ($store_order['mer_id'] == 496) {
+                    $ru_money = $store_order['pay_price'] - $yanglao;
+                } else {
+                    $ru_money = $store_order['pay_price'] - $yanglao;
+                }
+            }
+            Db::name('enterprise_platform_income_detail')
+                ->insert([
+                    'mer_id'        => $mer_id,
+                    'uid'           => $store_order['uid'],
+                    'title'         => '订单入账',
+                    'deal_order_sn' => $OrderMerchantRepository->getNewOrderId('jy2'),
+                    'deal_time'     => isset($close_time) ? $close_time : ((isset($store_order['pay_time']) && $store_order['pay_time']) ? $store_order['pay_time'] : date('Y-m-d H:i:s')),
+                    'money'         => $ru_money,
+                    'deal_type'     => 6,
+                    'order_id'      => $store_order['order_id'],
+                    'order_sn'      => $store_order['order_sn'],
+                    'user_extra_id' => '',
+                    'pm'            => 1,
+                    'create_time'   => date('Y-m-d H:i:s'),
+                ]);
+            unset($close_time);
+        }
+        //7 创客自营订单让利=创客自营订单金额*分润比例-（创客自营订单金额-运费）*养老金比例
+        $store_order_list = Db::name('store_order')
+            ->where('paid', 1)
+            ->where('is_settlement', 1)
+            ->where('douhuomall', 0)
+            ->order('order_id', 'desc')
+            //                    ->limit(500)
+            ->select()
+            ->toArray();
+        foreach ($store_order_list as $store_order) {
+            if (in_array('7' . $store_order['uid'] . $store_order['order_sn'] . $store_order['order_id'] . '0' . $mer_id, $unique_list)) continue;
+            $shop_bonus_setting = merchantConfig($store_order['mer_id'], 'shop_bonus_setting') ?: [
+                'shop_bonus_rate' => 30,
+                'yanglao_rate'    => 5,
+            ];
+            $pay_type = $store_order['pay_type'];
+            if ($pay_type != 0) {
+                $group_order = Db::name('store_group_order')
+                    ->alias('sgo')
+                    ->where('sgo.group_order_id', $store_order['group_order_id'])
+                    ->find();
+                if (empty($group_order)) continue;
+                $store_split_order = Db::name('store_split_order')
+                    ->where('group_order_id', $group_order['group_order_sn'])
+                    ->find();
+                if (empty($store_split_order)) continue;
+                $close_time = $this->getNextWorkday(date('Y-m-d H:i:s', strtotime('+1 days', strtotime($store_order['pay_time']))));
+
+                if (!$store_order['hf_fee_amt']) {
+                    $store_split_order = Db::name('store_split_order')
+                        ->where('group_order_id', $group_order['group_order_sn'])
+                        ->where('status', 1)
+                        ->find();
+                    if (empty($store_split_order)) continue;
+                    if ($pay_type == 1) {
+                        //微信
+                        if ($group_order['pay_wx'] == 3) {
+                            $api_key = 'api_live_b0a687ec-5450-4ada-a0e4-65bac0f46871';
+                        } else {
+                            $api_key = 'api_live_90ef02e4-54ac-41ee-adf1-e4927d23d58f';
+                        }
+                    } else {
+                        //支付宝
+                        $api_key = 'api_live_b23537ed-64b8-45d6-832e-fb228aa9e0a9';
+                    }
+                    $params['payment_confirm_id'] = $store_split_order['hf_pay_id'];
+                    $params['api_key'] = $api_key;
+                    //查询支付确认对象
+                    Db::name("log")->insert(array('data' => '汇付查询支付确认对象参数-----' . json_encode($params)));//日志记录
+                    $res = $this->payment_confirm_query_traits($params);
+                    Db::name("log")->insert(array('data' => '汇付查询支付确认对象返回-----' . json_encode($res)));//日志记录
+                    // 获取分账后一个工作日时间
+                    $close_time = $this->getNextWorkday(date('Y-m-d H:i:s', strtotime('+1 days', strtotime($store_order['pay_time']))));
+                    if (isset($res['status'])) {
+                        Db::name('store_order')->where('order_id', $store_order['order_id'])->update([
+                            'hf_fee_amt'    => $res['fee_amt'],
+                            'hf_clear_time' => $close_time
+                        ]);
+                        $store_order['hf_fee_amt'] = $res['fee_amt'];
+                    }
+                }
+                $yanglao = Db::name('user_bill')
+                    ->where('order_sn', $store_order['order_sn'])
+                    ->where('commission_type', 5)
+                    ->value('number');
+                if (isset($res['status']) && time() > strtotime($close_time)) {
+                    if ($store_order['mer_id'] == 496) {
+                        $ru_money = $store_order['pay_price'] - $yanglao - $store_order['hf_fee_amt'];
+                    } else {
+                        $ru_money = ($store_order['pay_price'] * $shop_bonus_setting['shop_bonus_rate'] / 100) - $yanglao;
+                    }
+                    $store_order['pay_time'] = '';//线上支付的
+                } else {
+                    continue;
+                }
+            }else{
+                if ($store_order['mer_id'] == 496) {
+                    $ru_money = $store_order['pay_price'] - $yanglao;
+                } else {
+                    $ru_money = ($store_order['pay_price'] * $shop_bonus_setting['shop_bonus_rate'] / 100) - $yanglao;
+                }
+            }
+            Db::name('enterprise_platform_income_detail')
+                ->insert([
+                    'mer_id'        => $mer_id,
+                    'uid'           => $store_order['uid'],
+                    'title'         => '创客自营订单让利',
+                    'deal_order_sn' => $OrderMerchantRepository->getNewOrderId('jy4'),
+                    'deal_time'     => isset($close_time) ? $close_time : ((isset($store_order['pay_time']) && $store_order['pay_time']) ? $store_order['pay_time'] : date('Y-m-d H:i:s')),
+                    'money'         => $ru_money,
+                    'deal_type'     => 7,
+                    'order_id'      => $store_order['order_id'],
+                    'order_sn'      => $store_order['order_sn'],
+                    'user_extra_id' => '',
+                    'pm'            => 1,
+                    'create_time'   => date('Y-m-d H:i:s'),
+                ]);
+            unset($close_time);
+
+        }
+        $start_time = '2024-04-01';
+        for ($i = 0; $i < 1000; $i++) {
+            $day = date('Y-m-d', strtotime("+{$i} days", strtotime($start_time)));
+            if (strtotime($day) > time()) {
+                break;
+            }
+            $Reconciliation->cron($day, 0);
+        }
+        return app('json')->success('获取平台收支明细成功');
+    }
+
     public function clear_platform_income_detail()
     {