外显等级

admin

2020-04-23 bb0d73a8de96fbaab9cf02312be96f30f972651c

 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/order/OrderDividentsMessageListener.java

@@ -27,7 +27,6 @@
import com.yeshi.fanli.exception.order.dividents.TeamDividentsSourceOrderException;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.order.CommonOrderService;

import com.yeshi.fanli.service.inter.order.dividents.TeamDividentsSourceOrderService;

import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;

import com.yeshi.fanli.service.inter.user.vip.TeamUserLevelStatisticService;

import com.yeshi.fanli.service.manger.order.TeamDividentsManager;

@@ -42,9 +41,6 @@
 */

@Component

public class OrderDividentsMessageListener implements MessageListener {



   @Resource

   private TeamDividentsSourceOrderService teamDividentsSourceOrderService;



   @Resource

   private CommonOrderService commonOrderService;

@@ -76,7 +72,7 @@
            // 查询上级红包

            UserForbiddenMQMsg dto = new Gson().fromJson(new String(message.getBody()), UserForbiddenMQMsg.class);

            if (dto != null) {

               teamDividentsSourceOrderService.invalidOrderByUid(dto.getUid(), "用户被封禁");

               teamDividentsSourceManager.invalidBySourceUid(dto.getUid(), "用户被封禁");

               return Action.CommitMessage;

            }

         }