修改 热卖改回老逻辑，修改 dragon消费

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/controller/KylinPerformancesController.java

@@ -85,8 +85,8 @@ public class KylinPerformancesController {
             @ApiImplicitParam(type = "query", dataType = "Integer", name = "type", value = "type为1的时候合并巡演")
     })
     public ResponseDto<HashMap<String, Object>> noticeList(@RequestParam(defaultValue = "") Integer type) {
-        HashMap<String, Object> result = kylinPerformancesService.noticeList(type);
-//        HashMap<String, Object> result = kylinPerformancesService.noticeListOld(type);
+//        HashMap<String, Object> result = kylinPerformancesService.noticeList(type);
+        HashMap<String, Object> result = kylinPerformancesService.noticeListOld(type);
         return ResponseDto.success(result);
     }
 

liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-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 = ObjectUtilDragon.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 = ObjectUtilDragon.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();