前置联调

message/message-boot/src/main/java/com/njcn/message/consumer/FrontDataConsumer.java

@@ -1,10 +1,12 @@
 package com.njcn.message.consumer;
 
-import com.alibaba.fastjson.JSONObject;
 
+import com.alibaba.fastjson.JSONObject;
+import com.njcn.common.pojo.enums.response.CommonResponseEnum;
+import com.njcn.common.pojo.response.HttpResult;
 import com.njcn.message.constant.MessageStatus;
 import com.njcn.message.messagedto.MessageDataDTO;
-import com.njcn.message.redis.RedisKeyPrefix;
+import com.njcn.message.constant.RedisKeyPrefix;
 import com.njcn.middle.rocket.constant.EnhanceMessageConstant;
 import com.njcn.middle.rocket.handler.EnhanceConsumerMessageHandler;
 import com.njcn.redis.pojo.enums.RedisKeyEnum;
@@ -24,6 +26,9 @@ import javax.annotation.Resource;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Objects;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
 
 
 /**
@@ -158,8 +163,6 @@ public class FrontDataConsumer extends EnhanceConsumerMessageHandler<MessageData
         return false;
     }
 
-
-
     //50个消息做一组插入数据库
     public void saveToDatabase(){
         try {