<?php

namespace app\api\controller;

use app\common\library\CommissionService;
use app\common\library\FinanceConfigService;
use app\common\library\InvoiceService;
use app\common\library\OrderStatus;
use think\Db;

/**
 * 商家端（企业账号）：入驻 / 资料 / 账单 / 开票 / 批量下单归属
 */
class Merchant extends Base
{
    /**
     * 商家入驻 / 重新提交
     * @ApiMethod (POST)
     */
    public function apply()
    {
        $data = [
            'name'            => trim((string)$this->request->post('name')),
            'license_no'      => trim((string)$this->request->post('license_no')),
            'license_image'   => (string)$this->request->post('license_image'),
            'legal_person'    => trim((string)$this->request->post('legal_person')),
            'contact'         => trim((string)$this->request->post('contact')),
            'mobile'          => trim((string)$this->request->post('mobile')),
            'province'        => trim((string)$this->request->post('province')),
            'city'            => trim((string)$this->request->post('city')),
            'district'        => trim((string)$this->request->post('district')),
            'address'         => trim((string)$this->request->post('address')),
            'invoice_title'   => trim((string)$this->request->post('invoice_title')),
            'invoice_tax_no'  => trim((string)$this->request->post('invoice_tax_no')),
            'invoice_bank'    => trim((string)$this->request->post('invoice_bank')),
            'invoice_account' => trim((string)$this->request->post('invoice_account')),
            'settle_type'     => $this->request->post('settle_type', 'prepay'),
        ];

        if ($data['name'] === '' || $data['license_no'] === '' || $data['contact'] === '' || $data['mobile'] === '') {
            $this->error('请填写企业名称、统一社会信用代码、联系人和电话');
        }
        if (!preg_match('/^1\d{10}$/', $data['mobile'])) {
            $this->error('联系电话格式不正确');
        }
        if (!in_array($data['settle_type'], ['prepay', 'monthly'], true)) {
            $data['settle_type'] = 'prepay';
        }

        // 已被商家绑定的关联账号，企业资料由主账号维护
        if (Db::name('merchant_member')->where('user_id', $this->uid())->find()) {
            $this->error('当前账号已绑定商家，企业资料请由主账号维护');
        }

        $exist = Db::name('merchant')->where('user_id', $this->uid())->find();
        if ($exist && $exist['verify_status'] === 'pass') {
            $this->error('您已是认证商家，无需重复入驻');
        }

        $save = array_merge($data, [
            'verify_status' => 'pending',
            'audit_msg'     => '',
            'updatetime'    => time(),
        ]);

        if ($exist) {
            Db::name('merchant')->where('id', $exist['id'])->update($save);
            $id = (int)$exist['id'];
        } else {
            $save['user_id'] = $this->uid();
            $save['createtime'] = time();
            $id = Db::name('merchant')->insertGetId($save);
        }

        $this->success('提交成功，请等待审核', ['merchant_id' => $id]);
    }

    /**
     * 商家档案与经营数据
     */
    public function info()
    {
        $merchant = $this->merchantInfo();
        if (!$merchant) {
            $this->success('未入驻', ['applied' => false]);
            return;
        }

        $uids = $this->merchantUserIds($merchant);
        $isOwner = (int)$merchant['user_id'] === $this->uid();
        $orderCount = (int)Db::name('order')->where('user_id', 'in', $uids)->where('pay_status', 1)->where('status', '<>', OrderStatus::CANCELLED)->count();
        $quota = InvoiceService::getQuotaSummary($this->uid());
        $totalAmount = (float)$quota['paid_amount'];
        $invoiced = (float)$quota['used_amount'];

        $this->success('', [
            'applied'  => true,
            'is_owner' => $isOwner,
            'role'     => $isOwner ? 'owner' : 'member',
            'merchant' => [
                'id'                  => (int)$merchant['id'],
                'name'                => $merchant['name'],
                'license_no'          => $merchant['license_no'],
                'legal_person'        => $merchant['legal_person'],
                'contact'             => $merchant['contact'],
                'mobile'              => $merchant['mobile'],
                'province'            => (string)$merchant['province'],
                'city'                => (string)$merchant['city'],
                'district'            => (string)$merchant['district'],
                'detail_address'      => (string)$merchant['address'],
                'address'             => $merchant['province'] . $merchant['city'] . $merchant['district'] . $merchant['address'],
                'invoice_title'       => $merchant['invoice_title'],
                'invoice_tax_no'      => $merchant['invoice_tax_no'],
                'invoice_bank'        => $merchant['invoice_bank'],
                'invoice_account'     => $merchant['invoice_account'],
                'settle_type'         => $merchant['settle_type'],
                'verify_status'       => $merchant['verify_status'],
                'audit_msg'           => $merchant['audit_msg'],
                'role'                => $isOwner ? 'owner' : 'member',
                'is_owner'            => $isOwner,
                'owner_user_id'       => (int)$merchant['user_id'],
                'member_count'        => max(0, count($uids) - 1),
                'order_count'         => $orderCount,
                'total_amount'        => round($totalAmount, 2),
                'invoiced_amount'     => round($invoiced, 2),
                'issued_amount'       => round((float)$quota['issued_amount'], 2),
                'wait_invoice_amount' => round((float)$quota['wait_amount'], 2),
                'invoiceable'         => round((float)$quota['available'], 2),
            ],
        ]);
    }

