待完成日账单月账单

app/controller/api/cron/CommissionCron.php

@@ -554,22 +554,6 @@ where o.paid=1 and o.is_settlement=1 and settlement_time between '$this->startMo
     //定时任务写日账单，月账单
     public function cron($day,$mer_id=496)
     {
-        //        $day=date('Y-m-d', strtotime('-1 days'));
-        //        $enterprise_bill_item=[];
-        //        $order= $order_query->select();
-        //        foreach ($order as $v) {
-        //            $arr = [];
-        //            $arr['mer_id'] = $mer_id;
-        //            $arr['transaction_time'] = $v['pay_time'];
-        //            $arr['money'] = $v['pay_price'];
-        //            $arr['uid'] = $v['uid'];
-        //            $arr['order_sn'] = $v['order_sn'];
-        //            $arr['type'] = 1;
-        //            $enterprise_bill_item[] = $arr;
-        //        }
-        //        if ($enterprise_bill_item) {
-        //            Db::name('enterprise_bill_item')->insertAll($enterprise_bill_item);
-        //        }
 
         Db::name('enterprise_day_bill')->where('mer_id', $mer_id)->where('day', $day)->delete();
 
@@ -1154,7 +1138,16 @@ 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()
+    /**
+     * 生成平台收支明细，从而生成 日账单 月账单
+     * 平台收入：线上订单表、线下订单表、话费表
+     * 平台支出：用户提现、商户分账
+     * @return mixed
+     * @throws DataNotFoundException
+     * @throws DbException
+     * @throws ModelNotFoundException
+     */
+    public function platform_income_detail_get_new($start_time, $end_time)
     {
 
         // 1、获取所有 商户 商户名称非空， 状态为正常、商户状态为开启
@@ -1198,29 +1191,62 @@ where o.paid=1 and o.is_settlement=1 and settlement_time between '$this->startMo
             ->toArray();
         $group_order_map = array_column($group_order, null, 'group_order_id');
         // 京豆
-        $jingdou_list = Db::name("user_sign_jingdou")
+        $jingdou_list_by_online = 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) {
+        $jingdou_map_by_online = array_reduce($jingdou_list_by_online, function($result, $jingdou_by_online) {
             // 根据 mer_id 进行分组
-            $result[$jingdou['order_id']][] = $jingdou;
+            $result[$jingdou_by_online['order_id']][] = $jingdou_by_online;
             return $result;
         }, []);
-        // // 查询分账信息
-        // $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');
+
+        // 线下扫码
+        $order_merchant_list = Db::name('order_merchant')
+            ->whereIn('mer_id', $merchant_list)
+            ->where('status', 1) // '0待支付，1已支付，2申请退款，3退款完成 5 已失效',
+            // ->where('arrive', 1) // 是否到账，系统应该是没对该字段进行维护 全是0
+            ->where('paid', 1)
+            ->where('binds', 0)
+            ->whereNotNull('pay_time')
+            ->order('id', 'desc')
+            ->select()
+            ->toArray();
+        $order_merchant_map = array_reduce($order_merchant_list, function($result, $order) {
+            // 根据 mer_id 进行分组
+            $result[$order['mer_id']][] = $order;
+            return $result;
+        }, []);
+        // 京豆
+        $jingdou_list_by_offline = Db::name("user_sign_jingdou")
+            ->where('order_type', '=','10')
+            ->where('status', '=',1)
+            ->whereIn('order_id', array_column($order_merchant_list,'id'))
+            ->select()
+            ->toArray();
+        $jingdou_map_by_offline = array_reduce($jingdou_list_by_offline, function($result, $jingdou_by_offline) {
+            // 根据 mer_id 进行分组
+            $result[$jingdou_by_offline['order_id']][] = $jingdou_by_offline;
+            return $result;
+        }, []);
+        // 话费
+        $order_huafei_list = Db::name('order_huafei')
+            ->where('status', 2) // '订单状态 0 待支付 1 已付 充值中 2充值成功 3充值失败 需要退款 4退款成功 5已超时 6待充值 7 已匹配 8已存单 9 已取消 10返销 11部分到账 12取消中'
+            // ->where('arrive', 1) // 是否到账，系统应该是没对该字段进行维护 全是0
+            // ->whereNotNull('finish_time')
+            ->order('order_huafei_id', 'desc')
+            ->select()
+            ->toArray();
+
 
         // 4、循环所有商户ID
         /** @var OrderMerchantRepository $OrderMerchantRepository */
         $OrderMerchantRepository = app()->make(OrderMerchantRepository::class);
         foreach ($merchant_list as $mer_id) {
+            // 线上订单
+            $online_data_list = [];
             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)) {
@@ -1231,8 +1257,9 @@ where o.paid=1 and o.is_settlement=1 and settlement_time between '$this->startMo
                     $vr = 0.00;
                     $jd = 0.00;
                     $fg = 0.00;
+                    $fenrun = $store_order['con_pri'] ?: 0.00;
                     if (!empty($store_order['fzone_pay_type'])) {
-                        $cost = bcsub($store_order['total_price'], $store_order['con_pri'] ?: 0.00, 2);
+                        $cost = bcsub($store_order['total_price'], $fenrun, 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'])) {
@@ -1241,12 +1268,12 @@ where o.paid=1 and o.is_settlement=1 and settlement_time between '$this->startMo
                             $fg = $cost;
                         }
                     }
-                    if (!empty($jingdou_map[$store_order['order_id']])) {
-                        $jd = array_sum(array_column($jingdou_map[$store_order['order_id']], 'number'));
+                    if (!empty($jingdou_map_by_online[$store_order['order_id']])) {
+                        $jd = array_sum(array_column($jingdou_map_by_online[$store_order['order_id']], 'number'));
                     }
 
-                    Db::name('enterprise_platform_income_detail')
-                        ->insert([
+
+                    $online_data_list[] = [
                             'mer_id' => $mer_id,
                             'uid' => $store_order['uid'],
                             'title' => '订单入账',
@@ -1254,17 +1281,66 @@ where o.paid=1 and o.is_settlement=1 and settlement_time between '$this->startMo
                             'deal_time' => $store_order['pay_time'] ?: date('Y-m-d H:i:s'),
                             'money' => $money,
                             'deal_type' => 1,
+                            'order_type' => 0,
                             '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
-                        ]);
+                            'jingdou' => $jd,
+                            'fg' => $fg,
+                            'fenrun' => $fenrun, // 让利
+                        ];
+                }
+            }
+            if (!empty($online_data_list)) {
+                Db::name('enterprise_platform_income_detail')
+                    ->insertAll($online_data_list);
+            }
+
+            // 线下订单 0平台1多多进宝2唯品会3苏宁易购4网易考拉5淘宝客6京东联盟7饿了么8线上 9话费 10 线下
+            $offline_data_list = [];
+            foreach ($order_merchant_map[$mer_id] as $order_merchant) {
+                // 判断该笔订单是否已 存在 平台收支明细表 的记录中
+                if (!in_array('1' . $order_merchant['uid'] . $order_merchant['out_trade_no'] . $order_merchant['order_id'] . '0' . $mer_id, $unique_list)) {
+                    // 经过和领导确认，入账 金额为 订单金额 - 让利金额 - 手续费
+
+                    $money = $order_merchant['mer_money'] ?: 0.00;
+                    $vr = 0.00;
+                    $jd = 0.00;
+                    $fg = 0.00;
+                    $fenrun = $order_merchant['mer_fanyong'] ?: 0.00;
+                    if (!empty($jingdou_map_by_offline[$order_merchant['id']])) {
+                        $jd = array_sum(array_column($jingdou_map_by_offline[$order_merchant['id']], 'number'));
+                    }
+
+                    $offline_data_list[] = [
+                            'mer_id' => $mer_id,
+                            'uid' => $order_merchant['uid'],
+                            'title' => '订单入账',
+                            'deal_order_sn' => $OrderMerchantRepository->getNewOrderId('jy2'),
+                            'deal_time' => $order_merchant['pay_time'] ?: date('Y-m-d H:i:s'),
+                            'money' => $money,
+                            'deal_type' => 1,
+                            'order_type' => 10,
+                            'order_id' => $order_merchant['id'],
+                            'order_sn' => $order_merchant['out_trade_no'],
+                            'user_extra_id' => '',
+                            'pm' => 1,
+                            'create_time' => date('Y-m-d H:i:s'),
+                            'vr' => $vr,
+                            'jingdou' => $jd,
+                            'fg' => $fg,
+                            'fenrun' => $fenrun,
+                        ];
                 }
             }
+            if (!empty($offline_data_list)) {
+                Db::name('enterprise_platform_income_detail')
+                    ->insertAll($offline_data_list);
+            }
+
             $start_time = '2025-01-22';
             for ($i = 0; $i < 1000; $i++) {
                 $day = date('Y-m-d', strtotime("+{$i} days", strtotime($start_time)));
@@ -1275,8 +1351,38 @@ where o.paid=1 and o.is_settlement=1 and settlement_time between '$this->startMo
             }
         }
 
