From 5981b2cae7c20ec9021c8ccbe1a926f35f640210 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 03 一月 2019 17:43:18 +0800
Subject: [PATCH] Merge branch 'dev-hongbao'

---
 fanli/src/main/java/com/yeshi/fanli/service/impl/hongbao/HongBaoV2ServiceImpl.java |  532 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 529 insertions(+), 3 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/hongbao/HongBaoV2ServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/hongbao/HongBaoV2ServiceImpl.java
index cb737e5..634c724 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/hongbao/HongBaoV2ServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/hongbao/HongBaoV2ServiceImpl.java
@@ -1,20 +1,80 @@
 package com.yeshi.fanli.service.impl.hongbao;
 
+import java.math.BigDecimal;
+import java.util.Calendar;
+import java.util.Collections;
+import java.util.Comparator;
+import java.util.Date;
+import java.util.List;
+
 import javax.annotation.Resource;
 
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import com.yeshi.fanli.dao.mybatis.HongBaoV2Mapper;
+import com.yeshi.fanli.dao.mybatis.hongbao.HongBaoMapper;
+import com.yeshi.fanli.dao.mybatis.order.CommonOrderGoodsMapper;
+import com.yeshi.fanli.dao.mybatis.order.CommonOrderMapper;
+import com.yeshi.fanli.dao.mybatis.order.HongBaoOrderMapper;
+import com.yeshi.fanli.dao.mybatis.order.OrderItemMapper;
+import com.yeshi.fanli.dao.mybatis.order.OrderMapper;
+import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoOrderMapper;
+import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoWeiQuanOrderMapper;
+import com.yeshi.fanli.entity.bus.user.HongBao;
 import com.yeshi.fanli.entity.bus.user.HongBaoV2;
+import com.yeshi.fanli.entity.bus.user.UserInfo;
+import com.yeshi.fanli.entity.order.CommonOrder;
+import com.yeshi.fanli.entity.order.CommonOrderGoods;
+import com.yeshi.fanli.entity.order.HongBaoOrder;
+import com.yeshi.fanli.entity.taobao.TaoBaoOrder;
+import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder;
+import com.yeshi.fanli.exception.HongBaoException;
+import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;
 import com.yeshi.fanli.service.inter.hongbao.HongBaoV2Service;
