修改 各个项目 impl 消费添加方法

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/utils/QueueUtils.java

@@ -24,6 +24,6 @@ public class QueueUtils {
     public void sendMsgByRedis(String streamKey, String jsonMsg) {
         HashMap<String, String> map = CollectionUtil.mapStringString();
         map.put(MQConst.QUEUE_MESSAGE_KEY, jsonMsg);
-        redisDataSourceUtil.getRedisKylinUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
+        redisDataSourceUtil.getRedisQueueUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
     }
 }

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/util/QueueUtils.java

 package com.liquidnet.service.adam.util;
 
+import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
 import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -12,10 +13,10 @@ import java.util.HashMap;
 @Component
 public class QueueUtils {
 
-//    @Autowired
+    //    @Autowired
 //    private RabbitTemplate rabbitTemplate;
     @Autowired
-    StringRedisTemplate stringRedisTemplate;
+    RedisDataSourceUtil redisDataSourceUtil;
 
     /**
      * 发送消息 - RABBIT
@@ -37,6 +38,6 @@ public class QueueUtils {
     public void sendMsgByRedis(String streamKey, String jsonMsg) {
         HashMap<String, String> map = CollectionUtil.mapStringString();
         map.put(MQConst.QUEUE_MESSAGE_KEY, jsonMsg);
-        stringRedisTemplate.opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
+        redisDataSourceUtil.getRedisQueueUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
     }
 }

liquidnet-bus-service/liquidnet-service-candy/liquidnet-service-candy-impl/src/main/java/com/liquidnet/service/candy/util/QueueUtils.java

 package com.liquidnet.service.candy.util;
 
+import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
 import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -13,7 +14,7 @@ import java.util.HashMap;
 public class QueueUtils {
 
     @Autowired
-    StringRedisTemplate stringRedisTemplate;
+    RedisDataSourceUtil redisDataSourceUtil;
 
     /**
      * 发送消息 - REDIS
@@ -24,6 +25,6 @@ public class QueueUtils {
     public void sendMsgByRedis(String streamKey, String jsonMsg) {
         HashMap<String, String> map = CollectionUtil.mapStringString();
         map.put(MQConst.QUEUE_MESSAGE_KEY, jsonMsg);
-        stringRedisTemplate.opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
+        redisDataSourceUtil.getRedisQueueUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
     }
 }

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/utils/MqHandleUtil.java

 package com.liquidnet.service.dragon.utils;
 
+import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
 import com.liquidnet.service.base.SqlMapping;
 import com.liquidnet.service.dragon.bo.PayNotifyReqBo;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -23,7 +24,7 @@ import java.util.LinkedList;
 @Component
 public class MqHandleUtil {
     @Autowired
-    StringRedisTemplate stringRedisTemplate;
+    RedisDataSourceUtil redisDataSourceUtil;
 
     /**
      * REDIS 队列发送消息 通知商户相关
@@ -35,7 +36,7 @@ public class MqHandleUtil {
             HashMap<String, String> map = ObjectUtil.cloneHashMapStringAndString();
             map.put("message", payNotifyReqBo.toString());
             MapRecord<String, String, String> record = StreamRecords.mapBacked(map).withStreamKey(queueKey);
-            stringRedisTemplate.opsForStream().add(record);
+            redisDataSourceUtil.getRedisQueueUtil().getStringRedisTemplate().opsForStream().add(record);
             return true;
         } catch (Exception e) {
             e.printStackTrace();
@@ -61,7 +62,7 @@ public class MqHandleUtil {
             HashMap<String, String> map = ObjectUtil.cloneHashMapStringAndString();
             map.put("message", sqlData);
             MapRecord<String, String, String> record = StreamRecords.mapBacked(map).withStreamKey(redisKey);
-            stringRedisTemplate.opsForStream().add(record);
+            redisDataSourceUtil.getRedisQueueUtil().getStringRedisTemplate().opsForStream().add(record);
             return true;
         } catch (Exception e) {
             e.printStackTrace();

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/utils/QueueUtils.java

 package com.liquidnet.service.kylin.utils;
 
+import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
 import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.service.base.SqlMapping;
 import com.liquidnet.service.base.constant.MQConst;
@@ -15,10 +16,10 @@ import java.util.HashMap;
 @Component
 public class QueueUtils {
 
-//    @Autowired
+    //    @Autowired
 //    private RabbitTemplate rabbitTemplate;
     @Autowired
-    StringRedisTemplate stringRedisTemplate;
+    RedisDataSourceUtil redisDataSourceUtil;
     @Autowired
     DataUtils dataUtils;
 
@@ -42,7 +43,7 @@ public class QueueUtils {
     public void sendMsgByRedis(String streamKey, String jsonMsg) {
         HashMap<String, String> map = CollectionUtil.mapStringString();
         map.put(MQConst.QUEUE_MESSAGE_KEY, jsonMsg);
-        stringRedisTemplate.opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
+        redisDataSourceUtil.getRedisQueueUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
     }
 
     public void pushPvUv(String uid, String accessType, String performanceId, String orderId, String orderCode, String ipAddress) {

liquidnet-bus-service/liquidnet-service-notify/liquidnet-service-notify-impl/src/main/java/com/liquidnet/service/dragon/utils/MqHandleUtil.java

 package com.liquidnet.service.dragon.utils;
 
+import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
 import com.liquidnet.service.base.SqlMapping;
 import com.liquidnet.service.dragon.bo.PayNotifyReqBo;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -23,7 +24,7 @@ import java.util.LinkedList;
 @Component
 public class MqHandleUtil {
     @Autowired
-    StringRedisTemplate stringRedisTemplate;
+    RedisDataSourceUtil redisDataSourceUtil;
 
     /**
      * REDIS 队列发送消息 通知商户相关
@@ -35,7 +36,7 @@ public class MqHandleUtil {
             HashMap<String, String> map = ObjectUtil.cloneHashMapStringAndString();
             map.put("message", payNotifyReqBo.toString());
             MapRecord<String, String, String> record = StreamRecords.mapBacked(map).withStreamKey(queueKey);
-            stringRedisTemplate.opsForStream().add(record);
+            redisDataSourceUtil.getRedisQueueUtil().getStringRedisTemplate().opsForStream().add(record);
             return true;
         } catch (Exception e) {
             e.printStackTrace();
@@ -61,7 +62,7 @@ public class MqHandleUtil {
             HashMap<String, String> map = ObjectUtil.cloneHashMapStringAndString();
             map.put("message", sqlData);
             MapRecord<String, String, String> record = StreamRecords.mapBacked(map).withStreamKey(redisKey);
-            stringRedisTemplate.opsForStream().add(record);
+            redisDataSourceUtil.getRedisQueueUtil().getStringRedisTemplate().opsForStream().add(record);
             return true;
         } catch (Exception e) {
             e.printStackTrace();

liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/utils/QueueUtils.java

 package com.liquidnet.service.order.utils;
 
+import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
 import com.liquidnet.service.base.SqlMapping;
 import com.liquidnet.service.base.constant.MQConst;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinIpAreaVo;
@@ -17,7 +18,7 @@ public class QueueUtils {
     //    @Autowired
 //    private RabbitTemplate rabbitTemplate;
     @Autowired
-    StringRedisTemplate stringRedisTemplate;
+    RedisDataSourceUtil redisDataSourceUtil;
     @Autowired
     DataUtils dataUtils;
 
@@ -41,7 +42,7 @@ public class QueueUtils {
     public void sendMsgByRedis(String streamKey, String jsonMsg) {
         HashMap<String, String> map = ObjectUtil.cloneHashMapStringAndString();
         map.put(MQConst.QUEUE_MESSAGE_KEY, jsonMsg);
-        stringRedisTemplate.opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
+        redisDataSourceUtil.getRedisQueueUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
     }
 
 
@@ -90,7 +91,7 @@ public class QueueUtils {
         map.put("id", masterOrderCode);
         map.put("type", type);
         map.put("time", createTime.toString());
-        stringRedisTemplate.opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
+        redisDataSourceUtil.getRedisQueueUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
     }
 
     public void pushPvUv(String uid, String accessType, String performanceId, String orderId, String orderCode, String ipAddress) {

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/utils/QueueUtils.java

@@ -39,7 +39,7 @@ public class QueueUtils {
     public void sendMsgByRedis(String streamKey, String jsonMsg) {
         HashMap<String, String> map = CollectionUtil.mapStringString();
         map.put(MQConst.QUEUE_MESSAGE_KEY, jsonMsg);
-        redisDataSourceUtil.getRedisKylinUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
+        redisDataSourceUtil.getRedisQueueUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
     }
 
     /**
@@ -51,7 +51,7 @@ public class QueueUtils {
     public void sendMsgByCandyRedis(String streamKey, String jsonMsg) {
         HashMap<String, String> map = CollectionUtil.mapStringString();
         map.put(MQConst.QUEUE_MESSAGE_KEY, jsonMsg);
-        redisDataSourceUtil.getRedisCandyUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
+        redisDataSourceUtil.getRedisQueueUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
     }
 
     /**
@@ -63,7 +63,7 @@ public class QueueUtils {
     public void sendMsgByGoblinRedis(String streamKey, String jsonMsg) {
         HashMap<String, String> map = CollectionUtil.mapStringString();
         map.put(MQConst.QUEUE_MESSAGE_KEY, jsonMsg);
-        redisDataSourceUtil.getRedisGoblinUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
+        redisDataSourceUtil.getRedisQueueUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
     }
 
     /**
@@ -72,7 +72,7 @@ public class QueueUtils {
      * @param
      */
     public void sendMssPhoneCodeRedis(Map<String,String> map) {
-        redisDataSourceUtil.getRedisGoblinUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(MQConst.GoblinQueue.GOBLIN_PHONE_CODE_OPERA.getKey()));
+        redisDataSourceUtil.getRedisQueueUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(MQConst.GoblinQueue.GOBLIN_PHONE_CODE_OPERA.getKey()));
     }
 
 }

