修改批量初始化es

amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/service/impl/ESOrgUsrService.java

@@ -12,6 +12,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.typroject.tyboot.core.foundation.utils.ValidationUtil;
 
+import java.util.ArrayList;
 import java.util.LinkedHashSet;
 import java.util.List;
 import java.util.Set;
@@ -69,9 +70,12 @@ public class ESOrgUsrService {
     public void saveAll(List<OrgUsr> orgUsrs) throws Exception {
 
         if (!ValidationUtil.isEmpty(orgUsrs)) {
-            for (OrgUsr orgUsr : orgUsrs) {
-                this.saveAlertCalledToES(orgUsr);
-            }
+//            for (OrgUsr orgUsr : orgUsrs) {
+//                this.saveAlertCalledToES(orgUsr);
+//            }
+
+                this.saveAlertCalledToES(orgUsrs);
+
         }
     }
 
@@ -90,6 +94,32 @@ public class ESOrgUsrService {
         return esOrgUsrDto;
     }
 
+    public List<ESOrgUsrDto> saveAlertCalledToES(List<OrgUsr> orgUsrs) throws Exception {
+        List<ESOrgUsrDto> listes=new ArrayList<>();
+        try {
+
+        for (OrgUsr orgUsr : orgUsrs) {
+            ESOrgUsrDto esOrgUsrDto = new ESOrgUsrDto();
+            String seqStr = String.valueOf(orgUsr.getSequenceNbr());
+
+            Long seq = Long.parseLong(seqStr);
+            esOrgUsrDto.setSequenceNbr(seq);
+            esOrgUsrDto.setBizOrgName(orgUsr.getBizOrgName());
+            listes.add(esOrgUsrDto);
+        }
+            esOrgUsrDtoRepository.saveAll(listes);
+
+
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return listes;
+    }
+
+
+
+
+
     public ESOrgUsrDto saveAlertCalledToESNew(OrgUsr orgUsr) throws Exception {
         ESOrgUsrDto esOrgUsrDto = new ESOrgUsrDto();
         String seqStr = String.valueOf(orgUsr.getSequenceNbr());