package com.yeshi.fanli.controller.xcx;

import java.io.PrintWriter;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.UUID;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;

import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.yeshi.utils.HttpUtil;
import org.yeshi.utils.IPUtil;
import org.yeshi.utils.JsonUtil;
import org.yeshi.utils.tencentcloud.COSManager;

import com.yeshi.fanli.entity.accept.AcceptData;
import com.yeshi.fanli.entity.bus.user.UserInfo;
import com.yeshi.fanli.entity.bus.user.WeiXinUser;
import com.yeshi.fanli.entity.goods.CollectionGoodsV2;
import com.yeshi.fanli.entity.system.System;
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBriefExtra;
import com.yeshi.fanli.exception.goods.CollectionGoodsException;
import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.config.ConfigService;
import com.yeshi.fanli.service.inter.goods.CollectionGoodsV2Service;
import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;
import com.yeshi.fanli.service.inter.hongbao.HongBaoService;
import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce;
import com.yeshi.fanli.service.inter.order.LostOrderService;
import com.yeshi.fanli.service.inter.order.OrderItemServcie;
import com.yeshi.fanli.service.inter.order.OrderService;
import com.yeshi.fanli.service.inter.user.AccountDetailsService;
import com.yeshi.fanli.service.inter.user.AccountMessageService;
import com.yeshi.fanli.service.inter.user.BindingAccountService;
import com.yeshi.fanli.service.inter.user.ExtractService;
import com.yeshi.fanli.service.inter.user.PassWordErrorRecordService;
import com.yeshi.fanli.service.inter.user.ShamUserService;
import com.yeshi.fanli.service.inter.user.UserInfoService;
import com.yeshi.fanli.service.inter.user.WxDownService;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.GsonUtil;
import com.yeshi.fanli.util.RedisManager;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.ThreadUtil;
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
import com.yeshi.fanli.util.wx.WXLoginUtil;

import net.sf.json.JSONObject;

@Controller
@RequestMapping("api/xcx/v1/XcxCustomer")
public class XcxUserInfoController {

	@Resource
	private UserInfoService userInfoService;

	@Resource
	private OrderService orderService;

	@Resource
	private HongBaoService hongBaoService;



	@Resource
	private BindingAccountService bindingAccountService;

	@Resource
	private ExtractService extractService;

	@Resource
	private PassWordErrorRecordService passWordErrorRecordService;

	@Resource
	private ConfigService configService;

	@Resource
	private XcxMiniControllerUtil xcxMiniControllerUtil;

	@Resource
	private ShamUserService shamUserService;

	@Resource
	private ThreeSaleSerivce threeSaleSerivce;

	@Resource
	private LostOrderService lostOrderService;

	@Resource
	private OrderItemServcie orderItemServcie;

	@Resource
	private AccountDetailsService accountDetailsService;

	@Resource
	private AccountMessageService accountMessageService;

	@Resource
	private CollectionGoodsV2Service collectionGoodsV2Service;
	@Resource
	private HongBaoManageService hongBaoManageService;

	@Resource
	private WxDownService wxDownService;

	@Resource
	private RedisManager redisManager;

