场地预约(javaweb实训项目)的所有代码

package com.example.servlet; import com.example.pojo.ClassAll; import com.example.pojo.ClassInfo; import com.example.pojo.User; import com.example.service.ClassAllService; import com.example.service.ClassInfoService; import com.example.service.UserService; import com.google.gson.Gson; import com.google.gson.GsonBuilder; import com.google.gson.JsonArray; import jakarta.servlet.ServletException; import jakarta.servlet.annotation.WebServlet; import jakarta.servlet.http.HttpServlet; import jakarta.servlet.http.HttpServletRequest; import jakarta.servlet.http.HttpServletResponse; import java.io.IOException; import java.io.PrintWriter; import java.sql.SQLException; import java.time.LocalDate; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; @WebServlet("/Index") public class Index extends HttpServlet {// 首页 // 设置放监听的Map private Map<String, ScheduledExecutorService> schedulerMap = new HashMap<>(); // schedulerMap的获取方法 public Map<String, ScheduledExecutorService> getSchedulerMap() { return schedulerMap; } @Override protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws IOException { req.setCharacterEncoding("UTF-8"); String type = req.getParameter("type");// 前端传过来的type ClassAllService classAllService = new ClassAllService(); Gson gson = new GsonBuilder().setDateFormat("yyyy-MM-dd").create(); int user_id = -1; if(req.getSession().getAttribute("user_id") != null){ user_id = (int)req.getSession().getAttribute("user_id"); // 用户已登录，获取session中存的用户id } if("class_all".equals(type)) { List<ClassAll> class_all = null;// 场地表 HashMap<Object, Object> dataMap = new HashMap<>(); try { class_all = classAllService.getAllClassAll();// 获取所有场地表 dataMap.put("class_all", class_all); dataMap.put("user_id", user_id); }catch (SQLException e) { throw new RuntimeException(e); } resp.setContentType("text/json;charset=utf-8"); PrintWriter pw = resp.getWriter(); pw.print(gson.toJson(dataMap)); } } @Override protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { req.setCharacterEncoding("UTF-8"); String type = req.getParameter("type");// 前端传过来的type ClassInfoService classInfoService = new ClassInfoService(); Gson gson = new GsonBuilder().setDateFormat("yyyy-MM-dd").create(); int user_id = -1; if(req.getSession().getAttribute("user_id") != null){ user_id = (int)req.getSession().getAttribute("user_id"); // 用户已登录，获取session中存的用户id } if("updateClass_Info".equals(type)) { String message = null; // 1.获取请求体传过来的值 String class_all_id_temp = req.getParameter("class_all_id"); String radioValue = req.getParameter("radioValue"); String checkboxValues = req.getParameter("checkboxValues"); JsonArray jsonArray = gson.fromJson(checkboxValues, JsonArray.class); int class_all_id = Integer.parseInt(class_all_id_temp); // 对checkboxValues进行处理 String[] names = new String[jsonArray.size()]; if(jsonArray.size() > 2){ //后端再次判断单次预约是否超过2小时 message = "单次预约不能超过2小时！哥们修改js是没用滴。"; }else{ for(int i = 0;i < jsonArray.size();i++){ // 数据处理，class_info表的name字段标准化 int checkboxValue = jsonArray.get(i).getAsInt(); // 处理names[i]为数据库对应格式 if(radioValue.equals("today")){ // 正常不用处理 }else if(radioValue.equals("tomorrow")){ checkboxValue = checkboxValue + 12; }else{ checkboxValue = checkboxValue + 24; } names[i] = radioValue + "_th" + checkboxValue; System.out.println(names[i]); // 输出测试 } // 2.循环查询是否已经被预约 boolean is_right = true; for(int i = 0;i < jsonArray.size();i++){ ClassInfo classInfo = null; try { classInfo = classInfoService.getClassInfo(class_all_id, names[i]); System.out.println("state: " + classInfo.getClass_state() + ", user_id: " + classInfo.getUser_id()); if(classInfo.getClass_state() != 0 || classInfo.getUser_id() != 0){ is_right = false; break; } } catch (SQLException e) { throw new RuntimeException(e); } } if(!is_right){ // 3.返回提示已经被预约 message = "失败!您选择的场地已经被预约了！"; }else{ // 3.预约 is_right = true; // 检查用户当前grade为多少，是否够预约 UserService userService = new UserService(); User user = null; List<ClassInfo> user_classInfo = null; // 查询用户等级可以预约的数量 int user_count = 0; try { user = userService.getUserById(user_id); if(user.getGrade() == 0){ user_count = 2; }else{ user_count = 6; } // 查询用户当前预约了多少小时 user_classInfo = classInfoService.getClassInfoByUser_id(user_id); if(user_classInfo.size() + jsonArray.size() > user_count){ // 准备预约的和已有的加起来大于限制 message = "抱歉，超出用户当前级别最大可预约的数量！"; is_right = false; } } catch (SQLException e) { throw new RuntimeException(e); } if(is_right){ // 循环update int i; for(i = 0;i < names.length;i++){ ClassInfo classInfo = new ClassInfo(-1, "", names[i], 1,user_id, class_all_id); try { int count = classInfoService.updateClassInfo(classInfo); if(count != 1) { message = "预约内部程序处理错误!"; break; } // --------超时自动取消部分-监听 // 2.根据class_info的name值转成时间,监听时间值每小时是否相等 String now_day = names[i].split("_th")[0]; // 日期 LocalDate today_temp = LocalDate.now();