liquidnet-bus-service/liquidnet-service-slime/liquidnet-service-slime-impl/src/main/java/com/liquidnet/service/slime/util/QueueUtil.java

 package com.liquidnet.service.slime.util;
 
+import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
 import com.liquidnet.commons.lang.util.CollectionUtil;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.connection.stream.StreamRecords;
@@ -11,7 +12,7 @@ import java.util.HashMap;
 @Component
 public class QueueUtil {
     @Autowired
-    StringRedisTemplate stringRedisTemplate;
+    RedisDataSourceUtil redisDataSourceUtil;
 
     /**
      * 发送消息 - REDIS
@@ -22,6 +23,6 @@ public class QueueUtil {
     public void sendMsgByRedis(String streamKey, String jsonMsg) {
         HashMap<String, String> map = CollectionUtil.mapStringString();
         map.put("message", jsonMsg);
-        stringRedisTemplate.opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
+        redisDataSourceUtil.getRedisQueueUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
     }
 }

liquidnet-bus-service/liquidnet-service-smile/liquidnet-service-smile-impl/src/main/java/com/liquidnet/service/util/QueueUtils.java

 package com.liquidnet.service.util;
 
+import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
 import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -15,7 +16,7 @@ public class QueueUtils {
     //    @Autowired
 //    private RabbitTemplate rabbitTemplate;
     @Autowired
-    StringRedisTemplate stringRedisTemplate;
+    RedisDataSourceUtil redisDataSourceUtil;
 
     /**
      * 发送消息 - RABBIT
@@ -37,7 +38,7 @@ public class QueueUtils {
     public void sendMsgByRedis(String streamKey, String jsonMsg) {
         HashMap<String, String> map = CollectionUtil.mapStringString();
         map.put(MQConst.QUEUE_MESSAGE_KEY, jsonMsg);
-        stringRedisTemplate.opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
+        redisDataSourceUtil.getRedisQueueUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
     }
 
     /**
@@ -55,7 +56,7 @@ public class QueueUtils {
             map.put(MQConst.QUEUE_MESSAGE_KEY, xlsPath);
             map.put("type", type);
             map.put("skuId", skuId);
-            stringRedisTemplate.opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(MQConst.GoblinQueue.GOBLIN_XLS_OPERA.getKey()));
+            redisDataSourceUtil.getRedisQueueUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(MQConst.GoblinQueue.GOBLIN_XLS_OPERA.getKey()));
         }
     }
 }

liquidnet-bus-service/liquidnet-service-stone/liquidnet-service-stone-impl/src/main/java/com/liquidnet/service/stone/util/QueueUtils.java

 package com.liquidnet.service.stone.util;
 
+import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
 import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -15,7 +16,7 @@ public class QueueUtils {
 //    @Autowired
 //    private RabbitTemplate rabbitTemplate;
     @Autowired
-    StringRedisTemplate stringRedisTemplate;
+RedisDataSourceUtil redisDataSourceUtil;
 
     /**
      * 发送消息 - RABBIT
@@ -37,6 +38,6 @@ public class QueueUtils {
     public void sendMsgByRedis(String streamKey, String jsonMsg) {
         HashMap<String, String> map = CollectionUtil.mapStringString();
         map.put(MQConst.QUEUE_MESSAGE_KEY, jsonMsg);
-        stringRedisTemplate.opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
+        redisDataSourceUtil.getRedisQueueUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
     }
 }

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/utils/QueueUtils.java

 package com.liquidnet.service.sweet.utils;
 
+import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
 import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -12,10 +13,10 @@ import java.util.HashMap;
 @Component
 public class QueueUtils {
 
-//    @Autowired
+    //    @Autowired
 //    private RabbitTemplate rabbitTemplate;
     @Autowired
-    StringRedisTemplate stringRedisTemplate;
+    RedisDataSourceUtil redisDataSourceUtil;
 
 //    /**
 //     * 发送消息 - RABBIT
@@ -37,6 +38,6 @@ public class QueueUtils {
     public void sendMsgByRedis(String streamKey, String jsonMsg) {
         HashMap<String, String> map = CollectionUtil.mapStringString();
         map.put(MQConst.QUEUE_MESSAGE_KEY, jsonMsg);
-        stringRedisTemplate.opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
+        redisDataSourceUtil.getRedisQueueUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
     }
 }