-
+import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce;
+import com.yeshi.fanli.service.inter.order.CommonOrderService;
+import com.yeshi.fanli.service.inter.user.UserInfoService;
+import com.yeshi.fanli.util.Constant;
+import com.yeshi.fanli.util.MoneyBigDecimalUtil;
+import com.yeshi.fanli.util.TimeUtil;
+import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil;
 
 @Service
 public class HongBaoV2ServiceImpl implements HongBaoV2Service {
-	
+
 	@Resource
 	private HongBaoV2Mapper hongBaoV2Mapper;
 
+	@Resource
+	private HongBaoMapper hongBaoMapper;
+
+	@Resource
+	private TaoBaoOrderMapper taoBaoOrderMapper;
+
+	@Resource
+	private OrderItemMapper orderItemMapper;
+
+	@Resource
+	private CommonOrderMapper commonOrderMapper;
+
+	@Resource
+	private CommonOrderGoodsMapper commonOrderGoodsMapper;
+
+	@Resource
+	private HongBaoOrderMapper hongBaoOrderMapper;
+
+	@Resource
+	private OrderMapper orderMapper;
+
+	@Resource
+	private CommonOrderService commonOrderService;
+
+	@Resource
+	private UserInfoService userInfoService;
+
+	@Resource
+	private TaoBaoWeiQuanOrderMapper taoBaoWeiQuanOrderMapper;
 
 	@Override
 	public int insert(HongBaoV2 record) {
@@ -45,5 +105,471 @@
 	public HongBaoV2 selectByPrimaryKey(Long id) {
 		return hongBaoV2Mapper.selectByPrimaryKey(id);
 	}
-	
+
+	private HongBaoV2 getHongBaoV2(HongBao hb) {
+		int type = hb.getType().intValue();
+		HongBaoV2 v2 = new HongBaoV2(hb.getId());
+		v2.setCreateTime(new Date(hb.getCreatetime()));
+		if (hb.getGetTime() == null || hb.getGetTime() == 0)
+			v2.setGetTime(null);
+		else
+			v2.setGetTime(new Date(hb.getGetTime()));
+
+		v2.setMoney(hb.getMoney());
+		if (hb.getParent() != null)
+			v2.setParent(new HongBaoV2(hb.getParent().getId()));
+
+		if (hb.getPreGettime() == null || hb.getPreGettime() == 0)
+			v2.setPreGetTime(null);
+		else
+			v2.setPreGetTime(new Date(hb.getPreGettime()));
+
+		v2.setState(hb.getState());
+		v2.setType(type);
+		v2.setUpdateTime(new Date(hb.getCreatetime()));
+		v2.setUrank(hb.getUrank());
+		v2.setUserInfo(hb.getUserInfo());
+		v2.setVersion(hb.getVersion());
+		return v2;
+	}
+
+	@Transactional
+	@Override
+	public void convert(HongBao hb) {
+		if (hb == null || hb.getParent() != null)
+			return;
+
+		int type = hb.getType().intValue();
+		if (type == HongBao.TYPE_TAOBAO || type == HongBao.TYPE_SHARE_GOODS) {// 鑷喘涓庡垎浜禋闇�瑕佹煡璇㈠嚭鎵�鏈夌殑璁㈠崟
+			// 灞炰簬杩斿埄璁㈠崟
+			String orderId = "";
+			if (hb.getOrder() != null) {
+				orderId = hb.getOrder().getOrderId();
+				// 鏌ヨ鍚屼竴璁㈠崟鍙风殑闈炲瓙绾㈠寘
+			} else
+				orderId = hb.getOrderId();
+
+			int count = commonOrderMapper.countByOrderNOAndOrderType(orderId, Constant.SOURCE_TYPE_TAOBAO);
+
+			// 宸茬粡鎻掑叆璁㈠崟
+			if (count > 0)
+				return;
+
+			//
+
+			if (hb.getVersion() == 1) {// 寰堣�佺増鏈殑澶勭悊鏂瑰紡,宸瞙ongbao涓轰富
+				if (hongBaoV2Mapper.selectByPrimaryKey(hb.getId()) != null)
+					return;
+				HongBaoV2 hongBaoV2 = getHongBaoV2(hb);
+				hongBaoV2.setBeizhu("璁㈠崟鍙�:" + orderId);
+				hongBaoV2Mapper.insert(hongBaoV2);
+
+				if (hb.getHasChild())// 瀛樺湪瀛愮孩鍖�
+				{
+					List<HongBao> children = hongBaoMapper.selectChildHongBaoByPid(hb.getId());
+					if (children != null)
+						for (HongBao hongBao : children) {
+							HongBaoV2 child = getHongBaoV2(hongBao);
+							hongBaoV2Mapper.insert(child);
+						}
+				}
+
+			} else {// 鏂扮増鏈鐞嗘柟寮�
+
+				List<HongBao> list = hongBaoMapper.selectByOrderId(orderId);
+
+				if (list.size() == 0)
+					list = hongBaoMapper.selectByOid(hb.getOrder().getId());
+				if (list != null)
+					// 鍒犻櫎瀛愮孩鍖�
+					for (int i = 0; i < list.size(); i++) {
+					if (list.get(i).getParent() != null) {
+					list.remove(i);
+					i--;
+					}
+
+					}
+
+				if (list.size() <= 0)
+					return;
+				List<TaoBaoOrder> orderList = taoBaoOrderMapper.selectTaoBaoOrderByOrderId(orderId);
+
+				if (orderList == null || orderList.size() < list.size()) {
+					System.out.println("绾㈠寘鏁颁笌璁㈠崟鏁颁笉瀵瑰簲");
+					return;
+				}
+
+				// 鍔犲叆鎺掑簭鍊�
+				for (int i = 0; i < orderList.size(); i++) {
+					orderList.get(i).setOrderBy(i + 1);
+				}
+
+				// 鎸夌収auctionId,payMoney鎺掑簭
+				Comparator<HongBao> cm = new Comparator<HongBao>() {
+
+					@Override
+					public int compare(HongBao o1, HongBao o2) {
+						return o1.getAuctionId() == o2.getAuctionId()
+								? (o1.getPayMoney().subtract(o2.getPayMoney()).compareTo(new BigDecimal(0)))
+								: (int) (o1.getAuctionId() - o2.getAuctionId());
+					}
+				};
+
+				Collections.sort(list, cm);
+
+				Comparator<TaoBaoOrder> cmOrder = new Comparator<TaoBaoOrder>() {
+
+					@Override
+					public int compare(TaoBaoOrder o1, TaoBaoOrder o2) {
+						return o1.getAuctionId() == o2.getAuctionId()
+								? (o1.getPayment().subtract(o2.getPayment()).compareTo(new BigDecimal(0)))
+								: (int) (o1.getAuctionId() - o2.getAuctionId());
+					}
+				};
+
+				Collections.sort(orderList, cmOrder);
+
+				for (int i = 0; i < list.size(); i++) {
+					CommonOrder commonOrder = TaoBaoOrderUtil.convert(orderList.get(i));
+					CommonOrderGoods goods = new CommonOrderGoods();
+					goods.setGoodsId(orderList.get(i).getAuctionId() + "");
+					goods.setGoodsType(Constant.SOURCE_TYPE_TAOBAO);
+					// 鍟嗗搧鏄惁宸茬粡鎻掑叆
+					List<CommonOrderGoods> commonGoodsList = commonOrderGoodsMapper
+							.listByGoodsIdAndGoodsType(goods.getGoodsId(), goods.getGoodsType());
+					if (commonGoodsList.size() <= 0)// 涓嶅瓨鍦ㄥ氨鎻掑叆鍟嗗搧
+						commonOrderGoodsMapper.insertSelective(goods);
+					else
+						goods.setId(commonGoodsList.get(commonGoodsList.size() - 1).getId());
+					commonOrder.setCommonOrderGoods(goods);
+
+					commonOrder.setUserInfo(list.get(i).getUserInfo());
+					commonOrder.setCreateTime(new Date(list.get(i).getCreatetime()));
+
+					// TODO 缁存潈鍒ゆ柇
+					List<TaoBaoWeiQuanOrder> weiQuanList = taoBaoWeiQuanOrderMapper.selectListByOrderIdAndState(orderId,
+							"缁存潈鎴愬姛");
+					if (weiQuanList != null && weiQuanList.size() > 0)
+						commonOrder.setState(CommonOrder.STATE_WQ);
+
+					commonOrderMapper.insertSelective(commonOrder);
+
+					// 鎻掑叆绾㈠寘
+					HongBaoV2 hongBaoV2 = getHongBaoV2(list.get(i));
+					hongBaoV2.setId(list.get(i).getId());
+					hongBaoV2Mapper.insert(hongBaoV2);
+
+					HongBaoOrder ho = new HongBaoOrder();
+					ho.setCommonOrder(commonOrder);
+					ho.setCreateTime(new Date());
+					ho.setHongBaoV2(hongBaoV2);
+					hongBaoOrderMapper.insertSelective(ho);
+
+					if (list.get(i).getHasChild())// 瀛樺湪瀛愮孩鍖�
+					{
+						List<HongBao> children = hongBaoMapper.selectChildHongBaoByPid(list.get(i).getId());
+						if (children != null)
+							for (HongBao hongBao : children) {
+								HongBaoV2 child = getHongBaoV2(hongBao);
+								hongBaoV2Mapper.insert(child);
+							}
+					}
+				}
+			}
+
+		} else {// 鐩存帴鎻掑叆
+
+			if (type != HongBao.TYPE_ERJI && type != HongBao.TYPE_YIJI && type != HongBao.TYPE_SHARE_YIJI
+					&& type != HongBao.TYPE_SHARE_ERJI) {
+				if (hongBaoV2Mapper.selectByPrimaryKey(hb.getId()) == null)
+					hongBaoV2Mapper.insert(getHongBaoV2(hb));
+			}
+
+		}
+
+	}
+
+	@Resource
+	private HongBaoManageService hongBaoManageService;
+
+	@Resource
+	private ThreeSaleSerivce threeSaleSerivce;
+
+	@Transactional
+	@Override
+	public void addHongBao(CommonOrder commonOrder, int type) throws HongBaoException {
+		if (commonOrder == null || commonOrder.getId() == null || commonOrder.getUserInfo() == null)
+			throw new HongBaoException(1, "璁㈠崟淇℃伅涓嶅畬鏁�");
+		HongBaoOrder hongBaoOrder = hongBaoOrderMapper.selectByCommonOrderId(commonOrder.getId());
+		if (hongBaoOrder == null) {
+			saveHongBao(commonOrder, type);
+		} else {
+			updateHongBao(hongBaoOrder, commonOrder, type);
+		}
+
+	}
+
+	@Transactional
+	private void updateHongBao(HongBaoOrder hongBaoOrder, CommonOrder commonOrder, int type) throws HongBaoException {
+		System.out.println(commonOrder.getOrderNo());
+		HongBaoV2 oldHongBao = hongBaoV2Mapper.selectByPrimaryKey(hongBaoOrder.getHongBaoV2().getId());
+		if (oldHongBao == null)
+			throw new HongBaoException(10, "绾㈠寘瀵硅薄涓嶅瓨鍦�");
+		// 宸茬粡澶辨晥鎴栬�呭凡缁忛鍙栫殑绾㈠寘涓嶅仛澶勭悊
+		if (oldHongBao.getState() == HongBaoV2.STATE_SHIXIAO || oldHongBao.getState() == HongBaoV2.STATE_YILINGQU)
+			return;
+
+		if (type == HongBaoV2.TYPE_ZIGOU) {// 鑾峰彇鑷喘鐨勮繑鍒╂瘮渚�
+			BigDecimal fanliRate = hongBaoManageService.getFanLiRate(commonOrder.getCreateTime().getTime());
+			HongBaoV2 hongBao = new HongBaoV2(hongBaoOrder.getHongBaoV2().getId());
+			hongBao.setUpdateTime(new Date());
+			// 鏇存敼鐘舵�佷笌璧勯噾
+			if (commonOrder.getState() == CommonOrder.STATE_FK) {
+				hongBao.setState(HongBaoV2.STATE_BUKELINGQU);
+				hongBao.setMoney(
+						MoneyBigDecimalUtil.mul(commonOrder.getEstimate(), fanliRate.divide(new BigDecimal(100))));
+			} else if (commonOrder.getState() == CommonOrder.STATE_JS) {
+				hongBao.setState(HongBaoV2.STATE_KELINGQU);
+				hongBao.setMoney(
+						MoneyBigDecimalUtil.mul(commonOrder.geteIncome(), fanliRate.divide(new BigDecimal(100))));
+				hongBao.setPreGetTime(new Date(commonOrder.getSettleTime().getTime() + 1000 * 60 * 60 * 24 * 15L));
+			} else if (commonOrder.getState() == CommonOrder.STATE_SX) {
+				hongBao.setState(HongBaoV2.STATE_SHIXIAO);
+				hongBao.setMoney(new BigDecimal(0));
+			}
+			hongBaoV2Mapper.updateByPrimaryKeySelective(hongBao);
+
+			// 鑾峰彇瀛愮孩鍖�
+			List<HongBaoV2> children = hongBaoV2Mapper.listChildrenById(hongBao.getId());
+			if (children != null)
+				for (HongBaoV2 child : children) {
+					HongBaoV2 childUpdate = new HongBaoV2(child.getId());
+					childUpdate.setState(hongBao.getState());
+					childUpdate.setUpdateTime(new Date());
+					BigDecimal rate = null;
+					if (child.getType() == HongBaoV2.TYPE_YIJI) {// 涓�绾у垎浜禋
+						rate = hongBaoManageService.getFirstInviteRate(child.getUrank(),
+								commonOrder.getCreateTime().getTime());
+					} else if (child.getType() == HongBaoV2.TYPE_ERJI) {// 浜岀骇鍒嗕韩璧�
+						rate = hongBaoManageService.getSecondInviteRate(child.getUrank(),
+								commonOrder.getCreateTime().getTime());
+					}
+
+					// 浠ュ疄闄呮敹鍏ヤ负鍑嗚绠楅浼版敹鐩�
+					if (hongBao.getState() == HongBaoV2.STATE_KELINGQU) {
+						childUpdate.setMoney(
+								MoneyBigDecimalUtil.mul(commonOrder.geteIncome(), rate.divide(new BigDecimal(100))));
+						Calendar calendar = Calendar.getInstance();
+						calendar.setTime(commonOrder.getSettleTime());
+						calendar.add(Calendar.MONTH, 1);
+						childUpdate.setPreGetTime(new Date(TimeUtil.convertToTimeTemp(
+								calendar.get(Calendar.YEAR) + "-" + (calendar.get(Calendar.MONTH) + 1) + "-25",
+								"yyyy-M-dd")));
+					} else if (hongBao.getState() == HongBaoV2.STATE_BUKELINGQU) {
+						childUpdate.setMoney(
+								MoneyBigDecimalUtil.mul(commonOrder.getEstimate(), rate.divide(new BigDecimal(100))));
+					}
+					hongBaoV2Mapper.updateByPrimaryKeySelective(childUpdate);
+				}
+
+		} else if (type == HongBaoV2.TYPE_SHARE_GOODS) {
+			BigDecimal fanliRate = hongBaoManageService.getFanLiRate(commonOrder.getCreateTime().getTime());
+			HongBaoV2 hongBao = new HongBaoV2(hongBaoOrder.getHongBaoV2().getId());
+			hongBao.setUpdateTime(new Date());
+			// 鏇存敼鐘舵�佷笌璧勯噾
+			if (commonOrder.getState() == CommonOrder.STATE_FK) {
+				hongBao.setState(HongBaoV2.STATE_BUKELINGQU);
+				hongBao.setMoney(
+						MoneyBigDecimalUtil.mul(commonOrder.getEstimate(), fanliRate.divide(new BigDecimal(100))));
+			} else if (commonOrder.getState() == CommonOrder.STATE_JS) {
+				hongBao.setState(HongBaoV2.STATE_KELINGQU);
+				hongBao.setMoney(
+						MoneyBigDecimalUtil.mul(commonOrder.geteIncome(), fanliRate.divide(new BigDecimal(100))));
+				Calendar calendar = Calendar.getInstance();
+				calendar.setTime(commonOrder.getSettleTime());
+				calendar.add(Calendar.MONTH, 1);
+				hongBao.setPreGetTime(new Date(TimeUtil.convertToTimeTemp(
+						calendar.get(Calendar.YEAR) + "-" + (calendar.get(Calendar.MONTH) + 1) + "-25", "yyyy-M-dd")));
+			} else if (commonOrder.getState() == CommonOrder.STATE_SX) {
+				hongBao.setState(HongBaoV2.STATE_SHIXIAO);
+				hongBao.setMoney(new BigDecimal(0));
+			}
+			hongBaoV2Mapper.updateByPrimaryKeySelective(hongBao);
+
+			// 鑾峰彇瀛愮孩鍖�
+			List<HongBaoV2> children = hongBaoV2Mapper.listChildrenById(hongBao.getId());
+			if (children != null)
+				for (HongBaoV2 child : children) {
+					HongBaoV2 childUpdate = new HongBaoV2(child.getId());
+					// 缁熶竴璁剧疆鐘舵��
+					childUpdate.setState(hongBao.getState());
+					childUpdate.setUpdateTime(new Date());
+					BigDecimal rate = null;
+					if (child.getType() == HongBaoV2.TYPE_SHARE_YIJI) {// 涓�绾у垎浜禋
+						rate = hongBaoManageService.getFirstShareRate(child.getUrank(),
+								commonOrder.getCreateTime().getTime());
+					} else if (child.getType() == HongBaoV2.TYPE_SHARE_ERJI) {// 浜岀骇鍒嗕韩璧�
+						rate = hongBaoManageService.getSecondShareRate(child.getUrank(),
+								commonOrder.getCreateTime().getTime());
+					}
+
+					// 浠ュ疄闄呮敹鍏ヤ负鍑嗚绠楅浼版敹鐩�
+					if (CommonOrder.STATE_JS == commonOrder.getState()) {
+						childUpdate.setMoney(
+								MoneyBigDecimalUtil.mul(commonOrder.geteIncome(), rate.divide(new BigDecimal(100))));
+						Calendar calendar = Calendar.getInstance();
+						calendar.setTime(commonOrder.getSettleTime());
+						calendar.add(Calendar.MONTH, 1);
+						childUpdate.setPreGetTime(new Date(TimeUtil.convertToTimeTemp(
+								calendar.get(Calendar.YEAR) + "-" + (calendar.get(Calendar.MONTH) + 1) + "-25",
+								"yyyy-M-dd")));
+					} else if (CommonOrder.STATE_FK == commonOrder.getState()) {
+						if (commonOrder.getOrderNo().equalsIgnoreCase("314134177659155087"))
+							System.out.println("");
+
+						childUpdate.setMoney(
+								MoneyBigDecimalUtil.mul(commonOrder.getEstimate(), rate.divide(new BigDecimal(100))));
+					}
+					hongBaoV2Mapper.updateByPrimaryKeySelective(childUpdate);
+				}
+		} else
+			throw new HongBaoException(2, "type閿欒");
+	}
+
+	@Transactional
+	private void saveHongBao(CommonOrder commonOrder, int type) throws HongBaoException {
+		if (type == HongBaoV2.TYPE_ZIGOU) {// 鑾峰彇鑷喘鐨勮繑鍒╂瘮渚�
+			BigDecimal fanliRate = hongBaoManageService.getFanLiRate(commonOrder.getCreateTime().getTime());
+			HongBaoV2 hongBao = new HongBaoV2();
+			hongBao.setUserInfo(commonOrder.getUserInfo());
+			hongBao.setCreateTime(new Date());
+			hongBao.setType(HongBaoV2.TYPE_ZIGOU);
+			hongBao.setVersion(2);
+			if (commonOrder.getState() == CommonOrder.STATE_FK) {
+				hongBao.setState(HongBaoV2.STATE_BUKELINGQU);
+				hongBao.setMoney(
+						MoneyBigDecimalUtil.mul(commonOrder.getEstimate(), fanliRate.divide(new BigDecimal(100))));
+			} else if (commonOrder.getState() == CommonOrder.STATE_JS) {
+				hongBao.setState(HongBaoV2.STATE_KELINGQU);
+				hongBao.setMoney(
+						MoneyBigDecimalUtil.mul(commonOrder.geteIncome(), fanliRate.divide(new BigDecimal(100))));
+				hongBao.setPreGetTime(new Date(commonOrder.getSettleTime().getTime() + 1000 * 60 * 60 * 24 * 15L));
+			} else if (commonOrder.getState() == CommonOrder.STATE_SX) {
+				hongBao.setState(HongBaoV2.STATE_SHIXIAO);
+				hongBao.setMoney(new BigDecimal(0));
+			} else {
+				throw new HongBaoException(3, "缁存潈璁㈠崟涓嶈兘鍒涘缓绾㈠寘");
+			}
+			UserInfo user = userInfoService.getUserById(commonOrder.getUserInfo().getId());
+			hongBao.setUrank(user.getRank());
+			hongBaoV2Mapper.insertSelective(hongBao);
+			// 娣诲姞绾㈠寘涓庤鍗曠殑鏄犲皠
+			HongBaoOrder hongBaoOrder = new HongBaoOrder();
+			hongBaoOrder.setCommonOrder(commonOrder);
+			hongBaoOrder.setCreateTime(new Date());
+			hongBaoOrder.setHongBaoV2(hongBao);
+			hongBaoOrderMapper.insertSelective(hongBaoOrder);
+
+			UserInfo boss = threeSaleSerivce.getBoss(user.getId());
+			if (boss != null && hongBao.getState() != HongBaoV2.STATE_SHIXIAO) {// 1绾OSS瀛樺湪涓旂孩鍖呮湭澶辨晥
+
+				// 鎻掑叆涓�绾у瓙绾㈠寘
+				BigDecimal firstRate = hongBaoManageService
+						.getFirstInviteRate(boss.getRank() == null ? 0 : boss.getRank());
+				if (firstRate.compareTo(new BigDecimal(0)) <= 0)
+					return;
+				HongBaoV2 firstHongbao = new HongBaoV2();
+				firstHongbao.setUserInfo(boss);
+				firstHongbao.setUrank(boss.getRank());
+				firstHongbao.setParent(hongBao);
+				firstHongbao.setCreateTime(new Date());
+				firstHongbao.setType(HongBaoV2.TYPE_YIJI);
+				firstHongbao.setVersion(2);
+				firstHongbao.setState(hongBao.getState());
+
+				if (hongBao.getState() == HongBaoV2.STATE_KELINGQU) {
+					firstHongbao.setMoney(
+							MoneyBigDecimalUtil.mul(commonOrder.geteIncome(), firstRate.divide(new BigDecimal(100))));
+					Calendar calendar = Calendar.getInstance();
+					calendar.setTime(commonOrder.getSettleTime());
+					calendar.add(Calendar.MONTH, 1);
+					firstHongbao.setPreGetTime(new Date(TimeUtil.convertToTimeTemp(
+							calendar.get(Calendar.YEAR) + "-" + (calendar.get(Calendar.MONTH) + 1) + "-25",
+							"yyyy-M-dd")));
+				} else if (hongBao.getState() == HongBaoV2.STATE_BUKELINGQU) {
+					firstHongbao.setMoney(
+							MoneyBigDecimalUtil.mul(commonOrder.getEstimate(), firstRate.divide(new BigDecimal(100))));
+				}
+				hongBaoV2Mapper.insertSelective(firstHongbao);
+
+				// 鎻掑叆浜岀骇瀛愮孩鍖�
+				boss = threeSaleSerivce.getBoss(boss.getId());
+				if (boss != null) {// 浜岀骇BOSS瀛樺湪
+					BigDecimal secondRate = hongBaoManageService
+							.getSecondInviteRate(boss.getRank() == null ? 0 : boss.getRank());
+					if (secondRate.compareTo(new BigDecimal(0)) <= 0)
+						return;
+					HongBaoV2 secondHongbao = new HongBaoV2();
+					secondHongbao.setUserInfo(boss);
+					secondHongbao.setUrank(boss.getRank());
+					secondHongbao.setParent(hongBao);
+					secondHongbao.setCreateTime(new Date());
+					secondHongbao.setType(HongBaoV2.TYPE_ERJI);
+					secondHongbao.setVersion(2);
+					secondHongbao.setState(hongBao.getState());
+					if (hongBao.getState() == HongBaoV2.STATE_KELINGQU) {
+						firstHongbao.setMoney(MoneyBigDecimalUtil.mul(commonOrder.geteIncome(),
+								secondRate.divide(new BigDecimal(100))));
+						Calendar calendar = Calendar.getInstance();
+						calendar.setTime(commonOrder.getSettleTime());
+						calendar.add(Calendar.MONTH, 1);
+						secondHongbao.setPreGetTime(new Date(TimeUtil.convertToTimeTemp(
+								calendar.get(Calendar.YEAR) + "-" + (calendar.get(Calendar.MONTH) + 1) + "-25",
+								"yyyy-M-dd")));
+					} else if (hongBao.getState() == HongBaoV2.STATE_BUKELINGQU) {
+						secondHongbao.setMoney(MoneyBigDecimalUtil.mul(commonOrder.getEstimate(),
+								secondRate.divide(new BigDecimal(100))));
+					}
+					hongBaoV2Mapper.insertSelective(secondHongbao);
+				}
+
+			}
+
+		} else if (type == HongBaoV2.TYPE_SHARE_GOODS) {
+			// 鍒嗕韩璧氫笉鍔犲叆澶辨晥鐨勮鍗�
+			if (commonOrder.getState() == CommonOrder.STATE_SX || commonOrder.getState() == CommonOrder.STATE_WQ)
+				return;
+			// 鍒嗕韩璧�
+			BigDecimal shareRate = hongBaoManageService.getShareRate(commonOrder.getCreateTime().getTime());
+			HongBaoV2 hongBao = new HongBaoV2();
+			hongBao.setCreateTime(new Date());
+			hongBao.setType(HongBaoV2.TYPE_SHARE_GOODS);
+			hongBao.setVersion(2);
+			if (commonOrder.getState() == CommonOrder.STATE_FK) {
+				hongBao.setState(HongBaoV2.STATE_BUKELINGQU);
+				hongBao.setMoney(
+						MoneyBigDecimalUtil.mul(commonOrder.getEstimate(), shareRate.divide(new BigDecimal(100))));
+			} else if (commonOrder.getState() == CommonOrder.STATE_JS) {
+				hongBao.setState(HongBaoV2.STATE_KELINGQU);
+				hongBao.setMoney(
+						MoneyBigDecimalUtil.mul(commonOrder.geteIncome(), shareRate.divide(new BigDecimal(100))));
+				Calendar calendar = Calendar.getInstance();
+				calendar.setTime(commonOrder.getSettleTime());
+				calendar.add(Calendar.MONTH, 1);
+				hongBao.setPreGetTime(new Date(TimeUtil.convertToTimeTemp(
+						calendar.get(Calendar.YEAR) + "-" + (calendar.get(Calendar.MONTH) + 1) + "-25", "yyyy-M-dd")));
+			}
+			UserInfo user = userInfoService.getUserById(commonOrder.getUserInfo().getId());
+			hongBao.setUrank(user.getRank());
+			hongBao.setUserInfo(user);
+			hongBaoV2Mapper.insertSelective(hongBao);
+			// 鎻掑叆绾㈠寘涓庤鍗曟槧灏�
+			HongBaoOrder hongBaoOrder = new HongBaoOrder();
+			hongBaoOrder.setCommonOrder(commonOrder);
+			hongBaoOrder.setCreateTime(new Date());
+			hongBaoOrder.setHongBaoV2(hongBao);
+			hongBaoOrderMapper.insertSelective(hongBaoOrder);
+		} else
+			throw new HongBaoException(2, "type閿欒");
+	}
 }

--
Gitblit v1.8.0