| | |
|---|
| | | import com.yeshi.fanli.entity.order.HongBaoOrder;
|
|---|
| | | import com.yeshi.fanli.entity.order.HongBaoV2SettleTemp;
|
|---|
| | | import com.yeshi.fanli.entity.order.InviteOrderSubsidy;
|
|---|
| | | import com.yeshi.fanli.entity.taobao.TaoBaoOrder;
|
|---|
| | | import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder;
|
|---|
| | | import com.yeshi.fanli.exception.money.InviteOrderSubsidyDebtException;
|
|---|
| | | import com.yeshi.fanli.exception.money.OrderMoneySettleException;
|
|---|
| | |
|---|
| | | import com.yeshi.fanli.util.factory.UserMoneyDetailFactory;
|
|---|
| | | import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;
|
|---|
| | | import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
|---|
| | | import com.yeshi.fanli.util.taobao.TaoKeOrderApiUtil;
|
|---|
| | |
|
|---|
| | | @Service
|
|---|
| | | public class OrderMoneySettleServiceImpl implements OrderMoneySettleService {
|
|---|
| | |
|---|
| | | @Resource
|
|---|
| | | private HongBaoV2SettleTempService hongBaoV2SettleTempService;
|
|---|
| | |
|
|---|
| | | //下级被封禁，红包失效
|
|---|
| | | // 下级被封禁，红包失效
|
|---|
| | | private void invalidHongBaoForbidden(Long id) {
|
|---|
| | | HongBaoV2 updateHongBaoV2 = new HongBaoV2(id);
|
|---|
| | | updateHongBaoV2.setState(HongBaoV2.STATE_SHIXIAO);
|
|---|
| | |
|---|
| | | Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.orderFanLiActual, mqMsg);
|
|---|
| | | String taskKey = getTaskKey(uid);
|
|---|
| | | msg.setKey(taskKey);
|
|---|
| | | |
|---|
| | | // 添加事务消息
|
|---|
| | | try {
|
|---|
| | | orderTransactionProducer.send(msg, new LocalTransactionExecuter() {
|
|---|
| | |
|---|
| | | }
|
|---|
| | | return debtMoney;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | }
|
|---|
