BroadbandSaler/app/DataApiNew/Helper/OrdersHelper.php

<?php
/*
 * @Description: 号卡订单管理
 * @Version: *
 * @Autor: lexuan
 * @Date: 2024-11-27 14:00:58
 * @LastEditors: lexuan
 * @LastEditTime: 2024-11-27 14:00:58
 */

namespace App\DataApiNew\Helper;

use App\DataApiNew\Models\Orders;
use App\Models\Pages;
use App\Models\SpoutExport;
use App\Models\SpoutImport;
use App\DataApiNew\Models\AdminUsers;
use App\DataApiNew\Models\HkOrderYjrecord;
use App\DataApiNew\Models\OrderSettRecord;
use App\DataApiNew\Models\PackageMemberLevelRoyalty;
use App\DataApiNew\Models\UserYjrecord;
use App\DataApiNew\Models\Packages;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Redis;
use Illuminate\Support\Facades\Validator;
use Vinkla\Hashids\Facades\Hashids;



class OrdersHelper
{
    // 查询条件
    public function whens($query, $request)
    {
        return $query
            ->when($request->filled('id'), fn ($q) => $q->where('id', $request->id))
            ->when($request->filled('order_no'), fn ($q) => $q->where('order_no', $request->order_no))
            ->when($request->filled('bus_order_id'), fn ($q) => $q->where('bus_order_id', $request->bus_order_id))
            ->when($request->filled('package_name'), fn ($q) => $q->where('package_name', 'like', "%$request->package_name%"))
            ->when($request->has('open_status'), fn ($q) => $q->where('open_status', $request->open_status))
            ->when($request->filled('operator_id'), fn ($q) => $q->where('operator_id', $request->operator_id))
            ->when($request->filled('id_card_name'), fn ($q) => $q->where('id_card_name', 'like', "%$request->id_card_name%"))
            ->when($request->filled('id_card'), fn ($q) => $q->where('id_card', $request->id_card))
            ->when($request->filled('mobile'), fn ($q) => $q->where('mobile', $request->mobile))
            ->when($request->filled('user_id'), fn ($q) => $q->where('user_id', $request->user_id))
            ->when($request->filled('express_no'), fn ($q) => $q->where('express_no', $request->express_no))
            ->when($request->filled('open_message'), fn ($q) => $q->where('open_message', $request->open_message))
            ->when($request->filled('created_at_start'), fn ($q) => $q->where('created_at', '>=', $request->created_at_start))
            ->when($request->filled('created_at_end'), fn ($q) => $q->where('created_at', '<=', $request->created_at_end))
            ->when($request->filled('sett_time_start'), fn ($q) => $q->where('sett_time', '>=', $request->sett_time_start))
            ->when($request->filled('sett_time_end'), fn ($q) => $q->where('sett_time', '<=', $request->sett_time_end));
    }

    // 查询列表
    public function select(Request $request)
    {
        $user_id = $request->user()->id;

        $page = new Pages($request, Orders::query());

        if (AdminUsers::isAdmin($user_id)) {
            // admin 查看全部
            $page->withRelations(['order_yjrecord']);

            $page->before(function ($query) use ($request) {
                $query->select(Orders::$selectFields);
                return $this->whens($query, $request);
            });
        } else {
            $request->validate([
                'type' => 'required|in:all,direct,saler',
            ]);

            // 按照type获取用户列表
            if ($request->type == 'all') {
                $user_list = AdminUsers::getChildrens($user_id);
            } elseif ($request->type == 'direct') {
                $user_list = [$user_id];
            } elseif ($request->type == 'saler') {
                $user_list = AdminUsers::getChildrensNotSelf($user_id);
            }

            // 只查看该用户的佣金记录
            $page->withRelations(['order_yjrecord' => function ($model) use ($user_id) {
                $model->where('user_id', $user_id)->select([
                    'order_no',
                    'user_id',
                    'user_yj'
                ]);
            }]);

            $page->before(function ($query) use ($request, $user_list, $user_id) {
                $query->select(Orders::$selectFields)
                    ->whereHas('order_yjrecord', function ($query) use ($user_id) {
                        $query->where('user_id', $user_id);
                    })
                    ->whereIn('user_id', $user_list);
                return $this->whens($query, $request);
            });
        }

        $result = $page->paginate();

        return $result;
    }

