批量空投

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerGoblinCodeStreamConfig.java

@@ -15,9 +15,9 @@ import org.springframework.data.redis.connection.stream.StreamOffset;
 import org.springframework.data.redis.stream.StreamMessageListenerContainer;
 import org.springframework.data.redis.stream.Subscription;
 
-// @Configuration
-public class ConsumerGoblinCodeStreamConfig  extends RedisStreamConfig {
-/*
+@Configuration
+public class ConsumerGoblinCodeStreamConfig extends RedisStreamConfig {
+
     @Autowired
     ConsumerGoblinCodeReceiver consumerGoblinCodeReceiver;
 
@@ -34,8 +34,6 @@ public class ConsumerGoblinCodeStreamConfig  extends RedisStreamConfig {
         listenerContainer.start();
         return subscription;
     }
-*/
-
 
 
 }

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerGoblinPhoneCodeStreamConfig.java

@@ -17,10 +17,10 @@ import org.springframework.data.redis.stream.Subscription;
 import com.liquidnet.service.consumer.kylin.receiver.ConsumerGoblinPhoneCodeReceiver;
 
 
-// @Configuration
+@Configuration
 public class ConsumerGoblinPhoneCodeStreamConfig extends RedisStreamConfig {
 
-/*
+
     @Autowired
     ConsumerGoblinPhoneCodeReceiver consumerGoblinPhoneCodeReceiver;
 
@@ -37,7 +37,7 @@ public class ConsumerGoblinPhoneCodeStreamConfig extends RedisStreamConfig {
         listenerContainer.start();
         return subscription;
     }
-*/
+
 
 
 /*    @Bean

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

@@ -75,10 +75,12 @@ public abstract class AbstractHttpRedisReceiver implements StreamListener<String
                 }
             }
 
-            LinkedList<String> sqls = CollectionUtil.linkedListString();
-            sqls.add(SqlMapping.get("goblin_activity.code.admin"));
-            String sqlData = SqlMapping.gets(sqls, addLink);
-            sendMsgByRedis(MQConst.GoblinQueue.GOBLIN_CODE_OPERA.getKey(),sqlData);
+            if (addLink!= null && !addLink.isEmpty()){
+                LinkedList<String> sqls = CollectionUtil.linkedListString();
+                sqls.add(SqlMapping.get("goblin_activity.code.admin"));
+                String sqlData = SqlMapping.gets(sqls, addLink);
+                sendMsgByRedis(MQConst.GoblinQueue.GOBLIN_CODE_OPERA.getKey(),sqlData);
+            }
 
         } catch (Exception e) {
             log.error("airdrop send fail:[{}]");

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

@@ -5,7 +5,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 
 @Slf4j
-// @Component
+@Component
 public class ConsumerGoblinCodeReceiver 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/ConsumerGoblinPhoneCodeReceiver.java

@@ -20,7 +20,7 @@ import java.util.List;
 import java.util.Map;
 
 @Slf4j
-// @Component
+@Component
 public class ConsumerGoblinPhoneCodeReceiver extends AbstractHttpRedisReceiver{
 
     @Override

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/goblin/GoblinNftExCodeServiceImpl.java

@@ -419,10 +419,10 @@ public class GoblinNftExCodeServiceImpl implements IGoblinNftExCodeService {
         }
 
         // 页条数
-        int pageSize = 1;
+        int pageSize = 50;
         ArrayList<String> userIdList = CollectionUtil.arrayListString();
         StringBuffer userIds = new StringBuffer();
-        int i = 1;
+        int pageNumber = 1;
         for (String phone : phoneList) {
             if (!phoneCheckList.contains(phone)) {
                 log.error("mobile select not user :[{}]" + phone);
@@ -441,7 +441,7 @@ public class GoblinNftExCodeServiceImpl implements IGoblinNftExCodeService {
             userIds.append(adamUserInfo.getUid()).append(",");
             if (userIdList.size() == pageSize) {
                 StringBuffer codes = new StringBuffer();
-                PageHelper.startPage(i, pageSize, true);
+                PageHelper.startPage(pageNumber, pageSize, true);
                 List<GoblinNftExCode> goblinNftExCodeList = goblinNftExCodeMapper.selectCodeAvailableByActivityId(activityId);
                 for (GoblinNftExCode goblinNftExCode : goblinNftExCodeList) {
                     codes.append(goblinNftExCode.getCode()).append(",");
@@ -455,12 +455,12 @@ public class GoblinNftExCodeServiceImpl implements IGoblinNftExCodeService {
                 queueUtils.sendMssPhoneCodeRedis(hashMap);
                 userIdList.clear();
                 userIds = new StringBuffer();
-                i++;
+                pageNumber++;
             }
         }
 
         if (userIdList.size() > 0) {
-            PageHelper.startPage(i, pageSize, true);
+            PageHelper.startPage(pageNumber, pageSize, true);
             List<GoblinNftExCode> goblinNftExCodeList = goblinNftExCodeMapper.selectCodeAvailableByActivityId(activityId);
             StringBuffer codes = new StringBuffer();
             for (GoblinNftExCode goblinNftExCode : goblinNftExCodeList) {