com.github.pagehelper
diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/controller/AppletController.java b/ruoyi-system/src/main/java/com/ruoyi/system/controller/AppletController.java
index eb2f58f..b243f6c 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/system/controller/AppletController.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/system/controller/AppletController.java
@@ -36,15 +36,9 @@ import java.math.BigDecimal;
import org.springframework.web.bind.annotation.RequestBody;
import com.ruoyi.system.config.QiniuConfig;
import com.ruoyi.system.utils.QiniuUploadUtil;
-
-import static com.ruoyi.common.core.domain.AjaxResult.error;
-import static com.ruoyi.common.core.domain.AjaxResult.success;
-import static com.ruoyi.common.utils.PageUtils.startPage;
-
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.ruoyi.system.domain.WechatTransfer;
-import com.ruoyi.common.utils.SecurityUtils;
import com.alibaba.fastjson2.JSONArray;
import com.ruoyi.system.domain.QuoteCraft;
import com.ruoyi.system.domain.QuoteType;
@@ -139,21 +133,18 @@ public class AppletController extends BaseController {
private IGoodsOrderCursorService goodsOrderCursorService;
@Autowired
private IWorkerApplyService workerApplyService;
+ @Autowired
+ private IUserMemberRechargeProgramService userMemberRechargeProgramService;
+
+ @Autowired
+ private IUserMemberRechargeLogService userMemberRechargeLogService;
+
+ @Autowired
+ private IUserMemnerConsumptionLogService userMemnerConsumptionLogService;
- /**
- * 生成订单号
- * 格式:年月日时分秒 + 4位随机数
- */
- private String generateNewOrderId() {
- SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss");
- String timeStr = sdf.format(new Date());
- int random = (int) ((Math.random() * 9 + 1) * 1000);
- return timeStr + random;
- }
-
/**
* 获取服务分类列表
*
@@ -191,48 +182,6 @@ public class AppletController extends BaseController {
}
-// /**
-// * 获取服务分类列表
-// *
-// * @param request HTTP请求对象
-// * @return 分类列表数据
-// *
-// * 接口说明:
-// * - 获取状态为启用的服务分类
-// * - 自动添加图片CDN前缀
-// * - 支持用户登录状态验证
-// */
-// @GetMapping(value = "/api/form/apply/worker")
-// public AjaxResult applyworker(@RequestBody Map params, HttpServletRequest request) {
-// try {
-//
-// // 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("用户信息获取失败");
-// }
-//
-//
-//
-// return AppletControllerUtil.appletSuccess("");
-// } catch (Exception e) {
-// return AppletControllerUtil.appletError("获取服务分类列表失败:" + e.getMessage());
-// }
-// }
-
-
-
-
-
-
-
/**
* 获取系统配置信息
*
@@ -1106,39 +1055,7 @@ public class AppletController extends BaseController {
}
}
-// /**
-// * 获取服务商品详细信息
-// *
-// * @param id 商品ID
-// * @param request HTTP请求对象
-// * @return 商品详细信息
-// *
-// * 接口说明:
-// * - 根据商品ID获取详细信息
-// * - 返回格式化的商品数据
-// * - 包含图片、基础信息等数组数据
-// */
-// @GetMapping(value = "/api/service/info/id/{id}")
-// public AjaxResult serviceGoodsQuery(@PathVariable("id") long id, HttpServletRequest request) {
-// try {
-// // 参数验证
-// if (id <= 0) {
-// return AppletControllerUtil.appletWarning("商品ID无效");
-// }
-//
-// // 查询商品信息
-// ServiceGoods serviceGoodsData = serviceGoodsService.selectServiceGoodsById(id);
-// if (serviceGoodsData != null) {
-// // 使用工具类转换数据格式
-// AppletControllerUtil.ServiceGoodsResponse response = new AppletControllerUtil.ServiceGoodsResponse(serviceGoodsData);
-// return AppletControllerUtil.appletSuccess(response);
-// } else {
-// return AppletControllerUtil.appletWarning("商品不存在或已下架");
-// }
-// } catch (Exception e) {
-// return AppletControllerUtil.appletWarning("查询商品详情失败:" + e.getMessage());
-// }
-// }
+
/**
* 获取服务商品详细信息
@@ -1384,31 +1301,7 @@ public class AppletController extends BaseController {
}
}
-//
-// @GetMapping(value = "/api/user/info")
-// public AjaxResult getUserByPhone(HttpServletRequest request) {
-// String token = request.getHeader("token");
-// Map order_num = new HashMap<>();
-// Map goods_order_num = new HashMap<>();
-// Users users = usersService.selectUsersByRememberToken(token);
-// if (users != null) {
-// users.setRemember_token(users.getRememberToken());
-// order_num.put("pending_accept", 2);
-// order_num.put("pending_service", 0);
-// order_num.put("in_service", 0);
-// order_num.put("other_status", 0);
-// users.setOrder_num(order_num);
-// goods_order_num.put("pending_accept", 0);
-// goods_order_num.put("pending_service", 3);
-// goods_order_num.put("in_service", 0);
-// goods_order_num.put("other_status", 0);
-// users.setGoods_order_num(goods_order_num);
-// return AppletControllerUtil.appletSuccess(users);
-// } else {
-// return AppletControllerUtil.appletError("查询用户信息失败:");
-// }
-//
-// }
+
/**
* 构建用户信息响应数据
@@ -1442,7 +1335,12 @@ public class AppletController extends BaseController {
userInfo.put("total_comm", user.getTotalComm().toString() != null ? user.getTotalComm().toString() : "0.00");
userInfo.put("propose", user.getPropose().toString() != null ? user.getPropose().toString() : "0.00");
}
-
+ if (user.getType().equals("1")) {
+ userInfo.put("balance", user.getBalance().toString() != null ? user.getBalance().toString() : "0.00");
+ userInfo.put("ismember", user.getIsmember());
+ userInfo.put("member_begin",user.getMemberBegin() != null ? sdf.format(user.getMemberBegin()) : null );
+ userInfo.put("member_end",user.getMemberEnd() != null ? sdf.format(user.getMemberEnd()) : null );
+ }
userInfo.put("integral", user.getIntegral() != null ? user.getIntegral() : 0);
userInfo.put("is_stop", user.getIsStop() != null ? user.getIsStop() : 1);
@@ -1832,44 +1730,7 @@ public class AppletController extends BaseController {
}
- /**
- * 获取服务商品详细信息
- *
- * @param params 商品ID
- * @param request HTTP请求对象
- * @return 商品详细信息
- *
- * 接口说明:
- * - 根据商品ID获取详细信息
- * - 返回格式化的商品数据
- * - 包含图片、基础信息等数组数据
- */
- /**
- * 手机号登录接口(未完整实现)
- *
- * @param params 包含code和phone参数
- * @param request HTTP请求对象
- * @return 登录结果
- *
- * 功能说明:
- * - 预留的手机号登录接口
- * - 当前实现不完整,需要补充验证逻辑
- * - 用于处理手机号码验证登录
- */
-// @GetMapping(value = "/user/phone/login")
-// public AjaxResult getUserByPhone(@RequestBody Map params, HttpServletRequest request) {
-// String code = (String) params.get("code");
-// String usercode = (String) params.get("phone");
-//
-// if (code == null) {
-//
-// }
-// if (usercode == null) {
-//
-// }
-// return AppletControllerUtil.appletSuccess();
-//
-// }
+
/**
@@ -2089,46 +1950,7 @@ public class AppletController extends BaseController {
}
}
- /**
- * 企业付款接口(用于代付等场景)
- *
- * @param params 付款参数
- * @param request HTTP请求对象
- * @return 付款结果
- *
- * 请求参数格式:
- * {
- * "partnerTradeNo": "商户订单号",
- * "openid": "用户openid",
- * "amount": 付款金额(分),
- * "desc": "付款描述"
- * }
- */
- @PostMapping(value = "/api/pay/transfer")
- public AjaxResult transferToUser(@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.appletWarning("用户未登录或token无效");
- }
- WechatPayUtil wechatPayUtil = new WechatPayUtil();
- // 2. 企业付款
- Map transferResult = wechatPayUtil.transferToUser(params);
- // 3. 返回结果
- boolean success = (Boolean) transferResult.get("success");
- if (success) {
- return AppletControllerUtil.appletSuccess(transferResult);
- } else {
- return AppletControllerUtil.appletWarning((String) transferResult.get("message"));
- }
-
- } catch (Exception e) {
- return AppletControllerUtil.appletWarning("企业付款失败:" + e.getMessage());
- }
- }
/**
@@ -2515,127 +2337,7 @@ public class AppletController extends BaseController {
}
}
-// ... existing code ...
-// /**
-// * 查询用户优惠券列表
-// *
-// * @param params 请求参数,包含status(优惠券状态)、product_id(指定商品ID)、price(最低价格)
-// * @param request HTTP请求对象
-// * @return 返回用户优惠券列表
-// */
-// @PostMapping("/api/coupon/my/lst")
-// public AjaxResult getMyCouponList(@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.appletWarning("用户未登录或token无效");
-// }
-// // 2. 获取用户信息
-// Users user = (Users) userValidation.get("user");
-// if (user == null) {
-// return AppletControllerUtil.appletWarning("用户信息获取失败");
-// }
-
-// // 3. 解析查询参数
-// Long status = parseParamToLong(params.get("status"), "状态参数格式错误");
-// Long productId = parseParamToLong(params.get("product_id"), "商品ID参数格式错误");
-// Integer price = parseParamToInteger(params.get("price"), "价格参数格式错误");
-
-// // 4. 查询用户的所有优惠券
-// CouponUser couponUserQuery = new CouponUser();
-// couponUserQuery.setUid(user.getId());
-// List couponUserList = couponUserService.selectCouponUserList(couponUserQuery);
-
-// // 5. 根据状态筛选优惠券
-// long currentTime = System.currentTimeMillis() / 1000; // 当前时间戳(秒)
-// List filteredList = new ArrayList<>();
-
-// if (status == null) {
-// // 如果未指定状态,返回所有优惠券
-// filteredList = couponUserList;
-// } else if (status == 1L) {
-// // 未使用的优惠券
-// for (CouponUser coupon : couponUserList) {
-// if (coupon.getStatus() != 2L && !isExpired(coupon, currentTime)) {
-// filteredList.add(coupon);
-// }
-// }
-// } else if (status == 2L) {
-// // 已使用的优惠券
-// for (CouponUser coupon : couponUserList) {
-// if (coupon.getStatus() != null && coupon.getStatus() == 2L) {
-// filteredList.add(coupon);
-// }
-// }
-// } else if (status == 3L) {
-// // 已过期的优惠券
-// for (CouponUser coupon : couponUserList) {
-// if (isExpired(coupon, currentTime)) {
-// filteredList.add(coupon);
-// }
-// }
-// } else if (status == 4L) {
-// // 待领取的优惠券 - 只返回手动领取(type=2)且剩余数量大于0的优惠券
-// Coupons couponsQuery = new Coupons();
-// couponsQuery.setStatus(1L); // 启用状态
-// couponsQuery.setType(2L); // 手动领取类型
-// List availableCoupons = couponsService.selectCouponsList(couponsQuery);
-
-// for (Coupons coupon : availableCoupons) {
-// // 检查剩余数量大于0且用户可领取
-// if (coupon.getCount() != null && coupon.getCount() > 0 &&
-// isCouponAvailableToReceive(coupon, user.getId(), currentTime)) {
-// // 创建一个临时的CouponUser对象,包含完整的优惠券信息
-// CouponUser tempCouponUser = new CouponUser();
-// tempCouponUser.setCouponId(coupon.getId());
-// tempCouponUser.setUid(user.getId());
-// tempCouponUser.setStatus(0L); // 待领取状态
-// tempCouponUser.setCouponTitle(coupon.getTitle());
-// tempCouponUser.setCouponPrice(coupon.getPrice() != null ? coupon.getPrice().intValue() : 0);
-// tempCouponUser.setMinPrice(coupon.getMinPrice() != null ? coupon.getMinPrice().longValue() : 0L);
-// tempCouponUser.setCateId(coupon.getCateId());
-// tempCouponUser.setProductId(coupon.getProductId());
-// tempCouponUser.setReceiveType(coupon.getReceiveType() != null ? coupon.getReceiveType().toString() : "1");
-
-// // 设置有效期
-// if (coupon.getCouponTime() != null) {
-// // 如果有固定的有效期天数,计算失效时间
-// long loseTime = currentTime + (coupon.getCouponTime() * 24 * 60 * 60);
-// tempCouponUser.setLoseTime(String.valueOf(loseTime));
-// } else if (coupon.getEndTime() != null) {
-// // 如果有结束时间,使用结束时间作为失效时间
-// tempCouponUser.setLoseTime(String.valueOf(coupon.getEndTime()));
-// }
-
-// filteredList.add(tempCouponUser);
-// }
-// }
-// }
-
-// // 6. 商品ID筛选
-// if (productId != null) {
-// filteredList = filteredList.stream()
-// .filter(coupon -> productId.equals(coupon.getProductId()))
-// .collect(Collectors.toList());
-// }
-
-// // 7. 价格筛选
-// List priceFilteredList = AppletControllerUtil.filterCouponsByPrice(filteredList, price);
-
-// // 8. 使用工具类处理数据格式化
-// List