mijia_team / mijia-android · Files

/**
 * @author 郎咸智
 * 下午4:16:53
 */
package com.ivt.android.me.model.seelive;

import java.util.ArrayList;
import java.util.List;

import org.jivesoftware.smackx.muc.MultiUserChat;

import android.app.Activity;
import android.content.Context;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.support.annotation.NonNull;
import android.view.View;
import android.widget.ImageView;
import android.widget.LinearLayout;

import com.ivt.android.me.MainApplication;
import com.ivt.android.me.R;
import com.ivt.android.me.api.LiveApiBean;
import com.ivt.android.me.bean.BeanUser;
import com.ivt.android.me.bean.ChatMessageBean;
import com.ivt.android.me.bean.DanmuBean;
import com.ivt.android.me.bean.JoinRoomBean;
import com.ivt.android.me.bean.JoinRoomEntity;
import com.ivt.android.me.bean.LiveDataBean;
import com.ivt.android.me.bean.MeMessage;
import com.ivt.android.me.bean.Min;
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.constant.CodeUtils;
import com.ivt.android.me.constant.XmppType;
import com.ivt.android.me.model.uplive.LiveView;
import com.ivt.android.me.ui.activity.seelive.SeeLiveActivity;
import com.ivt.android.me.ui.dialog.RedPDialog;
import com.ivt.android.me.ui.dialog.UpliveCloseTrueDialog;
import com.ivt.android.me.ui.myview.BarrageLayout;
import com.ivt.android.me.ui.myview.GifTool;
import com.ivt.android.me.ui.myview.GiftShowTool;
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.LogUtil;
import com.ivt.android.me.utils.publics.MyToastUtils;
import com.ivt.android.me.utils.publics.SharePreferenceUtil;
import com.ivt.android.me.utils.xmpp.XmppConnectionTool;
import com.ivt.android.me.utils.xmpp.XmppMessageType;

/**
 * @author 郎咸智
 * @version 创建时间：2016-8-25 下午4:16:53 类说明
 */

public class SeeLiveModle implements ISeeLiveFragment {

	public static UserEntity owner = new UserEntity();
	private LiveView liveView;
	public LiveDataBean dataBean;
	private MultiUserChat muc;
	private BarrageLayout danmakuLayout;
	private DanmuBean danmu;
	private LinearLayout flLayout;
	private ImageView bigIv;
	private RedPDialog dialog;
	private UpliveCloseTrueDialog closedia;
	private Context context;
	private GiftShowTool gst;
	private GifTool gif;
	private String liveId;
	private String roomid;
	private String ownerId;
	private boolean isChatAuth = false;

	private Handler handler = new Handler() {
		@Override
		public void handleMessage(Message msg) {
			super.handleMessage(msg);
			switch (msg.what) {
			case CodeUtils.XMPP_MSG_IN:
				Bundle bd = msg.getData();
				String body = bd.getString("msg");
				receiveMsg(body);
				break;
			case 0:
				isChatAuth = (boolean) msg.obj;
				if (isChatAuth) {
					MyToastUtils.showToast(context, "你已经被禁言");
				}
				break;
			case 1:
				dataBean.setMemberList((ArrayList<String>) XmppConnectionTool
						.getInstance().findMulitUser(muc));
				dataBean.setRoomPeopleNums(dataBean.getMemberList().size());
				liveView.initHeadView();
				liveView.notifyNums();
				break;
			}
		}
	};

	public SeeLiveModle(@NonNull LiveView liveView, View view, Context context) {
		super();
		this.liveView = liveView;
		this.context = context;
		this.liveId = SeeLiveActivity.liveId;
		this.roomid = SeeLiveActivity.jid;
		this.ownerId = SeeLiveActivity.ownerId;
		dataBean = new LiveDataBean();
		danmakuLayout = (BarrageLayout) view.findViewById(R.id.dmv);
		bigIv = (ImageView) view.findViewById(R.id.gift_iv);
		flLayout = (LinearLayout) view.findViewById(R.id.gift_item);
	}

	@Override
	public JoinRoomEntity GetOwnerInfo() {
		return dataBean.getRoominfo();
	}