    /**
     * 维护资料（联系人 / 地址 / 开票信息）
     * @ApiMethod (POST)
     */
    public function update()
    {
        $merchant = $this->requireMerchant();
        $this->requireMerchantOwner($merchant);
        $fields = ['contact', 'mobile', 'province', 'city', 'district', 'address',
            'invoice_title', 'invoice_tax_no', 'invoice_bank', 'invoice_account'];
        $data = ['updatetime' => time()];
        foreach ($fields as $f) {
            $v = $this->request->post($f, null);
            if ($v !== null) {
                $data[$f] = trim((string)$v);
            }
        }
        if (isset($data['mobile']) && $data['mobile'] !== '' && !preg_match('/^1\d{10}$/', $data['mobile'])) {
            $this->error('联系电话格式不正确');
        }
        Db::name('merchant')->where('id', $merchant['id'])->update($data);

        // 若维护了商家开票资料，同步刷新关联的商家默认发票抬头
        if (isset($data['invoice_title']) || isset($data['invoice_tax_no']) || isset($data['invoice_bank']) || isset($data['invoice_account'])) {
            $latest = Db::name('merchant')->where('id', $merchant['id'])->find();
            if ($latest) {
                $syncFields = ['updatetime' => time()];
                if (!empty($latest['invoice_title'])) $syncFields['title'] = $latest['invoice_title'];
                if (!empty($latest['invoice_tax_no'])) $syncFields['tax_no'] = strtoupper($latest['invoice_tax_no']);
                if (isset($data['invoice_bank'])) $syncFields['bank_name'] = $latest['invoice_bank'];
                if (isset($data['invoice_account'])) $syncFields['bank_account'] = $latest['invoice_account'];
                Db::name('invoice_title')
                    ->where('merchant_id', (int)$merchant['id'])
                    ->where('title_type', 'enterprise')
                    ->update($syncFields);
            }
        }

        $this->success('已保存');
    }

    /**
     * 账单中心：按月汇总 + 近期订单
     */
    public function bills()
    {
        $merchant = $this->requireMerchant();
        $uids = $this->merchantUserIds($merchant);

        $months = Db::name('order')
            ->field("FROM_UNIXTIME(createtime,'%Y-%m') as month, count(*) as cnt, sum(pay_amount) as amount")
            ->where('user_id', 'in', $uids)->where('pay_status', 1)
            ->group('month')->order('month desc')->limit(12)->select();
        foreach ($months as &$m) {
            $m['amount'] = round((float)$m['amount'], 2);
            $m['cnt'] = (int)$m['cnt'];
        }
        unset($m);

        $orders = Db::name('order')->field('id,order_no,service_name,pay_amount,status,createtime')
            ->where('user_id', 'in', $uids)->order('id desc')->limit(20)->select();
        foreach ($orders as &$o) {
            $o['pay_amount'] = (float)$o['pay_amount'];
            $o['status_text'] = \app\common\library\OrderStatus::label($o['status']);
            $o['time_text'] = date('Y-m-d H:i', (int)$o['createtime']);
        }
        unset($o);

        $this->success('', ['months' => $months, 'orders' => $orders]);
    }

