package com.tianting.infoloop.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.infoloop.tianting.mealorderservice.CreateOrderSubscriptionMessageRpcRequest;
import com.infoloop.tianting.mealorderservice.GetUserOrderSubscriptionMessageHistoryRpcRequest;
import com.tianting.infoloop.model.db.OrderSubscriptionMessageDb;

import java.util.List;

public interface OrderSubscriptionMessageDbService extends IService<OrderSubscriptionMessageDb> {

  OrderSubscriptionMessageDb createOrderSubscriptionMessage(CreateOrderSubscriptionMessageRpcRequest request);

  List<OrderSubscriptionMessageDb> getUserOrderSubscriptionMessageHistory(GetUserOrderSubscriptionMessageHistoryRpcRequest request);

  /**
   * 批量逻辑删除授权记录（表示已使用）
   * @param ids 要删除的记录ID列表
   * @param enterpriseId 企业ID
   * @return 受影响的行数
   */
  int batchDeleteByIds(java.util.List<Long> ids, int enterpriseId);

  /**
   * 批量物理删除授权记录
   * @param ids 要删除的记录ID列表
   * @param enterpriseId 企业ID
   * @return 受影响的行数
   */
  int batchPhysicalDeleteByIds(java.util.List<Long> ids, int enterpriseId);

  /**
   * 查询待发送的订阅消息（未删除的记录）
   * @param enterpriseId 企业ID
   * @return 待发送的订阅消息列表
   */
  List<OrderSubscriptionMessageDb> queryPendingMessages(int enterpriseId);
}