...

src/main/java/com/sczx/sync/config/ThreadPoolConfig.java

@@ -12,10 +12,11 @@ public class ThreadPoolConfig {
     
     public Executor kafkaMessageExecutor() {
         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
-        executor.setCorePoolSize(10);
+        executor.setCorePoolSize(70);
-        executor.setMaxPoolSize(20);
+        executor.setMaxPoolSize(70);
-        executor.setQueueCapacity(200);
+        executor.setQueueCapacity(700);
         executor.setThreadNamePrefix("kafka-message-processor-");
+        executor.setKeepAliveSeconds(60);
         executor.initialize();
         return executor;
     }

src/main/java/com/sczx/sync/controller/SendDataController.java

@@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.alibaba.fastjson.TypeReference;
 import com.sczx.sync.common.Result;
 import com.sczx.sync.dto.DataRceiveReq;
+import com.sczx.sync.dto.meituan;
 import com.sczx.sync.mapper.CompanyStoreMapper;
 import com.sczx.sync.service.SendDataService;
 import io.swagger.annotations.Api;
@@ -119,6 +120,14 @@ public class SendDataController {
                 });
     }
 
+    @ApiOperation(value = "接收需同步数据接口")
+    @GetMapping("/authorization")
+    public Result authorization(@PathVariable meituan dataRceiveReq){
+        log.info("接收meituan数据：{}",JSON.toJSONString(dataRceiveReq));
+
+        return null;
+    }
+
 
 
 //

src/main/java/com/sczx/sync/dto/meituan.java

@@ -0,0 +1,26 @@
+package com.sczx.sync.dto;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.Map;
+
+@Data
+@ApiModel
+public class meituan {
+
+    @ApiModelProperty("传入数据类型")
+    private String code;
+
+    private String sign;
+
+    @ApiModelProperty("租车平台对应表主键ID")
+    private Long developerId;
+
+    private int businessId;
+
+    @ApiModelProperty("传入数据Map")
+    private String state;
+
+}