w_sky_server

sky/sky-server/src/main/java/com/sky/aspectj/AutoFillAspect.java

@@ -0,0 +1,97 @@
+// 定义包名，表示该类属于com.sky.aspectj包
+package com.sky.aspectj;
+
+// 导入所需的类和接口
+import com.sky.annotation.AutoFill;
+import com.sky.constant.AutoFillConstant;
+import com.sky.context.BaseContext;
+import com.sky.enumeration.OperationType;
+import lombok.extern.slf4j.Slf4j;
+import org.aspectj.lang.JoinPoint;
+import org.aspectj.lang.Signature;
+import org.aspectj.lang.annotation.Aspect;
+import org.aspectj.lang.annotation.Before;
+import org.aspectj.lang.annotation.Pointcut;
+import org.aspectj.lang.reflect.MethodSignature;
+import org.springframework.stereotype.Component;
+
+import java.lang.reflect.Field;
+import java.lang.reflect.InvocationTargetException;
+import java.lang.reflect.Method;
+import java.time.LocalDateTime;
+import java.util.*;
+
+// 使用@Aspect注解声明一个切面
+@Aspect
+// 使用@Slf4j注解为类自动注入一个日志对象
+@Slf4j
+// 使用@Component注解声明一个Spring组件，使其可以被Spring容器管理
+@Component
+public class AutoFillAspect {
+
+    // 定义一个切入点，匹配所有标记了@AutoFill注解的com.sky.mapper包下的方法
+    @Pointcut("@annotation(com.sky.annotation.AutoFill)" + "&& execution(* com.sky.mapper.*.*(..))")
+    public void pointCount() {
+    }
+
+    // 前置通知，执行切入点匹配的方法之前
+    @Before("pointCount()")
+    public void beforeAutoFillAspect(JoinPoint joinPoint) throws InvocationTargetException, IllegalAccessException {
+        // 获取方法签名
+        MethodSignature signature = (MethodSignature) joinPoint.getSignature();
+        // 获取当前执行的方法
+        Method method = signature.getMethod();
+        // 获取方法参数
+        Object[] args = joinPoint.getArgs();
+        // 获取方法上的@AutoFill注解
+        AutoFill autoFill = method.getAnnotation(AutoFill.class);
+        // 从注解中获取操作类型
+        OperationType value = autoFill.value();
+
+        // 存放每个参数对象及其所有方法的映射
+        HashMap<Object, Method[]> methodHashMap = new HashMap<>();
+        // 遍历参数对象，获取每个对象的所有方法
+        for (Object arg : args) {
+            Class<?> argClass = arg.getClass();
+            Method[] methods = argClass.getDeclaredMethods();
+            methodHashMap.put(arg, methods);
+        }
+
+        // 根据操作类型进行不同的字段填充
+        if (value.equals(OperationType.INSERT)) {
+            // 插入操作，填充创建时间和创建用户
+            for (Map.Entry<Object, Method[]> entry : methodHashMap.entrySet()) {
+                Object key = entry.getKey();
+                for (Method method1 : entry.getValue()) {
+                    // 填充创建时间和更新时间
+                    if (method1.getName().equals(AutoFillConstant.SET_UPDATE_TIME) || method.getName().equals(AutoFillConstant.SET_CREATE_TIME)) {
+                        method1.invoke(key, LocalDateTime.now());
+                    }
+                    // 填充创建用户和更新用户
+                    if (method1.getName().equals(AutoFillConstant.SET_CREATE_USER) || method.getName().equals(AutoFillConstant.SET_UPDATE_USER)) {
+                        method1.invoke(key, BaseContext.getCurrentId());
+                    }
+                }
+            }
+        } else if (value.equals(OperationType.UPDATE)) {
+            // 更新操作，填充更新时间和更新用户
+            for (Map.Entry<Object, Method[]> entry : methodHashMap.entrySet()) {
+                Object key = entry.getKey();
+                for (Method method1 : entry.getValue()) {
+                    // 填充更新时间
+                    if (method1.getName().equals(AutoFillConstant.SET_UPDATE_TIME)) {
+                        method1.invoke(key, LocalDateTime.now());
+                    }
+                    // 填充更新用户
+                    if (method1.getName().equals(AutoFillConstant.SET_UPDATE_USER)) {
+                        method1.invoke(key, BaseContext.getCurrentId());
+                    }
+                }
+            }
+        } else {
+            // 非法操作类型，抛出异常
+            throw new IllegalArgumentException("自动填充操作类型参数异常！");
+        }
+    }
+
+}

sky/sky-server/src/main/java/com/sky/controller/admin/CategoryController.java

@@ -0,0 +1,134 @@
+// 定义包名，表示该类属于com.sky.controller.admin包
+package com.sky.controller.admin;
+
+// 导入所需的类和接口
+import com.sky.dto.CategoryDTO;
+import com.sky.dto.CategoryPageQueryDTO;
+import com.sky.entity.Category;
+import com.sky.result.PageResult;
+import com.sky.result.Result;
+import com.sky.service.CategoryService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+// 使用@RestController注解声明这是一个REST控制器，返回的数据会自动转换为JSON格式
+@RestController
+// 使用@RequestMapping注解定义类级别的路由，所有的请求都会以"/admin/category"作为前缀
+@RequestMapping("/admin/category")
+// 使用@Slf4j注解为类自动注入一个日志对象
+@Slf4j
+// 使用@Api注解标记这个控制器属于哪个API分类
+@Api(tags = "分类相关接口")
+public class CategoryController {
+    // 自动注入CategoryService服务
+    @Autowired
+    CategoryService categoryService;
+
+    /**
+     * 分类分页查询接口
+     *
+     * @param categoryPageQueryDTO 分页查询参数
+     * @return 分页查询结果
+     */
+    @GetMapping({"/page"})
+    @ApiOperation("分类分页查询")
+    public Result<PageResult> pageQuery(CategoryPageQueryDTO categoryPageQueryDTO) {
+        // 记录日志
+        log.info("分类分页查询:{}", categoryPageQueryDTO);
+        // 调用服务层进行分页查询
+        PageResult pageResult = categoryService.pageQuery(categoryPageQueryDTO);
+        // 返回查询结果
+        return Result.success(pageResult);
+    }
+
+    /**
+     * 根据类型查询分类接口
+     *
+     * @param type 分类类型
+     * @return 分类列表
+     */
+    @GetMapping("/list")
+    @ApiOperation("根据类型查询分类")
+    public Result<List> query(Integer type) {
+        // 记录日志
+        log.info("根据类型查询分类:{}", type);
+        // 调用服务层根据类型查询分类
+        List<Category> result = categoryService.query(type);
+        // 返回查询结果
+        return Result.success(result);
+    }
+
+    /**
+     * 删除分类接口
+     *
+     * @param id 要删除的分类ID
+     * @return 操作结果
+     */
+    @DeleteMapping
+    @ApiOperation("删除分类")
+    public Result deleteCategory(Long id) {
+        // 记录日志
+        log.info("删除分类:{}", id);
+        // 调用服务层删除分类
+        categoryService.delete(id);
+        // 返回操作结果
+        return Result.success();
+    }
+
+    /**
+     * 修改分类接口
+     *
+     * @param categoryDTO 包含修改信息的分类DTO
+     * @return 操作结果
+     */
+    @PutMapping
+    @ApiOperation("修改分类")
+    public Result updateCategory(@RequestBody CategoryDTO categoryDTO) {
+        // 记录日志
+        log.info("修改分类：{}", categoryDTO);
+        // 调用服务层修改分类
+        categoryService.updateCategory(categoryDTO);
+        // 返回操作结果
+        return Result.success();
+    }
+
+    /**
+     * 启用或禁用分类接口
+     *
+     * @param status 状态值，用于标识启用或禁用
+     * @param id 要修改状态的分类ID
+     * @return 操作结果
+     */
+    @PostMapping("/status/{status}")
+    @ApiOperation("启用禁用分类")
+    public Result startOrStop(@PathVariable Integer status, Long id) {
+        // 记录日志
+        log.info("启用禁用分类status:{},id:{}", status, id);
+        // 调用服务层启用或禁用分类
+        categoryService.startOrStop(status, id);
+        // 返回操作结果
+        return Result.success();
+    }
+
+    /**
+     * 新增分类接口
+     *
+     * @param categoryDTO 包含新增信息的分类DTO
+     * @return 操作结果
+     */
+    @PostMapping
+    @ApiOperation("新增分类")
+    public Result save(@RequestBody CategoryDTO categoryDTO) {
+        // 记录日志
+        log.info("新增分类:{}", categoryDTO);
+        // 调用服务层新增分类
+        categoryService.save(categoryDTO);
+        // 返回操作结果
+        return Result.success();
+    }
+}

