infantServiceApi/app/api/controller/Chat.php

<?php
declare (strict_types = 1);

namespace app\api\controller;

use app\BaseController;
use app\model\api\ChatRecord;
use app\model\api\ChatUserRelation;
use app\model\api\User;
use app\Request;
use app\services\chat\ChatBalanceService;

/**
 * 聊天控制器
 */
class Chat extends BaseController
{
    /**
     * 获取会话列表
     */
    public function sessionList(Request $request)
    {
        $userId = $request->user['uid'];
        $sessions = ChatUserRelation::getUserSessions($userId);
        
        return app('json')->success('获取成功', [
            'list' => $sessions,
        ]);
    }
    
    /**
     * 初始化会话（首次聊天扣次数）
     */
    public function initSession(Request $request)
    {
        $data = $request->post();
        $toUserId = (int)($data['to_user_id'] ?? 0);
        $userId = $request->user['uid'];
        
        if ($toUserId <= 0) {
            return app('json')->fail('对方用户ID错误');
        }
        
        if ($toUserId == $userId) {
            return app('json')->fail('不能和自己聊天');
        }
        
        // 检查对方用户是否存在
        $toUser = User::find($toUserId);
        if (!$toUser) {
            return app('json')->fail('用户不存在');
        }
        
        // 创建或获取会话关系
        $relation = ChatUserRelation::getOrCreate($userId, $toUserId);
        
        // 如果未扣过次数，则扣除
        if ($relation && $relation->is_deduct == ChatUserRelation::NOT_DEDUCT) {
            $result = ChatBalanceService::checkAndDeductFirstChat($userId, $toUserId);
            
            if (!$result['success']) {
                return app('json')->fail($result['message']);
            }
        }
        
        $balance = ChatBalanceService::getBalance($userId);
        
        return app('json')->success('会话创建成功', [
            'to_user_id' => $toUserId,
            'to_nickname' => $toUser->nickname ?? '',
            'to_avatar' => $toUser->avatar ?? '',
            'balance' => $balance,
        ]);
    }
    
    /**
     * 发送消息
     */
    public function send(Request $request)
    {
        $data = $request->post();
        $toUserId = (int)($data['to_user_id'] ?? 0);
        $content = trim($data['content'] ?? '');
        $type = (int)($data['type'] ?? ChatRecord::TYPE_TEXT);
        $formType = (int)($data['form_type'] ?? ChatRecord::FROM_PC);
        $userId = $request->user['uid'];
        
        // 验证 form_type 有效值
        if (!in_array($formType, [ChatRecord::FROM_PC, ChatRecord::FROM_WECHAT, ChatRecord::FROM_MINIAPP, ChatRecord::FROM_H5])) {
            $formType = ChatRecord::FROM_PC;
        }
        
        if ($toUserId <= 0) {
            return app('json')->fail('对方用户ID错误');
        }
        
        if (empty($content) && $type == ChatRecord::TYPE_TEXT) {
            return app('json')->fail('消息内容不能为空');
        }
        
        if ($toUserId == $userId) {
            return app('json')->fail('不能和自己聊天');
        }
        
        // 检查对方用户是否存在
        $toUser = User::find($toUserId);
        if (!$toUser) {
            return app('json')->fail('用户不存在');
        }
        
        // 检查会话关系是否存在，不存在则创建
        $relation = ChatUserRelation::getOrCreate($userId, $toUserId);
        
        // 如果未扣过次数，则扣除
        if ($relation && $relation->is_deduct == ChatUserRelation::NOT_DEDUCT) {
            $result = ChatBalanceService::checkAndDeductFirstChat($userId, $toUserId);
            
            if (!$result['success']) {
                return app('json')->fail($result['message']);
            }
        }
        
        // 保存聊天记录（包含来源类型）
        $record = ChatRecord::saveRecord($userId, $toUserId, $content, $type, $formType);
        
        // 更新会话关系时间
        ChatUserRelation::where('id', $relation->id)->update(['update_time' => time()]);
        
        return app('json')->success('发送成功', [
            'record_id' => $record->id,
            'create_time' => $record->create_time,
        ]);
    }
    
