<?php

namespace app\api\controller;

use app\common\library\OrderStatus;
use app\common\library\TiandituService;
use app\common\library\SmsService;
use think\Db;

/**
 * 师傅端：入驻 / 订单大厅 / 抢单 / 履约流转 / 收入
 */
class Master extends Base
{
    protected $noNeedLogin = [];

    /**
     * 师傅入驻申请
     * @ApiMethod (POST)
     */
    public function apply()
    {
        $realname = trim((string)$this->request->post('realname'));
        $mobile = preg_replace('/[^\d]/', '', trim((string)$this->request->post('mobile')));
        $rawIdcard = strtoupper(trim((string)$this->request->post('idcard_no', $this->request->post('idcard', ''))));
        $idcardFront = trim((string)$this->request->post('idcard_front'));
        $idcardBack = trim((string)$this->request->post('idcard_back'));
        $certImages = trim((string)$this->request->post('cert_images'));

        $province = trim((string)$this->request->post('province', ''));
        $city = trim((string)$this->request->post('city', ''));
        $district = trim((string)$this->request->post('district', ''));

        $cityParts = [];
        foreach ([$province, $city, $district] as $part) {
            if ($part === '') {
                continue;
            }
            $duplicated = false;
            foreach ($cityParts as $ep) {
                if (mb_strpos($ep, $part) !== false) {
                    $duplicated = true;
                    break;
                }
            }
            if (!$duplicated) {
                $cityParts[] = $part;
            }
        }
        $normalizedCity = mb_substr(implode(' ', $cityParts), 0, 50);

        $skillsRaw = $this->request->post('skills', null, null);
        $skillCatIds = [];
        if (is_string($skillsRaw)) {
            $decSkills = json_decode(htmlspecialchars_decode(trim($skillsRaw)), true);
            $skillsArr = is_array($decSkills) ? $decSkills : explode(',', $skillsRaw);
        } elseif (is_array($skillsRaw)) {
            $skillsArr = $skillsRaw;
        } else {
            $skillsArr = [];
        }
        foreach ($skillsArr as $sv) {
            if (is_array($sv)) {
                continue;
            }
            foreach (explode(',', (string)$sv) as $partId) {
                $cid = (int)trim($partId, " \t\n\r\0\x0B\"'[]");
                if ($cid > 0 && !in_array($cid, $skillCatIds, true)) {
                    $skillCatIds[] = $cid;
                }
            }
        }

        if ($realname === '' || $mobile === '' || $rawIdcard === '') {
            $this->error('请填写真实姓名、手机号和身份证号');
        }
        if (!preg_match('/^1\d{10}$/', $mobile)) {
            $this->error('手机号格式不正确');
        }
        if ($normalizedCity === '') {
            $this->error('请选择服务城市');
        }
        if (empty($skillCatIds)) {
            $this->error('请至少选择一个服务类目');
        }

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

        // 若是驳回后重提且未修改脱敏展示号，沿用原存储的完整身份证号；否则校验完整身份证号并真实入库
        if (strpos($rawIdcard, '*') !== false) {
            if ($exist && !empty($exist['idcard_no']) && strpos((string)$exist['idcard_no'], '*') === false) {
                $finalIdcard = (string)$exist['idcard_no'];
            } else {
                $this->error('请填写真实完整的18位身份证号码');
                return;
            }
        } else {
            if (!preg_match('/^(\d{15}|\d{17}[0-9X])$/', $rawIdcard)) {
                $this->error('身份证号码格式不正确');
            }
            $finalIdcard = $rawIdcard;
        }

        $catNameMap = Db::name('service_cat')->where('id', 'in', $skillCatIds)->column('name', 'id');

        $save = [
            'realname'      => mb_substr($realname, 0, 50),
            'mobile'        => $mobile,
            'idcard_no'     => $finalIdcard,
            'idcard_front'  => $idcardFront,
            'idcard_back'   => $idcardBack,
            'cert_images'   => $certImages,
            'city'          => $normalizedCity,
            'verify_status' => 'pending',
            'audit_msg'     => '',
            'updatetime'    => time(),
        ];

        Db::startTrans();
        try {
            if ($exist) {
                $masterId = (int)$exist['id'];
                Db::name('master')->where('id', $masterId)->update($save);
                Db::name('master_skill')->where('master_id', $masterId)->delete();
            } else {
                $save['user_id'] = $this->uid();
                $save['createtime'] = time();
                $masterId = Db::name('master')->insertGetId($save);
            }
            foreach ($skillCatIds as $catId) {
                $cName = isset($catNameMap[$catId]) ? (string)$catNameMap[$catId] : '';
                Db::name('master_skill')->insert([
                    'master_id'  => $masterId,
                    'cat_id'     => (int)$catId,
                    'skill_id'   => 0,
                    'skill_name' => $cName,
                    'category'   => '安装维修',
                    'is_custom'  => 0,
                    'status'     => 'normal',
                    'createtime' => time(),
                ]);
            }
            Db::commit();
        } catch (\Exception $e) {
            Db::rollback();
            $this->error('提交失败：' . $e->getMessage());
        }

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

    /**
     * 我的师傅档案
     */
    public function info()
    {
        $master = $this->masterInfo();
        if (!$master) {
            $this->success('未入驻', ['applied' => false]);
        }
        $skillsRaw = Db::name('master_skill')->alias('s')
            ->join('service_cat c', 'c.id = s.cat_id', 'LEFT')
            ->field('s.cat_id,s.skill_id,s.skill_name,s.category,s.is_custom,c.name as cat_name,c.icon')
            ->where('s.master_id', $master['id'])
            ->select();
        $skills = [];
        foreach ($skillsRaw as $sr) {
            $name = !empty($sr['skill_name']) ? $sr['skill_name'] : ($sr['cat_name'] ?? '');
            if ($name) {
                $skills[] = [
                    'cat_id'     => (int)$sr['cat_id'],
                    'skill_id'   => (int)$sr['skill_id'],
                    'name'       => $name,
                    'category'   => $sr['category'] ?: '服务技能',
                    'is_custom'  => (int)$sr['is_custom'],
                    'icon'       => $sr['icon'] ?? ''
                ];
            }
        }

        $todo = Db::name('order')->where('master_id', $master['id'])
            ->where('status', 'in', [OrderStatus::ACCEPTED, OrderStatus::SCHEDULED, OrderStatus::ARRIVED, OrderStatus::WORKING])
            ->count();
        $pendingVerify = Db::name('order')->where('master_id', $master['id'])
            ->where('status', OrderStatus::PENDING_VERIFY)->count();

        $rawIdcard = (string)($master['idcard_no'] ?? '');
        $maskedIdcard = strlen($rawIdcard) >= 10
            ? (substr($rawIdcard, 0, 6) . str_repeat('*', max(4, strlen($rawIdcard) - 10)) . substr($rawIdcard, -4))
            : $rawIdcard;

        $this->success('', [
            'applied' => true,
            'master'  => [
                'id'            => (int)$master['id'],
                'realname'      => $master['realname'],
                'mobile'        => $master['mobile'],
                'idcard_no'     => $maskedIdcard,
                'idcard'        => $maskedIdcard,
                'idcard_front'  => (string)($master['idcard_front'] ?? ''),
                'idcard_back'   => (string)($master['idcard_back'] ?? ''),
                'cert_images'   => (string)($master['cert_images'] ?? ''),
                'avatar'        => $master['avatar'],
                'city'          => $master['city'],
                'level'         => (int)$master['level'],
                'score'         => (float)$master['score'],
                'order_count'   => (int)$master['order_count'],
                'accept_rate'   => (float)$master['accept_rate'],
                'ontime_rate'   => (float)$master['ontime_rate'],
                'work_status'   => $master['work_status'],
                'verify_status' => $master['verify_status'],
                'audit_msg'     => $master['audit_msg'],
                'money'         => (float)$master['money'],
                'frozen_money'  => (float)$master['frozen_money'],
                'todo_count'    => (int)$todo,
                'verify_count'  => (int)$pendingVerify,
            ],
            'skills'  => $skills,
        ]);
    }

    /**
     * 接单开关
     * @ApiMethod (POST)
     */
    public function toggleWork()
    {
        $master = $this->requireMaster();
        $status = $this->request->post('work_status', '');
        if (!in_array($status, ['on', 'off'], true)) {
            $this->error('参数错误');
        }
        Db::name('master')->where('id', $master['id'])->update(['work_status' => $status, 'updatetime' => time()]);
        $this->success($status === 'on' ? '已开启接单' : '已暂停接单', ['work_status' => $status]);
    }

    /**
     * 订单大厅：支持排序与单类型筛选（一口价 / 师傅报价 / 用户自主定价）
     */
    public function hall()
    {
        $master = $this->requireMaster();
        $this->recycleExpired();

        $catIds = Db::name('master_skill')->where('master_id', $master['id'])->where('cat_id', '>', 0)->column('cat_id');
        $catIds = array_values(array_filter(array_unique($catIds)));
        $page = max(1, (int)$this->request->param('page', 1));
        $limit = min(30, max(1, (int)$this->request->param('limit', 10)));
        $sort = $this->request->param('sort', 'new');   // new 最新 / amount 报酬 / urgent 急单 / time 时效
        $type = $this->request->param('type', 'all');   // all / fixed 一口价 / quote 师傅报价 / custom 用户自主定价

        $buildBase = function () use ($catIds) {
            $q = Db::name('order')->where('master_id', 0)
                ->where('status', 'in', [OrderStatus::PENDING_ACCEPT, OrderStatus::QUOTING]);
            if (!empty($catIds)) {
                $q->where('cat_id', 'in', $catIds);
            }
            return $q;
        };

        $build = function () use ($buildBase, $type) {
            $q = $buildBase();
            if ($type === 'fixed') {
                $q->where('status', OrderStatus::PENDING_ACCEPT)->where('price_type', 'fixed');
            } elseif ($type === 'quote') {
                $q->where('status', 'in', [OrderStatus::PENDING_ACCEPT, OrderStatus::QUOTING])->where('price_type', 'quote');
            } elseif ($type === 'custom') {
                $q->where('status', OrderStatus::PENDING_ACCEPT)->where('price_type', 'custom');
            }
            return $q;
        };

        $counts = [
            'all'    => (int)$buildBase()->count(),
            'fixed'  => (int)$buildBase()->where('status', OrderStatus::PENDING_ACCEPT)->where('price_type', 'fixed')->count(),
            'quote'  => (int)$buildBase()->where('status', 'in', [OrderStatus::PENDING_ACCEPT, OrderStatus::QUOTING])->where('price_type', 'quote')->count(),
            'custom' => (int)$buildBase()->where('status', OrderStatus::PENDING_ACCEPT)->where('price_type', 'custom')->count(),
        ];

        if ($sort === 'amount') {
            $order = 'pay_amount desc, id desc';
        } elseif ($sort === 'urgent') {
            $order = 'urgent desc, id desc';
        } elseif ($sort === 'time') {
            $order = 'appoint_time asc, id desc';
        } else {
            $order = 'id desc';
        }

        $total = $build()->count();
        $list = $build()->order($order)->page($page, $limit)->select();

        $masterRecord = $this->masterInfo();
        $defaultLat = ($masterRecord && !empty($masterRecord['lat'])) ? (float)$masterRecord['lat'] : 0.0;
        $defaultLng = ($masterRecord && !empty($masterRecord['lng'])) ? (float)$masterRecord['lng'] : 0.0;
        $userLat = (float)$this->request->param('lat', $defaultLat);
        $userLng = (float)$this->request->param('lng', $defaultLng);
        $now = time();
        foreach ($list as &$row) {
            unset($row['verify_code']);
            $row['appoint_text'] = $row['appoint_time'] ? date('Y-m-d H:i', (int)$row['appoint_time']) : '接单后与业主预约';
            $row['pay_amount'] = (float)$row['pay_amount'];
            $row['urgent'] = (int)$row['urgent'];
            $row['mobile'] = substr_replace($row['mobile'], '****', 3, 4);

            $rawAddr = (string)$row['address'];
            $maskedAddr = preg_replace('/\d+栋|\d+单元|\d+室|\d+号楼/', '**', $rawAddr);
            $prefix = trim($row['city'] . $row['district']);
            if ($prefix !== '' && strpos($maskedAddr, $row['district']) === false && strpos($maskedAddr, $row['city']) === false) {
                $row['address'] = $prefix . $maskedAddr;
            } else {
                $row['address'] = $maskedAddr;
            }

            $row['status_text'] = OrderStatus::label($row['status']);
            $remain = (int)$row['createtime'] + 7 * 86400 - $now;
            $row['left_seconds'] = max(0, $remain);
            $row['quote_count'] = (int)Db::name('order_quote')->where('order_id', $row['id'])->count();
            $row['remaining_quote_slots'] = max(0, 4 - $row['quote_count']);
            $row['price_type_text'] = $row['price_type'] === 'fixed' ? '一口价'
                : ($row['price_type'] === 'quote' ? '师傅报价'
                : ($row['price_type'] === 'custom' ? '用户自主定价' : '按面积计价'));
            $row['user_price'] = $row['price_type'] === 'custom' ? (float)$row['base_amount'] : 0;

            $goodsName = '';
            $addonServices = '';
            $fallbackImg = '';
            if (!empty($row['goods_images'])) {
                $parsed = json_decode((string)$row['goods_images'], true);
                if (is_array($parsed) && !empty($parsed['goods_list']) && is_array($parsed['goods_list'])) {
                    $firstItem = $parsed['goods_list'][0];
                    if (is_array($firstItem)) {
                        $goodsName = isset($firstItem['goods_name']) && is_string($firstItem['goods_name'])
                            ? $firstItem['goods_name']
                            : (isset($firstItem['item_name']) && is_string($firstItem['item_name']) ? $firstItem['item_name'] : '');
                        if (!empty($firstItem['addon_services'])) {
                            if (is_array($firstItem['addon_services'])) {
                                $adLabels = [];
                                foreach ($firstItem['addon_services'] as $adIt) {
                                    if (is_string($adIt)) {
                                        $adLabels[] = $adIt;
                                    } elseif (is_array($adIt) && !empty($adIt['name'])) {
                                        $adLabels[] = $adIt['name'] . (!empty($adIt['num']) ? 'x' . (int)$adIt['num'] : '');
                                    }
                                }
                                $addonServices = implode(' · ', $adLabels);
                            } else {
                                $addonServices = (string)$firstItem['addon_services'];
                            }
                        }
                        if (!empty($firstItem['goods_image']) && is_string($firstItem['goods_image'])) {
                            $fallbackImg = $firstItem['goods_image'];
                        }
                    }
                }
            }
            $row['goods_name'] = $goodsName ?: $row['service_name'];
            $row['addon_services'] = rtrim(str_replace(';', ' · ', (string)$addonServices), ' ·');
            $row['goods_num'] = max(1, (int)($row['goods_num'] ?? 1));
            $row['service_type_tag'] = (strpos((string)$row['service_name'], '修') !== false || strpos((string)$row['service_name'], '检') !== false) ? '维修' : '安装';

            $img = !empty($row['service_image']) ? $row['service_image'] : $fallbackImg;
            if (empty($img) && !empty($row['service_id'])) {
                $s = Db::name('service')->where('id', (int)$row['service_id'])->value('image');
                if ($s) {
                    $img = $s;
                }
            }
            if (!empty($img)) {
                $row['service_image'] = strpos($img, 'http') === 0 ? $img : cdnurl($img, true);
            } else {
                $row['service_image'] = '';
            }

            $distKm = $this->calculateDistance($userLat, $userLng, (float)$row['lat'], (float)$row['lng']);
            $row['distance_km'] = $distKm;
            $row['distance_text'] = $distKm !== null ? ($distKm . 'km') : '';
        }
        unset($row);

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

    /**
     * 抢单（条件更新保证并发安全）
     * @ApiMethod (POST)
     */
    public function grab()
    {
        $master = $this->requireMaster();
        if ($master['work_status'] !== 'on') {
            $this->error('您已暂停接单，请先开启');
        }
        $orderId = (int)$this->request->post('order_id');
        $order = Db::name('order')->where('id', $orderId)->find();
        if (!$order) {
            $this->error('订单不存在');
        }
        if ((int)$order['user_id'] === (int)$this->uid()) {
            $this->error('不能承接或报价自己发布的订单');
        }
        if ($order['price_type'] === 'quote') {
            $this->error('该订单为师傅报价订单，请提交报价');
        }
        if ((int)$order['status'] !== OrderStatus::PENDING_ACCEPT || (int)$order['master_id'] !== 0) {
            $this->error('手慢了，该订单已被接走');
        }

        $affected = Db::name('order')
            ->where('id', $orderId)
            ->where('status', OrderStatus::PENDING_ACCEPT)
            ->where('master_id', 0)
            ->update([
                'master_id'   => (int)$master['id'],
                'status'      => OrderStatus::ACCEPTED,
                'accept_time' => time(),
                'updatetime'  => time(),
            ]);
        if (!$affected) {
            $this->error('手慢了，该订单已被接走');
        }

        $this->addLog($orderId, OrderStatus::ACCEPTED, '师傅接单：' . $master['realname'], 'master', (int)$master['id']);
        $this->notify('user', (int)$order['user_id'], '师傅已接单', '师傅 ' . $master['realname'] . ' 已接单，将尽快与您联系', 'order', $orderId);

        $this->success('抢单成功，请在 2 小时内联系客户', [
            'order_id'    => $orderId,
            'deadline'    => time() + 7200,
            'user_mobile' => $order['mobile'],
        ]);
    }

    /**
     * 标记已联系客户（2 小时考核）
     * @ApiMethod (POST)
     */
    public function contact()
    {
        $order = $this->ownOrder((int)$this->request->post('order_id'), 'master');
        if ((int)$order['contact_time'] > 0) {
            $this->success('已记录');
        }
        Db::name('order')->where('id', $order['id'])->update(['contact_time' => time(), 'updatetime' => time()]);
        $this->addLog((int)$order['id'], (int)$order['status'], '师傅已联系客户', 'master', (int)$order['master_id']);
        $this->success('已记录联系时间');
    }

    /**
     * 设置预约上门时间
     * @ApiMethod (POST)
     */
    public function schedule()
    {
        $order = $this->ownOrder((int)$this->request->post('order_id'), 'master');
        if (!in_array((int)$order['status'], [OrderStatus::ACCEPTED, OrderStatus::APPOINTED], true)) {
            $this->error('当前状态（' . OrderStatus::label((int)$order['status']) . '）不可修改预约时间');
        }
        $appointTime = (int)$this->request->post('appoint_time');
        if ($appointTime <= 0) {
            $this->error('请选择上门时间');
        }
        if ((int)$order['status'] === OrderStatus::ACCEPTED) {
            $this->transit($order, OrderStatus::SCHEDULED, '已与客户约定上门时间：' . date('Y-m-d H:i', $appointTime), [
                'appoint_time' => $appointTime,
                'contact_time' => (int)$order['contact_time'] ?: time(),
            ], 'master', (int)$order['master_id']);
        } else {
            Db::name('order')->where('id', $order['id'])->update(['appoint_time' => $appointTime, 'updatetime' => time()]);
            $this->addLog((int)$order['id'], OrderStatus::SCHEDULED, '师傅变更预约上门时间为：' . date('Y-m-d H:i', $appointTime), 'master', (int)$order['master_id']);
        }
        $this->notify('user', (int)$order['user_id'], '师傅已预约上门', '约定时间：' . date('m-d H:i', $appointTime), 'order', (int)$order['id']);
        $this->success('预约成功');
    }

    /**
     * 到达现场（定位打卡，不覆盖客户收货地址经纬度，签到坐标记录入日志）
     * @ApiMethod (POST)
     */
    public function arrive()
    {
        $order = $this->ownOrder((int)$this->request->post('order_id'), 'master');
        $lng = trim((string)$this->request->post('lng', ''));
        $lat = trim((string)$this->request->post('lat', ''));
        $extra = ['arrive_time' => time()];
        $remark = '师傅已到达现场';
        if ($lng !== '' && $lat !== '') {
            $remark .= sprintf('（签到坐标: %.6f, %.6f）', (float)$lng, (float)$lat);
            if (!empty($order['lat']) && !empty($order['lng'])) {
                $check = TiandituService::checkArriveDistance((float)$order['lat'], (float)$order['lng'], (float)$lat, (float)$lng, 1500.0);
                if (!$check['is_pass']) {
                    $remark .= " [异地打卡预警: 偏离{$check['distance']}米]";
                }
            }
        }
        $this->transit($order, OrderStatus::ARRIVED, $remark, $extra, 'master', (int)$order['master_id']);
        $this->notify('user', (int)$order['user_id'], '师傅已到达', '师傅已到达服务地址，请做好准备', 'order', (int)$order['id']);
        $this->success('已打卡到达');
    }

    /**
     * 开始服务
     * @ApiMethod (POST)
     */
    public function startJob()
    {
        $order = $this->ownOrder((int)$this->request->post('order_id'), 'master');
        $this->transit($order, OrderStatus::WORKING, '师傅开始施工', ['start_time' => time()], 'master', (int)$order['master_id']);
        $this->notify('user', (int)$order['user_id'], '师傅已开工', '师傅已开始服务，请留意进度', 'order', (int)$order['id']);
        $this->success('已开工');
    }

    /**
     * 完工并提交现场取证 → 进入待验收
     * @ApiMethod (POST)
     */
    public function finish()
    {
        $order = $this->ownOrder((int)$this->request->post('order_id'), 'master');
        $images = (array)$this->request->post('images/a', []);
        $damage = trim((string)$this->request->post('damage_remark', ''));

        Db::startTrans();
        try {
            $this->transit($order, OrderStatus::PENDING_VERIFY, '师傅完工，等待客户验收', [
                'finish_time' => time(),
            ], 'master', (int)$order['master_id']);

            foreach ($images as $url) {
                if (!$url) {
                    continue;
                }
                Db::name('order_media')->insert([
                    'order_id'   => (int)$order['id'],
                    'master_id'  => (int)$order['master_id'],
                    'stage'      => $damage !== '' ? 'damage' : 'finish',
                    'type'       => 'image',
                    'url'        => (string)$url,
                    'watermark'  => date('Y-m-d H:i') . ' ' . $order['address'],
                    'remark'     => $damage !== '' ? mb_substr($damage, 0, 255) : '',
                    'createtime' => time(),
                ]);
            }
            Db::commit();
        } catch (\Exception $e) {
            Db::rollback();
            $this->error('提交失败：' . $e->getMessage());
        }

        $code = (string)$order['verify_code'];
        if (!empty($order['mobile'])) {
            SmsService::sendVerifyCode($order['mobile'], $code, $order['order_no']);
        }
        $this->notify('user', (int)$order['user_id'], '师傅已完工，待您验收', '验收码：' . $code . '，请核对后确认完成', 'order', (int)$order['id']);
        $this->success('已提交完工，等待客户验收');
    }

    /**
     * 我的订单（师傅视角）
     */
    /**
     * 师傅端：输入客户 6 位短信核销码完成工单验收结算
     * @ApiMethod (POST)
     */
    public function verifyCode()
    {
        $orderId = (int)$this->request->post('order_id');
        $code = trim((string)$this->request->post('verify_code', ''));

        if ($orderId <= 0 || $code === '') {
            $this->error('请输入 6 位核销验证码');
        }

        $master = $this->requireMaster();
        $order = Db::name('order')->where('id', $orderId)->find();
        if (!$order) {
            $this->error('订单不存在');
        }
        if ((int)$order['master_id'] !== (int)$master['id']) {
            $this->error('无权操作该订单');
        }
        if ((int)$order['status'] !== OrderStatus::PENDING_VERIFY) {
            $this->error('当前状态（' . OrderStatus::label($order['status']) . '）不可核销');
        }

        if ((string)$order['verify_code'] !== '' && (string)$order['verify_code'] !== $code) {
            $this->error('核销验证码不正确，请核对后重新输入');
        }

        $masterId = (int)$master['id'];
        $payAmount = (float)$order['pay_amount'];
        $rate = 10.00;
        $commission = round($payAmount * $rate / 100, 2);
        $settleAmount = round($payAmount - $commission, 2);

        $newMoney = 0.00;
        Db::startTrans();
        try {
            $lockedOrder = Db::name('order')->where('id', $orderId)->lock(true)->find();
            if (!$lockedOrder || (int)$lockedOrder['status'] !== OrderStatus::PENDING_VERIFY || (int)$lockedOrder['settle_status'] === 1) {
                throw new \InvalidArgumentException('该工单已核销完成或状态已变更，请勿重复提交');
            }
            $payAmount = (float)$lockedOrder['pay_amount'];
            $commission = round($payAmount * $rate / 100, 2);
            $settleAmount = round($payAmount - $commission, 2);

            $this->transit($lockedOrder, OrderStatus::COMPLETED, '师傅已录入客户 6 位短信验证码，核销完工', [
                'verify_time'   => time(),
                'settle_status' => 1,
                'settle_amount' => $settleAmount,
            ], 'master', $masterId);

            Db::name('settle')->insert([
                'order_id'        => $orderId,
                'master_id'       => $masterId,
                'order_amount'    => $payAmount,
                'commission_rate' => $rate,
                'commission'      => $commission,
                'settle_amount'   => $settleAmount,
                'status'          => 'settled',
                'settle_time'     => time(),
                'createtime'      => time(),
            ]);

            $masterInfo = Db::name('master')->where('id', $masterId)->lock(true)->find();
            $newMoney = round((float)$masterInfo['money'] + $settleAmount, 2);
            Db::name('master')->where('id', $masterId)->update([
                'money'       => $newMoney,
                'order_count' => (int)$masterInfo['order_count'] + 1,
                'updatetime'  => time(),
            ]);

            Db::name('wallet_log')->insert([
                'user_type'  => 'master',
                'user_id'    => $masterId,
                'type'       => 'settle',
                'amount'     => $settleAmount,
                'balance'    => $newMoney,
                'order_id'   => $orderId,
                'remark'     => '工单 ' . $lockedOrder['order_no'] . ' 短信验证码核销入账',
                'createtime' => time(),
            ]);

            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('[Master::verifyCode] ' . $e->getMessage());
            $this->error('核销失败：' . $e->getMessage());
            return;
        }

        $this->notify('user', (int)$order['user_id'], '订单已核销完成', '您的工单已由师傅现场核销完成，感谢您的支持！', 'order', $orderId);
        $this->success('验收核销成功！工费已结算至您的钱包', [
            'settle_amount' => $settleAmount,
            'balance'       => $newMoney
        ]);
    }

    public function myOrders()
    {
        return $this->orders();
    }

    public function orders()
    {
        $master = $this->requireMaster();
        $status = $this->request->param('status', 'active');
        $page = max(1, (int)$this->request->param('page', 1));
        $limit = min(30, max(1, (int)$this->request->param('limit', 10)));

        // TP5 中 count() 会重置查询条件，故用闭包重建
        $build = function () use ($master, $status) {
            $q = Db::name('order')->where('master_id', $master['id']);
            if ($status === 'active') {
                $q->where('status', 'in', [OrderStatus::ACCEPTED, OrderStatus::SCHEDULED, OrderStatus::ARRIVED, OrderStatus::WORKING]);
            } elseif ($status === 'verify') {
                $q->where('status', OrderStatus::PENDING_VERIFY);
            } elseif ($status === 'completed') {
                $q->where('status', OrderStatus::COMPLETED);
            }
            return $q;
        };

        $total = $build()->count();
        $list = $build()->order('id desc')->page($page, $limit)->select();

        $serviceIds = array_values(array_unique(array_filter(array_map('intval', array_column($list, 'service_id')))));
        $serviceImgMap = $serviceIds ? Db::name('service')->where('id', 'in', $serviceIds)->column('image', 'id') : [];

        foreach ($list as &$row) {
            unset($row['verify_code']);
            $row['status_text'] = OrderStatus::label($row['status']);
            $row['pay_amount'] = (float)$row['pay_amount'];
            $row['appoint_text'] = $row['appoint_time'] ? date('m-d H:i', (int)$row['appoint_time']) : '尽快上门';
            $row['urgent'] = (int)$row['urgent'];
            $row['masked_mobile'] = substr_replace($row['mobile'], '****', 3, 4);
            $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'     => $list,
            'total'    => (int)$total,
            'page'     => $page,
            'has_more' => ($page * $limit) < (int)$total,
        ]);
    }

    /**
     * 收入概览
     */
    public function income()
    {
        $master = $this->requireMaster();
        $todayStart = strtotime(date('Y-m-d'));
        $todayIncome = Db::name('wallet_log')->where('user_type', 'master')->where('user_id', $master['id'])
            ->where('type', 'settle')->where('createtime', '>=', $todayStart)->sum('amount');
        $totalIncome = Db::name('wallet_log')->where('user_type', 'master')->where('user_id', $master['id'])
            ->where('type', 'settle')->sum('amount');
        $logs = Db::name('wallet_log')->where('user_type', 'master')->where('user_id', $master['id'])
            ->order('id desc')->limit(20)->select();

        $this->success('', [
            'money'        => (float)$master['money'],
            'frozen_money' => (float)$master['frozen_money'],
            'today_income' => round((float)$todayIncome, 2),
            'total_income' => round((float)$totalIncome, 2),
            'order_count'  => (int)$master['order_count'],
            'logs'         => $logs,
        ]);
    }

    /**
     * 报价（报价竞价单）
     * @ApiMethod (POST)
     */
    public function quote()
    {
        $master = $this->requireMaster();
        if ($master['work_status'] !== 'on') {
            $this->error('您已暂停接单，请先开启');
        }
        $orderId = (int)$this->request->post('order_id');
        $amount = (float)$this->request->post('amount');
        $desc = trim((string)$this->request->post('description', ''));
        $hours = min(72, max(1, (int)$this->request->post('valid_hours', 24)));

        $order = Db::name('order')->where('id', $orderId)->find();
        if (!$order) {
            $this->error('订单不存在');
        }
        if ((int)$order['user_id'] === (int)$this->uid()) {
            $this->error('不能承接或报价自己发布的订单');
        }
        if ($order['price_type'] !== 'quote') {
            $this->error('该订单不是报价竞价订单');
        }
        if (!in_array((int)$order['status'], [OrderStatus::PENDING_ACCEPT, OrderStatus::QUOTING], true)) {
            $this->error('该订单已不在报价阶段');
        }
        if ((int)$order['master_id'] > 0) {
            $this->error('该订单已选定师傅');
        }
        if ($amount <= 0) {
            $this->error('请填写报价金额');
        }
        if (Db::name('order_quote')->where('order_id', $orderId)->where('master_id', $master['id'])->find()) {
            $this->error('您已报价，请勿重复提交');
        }

        Db::name('order_quote')->insert([
            'order_id'    => $orderId,
            'master_id'   => (int)$master['id'],
            'amount'      => round($amount, 2),
            'description' => mb_substr($desc, 0, 500),
            'valid_hours' => $hours,
            'expire_time' => time() + $hours * 3600,
            'status'      => 'wait',
            'createtime'  => time(),
        ]);

        // 兼容旧流程：已支付但仍在待接单的报价单，收到首个报价时进入「报价中」
        if ((int)$order['status'] === OrderStatus::PENDING_ACCEPT) {
            $this->transit($order, OrderStatus::QUOTING, '收到师傅报价，订单进入报价中', [], 'master', (int)$master['id']);
        }
        $this->notify('user', (int)$order['user_id'], '收到新报价', '师傅 ' . $master['realname'] . ' 对订单 ' . $order['order_no'] . ' 报价 ¥' . round($amount, 2) . '，请前往订单详情选择', 'order', $orderId);

        $this->success('报价已提交');
    }

    /**
     * 申请提现
     * @ApiMethod (POST)
     */
    public function withdraw()
    {
        $master = $this->requireMaster();
        $amount = round((float)$this->request->post('amount'), 2);
        if ($amount < 10) {
            $this->error('单次提现金额不少于 10 元');
        }
        $channel = trim((string)$this->request->post('channel', 'wechat'));
        if (!in_array($channel, ['wechat', 'bank'], true)) {
            $channel = 'wechat';
        }
        $account = mb_substr(trim((string)$this->request->post('account', '')), 0, 100);
        $fee = round($amount * 0.006, 2);
        $arrive = round($amount - $fee, 2);
        $now = time();

        Db::startTrans();
        try {
            $lockedMaster = Db::name('master')->where('id', (int)$master['id'])->lock(true)->find();
            if (!$lockedMaster || $amount > (float)$lockedMaster['money']) {
                throw new \InvalidArgumentException('可提现余额不足');
            }

            $newMoney = round((float)$lockedMaster['money'] - $amount, 2);
            $newFrozen = round((float)$lockedMaster['frozen_money'] + $amount, 2);

            Db::name('master')->where('id', (int)$lockedMaster['id'])->update([
                'money'        => $newMoney,
                'frozen_money' => $newFrozen,
                'updatetime'   => $now,
            ]);

            Db::name('withdraw')->insert([
                'master_id'     => (int)$lockedMaster['id'],
                'amount'        => $amount,
                'fee'           => $fee,
                'arrive_amount' => $arrive,
                'channel'       => $channel,
                'account'       => $account,
                'status'        => 'wait',
                'createtime'    => $now,
                'updatetime'    => $now,
            ]);

            Db::name('wallet_log')->insert([
                'user_type'  => 'master',
                'user_id'    => (int)$lockedMaster['id'],
                'type'       => 'withdraw',
                'amount'     => -$amount,
                'balance'    => $newMoney,
                'order_id'   => 0,
                'remark'     => '提现申请（手续费 ¥' . $fee . '）',
                'createtime' => $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('[Master::withdraw] ' . $e->getMessage());
            $this->error('提现申请失败：' . $e->getMessage());
            return;
        }

        $this->success('提现申请已提交，等待审核', ['arrive_amount' => $arrive]);
    }

    /**
     * 超 2 小时未联系客户 → 订单自动回流大厅
     */
    protected function recycleExpired()
    {
        $rows = Db::name('order')
            ->where('status', OrderStatus::ACCEPTED)
            ->where('contact_time', 0)
            ->where('accept_time', '<', time() - 7200)
            ->limit(50)
            ->select();
        foreach ($rows as $row) {
            $toStatus = $row['price_type'] === 'quote' ? OrderStatus::QUOTING : OrderStatus::PENDING_ACCEPT;
            Db::name('order')->where('id', $row['id'])->update([
                'master_id'   => 0,
                'status'      => $toStatus,
                'accept_time' => null,
                'updatetime'  => time(),
            ]);
            if ($row['price_type'] === 'quote') {
                Db::name('order_quote')->where('order_id', $row['id'])->where('status', 'accept')->update(['status' => 'wait']);
            }
            $this->addLog($row['id'], $toStatus, $row['price_type'] === 'quote' ? '师傅超 2 小时未联系客户，订单重新开放报价' : '超 2 小时未联系客户，订单自动回流大厅', 'system', 0);
        }
    }

    /**
     * 信用体系：综合评分 / 接单率 / 准时率 / 好评率 / 投诉率
     */
    public function credit()
    {
        $master = $this->requireMaster();
        $mid = (int)$master['id'];

        $reviewTotal = (int)Db::name('review')->where('master_id', $mid)->where('status', 'normal')->count();
        $reviewGood = (int)Db::name('review')->where('master_id', $mid)->where('status', 'normal')->where('score', '>=', 4)->count();
        $appealCount = (int)Db::name('appeal')->where('master_id', $mid)->count();
        $orderCount = max(1, (int)$master['order_count']);

        $this->success('', [
            'score'          => (float)$master['score'],
            'level'          => (int)$master['level'],
            'accept_rate'    => (float)$master['accept_rate'],
            'ontime_rate'    => (float)$master['ontime_rate'],
            'good_rate'      => $reviewTotal ? round($reviewGood * 100 / $reviewTotal, 1) : 100,
            'complaint_rate' => round($appealCount * 100 / $orderCount, 1),
            'order_count'    => (int)$master['order_count'],
            'review_total'   => $reviewTotal,
            'appeal_total'   => $appealCount,
            'rules'          => [
                '综合评分 = 客户评价星级平均值（5 分制）',
                '接单率 = 已联系客户订单 / 接单总数',
                '准时率 = 按预约时间到达 / 上门总数',
                '好评率 = 4 星及以上评价占比',
                '投诉率 = 申诉工单数 / 完成订单数',
            ],
        ]);
    }

    /**
     * 申诉中心：列表
     */
    public function appeals()
    {
        $master = $this->requireMaster();
        $list = Db::name('appeal')->where('master_id', $master['id'])->order('id desc')->limit(30)->select();
        $typeText = ['misjudge' => '误判申诉', 'review' => '恶意评价', 'deduct' => '扣款申诉', 'other' => '其他'];
        $statusText = ['wait' => '待处理', 'handling' => '处理中', 'done' => '已处理', 'reject' => '已驳回'];
        foreach ($list as &$row) {
            $row['type_text'] = isset($typeText[$row['type']]) ? $typeText[$row['type']] : '其他';
            $row['status_text'] = isset($statusText[$row['status']]) ? $statusText[$row['status']] : $row['status'];
            $row['time_text'] = date('Y-m-d H:i', (int)$row['createtime']);

            $imgs = [];
            if (!empty($row['images'])) {
                $dec = json_decode((string)$row['images'], true);
                $rawImgs = is_array($dec) ? $dec : explode(',', (string)$row['images']);
                foreach ($rawImgs as $im) {
                    $im = trim((string)$im);
                    if ($im !== '') {
                        $imgs[] = strpos($im, 'http') === 0 ? $im : cdnurl($im, true);
                    }
                }
            }
            // 兼容清洗历史拼接在文本末尾的 [举证图片: ...]
            $content = (string)$row['content'];
            if (preg_match('/\[举证图片:\s*(.+?)\]\s*$/u', $content, $matches)) {
                $content = trim(preg_replace('/\[举证图片:\s*(.+?)\]\s*$/u', '', $content));
                foreach (explode(',', $matches[1]) as $extraIm) {
                    $extraIm = trim($extraIm);
                    if ($extraIm !== '') {
                        $full = strpos($extraIm, 'http') === 0 ? $extraIm : cdnurl($extraIm, true);
                        if (!in_array($full, $imgs, true)) {
                            $imgs[] = $full;
                        }
                    }
                }
            }
            $row['content'] = $content;
            $row['image_list'] = $imgs;
        }
        unset($row);
        $this->success('', ['list' => $list]);
    }

    /**
     * 申诉中心：提交
     * @ApiMethod (POST)
     */
    public function appeal()
    {
        $master = $this->requireMaster();
        $type = $this->request->post('type', 'other');
        $orderId = (int)$this->request->post('order_id', 0);
        $content = trim((string)$this->request->post('content'));
        if (!in_array($type, ['misjudge', 'review', 'deduct', 'other'], true)) {
            $this->error('申诉类型错误');
        }
        if (mb_strlen($content) < 5) {
            $this->error('请填写至少 5 个字的申诉说明');
        }
        if (Db::name('appeal')->where('master_id', $master['id'])->where('status', 'wait')->count() >= 5) {
            $this->error('您有多个待处理申诉，请等待处理完成');
        }
        Db::name('appeal')->insert([
            'master_id'  => $master['id'],
            'order_id'   => $orderId,
            'type'       => $type,
            'content'    => mb_substr($content, 0, 500),
            'images'     => (string)$this->request->post('images', ''),
            'status'     => 'wait',
            'createtime' => time(),
            'updatetime' => time(),
        ]);
        $this->success('申诉已提交，平台将在 24 小时内处理');
    }

    /**
     * 我的报价记录
     */
    public function quotes()
    {
        $master = $this->requireMaster();
        $list = Db::name('order_quote')->alias('q')
            ->join('order o', 'o.id = q.order_id', 'LEFT')
            ->field('q.*, o.order_no, o.service_name, o.pay_amount as order_amount, o.status as order_status')
            ->where('q.master_id', $master['id'])
            ->order('q.id desc')
            ->limit(30)
            ->select();
        $statusText = ['wait' => '等待客户选择', 'accept' => '已被选中', 'reject' => '未被选中', 'expired' => '已过期'];
        foreach ($list as &$row) {
            $row['status_text'] = isset($statusText[$row['status']]) ? $statusText[$row['status']] : $row['status'];
            $row['amount'] = (float)$row['amount'];
            $row['time_text'] = date('m-d H:i', (int)$row['createtime']);
            $row['expire_text'] = date('m-d H:i', (int)$row['expire_time']);
        }
        unset($row);
        $this->success('', ['list' => $list]);
    }
/**
     * 计算两点间距离 (km)
     */
    protected function calculateDistance($lat1, $lon1, $lat2, $lon2)
    {
        if (empty($lat1) || empty($lon1) || empty($lat2) || empty($lon2)) {
            return null;
        }
        $earthRadius = 6371;
        $dLat = deg2rad((float)$lat2 - (float)$lat1);
        $dLon = deg2rad((float)$lon2 - (float)$lon1);
        $a = sin($dLat / 2) * sin($dLat / 2) +
            cos(deg2rad((float)$lat1)) * cos(deg2rad((float)$lat2)) *
            sin($dLon / 2) * sin($dLon / 2);
        $c = 2 * atan2(sqrt($a), sqrt(1 - $a));
        return round($earthRadius * $c, 2);
    }

    /**
     * 师傅端订单抢单详情
     * @ApiMethod (GET)
     */
    /**
     * 师傅端：施工现场发起增项补差价申请
     * @ApiMethod (POST)
     */
    public function requestDiff()
    {
        $orderId = (int)$this->request->post('order_id');
        $amount = round((float)$this->request->post('amount'), 2);
        $remark = trim((string)$this->request->post('remark', '现场增项费用'));
        $image = trim((string)$this->request->post('image', ''));

        if ($orderId <= 0 || $amount <= 0) {
            $this->error('请输入有效的补差价金额');
        }

        $master = $this->requireMaster();
        $order = Db::name('order')->where('id', $orderId)->find();
        if (!$order || (int)$order['master_id'] !== (int)$master['id']) {
            $this->error('无权操作该订单');
        }

        $allowedStatus = [OrderStatus::ARRIVED, OrderStatus::WORKING];
        if (!in_array((int)$order['status'], $allowedStatus, true)) {
            $this->error('当前状态不可发起增项补差价');
        }

        Db::name('order')->where('id', $orderId)->update([
            'diff_amount' => $amount,
            'diff_status' => 1, // 1: 待客户支付
            'diff_remark' => mb_substr($remark, 0, 255),
            'diff_image'  => $image,
            'updatetime'  => time(),
        ]);

        $this->addLog($orderId, (int)$order['status'], '师傅发起施工现场增项补差价申请 ¥' . $amount . '，原因：' . $remark, 'master', (int)$master['id']);
        $this->notify('user', (int)$order['user_id'], '师傅发起增项补差价申请', '工单 ' . $order['order_no'] . ' 师傅申请增项补差价 ¥' . $amount . '，请查看并在线支付', 'order', $orderId);

        $this->success('已发起增项补差价申请，请提醒客户在线支付');
    }

    public function orderDetail()
    {
        $master = $this->requireMaster();
        $masterId = (int)$master['id'];
        $orderId = (int)$this->request->param('id') ?: (int)$this->request->param('order_id');
        if ($orderId <= 0) {
            $this->error('参数错误');
        }
        $order = Db::name('order')->where('id', $orderId)->find();
        if (!$order) {
            $this->error('订单不存在');
        }

        $isMyOrder = ($masterId > 0 && (int)$order['master_id'] === $masterId);
        $inHall = in_array((int)$order['status'], [OrderStatus::PENDING_ACCEPT, OrderStatus::QUOTING], true);
        if (!$isMyOrder && !$inHall) {
            $this->error('该订单已被其他师傅接单或已结束');
        }

        $now = time();
        $quoteCount = (int)Db::name('order_quote')->where('order_id', $orderId)->count();
        $myQuote = $masterId > 0 ? Db::name('order_quote')
            ->where('order_id', $orderId)
            ->where('master_id', $masterId)
            ->find() : null;

        $maxQuotes = 4;
        $remainingQuoteSlots = max(0, $maxQuotes - $quoteCount);
        $deadline = (int)$order['createtime'] + 3 * 86400;
        $countdownSeconds = max(0, $deadline - $now);

        $mobile = (string)$order['mobile'];
        $address = (string)$order['address'];
        if (!$isMyOrder) {
            $mobile = strlen($mobile) >= 7 ? substr_replace($mobile, '****', 3, 4) : $mobile;
            $address = preg_replace('/\d+号|\d+栋|\d+单元|\d+室/', '***', $address);
            if (mb_strlen($address) > 10) {
                $address = mb_substr($address, 0, 8) . '****号';
            }
        }

        $defaultLat = ($master && !empty($master['lat'])) ? (float)$master['lat'] : 0.0;
        $defaultLng = ($master && !empty($master['lng'])) ? (float)$master['lng'] : 0.0;
        $userLat = (float)$this->request->param('lat', $defaultLat);
        $userLng = (float)$this->request->param('lng', $defaultLng);
        $dist = $this->calculateDistance($userLat, $userLng, (float)$order['lat'], (float)$order['lng']);

        $service = Db::name('service')->where('id', $order['service_id'])->find();
        $category = Db::name('service_cat')->where('id', $order['cat_id'])->find();

        // 安全解析商品图片、视频、备注与多商品清单（彻底杜绝子数组强转 (string) 报错）
        $normalizeMediaList = function ($rawMedia) {
            $urls = [];
            if (empty($rawMedia)) {
                return $urls;
            }
            if (is_string($rawMedia)) {
                $dec = json_decode($rawMedia, true);
                $items = is_array($dec) ? $dec : explode(',', $rawMedia);
            } elseif (is_array($rawMedia)) {
                $items = $rawMedia;
            } else {
                return $urls;
            }
            foreach ($items as $it) {
                $u = '';
                if (is_string($it) || is_numeric($it)) {
                    $u = trim((string)$it);
                } elseif (is_array($it)) {
                    if (isset($it['url']) && is_string($it['url'])) {
                        $u = trim($it['url']);
                    } elseif (isset($it['path']) && is_string($it['path'])) {
                        $u = trim($it['path']);
                    } elseif (isset($it['tempFilePath']) && is_string($it['tempFilePath'])) {
                        $u = trim($it['tempFilePath']);
                    }
                }
                if ($u !== '' && $u !== 'Array') {
                    $full = strpos($u, 'http') === 0 ? $u : cdnurl($u, true);
                    if (!in_array($full, $urls, true)) {
                        $urls[] = $full;
                    }
                }
            }
            return $urls;
        };

        $goodsImages = [];
        $envImages = [];
        $goodsVideos = [];
        $parsedGoodsList = [];
        $topGoodsRemark = '';
        $topServiceRemark = '';
        $topExtras = [];

        if (!empty($order['goods_images'])) {
            $decoded = json_decode((string)$order['goods_images'], true);
            if (is_array($decoded)) {
                if (isset($decoded['images'])) {
                    $goodsImages = array_merge($goodsImages, $normalizeMediaList($decoded['images']));
                } elseif (!isset($decoded['goods_list'])) {
                    $goodsImages = array_merge($goodsImages, $normalizeMediaList($decoded));
                }
                if (isset($decoded['videos'])) {
                    $goodsVideos = array_merge($goodsVideos, $normalizeMediaList($decoded['videos']));
                }
                if (isset($decoded['goods_videos'])) {
                    $goodsVideos = array_merge($goodsVideos, $normalizeMediaList($decoded['goods_videos']));
                }
                if (!empty($decoded['goods_remark']) && is_string($decoded['goods_remark'])) {
                    $topGoodsRemark = trim($decoded['goods_remark']);
                }
                if (!empty($decoded['service_remark']) && is_string($decoded['service_remark'])) {
                    $topServiceRemark = trim($decoded['service_remark']);
                }
                if (!empty($decoded['extras']) && is_array($decoded['extras'])) {
                    $topExtras = $decoded['extras'];
                }
                if (!empty($decoded['goods_list']) && is_array($decoded['goods_list'])) {
                    $parsedGoodsList = $decoded['goods_list'];
                }
            } else {
                $goodsImages = array_merge($goodsImages, $normalizeMediaList((string)$order['goods_images']));
            }
        }

        // 解析 parsedGoodsList 中的多媒体、增项与备注，以便补充到 order_goods 行
        $parsedMetaByIdx = [];
        foreach ($parsedGoodsList as $pIdx => $pgItem) {
            if (!is_array($pgItem)) {
                continue;
            }
            $itemImgs = [];
            if (!empty($pgItem['images'])) {
                $itemImgs = array_merge($itemImgs, $normalizeMediaList($pgItem['images']));
            }
            if (!empty($pgItem['goods_images'])) {
                $itemImgs = array_merge($itemImgs, $normalizeMediaList($pgItem['goods_images']));
            }
            if (!empty($pgItem['goods_image'])) {
                $itemImgs = array_merge($itemImgs, $normalizeMediaList([$pgItem['goods_image']]));
            }
            foreach ($itemImgs as $imUrl) {
                if (!in_array($imUrl, $goodsImages, true)) {
                    $goodsImages[] = $imUrl;
                }
            }

            $itemEnvImgs = [];
            if (!empty($pgItem['envImages'])) {
                $itemEnvImgs = array_merge($itemEnvImgs, $normalizeMediaList($pgItem['envImages']));
            }
            if (!empty($pgItem['env_images'])) {
                $itemEnvImgs = array_merge($itemEnvImgs, $normalizeMediaList($pgItem['env_images']));
            }
            foreach ($itemEnvImgs as $envUrl) {
                if (!in_array($envUrl, $envImages, true)) {
                    $envImages[] = $envUrl;
                }
            }

            $itemVids = [];
            if (!empty($pgItem['videos'])) {
                $itemVids = array_merge($itemVids, $normalizeMediaList($pgItem['videos']));
            }
            if (!empty($pgItem['goods_videos'])) {
                $itemVids = array_merge($itemVids, $normalizeMediaList($pgItem['goods_videos']));
            }
            foreach ($itemVids as $vdUrl) {
                if (!in_array($vdUrl, $goodsVideos, true)) {
                    $goodsVideos[] = $vdUrl;
                }
            }

            $gRem = isset($pgItem['goods_remark']) && is_string($pgItem['goods_remark'])
                ? trim($pgItem['goods_remark'])
                : (isset($pgItem['remark']) && is_string($pgItem['remark']) ? trim($pgItem['remark']) : '');
            $sRem = isset($pgItem['service_remark']) && is_string($pgItem['service_remark']) ? trim($pgItem['service_remark']) : '';
            $itemExtras = [];
            if (!empty($pgItem['extras']) && is_array($pgItem['extras'])) {
                foreach ($pgItem['extras'] as $ex) {
                    if (is_array($ex) && (!isset($ex['num']) || (int)$ex['num'] > 0)) {
                        $itemExtras[] = $ex;
                        $topExtras[] = $ex;
                    }
                }
            }

            if ($gRem !== '' && $topGoodsRemark === '') {
                $topGoodsRemark = $gRem;
            }
            if ($sRem !== '' && $topServiceRemark === '') {
                $topServiceRemark = $sRem;
            }

            $parsedMetaByIdx[$pIdx] = [
                'images'         => $itemImgs,
                'goods_videos'   => $itemVids,
                'goods_remark'   => $gRem,
                'service_remark' => $sRem,
                'extras'         => $itemExtras,
            ];
        }

        $orderGoodsRows = Db::name('order_goods')->where('order_id', $orderId)->order('id asc')->select();
        $goodsList = [];
        if ($orderGoodsRows) {
            foreach ($orderGoodsRows as $rIdx => $og) {
                $gImg = !empty($og['goods_image']) ? (strpos($og['goods_image'], 'http') === 0 ? $og['goods_image'] : cdnurl($og['goods_image'], true)) : '';
                $meta = isset($parsedMetaByIdx[$rIdx]) ? $parsedMetaByIdx[$rIdx] : [
                    'images'         => $gImg !== '' ? [$gImg] : [],
                    'goods_videos'   => [],
                    'goods_remark'   => '',
                    'service_remark' => '',
                    'extras'         => [],
                ];
                $rowExtras = $meta['extras'];
                $addonRaw = (string)$og['addon_services'];
                if (empty($rowExtras) && $addonRaw !== '' && $addonRaw[0] === '[') {
                    $decAddon = json_decode($addonRaw, true);
                    if (is_array($decAddon)) {
                        $rowExtras = $decAddon;
                        if (empty($topExtras)) {
                            $topExtras = $decAddon;
                        }
                    }
                }
                $goodsList[] = [
                    'id'             => (int)$og['id'],
                    'service_id'     => (int)$og['service_id'],
                    'goods_name'     => (string)$og['goods_name'],
                    'goods_model'    => (string)$og['goods_model'],
                    'goods_num'      => (int)$og['goods_num'] ?: 1,
                    'goods_image'    => $gImg ?: (!empty($meta['images']) ? $meta['images'][0] : ''),
                    'images'         => $meta['images'],
                    'goods_videos'   => $meta['goods_videos'],
                    'goods_remark'   => $meta['goods_remark'],
                    'service_remark' => $meta['service_remark'],
                    'extras'         => $rowExtras,
                    'addon_services' => $addonRaw,
                    'base_price'     => (float)$og['base_price'],
                ];
            }
        } elseif ($parsedGoodsList) {
            foreach ($parsedGoodsList as $idx => $pg) {
                if (!is_array($pg)) {
                    continue;
                }
                $meta = isset($parsedMetaByIdx[$idx]) ? $parsedMetaByIdx[$idx] : [
                    'images'         => [],
                    'goods_videos'   => [],
                    'goods_remark'   => '',
                    'service_remark' => '',
                    'extras'         => [],
                ];
                $rawImg = '';
                if (!empty($pg['goods_image']) && is_string($pg['goods_image'])) {
                    $rawImg = trim($pg['goods_image']);
                } elseif (!empty($pg['image']) && is_string($pg['image'])) {
                    $rawImg = trim($pg['image']);
                }
                $firstMetaImg = !empty($meta['images']) ? $meta['images'][0] : '';
                $addonText = '';
                if (!empty($pg['addon_services'])) {
                    $addonText = is_array($pg['addon_services'])
                        ? json_encode($pg['addon_services'], JSON_UNESCAPED_UNICODE)
                        : (string)$pg['addon_services'];
                } elseif (!empty($meta['extras'])) {
                    $addonText = json_encode($meta['extras'], JSON_UNESCAPED_UNICODE);
                }
                $gNameVal = '';
                foreach (['custom_name', 'goods_name', 'item_name', 'name'] as $nk) {
                    if (!empty($pg[$nk]) && is_string($pg[$nk])) {
                        $gNameVal = trim($pg[$nk]);
                        break;
                    }
                }
                $gModelVal = '';
                foreach (['spec_name', 'goods_model', 'spec'] as $mk) {
                    if (!empty($pg[$mk]) && is_string($pg[$mk])) {
                        $gModelVal = trim($pg[$mk]);
                        break;
                    }
                }
                $goodsList[] = [
                    'id'             => $idx + 1,
                    'service_id'     => (int)($pg['service_id'] ?? $order['service_id']),
                    'goods_name'     => $gNameVal !== '' ? $gNameVal : ($order['service_name'] ?: '服务商品'),
                    'goods_model'    => $gModelVal,
                    'goods_num'      => max(1, (int)($pg['goods_num'] ?? ($pg['num'] ?? 1))),
                    'goods_image'    => $rawImg !== '' ? (strpos($rawImg, 'http') === 0 ? $rawImg : cdnurl($rawImg, true)) : $firstMetaImg,
                    'images'         => $meta['images'],
                    'goods_videos'   => $meta['goods_videos'],
                    'goods_remark'   => $meta['goods_remark'],
                    'service_remark' => $meta['service_remark'],
                    'extras'         => $meta['extras'],
                    'addon_services' => $addonText,
                    'base_price'     => (float)($pg['base_price'] ?? ($pg['price'] ?? 0)),
                ];
            }
        }

        $rawServiceImg = $order['service_image'] ?: ($service ? $service['image'] : '');
        $serviceImageUrl = $rawServiceImg ? (strpos($rawServiceImg, 'http') === 0 ? $rawServiceImg : cdnurl($rawServiceImg, true)) : '';

        $contactDisplay = $isMyOrder
            ? ($order['contact'] ?: '业主客户')
            : ($order['contact'] ? mb_substr($order['contact'], 0, 1) . '客户' : '业主客户');

        $prefix = trim($order['province'] . $order['city'] . $order['district']);
        $fullAddr = ($prefix !== '' && strpos($address, $order['district']) === false && strpos($address, $order['city']) === false)
            ? ($prefix . $address)
            : $address;

        // 计算结算比例与预计收益
        $commissionRate = 10.00;
        $payAmt = (float)$order['pay_amount'] > 0 ? (float)$order['pay_amount'] : (float)$order['total_amount'];
        $estCommission = round($payAmt * $commissionRate / 100, 2);
        $estMasterFee = round(max(0, $payAmt - $estCommission), 2);

        $data = [
            'id'                    => (int)$order['id'],
            'order_no'              => $order['order_no'],
            'price_type'            => $order['price_type'],
            'price_type_text'       => $order['price_type'] === 'fixed' ? '一口价' : ($order['price_type'] === 'quote' ? '师傅竞价' : ($order['price_type'] === 'custom' ? '用户定价' : '标准价')),
            'status'                => (int)$order['status'],
            'status_text'           => OrderStatus::label($order['status']),
            'total_amount'          => (float)$order['total_amount'],
            'base_amount'           => (float)$order['base_amount'],
            'floor_amount'          => (float)($order['floor_amount'] ?? 0),
            'urgent_amount'         => (float)($order['urgent_amount'] ?? 0),
            'pay_amount'            => (float)($order['pay_amount'] ?? 0),
            'master_fee'            => $estMasterFee,
            'user_price'            => $order['price_type'] === 'custom' ? (float)$order['base_amount'] : (float)$order['total_amount'],
            'service_name'          => $order['service_name'] ?: ($service ? $service['name'] : '家庭维修服务'),
            'service_image'         => $serviceImageUrl,
            'goods_images'          => $goodsImages,
            'env_images'            => $envImages,
            'goods_videos'          => $goodsVideos,
            'goods_remark'          => $topGoodsRemark,
            'service_remark'        => $topServiceRemark !== '' ? $topServiceRemark : (string)($order['remark'] ?: ''),
            'extras'                => $topExtras,
            'goods_list'            => $goodsList,
            'goods_model'           => $order['goods_model'] ?: '标准规格',
            'goods_num'             => (int)$order['goods_num'] ?: 1,
            'floor'                 => (int)($order['floor'] ?? 0),
            'has_elevator'          => (int)($order['has_elevator'] ?? 0),
            'urgent'                => (int)($order['urgent'] ?? 0),
            'cat_name'              => $category ? $category['name'] : '通用',
            'service_type_tag'      => $order['price_type'] === 'fixed' ? '一口价' : ($order['price_type'] === 'custom' ? '用户定价' : '维修'),
            'remark'                => $order['remark'] ?: '',
            'express_no'            => (string)($order['express_no'] ?? ''),
            'express_company'       => (string)($order['express_company'] ?? ''),
            'goods_arrived'         => (int)($order['goods_arrived'] ?? 1),
            'qual_req'              => (string)($order['qual_req'] ?? ''),
            'master_req'            => (string)($order['master_req'] ?? ''),
            'contact'               => $contactDisplay,
            'mobile'                => $mobile,
            'is_my_order'           => $isMyOrder,
            'province'              => $order['province'],
            'city'                  => $order['city'],
            'district'              => $order['district'],
            'full_address'          => $fullAddr,
            'lng'                   => $order['lng'],
            'lat'                   => $order['lat'],
            'distance_km'           => $dist,
            'appoint_time'          => (int)$order['appoint_time'],
            'appoint_time_text'     => $order['appoint_time'] ? date('Y-m-d H:i', (int)$order['appoint_time']) : '接单后与业主预约',
            'createtime'            => (int)$order['createtime'],
            'createtime_text'       => date('Y-m-d H:i', (int)$order['createtime']),
            'quote_count'           => $quoteCount,
            'remaining_quote_slots' => $remainingQuoteSlots,
            'countdown_seconds'     => $countdownSeconds,
            'my_quote'              => $myQuote ? [
                'id'          => (int)$myQuote['id'],
                'amount'      => (float)$myQuote['amount'],
                'description' => $myQuote['description'],
                'status'      => $myQuote['status'],
            ] : null,
            'can_grab'              => ($order['price_type'] !== 'quote' && (int)$order['status'] === OrderStatus::PENDING_ACCEPT && (int)$order['master_id'] === 0 && (int)$order['user_id'] !== $this->uid()),
            'can_quote'             => ($order['price_type'] === 'quote' && in_array((int)$order['status'], [OrderStatus::PENDING_ACCEPT, OrderStatus::QUOTING], true) && (int)$order['master_id'] === 0 && !$myQuote && (int)$order['user_id'] !== $this->uid()),
        ];

        // 本人已接工单：附带完整履约节点、增项补差、完工取证、结算入账与操作轨迹
        if ($isMyOrder) {
            $acceptTs = (int)($order['accept_time'] ?? 0);
            $contactTs = (int)($order['contact_time'] ?? 0);
            $arriveTs = (int)($order['arrive_time'] ?? 0);
            $startTs = (int)($order['start_time'] ?? 0);
            $finishTs = (int)($order['finish_time'] ?? 0);
            $verifyTs = (int)($order['verify_time'] ?? 0);

            $contactRemain = ($acceptTs > 0 && $contactTs <= 0) ? max(0, ($acceptTs + 7200) - $now) : 0;

            $diffImg = !empty($order['diff_image'])
                ? (strpos((string)$order['diff_image'], 'http') === 0 ? (string)$order['diff_image'] : cdnurl((string)$order['diff_image'], true))
                : '';

            $mediaRows = Db::name('order_media')->where('order_id', $orderId)->order('id asc')->select();
            $finishImages = [];
            $damageRemark = '';
            foreach ($mediaRows as $md) {
                $mUrl = !empty($md['url']) ? (strpos((string)$md['url'], 'http') === 0 ? (string)$md['url'] : cdnurl((string)$md['url'], true)) : '';
                if ($mUrl !== '') {
                    $finishImages[] = [
                        'id'        => (int)$md['id'],
                        'stage'     => (string)$md['stage'],
                        'url'       => $mUrl,
                        'watermark' => (string)$md['watermark'],
                        'remark'    => (string)$md['remark'],
                    ];
                }
                if ($damageRemark === '' && !empty($md['remark'])) {
                    $damageRemark = (string)$md['remark'];
                }
            }

            $settleRow = Db::name('settle')->where('order_id', $orderId)->order('id desc')->find();
            if ($settleRow) {
                $commissionRate = (float)$settleRow['commission_rate'];
                $estCommission = (float)$settleRow['commission'];
                $estMasterFee = (float)$settleRow['settle_amount'];
            }

            $logRows = Db::name('order_log')->where('order_id', $orderId)->order('id desc')->select();
            $logs = [];
            foreach ($logRows as $lg) {
                $logs[] = [
                    'id'            => (int)$lg['id'],
                    'status'        => (int)$lg['status'],
                    'status_text'   => OrderStatus::label((int)$lg['status']),
                    'remark'        => (string)$lg['remark'],
                    'operator_type' => (string)$lg['operator_type'],
                    'time_text'     => $lg['createtime'] ? date('m-d H:i', (int)$lg['createtime']) : '',
                ];
            }

            $data['accept_time'] = $acceptTs;
            $data['accept_time_text'] = $acceptTs > 0 ? date('Y-m-d H:i', $acceptTs) : '';
            $data['contact_time'] = $contactTs;
            $data['contact_time_text'] = $contactTs > 0 ? date('Y-m-d H:i', $contactTs) : '';
            $data['contact_remain'] = $contactRemain;
            $data['arrive_time'] = $arriveTs;
            $data['arrive_time_text'] = $arriveTs > 0 ? date('Y-m-d H:i', $arriveTs) : '';
            $data['start_time'] = $startTs;
            $data['start_time_text'] = $startTs > 0 ? date('Y-m-d H:i', $startTs) : '';
            $data['finish_time'] = $finishTs;
            $data['finish_time_text'] = $finishTs > 0 ? date('Y-m-d H:i', $finishTs) : '';
            $data['verify_time'] = $verifyTs;
            $data['verify_time_text'] = $verifyTs > 0 ? date('Y-m-d H:i', $verifyTs) : '';

            $data['diff_amount'] = (float)($order['diff_amount'] ?? 0);
            $data['diff_status'] = (int)($order['diff_status'] ?? 0);
            $data['diff_remark'] = (string)($order['diff_remark'] ?? '');
            $data['diff_image'] = $diffImg;

            $data['settle_status'] = (int)($order['settle_status'] ?? 0);
            $data['settle_amount'] = (int)($order['settle_status'] ?? 0) === 1 ? (float)$order['settle_amount'] : $estMasterFee;
            $data['commission_rate'] = $commissionRate;
            $data['commission'] = $estCommission;
            $data['master_fee'] = $data['settle_amount'];

            $data['finish_images'] = $finishImages;
            $data['damage_remark'] = $damageRemark;
            $data['logs'] = $logs;
        }

        $this->success('', $data);
    }

    /**
     * 获取技能字典树与师傅当前选定状态
     * @ApiMethod (GET)
     */
    public function skillDict()
    {
        $master = $this->masterInfo();
        $masterId = $master ? (int)$master['id'] : 0;

        // 1. 获取所有正常启用的字典项
        $dictList = Db::name('skill_dict')
            ->where('status', 'normal')
            ->order('weigh desc, id asc')
            ->select();

        // 2. 按大类分组
        $groups = [];
        $categoryOrder = ['安装维修', '建筑装修', '物流运输', '汽车服务', '家政服务', '便民服务'];
        foreach ($categoryOrder as $cat) {
            $groups[$cat] = [];
        }

        foreach ($dictList as $item) {
            $cat = $item['category'];
            if (!isset($groups[$cat])) {
                $groups[$cat] = [];
            }
            $groups[$cat][] = [
                'id'       => (int)$item['id'],
                'name'     => $item['name'],
                'category' => $item['category'],
                'source'   => $item['source'],
            ];
        }

        $tree = [];
        foreach ($groups as $catName => $items) {
            if (!empty($items)) {
                $tree[] = [
                    'category' => $catName,
                    'items'    => $items
                ];
            }
        }

        // 3. 当前师傅已勾选的技能（对齐标准字典项，历史类目名自动映射标准名，非字典项归入补充技能）
        $dictNameSet = [];
        foreach ($dictList as $dRow) {
            if (!empty($dRow['name'])) {
                $dictNameSet[(string)$dRow['name']] = true;
            }
        }
        $legacyAliasMap = [
            '家具安装'   => '家具',
            '卫浴洁具'   => '卫浴',
            '灯具电路'   => '灯具',
            '锁具安防'   => '锁具',
            '窗帘安装'   => '窗帘',
            '墙纸壁画'   => '墙纸/墙面',
            '墙纸/壁画'  => '墙纸/墙面',
            '净水设备'   => '净水器',
            '智能晾衣架' => '晾衣架',
            '门窗安装'   => '门窗',
            '家电安装'   => '家电',
            '电视投影'   => '电视/投影',
            '淋浴房安装' => '淋浴房',
            '商用厨电'   => '更多安装维修',
            '健身器材'   => '更多安装维修',
        ];

        $selectedNames = [];
        $customText = '';
        if ($masterId > 0) {
            $mySkills = Db::name('master_skill')->where('master_id', $masterId)->select();
            $customArr = [];
            foreach ($mySkills as $ms) {
                $sName = trim((string)(!empty($ms['skill_name']) ? $ms['skill_name'] : ''));
                if ($sName === '') {
                    continue;
                }
                if ((int)$ms['is_custom'] === 1 && !isset($dictNameSet[$sName])) {
                    if (!in_array($sName, $customArr, true)) {
                        $customArr[] = $sName;
                    }
                } elseif (isset($dictNameSet[$sName])) {
                    if (!in_array($sName, $selectedNames, true)) {
                        $selectedNames[] = $sName;
                    }
                } elseif (isset($legacyAliasMap[$sName]) && isset($dictNameSet[$legacyAliasMap[$sName]])) {
                    $mapped = $legacyAliasMap[$sName];
                    if (!in_array($mapped, $selectedNames, true)) {
                        $selectedNames[] = $mapped;
                    }
                } else {
                    if (!in_array($sName, $customArr, true)) {
                        $customArr[] = $sName;
                    }
                }
            }
            $customText = implode(' ', $customArr);
        }

        $this->success('ok', [
            'tree'            => $tree,
            'selected_skills' => $selectedNames,
            'custom_text'     => $customText,
        ]);
    }

    /**
     * 保存师傅服务技能与自定义输入技能
     * @ApiMethod (POST)
     */
    public function saveSkills()
    {
        $master = $this->requireMaster();
        $masterId = (int)$master['id'];

        // 同时兼容 skill_ids（ID 数组/逗号串/JSON串）与 selected_skills（名称数组/逗号串/JSON串）
        $parseStrList = function ($raw) {
            if (empty($raw)) {
                return [];
            }
            if (is_string($raw)) {
                $dec = json_decode(htmlspecialchars_decode(trim($raw)), true);
                $arr = is_array($dec) ? $dec : explode(',', $raw);
            } elseif (is_array($raw)) {
                $arr = $raw;
            } else {
                return [];
            }
            $out = [];
            foreach ($arr as $v) {
                if (is_array($v)) {
                    continue;
                }
                $s = trim((string)$v, " \t\n\r\0\x0B\"'[]");
                if ($s !== '' && !in_array($s, $out, true)) {
                    $out[] = $s;
                }
            }
            return $out;
        };

        $rawSkillIds = $this->request->post('skill_ids', null, null);
        $skillIds = [];
        foreach ($parseStrList($rawSkillIds) as $sidStr) {
            $sidInt = (int)$sidStr;
            if ($sidInt > 0 && !in_array($sidInt, $skillIds, true)) {
                $skillIds[] = $sidInt;
            }
        }

        $selectedSkills = $parseStrList($this->request->post('selected_skills', null, null));
        $customText = trim((string)$this->request->post('custom_text', ''));

        // 若传入了 skill_ids，关联 fa_skill_dict -> fa_skill_category 补全标准名称
        $dictById = [];
        if (!empty($skillIds)) {
            $idDictRows = Db::name('skill_dict')->alias('d')
                ->join('skill_category sc', 'sc.id = d.category_id', 'LEFT')
                ->field('d.id,d.category_id,d.category,d.name,sc.name as std_category_name')
                ->where('d.id', 'in', $skillIds)
                ->select();
            foreach ($idDictRows as $idr) {
                $dictById[(int)$idr['id']] = $idr;
                if (!empty($idr['name']) && !in_array($idr['name'], $selectedSkills, true)) {
                    $selectedSkills[] = (string)$idr['name'];
                }
            }
        }

        // 1. 处理自定义输入的技能
        $customNames = [];
        if ($customText !== '') {
            $parts = preg_split('/[,，\s]+/u', $customText);
            foreach ($parts as $p) {
                $p = trim($p);
                if ($p !== '' && !in_array($p, $customNames, true) && !in_array($p, $selectedSkills, true)) {
                    $customNames[] = $p;
                }
            }
        }

        if (empty($selectedSkills) && empty($customNames)) {
            $this->error('请至少选择或输入一项服务技能');
        }

        // 读取服务类目表 fa_service_cat 建立多策略匹配（精确匹配 -> 斜杠词根匹配 -> 行业语义映射 -> 原有入驻类目兜底）
        $catRows = Db::name('service_cat')->field('id,name')->where('status', 'normal')->select();
        $catExactMap = [];
        $catTokens = [];
        $otherCatId = 0;
        foreach ($catRows as $cr) {
            $cid = (int)$cr['id'];
            $cname = trim((string)$cr['name']);
            if ($cname === '') {
                continue;
            }
            $catExactMap[$cname] = $cid;
            if ($cname === '其它' || $cname === '其他') {
                $otherCatId = $cid;
            }
            foreach (preg_split('/[\/、\s]+/u', $cname) as $tk) {
                $tk = trim($tk);
                if (mb_strlen($tk, 'UTF-8') >= 2) {
                    $catTokens[$tk] = $cid;
                }
            }
        }

        $semanticKeywords = [
            '墙纸'   => '墙纸/壁画',
            '壁画'   => '墙纸/壁画',
            '墙面'   => '墙纸/壁画',
            '洁具'   => '卫浴',
            '马桶'   => '卫浴',
            '花洒'   => '卫浴',
            '强弱电' => '灯具',
            '热水器' => '家电',
            '空调'   => '家电',
            '洗衣机' => '家电',
            '冰箱'   => '家电',
            '家电清洗' => '家电',
            '油烟机' => '商用厨电',
            '厨电'   => '商用厨电',
            '木工'   => '家具',
            '送装'   => '家具',
            '家具养护' => '家具',
            '铝工'   => '门窗',
            '铝合金' => '门窗',
            '跑步机' => '健身器材',
        ];

        $resolveCatId = function ($skillName, $skillCategoryName, $fallbackCatId = 0) use ($catExactMap, $catTokens, $semanticKeywords, $otherCatId) {
            $skillName = trim((string)$skillName);
            $skillCategoryName = trim((string)$skillCategoryName);
            if (isset($catExactMap[$skillName])) {
                return $catExactMap[$skillName];
            }
            if (isset($catExactMap[$skillCategoryName])) {
                return $catExactMap[$skillCategoryName];
            }
            foreach (preg_split('/[\/、\s()（）]+/u', $skillName) as $part) {
                $part = trim($part);
                if ($part !== '' && isset($catTokens[$part])) {
                    return $catTokens[$part];
                }
            }
            foreach ($catTokens as $tk => $cid) {
                if (mb_strpos($skillName, $tk) !== false || mb_strpos($skillCategoryName, $tk) !== false) {
                    return $cid;
                }
            }
            foreach ($semanticKeywords as $kw => $targetCatName) {
                if (mb_strpos($skillName, $kw) !== false && isset($catExactMap[$targetCatName])) {
                    return $catExactMap[$targetCatName];
                }
            }
            if ($fallbackCatId > 0) {
                return $fallbackCatId;
            }
            return $otherCatId > 0 ? $otherCatId : 0;
        };

        // 读取该师傅原有已绑定的有效服务类目（保留入驻时选定的基础 cat_id，杜绝重存后丢失为 0）
        $oldSkillRows = Db::name('master_skill')->where('master_id', $masterId)->where('cat_id', '>', 0)->select();
        $oldCatBySkillName = [];
        $oldBaseCatRows = [];
        $primaryFallbackCatId = 0;
        foreach ($oldSkillRows as $osr) {
            $ocid = (int)$osr['cat_id'];
            if ($primaryFallbackCatId === 0 && $ocid > 0) {
                $primaryFallbackCatId = $ocid;
            }
            if (!empty($osr['skill_name'])) {
                $oldCatBySkillName[(string)$osr['skill_name']] = $ocid;
            }
            if ((int)$osr['skill_id'] === 0 && (int)$osr['is_custom'] === 0) {
                $oldBaseCatRows[$ocid] = $osr;
            }
        }

        $dictMap = [];
        if (!empty($selectedSkills)) {
            $dictRows = Db::name('skill_dict')->alias('d')
                ->join('skill_category sc', 'sc.id = d.category_id', 'LEFT')
                ->field('d.id,d.category_id,d.category,d.name,sc.name as std_category_name')
                ->where('d.name', 'in', $selectedSkills)
                ->select();
            foreach ($dictRows as $dr) {
                $dictMap[$dr['name']] = $dr;
            }
        }

        $now = time();
        $coveredCatIds = [];

        Db::startTrans();
        try {
            Db::name('master_skill')->where('master_id', $masterId)->delete();

            foreach ($selectedSkills as $sName) {
                $dict = isset($dictMap[$sName]) ? $dictMap[$sName] : null;
                $catName = $dict
                    ? (!empty($dict['std_category_name']) ? (string)$dict['std_category_name'] : (string)$dict['category'])
                    : '服务技能';
                $prevCat = isset($oldCatBySkillName[$sName]) ? (int)$oldCatBySkillName[$sName] : $primaryFallbackCatId;
                $matchedCatId = $resolveCatId($sName, $catName, $prevCat);
                if ($matchedCatId > 0) {
                    $coveredCatIds[$matchedCatId] = true;
                }
                Db::name('master_skill')->insert([
                    'master_id'  => $masterId,
                    'cat_id'     => $matchedCatId,
                    'skill_id'   => $dict ? (int)$dict['id'] : 0,
                    'skill_name' => mb_substr($sName, 0, 50),
                    'category'   => mb_substr($catName, 0, 50),
                    'is_custom'  => 0,
                    'cert_image' => '',
                    'status'     => 'normal',
                    'createtime' => $now,
                ]);
            }

            foreach ($customNames as $cName) {
                $exist = Db::name('skill_dict')->where('name', $cName)->find();
                if (!$exist) {
                    $skillDictId = (int)Db::name('skill_dict')->insertGetId([
                        'category_id' => 7,
                        'category'    => '其他技能',
                        'name'        => mb_substr($cName, 0, 50),
                        'source'      => 'custom',
                        'master_id'   => $masterId,
                        'weigh'       => 0,
                        'status'      => 'normal',
                        'createtime'  => $now,
                        'updatetime'  => $now,
                    ]);
                } else {
                    $skillDictId = (int)$exist['id'];
                }

                $prevCat = isset($oldCatBySkillName[$cName]) ? (int)$oldCatBySkillName[$cName] : $primaryFallbackCatId;
                $customCatId = $resolveCatId($cName, '其他技能', $prevCat);
                if ($customCatId > 0) {
                    $coveredCatIds[$customCatId] = true;
                }

                Db::name('master_skill')->insert([
                    'master_id'  => $masterId,
                    'cat_id'     => $customCatId,
                    'skill_id'   => $skillDictId,
                    'skill_name' => mb_substr($cName, 0, 50),
                    'category'   => '其他技能',
                    'is_custom'  => 1,
                    'cert_image' => '',
                    'status'     => 'normal',
                    'createtime' => $now,
                ]);
            }

            // 保留师傅入驻审核时已绑定但未被细分字典覆盖的基础服务大类记录，确保接单大厅类目过滤不丢失
            foreach ($oldBaseCatRows as $baseCid => $baseRow) {
                if (!isset($coveredCatIds[$baseCid])) {
                    Db::name('master_skill')->insert([
                        'master_id'  => $masterId,
                        'cat_id'     => (int)$baseCid,
                        'skill_id'   => 0,
                        'skill_name' => (string)$baseRow['skill_name'],
                        'category'   => (string)($baseRow['category'] ?: '安装维修'),
                        'is_custom'  => 0,
                        'cert_image' => (string)($baseRow['cert_image'] ?? ''),
                        'status'     => 'normal',
                        'createtime' => $now,
                    ]);
                }
            }

            Db::commit();
        } catch (\Exception $e) {
            Db::rollback();
            \think\Log::error('[Master::saveSkills] ' . $e->getMessage());
            $this->error('保存技能失败：' . $e->getMessage());
            return;
        }

        $this->success('服务技能保存成功');
    }
}