no message

routers/api/riskManagement/rescue_resources.py

@@ -766,6 +766,13 @@ async def create_inspection_task(
         db.add(new_task_log)
 
         db.commit()
+
+        # 标记消息已读
+        child_task_info = db.query(RiskManagementRescueResourcesTaskChildrenTask).filter(RiskManagementRescueResourcesTaskChildrenTask.id == children_task_id).first()
+        if child_task_info is not None:
+            logger.info("标记[数据采集任务]已读 {}", str(child_task_info.task_id))
+            db_msg_center.update_msg_read(db, user_id, "数据采集", str(child_task_info.task_id))
+
         # 返回创建成功的响应
         return {
             "code": 200,

routers/api/riskManagement/risk_router.py

@@ -764,8 +764,14 @@ async def create_inspection_task(
                 db.add(new_file)
         # 添加到数据库会话并提交
         db.add(new_task_log)
-
         db.commit()
+        
+        # 标记消息已读
+        child_task_info = db.query(RiskManagementRiskTaskChildrenTask).filter(RiskManagementRiskTaskChildrenTask.id == children_task_id).first()
+        if child_task_info is not None:
+            logger.info("标记[风险防控任务]已读 {}", str(child_task_info.task_id))
+            db_msg_center.update_msg_read(db, user_id, "风险防控", str(child_task_info.task_id))
+
         # 返回创建成功的响应
         return {
             "code": 200,

routers/api/riskManagement/task.py

@@ -746,8 +746,14 @@ async def create_inspection_task(
                 db.add(new_file)
         # 添加到数据库会话并提交
         db.add(new_task_log)
-
         db.commit()
+        
+        # 标记消息已读
+        child_task_info = db.query(RiskManagementInspectionTaskChildrenTask).filter(RiskManagementInspectionTaskChildrenTask.id == children_task_id).first()
+        if child_task_info is not None:
+            logger.info("标记[隐患巡查任务]已读 {}", str(child_task_info.task_id))
+            db_msg_center.update_msg_read(db, user_id, "隐患巡查", str(child_task_info.task_id))
+
         # 返回创建成功的响应
         return {
             "code": 200,