<?php

namespace app\api\controller;

use think\Db;

/**
 * 用户端 · 信息发布与详情（Module-POST）
 * 路由：
 *   POST   /api/v1/post/create           P1 发布信息（服务端定价）
 *   GET    /api/v1/post/mine             P8 我的发布（含审核状态与计数）
 *   GET    /api/v1/post/publish-config   P9 发布配置（发布模式/价格/我的剩余额度）
 *   GET    /api/v1/post/drafts           P2 草稿列表
 *   POST   /api/v1/post/draft            P3 保存草稿
 *   DELETE /api/v1/post/:id              P4 删除信息
 *   GET    /api/v1/post/:id              P5 信息详情
 *   POST   /api/v1/post/:id/pay-view     P6 付费查看联系方式
 *   POST   /api/v1/post/:id/comment      P7 发表评价
 *
 * 计费口径（后台「发布与费用配置」维护，真源=fc_config）；
 *   金额一律由服务端按配置计算，**不接受客户端传入金额**；
 *   判定顺序：① 套餐额度（fc_user_ext.post_quota_left，开通月/年卡赠送）
 *             → ② 免费发布条数（post.freeQuota，按 post.freeQuotaCycle 统计周期，0 = 不限制）
 *             → ③ 单条付费（post.singlePrice，即「付费发布」标准）；
 *   免费发布模式下免费条数用完即按 ③ 计费（客户端需切到「会员单条」并选支付方式重新提交）；
 *   月卡/年卡（含发布条数）的购买复用 POST /member/open，本控制器只处理
 *   「套餐额度/免费条数内免费发布」与「单条付费发布」两种。
 */