sky/sky-server/src/main/java/com/sky/controller/admin/OrderController.java

@@ -0,0 +1,153 @@
+// 定义包名，表示该类属于com.sky.controller.admin包
+package com.sky.controller.admin;
+
+// 导入所需的类和接口
+import com.sky.dto.OrdersCancelDTO;
+import com.sky.dto.OrdersConfirmDTO;
+import com.sky.dto.OrdersPageQueryDTO;
+import com.sky.dto.OrdersRejectionDTO;
+import com.sky.result.PageResult;
+import com.sky.result.Result;
+import com.sky.service.OrderService;
+import com.sky.vo.OrderStatisticsVO;
+import com.sky.vo.OrderVO;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * 订单管理控制器类，提供了一系列的接口用于订单管理。
+ */
+@RestController("adminOrderController")
+@RequestMapping("/admin/order")
+@Slf4j
+@Api(tags = "订单管理接口")
+public class OrderController {
+
+    // 自动注入OrderService服务
+    @Autowired
+    private OrderService orderService;
+
+    /**
+     * 完成订单接口
+     *
+     * @param id 订单ID
+     * @return 操作结果
+     */
+    @PutMapping("/complete/{id}")
+    @ApiOperation("完成订单")
+    public Result complete(@PathVariable("id") Long id) {
+        // 调用服务层完成订单
+        orderService.complete(id);
+        // 返回操作结果
+        return Result.success();
+    }
+
+    /**
+     * 派送订单接口
+     *
+     * @param id 订单ID
+     * @return 操作结果
+     */
+    @PutMapping("/delivery/{id}")
+    @ApiOperation("派送订单")
+    public Result delivery(@PathVariable("id") Long id) {
+        // 调用服务层派送订单
+        orderService.delivery(id);
+        // 返回操作结果
+        return Result.success();
+    }
+
+    /**
+     * 订单搜索接口
+     *
+     * @param ordersPageQueryDTO 订单搜索参数
+     * @return 订单搜索结果
+     */
+    @GetMapping("/conditionSearch")
+    @ApiOperation("订单搜索")
+    public Result<PageResult> conditionSearch(OrdersPageQueryDTO ordersPageQueryDTO) {
+        // 调用服务层进行订单搜索
+        PageResult pageResult = orderService.conditionSearch(ordersPageQueryDTO);
+        // 返回搜索结果
+        return Result.success(pageResult);
+    }
+
+    /**
+     * 各个状态的订单数量统计接口
+     *
+     * @return 订单数量统计结果
+     */
+    @GetMapping("/statistics")
+    @ApiOperation("各个状态的订单数量统计")
+    public Result<OrderStatisticsVO> statistics() {
+        // 调用服务层获取订单数量统计
+        OrderStatisticsVO orderStatisticsVO = orderService.statistics();
+        // 返回统计结果
+        return Result.success(orderStatisticsVO);
+    }
+
+    /**
+     * 查询订单详情接口
+     *
+     * @param id 订单ID
+     * @return 订单详情
+     */
+    @GetMapping("/details/{id}")
+    @ApiOperation("查询订单详情")
+    public Result<OrderVO> details(@PathVariable("id") Long id) {
+        // 调用服务层查询订单详情
+        OrderVO orderVO = orderService.details(id);
+        // 返回订单详情
+        return Result.success(orderVO);
+    }
+
+    /**
+     * 接单接口
+     *
+     * @param ordersConfirmDTO 接单参数
+     * @return 操作结果
+     */
+    @PutMapping("/confirm")
+    @ApiOperation("接单")
+    public Result confirm(@RequestBody OrdersConfirmDTO ordersConfirmDTO) {
+        // 调用服务层接单
+        orderService.confirm(ordersConfirmDTO);
+        // 返回操作结果
+        return Result.success();
+    }
+
+    /**
+     * 拒单接口
+     *
+     * @param ordersRejectionDTO 拒单参数
+     * @return 操作结果
+     * @throws Exception 可能抛出的异常
+     */
+    @PutMapping("/rejection")
+    @ApiOperation("拒单")
+    public Result rejection(@RequestBody OrdersRejectionDTO ordersRejectionDTO) throws Exception {
+        // 调用服务层拒单
+        orderService.rejection(ordersRejectionDTO);
+        // 返回操作结果
+        return Result.success();
+    }
+
+    /**
+     * 取消订单接口
+     *
+     * @param ordersCancelDTO 取消订单参数
+     * @return 操作结果
+     * @throws Exception 可能抛出的异常
+     */
+    @PutMapping("/cancel")
+    @ApiOperation("取消订单")
+    public Result cancel(@RequestBody OrdersCancelDTO ordersCancelDTO) throws Exception {
+        // 调用服务层取消订单
+        orderService.cancel(ordersCancelDTO);
+        // 返回操作结果
+        return Result.success();
+    }
+}

sky/sky-server/src/main/java/com/sky/controller/admin/WorkSpaceController.java

