| | |
| | | public class HdlMessageLogic { |
| | | private static volatile HdlMessageLogic sHdlMessageLogic; |
| | | |
| | | private int pageSize = 50;//页数 |
| | | private final int pageSize = 50;//页数 |
| | | private List<MessageBean> mListMessage = new ArrayList<>(); |
| | | |
| | | /** |
| | | * 获取当前对象 |
| | |
| | | } |
| | | return sHdlMessageLogic; |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 获取发生中缓存列表 |
| | |
| | | } |
| | | |
| | | |
| | | private List<MessageBean> mListMessage = new ArrayList<>(); |
| | | /** |
| | | * 获取未处理缓存消息数量 |
| | | */ |
| | | public String getMessageUntreatedMemoryCount() { |
| | | if (this.mListMessage == null || this.mListMessage.size() == 0) { |
| | | return "0"; |
| | | } |
| | | List<MessageBean> newList = new ArrayList<>(); |
| | | for (int i = 0; i < mListMessage.size(); i++) { |
| | | MessageBean messageBean = mListMessage.get(i); |
| | | if (messageBean == null) { |
| | | continue; |
| | | } |
| | | if (!messageBean.getStatus().equals(MessageStateType.untreated)) { |
| | | continue; |
| | | } |
| | | if (!messageBean.isRead()) { |
| | | newList.add(messageBean); |
| | | } |
| | | |
| | | } |
| | | return newList.size() + ""; |
| | | } |
| | | |
| | | /** |
| | | * 获取未处理消息数量 |
| | |
| | | json.addProperty("status", messageStateType); |
| | | } |
| | | json.addProperty("pageNo", 1);//页码 |
| | | json.addProperty("pageSize", 50);//页数 |
| | | json.addProperty("pageSize", pageSize);//页数 |
| | | |
| | | List<MessageBean> list = new ArrayList<>(); |
| | | HttpClient.getInstance().requestHttp(requestUrl, json.toString(), new CloudCallBeak<String>() { |
| | |
| | | } |
| | | |
| | | /** |
| | | * 获取消息列表 |
| | | * 获取指定页的获取消息列表 |
| | | * |
| | | * @param pageNo 页码 |
| | | * @param messageStateType all:全部,UNTREATED:未处理,PROCESSED:已处理; |
| | | * @param cloudCallBeak - |
| | | */ |
| | | private void getMessageList(int pageNo, String messageStateType, CloudCallBeak<List<MessageBean>> cloudCallBeak) { |
| | | public void getPageNoMessageList(int pageNo, String messageStateType, CloudCallBeak<MessageListClass> cloudCallBeak) { |
| | | String requestUrl = HttpApi.POST_Message_List; |
| | | JsonObject json = new JsonObject(); |
| | | |
| | | if (!MessageStateType.all.equals(messageStateType)) { |
| | | json.addProperty("status", messageStateType); |
| | | } |
| | | json.addProperty("pageNo", 1);//页码 |
| | | json.addProperty("pageSize", 50);//页数 |
| | | json.addProperty("pageNo", pageNo);//页码 |
| | | json.addProperty("pageSize", pageSize);//页数 |
| | | |
| | | List<MessageBean> list = new ArrayList<>(); |
| | | HttpClient.getInstance().requestHttp(requestUrl, json.toString(), new CloudCallBeak<String>() { |
| | | @Override |
| | | public void onSuccess(String jsonStr) { |
| | | if (TextUtils.isEmpty(jsonStr)) { |
| | | if (cloudCallBeak != null) { |
| | | cloudCallBeak.onSuccess(new ArrayList<>()); |
| | | cloudCallBeak.onSuccess(new MessageListClass()); |
| | | } |
| | | return; |
| | | } |
| | | Gson gson = new Gson(); |
| | | MessageListClass oldMessageListClass = gson.fromJson(jsonStr, MessageListClass.class); |
| | | list.addAll(oldMessageListClass.getList()); |
| | | setListMessage(oldMessageListClass.getList()); |
| | | //总共有多少页 |
| | | long totalPage = oldMessageListClass.totalPage; |
| | | if (totalPage < 2) { |
| | | if (cloudCallBeak != null) { |
| | | cloudCallBeak.onSuccess(list); |
| | | } |
| | | return; |
| | | } |
| | | //记录请求条数 |
| | | AtomicInteger atomicInteger = new AtomicInteger(0); |
| | | //从第二页获取数据 |
| | | for (int i = 2; i <= totalPage; i++) { |
| | | json.addProperty("pageNo", i);//更新页码 |
| | | HttpClient.getInstance().requestHttp(requestUrl, json.toString(), new CloudCallBeak<String>() { |
| | | @Override |
| | | public void onSuccess(String jsonStr) { |
| | | atomicInteger.set(atomicInteger.get() + 1); |
| | | MessageListClass newMessageListClass = gson.fromJson(jsonStr, MessageListClass.class); |
| | | list.addAll(newMessageListClass.getList()); |
| | | setListMessage(newMessageListClass.getList()); |
| | | if (atomicInteger.get() == totalPage - 1) { |
| | | //最后一条退出 |
| | | if (cloudCallBeak != null) { |
| | | cloudCallBeak.onSuccess(list); |
| | | } |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | public void onFailure(HDLException e) { |
| | | atomicInteger.set(atomicInteger.get() + 1); |
| | | if (atomicInteger.get() == totalPage - 1) { |
| | | //最后一条退出 |
| | | if (cloudCallBeak != null) { |
| | | cloudCallBeak.onSuccess(list); |
| | | } |
| | | } |
| | | } |
| | | }); |
| | | cloudCallBeak.onSuccess(oldMessageListClass); |
| | | } |
| | | } |
| | | |
| | |
| | | } |
| | | |
| | | |
| | | static class MessageListClass { |
| | | public static class MessageListClass { |
| | | |
| | | //总条数 |
| | | private long totalCount; |