    // 导出
    public function export(Request $request)
    {
        $request->validate([
            'created_at_start' => 'required',
            'created_at_end' => 'required',
        ]);

        sys_log($request, '订单导出', '号卡订单管理');
        $user_id = $request->user()->id;
        $query = Orders::select(Orders::$selectFields);
        
        if (AdminUsers::isAdmin($user_id)) {
            $query->with(['order_yjrecord']);
            $query = $this->whens($query, $request);
        } else {
            $request->validate([
                'type' => 'required|in:all,direct,saler',
            ]);

            // 按照type获取用户列表
            if ($request->type == 'all') {
                $user_list = AdminUsers::getChildrens($user_id);
            } elseif ($request->type == 'direct') {
                $user_list = [$user_id];
            } elseif ($request->type == 'saler') {
                $user_list = AdminUsers::getChildrensNotSelf($user_id);
            }

            // 只查看该用户的佣金记录
            $query->with(['order_yjrecord' => function ($model) use ($user_id) {
                $model->where('user_id', $user_id)->select([
                    'order_no',
                    'user_id',
                    'user_yj'
                ]);
            }])->whereHas('order_yjrecord', function ($query) use ($user_id) {
                $query->where('user_id', $user_id);
            })
            ->whereIn('user_id', $user_list);
        }

        $query->orderBy('created_at', 'desc');
        $header = [
            '订单号' => 'order_no',
            '订单状态' => 'open_status',
            '开卡回文' => 'open_message',
            '身份证姓名' => 'id_card_name',
            '身份证号' => 'id_card',
            '开卡号码' => 'phonenum',
            '收件人' => 'contact',
            '收件电话' => 'mobile',
            '收件地址' => 'express_address',
            '物流单号' => 'express_no',
            '物流公司' => 'express_name',
            '身份证正面图' => 'idcard_front',
            '身份证反面图' => 'idcard_back',
            '手持身份证图' => 'user_with_idcard',
            '套餐id' => 'package_id',
            '外部订单号' => 'bus_order_id',
            '外部产品id' => 'out_package_id',
            '套餐名称' => 'package_name',
            '激活状态' => 'active_status',
            '激活时间' => 'active_time',
            '来源' => 'src',
            '结算状态' => 'sett_status',
            '结算时间' => 'sett_time',
            '套餐封面图' => 'package_cover_img',
            '运营商id' => 'operator_id',
            '分销者等级' => 'level',
            '运营商单号' => 'api_order_no',
            '首冲状态' => 'first_charge_status',
            '首充时间' => 'first_charge_time',
            '首充金额' => 'first_charge_amount',
            '供货商id' => 'supplier_id',
            '用户id' => 'user_id',
            '佣金' => 'order_yjrecord.0.user_yj',
        ];
        $getEnValue = $this->getEnValue();

        $excel = new SpoutExport($header);
        $excel->setQuery($query);
        $result = $excel->setEnum($getEnValue)
            ->setProcessStyle()
            ->spoutToExcel('号卡订单');
        return $result ? success($result['url']) : error();
    }

