package com.yeshi.fanli.service.impl.order;
|
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.HashSet;
|
import java.util.Iterator;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Set;
|
import java.util.UUID;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import com.aliyun.openservices.ons.api.Message;
|
import com.aliyun.openservices.ons.api.transaction.LocalTransactionExecuter;
|
import com.aliyun.openservices.ons.api.transaction.TransactionProducer;
|
import com.aliyun.openservices.ons.api.transaction.TransactionStatus;
|
import com.google.gson.Gson;
|
import com.yeshi.fanli.dao.mybatis.HongBaoV2Mapper;
|
import com.yeshi.fanli.dao.mybatis.UserInfoMapper;
|
import com.yeshi.fanli.dao.mybatis.order.HongBaoOrderMapper;
|
import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoWeiQuanOrderMapper;
|
import com.yeshi.fanli.dto.HongBao;
|
import com.yeshi.fanli.dto.mq.order.OrderTopicTagEnum;
|
import com.yeshi.fanli.dto.mq.order.body.OrderMoneyRecievedMQMsg;
|
import com.yeshi.fanli.dto.mq.order.body.TeamRewardPreRecieveMQMsg;
|
import com.yeshi.fanli.entity.bus.user.HongBaoV2;
|
import com.yeshi.fanli.entity.bus.user.UserInfo;
|
import com.yeshi.fanli.entity.money.TeamRewardDebt;
|
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.TaoBaoWeiQuanOrder;
|
import com.yeshi.fanli.exception.ParamsException;
|
import com.yeshi.fanli.exception.money.OrderMoneySettleException;
|
import com.yeshi.fanli.exception.money.TeamEincomeRecordException;
|
import com.yeshi.fanli.exception.money.TeamRewardDebtException;
|
import com.yeshi.fanli.exception.money.UserMoneyDetailException;
|
import com.yeshi.fanli.exception.order.TaoBaoWeiQuanException;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.service.inter.hongbao.AccountDetailsHongBaoMapService;
|
import com.yeshi.fanli.service.inter.hongbao.HongBaoV2SettleTempService;
|
import com.yeshi.fanli.service.inter.money.TeamRewardDebtService;
|
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.OrderMoneySettleService;
|
import com.yeshi.fanli.service.inter.user.UserSystemCouponService;
|
import com.yeshi.fanli.service.manger.order.TeamRewardManager;
|
import com.yeshi.fanli.service.manger.order.TeamSubsidyManager;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.TimeUtil;
|
import com.yeshi.fanli.util.cmq.HongBaoRecieveCMQManager;
|
import com.yeshi.fanli.util.factory.UserMoneyDetailFactory;
|
import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;
|
import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
|
@Service
|
public class OrderMoneySettleServiceImpl implements OrderMoneySettleService {
|
|
@Resource
|
private HongBaoV2Mapper hongBaoV2Mapper;
|
|
@Resource
|
private HongBaoOrderMapper hongBaoOrderMapper;
|
|
@Resource
|
private UserInfoMapper userInfoMapper;
|
|
@Resource
|
private TaoBaoWeiQuanOrderMapper taoBaoWeiQuanOrderMapper;
|
|
@Resource
|
private UserMoneyService userMoneyService;
|
|
@Resource
|
private UserMoneyMsgNotificationService userMoneyMsgNotificationService;
|
|
@Resource
|
private TaoBaoWeiQuanDrawBackService taoBaoWeiQuanDrawBackService;
|
|
@Resource
|
private AccountDetailsHongBaoMapService accountDetailsHongBaoMapService;
|
|
@Resource
|
private CommonOrderService commonOrderService;
|
|
@Resource
|
private UserSystemCouponService userSystemCouponService;
|
|
@Resource(name = "orderTransactionProducer")
|
private TransactionProducer orderTransactionProducer;
|
|
// 邀请补贴
|
|
@Resource
|
private HongBaoV2SettleTempService hongBaoV2SettleTempService;
|
|
@Resource
|
private TeamRewardDebtService teamRewardDebtService;
|
|
@Resource
|
private TeamRewardManager teamRewardManager;
|
|
@Resource
|
private TeamSubsidyManager teamSubsidyManager;
|
|
// 下级被封禁，红包失效
|
private void invalidHongBaoForbidden(Long id) {
|
HongBaoV2 updateHongBaoV2 = new HongBaoV2(id);
|
updateHongBaoV2.setState(HongBaoV2.STATE_SHIXIAO);
|
updateHongBaoV2.setBeizhu("封禁失效");
|
updateHongBaoV2.setUpdateTime(new Date());
|
hongBaoV2Mapper.updateByPrimaryKeySelective(updateHongBaoV2);
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
@Override
|
public void inviteSettleTB(Long uid, Date maxPregetTime) throws OrderMoneySettleException {
|
// 查询UID的一二级邀请赚
|
int sourceType = Constant.SOURCE_TYPE_TAOBAO;
|
List<Integer> types = new ArrayList<>();
|
types.add(HongBaoV2.TYPE_YIJI);
|
types.add(HongBaoV2.TYPE_ERJI);
|
types.add(HongBaoV2.TYPE_SHARE_YIJI);
|
types.add(HongBaoV2.TYPE_SHARE_ERJI);
|
long count = hongBaoV2Mapper.countCanBalanceHongBaoByTypeAndUid(types, uid, sourceType, maxPregetTime);
|
List<HongBaoV2> hongBaoList = new ArrayList<>();
|
// 1000条数据为1页
|
int page = (int) (count % 1000 == 0 ? count / 1000 : count / 1000 + 1);
|
for (int i = 0; i < page; i++) {
|
List<HongBaoV2> tempHongBaoList = hongBaoV2Mapper.listCanBalanceHongBaoByTypeAndUid(types, uid, sourceType,
|
maxPregetTime, i * 1000, 1000);
|
if (tempHongBaoList != null && tempHongBaoList.size() > 0)
|
hongBaoList.addAll(tempHongBaoList);
|
}
|
|
for (int i = 0; i < hongBaoList.size(); i++) {
|
HongBaoV2 item = hongBaoList.get(i);
|
if (item != null && item.getParent() != null) {
|
if (item != null) {
|
HongBaoOrder hongBaoOrder = hongBaoOrderMapper.selectByHongBaoId(item.getParent().getId());
|
if (hongBaoOrder != null && hongBaoOrder.getCommonOrder() != null) {
|
CommonOrder co = hongBaoOrder.getCommonOrder();
|
// 上级用户不是正常用户，订单均不能到账
|
UserInfo userInfo = userInfoMapper.selectAvailableByPrimaryKey(co.getUserInfo().getId());
|
if (userInfo == null || userInfo.getState() != UserInfo.STATE_NORMAL) {
|
invalidHongBaoForbidden(item.getId());
|
hongBaoList.remove(i);
|
i--;
|
}
|
}
|
}
|
}
|
}
|
|
String taskKey = getTaskKey(uid);
|
|
TeamRewardPreRecieveMQMsg mqMsg = new TeamRewardPreRecieveMQMsg(taskKey, uid, sourceType, maxPregetTime,
|
new Date());
|
|
Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.teamRewardPreRecieved, mqMsg);
|
|
msg.setKey(taskKey);
|
// 添加事务消息
|
try {
|
orderTransactionProducer.send(msg, new LocalTransactionExecuter() {
|
@Override
|
public TransactionStatus execute(Message arg0, Object arg1) {
|
try {
|
fanliInvite(hongBaoList, uid, Constant.SOURCE_TYPE_TAOBAO, taskKey, maxPregetTime);
|
} catch (Exception e) {
|
e.printStackTrace();
|
return TransactionStatus.RollbackTransaction;
|
}
|
return TransactionStatus.CommitTransaction;
|
}
|
}, null);
|
} catch (Exception e) {
|
e.printStackTrace();
|
LogHelper.mqError(e.getMessage(), msg.getTopic(), msg.getTag(), new Gson().toJson(mqMsg));
|
}
|
System.out.println(new Gson().toJson(mqMsg));
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
@Override
|
public void inviteSettleJD(Long uid, Date maxPregetTime) throws OrderMoneySettleException {
|
// 查询UID的一二级邀请赚
|
int sourceType = Constant.SOURCE_TYPE_JD;
|
List<Integer> types = new ArrayList<>();
|
types.add(HongBaoV2.TYPE_YIJI);
|
types.add(HongBaoV2.TYPE_ERJI);
|
types.add(HongBaoV2.TYPE_SHARE_YIJI);
|
types.add(HongBaoV2.TYPE_SHARE_ERJI);
|
long count = hongBaoV2Mapper.countCanBalanceHongBaoByTypeAndUid(types, uid, sourceType, maxPregetTime);
|
List<HongBaoV2> hongBaoList = new ArrayList<>();
|
// 1000条数据为1页
|
int page = (int) (count % 1000 == 0 ? count / 1000 : count / 1000 + 1);
|
for (int i = 0; i < page; i++) {
|
List<HongBaoV2> tempHongBaoList = hongBaoV2Mapper.listCanBalanceHongBaoByTypeAndUid(types, uid, sourceType,
|
maxPregetTime, i * 1000, 1000);
|
if (tempHongBaoList != null && tempHongBaoList.size() > 0)
|
hongBaoList.addAll(tempHongBaoList);
|
}
|
|
for (int i = 0; i < hongBaoList.size(); i++) {
|
HongBaoV2 item = hongBaoList.get(i);
|
if (item != null && item.getParent() != null) {
|
if (item != null) {
|
HongBaoOrder hongBaoOrder = hongBaoOrderMapper.selectByHongBaoId(item.getParent().getId());
|
if (hongBaoOrder != null && hongBaoOrder.getCommonOrder() != null) {
|
CommonOrder co = hongBaoOrder.getCommonOrder();
|
// 上级用户不是正常用户，订单均不能到账
|
UserInfo userInfo = userInfoMapper.selectAvailableByPrimaryKey(co.getUserInfo().getId());
|
if (userInfo == null || userInfo.getState() != UserInfo.STATE_NORMAL) {
|
invalidHongBaoForbidden(item.getId());
|
hongBaoList.remove(i);
|
i--;
|
}
|
}
|
}
|
}
|
}
|
|
// 邀请赚到账事务消息
|
|
String taskKey = getTaskKey(uid);
|
TeamRewardPreRecieveMQMsg mqMsg = new TeamRewardPreRecieveMQMsg(taskKey, uid, sourceType, maxPregetTime,
|
new Date());
|
Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.teamRewardPreRecieved, mqMsg);
|
msg.setKey(taskKey);
|
// 添加事务消息
|
try {
|
orderTransactionProducer.send(msg, new LocalTransactionExecuter() {
|
@Override
|
public TransactionStatus execute(Message arg0, Object arg1) {
|
try {
|
fanliInvite(hongBaoList, uid, sourceType, taskKey, maxPregetTime);
|
} catch (Exception e) {
|
e.printStackTrace();
|
return TransactionStatus.RollbackTransaction;
|
}
|
return TransactionStatus.CommitTransaction;
|
}
|
}, null);
|
} catch (Exception e) {
|
LogHelper.mqError(e.getMessage(), msg.getTopic(), msg.getTag(), new Gson().toJson(mqMsg));
|
}
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
@Override
|
public void inviteSettlePDD(Long uid, Date maxPregetTime) throws OrderMoneySettleException {
|
// 查询UID的一二级邀请赚
|
int sourceType = Constant.SOURCE_TYPE_PDD;
|
List<Integer> types = new ArrayList<>();
|
types.add(HongBaoV2.TYPE_YIJI);
|
types.add(HongBaoV2.TYPE_ERJI);
|
types.add(HongBaoV2.TYPE_SHARE_YIJI);
|
types.add(HongBaoV2.TYPE_SHARE_ERJI);
|
long count = hongBaoV2Mapper.countCanBalanceHongBaoByTypeAndUid(types, uid, sourceType, maxPregetTime);
|
List<HongBaoV2> hongBaoList = new ArrayList<>();
|
// 1000条数据为1页
|
int page = (int) (count % 1000 == 0 ? count / 1000 : count / 1000 + 1);
|
for (int i = 0; i < page; i++) {
|
List<HongBaoV2> tempHongBaoList = hongBaoV2Mapper.listCanBalanceHongBaoByTypeAndUid(types, uid, sourceType,
|
maxPregetTime, i * 1000, 1000);
|
if (tempHongBaoList != null && tempHongBaoList.size() > 0)
|
hongBaoList.addAll(tempHongBaoList);
|
}
|
|
for (int i = 0; i < hongBaoList.size(); i++) {
|
HongBaoV2 item = hongBaoList.get(i);
|
if (item != null && item.getParent() != null) {
|
if (item != null) {
|
HongBaoOrder hongBaoOrder = hongBaoOrderMapper.selectByHongBaoId(item.getParent().getId());
|
if (hongBaoOrder != null && hongBaoOrder.getCommonOrder() != null) {
|
CommonOrder co = hongBaoOrder.getCommonOrder();
|
// 上级用户不是正常用户，订单均不能到账
|
UserInfo userInfo = userInfoMapper.selectAvailableByPrimaryKey(co.getUserInfo().getId());
|
if (userInfo == null || userInfo.getState() != UserInfo.STATE_NORMAL) {
|
invalidHongBaoForbidden(item.getId());
|
hongBaoList.remove(i);
|
i--;
|
}
|
}
|
}
|
}
|
}
|
|
// 邀请赚到账事务消息
|
String taskKey = getTaskKey(uid);
|
TeamRewardPreRecieveMQMsg mqMsg = new TeamRewardPreRecieveMQMsg(taskKey, uid, sourceType, maxPregetTime,
|
new Date());
|
Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.teamRewardPreRecieved, mqMsg);
|
msg.setKey(taskKey);
|
// 添加事务消息
|
try {
|
orderTransactionProducer.send(msg, new LocalTransactionExecuter() {
|
@Override
|
public TransactionStatus execute(Message arg0, Object arg1) {
|
try {
|
fanliInvite(hongBaoList, uid, sourceType, taskKey, maxPregetTime);
|
} catch (Exception e) {
|
return TransactionStatus.RollbackTransaction;
|
}
|
return TransactionStatus.CommitTransaction;
|
}
|
}, null);
|
} catch (Exception e) {
|
LogHelper.mqError(e.getMessage(), msg.getTopic(), msg.getTag(), new Gson().toJson(mqMsg));
|
}
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
@Override
|
public void shareSettleTB(Long uid, Date maxPregetTime) throws OrderMoneySettleException {
|
/**
|
* 处理分享赚
|
*/
|
int sourceType = Constant.SOURCE_TYPE_TAOBAO;
|
List<Integer> types = new ArrayList<>();
|
|
// 查询UID的分享赚订单
|
types.add(HongBaoV2.TYPE_SHARE_GOODS);
|
long count = hongBaoV2Mapper.countCanBalanceHongBaoByTypeAndUid(types, uid, sourceType, maxPregetTime);
|
List<HongBaoV2> hongBaoList = new ArrayList<>();
|
// 1000条数据为1页
|
int page = (int) (count % 1000 == 0 ? count / 1000 : count / 1000 + 1);
|
for (int i = 0; i < page; i++) {
|
List<HongBaoV2> tempHongBaoList = hongBaoV2Mapper.listCanBalanceHongBaoByTypeAndUid(types, uid, sourceType,
|
maxPregetTime, i * 1000, 1000);
|
if (tempHongBaoList != null && tempHongBaoList.size() > 0)
|
hongBaoList.addAll(tempHongBaoList);
|
}
|
|
OrderMoneyRecievedMQMsg mqMsg = new OrderMoneyRecievedMQMsg(OrderMoneyRecievedMQMsg.TYPE_SHARE, uid, sourceType,
|
null, null, new Date(), 0);
|
Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.orderFanLiActual, mqMsg);
|
String taskKey = getTaskKey(uid);
|
msg.setKey(taskKey);
|
|
// 添加事务消息
|
try {
|
orderTransactionProducer.send(msg, new LocalTransactionExecuter() {
|
@Override
|
public TransactionStatus execute(Message arg0, Object arg1) {
|
try {
|
fanLiShareTB(hongBaoList, uid, taskKey);
|
} catch (TaoBaoWeiQuanException e) {
|
return TransactionStatus.RollbackTransaction;
|
}
|
return TransactionStatus.CommitTransaction;
|
}
|
}, null);
|
} catch (Exception e) {
|
LogHelper.mqError(e.getMessage(), msg.getTopic(), msg.getTag(), new Gson().toJson(mqMsg));
|
}
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
@Override
|
public void shareSettleJD(Long uid, Date maxPregetTime) throws OrderMoneySettleException {
|
/**
|
* 处理分享赚
|
*/
|
int sourceType = Constant.SOURCE_TYPE_JD;
|
List<Integer> types = new ArrayList<>();
|
|
// 查询UID的分享赚订单
|
types.add(HongBaoV2.TYPE_SHARE_GOODS);
|
long count = hongBaoV2Mapper.countCanBalanceHongBaoByTypeAndUid(types, uid, sourceType, maxPregetTime);
|
List<HongBaoV2> hongBaoList = new ArrayList<>();
|
// 1000条数据为1页
|
int page = (int) (count % 1000 == 0 ? count / 1000 : count / 1000 + 1);
|
for (int i = 0; i < page; i++) {
|
List<HongBaoV2> tempHongBaoList = hongBaoV2Mapper.listCanBalanceHongBaoByTypeAndUid(types, uid, sourceType,
|
maxPregetTime, i * 1000, 1000);
|
if (tempHongBaoList != null && tempHongBaoList.size() > 0)
|
hongBaoList.addAll(tempHongBaoList);
|
}
|
|
OrderMoneyRecievedMQMsg mqMsg = new OrderMoneyRecievedMQMsg(OrderMoneyRecievedMQMsg.TYPE_SHARE, uid, sourceType,
|
null, null, new Date(), 0);
|
Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.orderFanLiActual, mqMsg);
|
String taskKey = getTaskKey(uid);
|
msg.setKey(taskKey);
|
// 添加事务消息
|
try {
|
orderTransactionProducer.send(msg, new LocalTransactionExecuter() {
|
@Override
|
public TransactionStatus execute(Message arg0, Object arg1) {
|
fanLiShareOther(hongBaoList, uid, sourceType, taskKey);
|
return TransactionStatus.CommitTransaction;
|
}
|
}, null);
|
} catch (Exception e) {
|
LogHelper.mqError(e.getMessage(), msg.getTopic(), msg.getTag(), new Gson().toJson(mqMsg));
|
}
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
@Override
|
public void shareSettlePDD(Long uid, Date maxPregetTime) throws OrderMoneySettleException {
|
/**
|
* 处理分享赚
|
*/
|
int sourceType = Constant.SOURCE_TYPE_PDD;
|
List<Integer> types = new ArrayList<>();
|
|
// 查询UID的分享赚订单
|
types.add(HongBaoV2.TYPE_SHARE_GOODS);
|
long count = hongBaoV2Mapper.countCanBalanceHongBaoByTypeAndUid(types, uid, sourceType, maxPregetTime);
|
List<HongBaoV2> hongBaoList = new ArrayList<>();
|
// 1000条数据为1页
|
int page = (int) (count % 1000 == 0 ? count / 1000 : count / 1000 + 1);
|
for (int i = 0; i < page; i++) {
|
List<HongBaoV2> tempHongBaoList = hongBaoV2Mapper.listCanBalanceHongBaoByTypeAndUid(types, uid, sourceType,
|
maxPregetTime, i * 1000, 1000);
|
if (tempHongBaoList != null && tempHongBaoList.size() > 0)
|
hongBaoList.addAll(tempHongBaoList);
|
}
|
|
OrderMoneyRecievedMQMsg mqMsg = new OrderMoneyRecievedMQMsg(OrderMoneyRecievedMQMsg.TYPE_SHARE, uid, sourceType,
|
null, null, new Date(), 0);
|
Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.orderFanLiActual, mqMsg);
|
String taskKey = getTaskKey(uid);
|
msg.setKey(taskKey);
|
// 添加事务消息
|
try {
|
orderTransactionProducer.send(msg, new LocalTransactionExecuter() {
|
@Override
|
public TransactionStatus execute(Message arg0, Object arg1) {
|
fanLiShareOther(hongBaoList, uid, sourceType, taskKey);
|
return TransactionStatus.CommitTransaction;
|
}
|
}, null);
|
} catch (Exception e) {
|
LogHelper.mqError(e.getMessage(), msg.getTopic(), msg.getTag(), new Gson().toJson(mqMsg));
|
}
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
@Override
|
public void ziGouSettle(String orderId, int sourceType, String taskKey) throws OrderMoneySettleException {
|
// 查询同一订单号的红包
|
List<CommonOrder> orderList = commonOrderService.listBySourceTypeAndOrderId(sourceType, orderId);
|
List<HongBaoV2> hongBaoList = new ArrayList<>();
|
Map<Long, BigDecimal> userMoney = new HashMap<>();
|
Map<Long, List<HongBaoV2>> userHongBao = new HashMap<>();
|
Map<Long, Integer> userGoodsCount = new HashMap<>();
|
for (CommonOrder co : orderList) {
|
HongBaoOrder hongBaoOrder = hongBaoOrderMapper.selectByCommonOrderId(co.getId());
|
hongBaoList.add(hongBaoOrder.getHongBaoV2());
|
Long uid = co.getUserInfo().getId();
|
if (userGoodsCount.get(uid) == null)
|
userGoodsCount.put(uid, co.getCount());
|
else
|
userGoodsCount.put(uid, Integer.valueOf(co.getCount() + userGoodsCount.get(uid)));
|
}
|
|
for (HongBaoV2 hb : hongBaoList) {
|
long currentTimeMillis = System.currentTimeMillis();
|
if (hb.getState() != HongBao.STATE_SHIXIAO) {
|
// 设置为已返利
|
// 处理主红包
|
if (hb.getState() != HongBaoV2.STATE_SHIXIAO && hb.getState() != HongBaoV2.STATE_YILINGQU
|
&& hb.getType() == HongBaoV2.TYPE_ZIGOU) {
|
// 如果红包没被领取
|
Long uid = hb.getUserInfo().getId();
|
HongBaoV2 updateHongBao = new HongBaoV2();
|
updateHongBao.setId(hb.getId());
|
updateHongBao.setState(HongBaoV2.STATE_YILINGQU);
|
updateHongBao.setGetTime(new Date(currentTimeMillis));
|
hongBaoV2Mapper.updateByPrimaryKeySelective(updateHongBao);
|
if (userMoney.get(uid) == null)
|
userMoney.put(uid, hb.getMoney());
|
else
|
userMoney.put(uid, userMoney.get(uid).add(hb.getMoney()));
|
|
// 添加红包到用户
|
if (userHongBao.get(uid) == null)
|
userHongBao.put(uid, new ArrayList<>());
|
userHongBao.get(uid).add(hb);
|
}
|
}
|
}
|
|
// 获取维权资金
|
if (sourceType == Constant.SOURCE_TYPE_TAOBAO) {
|
try {
|
Map<Long, BigDecimal> userSubMoneyMap = taoBaoWeiQuanDrawBackService.doWeiQuanFanli(orderId, false);
|
if (userSubMoneyMap != null) {
|
for (Iterator<Long> its = userMoney.keySet().iterator(); its.hasNext();) {
|
Long uid = its.next();
|
if (userSubMoneyMap.get(uid) != null) {
|
// 减去维权资金
|
userMoney.put(uid, userMoney.get(uid).subtract(userSubMoneyMap.get(uid)));
|
}
|
}
|
}
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
throw new OrderMoneySettleException(2, "维权订单出错");
|
}
|
}
|
|
// if (userMoney.isEmpty()) {
|
// throw new OrderMoneySettleException(1, "没有需要结算的订单");
|
// }
|
|
Iterator<Long> its = userMoney.keySet().iterator();
|
|
while (its.hasNext()) {
|
// 将自己添加到用户
|
Long uid = its.next();
|
BigDecimal money = userMoney.get(uid);
|
UserMoneyDetail userMoneyDetail = null;
|
// 插入新版资金明细
|
try {
|
// 此处不用订单号做唯一性索引
|
userMoneyDetail = UserMoneyDetailFactory.createFanLi(uid, orderId, sourceType, null, money);
|
} catch (UserMoneyDetailException e1) {
|
try {
|
LogHelper.errorDetailInfo(e1, "订单号:" + orderId, "");
|
} catch (Exception e2) {
|
e2.printStackTrace();
|
}
|
}
|
|
userMoneyService.addUserMoney(uid, money, userMoneyDetail);
|
|
List<Long> hbIdList = new ArrayList<>();
|
// 添加资金明细与红包的映射关系
|
for (HongBaoV2 v2 : userHongBao.get(uid)) {
|
hbIdList.add(v2.getId());
|
accountDetailsHongBaoMapService.saveAccountDetailsHongBaoMap(v2.getId(), userMoneyDetail.getId());
|
try {
|
HongBaoRecieveCMQManager.getInstance().addHongBaoRecieveMsg(v2.getId());
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
}
|
}
|
// 添加结算映射
|
hongBaoV2SettleTempService.addTemp(hbIdList, taskKey);
|
|
// 站内信+推送
|
UserInfo user = userInfoMapper.selectByPrimaryKey(uid);
|
|
// 新版通知
|
|
userMoneyMsgNotificationService.fanliOrderReceived(uid, orderId, sourceType, userGoodsCount.get(uid), money,
|
user.getMyHongBao(), orderList.get(0).getThirdCreateTime());
|
}
|
// 通知免单到账
|
try {
|
userSystemCouponService.updateStateByArrivalAccount(orderId);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
// 添加结算映射
|
|
}
|
|
private HongBaoV2 filterWeiQuanINGHongBao(HongBaoV2 hongBao) {
|
|
long hbId = hongBao.getId();
|
if (hongBao.getParent() != null) {
|
hbId = hongBao.getParent().getId();
|
}
|
|
HongBaoOrder hongbaoOrder = hongBaoOrderMapper.selectByHongBaoId(hbId);
|
|
if (hongbaoOrder == null)
|
return null;
|
|
List<TaoBaoWeiQuanOrder> taoBaoWeiQuanList = taoBaoWeiQuanOrderMapper
|
.selectListByOrderIdAndState(hongbaoOrder.getCommonOrder().getOrderNo(), "维权创建");
|
|
List<TaoBaoWeiQuanOrder> taoBaoWeiQuanList1 = taoBaoWeiQuanOrderMapper
|
.selectListByOrderIdAndState(hongbaoOrder.getCommonOrder().getOrderNo(), "等待处理");
|
if ((taoBaoWeiQuanList != null && taoBaoWeiQuanList.size() > 0)
|
|| (taoBaoWeiQuanList1 != null && taoBaoWeiQuanList1.size() > 0)) {
|
return null;
|
}
|
return hongBao;
|
}
|
|
@Transactional
|
private void fanliInvite(List<HongBaoV2> hongBaoList, Long uid, int sourceType, String key, Date maxPreGetTime)
|
throws TeamEincomeRecordException, ParamsException, TeamRewardDebtException {
|
List<Long> hbIdList = new ArrayList<>();
|
BigDecimal invitemoney = new BigDecimal(0);
|
Set<String> inviteOrders = new HashSet<>();
|
|
// 需要判断退款的订单号
|
for (HongBaoV2 hongBao : hongBaoList) {
|
hongBao = filterWeiQuanINGHongBao(hongBao);
|
if (hongBao == null)
|
continue;
|
hongBao = hongBaoV2Mapper.selectByPrimaryKeyForUpdate(hongBao.getId());
|
if (hongBao.getState() == HongBaoV2.STATE_BUKELINGQU || hongBao.getState() == HongBaoV2.STATE_KELINGQU) {
|
TeamRewardDebt debt = teamRewardDebtService.selectBySourceId(hongBao.getId());
|
BigDecimal money = hongBao.getMoney();
|
if (debt != null && debt.getLeftMoney().compareTo(new BigDecimal(0)) > 0
|
&& money.compareTo(debt.getLeftMoney()) >= 0) {
|
money = money.subtract(debt.getLeftMoney());
|
// 还钱
|
teamRewardDebtService.repayDebt(debt.getId(), debt.getLeftMoney());
|
}
|
|
invitemoney = invitemoney.add(money);
|
HongBaoV2 updateHongBao = new HongBaoV2();
|
updateHongBao.setId(hongBao.getId());
|
updateHongBao.setGetTime(new Date());
|
updateHongBao.setState(HongBaoV2.STATE_YILINGQU);
|
updateHongBao.setUpdateTime(new Date());
|
hongBaoV2Mapper.updateByPrimaryKeySelective(updateHongBao);
|
// 添加到红包返利记录集合
|
hbIdList.add(hongBao.getId());
|
|
// 2018-08-05 过后的订单才处理维权
|
|
HongBaoOrder hongBaoOrder = hongBaoOrderMapper.selectByHongBaoId(hongBao.getParent().getId());
|
inviteOrders.add(hongBaoOrder.getCommonOrder().getOrderNo());
|
}
|
}
|
|
// 邀请赚到账
|
if (invitemoney.compareTo(new BigDecimal(0)) > 0) {
|
// 获取当前的月份
|
teamRewardManager.addToEincome(uid, maxPreGetTime, invitemoney, sourceType);
|
}
|
|
hongBaoV2SettleTempService.addTemp(hbIdList, key);
|
|
// 所有的返利到账红包ID
|
for (Long hongBaoId : hbIdList) {
|
try {
|
if (Constant.ENABLE_MQ)
|
HongBaoRecieveCMQManager.getInstance().addHongBaoRecieveMsg(hongBaoId);
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
}
|
}
|
}
|
|
/**
|
* 淘宝分享赚返利
|
*
|
* @param hongBaoList
|
* @param uid
|
* @throws TaoBaoWeiQuanException
|
*/
|
private void fanLiShareTB(List<HongBaoV2> hongBaoList, Long uid, String key) throws TaoBaoWeiQuanException {
|
BigDecimal sharemoney = new BigDecimal(0);
|
List<Long> hbIdList = new ArrayList<>();
|
Set<String> drawBackOrders = new HashSet<String>();
|
List<Long> recieveHongBaoIds = new ArrayList<>();
|
int shareGoodsCount = 0;
|
Set<String> shareOrders = new HashSet<>();
|
|
for (HongBaoV2 hongBao : hongBaoList) {
|
hongBao = hongBaoV2Mapper.selectByPrimaryKeyForUpdate(hongBao.getId());
|
hongBao = filterWeiQuanINGHongBao(hongBao);
|
if (hongBao == null)
|
continue;
|
|
if (hongBao.getState() == HongBaoV2.STATE_BUKELINGQU || hongBao.getState() == HongBaoV2.STATE_KELINGQU) {
|
sharemoney = sharemoney.add(hongBao.getMoney());
|
HongBaoV2 updateHongBao = new HongBaoV2();
|
updateHongBao.setId(hongBao.getId());
|
updateHongBao.setGetTime(new Date());
|
updateHongBao.setState(HongBao.STATE_YILINGQU);
|
updateHongBao.setUpdateTime(new Date());
|
hongBaoV2Mapper.updateByPrimaryKeySelective(updateHongBao);
|
// 添加到红包返利记录集合
|
hbIdList.add(hongBao.getId());
|
// 2018-08-05 过后的订单才处理维权
|
Date balanceTime = null;
|
HongBaoOrder hongBaoOrder = hongBaoOrderMapper.selectByHongBaoId(hongBao.getId());
|
if (hongBaoOrder != null) {
|
balanceTime = hongBaoOrder.getCommonOrder().getSettleTime();
|
shareGoodsCount += hongBaoOrder.getCommonOrder().getCount();
|
}
|
shareOrders.add(hongBaoOrder.getCommonOrder().getOrderNo());
|
if (balanceTime != null
|
&& balanceTime.getTime() >= TimeUtil.convertToTimeTemp("2018-08-05", "yyyy-MM-dd")) {
|
drawBackOrders.add(hongBaoOrder.getCommonOrder().getOrderNo());
|
}
|
}
|
}
|
|
/**
|
* 分享赚到账
|
*/
|
|
if (sharemoney.compareTo(new BigDecimal(0)) > 0) {
|
// 添加新版详情记录
|
try {
|
UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createShare(uid, Constant.SOURCE_TYPE_TAOBAO,
|
sharemoney, new Date());
|
// 添加资金
|
userMoneyService.addUserMoney(uid, sharemoney, userMoneyDetail);
|
|
// 添加到红包返利记录集合
|
accountDetailsHongBaoMapService.saveAccountDetailsHongBaoMap(hbIdList, userMoneyDetail.getId());
|
if (hbIdList.size() > 0)
|
recieveHongBaoIds.addAll(hbIdList);
|
} catch (UserMoneyDetailException e) {
|
try {
|
LogHelper.errorDetailInfo(e);
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
}
|
|
// 新版通知
|
userMoneyMsgNotificationService.shareOrderReceived(uid, Constant.SOURCE_TYPE_TAOBAO, shareOrders.size(),
|
shareGoodsCount, sharemoney, userInfoMapper.selectAvailableByPrimaryKey(uid).getMyHongBao(), null,
|
null);
|
|
for (String orderId : drawBackOrders)
|
taoBaoWeiQuanDrawBackService.doWeiQuanShare(orderId);
|
}
|
|
hongBaoV2SettleTempService.addTemp(recieveHongBaoIds, key);
|
|
// 所有的返利到账红包ID
|
for (Long hongBaoId : recieveHongBaoIds) {
|
try {
|
if (Constant.ENABLE_MQ)
|
HongBaoRecieveCMQManager.getInstance().addHongBaoRecieveMsg(hongBaoId);
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
}
|
|
}
|
}
|
|
/**
|
* 其他平台分享赚返利
|
*
|
* @param hongBaoList
|
* @param uid
|
* @param sourceType
|
*/
|
private void fanLiShareOther(List<HongBaoV2> hongBaoList, Long uid, int sourceType, String key) {
|
BigDecimal sharemoney = new BigDecimal(0);
|
List<Long> hbIdList = new ArrayList<>();
|
List<Long> recieveHongBaoIds = new ArrayList<>();
|
int shareGoodsCount = 0;
|
Set<String> shareOrders = new HashSet<>();
|
|
for (HongBaoV2 hongBao : hongBaoList) {
|
hongBao = hongBaoV2Mapper.selectByPrimaryKeyForUpdate(hongBao.getId());
|
hongBao = filterWeiQuanINGHongBao(hongBao);
|
if (hongBao == null)
|
continue;
|
|
if (hongBao.getState() == HongBaoV2.STATE_BUKELINGQU || hongBao.getState() == HongBaoV2.STATE_KELINGQU) {
|
sharemoney = sharemoney.add(hongBao.getMoney());
|
HongBaoV2 updateHongBao = new HongBaoV2();
|
updateHongBao.setId(hongBao.getId());
|
updateHongBao.setGetTime(new Date());
|
updateHongBao.setState(HongBao.STATE_YILINGQU);
|
updateHongBao.setUpdateTime(new Date());
|
hongBaoV2Mapper.updateByPrimaryKeySelective(updateHongBao);
|
// 添加到红包返利记录集合
|
hbIdList.add(hongBao.getId());
|
// 2018-08-05 过后的订单才处理维权
|
HongBaoOrder hongBaoOrder = hongBaoOrderMapper.selectByHongBaoId(hongBao.getId());
|
if (hongBaoOrder != null) {
|
shareGoodsCount += hongBaoOrder.getCommonOrder().getCount();
|
}
|
shareOrders.add(hongBaoOrder.getCommonOrder().getOrderNo());
|
}
|
}
|
|
/**
|
* 分享赚到账
|
*/
|
|
if (sharemoney.compareTo(new BigDecimal(0)) > 0) {
|
// 添加新版详情记录
|
try {
|
UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createShare(uid, sourceType, sharemoney,
|
new Date());
|
// 添加资金
|
userMoneyService.addUserMoney(uid, sharemoney, userMoneyDetail);
|
|
// 添加到红包返利记录集合
|
accountDetailsHongBaoMapService.saveAccountDetailsHongBaoMap(hbIdList, userMoneyDetail.getId());
|
if (hbIdList.size() > 0)
|
recieveHongBaoIds.addAll(hbIdList);
|
} catch (UserMoneyDetailException e) {
|
try {
|
LogHelper.errorDetailInfo(e);
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
}
|
|
// 新版通知
|
userMoneyMsgNotificationService.shareOrderReceived(uid, Constant.SOURCE_TYPE_TAOBAO, shareOrders.size(),
|
shareGoodsCount, sharemoney, userInfoMapper.selectAvailableByPrimaryKey(uid).getMyHongBao(), null,
|
null);
|
}
|
|
hongBaoV2SettleTempService.addTemp(recieveHongBaoIds, key);
|
|
// 所有的返利到账红包ID
|
for (Long hongBaoId : recieveHongBaoIds) {
|
try {
|
if(Constant.ENABLE_MQ)
|
HongBaoRecieveCMQManager.getInstance().addHongBaoRecieveMsg(hongBaoId);
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
}
|
}
|
}
|
|
/**
|
* 邀请补贴结算
|
*
|
* @param orderId
|
* @param sourceType
|
* @throws ParamsException
|
* @throws TeamEincomeRecordException
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
@Override
|
public void inviteSubsidySettle(Long uid, String taskKey, Date maxPreGetTime)
|
throws OrderMoneySettleException, TeamEincomeRecordException, ParamsException {
|
teamSubsidyManager.addToTeamEincome(uid, taskKey, maxPreGetTime);
|
}
|
|
private String getTaskKey(Long uid) {
|
return uid + "-" + UUID.randomUUID().toString();
|
}
|
|
}
|