-        //5用户佣金提现
         $mer_id = 0;
+
+        $order_huafei_data_list = [];
+        foreach ($order_huafei_list as $order_huafei) {
+            if (!in_array('1' . $order_huafei['uid'] . $order_huafei['order_sn'] . $order_huafei['order_huafei_id'] . '0' . $mer_id, $unique_list)) {
+                $order_huafei_data_list[] = [
+                    'mer_id' => $mer_id,
+                    'uid' => $order_huafei['uid'],
+                    'title' => '订单入账',
+                    'deal_order_sn' => $OrderMerchantRepository->getNewOrderId('jy2'),
+                    'deal_time' => $order_huafei['finish_time'] ?: date('Y-m-d H:i:s'),
+                    'money' => $order_huafei['cost_price'],
+                    'deal_type' => 1,
+                    'order_type' => 9,
+                    'order_id' => $order_huafei['order_huafei_id'],
+                    'order_sn' => $order_huafei['order_sn'],
+                    'user_extra_id' => '',
+                    'pm' => 1,
+                    'create_time' => date('Y-m-d H:i:s'),
+                    'vr' => 0.00,
+                    'jingdou' => 0.00,
+                    'fg' => 0.00,
+                    'fenrun' => $order_huafei['fanli_price'] // 让利
+                ];
+            }
+        }
+        if (!empty($order_huafei_data_list)) {
+            Db::name('enterprise_platform_income_detail')
+                ->insertAll($order_huafei_data_list);
+        }
+
+        // 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)
@@ -1301,9 +1407,160 @@ where o.paid=1 and o.is_settlement=1 and settlement_time between '$this->startMo
                     'create_time'   => date('Y-m-d H:i:s'),
                 ]);
         }