	@Override
	public void JoinRoom() {
		// 请求的路径
		String requestUrl = LiveApiBean.loginLiveRoom(BaseInfo.UserId,
				BaseInfo.Captcha, liveId, ownerId);

		HttpUtils.get(requestUrl, new HttpCallback() {
			@Override
			public void onSuccess(String data) {
				JoinRoomBean bean = JsonUtils.deserialize(data,
						JoinRoomBean.class);
				if (bean.getCode() == 0) {
					dataBean.setRoominfo(bean.getData());
					dataBean.setMeTang(dataBean.getRoominfo().getMecointotal());
					liveView.SetOwnerInfo();
					liveView.notifyMetang();
				} else if (bean.getCode() == 3001) {
					Long mtt = (long) 0;
					Long peoplenum = (long) 0;
					if (bean.getMeTotal() != null) {
						mtt = bean.getMeTotal();
					}
					if (bean.getAudienceTotalNum() != null) {
						peoplenum = bean.getAudienceTotalNum();
					}
					if (closedia == null) {
						closedia = new UpliveCloseTrueDialog(context,
								R.style.dialog, 2, new Long(peoplenum).intValue(),  new Long(mtt).intValue());
						if (closedia != null) {
							Activity a = (Activity) context;
							if (!a.isFinishing()) {
								closedia.show();
							}
						}
					}
				}
			}
		});
		new Thread() {
			public void run() {
				muc = XmppConnectionTool.getInstance().joinRoom(roomid,
						BaseInfo.UserId);
				handler.sendEmptyMessage(1);
			};
		}.start();
		XmppConnectionTool.getInstance().addGroupChatListener(handler);
		gst = new GiftShowTool(context, flLayout);
		gif = new GifTool(context, bigIv);
		BaseInfo.Islive = false;
		MainApplication.Islive = false;
	}

	public void agaJoinRoom() {
		muc = XmppConnectionTool.getInstance().joinRoom(roomid, BaseInfo.UserId);
		XmppConnectionTool.getInstance().addGroupChatListener(handler);
		dataBean.setRoomPeopleNums(dataBean.getMemberList().size());
		liveView.initHeadView();
		liveView.notifyNums();
	}

	@Override
	public void LeaveRoom() {
		XmppConnectionTool.getInstance().removeGroupChatListener();
		XmppConnectionTool.getInstance().leaveFromChatRoom(muc);
		String requestUrl = LiveApiBean.logoutLiveRoom(BaseInfo.UserId,BaseInfo.Captcha, liveId, ownerId);
		HttpUtils.get(requestUrl, new HttpCallback() {
			@Override
			public void onSuccess(String data) {

			}
		});
	}

	@Override
	public String getRoomNums() {
		return dataBean.getRoomPeopleNums() + "";
	}

	@Override
	public List<BeanUser> getMucList() {
		List<BeanUser> list = dataBean.getMucList();
		return list;
	}

