package cc.mrbird.febs.mall.service.impl; import cc.mrbird.febs.common.entity.FebsResponse; import cc.mrbird.febs.common.enumerates.*; import cc.mrbird.febs.common.exception.FebsException; import cc.mrbird.febs.common.utils.LoginUserUtil; import cc.mrbird.febs.common.utils.MallUtils; import cc.mrbird.febs.common.utils.ShareCodeUtil; import cc.mrbird.febs.mall.dto.*; import cc.mrbird.febs.mall.dto.activity.*; import cc.mrbird.febs.mall.entity.*; import cc.mrbird.febs.mall.mapper.*; import cc.mrbird.febs.mall.service.HappyActivityService; import cc.mrbird.febs.mall.service.IApiMallMemberWalletService; import cc.mrbird.febs.mall.vo.*; import cc.mrbird.febs.mall.dto.ApiOperateDoDto; import cc.mrbird.febs.mall.vo.activity.*; import cc.mrbird.febs.pay.model.BrandWCPayRequestData; import cc.mrbird.febs.pay.service.IXcxPayService; import cc.mrbird.febs.rabbit.producter.AgentProducer; import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.DateTime; import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.crypto.SecureUtil; import cn.hutool.json.JSONUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.math.BigDecimal; import java.math.RoundingMode; import java.util.*; import java.util.function.Function; import java.util.stream.Collectors; @Slf4j @Service @RequiredArgsConstructor @Transactional public class HappyActivityServiceImpl extends ServiceImpl implements HappyActivityService { private final HappyFollowMapper happyFollowMapper; private final MallMemberMapper mallMemberMapper; private final HappyActivityOptionMapper happyActivityOptionMapper; private final HappyActivityConnectMapper happyActivityConnectMapper; private final HappyActivityOrderMapper happyActivityOrderMapper; private final HappyActivityCommentMapper happyActivityCommentMapper; private final HappyActivityOrderItemMapper happyActivityOrderItemMapper; private final IXcxPayService iXcxPayService; private final IApiMallMemberWalletService iApiMallMemberWalletService; private final HappyActivityCategoryMapper happyActivityCategoryMapper; private final AgentProducer agentProducer; @Override public FebsResponse activityList(ApiActivityInfoDto dto) { // 创建分页对象，传入当前页和每页大小 Page page = new Page<>(dto.getPageNow(), dto.getPageSize()); // 调用Mapper方法获取活动分页数据 Page happyActivityPage = this.baseMapper.selectActivityPage(page, dto); // 检查分页结果是否包含数据 if(CollUtil.isNotEmpty(happyActivityPage.getRecords())){ List records = happyActivityPage.getRecords(); // 遍历活动记录，为每个活动添加成员头像信息 records.forEach(record -> { // 查询关注点赞转发记录，筛选出关注活动类型且未删除的关注记录，并按ID升序排序，限制结果数量为3 List happyFollows = happyFollowMapper.selectList( new LambdaQueryWrapper() .eq(HappyFollow::getSourceType, StateUpDownEnum.SOURCE_TYPE_ACTIVITY.getCode()) .eq(HappyFollow::getSourceId, record.getId()) .eq(HappyFollow::getDeleteFlag, StateUpDownEnum.DOWN.getCode()) .groupBy(HappyFollow::getMemberId) .orderByAsc(HappyFollow::getId) .last("limit 3") ); // 检查关注记录是否不为空 if(CollUtil.isNotEmpty(happyFollows)){ // 使用Stream流操作关注记录，获取所有成员ID的集合 Set memberIds = happyFollows.stream().collect(Collectors.mapping(HappyFollow::getMemberId, Collectors.toSet())); // 查询成员信息，获取成员的ID和头像 List mallMembers = mallMemberMapper.selectList( new LambdaQueryWrapper() .select(MallMember::getAvatar) .in(MallMember::getId, memberIds) ); List memberAvatars = mallMembers.stream().map(MallMember::getAvatar).collect(Collectors.toList()); record.setMemberAvatars(memberAvatars); } }); } // 返回成功响应，包含活动分页数据 return new FebsResponse().success().data(happyActivityPage); } @Override public FebsResponse activityInfo(ApiActivityDto dto) { ApiActivityVo apiActivityVo = new ApiActivityVo(); HappyActivity happyActivity = this.baseMapper.selectOne( new LambdaQueryWrapper() .eq(HappyActivity::getId, dto.getId()) .eq(HappyActivity::getDeleteFlag, StateUpDownEnum.DOWN.getCode()) .ne(HappyActivity::getState, StateUpDownEnum.ACTIVITY_STATE_NOT_START.getCode()) ); if(happyActivity != null){ BeanUtil.copyProperties(happyActivity,apiActivityVo); Integer commentCount = happyActivityCommentMapper.selectCount( new LambdaQueryWrapper() .eq(HappyActivityComment::getActivityId, happyActivity.getId()) .eq(HappyActivityComment::getShowState, StateUpDownEnum.UP.getCode()) ); apiActivityVo.setCommentCount(commentCount); List happyFollows = happyFollowMapper.selectList( new LambdaQueryWrapper() .select(HappyFollow::getId, HappyFollow::getType) .eq(HappyFollow::getSourceType, StateUpDownEnum.SOURCE_TYPE_ACTIVITY.getCode()) .eq(HappyFollow::getSourceId, happyActivity.getId()) .in(HappyFollow::getType, Arrays.asList(StateUpDownEnum.LIKE.getCode(), StateUpDownEnum.SHARE.getCode())) .eq(HappyFollow::getDeleteFlag, StateUpDownEnum.DOWN.getCode()) ); if(CollUtil.isNotEmpty(happyFollows)){ // 使用Stream流操作happyFollows，按照type分类，返回每一个不同type的总数量，并返回一个Map Map typeCountMap = happyFollows.stream() .collect(Collectors.groupingBy(HappyFollow::getType, Collectors.counting())); Long zanCnt = ObjectUtil.defaultIfNull(typeCountMap.get(StateUpDownEnum.LIKE.getCode()), 0L); apiActivityVo.setZanCnt(Math.toIntExact(zanCnt)); Long sendCnt = ObjectUtil.defaultIfNull(typeCountMap.get(StateUpDownEnum.SHARE.getCode()), 0L); apiActivityVo.setSendCnt(Math.toIntExact(sendCnt)); } } return new FebsResponse().success().data(apiActivityVo); } @Override public FebsResponse voteOptionInPage(ApiVoteOptionInPageDto dto) { // 创建分页对象，传入当前页和每页大小 Page page = new Page<>(dto.getPageNow(), dto.getPageSize()); Page voteRecordInPage = this.baseMapper.getVoteOptionInPage(page, dto); return new FebsResponse().success().data(voteRecordInPage); } @Override public FebsResponse voteOptionRecordInPage(ApiVoteOptionRecordInPageDto dto) { // 创建分页对象，传入当前页和每页大小 Page page = new Page<>(dto.getPageNow(), dto.getPageSize()); Page voteRecordInPage = this.baseMapper.getVoteOptionRecordInPage(page, dto); return new FebsResponse().success().data(voteRecordInPage); } @Override public FebsResponse voteOption(Long id) { ApiActivityOptionVo apiActivityOptionVo = new ApiActivityOptionVo(); HappyActivityOption happyActivityOption = happyActivityOptionMapper.selectById(id); if(happyActivityOption != null){ BeanUtil.copyProperties(happyActivityOption, apiActivityOptionVo); } //投票人数 List happyFollows = happyFollowMapper.selectList( new LambdaQueryWrapper() .select(HappyFollow::getId) .eq(HappyFollow::getSourceOptionId, id) .eq(HappyFollow::getType, StateUpDownEnum.VOTE.getCode()) .eq(HappyFollow::getDeleteFlag, StateUpDownEnum.DOWN.getCode()) .groupBy(HappyFollow::getMemberId) ); apiActivityOptionVo.setVoteCnt(CollUtil.isNotEmpty(happyFollows) ? happyFollows.size() : 0); List happyActivityOptions = happyActivityOptionMapper.selectList( new LambdaQueryWrapper() .select(HappyActivityOption::getId,HappyActivityOption::getLikesCnt) .eq(HappyActivityOption::getActivityId, happyActivityOption.getActivityId()) .eq(HappyActivityOption::getDeleteFlag, StateUpDownEnum.DOWN.getCode()) .eq(HappyActivityOption::getState, StateUpDownEnum.VOTE_OPTION_STATE_AUDIT_SUCCESS.getCode()) .orderByDesc(HappyActivityOption::getLikesCnt) ); //获取上一个名次的数据 int firstCnt = 1; int distanceCnt = 0; for (HappyActivityOption option : happyActivityOptions){ if(option.getId().equals(id)){ apiActivityOptionVo.setFirstCnt(firstCnt); if( firstCnt == 1 ){ apiActivityOptionVo.setDistanceCnt(distanceCnt); }else{ apiActivityOptionVo.setDistanceCnt(distanceCnt- option.getLikesCnt()); } break; }else{ firstCnt = firstCnt + 1; distanceCnt = option.getLikesCnt(); } } return new FebsResponse().success().data(apiActivityOptionVo); } @Override public FebsResponse operateDo(ApiOperateDoDto dto) { Long memberId = LoginUserUtil.getLoginUser().getId(); Integer sourceType = dto.getSourceType(); Long sourceId = dto.getSourceId(); Integer type = dto.getType(); try { if (StateUpDownEnum.SOURCE_TYPE_ACTIVITY.getCode() == sourceType) { // 活动点赞或关注 HappyActivity happyActivity = this.baseMapper.selectById(sourceId); if (happyActivity == null) { throw new FebsException("活动不存在"); } this.operateDo(memberId, StateUpDownEnum.SOURCE_TYPE_ACTIVITY.getCode(), sourceId, type); // if (StateUpDownEnum.ACTIVITY_TYPE_VOTE.getCode() == happyActivity.getType()) { // Long sourceOptionId = dto.getSourceOptionId(); // if (sourceOptionId == null) { // throw new FebsException("选项ID不能为空"); // } // this.operateDoVote(memberId, StateUpDownEnum.SOURCE_TYPE_ACTIVITY.getCode(), sourceId, sourceOptionId, type); // this.addLikeCnt(sourceOptionId); // } else { // this.operateDo(memberId, StateUpDownEnum.SOURCE_TYPE_ACTIVITY.getCode(), sourceId, type); // } } else if (StateUpDownEnum.SOURCE_TYPE_SOCIAL_CIRCLE.getCode() == sourceType) { // 朋友圈点赞或关注 this.operateDo(memberId, StateUpDownEnum.SOURCE_TYPE_SOCIAL_CIRCLE.getCode(), sourceId, type); } else { throw new FebsException("不支持的操作类型"); } } catch (Exception e) { // 捕获异常并返回错误信息 log.error("操作失败：{}", e.getMessage()); throw new FebsException("操作失败"); } return new FebsResponse().success(); } @Override public void operateDoVote(Long memberId, int code, Long sourceId, Long sourceOptionId, Integer type) { HappyFollow happyFollow = new HappyFollow(); happyFollow.setMemberId(memberId); happyFollow.setSourceType(code); happyFollow.setSourceId(sourceId); happyFollow.setSourceOptionId(sourceOptionId); happyFollow.setType(type); happyFollowMapper.insert(happyFollow); } @Override public void operateDo(Long memberId, int code, Long sourceId, Integer type) { HappyFollow happyFollow = new HappyFollow(); happyFollow.setMemberId(memberId); happyFollow.setSourceType(code); happyFollow.setSourceId(sourceId); happyFollow.setType(type); happyFollowMapper.insert(happyFollow); } @Override public FebsResponse operateVote(ApiOperateVoteDto dto) { Long memberId = LoginUserUtil.getLoginUser().getId(); Long sourceId = dto.getSourceId(); Long sourceOptionId = dto.getSourceOptionId(); Integer sourceType = dto.getSourceType(); Integer type = StateUpDownEnum.VOTE.getCode(); HappyActivity happyActivity = this.baseMapper.selectById(sourceId); if(StateUpDownEnum.ACTIVITY_TYPE_VOTE.getCode() != happyActivity.getType()){ throw new FebsException("当前活动无法投票"); } if (StateUpDownEnum.ACTIVITY_STATE_NOT_START.getCode() == happyActivity.getState()) { throw new FebsException("活动尚未开始"); } if (StateUpDownEnum.ACTIVITY_STATE_END.getCode() == happyActivity.getState()) { throw new FebsException("活动已结束"); } HappyActivityOption happyActivityOption = happyActivityOptionMapper.selectById(sourceOptionId); if (null == happyActivityOption) { throw new FebsException("投票对象不存在"); } if (StateUpDownEnum.VOTE_OPTION_STATE_AUDIT_SUCCESS.getCode() != happyActivityOption.getState()) { throw new FebsException("请重新选择投票对象"); } //验证当前登录人员今日是否已经投票 List happyFollows = happyFollowMapper.selectList( new LambdaQueryWrapper() .eq(HappyFollow::getMemberId, memberId) .eq(HappyFollow::getSourceId, sourceId) .eq(HappyFollow::getType, type) .gt(HappyFollow::getCreatedTime, DateUtil.beginOfDay(new Date())) ); if (CollUtil.isNotEmpty(happyFollows) && happyFollows.size() >= happyActivity.getVoteCnt()){ throw new FebsException("今日已经投完票"); } this.baseMapper.updateHappyActivityOptionLikeCnt(sourceOptionId); this.operateDoVote(memberId, sourceType, sourceId, sourceOptionId, type); return new FebsResponse().success(); } @Override public FebsResponse voteRecordInPage(ApiVoteRecordInPageDto dto) { // 创建分页对象，传入当前页和每页大小 Page page = new Page<>(dto.getPageNow(), dto.getPageSize()); Page voteRecordInPage = this.baseMapper.getVoteRecordInPage(page, dto); List records = voteRecordInPage.getRecords(); if(CollUtil.isNotEmpty(records)){ //stream流操作records，获取全部的memberId(全部投票人) Set memberIds = records.stream().map(ApiVoteRecordInPageVo::getMemberId).collect(Collectors.toSet()); if(CollUtil.isNotEmpty(memberIds)){ List mallMembers = mallMemberMapper.selectList( new LambdaQueryWrapper() .select(MallMember::getId, MallMember::getName, MallMember::getAvatar) .in(MallMember::getId,memberIds) ); //stream流操作mallMembers得到一个Map的map对象 Map mallMemberMap = mallMembers.stream().collect(Collectors.toMap(MallMember::getId, mallMember -> mallMember)); records.forEach(record -> { MallMember mallMember = mallMemberMap.get(record.getMemberId()); record.setName(mallMember.getName()); record.setAvatar(mallMember.getAvatar()); }); } } return new FebsResponse().success().data(voteRecordInPage); } @Override public FebsResponse operateValidRegister(ApiOperateValidRegisterActivityDto dto) { Long memberId = LoginUserUtil.getLoginUser().getId(); HappyActivity happyActivity = this.baseMapper.selectById(dto.getActivityId()); if (StateUpDownEnum.ACTIVITY_STATE_END.getCode() == happyActivity.getState()) { throw new FebsException("活动已结束"); } if (StateUpDownEnum.DOWN.getCode() == happyActivity.getAddState()) { throw new FebsException("活动尚未开启报名"); } //判断用户是否重复报名 Integer registerCnt = happyActivityOptionMapper.selectCount( new LambdaQueryWrapper() .eq(HappyActivityOption::getMemberId, memberId) .eq(HappyActivityOption::getActivityId, dto.getActivityId()) .ne(HappyActivityOption::getState, StateUpDownEnum.VOTE_OPTION_STATE_AUDIT_REFUSE.getCode()) .eq(HappyActivityOption::getDeleteFlag, StateUpDownEnum.DOWN.getCode()) ); if (registerCnt > 0) { throw new FebsException("您已经报名过了"); } return new FebsResponse().success(); } @Override public FebsResponse operateRegister(ApiOperateRegisterActivityDto dto) { Long memberId = LoginUserUtil.getLoginUser().getId(); HappyActivity happyActivity = this.baseMapper.selectById(dto.getActivityId()); if (StateUpDownEnum.ACTIVITY_STATE_END.getCode() == happyActivity.getState()) { throw new FebsException("活动已结束"); } if (StateUpDownEnum.DOWN.getCode() == happyActivity.getAddState()) { throw new FebsException("活动尚未开启报名"); } //判断用户是否重复报名 Integer registerCnt = happyActivityOptionMapper.selectCount( new LambdaQueryWrapper() .eq(HappyActivityOption::getMemberId, memberId) .eq(HappyActivityOption::getActivityId, dto.getActivityId()) .ne(HappyActivityOption::getState, StateUpDownEnum.VOTE_OPTION_STATE_AUDIT_REFUSE.getCode()) .eq(HappyActivityOption::getDeleteFlag, StateUpDownEnum.DOWN.getCode()) ); if (registerCnt > 0) { throw new FebsException("您已经报名过了"); } Integer optionCnt = happyActivityOptionMapper.selectCount( new LambdaQueryWrapper() .eq(HappyActivityOption::getActivityId, dto.getActivityId()) .eq(HappyActivityOption::getDeleteFlag, StateUpDownEnum.DOWN.getCode()) ); HappyActivityOption happyActivityOption = new HappyActivityOption(); BeanUtil.copyProperties(dto, happyActivityOption); happyActivityOption.setOrderCnt(optionCnt + 1); happyActivityOption.setMemberId(memberId); happyActivityOption.setOptionName(dto.getRealName()); happyActivityOptionMapper.insert(happyActivityOption); return new FebsResponse().success().message("报名成功"); } @Override public FebsResponse addConnect(ApiOperateRegisterUserDto dto) { Long memberId = LoginUserUtil.getLoginUser().getId(); List happyActivityConnects = happyActivityConnectMapper.selectList( new LambdaQueryWrapper() .eq(HappyActivityConnect::getMemberId, memberId) .eq(HappyActivityConnect::getName, dto.getName()) .eq(HappyActivityConnect::getPhone, dto.getPhone()) ); if(CollUtil.isNotEmpty(happyActivityConnects)){ throw new FebsException("已经添加过该联系人"); } HappyActivityConnect happyActivityConnect = new HappyActivityConnect(); happyActivityConnect.setMemberId(memberId); happyActivityConnect.setName(dto.getName()); happyActivityConnect.setPhone(dto.getPhone()); happyActivityConnect.setAddress(dto.getAddress()); happyActivityConnectMapper.insert(happyActivityConnect); return new FebsResponse().success(); } @Override public FebsResponse connectList(ApiConnectListDto dto) { Long memberId = LoginUserUtil.getLoginUser().getId(); dto.setMemberId(memberId); // 创建分页对象，传入当前页和每页大小 Page page = new Page<>(dto.getPageNow(), dto.getPageSize()); Page voteRecordInPage = happyActivityConnectMapper.selectConnectListPage(page, dto); return new FebsResponse().success().data(voteRecordInPage); } @Override public FebsResponse connectInfo(Long id) { Long memberId = LoginUserUtil.getLoginUser().getId(); HappyActivityConnect happyActivityConnect = happyActivityConnectMapper.selectById(id); ApiConnectListInPageVo apiConnectListInPageVo = new ApiConnectListInPageVo(); BeanUtil.copyProperties(happyActivityConnect,apiConnectListInPageVo); return new FebsResponse().success().data(apiConnectListInPageVo); } @Override public FebsResponse connectDel(Long id) { Long memberId = LoginUserUtil.getLoginUser().getId(); happyActivityConnectMapper.deleteById(id); return new FebsResponse().success(); } @Override public FebsResponse connectSave(ApiConnectSaveDto dto) { Long memberId = LoginUserUtil.getLoginUser().getId(); Long id = dto.getId(); HappyActivityConnect happyActivityConnect = happyActivityConnectMapper.selectById(id); if (happyActivityConnect == null) { throw new FebsException("记录不存在"); } happyActivityConnect.setName(dto.getName()); happyActivityConnect.setPhone(dto.getPhone()); happyActivityConnect.setAddress(dto.getAddress()); happyActivityConnectMapper.updateById(happyActivityConnect); return new FebsResponse().success(); } @Override public FebsResponse expireOrder(ApiExpireOrderDto dto) { if(CollUtil.isEmpty(dto.getIds())){ throw new FebsException("请选择订单"); } dto.getIds().forEach(id -> { HappyActivityOrder happyActivityOrder = happyActivityOrderMapper.selectById(id); if(ObjectUtil.isNotEmpty(happyActivityOrder)){ Long activityId = happyActivityOrder.getActivityId(); Integer numCnt = happyActivityOrder.getNumCnt(); this.baseMapper.updateHappyActivitySurplusCnt(activityId,numCnt); happyActivityOrder.setState(StateUpDownEnum.ORDER_STATE_OVERTIME.getCode()); happyActivityOrderMapper.updateById(happyActivityOrder); } }); return new FebsResponse().success(); } @Override public FebsResponse createOrder(ApiCreateOrderDto dto) { Long memberId = LoginUserUtil.getLoginUser().getId(); if(CollUtil.isEmpty(dto.getConnectIds())){ throw new FebsException("请选择报名人"); } List connectIds = dto.getConnectIds(); Integer numCnt = dto.getNumCnt(); if(numCnt != connectIds.size()){ throw new FebsException("报名人数与票的数量不匹配"); } Long activityId = dto.getActivityId(); List happyActivityOrderItems = happyActivityOrderItemMapper.selectList( new LambdaQueryWrapper() .eq(HappyActivityOrderItem::getActivityId, activityId) .in(HappyActivityOrderItem::getConnectId, connectIds) ); if(CollUtil.isNotEmpty(happyActivityOrderItems)){ //stream流操作happyActivityOrderItems，返回一个orderId的Set集合 Set orderIdSet = happyActivityOrderItems.stream().map(HappyActivityOrderItem::getOrderId).collect(Collectors.toSet()); List happyActivityOrders = happyActivityOrderMapper.selectList( new LambdaQueryWrapper() .in(HappyActivityOrder::getId, orderIdSet) .in(HappyActivityOrder::getState, Arrays.asList(StateUpDownEnum.ORDER_STATE_WAIT_PAY.getCode(),StateUpDownEnum.ORDER_STATE_WAIT_USE.getCode())) ); if(CollUtil.isNotEmpty(happyActivityOrders)){ throw new FebsException("有报名人重复报名了活动，请重新选择"); } } HappyActivity happyActivity = this.baseMapper.selectById(activityId); if (ObjectUtil.isEmpty(happyActivity)) { throw new FebsException("活动不存在"); } if (StateUpDownEnum.ACTIVITY_STATE_NOT_START.getCode() == happyActivity.getState()) { throw new FebsException("活动尚未开始"); } if (StateUpDownEnum.ACTIVITY_STATE_END.getCode() == happyActivity.getState()) { throw new FebsException("活动已结束"); } Integer surplusCnt = happyActivity.getSurplusCnt(); if(surplusCnt < numCnt){ throw new FebsException("报名额度剩下"+surplusCnt+"，请减少报名人数"); } //支付总金额 BigDecimal amount = happyActivity.getPayAmount().multiply(new BigDecimal(dto.getNumCnt())).setScale(2, RoundingMode.DOWN); if(amount.compareTo(BigDecimal.ZERO) < 0){ throw new FebsException("支付金额错误"); } DateTime failTime = DateUtil.offsetMinute(new Date(), StateUpDownEnum.ORDER_OVERTIME.getCode()); HappyActivityOrder happyActivityOrder = new HappyActivityOrder(); happyActivityOrder.setOrderNo(MallUtils.getOrderNum()); happyActivityOrder.setMemberId(memberId); happyActivityOrder.setActivityId(dto.getActivityId()); happyActivityOrder.setPrice(happyActivity.getPayAmount()); happyActivityOrder.setNumCnt(dto.getNumCnt()); happyActivityOrder.setAmount(amount); happyActivityOrder.setPayState(StateUpDownEnum.PAY_STATE_NOT_PAY.getCode()); happyActivityOrder.setPayType(StateUpDownEnum.PAY_METHOD_WECHAT.getCode()); happyActivityOrder.setFailTime(failTime); log.info("创建订单，订单号="+JSONUtil.parse(happyActivityOrder)); happyActivityOrderMapper.insert(happyActivityOrder); for(Long connectId : connectIds){ HappyActivityConnect happyActivityConnect = happyActivityConnectMapper.selectById(connectId); HappyActivityOrderItem happyActivityOrderItem = new HappyActivityOrderItem(); happyActivityOrderItem.setMemberId(memberId); happyActivityOrderItem.setActivityId(dto.getActivityId()); happyActivityOrderItem.setOrderId(happyActivityOrder.getId()); happyActivityOrderItem.setConnectId(connectId); happyActivityOrderItem.setPrice(happyActivity.getPayAmount()); happyActivityOrderItem.setName(happyActivityConnect.getName()); happyActivityOrderItem.setPhone(happyActivityConnect.getPhone()); happyActivityOrderItem.setAddress(happyActivityConnect.getAddress()); happyActivityOrderItem.setState(StateUpDownEnum.DOWN.getCode()); happyActivityOrderItemMapper.insert(happyActivityOrderItem); } this.baseMapper.updateHappyActivitySurplusCnt(activityId, happyActivityOrder.getNumCnt() * (-1)); HashMap stringObjectHashMap = new HashMap<>(); stringObjectHashMap.put("orderId",happyActivityOrder.getId()); stringObjectHashMap.put("amount",amount); stringObjectHashMap.put("failTime",failTime); return new FebsResponse().success().data(stringObjectHashMap); } /** * 支付订单函数，根据传入的支付订单数据对象处理不同支付类型的订单支付逻辑。 * * @param dto 包含支付订单相关信息的数据传输对象，包括订单ID和支付类型等信息。 * - orderId: 订单ID，用于查询订单信息。 * - payType: 支付类型，决定支付逻辑的分支。 * - tradePwd: 交易密码（可选），用于余额或积分支付时验证。 * @return FebsResponse 返回支付结果的响应对象，包含支付状态、订单信息等数据。 * - orderInfo: 支付结果信息，可能是预支付ID或其他支付相关数据。 * - orderNo: 订单编号。 * - orderId: 订单ID。 * - wxResultStr: 微信支付相关的结果字符串（仅在微信支付时返回）。 * @throws FebsException 如果订单不存在、已支付、支付失败或支付类型不支持，则抛出异常。 */ @Override public FebsResponse payOrder(ApiPayOrderDto dto) { // 获取当前登录用户的ID Long memberId = LoginUserUtil.getLoginUser().getId(); Long orderId = dto.getOrderId(); Integer payType = dto.getPayType(); // 查询订单信息，确保订单存在且未支付 HappyActivityOrder happyActivityOrder = happyActivityOrderMapper.selectById(orderId); if (ObjectUtil.isEmpty(happyActivityOrder)) { throw new FebsException("订单不存在"); } if (happyActivityOrder.getPayState() == StateUpDownEnum.PAY_STATE_PAY_SUCCESS.getCode()) { throw new FebsException("订单已支付"); } String payResultStr = ""; String wxResultStr = ""; try { // 根据支付类型处理不同的支付逻辑 if (StateUpDownEnum.PAY_METHOD_NO_PAY.getCode() == payType) { // 处理无需支付的订单逻辑 processNoPayOrder(happyActivityOrder, orderId); } else if (StateUpDownEnum.PAY_METHOD_WECHAT.getCode() == payType) { // 处理微信支付逻辑，生成支付请求数据并更新订单状态 BrandWCPayRequestData brandWCPayRequestData = iXcxPayService.startPaymentActivity(happyActivityOrder); wxResultStr = JSONUtil.toJsonStr(brandWCPayRequestData); payResultStr = brandWCPayRequestData.getPrepay_id(); updateOrderState(happyActivityOrder, payType, StateUpDownEnum.PAY_STATE_NOT_PAY.getCode(),StateUpDownEnum.ORDER_STATE_WAIT_PAY.getCode()); } else if (StateUpDownEnum.PAY_METHOD_BALANCE.getCode() == payType || StateUpDownEnum.PAY_METHOD_INTEGRAL.getCode() == payType) { // 处理余额或积分支付逻辑，验证交易密码并完成支付 String payMethod = StateUpDownEnum.PAY_METHOD_BALANCE.getCode() == payType ? "balance" : "prizeScore"; payResultStr = balancePay(happyActivityOrder, dto.getTradePwd(), payMethod); processPaidOrder(happyActivityOrder, orderId, payType); } else { // 如果支付类型不支持，抛出异常 throw new FebsException("不支持的支付类型"); } } catch (Exception e) { // 捕获支付过程中的异常，记录日志并抛出自定义异常 log.error("支付失败，订单ID：{}，支付类型：{}", orderId, payType, e); throw new FebsException("支付失败：" + e.getMessage()); } // 构造返回结果，包含支付相关信息 Map map = new HashMap<>(); map.put("orderInfo", payResultStr); map.put("orderNo", happyActivityOrder.getOrderNo()); map.put("orderId", happyActivityOrder.getId()); map.put("wxResultStr", wxResultStr); return new FebsResponse().success().data(map).message("支付成功"); } @Override public void addLikeCnt(Long sourceOptionId) { HappyActivityOption happyActivityOption = happyActivityOptionMapper.selectById(sourceOptionId); happyActivityOption.setLikesCnt(happyActivityOption.getLikesCnt() + 1); happyActivityOptionMapper.updateById(happyActivityOption); } // 处理无需支付订单 private void processNoPayOrder(HappyActivityOrder order, Long orderId) { updateOrderState(order, StateUpDownEnum.PAY_METHOD_NO_PAY.getCode(), StateUpDownEnum.PAY_STATE_PAY_SUCCESS.getCode(),StateUpDownEnum.ORDER_STATE_WAIT_USE.getCode()); generateOrderItemCodes(orderId); } // 处理余额和积分支付的订单 private void processPaidOrder(HappyActivityOrder order, Long orderId, Integer payType) { updateOrderState(order, payType, StateUpDownEnum.PAY_STATE_PAY_SUCCESS.getCode(),StateUpDownEnum.ORDER_STATE_WAIT_USE.getCode()); generateOrderItemCodes(orderId); } // 更新订单状态 private void updateOrderState(HappyActivityOrder order, Integer payType, Integer payState, Integer state) { order.setPayState(payState); order.setPayType(payType); order.setState(state); if (payState == StateUpDownEnum.PAY_STATE_PAY_SUCCESS.getCode()) { order.setPayTime(new Date()); } happyActivityOrderMapper.updateById(order); } // 批量生成订单项编码 private void generateOrderItemCodes(Long orderId) { List items = happyActivityOrderItemMapper.selectList( new LambdaQueryWrapper() .eq(HappyActivityOrderItem::getOrderId, orderId) ); if (CollUtil.isNotEmpty(items)) { for (HappyActivityOrderItem item : items) { String code = ShareCodeUtil.toSerialCode(item.getOrderId()) + MallUtils.getRandomNum(8); item.setCode(code); happyActivityOrderItemMapper.updateById(item); } } } private String balancePay(HappyActivityOrder happyActivityOrder, String tradePwd, String field) { if (StrUtil.isBlank(tradePwd)) { throw new FebsException("支付密码错误"); } MallMember mallMember = mallMemberMapper.selectById(happyActivityOrder.getMemberId()); if (StrUtil.isBlank(mallMember.getTradePassword())) { throw new FebsException("未设置支付密码"); } if (!SecureUtil.md5(tradePwd).equals(mallMember.getTradePassword())) { throw new FebsException("支付密码错误"); } int reduce = iApiMallMemberWalletService.reduce(happyActivityOrder.getAmount(), mallMember.getId(), field); if (reduce == 2) { throw new FebsException("余额不足"); } return happyActivityOrder.getOrderNo(); } @Override public FebsResponse orderList(ApiActivityOrderListDto dto) { // 获取当前登录用户的ID Long memberId = LoginUserUtil.getLoginUser().getId(); ArrayList apiActivityOrderListVos = new ArrayList<>(); LambdaQueryWrapper happyActivityOrderLambdaQueryWrapper = new LambdaQueryWrapper<>(); happyActivityOrderLambdaQueryWrapper.eq(HappyActivityOrder::getMemberId, memberId); if(ObjectUtil.isNotEmpty(dto.getState()) && dto.getState() != 0){ happyActivityOrderLambdaQueryWrapper.eq(HappyActivityOrder::getState, dto.getState()); } happyActivityOrderLambdaQueryWrapper.eq(HappyActivityOrder::getDeleteFlag, StateUpDownEnum.DOWN.getCode()); happyActivityOrderLambdaQueryWrapper.orderByDesc(HappyActivityOrder::getCreatedTime); Page page = new Page<>(dto.getPageNum(), dto.getPageSize()); Page voteActivityPage = happyActivityOrderMapper.selectPage(page, happyActivityOrderLambdaQueryWrapper); List records = voteActivityPage.getRecords(); if(CollUtil.isNotEmpty(records)){ Set activityIds = records.stream().map(HappyActivityOrder::getActivityId).collect(Collectors.toSet()); List happyActivities = this.baseMapper.selectList( new LambdaQueryWrapper() .select( HappyActivity::getId, HappyActivity::getCategoryId, HappyActivity::getName, HappyActivity::getStartTime, HappyActivity::getEndTime, HappyActivity::getAddress) .in(HappyActivity::getId, activityIds) ); Map activityMap = happyActivities.stream().collect(Collectors.toMap(HappyActivity::getId, Function.identity())); Set categoryIds = happyActivities.stream().map(HappyActivity::getCategoryId).collect(Collectors.toSet()); //stream流操作categoryIds得到一个Map的map对象 List happyActivityCategories = happyActivityCategoryMapper.selectList( new LambdaQueryWrapper() .select( HappyActivityCategory::getId, HappyActivityCategory::getName) .in(HappyActivityCategory::getId,categoryIds) ); Map categoryMap = happyActivityCategories.stream().collect(Collectors.toMap(HappyActivityCategory::getId, Function.identity())); for(HappyActivityOrder happyActivityOrder : records){ ApiActivityOrderListVo apiActivityOrderListVo = new ApiActivityOrderListVo(); BeanUtil.copyProperties(happyActivityOrder, apiActivityOrderListVo); apiActivityOrderListVo.setActivityName(activityMap.get(happyActivityOrder.getActivityId()).getName()); apiActivityOrderListVo.setStartTime(activityMap.get(happyActivityOrder.getActivityId()).getStartTime()); apiActivityOrderListVo.setEndTime(activityMap.get(happyActivityOrder.getActivityId()).getEndTime()); apiActivityOrderListVo.setAddress(activityMap.get(happyActivityOrder.getActivityId()).getAddress()); apiActivityOrderListVo.setCategoryName(categoryMap.get(activityMap.get(happyActivityOrder.getActivityId()).getCategoryId()).getName()); apiActivityOrderListVos.add(apiActivityOrderListVo); } } return new FebsResponse().success().data(apiActivityOrderListVos); } @Override public FebsResponse orderInfo(Long id) { // 获取当前登录用户的ID Long memberId = LoginUserUtil.getLoginUser().getId(); ArrayList apiActivityOrderInfoVos = new ArrayList<>(); HappyActivityOrder happyActivityOrder = happyActivityOrderMapper.selectById(id); HappyActivity happyActivity = this.baseMapper.selectById(happyActivityOrder.getActivityId()); List happyActivityOrderItems = happyActivityOrderItemMapper.selectList( new LambdaQueryWrapper() .eq(HappyActivityOrderItem::getOrderId, happyActivityOrder.getId()) .eq(HappyActivityOrderItem::getMemberId, memberId) ); if(CollUtil.isNotEmpty(happyActivityOrderItems)){ for(HappyActivityOrderItem happyActivityOrderItem : happyActivityOrderItems){ ApiActivityOrderInfoVo apiActivityOrderInfoVo = new ApiActivityOrderInfoVo(); BeanUtil.copyProperties(happyActivityOrderItem, apiActivityOrderInfoVo); apiActivityOrderInfoVo.setOrderState(happyActivityOrder.getState()); apiActivityOrderInfoVo.setActivityName(happyActivity.getName()); apiActivityOrderInfoVo.setActivityStartTime(happyActivity.getStartTime()); apiActivityOrderInfoVo.setActivityEndTime(happyActivity.getEndTime()); apiActivityOrderInfoVo.setActivityAddress(happyActivity.getAddress()); apiActivityOrderInfoVos.add(apiActivityOrderInfoVo); } } return new FebsResponse().success().data(apiActivityOrderInfoVos); } @Override public FebsResponse orderDelete(Long id) { // 获取当前登录用户的ID Long memberId = LoginUserUtil.getLoginUser().getId(); List happyActivityOrders = happyActivityOrderMapper.selectList( new LambdaQueryWrapper() .eq(HappyActivityOrder::getId, id) .eq(HappyActivityOrder::getMemberId, memberId) ); if(CollUtil.isNotEmpty(happyActivityOrders)){ happyActivityOrders.forEach(happyActivityOrder -> { happyActivityOrder.setDeleteFlag(StateUpDownEnum.UP.getCode()); happyActivityOrderMapper.updateById(happyActivityOrder); }); } return new FebsResponse().success(); } @Override public void activityEnd() { Date date = new Date(); List happyActivities = this.baseMapper.selectList( new LambdaQueryWrapper() .eq(HappyActivity::getState, StateUpDownEnum.ACTIVITY_STATE_ENROLLING.getCode()) .le(HappyActivity::getEndTime, date) ); if(CollUtil.isEmpty(happyActivities)){ return; } happyActivities.forEach(happyActivity -> { happyActivity.setState(StateUpDownEnum.ACTIVITY_STATE_END.getCode()); this.baseMapper.updateById(happyActivity); }); } /** * 当活动即将开始时自动更新活动状态 * 此方法旨在查询所有即将开始的活动，并将它们的状态更新为报名进行中 */ @Override public void activityStart() { // 获取当前日期和时间 DateTime date = DateUtil.date(); // 查询所有状态为未开始且当前时间在活动开始时间结束时间之间的活动 List happyActivities = this.baseMapper.selectList( new LambdaQueryWrapper() .eq(HappyActivity::getState, StateUpDownEnum.ACTIVITY_STATE_NOT_START.getCode()) .le(HappyActivity::getStartTime, date) .ge(HappyActivity::getEndTime, date) ); // 如果没有找到任何符合条件的活动，则直接返回 if(CollUtil.isEmpty(happyActivities)){ return; } // 遍历每个符合条件的活动，将其状态更新为报名进行中，并保存更新 happyActivities.forEach(happyActivity -> { happyActivity.setState(StateUpDownEnum.ACTIVITY_STATE_ENROLLING.getCode()); this.baseMapper.updateById(happyActivity); }); } @Override public FebsResponse checkOrder(ApiCheckOrderDto dto) { // 获取当前登录用户的ID Long memberId = LoginUserUtil.getLoginUser().getId(); MallMember mallMember = mallMemberMapper.selectById(memberId); if(StateUpDownEnum.UP.getCode() != mallMember.getCheckOrder()){ throw new FebsException("您不是核销员！"); } String orderItemCode = dto.getOrderItemCode(); HappyActivityOrderItem happyActivityOrderItem = happyActivityOrderItemMapper.selectOne( new LambdaQueryWrapper() .eq(HappyActivityOrderItem::getCode, orderItemCode) .last("limit 1") ); if(happyActivityOrderItem == null){ throw new FebsException("票号异常！"); } HappyActivity happyActivity = this.baseMapper.selectById(happyActivityOrderItem.getActivityId()); ApiCheckOrderVo apiCheckOrderVo = new ApiCheckOrderVo(); apiCheckOrderVo.setActivityName(happyActivity.getName()); apiCheckOrderVo.setActivityStartTime(happyActivity.getStartTime()); apiCheckOrderVo.setActivityEndTime(happyActivity.getEndTime()); apiCheckOrderVo.setActivityAddress(happyActivity.getAddress()); apiCheckOrderVo.setCode(happyActivityOrderItem.getCode()); apiCheckOrderVo.setName(happyActivityOrderItem.getName()); apiCheckOrderVo.setPhone(happyActivityOrderItem.getPhone()); apiCheckOrderVo.setPrice(happyActivityOrderItem.getPrice()); apiCheckOrderVo.setState(happyActivityOrderItem.getState()); return new FebsResponse().success().data(apiCheckOrderVo); } @Override public FebsResponse insureOrder(ApiCheckOrderDto dto) { // 获取当前登录用户的ID Long memberId = LoginUserUtil.getLoginUser().getId(); MallMember mallMember = mallMemberMapper.selectById(memberId); if(StateUpDownEnum.UP.getCode() != mallMember.getCheckOrder()){ throw new FebsException("您不是核销员！"); } String orderItemCode = dto.getOrderItemCode(); HappyActivityOrderItem happyActivityOrderItem = happyActivityOrderItemMapper.selectOne( new LambdaQueryWrapper() .eq(HappyActivityOrderItem::getCode, orderItemCode) .last("limit 1") ); if(happyActivityOrderItem != null){ if(StateUpDownEnum.UP.getCode() == happyActivityOrderItem.getState()){ throw new FebsException("票号已核销！"); } happyActivityOrderItem.setState(StateUpDownEnum.UP.getCode()); happyActivityOrderItem.setTransferItemId(memberId); happyActivityOrderItemMapper.updateById(happyActivityOrderItem); agentProducer.sendCheckActivityItem(happyActivityOrderItem.getOrderId()); } return new FebsResponse().success().message("操作成功"); } /** * 检查活动订单项的状态 * 当指定订单的所有活动订单项都不处于"未使用"状态时，将订单状态更新为"已使用" * * @param orderId 订单ID，用于查询活动订单项和订单信息 */ @Override public void checkActivityItem(Long orderId) { // 查询指定订单ID的活动订单项数量，且状态为"未使用" Integer integer = happyActivityOrderItemMapper.selectCount( new LambdaQueryWrapper() .eq(HappyActivityOrderItem::getOrderId, orderId) .eq(HappyActivityOrderItem::getState, StateUpDownEnum.DOWN.getCode()) ); // 如果没有找到任何未使用的活动订单项 if(0 == integer){ // 根据订单ID查询订单信息 HappyActivityOrder happyActivityOrder = happyActivityOrderMapper.selectById(orderId); if(happyActivityOrder == null){ return; } // 更新订单状态为"已使用" happyActivityOrder.setState(StateUpDownEnum.ORDER_STATE_USED.getCode()); // 保存更新后的订单信息 happyActivityOrderMapper.updateById(happyActivityOrder); } // 结束方法执行 return; } @Override public void overtimeJob() { List happyActivityOrders = happyActivityOrderMapper.selectList( new LambdaQueryWrapper() .eq(HappyActivityOrder::getState, StateUpDownEnum.ORDER_STATE_WAIT_PAY.getCode()) .lt(HappyActivityOrder::getFailTime, new Date()) ); if(CollUtil.isNotEmpty(happyActivityOrders)){ happyActivityOrders.forEach(happyActivityOrder -> { Long activityId = happyActivityOrder.getActivityId(); Integer numCnt = happyActivityOrder.getNumCnt(); this.baseMapper.updateHappyActivitySurplusCnt(activityId,numCnt); happyActivityOrder.setState(StateUpDownEnum.ORDER_STATE_OVERTIME.getCode()); happyActivityOrderMapper.updateById(happyActivityOrder); }); } } @Override public FebsResponse addComment(ApiPayOrderAddCommentDto dto) { // 获取当前登录用户的ID Long memberId = LoginUserUtil.getLoginUser().getId(); Long orderId = dto.getOrderId(); HappyActivityOrder happyActivityOrder = happyActivityOrderMapper.selectById(orderId); if(StateUpDownEnum.ORDER_STATE_USED.getCode() != happyActivityOrder.getState()){ throw new FebsException("该订单状态不是已使用状态！"); } happyActivityOrder.setState(StateUpDownEnum.ORDER_STATE_COMMENT.getCode()); happyActivityOrderMapper.updateById(happyActivityOrder); HappyActivity happyActivity = this.baseMapper.selectById(happyActivityOrder.getActivityId()); HappyActivityComment happyActivityComment = new HappyActivityComment(); happyActivityComment.setActivityId(happyActivity.getId()); happyActivityComment.setActivityName(happyActivity.getName()); happyActivityComment.setMemberId(memberId); happyActivityComment.setOrderId(orderId); happyActivityComment.setStar(dto.getStar()); happyActivityComment.setComment(dto.getComment()); happyActivityComment.setImages(dto.getImages()); happyActivityCommentMapper.insert(happyActivityComment); return new FebsResponse().success().message("操作成功"); } @Override public List commentByActivityId(ApiActivityCommentDto dto) { Page page = new Page<>(dto.getPageNow(), dto.getPageSize()); return this.baseMapper.selectActivityCommentPage(page,dto); } @Override public FebsResponse voteActivityHot(Long id) { ApiVoteActivityHotVo apiVoteActivityHotVo = new ApiVoteActivityHotVo(); Integer optionCnt = happyActivityOptionMapper.selectCount( new LambdaQueryWrapper() .eq(HappyActivityOption::getActivityId, id) .eq(HappyActivityOption::getDeleteFlag, StateUpDownEnum.DOWN.getCode()) .eq(HappyActivityOption::getState, StateUpDownEnum.VOTE_OPTION_STATE_AUDIT_SUCCESS.getCode()) ); apiVoteActivityHotVo.setOptionCnt(optionCnt); Integer followVoteCnt = happyFollowMapper.selectCount( new LambdaQueryWrapper() .eq(HappyFollow::getSourceType, StateUpDownEnum.SOURCE_TYPE_ACTIVITY.getCode()) .eq(HappyFollow::getSourceId, id) .eq(HappyFollow::getType, StateUpDownEnum.VOTE.getCode()) .eq(HappyFollow::getDeleteFlag, StateUpDownEnum.DOWN.getCode()) ); apiVoteActivityHotVo.setFollowVoteCnt(followVoteCnt); return new FebsResponse().success().data(apiVoteActivityHotVo); } public static void main(String[] args) { Date date = new Date(); //获取今日的凌晨的时间 DateTime dateTime = DateUtil.beginOfDay(date); System.out.println(dateTime); } }