    // 导入
    public function import(Request $request)
    {
        $header = [
            '订单号' => 'order_no',
            '订单状态 0待开卡 1开卡中 2开卡成功 3开卡失败' => 'open_status',
            '开卡回文' => 'open_message',
            '身份证姓名' => 'id_card_name',
            '身份证号' => 'id_card',
            '开卡号码' => 'phonenum',
            '收件人' => 'contact',
            '收件电话' => 'mobile',
            '收件地址' => 'express_address',
            '物流单号' => 'express_no',
            '物流公司' => 'express_name',
            '身份证正面图' => 'idcard_front',
            '身份证反面图' => 'idcard_back',
            '手持身份证图' => 'user_with_idcard',
            '套餐id' => 'package_id',
            '外部订单号' => 'bus_order_id',
            '外部产品id' => 'out_package_id',
            '套餐名称' => 'package_name',
            '激活状态' => 'active_status',
            '激活时间' => 'active_time',
            '来源，0落地页，1小程序' => 'src',
            '祖级' => 'ppid',
            '结算状态' => 'sett_status',
            '结算时间' => 'sett_time',
            '套餐封面图' => 'package_cover_img',
            '分享方式 1：落地页 2：小店' => 'share_type',
            '运营商id' => 'operator_id',
            '代理ID' => 'agent_pro_id',
            '分销者等级 0：合伙人 1：一级代理 2：二级代理 3：三级代理' => 'level',
            '抖音Uid' => 'dy_uid',
            '运营商单号' => 'api_order_no',
            '是否选号' => 'select_status',
            '是否直接提交给局方' => 'direct_send_status',
            '是否校验' => 'is_valid',
            '前置校验编码' => 'valid_req_code',
            '首冲状态' => 'first_charge_status',
            '首充时间' => 'first_charge_time',
            '首充金额' => 'first_charge_amount',
            '是否接口佣金 0否 1是' => 'is_api_yj',
            '同步局方状态 0:未同步 1:已同步' => 'api_sync',
            '同步集客仓状态 0:未同步 1:已同步' => 'jkc_sync',
            '订单类型  0号卡，1宽带   整型' => 'order_type',
            '供货商id' => 'supplier_id',
            '校验' => 'api_valid',
            '意向单token' => 'intercept_msg',
            '用户id' => 'user_id',
        ];
        $getEnValue = $this->getEnValue();
        $SpoutImport = new SpoutImport($header);
        $dataList = $SpoutImport->setRequest($request)->getExcelData();
        return $dataList;
    }

    // 获取枚举值
    public function getEnValue()
    {
        $data = [
            'open_status' =>  Orders::$openStatus,
            'sett_status' =>  Orders::$settStatus,
            'first_charge_status' =>  Orders::$firstChargeStatus,
            'active_status' =>  Orders::$activeStatus,
            'src' =>  Orders::$src,
            'operator_id' =>  Orders::$operatorId,
        ];
        return $data;
    }

    // 查询一条
    public function find(Request $request)
    {
        $result = [];
        if($request->has('id')){
            $result = Orders::with(['order_yjrecord'])->where(['id' => $request->id])->select(Orders::$selectFields)->first();
        }

        if($request->has('order_no')){
            $result = Orders::with(['order_yjrecord'])->where(['order_no' => $request->order_no])->select(Orders::$selectFields)->first();
        }
        
        return success($result);
    }

    // 添加
    public function insert(Request $request)
    {
        $request->validate([
            'name' => 'required',
        ]);
        $result = Orders::create($request->all());
        if ($result) {
            return success();
        } else {
            return error();
        }
    }

    // 修改
    public function update(Request $request)
    {
        $request->validate([
            'id' => 'required|integer',
        ]);

        $result = Orders::where(['id' => $request->id])->update($request->all());
        if ($result) {
            return success();
        } else {
            return error();
        }
    }

    // 删除
    public function delete(Request $request)
    {
        $request->validate([
            'ids' => 'required',
        ]);
        $id_str = $request->ids;
        $arr = explode(",", $id_str);
        // 查询是否存在子数据
        // $count = Shop::whereIn('tm_id',$arr)->count();
        // if($count > 0){
        //     return ['code'=>0,'msg'=>"存在子数据，禁止删除"];
        // }
        $result = Orders::whereIn('id', $arr)->delete();
        if ($result) {
            return success();
        } else {
            return error();
        }
    }

