Browse Source

消息提醒

gorden 7 months ago
parent
commit
e20b958bb8
2 changed files with 3 additions and 4 deletions
  1. 2 3
      app/admin/service/client/MessageService.php
  2. 1 1
      process/Task.php

+ 2 - 3
app/admin/service/client/MessageService.php

@@ -17,10 +17,9 @@ class MessageService
         $chats = Db::table('chat_message')
             ->selectRaw('join_message_recv_id,join_message_send_id,GROUP_CONCAT(chat_message_id) as chat_message_ids,MIN(chat_message_id) as min_chat_message_id')
             ->where('chat_message_status', 'PENDING')
-//            ->whereBetween('chat_message_addtimes',$times)
+            ->whereBetween('chat_message_addtimes',$times)
             ->groupBy('join_message_send_id', 'join_message_recv_id')
             ->get();
-        dump($chats);
 
         foreach ($chats as $chat) {
             // 接收者是后台人员
@@ -29,7 +28,7 @@ class MessageService
             }
             if (ClientMessage::where('join_client_message_recv_member_id', $chat->join_message_recv_id)
                 ->where('client_message_classify','CHAT')
-                ->whereJsonContains("client_message_extend_json->message_id",'\"'.$chat->min_chat_message_id.'\"')
+                ->whereJsonContains("client_message_extend_json->message_id",strval($chat->min_chat_message_id))
                 ->exists()) {
                 continue;
             }

+ 1 - 1
process/Task.php

@@ -24,7 +24,7 @@ class Task
             OrderService::checkPayingOrder();
 
             // 会员消息 30分钟未读,发送站内信
-//            MessageService::unreadChatMessage();
+            MessageService::unreadChatMessage();
         });
 
         // 每天的8点执行,注意这里省略了秒位