    /**
     * 企业订单：主账号 + 关联账号的全部订单
     */
    public function orders()
    {
        $merchant = $this->requireMerchant();
        $uids = $this->merchantUserIds($merchant);
        $status = $this->request->param('status', 'all');
        $keyword = trim((string)$this->request->param('keyword', ''));
        $memberUid = (int)$this->request->param('member_uid', 0);
        $month = trim((string)$this->request->param('month', ''));
        $page = max(1, (int)$this->request->param('page', 1));
        $limit = min(50, max(1, (int)$this->request->param('limit', 20)));

        $targetUids = ($memberUid > 0 && in_array($memberUid, $uids, true)) ? [$memberUid] : $uids;

        $build = function () use ($targetUids, $status, $keyword, $month) {
            $q = Db::name('order')->where('user_id', 'in', $targetUids);
            if ($month !== '' && preg_match('/^\d{4}-\d{2}$/', $month)) {
                $startTs = strtotime($month . '-01 00:00:00');
                $endTs = strtotime('+1 month', $startTs) - 1;
                if ($startTs > 0 && $endTs > 0) {
                    $q->where('createtime', 'between', [$startTs, $endTs]);
                }
            }
            if ($keyword !== '') {
                $q->where(function ($sub) use ($keyword) {
                    $sub->where('contact', 'like', "%{$keyword}%")
                        ->whereOr('mobile', 'like', "%{$keyword}%")
                        ->whereOr('order_no', 'like', "%{$keyword}%")
                        ->whereOr('service_name', 'like', "%{$keyword}%")
                        ->whereOr('address', 'like', "%{$keyword}%")
                        ->whereOr('remark', 'like', "%{$keyword}%");
                });
            }
            if ($status === 'active') {
                $q->where('status', 'in', \app\common\library\OrderStatus::activeValues());
            } elseif ($status === 'completed') {
                $q->where('status', \app\common\library\OrderStatus::COMPLETED);
            } elseif ($status === 'cancelled') {
                $q->where('status', \app\common\library\OrderStatus::CANCELLED);
            } elseif ($status !== 'all' && $status !== '') {
                $q->where('status', (int)$status);
            }
            return $q;
        };

        $total = $build()->count();
        $rows = $build()->order('id desc')->page($page, $limit)->select();
        $userMap = Db::name('user')->where('id', 'in', $uids)->column('id,nickname,mobile', 'id');
        $serviceIds = array_values(array_unique(array_filter(array_map('intval', array_column($rows, 'service_id')))));
        $serviceImgMap = $serviceIds ? Db::name('service')->where('id', 'in', $serviceIds)->column('image', 'id') : [];
        $orderIds = array_values(array_unique(array_filter(array_map('intval', array_column($rows, 'id')))));
        $batchMap = $orderIds ? Db::name('merchant_order')->where('order_id', 'in', $orderIds)->column('batch_no', 'order_id') : [];

        foreach ($rows as &$row) {
            $ownerUser = (int)$row['user_id'] === (int)$merchant['user_id'];
            $u = isset($userMap[(int)$row['user_id']]) ? $userMap[(int)$row['user_id']] : null;
            $mobile = $u ? (string)$u['mobile'] : '';
            $custMobile = (string)$row['mobile'];
            $row['mobile_mask'] = strlen($custMobile) === 11 ? substr_replace($custMobile, '****', 3, 4) : $custMobile;
            $row['pay_amount'] = (float)$row['pay_amount'];
            $row['urgent'] = (int)$row['urgent'];
            $row['status_text'] = \app\common\library\OrderStatus::label((int)$row['status']);
            $row['appoint_text'] = $row['appoint_time'] ? date('m-d H:i', (int)$row['appoint_time']) : '尽快上门';
            $row['create_text'] = date('Y-m-d H:i', (int)$row['createtime']);
            $row['address_text'] = $row['province'] . $row['city'] . $row['district'] . $row['address'];
            $row['account_name'] = $u && $u['nickname'] ? $u['nickname'] : ('用户' . substr($mobile, -4));
            $row['account_role'] = $ownerUser ? 'owner' : 'member';
            $row['account_role_text'] = $ownerUser ? '主账号' : '关联账号';
            $row['batch_no'] = isset($batchMap[(int)$row['id']]) ? (string)$batchMap[(int)$row['id']] : '';
            $img = !empty($row['service_image']) ? $row['service_image'] : '';
            if (empty($img) && !empty($row['service_id']) && isset($serviceImgMap[(int)$row['service_id']])) {
                $img = $serviceImgMap[(int)$row['service_id']];
            }
            if ($img && strpos($img, 'http') !== 0) {
                $img = cdnurl($img, true);
            }
            $row['service_image'] = $img;
            $row['goods_image_url'] = $img;
        }
        unset($row);

        $this->success('', [
            'list'     => $rows,
            'total'    => (int)$total,
            'page'     => $page,
            'has_more' => ($page * $limit) < (int)$total,
        ]);
    }

    /**
     * 开票记录与可开票额度（个人用户与认证商家通用，兼容旧版调用并复用 InvoiceService）
     */
    public function invoices()
    {
        $records = InvoiceService::getRecordList($this->uid(), 'all', 1, 30);
        $quota = InvoiceService::getQuotaSummary($this->uid());

        $this->success('', [
            'list'  => $records['list'],
            'quota' => $quota,
        ]);
    }

    /**
     * 申请开票（向下兼容旧版入口，底层复用 InvoiceService）
     * @ApiMethod (POST)
     */
    public function invoice()
    {
        $params = [
            'order_ids'      => $this->request->post('order_ids', '', null),
            'amount'         => $this->request->post('amount', 0),
            'title_id'       => $this->request->post('title_id', 0),
            'type'           => $this->request->post('type', 'normal'),
            'title_type'     => $this->request->post('title_type', ''),
            'title'          => $this->request->post('title', ''),
            'tax_no'         => $this->request->post('tax_no', ''),
            'bank_name'      => $this->request->post('bank_name', ''),
            'bank_account'   => $this->request->post('bank_account', ''),
            'reg_address'    => $this->request->post('reg_address', ''),
            'reg_mobile'     => $this->request->post('reg_mobile', ''),
            'email'          => $this->request->post('email', ''),
            'receive_mobile' => $this->request->post('receive_mobile', ''),
            'remark'         => $this->request->post('remark', ''),
            'save_title'     => $this->request->post('save_title', 0),
        ];

        try {
            $result = InvoiceService::submitInvoice($this->uid(), $params, false);
        } catch (\InvalidArgumentException $e) {
            $this->error($e->getMessage());
            return;
        } catch (\Exception $e) {
            \think\Log::error('[Merchant::invoice] ' . $e->getMessage());
            $this->error('开票申请提交失败，请稍后重试');
            return;
        }

        $this->success('开票申请已提交，3 个工作日内开具', $result);
    }