class Post extends V1
{
    /**
     * P1 发布信息
     * POST /api/v1/post/create
     *   入参 {categoryId,title,content,media[],contact,phone,address,plan,payType}
     *   →  {postId,auditStatus,order,plan,amount,quotaLeft,freeQuotaLeft}
     * 规则 BR-03/BR-04/BR-02/BR-13（计费顺序：套餐额度 → 免费发布条数 → 单条付费）
     */
    public function create()
    {
        $user = $this->auth();

        $categoryId = (int)$this->input('categoryId', 0);
        $title = trim((string)$this->input('title', ''));
        $content = trim((string)$this->input('content', ''));

        if ($categoryId <= 0) {
            $this->fail('分类不能为空');
        }
        if ($title === '') {
            $this->fail('标题不能为空');
        }
        if ($content === '') {
            $this->fail('内容不能为空');
        }
        if (mb_strlen($title) > 40) {
            $this->fail('标题不能超过 40 字');
        }
        if (mb_strlen($content) > 500) {
            $this->fail('内容不能超过 500 字');
        }

        $phone = trim((string)$this->input('phone', ''));
        if ($phone !== '' && !preg_match('/^1\d{10}$/', $phone)) {
            $this->fail('手机号格式不正确');
        }

        // ---- 发布计费：金额一律由服务端按后台配置计算，不信任客户端传值 ----
        $rule = $this->publishRule();
        $plan = trim((string)$this->input('plan', ''));
        if ($plan === '' && (bool)$this->input('paid', false)) {
            // 兼容 v1.0.6 及更早客户端：paid=true 视为单条付费（金额仍由服务端决定）
            $plan = 'single';
        }
        if ($plan === '') {
            $plan = 'free';
        }
        if (!in_array($plan, ['free', 'single'], true)) {
            // 月卡/年卡走会员接口开通（POST /member/open），拿到额度后再以 free 发布
            $this->fail('发布方式不支持，请先开通会员套餐');
        }

        $ext = $this->ext($user['id']);
        $quotaLeft = $this->quotaLeft($ext);
        $free = $this->freeQuotaState($user['id']);

        $amount = 0;
        $payType = '';
        $useQuota = false;      // 套餐额度内免费
        $useFreeQuota = false;  // 免费发布条数内免费
        if ($plan === 'single') {
            // 单条付费 = 付费发布标准（免费发布条数用完后即按此计费）
            $amount = $rule['singlePrice'];
            $payType = trim((string)$this->input('payType', ''));
            if ($amount > 0 && !in_array($payType, ['wxpay', 'balance'], true)) {
                $this->fail('支付方式不支持');
            }
            // 余额校验须在落库之前：否则余额不足时会残留一条 is_paid=1 的无效发布
            if ($amount > 0 && $payType === 'balance' && (float)$user['money'] < $amount) {
                $this->fail('余额不足');
            }
        } elseif ($quotaLeft > 0) {
            $useQuota = true;        // ① 套餐额度（开通月/年卡赠送，随会员有效期）
        } elseif ($free['unlimited'] || $free['left'] > 0) {
            $useFreeQuota = true;    // ② 免费发布条数（post.freeQuota + post.freeQuotaCycle）
        } elseif ($rule['mode'] === 'free') {
            // 免费发布模式下免费条数已用完 → 按「付费发布」标准计费：
            // 需要客户端切到「会员单条」（plan=single）并选支付方式后重新提交，
            // 服务端不主动扣款（避免未经用户确认就产生订单）
            $this->fail('免费额度已用完，请按 ' . number_format((float)$rule['singlePrice'], 2) . ' 元/条付费发布');
        } else {
            $this->fail('请选择发布方式');
        }
        $paid = $amount > 0;

        $now = time();
        $postId = Db::name('fc_post')->insertGetId([
            'user_id'       => $user['id'],
            'category_id'   => $categoryId,
            'title'         => $title,
            'content'       => $content,
            'cover'         => '',
            'media'         => json_encode($this->mediaArray(), JSON_UNESCAPED_UNICODE),
            'price'         => round((float)$this->input('price', 0), 2),
            'price_unit'    => (string)$this->input('priceUnit', ''),
            'area'          => (string)$this->input('area', ''),
            'address'       => (string)$this->input('address', ''),
            'contact'       => (string)$this->input('contact', ''),
            'phone'         => $phone,
            'wechat'        => '',
            'tags'          => $this->tagsString(),
            'is_paid'       => $paid ? 1 : 0,
            'amount'        => $paid ? $amount : 0,
            'pay_type'      => $paid ? $payType : '',
            'audit_status'  => 0,
            'views'         => 0,
            'likes'         => 0,
            'comment_count' => 0,
            'status'        => 1,
            'createtime'    => $now,
            'updatetime'    => $now,
        ]);

        $order = null;
        if ($paid) {
            // 余额支付为「即时支付」：下单即扣款、订单直接置为已支付；
            // 微信支付需要前端调起收银台，保持 pending 由支付回调置为 paid。
            $paidNow = $payType === 'balance';
            $orderNo = $this->orderNo('PO');
            Db::name('fc_order')->insert([
                'order_no'   => $orderNo,
                'user_id'    => $user['id'],
                'type'       => 'post',
                'title'      => $title,
                'amount'     => $amount,
                'pay_type'   => $payType,
                'status'     => $paidNow ? 'paid' : 'pending',
                'paytime'    => $paidNow ? $now : null,
                'related_id' => $postId,
                'createtime' => $now,
                'updatetime' => $now,
            ]);

            if ($paidNow) {
                $balance = round((float)$user['money'] - $amount, 2);
                Db::name('user')->where('id', $user['id'])->update([
                    'money'      => $balance,
                    'updatetime' => $now,
                ]);
                $this->flow('income', '发布付费', $amount, $balance, $postId);
            }

            $order = [
                'orderNo' => $orderNo,
                'amount'  => $amount,
                'payType' => $payType,
                'status'  => $paidNow ? 'paid' : 'pending',
            ];
        }

        // 套餐额度内免费发布：落库成功后扣减 1 条额度（先发布后扣，发布失败不白扣）
        if ($useQuota) {
            $quotaLeft = max(0, $quotaLeft - 1);
            Db::name('fc_user_ext')->where('user_id', $user['id'])->update([
                'post_quota_left' => $quotaLeft,
                'updatetime'      => $now,
            ]);
        }

        $this->ok([
            'postId'        => $postId,
            'auditStatus'   => 0,
            'order'         => $order,
            'plan'          => $useQuota ? 'quota' : ($useFreeQuota ? 'free' : ($paid ? 'single' : 'free')),
            'amount'        => $amount,
            'quotaLeft'     => $quotaLeft,
            // -1 = 不限制（免费发布模式且未设置免费条数）
            'freeQuotaLeft' => $free['unlimited'] ? -1 : max(0, $free['left'] - ($useFreeQuota ? 1 : 0)),
        ]);
    }

