diff --git a/SingleSeachController.java b/SingleSeachController.java new file mode 100644 index 0000000..3054ac9 --- /dev/null +++ b/SingleSeachController.java @@ -0,0 +1,297 @@ +// 声明当前文件所在的包路径 +package com.controller; + +// 导入所需的Java类库 +import java.io.File; // 文件操作类 +import java.math.BigDecimal; // 高精度数字计算类 +import java.net.URL; // 统一资源定位符类 +import java.text.SimpleDateFormat; // 日期格式化类 +import com.alibaba.fastjson.JSONObject; // FastJSON的JSON对象类 +import java.util.*; // 通用工具类集合 +import org.springframework.beans.BeanUtils; // Spring Bean工具类 +import javax.servlet.http.HttpServletRequest; // HTTP请求类 +import org.springframework.web.context.ContextLoader; // Spring上下文加载器 +import javax.servlet.ServletContext; // Servlet上下文接口 +import com.service.TokenService; // 自定义Token服务类 +import com.utils.*; // 自定义工具类包 +import java.lang.reflect.InvocationTargetException; // 反射异常类 + +// 导入自定义服务类 +import com.service.DictionaryService; // 字典服务类 +import org.apache.commons.lang3.StringUtils; // Apache字符串工具类 +import com.annotation.IgnoreAuth; // 自定义忽略认证注解 +import org.slf4j.Logger; // 日志接口 +import org.slf4j.LoggerFactory; // 日志工厂类 +import org.springframework.beans.factory.annotation.Autowired; // Spring自动注入注解 +import org.springframework.stereotype.Controller; // Spring控制器注解 +import org.springframework.web.bind.annotation.*; // Spring Web注解集合 +import com.baomidou.mybatisplus.mapper.EntityWrapper; // MyBatis Plus实体包装类 +import com.baomidou.mybatisplus.mapper.Wrapper; // MyBatis Plus包装接口 +import com.entity.*; // 实体类包 +import com.entity.view.*; // 实体视图类包 +import com.service.*; // 服务接口包 +import com.utils.PageUtils; // 分页工具类 +import com.utils.R; // 通用返回结果类 +import com.alibaba.fastjson.*; // FastJSON工具包 + + + //单页数据 + //后端接口控制器 + //@author + //@email + +@RestController // 标识这是一个RESTful风格的控制器 +@Controller // 标识这是一个Spring MVC控制器 +@RequestMapping("/singleSeach") // 定义基础请求路径 +public class SingleSeachController { + private static final Logger logger = LoggerFactory.getLogger(SingleSeachController.class); // 日志记录器 + + private static final String TABLE_NAME = "singleSeach"; // 数据库表名常量 + + @Autowired + private SingleSeachService singleSeachService; // 注入单页数据服务 + + @Autowired + private TokenService tokenService; // 注入token服务 + + // 注入其他相关服务 + @Autowired + private DictionaryService dictionaryService; // 字典服务 + @Autowired + private ForumService forumService; // 健身论坛服务 + @Autowired + private JianshenkechengService jianshenkechengService; // 健身课程服务 + @Autowired + private JianshenkechengCollectionService jianshenkechengCollectionService; // 课程收藏服务 + @Autowired + private JianshenkechengLiuyanService jianshenkechengLiuyanService; // 课程留言服务 + @Autowired + private JiaolianService jiaolianService; // 教练服务 + @Autowired + private JiaolianYuyueService jiaolianYuyueService; // 教练预约申请服务 + @Autowired + private NewsService newsService; // 健身资讯服务 + @Autowired + private YonghuService yonghuService; // 用户服务 + @Autowired + private UsersService usersService; // 管理员服务 + + + //后端列表 + //分页查询单页数据 + //@param params 请求参数Map + //@param request HTTP请求对象 + //@return 返回分页数据结果 + + @RequestMapping("/page") + public R page(@RequestParam Map params, HttpServletRequest request){ + logger.debug("page方法:,,Controller:{},,params:{}",this.getClass().getName(),JSONObject.toJSONString(params)); // 记录日志 + String role = String.valueOf(request.getSession().getAttribute("role")); // 获取用户角色 + if(false) // 条件判断 + return R.error(511,"永不会进入"); // 返回错误信息 + else if("用户".equals(role)) // 如果是用户角色 + params.put("yonghuId",request.getSession().getAttribute("userId")); // 添加用户ID参数 + else if("教练".equals(role)) // 如果是教练角色 + params.put("jiaolianId",request.getSession().getAttribute("userId")); // 添加教练ID参数 + CommonUtil.checkMap(params); // 检查参数 + PageUtils page = singleSeachService.queryPage(params); // 调用服务层分页查询 + + // 字典表数据转换 + List list =(List)page.getList(); // 获取分页数据列表 + for(SingleSeachView c:list){ // 遍历列表 + dictionaryService.dictionaryConvert(c, request); // 转换字典表字段 + } + return R.ok().put("data", page); // 返回成功结果和数据 + } + + + //后端详情 + //根据ID查询单条单页数据详情 + //@param id 数据ID + //@param request HTTP请求对象 + //@return 返回查询结果 + @RequestMapping("/info/{id}") + public R info(@PathVariable("id") Long id, HttpServletRequest request){ + logger.debug("info方法:,,Controller:{},,id:{}",this.getClass().getName(),id); // 记录日志 + SingleSeachEntity singleSeach = singleSeachService.selectById(id); // 根据ID查询数据 + if(singleSeach !=null){ // 如果查询到数据 + SingleSeachView view = new SingleSeachView(); // 创建视图对象 + BeanUtils.copyProperties(singleSeach, view); // 复制属性到视图对象 + dictionaryService.dictionaryConvert(view, request); // 转换字典表字段 + return R.ok().put("data", view); // 返回成功结果和数据 + }else { + return R.error(511,"查不到数据"); // 返回错误信息 + } + } + + + //后端保存 + //新增单页数据 + //@param singleSeach 单页数据实体 + //@param request HTTP请求对象 + //@return 返回操作结果 + //@RequestMapping("/save") + public R save(@RequestBody SingleSeachEntity singleSeach, HttpServletRequest request){ + logger.debug("save方法:,,Controller:{},,singleSeach:{}",this.getClass().getName(),singleSeach.toString()); // 记录日志 + String role = String.valueOf(request.getSession().getAttribute("role")); // 获取用户角色 + if(false) // 条件判断 + return R.error(511,"永远不会进入"); // 返回错误信息 + + // 构建查询条件 + Wrapper queryWrapper = new EntityWrapper() + .eq("single_seach_types",singleSeach.getSingleSeachTypes()); // 按类型查询 + + logger.info("sql语句:"+queryWrapper.getSqlSegment()); // 记录SQL语句 + SingleSeachEntity singleSeachEntity = singleSeachService.selectOne(queryWrapper); // 查询是否存在 + if(singleSeachEntity==null){ // 如果不存在 + singleSeach.setCreateTime(new Date()); // 设置创建时间 + singleSeachService.insert(singleSeach); // 插入新数据 + return R.ok(); // 返回成功结果 + }else { + return R.error(511,"该类型已经有存在的,请删除后重新新增"); // 返回错误信息 + } + } + + //后端修改 + //更新单页数据 + //@param singleSeach 单页数据实体 + //@param request HTTP请求对象 + //@return 返回操作结果 + @RequestMapping("/update") + public R update(@RequestBody SingleSeachEntity singleSeach, HttpServletRequest request) throws NoSuchFieldException, ClassNotFoundException, IllegalAccessException, InstantiationException { + logger.debug("update方法:,,Controller:{},,singleSeach:{}",this.getClass().getName(),singleSeach.toString()); // 记录日志 + SingleSeachEntity oldSingleSeachEntity = singleSeachService.selectById(singleSeach.getId()); // 查询原数据 + + String role = String.valueOf(request.getSession().getAttribute("role")); // 获取用户角色 + if("".equals(singleSeach.getSingleSeachPhoto()) || "null".equals(singleSeach.getSingleSeachPhoto())){ // 如果图片为空 + singleSeach.setSingleSeachPhoto(null); // 设置为null + } + if("".equals(singleSeach.getSingleSeachContent()) || "null".equals(singleSeach.getSingleSeachContent())){ // 如果内容为空 + singleSeach.setSingleSeachContent(null); // 设置为null + } + + singleSeachService.updateById(singleSeach); // 更新数据 + return R.ok(); // 返回成功结果 + } + + + //删除 + //批量删除单页数据 + //@param ids 要删除的ID数组 + //@param request HTTP请求对象 + //@return 返回操作结果 + @RequestMapping("/delete") + public R delete(@RequestBody Integer[] ids, HttpServletRequest request){ + logger.debug("delete:,,Controller:{},,ids:{}",this.getClass().getName(),ids.toString()); // 记录日志 + List oldSingleSeachList = singleSeachService.selectBatchIds(Arrays.asList(ids)); // 查询要删除的数据 + singleSeachService.deleteBatchIds(Arrays.asList(ids)); // 批量删除 + return R.ok(); // 返回成功结果 + } + + + //批量上传/ + //通过Excel批量导入数据 + //@param fileName Excel文件名 + //@param request HTTP请求对象 + //@return 返回操作结果 + @RequestMapping("/batchInsert") + public R save(String fileName, HttpServletRequest request){ + logger.debug("batchInsert方法:,,Controller:{},,fileName:{}",this.getClass().getName(),fileName); // 记录日志 + Integer yonghuId = Integer.valueOf(String.valueOf(request.getSession().getAttribute("userId"))); // 获取用户ID + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); // 创建日期格式化对象 + try { + List singleSeachList = new ArrayList<>(); // 创建数据列表 + Map> seachFields = new HashMap<>(); // 创建查询字段Map + Date date = new Date(); // 当前时间 + int lastIndexOf = fileName.lastIndexOf("."); // 获取文件后缀位置 + if(lastIndexOf == -1){ // 如果没有后缀 + return R.error(511,"该文件没有后缀"); // 返回错误信息 + }else{ + String suffix = fileName.substring(lastIndexOf); // 获取文件后缀 + if(!".xls".equals(suffix)){ // 如果不是xls文件 + return R.error(511,"只支持后缀为xls的excel文件"); // 返回错误信息 + }else{ + URL resource = this.getClass().getClassLoader().getResource("static/upload/" + fileName); // 获取文件路径 + File file = new File(resource.getFile()); // 创建文件对象 + if(!file.exists()){ // 如果文件不存在 + return R.error(511,"找不到上传文件,请联系管理员"); // 返回错误信息 + }else{ + List> dataList = PoiUtil.poiImport(file.getPath()); // 读取Excel文件 + dataList.remove(0); // 删除标题行 + for(List data:dataList){ // 遍历数据行 + SingleSeachEntity singleSeachEntity = new SingleSeachEntity(); // 创建实体对象 + // 可以在此处设置实体属性,示例中被注释掉了 + singleSeachList.add(singleSeachEntity); // 添加到列表 + } + singleSeachService.insertBatch(singleSeachList); // 批量插入 + return R.ok(); // 返回成功结果 + } + } + } + }catch (Exception e){ // 捕获异常 + e.printStackTrace(); // 打印异常堆栈 + return R.error(511,"批量插入数据异常,请联系管理员"); // 返回错误信息 + } + } + + + //前端列表 + //无需认证的分页查询 + //@param params 请求参数Map + //@param request HTTP请求对象 + //@return 返回分页数据结果 + @IgnoreAuth // 忽略认证 + @RequestMapping("/list") + public R list(@RequestParam Map params, HttpServletRequest request){ + logger.debug("list方法:,,Controller:{},,params:{}",this.getClass().getName(),JSONObject.toJSONString(params)); // 记录日志 + CommonUtil.checkMap(params); // 检查参数 + PageUtils page = singleSeachService.queryPage(params); // 分页查询 + + List list = (List)page.getList(); // 获取数据列表 + for(SingleSeachView c:list) // 遍历列表 + dictionaryService.dictionaryConvert(c, request); // 转换字典表字段 + + return R.ok().put("data", page); // 返回成功结果和数据 + } + + + //前端详情 + //根据类型查询单条数据 + //@param id 数据类型ID + //@param request HTTP请求对象 + //@return 返回查询结果 + @RequestMapping("/detail/{id}") + public R detail(@PathVariable("id") Integer id, HttpServletRequest request){ + logger.debug("detail方法:,,Controller:{},,id:{}",this.getClass().getName(),id); // 记录日志 + // 根据类型查询单条数据 + SingleSeachEntity singleSeach = singleSeachService.selectOne(new EntityWrapper().eq("single_seach_types", id)); + if(singleSeach != null) // 如果查询到数据 + return R.ok().put("data", singleSeach); // 返回成功结果和数据 + else + return R.error(511,"查不到数据"); // 返回错误信息 + } + + + //前端保存 + //新增单页数据 + //@param singleSeach 单页数据实体 + //@param request HTTP请求对象 + //@return 返回操作结果 + @RequestMapping("/add") + public R add(@RequestBody SingleSeachEntity singleSeach, HttpServletRequest request){ + logger.debug("add方法:,,Controller:{},,singleSeach:{}",this.getClass().getName(),singleSeach.toString()); // 记录日志 + // 构建查询条件 + Wrapper queryWrapper = new EntityWrapper() + .eq("single_seach_types",singleSeach.getSingleSeachTypes()); // 按类型查询 + + logger.info("sql语句:"+queryWrapper.getSqlSegment()); // 记录SQL语句 + SingleSeachEntity singleSeachEntity = singleSeachService.selectOne(queryWrapper); // 查询是否已存在 + if(singleSeachEntity==null){ // 如果不存在 + singleSeach.setCreateTime(new Date()); // 设置创建时间 + singleSeachService.insert(singleSeach); // 插入新数据 + return R.ok(); // 返回成功结果 + }else { + return R.error(511,"该类型已经有存在的,请删除后重新新增"); // 返回错误信息 + } + } +} \ No newline at end of file