clean

ibzou-core/src/main/java/cn/ibizlab/core/util/config/RocketMQListenerProcessor.java

-package cn.ibizlab.core.util.config;
-
-import lombok.extern.slf4j.Slf4j;
-import com.alibaba.fastjson.JSON;
-import org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyContext;
-import org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyStatus;
-import org.apache.rocketmq.client.consumer.listener.MessageListenerOrderly;
-import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
-import org.apache.rocketmq.common.message.MessageExt;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.context.annotation.Lazy;
-import org.springframework.stereotype.Component;
-import org.springframework.util.CollectionUtils;
-import java.util.List;
-
-/**
- * MQ订阅消息处理
- */
-@Slf4j
-@Component
-@ConditionalOnExpression("${ibiz.rocketmq.producer.isOnOff:'off'}.equals('on')")
-public class RocketMQListenerProcessor implements MessageListenerOrderly {
-
-    @Autowired
-    @Lazy
-    cn.ibizlab.core.ou.service.ISysDeptMemberService SysDeptMemberService;
-
-    @Override
-    public ConsumeOrderlyStatus consumeMessage(List<MessageExt> list, ConsumeOrderlyContext consumeOrderlyContext) {
-        if (CollectionUtils.isEmpty(list)) {
-            log.info("MQ接收消息为空，直接返回成功");
-            return ConsumeOrderlyStatus.SUCCESS;
-        }
-        for (MessageExt messageExt : list) {
-            log.info("MQ接收到的消息为：" + messageExt.toString());
-            try {
-                String topic = messageExt.getTopic();
-                String tags = messageExt.getTags();
-                String body = new String(messageExt.getBody(), "utf-8");
-                log.info("MQ消息topic={}, tags={}, 消息内容={}", topic, tags, body);
-                if ("savesysuser".equalsIgnoreCase(tags)) {
-                    cn.ibizlab.core.ou.domain.SysDeptMember domain = JSON.parseObject(new String(body),cn.ibizlab.core.ou.domain.SysDeptMember.class);
-                    SysDeptMemberService.saveDeptMember(domain);
-                }
-            } catch (Exception e) {
-                log.error("获取MQ消息内容异常{}", e);
-            }
-
-        }
-        return ConsumeOrderlyStatus.SUCCESS;
-    }
-}