批量更新巡更点

src/main/java/com/sooka/sponest/middleware/data/consumer/DataListener.java

@@ -15,7 +15,9 @@ import com.sooka.sponest.data.api.digitalemergency.domain.EmergencyWarehouse;
 import com.sooka.sponest.data.api.digitalenvironment.domain.*;
 import com.sooka.sponest.data.api.digitalfire.domain.*;
 import com.sooka.sponest.data.api.digitalforest.domain.*;
-import com.sooka.sponest.data.api.digitalresource.domain.*;
+import com.sooka.sponest.data.api.digitalresource.domain.Deposit;
+import com.sooka.sponest.data.api.digitalresource.domain.GeologicHazard;
+import com.sooka.sponest.data.api.digitalresource.domain.IllegalConstruction;
 import com.sooka.sponest.data.api.digitaltraffic.domain.Bridge;
 import com.sooka.sponest.data.api.digitaltraffic.domain.Culvert;
 import com.sooka.sponest.data.api.digitaltraffic.domain.WarningSign;
@@ -423,6 +425,9 @@ public class DataListener {
             case DocumentNameConstants.EMERGENCY_PATROLPOINT:// 巡更点
                 if (dataBO.getType().equals(BusinessType.DELETE)) {
                     SpringUtils.getBean(CenterdataTEmergencyPatrolpointDao.class).deleteAllById(result);
+                } else if (dataBO.getType().equals(BusinessType.UPDATEALL)) {
+                    List<EmergencyPatrolpoint> emergencyPatrolpoints = JSON.parseArray(dataBO.getModelStr(), EmergencyPatrolpoint.class);
+                    SpringUtils.getBean(ICenterdataTEmergencyPatrolpointService.class).saveAll(emergencyPatrolpoints);
                 } else {
                     EmergencyPatrolpoint emergencyPatrolpoint = JSON.parseObject(dataBO.getModelStr(), EmergencyPatrolpoint.class);
                     SpringUtils.getBean(ICenterdataTEmergencyPatrolpointService.class).save(emergencyPatrolpoint);

src/main/java/com/sooka/sponest/middleware/data/digitalemergency/service/ICenterdataTEmergencyPatrolpointService.java

@@ -8,4 +8,5 @@ public interface ICenterdataTEmergencyPatrolpointService {
 
     void save(EmergencyPatrolpoint emergencyPatrolpoint);
 
+    void saveAll(List<EmergencyPatrolpoint> emergencyPatrolpoints);
 }

src/main/java/com/sooka/sponest/middleware/data/digitalemergency/service/impl/CenterdataTEmergencyPatrolpointServiceImpl.java

@@ -7,6 +7,8 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.elasticsearch.core.geo.GeoPoint;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+
 @Service
 public class CenterdataTEmergencyPatrolpointServiceImpl implements ICenterdataTEmergencyPatrolpointService {
 
@@ -19,4 +21,12 @@ public class CenterdataTEmergencyPatrolpointServiceImpl implements ICenterdataTE
         centerdataTEmergencyPatrolpointDao.save(emergencyPatrolpoint);
     }
 
+    @Override
+    public void saveAll(List<EmergencyPatrolpoint> emergencyPatrolpoints) {
+        for (EmergencyPatrolpoint emergencyPatrolpoint : emergencyPatrolpoints) {
+            emergencyPatrolpoint.setLocation(new GeoPoint(Double.valueOf(emergencyPatrolpoint.getLatitude()), Double.valueOf(emergencyPatrolpoint.getLongitude())));
+        }
+        centerdataTEmergencyPatrolpointDao.saveAll(emergencyPatrolpoints);
+    }
+
 }