	@Override
	public void receiveMsg(String msg) {

		ChatMessageBean cmb = null;
		try {
			// 判断是否是合法的json格式
			cmb = JsonUtils.deserialize(msg, ChatMessageBean.class);
		} catch (Exception e) {
			LogUtil.d("UpLiveModle", "这里收到了一条不合法的消息数据");
			return;
		}
		LogUtil.d("监听聊天信息:===============" + cmb.toString());
		XmppType type = cmb.getMsgType();
		if (type == null) {
			return;
		}
		String message = cmb.getMsgBody();
		UserEntity user = cmb.getUserInfo();
		switch (type) {
		case kSystemMessageType:
			dataBean.addMsg(new BeanUser(user.getUserId(), "直播消息", "", message,
					XmppMessageType.COLOR_TYPE_XT, user.getLevel(), user));
			break;
		case kNormalRoomChatMessageType:
			dataBean.addMsg(new BeanUser(user.getUserId(), user.getUserName(),
					"", message, XmppMessageType.COLOR_TYPE_MSG, user
							.getLevel(), user));
			break;
		case kDanMuRoomChatMessageType:
			if (cmb.getMsgBody() == null) {
				return;
			}
			synchronized (MainApplication.getInstance()) {

				if (danmu != null) {
					danmu = null;
				}
				danmu = new DanmuBean(user.getAvatar(), user.getUserName()
						+ ":" + message);
				danmakuLayout.addData(danmu);
				danmakuLayout.startAnimator();
				dataBean.addMsg(new BeanUser(user.getUserId(), user
						.getUserName(), "", message,
						XmppMessageType.COLOR_TYPE_BAR, user.getLevel(), user));
				danmu = null;
			}
			break;
		// case CodeUtils.XMMT_JOINROOM:
		// break;
		case kBigGiftType:
			operation(cmb.getGiftNumber(), cmb.getGiftPrice());
			gif.addGift(cmb.getGiftPic());
			gif.showGifta();
			dataBean.addMsg(new BeanUser(user.getUserId(), user.getUserName(),
					"", message, XmppMessageType.COLOR_TYPE_GIF, user
							.getLevel(), user));
			break;

		case kSmallGiftType:
			// 参数1 为头像路径
			MeMessage mem = new MeMessage(user.getAvatar(),
					cmb.getGiftNumber(), message, cmb.getGiftPic(),
					user.getUserName(), cmb.getMsgTime(), user.getUserId());
			gst.addGift(mem);
			// 发通知 让计算直播间的蜜糖数
			operation(cmb.getGiftNumber(), cmb.getGiftPrice());
			dataBean.addMsg(new BeanUser(user.getUserId(), user.getUserName(),
					"", message, XmppMessageType.COLOR_TYPE_ANI, user
							.getLevel(), user));
			break;
		case kPrivateRedPacketType:
			dataBean.addMsg(new BeanUser(user.getUserId(), user.getUserName(),
					"", message, XmppMessageType.COLOR_TYPE_SRHB, user
							.getLevel(), user));
			operation(cmb.getGiftNumber(), cmb.getGiftPrice());
			break;
		case kGroupRedPacketType:
			int redid = cmb.getGiftId();
			dataBean.addMsg(new BeanUser(user.getUserId(), user.getUserName(),
					"", cmb.getMsgBody(), XmppMessageType.COLOR_TYPE_MSG, user
							.getLevel(), user));
			dataBean.addMsg(new BeanUser(user.getUserId(), user.getUserName(),
					"", user.getAvatar(), XmppMessageType.COLOR_TYPE_REDP,
					redid + "", user.getSex(), user.getLevel(), user));
			if (redid != 0) {
				dialog = null;
				dialog = new RedPDialog(context, R.style.dialog, redid + "",
						user.getUserName(), user.getAvatar(), user.getSex(),
						user.getLevel());
				if (dialog != null) {
					Activity a = (Activity) context;
					if (!a.isFinishing()) {
						dialog.show();
					}
				}
			}
			break;
		case kSetBanSendMessageType:
			if (BaseInfo.UserId.equals(user.getUserId() + "")) {
				isChatAuth = true;
				MyToastUtils.showToast(context, "你已被禁言");
			} else {
				dataBean.addMsg(new BeanUser(user.getUserId(), "直播消息", user
						.getUserName(), message,
						XmppMessageType.COLOR_TYPE_MSG, user.getLevel(), user));
			}
			break;
		case kCancelBanSendMessageType:
			if (BaseInfo.UserId.equals(user.getUserId() + "")) {
				isChatAuth = false;
				MyToastUtils.showToast(context, "你已被取消禁言");
			} else {
				dataBean.addMsg(new BeanUser(user.getUserId(), "直播消息", user
						.getUserName(), message,
						XmppMessageType.COLOR_TYPE_MSG, user.getLevel(), user));
			}
			break;
		case kSetManagerType:
			if (BaseInfo.UserId.equals(user.getUserId() + "")) {
				SharePreferenceUtil.setValue(context, "isAdmin" + liveId, true);
				MyToastUtils.showToast(context, "你已成为管理员");
			} else {
				dataBean.addMsg(new BeanUser(user.getUserId(), "直播消息", user
						.getUserName(), message,
						XmppMessageType.COLOR_TYPE_MSG, user.getLevel(), user));
			}
			break;
		case kCancelManagerType:
			if (BaseInfo.UserId.equals(user.getUserId() + "")) {
				SharePreferenceUtil
						.setValue(context, "isAdmin" + liveId, false);
				MyToastUtils.showToast(context, "你已被解除管理员权限");
			} else {
				dataBean.addMsg(new BeanUser(user.getUserId(), "直播消息", user
						.getUserName(), message,
						XmppMessageType.COLOR_TYPE_MSG, user.getLevel(), user));
			}
			break;
		case kQuitRoomType:

			if (!BaseInfo.UserId.equalsIgnoreCase(user.getUserId() + "")) {
				if (closedia == null) {
					closedia = new UpliveCloseTrueDialog(context,
							R.style.dialog, 2, cmb.getGiftNumber(),
							cmb.getGiftPrice());
					if (closedia != null) {
						Activity a = (Activity) context;
						if (!a.isFinishing()) {
							closedia.show();
						}
					}
				}
			}
			break;
		// case CodeUtils.XMMT_OWNER_LEAVE:// 主播暂时离开
		// if (BaseInfo.UserId.equals(user.getUserId())) {
		// return;
		// }
		// switch (mm.getGiftNums()) {
		// case 1:
		// live_leave.setVisibility(View.VISIBLE);
		// // time.start();
		// break;
		// case 0:
		// // time.cancel();
		// live_leave.setVisibility(View.GONE);
		// break;
		// }
		// break;
		default:
			break;

		}

		liveView.notifyMsg();
	}