    /**
     * P8 我的发布
     * GET /api/v1/post/mine  {status?,page,size}
     *   →  {list,page,size,total,hasMore,counts}
     * status: all(默认) / pending 待审核 / passed 已通过 / rejected 已驳回 / offline 已下架
     * 规则：仅本人（过滤软删）；置顶优先、其次按发布时间倒序；counts 为各状态条数
     */
    public function mine()
    {
        $user = $this->auth();
        list($page, $size) = $this->pager();

        $status = (string)$this->input('status', 'all');

        /** 组合状态筛选（all 不加条件） */
        $apply = function ($query, $status) {
            if ($status === 'pending') {
                $query->where('audit_status', 0)->where('status', 1);
            } elseif ($status === 'passed') {
                $query->where('audit_status', 1)->where('status', 1);
            } elseif ($status === 'rejected') {
                $query->where('audit_status', 2);
            } elseif ($status === 'offline') {
                $query->where('status', 0);
            }
            return $query;
        };
        $base = function () use ($user) {
            return Db::name('fc_post')->where('user_id', $user['id'])->whereNull('deletetime');
        };

        $total = $apply($base(), $status)->count();
        $rows = $apply($base(), $status)->order('is_top desc, createtime desc')
            ->page($page, $size)->select();

        $list = [];
        foreach ($rows as $row) {
            $cat = Db::name('fc_category')->where('id', $row['category_id'])->find();
            $list[] = [
                'id'           => (int)$row['id'],
                'title'        => (string)$row['title'],
                'content'      => (string)$row['content'],
                'categoryId'   => (int)$row['category_id'],
                'categoryName' => $cat ? (string)$cat['name'] : '',
                'cover'        => (string)$row['cover'],
                'price'        => (float)$row['price'],
                'priceUnit'    => (string)$row['price_unit'],
                'area'         => (string)$row['area'],
                'address'      => (string)$row['address'],
                'auditStatus'  => (int)$row['audit_status'],
                'auditReason'  => (string)$row['audit_reason'],
                'status'       => (int)$row['status'],
                'isTop'        => (int)$row['is_top'] === 1,
                'isPaid'       => (int)$row['is_paid'] === 1,
                'amount'       => (float)$row['amount'],
                'views'        => (int)$row['views'],
                'likes'        => (int)$row['likes'],
                'commentCount' => (int)$row['comment_count'],
                'createdAt'    => $this->iso($row['createtime']),
            ];
        }

        $counts = [
            'all'      => (int)$base()->count(),
            'pending'  => (int)$apply($base(), 'pending')->count(),
            'passed'   => (int)$apply($base(), 'passed')->count(),
            'rejected' => (int)$apply($base(), 'rejected')->count(),
            'offline'  => (int)$apply($base(), 'offline')->count(),
        ];

        $this->ok(array_merge($this->paginate($list, $total, $page, $size), ['counts' => $counts]));
    }

    /**
     * P9 发布配置
     * GET /api/v1/post/publish-config
     *   →  {mode,singlePrice,monthPrice,monthQuota,yearPrice,yearQuota,
     *       quotaLeft,quotaExpireAt,isMember,memberExpireAt}
     * 用途：发布页按「免费/付费」呈现并显示套餐价格与剩余额度（价格由后台配置，前端不再写死）
     */
    public function publishConfig()
    {
        $user = $this->auth();
        $rule = $this->publishRule();
        $ext = $this->ext($user['id']);
        $now = time();

        $quotaExpire = (int)$ext['post_quota_expire'];
        $memberExpire = (int)$ext['member_expiretime'];

        // 免费发布条数（post.freeQuota / post.freeQuotaCycle）：超出即按付费发布标准计费
        $free = $this->freeQuotaState($user['id']);

        $this->ok([
            'mode'           => $rule['mode'],
            'singlePrice'    => $rule['singlePrice'],
            'monthPrice'     => $rule['monthPrice'],
            'monthQuota'     => $rule['monthQuota'],
            'yearPrice'      => $rule['yearPrice'],
            'yearQuota'      => $rule['yearQuota'],
            'quotaLeft'      => $this->quotaLeft($ext),
            // 免费发布条数（0 条 + freeUnlimited=true 表示「不限制」，免费到底）
            'freeQuota'      => $free['quota'],
            'freeQuotaCycle' => $free['cycle'],
            'freeQuotaUsed'  => $free['used'],
            'freeQuotaLeft'  => $free['unlimited'] ? -1 : $free['left'],
            'freeUnlimited'  => $free['unlimited'],
            'quotaExpireAt'  => $quotaExpire > 0 ? $this->iso($quotaExpire) : '',
            'isMember'       => (int)$ext['is_member'] === 1 && ($memberExpire === 0 || $memberExpire > $now),
            'memberExpireAt' => $memberExpire > 0 ? $this->iso($memberExpire) : '',
        ]);
    }