    /**
     * 商家关联账号列表（主账号 + 已绑定账号）
     */
    public function members()
    {
        $merchant = $this->requireMerchant();
        $uids = $this->merchantUserIds($merchant);
        $isOwner = (int)$merchant['user_id'] === $this->uid();

        $users = Db::name('user')->where('id', 'in', $uids)->column('id,nickname,mobile,avatar', 'id');
        $bindRows = Db::name('merchant_member')->where('merchant_id', (int)$merchant['id'])->select();
        $bindMap = [];
        foreach ($bindRows as $b) {
            $bindMap[(int)$b['user_id']] = $b;
        }

        $stats = Db::name('order')->field('user_id,count(*) as cnt,sum(pay_amount) as amount')
            ->where('user_id', 'in', $uids)->where('pay_status', 1)
            ->group('user_id')->select();
        $statMap = [];
        foreach ($stats as $s) {
            $statMap[(int)$s['user_id']] = $s;
        }

        $list = [];
        foreach ($uids as $uid) {
            $u = isset($users[$uid]) ? $users[$uid] : null;
            $owner = (int)$uid === (int)$merchant['user_id'];
            $bind = isset($bindMap[(int)$uid]) ? $bindMap[(int)$uid] : null;
            $mobile = $u ? (string)$u['mobile'] : '';
            $list[] = [
                'id'              => $owner ? 0 : (int)$bind['id'],
                'user_id'         => (int)$uid,
                'nickname'        => $u ? ($u['nickname'] ?: ('用户' . substr($mobile, -4))) : '用户',
                'mobile'          => $mobile !== '' ? substr_replace($mobile, '****', 3, 4) : '',
                'avatar'          => $u ? $u['avatar'] : '',
                'role'            => $owner ? 'owner' : 'member',
                'role_text'       => $owner ? '主账号' : '关联账号',
                'is_owner'        => $owner,
                'order_count'     => isset($statMap[(int)$uid]) ? (int)$statMap[(int)$uid]['cnt'] : 0,
                'total_amount'    => isset($statMap[(int)$uid]) ? round((float)$statMap[(int)$uid]['amount'], 2) : 0,
                'bind_time_text'  => (!$owner && $bind) ? date('Y-m-d H:i', (int)$bind['createtime']) : '',
            ];
        }

        // 主账号排在最前
        usort($list, function ($a, $b) {
            return (int)$b['is_owner'] - (int)$a['is_owner'];
        });

        $this->success('', [
            'list'     => $list,
            'is_owner' => $isOwner,
            'total'    => count($list),
        ]);
    }

    /**
     * 绑定关联账号（仅主账号）
     * @ApiMethod (POST)
     */
    public function bindMember()
    {
        $merchant = $this->requireMerchant();
        $this->requireMerchantOwner($merchant);

        $mobile = trim((string)$this->request->post('mobile'));
        if (!preg_match('/^1\d{10}$/', $mobile)) {
            $this->error('请输入正确的关联账号手机号');
        }

        $user = Db::name('user')->where('mobile', $mobile)->find();
        if (!$user) {
            $this->error('该手机号尚未注册，请对方先登录小程序');
        }
        if ((int)$user['id'] === $this->uid()) {
            $this->error('不能绑定当前主账号');
        }
        if (Db::name('merchant')->where('user_id', $user['id'])->find()) {
            $this->error('该账号已是商家主账号，不能重复绑定');
        }
        if (Db::name('merchant_member')->where('user_id', $user['id'])->find()) {
            $this->error('该账号已绑定其他商家');
        }

        $id = Db::name('merchant_member')->insertGetId([
            'merchant_id' => (int)$merchant['id'],
            'user_id'     => (int)$user['id'],
            'remark'      => '',
            'createtime'  => time(),
            'updatetime'  => time(),
        ]);

        try {
            $this->notify('user', (int)$user['id'], '已加入商家账号', '您的账号已关联到商家「' . $merchant['name'] . '」，下单、账单、开票数据将实时同步', 'system', 0);
        } catch (\Exception $e) {
            \think\Log::error('[Merchant::bindMember notify] ' . $e->getMessage());
        }

        $this->success('绑定成功，关联账号数据将实时同步', [
            'member_id' => (int)$id,
            'user_id'   => (int)$user['id'],
            'nickname'  => $user['nickname'] ?: ('用户' . substr($mobile, -4)),
        ]);
    }

