淘宝转链接口更新

admin

2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe

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

@@ -1,58 +1,54 @@
package com.yeshi.fanli.util.rocketmq.consumer.user;



import javax.annotation.Resource;



import org.springframework.stereotype.Component;



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

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

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;



/**

 * 用户云发单

 * 
 * @author Administrator

 *

 */

@Component

public class UserCloudMessageListener implements MessageListener {



   @Resource

   private UserCloudService userCloudService;



   @Override

   public Action consume(Message message, ConsumeContext context) {

      LogHelper.mqInfo("consumer-UserCloudMessageListener", message.getMsgID(), message.getTopic(), message.getTag(),

            new String(message.getBody()));

      String tag = message.getTag();

      if (tag == null)

         tag = "";

      if (MQTopicName.TOPIC_USER.name().equalsIgnoreCase(message.getTopic())) {

         if (tag.equalsIgnoreCase(UserTopicTagEnum.userCloud.name())) {

            UserCloudMQMsg msg = new Gson().fromJson(new String(message.getBody()),UserCloudMQMsg.class);

            if (msg.getType() == UserCloudMQMsg.TYPE_EVALUATE) {

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

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

            } else {

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

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

            }

         }	 
      }

      return Action.CommitMessage;

   }

}

package com.yeshi.fanli.util.rocketmq.consumer.user;

import javax.annotation.Resource;

import org.springframework.stereotype.Component;

import com.aliyun.openservices.ons.api.Action;
import com.aliyun.openservices.ons.api.ConsumeContext;
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.user.UserTopicTagEnum;
import com.yeshi.fanli.dto.mq.user.body.UserCloudMQMsg;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.user.cloud.UserCloudService;
import com.yeshi.fanli.util.rocketmq.MQTopicName;

/**
 * 用户云发单
 * 
 * @author Administrator
 *
 */
@Component
public class UserCloudMessageListener implements MessageListener {

   @Resource
   private UserCloudService userCloudService;

   @Override
   public Action consume(Message message, ConsumeContext context) {
      LogHelper.mqInfo("consumer-UserCloudMessageListener", message.getMsgID(), message.getTopic(), message.getTag(),
            new String(message.getBody()));
      String tag = message.getTag();
      if (tag == null)
         tag = "";
      if (MQTopicName.TOPIC_USER.name().equalsIgnoreCase(message.getTopic())) {
         if (tag.equalsIgnoreCase(UserTopicTagEnum.userCloud.name())) {
            UserCloudMQMsg msg = new Gson().fromJson(new String(message.getBody()),UserCloudMQMsg.class);
            if (msg.getType() == UserCloudMQMsg.TYPE_EVALUATE) {
               LogHelper.cloudInfo("发圈中信息 -" + msg.getId()  );
               userCloudService.autoSendByDynamic(msg.getUid(), msg.getId());
            } 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());
            }
         }	 
      }
      return Action.CommitMessage;
   }
}