	/**
	 * 获取用户信息
	 * 
	 * @param acceptData
	 * @param form
	 * @param requst
	 * @param out
	 */
	@RequestMapping(value = "getuserinfo", method = RequestMethod.POST)
	public void getUserInfo(AcceptData acceptData, UserInfo form, String code, String create, boolean first,
			HttpServletRequest requst, PrintWriter out) {
		String remotIP = IPUtil.getRemotIP(requst);
		long id = form.getId();
		// 判断是不是用ID登陆的，如果是用ID登陆的其他都不要管了
		if (id != 0) {
			UserInfo find = userInfoService.getUserById(id);
			if (find != null) {
				outUserInfo(out, remotIP, find, acceptData.getDevice());
				return;
			} else {
				out.print(JsonUtil.loadFalseResult("不存在该账户！"));
				return;
			}
		}
		// 不是用ID的登陆的事就多了
		System system = xcxMiniControllerUtil.getSystem(acceptData);
		if (system == null) {
			out.print(JsonUtil.loadFalseResult(XcxMiniControllerUtil.NOSYSTEM));
			return;
		}
		String appid = system.getAppid();

		// 判断是否是第一次正常登陆
		/*
		 * String platform = acceptData.getPlatform(); if(platform == "ios") {
		 * // 1: 安卓 2：ios if(firstIos == "1") { //第一次登陆 first = true; } else {
		 * first = false; } }
		 */
		if (first) {
			int loginType = form.getLoginType();
			// WeiXinUserParam wxParam = null;
			// 如果是微信登陆，那需要先获取到微信的unionid
			WeiXinUser weiXinUser = WXLoginUtil.getWeiXinUserWithSavePortrait(code);
			if (loginType == Constant.WEIXIN && StringUtil.isNullOrEmpty(form.getWxUnionId())) {
				// wxParam = WXinUtil.getWxParam(code);
				if (weiXinUser == null) {
					out.print(JsonUtil.loadFalseResult(XcxMiniControllerUtil.FAILED));
					return;
				}
				form.setWxOpenId(weiXinUser.getOpenid());
				form.setWxUnionId(weiXinUser.getUnionid());
			}
			String openid = loginType == 1 ? form.getOpenid() : form.getWxUnionId();
			LogHelper.userInfo("[ip:" + IPUtil.getRemotIP(requst) + "]" + (loginType == 1 ? "淘宝登陆" : "微信登陆")
					+ "[openid:" + openid + "]");
			if (openid == null || openid.equals("")) {
				out.print(JsonUtil.loadFalseResult(XcxMiniControllerUtil.FAILED));
				return;
			}
			// 获取用户信息
			UserInfo user = userInfoService.getUserByLoginTypeAndOpenId(loginType, openid, appid);
			// 判断获取的用户信息是否为空，如果不为空就做的事就又多了
			if (user != null) {// 数据库中已经存在该用户
				outUserInfo(out, remotIP, user, acceptData.getDevice());
				UserInfo temp = user;
				long lastLoginTime = temp.getLastLoginTime() == null ? 0 : temp.getLastLoginTime().longValue();
				if (lastLoginTime == 0) {// 等于0则是第一次登陆，那么需要判断用户是不是被传销来的,如果是的话，那需要修改相关三级分销的状态
					ThreadUtil.run(new Runnable() {
						@Override
						public void run() {
							threeSaleSerivce.effective(temp);
						}

					});
				}
				return;
			}
			// 查询到的用户信息为空,那么需要填充一些用户信息
			if (loginType == Constant.WEIXIN) {
				form.setPortrait(weiXinUser.getHeadimgurl());
				String wxHeadImg = COSManager.getInstance()
						.uploadFile(HttpUtil.getAsInputStream(weiXinUser.getHeadimgurl()),
								Constant.WXHEADURL + UUID.randomUUID().toString())
						.getUrl();
				form.setWxPic(wxHeadImg);
				form.setNickName(weiXinUser.getNickname());
				form.setWxName(weiXinUser.getNickname());
			} else if (loginType == Constant.TAOBAO) {
				form.setTbName(form.getNickName());
				form.setTbPic(form.getPortrait());
			}
			form.setLastLoginIp(remotIP);
			form.setLastLoginTime(java.lang.System.currentTimeMillis());
			form.setSystem(system);
			requst.getSession().setAttribute("newUser", form);
			out.append(JsonUtil.loadTrueResult(2, form));
			return;
		}

		if (create == null || "0".equals(create)) {
			out.append(JsonUtil.loadFalseResult("参数create不能为空!"));
			return;
		}

		UserInfo newUser = (UserInfo) requst.getSession().getAttribute("newUser");
		UserInfo mainUser = (UserInfo) requst.getSession().getAttribute("mainUser");
		if (Constant.NEWUSER.equals(create)) { // 创建
			UserInfo user;
			synchronized (UserInfo.class) {
				user = userInfoService.addUser(newUser, appid);
			}
			if (user != null) {
				JSONObject data = new JSONObject();
				data.put("user", GsonUtil.toJsonExpose(user));
				data.put("first", 1);
				out.print(JsonUtil.loadTrueResult(data));
				LogHelper.userInfo(GsonUtil.toJsonExpose(user));
			} else {
				LogHelper.userInfo("不存在用户:" + GsonUtil.toJsonExpose(form));
				out.print(JsonUtil.loadFalseResult(XcxMiniControllerUtil.FAILED));
			}
			requst.getSession().removeAttribute("newUser");
			return;
		} else if (Constant.BINDUSER.equals(create) && mainUser == null) { // 绑定
			int formLoginType = form.getLoginType();
			int newUserLoginType = newUser.getLoginType();
			if (newUserLoginType == formLoginType) { // 相同类型不能绑定
				out.print(JsonUtil.loadFalseResult("相同类型的账号不能绑定！"));
				return;
			}
			// 判断是不是微信。如果是微信就要填充微信相关信息
			if (formLoginType == Constant.WEIXIN/*
												 * &&
												 * StringUtil.isNullOrEmpty(form
												 * .getWxOpenId())
												 */) {
				WeiXinUser xinUser = WXLoginUtil.getWeiXinUserWithSavePortrait(code);
				if (xinUser == null) {
					out.print(JsonUtil.loadFalseResult(XcxMiniControllerUtil.FAILED));
					return;
				}
				form.setWxOpenId(xinUser.getOpenid());
				form.setWxUnionId(xinUser.getUnionid());
				form.setPortrait(xinUser.getHeadimgurl());
				form.setNickName(xinUser.getNickname());
				form.setWxName(xinUser.getNickname());
				String wxHeadImg = COSManager.getInstance()
						.uploadFile(HttpUtil.getAsInputStream(xinUser.getHeadimgurl()),
								Constant.WXHEADURL + UUID.randomUUID().toString())
						.getUrl();
				form.setWxPic(wxHeadImg);
			} else if (formLoginType == Constant.TAOBAO) {
				form.setTbName(form.getNickName());
				form.setTbPic(form.getPortrait());
			}
			form.setSystem(system);
			requst.getSession().setAttribute("mainUser", form);
			String openid = formLoginType == 1 ? form.getOpenid() : form.getWxUnionId();
			// 获取主账户用户信息
			UserInfo find = userInfoService.getUserByLoginTypeAndOpenId(formLoginType, openid, appid);
			if (find != null) {
				// 主账户不为空就进行绑定操作
				bind(find, newUser);
				userInfoService.update(find);
				outUserInfo(out, remotIP, find, acceptData.getDevice());
				requst.getSession().removeAttribute("newUser");
				requst.getSession().removeAttribute("mainUser");
			} else {
				// 为空的话就返回用户信息
				out.print(JsonUtil.loadTrueResult(3, form));
				return;
			}
		} else {// create=2 ，mainUser != null 创建并绑定！
			bind(mainUser, newUser);
			mainUser = userInfoService.addUser(mainUser, appid);
			outUserInfo(out, remotIP, mainUser, acceptData.getDevice());
			requst.getSession().removeAttribute("newUser");
			requst.getSession().removeAttribute("mainUser");
		}
	}

