package com.yanzuoguang.mq.service;

import com.yanzuoguang.mq.vo.req.MessageLogRemoveReqVo;
import com.yanzuoguang.mq.vo.req.MessageLogReqVo;
import io.swagger.annotations.ApiOperation;
import org.springframework.amqp.core.Message;

/**
 * 消息日志服务
 *
 * @author
 */
public interface MessageLogService {
    /**
     * 写入当前对象
     *
     * @param message 当前消息的内容
     * @return
     */
    @ApiOperation(value = "写入当前对象")
    void logCurrent(Message message);

    /**
     * 删除当前对象
     *
     * @return
     */
    @ApiOperation(value = "写入当前对象")
    void logCurrentRemove();

    /**
     * 记录一个消息已完成
     *
     * @return
     */
    @ApiOperation(value = "记录一个消息已完成，重复时抛出CodeException异常")
    String log();

    /**
     * 记录一个消息已完成
     *
     * @param req 消息的内容
     * @return
     */
    @ApiOperation(value = "记录一个消息已完成，重复时抛出CodeException异常")
    String log(MessageLogReqVo req);

    /**
     * 删除一个消息
     *
     * @param req 消息的内容
     * @return
     */
    @ApiOperation(value = "删除一个消息")
    String logRemove(MessageLogRemoveReqVo req);

    /**
     * 删除历史日志
     *
     * @param day
     */
    @ApiOperation(value = "删除历史日志")
    void logClear(String day);
}