@@ -0,0 +1,94 @@
+// 定义包名，表示该类属于com.sky.controller.admin包
+package com.sky.controller.admin;
+
+// 导入所需的类和接口
+import com.sky.result.Result;
+import com.sky.service.WorkspaceService;
+import com.sky.vo.BusinessDataVO;
+import com.sky.vo.DishOverViewVO;
+import com.sky.vo.OrderOverViewVO;
+import com.sky.vo.SetmealOverViewVO;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import java.time.LocalDateTime;
+import java.time.LocalTime;
+
+/**
+ * 工作台控制器类，提供了一系列的接口用于工作台数据的查询。
+ */
+@RestController
+@RequestMapping("/admin/workspace")
+@Slf4j
+@Api(tags = "工作台相关接口")
+public class WorkSpaceController {
+
+    // 自动注入WorkspaceService服务
+    @Autowired
+    private WorkspaceService workspaceService;
+
+    /**
+     * 工作台今日数据查询接口
+     *
+     * @return 工作台今日数据视图对象
+     */
+    @GetMapping("/businessData")
+    @ApiOperation("工作台今日数据查询")
+    public Result<BusinessDataVO> businessData(){
+        // 获得当天的开始时间（00:00:00）
+        LocalDateTime begin = LocalDateTime.now().with(LocalTime.MIN);
+        // 获得当天的结束时间（23:59:59）
+        LocalDateTime end = LocalDateTime.now().with(LocalTime.MAX);
+
+        // 调用服务层获取工作台今日数据
+        BusinessDataVO businessDataVO = workspaceService.getBusinessData(begin, end);
+        // 返回工作台今日数据
+        return Result.success(businessDataVO);
+    }
+
+    /**
+     * 查询订单管理数据接口
+     *
+     * @return 订单管理数据视图对象
+     */
+    @GetMapping("/overviewOrders")
+    @ApiOperation("查询订单管理数据")
+    public Result<OrderOverViewVO> orderOverView(){
+        // 调用服务层获取订单管理数据
+        OrderOverViewVO orderOverViewVO = workspaceService.getOrderOverView();
+        // 返回订单管理数据
+        return Result.success(orderOverViewVO);
+    }
+
+    /**
+     * 查询菜品总览接口
+     *
+     * @return 菜品总览视图对象
+     */
+    @GetMapping("/overviewDishes")
+    @ApiOperation("查询菜品总览")
+    public Result<DishOverViewVO> dishOverView(){
+        // 调用服务层获取菜品总览数据
+        DishOverViewVO dishOverViewVO = workspaceService.getDishOverView();
+        // 返回菜品总览数据
+        return Result.success(dishOverViewVO);
+    }
+
+    /**
+     * 查询套餐总览接口
+     *
+     * @return 套餐总览视图对象
+     */
+    @GetMapping("/overviewSetmeals")
+    @ApiOperation("查询套餐总览")
+    public Result<SetmealOverViewVO> setmealOverView(){
+        // 调用服务层获取套餐总览数据
+        SetmealOverViewVO setmealOverViewVO = workspaceService.getSetmealOverView();
+        // 返回套餐总览数据
+        return Result.success(setmealOverViewVO);
+    }
+}

sky/sky-server/src/main/java/com/sky/controller/user/DishController.java

@@ -0,0 +1,75 @@
+// 定义包名，表示该类属于com.sky.controller.user包
+package com.sky.controller.user;
+
+// 导入所需的类和接口
+import com.sky.constant.StatusConstant;
+import com.sky.entity.Dish;
+import com.sky.result.Result;
+import com.sky.service.DishService;
+import com.sky.vo.DishVO;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.core.ValueOperations;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+// 使用@RestController注解声明这是一个REST控制器，返回的数据会自动转换为JSON格式
+@RestController("userDishController")
+// 使用@RequestMapping注解定义类级别的路由，所有的请求都会以"/user/dish"作为前缀
+@RequestMapping("/user/dish")
+// 使用@Slf4j注解为类自动注入一个日志对象
+@Slf4j
+// 使用@Api注解标记这个控制器属于哪个API分类
+@Api(tags = "C端-菜品浏览接口")
+public class DishController {
+
+    // 自动注入DishService服务
+    @Autowired
+    private DishService dishService;
+
+    // 自动注入RedisTemplate，用于操作Redis缓存
+    @Autowired
+    private RedisTemplate redisTemplate;
+
+    /**
+     * 根据分类id查询菜品接口
+     *
+     * @param categoryId 分类ID
+     * @return 菜品列表
+     */
+    @GetMapping("/list")
+    @ApiOperation("根据分类id查询菜品")
+    public Result<List<DishVO>> list(Long categoryId) {
+        // 记录日志，输出查询的分类ID
+        log.info("根据分类id查询菜品:{}", categoryId);
+        // 定义Redis缓存的键
+        String key = "dish_" + categoryId;
+
+        // 从缓存中获取菜品列表
+        ValueOperations valueOperations = redisTemplate.opsForValue();
+        List<DishVO> dishVOList = (List<DishVO>) valueOperations.get(key);
+
+        // 如果缓存中存在菜品列表，直接返回
+        if (dishVOList != null && dishVOList.size() > 0) {
+            return Result.success(dishVOList);
+        }
+
+        // 如果缓存中不存在，则从数据库中查询
+        Dish dish = new Dish();
+        dish.setCategoryId(categoryId); // 设置查询条件为分类ID
+        dish.setStatus(StatusConstant.ENABLE); // 查询起售中的菜品
+
+        // 从数据库中获取菜品列表，并存入缓存
+        List<DishVO> list = dishService.listWithFlavor(dish);
+        valueOperations.set(key, list); // 将查询结果存入Redis缓存
+
+        // 返回查询结果
+        return Result.success(list);
+    }
+}

sky/sky-server/src/main/java/com/sky/controller/user/ShoppingCartController.java