	/**
	 * 将副账户绑定到主账户上
	 * 
	 * @param mainUser
	 * @param viceUser
	 */
	private void bind(UserInfo mainUser, UserInfo viceUser) {
		int loginType = viceUser.getLoginType();
		if (loginType == Constant.TAOBAO) {
			mainUser.setOpenid(viceUser.getOpenid());
			mainUser.setTbName(viceUser.getNickName());
			mainUser.setTbPic(viceUser.getTbPic());
		} else if (loginType == Constant.WEIXIN) {
			mainUser.setWxName(viceUser.getWxName());
			mainUser.setWxOpenId(viceUser.getWxOpenId());
			mainUser.setWxUnionId(viceUser.getWxUnionId());
			mainUser.setWxPic(viceUser.getWxPic());
		}
	}

	private void outUserInfo(PrintWriter out, String remotIP, UserInfo user, String device) {
		BigDecimal totalmoney = hongBaoService.getTotalHongBaoByUid(user.getId());
		user.setTotalHongBao(totalmoney);
		BigDecimal unOpenmoney = hongBaoService.getUnOpenHongBaoByUid(user.getId());
		BigDecimal canOpenMoney = hongBaoService.getCanOpenHongBaoByUid(user.getId());
		user.setNoOpenHongBao(unOpenmoney);
		user.setCanOpenHongBao(canOpenMoney);
		JSONObject data = new JSONObject();
		data.put("user", GsonUtil.toJsonExpose(user));
		data.put("first", 0);
		out.print(JsonUtil.loadTrueResult(data));
		final UserInfo uuser = user;
		ThreadUtil.run(new Runnable() {
			public void run() {
				LogHelper.userInfo(GsonUtil.toJsonExpose(uuser));
				uuser.setLastLoginIp(remotIP);
				uuser.setLastLoginTime(java.lang.System.currentTimeMillis());
				userInfoService.updateLoginInfo(uuser);
				wxDownService.save(device);
			}
		});
	}

