重写平台明细日账单月账单

app/controller/api/cron/CommissionCron.php

@@ -1197,6 +1197,18 @@ where o.paid=1 and o.is_settlement=1 and settlement_time between '$this->startMo
             ->select()
             ->toArray();
         $group_order_map = array_column($group_order, null, 'group_order_id');
+        // 京豆
+        $jingdou_list = Db::name("user_sign_jingdou")
+            ->where('order_type', '=','0')
+            ->where('status', '=',1)
+            ->whereIn('order_id', array_column($store_order_list,'order_id'))
+            ->select()
+            ->toArray();
+        $jingdou_map = array_reduce($jingdou_list, function($result, $jingdou) {
+            // 根据 mer_id 进行分组
+            $result[$jingdou['order_id']][] = $jingdou;
+            return $result;
+        }, []);
         // // 查询分账信息
         // $store_split_order = Db::name('store_split_order')
         //     ->whereIn('group_order_id', array_column($group_order,'group_order_sn'))
@@ -1215,69 +1227,45 @@ where o.paid=1 and o.is_settlement=1 and settlement_time between '$this->startMo
                     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'];
+                    $money = 0.00;
+                    $vr = 0.00;
+                    $jd = 0.00;
+                    $fg = 0.00;
+                    if (!empty($store_order['fzone_pay_type'])) {
+                        $cost = bcsub($store_order['total_price'], $store_order['con_pri'] ?: 0.00, 2);
+                        if (in_array($store_order['fzone_pay_type'], ['a2', 'a3', 'b2', 'b4', 'b6'])) {
+                            $money = $cost;
+                        } else if (in_array($store_order['fzone_pay_type'], ['a1', 'b1', 'b5'])) {
+                            $vr = $cost;
+                        } else if (in_array($store_order['fzone_pay_type'], ['c1'])) {
+                            $fg = $cost;
+                        }
+                    }
+                    if (!empty($jingdou_map[$store_order['order_id']])) {
+                        $jd = array_sum(array_column($jingdou_map[$store_order['order_id']], 'number'));
                     }
 
                     Db::name('enterprise_platform_income_detail')
                         ->insert([
                             'mer_id' => $mer_id,
                             'uid' => $store_order['uid'],
-                            'title' => '自营订单入账',
+                            '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_time' => $store_order['pay_time'] ?: date('Y-m-d H:i:s'),
+                            'money' => $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'),
+                            'vr' => $vr,
+                            'jd' => $jd,
+                            'fg' => $fg
                         ]);
-                    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';
+            $start_time = '2025-01-22';
             for ($i = 0; $i < 1000; $i++) {
                 $day = date('Y-m-d', strtotime("+{$i} days", strtotime($start_time)));
                 if (strtotime($day) > time()) {
@@ -1287,56 +1275,12 @@ where o.paid=1 and o.is_settlement=1 and settlement_time between '$this->startMo
             }
         }
 
-        // 计算平台
-        //交易类型 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用户佣金提现
+        $mer_id = 0;
         $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) {
@@ -1357,214 +1301,6 @@ where o.paid=1 and o.is_settlement=1 and settlement_time between '$this->startMo
                     '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('获取平台收支明细成功');
     }