    // 号卡订单提交
    public function hkOrderSubmit(Request $request)
    {
        $request->validate([
            'encrypted_data' => 'required',
            'encrypted_key' => 'required',
            'iv' => 'required',
        ]);

        $encrypted_data = $request['encrypted_data'];
        $encrypted_key = $request['encrypted_key'];
        $iv = $request['iv'];

        $request = UtilsHelper::aesRsaDecrypt($encrypted_data, $encrypted_key, $iv);
        if ($request) {
            Log::info("号卡提单解密", [$request]);
        } else {
            Log::error("号卡提单解密失败：" . $iv);
            return ['code' => 0, 'msg' => "解密失败"];
        }

        $request['src'] = Orders::SRC_LODDING;
        return $this->orderSubmit($request);
    }

    // 提单逻辑
    public function orderSubmit(array $request)
    {
        $validate = Validator::make($request, [
            'user_key' => 'required',
            'package_key' => 'required',
            'id_card_name' => 'required',
            'id_card' => 'required',
            'express_address' => 'required|max:200',
            'mobile' => 'required',
            'contact' => 'required|max:15',
        ]);

        if ($validate->fails()) {
            return response()->json(['code' => 0, 'msg' => '信息异常'], 400);
        }

        $user_key = Hashids::decode($request['user_key']);
        if (empty($user_key)) {
            return response()->json(['code' => 0, 'msg' => '用户信息异常'], 400);
        }

        $package_key = Hashids::decode($request['package_key']);
        if (empty($package_key)) {
            return response()->json(['code' => 0, 'msg' => '套餐信息异常'], 400);
        }

        $request['user_id'] = $user_key[0];
        $request['package_id'] = $package_key[0];

        $request['order_no'] = UtilsHelper::order_id();

        $order_no = UtilsHelper::order_id();
        $user_id = $request['user_id'];
        $id_card_name = $request['id_card_name'];
        $id_card = $request['id_card'];
        $express_address = $request['express_address'];
        $mobile = $request['mobile'];
        $contact = $request['contact'];
        $package_id = $request['package_id'];
        $idcard_front = $request['idcard_front'] ?? null; //身份证正面
        $idcard_back = $request['idcard_back'] ?? null; //身份证反面
        $user_with_idcard = $request['user_with_idcard'] ?? null; //手持身份证照
        $src = $request['src'] ?? Orders::SRC_LODDING;;
        $bus_order_id = $request['bus_order_id'] ?? null;

        $cacheKey = "order_put_" . $mobile;
        if (!Cache::add($cacheKey, 1, 5)) {
            return response()->json(['code' => 0, 'msg' => '请勿频繁请求'], 400);
        }

        // 检查订单
        $orders = Orders::where([
            'package_id' => $package_id,
            'id_card_name' => $id_card_name,
            'id_card' => $id_card,
            'mobile' => $mobile,
        ])->where('open_status', "!=", Orders::OPEN_STATUS_FAIL)->exists();
        if ($orders) return response()->json(['code' => 0, 'msg' => "该身份证已下过该套餐"], 400);

        list($status, $msg, $userYjRecord) = $this->orderCommission($user_id, $package_id, $order_no);
        if (!$status) return response()->json(['code' => 0, 'msg' => $msg], 400);

        $packageInfo = Packages::select(['id', 'name', 'yj', 'out_package_id','cover_img'])->where('id', $package_id)->first();
        $userInfo = AdminUsers::select(['id', 'name', 'mobile', 'agent_level'])->where('id', $user_id)->first();
        DB::beginTransaction();
        try {
            // 创建订单
            $orderData = [
                'user_id' => $user_id,
                'package_id' => $package_id,
                'order_no' => $order_no,
                'express_address' => $express_address,
                'mobile' => $mobile,
                'contact' => $contact,
                'id_card_name' => $id_card_name,
                'id_card' => $id_card,
                'idcard_front' => $idcard_front ?? null,
                'idcard_back' => $idcard_back,
                'user_with_idcard' => $user_with_idcard,
                'open_status' => Orders::OPEN_STATUS_WAIT,
                'original_yj' => $packageInfo->yj,
                'package_name' => $packageInfo->name,
                'out_package_id' => $packageInfo->out_package_id,
                'src' => $src,
                'bus_order_id' => $bus_order_id,
                'level' => $userInfo->agent_level,
                'package_cover_img' => $packageInfo->cover_img,
            ];
            Orders::create($orderData);

            // 记录佣金记录
            HkOrderYjrecord::insert($userYjRecord);

            DB::commit();

            return response()->json(['code' => 1, 'msg' => "下单成功"], 200);
        } catch (\Throwable $th) {
            DB::rollBack();
            Log::error("下单失败 $mobile :" . $th);
            return response()->json(['code' => 0, 'msg' => "下单失败"], 400);
        }
    }