    /**
     * 解除关联账号（仅主账号）
     * @ApiMethod (POST)
     */
    public function unbindMember()
    {
        $merchant = $this->requireMerchant();
        $this->requireMerchantOwner($merchant);

        $memberId = (int)$this->request->post('member_id');
        $userId = (int)$this->request->post('user_id');
        $query = Db::name('merchant_member')->where('merchant_id', (int)$merchant['id']);
        if ($memberId > 0) {
            $query->where('id', $memberId);
        } elseif ($userId > 0) {
            $query->where('user_id', $userId);
        } else {
            $this->error('缺少关联账号参数');
        }
        $row = $query->find();
        if (!$row) {
            $this->error('关联账号不存在或已解除');
        }
        if ((int)$row['user_id'] === (int)$merchant['user_id']) {
            $this->error('不能解除主账号');
        }

        Db::name('merchant_member')->where('id', (int)$row['id'])->delete();
        try {
            $this->notify('user', (int)$row['user_id'], '商家关联已解除', '您已与商家「' . $merchant['name'] . '」解除关联，对方商家数据不再同步', 'system', 0);
        } catch (\Exception $e) {
            \think\Log::error('[Merchant::unbindMember notify] ' . $e->getMessage());
        }
        $this->success('已解除关联，对方将不再同步商家数据');
    }

    /**
     * 批量下单后绑定批次（订单本身走已验收的 /order/create）
     * @ApiMethod (POST)
     */
    public function bindBatch()
    {
        $merchant = $this->requireMerchant();
        $uids = $this->merchantUserIds($merchant);
        // 兼容三种入参：数组 / 逗号串 / 混合
        $raw = $this->request->post('order_ids');
        $orderIds = [];
        foreach ((array)$raw as $v) {
            foreach (explode(',', (string)$v) as $one) {
                $one = (int)$one;
                if ($one > 0) {
                    $orderIds[] = $one;
                }
            }
        }
        $orderIds = array_values(array_unique($orderIds));
        $batchNo = trim((string)$this->request->post('batch_no', ''));
        if (empty($orderIds)) {
            $this->error('缺少订单');
        }
        if ($batchNo === '') {
            $batchNo = date('YmdHis') . mt_rand(100, 999);
        }

        $ok = 0;
        foreach ($orderIds as $oid) {
            $oid = (int)$oid;
            if (!Db::name('order')->where('id', $oid)->where('user_id', 'in', $uids)->find()) {
                continue;
            }
            if (Db::name('merchant_order')->where('order_id', $oid)->find()) {
                continue;
            }
            Db::name('merchant_order')->insert([
                'merchant_id' => (int)$merchant['id'],
                'order_id'    => $oid,
                'batch_no'    => $batchNo,
                'createtime'  => time(),
            ]);
            $ok++;
        }
        $this->success('已归属到批次', ['batch_no' => $batchNo, 'count' => $ok]);
    }