    /**
     * 发布规则（后台「发布与费用配置」维护；配置缺失时回落旧 fee.* 再回落内置默认）
     * @return array
     */
    protected function publishRule()
    {
        $mode = (string)$this->cfg('post.mode', 'paid');
        if (!in_array($mode, ['free', 'paid'], true)) {
            $mode = 'paid';
        }
        return [
            'mode'        => $mode,
            'singlePrice' => round((float)$this->cfg('post.singlePrice', $this->cfg('fee.singlePost', 5)), 2),
            'monthPrice'  => round((float)$this->cfg('post.monthPrice', $this->cfg('fee.memberMonth', 19.9)), 2),
            'monthQuota'  => max(0, (int)$this->cfg('post.monthQuota', 30)),
            'yearPrice'   => round((float)$this->cfg('post.yearPrice', $this->cfg('fee.memberYear', 168)), 2),
            'yearQuota'   => max(0, (int)$this->cfg('post.yearQuota', 500)),
        ];
    }

    /**
     * 免费发布条数规则（v1.0.10）
     *   post.freeQuota      免费发布条数（0 = 不限制，免费发布模式下「免费到底」）
     *   post.freeQuotaCycle 统计周期：day 每日 / month 每月 / total 累计（不重置）
     * 兼容：配置项 **缺失** 时（老库未执行新版 fc:install）回落 `fee.freePostPerDay` 按日计；
     *       一旦配置项存在（后台「发布与费用配置」保存过或 fc:install 种过），就以配置为准，
     *       此时 `0` 表示「不限制」而不再回落旧值。
     * @return array{quota:int,cycle:string}
     */
    protected function freeQuotaRule()
    {
        $cycle = (string)$this->cfg('post.freeQuotaCycle', 'day');
        if (!in_array($cycle, ['day', 'month', 'total'], true)) {
            $cycle = 'day';
        }
        $raw = $this->cfg('post.freeQuota', null);
        if ($raw === null || $raw === '') {
            $legacy = max(0, (int)$this->cfg('fee.freePostPerDay', 0));
            return ['quota' => $legacy, 'cycle' => $legacy > 0 ? 'day' : $cycle];
        }
        return ['quota' => max(0, (int)$raw), 'cycle' => $cycle];
    }

    /**
     * 免费条数使用情况（按周期统计本人已发布条数，不含软删）
     * @param int $userId
     * @return array{quota:int,cycle:string,used:int,left:int,unlimited:bool}
     */
    protected function freeQuotaState($userId)
    {
        $rule = $this->freeQuotaRule();
        if ($rule['quota'] <= 0) {
            // 0 = 不限制：免费发布模式「免费到底」；付费发布模式视为不额外提供免费条数（走套餐额度或单条付费）
            $unlimited = $this->publishRule()['mode'] === 'free';
            return ['quota' => 0, 'cycle' => $rule['cycle'], 'used' => 0, 'left' => 0, 'unlimited' => $unlimited];
        }
        $used = $this->periodPostCount($userId, $rule['cycle']);
        return [
            'quota'     => $rule['quota'],
            'cycle'     => $rule['cycle'],
            'used'      => $used,
            'left'      => max(0, $rule['quota'] - $used),
            'unlimited' => false,
        ];
    }