    // 查单逻辑
    public function orderQuery($orderInfo, array $selectFields = [])
    {
        $order_no = $orderInfo['order_no'] ?? null;
        $bus_order_id = $orderInfo['distributor_order_no'] ?? null;
        $user_id = Hashids::decode($orderInfo['user_key'])[0] ?? null;

        if (empty($order_no) && empty($bus_order_id)) return response()->json(['code' => 0, 'msg' => "订单号和平台单号不能同时为空"], 400);
        if (empty($user_id)) return response()->json(['code' => 0, 'msg' => "用户信息异常"], 400);

        if ($order_no) {
            $result = Orders::select(empty($selectFields) ? Orders::$selectFields : $selectFields)->where('order_no', $order_no)->where('user_id', $user_id)->first();
            return response()->json(['code' => 1, 'msg' => "查单成功", 'data' => $result], 200);
        }

        if ($bus_order_id) {
            $result = Orders::select(empty($selectFields) ? Orders::$selectFields : $selectFields)->where('bus_order_id', $bus_order_id)->where('user_id', $user_id)->first();
            return response()->json(['code' => 1, 'msg' => "查单成功", 'data' => $result], 200);
        }

        return response()->json(['code' => 0, 'msg' => "未查询到订单信息"], 400);
    }

    // 计算订单佣金
    public function orderCommission($user_id, $package_id, $order_no)
    {
        $yj = (string)Packages::where('id', $package_id)->where('is_upload', 1)->value('yj');
        if (empty($yj)) return [false, '套餐已下架 ' . $package_id, []];
        $original_yj = $yj; // 原始佣金
        $created_at = now(); // 下单时间

        $userInfo = AdminUsers::select(['id', 'yj_type', 'yj_a', 'yj_p', 'parent_id', 'agent_level', 'member_level_id'])->with(['member_level'])->where('id', $user_id)->first();
        // 获取父用户的佣金信息
        $parentList = AdminUsers::getParents($user_id);
        $parentYjType = AdminUsers::with(['agent_package'])
            ->select(['id', 'yj_type', 'yj_a', 'yj_p', 'parent_id', 'agent_level'])
            ->whereIn('id', $parentList)
            ->orderBy('agent_level', 'ASC')
            ->get()
            ->keyBy('agent_level'); // 重置索引为用户id

        $orderYjRecord = []; // 订单佣金记录

        // 遍历所有上级用户
        foreach ($parentYjType as $user) {
            $now_user = $parentYjType[$user->agent_level]; // 当前用户
            $next_user = $parentYjType[$now_user->agent_level + 1] ?? 0;  // 下级用户

            $level_diff = $parentYjType[$userInfo->agent_level]->agent_level - ($now_user->agent_level ?? 0);  // 计算层级差值

            if (empty($next_user) && $now_user->id == end($parentList)) {
                // 订单所属用户
                if (empty($userInfo->member_level)) {
                    $royalty_yj = 0;
                } else {
                    // $royalty_yj = $userInfo->member_level->royalty_yj ?? 0; //头衔提成
                    $royalty_yj = PackageMemberLevelRoyalty::where('package_id',$package_id)->where('member_level_id', $userInfo->member_level_id)->value('royalty_yj') ?? 0; //头衔提成
                }

                $record = [
                    'order_no' => $order_no,
                    'user_id' => $now_user->id,
                    'from_user_id' => $user_id,
                    'original_yj' => $original_yj,
                    'parent_id' => $now_user->parent_id ?? 0,
                    'user_yj' => $yj,
                    'level_diff' => $level_diff,
                    'yj_type' => 0,
                    'yj_p' => 0,
                    'yj_a' => 0,
                    'created_at' => $created_at,
                    'royalty_yj' => $royalty_yj, //头衔提成
                ];
                $orderYjRecord[] = $record;
                break;
            }

            $yj_type = $next_user->yj_type ?? 0;  // 佣金类型
            $yj_p = (string)($next_user->yj_p ?? 0);  // 百分比
            $yj_a = (string)($next_user->yj_a ?? 0);  // 固定金额

            $agent_package = $next_user->agent_package->keyBy('package_id');  // 提前获取代理包裹数据并按package_id索引

            // 获取单品抽成
            if (isset($agent_package[$package_id]) && $agent_package[$package_id]['yj_type'] != 0) {
                $package_info = $agent_package[$package_id];
                $yj_type = $package_info['yj_type'];  // 佣金类型
                $yj_p = (string)$package_info['yj_p'];  // 百分比
                $yj_a = (string)$package_info['yj_a'];  // 固定金额
            }

            // 根据佣金类型进行计算
            if ($yj_type == 1) {  // 百分比计算
                $yj_p = bcdiv($yj_p, 100, 2);  // 百分比转化为小数
                $parent_yj = bcmul($yj, $yj_p, 2);  // 计算父级佣金
                $yj = bcsub($yj, $parent_yj, 2);  // 计算佣金
            } elseif ($yj_type == 2) {  // 固定金额计算
                $parent_yj = $yj_a;  // 父级佣金
                $yj = bcsub($yj, $parent_yj, 2);  // 计算佣金
            }

            // 如果佣金小于0，则设置为0
            if (bccomp($yj, '0', 2) < 0) {
                $yj = '0';  // 设置为 0
            }

            $record = [
                'order_no' => $order_no,
                'user_id' => $now_user->id,
                'from_user_id' => $user_id,
                'original_yj' => $original_yj,
                'parent_id' => $now_user->parent_id ?? 0,
                'user_yj' => $parent_yj,
                'level_diff' => $level_diff,
                'yj_type' => $yj_type,
                'yj_p' => $yj_p,
                'yj_a' => $yj_a,
                'created_at' => $created_at,
                'royalty_yj' => 0, //头衔提成
            ];

            $orderYjRecord[] = $record; // 记录佣金记录
        }

        return [true, 'success', $orderYjRecord];
    }

