GetMessagesDynamicallyParam.java

浏览该文件的文档.

package com.netease.nimlib.sdk.msg.model;

import androidx.annotation.NonNull;
import androidx.annotation.Nullable;

import com.netease.nimlib.sdk.msg.MessageBuilder;
import com.netease.nimlib.sdk.msg.constant.MsgTypeEnum;
import com.netease.nimlib.sdk.msg.constant.SessionTypeEnum;
import com.netease.nimlib.session.IMMessageImpl;
import com.netease.nimlib.session.MsgDBHelper;
import com.netease.nimlib.util.StringUtil;

import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;

public class GetMessagesDynamicallyParam implements Serializable {

    public static final int MAX_LIMIT = 100;
    @NonNull
    private final String sessionId;
    @NonNull
    private final SessionTypeEnum sessionType;
    private long fromTime;
    private long toTime;

    private long anchorServerId;
    private String anchorClientId;
    private int limit;

    @Nullable
    private GetMessageDirectionEnum direction;

    private List<MsgTypeEnum> messageTypes;
    private boolean strictMode;

    public GetMessagesDynamicallyParam(@NonNull String sessionId, @NonNull SessionTypeEnum sessionType) {
        this(sessionId, sessionType, 0, 0, 0, null, 0, GetMessageDirectionEnum.FORWARD, null, false);
    }

    public GetMessagesDynamicallyParam(@NonNull String sessionId, @NonNull SessionTypeEnum sessionType, long fromTime, long toTime, long anchorServerId, String anchorClientId, int limit, @Nullable GetMessageDirectionEnum direction) {
        this(sessionId, sessionType, fromTime, toTime, anchorServerId, anchorClientId, limit, direction, null, false);
    }

    public GetMessagesDynamicallyParam(@NonNull String sessionId, @NonNull SessionTypeEnum sessionType, long fromTime, long toTime, long anchorServerId, String anchorClientId, int limit, @Nullable GetMessageDirectionEnum direction, @Nullable List<MsgTypeEnum> messageTypes, boolean strictMode) {
        this.sessionId = sessionId;
        this.sessionType = sessionType;
        this.fromTime = fromTime;
        this.toTime = toTime;
        this.anchorServerId = anchorServerId;
        this.anchorClientId = anchorClientId;
        this.limit = limit;
        this.direction = direction;
        this.messageTypes = messageTypes;
        this.strictMode = strictMode;
    }

    @NonNull
    public String getSessionId() {
        return sessionId;
    }

    @NonNull
    public SessionTypeEnum getSessionType() {
        return sessionType;
    }

    public long getFromTime() {
        return fromTime;
    }

    public void setFromTime(long fromTime) {
        this.fromTime = fromTime;
    }

    public long getToTime() {
        return toTime;
    }

    public void setToTime(long toTime) {
        this.toTime = toTime;
    }

    public long getAnchorServerId() {
        return anchorServerId;
    }

    public void setAnchorServerId(long anchorServerId) {
        this.anchorServerId = anchorServerId;
    }

    public String getAnchorClientId() {
        return anchorClientId;
    }

    public void setAnchorClientId(String anchorClientId) {
        this.anchorClientId = anchorClientId;
    }

    public int getLimit() {
        return limit;
    }

    public void setLimit(int limit) {
        this.limit = limit;
    }

    public GetMessageDirectionEnum getDirection() {
        return direction;
    }

    public void setDirection(GetMessageDirectionEnum direction) {
        this.direction = direction;
    }

    public List<MsgTypeEnum> getMessageTypes() {
        return messageTypes;
    }

    public void setMessageTypes(List<MsgTypeEnum> messageTypes) {
        this.messageTypes = messageTypes;
    }

    public boolean isStrictMode() {
        return strictMode;
    }

    public void setStrictMode(boolean strictMode) {
        this.strictMode = strictMode;
    }

    @NonNull
    public IMMessage getAnchor() {
        String clientId = this.getAnchorClientId();
        if (StringUtil.isNotEmpty(clientId)) {
            IMMessage anchor = MsgDBHelper.queryMessageByUuid(clientId);
            if (anchor != null) {
                return anchor;
            }
        }
        long anchorTime = this.getDirection() == GetMessageDirectionEnum.BACKWARD ? this.getFromTime() : this.getToTime();
        IMMessageImpl anchor = (IMMessageImpl) MessageBuilder.createEmptyMessage(this.getSessionId(), this.getSessionType(), anchorTime);
        anchor.setUuid(this.getAnchorClientId());
        anchor.setServerId(this.getAnchorServerId());
        return anchor;
    }

    public GetMessagesDynamicallyParam createStandardizedParam() {
        return createStandardizedParam(true);
    }

    public GetMessagesDynamicallyParam createStandardizedParam(boolean checkLimit) {
        String formedSessionId = this.sessionId;
        SessionTypeEnum formedSessionType = this.sessionType == null ? SessionTypeEnum.None : this.sessionType;
        long formedFromTime = this.fromTime;
        long formedToTime = this.toTime;
        long formedExcludeServerId = this.anchorServerId;
        String formedExcludeClientId = this.anchorClientId;
        int formedLimit = this.limit;
        if (checkLimit) {
            formedLimit = formedLimit <= 0 ? GetMessagesDynamicallyParam.MAX_LIMIT : formedLimit;
            formedLimit = Math.min(formedLimit, GetMessagesDynamicallyParam.MAX_LIMIT);
        }
        GetMessageDirectionEnum formedDirection = this.direction == null ? GetMessageDirectionEnum.FORWARD : this.direction;
        List<MsgTypeEnum>msgTypes = this.messageTypes == null ? new ArrayList<>(0) : this.messageTypes;
        return new GetMessagesDynamicallyParam(formedSessionId, formedSessionType, formedFromTime, formedToTime, formedExcludeServerId, formedExcludeClientId, formedLimit, formedDirection, msgTypes, this.strictMode);
    }

    public boolean isValid() {
        return StringUtil.isNotEmpty(sessionId)
                && (sessionType == SessionTypeEnum.P2P || sessionType == SessionTypeEnum.Team || sessionType == SessionTypeEnum.SUPER_TEAM)
                && fromTime >= 0
                && toTime >= 0
                && (toTime == 0 || toTime >= fromTime)
                && limit >= 0 && limit <= MAX_LIMIT
                && (anchorServerId == 0 || StringUtil.isNotEmpty(anchorClientId));
    }

    @Override
    public String toString() {
        return "GetMessagesDynamicallyParam{" +
                "sessionId='" + sessionId + '\'' +
                ", sessionType=" + sessionType +
                ", fromTime=" + fromTime +
                ", toTime=" + toTime +
                ", excludeServerId=" + anchorServerId +
                ", excludeClientId='" + anchorClientId + '\'' +
                ", limit=" + limit +
                ", direction=" + direction +
                ", messageTypes=" + messageTypes +
                ", strictMode=" + strictMode +
                '}';
    }
}