    /**
     * 当前用户商家档案：主账号直接匹配，关联账号通过绑定关系匹配
     */
    /**
     * 商户端：Excel 或结构化数据一键批量解析下单
     * @ApiMethod (POST)
     */
    public function importBatch()
    {
        $merchant = $this->requireMerchant();
        $rawOrders = $this->request->post('orders', null, null);
        if ($rawOrders === null || $rawOrders === '' || $rawOrders === []) {
            $rawOrders = $this->request->post('items', [], null);
        }

        $items = [];
        if (is_string($rawOrders)) {
            $decoded = json_decode(htmlspecialchars_decode(trim($rawOrders)), true);
            if (is_array($decoded)) {
                $items = $decoded;
            }
        } elseif (is_array($rawOrders)) {
            if (count($rawOrders) === 1 && isset($rawOrders[0]) && is_string($rawOrders[0])) {
                $decoded = json_decode(htmlspecialchars_decode(trim($rawOrders[0])), true);
                $items = is_array($decoded) ? $decoded : $rawOrders;
            } else {
                $items = $rawOrders;
            }
        }

        if (empty($items) || !is_array($items)) {
            $this->error('导入数据不能为空');
        }
        if (count($items) > 100) {
            $this->error('单次批量导入最多支持 100 条订单');
        }

        $globalServiceId = (int)$this->request->post('service_id', 0);
        $serviceCache = [];
        $preparedRows = [];

        foreach ($items as $idx => $item) {
            if (is_string($item)) {
                $decItem = json_decode(htmlspecialchars_decode(trim($item)), true);
                if (is_array($decItem)) {
                    $item = $decItem;
                }
            }
            if (!is_array($item)) {
                continue;
            }

            $contact = trim((string)(isset($item['contact']) ? $item['contact'] : '买家'));
            $mobile = preg_replace('/[^\d]/', '', trim((string)(isset($item['mobile']) ? $item['mobile'] : '')));
            $address = trim((string)(isset($item['address']) ? $item['address'] : ''));
            if ($mobile === '' && $address === '') {
                continue;
            }
            $rowNo = $idx + 1;
            if (!preg_match('/^1\d{10}$/', $mobile)) {
                $this->error("第 {$rowNo} 条订单联系电话格式不正确");
            }
            if ($address === '') {
                $this->error("第 {$rowNo} 条订单缺少详细服务地址");
            }

            $itemServiceId = !empty($item['service_id']) ? (int)$item['service_id'] : $globalServiceId;
            if ($itemServiceId <= 0) {
                $this->error("第 {$rowNo} 条订单未指定有效的服务项目");
            }
            if (!array_key_exists($itemServiceId, $serviceCache)) {
                $serviceCache[$itemServiceId] = Db::name('service')
                    ->where('id', $itemServiceId)
                    ->where('status', 'normal')
                    ->find() ?: null;
            }
            $svc = $serviceCache[$itemServiceId];
            if (!$svc) {
                $this->error("第 {$rowNo} 条订单关联的服务项目不存在或已下架");
            }
            if ($svc['price_type'] === 'quote') {
                $this->error("第 {$rowNo} 条订单所选服务「{$svc['name']}」为师傅报价项目，不支持批量一口价导入");
            }

            $goodsNum = max(1, (int)(isset($item['goods_num']) ? $item['goods_num'] : (isset($item['num']) ? $item['num'] : 1)));
            $floor = isset($item['floor']) ? max(1, (int)$item['floor']) : 1;
            $hasElevator = isset($item['has_elevator'])
                ? (int)$item['has_elevator']
                : (isset($item['elevator']) ? (int)$item['elevator'] : 1);
            $urgent = !empty($item['urgent']) ? 1 : 0;
            $specId = isset($item['spec_id']) ? (int)$item['spec_id'] : 0;
            $reqServiceType = isset($item['service_type']) ? trim((string)$item['service_type']) : '';

            // 严禁采信前端传入的 price，强制根据数据库 fa_service / fa_service_spec 与楼层规则计算真实金额
            try {
                $calc = Home::calcAmount($svc, [
                    'floor'        => $floor,
                    'has_elevator' => $hasElevator ? 1 : 0,
                    'urgent'       => $urgent,
                    'goods_num'    => $goodsNum,
                    'spec_id'      => $specId,
                    'service_type' => $reqServiceType,
                    'strict'       => true,
                ], 0, $this->uid(), 'fixed', 0, []);
            } catch (\InvalidArgumentException $e) {
                $this->error("第 {$rowNo} 条订单计价校验失败：" . $e->getMessage());
                return;
            }

            if ((float)$calc['pay_amount'] <= 0) {
                $this->error("第 {$rowNo} 条订单计算金额异常");
            }

            $resolvedProvince = mb_substr(trim((string)(isset($item['province']) && $item['province'] !== '' ? $item['province'] : ($merchant['province'] ?: ''))), 0, 50);
            $resolvedCity = mb_substr(trim((string)(isset($item['city']) && $item['city'] !== '' ? $item['city'] : ($merchant['city'] ?: ''))), 0, 50);
            if ($resolvedProvince === '' || $resolvedCity === '') {
                $this->error("第 {$rowNo} 条订单缺少服务省份或城市信息，请在Excel或表格中填写后再提交");
            }

            $preparedRows[] = [
                'svc'          => $svc,
                'service_id'   => (int)$svc['id'],
                'cat_id'       => (int)$svc['cat_id'],
                'service_name' => (string)$svc['name'],
                'service_img'  => (string)$svc['image'],
                'goods_model'  => mb_substr(trim((string)(isset($item['goods_model']) ? $item['goods_model'] : '')), 0, 100),
                'goods_num'    => $goodsNum,
                'contact'      => mb_substr($contact ?: '买家', 0, 50),
                'mobile'       => $mobile,
                'province'     => $resolvedProvince,
                'city'         => $resolvedCity,
                'district'     => mb_substr(trim((string)(isset($item['district']) ? $item['district'] : ($merchant['district'] ?: ''))), 0, 50),
                'address'      => mb_substr($address, 0, 255),
                'floor'        => $floor,
                'has_elevator' => $hasElevator ? 1 : 0,
                'urgent'       => $urgent,
                'remark'       => mb_substr(trim((string)(isset($item['remark']) ? $item['remark'] : '')), 0, 500),
                'appoint_time' => !empty($item['appoint_time']) ? (int)$item['appoint_time'] : null,
                'calc'         => $calc,
            ];
        }

        if (empty($preparedRows)) {
            $this->error('未解析到有效的导入订单数据');
        }

        $ordersCreated = [];
        $orderIds = [];
        $totalAmount = 0.00;
        $isMonthly = false;
        $batchNo = 'MB' . date('YmdHis') . mt_rand(1000, 9999);
        $now = time();
        // 事务外一次性预加载生效抽佣规则与默认兜底配置，循环内纯内存匹配快照（零额外 SQL）
        $activeCommRules = CommissionService::getActiveRules();
        $commDefaults = FinanceConfigService::getCommissionDefaults();

        Db::startTrans();
        try {
            $lockedMerchant = Db::name('merchant')->where('id', (int)$merchant['id'])->lock(true)->find();
            if (!$lockedMerchant || $lockedMerchant['verify_status'] !== 'pass') {
                throw new \InvalidArgumentException('商家资质状态异常，无法批量发单');
            }
            $isMonthly = ($lockedMerchant['settle_type'] === 'monthly');
            $initStatus = $isMonthly ? OrderStatus::PENDING_ACCEPT : OrderStatus::PENDING_PAY;
            $initPayStatus = $isMonthly ? 1 : 0;
            $initPayType = $isMonthly ? 'monthly' : '';
            $initPayTime = $isMonthly ? $now : null;

            foreach ($preparedRows as $pRow) {
                $orderNo = $this->makeOrderNo();
                $verifyCode = str_pad((string)mt_rand(0, 999999), 6, '0', STR_PAD_LEFT);
                $calc = $pRow['calc'];
                $payAmt = round((float)$calc['pay_amount'], 2);
                $unitPrice = round((float)$calc['base_amount'] / max(1, (int)$pRow['goods_num']), 2);
                $commMatch = CommissionService::matchOrderSnapshot([
                    'price_type'    => 'fixed',
                    'customer_type' => 'merchant',
                    'cat_id'        => (int)$pRow['cat_id'],
                    'urgent'        => (int)$pRow['urgent'],
                    'order_amount'  => $payAmt,
                ], $activeCommRules, $commDefaults);

                $orderId = (int)Db::name('order')->insertGetId([
                    'order_no'        => $orderNo,
                    'user_id'         => $this->uid(),
                    'master_id'       => 0,
                    'cat_id'          => $pRow['cat_id'],
                    'service_id'      => $pRow['service_id'],
                    'service_name'    => $pRow['service_name'],
                    'service_image'   => $pRow['service_img'],
                    'price_type'      => 'fixed',
                    'goods_model'     => $pRow['goods_model'],
                    'goods_num'       => $pRow['goods_num'],
                    'contact'         => $pRow['contact'],
                    'mobile'          => $pRow['mobile'],
                    'province'        => $pRow['province'],
                    'city'            => $pRow['city'],
                    'district'        => $pRow['district'],
                    'address'         => $pRow['address'],
                    'floor'           => $pRow['floor'],
                    'has_elevator'    => $pRow['has_elevator'],
                    'urgent'          => $pRow['urgent'],
                    'remark'          => $pRow['remark'],
                    'appoint_time'    => $pRow['appoint_time'],
                    'base_amount'     => $calc['base_amount'],
                    'floor_amount'    => $calc['floor_amount'],
                    'urgent_amount'   => $calc['urgent_amount'],
                    'discount_amount' => 0.00,
                    'total_amount'        => $calc['total_amount'],
                    'pay_amount'          => $payAmt,
                    'commission_rate'     => $commMatch['commission_rate'],
                    'commission_snapshot' => $commMatch['commission_snapshot'],
                    'status'              => $initStatus,
                    'pay_status'      => $initPayStatus,
                    'pay_type'        => $initPayType,
                    'pay_time'        => $initPayTime,
                    'transaction_id'  => $isMonthly ? ('MONTHLY' . date('YmdHis', $now) . mt_rand(1000, 9999)) : '',
                    'verify_code'     => $verifyCode,
                    'createtime'      => $now,
                    'updatetime'      => $now,
                ]);

                Db::name('order_goods')->insert([
                    'order_id'       => $orderId,
                    'service_id'     => $pRow['service_id'],
                    'goods_name'     => $pRow['service_name'],
                    'goods_model'    => $pRow['goods_model'],
                    'goods_num'      => $pRow['goods_num'],
                    'goods_image'    => $pRow['service_img'],
                    'addon_services' => '',
                    'base_price'     => $unitPrice,
                    'createtime'     => $now,
                ]);

                Db::name('merchant_order')->insert([
                    'merchant_id' => (int)$lockedMerchant['id'],
                    'order_id'    => $orderId,
                    'batch_no'    => $batchNo,
                    'createtime'  => $now,
                ]);

                $this->addLog(
                    $orderId,
                    $initStatus,
                    $isMonthly ? "企业批量导单（月结授信，批次 {$batchNo}），已进入接单大厅" : "企业批量导单创建（待支付，批次 {$batchNo}）",
                    'user',
                    $this->uid()
                );

                $orderIds[] = $orderId;
                $ordersCreated[] = [
                    'order_id' => $orderId,
                    'order_no' => $orderNo,
                    'contact'  => $pRow['contact'],
                    'amount'   => $payAmt,
                ];
                $totalAmount = round($totalAmount + $payAmt, 2);
            }

            if ($isMonthly) {
                Db::name('merchant')->where('id', (int)$lockedMerchant['id'])->update([
                    'order_count'  => (int)$lockedMerchant['order_count'] + count($ordersCreated),
                    'total_amount' => round((float)$lockedMerchant['total_amount'] + $totalAmount, 2),
                    'updatetime'   => $now,
                ]);
            }

            Db::commit();
        } catch (\think\exception\HttpResponseException $e) {
            Db::rollback();
            throw $e;
        } catch (\InvalidArgumentException $e) {
            Db::rollback();
            $this->error($e->getMessage());
            return;
        } catch (\Exception $e) {
            Db::rollback();
            \think\Log::error('[Merchant::importBatch] ' . $e->getMessage());
            $this->error('批量导入失败：' . $e->getMessage());
            return;
        }

        if ($isMonthly && !empty($orderIds)) {
            try {
                $masters = Db::name('master')
                    ->where('verify_status', 'pass')
                    ->where('work_status', 'on')
                    ->where('user_id', '<>', $this->uid())
                    ->limit(20)
                    ->select();
                $cnt = count($orderIds);
                foreach ($masters as $m) {
                    $this->notify('master', (int)$m['id'], '企业批量新工单就绪', "商家刚发布了 {$cnt} 笔新工单进入接单大厅，请尽快前往查看抢单！", 'order', (int)$orderIds[0]);
                }
            } catch (\Exception $e) {
                \think\Log::error('[Merchant::importBatch broadcast] ' . $e->getMessage());
            }
        }

        $this->success($isMonthly ? '批量下单成功，已按月结授信进入接单大厅！' : '批量导入成功，请完成批次支付', [
            'need_pay'     => !$isMonthly,
            'settle_type'  => $isMonthly ? 'monthly' : 'prepay',
            'batch_no'     => $batchNo,
            'count'        => count($ordersCreated),
            'total_amount' => round($totalAmount, 2),
            'order_ids'    => $orderIds,
            'orders'       => $ordersCreated,
        ]);
    }