    // 订单结算逻辑
    public function hkOrderSettlement($order_no)
    {
        if (empty($order_no)) return [false, '订单号不能为空', []];

        $order = Orders::select([
            'id',
            'user_id',
            'order_no',
            'sett_status',
            'package_id',
        ])
            ->with(['order_yjrecord'])
            ->where('order_no', $order_no)->first();

        if (empty($order)) return [false, '订单不存在', []];

        // if ($order->sett_status == 1) return [false, '订单已结算', []];

        if (empty($order->order_yjrecord)) return [false, '订单佣金记录不存在', []];

        DB::beginTransaction();
        try {
            foreach ($order->order_yjrecord as $value) {
                // 计算佣金
                if($value['user_id'] == $value['from_user_id']){
                    $type = UserYjrecord::TYPE_DIRECT;
                }else{
                    $type = UserYjrecord::TYPE_DISTRIBUTION;
                }
                list($status, $msg, $data) = (new UserYjrecord())->recharge([
                    'user_id' => $value['user_id'],
                    'order_no' => $value['order_no'],
                    'status' => UserYjrecord::STATUS_ADD,
                    'type' => $type,
                    'source' => '号卡订单结算',
                    'yj' => $value['user_yj'],
                    'order_yj' => $value['original_yj'],
                ]);
                if (!$status) {
                    DB::rollBack();
                    return [false, $msg, []];
                }

                // 计算头衔提成
                if ($value['royalty_yj'] > 0) {
                    list($status, $msg, $data) = (new UserYjrecord())->recharge([
                        'user_id' => $value['user_id'],
                        'order_no' => $value['order_no'],
                        'status' => UserYjrecord::STATUS_ADD,
                        'type' => UserYjrecord::TYPE_ROYALTY,
                        'source' => '号卡订单结算',
                        'yj' => $value['royalty_yj'],
                        'order_yj' => $value['original_yj'],
                    ]);
                    if (!$status) {
                        DB::rollBack();
                        return [false, $msg, []];
                    }
                }
            }

            Orders::where('order_no', $order_no)->update(['sett_status' => 1, 'sett_time' => now()]);
            DB::commit();
            return [true, 'success', []];
        } catch (\Throwable $th) {
            DB::rollBack();
            return [false, $th->getMessage(), []];
        }
    }

