From 628e93c0fac7df60b68d9499d01986bf31a83f22 Mon Sep 17 00:00:00 2001
From: yujt <work@yujt.net.cn>
Date: Thu, 4 Jun 2020 14:37:54 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4=E6=97=A0=E7=94=A8=E7=B1=BB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../esua/epdc/config/RedisMessageConfig.java  | 41 ----------------
 .../SentryPostUserInfoRedisListener.java      | 47 -------------------
 2 files changed, 88 deletions(-)
 delete mode 100644 epdc-cloud-api/src/main/java/com/elink/esua/epdc/config/RedisMessageConfig.java
 delete mode 100644 epdc-cloud-api/src/main/java/com/elink/esua/epdc/listener/SentryPostUserInfoRedisListener.java

diff --git a/epdc-cloud-api/src/main/java/com/elink/esua/epdc/config/RedisMessageConfig.java b/epdc-cloud-api/src/main/java/com/elink/esua/epdc/config/RedisMessageConfig.java
deleted file mode 100644
index b455162..0000000
--- a/epdc-cloud-api/src/main/java/com/elink/esua/epdc/config/RedisMessageConfig.java
+++ /dev/null
@@ -1,41 +0,0 @@
-package com.elink.esua.epdc.config;
-
-import com.elink.esua.epdc.commons.tools.redis.RedisChannels;
-import com.elink.esua.epdc.listener.SentryPostUserInfoRedisListener;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.context.annotation.Bean;
-import org.springframework.data.redis.connection.RedisConnectionFactory;
-import org.springframework.data.redis.listener.PatternTopic;
-import org.springframework.data.redis.listener.RedisMessageListenerContainer;
-import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;
-import org.springframework.stereotype.Component;
-
-/**
- * @author work@yujt.net.cn
- * @date 1 1
- */
-@Component
-public class RedisMessageConfig {
-
-    @Autowired
-    private RedisConnectionFactory factory;
-
-    @Autowired
-    private SentryPostUserInfoRedisListener sentryPostUserInfoRedisListener;
-
-    @Bean
-    MessageListenerAdapter sentryPostUserInfoAdapter() {
-        return new MessageListenerAdapter(sentryPostUserInfoRedisListener);
-    }
-
-
-    @Bean
-    RedisMessageListenerContainer container() {
-        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
-        container.setConnectionFactory(factory);
-        container.addMessageListener(sentryPostUserInfoAdapter(), new PatternTopic(RedisChannels.COMPLETE_INFO_BY_SENTRY_POST));
-        return container;
-    }
-
-
-}
diff --git a/epdc-cloud-api/src/main/java/com/elink/esua/epdc/listener/SentryPostUserInfoRedisListener.java b/epdc-cloud-api/src/main/java/com/elink/esua/epdc/listener/SentryPostUserInfoRedisListener.java
deleted file mode 100644
index 4c09a96..0000000
--- a/epdc-cloud-api/src/main/java/com/elink/esua/epdc/listener/SentryPostUserInfoRedisListener.java
+++ /dev/null
@@ -1,47 +0,0 @@
-package com.elink.esua.epdc.listener;
-
-import com.alibaba.fastjson.JSONObject;
-import com.elink.esua.epdc.commons.tools.utils.Result;
-import com.elink.esua.epdc.dto.EpidemicSentryPostDTO;
-import com.elink.esua.epdc.dto.epdc.form.EpdcAppPidemicCompleteInfoFromDTO;
-import com.elink.esua.epdc.feign.CustomFeignClient;
-import com.elink.esua.epdc.feign.UserFeignClient;
-import com.elink.esua.epdc.service.CustomService;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.lang3.StringUtils;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.data.redis.connection.Message;
-import org.springframework.data.redis.connection.MessageListener;
-import org.springframework.stereotype.Service;
-
-/**
- * 处理防疫哨卡提交的用户信息
- *
- * @author work@yujt.net.cn
- * @date 2020/2/16 16:49
- */
-@Slf4j
-@Service
-public class SentryPostUserInfoRedisListener implements MessageListener {
-
-    @Autowired
-    private CustomService customService;
-
-    @Override
-    public void onMessage(Message message, byte[] pattern) {
-
-        if (StringUtils.isBlank(message.toString())) {
-            return;
-        }
-        try {
-            EpdcAppPidemicCompleteInfoFromDTO completeInfoDto = JSONObject.parseObject(message.toString(), EpdcAppPidemicCompleteInfoFromDTO.class);
-
-            customService.completeSentryPostUserInfo(completeInfoDto);
-
-        } catch (Exception e) {
-            log.error("处理哨卡登记信息失败");
-        }
-    }
-
-
-}