BUG提交 订单ES入库修正

common/fire-dto/src/main/java/com/fire/es/OrderEsDto.java

@@ -295,5 +295,10 @@ public class OrderEsDto {
             otherFields = @InnerField(suffix = "keyword", type=FieldType.Keyword))
     private String phoneHome;
 
-
+    /**
+     * 归属地名称
+     */
+    @ApiModelProperty("适配器名称")
+    @Field(type = FieldType.Keyword)
+    private String adapterName;
 }

modules/save-data/src/main/java/com/fire/savedata/consumer/OderEsConsumer.java

@@ -35,7 +35,7 @@ public class OderEsConsumer implements RocketMQListener<String> {
             IndexQuery indexQuery = new IndexQuery();
             indexQuery.setId(orderEsDto.getOrderId());
             indexQuery.setObject(orderEsDto);
-            IndexCoordinates indexCoordinates = IndexCoordinates.of("mobile_flow_dispatch_rec");
+            IndexCoordinates indexCoordinates = IndexCoordinates.of("flow_order_info");
             restTemplate.index(indexQuery, indexCoordinates);
         } catch (JsonProcessingException e) {
             e.printStackTrace();

modules/save-data/src/main/resources/bootstrap.yml

@@ -1,5 +1,5 @@
 server:
-  port: 8088
+  port: 8084
 spring:
   application:
     name: save-data