diff --git a/ruoyi-models/ruoyi-online/src/main/java/com/ruoyi/online/controller/OnLineController.java b/ruoyi-models/ruoyi-online/src/main/java/com/ruoyi/online/controller/OnLineController.java index 37f6476..4eb976a 100644 --- a/ruoyi-models/ruoyi-online/src/main/java/com/ruoyi/online/controller/OnLineController.java +++ b/ruoyi-models/ruoyi-online/src/main/java/com/ruoyi/online/controller/OnLineController.java @@ -72,7 +72,7 @@ public class OnLineController extends BaseController { return object; } - public Boolean checkPermission(String permissionType,String permissionValue) { + public Boolean checkPermission(String permissionType, String permissionValue) { if (permissionType == null) return true; return switch (permissionType) { @@ -89,18 +89,22 @@ public class OnLineController extends BaseController { public Object processingMapper(String sqlContext, String actuatot, Map params) { String sql = ""; SqlSession sqlSession = sqlSessionFactory.openSession(); - SqlMapper sqlMapper = new SqlMapper(sqlSession); - Object res = null; - res = switch (actuatot) { - case "selectList" -> getDataTable(sqlMapper.selectList(sql, params)); - case "insert" -> toAjax(sqlMapper.insert(sql, params)); - case "selectOne" -> success(sqlMapper.selectOne(sql, params)); - case "update" -> toAjax(sqlMapper.update(sql, params)); - case "delete" -> toAjax(sqlMapper.delete(sql, params)); - default -> AjaxResult.error(500, "系统错误,执行器错误"); - }; - sqlSession.close(); - return res; + try { + SqlMapper sqlMapper = new SqlMapper(sqlSession); + Object res = null; + res = switch (actuatot) { + case "selectList" -> getDataTable(sqlMapper.selectList(sql, params)); + case "insert" -> toAjax(sqlMapper.insert(sql, params)); + case "selectOne" -> success(sqlMapper.selectOne(sql, params)); + case "update" -> toAjax(sqlMapper.update(sql, params)); + case "delete" -> toAjax(sqlMapper.delete(sql, params)); + default -> AjaxResult.error(500, "系统错误,执行器错误"); + }; + return res; + } finally { + sqlSession.close(); + } + } @RequestMapping("/api/**") @@ -120,7 +124,7 @@ public class OnLineController extends BaseController { return AjaxResult.error(500, "系统错误,在线接口重复"); } else { OnlineMb onlineMb = selectOnlineMbList.get(0); - if (!checkPermission(onlineMb.getPermissionType(),onlineMb.getPermissionValue())) + if (!checkPermission(onlineMb.getPermissionType(), onlineMb.getPermissionValue())) return AjaxResult.error(403, "没有权限,请联系管理员授权"); if (onlineMb.getDeptId() != null && onlineMb.getDeptId().equals("1")) { diff --git a/sql/online.sql b/sql/online.sql index baf1b9f..cfc33d0 100644 --- a/sql/online.sql +++ b/sql/online.sql @@ -15,7 +15,7 @@ CREATE TABLE online_mb ( dept_id char(1) NULL COMMENT '是否需要deptId', permission_type varchar(255) NULL COMMENT '许可类型', permission_value varchar(255) NULL COMMENT '许可值', - del_flag varchar(10) NOT NULL COMMENT '删除标志(0代表存在 1代表删除)', + del_flag varchar(10) NOT NULL DEFAULT '0' COMMENT '删除标志(0代表存在 1代表删除)', PRIMARY KEY (mb_id) ) ENGINE = InnoDB COMMENT = '在线接口';