| | |
|---|
| | | package com.yeshi.fanli.service.impl.money;
|
|---|
| | |
|
|---|
| | | import java.math.BigDecimal;
|
|---|
| | | 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.AlipayAccountValidNormalHistoryMapper;
|
|---|
| | | import com.yeshi.fanli.dao.mybatis.money.UserMoneyDebtMapper;
|
|---|
| | | import com.yeshi.fanli.dao.mybatis.money.UserMoneyDebtReturnHistoryMapper;
|
|---|
| | | import com.yeshi.fanli.entity.bus.user.AlipayAccountValidNormalHistory;
|
|---|
| | | import com.yeshi.fanli.entity.bus.user.HongBaoV2;
|
|---|
| | | import com.yeshi.fanli.entity.money.UserMoneyDebt;
|
|---|
| | | import com.yeshi.fanli.entity.money.UserMoneyDebt.UserMoneyDebtTypeEnum;
|
|---|
| | | import com.yeshi.fanli.entity.money.UserMoneyDebtReturnHistory;
|
|---|
| | | import com.yeshi.fanli.entity.money.UserMoneyDetail;
|
|---|
| | | import com.yeshi.fanli.entity.order.CommonOrder;
|
|---|
| | | import com.yeshi.fanli.entity.order.HongBaoOrder;
|
|---|
| | | import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanDrawBack;
|
|---|
| | | import com.yeshi.fanli.exception.money.UserMoneyDebtException;
|
|---|
| | | import com.yeshi.fanli.exception.money.UserMoneyDetailException;
|
|---|
| | | import com.yeshi.fanli.log.LogHelper;
|
|---|
| | | import com.yeshi.fanli.service.inter.money.UserMoneyDebtService;
|
|---|
| | | import com.yeshi.fanli.service.inter.money.UserMoneyService;
|
|---|
| | | import com.yeshi.fanli.service.inter.money.msg.UserMoneyMsgNotificationService;
|
|---|
| | | import com.yeshi.fanli.service.inter.money.tb.TaoBaoWeiQuanDrawBackService;
|
|---|
| | | import com.yeshi.fanli.service.inter.order.CommonOrderService;
|
|---|
| | | import com.yeshi.fanli.service.inter.order.HongBaoOrderService;
|
|---|
| | | import com.yeshi.fanli.service.inter.order.HongBaoV2Service;
|
|---|
| | | import com.yeshi.fanli.service.inter.order.tb.TaoBaoOrderService;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.UserInfoService;
|
|---|
| | | import com.yeshi.fanli.util.Constant;
|
|---|
| | | import com.yeshi.fanli.util.factory.UserMoneyDetailFactory;
|
|---|
| | |
|
|---|
| | | @Service
|
|---|
| | | public class UserMoneyDebtServiceImpl implements UserMoneyDebtService {
|
|---|
| | |
|---|
| | | @Resource
|
|---|
| | | private UserMoneyDebtMapper userMoneyDebtMapper;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private UserMoneyDebtReturnHistoryMapper userMoneyDebtReturnHistoryMapper;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private TaoBaoWeiQuanDrawBackService taoBaoWeiQuanDrawBackService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private TaoBaoOrderService taoBaoOrderService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private HongBaoV2Service hongBaoV2Service;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private HongBaoOrderService hongBaoOrderService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private UserMoneyService userMoneyService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private UserMoneyMsgNotificationService userMoneyMsgNotificationService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private UserInfoService userInfoService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private AlipayAccountValidNormalHistoryMapper alipayAccountValidNormalHistoryMapper;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private CommonOrderService commonOrderService;
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public void addUserMoneyDebt(UserMoneyDebt debt) throws UserMoneyDebtException {
|
|---|
| | | if (debt == null)
|
|---|
| | | return;
|
|---|
| | |
|
|---|
| | | if (debt.getType() == UserMoneyDebtTypeEnum.hongBao) {
|
|---|
| | | if (debt.getType() == UserMoneyDebtTypeEnum.order) {
|
|---|
| | | if (debt.getSourceId() == null)
|
|---|
| | | throw new UserMoneyDebtException(1, "sourceId为空");
|
|---|
| | | if (debt.getUid() == null || debt.getOriginMoney() == null)
|
|---|
| | |
|---|
| | | if (debt.getCreateTime() == null)
|
|---|
| | | debt.setCreateTime(new Date());
|
|---|
| | |
|
|---|
| | | UserMoneyDebt old = userMoneyDebtMapper.selectByUidAndSourceId(debt.getUid(), debt.getSourceId());
|
|---|
| | | UserMoneyDebt old = userMoneyDebtMapper.selectByUidAndTypeAndSourceId(debt.getUid(), debt.getType(),
|
|---|
| | | debt.getSourceId());
|
|---|
| | | if (old != null) {
|
|---|
| | | throw new UserMoneyDebtException(3, "对应用户的红包已经存在");
|
|---|
| | | throw new UserMoneyDebtException(3, "对应售后已经存在");
|
|---|
| | | }
|
|---|
| | | userMoneyDebtMapper.insertSelective(debt);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public UserMoneyDebt selectByTypeAndSourceId(UserMoneyDebtTypeEnum type, Long sourceId) {
|
|---|
| | |
|
|---|
| | | return userMoneyDebtMapper.selectByTypeAndSourceId(type, sourceId);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Transactional(rollbackFor = Exception.class)
|
|---|
| | | @Override
|
|---|
| | | public void repayDebt(UserMoneyDebt debt, BigDecimal money) throws UserMoneyDebtException {
|
|---|
| | | if (debt == null || debt.getId() == null)
|
|---|
| | | throw new UserMoneyDebtException(1, "参数不完整");
|
|---|
| | |
|
|---|
| | | if (money == null || money.compareTo(new BigDecimal(0)) <= 0)
|
|---|
| | | throw new UserMoneyDebtException(2, "偿还资金需大于0");
|
|---|
| | |
|
|---|
| | | UserMoneyDebt old = userMoneyDebtMapper.selectByPrimaryKey(debt.getId());
|
|---|
| | | if (old == null)
|
|---|
| | | throw new UserMoneyDebtException(3, "借贷关系不存在");
|
|---|
| | |
|
|---|
| | | if (old.getUid().longValue() != debt.getUid())
|
|---|
| | | throw new UserMoneyDebtException(4, "只能本人还钱");
|
|---|
| | |
|
|---|
| | | if (money.compareTo(old.getLeftMoney()) < 0)
|
|---|
| | | throw new UserMoneyDebtException(5, "不够还");
|
|---|
| | |
|
|---|
| | | UserMoneyDebt update = new UserMoneyDebt();
|
|---|
| | | update.setId(old.getId());
|
|---|
| | | update.setUpdateTime(new Date());
|
|---|
| | | update.setLeftMoney(old.getLeftMoney().subtract(money));
|
|---|
| | | userMoneyDebtMapper.updateByPrimaryKeySelective(update);
|
|---|
| | |
|
|---|
| | | UserMoneyDebtReturnHistory history = new UserMoneyDebtReturnHistory();
|
|---|
| | | history.setBeiZhu(null);
|
|---|
| | | history.setCreateTime(new Date());
|
|---|
| | | history.setDebt(old);
|
|---|
| | | history.setMoney(money);
|
|---|
| | | history.setUid(old.getUid());
|
|---|
| | | userMoneyDebtReturnHistoryMapper.insertSelective(history);
|
|---|
| | |
|
|---|
| | | if (debt.getType() == UserMoneyDebtTypeEnum.order) {
|
|---|
| | | HongBaoV2 hb = hongBaoV2Service.selectByPrimaryKey(debt.getSourceId());
|
|---|
| | | if (hb == null) {
|
|---|
| | | throw new UserMoneyDebtException(6, "偿还的订单ID不存在");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | TaoBaoWeiQuanDrawBack weiQuanDrawBack = taoBaoWeiQuanDrawBackService.selectByHongBaoId(hb.getId());
|
|---|
| | | if (weiQuanDrawBack == null)
|
|---|
| | | throw new UserMoneyDebtException(7, "尚未找到退款信息");
|
|---|
| | |
|
|---|
| | | // 资金变化，添加用户资金记录，添加相关通知
|
|---|
| | | Long uid = debt.getUid();
|
|---|
| | | switch (hb.getType()) {
|
|---|
| | | case HongBaoV2.TYPE_ZIGOU:
|
|---|
| | | // 新版资金记录
|
|---|
| | | try {
|
|---|
| | | UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createFanLiWeiQuan(uid, weiQuanDrawBack,
|
|---|
| | | money);
|
|---|
| | | userMoneyService.subUserMoney(uid, money, userMoneyDetail);
|
|---|
| | | } catch (UserMoneyDetailException e) {
|
|---|
| | | throw new UserMoneyDebtException(12, "插入资金详情出错");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | // 新版通知
|
|---|
| | | List<CommonOrder> orderList = commonOrderService.listBySourceTypeAndOrderId(Constant.SOURCE_TYPE_TAOBAO,
|
|---|
| | | weiQuanDrawBack.getOrderId());
|
|---|
| | | int goodsCount = 0;
|
|---|
| | | for (CommonOrder co : orderList) {
|
|---|
| | | if (co.getState() != CommonOrder.STATE_SX)
|
|---|
| | | goodsCount += co.getCount();
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | BigDecimal fanliMoney = new BigDecimal(0);
|
|---|
| | | List<HongBaoOrder> hongBaoOrderList = hongBaoOrderService
|
|---|
| | | .listDetailByOrderIdAndSourceType(weiQuanDrawBack.getOrderId(), Constant.SOURCE_TYPE_TAOBAO);
|
|---|
| | |
|
|---|
| | | for (HongBaoOrder hongBaoOrder : hongBaoOrderList) {
|
|---|
| | | fanliMoney = fanliMoney.add(hongBaoOrder.getHongBaoV2().getMoney());
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | userMoneyMsgNotificationService.fanliOrderWeiQuan(uid, weiQuanDrawBack.getOrderId(),
|
|---|
| | | Constant.SOURCE_TYPE_TAOBAO, money, fanliMoney, goodsCount,
|
|---|
| | | orderList.get(0).getThirdCreateTime());
|
|---|
| | |
|
|---|
| | | break;
|
|---|
| | | case HongBaoV2.TYPE_SHARE_GOODS:
|
|---|
| | |
|
|---|
| | | // 新版资金记录
|
|---|
| | | try {
|
|---|
| | | UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createShareWeiQuan(debt.getUid(),
|
|---|
| | | weiQuanDrawBack, money);
|
|---|
| | | userMoneyService.subUserMoney(uid, money, userMoneyDetail);
|
|---|
| | |
|
|---|
| | | // 新版通知
|
|---|
| | | List<CommonOrder> orderList1 = commonOrderService
|
|---|
| | | .listBySourceTypeAndOrderId(Constant.SOURCE_TYPE_TAOBAO, weiQuanDrawBack.getOrderId());
|
|---|
| | | int goodsCount1 = 0;
|
|---|
| | | for (CommonOrder co : orderList1) {
|
|---|
| | | if (co.getState() != CommonOrder.STATE_SX)
|
|---|
| | | goodsCount1 += co.getCount();
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | BigDecimal fanliMoney1 = new BigDecimal(0);
|
|---|
| | | List<HongBaoOrder> hongBaoOrderList1 = hongBaoOrderService.listDetailByOrderIdAndSourceType(
|
|---|
| | | weiQuanDrawBack.getOrderId(), Constant.SOURCE_TYPE_TAOBAO);
|
|---|
| | |
|
|---|
| | | for (HongBaoOrder hongBaoOrder : hongBaoOrderList1) {
|
|---|
| | | fanliMoney1 = fanliMoney1.add(hongBaoOrder.getHongBaoV2().getMoney());
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | userMoneyMsgNotificationService.shareOrderWeiQuan(uid, weiQuanDrawBack.getOrderId(),
|
|---|
| | | Constant.SOURCE_TYPE_TAOBAO, money, fanliMoney1, goodsCount1,
|
|---|
| | | orderList1.get(0).getThirdCreateTime());
|
|---|
| | |
|
|---|
| | | } catch (UserMoneyDetailException e) {
|
|---|
| | | throw new UserMoneyDebtException(12, "插入资金详情出错");
|
|---|
| | | }
|
|---|
| | | break;
|
|---|
| | | case HongBaoV2.TYPE_SHARE_ERJI:
|
|---|
| | | case HongBaoV2.TYPE_SHARE_YIJI:
|
|---|
| | | case HongBaoV2.TYPE_ERJI:
|
|---|
| | | case HongBaoV2.TYPE_YIJI:
|
|---|
| | |
|
|---|
| | | // 新版资金记录
|
|---|
| | | try {
|
|---|
| | | UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createInviteWeiQuan(uid, weiQuanDrawBack,
|
|---|
| | | money);
|
|---|
| | | userMoneyService.subUserMoney(uid, money, userMoneyDetail);
|
|---|
| | | } catch (UserMoneyDetailException e) {
|
|---|
| | | throw new UserMoneyDebtException(12, "插入资金详情出错");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | break;
|
|---|
| | | }
|
|---|
| | | } else if (debt.getType() == UserMoneyDebtTypeEnum.extractVerify) {// 提现验证
|
|---|
| | | // 新版资金记录
|
|---|
| | | AlipayAccountValidNormalHistory aliPayAccountHistory = alipayAccountValidNormalHistoryMapper
|
|---|
| | | .selectByPrimaryKey(debt.getSourceId());
|
|---|
| | |
|
|---|
| | | AlipayAccountValidNormalHistory first = alipayAccountValidNormalHistoryMapper
|
|---|
| | | .selectLatestByUid(aliPayAccountHistory.getUid());
|
|---|
| | |
|
|---|
| | | if (aliPayAccountHistory == null)
|
|---|
| | | return;
|
|---|
| | | try {
|
|---|
| | | UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createExtractAccountValid(aliPayAccountHistory,
|
|---|
| | | money);
|
|---|
| | | userMoneyService.subUserMoney(aliPayAccountHistory.getUid(), money, userMoneyDetail);
|
|---|
| | | } catch (UserMoneyDetailException e) {
|
|---|
| | | throw new UserMoneyDebtException(12, "插入资金详情出错");
|
|---|
| | | }
|
|---|
| | | userMoneyMsgNotificationService.alipayAccountValid(aliPayAccountHistory, "1个月",
|
|---|
| | | first.getId().longValue() != aliPayAccountHistory.getId());
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Transactional(rollbackFor = Exception.class)
|
|---|
| | | @Override
|
|---|
| | | public void repayDebt(Long uid) {
|
|---|
| | | // 查询是否有欠债
|
|---|
| | | List<UserMoneyDebt> list = userMoneyDebtMapper.listByUidWithHasLeftMoney(uid, 0, 50);
|
|---|
| | | if (list != null && list.size() > 0) {// 有欠债
|
|---|
| | | for (UserMoneyDebt debt : list) {
|
|---|
| | | BigDecimal leftMoney = userInfoService.getBalance(uid);
|
|---|
| | | if (leftMoney.compareTo(debt.getLeftMoney()) >= 0) {// 有足够的资金偿还债务
|
|---|
| | | try {
|
|---|
| | | repayDebt(debt, debt.getLeftMoney());
|
|---|
| | | } catch (UserMoneyDebtException e) {
|
|---|
| | | try {
|
|---|
| | | LogHelper.errorDetailInfo(e, "uid:" + uid + " debtId:" + debt.getId(), null);
|
|---|
| | | } catch (Exception e1) {
|
|---|
| | | e1.printStackTrace();
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public boolean isHaveDebtToRepay(Long uid) {
|
|---|
| | | List<UserMoneyDebt> debtList = userMoneyDebtMapper.listByUidWithHasLeftMoney(uid, 0, 1);
|
|---|
| | | if (debtList != null && debtList.size() > 0)
|
|---|
| | | return true;
|
|---|
| | | return false;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | }
|
|---|
