mijia_team / mijia-android · Files

package com.ivt.android.me.model.live;

import java.util.ArrayList;
import java.util.Collections;
import java.util.Comparator;
import java.util.List;

import android.annotation.SuppressLint;
import android.content.Context;
import android.os.Handler;
import android.os.Message;
import android.support.annotation.NonNull;
import android.support.v7.widget.RecyclerView;
import android.view.View;

import com.ivt.android.me.api.LiveApiBean;
import com.ivt.android.me.api.UserApiBean;
import com.ivt.android.me.bean.MyFollowerBean;
import com.ivt.android.me.bean.UserBean;
import com.ivt.android.me.bean.UserEntity;
import com.ivt.android.me.constant.BaseInfo;
import com.ivt.android.me.model.uplive.LiveView;
import com.ivt.android.me.ui.activity.mine.UserDetilas;
import com.ivt.android.me.ui.adapter.RVHeadAdapter;
import com.ivt.android.me.ui.adapter.RVHeadAdapter.OnRecycItemClickListener;
import com.ivt.android.me.utils.httputil.HttpUtils;
import com.ivt.android.me.utils.httputil.HttpUtils.HttpCallback;
import com.ivt.android.me.utils.httputil.JsonUtils;
import com.ivt.android.me.utils.publics.ClickUtil;
import com.ivt.android.me.utils.publics.MyToastUtils;
import com.lidroid.xutils.http.client.HttpRequest.HttpMethod;

@SuppressLint("NewApi")
public class LiveHeadModel {
	private static String TAG = "LiveHeadTool===";

	private String owner;
	private String roomId;
	private int listfiredNums;
	private boolean isSort = false;// 是否排序

	private List<String> listPeople;// 进入房间时xmpp所有人
	private List<String> listMore;// xmpp所有人
	private List<UserEntity> OwnerGiftTen;// 贡献榜前十
	private List<UserEntity> OwnerGiftlist;// 贡献榜
	private List<UserEntity> listfired;// 贡献榜有且listMore中存在的
	private List<UserEntity> allList = new ArrayList<UserEntity>();// 获取总用户信息所有

	/**
	 * @return the allList
	 */
	public List<UserEntity> getAllList() {
		return allList;
	}

	private RecyclerView rvHead;
	private RVHeadAdapter adapter;
	private Context context;
	private LiveView liveView;

	private boolean first = true;

	private static UserEntity userinfo = null;

	public LiveHeadModel(@NonNull LiveView liveView, List<String> memberlist,
			RecyclerView rvHead, Context context, String owner, String roomId) {
		this.listPeople = memberlist;
		this.context = context;
		this.owner = owner;
		this.roomId = roomId;
		this.rvHead = rvHead;
		this.liveView = liveView;
		rvHead.setHasFixedSize(true);
		init();
		if (isSort) {
			getOwnerGiftlist();
		} else {
			getlistAgo();
		}
	}

	public void init() {
		adapter = new RVHeadAdapter(context, allList);
		rvHead.setAdapter(adapter);
		adapter.setOnItemClickListener(new OnRecycItemClickListener() {
			@Override
			public void onItemClick(View view, int position) {
				liveView.softKeyB();
				if (!BaseInfo.ISNETCONTEXT) {
					MyToastUtils.showNoNet(context);
					return;
				}
				if (ClickUtil.isSeeGiftDoubleClick()) {
					return;
				} else {
					int xx = 1;
					if (BaseInfo.UserId.equals(allList.get(position).getId()
							+ "")) {
						xx = 0;
					}
					UserDetilas.GoToUserDetilas(context, xx,
							allList.get(position), roomId);
				}
			}
		});
	}

	/**
	 * 不排序时用的
	 */
	public void getlistAgo() {
		listMore = new ArrayList<String>();
		for (int i = 0; i < listPeople.size(); i++) {
			if (listPeople.get(i).equals(owner)) {
				continue;
			}
			if (listPeople.get(i) == null) {
				continue;
			}
			GetUserInfo(listPeople.get(i));// 不排序时新加的
		}
	}

