| | |
|---|
| | | import com.yeshi.fanli.service.inter.hongbao.AccountDetailsHongBaoMapService;
|
|---|
| | | import com.yeshi.fanli.service.inter.hongbao.HongBaoV2SettleTempService;
|
|---|
| | | import com.yeshi.fanli.service.inter.money.InviteOrderSubsidyDebtService;
|
|---|
| | | import com.yeshi.fanli.service.inter.money.OrderTeamRewardDebtService;
|
|---|
| | | 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;
|
|---|
| | |
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private HongBaoV2SettleTempService hongBaoV2SettleTempService;
|
|---|
| | |
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private OrderTeamRewardDebtService orderTeamRewardDebtService;
|
|---|
| | |
|
|---|
| | | // 下级被封禁，红包失效
|
|---|
| | | private void invalidHongBaoForbidden(Long id) {
|
|---|
| | |
|---|
| | | Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.orderFanLiActual, mqMsg);
|
|---|
| | | String taskKey = getTaskKey(uid);
|
|---|
| | | msg.setKey(taskKey);
|
|---|
| | | |
|---|
| | | // 添加事务消息
|
|---|
| | | try {
|
|---|
| | | orderTransactionProducer.send(msg, new LocalTransactionExecuter() {
|
|---|