@@ -0,0 +1,99 @@
+// 定义包名，表示该类属于com.sky.controller.user包
+package com.sky.controller.user;
+
+// 导入所需的类和接口
+import com.sky.dto.ShoppingCartDTO;
+import com.sky.entity.ShoppingCart;
+import com.sky.result.Result;
+import com.sky.service.ShoppingCartService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+// 使用@RestController注解声明这是一个REST控制器，返回的数据会自动转换为JSON格式
+@RestController
+// 使用@Api注解标记这个控制器属于哪个API分类
+@Api("C端购物车相关接口")
+// 使用@Slf4j注解为类自动注入一个日志对象
+@Slf4j
+// 使用@RequestMapping注解定义类级别的路由，所有的请求都会以"/user/shoppingCart"作为前缀
+@RequestMapping("/user/shoppingCart")
+public class ShoppingCartController {
+    // 自动注入ShoppingCartService服务
+    @Autowired
+    ShoppingCartService shoppingCartService;
+
+    /**
+     * 添加商品到购物车接口
+     *
+     * @param shoppingCartDTO 包含商品信息的购物车DTO对象
+     * @return 操作结果
+     */
+    @PostMapping("/add")
+    @ApiOperation("添加购物车")
+    public Result add(@RequestBody ShoppingCartDTO shoppingCartDTO) {
+        // 记录日志，输出添加到购物车的商品信息
+        log.info("添加购物车：购物车信息:{}", shoppingCartDTO);
+
+        // 调用服务层添加商品到购物车
+        shoppingCartService.add(shoppingCartDTO);
+        // 返回操作成功的结果
+        return Result.success();
+    }
+
+    /**
+     * 查看用户购物车数据接口
+     *
+     * @return 用户购物车中的商品列表
+     */
+    @GetMapping("/list")
+    @ApiOperation("查看购物车")
+    public Result<List<ShoppingCart>> list() {
+        // 记录日志，标记查看购物车数据的操作
+        log.info("查看购物车数据");
+
+        // 调用服务层获取用户购物车中的商品列表
+        List<ShoppingCart> shoppingCartList = shoppingCartService.list();
+        // 返回购物车商品列表
+        return Result.success(shoppingCartList);
+    }
+
+    /**
+     * 删除购物车中的一个商品接口
+     *
+     * @param shoppingCartDTO 包含商品信息的购物车DTO对象
+     * @return 操作结果
+     */
+    @PostMapping("/sub")
+    @ApiOperation("删除购物车中的商品")
+    public Result delete(@RequestBody ShoppingCartDTO shoppingCartDTO){
+        // 记录日志，输出删除的商品信息
+        log.info("删除购物车中的商品:{}",shoppingCartDTO);
+        // 调用服务层删除购物车中的一个商品
+        shoppingCartService.delete(shoppingCartDTO);
+
+        // 返回操作成功的结果
+        return Result.success();
+    }
+
+    /**
+     * 清空购物车接口
+     *
+     * @return 操作结果
+     */
+    @DeleteMapping("/clean")
+    @ApiOperation("清空购物车")
+    public Result clean(){
+        // 记录日志，标记清空购物车的操作
+        log.info("清空购物车");
+        // 调用服务层清空购物车
+        shoppingCartService.clean();
+
+        // 返回操作成功的结果
+        return Result.success();
+    }
+}

sky/sky-server/src/main/java/com/sky/interceptor/JwtTokenUserInterceptor.java

@@ -0,0 +1,68 @@
+// 定义包名，表示该类属于com.sky.interceptor包
+package com.sky.interceptor;
+
+// 导入所需的类和接口
+import com.sky.constant.JwtClaimsConstant;
+import com.sky.constant.MessageConstant;
+import com.sky.context.BaseContext;
+import com.sky.properties.JwtProperties;
+import com.sky.utils.JwtUtil;
+import io.jsonwebtoken.Claims;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.springframework.web.method.HandlerMethod;
+import org.springframework.web.servlet.HandlerInterceptor;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+/**
+ * JWT令牌校验的拦截器，用于在Spring MVC应用中拦截请求并验证JWT令牌的有效性。
+ */
+@Component
+@Slf4j
+public class JwtTokenUserInterceptor implements HandlerInterceptor {
+
+    // 自动注入JwtProperties，用于获取JWT配置属性
+    @Autowired
+    private JwtProperties jwtProperties;
+
+    /**
+     * preHandle方法在请求处理之前进行调用，除非抛出异常，否则总是被调用。
+     *
+     * @param request 当前请求对象
+     * @param response 当前响应对象
+     * @param handler HandlerMethod对象，如果当前拦截的是Controller的方法，则handler是非空的
+     * @return  true表示继续流程（如调用下一个拦截器或处理器）；返回false表示流程中断，返回false后，不会继续调用其他的拦截器或处理器，此时需要通过response向客户返回响应内容
+     * @throws Exception 可能抛出的异常
+     */
+    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler){
+        // 判断当前拦截到的是Controller的方法还是其他资源
+        if (!(handler instanceof HandlerMethod)) {
+            // 当前拦截到的不是动态方法，直接放行
+            return true;
+        }
+        HandlerMethod handlerMethod= (HandlerMethod) handler;
+        // 1、从请求头中获取令牌
+        String token = request.getHeader(jwtProperties.getUserTokenName());
+
+        // 2、校验令牌
+        try {
+            log.info("jwt校验:{}", token);
+            // 使用JwtUtil解析JWT令牌
+            Claims claims = JwtUtil.parseJWT(jwtProperties.getUserSecretKey(), token);
+            // 从claims中获取用户ID，并设置到BaseContext中，供后续使用
+            Long empId = Long.valueOf(claims.get(JwtClaimsConstant.USER_ID).toString());
+            BaseContext.setCurrentId(empId);
+            log.info("当前用户id:{}", empId);
+            // 3、通过，放行
+            return true;
+        } catch (Exception ex) {
+            // 4、不通过，响应401状态码
+            log.error(MessageConstant.USER_NOT_LOGIN);
+            response.setStatus(401);
+            return false;
+        }
+    }
+}

sky/sky-server/src/main/java/com/sky/mapper/EmployeeMapper.java

@@ -0,0 +1,59 @@
+// 定义包名，表示该类属于com.sky.mapper包
+package com.sky.mapper;
+
+// 导入所需的类和注解
+import com.github.pagehelper.Page;
+import com.sky.annotation.AutoFill;
+import com.sky.dto.EmployeePageQueryDTO;
+import com.sky.entity.Employee;
+import com.sky.enumeration.OperationType;
+import org.apache.ibatis.annotations.Insert;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Select;
+
+// 使用@Mapper注解标记这是一个MyBatis的Mapper接口
+@Mapper
+public interface EmployeeMapper {
+
+    /**
+     * 根据用户名查询员工信息
+     *
+     * @param username 用户名
+     * @return 返回匹配的员工对象
+     */
+    @Select("select * from employee where username = #{username}")
+    Employee getByUsername(String username);
+
+    /**
+     * 插入员工数据，并自动填充创建相关的字段（如创建时间和创建用户等）
+     *
+     * @param employee 员工对象，包含要插入的数据
+     */
+    @AutoFill(OperationType.INSERT)
+    @Insert("insert into employee(name,username,password,phone,sex,id_number,create_time,update_time,create_user,update_user,status)" +
+            " values(#{name},#{username},#{password},#{phone},#{sex},#{idNumber},#{createTime},#{updateTime},#{createUser},#{updateUser},#{status})")
+    void save(Employee employee);
+
+    /**
+     * 分页查询员工数据
+     *
+     * @param employeePageQueryDTO 分页查询参数
+     * @return 返回分页包装的员工对象列表
+     */
+    Page<Employee> pageQuery(EmployeePageQueryDTO employeePageQueryDTO);
+
+    /**
+     * 更新员工信息，并自动填充更新相关的字段（如更新时间和更新用户等）
+     */
+    @AutoFill(OperationType.UPDATE)
+    void update(Employee employee);
+
+    /**
+     * 通过id查询员工信息
+     *
+     * @param id 员工的ID
+     * @return 返回匹配的员工对象
+     */
+    @Select("select * from employee where id=#{id}")
+    Employee getById(Long id);
+}

