| | |
|---|
| | | import com.yeshi.fanli.service.inter.hongbao.HongBaoV2SettleTempService;
|
|---|
| | | import com.yeshi.fanli.service.inter.order.CommonOrderService;
|
|---|
| | | import com.yeshi.fanli.service.inter.order.HongBaoOrderService;
|
|---|
| | | import com.yeshi.fanli.service.inter.order.InviteOrderSubsidyService;
|
|---|
| | | import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
|---|
| | |
|
|---|
| | | @Component
|
|---|
| | |
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private HongBaoV2SettleTempService hongBaoV2SettleTempService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private InviteOrderSubsidyService inviteOrderSubsidyService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private CommonOrderService commonOrderService;
|
|---|
| | |
|---|
| | |
|
|---|
| | | String tag = msg.getTag();
|
|---|
| | | if (msg.getTopic().equalsIgnoreCase(MQTopicName.TOPIC_ORDER.name())) {
|
|---|
| | |
|
|---|
| | | if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderStatistic.name())) {
|
|---|
| | | // TODO 加入成功标识
|
|---|
| | | return TransactionStatus.CommitTransaction;
|
|---|
| | | } else if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiActual.name())) {
|
|---|
| | | if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiActual.name())) {
|
|---|
| | | if (hongBaoV2SettleTempService.countByKey(msg.getKey()) > 0)
|
|---|
| | | return TransactionStatus.CommitTransaction;
|
|---|
| | | else
|
|---|
