1

app/api/controller/Chat.php

@@ -172,9 +172,11 @@ class Chat extends BaseController
         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('标记成功');
     }
     
@@ -186,7 +188,9 @@ class Chat extends BaseController
         $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);

app/model/api/ChatRecord.php

@@ -5,6 +5,7 @@ namespace app\model\api;
 
 use library\basic\BaseModel;
 use library\traits\ModelTrait;
+use think\facade\Db;
 use think\Model;
 
 /**
@@ -99,16 +100,17 @@ class ChatRecord extends BaseModel
      */
     public static function markAsRead(int $userId, int $fromUserId): bool
     {
-        $affected = \think\facade\Db::name('chat_record')
+        $affected = Db::name('chat_record')
             ->where('user_id', $fromUserId)
             ->where('to_user_id', $userId)
-            ->where('is_read', self::UNREAD)
-            ->update(['is_read' => self::READ]);
-        
+            ->where('is_read', 0)
+            ->update(['is_read' => 1]);
+        @file_put_contents('quanju.txt',  $affected."-何意啊333\r\n", 8);
+
         // 调试：记录执行的SQL和影响行数
-        $sql = \think\facade\Db::name('chat_record')->getLastSql();
-        trace('【markAsRead】SQL: ' . $sql . ' | 影响行数: ' . $affected, 'chat_debug');
-        
+//        $sql = Db::name('chat_record')->getLastSql();
+//        trace('【markAsRead】SQL: ' . $sql . ' | 影响行数: ' . $affected, 'chat_debug');
+//
         return $affected > 0;
     }
     
@@ -120,9 +122,9 @@ class ChatRecord extends BaseModel
      */
     public static function getUnreadCount(int $userId, ?int $fromUserId = null): int
     {
-        $query = \think\facade\Db::name('chat_record')
+        $query = Db::name('chat_record')
             ->where('to_user_id', $userId)
-            ->where('is_read', self::UNREAD);
+            ->where('is_read', 0);
         
         if ($fromUserId !== null && $fromUserId > 0) {
             $query->where('user_id', $fromUserId);
@@ -130,10 +132,10 @@ class ChatRecord extends BaseModel
         
         $count = $query->count();
         
-        // 调试：记录执行的SQL和结果
-        $sql = \think\facade\Db::name('chat_record')->getLastSql();
-        trace('【getUnreadCount】SQL: ' . $sql . ' | 结果: ' . $count, 'chat_debug');
-        
+//        // 调试：记录执行的SQL和结果
+//        $sql = Db::name('chat_record')->getLastSql();
+//        trace('【getUnreadCount】SQL: ' . $sql . ' | 结果: ' . $count, 'chat_debug');
+//
         return $count;
     }
     
@@ -144,15 +146,15 @@ class ChatRecord extends BaseModel
      */
     public static function getTotalUnreadCount(int $userId): int
     {
-        $count = \think\facade\Db::name('chat_record')
+        $count = Db::name('chat_record')
             ->where('to_user_id', $userId)
-            ->where('is_read', self::UNREAD)
+            ->where('is_read', 0)
             ->count();
         
-        // 调试：记录执行的SQL和结果
-        $sql = \think\facade\Db::name('chat_record')->getLastSql();
-        trace('【getTotalUnreadCount】SQL: ' . $sql . ' | 结果: ' . $count, 'chat_debug');
-        
+//        // 调试：记录执行的SQL和结果
+//        $sql = Db::name('chat_record')->getLastSql();
+//        trace('【getTotalUnreadCount】SQL: ' . $sql . ' | 结果: ' . $count, 'chat_debug');
+//
         return $count;
     }