+
+        // // 查询分账信息
+        // $store_split_order = Db::name('store_split_order')
+        //     ->where('status', 1)
+        //     ->select()
+        //     ->toArray();
+        // $store_split_order_map = array_column($store_split_order, null, 'group_order_id');
+        // 待完善
+
         return app('json')->success('获取平台收支明细成功');
     }
 
+    public function set_enterprise_bill($start_time, $end_time)
+    {
+        // 1、查出 时间范围内的 平台收支明细
+        $enterprise_platform_income_detail_list = Db::name('enterprise_platform_income_detail')
+            // deal_time格式 2025-03-10 10:44:34
+            ->whereBetween('deal_time', [$start_time, $end_time])
+            ->select()
+            ->toArray();
+
+        // 2、根据时间进行分组
+        $enterprise_platform_income_detail_map = array_reduce($enterprise_platform_income_detail_list, function ($result, $enterprise_platform_income_detail) {
+            // 根据 mer_id 进行分组
+            $result[date('Y-m-d', strtotime($enterprise_platform_income_detail['deal_time']))][] = $enterprise_platform_income_detail;
+            return $result;
+        }, []);
+
+        // 3、循环计算平台当天内的 收支流水
+        foreach ($enterprise_platform_income_detail_map as $day => $enterprise_platform_income_detail_list_by_day) {
+            $day_bill_map = [];
+            // 平台的日账单
+            $day_bill_map[$day . '-0'] = [
+                'mer_id' => 0,
+                'day' => $day,
+                'flow' => 0.00,
+                'expenditure' => 0.00,
+                'balance' => 0.00,
+                'jingdou' => 0.00,
+                'fenrun' => 0.00,
+                'vr' => 0.00,
+                'jd' => 0.00,
+                'fg' => 0.00
+            ];
+            foreach ($enterprise_platform_income_detail_list_by_day as $enterprise_platform_income_detail) {
+                /**
+                 * `id` int(10) NOT NULL AUTO_INCREMENT,
+                 * `mer_id` int(11) NOT NULL DEFAULT '0' COMMENT '商户id',
+                 * `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+                 * `day` date DEFAULT NULL COMMENT '日期',
+                 * `flow` double(11,2) NOT NULL DEFAULT '0.00' COMMENT '订单流水',
+                 * `expenditure` double(11,2) NOT NULL DEFAULT '0.00' COMMENT '支出金额',
+                 * `accounting` double(11,2) NOT NULL DEFAULT '0.00' COMMENT '入账金额',
+                 * `balance` double(11,2) NOT NULL DEFAULT '0.00' COMMENT '结余',
+                 * `jingdou` double(11,2) NOT NULL DEFAULT '0.00' COMMENT '京豆',
+                 * `fenrun` double(11,2) NOT NULL DEFAULT '0.00' COMMENT '分润',
+                 * `vr` decimal(12,2) DEFAULT NULL COMMENT 'VR',
+                 * `jd` decimal(12,2) DEFAULT NULL COMMENT '京豆',
+                 * `fg` decimal(12,2) DEFAULT NULL COMMENT '复购金',
+                 */
+                if (!isset($day_bill_map[$day . '-' . $enterprise_platform_income_detail['mer_id']])) {
+                    $day_bill_map[$day . '-' . $enterprise_platform_income_detail['mer_id']] = [
+                        'mer_id' => $enterprise_platform_income_detail['mer_id'],
+                        'day' => $day,
+                        'flow' => 0.00,
+                        'expenditure' => 0.00,
+                        'balance' => 0.00,
+                        'jingdou' => 0.00,
+                        'fenrun' => 0.00,
+                        'vr' => 0.00,
+                        'jd' => 0.00,
+                        'fg' => 0.00
+                    ];
+                }
+                if($enterprise_platform_income_detail['pm'] == 1) {
+                    // 订单总价
+                    $day_bill_map[$day . '-' . $enterprise_platform_income_detail['mer_id']]['flow'] += ($enterprise_platform_income_detail['money'] + $enterprise_platform_income_detail['vr'] + $enterprise_platform_income_detail['fg'] + $enterprise_platform_income_detail['fenrun']);
+                    if ($enterprise_platform_income_detail['mer_id'] != 0) {
+                        $day_bill_map[$day . '-0']['flow'] += ($enterprise_platform_income_detail['money'] + $enterprise_platform_income_detail['vr'] + $enterprise_platform_income_detail['fg'] + $enterprise_platform_income_detail['fenrun']);
+                    }
+                    // 入账现金
+                    $day_bill_map[$day . '-' . $enterprise_platform_income_detail['mer_id']]['accounting'] += $enterprise_platform_income_detail['money'];
+                    if ($enterprise_platform_income_detail['mer_id'] != 0) {
+                        $day_bill_map[$day . '-0']['accounting'] += $enterprise_platform_income_detail['money'];
+                    }
+                    // VR
+                    $day_bill_map[$day . '-' . $enterprise_platform_income_detail['mer_id']]['vr'] += $enterprise_platform_income_detail['vr'];
+                    if ($enterprise_platform_income_detail['mer_id'] != 0) {
+                        $day_bill_map[$day . '-0']['vr'] += $enterprise_platform_income_detail['vr'];
+                    }
+                    // 复购
+                    $day_bill_map[$day . '-' . $enterprise_platform_income_detail['mer_id']]['fg'] += $enterprise_platform_income_detail['fg'];
+                    if ($enterprise_platform_income_detail['mer_id'] != 0) {
+                        $day_bill_map[$day . '-0']['fg'] += $enterprise_platform_income_detail['fg'];
+                    }
+                    // 分润
+                    $day_bill_map[$day . '-' . $enterprise_platform_income_detail['mer_id']]['fenrun'] += $enterprise_platform_income_detail['fenrun'];
+                    if ($enterprise_platform_income_detail['mer_id'] != 0) {
+                        $day_bill_map[$day . '-0']['fenrun'] += $enterprise_platform_income_detail['fenrun'];
+                    }
+                    // 获得的京豆
+                    $day_bill_map[$day . '-' . $enterprise_platform_income_detail['mer_id']]['jingdou'] += $enterprise_platform_income_detail['jingdou'];
+                    if ($enterprise_platform_income_detail['mer_id'] != 0) {
+                        $day_bill_map[$day . '-0']['jingdou'] += $enterprise_platform_income_detail['jingdou'];
+                    }
+                    // 现金结余
+                    $day_bill_map[$day . '-' . $enterprise_platform_income_detail['mer_id']]['balance'] += $enterprise_platform_income_detail['money'];
+                    if ($enterprise_platform_income_detail['mer_id'] != 0) {
+                        $day_bill_map[$day . '-0']['balance'] += $enterprise_platform_income_detail['money'];
+                    }
+                }
+                if($enterprise_platform_income_detail['pm'] == 0) {
+
+                    // 支出现金
+                    $day_bill_map[$day . '-' . $enterprise_platform_income_detail['mer_id']]['expenditure'] += $enterprise_platform_income_detail['money'];
+                    if ($enterprise_platform_income_detail['mer_id'] != 0) {
+                        $day_bill_map[$day . '-0']['expenditure'] += $enterprise_platform_income_detail['money'];
+                    }
+                    // VR
+                    $day_bill_map[$day . '-' . $enterprise_platform_income_detail['mer_id']]['vr'] -= $enterprise_platform_income_detail['vr'];
+                    if ($enterprise_platform_income_detail['mer_id'] != 0) {
+                        $day_bill_map[$day . '-0']['vr'] -= $enterprise_platform_income_detail['vr'];
+                    }
+                    // 复购
+                    $day_bill_map[$day . '-' . $enterprise_platform_income_detail['mer_id']]['fg'] -= $enterprise_platform_income_detail['fg'];
+                    if ($enterprise_platform_income_detail['mer_id'] != 0) {
+                        $day_bill_map[$day . '-0']['fg'] -= $enterprise_platform_income_detail['fg'];
+                    }
+                    // 分润
+                    $day_bill_map[$day . '-' . $enterprise_platform_income_detail['mer_id']]['fenrun'] -= $enterprise_platform_income_detail['fenrun'];
+                    if ($enterprise_platform_income_detail['mer_id'] != 0) {
+                        $day_bill_map[$day . '-0']['fenrun'] -= $enterprise_platform_income_detail['fenrun'];
+                    }
+                    // 获得的京豆
+                    $day_bill_map[$day . '-' . $enterprise_platform_income_detail['mer_id']]['jingdou'] -= $enterprise_platform_income_detail['jingdou'];
+                    if ($enterprise_platform_income_detail['mer_id'] != 0) {
+                        $day_bill_map[$day . '-0']['jingdou'] -= $enterprise_platform_income_detail['jingdou'];
+                    }
+                    // 现金结余
+                    $day_bill_map[$day . '-' . $enterprise_platform_income_detail['mer_id']]['balance'] -= $enterprise_platform_income_detail['money'];
+                    if ($enterprise_platform_income_detail['mer_id'] != 0) {
+                        $day_bill_map[$day . '-0']['balance'] -= $enterprise_platform_income_detail['money'];
+                    }
+                }
+
+            }
+
+        }
+        // 3.1 再根据每天内的商户分组
+
+        // 4、根据开始时间，的上一个月，到当前时间的上一个月，查看是否有 月统计数据
+        // 4.1补齐月数据
+    }
+
     public function clear_platform_income_detail()
     {