系统区分BUG修复

admin

2020-07-14 eec7e789a87863c25d92c10ad5dfc22ad80c448d

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

@@ -9,17 +9,10 @@
import com.aliyun.openservices.ons.api.Message;

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

import com.google.gson.Gson;

import com.yeshi.fanli.dto.mq.order.OrderTopicTagEnum;

import com.yeshi.fanli.dto.mq.order.body.OrderConfirmMQMsg;

import com.yeshi.fanli.dto.mq.order.body.OrderMoneyRecievedMQMsg;

import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;

import com.yeshi.fanli.dto.mq.user.body.UserCloudMQMsg;

import com.yeshi.fanli.entity.bus.user.UserActiveLog;

import com.yeshi.fanli.entity.bus.user.UserInfo;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.user.cloud.UserCloudService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.VersionUtil;

import com.yeshi.fanli.util.rocketmq.MQTopicName;



/**

@@ -47,9 +40,12 @@
            if (msg.getType() == UserCloudMQMsg.TYPE_EVALUATE) {

               LogHelper.cloudInfo("发圈中信息 -" + msg.getId()  );

               userCloudService.autoSendByDynamic(msg.getUid(), msg.getId());

            } else {

            } else if (msg.getType() == UserCloudMQMsg.TYPE_STORE) {

               LogHelper.cloudInfo("选品库信息 -" + msg.getId()  );

               userCloudService.autoSendCustomGoods(msg.getUid(), Long.parseLong(msg.getId()));

            } else if (msg.getType() == UserCloudMQMsg.TYPE_PUSH) {

               LogHelper.cloudInfo("站内信息 -" + msg.getId()  );

               userCloudService.offlineNotificationZNX(msg.getUid());

            }

         }    

      }