mijia_team / mijia-android · Files

/**
 * @author 郎咸智
 * 上午11:48:18
 */
package com.ivt.android.me.model.main;

import org.json.JSONException;
import org.json.JSONObject;

import android.app.Activity;
import android.content.Context;
import android.content.Intent;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;

import com.ivt.android.me.api.UserApiBean;
import com.ivt.android.me.bean.BaseBean;
import com.ivt.android.me.bean.ChatDBEntity;
import com.ivt.android.me.bean.UserBean;
import com.ivt.android.me.bean.UserEntity;
import com.ivt.android.me.bean.WeiBoEntity;
import com.ivt.android.me.bean.evenbus.CodeBean;
import com.ivt.android.me.constant.BaseInfo;
import com.ivt.android.me.constant.CodeUtils;
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.AuthLinstener;
import com.ivt.android.me.utils.publics.DateUtils;
import com.ivt.android.me.utils.publics.DbUtil;
import com.ivt.android.me.utils.publics.LocationUserUtil;
import com.ivt.android.me.utils.publics.LogUtil;
import com.ivt.android.me.utils.publics.MyToastUtils;
import com.ivt.android.me.utils.publics.PhoneNumUtils;
import com.ivt.android.me.utils.publics.SharePreferenceUtil;
import com.ivt.android.me.utils.publics.StringUtils;
import com.ivt.android.me.utils.xmpp.XmppConnectionTool;
import com.lidroid.xutils.DbUtils;
import com.lidroid.xutils.exception.DbException;
import com.lidroid.xutils.http.client.HttpRequest;
import com.sina.weibo.sdk.auth.AuthInfo;
import com.sina.weibo.sdk.auth.Oauth2AccessToken;
import com.sina.weibo.sdk.auth.WeiboAuthListener;
import com.sina.weibo.sdk.auth.sso.SsoHandler;
import com.sina.weibo.sdk.exception.WeiboException;
import com.tencent.connect.common.Constants;
import com.tencent.mm.sdk.modelmsg.SendAuth;
import com.tencent.mm.sdk.openapi.IWXAPI;
import com.tencent.mm.sdk.openapi.WXAPIFactory;
import com.tencent.tauth.IUiListener;
import com.tencent.tauth.Tencent;
import com.tencent.tauth.UiError;

public class ModleLogin implements Ilogin {
	private Context context;
	/** 获取验证码成功 */
	private final int GETCODESUCCESS = 1000;
	/** 获取验证码失败 */
	private final int GETCODEFail = -1;
	/** 手机号登陆成功 */
	private final int PHONELOGINSUCCESS = 1001;
	/** 手机号登陆失败 */
	private final int PHONELOGINFAIL = -2;
	/** 登录中 */
	private final int LOGINING = 1002;
	/** 判定手机号 */
	private final int BANGPHONENUM = 1003;

	/** 登录XMPP成功 */
	private final int LOGINXMPPSUCCESS = 1008;
	/** 登录XMPP失败 */
	private final int LOGINXMPPFAIL = 1009;

	private Message msg;

	private Tencent mTencent;
	private String openId;
	/** 注意：SsoHandler 仅当 SDK 支持 SSO 时有效 */
	private SsoHandler mSsoHandler;
	private AuthInfo mAuthInfo;
	// 微信登录
	private IWXAPI api;

	private Handler h;

	public ModleLogin(Context context, Handler h,SsoHandler mSsoHandler) {
		// TODO Auto-generated constructor stub
		this.context = context;
		this.h = h;
		this.mSsoHandler=mSsoHandler;
		// 配置IM
		api = WXAPIFactory.createWXAPI(this.context, BaseInfo.WEIXIN_APP_ID,
				false);
		api.registerApp(BaseInfo.WEIXIN_APP_ID);

	}

	@Override
	public void LoginXmpp(String userId, final String Captcha,
			final UserEntity user) {
		// TODO Auto-generated method stub
		new Thread() {
			public void run() {
				if (user.getCaptcha().length() <= 0) {
					user.setCaptcha(Captcha);
				}
				Boolean b = XmppConnectionTool.getInstance().intent(user);
				if (b) {
					h.sendEmptyMessage(LOGINXMPPSUCCESS);
				} else {
					h.sendEmptyMessage(LOGINXMPPFAIL);
				}
			};
		}.start();
	}

