nft修改消费相关代码

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerJsonNftPublishAndBuyConfig.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerGalaxyJsonNftPublishAndBuyConfig.java

@@ -2,7 +2,7 @@ package com.liquidnet.service.consumer.kylin.config;
 
 import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
 import com.liquidnet.service.base.constant.MQConst;
-import com.liquidnet.service.consumer.kylin.receiver.JsonRedisJsonNftPublishAndBuyReceiver;
+import com.liquidnet.service.consumer.kylin.receiver.ConsumerGalaxyJsonNftPublishAndBuyReceiver;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -28,9 +28,9 @@ import java.util.List;
  * @date 2022/3/25 14:45
  */
 @Configuration
-public class ConsumerJsonNftPublishAndBuyConfig extends RedisStreamConfig {
+public class ConsumerGalaxyJsonNftPublishAndBuyConfig extends RedisStreamConfig {
     @Autowired
-    private JsonRedisJsonNftPublishAndBuyReceiver jsonNftPublishAndBuyReceiver;
+    private ConsumerGalaxyJsonNftPublishAndBuyReceiver jsonNftPublishAndBuyReceiver;
 
     @Autowired
     StringRedisTemplate stringRedisTemplate;

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerSqlNftOrderInfoConfig.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerGalaxySqlNftOrderInfoConfig.java

@@ -2,7 +2,7 @@ package com.liquidnet.service.consumer.kylin.config;
 
 import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
 import com.liquidnet.service.base.constant.MQConst;
-import com.liquidnet.service.consumer.kylin.receiver.SqlRedisSqlSeriesInfoReceiver;
+import com.liquidnet.service.consumer.kylin.receiver.ConsumerGalaxySqlSeriesInfoReceiver;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -28,9 +28,9 @@ import java.util.List;
  * @date 2022/3/25 14:45
  */
 @Configuration
-public class ConsumerSqlNftOrderInfoConfig extends RedisStreamConfig {
+public class ConsumerGalaxySqlNftOrderInfoConfig extends RedisStreamConfig {
     @Autowired
-    private SqlRedisSqlSeriesInfoReceiver sqlSeriesInfoReceiver;
+    private ConsumerGalaxySqlSeriesInfoReceiver sqlSeriesInfoReceiver;
 
     @Autowired
     StringRedisTemplate stringRedisTemplate;

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerSqlNftTradeInfoConfig.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerGalaxySqlNftTradeInfoConfig.java

@@ -2,7 +2,7 @@ package com.liquidnet.service.consumer.kylin.config;
 
 import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
 import com.liquidnet.service.base.constant.MQConst;
-import com.liquidnet.service.consumer.kylin.receiver.SqlRedisSqlSeriesInfoReceiver;
+import com.liquidnet.service.consumer.kylin.receiver.ConsumerGalaxySqlSeriesInfoReceiver;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -28,9 +28,9 @@ import java.util.List;
  * @date 2022/3/25 14:45
  */
 @Configuration
-public class ConsumerSqlNftTradeInfoConfig extends RedisStreamConfig {
+public class ConsumerGalaxySqlNftTradeInfoConfig extends RedisStreamConfig {
     @Autowired
-    private SqlRedisSqlSeriesInfoReceiver sqlSeriesInfoReceiver;
+    private ConsumerGalaxySqlSeriesInfoReceiver sqlSeriesInfoReceiver;
 
     @Autowired
     StringRedisTemplate stringRedisTemplate;

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerSqlSeriesInfoConfig.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerGalaxySqlSeriesInfoConfig.java

@@ -2,7 +2,7 @@ package com.liquidnet.service.consumer.kylin.config;
 
 import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
 import com.liquidnet.service.base.constant.MQConst;
-import com.liquidnet.service.consumer.kylin.receiver.SqlRedisSqlSeriesInfoReceiver;
+import com.liquidnet.service.consumer.kylin.receiver.ConsumerGalaxySqlSeriesInfoReceiver;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -28,9 +28,9 @@ import java.util.List;
  * @date 2022/3/25 14:45
  */
 @Configuration
-public class ConsumerSqlSeriesInfoConfig extends RedisStreamConfig {
+public class ConsumerGalaxySqlSeriesInfoConfig extends RedisStreamConfig {
     @Autowired
-    private SqlRedisSqlSeriesInfoReceiver sqlSeriesInfoReceiver;
+    private ConsumerGalaxySqlSeriesInfoReceiver sqlSeriesInfoReceiver;
 
     @Autowired
     StringRedisTemplate stringRedisTemplate;

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerSqlUserInfoConfig.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerGalaxySqlUserInfoConfig.java

@@ -2,7 +2,7 @@ package com.liquidnet.service.consumer.kylin.config;
 
 import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
 import com.liquidnet.service.base.constant.MQConst;
-import com.liquidnet.service.consumer.kylin.receiver.SqlRedisSqlUserInfoReceiver;
+import com.liquidnet.service.consumer.kylin.receiver.ConsumerGalaxySqlUserInfoReceiver;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -28,9 +28,9 @@ import java.util.List;
  * @date 2022/3/22 14:45
  */
 @Configuration
-public class ConsumerSqlUserInfoConfig extends RedisStreamConfig {
+public class ConsumerGalaxySqlUserInfoConfig extends RedisStreamConfig {
     @Autowired
-    private SqlRedisSqlUserInfoReceiver sqlUserInfoReceiver;
+    private ConsumerGalaxySqlUserInfoReceiver sqlUserInfoReceiver;
 
     @Autowired
     StringRedisTemplate stringRedisTemplate;

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/AbstractJsonRedisReceiver.java

@@ -2,7 +2,7 @@ package com.liquidnet.service.consumer.kylin.receiver;
 
 import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.commons.lang.util.JsonUtils;
-import com.liquidnet.service.consumer.kylin.service.processor.ConsumerJsonNftPublishAndBuyProcessor;
+import com.liquidnet.service.consumer.kylin.service.processor.ConsumerGalaxyJsonNftPublishAndBuyProcessor;
 import com.liquidnet.service.galaxy.dto.param.GalaxyNftPublishAndBuyReqDto;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -19,7 +19,7 @@ public abstract class AbstractJsonRedisReceiver implements StreamListener<String
     StringRedisTemplate stringRedisTemplate;
 
     @Autowired
-    private ConsumerJsonNftPublishAndBuyProcessor jsonNftPublishAndBuyProcessor;
+    private ConsumerGalaxyJsonNftPublishAndBuyProcessor jsonNftPublishAndBuyProcessor;
 
     @Override
     public void onMessage(MapRecord<String, String, String> message) {

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/JsonRedisJsonNftPublishAndBuyReceiver.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerGalaxyJsonNftPublishAndBuyReceiver.java

@@ -6,7 +6,7 @@ import org.springframework.stereotype.Component;
 
 @Slf4j
 @Component
-public class JsonRedisJsonNftPublishAndBuyReceiver extends AbstractJsonRedisReceiver {
+public class ConsumerGalaxyJsonNftPublishAndBuyReceiver extends AbstractJsonRedisReceiver {
 
     @Override
     protected String getRedisStreamKey() {

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/SqlRedisSqlNftOrderInfoReceiver.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerGalaxySqlNftOrderInfoReceiver.java

@@ -6,7 +6,7 @@ import org.springframework.stereotype.Component;
 
 @Slf4j
 @Component
-public class SqlRedisSqlNftOrderInfoReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerGalaxySqlNftOrderInfoReceiver extends AbstractSqlRedisReceiver {
 
     @Override
     protected String getRedisStreamKey() {

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/SqlRedisSqlNftTradeInfoReceiver.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerGalaxySqlNftTradeInfoReceiver.java

@@ -6,7 +6,7 @@ import org.springframework.stereotype.Component;
 
 @Slf4j
 @Component
-public class SqlRedisSqlNftTradeInfoReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerGalaxySqlNftTradeInfoReceiver extends AbstractSqlRedisReceiver {
 
     @Override
     protected String getRedisStreamKey() {

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/SqlRedisSqlSeriesInfoReceiver.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerGalaxySqlSeriesInfoReceiver.java

@@ -6,7 +6,7 @@ import org.springframework.stereotype.Component;
 
 @Slf4j
 @Component
-public class SqlRedisSqlSeriesInfoReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerGalaxySqlSeriesInfoReceiver extends AbstractSqlRedisReceiver {
 
     @Override
     protected String getRedisStreamKey() {

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/SqlRedisSqlUserInfoReceiver.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerGalaxySqlUserInfoReceiver.java

@@ -6,7 +6,7 @@ import org.springframework.stereotype.Component;
 
 @Slf4j
 @Component
-public class SqlRedisSqlUserInfoReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerGalaxySqlUserInfoReceiver extends AbstractSqlRedisReceiver {
 
     @Override
     protected String getRedisStreamKey() {

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/service/processor/ConsumerJsonNftPublishAndBuyProcessor.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/service/processor/ConsumerGalaxyJsonNftPublishAndBuyProcessor.java

@@ -37,7 +37,7 @@ import java.util.Date;
  */
 @Slf4j
 @Component
-public class ConsumerJsonNftPublishAndBuyProcessor {
+public class ConsumerGalaxyJsonNftPublishAndBuyProcessor {
     @Autowired
     private ZxlnftSdkUtil zxlnftSdkUtil;