diff --git a/ruoyi-admin/src/main/java/com/ruoyi/base/service/IBaseCardRightsService.java b/ruoyi-admin/src/main/java/com/ruoyi/base/service/IBaseCardRightsService.java index 7fcebd8..8df1506 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/base/service/IBaseCardRightsService.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/base/service/IBaseCardRightsService.java @@ -34,4 +34,13 @@ public interface IBaseCardRightsService extends IService * @param cardRightsVOS TODO **/ void saveAndUpdate(List cardRightsVOS); + + /** + * 通过会员卡id查询权益 + * @author PQZ + * @date 16:31 2025/3/26 + * @param cardId 会员卡id + * @return java.util.List + **/ + List queryByCardId(String cardId); } diff --git a/ruoyi-admin/src/main/java/com/ruoyi/base/service/IBaseCardService.java b/ruoyi-admin/src/main/java/com/ruoyi/base/service/IBaseCardService.java index 740cba1..81dacf8 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/base/service/IBaseCardService.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/base/service/IBaseCardService.java @@ -1,18 +1,27 @@ package com.ruoyi.base.service; -import java.util.List; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.IService; import com.ruoyi.base.domain.BaseCard; +import com.ruoyi.base.vo.BaseCardVO; /** * 会员卡Service接口 - * + * * @author vinjor-m * @date 2025-03-17 */ -public interface IBaseCardService extends IService -{ +public interface IBaseCardService extends IService { IPage queryListPage(BaseCard pageReqVO, Page page); + + /** + * 通过会员卡id查询会员及权益 + * + * @param cardId 卡片id + * @return com.ruoyi.base.vo.BaseCardVO + * @author PQZ + * @date 16:25 2025/3/26 + **/ + BaseCardVO queryByCardId(String cardId); } diff --git a/ruoyi-admin/src/main/java/com/ruoyi/base/service/IBaseRightsService.java b/ruoyi-admin/src/main/java/com/ruoyi/base/service/IBaseRightsService.java index d0bcf1d..4441316 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/base/service/IBaseRightsService.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/base/service/IBaseRightsService.java @@ -1,6 +1,5 @@ package com.ruoyi.base.service; -import java.util.List; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.IService; @@ -8,11 +7,10 @@ import com.ruoyi.base.domain.BaseRights; /** * 会员权益Service接口 - * + * * @author vinjor-m * @date 2025-03-17 */ -public interface IBaseRightsService extends IService -{ +public interface IBaseRightsService extends IService { IPage queryListPage(BaseRights pageReqVO, Page page); } diff --git a/ruoyi-admin/src/main/java/com/ruoyi/base/service/impl/BaseCardRightsServiceImpl.java b/ruoyi-admin/src/main/java/com/ruoyi/base/service/impl/BaseCardRightsServiceImpl.java index 845b43a..4795aea 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/base/service/impl/BaseCardRightsServiceImpl.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/base/service/impl/BaseCardRightsServiceImpl.java @@ -3,7 +3,9 @@ package com.ruoyi.base.service.impl; import java.util.ArrayList; import java.util.List; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.ruoyi.base.vo.CardRightsVO; +import com.ruoyi.common.core.domain.DlBaseEntity; import com.ruoyi.common.utils.DateUtils; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; @@ -77,4 +79,19 @@ public class BaseCardRightsServiceImpl extends ServiceImpl + * @author PQZ + * @date 16:31 2025/3/26 + **/ + @Override + public List queryByCardId(String cardId) { + LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); + lambdaQueryWrapper.eq(BaseCardRights::getCardId,cardId).eq(DlBaseEntity::getDelFlag,0); + return list(lambdaQueryWrapper); + } } diff --git a/ruoyi-admin/src/main/java/com/ruoyi/base/service/impl/BaseCardServiceImpl.java b/ruoyi-admin/src/main/java/com/ruoyi/base/service/impl/BaseCardServiceImpl.java index c4e6c41..4852b7e 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/base/service/impl/BaseCardServiceImpl.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/base/service/impl/BaseCardServiceImpl.java @@ -1,15 +1,21 @@ package com.ruoyi.base.service.impl; -import java.util.List; -import com.ruoyi.common.utils.DateUtils; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.mchange.v2.beans.BeansUtils; +import com.ruoyi.base.domain.BaseCard; +import com.ruoyi.base.domain.BaseCardRights; +import com.ruoyi.base.mapper.BaseCardMapper; +import com.ruoyi.base.service.IBaseCardRightsService; +import com.ruoyi.base.service.IBaseCardService; +import com.ruoyi.base.vo.BaseCardVO; +import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; -import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; -import com.ruoyi.base.mapper.BaseCardMapper; -import com.ruoyi.base.domain.BaseCard; -import com.ruoyi.base.service.IBaseCardService; + +import javax.annotation.Resource; +import java.util.List; /** * 会员卡Service业务层处理 @@ -22,9 +28,29 @@ public class BaseCardServiceImpl extends ServiceImpl i { @Autowired private BaseCardMapper baseCardMapper; + @Resource + private IBaseCardRightsService cardRightsService; @Override public IPage queryListPage(BaseCard pageReqVO, Page page) { return baseCardMapper.queryListPage(pageReqVO, page); } + + /** + * 通过会员卡id查询会员及权益 + * + * @param cardId 卡片id + * @return com.ruoyi.base.vo.BaseCardVO + * @author PQZ + * @date 16:25 2025/3/26 + **/ + @Override + public BaseCardVO queryByCardId(String cardId) { + BaseCardVO cardVO = new BaseCardVO(); + BaseCard card = getById(cardId); + BeanUtils.copyProperties(card,cardVO); + List rights = cardRightsService.queryByCardId(cardId); + cardVO.setRights(rights); + return cardVO; + } } diff --git a/ruoyi-admin/src/main/java/com/ruoyi/base/vo/BaseCardVO.java b/ruoyi-admin/src/main/java/com/ruoyi/base/vo/BaseCardVO.java new file mode 100644 index 0000000..8b717d1 --- /dev/null +++ b/ruoyi-admin/src/main/java/com/ruoyi/base/vo/BaseCardVO.java @@ -0,0 +1,13 @@ +package com.ruoyi.base.vo; + +import com.ruoyi.base.domain.BaseCard; +import com.ruoyi.base.domain.BaseCardRights; +import lombok.Data; + +import java.util.List; + +@Data +public class BaseCardVO extends BaseCard { + /**会员卡关联权益*/ + List rights; +} diff --git a/ruoyi-admin/src/main/java/com/ruoyi/member/controller/MemberOrderController.java b/ruoyi-admin/src/main/java/com/ruoyi/member/controller/MemberOrderController.java index 3568ad2..ca9818b 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/member/controller/MemberOrderController.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/member/controller/MemberOrderController.java @@ -53,6 +53,21 @@ public class MemberOrderController extends BaseController { return success(list); } + /** + * 订单支付回调 + * + * @param memberOrder {@link MemberOrder} + * @return com.ruoyi.common.core.domain.AjaxResult + * @author PQZ + * @date 14:01 2025/3/26 + **/ + @Log(title = "订单支付回调", businessType = BusinessType.INSERT) + @PostMapping("/payCallback") + public AjaxResult payCallback(@RequestBody MemberOrder memberOrder) { + memberOrderService.payCallback(memberOrder.getOrderNo()); + return toAjax(true); + } + /** * 导出订单列表 diff --git a/ruoyi-admin/src/main/java/com/ruoyi/member/domain/MemberOrder.java b/ruoyi-admin/src/main/java/com/ruoyi/member/domain/MemberOrder.java index 3436b29..d45d924 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/member/domain/MemberOrder.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/member/domain/MemberOrder.java @@ -59,6 +59,10 @@ public class MemberOrder extends DlBaseEntity @Excel(name = "商品数量") private Integer goodsNum; + /** 商品服务周期 */ + @Excel(name = "商品服务周期") + private String goodsCycle; + /** 订单总价 */ @Excel(name = "订单总价") private BigDecimal goodsPrice; diff --git a/ruoyi-admin/src/main/java/com/ruoyi/member/service/IMemberCardService.java b/ruoyi-admin/src/main/java/com/ruoyi/member/service/IMemberCardService.java index 8f34d36..5782014 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/member/service/IMemberCardService.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/member/service/IMemberCardService.java @@ -2,6 +2,7 @@ package com.ruoyi.member.service; import com.baomidou.mybatisplus.extension.service.IService; import com.ruoyi.member.domain.MemberCard; +import com.ruoyi.member.domain.MemberOrder; import java.util.List; @@ -21,6 +22,15 @@ public interface IMemberCardService extends IService { * @author PQZ * @date 14:24 2025/3/21 **/ - List listByUserId(Long userId,String userType); + List listByUserId(Long userId, String userType); + + /** + * 会员开卡处理 + * + * @param order 订单 + * @author PQZ + * @date 16:18 2025/3/26 + **/ + void dealMemberCard(MemberOrder order); } diff --git a/ruoyi-admin/src/main/java/com/ruoyi/member/service/IMemberOrderService.java b/ruoyi-admin/src/main/java/com/ruoyi/member/service/IMemberOrderService.java index 97998ce..b528870 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/member/service/IMemberOrderService.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/member/service/IMemberOrderService.java @@ -24,4 +24,13 @@ public interface IMemberOrderService extends IService { * @date 15:25 2025/3/25 **/ IPage queryListPage(MemberOrderVO memberOrder, Page page); + + /** + * 订单支付回调 + * + * @param orderNo 订单编号 + * @author PQZ + * @date 14:02 2025/3/26 + **/ + void payCallback(String orderNo); } diff --git a/ruoyi-admin/src/main/java/com/ruoyi/member/service/IMemberPointsService.java b/ruoyi-admin/src/main/java/com/ruoyi/member/service/IMemberPointsService.java index f069217..973d8e2 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/member/service/IMemberPointsService.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/member/service/IMemberPointsService.java @@ -1,16 +1,17 @@ package com.ruoyi.member.service; -import java.util.List; import com.baomidou.mybatisplus.extension.service.IService; import com.ruoyi.member.domain.MemberPoints; +import java.util.List; + /** * 博主积分变动明细Service接口 - * + * * @author pqz * @date 2025-03-17 */ -public interface IMemberPointsService extends IService -{ +public interface IMemberPointsService extends IService { + void dealMemberPoints(Long userId, List ); } diff --git a/ruoyi-admin/src/main/java/com/ruoyi/member/service/impl/MemberCardServiceImpl.java b/ruoyi-admin/src/main/java/com/ruoyi/member/service/impl/MemberCardServiceImpl.java index f2de537..87bf218 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/member/service/impl/MemberCardServiceImpl.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/member/service/impl/MemberCardServiceImpl.java @@ -2,26 +2,34 @@ package com.ruoyi.member.service.impl; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.ruoyi.base.domain.BaseCard; +import com.ruoyi.base.service.IBaseCardService; +import com.ruoyi.base.vo.BaseCardVO; import com.ruoyi.common.core.domain.DlBaseEntity; import com.ruoyi.member.domain.MemberCard; +import com.ruoyi.member.domain.MemberOrder; import com.ruoyi.member.mapper.MemberCardMapper; import com.ruoyi.member.service.IMemberCardService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import javax.annotation.Resource; +import java.util.Calendar; +import java.util.Date; import java.util.List; /** * 会员开卡记录Service业务层处理 - * + * * @author pqz * @date 2025-03-17 */ @Service -public class MemberCardServiceImpl extends ServiceImpl implements IMemberCardService -{ +public class MemberCardServiceImpl extends ServiceImpl implements IMemberCardService { @Autowired private MemberCardMapper memberCardMapper; + @Resource + private IBaseCardService baseCardService; /** @@ -33,14 +41,72 @@ public class MemberCardServiceImpl extends ServiceImpl listByUserId(Long userId,String userType) { + public List listByUserId(Long userId, String userType) { //查询列表 LambdaUpdateWrapper lambdaUpdateWrapper = new LambdaUpdateWrapper<>(); lambdaUpdateWrapper - .eq(DlBaseEntity::getDelFlag,0) - .eq(MemberCard::getUserId,userId) - .eq(MemberCard::getUserType,userType) + .eq(DlBaseEntity::getDelFlag, 0) + .eq(MemberCard::getUserId, userId) + .eq(MemberCard::getUserType, userType) .orderByDesc(DlBaseEntity::getCreateTime); return list(lambdaUpdateWrapper); } + + /** + * 会员开卡处理 + * + * @param order {@link MemberOrder} + * @author PQZ + * @date 16:19 2025/3/26 + **/ + @Override + public void dealMemberCard(MemberOrder order) { + /*1、数据初始化*/ + //查询会员卡 + BaseCardVO card = baseCardService.queryByCardId(order.getGoodsId()); + //计算到期时间 + Date startTime = new Date(); + Date endTime = getEndTime(startTime,order.getGoodsCycle()); + //初始化会员开通记录 + MemberCard memberCard = new MemberCard(); + memberCard.setUserId(order.getUserId()); + memberCard.setUserType(order.getUserType()); + memberCard.setCardId(order.getGoodsId()); + memberCard.setOrderId(order.getId()); + memberCard.setCardName(card.getCardName()); + memberCard.setStartDate(startTime); + memberCard.setEndDate(endTime); + /*2、处理会员权益*/ + + /*3、保存记录*/ + + } + + /** + * 获取会员结束时间 + * + * @param date 当前时间 + * @param type 类型(01:1个月;02:1季度;03:1年) + * @return java.util.Date + * @author PQZ + * @date 16:40 2025/3/26 + **/ + private Date getEndTime(Date date, String type) { + Calendar calendar = Calendar.getInstance(); + calendar.setTime(date); + switch (type) { + case "01": + calendar.add(Calendar.MONTH, 1); + break; + case "02": + calendar.add(Calendar.MONTH, 3); + break; + case "03": + calendar.add(Calendar.YEAR, 1); + break; + default: + throw new IllegalArgumentException("无效的时间类型: " + type); + } + return calendar.getTime(); + } } diff --git a/ruoyi-admin/src/main/java/com/ruoyi/member/service/impl/MemberOrderServiceImpl.java b/ruoyi-admin/src/main/java/com/ruoyi/member/service/impl/MemberOrderServiceImpl.java index 760ef80..e4df9f9 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/member/service/impl/MemberOrderServiceImpl.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/member/service/impl/MemberOrderServiceImpl.java @@ -1,14 +1,22 @@ package com.ruoyi.member.service.impl; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.ruoyi.common.core.domain.DlBaseEntity; +import com.ruoyi.common.utils.StringUtils; import com.ruoyi.member.domain.MemberOrder; import com.ruoyi.member.mapper.MemberOrderMapper; +import com.ruoyi.member.service.IMemberCardService; import com.ruoyi.member.service.IMemberOrderService; import com.ruoyi.member.vo.MemberOrderVO; +import lombok.SneakyThrows; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import javax.annotation.Resource; /** * 订单Service业务层处理 @@ -21,6 +29,8 @@ public class MemberOrderServiceImpl extends ServiceImpl queryListPage(MemberOrderVO memberOrder, Page page) { return memberOrderMapper.queryListPage(memberOrder,page); } + + /** + * 订单支付回调 + * + * @param orderNo 订单编号 + * @author PQZ + * @date 14:02 2025/3/26 + **/ + @Override + @Transactional(rollbackFor = Exception.class) + @SneakyThrows + public void payCallback(String orderNo) { + /*1、校验数据完整性*/ + LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); + lambdaQueryWrapper.eq(DlBaseEntity::getDelFlag,0).eq(MemberOrder::getOrderNo,orderNo); + MemberOrder memberOrder = getOne(lambdaQueryWrapper); + /*2、处理不同类型*/ + if ("01".equals(memberOrder.getOrderType())) { + cardService.dealMemberCard(memberOrder); + } else { + + } + } + }