    /**
     * 获取聊天记录（分页）
     * page=1 为最新的一批消息，页码递增则获取更早的消息
     */
    public function recordList(Request $request)
    {
        $data = $request->get();
        $toUserId = (int)($data['to_user_id'] ?? 0);
        $page = (int)($data['page'] ?? 1);
        $limit = (int)($data['limit'] ?? 20);
        $userId = $request->user['uid'];
        
        if ($toUserId <= 0) {
            return app('json')->fail('对方用户ID错误');
        }
        
        if ($page < 1) $page = 1;
        if ($limit < 1) $limit = 20;
        if ($limit > 100) $limit = 100;
        
        $result = ChatRecord::getChatRecords($userId, $toUserId, $page, $limit);
        
        // 处理附加字段
        foreach ($result['list'] as &$item) {
            $item['type_text'] = ChatRecord::getTypeText($item['type']);
            $item['form_type_text'] = ChatRecord::getFormTypeText($item['form_type'] ?? 0);
            $item['is_mine'] = $item['user_id'] == $userId;
        }
        unset($item);
        
        return app('json')->success('获取成功', $result);
    }
    
    /**
     * 标记消息已读
     */
    public function markRead(Request $request)
    {
        $data = $request->post();
        $fromUserId = (int)($data['from_user_id'] ?? 0);
        $userId = $request->user['uid'];
        
        if ($fromUserId <= 0) {
            return app('json')->fail('用户ID错误');
        }
//        @file_put_contents('quanju.txt',  $userId."-何意啊111\r\n", 8);
//        @file_put_contents('quanju.txt',  $fromUserId."-何意啊222\r\n", 8);

        ChatRecord::markAsRead($userId, $fromUserId);

        return app('json')->success('标记成功');
    }
    
    /**
     * 获取未读消息数
     */
    public function unreadCount(Request $request)
    {
        $data = $request->get();
        $fromUserId = $data['from_user_id'] ?? null;
        $userId = $request->user['uid'];
//        @file_put_contents('quanju.txt',  $userId."-何意啊111444\r\n", 8);
//        @file_put_contents('quanju.txt',  $fromUserId."-何意啊222555\r\n", 8);

        // 处理空字符串等无效值
        if ($fromUserId !== null && $fromUserId !== '' && (int)$fromUserId > 0) {
            $count = ChatRecord::getUnreadCount($userId, (int)$fromUserId);
        } else {
            $count = ChatRecord::getTotalUnreadCount($userId);
        }
        
        return app('json')->success('获取成功', [
            'count' => $count,
        ]);
    }
    
    /**
     * 删除会话
     */
    public function deleteSession(Request $request)
    {
        $data = $request->post();
        $toUserId = (int)($data['to_user_id'] ?? 0);
        $userId = $request->user['uid'];
        
        if ($toUserId <= 0) {
            return app('json')->fail('对方用户ID错误');
        }
        
        $result = ChatUserRelation::deleteSession($userId, $toUserId);
        
        if ($result) {
            return app('json')->success('删除成功');
        }
        
        return app('json')->fail('删除失败');
    }
    
    /**
     * 获取用户信息
     */
    public function getUserInfo(Request $request)
    {
        $data = $request->get();
        $userId = (int)($data['user_id'] ?? 0);
        
        if ($userId <= 0) {
            return app('json')->fail('用户ID错误');
        }
        
        $user = User::find($userId);
        if (!$user) {
            return app('json')->fail('用户不存在');
        }
        
        return app('json')->success('获取成功', [
            'user_id' => $user->id,
            'nickname' => $user->nickname ?? '',
            'avatar' => $user->avatar ?? '',
        ]);
    }
}