	@Override
	public void LoginMe(final String PhoneNum, final String Captcha) {
		// TODO Auto-generated method stub
		if (PhoneNumUtils.judgePhoneNums(PhoneNum)) {
			if (PhoneNumUtils.isYanZM(Captcha, 4, context)) {
				String url = UserApiBean.Login(PhoneNum, Captcha);
				HttpUtils.getbase(url, new HttpCallback() {
					@Override
					public void onStart() {
						// TODO Auto-generated method stub
						super.onStart();
						h.sendEmptyMessage(LOGINING);
					}

					@Override
					public void onError(String msg) {
						// TODO Auto-generated method stub
						super.onError(msg);
						h.sendEmptyMessage(PHONELOGINFAIL);
					}

					@Override
					public void onSuccess(String data) {
						// TODO Auto-generated method stub
						UserBean bean = JsonUtils.deserialize(data,
								UserBean.class);
						int code = bean.getCode();
						if (code == 0) {
							UserEntity user = bean.getData();
							user.setCaptcha(Captcha);
							user.setMsisdn(PhoneNum);
							BaseInfo.timeDiff = user.getServertime()
									- DateUtils.getCurrentTime();
							// user.setToken(MD5Util.GetMD5Code(user.getServertime()));
							SaveInfo(user);
							Bundle b = new Bundle();
							b.putSerializable("user", user);
							msg = new Message();
							msg.what = PHONELOGINSUCCESS;
							msg.obj = b;
							h.sendMessage(msg);
						} else {
							h.sendEmptyMessage(PHONELOGINFAIL);
						}
					}
				});
			} else {
				MyToastUtils.showToast(context, "请输入有效的验证码");
			}
		}
	}

	private void SaveInfo(UserEntity user) {

		// 是否需要清除数据库
		checkChatSql(user.getId());
		BaseInfo.Captcha = user.getCaptcha();
		BaseInfo.UserId = user.getId() + "";
		BaseInfo.base_user = user;
		LocationUserUtil.SaveUser(user);
		SharePreferenceUtil.setValue(context, "XmppDbId", user.getId());
	}

	@Override
	public void GetCode(String PhoneNum) {
		// TODO Auto-generated method stub
		String url = UserApiBean.sendsms(PhoneNum);
		HttpUtils.getbase(url, new HttpCallback() {
			@Override
			public void onSuccess(String data) {
				// TODO Auto-generated method stub
				BaseBean base = JsonUtils.deserialize(data, BaseBean.class);
				LogUtil.e(data);
				int code = base.getCode();
				if (code == 0) {
					h.sendEmptyMessage(GETCODESUCCESS);
				} else {
					h.sendEmptyMessage(GETCODEFail);
				}
			}

			@Override
			public void onError(String msg) {
				// TODO Auto-generated method stub
				super.onError(msg);
				h.sendEmptyMessage(GETCODEFail);
			}

		});
	}

	@Override
	public void iSBangThird(final String value, final String thirdPartyAccount) {
		// TODO Auto-generated method stub
		String requestUrl = UserApiBean
				.thridpartLogin(value, thirdPartyAccount);

		HttpUtils.get(requestUrl, new HttpCallback() {
			@Override
			public void onStart() {
				// TODO Auto-generated method stub
				super.onStart();
				h.sendEmptyMessage(LOGINING);
			}

			@Override
			public void onError(String msg) {
				// TODO Auto-generated method stub
				super.onError(msg);
				h.sendEmptyMessage(PHONELOGINFAIL);
			}

			@Override
			public void onSuccess(String data) {
				// TODO Auto-generated method stub
				UserBean bean = JsonUtils.deserialize(data, UserBean.class);
				int code = bean.getCode();

				if (code == 1) {
					msg = new Message();
					Bundle b = new Bundle();
					b.putString("thirdPartyAccount", thirdPartyAccount);
					b.putString("value", value);
					msg.obj = b;

					msg.what = BANGPHONENUM;
					h.sendMessage(msg);

					// MainApplication.finishActivity();
				} else if (code == 0) {
					UserEntity user = bean.getData();
					Bundle b = new Bundle();
					b.putSerializable("user", user);

					BaseInfo.timeDiff = user.getServertime()
							- DateUtils.getCurrentTime();

					SaveInfo(user);
					msg = new Message();
					msg.what = PHONELOGINSUCCESS;
					msg.obj = b;
					h.sendMessage(msg);
				}
			}
		});
	}