    /**
     * 周期起点时间戳
     * @param string $cycle day|month|total
     * @return int
     */
    protected function quotaCycleStart($cycle)
    {
        if ($cycle === 'day') {
            return strtotime(date('Y-m-d') . ' 00:00:00');
        }
        if ($cycle === 'month') {
            return strtotime(date('Y-m') . '-01 00:00:00');
        }
        return 0;
    }

    /**
     * 周期内已发布条数（不含软删）
     * @param int $userId
     * @param string $cycle
     * @return int
     */
    protected function periodPostCount($userId, $cycle)
    {
        $start = $this->quotaCycleStart($cycle);
        $query = Db::name('fc_post')->where('user_id', $userId)->whereNull('deletetime');
        if ($start > 0) {
            $query->where('createtime', '>=', $start);
        }
        return (int)$query->count();
    }

    /**
     * 剩余发布条数（超出有效期视为 0，并顺手把过期额度清零）
     * @param array $ext fc_user_ext 行
     * @return int
     */
    protected function quotaLeft($ext)
    {
        $left = (int)(isset($ext['post_quota_left']) ? $ext['post_quota_left'] : 0);
        $expire = (int)(isset($ext['post_quota_expire']) ? $ext['post_quota_expire'] : 0);
        if ($left > 0 && $expire > 0 && $expire < time()) {
            Db::name('fc_user_ext')->where('user_id', $ext['user_id'])->update([
                'post_quota_left' => 0,
                'updatetime'      => time(),
            ]);
            return 0;
        }
        return $left;
    }

    /**
     * P2 草稿列表
     * GET /api/v1/post/drafts  →  [{draftId,title,content,categoryId,savedAt}]
     */
    public function drafts()
    {
        $user = $this->auth();

        $rows = Db::name('fc_draft')
            ->where('user_id', $user['id'])
            ->order('savedat desc')
            ->select();

        $list = [];
        foreach ($rows as $row) {
            $list[] = [
                'draftId'    => (int)$row['id'],
                'title'      => (string)$row['title'],
                'content'    => (string)$row['content'],
                'categoryId' => (int)$row['category_id'],
                'savedAt'    => $this->iso($row['savedat']),
            ];
        }
        $this->ok($list);
    }

    /**
     * P3 保存草稿
     * POST /api/v1/post/draft  {draftId?,categoryId?,title?,content?,media?,contact?,phone?,address?}
     *   →  {draftId,savedAt,categoryId,title,content}
     */
    public function saveDraft()
    {
        $user = $this->auth();

        $draftId = (int)$this->input('draftId', 0);
        $categoryId = (int)$this->input('categoryId', 0);
        $title = (string)$this->input('title', '');
        $content = (string)$this->input('content', '');
        $now = time();

        $data = [
            'user_id'    => $user['id'],
            'category_id' => $categoryId,
            'title'      => $title,
            'content'    => $content,
            'media'      => json_encode($this->mediaArray(), JSON_UNESCAPED_UNICODE),
            'contact'    => (string)$this->input('contact', ''),
            'phone'      => (string)$this->input('phone', ''),
            'address'    => (string)$this->input('address', ''),
            'savedat'    => $now,
            'updatetime' => $now,
        ];

        if ($draftId > 0) {
            $exist = Db::name('fc_draft')->where('id', $draftId)->find();
            if (!$exist || (int)$exist['user_id'] !== (int)$user['id']) {
                $this->fail('草稿不存在');
            }
            Db::name('fc_draft')->where('id', $draftId)->update($data);
        } else {
            $data['createtime'] = $now;
            $draftId = Db::name('fc_draft')->insertGetId($data);
        }

        $this->ok([
            'draftId'    => $draftId,
            'savedAt'    => $this->iso($now),
            'categoryId' => $categoryId,
            'title'      => $title,
            'content'    => $content,
        ]);
    }

    /**
     * P4 删除信息（软删）
     * DELETE /api/v1/post/:id  →  {deleted:true}
     * 规则：仅能删除本人发布
     */
    public function remove()
    {
        $user = $this->auth();
        $id = $this->routeId();

        $post = Db::name('fc_post')->where('id', $id)->whereNull('deletetime')->find();
        if (!$post) {
            $this->fail('信息不存在', 404);
        }
        if ((int)$post['user_id'] !== (int)$user['id']) {
            $this->fail('无权操作');
        }

        Db::name('fc_post')->where('id', $id)->update([
            'deletetime' => time(),
            'updatetime' => time(),
        ]);

        $this->ok(['deleted' => true]);
    }

