修改dm

ibzdst-core/src/main/java/cn/ibizlab/core/lite/extensions/service/DbEntityService.java

@@ -244,16 +244,20 @@ public class DbEntityService extends ServiceImpl<DbEntityMapper, EntityObj> impl
                 });
             });
 
+            int batchsize=500;
             if ("dameng".equals(dstype)||"dm".equals(dstype)) {
-                List<List<EntityObj>> splist=LiteDataService.splitList(list, 100);
+                batchsize=100;
+            }
+            if(list.size()>batchsize)
+            {
+                List<List<EntityObj>> splist=LiteDataService.splitList(list, batchsize);
                 splist.forEach(array->{
-                    baseMapper.saveBatchDm(entityModel, array);
+                    baseMapper.saveBatch(entityModel, array);
                 });
             }
             else
-            {
                 baseMapper.saveBatch(entityModel, list);
-            }
+
 
             return true;
 

ibzdst-core/src/main/java/cn/ibizlab/core/lite/extensions/service/LiteDataService.java

@@ -57,23 +57,15 @@ public class LiteDataService {
     }
 
     public boolean saveBatch(EntityModel entityModel, String dsName, List<EntityObj> list) {
-        List<List<EntityObj>> splist=splitList(list, 500);
-        for(List<EntityObj> objs:splist)
-        {
-            if(!getEntityService(StringUtils.isEmpty(dsName)?entityModel.getDsName():dsName).saveBatch(dsName,entityModel,objs))
-                return false;
-        }
+        if(!getEntityService(StringUtils.isEmpty(dsName)?entityModel.getDsName():dsName).saveBatch(dsName,entityModel,list))
+            return false;
         return true;
     }
 
     public boolean saveBatch(String systemId, String entityName, String dsName, List<EntityObj> list) {
         EntityModel entityModel = liteModelService.getEntityModel(systemId,entityName);
-        List<List<EntityObj>> splist=splitList(list, 500);
-        for(List<EntityObj> objs:splist)
-        {
-            if(!getEntityService(StringUtils.isEmpty(dsName)?entityModel.getDsName():dsName).saveBatch(dsName,entityModel,objs))
-                return false;
-        }
+        if(!getEntityService(StringUtils.isEmpty(dsName)?entityModel.getDsName():dsName).saveBatch(dsName,entityModel,list))
+            return false;
         return true;
     }