好友聊天消息列表本地数据库封装

import com.xuehu365.xuehu.utils.DBHelp;
import com.xuehu365.xuehu.utils.LogHelp;

import org.xutils.ex.DbException;

import java.util.List;

/**
* Created by Administrator on 2016/10/26.
*/
public class PersonalMessageListData {

public static MessageChatEntity getById(String relationId) {
try {
return DBHelp.getInstance().getDbManager().selector(MessageChatEntity.class).where("relationId", "=", relationId).findFirst();
} catch (DbException e) {
e.printStackTrace();
}
return null;
}

/**
* 获取所有未读消息数量
*/
public static int getTotalPersonalMsgUnReadCount() {
int total = 0;
try {
List<MessageChatEntity> allPersonalMsg = DBHelp.getInstance().getDbManager().findAll(MessageChatEntity.class);
if (null != allPersonalMsg && allPersonalMsg.size() > 0) {
for (MessageChatEntity entity : allPersonalMsg) {
total += entity.getMsgCount();
}
}
} catch (DbException e) {
e.printStackTrace();
}
return total;
}

/**
* 删除好友回话
*/
public static void deletePersonalMessage(String relationId) {
try {
DBHelp.getInstance().getDbManager().deleteById(MessageChatEntity.class, relationId);
} catch (DbException e) {
e.printStackTrace();
}
}

/**
* 设置未读消息
*/
public static void setPersonalMsg(PrivateMessage message) {
//更新用户消息
MessageChatEntity entity = getById(message.getConversationId());
//之前存在
if (null == entity) {
entity = new MessageChatEntity();
entity.setRelationId(message.getConversationId());
}
entity.setMsgCount(entity.getMsgCount() + 1);
entity.setFriendId(message.getUserId());
entity.setImageUrl(message.getHeadUrl());
entity.setName(message.getUserName());
entity.setChatDate(Long.parseLong(message.getTime()));
entity.setChatContent(message.getMsg());
entity.setIsFriend(message.getPersonalMsgType());
entity.setMsgType(message.getMsgType());
DBHelp.getInstance().saveOrUpdate(entity);
}

/**
* 设置自己的消息
*/
public static void setSelfPersonMsg(PrivateMessage message, FriendModel model) {
//更新用户消息
MessageChatEntity entity = getById(message.getConversationId());
//之前存在
if (null == entity) {
entity = new MessageChatEntity();
entity.setRelationId(message.getConversationId());
}
entity.setMsgCount(0);
entity.setFriendId(model.getFriendId());
entity.setImageUrl(model.getHeadUrl());
entity.setName(model.getFriendName());
entity.setChatDate(Long.parseLong(message.getTime()));
entity.setChatContent(message.getMsg());
entity.setIsFriend(message.getPersonalMsgType());
entity.setMsgType(message.getMsgType());
DBHelp.getInstance().saveOrUpdate(entity);
}

/**
* 查出所有好友消息
*/
public static List<MessageChatEntity> getAllPersonalMessage() {
try {
return DBHelp.getInstance().getDbManager().selector(MessageChatEntity.class).orderBy("chatDate", true).findAll();
} catch (DbException e) {
e.printStackTrace();
}
return null;
}

/**
* 设置好友消息已读
*/
public static void setMessageRead(String relationId) {
LogHelp.i("friend", "fadfagagr");
MessageChatEntity entity = getById(relationId);
if (null != entity) {
entity.setMsgCount(0);
DBHelp.getInstance().saveOrUpdate(entity);
}

}

}