	/**
	 * 
	 * 方法说明: 收藏商品
	 * 
	 * @author mawurui createTime 2018年4月25日 下午4:58:12
	 * @param uid
	 * @param auctionId
	 * @param type
	 * @param out
	 */
	@RequestMapping("collectionGoods")
	public void collectionGoods(long uid, long auctionId, int type, PrintWriter out) {
		CollectionGoodsV2 find = collectionGoodsV2Service.findByUidAndAuctionId(uid, auctionId);
		if (type == 1) {
			if (find != null) {
				out.print(JsonUtil.loadFalseResult(""));
				return;
			}
			try {
				TaoBaoGoodsBrief taoBaoGoodsBrief = redisManager.getTaoBaoGoodsBrief(auctionId);
				collectionGoodsV2Service.addCollection(uid, taoBaoGoodsBrief);
				out.print(JsonUtil.loadTrueResult("收藏成功"));
			} catch (TaobaoGoodsDownException e) {
				out.print(JsonUtil.loadFalseResult(1, "商品已下架"));
			} catch (CollectionGoodsException e1) {
				out.print(JsonUtil.loadFalseResult(e1.getCode(), e1.getMsg()));
			}
		} else {
			if (find == null) {
				out.print(JsonUtil.loadTrueResult("取消收藏成功"));
				return;
			} else {
				try {
					collectionGoodsV2Service.cancelCollectionByAuctionId(uid, auctionId);
					out.print(JsonUtil.loadTrueResult("取消收藏成功"));
				} catch (CollectionGoodsException e) {
					out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg()));
				}
			}
		}
	}

	/**
	 * 
	 * 方法说明: 查看我的收藏列表
	 * 
	 * @author mawurui createTime 2018年4月25日 下午4:38:32
	 * @param uid
	 * @param page
	 * @param out
	 */
	@RequestMapping("collectionGoodsList")
	public void collectionGoodsList(long uid, int page, int pageSize, PrintWriter out) {
		List<CollectionGoodsV2> coList = collectionGoodsV2Service.getCollectionGoodsList(uid, page, pageSize);
		long count = collectionGoodsV2Service.getCollectionGoodsCount(uid);
		JSONObject data = new JSONObject();
		BigDecimal proportion = hongBaoManageService.getFanLiRate();
		List<TaoBaoGoodsBriefExtra> list = new ArrayList<TaoBaoGoodsBriefExtra>();
		coList.parallelStream().forEachOrdered(cg -> {
			TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.convert(cg.getCommonGoods());
			TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief,
					proportion.toString(), "");
			list.add(taoBaoGoodsBriefExtra);
		});
		int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
		data.put("totalPage", totalPage);
		data.put("list", GsonUtil.toJsonExpose(list));
		data.put("count", count);
		out.print(JsonUtil.loadTrueResult(data));
	}

	/**
	 * 
	 * 方法说明: 删除收藏商品
	 * 
	 * @author mawurui createTime 2018年4月25日 下午4:58:39
	 * @param ids
	 * @param uid
	 * @param out
	 */
	@RequestMapping("deleteCollectionGoods")
	public void deleteCollectionGoods(String ids, long uid, PrintWriter out) {
		if (ids != null) {
			Arrays.asList(ids.split(",")).parallelStream().forEach(auctionIdStr -> {
				try {
					collectionGoodsV2Service.cancelCollection(uid, Long.parseLong(auctionIdStr));
				} catch (Exception e) {
					e.printStackTrace();
				}
			});

		}
		out.print(JsonUtil.loadTrueResult("删除成功"));
	}

	/**
	 * 
	 * 方法说明: 清空收藏列表
	 * 
	 * @author mawurui createTime 2018年4月25日 下午4:58:46
	 * @param uid
	 * @param out
	 */
	@RequestMapping("clearConllectionGoods")
	public void clearConllectionGoods(long uid, PrintWriter out) {
		try {
			collectionGoodsV2Service.cancelCollectionByUid(uid);
		} catch (CollectionGoodsException e) {
			e.printStackTrace();
		}
		out.print(JsonUtil.loadTrueResult("删除成功"));
	}

	/**
	 * 
	 * 方法说明: 微信登陆
	 * 
	 * @author mawurui createTime 2018年4月25日 下午5:02:02
	 * @param acceptData
	 * @param out
	 */
	@RequestMapping(value = "isWxDown")
	public void isWxDown(AcceptData acceptData, PrintWriter out) {
		boolean b = wxDownService.isWxDownFirstLogin(acceptData.getDevice());
		JSONObject data = new JSONObject();
		data.put("isFirst", b);
		out.print(JsonUtil.loadTrueResult(data));
	}

	/**
	 * 
	 * 方法说明: 获取商品分享连接
	 * 
	 * @author mawurui createTime 2018年4月25日 下午5:02:09
	 * @param acceptData
	 * @param id
	 * @param out
	 */
	@RequestMapping(value = "getGoodsShareUrl")
	public void getGoodsShareUrl(AcceptData acceptData, long id, PrintWriter out) {
		out.print(JsonUtil.loadTrueResult(Constant.systemCommonConfig.getAppShareInfoUrl() + "?id=" + id));
	}

}