    /**
     * P5 信息详情
     * GET /api/v1/post/:id  →  Post 结构（contact 为脱敏串，绝不返回完整手机号）
     * 规则：允许游客；不存在 fail('信息不存在',404)；每次浏览 views+1
     */
    public function detail()
    {
        // GET /post/:id（详情）与 DELETE /post/:id（软删）共用同一路径，
        // PHP 数组键无法为同一路径注册两条规则，故在此按请求方法分派。
        if ($this->request->isDelete()) {
            $this->remove();
        }

        $id = $this->routeId();

        $post = Db::name('fc_post')->where('id', $id)->whereNull('deletetime')->find();
        if (!$post) {
            $this->fail('信息不存在', 404);
        }

        Db::name('fc_post')->where('id', $id)->setInc('views');
        $post['views'] = (int)$post['views'] + 1;

        $this->ok($this->buildPost($post));
    }

    /**
     * P6 付费查看联系方式
     * POST /api/v1/post/:id/pay-view  {payType}
     *   →  {unlocked:true,contact:{phone,wechat}}
     * 规则 BR-05；金额取 fee.payView；会员或已解锁免费
     */
    public function payView()
    {
        $user = $this->auth();
        $id = $this->routeId();

        $payType = (string)$this->input('payType', '');
        if (!in_array($payType, ['wxpay', 'balance'], true)) {
            $this->fail('支付方式不支持');
        }

        $post = Db::name('fc_post')->where('id', $id)->whereNull('deletetime')->find();
        if (!$post) {
            $this->fail('信息不存在', 404);
        }

        $contact = [
            'phone'  => (string)$post['phone'],
            'wechat' => $post['wechat'] !== '' ? (string)$post['wechat'] : ('tongcheng_' . $id),
        ];

        // 已解锁直接返回
        $exist = Db::name('fc_pay_view')
            ->where('user_id', $user['id'])
            ->where('post_id', $id)
            ->find();
        if ($exist) {
            $this->ok(['unlocked' => true, 'contact' => $contact]);
        }

        $amount = round((float)$this->cfg('fee.payView', 2), 2);
        $now = time();

        $ext = $this->ext($user['id']);
        $isMember = (int)$ext['is_member'] === 1
            && (!$ext['member_expiretime'] || $ext['member_expiretime'] > $now);

        $orderId = 0;
        if ($isMember) {
            // 会员免费解锁
            $amount = 0;
            $payType = 'free';
        } elseif ($payType === 'balance') {
            $balance = (float)$user['money'];
            if ($balance < $amount) {
                $this->fail('余额不足');
            }
            $balance = round($balance - $amount, 2);
            Db::name('user')->where('id', $user['id'])->update([
                'money'      => $balance,
                'updatetime' => $now,
            ]);
            $this->flow('expense', '付费查看', $amount, $balance, $id);
        } else {
            // 微信支付：创建已支付订单
            $orderId = Db::name('fc_order')->insertGetId([
                'order_no'   => $this->orderNo('VO'),
                'user_id'    => $user['id'],
                'type'       => 'post',
                'title'      => '付费查看 #' . $id,
                'amount'     => $amount,
                'pay_type'   => $payType,
                'status'     => 'paid',
                'paytime'    => $now,
                'related_id' => $id,
                'createtime' => $now,
                'updatetime' => $now,
            ]);
        }

        Db::name('fc_pay_view')->insert([
            'user_id'    => $user['id'],
            'post_id'    => $id,
            'pay_type'   => $payType,
            'amount'     => $amount,
            'order_id'   => $orderId,
            'createtime' => $now,
        ]);

        $this->ok(['unlocked' => true, 'contact' => $contact]);
    }

