<?php

namespace app\api\controller;

use app\common\controller\Api;
use app\common\service\CommonService;
use app\common\service\MessageService;
use think\exception\HttpResponseException;
use think\Validate;

class Message extends Api
{
    protected $noNeedLogin = [];
    protected $noNeedRight = ['*'];

    public function list()
    {
        try {
            $user_id = $this->auth->id ?? -1;
            $page = $this->request->get('page', 1);
            $page_size = $this->request->get('pageSize', 10);
            //消息类型筛选：0=系统消息,1=公告消息,2=需求消息，不传=全部
            $message_type = $this->request->get('message_type', '');
            $where = [
                'to_user_id' => $user_id
            ];
            if ($message_type !== '' && $message_type !== null) {
                $where['message_type'] = $message_type;
            }
            //总未读数（兼容旧字段）+ 分类未读数（前端tab角标用）
            $unreadCount = MessageService::where($where + ['is_read' => CommonService::STATUS_OFF])->count();
            //where() 走的是 Query 对象，select() 返回普通数组而非 Collection，需兼容处理
            $unreadList = MessageService::where(['to_user_id' => $user_id, 'is_read' => CommonService::STATUS_OFF])
                ->field('message_type, count(*) as total')
                ->group('message_type')
                ->select();
            $unreadList = is_object($unreadList) && method_exists($unreadList, 'toArray')
                ? $unreadList->toArray()
                : (array)$unreadList;
            $unreadMap = [
                MessageService::TYPE_SYSTEM => 0,
                MessageService::TYPE_NOTICE => 0,
                MessageService::TYPE_DEMAND => 0,
            ];
            foreach ($unreadList as $item) {
                $unreadMap[$item['message_type']] = (int)$item['total'];
            }

            $list = MessageService::getList($where, $page_size, 'id desc')->toArray();
            $list['unread_count'] = $unreadCount;
            $list['unread_map'] = $unreadMap;

            $this->success('', $list);
        } catch (\Exception $e) {
            if ($e instanceof HttpResponseException) {
                throw $e;
            }
            $this->error($e->getMessage());
        }
    }


    /**
     * 未读消息数（供底部tabbar红点等轻量场景）
     * @return void
     */
    public function unreadCount()
    {
        try {
            $user_id = $this->auth->id ?? -1;
            $count = MessageService::where([
                'to_user_id' => $user_id,
                'is_read' => CommonService::STATUS_OFF
            ])->count();
            $this->success('', ['unread_count' => (int)$count]);
        } catch (\Exception $e) {
            if ($e instanceof HttpResponseException) {
                throw $e;
            }
            $this->error($e->getMessage());
        }
    }

    /**
     * 详情
     * @return void
     */
    public function detail()
    {
        $user_id = $this->auth->id ?? -1;
        $id = $this->request->get('id', 0);
        $info = MessageService::getOne(['id' => $id, 'to_user_id' => $user_id]);

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

    /**
     * 设为已读
     * @return void
     */
    public function setRead()
    {
        try {
            $user_id = $this->auth->id ?? -1;
            $id = $this->request->post('id', 0);
            $isAll = $this->request->post('isAll', 0);
            //isAll 时可携带 message_type，仅将该类型全部设为已读
            $message_type = $this->request->post('message_type', '');
            $where = ['id' => $id, 'to_user_id' => $user_id];
            if ($isAll) {
                unset($where['id']);
                if ($message_type !== '' && $message_type !== null) {
                    $where['message_type'] = $message_type;
                }
            }
            $res = MessageService::where($where)->update(['is_read' => CommonService::STATUS_ON]);
            if ($res === false) {
                exception('操作失败');
            }
            $this->success('操作成功');
        } catch (\Exception $e) {
            if ($e instanceof HttpResponseException) {
                throw $e;
            }
            $this->error($e->getMessage());
        }
    }
}