系统区分BUG修复

admin

2020-07-14 eec7e789a87863c25d92c10ad5dfc22ad80c448d

 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/InvitePictureChangeMessageListener.java

@@ -2,6 +2,10 @@


import javax.annotation.Resource;



import com.yeshi.fanli.entity.SystemEnum;

import com.yeshi.fanli.entity.SystemFunction;

import com.yeshi.fanli.service.inter.user.UserInfoService;

import com.yeshi.fanli.util.SystemInfoUtil;

import org.springframework.stereotype.Component;



import com.aliyun.openservices.ons.api.Action;

@@ -28,6 +32,8 @@


   @Resource

   private SpreadUserImgService spreadUserImgService;

   @Resource

   private UserInfoService userInfoService;



   @Override

   public Action consume(Message message, ConsumeContext context) {

@@ -41,20 +47,37 @@
         if (tag.equalsIgnoreCase(UserTopicTagEnum.inviteCodeActive.name())) {// 邀请码激活

            InviteCodeActiveMQMsg inviteCodeActiveMQMsg = new Gson().fromJson(new String(message.getBody()),

                  InviteCodeActiveMQMsg.class);



            //是否有三级分销权限

            SystemEnum system = userInfoService.getUserSystem(inviteCodeActiveMQMsg.getUid());

            if (!SystemInfoUtil.hasFunctions(system, SystemFunction.threeSale))

               return Action.CommitMessage;



            if (inviteCodeActiveMQMsg != null && inviteCodeActiveMQMsg.getUid() != null)

               spreadUserImgService.deleteImgUrl(inviteCodeActiveMQMsg.getUid());



            return Action.CommitMessage;

         } else if (tag.equalsIgnoreCase(UserTopicTagEnum.userInfoUpdate.name())) {// 订单统计

            UserInfoUpdateMQMsg userInfoUpdateMQMsg = new Gson().fromJson(new String(message.getBody()),

                  UserInfoUpdateMQMsg.class);

            if (userInfoUpdateMQMsg != null && (userInfoUpdateMQMsg.getType() == UserInfoUpdateTypeEnum.portrait

                  || userInfoUpdateMQMsg.getType() == UserInfoUpdateTypeEnum.inviteCode)) {

               if (userInfoUpdateMQMsg.getUid() != null)

                  spreadUserImgService.deleteImgUrl(userInfoUpdateMQMsg.getUid());

         } else if (tag.equalsIgnoreCase(UserTopicTagEnum.userInfoUpdate.name())) {// 用户信息更新



            try {

               UserInfoUpdateMQMsg userInfoUpdateMQMsg = new Gson().fromJson(new String(message.getBody()),

                     UserInfoUpdateMQMsg.class);



               //是否有三级分销权限

               SystemEnum system = userInfoService.getUserSystem(userInfoUpdateMQMsg.getUid());

               if (!SystemInfoUtil.hasFunctions(system, SystemFunction.threeSale))

                  return Action.CommitMessage;



               if (userInfoUpdateMQMsg != null && (userInfoUpdateMQMsg.getType() == UserInfoUpdateTypeEnum.portrait

                     || userInfoUpdateMQMsg.getType() == UserInfoUpdateTypeEnum.inviteCode)) {

                  if (userInfoUpdateMQMsg.getUid() != null)

                     spreadUserImgService.deleteImgUrl(userInfoUpdateMQMsg.getUid());

               }

               return Action.CommitMessage;

            } catch (Exception e) {

               LogHelper.errorDetailInfo(e, "msgId:" + message.getMsgID(), "");

            }



            return Action.CommitMessage;

         }

      }

      return Action.CommitMessage;