package com.yeshi.fanli.service.manger.order;
|
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.Iterator;
|
import java.util.List;
|
import java.util.Map;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.stereotype.Component;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import com.yeshi.fanli.entity.bus.user.ThreeSale;
|
import com.yeshi.fanli.entity.bus.user.vip.TeamUserLevelStatistic;
|
import com.yeshi.fanli.entity.bus.user.vip.UserLevelEnum;
|
import com.yeshi.fanli.entity.order.CommonOrder;
|
import com.yeshi.fanli.entity.order.dividents.TeamDividentsDebt;
|
import com.yeshi.fanli.entity.order.dividents.TeamDividentsRecord;
|
import com.yeshi.fanli.entity.order.dividents.TeamDividentsSourceOrder;
|
import com.yeshi.fanli.entity.order.dividents.TeamDividentsSourceUser;
|
import com.yeshi.fanli.exception.ParamsException;
|
import com.yeshi.fanli.exception.money.TeamDividentsDebtException;
|
import com.yeshi.fanli.exception.money.TeamEincomeRecordException;
|
import com.yeshi.fanli.exception.money.UserMoneyDetailException;
|
import com.yeshi.fanli.exception.order.dividents.TeamDividentsRecordException;
|
import com.yeshi.fanli.exception.order.dividents.TeamDividentsSourceOrderException;
|
import com.yeshi.fanli.service.inter.money.TeamDividentsDebtService;
|
import com.yeshi.fanli.service.inter.money.UserMoneyService;
|
import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;
|
import com.yeshi.fanli.service.inter.order.dividents.TeamDividentsRecordService;
|
import com.yeshi.fanli.service.inter.order.dividents.TeamDividentsSourceOrderService;
|
import com.yeshi.fanli.service.inter.order.dividents.TeamDividentsSourceUserService;
|
import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;
|
import com.yeshi.fanli.service.inter.user.vip.TeamUserLevelStatisticService;
|
import com.yeshi.fanli.service.manger.money.TeamEincomeManager;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.MoneyBigDecimalUtil;
|
import com.yeshi.fanli.util.TimeUtil;
|
import com.yeshi.fanli.util.factory.order.dividents.TeamDividentsSourceOrderFactory;
|
import com.yeshi.fanli.util.user.UserLevelUtil;
|
|
/**
|
* 团队分红管理
|
* @author Administrator
|
*
|
*/
|
@Component
|
public class TeamDividentsManager {
|
|
@Resource
|
private TeamDividentsSourceOrderService teamDividentsSourceOrderService;
|
|
@Resource
|
private TeamDividentsSourceUserService teamDividentsSourceUserService;
|
|
@Resource
|
private TeamDividentsRecordService teamDividentsRecordService;
|
|
@Resource
|
private ThreeSaleSerivce threeSaleSerivce;
|
|
@Resource
|
private TeamUserLevelStatisticService teamUserLevelStatisticService;
|
|
@Resource
|
private TeamDividentsDebtService teamDividentsDebtService;
|
|
@Resource
|
private UserMoneyService userMoneyService;
|
|
@Resource
|
private HongBaoManageService hongBaoManageService;
|
|
@Resource
|
private TeamEincomeManager teamEincomeManager;
|
|
@Transactional(rollbackFor = Exception.class)
|
public void addDividentsSourceOrder(List<CommonOrder> commonOrderList) throws TeamDividentsSourceOrderException {
|
if (commonOrderList.get(0).getThirdCreateTime().getTime() < Constant.NEW_ORDER_FANLI_RULE_TIME)
|
return;
|
|
UserLevelEnum level = UserLevelUtil.getByOrderRank(commonOrderList.get(0).getUrank());
|
if (level == null)
|
level = UserLevelEnum.daRen;
|
BigDecimal rate = getSourceOrderDividentsRate(level);
|
TeamDividentsSourceOrder order = TeamDividentsSourceOrderFactory.create(commonOrderList, rate);
|
if (order == null)
|
return;
|
try {
|
teamDividentsSourceOrderService.addTeamDividentsSourceOrder(order);
|
} catch (ParamsException e) {
|
throw new TeamDividentsSourceOrderException(101, "参数不完整");
|
}
|
}
|
|
/**
|
* 开始分红
|
* @Title: startDividents
|
* @Description:
|
* @param sourceUid -源用户
|
* void 返回类型
|
* @throws
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
public void startDividents(Long sourceUid) throws ParamsException {
|
String day = TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyy-MM-dd");
|
Date preSendTime = new Date(TimeUtil.convertToTimeTemp(day, "yyyy-MM-dd"));
|
startDividents(sourceUid, preSendTime);
|
}
|
|
// 是否可以分红
|
private boolean isCanDividents(TeamUserLevelStatistic tus) {
|
if (Constant.IS_TEST && tus.getLevel() != UserLevelEnum.daRen && tus.getLevel() != UserLevelEnum.normalVIP)
|
return true;
|
|
if (tus != null && (tus.getLevel() == UserLevelEnum.highVIP || tus.getLevel() == UserLevelEnum.superVIP
|
|| tus.getLevel() == UserLevelEnum.tearcher)) {
|
if (tus.getLevel() == UserLevelEnum.highVIP) {
|
int vipFirstCount = tus.getNormalFirstCount() + tus.getHighFirstCount() + tus.getSuperFirstCount()
|
+ tus.getTearcherFirstCount();
|
if (vipFirstCount >= 3)// 直接粉丝普通会员等级以上的用户>=3
|
return true;
|
} else if (tus.getLevel() == UserLevelEnum.superVIP) {
|
int firstCount = tus.getSuperFirstCount() + tus.getTearcherFirstCount();
|
int secondCount = tus.getNormalSecondCount() + tus.getHighSecondCount() + tus.getSuperSecondCount()
|
+ tus.getTearcherSecondCount();
|
if (firstCount >= 3 && secondCount >= 3) {// 直接粉丝超级会员等级以上的用户>=3
|
// 间接粉丝普通会员以上等级>=3
|
return true;
|
}
|
} else {
|
int firstCount = tus.getSuperFirstCount() + tus.getTearcherFirstCount();
|
int secondCount = tus.getHighSecondCount() + tus.getSuperSecondCount() + tus.getTearcherSecondCount();
|
if (firstCount >= 3 && secondCount >= 3) {// 直接粉丝超级会员等级以上的用户>=3
|
// 间接粉丝高级会员以上等级>=3
|
return true;
|
}
|
}
|
}
|
return false;
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
public void startDividents(Long sourceUid, Date preSendTime) throws ParamsException {
|
String day = TimeUtil.getGernalTime(preSendTime.getTime(), "yyyy-MM-dd");
|
// 查询出可用于分红的用户的总金额
|
long count = teamDividentsSourceOrderService.countCanSendByUidAndPreSendTime(sourceUid, preSendTime);
|
int pageSize = 1000;
|
int page = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
|
List<TeamDividentsSourceOrder> totalList = new ArrayList<>();
|
for (int p = 0; p < page; p++) {
|
List<TeamDividentsSourceOrder> list = teamDividentsSourceOrderService
|
.listCanSendByUidAndPreSendTime(sourceUid, preSendTime, p + 1, pageSize);
|
if (list != null && list.size() > 0)
|
totalList.addAll(list);
|
}
|
|
BigDecimal totalMoney = new BigDecimal(0);
|
|
for (TeamDividentsSourceOrder order : totalList) {
|
TeamDividentsSourceOrder sourceOrder = teamDividentsSourceOrderService
|
.selectByPrimaryKeyForUpdate(order.getId());
|
if (sourceOrder != null && sourceOrder.getState() == TeamDividentsSourceOrder.STATE_CAN_SEND) {
|
totalMoney = totalMoney.add(sourceOrder.getMoney());
|
teamDividentsSourceOrderService.send(sourceOrder.getId());
|
}
|
}
|
|
// 分红金额为0的不参与
|
if (totalMoney.compareTo(new BigDecimal(0)) <= 0)
|
return;
|
|
// 查询出可以参与分红的用户
|
List<ThreeSale> threeSalesList = threeSaleSerivce.getMyBossDeepList(sourceUid);
|
if (threeSalesList == null)
|
return;
|
|
Map<Long, UserLevelEnum> uidLevel = new HashMap<Long, UserLevelEnum>();
|
for (ThreeSale ts : threeSalesList) {
|
if (ts.getBoss() != null) {
|
TeamUserLevelStatistic tus = teamUserLevelStatisticService.selectByUid(ts.getBoss().getId());
|
if (tus == null)
|
teamUserLevelStatisticService.initData(ts.getBoss().getId());
|
tus = teamUserLevelStatisticService.selectByUid(ts.getBoss().getId());
|
|
if (isCanDividents(tus)) {
|
uidLevel.put(tus.getId(), tus.getLevel());
|
}
|
}
|
}
|
|
// 没有参与分红的用户
|
if (uidLevel == null || uidLevel.size() == 0) {
|
return;
|
}
|
|
BigDecimal perDivident = computePerDivident(uidLevel, totalMoney);
|
for (Iterator<Long> its = uidLevel.keySet().iterator(); its.hasNext();) {
|
Long uid = its.next();
|
BigDecimal dividents = computeUserDivident(perDivident, uidLevel.get(uid));
|
// 将资金分配到参与分红的用户
|
TeamDividentsSourceUser teamDividentsSourceUser = new TeamDividentsSourceUser();
|
teamDividentsSourceUser.setDay(day);
|
teamDividentsSourceUser.setMoney(dividents);
|
teamDividentsSourceUser.setSourceUid(sourceUid);
|
teamDividentsSourceUser.setTargetUid(uid);
|
teamDividentsSourceUserService.addTeamDividentsSourceUser(teamDividentsSourceUser);
|
}
|
}
|
|
// 计算平均分红
|
private BigDecimal computePerDivident(Map<Long, UserLevelEnum> uidLevels, BigDecimal totalMoney) {
|
int count = 0;
|
for (Iterator<Long> its = uidLevels.keySet().iterator(); its.hasNext();) {
|
Long uid = its.next();
|
if (uidLevels.get(uid) == UserLevelEnum.highVIP) {
|
count += 1;
|
} else if (uidLevels.get(uid) == UserLevelEnum.superVIP) {
|
count += 2;
|
}
|
}
|
return MoneyBigDecimalUtil.div(totalMoney, new BigDecimal(count));
|
}
|
|
private BigDecimal computeUserDivident(BigDecimal perDivident, UserLevelEnum userLevel) {
|
if (userLevel == UserLevelEnum.highVIP) {
|
return perDivident;
|
} else if (userLevel == UserLevelEnum.superVIP) {
|
return MoneyBigDecimalUtil.mul(perDivident, new BigDecimal(2));
|
} else if (userLevel == UserLevelEnum.tearcher) {
|
return MoneyBigDecimalUtil.mul(perDivident, new BigDecimal(2));
|
}
|
return null;
|
}
|
|
/**
|
* 分红计算是否完成
|
* @Title: isSourceUserComupteFinish
|
* @Description:
|
* @return
|
* boolean 返回类型
|
* @throws
|
*/
|
public boolean isSourceUserComupteFinish(String day) {
|
Date preSendTime = new Date(TimeUtil.convertToTimeTemp(day, "yyyy-MM-dd"));
|
long count = teamDividentsSourceOrderService.countCanSendByUidAndPreSendTime(null, preSendTime);
|
return count == 0;
|
}
|
|
/**
|
* @throws TeamDividentsDebtException
|
* 添加分红记录
|
* @Title: addDividentsRecord
|
* @Description:
|
* @param uid -用户ID
|
* @param money -分红金额
|
* @param day -分红日期
|
* void 返回类型
|
* @throws
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
public void addToTeamEincome(Long uid, Date preSendTime) throws TeamDividentsRecordException,
|
TeamDividentsDebtException, UserMoneyDetailException, ParamsException, TeamEincomeRecordException {
|
String day = TimeUtil.getGernalTime(preSendTime.getTime(), "yyyy-MM-dd");
|
BigDecimal money = teamDividentsSourceUserService.sumMoneyByUidAndDay(uid, day);
|
// 查询需要扣除的资金
|
List<TeamDividentsDebt> list = teamDividentsDebtService.listNeedRepayDebt(uid, preSendTime, 1, 1000);
|
for (TeamDividentsDebt debt : list) {
|
if (money.subtract(debt.getLeftMoney()).compareTo(new BigDecimal(0)) >= 0) {// 还有钱还
|
money = money.subtract(debt.getLeftMoney());
|
teamDividentsDebtService.repayDebt(debt.getId(), debt.getLeftMoney());
|
} else if (money.compareTo(new BigDecimal(0)) > 0) {
|
teamDividentsDebtService.repayDebt(debt.getId(), money);
|
money = new BigDecimal(0);
|
} else// 没有钱还了
|
break;
|
}
|
|
// 统计资金
|
TeamDividentsRecord record = new TeamDividentsRecord();
|
record.setDay(day);
|
record.setMoney(money);
|
record.setState(TeamDividentsRecord.STATE_VALID);
|
record.setUid(uid);
|
teamDividentsRecordService.addTeamDividentsRecord(record);
|
|
// 有分红才显示资金明细
|
if (money.compareTo(new BigDecimal(0)) > 0) {
|
teamEincomeManager.addTeamDividents(uid, preSendTime, money);
|
}
|
}
|
|
/**
|
* @throws TeamDividentsDebtException
|
* 订单维权
|
* @Title: weiQuan
|
* @Description:
|
* @param orderNo
|
* @param tradeId
|
* @param sourceType
|
* void 返回类型
|
* @throws
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
public void weiQuan(String orderNo, int sourceType) throws TeamDividentsDebtException {
|
// 查询订单是否已经分红
|
TeamDividentsSourceOrder sourceOrder = teamDividentsSourceOrderService.selectByOrderNoSourceType(orderNo,
|
sourceType);
|
if (sourceOrder == null)
|
return;
|
if (sourceOrder.getState() == TeamDividentsSourceOrder.STATE_INVALID)
|
return;
|
|
if (sourceOrder.getState() == TeamDividentsSourceOrder.STATE_ALREADY_SEND) {// 已经发送，需要参与分红的人分摊
|
BigDecimal money = sourceOrder.getMoney();
|
// 查询参与这一单分红的人
|
String day = TimeUtil.getGernalTime(sourceOrder.getSendTime().getTime(), "yyyy-MM-dd");
|
if (Constant.IS_TEST)
|
day = TimeUtil.getGernalTime(sourceOrder.getPreSendTime().getTime(), "yyyy-MM-dd");
|
|
List<TeamDividentsSourceUser> list = teamDividentsSourceUserService
|
.listBySourceUidAndDay(sourceOrder.getUid(), day);
|
// 计算每个人的比例
|
BigDecimal total = new BigDecimal(0);
|
for (TeamDividentsSourceUser su : list) {
|
total = total.add(su.getMoney());
|
}
|
|
for (TeamDividentsSourceUser su : list) {
|
BigDecimal debtMoney = MoneyBigDecimalUtil.divUp(money.multiply(su.getMoney()), total);
|
// 需要偿还的资金
|
TeamDividentsDebt debt = new TeamDividentsDebt();
|
debt.setLeftMoney(debtMoney);
|
debt.setOriginMoney(debtMoney);
|
debt.setOrderNo(orderNo);
|
debt.setSourceType(sourceType);
|
debt.setUid(su.getTargetUid());
|
// 加入待偿还记录
|
teamDividentsDebtService.addDebt(debt);
|
}
|
} else if (sourceOrder.getState() == TeamDividentsSourceOrder.STATE_CAN_SEND) {
|
teamDividentsSourceOrderService.invalidOrder(orderNo, sourceType, "订单维权");
|
}
|
}
|
|
/**
|
* 获取源订单需要参与分红的比例
|
* @Title: getSourceOrderDividentsRate
|
* @Description:
|
* @param level
|
* @return
|
* BigDecimal 返回类型
|
* @throws
|
*/
|
public BigDecimal getSourceOrderDividentsRate(UserLevelEnum level) {
|
String rate = hongBaoManageService.get("team_source_order_dividents_" + level.getLevel());
|
return new BigDecimal(rate);
|
}
|
|
}
|
