From 43e79a1b48fb38e9a9b60293c874516b16624388 Mon Sep 17 00:00:00 2001 From: Derran Date: Mon, 10 Nov 2025 15:28:18 +0800 Subject: [PATCH] =?UTF-8?q?=E7=8E=AB=E7=91=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../order/OrderApplicationService.java | 11 ++++++++ .../UserMarriageInformationQueryService.java | 9 +++++++ ...erMarriageInformationQueryServiceImpl.java | 27 +++++++++++++++++++ 3 files changed, 47 insertions(+) create mode 100644 dating-agency-mall-server/src/main/java/com/qniao/dam/query/usermarriageinformation/UserMarriageInformationQueryService.java create mode 100644 dating-agency-mall-server/src/main/java/com/qniao/dam/query/usermarriageinformation/impl/UserMarriageInformationQueryServiceImpl.java diff --git a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/service/order/OrderApplicationService.java b/dating-agency-mall-server/src/main/java/com/qniao/dam/application/service/order/OrderApplicationService.java index 7072406..edc1cb7 100644 --- a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/service/order/OrderApplicationService.java +++ b/dating-agency-mall-server/src/main/java/com/qniao/dam/application/service/order/OrderApplicationService.java @@ -47,10 +47,12 @@ import com.qniao.dam.query.order.OrderQueryService; import com.qniao.dam.query.product.ProductQueryService; import com.qniao.dam.query.rewardconfig.RewardConfigQueryService; import com.qniao.dam.query.right.RightQueryService; +import com.qniao.dam.query.usermarriageinformation.UserMarriageInformationQueryService; import com.qniao.das.application.DatingAgencyServiceApplicationService; import com.qniao.das.application.request.CalculateSiteActivityFeeDto; import com.qniao.das.application.response.CalculateSiteActivityFeeVo; import com.qniao.das.domian.aggregate.marriageinformation.MarriageInformation; +import com.qniao.das.domian.aggregate.marriageinformation.UserMarriageInformation; import com.qniao.das.domian.aggregate.matchmakermarriage.MatchmakerMarriageInformation; import com.qniao.das.domian.aggregate.siteactivity.SiteActivity; import com.qniao.das.domian.aggregate.vip.VIPEnum; @@ -116,6 +118,9 @@ public class OrderApplicationService extends BaseApplicationService { private OrderAggregate orderAggregate; @Resource private OrderDiscountConfigQueryService orderDiscountConfigQueryService; + @Resource + private UserMarriageInformationQueryService userMarriageInformationQueryService; + @Value("${default_marriage_bounty_matchmaker_id}") private Long defaultMarriageBountyMatchmakerId; @@ -198,6 +203,12 @@ public class OrderApplicationService extends BaseApplicationService { } } if (OrderBelongingEnum.CUSTOMER.equals(order.getOrderBelonging())) { + if (Objects.isNull(order.getMiId())) { + UserMarriageInformation userMarriageInformation = userMarriageInformationQueryService.queryByOwn(order.getUserId()); + if (Objects.nonNull(userMarriageInformation)) { + order.setMiId(userMarriageInformation.getMiId()); + } + } if (Objects.nonNull(order.getMiId())) { MarriageInformation marriageInformation = marriageInformationDao.selectById(order.getMiId()); order.setOrderBelongName(marriageInformation.getNickName()); diff --git a/dating-agency-mall-server/src/main/java/com/qniao/dam/query/usermarriageinformation/UserMarriageInformationQueryService.java b/dating-agency-mall-server/src/main/java/com/qniao/dam/query/usermarriageinformation/UserMarriageInformationQueryService.java new file mode 100644 index 0000000..c6f839b --- /dev/null +++ b/dating-agency-mall-server/src/main/java/com/qniao/dam/query/usermarriageinformation/UserMarriageInformationQueryService.java @@ -0,0 +1,9 @@ +package com.qniao.dam.query.usermarriageinformation; + +import com.qniao.das.domian.aggregate.marriageinformation.UserMarriageInformation; + +public interface UserMarriageInformationQueryService { + + UserMarriageInformation queryByOwn(Long userId); + +} diff --git a/dating-agency-mall-server/src/main/java/com/qniao/dam/query/usermarriageinformation/impl/UserMarriageInformationQueryServiceImpl.java b/dating-agency-mall-server/src/main/java/com/qniao/dam/query/usermarriageinformation/impl/UserMarriageInformationQueryServiceImpl.java new file mode 100644 index 0000000..6d56075 --- /dev/null +++ b/dating-agency-mall-server/src/main/java/com/qniao/dam/query/usermarriageinformation/impl/UserMarriageInformationQueryServiceImpl.java @@ -0,0 +1,27 @@ +package com.qniao.dam.query.usermarriageinformation.impl; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.qniao.dam.infrastructure.persistent.dao.domain.UserMarriageInformationDao; +import com.qniao.dam.query.usermarriageinformation.UserMarriageInformationQueryService; +import com.qniao.das.domian.aggregate.marriageinformation.UserMarriageInformation; +import com.qniao.das.domian.aggregate.marriageinformation.constant.UserMarriageInformationTypeEnum; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; + +@Service +public class UserMarriageInformationQueryServiceImpl implements UserMarriageInformationQueryService { + + @Resource + private UserMarriageInformationDao userMarriageInformationDao; + + @Override + public UserMarriageInformation queryByOwn(Long userId) { + LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); + wrapper.eq(UserMarriageInformation::getType, UserMarriageInformationTypeEnum.OWN); + wrapper.eq(UserMarriageInformation::getUserId, userId); + wrapper.last("limit 1"); + return userMarriageInformationDao.selectOne(wrapper); + } + +}