	@SuppressWarnings("deprecation")
	@Override
	public void GetQQInfo(Intent intent) {
		mTencent.handleLoginData(intent, iulin);
	}

	@Override
	public void CallThirdLogin(int value) {
		// TODO Auto-generated method stub
		switch (value) {
		case 1:
			h.sendEmptyMessage(LOGINING);
			mTencent = Tencent.createInstance(BaseInfo.QQ_mAppid, context);
			mTencent.login((Activity) context, "all", iulin);
			break;
		case 2:
			// h.sendEmptyMessage(LOGINING);
			SendAuth.Req req = new SendAuth.Req();
			req.scope = "snsapi_userinfo";
			req.state = "wechat_sdk_demo_test";
			api.sendReq(req);
			break;
		case 3:
			AuthLinstener auth = new AuthLinstener(h, new HttpCallback() {
				@Override
				public void onSuccess(String data) {
					// TODO Auto-generated method stub
					WeiBoEntity userb = JsonUtils.deserialize(data,WeiBoEntity.class);
					openId = userb.getId() + "";
					iSBangThird("SINA", openId);
				}
			});
			mSsoHandler.authorize(auth);
			break;
		}
	}

	/**************** QQ监听 *******************/
	IUiListener iulin = new IUiListener() {

		@Override
		public void onError(UiError arg0) {
			// TODO Auto-generated method stub
		}

		@Override
		public void onComplete(Object response) {
			// TODO Auto-generated method stub
			if (null == response) {
				return;
			}
			JSONObject jsonResponse = (JSONObject) response;
			if (null != jsonResponse && jsonResponse.length() == 0) {
				return;
			}
			try {
				String token = jsonResponse
						.getString(Constants.PARAM_ACCESS_TOKEN);
				String expires = jsonResponse
						.getString(Constants.PARAM_EXPIRES_IN);
				openId = jsonResponse.getString(Constants.PARAM_OPEN_ID);
				if (!StringUtils.isEmpty(token)
						&& !StringUtils.isEmpty(expires)
						&& !StringUtils.isEmpty(openId)) {
					mTencent.setAccessToken(token, expires);
					mTencent.setOpenId(openId);
					iSBangThird("QQ", openId);
					// updateUserInfo(mTencent, openId, h);
				}

			} catch (JSONException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
				h.sendEmptyMessage(PHONELOGINFAIL);
			}
		}

		@Override
		public void onCancel() {
			// TODO Auto-generated method stub
			h.sendEmptyMessage(PHONELOGINFAIL);
		}
	};

	public void onEventMainThread(CodeBean code) {
		switch (code.getCode()) {
		case CodeUtils.LOGINWEIXINSU:
			openId = (String) code.getOther();
			iSBangThird("WECHAT", openId);
			break;
		case CodeUtils.LOGINWEIXINFA:
			h.sendEmptyMessage(PHONELOGINFAIL);
			break;
		default:
			break;
		}
	}

	/**
	 * 检查是否应该清除聊天记录
	 * 
	 * @param userId
	 *            当前登录账号的 id
	 */
	public void checkChatSql(int userId) {
		int oldId = SharePreferenceUtil.getInt(context, "XmppDbId", 0);
		if (oldId != userId) {
			DbUtil db = new DbUtil(context);
			DbUtils dbUtils = db.getDbUtils();
			try {
				dbUtils.deleteAll(ChatDBEntity.class);
			} catch (DbException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}

}