	@Override
	public void sendMsg(String msg, XmppType type) {
		if (isChatAuth) {
			MyToastUtils.showToast(context, "你已经被禁言");
			return;
		}
		ChatMessageBean bean = new ChatMessageBean(msg, type);
		String me = JsonUtils.serialize(bean);
		try {
			if (type == XmppType.kDanMuRoomChatMessageType) {
				SendDanMu(me);
			} else {
				muc.sendMessage(me);
			}
		} catch (Exception e) {
			e.printStackTrace();
			agaJoinRoom();
		}
	}

	public void sendMssg(ChatMessageBean bean) {
		String me = JsonUtils.serialize(bean);
		try {
			muc.sendMessage(me);
		} catch (Exception e) {
			e.printStackTrace();
			agaJoinRoom();
		}

	}

	@Override
	public List<String> getMemberList() {
		return dataBean.getMemberList();
	}

	@Override
	public void chechChatAuth(String userId) {

		String requestUrl = LiveApiBean.chechChatAuth(userId, liveId);

		HttpUtils.get(requestUrl, new HttpCallback() {
			@Override
			public void onSuccess(String data) {
				Min mm = JsonUtils.deserialize(data, Min.class);
				Message message = new Message();
				message.what = 0;
				message.obj = mm.isState();
				handler.sendMessage(message);
			}
		});

	}

	private void SendDanMu(final String msgType) {
		// 请求的路径
		String requestUrl = LiveApiBean.sendBulletScreenMessage(
				BaseInfo.UserId, BaseInfo.Captcha, Integer.parseInt(liveId));
		HttpUtils.get(requestUrl, new HttpCallback() {
			@Override
			public void onSuccess(String data) {
				// TODO Auto-generated method stub
				UserBean user1 = JsonUtils.deserialize(data, UserBean.class);
				if (user1.getCode() == 0) {
					try {
						muc.sendMessage(msgType);
					} catch (Exception e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
						agaJoinRoom();
					}
				} else if (user1.getCode() == 1009) {
					MyToastUtils.showToast(MainApplication.getInstance(),
							"中国币不足，请充值");
				} else {
					MyToastUtils.showToast(MainApplication.getInstance(),
							"发送失败");
				}
			}

			@Override
			public void onError(String msg) {
				// TODO Auto-generated method stub
				super.onError(msg);
				MyToastUtils.showToast(MainApplication.getInstance(), "发送失败");
			}
		});
	}

	@Override
	public void operation(int nums, int price) {
		// TODO Auto-generated method stub
		int meTang = nums * price;
		int mt = dataBean.getMeTang();
		int zongtang = meTang + mt;
		dataBean.setMeTang(zongtang);
		liveView.notifyMetang();
	}

	@Override
	public int getMeTang() {
		// TODO Auto-generated method stub
		return dataBean.getMeTang();
	}

}