	/**
	 * 排序时 xmpp所有id
	 */
	public void getlistMore() {
		listMore = new ArrayList<String>();
		listfired = new ArrayList<UserEntity>();
		for (int i = 0; i < listPeople.size(); i++) {
			if (listPeople.get(i).equals(owner)) {
				continue;
			}
			listMore.add(listPeople.get(i));
			isTen(listPeople.get(i));
		}

		listfired = mySort(listfired);
		listfiredNums = listfired.size();
		allList.addAll(listfired);
		adapter.notifyDataSetChanged();

		for (int i = 0; i < listMore.size(); i++) {
			GetUserInfo(listMore.get(i));
		}
	}

	/**
	 * 判断是不是贡献榜前十
	 *
	 * @param userId
	 */
	public void isTen(String userId) {
		for (int i = 0; i < OwnerGiftTen.size(); i++) {
			if (userId.equals(OwnerGiftTen.get(i).getId() + "")) {
				listfired.add(OwnerGiftTen.get(i));
				listMore.remove(listMore.size() - 1);
				return;
			}
		}
	}

	/**
	 * 比我之后进来的人是否在 贡献榜前十
	 *
	 * @param userId
	 */
	public UserEntity isInTen(String userId) {
		UserEntity entity = null;
		if (OwnerGiftTen.size() == 0) {
			return null;
		}
		for (int i = 0; i < OwnerGiftTen.size(); i++) {
			if (userId.equals(OwnerGiftTen.get(i).getId() + "")) {
				entity = new UserEntity();
				listfired.add(OwnerGiftTen.get(i));
				listfiredNums++;
				entity = OwnerGiftTen.get(i);
				return entity;
			}
		}
		return entity;
	}

	private Handler handler = new Handler() {
		@SuppressWarnings("unchecked")
		public void handleMessage(Message msg) {
			switch (msg.what) {
			case 000:// 贡献榜前十
				OwnerGiftTen = new ArrayList<UserEntity>();
				OwnerGiftlist.addAll((List<UserEntity>) msg.obj);
				OwnerGiftlist = mySort(OwnerGiftlist);
				int nums = 10;
				if (OwnerGiftlist.size() < nums) {
					nums = OwnerGiftlist.size();
				}
				for (int i = 0; i < nums; i++) {
					OwnerGiftTen.add(OwnerGiftlist.get(i));
					OwnerGiftTen.get(i).setId(OwnerGiftTen.get(i).getUserId());
				}
				getlistMore();
				break;
			case 111:
				UserEntity entity = (UserEntity) msg.obj;
				if (!first && isSort) {
					UserEntity user = isInTen(entity.getId() + "");
					if (user != null) {
						entity = user;
						if (listfired.size() == 0) {
							allList.add(0, entity);
							adapter.notifyItemInserted(0);
							return;
						}
						if (allList.size() == 0) {
							allList.add(entity);
							adapter.notifyDataSetChanged();
							return;
						}
						if (allList.size() >= listfiredNums - 1) {
							if (entity.getPrice() < allList.get(
									listfiredNums - 1).getPrice()) {
								allList.add(listfiredNums - 1, entity);
								adapter.notifyItemInserted(listfiredNums - 1);
								return;
							}
						}
						for (int i = 0; i < listfiredNums; i++) {
							if (entity.getPrice() >= allList.get(i).getPrice()) {
								allList.add(i, entity);
								adapter.notifyItemInserted(i);
								return;
							}
						}
					}
				}
				allList.add(entity);
				adapter.notifyDataSetChanged();
				break;

			}
		};
	};

	/**
	 * 贡献榜前十所有用户信息
	 */
	public void getOwnerGiftlist() {
		OwnerGiftlist = new ArrayList<UserEntity>();
		getUserGiftStatList(owner);
	}

