修改批量录入

amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/service/impl/ESAlertCalledService.java

 package com.yeejoin.amos.boot.module.jcs.biz.service.impl;
 
+import java.util.ArrayList;
 import java.util.Date;
 import java.util.LinkedList;
 import java.util.List;
@@ -86,11 +87,14 @@ public class ESAlertCalledService {
         List<AlertCalled> alertCalleds = alertCalledService.list(wrapper);
         if (!ValidationUtil.isEmpty(alertCalleds))
 		{
-    		for (AlertCalled alertCalled : alertCalleds)
-    		{
-    			saveAlertCalledToES(alertCalled);
-    		}
+//    		for (AlertCalled alertCalled : alertCalleds)
+//    		{
+//    			saveAlertCalledToES(alertCalled);
+//    		}
+
+			saveAlertCalledToES(alertCalleds);
 		}
+
         return true;
     }
 
@@ -151,6 +155,44 @@ public class ESAlertCalledService {
     	return esAlertCalled;
     }
 
+
+	public List<ESAlertCalled> saveAlertCalledToES(List<AlertCalled> alertCalleds) throws Exception
+	{
+		List<ESAlertCalled> list1=new ArrayList<>();
+		for (AlertCalled alertCalled : alertCalleds)
+		{
+			ESAlertCalled esAlertCalled = new ESAlertCalled();
+			esAlertCalled.setSequenceNbr(alertCalled.getSequenceNbr());
+			esAlertCalled.setAlertType(alertCalled.getAlertType());
+			esAlertCalled.setAlertTypeCode(alertCalled.getAlertTypeCode());
+			esAlertCalled.setCallTime(alertCalled.getCallTime());
+			esAlertCalled.setCallTimeLong(alertCalled.getCallTime()!=null?alertCalled.getCallTime().getTime():null);
+			esAlertCalled.setContactUser(alertCalled.getContactUser());
+			esAlertCalled.setContactPhone(alertCalled.getContactPhone());
+			esAlertCalled.setAddress(alertCalled.getAddress());
+			esAlertCalled.setAlertStage(alertCalled.getAlertStage());
+			esAlertCalled.setAlertStatus(alertCalled.getAlertStatus());
+			if (alertCalled.getAlertStatus())
+			{
+				esAlertCalled.setAlertStatusStr(AlertStatusEnum.CLOSED.getCode());
+			}else
+			{
+				esAlertCalled.setAlertStatusStr(AlertStatusEnum.UNCLOSED.getCode());
+			}
+			esAlertCalled.setResponseLevelCode(alertCalled.getResponseLevelCode());
+			esAlertCalled.setUnitInvolved(alertCalled.getUnitInvolved());
+			esAlertCalled.setCoordinateX(alertCalled.getCoordinateX());
+			esAlertCalled.setCoordinateY(alertCalled.getCoordinateY());
+			list1.add(esAlertCalled);
+		}
+
+		esAlertCalledRepository.saveAll(list1);
+		return list1;
+	}
+
+
+
+
     /**
      *
      * <pre>