    // 批量结算
    public function batchOrderSettle($id)
    {
        $OrderSettRecordInfo = OrderSettRecord::find($id);
        $OrderSettRecordInfo->update(['status' => 1]);

        if (empty($OrderSettRecordInfo)) {
            $OrderSettRecordInfo->update(['status' => 3]);
            return [false, '结算记录不存在', []];
        }

        if (empty($OrderSettRecordInfo->put_file)) {
            $OrderSettRecordInfo->update(['status' => 3]);
            return [false, '结算文件不存在', []];
        }

        $put_file = public_path($OrderSettRecordInfo->put_file);
        if (!file_exists($put_file)) {
            $OrderSettRecordInfo->update(['status' => 3]);
            return [false, '结算文件不存在', []];
        }

        // 读取表格信息
        $SpoutImport = new SpoutImport([]);
        $dataList = $SpoutImport->setFilePath($put_file)->getExcelData();
        if (empty($dataList)) {
            $OrderSettRecordInfo->update(['status' => 3]);
            return [false, '结算文件内容为空', []];
        }

        try {
            $header = $SpoutImport->getFirstRowContent();
            $header[] = "执行结果";

            foreach ($dataList as &$value) {
                list($status, $msg, $data) = $this->hkOrderSettlement($value[0]);
                if ($status) {
                    $value[] = "执行成功";
                } else {
                    $value[] = "执行失败：" . $msg;
                }
            }

            // 导出执行结果
            $SpoutImport = new SpoutExport($header);
            list($status, $msg, $result) = $SpoutImport
                ->setData($dataList)
                ->setProcessStyle()
                ->arrayToExcel("sttle_out_" . uniqid() . '_' . time(), public_path('csv/batch_order_settle/out/'));

            if ($status) {
                $OrderSettRecordInfo->update(['out_file' => $result['path'], 'status' => 2]);
            } else {
                $OrderSettRecordInfo->update(['status' => 3, 'remark' => $msg]);
            }
        } catch (\Throwable $th) {
            $OrderSettRecordInfo->update(['status' => 3, 'remark' => $th->getMessage()]);
        }
    }

    // 手机号订单查询
    public function hkOrderQuery(Request $request)
    {
        $request->validate([
            'mobile' => 'required',
        ]);
        $mobile = $request->input('mobile'); 
        $order = Orders::select([
            'order_no',
            'open_status',
            'id_card_name',
            'id_card',
            'phonenum',
            'contact',
            'mobile',
            'express_address',
            'created_at',
            'package_name',
            'active_status',
            'open_status',
            'package_cover_img',
        ])
        ->when($request->filled('open_status'), fn ($q) => $q->where('open_status', $request->open_status))
        ->where('mobile', $mobile);

        $pages = new Pages($request, $order);

        return $pages->paginate();
    }

}