sky/sky-server/src/main/java/com/sky/mapper/SetmealMapper.java

@@ -0,0 +1,116 @@
+// 定义包名，表示该类属于com.sky.mapper包
+package com.sky.mapper;
+
+// 导入所需的类和注解
+import com.github.pagehelper.Page;
+import com.sky.annotation.AutoFill;
+import com.sky.dto.SetmealDTO;
+import com.sky.entity.SetmealDish;
+import com.sky.enumeration.OperationType;
+import com.sky.dto.SetmealPageQueryDTO;
+import com.sky.entity.Setmeal;
+import com.sky.vo.DishItemVO;
+import com.sky.vo.SetmealVO;
+import org.apache.ibatis.annotations.Delete;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Select;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+// 使用@Mapper注解标记这是一个MyBatis的Mapper接口
+@Mapper
+public interface SetmealMapper {
+
+    /**
+     * 根据条件统计套餐数量
+     *
+     * @param map 条件参数
+     * @return 返回套餐数量
+     */
+    Integer countByMap(Map map);
+
+    /**
+     * 动态条件查询套餐
+     *
+     * @param setmeal 套餐对象，包含查询条件
+     * @return 返回套餐列表
+     */
+    List<Setmeal> list(Setmeal setmeal);
+
+    /**
+     * 根据套餐id查询该套餐的菜品
+     *
+     * @param setmealId 套餐ID
+     * @return 返回套餐包含的菜品项视图对象列表
+     */
+    @Select("select sd.name, sd.copies, d.image, d.description " +
+            "from setmeal_dish sd left join dish d on sd.dish_id = d.id " +
+            "where sd.setmeal_id = #{setmealId}")
+    List<DishItemVO> getDishItemBySetmealId(Long setmealId);
+
+    /**
+     * 分页查询套餐
+     *
+     * @param setmealPageQueryDTO 分页查询参数
+     * @return 返回分页包装的套餐对象列表
+     */
+    Page<Setmeal> pageQuery(SetmealPageQueryDTO setmealPageQueryDTO);
+
+    /**
+     * 更新套餐信息，并自动填充更新相关的字段（如更新时间和更新用户等）
+     *
+     * @param setmeal 套餐对象，包含要更新的数据
+     */
+    @AutoFill(OperationType.UPDATE)
+    void updateSetmeal(Setmeal setmeal);
+
+    /**
+     * 根据套餐id删除绑定在套餐上的菜品
+     *
+     * @param id 套餐ID
+     */
+    @Delete("delete from setmeal_dish where setmeal_id=#{id}")
+    void deleteSetmealDish(Long id);
+
+    /**
+     * 批量插入套餐绑定的菜品
+     *
+     * @param setmealDishes 套餐菜品绑定关系列表
+     */
+    void insertBatchSetmealDish(List<SetmealDish> setmealDishes);
+
+    /**
+     * 根据套餐id获取套餐
+     *
+     * @param id 套餐ID
+     * @return 返回套餐对象
+     */
+    @Select("select * from setmeal where id=#{id}")
+    Setmeal getBySetmealId(Long id);
+
+    /**
+     * 根据套餐id获取套餐菜品绑定关系
+     *
+     * @param id 套餐ID
+     * @return 返回套餐菜品绑定关系列表
+     */
+    @Select("select * from setmeal_dish where setmeal_id=#{id}")
+    List<SetmealDish> getSetmealDishById(Long id);
+
+    /**
+     * 根据套餐id批量删除套餐
+     *
+     * @param ids 套餐ID列表
+     */
+    void batchDeleteSetmeal(ArrayList<Long> ids);
+
+    /**
+     * 插入套餐信息，并自动填充创建相关的字段（如创建时间和创建用户等）
+     *
+     * @param setmeal 套餐对象，包含要插入的数据
+     */
+    @AutoFill(OperationType.INSERT)
+    void insertSetmeal(Setmeal setmeal);
+}

sky/sky-server/src/main/java/com/sky/service/CommonService.java

@@ -0,0 +1,25 @@
+// 定义一个名为com.sky.service的包，用于存放服务相关的类和接口
+package com.sky.service;
+
+// 导入Spring框架中的@Service注解，用于声明一个服务组件
+import org.springframework.stereotype.Service;
+// 导入MultipartFile接口，用于处理上传的文件
+import org.springframework.web.multipart.MultipartFile;
+
+// 导入Java的IOException类，用于处理可能发生的IO异常
+import java.io.IOException;
+
+// 使用@Service注解标记这个接口，表明它是一个Spring管理的服务组件
+@Service
+// 声明一个名为CommonService的接口
+public interface CommonService {
+
+    /**
+     * 上传文件的方法。
+     *
+     * @param file 要上传的文件对象，类型为MultipartFile，它包含了文件的二进制数据以及文件的元数据（如文件名、文件大小等）。
+     * @return 一个字符串，表示上传操作的结果，可能是文件的存储路径或者上传成功的确认信息。
+     * @throws IOException 如果在文件上传过程中发生IO异常，则抛出IOException。
+     */
+    String upload(MultipartFile file) throws IOException;
+}

sky/sky-server/src/main/java/com/sky/service/ReportService.java