	/**
	 * 添加新进入的人的信息
	 *
	 * @param userId
	 */
	public void addDate(String userId) {
		first = false;
		// UserEntity entity = MulitChatTools.roomMap.get(userId);
		UserEntity entity = null;
		if (entity == null) {
			GetUserInfo(userId);
			return;
		}
		if (entity.getAvatar() != null) {
			if (isSort) {
				UserEntity user = isInTen(entity.getId() + "");
				if (user != null) {
					entity = user;
					if (listfired.size() == 0) {
						allList.add(0, entity);
						adapter.notifyItemInserted(0);
						return;
					}
					if (allList.size() >= listfiredNums - 1) {
						if (entity.getPrice() < allList.get(listfiredNums - 1)
								.getPrice()) {
							allList.add(listfiredNums - 1, entity);
							adapter.notifyItemInserted(listfiredNums - 1);
							return;
						}
					}
					for (int i = 0; i < listfiredNums; i++) {
						if (entity.getPrice() >= allList.get(i).getPrice()) {
							allList.add(i, entity);
							adapter.notifyItemInserted(i);
							return;
						}
					}
				}
			}
			allList.add(entity);
			adapter.notifyDataSetChanged();
		} else {
			GetUserInfo(userId);
		}
	}

	/**
	 * 离开则删除
	 *
	 * @param userId
	 */
	public void removeDate(String userId) {
		if (allList.size() < 1) {
			return;
		}
		for (int i = 0; i <= allList.size(); i++) {
			if (userId.equals(allList.get(i).getId() + "")) {
				if (i <= listfiredNums) {
					listfiredNums--;
				}
				allList.remove(i);
				adapter.notifyItemRemoved(i);
				adapter.notifyItemRangeChanged(i, allList.size());
				return;
			}
		}
	}

	/**
	 * 获取个人信息
	 *
	 * @param userid
	 * @return
	 */
	public UserEntity GetUserInfo(String userid) {
		// 请求的路径
		String requestUrl = UserApiBean.requestUserInfo(BaseInfo.UserId,
				BaseInfo.Captcha, userid);

		HttpUtils.get(requestUrl, new HttpCallback() {

			@Override
			public void onSuccess(String data) {
				// TODO Auto-generated method stub
				UserBean user1 = JsonUtils.deserialize(data, UserBean.class);
				int code = user1.getCode();
				if (code == 0) {
					userinfo = user1.getData();
					Message mes = new Message();
					mes.what = 111;
					mes.obj = userinfo;
					handler.sendMessage(mes);

				} else if (code == 1004) {
					userinfo = null;
				} else {
					userinfo = null;
				}
			}
		});

		return userinfo;

	}

	static List<UserEntity> serList = null;

	/**
	 * 获取贡献榜
	 *
	 * @param userId
	 * @return
	 */
	public List<UserEntity> getUserGiftStatList(String userId) {
		// 请求的方式
		HttpMethod requestMethod = HttpMethod.GET;

		// 请求的路径
		String requestUrl = LiveApiBean.getUserGiftStatList(BaseInfo.UserId,
				BaseInfo.Captcha, userId, 1, 10);

		HttpUtils.get(requestUrl, new HttpCallback() {

			@Override
			public void onSuccess(String data) {
				// TODO Auto-generated method stub
				MyFollowerBean user1 = JsonUtils.deserialize(data,
						MyFollowerBean.class);
				int code = user1.getCode();
				if (code == 0) {
					serList = user1.getData();
					Message mes = new Message();
					mes.what = 000;
					mes.obj = serList;
					handler.sendMessage(mes);
				} else if (code == 1004) {
					serList = null;
				} else {
					serList = null;
				}
			}
		});

		return serList;
	}

	/**
	 * 根据贡献度排序
	 *
	 * @param users
	 * @return
	 */
	private List<UserEntity> mySort(List<UserEntity> users) {

		Collections.sort(users, new Comparator<UserEntity>() {
			@Override
			public int compare(UserEntity lhs, UserEntity rhs) {

				if (lhs.getPrice() > rhs.getPrice()) {
					return -1;
				}
				if (lhs.getPrice() == rhs.getPrice()) {
					return 0;
				}
				if (lhs.getPrice() < rhs.getPrice()) {
					return 1;
				}
				return 0;
			}
		});
		return users;
	}

}