    /**
     * 商户端：预付商家按批次号支付待支付批量订单（严禁模拟免付兜底，预付订单须逐笔走真实微信支付）
     * @ApiMethod (POST)
     */
    public function payBatch()
    {
        $this->requireMerchant();
        $this->error('系统已全面禁用模拟支付通道，企业预付工单请逐笔使用真实微信支付完成付款（月结授信企业导单时已直接授信进入大厅）');
    }

    protected function merchantInfo()
    {
        $merchant = Db::name('merchant')->where('user_id', $this->uid())->find();
        if ($merchant) {
            return $merchant;
        }
        $bind = Db::name('merchant_member')->where('user_id', $this->uid())->find();
        if ($bind) {
            return Db::name('merchant')->where('id', (int)$bind['merchant_id'])->find();
        }
        return null;
    }

    /**
     * 商家数据归属用户集合：主账号 + 所有关联账号
     */
    protected function merchantUserIds($merchant)
    {
        $ids = [(int)$merchant['user_id']];
        $rows = Db::name('merchant_member')->where('merchant_id', (int)$merchant['id'])->column('user_id');
        foreach ($rows as $id) {
            $id = (int)$id;
            if ($id > 0 && !in_array($id, $ids, true)) {
                $ids[] = $id;
            }
        }
        return $ids;
    }

