[模型模块]分类复杂查询改动

src/main/java/com/tykj/model_layer/controller/ModelController.java

@@ -47,8 +47,6 @@ public class ModelController {
     private VersionService versionService;
 
 
-
-
     /**
      * @param
      * @return java.util.List<com.tykj.workflowcore.model_layer.model.TableInfo>
@@ -78,7 +76,7 @@ public class ModelController {
         List<ColumnInfo> columnInfos = modelService.showModelFields(searchColumnInfoVo);
         for (ColumnInfo columnInfo : columnInfos) {
             List<Quote> allByColumnId = quoteDao.findAllByColumnId(columnInfo.getId());
-           columnInfo.setQuoteList(allByColumnId);
+            columnInfo.setQuoteList(allByColumnId);
         }
         return ResultUtil.success(columnInfos, "数据查询成功！");
     }
@@ -183,7 +181,7 @@ public class ModelController {
     @ApiOperation("复杂查询(分类)")
     @PostMapping("/complexQuery/group")
     public ResponseEntity complexQueryWithGroup(@RequestBody complexQueryVo complexQueryVo) {
-        Map<Object, List<Map<String, Object>>> list = modelService.complexQueryWithGroup(complexQueryVo.getTableName(), complexQueryVo.getColumnNames(), complexQueryVo.getQueryConditions(), complexQueryVo.getGroupByColumn());
+        Map<Object, List<Map<String, Object>>> list = modelService.complexQueryWithGroup(complexQueryVo.getTableName(), complexQueryVo.getGroupConditions(), complexQueryVo.getColumnNames(), complexQueryVo.getQueryConditions(), complexQueryVo.getGroupByColumn());
         if (list != null) {
             return ResultUtil.success(list, "查询成功!");
         }

src/main/java/com/tykj/model_layer/entity/vo/GroupCondition.java

+package com.tykj.model_layer.entity.vo;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@AllArgsConstructor
+@NoArgsConstructor
+@Data
+public class GroupCondition {
+
+    private String name;
+
+    private String value;
+
+}

src/main/java/com/tykj/model_layer/entity/vo/complexQueryVo.java

@@ -27,6 +27,9 @@ public class complexQueryVo {
     @ApiModelProperty("筛选字段")
     List<String> columnNames;
 
+    @ApiModelProperty("分类条件信息")
+    List<GroupCondition> groupConditions;
+
     @ApiModelProperty("查询条件")
     List<QueryCondition> queryConditions;
 

src/main/java/com/tykj/model_layer/service/ModelService.java

@@ -22,32 +22,33 @@ public interface ModelService {
 
     /**
      * 分页查询
+     *
      * @param searchTableInfoVo
      * @return
-
      */
     Page<TableInfo> pageAllEntities(SearchTableInfoVo searchTableInfoVo);
 
 
     /**
      * 方法重载不分页查询
+     *
      * @return
      */
-    List<TableInfo> listAllEntities(SearchTableInfoVo searchTableInfoVo) ;
-
+    List<TableInfo> listAllEntities(SearchTableInfoVo searchTableInfoVo);
 
 
     /**
      * 根据表名查询所有字段信息
+     *
      * @param searchColumnInfoVo
      * @return
      */
     List<ColumnInfo> showModelFields(SearchColumnInfoVo searchColumnInfoVo);
 
 
-
     /**
      * 新建模型
+     *
      * @param tableVO
      * @return
      */
@@ -56,6 +57,7 @@ public interface ModelService {
 
     /**
      * 根据表名插入数据
+     *
      * @param map
      * @return
      */
@@ -63,6 +65,7 @@ public interface ModelService {
 
     /**
      * 插入一组数据
+     *
      * @param mapList
      * @return
      */
@@ -70,33 +73,37 @@ public interface ModelService {
 
     /**
      * 根据表名查询所有
+     *
      * @param name
      * @return
      * @throws SQLException
      */
-    List<Map<String, Object>>  findAllByName(String name) throws SQLException;
+    List<Map<String, Object>> findAllByName(String name) throws SQLException;
 
 
     /**
      * 复杂查询
+     *
      * @param tableName
      * @param queryConditions
      * @return
      */
-    List<Map<String, Object>> complexQuery(String tableName,List<String> columnNames, List<QueryCondition> queryConditions);
+    List<Map<String, Object>> complexQuery(String tableName, List<String> columnNames, List<QueryCondition> queryConditions);
 
     /**
      * 复杂查询（带分类）
+     *
      * @param tableName
      * @param queryConditions
      * @return
      */
-    Map<Object,List<Map<String, Object>>> complexQueryWithGroup(String tableName,List<String> columnNames, List<QueryCondition> queryConditions,String groupByColumn);
+    Map<Object, List<Map<String, Object>>> complexQueryWithGroup(String tableName, List<GroupCondition> groupConditions, List<String>columnNames, List<QueryCondition> queryConditions, String groupByColumn);
 
 
     /**
      * 修改表
-      * @param updateTableInfoVO
+     *
+     * @param updateTableInfoVO
      * @return
      */
     int updateTable(UpdateTableInfoVO updateTableInfoVO);
@@ -104,6 +111,7 @@ public interface ModelService {
 
     /**
      * 删除表
+     *
      * @param delTableVO
      * @return
      */
@@ -112,6 +120,7 @@ public interface ModelService {
 
     /**
      * 根据id批量查询所有tableInfo和ColumnInfo
+     *
      * @param ids
      * @return
      */

src/main/java/com/tykj/model_layer/service/impl/ModelImpl.java

@@ -11,6 +11,7 @@ import com.tykj.model_layer.dao.TableInfoDao;
 import com.tykj.model_layer.entity.ColumnInfo;
 import com.tykj.model_layer.entity.Quote;
 import com.tykj.model_layer.entity.TableInfo;
+import com.tykj.model_layer.entity.customEnums.ConnectionType;
 import com.tykj.model_layer.entity.vo.*;
 import com.tykj.model_layer.myEnum.ModelType;
 import com.tykj.model_layer.service.ModelService;
@@ -157,7 +158,7 @@ public class ModelImpl implements ModelService {
         tableInfo.setModelName(tableVO.getModelName());
         tableInfo.setModelTitle(tableVO.getModelTitle());
         tableInfo.setXml(xmlMapping);
-        tableInfo.setBackName(tableVO.getModelName()+"_back");
+        tableInfo.setBackName(tableVO.getModelName() + "_back");
         tableInfo.setBackXml(xmlBack);
         tableInfo.setModelType(tableVO.getModelType());
         tableInfo.setDescription(tableVO.getDescription());
@@ -179,9 +180,9 @@ public class ModelImpl implements ModelService {
             columnInfo.setPrimaryKey(columnVO.getPrimaryKey());
             ColumnInfo save = columnInfoDao.save(columnInfo);
             List<Quote> quoteList = columnVO.getQuoteList();
-            if (quoteList!=null){
+            if (quoteList != null) {
                 for (Quote quote : quoteList) {
-                    if (StringUtils.isNotEmpty(quote.getValue())){
+                    if (StringUtils.isNotEmpty(quote.getValue())) {
                         quote.setColumnId(save.getId());
                         quoteDao.save(quote);
                     }
@@ -218,22 +219,22 @@ public class ModelImpl implements ModelService {
             }
             Integer modelType = tableInfo.getModelType();
 
-            SessionImpl session = (SessionImpl)sessionUtil.getSession();
+            SessionImpl session = (SessionImpl) sessionUtil.getSession();
             session.getTransaction().begin();
-                Object values = map.get(tableName);
-                if (values instanceof Map) {
-                    //插入数据
-                    insertValue(tableInfo.getModelName(), (Map) values,session,true,false);
+            Object values = map.get(tableName);
+            if (values instanceof Map) {
+                //插入数据
+                insertValue(tableInfo.getModelName(), (Map) values, session, true, false);
 
-                } else {
-                    //循环插入数据
-                    List valuesList = (List) values;
-                    for (int i = 0; i < valuesList.size(); i++) {
-                        insertValue(tableInfo.getModelName(), (Map) valuesList.get(i),session,true,false);
-                    }
+            } else {
+                //循环插入数据
+                List valuesList = (List) values;
+                for (int i = 0; i < valuesList.size(); i++) {
+                    insertValue(tableInfo.getModelName(), (Map) valuesList.get(i), session, true, false);
                 }
-                session.getTransaction().commit();
-                session.close();
+            }
+            session.getTransaction().commit();
+            session.close();
 
 
         }
@@ -249,7 +250,7 @@ public class ModelImpl implements ModelService {
      **/
     @Override
     public int putValueByEntityNameList(List<Map<String, Object>> mapList) {
-        SessionImpl session = (SessionImpl)sessionUtil.getSession();
+        SessionImpl session = (SessionImpl) sessionUtil.getSession();
         session.getTransaction().begin();
         for (Map<String, Object> map : mapList) {
             for (String tableName :
@@ -267,17 +268,17 @@ public class ModelImpl implements ModelService {
                     tableInfo = (TableInfo) one.get();
                 }
                 Integer modelType = tableInfo.getModelType();
-                    Object values = map.get(tableName);
-                    if (values instanceof Map) {
-                        //插入数据
-                        insertValue(tableInfo.getModelName(), (Map) values,session,true,false);
-                    } else {
-                        //循环插入数据
-                        List valuesList = (List) values;
-                        for (int i = 0; i < valuesList.size(); i++) {
-                            insertValue(tableInfo.getModelName(), (Map) valuesList.get(i),session,true,false);
-                        }
+                Object values = map.get(tableName);
+                if (values instanceof Map) {
+                    //插入数据
+                    insertValue(tableInfo.getModelName(), (Map) values, session, true, false);
+                } else {
+                    //循环插入数据
+                    List valuesList = (List) values;
+                    for (int i = 0; i < valuesList.size(); i++) {
+                        insertValue(tableInfo.getModelName(), (Map) valuesList.get(i), session, true, false);
                     }
+                }
 
             }
         }
@@ -295,7 +296,7 @@ public class ModelImpl implements ModelService {
      * @Description 新增参数的方法
      * @Date 16:17 2021/3/5
      **/
-    public void insertValue(String tableName, Map map,SessionImpl session,boolean back,boolean saveOrSaveAndUpdate) {
+    public void insertValue(String tableName, Map map, SessionImpl session, boolean back, boolean saveOrSaveAndUpdate) {
         EntityPersister entityPersister = session.getEntityPersister(tableName, map);
         Type[] propertyTypes = entityPersister.getPropertyTypes();
         String[] propertyNames = entityPersister.getEntityPersister().getPropertyNames();
@@ -306,8 +307,8 @@ public class ModelImpl implements ModelService {
             //先将Type转为java类
             if (propertyType instanceof TimestampType) {
                 try {
-                    if (value instanceof String){
-                        if (StringUtils.isNotEmpty((String)value)){
+                    if (value instanceof String) {
+                        if (StringUtils.isNotEmpty((String) value)) {
                             Date parse = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse((String) value);
                             map.put(propertyNames[i], parse);
                         }
@@ -329,17 +330,17 @@ public class ModelImpl implements ModelService {
         }
         HashMap hashMap = new HashMap();
         hashMap.putAll(map);
-        if (saveOrSaveAndUpdate){
+        if (saveOrSaveAndUpdate) {
             session.save(tableName, map);
-        }else {
+        } else {
             session.saveOrUpdate(tableName, map);
         }
 
-        if (back){
-            if (saveOrSaveAndUpdate){
-                session.save(tableName+"_back", map);
-            }else {
-                session.saveOrUpdate(tableName+"_back", map);
+        if (back) {
+            if (saveOrSaveAndUpdate) {
+                session.save(tableName + "_back", map);
+            } else {
+                session.saveOrUpdate(tableName + "_back", map);
             }
         }
     }
@@ -395,27 +396,36 @@ public class ModelImpl implements ModelService {
     }
 
     @Override
-    public Map<Object, List<Map<String, Object>>> complexQueryWithGroup(String tableName, List<String> columnNames, List<QueryCondition> queryConditions, String groupByColumn) {
+    public Map<Object, List<Map<String, Object>>> complexQueryWithGroup(String tableName, List<GroupCondition> groupConditions, List<String> columnNames, List<QueryCondition> queryConditions, String groupByColumn) {
         Map<Object, List<Map<String, Object>>> result = new HashMap<>();
-        if (Strings.isNotEmpty(tableName)) {
-            String query = createQuery(tableName, new ArrayList<>(), queryConditions, Strings.EMPTY);
-            Session session = sessionUtil.getSession();
-            Query query1 = session.createQuery(query);
-            List<Map<String, Object>> list = query1.list();
-            if (Strings.isNotEmpty(groupByColumn)) {
-                Set<Object> groupValues = list.stream().map(obj -> obj.get(groupByColumn)).collect(Collectors.toSet());
-                for (Object groupValue : groupValues) {
-                    List<Map<String, Object>> entityList = list.stream().filter(obj -> Objects.equals(obj.get(groupByColumn), groupValue)).collect(Collectors.toList());
-                    result.put(groupValue, entityList);
-                }
-            } else {
-                result.put("all", list);
+        if (Strings.isNotEmpty(tableName) && Strings.isNotEmpty(groupByColumn) && !groupConditions.isEmpty()) {
+            for (GroupCondition groupCondition : groupConditions) {
+                queryConditions.add(new QueryCondition(
+                        groupByColumn,
+                        "like",
+                        groupCondition.getValue(),
+                        ConnectionType.AND
+                ));
+                String query = createQuery(tableName, columnNames, queryConditions, Strings.EMPTY);
+                Session session = sessionUtil.getSession();
+                Query query1 = session.createQuery(query);
+                List<Map<String, Object>> list = query1.list();
+                result.put(groupCondition.getName(), list);
             }
             return result;
         }
         return null;
     }
 
+    private QueryCondition queryCondition(String groupByColumn, GroupCondition groupCondition) {
+        return new QueryCondition(
+                groupByColumn,
+                "like",
+                groupCondition.getValue(),
+                ConnectionType.AND
+        );
+    }
+
     @Override
     public int updateTable(UpdateTableInfoVO updateTableInfoVO) {
         //tableInfo和columnInfo变化
@@ -423,49 +433,49 @@ public class ModelImpl implements ModelService {
         TableVO tableVO = updateTableInfoVO.getTableVO();
         Integer dbId = updateTableInfoVO.getDbId();
         TableInfo tableInfo = tableInfoDao.findById(dbId).orElseThrow(() -> new RuntimeException("未找到该id的表信息"));
-            tableInfo.setUpdatedTime(new Date());
-            tableInfo.setDescription(tableVO.getDescription());
-            tableInfo.setModelTitle(tableVO.getModelTitle());
-            tableInfo.setModelType(tableVO.getModelType());
-            String xml = createTable(tableVO);
-            //重新存xml
-            tableInfo.setXml(xml);
-            tableInfoDao.save(tableInfo);
-
-            //原来的字段信息
-            Specification spec = (Specification) (root, criteriaQuery, criteriaBuilder) -> {
-                Predicate predicate = criteriaBuilder.equal(root.get("dbId"), dbId);
-                return predicate;
-            };
-            List<ColumnInfo> originalColumnInfos = columnInfoDao.findAll(spec);
-            //新的字段信息
-            List<ColumnInfo> currentColumnInfos = tableVO.getDataList().stream()
-                    .map(columnVO -> columnInfo(tableInfo.getId(), tableInfo.getModelName(), columnVO))
-                    .collect(Collectors.toList());
+        tableInfo.setUpdatedTime(new Date());
+        tableInfo.setDescription(tableVO.getDescription());
+        tableInfo.setModelTitle(tableVO.getModelTitle());
+        tableInfo.setModelType(tableVO.getModelType());
+        String xml = createTable(tableVO);
+        //重新存xml
+        tableInfo.setXml(xml);
+        tableInfoDao.save(tableInfo);
 
+        //原来的字段信息
+        Specification spec = (Specification) (root, criteriaQuery, criteriaBuilder) -> {
+            Predicate predicate = criteriaBuilder.equal(root.get("dbId"), dbId);
+            return predicate;
+        };
+        List<ColumnInfo> originalColumnInfos = columnInfoDao.findAll(spec);
+        //新的字段信息
+        List<ColumnInfo> currentColumnInfos = tableVO.getDataList().stream()
+                .map(columnVO -> columnInfo(tableInfo.getId(), tableInfo.getModelName(), columnVO))
+                .collect(Collectors.toList());
 
-            //根据ColumnInfo集合得出表实际改动的sql语句集合
-            List<String> sqls = getTableSqls(tableInfo.getModelName(), originalColumnInfos, currentColumnInfos);
-            //执行sql语句
-            for (String sql : sqls) {
-                System.out.println(sql);
-                jdbcTemplate.execute(sql);
 
-            }
+        //根据ColumnInfo集合得出表实际改动的sql语句集合
+        List<String> sqls = getTableSqls(tableInfo.getModelName(), originalColumnInfos, currentColumnInfos);
+        //执行sql语句
+        for (String sql : sqls) {
+            System.out.println(sql);
+            jdbcTemplate.execute(sql);
 
-            //重新保存字段信息
-            List<ColumnInfo> columnsForAdd = getColumnsForAdd(originalColumnInfos, currentColumnInfos);
-            for (ColumnInfo columnInfo : columnsForAdd) {
-                columnInfoDao.save(columnInfo);
-            }
-            List<ColumnInfo> columnsForUpdate = getColumnsForUpdate(originalColumnInfos, currentColumnInfos);
-            for (ColumnInfo columnInfo : columnsForUpdate) {
-                columnInfoDao.save(columnInfo);
-            }
-            List<ColumnInfo> columnsFordDelete = getColumnsFordDelete(originalColumnInfos, currentColumnInfos);
-            for (ColumnInfo originColumnInfo : columnsFordDelete) {
-                columnInfoDao.delete(originColumnInfo);
-            }
+        }
+
+        //重新保存字段信息
+        List<ColumnInfo> columnsForAdd = getColumnsForAdd(originalColumnInfos, currentColumnInfos);
+        for (ColumnInfo columnInfo : columnsForAdd) {
+            columnInfoDao.save(columnInfo);
+        }
+        List<ColumnInfo> columnsForUpdate = getColumnsForUpdate(originalColumnInfos, currentColumnInfos);
+        for (ColumnInfo columnInfo : columnsForUpdate) {
+            columnInfoDao.save(columnInfo);
+        }
+        List<ColumnInfo> columnsFordDelete = getColumnsFordDelete(originalColumnInfos, currentColumnInfos);
+        for (ColumnInfo originColumnInfo : columnsFordDelete) {
+            columnInfoDao.delete(originColumnInfo);
+        }
 //            columnInfoDao.deleteAllByDbId(updateTableInfoVO.getDbId());
 //
 //            List<ColumnInfo> dataList = updateTableInfoVO.getTableVO().getDataList().stream()
@@ -482,7 +492,7 @@ public class ModelImpl implements ModelService {
 ////            重新存xml
 //            tableInfo.setXml(xml2);
 //            tableInfoDao.save(tableInfo);
-            return 1;
+        return 1;
 
     }
 
@@ -525,7 +535,7 @@ public class ModelImpl implements ModelService {
             }
         }
         for (ColumnInfo originColumnInfo : origin) {
-            if (!originColumnInfo.getFieldName().equals("id")){
+            if (!originColumnInfo.getFieldName().equals("id")) {
                 boolean noneMatch = current.stream()
                         .noneMatch(columnInfo1 -> Objects.equals(originColumnInfo.getId(), columnInfo1.getId()));
                 if (noneMatch) {