    /**
     * P7 发表评价
     * POST /api/v1/post/:id/comment  {score,content}  →  {commentId}
     * 规则 BR-06
     */
    public function comment()
    {
        $user = $this->auth();
        $id = $this->routeId();

        $content = trim((string)$this->input('content', ''));
        if ($content === '') {
            $this->fail('评价内容不能为空');
        }

        $score = (int)$this->input('score', 5);
        if ($score < 1 || $score > 5) {
            $this->fail('评分需在 1-5 之间');
        }

        $post = Db::name('fc_post')->where('id', $id)->whereNull('deletetime')->find();
        if (!$post) {
            $this->fail('信息不存在', 404);
        }

        $now = time();
        $commentId = Db::name('fc_comment')->insertGetId([
            'post_id'    => $id,
            'user_id'    => $user['id'],
            'score'      => $score,
            'content'    => $content,
            'images'     => '',
            'reply'      => '',
            'top'        => 0,
            'status'     => 1,
            'createtime' => $now,
            'updatetime' => $now,
        ]);

        Db::name('fc_post')->where('id', $id)->setInc('comment_count');

        $this->notify(
            $post['user_id'],
            'interact',
            '收到新评价',
            '用户「' . (string)$user['nickname'] . '」评价了您的信息：' . $content
        );

        $this->ok(['commentId' => $commentId]);
    }

    /**
     * 读取路由 :id 参数（兼容 POST 体/查询串传入）
     * @return int
     */
    protected function routeId()
    {
        $id = (int)$this->input('id', 0);
        if ($id <= 0) {
            $id = (int)$this->request->param('id', 0);
        }
        return $id;
    }

    /**
     * media 入参归一化为数组
     * @return array
     */
    protected function mediaArray()
    {
        $media = $this->input('media', []);
        if (is_string($media)) {
            $decoded = json_decode($media, true);
            $media = is_array($decoded) ? $decoded : [];
        }
        return is_array($media) ? array_values($media) : [];
    }

    /**
     * tags 入参归一化为逗号分隔字符串
     * @return string
     */
    protected function tagsString()
    {
        $tags = $this->input('tags', []);
        if (is_array($tags)) {
            $tags = implode(',', $tags);
        }
        return (string)$tags;
    }

    /**
     * 组装 Post 结构（与前端 mock 数据字段严格对齐）
     * @param array $row fc_post 行
     * @return array
     */
    protected function buildPost($row)
    {
        $categoryName = '';
        if (!empty($row['category_id'])) {
            $cat = Db::name('fc_category')->where('id', $row['category_id'])->find();
            if ($cat) {
                $categoryName = (string)$cat['name'];
            }
        }

        $publisher = ['id' => 0, 'name' => '', 'avatar' => '', 'isMerchant' => false, 'verified' => false];
        if (!empty($row['user_id'])) {
            $pub = Db::name('user')->where('id', $row['user_id'])->find();
            if ($pub) {
                $pubExt = Db::name('fc_user_ext')->where('user_id', $pub['id'])->find();
                $isMerchant = $pubExt && (int)$pubExt['user_type'] === 2;
                $publisher = [
                    'id'         => (int)$pub['id'],
                    'name'       => (string)$pub['nickname'],
                    'avatar'     => (string)$pub['avatar'],
                    'isMerchant' => (bool)$isMerchant,
                    'verified'   => (bool)$isMerchant,
                ];
            }
        }

        $tags = [];
        if (!empty($row['tags'])) {
            foreach (explode(',', (string)$row['tags']) as $tag) {
                $tag = trim($tag);
                if ($tag !== '') {
                    $tags[] = $tag;
                }
            }
        }

        return [
            'id'           => (int)$row['id'],
            'categoryId'   => (int)$row['category_id'],
            'categoryName' => $categoryName,
            'title'        => (string)$row['title'],
            'content'      => (string)$row['content'],
            'cover'        => (string)$row['cover'],
            'price'        => (float)$row['price'],
            'priceUnit'    => (string)$row['price_unit'],
            'area'         => (string)$row['area'],
            'address'      => (string)$row['address'],
            'contact'      => $this->maskPhone($row['phone']),
            'views'        => (int)$row['views'],
            'likes'        => (int)$row['likes'],
            'isPaid'       => (int)$row['is_paid'] === 1,
            'auditStatus'  => (int)$row['audit_status'],
            'createdAt'    => $this->iso($row['createtime']),
            'tags'         => $tags,
            'publisher'    => $publisher,
            'commentCount' => (int)$row['comment_count'],
            'distance'     => (int)$row['distance'],
        ];
    }
}