    /**
     * 仅商家主账号可执行敏感操作
     */
    protected function requireMerchantOwner($merchant)
    {
        if ((int)$merchant['user_id'] !== $this->uid()) {
            $this->error('仅主账号可执行此操作', null, 403);
        }
    }

    /**
     * 要求已通过审核的商家
     */
    protected function requireMerchant()
    {
        $m = $this->merchantInfo();
        if (!$m) {
            $curUser = Db::name('user')->where('id', $this->uid())->find();
            if ($curUser && !empty($curUser['user_type']) && $curUser['user_type'] === 'merchant') {
                $now = time();
                $newId = Db::name('merchant')->insertGetId([
                    'user_id'       => $this->uid(),
                    'name'          => !empty($curUser['nickname']) ? (string)$curUser['nickname'] : '商家用户',
                    'license_no'    => '',
                    'contact'       => (string)$curUser['nickname'],
                    'mobile'        => (string)$curUser['mobile'],
                    'address'       => isset($curUser['contact_address']) ? (string)$curUser['contact_address'] : '',
                    'email'         => isset($curUser['email']) ? (string)$curUser['email'] : '',
                    'verify_status' => 'pass',
                    'createtime'    => $now,
                    'updatetime'    => $now,
                ]);
                return Db::name('merchant')->where('id', $newId)->find();
            }
            $this->error('请先在「账号信息」切换为商家类型', null, 2001);
        }
        if ($m['verify_status'] !== 'pass') {
            Db::name('merchant')->where('id', (int)$m['id'])->update([
                'verify_status' => 'pass',
                'updatetime'    => time(),
            ]);
            $m['verify_status'] = 'pass';
        }
        return $m;
    }
}