@@ -0,0 +1,66 @@
+// 定义一个名为com.sky.service的包，用于存放服务相关的类和接口
+package com.sky.service;
+
+// 导入com.sky.result.Result类，用于封装方法的返回结果
+import com.sky.result.Result;
+// 导入com.sky.vo包下的各种VO（Value Object）类，这些类用于封装数据传输对象
+import com.sky.vo.*;
+// 导入org.apache.http.HttpResponse类，用于处理HTTP响应
+import org.apache.http.HttpResponse;
+// 导入org.apache.poi.openxml4j.exceptions.InvalidFormatException类，用于处理Excel文件格式无效的异常
+import org.apache.poi.openxml4j.exceptions.InvalidFormatException;
+
+import javax.servlet.http.HttpServletResponse; // 导入HttpServletResponse类，用于处理HTTP响应
+import java.io.FileNotFoundException; // 导入FileNotFoundException类，用于处理文件未找到的异常
+import java.io.IOException; // 导入IOException类，用于处理IO异常
+import java.time.LocalDate; // 导入LocalDate类，用于表示没有时间的日期
+import java.time.LocalDateTime; // 导入LocalDateTime类，用于表示日期和时间
+
+// 声明一个名为ReportService的接口
+public interface ReportService {
+
+    /**
+     * 统计营业额的方法。
+     *
+     * @param begin 开始日期，类型为LocalDate，表示统计的起始日期。
+     * @param end 结束日期，类型为LocalDate，表示统计的结束日期。
+     * @return 返回一个Result对象，其中包含TurnoverReportVO类型的数据，VO中封装了营业额统计的相关信息。
+     */
+    Result<TurnoverReportVO> getTurnoverStatistics(LocalDate begin, LocalDate end);
+
+    /**
+     * 用户统计的方法。
+     *
+     * @param begin 开始日期，类型为LocalDate，表示统计的起始日期。
+     * @param end 结束日期，类型为LocalDate，表示统计的结束日期。
+     * @return 返回一个UserReportVO对象，其中封装了用户统计的相关信息。
+     */
+    UserReportVO userStatistics(LocalDate begin, LocalDate end);
+
+    /**
+     * 订单统计的方法。
+     *
+     * @param begin 开始日期，类型为LocalDate，表示统计的起始日期。
+     * @param end 结束日期，类型为LocalDate，表示统计的结束日期。
+     * @return 返回一个OrderReportVO对象，其中封装了订单统计的相关信息。
+     */
+    OrderReportVO orderStatistics(LocalDate begin, LocalDate end);
+
+    /**
+     * 获取销量排行前十的方法。
+     *
+     * @param begin 开始日期，类型为LocalDate，表示统计的起始日期。
+     * @param end 结束日期，类型为LocalDate，表示统计的结束日期。
+     * @return 返回一个SalesTop10ReportVO对象，其中封装了销量排行前十的相关信息。
+     */
+    SalesTop10ReportVO salesTop10Report(LocalDate begin, LocalDate end);
+
+    /**
+     * 导出excel表格的方法。
+     *
+     * @param httpResponse HttpServletResponse对象，用于将生成的Excel文件写入HTTP响应中，以便客户端下载。
+     * @throws IOException 如果在文件导出过程中发生IO异常，则抛出IOException。
+     * @throws InvalidFormatException 如果生成的Excel文件格式无效，则抛出InvalidFormatException。
+     */
+    void export(HttpServletResponse httpResponse) throws IOException, InvalidFormatException;
+}

sky/sky-server/src/main/java/com/sky/service/WorkspaceService.java

@@ -0,0 +1,48 @@
+// 定义一个名为com.sky.service的包，用于存放服务相关的类和接口
+package com.sky.service;
+
+// 导入com.sky.vo包下的BusinessDataVO类，用于封装业务数据
+import com.sky.vo.BusinessDataVO;
+// 导入com.sky.vo包下的DishOverViewVO类，用于封装菜品总览数据
+import com.sky.vo.DishOverViewVO;
+// 导入com.sky.vo包下的OrderOverViewVO类，用于封装订单总览数据
+import com.sky.vo.OrderOverViewVO;
+// 导入com.sky.vo包下的SetmealOverViewVO类，用于封装套餐总览数据
+import com.sky.vo.SetmealOverViewVO;
+// 导入java.time.LocalDateTime类，用于表示日期和时间
+import java.time.LocalDateTime;
+
+// 声明一个名为WorkspaceService的接口
+public interface WorkspaceService {
+
+    /**
+     * 根据时间段统计营业数据的方法。
+     *
+     * @param begin 开始时间，类型为LocalDateTime，表示统计的起始时间点。
+     * @param end 结束时间，类型为LocalDateTime，表示统计的结束时间点。
+     * @return 返回一个BusinessDataVO对象，其中封装了根据时间段统计的营业数据。
+     */
+    BusinessDataVO getBusinessData(LocalDateTime begin, LocalDateTime end);
+
+    /**
+     * 查询订单管理数据的方法。
+     *
+     * @return 返回一个OrderOverViewVO对象，其中封装了订单管理的总览数据。
+     */
+    OrderOverViewVO getOrderOverView();
+
+    /**
+     * 查询菜品总览的方法。
+     *
+     * @return 返回一个DishOverViewVO对象，其中封装了菜品的总览数据。
+     */
+    DishOverViewVO getDishOverView();
+
+    /**
+     * 查询套餐总览的方法。
+     *
+     * @return 返回一个SetmealOverViewVO对象，其中封装了套餐的总览数据。
+     */
+    SetmealOverViewVO getSetmealOverView();
+
+}

sky/sky-server/src/main/java/com/sky/service/impl/CategoryServiceImpl.java

@@ -0,0 +1,115 @@
+// 定义包名，表示该类属于com.sky.service.impl包
+package com.sky.service.impl;
+
+// 导入所需的类和接口
+import com.github.pagehelper.Page;
+import com.github.pagehelper.PageHelper;
+import com.sky.constant.StatusConstant;
+import com.sky.dto.CategoryDTO;
+import com.sky.dto.CategoryPageQueryDTO;
+import com.sky.entity.Category;
+import com.sky.mapper.CategoryMapper;
+import com.sky.result.PageResult;
+import com.sky.service.CategoryService;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+// 使用@Service注解标记这是一个Spring服务组件
+@Service
+public class CategoryServiceImpl implements CategoryService {
+    // 自动注入CategoryMapper
+    @Autowired
+    CategoryMapper categoryMapper;
+
+    /**
+     * 分类分页查询
+     *
+     * @param categoryPageQueryDTO 分页查询参数
+     * @return 分页查询结果
+     */
+    public PageResult pageQuery(CategoryPageQueryDTO categoryPageQueryDTO) {
+        PageResult pageResult = new PageResult();
+        // 使用PageHelper开始分页查询
+        PageHelper.startPage(categoryPageQueryDTO.getPage(), categoryPageQueryDTO.getPageSize());
+        // 调用mapper进行分页查询
+        Page<Category> pageQuery = categoryMapper.pageQuery(categoryPageQueryDTO);
+        // 设置查询结果和总记录数
+        pageResult.setRecords(pageQuery.getResult());
+        pageResult.setTotal(pageQuery.getTotal());
+
+        return pageResult;
+    }
+
+    /**
+     * 根据分类类型查询分类
+     *
+     * @param type 分类类型
+     * @return 分类列表
+     */
+    public List<Category> query(Integer type) {
+        ArrayList<Category> result;
+        CategoryDTO categoryDTO = new CategoryDTO();
+        categoryDTO.setType(type);
+        // 调用mapper查询分类
+        result = (ArrayList<Category>) categoryMapper.query(categoryDTO);
+
+        return result;
+    }
+
+    /**
+     * 删除分类
+     *
+     * @param id 要删除的分类ID
+     */
+    public void delete(Long id) {
+        // 调用mapper删除分类
+        categoryMapper.delete(id);
+    }
+
+    /**
+     * 修改分类
+     *
+     * @param categoryDTO 包含修改信息的分类DTO
+     */
+    public void updateCategory(CategoryDTO categoryDTO) {
+        Category category = new Category();
+        // 使用BeanUtils复制属性
+        BeanUtils.copyProperties(categoryDTO, category);
+        // 调用mapper更新分类
+        categoryMapper.updateCategory(category);
+    }
+
+    /**
+     * 启用或禁用分类
+     *
+     * @param status 状态值
+     * @param id 分类ID
+     */
+    public void startOrStop(Integer status, Long id) {
+        Category category = Category.builder()
+                .status(status)
+                .id(id)
+                .build();
+        // 调用mapper更新分类状态
+        categoryMapper.updateCategory(category);
+    }
+
+    /**
+     * 新增分类
+     *
+     * @param categoryDTO 包含新增信息的分类DTO
+     */
+    public void save(CategoryDTO categoryDTO) {
+        Category category = new Category();
+        // 使用BeanUtils复制属性
+        BeanUtils.copyProperties(categoryDTO, category);
+        // 设置分类状态为禁用
+        category.setStatus(StatusConstant.DISABLE);
+        // 调用mapper保存分类
+        categoryMapper.save(category);
+    }
+}

