orderData = AppletControllerUtil.buildIntegralOrderDetail(
+ integralOrder, integralProductService, integralOrderLogService);
+
+ return success(orderData);
+
+ } catch (Exception e) {
+ System.err.println("查询积分订单详情异常：" + e.getMessage());
+ return error("查询订单详情失败：" + e.getMessage());
+ }
+}
+
+/**
+ * 查询积分商品分类列表
+ *
+ * @param request HTTP请求对象
+ * @return 返回积分商品分类列表
+ *
+ * 功能说明：
+ * - 获取所有启用状态的积分商品分类
+ * - 返回分类的ID和名称
+ * - 用于积分商城分类展示
+ *
+ * 返回格式：
+ * {
+ * "code": 200,
+ * "msg": "OK",
+ * "data": [
+ * {
+ * "id": 4,
+ * "title": "家清商品"
+ * }
+ * ]
+ * }
+ */
+@GetMapping("/api/integral/product/cate")
+public AjaxResult getIntegralProductCateList(HttpServletRequest request) {
+ try {
+ // 1. 构建查询条件：查询启用状态的积分商品分类
+ IntegralCate integralCateQuery = new IntegralCate();
+ integralCateQuery.setStatus(1L); // 启用状态
+
+ // 2. 查询积分商品分类列表
+ List integralCateList = integralCateService.selectIntegralCateList(integralCateQuery);
+
+ // 3. 构建返回数据格式
+ List> resultList = new ArrayList<>();
+ for (IntegralCate integralCate : integralCateList) {
+ Map cateData = new HashMap<>();
+ cateData.put("id", integralCate.getId());
+ cateData.put("title", integralCate.getTitle());
+ resultList.add(cateData);
+ }
+
+ return success(resultList);
+
+ } catch (Exception e) {
+ System.err.println("查询积分商品分类列表异常：" + e.getMessage());
+ return error("查询分类列表失败：" + e.getMessage());
+ }
+}
+
+/**
+ * 查询积分商品列表
+ *
+ * @param params 请求参数，包含limit(每页数量)、page(页码)、type(分类ID)
+ * @param request HTTP请求对象
+ * @return 返回分页的积分商品列表
+ *
+ * 功能说明：
+ * - 获取积分商品列表，支持分页
+ * - 支持按分类筛选
+ * - 返回商品详细信息和分页信息
+ * - 按创建时间倒序排列
+ *
+ * 请求参数格式：
+ * {
+ * "limit": 15, // 每页显示数量
+ * "page": 1, // 页码
+ * "type": "1" // 分类ID（可选）
+ * }
+ *
+ * 返回格式：
+ * {
+ * "code": 200,
+ * "msg": "OK",
+ * "data": {
+ * "current_page": 1,
+ * "data": [
+ * {
+ * "id": 7,
+ * "title": "全无码食品火锅",
+ * "image": "https://img.huafurenjia.cn/images/cb03ed40d32282bb47235568219ca26.png",
+ * "num": 11,
+ * "price": "53.90",
+ * "sales": 568,
+ * "tags": []
+ * }
+ * ],
+ * "from": 1,
+ * "last_page": 1,
+ * "per_page": 15,
+ * "to": 2,
+ * "total": 2
+ * }
+ * }
+ */
+@PostMapping("/api/integral/product/lst")
+public AjaxResult getIntegralProductList(@RequestBody Map params, HttpServletRequest request) {
+ try {
+ // 1. 获取分页参数
+ int page = params.get("page") != null ? (Integer) params.get("page") : 1;
+ int limit = params.get("limit") != null ? (Integer) params.get("limit") : 15;
+ String type = params.get("type") != null ? params.get("type").toString() : null;
+
+ // 2. 验证分页参数
+ Map pageValidation = PageUtil.validatePageParams(page, limit);
+ if (!(Boolean) pageValidation.get("valid")) {
+ return error((String) pageValidation.get("message"));
+ }
+
+ // 3. 设置分页参数
+ PageHelper.startPage(page, limit);
+
+ // 4. 构建查询条件
+ IntegralProduct integralProductQuery = new IntegralProduct();
+ integralProductQuery.setStatus(1L); // 只查询启用状态的商品
+
+ // 如果有分类参数，添加分类筛选
+ if (type != null && !type.trim().isEmpty()) {
try {
- return Long.parseLong((String) param);
+ Long cateId = Long.parseLong(type.trim());
+ integralProductQuery.setCateId(cateId);
} catch (NumberFormatException e) {
- throw new RuntimeException(errorMsg);
+ return error("分类参数格式错误");
}
}
- return null;
+
+ // 5. 查询积分商品列表
+ List integralProductList = integralProductService.selectIntegralProductList(integralProductQuery);
+
+ // 6. 构建分页信息
+ PageInfo pageInfo = new PageInfo<>(integralProductList);
+
+ // 7. 使用工具类处理数据格式化
+ List> formattedProductList = AppletControllerUtil.buildIntegralProductList(integralProductList);
+ Map responseData = AppletControllerUtil.buildPaginationResponse(
+ pageInfo, formattedProductList, "https://www.huafurenjia.cn/api/integral/product/lst");
+
+ return success(responseData);
+
+ } catch (Exception e) {
+ System.err.println("查询积分商品列表异常：" + e.getMessage());
+ return error("查询积分商品列表失败：" + e.getMessage());
}
+}
- /**
- * 解析参数为Integer类型
- */
- private Integer parseParamToInteger(Object param, String errorMsg) {
- if (param == null) return null;
+/**
+ * 查询积分商品详情
+ *
+ * @param id 商品ID
+ * @param request HTTP请求对象
+ * @return 返回积分商品详细信息
+ *
+ * 功能说明：
+ * - 根据商品ID获取积分商品详细信息
+ * - 返回完整的商品数据包括图片、规格、库存等
+ * - 自动处理图片URL添加CDN前缀
+ * - 格式化轮播图和标签为数组格式
+ *
+ * 返回格式：
+ * {
+ * "code": 200,
+ * "msg": "OK",
+ * "data": {
+ * "id": 7,
+ * "title": "全无码食品火锅",
+ * "cate_id": 4,
+ * "contetnt": "
![](\"...\")
",
+ * "created_at": "2024-07-17 14:59:44",
+ * "image": "https://img.huafurenjia.cn/images/cb03ed40d32282bb47235568219ca26.png",
+ * "images": ["https://img.huafurenjia.cn/images/..."],
+ * "num": 11,
+ * "price": "53.90",
+ * "sales": 568,
+ * "sku": {"type": "single"},
+ * "sku_type": 1,
+ * "sort": 1,
+ * "status": 1,
+ * "stock": 120,
+ * "tags": [],
+ * "updated_at": "2024-08-16 15:03:33"
+ * }
+ * }
+ */
+@GetMapping("/api/integral/product/info/{id}")
+public AjaxResult getIntegralProductInfo(@PathVariable("id") Long id, HttpServletRequest request) {
+ try {
+ // 1. 参数验证
+ if (id == null || id <= 0) {
+ return error("商品ID无效");
+ }
- if (param instanceof Integer) {
- return (Integer) param;
- } else if (param instanceof String && !((String) param).trim().isEmpty()) {
- try {
- return Integer.parseInt((String) param);
- } catch (NumberFormatException e) {
- throw new RuntimeException(errorMsg);
+ // 2. 查询积分商品信息
+ IntegralProduct integralProduct = integralProductService.selectIntegralProductById(id);
+ if (integralProduct == null) {
+ return error("商品不存在");
+ }
+
+ // 3. 验证商品状态（只返回启用状态的商品）
+ if (integralProduct.getStatus() == null || integralProduct.getStatus() != 1) {
+ return error("商品已下架或不可用");
+ }
+
+ // 4. 使用工具类构建商品详情数据
+ Map productDetail = AppletControllerUtil.buildIntegralProductDetail(integralProduct);
+
+ return success(productDetail);
+
+ } catch (Exception e) {
+ System.err.println("查询积分商品详情异常：" + e.getMessage());
+ return error("查询商品详情失败：" + e.getMessage());
+ }
+}
+
+/**
+ * 获取用户默认收货地址
+ *
+ * @param request HTTP请求对象
+ * @return 默认地址信息
+ *
+ * 接口说明：
+ * - 查询用户的默认收货地址（is_default = 1）
+ * - 如果没有默认地址，返回用户地址列表的第一条数据
+ * - 验证用户登录状态和地址归属权
+ * - 返回AddressApple格式的地址数据
+ *
+ * 返回格式：
+ * {
+ * "code": 200,
+ * "msg": "操作成功",
+ * "data": {
+ * "id": 160,
+ * "uid": 302,
+ * "name": "赵先生",
+ * "phone": "18709185987",
+ * "latitude": "34.15643",
+ * "longitude": "108.86683",
+ * "address_name": "陕西省西安市长安区榆林北段与建设大道交叉口处北侧",
+ * "address_info": "陕西省西安市长安区榆林北段与建设大道交叉口处",
+ * "info": "14号楼2302",
+ * "is_default": 1,
+ * "created_at": null,
+ * "updated_at": null
+ * }
+ * }
+ */
+@GetMapping("/api/user/address/default")
+public AjaxResult getUserDefaultAddress(HttpServletRequest request) {
+ try {
+ // 1. 验证用户登录状态
+ String token = request.getHeader("token");
+ Map userValidation = AppletLoginUtil.validateUserToken(token, usersService);
+ if (!(Boolean) userValidation.get("valid")) {
+ return error("用户未登录或token无效");
+ }
+
+ // 2. 获取用户信息
+ Users user = (Users) userValidation.get("user");
+ if (user == null) {
+ return error("用户信息获取失败");
+ }
+
+ // 3. 首先查询用户的默认地址
+ UserAddress userAddressQuery = new UserAddress();
+ userAddressQuery.setUid(user.getId());
+ userAddressQuery.setIsDefault(1L); // 查询默认地址
+ List defaultAddressList = userAddressService.selectUserAddressList(userAddressQuery);
+
+ UserAddress targetAddress = null;
+
+ if (!defaultAddressList.isEmpty()) {
+ // 找到默认地址
+ targetAddress = defaultAddressList.get(0);
+ } else {
+ // 没有默认地址，查询用户的第一条地址
+ UserAddress allAddressQuery = new UserAddress();
+ allAddressQuery.setUid(user.getId());
+ List allAddressList = userAddressService.selectUserAddressList(allAddressQuery);
+
+ if (!allAddressList.isEmpty()) {
+ targetAddress = allAddressList.get(0);
+ } else {
+ return error("用户暂无收货地址");
}
}
- return null;
- }
- /**
- * 查询用户积分日志列表
- *
- * @param params 请求参数，包含limit(每页数量)、page(页码)
- * @param request HTTP请求对象
- * @return 返回分页的积分日志列表
- */
- @PostMapping("/api/integral/user/log/lst")
- public AjaxResult getUserIntegralLogList(@RequestBody Map params, HttpServletRequest request) {
+ // 4. 转换为AddressApple格式并返回
+ AddressApple addressApple = AddressApple.fromUserAddress(targetAddress);
+
+ return success(addressApple);
+
+ } catch (Exception e) {
+ System.err.println("查询用户默认地址异常：" + e.getMessage());
+ return error("查询默认地址失败：" + e.getMessage());
+ }
+}
+
+/**
+ * 获取用户小程序通知订阅状态
+ *
+ * @param request HTTP请求对象
+ * @return 用户通知订阅状态
+ *
+ * 接口说明：
+ * - 查询用户对小程序消息模板的订阅状态
+ * - 返回三个消息模板的订阅配置信息
+ * - 支持不同业务场景的消息通知配置
+ * - 验证用户登录状态
+ *
+ * 消息模板说明：
+ * - pv3cba-wPoinUbBZSskp0KpDNnJwrHqS0rvGBfDNQ1M: 积分相关通知模板
+ * - YKnuTCAD-oEEhNGoI3LUVkAqNsykOMTcyrf71S9vev8: 操作成功通知模板
+ * - 5lA-snytEPl25fBS7rf6rQi8Y0i5HOSdG0JMVdUnMcU: 工作人员通知模板
+ *
+ * 返回格式：
+ * {
+ * "code": 200,
+ * "msg": "OK",
+ * "data": {
+ * "integral": ["pv3cba-wPoinUbBZSskp0KpDNnJwrHqS0rvGBfDNQ1M"],
+ * "make_success": ["YKnuTCAD-oEEhNGoI3LUVkAqNsykOMTcyrf71S9vev8", "5lA-snytEPl25fBS7rf6rQi8Y0i5HOSdG0JMVdUnMcU"],
+ * "is": "5lA-snytEPl25fBS7rf6rQi8Y0i5HOSdG0JMVdUnMcU",
+ * "new_success": ["pv3cba-wPoinUbBZSskp0KpDNnJwrHqS0rvGBfDNQ1M"],
+ * "s": "pv3cba-wPoinUbBZSskp0KpDNnJwrHqS0rvGBfDNQ1M",
+ * "workers": ["5lA-snytEPl25fBS7rf6rQi8Y0i5HOSdG0JMVdUnMcU"],
+ * "a": "5lA-snytEPl25fBS7rf6rQi8Y0i5HOSdG0JMVdUnMcU"
+ * }
+ * }
+ */
+@GetMapping("/api/user/notification/status")
+public AjaxResult getUserNotificationStatus(HttpServletRequest request) {
+ try {
+ // 1. 验证用户登录状态
+ String token = request.getHeader("token");
+ Map userValidation = AppletLoginUtil.validateUserToken(token, usersService);
+ if (!(Boolean) userValidation.get("valid")) {
+ return error("用户未登录或token无效");
+ }
+
+ // 2. 获取用户信息
+ Users user = (Users) userValidation.get("user");
+ if (user == null) {
+ return error("用户信息获取失败");
+ }
+
+ // 3. 直接返回固定的消息模板配置数据
+ Map notificationStatus = AppletControllerUtil.buildMiniProgramNotificationStatus(user);
+
+ return success(notificationStatus);
+
+ } catch (Exception e) {
+ System.err.println("查询用户通知订阅状态异常：" + e.getMessage());
+ return error("查询通知订阅状态失败：" + e.getMessage());
+ }
+}
+
+/**
+ * 用户订阅消息授权接口
+ *
+ * @param params 请求参数，包含tmplIds(模板ID数组)
+ * @param request HTTP请求对象
+ * @return 授权结果
+ *
+ * 接口说明：
+ * - 处理用户对消息模板的订阅授权
+ * - 记录用户的授权状态
+ * - 支持批量处理多个模板ID
+ *
+ * 请求参数格式：
+ * {
+ * "tmplIds": ["pv3cba-wPoinUbBZSskp0KpDNnJwrHqS0rvGBfDNQ1M", "YKnuTCAD-oEEhNGoI3LUVkAqNsykOMTcyrf71S9vev8"]
+ * }
+ */
+@PostMapping("/api/user/notification/subscribe")
+public AjaxResult subscribeNotification(@RequestBody Map params, HttpServletRequest request) {
+ try {
+ // 1. 验证用户登录状态
+ String token = request.getHeader("token");
+ Map userValidation = AppletLoginUtil.validateUserToken(token, usersService);
+ if (!(Boolean) userValidation.get("valid")) {
+ return error("用户未登录或token无效");
+ }
+
+ // 2. 获取用户信息
+ Users user = (Users) userValidation.get("user");
+ if (user == null) {
+ return error("用户信息获取失败");
+ }
+
+ // 3. 获取模板ID列表
+ List tmplIds = (List) params.get("tmplIds");
+ if (tmplIds == null || tmplIds.isEmpty()) {
+ return error("模板ID列表不能为空");
+ }
+
+ // 4. 验证模板ID的有效性
+ List validTemplateIds = new ArrayList<>();
+ validTemplateIds.add("pv3cba-wPoinUbBZSskp0KpDNnJwrHqS0rvGBfDNQ1M");
+ validTemplateIds.add("YKnuTCAD-oEEhNGoI3LUVkAqNsykOMTcyrf71S9vev8");
+ validTemplateIds.add("5lA-snytEPl25fBS7rf6rQi8Y0i5HOSdG0JMVdUnMcU");
+
+ for (String tmplId : tmplIds) {
+ if (!validTemplateIds.contains(tmplId)) {
+ return error("无效的模板ID：" + tmplId);
+ }
+ }
+
+ // 5. 处理订阅逻辑（这里可以记录到数据库或调用微信API）
+ Map subscribeResult = new HashMap<>();
+ subscribeResult.put("user_id", user.getId());
+ subscribeResult.put("template_ids", tmplIds);
+ subscribeResult.put("subscribe_time", new Date());
+ subscribeResult.put("status", "success");
+
+ // 6. 这里可以将订阅状态保存到数据库
+ // 例如：userNotificationService.saveSubscribeStatus(user.getId(), tmplIds);
+
+ return success(subscribeResult);
+
+ } catch (Exception e) {
+ System.err.println("用户订阅消息异常：" + e.getMessage());
+ return error("订阅消息失败：" + e.getMessage());
+ }
+}
+
+
+/**
+ * 小程序下单时用户订阅消息推送接口（前端不传值，后端返回固定结构）
+ *
+ * @return 订阅消息推送ID分类结果
+ */
+@GetMapping("/api/public/massge/notice")
+public Map subscribeMessageNotice() {
+ Map data = new HashMap<>();
+ data.put("make_success", Arrays.asList(
+ "YKnuTCAD-oEEhNGoI3LUVkAqNsykOMTcyrf71S9vev8",
+ "5lA-snytEPl25fBS7rf6rQi8Y0i5HOSdG0JMVdUnMcU"
+ ));
+ data.put("pay_success", Arrays.asList(
+ "pv3cba-wPoinUbBZSskp0KpDNnJwrHqS0rvGBfDNQ1M"
+ ));
+ data.put("integral", Arrays.asList(
+ "pv3cba-wPoinUbBZSskp0KpDNnJwrHqS0rvGBfDNQ1M"
+ ));
+ data.put("worker", Arrays.asList(
+ "5lA-snytEPl25fBS7rf6rQi8Y0i5HOSdG0JMVdUnMcU"
+ ));
+ Map result = new HashMap<>();
+ result.put("code", 200);
+ result.put("msg", "OK");
+ result.put("data", data);
+ return result;
+}
+
+
+/**
+ * 积分商品兑换接口
+ *
+ * @param params 请求参数，包含id(积分商品ID)、address_id(收货地址ID)、num(购买数量)、sku(规格)、mark(备注)
+ * @param request HTTP请求对象
+ * @return 兑换结果
+ *
+ * 接口说明：
+ * - 使用积分兑换积分商品
+ * - 验证用户积分是否足够支付
+ * - 创建积分订单并扣除用户积分
+ * - 记录积分变动日志
+ *
+ * 请求参数格式：
+ * {
+ * "id": 7, // 积分商品ID
+ * "num": 1, // 购买数量
+ * "sku": "", // 商品规格（可选）
+ * "address_id": 2151, // 收货地址ID
+ * "mark": "" // 备注（可选）
+ * }
+ *
+ * 返回格式：
+ * {
+ * "code": 200,
+ * "msg": "操作成功",
+ * "data": {
+ * "order_id": "JF20241217143055",
+ * "message": "积分商品兑换成功"
+ * }
+ * }
+ */
+@PostMapping("/api/integral/user/exchange")
+public AjaxResult exchangeIntegralProduct(@RequestBody Map params, HttpServletRequest request) {
+ try {
+ // 1. 验证用户登录状态
+ String token = request.getHeader("token");
+ Map userValidation = AppletLoginUtil.validateUserToken(token, usersService);
+ if (!(Boolean) userValidation.get("valid")) {
+ return error("用户未登录或token无效");
+ }
+
+ // 2. 获取用户信息
+ Users user = (Users) userValidation.get("user");
+ if (user == null) {
+ return error("用户信息获取失败");
+ }
+
+ // 3. 验证请求参数
+ String validationResult = AppletControllerUtil.validateIntegralExchangeParams(params);
+ if (validationResult != null) {
+ return error(validationResult);
+ }
+
+ // 4. 获取并验证积分商品信息
+ Long productId = Long.valueOf(params.get("id").toString());
+ IntegralProduct product = integralProductService.selectIntegralProductById(productId);
+ if (product == null) {
+ return error("积分商品不存在");
+ }
+
+ if (product.getStatus() == null || product.getStatus() != 1) {
+ return error("积分商品已下架或不可用");
+ }
+
+ // 5. 获取并验证收货地址信息
+ Long addressId = Long.valueOf(params.get("address_id").toString());
+ UserAddress address = userAddressService.selectUserAddressById(addressId);
+ if (address == null) {
+ return error("收货地址不存在");
+ }
+
+ if (!address.getUid().equals(user.getId())) {
+ return error("无权使用该收货地址");
+ }
+
+ // 6. 计算所需积分并验证库存
+ Integer num = Integer.valueOf(params.get("num").toString());
+ if (product.getStock() != null && product.getStock() < num) {
+ return error("商品库存不足");
+ }
+
+ Long totalIntegral = product.getNum() * num;
+
+ // 7. 验证用户积分是否足够
+ if (!AppletControllerUtil.checkUserIntegralSufficient(user, totalIntegral)) {
+ // 积分不足，返回422状态码
+ return AppletControllerUtil.appletWarning("积分不足");
+ }
+
+ // 8. 创建积分订单
+ IntegralOrder order = AppletControllerUtil.buildIntegralOrder(params, user, product, address);
+ int orderResult = integralOrderService.insertIntegralOrder(order);
+
+ if (orderResult <= 0) {
+ return error("订单创建失败");
+ }
+
+ // 9. 扣除用户积分
+ Users updateUser = new Users();
+ updateUser.setId(user.getId());
+ updateUser.setIntegral(user.getIntegral() - totalIntegral);
+ int updateResult = usersService.updateUsers(updateUser);
+
+ if (updateResult <= 0) {
+ return error("扣除积分失败");
+ }
+
+ // 10. 记录积分变动日志
+ IntegralLog integralLog = AppletControllerUtil.buildIntegralLog(
+ user, -totalIntegral, order.getOrderId(), product.getTitle());
+ integralLogService.insertIntegralLog(integralLog);
+
+ // 11. 更新商品库存（如果有库存管理）
+ if (product.getStock() != null) {
+ IntegralProduct updateProduct = new IntegralProduct();
+ updateProduct.setId(product.getId());
+ updateProduct.setStock(product.getStock() - num);
+ updateProduct.setSales(product.getSales() != null ? product.getSales() + num : num.longValue());
+ integralProductService.updateIntegralProduct(updateProduct);
+ }
+ // 12. 构建返回结果
+ return AppletControllerUtil.appletSuccess("兑换成功");
+ } catch (Exception e) {
+ System.err.println("积分商品兑换异常：" + e.getMessage());
+ return AppletControllerUtil.appletError("积分商品兑换失败：" + e.getMessage());
+ }
+}
+
+/**
+ * 获取服务订单详情
+ *
+ * @param id 订单ID
+ * @param request HTTP请求对象
+ * @return 服务订单详细信息
+ *
+ * 接口说明：
+ * - 根据订单ID获取服务订单完整信息
+ * - 包含订单基本信息、订单日志和商品信息
+ * - 验证用户登录状态和订单归属权
+ * - 返回完整的订单详情数据
+ *
+ * 返回格式：
+ * {
+ * "code": 200,
+ * "msg": "OK",
+ * "data": {
+ * // 订单基本信息
+ * "id": 260,
+ * "order_id": "B831770908583777",
+ * // ... 其他订单字段
+ * "log": [
+ * // 订单日志数组
+ * ],
+ * "product": {
+ * // 商品信息
+ * }
+ * }
+ * }
+ */
+@GetMapping("/api/service/order/info/{id}")
+public AjaxResult getServiceOrderInfo(@PathVariable("id") Long id, HttpServletRequest request) {
+ try {
+ // 1. 参数验证
+ if (id == null || id <= 0) {
+ return AppletControllerUtil.appletWarning("订单ID无效");
+ }
+
+ // 2. 验证用户登录状态
+ String token = request.getHeader("token");
+ Map userValidation = AppletLoginUtil.validateUserToken(token, usersService);
+ if (!(Boolean) userValidation.get("valid")) {
+ return AppletControllerUtil.appletUnauthorized();
+ }
+
+ // 3. 获取用户信息
+ Users user = (Users) userValidation.get("user");
+ if (user == null) {
+ return AppletControllerUtil.appletWarning("用户信息获取失败");
+ }
+
+ // 4. 查询订单信息并验证归属权
+ Order order = orderService.selectOrderById(id);
+ if (order == null) {
+ return AppletControllerUtil.appletWarning("订单不存在");
+ }
+
+ // 5. 验证订单归属权
+ if (!order.getUid().equals(user.getId())) {
+ return AppletControllerUtil.appletWarning("无权访问该订单信息");
+ }
+
+ // 6. 使用工具类构建订单详情数据
+ Map orderDetail = AppletControllerUtil.buildServiceOrderDetail(
+ order, orderLogService, serviceGoodsService);
+
+ return AppletControllerUtil.appletSuccess(orderDetail);
+
+ } catch (Exception e) {
+ System.err.println("查询服务订单详情异常：" + e.getMessage());
+ return AppletControllerUtil.appletError("查询订单详情失败：" + e.getMessage());
+ }
+}
+
+/**
+ * 获取城市列表接口
+ *
+ * @param request HTTP请求对象
+ * @return 城市列表数据
+ *
+ * 接口说明：
+ * - 获取所有启用状态的城市列表
+ * - 返回城市的ID、名称和父级ID
+ * - 用于小程序城市选择功能
+ * - 无需用户登录验证
+ *
+ * 返回格式：
+ * {
+ * "code": 200,
+ * "msg": "OK",
+ * "data": [
+ * {
+ * "id": 1,
+ * "title": "西安市",
+ * "pid": 0
+ * }
+ * ]
+ * }
+ */
+@GetMapping(value = "/api/public/diy/city")
+public AjaxResult getDiyCityList(HttpServletRequest request) {
+ try {
+ // 查询所有城市列表
+ List cityList = diyCityService.selectDiyCityList(null);
+
+ // 构建树状结构数据
+ List> resultList = AppletControllerUtil.buildCityTree(cityList);
+
+ return AppletControllerUtil.appletSuccess(resultList);
+ } catch (Exception e) {
+ System.err.println("获取城市列表异常：" + e.getMessage());
+ return AppletControllerUtil.appletError("获取城市列表失败：" + e.getMessage());
+ }
+}
+
+/**
+ * 获取技能列表接口
+ *
+ * @param request HTTP请求对象
+ * @return 技能列表数据
+ *
+ * 接口说明：
+ * - 获取所有技能列表数据
+ * - 返回技能的ID、名称、排序、状态等信息
+ * - 用于小程序技能选择功能
+ * - 无需用户登录验证
+ *
+ * 返回格式：
+ * {
+ * "code": 200,
+ * "msg": "OK",
+ * "data": [
+ * {
+ * "id": 47,
+ * "title": "燃气灶维修",
+ * "sort": 43,
+ * "status": 1,
+ * "created_at": "2025-04-10 09:36:35",
+ * "updated_at": "2025-04-10 09:36:35"
+ * }
+ * ]
+ * }
+ */
+@GetMapping(value = "/api/form/skill/lst")
+public AjaxResult getSkillList(HttpServletRequest request) {
+ try {
+ // 查询技能列表
+ List skillList = siteSkillService.selectSiteSkillList(null);
+
+ // 构建返回数据格式
+ List> resultList = new ArrayList<>();
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+
+ for (SiteSkill skill : skillList) {
+ Map skillData = new HashMap<>();
+ skillData.put("id", skill.getId());
+ skillData.put("title", skill.getTitle());
+ skillData.put("sort", skill.getSort());
+ skillData.put("status", skill.getStatus());
+
+ // 格式化时间字段
+ if (skill.getCreatedAt() != null) {
+ skillData.put("created_at", sdf.format(skill.getCreatedAt()));
+ } else {
+ skillData.put("created_at", null);
+ }
+
+ if (skill.getUpdatedAt() != null) {
+ skillData.put("updated_at", sdf.format(skill.getUpdatedAt()));
+ } else {
+ skillData.put("updated_at", null);
+ }
+
+ resultList.add(skillData);
+ }
+
+ return AppletControllerUtil.appletSuccess(resultList);
+ } catch (Exception e) {
+ System.err.println("获取技能列表异常：" + e.getMessage());
+ return AppletControllerUtil.appletError("获取技能列表失败：" + e.getMessage());
+ }
+}
+
+/**
+ * 文件上传接口
+ *
+ * @param file 上传的文件
+ * @param request HTTP请求对象
+ * @return 上传结果
+ *
+ * 接口说明：
+ * - 支持图片和文档文件上传
+ * - 优先使用七牛云上传，未启用时使用本地上传
+ * - 自动验证文件格式和大小
+ * - 无需用户登录验证（public 接口）
+ *
+ * 支持的文件格式：
+ * - 图片：jpg, jpeg, png, gif, bmp, webp, svg
+ * - 文档：doc, docx, xls, xlsx, ppt, pptx, txt, pdf
+ *
+ * 返回格式：
+ * {
+ * "code": 200,
+ * "msg": "OK",
+ * "data": {
+ * "path": "images/2025-06-11/zvsZHNoFYlFkMCePQs1624hKwBSCozL9XM7pEUmo.jpg",
+ * "full_path": "http://img.huafurenjia.cn/images/2025-06-11/zvsZHNoFYlFkMCePQs1624hKwBSCozL9XM7pEUmo.jpg"
+ * }
+ * }
+ */
+@PostMapping(value = "/api/public/upload/file")
+public AjaxResult uploadFile(@RequestParam("file") MultipartFile file, HttpServletRequest request) {
+ try {
+ // 1. 验证文件是否为空
+ if (file == null || file.isEmpty()) {
+ return AppletControllerUtil.appletWarning("上传文件不能为空");
+ }
+
+ // 2. 验证文件格式
+ String[] allowedTypes = {
+ // 图片格式
+ "jpg", "jpeg", "png", "gif", "bmp", "webp", "svg",
+ // 文档格式
+ "doc", "docx", "xls", "xlsx", "ppt", "pptx", "txt", "pdf"
+ };
+
+ if (!QiniuUploadUtil.isValidFileType(file.getOriginalFilename(), allowedTypes)) {
+ return AppletControllerUtil.appletWarning("不支持的文件格式");
+ }
+
+ // 3. 验证文件大小（10MB）
+ long maxSize = 10 * 1024 * 1024;
+ if (!QiniuUploadUtil.isFileSizeValid(file.getSize(), maxSize)) {
+ return AppletControllerUtil.appletWarning("文件大小不能超过10MB");
+ }
+
+ String fileUrl;
+ String filePath;
+
+ // 4. 检查是否启用七牛云上传
+ if (qiniuConfig.isEnabled()) {
+ // 使用七牛云上传
+ fileUrl = QiniuUploadUtil.uploadFile(file);
+ // 从完整URL中提取路径部分
+ filePath = AppletControllerUtil.extractPathFromUrl(fileUrl, "https://" + qiniuConfig.getDomain() + "/");
+ } else {
+ // 使用本地上传（这里需要集成本地上传逻辑）
+ return AppletControllerUtil.appletError("本地上传功能暂未在此接口中实现，请启用七牛云上传");
+ }
+
+ // 5. 构建返回数据
+ Map uploadResult = new HashMap<>();
+ uploadResult.put("path", filePath);
+ uploadResult.put("full_path", fileUrl);
+
+ return AppletControllerUtil.appletSuccess(uploadResult);
+
+ } catch (Exception e) {
+ System.err.println("文件上传异常：" + e.getMessage());
+ return AppletControllerUtil.appletError("文件上传失败：" + e.getMessage());
+ }
+}
+
+
+/**
+ * 获取服务预约时间段接口
+ *
+ * @param params 请求参数，包含day(预约日期)
+ * @param request HTTP请求对象
+ * @return 时间段列表数据
+ *
+ * 接口说明：
+ * - 根据指定日期获取可预约的时间段列表
+ * - 返回每个时间段的可用状态和剩余数量
+ * - 支持动态时间段配置
+ * - 无需用户登录验证
+ *
+ * 请求参数格式：
+ * {
+ * "day": "2025-06-11"
+ * }
+ *
+ * 返回格式：
+ * {
+ * "code": 200,
+ * "msg": "OK",
+ * "data": [
+ * {
+ * "click": true,
+ * "value": "8:00-10:00",
+ * "prove": "可预约",
+ * "residue_num": 99
+ * }
+ * ]
+ * }
+ */
+@PostMapping(value = "/api/service/make/time")
+public AjaxResult getServiceMakeTime(@RequestBody Map params, HttpServletRequest request) {
+ try {
+ // 1. 参数验证
+ if (params == null || params.get("day") == null) {
+ return AppletControllerUtil.appletWarning("日期参数不能为空");
+ }
+
+ String day = params.get("day").toString().trim();
+ if (day.isEmpty()) {
+ return AppletControllerUtil.appletWarning("日期参数不能为空");
+ }
+
+ // 2. 验证日期格式
+ if (!AppletControllerUtil.isValidDateFormat(day)) {
+ return AppletControllerUtil.appletWarning("日期格式错误，请使用yyyy-MM-dd格式");
+ }
+
+ // 3. 检查日期是否为过去时间
+ if (AppletControllerUtil.isPastDate(day)) {
+ return AppletControllerUtil.appletWarning("不能预约过去的日期");
+ }
+
+ // 4. 构建时间段列表
+ List> timeSlotList = AppletControllerUtil.buildTimeSlotList(day);
+
+ return AppletControllerUtil.appletSuccess(timeSlotList);
+
+ } catch (Exception e) {
+ System.err.println("获取服务预约时间段异常：" + e.getMessage());
+ return AppletControllerUtil.appletError("获取时间段失败：" + e.getMessage());
+ }
+}
+
+
+/**
+ * 添加商品到购物车接口
+ *
+ * @param params 请求参数，包含good_id(商品ID)、sku(商品规格)
+ * @param request HTTP请求对象
+ * @return 添加结果
+ *
+ * 接口说明：
+ * - 将指定商品添加到用户购物车
+ * - 验证商品是否存在和可用
+ * - 支持商品规格选择
+ * - 需要用户登录验证
+ *
+ * 请求参数格式：
+ * {
+ * "good_id": 86,
+ * "sku": ""
+ * }
+ *
+ * 返回格式：
+ * {
+ * "code": 200,
+ * "msg": "操作成功",
+ * "data": "商品已添加到购物车"
+ * }
+ */
+@PostMapping(value = "/api/cart/add")
+public AjaxResult addToCart(@RequestBody Map params, HttpServletRequest request) {
+ try {
+ // 1. 验证用户登录状态
+ String token = request.getHeader("token");
+ Map userValidation = AppletLoginUtil.validateUserToken(token, usersService);
+ if (!(Boolean) userValidation.get("valid")) {
+ return AppletControllerUtil.appletUnauthorized();
+ }
+
+ // 2. 获取用户信息
+ Users user = (Users) userValidation.get("user");
+ if (user == null) {
+ return AppletControllerUtil.appletWarning("用户信息获取失败");
+ }
+
+ // 3. 验证请求参数
+ if (params == null || params.get("good_id") == null) {
+ return AppletControllerUtil.appletWarning("商品ID不能为空");
+ }
+
+ Long goodId;
try {
- // 1. 获取分页参数
- int page = params.get("page") != null ? (Integer) params.get("page") : 1;
- int limit = params.get("limit") != null ? (Integer) params.get("limit") : 15;
-
- // 2. 验证分页参数
- Map pageValidation = PageUtil.validatePageParams(page, limit);
- if (!(Boolean) pageValidation.get("valid")) {
- return error((String) pageValidation.get("message"));
+ goodId = Long.valueOf(params.get("good_id").toString());
+ if (goodId <= 0) {
+ return AppletControllerUtil.appletWarning("商品ID无效");
}
-
- // 3. 验证用户登录状态
- String token = request.getHeader("token");
- Map userValidation = AppletLoginUtil.validateUserToken(token, usersService);
- if (!(Boolean) userValidation.get("valid")) {
- return error("用户未登录或token无效");
- }
-
- // 4. 获取用户信息
- Users user = (Users) userValidation.get("user");
- if (user == null) {
- return error("用户信息获取失败");
- }
-
- // 5. 设置分页参数
- PageHelper.startPage(page, limit);
-
- // 6. 构建查询条件并查询
- IntegralLog integralLogQuery = new IntegralLog();
- integralLogQuery.setUid(user.getId());
- List integralLogList = integralLogService.selectIntegralLogList(integralLogQuery);
-
- // 7. 构建分页信息
- PageInfo pageInfo = new PageInfo<>(integralLogList);
-
- // 8. 使用工具类处理数据格式化
- List> formattedLogList = AppletControllerUtil.buildIntegralLogList(integralLogList);
- Map paginationData = AppletControllerUtil.buildPaginationResponse(
- pageInfo, formattedLogList, "https://www.huafurenjia.cn/api/integral/user/log/lst");
- Map userData = AppletControllerUtil.buildUserDataInfo(user);
-
- // 9. 构建最终返回数据结构
- Map responseData = new HashMap<>();
- responseData.put("data", paginationData);
- responseData.put("user", userData);
- responseData.put("msg", "OK");
-
- return success(responseData);
-
- } catch (Exception e) {
- System.err.println("查询用户积分日志列表异常：" + e.getMessage());
- return error("查询积分日志列表失败：" + e.getMessage());
+ } catch (NumberFormatException e) {
+ return AppletControllerUtil.appletWarning("商品ID格式错误");
}
- }
- /**
- * 查询用户积分商城订单列表
- *
- * @param params 请求参数，包含limit(每页数量)、page(页码)、status(订单状态)
- * @param request HTTP请求对象
- * @return 返回分页的积分商城订单列表
- */
- @PostMapping("/api/integral/user/order")
- public AjaxResult getUserIntegralOrderList(@RequestBody Map params, HttpServletRequest request) {
- try {
- // 1. 获取分页参数
- int page = params.get("page") != null ? (Integer) params.get("page") : 1;
- int limit = params.get("limit") != null ? (Integer) params.get("limit") : 15;
- String status = params.get("status") != null ? params.get("status").toString() : null;
-
- // 2. 验证分页参数
- Map pageValidation = PageUtil.validatePageParams(page, limit);
- if (!(Boolean) pageValidation.get("valid")) {
- return error((String) pageValidation.get("message"));
- }
-
- // 3. 验证用户登录状态
- String token = request.getHeader("token");
- Map userValidation = AppletLoginUtil.validateUserToken(token, usersService);
- if (!(Boolean) userValidation.get("valid")) {
- return error("用户未登录或token无效");
- }
-
- // 4. 获取用户信息
- Users user = (Users) userValidation.get("user");
- if (user == null) {
- return error("用户信息获取失败");
- }
-
- // 5. 设置分页参数
- PageHelper.startPage(page, limit);
-
- // 6. 构建查询条件并查询
- IntegralOrder integralOrderQuery = new IntegralOrder();
- integralOrderQuery.setUid(user.getId());
- if (status != null && !status.trim().isEmpty()) {
- integralOrderQuery.setStatus(status.trim());
- }
- List integralOrderList = integralOrderService.selectIntegralOrderList(integralOrderQuery);
-
- // 7. 构建分页信息
- PageInfo pageInfo = new PageInfo<>(integralOrderList);
-
- // 8. 使用工具类处理数据格式化
- List> formattedOrderList = AppletControllerUtil.buildIntegralOrderList(
- integralOrderList, integralProductService);
- Map responseData = AppletControllerUtil.buildPaginationResponse(
- pageInfo, formattedOrderList, "https://www.huafurenjia.cn/api/integral/user/order");
-
- return success(responseData);
-
- } catch (Exception e) {
- System.err.println("查询用户积分商城订单列表异常：" + e.getMessage());
- return error("查询积分商城订单列表失败：" + e.getMessage());
- }
- }
-
- /**
- * 查询积分订单详情
- *
- * @param id 订单ID
- * @param request HTTP请求对象
- * @return 返回积分订单详细信息
- */
- @GetMapping("/api/integral/user/order/info/{id}")
- public AjaxResult getIntegralOrderInfo(@PathVariable("id") Long id, HttpServletRequest request) {
- try {
- // 1. 参数验证
- if (id == null || id <= 0) {
- return error("订单ID无效");
- }
-
- // 2. 验证用户登录状态
- String token = request.getHeader("token");
- Map userValidation = AppletLoginUtil.validateUserToken(token, usersService);
- if (!(Boolean) userValidation.get("valid")) {
- return error("用户未登录或token无效");
- }
-
- // 3. 获取用户信息
- Users user = (Users) userValidation.get("user");
- if (user == null) {
- return error("用户信息获取失败");
- }
-
- // 4. 查询积分订单信息
- IntegralOrder integralOrder = integralOrderService.selectIntegralOrderById(id);
- if (integralOrder == null) {
- return error("订单不存在");
- }
-
- // 5. 验证订单归属权
- if (!integralOrder.getUid().equals(user.getId())) {
- return error("无权访问该订单信息");
- }
-
- // 6. 使用工具类构建订单详情数据
- Map orderData = AppletControllerUtil.buildIntegralOrderDetail(
- integralOrder, integralProductService, integralOrderLogService);
-
- return success(orderData);
-
- } catch (Exception e) {
- System.err.println("查询积分订单详情异常：" + e.getMessage());
- return error("查询订单详情失败：" + e.getMessage());
- }
- }
-
- /**
- * 查询积分商品分类列表
- *
- * @param request HTTP请求对象
- * @return 返回积分商品分类列表
- *
- * 功能说明：
- * - 获取所有启用状态的积分商品分类
- * - 返回分类的ID和名称
- * - 用于积分商城分类展示
- *
- * 返回格式：
- * {
- * "code": 200,
- * "msg": "OK",
- * "data": [
- * {
- * "id": 4,
- * "title": "家清商品"
- * }
- * ]
- * }
- */
- @GetMapping("/api/integral/product/cate")
- public AjaxResult getIntegralProductCateList(HttpServletRequest request) {
- try {
- // 1. 构建查询条件：查询启用状态的积分商品分类
- IntegralCate integralCateQuery = new IntegralCate();
- integralCateQuery.setStatus(1L); // 启用状态
-
- // 2. 查询积分商品分类列表
- List integralCateList = integralCateService.selectIntegralCateList(integralCateQuery);
-
- // 3. 构建返回数据格式
- List> resultList = new ArrayList<>();
- for (IntegralCate integralCate : integralCateList) {
- Map cateData = new HashMap<>();
- cateData.put("id", integralCate.getId());
- cateData.put("title", integralCate.getTitle());
- resultList.add(cateData);
- }
-
- return success(resultList);
-
- } catch (Exception e) {
- System.err.println("查询积分商品分类列表异常：" + e.getMessage());
- return error("查询分类列表失败：" + e.getMessage());
- }
- }
-
- /**
- * 查询积分商品列表
- *
- * @param params 请求参数，包含limit(每页数量)、page(页码)、type(分类ID)
- * @param request HTTP请求对象
- * @return 返回分页的积分商品列表
- *
- * 功能说明：
- * - 获取积分商品列表，支持分页
- * - 支持按分类筛选
- * - 返回商品详细信息和分页信息
- * - 按创建时间倒序排列
- *
- * 请求参数格式：
- * {
- * "limit": 15, // 每页显示数量
- * "page": 1, // 页码
- * "type": "1" // 分类ID（可选）
- * }
- *
- * 返回格式：
- * {
- * "code": 200,
- * "msg": "OK",
- * "data": {
- * "current_page": 1,
- * "data": [
- * {
- * "id": 7,
- * "title": "全无码食品火锅",
- * "image": "https://img.huafurenjia.cn/images/cb03ed40d32282bb47235568219ca26.png",
- * "num": 11,
- * "price": "53.90",
- * "sales": 568,
- * "tags": []
- * }
- * ],
- * "from": 1,
- * "last_page": 1,
- * "per_page": 15,
- * "to": 2,
- * "total": 2
- * }
- * }
- */
- @PostMapping("/api/integral/product/lst")
- public AjaxResult getIntegralProductList(@RequestBody Map params, HttpServletRequest request) {
- try {
- // 1. 获取分页参数
- int page = params.get("page") != null ? (Integer) params.get("page") : 1;
- int limit = params.get("limit") != null ? (Integer) params.get("limit") : 15;
- String type = params.get("type") != null ? params.get("type").toString() : null;
-
- // 2. 验证分页参数
- Map pageValidation = PageUtil.validatePageParams(page, limit);
- if (!(Boolean) pageValidation.get("valid")) {
- return error((String) pageValidation.get("message"));
- }
-
- // 3. 设置分页参数
- PageHelper.startPage(page, limit);
-
- // 4. 构建查询条件
- IntegralProduct integralProductQuery = new IntegralProduct();
- integralProductQuery.setStatus(1L); // 只查询启用状态的商品
-
- // 如果有分类参数，添加分类筛选
- if (type != null && !type.trim().isEmpty()) {
+ // 4. 获取商品规格参数
+ // String sku = params.get("sku") != null ? params.get("sku").toString().trim() : "";
+ String sku = null;
+ if (params.get("sku") != null) {
+ Object skuParam = params.get("sku");
+ if (skuParam instanceof Map) {
+ // 如果前端传递的是Map对象，转换为JSON字符串
try {
- Long cateId = Long.parseLong(type.trim());
- integralProductQuery.setCateId(cateId);
- } catch (NumberFormatException e) {
- return error("分类参数格式错误");
+ sku = com.alibaba.fastjson2.JSON.toJSONString(skuParam);
+ } catch (Exception e) {
+ System.err.println("SKU转换JSON失败：" + e.getMessage());
+ sku = skuParam.toString();
}
- }
-
- // 5. 查询积分商品列表
- List integralProductList = integralProductService.selectIntegralProductList(integralProductQuery);
-
- // 6. 构建分页信息
- PageInfo pageInfo = new PageInfo<>(integralProductList);
-
- // 7. 使用工具类处理数据格式化
- List> formattedProductList = AppletControllerUtil.buildIntegralProductList(integralProductList);
- Map responseData = AppletControllerUtil.buildPaginationResponse(
- pageInfo, formattedProductList, "https://www.huafurenjia.cn/api/integral/product/lst");
-
- return success(responseData);
-
- } catch (Exception e) {
- System.err.println("查询积分商品列表异常：" + e.getMessage());
- return error("查询积分商品列表失败：" + e.getMessage());
- }
- }
-
- /**
- * 查询积分商品详情
- *
- * @param id 商品ID
- * @param request HTTP请求对象
- * @return 返回积分商品详细信息
- *
- * 功能说明：
- * - 根据商品ID获取积分商品详细信息
- * - 返回完整的商品数据包括图片、规格、库存等
- * - 自动处理图片URL添加CDN前缀
- * - 格式化轮播图和标签为数组格式
- *
- * 返回格式：
- * {
- * "code": 200,
- * "msg": "OK",
- * "data": {
- * "id": 7,
- * "title": "全无码食品火锅",
- * "cate_id": 4,
- * "contetnt": "
",
- * "created_at": "2024-07-17 14:59:44",
- * "image": "https://img.huafurenjia.cn/images/cb03ed40d32282bb47235568219ca26.png",
- * "images": ["https://img.huafurenjia.cn/images/..."],
- * "num": 11,
- * "price": "53.90",
- * "sales": 568,
- * "sku": {"type": "single"},
- * "sku_type": 1,
- * "sort": 1,
- * "status": 1,
- * "stock": 120,
- * "tags": [],
- * "updated_at": "2024-08-16 15:03:33"
- * }
- * }
- */
- @GetMapping("/api/integral/product/info/{id}")
- public AjaxResult getIntegralProductInfo(@PathVariable("id") Long id, HttpServletRequest request) {
- try {
- // 1. 参数验证
- if (id == null || id <= 0) {
- return error("商品ID无效");
- }
-
- // 2. 查询积分商品信息
- IntegralProduct integralProduct = integralProductService.selectIntegralProductById(id);
- if (integralProduct == null) {
- return error("商品不存在");
- }
-
- // 3. 验证商品状态（只返回启用状态的商品）
- if (integralProduct.getStatus() == null || integralProduct.getStatus() != 1) {
- return error("商品已下架或不可用");
- }
-
- // 4. 使用工具类构建商品详情数据
- Map productDetail = AppletControllerUtil.buildIntegralProductDetail(integralProduct);
-
- return success(productDetail);
-
- } catch (Exception e) {
- System.err.println("查询积分商品详情异常：" + e.getMessage());
- return error("查询商品详情失败：" + e.getMessage());
- }
- }
-
- /**
- * 获取用户默认收货地址
- *
- * @param request HTTP请求对象
- * @return 默认地址信息
- *
- * 接口说明：
- * - 查询用户的默认收货地址（is_default = 1）
- * - 如果没有默认地址，返回用户地址列表的第一条数据
- * - 验证用户登录状态和地址归属权
- * - 返回AddressApple格式的地址数据
- *
- * 返回格式：
- * {
- * "code": 200,
- * "msg": "操作成功",
- * "data": {
- * "id": 160,
- * "uid": 302,
- * "name": "赵先生",
- * "phone": "18709185987",
- * "latitude": "34.15643",
- * "longitude": "108.86683",
- * "address_name": "陕西省西安市长安区榆林北段与建设大道交叉口处北侧",
- * "address_info": "陕西省西安市长安区榆林北段与建设大道交叉口处",
- * "info": "14号楼2302",
- * "is_default": 1,
- * "created_at": null,
- * "updated_at": null
- * }
- * }
- */
- @GetMapping("/api/user/address/default")
- public AjaxResult getUserDefaultAddress(HttpServletRequest request) {
- try {
- // 1. 验证用户登录状态
- String token = request.getHeader("token");
- Map userValidation = AppletLoginUtil.validateUserToken(token, usersService);
- if (!(Boolean) userValidation.get("valid")) {
- return error("用户未登录或token无效");
- }
-
- // 2. 获取用户信息
- Users user = (Users) userValidation.get("user");
- if (user == null) {
- return error("用户信息获取失败");
- }
-
- // 3. 首先查询用户的默认地址
- UserAddress userAddressQuery = new UserAddress();
- userAddressQuery.setUid(user.getId());
- userAddressQuery.setIsDefault(1L); // 查询默认地址
- List defaultAddressList = userAddressService.selectUserAddressList(userAddressQuery);
-
- UserAddress targetAddress = null;
-
- if (!defaultAddressList.isEmpty()) {
- // 找到默认地址
- targetAddress = defaultAddressList.get(0);
} else {
- // 没有默认地址，查询用户的第一条地址
- UserAddress allAddressQuery = new UserAddress();
- allAddressQuery.setUid(user.getId());
- List allAddressList = userAddressService.selectUserAddressList(allAddressQuery);
-
- if (!allAddressList.isEmpty()) {
- targetAddress = allAddressList.get(0);
- } else {
- return error("用户暂无收货地址");
- }
+ // 如果前端传递的是字符串，直接使用
+ sku = skuParam.toString().trim();
}
-
- // 4. 转换为AddressApple格式并返回
- AddressApple addressApple = AddressApple.fromUserAddress(targetAddress);
-
- return success(addressApple);
-
- } catch (Exception e) {
- System.err.println("查询用户默认地址异常：" + e.getMessage());
- return error("查询默认地址失败：" + e.getMessage());
+ } else {
+ sku = null;
}
- }
-
- /**
- * 获取用户小程序通知订阅状态
- *
- * @param request HTTP请求对象
- * @return 用户通知订阅状态
- *
- * 接口说明：
- * - 查询用户对小程序消息模板的订阅状态
- * - 返回三个消息模板的订阅配置信息
- * - 支持不同业务场景的消息通知配置
- * - 验证用户登录状态
- *
- * 消息模板说明：
- * - pv3cba-wPoinUbBZSskp0KpDNnJwrHqS0rvGBfDNQ1M: 积分相关通知模板
- * - YKnuTCAD-oEEhNGoI3LUVkAqNsykOMTcyrf71S9vev8: 操作成功通知模板
- * - 5lA-snytEPl25fBS7rf6rQi8Y0i5HOSdG0JMVdUnMcU: 工作人员通知模板
- *
- * 返回格式：
- * {
- * "code": 200,
- * "msg": "OK",
- * "data": {
- * "integral": ["pv3cba-wPoinUbBZSskp0KpDNnJwrHqS0rvGBfDNQ1M"],
- * "make_success": ["YKnuTCAD-oEEhNGoI3LUVkAqNsykOMTcyrf71S9vev8", "5lA-snytEPl25fBS7rf6rQi8Y0i5HOSdG0JMVdUnMcU"],
- * "is": "5lA-snytEPl25fBS7rf6rQi8Y0i5HOSdG0JMVdUnMcU",
- * "new_success": ["pv3cba-wPoinUbBZSskp0KpDNnJwrHqS0rvGBfDNQ1M"],
- * "s": "pv3cba-wPoinUbBZSskp0KpDNnJwrHqS0rvGBfDNQ1M",
- * "workers": ["5lA-snytEPl25fBS7rf6rQi8Y0i5HOSdG0JMVdUnMcU"],
- * "a": "5lA-snytEPl25fBS7rf6rQi8Y0i5HOSdG0JMVdUnMcU"
- * }
- * }
- */
- @GetMapping("/api/user/notification/status")
- public AjaxResult getUserNotificationStatus(HttpServletRequest request) {
- try {
- // 1. 验证用户登录状态
- String token = request.getHeader("token");
- Map userValidation = AppletLoginUtil.validateUserToken(token, usersService);
- if (!(Boolean) userValidation.get("valid")) {
- return error("用户未登录或token无效");
- }
-
- // 2. 获取用户信息
- Users user = (Users) userValidation.get("user");
- if (user == null) {
- return error("用户信息获取失败");
- }
-
- // 3. 直接返回固定的消息模板配置数据
- Map notificationStatus = AppletControllerUtil.buildMiniProgramNotificationStatus(user);
-
- return success(notificationStatus);
-
- } catch (Exception e) {
- System.err.println("查询用户通知订阅状态异常：" + e.getMessage());
- return error("查询通知订阅状态失败：" + e.getMessage());
+ // 5. 查询商品信息并验证
+ ServiceGoods serviceGoods = serviceGoodsService.selectServiceGoodsById(goodId);
+ if (serviceGoods == null) {
+ return AppletControllerUtil.appletWarning("商品不存在");
}
- }
- /**
- * 用户订阅消息授权接口
- *
- * @param params 请求参数，包含tmplIds(模板ID数组)
- * @param request HTTP请求对象
- * @return 授权结果
- *
- * 接口说明：
- * - 处理用户对消息模板的订阅授权
- * - 记录用户的授权状态
- * - 支持批量处理多个模板ID
- *
- * 请求参数格式：
- * {
- * "tmplIds": ["pv3cba-wPoinUbBZSskp0KpDNnJwrHqS0rvGBfDNQ1M", "YKnuTCAD-oEEhNGoI3LUVkAqNsykOMTcyrf71S9vev8"]
- * }
- */
- @PostMapping("/api/user/notification/subscribe")
- public AjaxResult subscribeNotification(@RequestBody Map params, HttpServletRequest request) {
- try {
- // 1. 验证用户登录状态
- String token = request.getHeader("token");
- Map userValidation = AppletLoginUtil.validateUserToken(token, usersService);
- if (!(Boolean) userValidation.get("valid")) {
- return error("用户未登录或token无效");
- }
-
- // 2. 获取用户信息
- Users user = (Users) userValidation.get("user");
- if (user == null) {
- return error("用户信息获取失败");
- }
-
- // 3. 获取模板ID列表
- List tmplIds = (List) params.get("tmplIds");
- if (tmplIds == null || tmplIds.isEmpty()) {
- return error("模板ID列表不能为空");
- }
-
- // 4. 验证模板ID的有效性
- List validTemplateIds = new ArrayList<>();
- validTemplateIds.add("pv3cba-wPoinUbBZSskp0KpDNnJwrHqS0rvGBfDNQ1M");
- validTemplateIds.add("YKnuTCAD-oEEhNGoI3LUVkAqNsykOMTcyrf71S9vev8");
- validTemplateIds.add("5lA-snytEPl25fBS7rf6rQi8Y0i5HOSdG0JMVdUnMcU");
-
- for (String tmplId : tmplIds) {
- if (!validTemplateIds.contains(tmplId)) {
- return error("无效的模板ID：" + tmplId);
- }
- }
-
- // 5. 处理订阅逻辑（这里可以记录到数据库或调用微信API）
- Map subscribeResult = new HashMap<>();
- subscribeResult.put("user_id", user.getId());
- subscribeResult.put("template_ids", tmplIds);
- subscribeResult.put("subscribe_time", new Date());
- subscribeResult.put("status", "success");
-
- // 6. 这里可以将订阅状态保存到数据库
- // 例如：userNotificationService.saveSubscribeStatus(user.getId(), tmplIds);
-
- return success(subscribeResult);
-
- } catch (Exception e) {
- System.err.println("用户订阅消息异常：" + e.getMessage());
- return error("订阅消息失败：" + e.getMessage());
- }
- }
-
-
-
- /**
- * 小程序下单时用户订阅消息推送接口（前端不传值，后端返回固定结构）
- * @return 订阅消息推送ID分类结果
- */
- @GetMapping("/api/public/massge/notice")
- public Map subscribeMessageNotice() {
- Map data = new HashMap<>();
- data.put("make_success", Arrays.asList(
- "YKnuTCAD-oEEhNGoI3LUVkAqNsykOMTcyrf71S9vev8",
- "5lA-snytEPl25fBS7rf6rQi8Y0i5HOSdG0JMVdUnMcU"
- ));
- data.put("pay_success", Arrays.asList(
- "pv3cba-wPoinUbBZSskp0KpDNnJwrHqS0rvGBfDNQ1M"
- ));
- data.put("integral", Arrays.asList(
- "pv3cba-wPoinUbBZSskp0KpDNnJwrHqS0rvGBfDNQ1M"
- ));
- data.put("worker", Arrays.asList(
- "5lA-snytEPl25fBS7rf6rQi8Y0i5HOSdG0JMVdUnMcU"
- ));
- Map result = new HashMap<>();
- result.put("code", 200);
- result.put("msg", "OK");
- result.put("data", data);
- return result;
- }
-
-
- /**
- * 积分商品兑换接口
- *
- * @param params 请求参数，包含id(积分商品ID)、address_id(收货地址ID)、num(购买数量)、sku(规格)、mark(备注)
- * @param request HTTP请求对象
- * @return 兑换结果
- *
- * 接口说明：
- * - 使用积分兑换积分商品
- * - 验证用户积分是否足够支付
- * - 创建积分订单并扣除用户积分
- * - 记录积分变动日志
- *
- * 请求参数格式：
- * {
- * "id": 7, // 积分商品ID
- * "num": 1, // 购买数量
- * "sku": "", // 商品规格（可选）
- * "address_id": 2151, // 收货地址ID
- * "mark": "" // 备注（可选）
- * }
- *
- * 返回格式：
- * {
- * "code": 200,
- * "msg": "操作成功",
- * "data": {
- * "order_id": "JF20241217143055",
- * "message": "积分商品兑换成功"
- * }
- * }
- */
- @PostMapping("/api/integral/user/exchange")
- public AjaxResult exchangeIntegralProduct(@RequestBody Map params, HttpServletRequest request) {
- try {
- // 1. 验证用户登录状态
- String token = request.getHeader("token");
- Map userValidation = AppletLoginUtil.validateUserToken(token, usersService);
- if (!(Boolean) userValidation.get("valid")) {
- return error("用户未登录或token无效");
- }
-
- // 2. 获取用户信息
- Users user = (Users) userValidation.get("user");
- if (user == null) {
- return error("用户信息获取失败");
- }
-
- // 3. 验证请求参数
- String validationResult = AppletControllerUtil.validateIntegralExchangeParams(params);
- if (validationResult != null) {
- return error(validationResult);
- }
-
- // 4. 获取并验证积分商品信息
- Long productId = Long.valueOf(params.get("id").toString());
- IntegralProduct product = integralProductService.selectIntegralProductById(productId);
- if (product == null) {
- return error("积分商品不存在");
- }
-
- if (product.getStatus() == null || product.getStatus() != 1) {
- return error("积分商品已下架或不可用");
- }
-
- // 5. 获取并验证收货地址信息
- Long addressId = Long.valueOf(params.get("address_id").toString());
- UserAddress address = userAddressService.selectUserAddressById(addressId);
- if (address == null) {
- return error("收货地址不存在");
- }
-
- if (!address.getUid().equals(user.getId())) {
- return error("无权使用该收货地址");
- }
-
- // 6. 计算所需积分并验证库存
- Integer num = Integer.valueOf(params.get("num").toString());
- if (product.getStock() != null && product.getStock() < num) {
- return error("商品库存不足");
- }
-
- Long totalIntegral = product.getNum() * num;
-
- // 7. 验证用户积分是否足够
- if (!AppletControllerUtil.checkUserIntegralSufficient(user, totalIntegral)) {
- // 积分不足，返回422状态码
- return AppletControllerUtil.appletWarning("积分不足");
- }
-
- // 8. 创建积分订单
- IntegralOrder order = AppletControllerUtil.buildIntegralOrder(params, user, product, address);
- int orderResult = integralOrderService.insertIntegralOrder(order);
-
- if (orderResult <= 0) {
- return error("订单创建失败");
- }
-
- // 9. 扣除用户积分
- Users updateUser = new Users();
- updateUser.setId(user.getId());
- updateUser.setIntegral(user.getIntegral() - totalIntegral);
- int updateResult = usersService.updateUsers(updateUser);
-
- if (updateResult <= 0) {
- return error("扣除积分失败");
- }
-
- // 10. 记录积分变动日志
- IntegralLog integralLog = AppletControllerUtil.buildIntegralLog(
- user, -totalIntegral, order.getOrderId(), product.getTitle());
- integralLogService.insertIntegralLog(integralLog);
-
- // 11. 更新商品库存（如果有库存管理）
- if (product.getStock() != null) {
- IntegralProduct updateProduct = new IntegralProduct();
- updateProduct.setId(product.getId());
- updateProduct.setStock(product.getStock() - num);
- updateProduct.setSales(product.getSales() != null ? product.getSales() + num : num.longValue());
- integralProductService.updateIntegralProduct(updateProduct);
- }
- // 12. 构建返回结果
- return AppletControllerUtil.appletSuccess("兑换成功");
- } catch (Exception e) {
- System.err.println("积分商品兑换异常：" + e.getMessage());
- return AppletControllerUtil.appletError("积分商品兑换失败：" + e.getMessage());
- }
- }
-
- /**
- * 获取服务订单详情
- *
- * @param id 订单ID
- * @param request HTTP请求对象
- * @return 服务订单详细信息
- *
- * 接口说明：
- * - 根据订单ID获取服务订单完整信息
- * - 包含订单基本信息、订单日志和商品信息
- * - 验证用户登录状态和订单归属权
- * - 返回完整的订单详情数据
- *
- * 返回格式：
- * {
- * "code": 200,
- * "msg": "OK",
- * "data": {
- * // 订单基本信息
- * "id": 260,
- * "order_id": "B831770908583777",
- * // ... 其他订单字段
- * "log": [
- * // 订单日志数组
- * ],
- * "product": {
- * // 商品信息
- * }
- * }
- * }
- */
- @GetMapping("/api/service/order/info/{id}")
- public AjaxResult getServiceOrderInfo(@PathVariable("id") Long id, HttpServletRequest request) {
- try {
- // 1. 参数验证
- if (id == null || id <= 0) {
- return AppletControllerUtil.appletWarning("订单ID无效");
- }
-
- // 2. 验证用户登录状态
- String token = request.getHeader("token");
- Map userValidation = AppletLoginUtil.validateUserToken(token, usersService);
- if (!(Boolean) userValidation.get("valid")) {
- return AppletControllerUtil.appletUnauthorized();
- }
-
- // 3. 获取用户信息
- Users user = (Users) userValidation.get("user");
- if (user == null) {
- return AppletControllerUtil.appletWarning("用户信息获取失败");
- }
-
- // 4. 查询订单信息并验证归属权
- Order order = orderService.selectOrderById(id);
- if (order == null) {
- return AppletControllerUtil.appletWarning("订单不存在");
- }
-
- // 5. 验证订单归属权
- if (!order.getUid().equals(user.getId())) {
- return AppletControllerUtil.appletWarning("无权访问该订单信息");
- }
-
- // 6. 使用工具类构建订单详情数据
- Map orderDetail = AppletControllerUtil.buildServiceOrderDetail(
- order, orderLogService, serviceGoodsService);
-
- return AppletControllerUtil.appletSuccess(orderDetail);
-
- } catch (Exception e) {
- System.err.println("查询服务订单详情异常：" + e.getMessage());
- return AppletControllerUtil.appletError("查询订单详情失败：" + e.getMessage());
- }
- }
-
- /**
- * 获取城市列表接口
- *
- * @param request HTTP请求对象
- * @return 城市列表数据
- *
- * 接口说明：
- * - 获取所有启用状态的城市列表
- * - 返回城市的ID、名称和父级ID
- * - 用于小程序城市选择功能
- * - 无需用户登录验证
- *
- * 返回格式：
- * {
- * "code": 200,
- * "msg": "OK",
- * "data": [
- * {
- * "id": 1,
- * "title": "西安市",
- * "pid": 0
- * }
- * ]
- * }
- */
- @GetMapping(value = "/api/public/diy/city")
- public AjaxResult getDiyCityList(HttpServletRequest request) {
- try {
- // 查询所有城市列表
- List cityList = diyCityService.selectDiyCityList(null);
-
- // 构建树状结构数据
- List> resultList = AppletControllerUtil.buildCityTree(cityList);
-
- return AppletControllerUtil.appletSuccess(resultList);
- } catch (Exception e) {
- System.err.println("获取城市列表异常：" + e.getMessage());
- return AppletControllerUtil.appletError("获取城市列表失败：" + e.getMessage());
- }
- }
-
- /**
- * 获取技能列表接口
- *
- * @param request HTTP请求对象
- * @return 技能列表数据
- *
- * 接口说明：
- * - 获取所有技能列表数据
- * - 返回技能的ID、名称、排序、状态等信息
- * - 用于小程序技能选择功能
- * - 无需用户登录验证
- *
- * 返回格式：
- * {
- * "code": 200,
- * "msg": "OK",
- * "data": [
- * {
- * "id": 47,
- * "title": "燃气灶维修",
- * "sort": 43,
- * "status": 1,
- * "created_at": "2025-04-10 09:36:35",
- * "updated_at": "2025-04-10 09:36:35"
- * }
- * ]
- * }
- */
- @GetMapping(value = "/api/form/skill/lst")
- public AjaxResult getSkillList(HttpServletRequest request) {
- try {
- // 查询技能列表
- List skillList = siteSkillService.selectSiteSkillList(null);
-
- // 构建返回数据格式
- List> resultList = new ArrayList<>();
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-
- for (SiteSkill skill : skillList) {
- Map skillData = new HashMap<>();
- skillData.put("id", skill.getId());
- skillData.put("title", skill.getTitle());
- skillData.put("sort", skill.getSort());
- skillData.put("status", skill.getStatus());
-
- // 格式化时间字段
- if (skill.getCreatedAt() != null) {
- skillData.put("created_at", sdf.format(skill.getCreatedAt()));
- } else {
- skillData.put("created_at", null);
- }
-
- if (skill.getUpdatedAt() != null) {
- skillData.put("updated_at", sdf.format(skill.getUpdatedAt()));
- } else {
- skillData.put("updated_at", null);
- }
-
- resultList.add(skillData);
- }
-
- return AppletControllerUtil.appletSuccess(resultList);
- } catch (Exception e) {
- System.err.println("获取技能列表异常：" + e.getMessage());
- return AppletControllerUtil.appletError("获取技能列表失败：" + e.getMessage());
- }
- }
-
- /**
- * 文件上传接口
- *
- * @param file 上传的文件
- * @param request HTTP请求对象
- * @return 上传结果
- *
- * 接口说明：
- * - 支持图片和文档文件上传
- * - 优先使用七牛云上传，未启用时使用本地上传
- * - 自动验证文件格式和大小
- * - 无需用户登录验证（public 接口）
- *
- * 支持的文件格式：
- * - 图片：jpg, jpeg, png, gif, bmp, webp, svg
- * - 文档：doc, docx, xls, xlsx, ppt, pptx, txt, pdf
- *
- * 返回格式：
- * {
- * "code": 200,
- * "msg": "OK",
- * "data": {
- * "path": "images/2025-06-11/zvsZHNoFYlFkMCePQs1624hKwBSCozL9XM7pEUmo.jpg",
- * "full_path": "http://img.huafurenjia.cn/images/2025-06-11/zvsZHNoFYlFkMCePQs1624hKwBSCozL9XM7pEUmo.jpg"
- * }
- * }
- */
- @PostMapping(value = "/api/public/upload/file")
- public AjaxResult uploadFile(@RequestParam("file") MultipartFile file, HttpServletRequest request) {
- try {
- // 1. 验证文件是否为空
- if (file == null || file.isEmpty()) {
- return AppletControllerUtil.appletWarning("上传文件不能为空");
- }
-
- // 2. 验证文件格式
- String[] allowedTypes = {
- // 图片格式
- "jpg", "jpeg", "png", "gif", "bmp", "webp", "svg",
- // 文档格式
- "doc", "docx", "xls", "xlsx", "ppt", "pptx", "txt", "pdf"
- };
-
- if (!QiniuUploadUtil.isValidFileType(file.getOriginalFilename(), allowedTypes)) {
- return AppletControllerUtil.appletWarning("不支持的文件格式");
- }
-
- // 3. 验证文件大小（10MB）
- long maxSize = 10 * 1024 * 1024;
- if (!QiniuUploadUtil.isFileSizeValid(file.getSize(), maxSize)) {
- return AppletControllerUtil.appletWarning("文件大小不能超过10MB");
- }
-
- String fileUrl;
- String filePath;
-
- // 4. 检查是否启用七牛云上传
- if (qiniuConfig.isEnabled()) {
- // 使用七牛云上传
- fileUrl = QiniuUploadUtil.uploadFile(file);
- // 从完整URL中提取路径部分
- filePath = AppletControllerUtil.extractPathFromUrl(fileUrl, "https://" + qiniuConfig.getDomain() + "/");
- } else {
- // 使用本地上传（这里需要集成本地上传逻辑）
- return AppletControllerUtil.appletError("本地上传功能暂未在此接口中实现，请启用七牛云上传");
- }
-
- // 5. 构建返回数据
- Map uploadResult = new HashMap<>();
- uploadResult.put("path", filePath);
- uploadResult.put("full_path", fileUrl);
-
- return AppletControllerUtil.appletSuccess(uploadResult);
-
- } catch (Exception e) {
- System.err.println("文件上传异常：" + e.getMessage());
- return AppletControllerUtil.appletError("文件上传失败：" + e.getMessage());
- }
- }
-
-
- /**
- * 获取服务预约时间段接口
- *
- * @param params 请求参数，包含day(预约日期)
- * @param request HTTP请求对象
- * @return 时间段列表数据
- *
- * 接口说明：
- * - 根据指定日期获取可预约的时间段列表
- * - 返回每个时间段的可用状态和剩余数量
- * - 支持动态时间段配置
- * - 无需用户登录验证
- *
- * 请求参数格式：
- * {
- * "day": "2025-06-11"
- * }
- *
- * 返回格式：
- * {
- * "code": 200,
- * "msg": "OK",
- * "data": [
- * {
- * "click": true,
- * "value": "8:00-10:00",
- * "prove": "可预约",
- * "residue_num": 99
- * }
- * ]
- * }
- */
- @PostMapping(value = "/api/service/make/time")
- public AjaxResult getServiceMakeTime(@RequestBody Map params, HttpServletRequest request) {
- try {
- // 1. 参数验证
- if (params == null || params.get("day") == null) {
- return AppletControllerUtil.appletWarning("日期参数不能为空");
- }
-
- String day = params.get("day").toString().trim();
- if (day.isEmpty()) {
- return AppletControllerUtil.appletWarning("日期参数不能为空");
- }
-
- // 2. 验证日期格式
- if (!AppletControllerUtil.isValidDateFormat(day)) {
- return AppletControllerUtil.appletWarning("日期格式错误，请使用yyyy-MM-dd格式");
- }
-
- // 3. 检查日期是否为过去时间
- if (AppletControllerUtil.isPastDate(day)) {
- return AppletControllerUtil.appletWarning("不能预约过去的日期");
- }
-
- // 4. 构建时间段列表
- List> timeSlotList = AppletControllerUtil.buildTimeSlotList(day);
-
- return AppletControllerUtil.appletSuccess(timeSlotList);
-
- } catch (Exception e) {
- System.err.println("获取服务预约时间段异常：" + e.getMessage());
- return AppletControllerUtil.appletError("获取时间段失败：" + e.getMessage());
- }
- }
-
-
- /**
- * 添加商品到购物车接口
- *
- * @param params 请求参数，包含good_id(商品ID)、sku(商品规格)
- * @param request HTTP请求对象
- * @return 添加结果
- *
- * 接口说明：
- * - 将指定商品添加到用户购物车
- * - 验证商品是否存在和可用
- * - 支持商品规格选择
- * - 需要用户登录验证
- *
- * 请求参数格式：
- * {
- * "good_id": 86,
- * "sku": ""
- * }
- *
- * 返回格式：
- * {
- * "code": 200,
- * "msg": "操作成功",
- * "data": "商品已添加到购物车"
- * }
- */
- @PostMapping(value = "/api/cart/add")
- public AjaxResult addToCart(@RequestBody Map params, HttpServletRequest request) {
- try {
- // 1. 验证用户登录状态
- String token = request.getHeader("token");
- Map userValidation = AppletLoginUtil.validateUserToken(token, usersService);
- if (!(Boolean) userValidation.get("valid")) {
- return AppletControllerUtil.appletUnauthorized();
- }
-
- // 2. 获取用户信息
- Users user = (Users) userValidation.get("user");
- if (user == null) {
- return AppletControllerUtil.appletWarning("用户信息获取失败");
- }
-
- // 3. 验证请求参数
- if (params == null || params.get("good_id") == null) {
- return AppletControllerUtil.appletWarning("商品ID不能为空");
- }
-
- Long goodId;
- try {
- goodId = Long.valueOf(params.get("good_id").toString());
- if (goodId <= 0) {
- return AppletControllerUtil.appletWarning("商品ID无效");
- }
- } catch (NumberFormatException e) {
- return AppletControllerUtil.appletWarning("商品ID格式错误");
- }
-
- // 4. 获取商品规格参数
- // String sku = params.get("sku") != null ? params.get("sku").toString().trim() : "";
- String sku = null;
- if (params.get("sku") != null) {
- Object skuParam = params.get("sku");
- if (skuParam instanceof Map) {
- // 如果前端传递的是Map对象，转换为JSON字符串
- try {
- sku = com.alibaba.fastjson2.JSON.toJSONString(skuParam);
- } catch (Exception e) {
- System.err.println("SKU转换JSON失败：" + e.getMessage());
- sku = skuParam.toString();
- }
- } else {
- // 如果前端传递的是字符串，直接使用
- sku = skuParam.toString().trim();
- }
- }else{
- sku = null;
- }
- // 5. 查询商品信息并验证
- ServiceGoods serviceGoods = serviceGoodsService.selectServiceGoodsById(goodId);
- if (serviceGoods == null) {
- return AppletControllerUtil.appletWarning("商品不存在");
- }
-
- // 6. 验证商品状态
+ // 6. 验证商品状态
// if (serviceGoods.getStatus() == null || !serviceGoods.getStatus().equals(1L)) {
// return AppletControllerUtil.appletWarning("商品已下架或不可用");
// }
- // 7. 检查商品库存（如果有库存管理）
+ // 7. 检查商品库存（如果有库存管理）
// if (serviceGoods.getStock() != null && serviceGoods.getStock() <= 0L) {
// return AppletControllerUtil.appletWarning("商品库存不足");
// }
- // 8. 检查购物车中是否已存在该商品
- GoodsCart existingCartItem = AppletControllerUtil.findExistingCartItem(user.getId(), goodId, sku, goodsCartService);
+ // 8. 检查购物车中是否已存在该商品
+ GoodsCart existingCartItem = AppletControllerUtil.findExistingCartItem(user.getId(), goodId, sku, goodsCartService);
- if (existingCartItem != null) {
- // 如果已存在，更新数量
- return AppletControllerUtil.updateCartItemQuantity(existingCartItem, serviceGoods, goodsCartService);
- } else {
- // 如果不存在，新增购物车记录
- return AppletControllerUtil.addNewCartItem(user, serviceGoods, sku, goodsCartService);
- }
-
- } catch (Exception e) {
- System.err.println("添加购物车异常：" + e.getMessage());
- return AppletControllerUtil.appletError("添加购物车失败：" + e.getMessage());
+ if (existingCartItem != null) {
+ // 如果已存在，更新数量
+ return AppletControllerUtil.updateCartItemQuantity(existingCartItem, serviceGoods, goodsCartService);
+ } else {
+ // 如果不存在，新增购物车记录
+ return AppletControllerUtil.addNewCartItem(user, serviceGoods, sku, goodsCartService);
}
+
+ } catch (Exception e) {
+ System.err.println("添加购物车异常：" + e.getMessage());
+ return AppletControllerUtil.appletError("添加购物车失败：" + e.getMessage());
}
+}
- /**
- * 查询购物车列表接口
- *
- * @param params 请求参数，包含limit(每页数量)、page(页码)
- * @param request HTTP请求对象
- * @return 购物车列表数据
- *
- * 接口说明：
- * - 获取当前登录用户的购物车商品列表
- * - 支持分页查询
- * - 返回完整的商品信息
- * - 需要用户登录验证
- *
- * 请求参数格式：
- * {
- * "limit": 15,
- * "page": 1
- * }
- *
- * 返回格式：
- * {
- * "code": 200,
- * "msg": "OK",
- * "data": {
- * "current_page": 1,
- * "data": [
- * {
- * "id": 248,
- * "uid": 302,
- * "good_id": 86,
- * "good_num": 1,
- * "sku": null,
- * "created_at": "2025-06-11 10:05:37",
- * "updated_at": "2025-06-11 10:05:37",
- * "good": {
- * "id": 86,
- * "title": "马桶漏水",
- * "price": "0.00",
- * "icon": "https://img.huafurenjia.cn/images/...",
- * "stock": 232,
- * "type": 1
- * }
- * }
- * ],
- * "from": 1,
- * "last_page": 1,
- * "per_page": 15,
- * "to": 1,
- * "total": 1
- * }
- * }
- */
- @PostMapping(value = "/api/cart/lst")
- public AjaxResult getCartList(@RequestBody Map params, HttpServletRequest request) {
- try {
- // 1. 验证用户登录状态
- String token = request.getHeader("token");
- Map userValidation = AppletLoginUtil.validateUserToken(token, usersService);
- if (!(Boolean) userValidation.get("valid")) {
- return AppletControllerUtil.appletUnauthorized();
- }
-
- // 2. 获取用户信息
- Users user = (Users) userValidation.get("user");
- if (user == null) {
- return AppletControllerUtil.appletWarning("用户信息获取失败");
- }
-
- // 3. 获取分页参数
- int page = params.get("page") != null ? (Integer) params.get("page") : 1;
- int limit = params.get("limit") != null ? (Integer) params.get("limit") : 15;
-
- // 4. 验证分页参数
- Map pageValidation = PageUtil.validatePageParams(page, limit);
- if (!(Boolean) pageValidation.get("valid")) {
- return AppletControllerUtil.appletWarning((String) pageValidation.get("message"));
- }
-
- // 5. 设置分页参数
- PageHelper.startPage(page, limit);
-
- // 6. 构建查询条件
- GoodsCart queryCart = new GoodsCart();
- queryCart.setUid(user.getId());
-
- // 7. 查询购物车列表
- List cartList = goodsCartService.selectGoodsCartList(queryCart);
-
- // 8. 为每个购物车项目填充商品信息
- List> resultList = new ArrayList<>();
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-
- for (GoodsCart cart : cartList) {
- Map cartData = new HashMap<>();
-
- // 基本购物车信息
- cartData.put("id", cart.getId());
- cartData.put("uid", cart.getUid());
- cartData.put("good_id", cart.getGoodId());
- cartData.put("good_num", cart.getGoodNum());
- if (cart.getSku() != null||cart.getSku() != "") {
- cartData.put("sku", JSONObject.parseObject(cart.getSku()));
- }else{
- cartData.put("sku", null);
- }
-
-
- // 格式化时间字段
- cartData.put("created_at", cart.getCreatedAt() != null ?
- sdf.format(cart.getCreatedAt()) : null);
- cartData.put("updated_at", cart.getUpdatedAt() != null ?
- sdf.format(cart.getUpdatedAt()) : null);
-
- // 查询并添加商品详细信息
- Map goodInfo = AppletControllerUtil.getGoodDetailForCart(cart.getGoodId(), serviceGoodsService);
- cartData.put("good", goodInfo);
-
- resultList.add(cartData);
- }
-
- // 9. 构建分页信息
- PageInfo pageInfo = new PageInfo<>(cartList);
-
- // 10. 构建返回数据格式
- Map responseData = new HashMap<>();
- responseData.put("current_page", pageInfo.getPageNum());
- responseData.put("data", resultList);
- responseData.put("from", pageInfo.getStartRow());
- responseData.put("last_page", pageInfo.getPages());
- responseData.put("per_page", pageInfo.getPageSize());
- responseData.put("to", pageInfo.getEndRow());
- responseData.put("total", pageInfo.getTotal());
-
- // 构建分页链接信息
- String baseUrl = "https://www.huafurenjia.cn/api/cart/lst";
- responseData.put("first_page_url", baseUrl + "?page=1");
- responseData.put("last_page_url", baseUrl + "?page=" + pageInfo.getPages());
- responseData.put("next_page_url", pageInfo.isHasNextPage() ?
- baseUrl + "?page=" + pageInfo.getNextPage() : null);
- responseData.put("prev_page_url", pageInfo.isHasPreviousPage() ?
- baseUrl + "?page=" + pageInfo.getPrePage() : null);
- responseData.put("path", baseUrl);
-
- // 构建links数组
- List> links = new ArrayList<>();
- Map prevLink = new HashMap<>();
- prevLink.put("url", pageInfo.isHasPreviousPage() ?
- baseUrl + "?page=" + pageInfo.getPrePage() : null);
- prevLink.put("label", "« Previous");
- prevLink.put("active", false);
- links.add(prevLink);
-
- Map nextLink = new HashMap<>();
- nextLink.put("url", pageInfo.isHasNextPage() ?
- baseUrl + "?page=" + pageInfo.getNextPage() : null);
- nextLink.put("label", "Next »");
- nextLink.put("active", false);
- links.add(nextLink);
-
- responseData.put("links", links);
-
- return AppletControllerUtil.appletSuccess(responseData);
-
- } catch (Exception e) {
- System.err.println("查询购物车列表异常：" + e.getMessage());
- return AppletControllerUtil.appletError("查询购物车列表失败：" + e.getMessage());
+/**
+ * 查询购物车列表接口
+ *
+ * @param params 请求参数，包含limit(每页数量)、page(页码)
+ * @param request HTTP请求对象
+ * @return 购物车列表数据
+ *
+ * 接口说明：
+ * - 获取当前登录用户的购物车商品列表
+ * - 支持分页查询
+ * - 返回完整的商品信息
+ * - 需要用户登录验证
+ *
+ * 请求参数格式：
+ * {
+ * "limit": 15,
+ * "page": 1
+ * }
+ *
+ * 返回格式：
+ * {
+ * "code": 200,
+ * "msg": "OK",
+ * "data": {
+ * "current_page": 1,
+ * "data": [
+ * {
+ * "id": 248,
+ * "uid": 302,
+ * "good_id": 86,
+ * "good_num": 1,
+ * "sku": null,
+ * "created_at": "2025-06-11 10:05:37",
+ * "updated_at": "2025-06-11 10:05:37",
+ * "good": {
+ * "id": 86,
+ * "title": "马桶漏水",
+ * "price": "0.00",
+ * "icon": "https://img.huafurenjia.cn/images/...",
+ * "stock": 232,
+ * "type": 1
+ * }
+ * }
+ * ],
+ * "from": 1,
+ * "last_page": 1,
+ * "per_page": 15,
+ * "to": 1,
+ * "total": 1
+ * }
+ * }
+ */
+@PostMapping(value = "/api/cart/lst")
+public AjaxResult getCartList(@RequestBody Map params, HttpServletRequest request) {
+ try {
+ // 1. 验证用户登录状态
+ String token = request.getHeader("token");
+ Map userValidation = AppletLoginUtil.validateUserToken(token, usersService);
+ if (!(Boolean) userValidation.get("valid")) {
+ return AppletControllerUtil.appletUnauthorized();
}
- }
-
- /**
- * 服务/商品搜索接口
- *
- * @param params 请求参数，包含limit(每页数量)、page(页码)、keywords(搜索关键词)
- * @param request HTTP请求对象
- * @return 搜索结果列表
- *
- * 接口说明：
- * - 根据关键词搜索服务商品
- * - 支持按商品标题进行模糊查询
- * - 支持分页查询
- * - 无需用户登录验证
- *
- * 请求参数格式：
- * {
- * "limit": 15,
- * "page": 1,
- * "keywords": "3"
- * }
- *
- * 返回格式：
- * {
- * "code": 200,
- * "msg": "OK",
- * "data": {
- * "current_page": 1,
- * "data": [
- * {
- * "id": 161,
- * "title": "238元套餐",
- * "icon": "https://img.huafurenjia.cn/images/238元套餐.png",
- * "cate_id": 8,
- * "price": "238.00",
- * "price_zn": "元起",
- * "sales": 66,
- * "stock": 942,
- * "sub_title": "咖啡机（咖啡）冷台·洗衣机（空调）烘",
- * "title": "238元套餐",
- * "type": 1
- * }
- * ],
- * "from": 1,
- * "last_page": 1,
- * "per_page": 15,
- * "to": 2,
- * "total": 2
- * }
- * }
- */
- @PostMapping(value = "/api/service/search")
- public AjaxResult searchServices(@RequestBody Map params, HttpServletRequest request) {
- try {
- // 1. 获取搜索参数
- int page = params.get("page") != null ? (Integer) params.get("page") : 1;
- int limit = params.get("limit") != null ? (Integer) params.get("limit") : 15;
- String keywords = params.get("keywords") != null ? params.get("keywords").toString().trim() : "";
-
- // 2. 验证分页参数
- Map pageValidation = PageUtil.validatePageParams(page, limit);
- if (!(Boolean) pageValidation.get("valid")) {
- return AppletControllerUtil.appletWarning((String) pageValidation.get("message"));
- }
-
- // 3. 设置分页参数
- PageHelper.startPage(page, limit);
-
- // 4. 构建查询条件
- ServiceGoods queryGoods = new ServiceGoods();
-
- // 如果有关键词，设置标题模糊查询
- if (!keywords.isEmpty()) {
- queryGoods.setTitle(keywords); // 这里依赖mapper中的like查询实现
- }
-
- // 5. 查询商品列表
- List goodsList = serviceGoodsService.selectServiceGoodsList(queryGoods);
-
- // 6. 构建返回数据
- List> resultList = new ArrayList<>();
- for (ServiceGoods goods : goodsList) {
- Map goodsData = AppletControllerUtil.buildServiceGoodsData(goods);
- resultList.add(goodsData);
- }
-
- // 7. 构建分页信息
- PageInfo pageInfo = new PageInfo<>(goodsList);
-
- // 8. 构建返回数据格式
- Map responseData = new HashMap<>();
- responseData.put("current_page", pageInfo.getPageNum());
- responseData.put("data", resultList);
- responseData.put("from", pageInfo.getStartRow());
- responseData.put("last_page", pageInfo.getPages());
- responseData.put("per_page", pageInfo.getPageSize());
- responseData.put("to", pageInfo.getEndRow());
- responseData.put("total", pageInfo.getTotal());
-
- // 构建分页链接信息
- String baseUrl = "https://www.huafurenjia.cn/api/service/search";
- responseData.put("first_page_url", baseUrl + "?page=1");
- responseData.put("last_page_url", baseUrl + "?page=" + pageInfo.getPages());
- responseData.put("next_page_url", pageInfo.isHasNextPage() ?
- baseUrl + "?page=" + pageInfo.getNextPage() : null);
- responseData.put("prev_page_url", pageInfo.isHasPreviousPage() ?
- baseUrl + "?page=" + pageInfo.getPrePage() : null);
- responseData.put("path", baseUrl);
-
- // 构建links数组
- List> links = new ArrayList<>();
- Map prevLink = new HashMap<>();
- prevLink.put("url", pageInfo.isHasPreviousPage() ?
- baseUrl + "?page=" + pageInfo.getPrePage() : null);
- prevLink.put("label", "« Previous");
- prevLink.put("active", false);
- links.add(prevLink);
-
- Map nextLink = new HashMap<>();
- nextLink.put("url", pageInfo.isHasNextPage() ?
- baseUrl + "?page=" + pageInfo.getNextPage() : null);
- nextLink.put("label", "Next »");
- nextLink.put("active", false);
- links.add(nextLink);
-
- responseData.put("links", links);
-
- return AppletControllerUtil.appletSuccess(responseData);
-
- } catch (Exception e) {
- System.err.println("搜索服务商品异常：" + e.getMessage());
- return AppletControllerUtil.appletError("搜索失败：" + e.getMessage());
+ // 2. 获取用户信息
+ Users user = (Users) userValidation.get("user");
+ if (user == null) {
+ return AppletControllerUtil.appletWarning("用户信息获取失败");
}
- }
- /**
- * 获取商品订单详情接口
- *
- * @param id 订单ID
- * @param request HTTP请求对象
- * @return 订单详细信息
- *
- * 接口说明：
- * - 根据订单ID获取商品订单完整信息
- * - 包含订单基本信息、用户地址、商品信息等
- * - 验证用户登录状态和订单归属权
- * - 返回完整的订单详情数据
- *
- * 返回格式：
- * {
- * "code": 200,
- * "msg": "OK",
- * "data": {
- * "id": 2,
- * "type": 2,
- * "main_order_id": "WXBB08452049418556",
- * "order_id": "BB08452049567554",
- * // ... 其他订单字段
- * "address": {
- * // 地址信息
- * },
- * "product": {
- * // 商品信息
- * },
- * "comment": [],
- * "delivery": []
- * }
- * }
- */
- @GetMapping("/api/goods/order/info/{id}")
- public AjaxResult getGoodsOrderInfo(@PathVariable("id") Long id, HttpServletRequest request) {
- try {
- // 1. 参数验证
- if (id == null || id <= 0) {
- return AppletControllerUtil.appletWarning("订单ID无效");
- }
+ // 3. 获取分页参数
+ int page = params.get("page") != null ? (Integer) params.get("page") : 1;
+ int limit = params.get("limit") != null ? (Integer) params.get("limit") : 15;
- // 2. 验证用户登录状态
- String token = request.getHeader("token");
- Map userValidation = AppletLoginUtil.validateUserToken(token, usersService);
- if (!(Boolean) userValidation.get("valid")) {
- return AppletControllerUtil.appletUnauthorized();
- }
-
- // 3. 获取用户信息
- Users user = (Users) userValidation.get("user");
- if (user == null) {
- return AppletControllerUtil.appletWarning("用户信息获取失败");
- }
-
- // 4. 查询订单信息并验证归属权
- GoodsOrder order = goodsOrderService.selectGoodsOrderById(id);
- if (order == null) {
- return AppletControllerUtil.appletWarning("订单不存在");
- }
-
- // 5. 验证订单归属权
- if (!order.getUid().equals(user.getId())) {
- return AppletControllerUtil.appletWarning("无权访问该订单信息");
- }
-
- // 6. 构建订单详情数据
- Map orderDetail = buildGoodsOrderDetail(order);
-
- return AppletControllerUtil.appletSuccess(orderDetail);
-
- } catch (Exception e) {
- System.err.println("查询商品订单详情异常：" + e.getMessage());
- return AppletControllerUtil.appletError("查询订单详情失败：" + e.getMessage());
+ // 4. 验证分页参数
+ Map pageValidation = PageUtil.validatePageParams(page, limit);
+ if (!(Boolean) pageValidation.get("valid")) {
+ return AppletControllerUtil.appletWarning((String) pageValidation.get("message"));
}
- }
- /**
- * 构建商品订单详情数据
- *
- * @param order 订单信息
- * @return 格式化的订单详情
- */
- private Map buildGoodsOrderDetail(GoodsOrder order) {
- Map orderDetail = new HashMap<>();
+ // 5. 设置分页参数
+ PageHelper.startPage(page, limit);
+
+ // 6. 构建查询条件
+ GoodsCart queryCart = new GoodsCart();
+ queryCart.setUid(user.getId());
+
+ // 7. 查询购物车列表
+ List cartList = goodsCartService.selectGoodsCartList(queryCart);
+
+ // 8. 为每个购物车项目填充商品信息
+ List> resultList = new ArrayList<>();
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
- // 订单基本信息
- orderDetail.put("id", order.getId());
- orderDetail.put("type", order.getType());
- orderDetail.put("main_order_id", order.getMainOrderId());
- orderDetail.put("order_id", order.getOrderId());
- orderDetail.put("transaction_id", order.getTransactionId() != null ? order.getTransactionId() : "");
- orderDetail.put("uid", order.getUid());
- orderDetail.put("product_id", order.getProductId());
- orderDetail.put("name", order.getName());
- orderDetail.put("phone", order.getPhone());
- orderDetail.put("num", order.getNum());
- orderDetail.put("total_price", order.getTotalPrice() != null ? order.getTotalPrice().toString() : "0.00");
- orderDetail.put("good_price", order.getGoodPrice() != null ? order.getGoodPrice().toString() : "0.00");
- orderDetail.put("service_price", order.getServicePrice());
- orderDetail.put("pay_price", order.getPayPrice() != null ? order.getPayPrice().toString() : "0.00");
- orderDetail.put("deduction", order.getDeduction() != null ? order.getDeduction().toString() : "0.00");
- orderDetail.put("postage", order.getPostage());
- orderDetail.put("pay_time", order.getPayTime() != null ? sdf.format(order.getPayTime()) : null);
- orderDetail.put("status", order.getStatus());
- orderDetail.put("delivery_id", order.getDeliveryId());
- orderDetail.put("delivery_num", order.getDeliveryNum() != null ? order.getDeliveryNum() : "");
- orderDetail.put("send_time", order.getSendTime() != null ? sdf.format(order.getSendTime()) : null);
- orderDetail.put("mark", order.getMark());
- orderDetail.put("address_id", order.getAddressId());
- orderDetail.put("sku", order.getSku());
+ for (GoodsCart cart : cartList) {
+ Map cartData = new HashMap<>();
- // 时间字段格式化
- orderDetail.put("created_at", order.getCreatedAt() != null ? sdf.format(order.getCreatedAt()) : null);
- orderDetail.put("updated_at", order.getUpdatedAt() != null ? sdf.format(order.getUpdatedAt()) : null);
- orderDetail.put("deleted_at", order.getDeletedAt() != null ? sdf.format(order.getDeletedAt()) : null);
-
- // 查询并添加地址信息
- if (order.getAddressId() != null) {
- UserAddress address = userAddressService.selectUserAddressById(order.getAddressId());
- if (address != null) {
- Map addressInfo = new HashMap<>();
- addressInfo.put("id", address.getId());
- addressInfo.put("uid", address.getUid());
- addressInfo.put("name", address.getName());
- addressInfo.put("phone", address.getPhone());
- addressInfo.put("latitude", address.getLatitude());
- addressInfo.put("longitude", address.getLongitude());
- addressInfo.put("address_name", address.getAddressName());
- addressInfo.put("address_info", address.getAddressInfo());
- addressInfo.put("info", address.getInfo());
- addressInfo.put("is_default", address.getIsDefault());
- addressInfo.put("created_at", address.getCreatedAt() != null ? sdf.format(address.getCreatedAt()) : null);
- addressInfo.put("updated_at", address.getUpdatedAt() != null ? sdf.format(address.getUpdatedAt()) : null);
- addressInfo.put("deleted_at", null); // UserAddress可能没有deletedAt字段
-
- orderDetail.put("address", addressInfo);
+ // 基本购物车信息
+ cartData.put("id", cart.getId());
+ cartData.put("uid", cart.getUid());
+ cartData.put("good_id", cart.getGoodId());
+ cartData.put("good_num", cart.getGoodNum());
+ if (cart.getSku() != null || cart.getSku() != "") {
+ cartData.put("sku", JSONObject.parseObject(cart.getSku()));
+ } else {
+ cartData.put("sku", null);
}
+
+
+ // 格式化时间字段
+ cartData.put("created_at", cart.getCreatedAt() != null ?
+ sdf.format(cart.getCreatedAt()) : null);
+ cartData.put("updated_at", cart.getUpdatedAt() != null ?
+ sdf.format(cart.getUpdatedAt()) : null);
+
+ // 查询并添加商品详细信息
+ Map goodInfo = AppletControllerUtil.getGoodDetailForCart(cart.getGoodId(), serviceGoodsService);
+ cartData.put("good", goodInfo);
+
+ resultList.add(cartData);
}
- // 查询并添加商品信息
- if (order.getProductId() != null) {
- ServiceGoods product = serviceGoodsService.selectServiceGoodsById(order.getProductId());
- if (product != null) {
- Map productInfo = new HashMap<>();
- productInfo.put("id", product.getId());
- productInfo.put("title", product.getTitle());
- productInfo.put("sub_title", product.getSubTitle());
- productInfo.put("icon", AppletControllerUtil.buildImageUrl(product.getIcon()));
+ // 9. 构建分页信息
+ PageInfo pageInfo = new PageInfo<>(cartList);
- orderDetail.put("product", productInfo);
- }
+ // 10. 构建返回数据格式
+ Map responseData = new HashMap<>();
+ responseData.put("current_page", pageInfo.getPageNum());
+ responseData.put("data", resultList);
+ responseData.put("from", pageInfo.getStartRow());
+ responseData.put("last_page", pageInfo.getPages());
+ responseData.put("per_page", pageInfo.getPageSize());
+ responseData.put("to", pageInfo.getEndRow());
+ responseData.put("total", pageInfo.getTotal());
+
+ // 构建分页链接信息
+ String baseUrl = "https://www.huafurenjia.cn/api/cart/lst";
+ responseData.put("first_page_url", baseUrl + "?page=1");
+ responseData.put("last_page_url", baseUrl + "?page=" + pageInfo.getPages());
+ responseData.put("next_page_url", pageInfo.isHasNextPage() ?
+ baseUrl + "?page=" + pageInfo.getNextPage() : null);
+ responseData.put("prev_page_url", pageInfo.isHasPreviousPage() ?
+ baseUrl + "?page=" + pageInfo.getPrePage() : null);
+ responseData.put("path", baseUrl);
+
+ // 构建links数组
+ List> links = new ArrayList<>();
+ Map prevLink = new HashMap<>();
+ prevLink.put("url", pageInfo.isHasPreviousPage() ?
+ baseUrl + "?page=" + pageInfo.getPrePage() : null);
+ prevLink.put("label", "« Previous");
+ prevLink.put("active", false);
+ links.add(prevLink);
+
+ Map nextLink = new HashMap<>();
+ nextLink.put("url", pageInfo.isHasNextPage() ?
+ baseUrl + "?page=" + pageInfo.getNextPage() : null);
+ nextLink.put("label", "Next »");
+ nextLink.put("active", false);
+ links.add(nextLink);
+
+ responseData.put("links", links);
+
+ return AppletControllerUtil.appletSuccess(responseData);
+
+ } catch (Exception e) {
+ System.err.println("查询购物车列表异常：" + e.getMessage());
+ return AppletControllerUtil.appletError("查询购物车列表失败：" + e.getMessage());
+ }
+}
+
+
+/**
+ * 服务/商品搜索接口
+ *
+ * @param params 请求参数，包含limit(每页数量)、page(页码)、keywords(搜索关键词)
+ * @param request HTTP请求对象
+ * @return 搜索结果列表
+ *
+ * 接口说明：
+ * - 根据关键词搜索服务商品
+ * - 支持按商品标题进行模糊查询
+ * - 支持分页查询
+ * - 无需用户登录验证
+ *
+ * 请求参数格式：
+ * {
+ * "limit": 15,
+ * "page": 1,
+ * "keywords": "3"
+ * }
+ *
+ * 返回格式：
+ * {
+ * "code": 200,
+ * "msg": "OK",
+ * "data": {
+ * "current_page": 1,
+ * "data": [
+ * {
+ * "id": 161,
+ * "title": "238元套餐",
+ * "icon": "https://img.huafurenjia.cn/images/238元套餐.png",
+ * "cate_id": 8,
+ * "price": "238.00",
+ * "price_zn": "元起",
+ * "sales": 66,
+ * "stock": 942,
+ * "sub_title": "咖啡机（咖啡）冷台·洗衣机（空调）烘",
+ * "title": "238元套餐",
+ * "type": 1
+ * }
+ * ],
+ * "from": 1,
+ * "last_page": 1,
+ * "per_page": 15,
+ * "to": 2,
+ * "total": 2
+ * }
+ * }
+ */
+@PostMapping(value = "/api/service/search")
+public AjaxResult searchServices(@RequestBody Map params, HttpServletRequest request) {
+ try {
+ // 1. 获取搜索参数
+ int page = params.get("page") != null ? (Integer) params.get("page") : 1;
+ int limit = params.get("limit") != null ? (Integer) params.get("limit") : 15;
+ String keywords = params.get("keywords") != null ? params.get("keywords").toString().trim() : "";
+
+ // 2. 验证分页参数
+ Map pageValidation = PageUtil.validatePageParams(page, limit);
+ if (!(Boolean) pageValidation.get("valid")) {
+ return AppletControllerUtil.appletWarning((String) pageValidation.get("message"));
}
- // 添加评论和配送信息（暂时为空数组，后续可以扩展）
- orderDetail.put("comment", new ArrayList<>());
- orderDetail.put("delivery", new ArrayList<>());
+ // 3. 设置分页参数
+ PageHelper.startPage(page, limit);
- return orderDetail;
+ // 4. 构建查询条件
+ ServiceGoods queryGoods = new ServiceGoods();
+
+ // 如果有关键词，设置标题模糊查询
+ if (!keywords.isEmpty()) {
+ queryGoods.setTitle(keywords); // 这里依赖mapper中的like查询实现
+ }
+
+ // 5. 查询商品列表
+ List goodsList = serviceGoodsService.selectServiceGoodsList(queryGoods);
+
+ // 6. 构建返回数据
+ List> resultList = new ArrayList<>();
+ for (ServiceGoods goods : goodsList) {
+ Map goodsData = AppletControllerUtil.buildServiceGoodsData(goods);
+ resultList.add(goodsData);
+ }
+
+ // 7. 构建分页信息
+ PageInfo pageInfo = new PageInfo<>(goodsList);
+
+ // 8. 构建返回数据格式
+ Map responseData = new HashMap<>();
+ responseData.put("current_page", pageInfo.getPageNum());
+ responseData.put("data", resultList);
+ responseData.put("from", pageInfo.getStartRow());
+ responseData.put("last_page", pageInfo.getPages());
+ responseData.put("per_page", pageInfo.getPageSize());
+ responseData.put("to", pageInfo.getEndRow());
+ responseData.put("total", pageInfo.getTotal());
+
+ // 构建分页链接信息
+ String baseUrl = "https://www.huafurenjia.cn/api/service/search";
+ responseData.put("first_page_url", baseUrl + "?page=1");
+ responseData.put("last_page_url", baseUrl + "?page=" + pageInfo.getPages());
+ responseData.put("next_page_url", pageInfo.isHasNextPage() ?
+ baseUrl + "?page=" + pageInfo.getNextPage() : null);
+ responseData.put("prev_page_url", pageInfo.isHasPreviousPage() ?
+ baseUrl + "?page=" + pageInfo.getPrePage() : null);
+ responseData.put("path", baseUrl);
+
+ // 构建links数组
+ List> links = new ArrayList<>();
+ Map prevLink = new HashMap<>();
+ prevLink.put("url", pageInfo.isHasPreviousPage() ?
+ baseUrl + "?page=" + pageInfo.getPrePage() : null);
+ prevLink.put("label", "« Previous");
+ prevLink.put("active", false);
+ links.add(prevLink);
+
+ Map nextLink = new HashMap<>();
+ nextLink.put("url", pageInfo.isHasNextPage() ?
+ baseUrl + "?page=" + pageInfo.getNextPage() : null);
+ nextLink.put("label", "Next »");
+ nextLink.put("active", false);
+ links.add(nextLink);
+
+ responseData.put("links", links);
+
+ return AppletControllerUtil.appletSuccess(responseData);
+
+ } catch (Exception e) {
+ System.err.println("搜索服务商品异常：" + e.getMessage());
+ return AppletControllerUtil.appletError("搜索失败：" + e.getMessage());
+ }
+}
+
+/**
+ * 获取商品订单详情接口
+ *
+ * @param id 订单ID
+ * @param request HTTP请求对象
+ * @return 订单详细信息
+ *
+ * 接口说明：
+ * - 根据订单ID获取商品订单完整信息
+ * - 包含订单基本信息、用户地址、商品信息等
+ * - 验证用户登录状态和订单归属权
+ * - 返回完整的订单详情数据
+ *
+ * 返回格式：
+ * {
+ * "code": 200,
+ * "msg": "OK",
+ * "data": {
+ * "id": 2,
+ * "type": 2,
+ * "main_order_id": "WXBB08452049418556",
+ * "order_id": "BB08452049567554",
+ * // ... 其他订单字段
+ * "address": {
+ * // 地址信息
+ * },
+ * "product": {
+ * // 商品信息
+ * },
+ * "comment": [],
+ * "delivery": []
+ * }
+ * }
+ */
+@GetMapping("/api/goods/order/info/{id}")
+public AjaxResult getGoodsOrderInfo(@PathVariable("id") Long id, HttpServletRequest request) {
+ try {
+ // 1. 参数验证
+ if (id == null || id <= 0) {
+ return AppletControllerUtil.appletWarning("订单ID无效");
+ }
+
+ // 2. 验证用户登录状态
+ String token = request.getHeader("token");
+ Map userValidation = AppletLoginUtil.validateUserToken(token, usersService);
+ if (!(Boolean) userValidation.get("valid")) {
+ return AppletControllerUtil.appletUnauthorized();
+ }
+
+ // 3. 获取用户信息
+ Users user = (Users) userValidation.get("user");
+ if (user == null) {
+ return AppletControllerUtil.appletWarning("用户信息获取失败");
+ }
+
+ // 4. 查询订单信息并验证归属权
+ GoodsOrder order = goodsOrderService.selectGoodsOrderById(id);
+ if (order == null) {
+ return AppletControllerUtil.appletWarning("订单不存在");
+ }
+
+ // 5. 验证订单归属权
+ if (!order.getUid().equals(user.getId())) {
+ return AppletControllerUtil.appletWarning("无权访问该订单信息");
+ }
+
+ // 6. 构建订单详情数据
+ Map orderDetail = buildGoodsOrderDetail(order);
+
+ return AppletControllerUtil.appletSuccess(orderDetail);
+
+ } catch (Exception e) {
+ System.err.println("查询商品订单详情异常：" + e.getMessage());
+ return AppletControllerUtil.appletError("查询订单详情失败：" + e.getMessage());
+ }
+}
+
+/**
+ * 构建商品订单详情数据
+ *
+ * @param order 订单信息
+ * @return 格式化的订单详情
+ */
+private Map buildGoodsOrderDetail(GoodsOrder order) {
+ Map orderDetail = new HashMap<>();
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+
+ // 订单基本信息
+ orderDetail.put("id", order.getId());
+ orderDetail.put("type", order.getType());
+ orderDetail.put("main_order_id", order.getMainOrderId());
+ orderDetail.put("order_id", order.getOrderId());
+ orderDetail.put("transaction_id", order.getTransactionId() != null ? order.getTransactionId() : "");
+ orderDetail.put("uid", order.getUid());
+ orderDetail.put("product_id", order.getProductId());
+ orderDetail.put("name", order.getName());
+ orderDetail.put("phone", order.getPhone());
+ orderDetail.put("num", order.getNum());
+ orderDetail.put("total_price", order.getTotalPrice() != null ? order.getTotalPrice().toString() : "0.00");
+ orderDetail.put("good_price", order.getGoodPrice() != null ? order.getGoodPrice().toString() : "0.00");
+ orderDetail.put("service_price", order.getServicePrice());
+ orderDetail.put("pay_price", order.getPayPrice() != null ? order.getPayPrice().toString() : "0.00");
+ orderDetail.put("deduction", order.getDeduction() != null ? order.getDeduction().toString() : "0.00");
+ orderDetail.put("postage", order.getPostage());
+ orderDetail.put("pay_time", order.getPayTime() != null ? sdf.format(order.getPayTime()) : null);
+ orderDetail.put("status", order.getStatus());
+ orderDetail.put("delivery_id", order.getDeliveryId());
+ orderDetail.put("delivery_num", order.getDeliveryNum() != null ? order.getDeliveryNum() : "");
+ orderDetail.put("send_time", order.getSendTime() != null ? sdf.format(order.getSendTime()) : null);
+ orderDetail.put("mark", order.getMark());
+ orderDetail.put("address_id", order.getAddressId());
+ orderDetail.put("sku", order.getSku());
+
+ // 时间字段格式化
+ orderDetail.put("created_at", order.getCreatedAt() != null ? sdf.format(order.getCreatedAt()) : null);
+ orderDetail.put("updated_at", order.getUpdatedAt() != null ? sdf.format(order.getUpdatedAt()) : null);
+ orderDetail.put("deleted_at", order.getDeletedAt() != null ? sdf.format(order.getDeletedAt()) : null);
+
+ // 查询并添加地址信息
+ if (order.getAddressId() != null) {
+ UserAddress address = userAddressService.selectUserAddressById(order.getAddressId());
+ if (address != null) {
+ Map addressInfo = new HashMap<>();
+ addressInfo.put("id", address.getId());
+ addressInfo.put("uid", address.getUid());
+ addressInfo.put("name", address.getName());
+ addressInfo.put("phone", address.getPhone());
+ addressInfo.put("latitude", address.getLatitude());
+ addressInfo.put("longitude", address.getLongitude());
+ addressInfo.put("address_name", address.getAddressName());
+ addressInfo.put("address_info", address.getAddressInfo());
+ addressInfo.put("info", address.getInfo());
+ addressInfo.put("is_default", address.getIsDefault());
+ addressInfo.put("created_at", address.getCreatedAt() != null ? sdf.format(address.getCreatedAt()) : null);
+ addressInfo.put("updated_at", address.getUpdatedAt() != null ? sdf.format(address.getUpdatedAt()) : null);
+ addressInfo.put("deleted_at", null); // UserAddress可能没有deletedAt字段
+
+ orderDetail.put("address", addressInfo);
+ }
}
- /**
- * 获取用户优惠券数量统计接口
- *
- * @param request HTTP请求对象
- * @return 优惠券数量统计信息
- *
- * 接口说明：
- * - 统计当前登录用户的优惠券数量
- * - 包含未使用、已使用、已过期、待领取数量
- * - 需要用户登录验证
- *
- * 返回格式：
- * {
- * "code": 200,
- * "msg": "OK",
- * "data": {
- * "one": 1, // 未使用数量
- * "two": 0, // 已使用数量
- * "three": 0, // 已过期数量
- * "four": 13 // 待领取数量
- * }
- * }
- */
- @GetMapping("/api/coupon/my/count")
- public AjaxResult getMyCouponCount(HttpServletRequest request) {
- try {
- // 1. 验证用户登录状态
- String token = request.getHeader("token");
- Map userValidation = AppletLoginUtil.validateUserToken(token, usersService);
- if (!(Boolean) userValidation.get("valid")) {
- return AppletControllerUtil.appletUnauthorized();
- }
+ // 查询并添加商品信息
+ if (order.getProductId() != null) {
+ ServiceGoods product = serviceGoodsService.selectServiceGoodsById(order.getProductId());
+ if (product != null) {
+ Map productInfo = new HashMap<>();
+ productInfo.put("id", product.getId());
+ productInfo.put("title", product.getTitle());
+ productInfo.put("sub_title", product.getSubTitle());
+ productInfo.put("icon", AppletControllerUtil.buildImageUrl(product.getIcon()));
- // 2. 获取用户信息
- Users user = (Users) userValidation.get("user");
- if (user == null) {
- return AppletControllerUtil.appletWarning("用户信息获取失败");
- }
+ orderDetail.put("product", productInfo);
+ }
+ }
- // 3. 查询用户的所有优惠券
- CouponUser couponUserQuery = new CouponUser();
- couponUserQuery.setUid(user.getId());
- List userCouponList = couponUserService.selectCouponUserList(couponUserQuery);
+ // 添加评论和配送信息（暂时为空数组，后续可以扩展）
+ orderDetail.put("comment", new ArrayList<>());
+ orderDetail.put("delivery", new ArrayList<>());
- // 4. 统计各种状态的优惠券数量
- int unusedCount = 0; // 未使用数量 (one)
- int usedCount = 0; // 已使用数量 (two)
- int expiredCount = 0; // 已过期数量 (three)
+ return orderDetail;
+}
- long currentTime = System.currentTimeMillis() / 1000; // 当前时间戳（秒）
+/**
+ * 获取用户优惠券数量统计接口
+ *
+ * @param request HTTP请求对象
+ * @return 优惠券数量统计信息
+ *
+ * 接口说明：
+ * - 统计当前登录用户的优惠券数量
+ * - 包含未使用、已使用、已过期、待领取数量
+ * - 需要用户登录验证
+ *
+ * 返回格式：
+ * {
+ * "code": 200,
+ * "msg": "OK",
+ * "data": {
+ * "one": 1, // 未使用数量
+ * "two": 0, // 已使用数量
+ * "three": 0, // 已过期数量
+ * "four": 13 // 待领取数量
+ * }
+ * }
+ */
+@GetMapping("/api/coupon/my/count")
+public AjaxResult getMyCouponCount(HttpServletRequest request) {
+ try {
+ // 1. 验证用户登录状态
+ String token = request.getHeader("token");
+ Map userValidation = AppletLoginUtil.validateUserToken(token, usersService);
+ if (!(Boolean) userValidation.get("valid")) {
+ return AppletControllerUtil.appletUnauthorized();
+ }
- for (CouponUser couponUser : userCouponList) {
- // 检查是否已使用
- if (couponUser.getStatus() != null && couponUser.getStatus() == 2L) {
- usedCount++;
+ // 2. 获取用户信息
+ Users user = (Users) userValidation.get("user");
+ if (user == null) {
+ return AppletControllerUtil.appletWarning("用户信息获取失败");
+ }
+
+ // 3. 查询用户的所有优惠券
+ CouponUser couponUserQuery = new CouponUser();
+ couponUserQuery.setUid(user.getId());
+ List userCouponList = couponUserService.selectCouponUserList(couponUserQuery);
+
+ // 4. 统计各种状态的优惠券数量
+ int unusedCount = 0; // 未使用数量 (one)
+ int usedCount = 0; // 已使用数量 (two)
+ int expiredCount = 0; // 已过期数量 (three)
+
+ long currentTime = System.currentTimeMillis() / 1000; // 当前时间戳（秒）
+
+ for (CouponUser couponUser : userCouponList) {
+ // 检查是否已使用
+ if (couponUser.getStatus() != null && couponUser.getStatus() == 2L) {
+ usedCount++;
+ } else {
+ // 检查是否已过期
+ if (isExpired(couponUser, currentTime)) {
+ expiredCount++;
} else {
- // 检查是否已过期
- if (isExpired(couponUser, currentTime)) {
- expiredCount++;
- } else {
- // 未使用且未过期
- unusedCount++;
- }
+ // 未使用且未过期
+ unusedCount++;
}
}
+ }
- // 5. 查询可领取的优惠券数量
- Coupons couponsQuery = new Coupons();
- couponsQuery.setStatus(1L); // 启用状态
- List availableCoupons = couponsService.selectCouponsList(couponsQuery);
+ // 5. 查询可领取的优惠券数量
+ Coupons couponsQuery = new Coupons();
+ couponsQuery.setStatus(1L); // 启用状态
+ List availableCoupons = couponsService.selectCouponsList(couponsQuery);
- int availableToReceiveCount = 0; // 待领取数量 (four)
- for (Coupons coupon : availableCoupons) {
- if (isCouponAvailableToReceive(coupon, user.getId(), currentTime)) {
- availableToReceiveCount++;
- }
+ int availableToReceiveCount = 0; // 待领取数量 (four)
+ for (Coupons coupon : availableCoupons) {
+ if (isCouponAvailableToReceive(coupon, user.getId(), currentTime)) {
+ availableToReceiveCount++;
}
+ }
- // 6. 构建返回数据
- Map countData = new HashMap<>();
- countData.put("one", unusedCount); // 未使用数量
- countData.put("two", usedCount); // 已使用数量
- countData.put("three", expiredCount); // 已过期数量
- countData.put("four", availableToReceiveCount); // 待领取数量
+ // 6. 构建返回数据
+ Map countData = new HashMap<>();
+ countData.put("one", unusedCount); // 未使用数量
+ countData.put("two", usedCount); // 已使用数量
+ countData.put("three", expiredCount); // 已过期数量
+ countData.put("four", availableToReceiveCount); // 待领取数量
- return AppletControllerUtil.appletSuccess(countData);
+ return AppletControllerUtil.appletSuccess(countData);
- } catch (Exception e) {
- System.err.println("查询用户优惠券数量统计异常：" + e.getMessage());
- return AppletControllerUtil.appletError("查询优惠券数量统计失败：" + e.getMessage());
+ } catch (Exception e) {
+ System.err.println("查询用户优惠券数量统计异常：" + e.getMessage());
+ return AppletControllerUtil.appletError("查询优惠券数量统计失败：" + e.getMessage());
+ }
+}
+
+/**
+ * 判断优惠券是否已过期
+ *
+ * @param couponUser 用户优惠券
+ * @param currentTime 当前时间戳（秒）
+ * @return 是否过期
+ */
+private boolean isExpired(CouponUser couponUser, long currentTime) {
+ // 检查lose_time字段（失效时间），这是一个字符串时间戳
+ if (couponUser.getLoseTime() != null && !couponUser.getLoseTime().isEmpty()) {
+ try {
+ long loseTimeStamp = Long.parseLong(couponUser.getLoseTime());
+ return currentTime > loseTimeStamp;
+ } catch (NumberFormatException e) {
+ // 如果解析失败，假设为日期格式，暂时认为未过期
+ System.err.println("解析失效时间失败：" + couponUser.getLoseTime());
}
}
- /**
- * 判断优惠券是否已过期
- *
- * @param couponUser 用户优惠券
- * @param currentTime 当前时间戳（秒）
- * @return 是否过期
- */
- private boolean isExpired(CouponUser couponUser, long currentTime) {
- // 检查lose_time字段（失效时间），这是一个字符串时间戳
- if (couponUser.getLoseTime() != null && !couponUser.getLoseTime().isEmpty()) {
- try {
- long loseTimeStamp = Long.parseLong(couponUser.getLoseTime());
- return currentTime > loseTimeStamp;
- } catch (NumberFormatException e) {
- // 如果解析失败，假设为日期格式，暂时认为未过期
- System.err.println("解析失效时间失败：" + couponUser.getLoseTime());
- }
- }
-
- // 如果状态为3，表示已失效
- if (couponUser.getStatus() != null && couponUser.getStatus() == 3L) {
- return true;
- }
-
- // 如果都没有设置，认为未过期
- return false;
- }
-
- /**
- * 判断优惠券是否可以领取
- *
- * @param coupon 优惠券
- * @param userId 用户ID
- * @param currentTime 当前时间戳（秒）
- * @return 是否可以领取
- */
- private boolean isCouponAvailableToReceive(Coupons coupon, Long userId, long currentTime) {
- // 检查优惠券状态
- if (coupon.getStatus() == null || coupon.getStatus() != 1L) {
- return false;
- }
-
- // 检查领取时间范围
- if (coupon.getStartTime() != null && currentTime < coupon.getStartTime()) {
- return false; // 还未到领取时间
- }
-
- if (coupon.getEndTime() != null && currentTime > coupon.getEndTime()) {
- return false; // 已过领取时间
- }
-
- // 检查数量限制（如果不是无限领取）
- if (coupon.getIsPermanent() == null || coupon.getIsPermanent() != 1L) {
- if (coupon.getCount() != null && coupon.getCount() <= 0) {
- return false; // 数量已用完
- }
- }
-
- // 检查用户是否已经领取过此优惠券（如果有限制的话）
- // 这里可以根据业务规则进一步完善
-
+ // 如果状态为3，表示已失效
+ if (couponUser.getStatus() != null && couponUser.getStatus() == 3L) {
return true;
}
+ // 如果都没有设置，认为未过期
+ return false;
+}
+
+/**
+ * 判断优惠券是否可以领取
+ *
+ * @param coupon 优惠券
+ * @param userId 用户ID
+ * @param currentTime 当前时间戳（秒）
+ * @return 是否可以领取
+ */
+private boolean isCouponAvailableToReceive(Coupons coupon, Long userId, long currentTime) {
+ // 检查优惠券状态
+ if (coupon.getStatus() == null || coupon.getStatus() != 1L) {
+ return false;
+ }
+
+ // 检查领取时间范围
+ if (coupon.getStartTime() != null && currentTime < coupon.getStartTime()) {
+ return false; // 还未到领取时间
+ }
+
+ if (coupon.getEndTime() != null && currentTime > coupon.getEndTime()) {
+ return false; // 已过领取时间
+ }
+
+ // 检查数量限制（如果不是无限领取）
+ if (coupon.getIsPermanent() == null || coupon.getIsPermanent() != 1L) {
+ if (coupon.getCount() != null && coupon.getCount() <= 0) {
+ return false; // 数量已用完
+ }
+ }
+
+ // 检查用户是否已经领取过此优惠券（如果有限制的话）
+ // 这里可以根据业务规则进一步完善
+
+ return true;
+}
// /**
@@ -4427,267 +4509,517 @@ public class AppletController extends BaseController {
// }
+/**
+ * 创建服务订单（支持多商品批量下单）
+ *
+ * @param params 请求参数，包含多个商品信息、地址信息和预约时间
+ * @param request HTTP请求对象
+ * @return 返回创建结果
+ */
+@PostMapping("/api/service/create/order")
+public AjaxResult createServiceOrder(@RequestBody Map params, HttpServletRequest request) {
+ try {
+ // 1. 验证用户登录状态
+ String token = request.getHeader("token");
+ Map userValidation = AppletLoginUtil.validateUserToken(token, usersService);
+ if (!(Boolean) userValidation.get("valid")) {
+ return error("用户未登录或token无效");
+ }
+ // 2. 获取用户信息
+ Users user = (Users) userValidation.get("user");
+ if (user == null) {
+ return error("用户信息获取失败");
+ }
+ // 3. 验证订单参数
+ if (params == null || params.isEmpty()) {
+ return error("订单参数不能为空");
+ }
- /**
- * 创建服务订单（支持多商品批量下单）
- *
- * @param params 请求参数，包含多个商品信息、地址信息和预约时间
- * @param request HTTP请求对象
- * @return 返回创建结果
- */
- @PostMapping("/api/service/create/order")
- public AjaxResult createServiceOrder(@RequestBody Map params, HttpServletRequest request) {
- try {
- // 1. 验证用户登录状态
- String token = request.getHeader("token");
- Map userValidation = AppletLoginUtil.validateUserToken(token, usersService);
- if (!(Boolean) userValidation.get("valid")) {
- return error("用户未登录或token无效");
+ // 4. 生成主订单号
+ String mainOrderId = GenerateCustomCode.generCreateOrder("WXB");
+
+ // 5. 存储所有订单信息
+ List> orderList = new ArrayList<>();
+ BigDecimal totalAmount = BigDecimal.ZERO; // 总金额
+
+ // 6. 遍历所有订单项
+ for (String key : params.keySet()) {
+ // 跳过非数字键
+ if (!key.matches("\\d+")) {
+ continue;
}
- // 2. 获取用户信息
- Users user = (Users) userValidation.get("user");
- if (user == null) {
- return error("用户信息获取失败");
+ Map orderParams = (Map) params.get(key);
+
+ // 验证必要参数
+ if (orderParams.get("product_id") == null || orderParams.get("address_id") == null) {
+ return error("商品ID或地址ID不能为空");
}
- // 3. 验证订单参数
- if (params == null || params.isEmpty()) {
- return error("订单参数不能为空");
+ Long productId = Long.valueOf(orderParams.get("product_id").toString());
+ Long addressId = Long.valueOf(orderParams.get("address_id").toString());
+ Long num = orderParams.get("num") != null ? Long.valueOf(orderParams.get("num").toString()) : 1L;
+
+ // 处理SKU参数
+ String sku = AppletControllerUtil.processSkuParam(orderParams.get("sku"));
+
+ // 查询商品信息
+ ServiceGoods serviceGoods = serviceGoodsService.selectServiceGoodsById(productId);
+ if (serviceGoods == null) {
+ return error("商品ID " + productId + " 不存在");
}
- // 4. 生成主订单号
- String mainOrderId =GenerateCustomCode.generCreateOrder("WXB");
+ // 查询地址信息（只需要查询一次，假设所有订单使用相同地址）
+ UserAddress userAddress = userAddressService.selectUserAddressById(addressId);
+ if (userAddress == null) {
+ return error("地址不存在");
+ }
+
+ // 计算单个订单金额
+ BigDecimal itemPrice = serviceGoods.getPrice().multiply(BigDecimal.valueOf(num));
+ totalAmount = totalAmount.add(itemPrice);
+
+ // 判断商品类型并创建相应订单
+ if (serviceGoods.getType() == 2) {
+ // 创建服务订单
+ String coupon_id = orderParams.get("coupon_id") != null ? orderParams.get("coupon_id").toString() : "";
+ if (coupon_id!=null){
+ CouponUser coupon = couponUserService.selectCouponUserById(Long.valueOf(coupon_id));
+ if (coupon==null){
+ return AppletControllerUtil.appletWarning("优惠券不存在");
+ }
- // 5. 存储所有订单信息
- List> orderList = new ArrayList<>();
- BigDecimal totalAmount = BigDecimal.ZERO; // 总金额
- // 6. 遍历所有订单项
- for (String key : params.keySet()) {
- // 跳过非数字键
- if (!key.matches("\\d+")) {
- continue;
}
- Map orderParams = (Map) params.get(key);
+ // 创建商品订单
+ GoodsOrder goodsOrder = new GoodsOrder();
+ goodsOrder.setType(2);
+ goodsOrder.setMainOrderId(mainOrderId);
+ goodsOrder.setOrderId(GenerateCustomCode.generCreateOrder("B")); // 独立订单号
+ goodsOrder.setUid(user.getId());
+ goodsOrder.setProductId(productId);
+ goodsOrder.setName(userAddress.getName());
+ goodsOrder.setPhone(userAddress.getPhone());
+ goodsOrder.setAddress(userAddress.getAddressName());
+ goodsOrder.setNum(num);
+ goodsOrder.setTotalPrice(itemPrice);
+ goodsOrder.setGoodPrice(serviceGoods.getPrice());
+ goodsOrder.setPayPrice(itemPrice);
+ goodsOrder.setDeduction(new BigDecimal(0));
+ goodsOrder.setStatus(1L); // 待支付状态
+ goodsOrder.setAddressId(addressId);
+ goodsOrder.setSku(sku);
- // 验证必要参数
- if (orderParams.get("product_id") == null || orderParams.get("address_id") == null) {
- return error("商品ID或地址ID不能为空");
+ // 保存商品订单
+ int insertResult = goodsOrderService.insertGoodsOrder(goodsOrder);
+ if (insertResult <= 0) {
+ return error("商品订单创建失败，请稍后重试");
}
- Long productId = Long.valueOf(orderParams.get("product_id").toString());
- Long addressId = Long.valueOf(orderParams.get("address_id").toString());
- Long num = orderParams.get("num") != null ? Long.valueOf(orderParams.get("num").toString()) : 1L;
+ // 添加到订单列表
+ Map orderInfo = new HashMap<>();
+ orderInfo.put("type", "goods");
+ orderInfo.put("orderId", goodsOrder.getId());
+ orderInfo.put("orderNo", goodsOrder.getOrderId());
+ orderInfo.put("productName", serviceGoods.getTitle());
+ orderInfo.put("price", itemPrice.toString());
+ orderList.add(orderInfo);
- // 处理SKU参数
- String sku = AppletControllerUtil.processSkuParam(orderParams.get("sku"));
+ } else {
+ // 创建服务订单
+ String makeTime = orderParams.get("make_time") != null ? orderParams.get("make_time").toString() : "";
- // 查询商品信息
- ServiceGoods serviceGoods = serviceGoodsService.selectServiceGoodsById(productId);
- if (serviceGoods == null) {
- return error("商品ID " + productId + " 不存在");
- }
+ Order order = new Order();
+ order.setType(1); // 1:服务项目
+ order.setCreateType(1); // 1：用户自主下单
+ order.setUid(user.getId());
+ order.setUname(user.getName());
+ order.setProductId(productId);
+ order.setProductName(serviceGoods.getTitle());
+ order.setName(userAddress.getName());
+ order.setPhone(userAddress.getPhone());
+ order.setAddress(userAddress.getAddressInfo());
+ order.setAddressId(addressId);
+ order.setSku(sku);
+ order.setMainOrderId(mainOrderId);
+ order.setOrderId(GenerateCustomCode.generCreateOrder("B")); // 独立订单号
- // 查询地址信息（只需要查询一次，假设所有订单使用相同地址）
- UserAddress userAddress = userAddressService.selectUserAddressById(addressId);
- if (userAddress == null) {
- return error("地址不存在");
- }
-
- // 计算单个订单金额
- BigDecimal itemPrice = serviceGoods.getPrice().multiply(BigDecimal.valueOf(num));
- totalAmount = totalAmount.add(itemPrice);
-
- // 判断商品类型并创建相应订单
- if (serviceGoods.getType() == 2) {
- // 创建商品订单
- GoodsOrder goodsOrder = new GoodsOrder();
- goodsOrder.setType(2);
- goodsOrder.setMainOrderId(mainOrderId);
- goodsOrder.setOrderId(GenerateCustomCode.generCreateOrder("B")); // 独立订单号
- goodsOrder.setUid(user.getId());
- goodsOrder.setProductId(productId);
- goodsOrder.setName(userAddress.getName());
- goodsOrder.setPhone(userAddress.getPhone());
- goodsOrder.setAddress(userAddress.getAddressName());
- goodsOrder.setNum(num);
- goodsOrder.setTotalPrice(itemPrice);
- goodsOrder.setGoodPrice(serviceGoods.getPrice());
- goodsOrder.setPayPrice(itemPrice);
- goodsOrder.setDeduction(new BigDecimal(0));
- goodsOrder.setStatus(1L); // 待支付状态
- goodsOrder.setAddressId(addressId);
- goodsOrder.setSku(sku);
-
- // 保存商品订单
- int insertResult = goodsOrderService.insertGoodsOrder(goodsOrder);
- if (insertResult <= 0) {
- return error("商品订单创建失败，请稍后重试");
- }
-
- // 添加到订单列表
- Map orderInfo = new HashMap<>();
- orderInfo.put("type", "goods");
- orderInfo.put("orderId", goodsOrder.getId());
- orderInfo.put("orderNo", goodsOrder.getOrderId());
- orderInfo.put("productName", serviceGoods.getTitle());
- orderInfo.put("price", itemPrice.toString());
- orderList.add(orderInfo);
-
- } else {
- // 创建服务订单
- String makeTime = orderParams.get("make_time") != null ? orderParams.get("make_time").toString() : "";
-
- Order order = new Order();
- order.setType(1); // 1:服务项目
- order.setCreateType(1); // 1：用户自主下单
- order.setUid(user.getId());
- order.setUname(user.getName());
- order.setProductId(productId);
- order.setProductName(serviceGoods.getTitle());
- order.setName(userAddress.getName());
- order.setPhone(userAddress.getPhone());
- order.setAddress(userAddress.getAddressInfo());
- order.setAddressId(addressId);
- order.setSku(sku);
- order.setMainOrderId(mainOrderId);
- order.setOrderId(GenerateCustomCode.generCreateOrder("B")); // 独立订单号
-
- // 处理预约时间
- if (makeTime != null && !makeTime.isEmpty()) {
- String[] makeTimeArr = makeTime.split(" ");
- if (makeTimeArr.length == 2) {
- try {
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
- Date date = sdf.parse(makeTimeArr[0]);
- order.setMakeTime(date.getTime() / 1000);
- order.setMakeHour(makeTimeArr[1]);
- } catch (Exception e) {
- logger.warn("预约时间格式错误: " + makeTime);
- }
+ // 处理预约时间
+ if (makeTime != null && !makeTime.isEmpty()) {
+ String[] makeTimeArr = makeTime.split(" ");
+ if (makeTimeArr.length == 2) {
+ try {
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+ Date date = sdf.parse(makeTimeArr[0]);
+ order.setMakeTime(date.getTime() / 1000);
+ order.setMakeHour(makeTimeArr[1]);
+ } catch (Exception e) {
+ logger.warn("预约时间格式错误: " + makeTime);
}
}
-
- order.setNum(num);
- order.setTotalPrice(itemPrice);
- order.setGoodPrice(serviceGoods.getPrice());
- order.setServicePrice(BigDecimal.ZERO);
- order.setPayPrice(itemPrice);
- order.setStatus(1L); // 1:待接单
- order.setReceiveType(1L); // 1：自由抢单
- order.setIsAccept(0);
- order.setIsComment(0);
- order.setIsPause(1);
- order.setDeduction(new BigDecimal(0));
-
- // 保存服务订单
- int result = orderService.insertOrder(order);
- if (result <= 0) {
- return error("服务订单创建失败，请稍后重试");
- }
-
- // 添加订单日志
- OrderLog orderLog = new OrderLog();
- orderLog.setOid(order.getId());
- orderLog.setOrderId(order.getOrderId());
- orderLog.setTitle("订单生成");
- JSONObject jsonObject = new JSONObject();
- jsonObject.put("name", "预约成功，将尽快为主人派单");
- orderLog.setType(new BigDecimal(1.0));
- orderLog.setContent(jsonObject.toString());
- orderLogService.insertOrderLog(orderLog);
-
- // 系统派单和消息通知逻辑
- Order orderNewData = orderService.selectOrderById(order.getId());
- String wxsendmsg = WXsendMsgUtil.sendMsgForUserInfo(user.getOpenid(), orderNewData, serviceGoods);
- Users worker = AppletControllerUtil.creatWorkerForOrder(orderNewData);
-
- if (worker != null) {
- // 更新订单状态为已派单
- orderNewData.setWorkerId(worker.getId());
- orderNewData.setStatus(2l);
- orderNewData.setIsPause(1);
- orderNewData.setReceiveTime(new Date());
- orderNewData.setReceiveType(3l);
- orderNewData.setLogStatus(9);
- JSONObject jSONObject = new JSONObject();
- jSONObject.put("type", 9);
- orderNewData.setLogJson(jSONObject.toJSONString());
- orderService.updateOrder(orderNewData);
-
- // 添加派单日志
- OrderLog orderLognew = new OrderLog();
- orderLognew.setOid(orderNewData.getId());
- orderLognew.setOrderId(orderNewData.getOrderId());
- orderLognew.setTitle("平台派单");
- orderLognew.setType(new BigDecimal(1.1));
- JSONObject jSONObject1 = new JSONObject();
- jSONObject1.put("name", "师傅收到派单信息");
- orderLognew.setContent(jSONObject1.toJSONString());
- orderLognew.setWorkerId(worker.getId());
- orderLognew.setWorkerLogId(worker.getId());
- orderLogService.insertOrderLog(orderLognew);
-
- // 发送通知
- WXsendMsgUtil.sendMsgForWorkerInfo(worker.getOpenid(), orderNewData, serviceGoods);
- YunXinPhoneUtilAPI.httpsAxbTransfer(worker.getPhone());
- }
-
- // 添加到订单列表
- Map orderInfo = new HashMap<>();
- orderInfo.put("type", "service");
- orderInfo.put("orderId", order.getId());
- orderInfo.put("orderNo", order.getOrderId());
- orderInfo.put("productName", serviceGoods.getTitle());
- orderInfo.put("price", itemPrice.toString());
- orderList.add(orderInfo);
}
+
+ order.setNum(num);
+ order.setTotalPrice(itemPrice);
+ order.setGoodPrice(serviceGoods.getPrice());
+ order.setServicePrice(BigDecimal.ZERO);
+ order.setPayPrice(itemPrice);
+ order.setStatus(1L); // 1:待接单
+ order.setReceiveType(1L); // 1：自由抢单
+ order.setIsAccept(0);
+ order.setIsComment(0);
+ order.setIsPause(1);
+ order.setDeduction(new BigDecimal(0));
+
+ // 保存服务订单
+ int result = orderService.insertOrder(order);
+ if (result <= 0) {
+ return error("服务订单创建失败，请稍后重试");
+ }
+
+ // 添加订单日志
+ OrderLog orderLog = new OrderLog();
+ orderLog.setOid(order.getId());
+ orderLog.setOrderId(order.getOrderId());
+ orderLog.setTitle("订单生成");
+ JSONObject jsonObject = new JSONObject();
+ jsonObject.put("name", "预约成功，将尽快为主人派单");
+ orderLog.setType(new BigDecimal(1.0));
+ orderLog.setContent(jsonObject.toString());
+ orderLogService.insertOrderLog(orderLog);
+
+ // 系统派单和消息通知逻辑
+ Order orderNewData = orderService.selectOrderById(order.getId());
+ String wxsendmsg = WXsendMsgUtil.sendMsgForUserInfo(user.getOpenid(), orderNewData, serviceGoods);
+ Users worker = AppletControllerUtil.creatWorkerForOrder(orderNewData);
+
+ if (worker != null) {
+ // 更新订单状态为已派单
+ orderNewData.setWorkerId(worker.getId());
+ orderNewData.setStatus(2l);
+ orderNewData.setIsPause(1);
+ orderNewData.setReceiveTime(new Date());
+ orderNewData.setReceiveType(3l);
+ orderNewData.setLogStatus(9);
+ JSONObject jSONObject = new JSONObject();
+ jSONObject.put("type", 9);
+ orderNewData.setLogJson(jSONObject.toJSONString());
+ orderService.updateOrder(orderNewData);
+
+ // 添加派单日志
+ OrderLog orderLognew = new OrderLog();
+ orderLognew.setOid(orderNewData.getId());
+ orderLognew.setOrderId(orderNewData.getOrderId());
+ orderLognew.setTitle("平台派单");
+ orderLognew.setType(new BigDecimal(1.1));
+ JSONObject jSONObject1 = new JSONObject();
+ jSONObject1.put("name", "师傅收到派单信息");
+ orderLognew.setContent(jSONObject1.toJSONString());
+ orderLognew.setWorkerId(worker.getId());
+ orderLognew.setWorkerLogId(worker.getId());
+ orderLogService.insertOrderLog(orderLognew);
+
+ // 发送通知
+ WXsendMsgUtil.sendMsgForWorkerInfo(worker.getOpenid(), orderNewData, serviceGoods);
+ YunXinPhoneUtilAPI.httpsAxbTransfer(worker.getPhone());
+ }
+
+ // 添加到订单列表
+ Map orderInfo = new HashMap<>();
+ orderInfo.put("type", "service");
+ orderInfo.put("orderId", order.getId());
+ orderInfo.put("orderNo", order.getOrderId());
+ orderInfo.put("productName", serviceGoods.getTitle());
+ orderInfo.put("price", itemPrice.toString());
+ orderList.add(orderInfo);
}
+ }
- // 7. 如果有商品订单，需要发起微信支付
- boolean hasGoodsOrder = orderList.stream().anyMatch(order -> "goods".equals(order.get("type")));
+ // 7. 如果有商品订单，需要发起微信支付
+ boolean hasGoodsOrder = orderList.stream().anyMatch(order -> "goods".equals(order.get("type")));
- if (hasGoodsOrder && totalAmount.compareTo(BigDecimal.ZERO) > 0) {
- // 使用工具类简化微信支付参数组装
- Map payResult = wechatPayUtil.createBatchOrderAndPay(user.getOpenid(), mainOrderId, new BigDecimal(0.01), orderList.size(),"https://4d983d7f.r3.cpolar.top/api/goods/pay/notify");
- //Map payResult = wechatPayUtil.createBatchOrderAndPay(user.getOpenid(), mainOrderId, totalAmount, orderList.size());
- if (payResult != null && Boolean.TRUE.equals(payResult.get("success"))) {
- Map responseData = new HashMap<>();
- responseData.put("mainOrderId", mainOrderId);
- responseData.put("orderList", orderList);
- responseData.put("totalAmount", totalAmount.toString());
- responseData.put("prepayId", payResult.get("prepayId"));
- // 直接合并所有支付参数
- responseData.putAll(payResult);
- return AppletControllerUtil.appletSuccess(responseData);
- } else {
- String errorMsg = payResult != null ? (String) payResult.get("message") : "微信支付下单失败";
- return error("支付下单失败：" + errorMsg);
- }
- } else {
- // 没有商品订单，只有服务订单，直接返回成功
+ if (hasGoodsOrder && totalAmount.compareTo(BigDecimal.ZERO) > 0) {
+ // 使用工具类简化微信支付参数组装
+ Map payResult = wechatPayUtil.createBatchOrderAndPay(user.getOpenid(), mainOrderId, new BigDecimal(0.01), orderList.size(), "https://2d684c7a.r5.cpolar.xyz/api/goods/pay/notify");
+ //Map payResult = wechatPayUtil.createBatchOrderAndPay(user.getOpenid(), mainOrderId, totalAmount, orderList.size());
+ if (payResult != null && Boolean.TRUE.equals(payResult.get("success"))) {
Map responseData = new HashMap<>();
responseData.put("mainOrderId", mainOrderId);
responseData.put("orderList", orderList);
responseData.put("totalAmount", totalAmount.toString());
+ responseData.put("prepayId", payResult.get("prepayId"));
+ // 直接合并所有支付参数
+ responseData.putAll(payResult);
return AppletControllerUtil.appletSuccess(responseData);
+ } else {
+ String errorMsg = payResult != null ? (String) payResult.get("message") : "微信支付下单失败";
+ return error("支付下单失败：" + errorMsg);
}
+ } else {
+ // 没有商品订单，只有服务订单，直接返回成功
+ Map responseData = new HashMap<>();
+ responseData.put("mainOrderId", mainOrderId);
+ responseData.put("orderList", orderList);
+ responseData.put("totalAmount", totalAmount.toString());
+ return AppletControllerUtil.appletSuccess(responseData);
+ }
- } catch (Exception e) {
- logger.error("创建订单异常：", e);
- return error("创建订单失败：" + e.getMessage());
+ } catch (Exception e) {
+ logger.error("创建订单异常：", e);
+ return error("创建订单失败：" + e.getMessage());
+ }
+}
+
+/**
+ * 尾款结算
+ */
+@PostMapping("api/service/order/pay/total/price")
+public AjaxResult apiServiceOrderPayTotalPprice(@RequestBody Map params, HttpServletRequest request) {
+ // 1. 验证用户登录状态
+ String token = request.getHeader("token");
+ Map