Update push_service: do not send empty response

pqai_agent/push_service.py

@@ -154,7 +154,7 @@ class PushTaskWorkerPool:
             if response:
                 self.agent_service.send_response(staff_id, user_id, response, message_type, skip_check=True)
             else:
-                logger.debug(f"agent[{staff_id}] generate empty response")
+                logger.debug(f"staff[{staff_id}], user[{user_id}]: generate empty response")
             self.consumer.ack(msg)
         except Exception as e:
             fmt_exc = traceback.format_exc()
@@ -173,9 +173,12 @@ class PushTaskWorkerPool:
                     staff_id, user_id, main_agent.last_interaction_time, limit=100
                 )
             )
-            rmq_message = generate_task_rmq_message(self.rmq_topic, staff_id, user_id, TaskType.SEND, message_to_user)
-            logger.debug(f"send message: {rmq_message.body.decode('utf-8')}")
-            self.producer.send(rmq_message)
+            if message_to_user:
+                rmq_message = generate_task_rmq_message(self.rmq_topic, staff_id, user_id, TaskType.SEND, message_to_user)
+                logger.debug(f"send message: {rmq_message.body.decode('utf-8')}")
+                self.producer.send(rmq_message)
+            else:
+                logger.info(f"staff[{staff_id}], user[{user_id}]: no push message generated")
             self.consumer.ack(msg)
         except Exception as e:
             fmt_exc = traceback.format_exc()