修改区域

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

@@ -61,7 +61,7 @@ public class CinemaPublish implements ProductPublish {
         Map<String, String> collect = byPath.stream().collect(Collectors.toMap(it -> JSONUtil.parseObj(it).get("name").toString(), it -> JSONUtil.parseObj(it).get("cityId").toString()));
 //
 
-        Object updateName = productTriggerTask.getScheduledTask().getParameter().get("updateName");
+        Object updateName = productTriggerTask.getRegion().getParams().get("updateName");
         String name = String.valueOf(updateName);
         String s = collect.get(name);
         if (ObjectUtil.isEmpty(s)) {

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

@@ -63,7 +63,7 @@ public class HotelPublish implements ProductPublish {
     public void trigger(ProductPushService updateService, ProductTriggerTaskModel productTriggerTask) {
 
 
-        Object updateName = productTriggerTask.getScheduledTask().getParameter().get("updateName");
+        Object updateName = productTriggerTask.getRegion().getParams().get("updateName");
         String name = String.valueOf(updateName);
         QueryNewRequest queryNewRequest = new QueryNewRequest();
         queryNewRequest.setKeywords(name);

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

@@ -57,7 +57,7 @@ public class KfcPublish implements ProductPublish {
         CityListResponse cityListResponse = kfcApi.cityList();
         Map<String, String> collect = cityListResponse.getData().stream().collect(Collectors.toMap(it -> it.getName(), it -> it.getCityId()));
 
-        Object updateName = productTriggerTask.getScheduledTask().getParameter().get("updateName");
+        Object updateName = productTriggerTask.getRegion().getParams().get("updateName");
         String name = String.valueOf(updateName);
         String s = collect.get(name);
         if (ObjectUtil.isEmpty(s)) {

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

@@ -61,7 +61,7 @@ public class PetrolStationPublish implements ProductPublish {
     public void trigger(ProductPushService updateService, ProductTriggerTaskModel productTriggerTask) {
 
 
-        Object updateName = productTriggerTask.getScheduledTask().getParameter().get("updateName");
+        Object updateName = productTriggerTask.getRegion().getParams().get("updateName");
         String name = String.valueOf(updateName);
 
         xiaoJuStoreDao.findByCityNameContains(name).forEach(it -> {

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

@@ -53,7 +53,7 @@ public class TicketPublish implements ProductPublish {
     public void trigger(ProductPushService updateService, ProductTriggerTaskModel productTriggerTask) {
 
 
-        Object updateName = productTriggerTask.getScheduledTask().getParameter().get("updateName");
+        Object updateName = productTriggerTask.getRegion().getParams().get("updateName");
         String name = String.valueOf(updateName);
 
         int page = 1;