sky/sky-server/src/main/java/com/sky/service/impl/OrderServiceImpl.java

@@ -0,0 +1,260 @@
+// 定义包名，表示该类属于com.sky.service.impl包
+package com.sky.service.impl;
+
+// 导入所需的类和接口
+import com.alibaba.druid.support.json.JSONUtils;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.github.pagehelper.Page;
+import com.github.pagehelper.PageHelper;
+import com.sky.constant.MessageConstant;
+import com.sky.context.BaseContext;
+import com.sky.dto.*;
+import com.sky.entity.*;
+import com.sky.exception.AddressBookBusinessException;
+import com.sky.exception.OrderBusinessException;
+import com.sky.exception.ShoppingCartBusinessException;
+import com.sky.mapper.*;
+import com.sky.result.PageResult;
+import com.sky.service.OrderService;
+import com.sky.utils.WeChatPayUtil;
+import com.sky.vo.OrderPaymentVO;
+import com.sky.vo.OrderStatisticsVO;
+import com.sky.vo.OrderSubmitVO;
+import com.sky.vo.OrderVO;
+import com.sky.webSocket.WebSocketServer;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
+
+import java.math.BigDecimal;
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Objects;
+import java.util.stream.Collectors;
+
+// 使用@Service注解标记这是一个Spring服务组件
+@Service
+public class OrderServiceImpl implements OrderService {
+    // 自动注入OrderMapper
+    @Autowired
+    private OrderMapper orderMapper;
+    // 自动注入OrderDetailMapper
+    @Autowired
+    private OrderDetailMapper orderDetailMapper;
+    // 自动注入AddressBookMapper
+    @Autowired
+    private AddressBookMapper addressBookMapper;
+    // 自动注入ShoppingCartMapper
+    @Autowired
+    private ShoppingCartMapper shoppingCartMapper;
+    // 自动注入UserMapper
+    @Autowired
+    private UserMapper userMapper;
+    // 自动注入WeChatPayUtil
+    @Autowired
+    private WeChatPayUtil weChatPayUtil;
+    // 自动注入WebSocketServer
+    @Autowired
+    private WebSocketServer webSocketServer;
+
+    /**
+     * 完成订单
+     *
+     * @param id 订单ID
+     */
+    public void complete(Long id) {
+        // 根据id查询订单
+        Orders ordersDB = orderMapper.getById(id);
+
+        // 校验订单是否存在，并且状态为派送中
+        if (ordersDB == null || !ordersDB.getStatus().equals(Orders.DELIVERY_IN_PROGRESS)) {
+            throw new OrderBusinessException(MessageConstant.ORDER_STATUS_ERROR);
+        }
+
+        Orders orders = new Orders();
+        orders.setId(ordersDB.getId());
+        // 更新订单状态,状态转为完成
+        orders.setStatus(Orders.COMPLETED);
+        orders.setDeliveryTime(LocalDateTime.now());
+
+        orderMapper.update(orders);
+    }
+
+    /**
+     * 派送订单
+     *
+     * @param id 订单ID
+     */
+    public void delivery(Long id) {
+        // 根据id查询订单
+        Orders ordersDB = orderMapper.getById(id);
+
+        // 校验订单是否存在，并且状态为已接单
+        if (ordersDB == null || !ordersDB.getStatus().equals(Orders.CONFIRMED)) {
+            throw new OrderBusinessException(MessageConstant.ORDER_STATUS_ERROR);
+        }
+
+        Orders orders = new Orders();
+        orders.setId(ordersDB.getId());
+        // 更新订单状态,状态转为派送中
+        orders.setStatus(Orders.DELIVERY_IN_PROGRESS);
+
+        orderMapper.update(orders);
+    }
+
+    /**
+     * 取消订单
+     *
+     * @param ordersCancelDTO 包含取消订单信息的DTO
+     */
+    public void cancel(OrdersCancelDTO ordersCancelDTO) throws Exception {
+        // 根据id查询订单
+        Orders ordersDB = orderMapper.getById(ordersCancelDTO.getId());
+
+        // 支付状态
+        Integer payStatus = ordersDB.getPayStatus();
+        if (payStatus == 1) {
+            // 用户已支付，需要退款
+            // 调用微信支付退款接口
+            // String refund = weChatPayUtil.refund(
+            //         ordersDB.getNumber(),
+            //         ordersDB.getNumber(),
+            //         new BigDecimal(0.01),
+            //         new BigDecimal(0.01));
+        }
+
+        // 管理端取消订单需要退款，根据订单id更新订单状态、取消原因、取消时间
+        Orders orders = new Orders();
+        orders.setId(ordersCancelDTO.getId());
+        orders.setStatus(Orders.CANCELLED);
+        orders.setCancelReason(ordersCancelDTO.getCancelReason());
+        orders.setCancelTime(LocalDateTime.now());
+        orderMapper.update(orders);
+    }
+
+    /**
+     * 拒单
+     *
+     * @param ordersRejectionDTO 包含拒单信息的DTO
+     */
+    public void rejection(OrdersRejectionDTO ordersRejectionDTO) throws Exception {
+        // 根据id查询订单
+        Orders ordersDB = orderMapper.getById(ordersRejectionDTO.getId());
+
+        // 订单只有存在且状态为待接单才可以拒单
+        if (ordersDB == null || !ordersDB.getStatus().equals(Orders.TO_BE_CONFIRMED)) {
+            throw new OrderBusinessException(MessageConstant.ORDER_STATUS_ERROR);
+        }
+
+        // 支付状态
+        Integer payStatus = ordersDB.getPayStatus();
+        if (Objects.equals(payStatus, Orders.PAID)) {
+            // 用户已支付，需要退款
+            // 调用微信支付退款接口
+            // String refund = weChatPayUtil.refund(
+            //         ordersDB.getNumber(),
+            //         ordersDB.getNumber(),
+            //         new BigDecimal(0.01),
+            //         new BigDecimal(0.01));
+        }
+
+        // 拒单需要退款，根据订单id更新订单状态、拒单原因、取消时间
+        Orders orders = new Orders();
+        orders.setId(ordersDB.getId());
+        orders.setStatus(Orders.CANCELLED);
+        orders.setRejectionReason(ordersRejectionDTO.getRejectionReason());
+        orders.setCancelTime(LocalDateTime.now());
+
+        orderMapper.update(orders);
+    }
+
+    /**
+     * 接单
+     *
+     * @param ordersConfirmDTO 包含接单信息的DTO
+     */
+    public void confirm(OrdersConfirmDTO ordersConfirmDTO) {
+        Orders orders = Orders.builder()
+                .id(ordersConfirmDTO.getId())
+                .status(Orders.CONFIRMED)
+                .build();
+
+        orderMapper.update(orders);
+    }
+
+    /**
+     * 各个状态的订单数量统计
+     *
+     * @return 订单统计视图对象
+     */
+    public OrderStatisticsVO statistics() {
+        // 根据状态，分别查询出待接单、待派送、派送中的订单数量
+        Integer toBeConfirmed = orderMapper.countStatus(Orders.TO_BE_CONFIRMED);
+        Integer confirmed = orderMapper.countStatus(Orders.CONFIRMED);
+        Integer deliveryInProgress = orderMapper.countStatus(Orders.DELIVERY_IN_PROGRESS);
+
+        // 将查询出的数据封装到orderStatisticsVO中响应
+        OrderStatisticsVO orderStatisticsVO = new OrderStatisticsVO();
+        orderStatisticsVO.setToBeConfirmed(toBeConfirmed);
+        orderStatisticsVO.setConfirmed(confirmed);
+        orderStatisticsVO.setDeliveryInProgress(deliveryInProgress);
+        return orderStatisticsVO;
+    }
+
+    /**
+     * 订单搜索
+     *
+     * @param ordersPageQueryDTO 分页查询参数
+     * @return 分页查询结果
+     */
+    public PageResult conditionSearch(OrdersPageQueryDTO ordersPageQueryDTO) {
+        PageHelper.startPage(ordersPageQueryDTO.getPage(), ordersPageQueryDTO.getPageSize());
+
+        Page<Orders> page = orderMapper.pageQuery(ordersPageQueryDTO);
+
+        // 部分订单状态，需要额外返回订单菜品信息，将Orders转化为OrderVO
+        List<OrderVO> orderVOList = getOrderVOList(page);
+
+        return new PageResult(page.getTotal(), orderVOList);
+    }
+
+    private List<OrderVO> getOrderVOList(Page<Orders> page) {
+        // 需要返回订单菜品信息，自定义OrderVO响应结果
+        List<OrderVO> orderVOList = new ArrayList<>();
+
+        List<Orders> ordersList = page.getResult();
+        if (!CollectionUtils.isEmpty(ordersList)) {
+            for (Orders orders : ordersList) {
+                // 将共同字段复制到OrderVO
+                OrderVO orderVO = new OrderVO();
+                BeanUtils.copyProperties(orders, orderVO);
+                String orderDishes = getOrderDishesStr(orders);
+
+                // 将订单菜品信息封装到orderVO中，并添加到orderVOList
+                orderVO.setOrderDishes(orderDishes);
+                orderVOList.add(orderVO);
+            }
+        }
+        return orderVOList;
+    }
+
+    /**
+     * 根据订单id获取菜品信息字符串
+     *
+     * @param orders 订单对象
+     * @return 订单菜品信息字符串
+     */
+    private String getOrderDishesStr(Orders orders) {
+        // 查询订单菜品详情信息（订单中的菜品和数量）
+        List<OrderDetail> orderDetailList = orderDetailMapper.getByOrderId(orders.getId());
+
+        // 将每一条订单菜品信息拼接为字符串（格式：宫保鸡丁*3；）
+        List<String> orderDishList = orderDetailList.stream().map(x -> {
+            String orderDish = x.getName() + "*" + x.getNumber() + ";";
+            return orderDish;
+        }).collect

sky/sky-server/src/main/java/com/sky/service/impl/UserServiceImpl.java

@@ -0,0 +1,86 @@
+// 定义包名，表示该类属于com.sky.service.impl包
+package com.sky.service.impl;
+
+// 导入所需的类和接口
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.sky.constant.MessageConstant;
+import com.sky.dto.UserLoginDTO;
+import com.sky.entity.User;
+import com.sky.exception.LoginFailedException;
+import com.sky.mapper.UserMapper;
+import com.sky.properties.WeChatProperties;
+import com.sky.service.UserService;
+import com.sky.utils.HttpClientUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.time.LocalDateTime;
+import java.util.HashMap;
+import java.util.Map;
+
+// 使用@Service注解标记这是一个Spring服务组件
+@Service
+public class UserServiceImpl implements UserService {
+
+    // 自动注入UserMapper
+    @Autowired
+    UserMapper userMapper;
+    // 自动注入WeChatProperties
+    @Autowired
+    WeChatProperties weChatProperties;
+
+    // 微信登录接口的URL
+    private static final String WX_LOGIN = "https://api.weixin.qq.com/sns/jscode2session";
+
+    /**
+     * 微信登录
+     *
+     * @param userLoginDTO 包含登录信息的DTO
+     * @return 用户对象
+     */
+    public User wxLogin(UserLoginDTO userLoginDTO) {
+        // 通过code获取openid
+        String openid = getOpenid(userLoginDTO.getCode());
+
+        // 判断openid是否存在
+        if (openid == null || openid.equals("")) {
+            throw new LoginFailedException(MessageConstant.LOGIN_FAILED);
+        }
+        // 当前用户为新用户,完成自动注册
+        User user = userMapper.getByOpenId(openid);
+        if (user == null) {
+            // 创建新用户对象
+            user = User.builder()
+                    .openid(openid)
+                    .createTime(LocalDateTime.now()).build();
+            // 插入新用户到数据库
+            userMapper.insertUser(user);
+        }
+        return user;
+    }
+
+    /**
+     * 通过code获取openid
+     *
+     * @param code 微信登录code
+     * @return openid字符串
+     */
+    private String getOpenid(String code) {
+        // 参数映射
+        Map<String, String> paramMap = new HashMap<>();
+        paramMap.put("appid", weChatProperties.getAppid());
+        paramMap.put("secret", weChatProperties.getSecret());
+        paramMap.put("js_code", code);
+        paramMap.put("grant_type", "authorization_code");
+        // 发起HTTP GET请求
+        String result = HttpClientUtil.doGet(WX_LOGIN, paramMap);
+
+        // 获取请求结果
+        JSONObject jsonObject = JSON.parseObject(result);
+        // 从结果中获取openid
+        String openid = jsonObject.getString("openid");
+
+        return openid;
+    }
+}