phfsut2ie
4 months ago
parent
bf743d7819
commit
2c28f5f0c0
@ -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<String, Object> 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<SingleSeachView> list =(List<SingleSeachView>)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<SingleSeachEntity> queryWrapper = new EntityWrapper<SingleSeachEntity>()
|
||||
.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<SingleSeachEntity> 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<SingleSeachEntity> singleSeachList = new ArrayList<>(); // 创建数据列表
|
||||
Map<String, List<String>> 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<List<String>> dataList = PoiUtil.poiImport(file.getPath()); // 读取Excel文件
|
||||
dataList.remove(0); // 删除标题行
|
||||
for(List<String> 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<String, Object> params, HttpServletRequest request){
|
||||
logger.debug("list方法:,,Controller:{},,params:{}",this.getClass().getName(),JSONObject.toJSONString(params)); // 记录日志
|
||||
CommonUtil.checkMap(params); // 检查参数
|
||||
PageUtils page = singleSeachService.queryPage(params); // 分页查询
|
||||
|
||||
List<SingleSeachView> list = (List<SingleSeachView>)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<SingleSeachEntity>().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<SingleSeachEntity> queryWrapper = new EntityWrapper<SingleSeachEntity>()
|
||||
.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,"该类型已经有存在的,请删除后重新新增"); // 返回错误信息
|
||||
}
|
||||
}
|
||||
}
|
||||
Loading…
Reference in new issue