增加sql列表管理

src/main/java/com/roma/romaapi/controller/ApiController.java

@@ -125,6 +125,26 @@ public class ApiController {
         return CustomResponse.formatResponse(ret);
     }
 
+    // 返回带分页格式的数据-sql列表管理页
+    @RequestMapping("/api/sqlManageList")
+    public Map sqlManageList(HttpServletRequest request, @RequestBody String data){
+        Map maps = commonUtil.analysisRequestParams(request, data); // 参数
+        Map<String, Object> ret = new HashMap<>();
+        ret = apiService.sqlListHasPaging(maps);
+
+        return CustomResponse.formatResponse(ret);
+    }
+
+    // sql管理-新增和编辑Sql
+    @RequestMapping("/api/sqlSave")
+    public Map sqlSave(HttpServletRequest request, @RequestBody String data, @RequestHeader("Authorization") String authorization) {
+        Map maps = commonUtil.analysisRequestParams(request, data); // 参数
+
+        Map ret = apiService.addSql(maps, authorization);
+
+        return CustomResponse.formatResponse(ret);
+    }
+
     // 权限管理-添加权限-获取所有页面,选择关联页面
     @RequestMapping("/api/sqlList")
     public Map sqlDetailsList(){
@@ -135,7 +155,7 @@ public class ApiController {
         return CustomResponse.formatResponse(ret);
     }
 
-    // 权限管理-添加权限-获取所有页面,选择关联页面
+    // 权限管理-添加权限-获取所有页面,选择关联api
     @RequestMapping("/api/apiList")
     public Map apiDetailsList(){
         Map<String, Object> ret = new HashMap<>();
@@ -145,7 +165,7 @@ public class ApiController {
         return CustomResponse.formatResponse(ret);
     }
 
-    // 权限管理-添加权限-获取所有页面,选择关联页面
+    // 权限管理-添加权限-获取所有页面,选择关联item
     @RequestMapping("/api/itemList")
     public Map itemDetailsList(){
         Map<String, Object> ret = new HashMap<>();

src/main/java/com/roma/romaapi/dao/ApiDao.java

@@ -152,6 +152,28 @@ public class ApiDao {
         }
     }
 
+    // 添加/编辑sql_details表数据
+    public Integer addSqlDetails(Map<String, Object> bindValue, String editId) {
+        String sql = "";
+        if (editId.length()==0) {
+            sql = " INSERT INTO `sql_details` (`sql_name`,`sql_code`,`sql_string`,`sql_type`,`is_list`," +
+                    "`is_enable`,`created_user`,`created_at`,`sql_description`)  " +
+                    "VALUES (:sqlName,:sqlCode,:sqlString,:sqlType,:isList,:isEnable,:actionUser,:createdAt, :sqlDesc)  ";
+            KeyHolder keyHolder = new GeneratedKeyHolder();
+            Integer row = namedParameterJdbcTemplate.update(sql, new MapSqlParameterSource(bindValue), keyHolder);
+            int k = keyHolder.getKey().intValue();
+
+            return k;
+        } else {
+            bindValue.put("id", editId);
+            sql = " UPDATE `sql_details` SET `sql_name`=:sqlName,`sql_code`=:sqlCode,`sql_string`=:sqlString,`sql_type`=:sqlType," +
+                    "`is_list`=:isList,`is_enable`=:isEnable,`sql_description`=:sqlDesc,`update_user`=:actionUser WHERE id=:id";
+            Integer row = namedParameterJdbcTemplate.update(sql, bindValue);
+
+            return row;
+        }
+    }
+
     // Role角色管理-获取总数
     public Integer getAllRoleListHasPagingCount(Map bindValue) {
         // 获取总数

src/main/java/com/roma/romaapi/dao/PageDao.java

@@ -94,6 +94,27 @@ public class PageDao {
         return count;
     }
 
+    // Sql页面管理-获取总数
+    public Integer getAllSqlListHasPagingCount(Map bindValue) {
+        // 获取总数
+        String countInnerSql = " SELECT * FROM `sql_details` WHERE 1=1 ";
+        String countSql = "SELECT COUNT(*) AS `totalData` FROM ( " + countInnerSql + " ) AS ROMA";
+        Integer count = namedParameterJdbcTemplate.queryForObject(countSql, bindValue, Integer.class);
+
+        return count;
+    }
+
+    // Sql页面管理-获取带分页的列表数据
+    public List<Map<String, Object>> getAllSqlListHasPaging(Map bindValue, String page, String perPage, Integer count) {
+        // 计算分页
+        String limitAfter = commonUtil.calcPagingString(count, page, perPage);
+        String listSql = "SELECT  *  FROM `sql_details` WHERE 1=1 ORDER BY `id` DESC " + " LIMIT " + limitAfter;
+
+        List<Map<String, Object>> resMap2 = namedParameterJdbcTemplate.queryForList(listSql, bindValue);
+
+        return resMap2;
+    }
+
     // 获取全部的sql
     public List<Map<String, Object>> getAllSqlList() {
         Map<String, Object> paramMap = new HashMap<>();

src/main/java/com/roma/romaapi/service/ApiService.java

@@ -179,6 +179,26 @@ public class ApiService {
         return res;
     }
 
+    // sql管理列表-获取带分页的page数据
+    public Map sqlListHasPaging(Map<String, String> maps) {
+        String page = "1"; // 页数
+        String perPage = "15"; // 显示多少条
+        Map res = new HashMap<>();
+        Map bindData = commonUtil.filterApiBindParams(maps);
+        if(maps.containsKey("page")) {
+            page = maps.get("page");
+        }
+        if(maps.containsKey("perPage")) {
+            perPage = maps.get("perPage");
+        }
+        Integer count = pageDao.getAllSqlListHasPagingCount(bindData);
+        List info = pageDao.getAllSqlListHasPaging(bindData, page, perPage, count);
+        res.put("count", count);
+        res.put("rows", info);
+
+        return res;
+    }
+
     // 获取全部sql_details
     public List sqlList() {
         Map<String, Object> map = new HashMap<>();
@@ -353,6 +373,47 @@ public class ApiService {
         return retInfo;
     }
 
+    // 添加sql_details表数据
+    public Map addSql(Map maps, String authorization) {
+        String sqlDesc = "";
+        String isList = maps.get("is_list").toString();
+        String sqlType = maps.get("sql_type").toString();
+        String isEnable = maps.get("is_enable").toString();
+        String sqlCode = maps.get("sql_code").toString();
+        String sqlName = maps.get("sql_name").toString();
+        String sqlString = maps.get("sql_string").toString();
+        if(maps.containsKey("sql_description")) {
+            sqlDesc = maps.get("sql_description").toString();
+        }
+        // 通过是否存在id,判读是新增还是修改
+        String editId = "";
+        if (maps.containsKey("id")) {
+            editId = maps.get("id").toString();
+        }
+        String createdAt = commonUtil.getNowYYMMDDHHIISS();
+        Map<String, Object> addPagePamars = new HashMap<>();
+        addPagePamars.put("isList", isList);
+        addPagePamars.put("sqlType", sqlType);
+        addPagePamars.put("isEnable", isEnable);
+        addPagePamars.put("sqlCode", sqlCode);
+        addPagePamars.put("sqlName", sqlName);
+        addPagePamars.put("sqlString", sqlString);
+        addPagePamars.put("sqlDesc", sqlDesc);
+        Map<String, Object> loginResult = this.userInfo(authorization);
+        addPagePamars.put("actionUser", loginResult.get("userName")); // 获取当前用户信息
+        if (editId.length()==0) {
+            // 如果不存在说明是新增
+            addPagePamars.put("createdAt", createdAt);
+        }
+        // 添加/编辑Sql
+        Integer pageId = apiDao.addSqlDetails(addPagePamars, editId);
+        Map retInfo = new HashMap<>();
+        if(pageId <= 0){
+            retInfo.put("sysErrorCode", "500");
+        }
+        return retInfo;
+    }
+
     // 转换tree结构数据
     private List<Map<String, Object>> treeMenu(List<Map<String, Object>> renderMenu){
         // 处理的数据存在