添加父级id

SpringBatchServiceServer/src/main/java/com/zswl/cloud/springBtach/server/core/publish/CinemaPublish.java

@@ -88,6 +88,7 @@ public class CinemaPublish implements ProductPublish {
                         ProductPushModel.builder()
                                 .regionCode(productTriggerTask.getRegion().getCode())
                                 .pid(cinemaCode)
+                                .parkId(productTriggerTask.getRegion().getParentId())
                                 .productType(ProductType.Cinema)
                                 .title(names)
                                 .address(address)

SpringBatchServiceServer/src/main/java/com/zswl/cloud/springBtach/server/core/publish/ComingMoviePublish.java

@@ -84,6 +84,7 @@ public class ComingMoviePublish implements ProductPublish {
                 String posterUrl = entry.get("posterUrl").toString();
                 productCenterStream.send(List.of(ProductPushModel.builder()
                         .regionCode(productTriggerTask.getRegion().getCode())
+                        .parkId(productTriggerTask.getRegion().getParentId())
                         .pid(ObjectUtil.isEmpty(movieCode) ? entry.get("movieId").toString() : movieCode)
                         .productType(ProductType.MovieTicket)
                         .cover(new String[]{posterUrl})

SpringBatchServiceServer/src/main/java/com/zswl/cloud/springBtach/server/core/publish/HotelPublish.java

@@ -113,6 +113,7 @@ public class HotelPublish implements ProductPublish {
                             productCenterStream.send(List.of(ProductPushModel.builder()
                                     .regionCode(productTriggerTask.getRegion().getCode())
                                     .pid(hotelId)
+                                    .parkId(productTriggerTask.getRegion().getParentId())
                                     .productType(ProductType.Hotel)
                                     .cover(new String[]{picture})
                                     .salePrice(price.longValue())

SpringBatchServiceServer/src/main/java/com/zswl/cloud/springBtach/server/core/publish/KfcPublish.java

@@ -93,6 +93,7 @@ public class KfcPublish implements ProductPublish {
                                             .regionCode(productTriggerTask.getRegion().getCode())
                                             .pid(it.getId())
                                             .address(it.getAddress())
+                                            .parkId(productTriggerTask.getRegion().getParentId())
                                             .productType(ProductType.Restaurant)
                                             .locationPoint(locationModel)
                                             .title(it.getShopName())
@@ -119,6 +120,7 @@ public class KfcPublish implements ProductPublish {
                                     productCenterStream.send(List.of(
                                             ProductPushModel.builder()
                                                     .regionCode(productTriggerTask.getRegion().getCode())
+                                                    .parkId(productTriggerTask.getRegion().getParentId())
                                                     .pid((String) productId)
                                                     .address(it.getAddress())
                                                     .productType(ProductType.RestaurantFood)

SpringBatchServiceServer/src/main/java/com/zswl/cloud/springBtach/server/core/publish/MoviePublish.java

@@ -84,6 +84,7 @@ public class MoviePublish implements ProductPublish {
                 String posterUrl = entry.get("posterUrl").toString();
                 productCenterStream.send(List.of(ProductPushModel.builder()
                         .regionCode(productTriggerTask.getRegion().getCode())
+                        .parkId(productTriggerTask.getRegion().getParentId())
                         .pid(ObjectUtil.isEmpty(movieCode)?entry.get("movieId").toString(): movieCode)
                         .productType(ProductType.MovieTicket)
                         .cover(new String[]{posterUrl})

SpringBatchServiceServer/src/main/java/com/zswl/cloud/springBtach/server/core/publish/PetrolStationPublish.java

@@ -87,6 +87,7 @@ public class PetrolStationPublish implements ProductPublish {
                 productCenterStream.send(List.of(
                         ProductPushModel.builder()
                                 .regionCode(productTriggerTask.getRegion().getCode())
+                                .parkId(productTriggerTask.getRegion().getParentId())
                                 .pid(it.getStoreId())
                                 .productType(ProductType.PetrolStation)
                                 .cover(it.getPicList().stream().toArray(String[]::new))

SpringBatchServiceServer/src/main/java/com/zswl/cloud/springBtach/server/core/publish/TicketPublish.java

@@ -85,6 +85,7 @@ public class TicketPublish implements ProductPublish {
                     productCenterStream.send(List.of(
                             ProductPushModel.builder()
                                     .regionCode(productTriggerTask.getRegion().getCode())
+                                    .parkId(productTriggerTask.getRegion().getParentId())
                                     .pid(it.getScenicId())
                                     .productType(ProductType.Scenic)
                                     .cover(new String[]{it.getNewPicUrl()})

SpringBatchServiceServer/src/main/java/com/zswl/cloud/springBtach/server/core/publish/Video2Publish.java

@@ -65,6 +65,7 @@ public class Video2Publish implements ProductPublish {
                 productCenterStream.send(List.of(
                         ProductPushModel.builder()
                                 .regionCode(productTriggerTask.getRegion().getCode())
+                                .parkId(productTriggerTask.getRegion().getParentId())
                                 .pid(String.valueOf(it.getProductId()))
                                 .productType(ProductType.Recharge)
                                 .title(it.getItemName())