From aabc308b837880569b4bd96b4685f14d7c969b42 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E6=9D=BE?= <8605635+zhang3064194730@user.noreply.gitee.com> Date: Tue, 11 Nov 2025 16:24:56 +0800 Subject: [PATCH 1/9] =?UTF-8?q?=E6=96=B0=E5=AE=A2=E7=AB=8B=E5=87=8F?= =?UTF-8?q?=E7=9B=B8=E5=85=B3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../czg/account/dto/shopuser/ShopUserDTO.java | 1 + .../MkShopConsumeDiscountRecordService.java | 3 +++ .../service/impl/AShopUserServiceImpl.java | 9 ++++++- ...kShopConsumeDiscountRecordServiceImpl.java | 27 +++++++++++++------ 4 files changed, 31 insertions(+), 9 deletions(-) diff --git a/cash-common/cash-common-service/src/main/java/com/czg/account/dto/shopuser/ShopUserDTO.java b/cash-common/cash-common-service/src/main/java/com/czg/account/dto/shopuser/ShopUserDTO.java index 5cf4c5bf9..63519f844 100644 --- a/cash-common/cash-common-service/src/main/java/com/czg/account/dto/shopuser/ShopUserDTO.java +++ b/cash-common/cash-common-service/src/main/java/com/czg/account/dto/shopuser/ShopUserDTO.java @@ -27,4 +27,5 @@ public class ShopUserDTO extends ShopUser { private String memberLevelName; private String nextMemberLevelName; private Long nextExperience; + private boolean isNew; } diff --git a/cash-common/cash-common-service/src/main/java/com/czg/market/service/MkShopConsumeDiscountRecordService.java b/cash-common/cash-common-service/src/main/java/com/czg/market/service/MkShopConsumeDiscountRecordService.java index 7b75ca035..f0b839135 100644 --- a/cash-common/cash-common-service/src/main/java/com/czg/market/service/MkShopConsumeDiscountRecordService.java +++ b/cash-common/cash-common-service/src/main/java/com/czg/market/service/MkShopConsumeDiscountRecordService.java @@ -1,5 +1,6 @@ package com.czg.market.service; +import com.czg.account.entity.ShopUser; import com.czg.market.vo.MkConsumeDiscountVO; import com.mybatisflex.core.service.IService; import com.czg.market.entity.MkShopConsumeDiscountRecord; @@ -37,4 +38,6 @@ public interface MkShopConsumeDiscountRecordService extends IService getPage(String key, Integer isVip, BigDecimal amount) { Long mainIdByShopId = shopInfoService.getMainIdByShopId(StpKit.USER.getShopId()); PageHelper.startPage(PageUtil.buildPageHelp()); - return PageUtil.convert(new PageInfo<>(shopUserMapper.selectPageByKeyAndIsVip(mainIdByShopId, isVip, key, amount))); + PageInfo shopUserDTOPageInfo = new PageInfo<>(shopUserMapper.selectPageByKeyAndIsVip(mainIdByShopId, isVip, key, amount)); + shopUserDTOPageInfo.getList().forEach(item -> { + item.setNew(consumeDiscountService.isNewUser(item, StpKit.USER.getShopId())); + }); + return PageUtil.convert(shopUserDTOPageInfo); } @Override diff --git a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkShopConsumeDiscountRecordServiceImpl.java b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkShopConsumeDiscountRecordServiceImpl.java index 010146724..8fba69d97 100644 --- a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkShopConsumeDiscountRecordServiceImpl.java +++ b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkShopConsumeDiscountRecordServiceImpl.java @@ -22,6 +22,7 @@ import jakarta.annotation.Resource; import lombok.extern.slf4j.Slf4j; import org.apache.dubbo.auth.v1alpha1.Ca; import org.apache.dubbo.config.annotation.DubboReference; +import org.apache.dubbo.config.annotation.DubboService; import org.springframework.stereotype.Service; import java.math.BigDecimal; @@ -35,7 +36,7 @@ import java.util.Random; * @since 2025-09-17 */ @Slf4j -@Service +@DubboService public class MkShopConsumeDiscountRecordServiceImpl extends ServiceImpl implements MkShopConsumeDiscountRecordService { @Resource private MkConsumeDiscountService consumeDiscountService; @@ -101,9 +102,25 @@ public class MkShopConsumeDiscountRecordServiceImpl extends ServiceImpl Date: Tue, 11 Nov 2025 18:10:58 +0800 Subject: [PATCH 2/9] =?UTF-8?q?=E5=88=86=E9=94=80=E8=AE=B0=E5=BD=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/MkDistributionUserServiceImpl.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkDistributionUserServiceImpl.java b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkDistributionUserServiceImpl.java index 32db55c17..ac737a11a 100644 --- a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkDistributionUserServiceImpl.java +++ b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkDistributionUserServiceImpl.java @@ -546,10 +546,10 @@ public class MkDistributionUserServiceImpl extends ServiceImpl Date: Thu, 13 Nov 2025 09:23:02 +0800 Subject: [PATCH 3/9] =?UTF-8?q?=E5=88=86=E9=94=80=E9=80=80=E6=AC=BE?= =?UTF-8?q?=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/czg/task/DistributionTask.java | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) diff --git a/cash-api/market-server/src/main/java/com/czg/task/DistributionTask.java b/cash-api/market-server/src/main/java/com/czg/task/DistributionTask.java index 9cfe1e6a1..cbc25844b 100644 --- a/cash-api/market-server/src/main/java/com/czg/task/DistributionTask.java +++ b/cash-api/market-server/src/main/java/com/czg/task/DistributionTask.java @@ -49,7 +49,6 @@ public class DistributionTask { // @Scheduled(cron = "0 0 0 * * ?") // @Scheduled(fixedRate = 30000) public void deliver() { - // TODO 逻辑修改 // 1. 订单完成支付时（判断是否分销）产生流水记录。 // 2. 判断入账时间。 // 3. 如果是 0 天，再去判断商户余额是否足够。够则入账，不足则不管。 @@ -58,10 +57,7 @@ public class DistributionTask { // 6. 订单产生退款时，去流水表查询该订单的流水记录，如果未入账改为已入账，并插入一条退款扣钱的流水。 LocalDateTime localDateTime = DateUtil.date().toLocalDateTime(); distributionFlowService.list(new QueryWrapper() - .eq(MkDistributionFlow::getStatus, TableValueConstant.DistributionFlow.Status.PENDING.getCode())).forEach(item -> { - if (item.getDeliverTime() != null && item.getDeliverTime().isAfter(localDateTime)) { - return; - } + .eq(MkDistributionFlow::getStatus, TableValueConstant.DistributionFlow.Status.PENDING.getCode()).le(MkDistributionFlow::getDeliverTime, localDateTime)).forEach(item -> { FunUtils.safeRunVoid(() -> { log.info("开始处理延时分账， id: {}, orderNo: {}, 类型: {}", item.getId(), item.getOrderNo(), item.getType()); @@ -72,15 +68,15 @@ public class DistributionTask { } if (CollUtil.newArrayList(OrderStatusEnums.REFUND.getCode(), OrderStatusEnums.REFUNDING.getCode(), OrderStatusEnums.PART_REFUND.getCode()).contains(orderInfo.getStatus())) { log.warn("订单已退款, 订单号: {}", item.getOrderNo()); - item.setStatus(TableValueConstant.DistributionFlow.Status.REFUND.getCode()); + distributionUserService.refund(orderInfo.getId(), orderInfo.getOrderNo()); } else { item.setStatus(TableValueConstant.DistributionFlow.Status.SUCCESS.getCode()); ShopUser shopUser = shopUserService.getById(item.getDistributionUserId()); distributionUserService.updateShopInfoAmount(orderInfo.getShopId(), item.getRewardAmount().negate(), orderInfo.getId(), TableValueConstant.DistributionAmountFlow.Type.SUB, "分销扣减"); distributionUserService.updateIncome(item.getRewardAmount().negate(), item.getRewardAmount(), BigDecimal.ZERO, item.getDistributionUserId(), shopUser.getUserId(), item.getShopUserId(), item.getShopId(), item.getLevel()); + distributionFlowService.updateById(item); } - distributionFlowService.updateById(item); }); }); } From d47aba8add1b4563582c9c6b79fe826286e7138f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E6=9D=BE?= <8605635+zhang3064194730@user.noreply.gitee.com> Date: Thu, 13 Nov 2025 09:43:49 +0800 Subject: [PATCH 4/9] =?UTF-8?q?=E5=88=86=E9=94=80=E9=80=80=E6=AC=BE?= =?UTF-8?q?=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/czg/task/MemberTask.java | 1 + .../impl/TbMemberConfigServiceImpl.java | 19 +++++++++++++++++-- 2 files changed, 18 insertions(+), 2 deletions(-) diff --git a/cash-api/market-server/src/main/java/com/czg/task/MemberTask.java b/cash-api/market-server/src/main/java/com/czg/task/MemberTask.java index 83a40f263..f7e2857c2 100644 --- a/cash-api/market-server/src/main/java/com/czg/task/MemberTask.java +++ b/cash-api/market-server/src/main/java/com/czg/task/MemberTask.java @@ -44,6 +44,7 @@ public class MemberTask { }); } + @Scheduled(cron = "0 */10 * * * *") public void check() { List shopUsers = shopUserService.list(new QueryWrapper().isNotNull(ShopUser::getEndTime).eq(ShopUser::getIsVip, 1).lt(ShopUser::getEndTime, DateUtil.date())); shopUsers.forEach(item -> { diff --git a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/TbMemberConfigServiceImpl.java b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/TbMemberConfigServiceImpl.java index 20b6a11d0..cf2ee0d6c 100644 --- a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/TbMemberConfigServiceImpl.java +++ b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/TbMemberConfigServiceImpl.java @@ -281,6 +281,20 @@ public class TbMemberConfigServiceImpl extends ServiceImpl { + exp = expVal; + } + } + + System.out.println(exp); + + } + @Override @Transactional(rollbackFor = Exception.class) public boolean deliver(Long shopId, Long userId, TableValueConstant.MemberExpFlow.Type type, BigDecimal money, Integer expVal, Long sourceId) { @@ -308,7 +322,7 @@ public class TbMemberConfigServiceImpl extends ServiceImpl Date: Thu, 13 Nov 2025 09:47:19 +0800 Subject: [PATCH 5/9] =?UTF-8?q?=E4=BD=99=E9=A2=9D=E6=98=8E=E7=BB=86?= =?UTF-8?q?=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/czg/controller/user/UShopUserController.java | 3 ++- .../src/main/java/com/czg/account/entity/ShopUserFlow.java | 1 + .../czg/service/account/service/impl/ShopUserServiceImpl.java | 1 + 3 files changed, 4 insertions(+), 1 deletion(-) diff --git a/cash-api/account-server/src/main/java/com/czg/controller/user/UShopUserController.java b/cash-api/account-server/src/main/java/com/czg/controller/user/UShopUserController.java index abd891ed6..f171892a7 100644 --- a/cash-api/account-server/src/main/java/com/czg/controller/user/UShopUserController.java +++ b/cash-api/account-server/src/main/java/com/czg/controller/user/UShopUserController.java @@ -90,7 +90,8 @@ public class UShopUserController { */ @GetMapping("/moneyRecord") public CzgResult> getMoneyRecord(@RequestParam Long shopId) { - return CzgResult.success(shopUserFlowService.pageAs(PageUtil.buildPage(), new MyQueryWrapper().eq(ShopUserFlow::getShopId, shopId) + ShopUser shopUserInfo = shopUserService.getShopUserInfo(shopId, StpKit.USER.getLoginIdAsLong()); + return CzgResult.success(shopUserFlowService.pageAs(PageUtil.buildPage(), new MyQueryWrapper().eq(ShopUserFlow::getShopUserId, shopUserInfo.getId()) .selectAll(ShopUserFlow.class) .eq(ShopUserFlow::getUserId, StpKit.USER.getLoginIdAsLong()).leftJoin(ShopInfo.class).on(ShopUserFlow::getShopId, ShopInfo::getId) .select(ShopInfo::getShopName) diff --git a/cash-common/cash-common-service/src/main/java/com/czg/account/entity/ShopUserFlow.java b/cash-common/cash-common-service/src/main/java/com/czg/account/entity/ShopUserFlow.java index fa9d97635..322d6eb64 100644 --- a/cash-common/cash-common-service/src/main/java/com/czg/account/entity/ShopUserFlow.java +++ b/cash-common/cash-common-service/src/main/java/com/czg/account/entity/ShopUserFlow.java @@ -35,6 +35,7 @@ public class ShopUserFlow implements Serializable { private Long id; private Long userId; + private Long shopUserId; private Long shopId; /** diff --git a/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/ShopUserServiceImpl.java b/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/ShopUserServiceImpl.java index b37996448..2a9f51820 100644 --- a/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/ShopUserServiceImpl.java +++ b/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/ShopUserServiceImpl.java @@ -135,6 +135,7 @@ public class ShopUserServiceImpl extends ServiceImpl i userInfo.setAmount(BigDecimal.ZERO); } userFlow.setUserId(userInfo.getUserId()); + userFlow.setShopUserId(shopUserEditDTO.getId()); userFlow.setShopId(userInfo.getSourceShopId()); userFlow.setAmount(shopUserEditDTO.getType() == 0 ? shopUserEditDTO.getMoney().negate() : shopUserEditDTO.getMoney()); userFlow.setBalance(shopUserEditDTO.getType() == 0 ? userInfo.getAmount().subtract(shopUserEditDTO.getMoney()) : userInfo.getAmount().add(shopUserEditDTO.getMoney())); From ba283a6a982b9d23587ceceeb28b3d5e3f76eb5d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E6=9D=BE?= <8605635+zhang3064194730@user.noreply.gitee.com> Date: Thu, 13 Nov 2025 09:52:17 +0800 Subject: [PATCH 6/9] =?UTF-8?q?=E4=BC=9A=E5=91=98=E7=94=9F=E6=97=A5?= =?UTF-8?q?=E7=A9=BA=E4=B8=B2=E6=8A=A5=E9=94=99=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../czg/service/account/service/impl/UShopUserServiceImpl.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/UShopUserServiceImpl.java b/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/UShopUserServiceImpl.java index 43d7a08f4..11c5ad581 100644 --- a/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/UShopUserServiceImpl.java +++ b/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/UShopUserServiceImpl.java @@ -179,6 +179,9 @@ public class UShopUserServiceImpl implements UShopUserService { if (StrUtil.isBlank(shopUser.getCode())) { shopUser.setCode(generateCode(shopId)); } + if (StrUtil.isBlank(shopUser.getBirthDay())) { + shopUser.setBirthDay(null); + } shopUser.setJoinTime(shopUser.getJoinTime() == null ? DateUtil.date().toLocalDateTime() : shopUser.getJoinTime()); From 1495ff2553327100aae2aab4a9b6dc9570c29f20 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E6=9D=BE?= <8605635+zhang3064194730@user.noreply.gitee.com> Date: Thu, 13 Nov 2025 10:41:17 +0800 Subject: [PATCH 7/9] =?UTF-8?q?=E5=BC=80=E9=80=9A=E4=BC=9A=E5=91=98?= =?UTF-8?q?=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/czg/controller/NotifyController.java | 7 +++++++ .../market/service/impl/TbMemberConfigServiceImpl.java | 9 +++++---- .../service/order/service/impl/OrderInfoServiceImpl.java | 5 ++--- 3 files changed, 14 insertions(+), 7 deletions(-) diff --git a/cash-api/order-server/src/main/java/com/czg/controller/NotifyController.java b/cash-api/order-server/src/main/java/com/czg/controller/NotifyController.java index 7b233d415..a72802774 100644 --- a/cash-api/order-server/src/main/java/com/czg/controller/NotifyController.java +++ b/cash-api/order-server/src/main/java/com/czg/controller/NotifyController.java @@ -7,6 +7,7 @@ import com.alibaba.fastjson2.JSONObject; import com.czg.CzgPayUtils; import com.czg.entity.CzgBaseRespParams; import com.czg.market.service.MkDistributionUserService; +import com.czg.market.service.TbMemberConfigService; import com.czg.mq.PrintMqListener; import com.czg.order.entity.OrderPayment; import com.czg.order.service.OrderInfoService; @@ -53,10 +54,16 @@ public class NotifyController { private MkDistributionUserService distributionUserService; @Resource private OrderPaymentService paymentService; + @Resource + private TbMemberConfigService memberConfigService; @GetMapping("testOpen") public JSONObject test1(String code) throws Exception { + JSONObject czg = JSONObject.parseObject("{\"amount\":10,\"cashFee\":0,\"channelSendNo\":\"20251113110113130266202235210653\",\"channelTradeNo\":\"4200002932202511131794511090\",\"currency\":\"cny\",\"drType\":\"00\",\"ifCode\":\"lklspay\",\"mchOrderNo\":\"WX1988788559919120384\",\"mercNo\":\"B251107293903\",\"msgType\":\"sft.trade.notify\",\"note\":\"成功\",\"payOrderId\":\"2025111319887885609440501775VT\",\"payTime\":\"2025-11-13 09:58:44\",\"payType\":\"WECHAT\",\"refundAmt\":0,\"refundState\":0,\"settlementType\":\"D1\",\"state\":\"TRADE_SUCCESS\",\"storeId\":\"S2511077140\",\"subject\":\"万维时光的店铺\",\"tradeFee\":0,\"userId\":\"oVxsc1QNZRRsWdWDmTdwPJGT9BWc\"}"); + AssertUtil.isNull(czg, "支付回调数据为空"); + log.info("支付回调数据为:{}", czg); + orderInfoService.payCallBackOrder(czg.getString("mchOrderNo"), czg, 0); return null; } diff --git a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/TbMemberConfigServiceImpl.java b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/TbMemberConfigServiceImpl.java index cf2ee0d6c..5a315b0f8 100644 --- a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/TbMemberConfigServiceImpl.java +++ b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/TbMemberConfigServiceImpl.java @@ -31,6 +31,7 @@ import com.mybatisflex.spring.service.impl.ServiceImpl; import lombok.extern.slf4j.Slf4j; import org.apache.dubbo.config.annotation.DubboReference; import org.apache.dubbo.config.annotation.DubboService; +import org.springframework.transaction.annotation.Isolation; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; @@ -296,9 +297,9 @@ public class TbMemberConfigServiceImpl extends ServiceImpl Date: Thu, 13 Nov 2025 10:52:11 +0800 Subject: [PATCH 8/9] =?UTF-8?q?=E5=BC=80=E9=80=9A=E4=BC=9A=E5=91=98?= =?UTF-8?q?=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/czg/task/MemberTask.java | 2 +- .../market/service/TbMemberConfigService.java | 3 +- .../impl/TbMemberConfigServiceImpl.java | 29 +++++++++---------- .../service/impl/OrderInfoServiceImpl.java | 5 ++-- .../order/service/impl/PayServiceImpl.java | 2 +- 5 files changed, 21 insertions(+), 20 deletions(-) diff --git a/cash-api/market-server/src/main/java/com/czg/task/MemberTask.java b/cash-api/market-server/src/main/java/com/czg/task/MemberTask.java index f7e2857c2..a64de374f 100644 --- a/cash-api/market-server/src/main/java/com/czg/task/MemberTask.java +++ b/cash-api/market-server/src/main/java/com/czg/task/MemberTask.java @@ -40,7 +40,7 @@ public class MemberTask { // @Scheduled(cron = "0 0 1 * * ? ") public void task() { shopUserService.list(new QueryWrapper().eq(ShopUser::getIsVip, 1).lt(ShopUser::getNextDeliverTime, DateUtil.date().toLocalDateTime())).forEach(item -> { - memberConfigService.deliver(item.getSourceShopId(), item.getUserId(), TableValueConstant.MemberExpFlow.Type.MEMBER_TASK, null, null, null); + memberConfigService.deliver(item, TableValueConstant.MemberExpFlow.Type.MEMBER_TASK, null, null, null); }); } diff --git a/cash-common/cash-common-service/src/main/java/com/czg/market/service/TbMemberConfigService.java b/cash-common/cash-common-service/src/main/java/com/czg/market/service/TbMemberConfigService.java index 8bbd841e4..52fb74d60 100644 --- a/cash-common/cash-common-service/src/main/java/com/czg/market/service/TbMemberConfigService.java +++ b/cash-common/cash-common-service/src/main/java/com/czg/market/service/TbMemberConfigService.java @@ -1,5 +1,6 @@ package com.czg.market.service; +import com.czg.account.entity.ShopUser; import com.czg.constant.TableValueConstant; import com.czg.exception.ApiNotPrintException; import com.czg.market.dto.MemberConfigDTO; @@ -46,7 +47,7 @@ public interface TbMemberConfigService extends IService { * @param expVal 经验值，只有当type为pay的时候才生效 * @return 是否成功 */ - boolean deliver(Long shopId, Long userId, TableValueConstant.MemberExpFlow.Type type, BigDecimal money, Integer expVal, Long sourceId); + boolean deliver(ShopUser shopUser, TableValueConstant.MemberExpFlow.Type type, BigDecimal money, Integer expVal, Long sourceId); /** * 获取用户会员列表 diff --git a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/TbMemberConfigServiceImpl.java b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/TbMemberConfigServiceImpl.java index 5a315b0f8..a597c7a0f 100644 --- a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/TbMemberConfigServiceImpl.java +++ b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/TbMemberConfigServiceImpl.java @@ -297,18 +297,17 @@ public class TbMemberConfigServiceImpl extends ServiceImpl { - shopCouponRecordService.grant(shopId, new MkRewardCouponDTO().setCouponId(item.getCoupon().getId()) + shopCouponRecordService.grant(shopUser.getMainShopId(), new MkRewardCouponDTO().setCouponId(item.getCoupon().getId()) .setNum(item.getNum()) .setUserId(shopUser.getUserId()) - .setShopId(shopId)); + .setShopId(shopUser.getMainShopId())); }); // couponGiftService.addCouponGift(memberOrderId, "会员开通赠券", 1, giftDTOS); @@ -371,8 +370,8 @@ public class TbMemberConfigServiceImpl extends ServiceImpl= nextConfig.getExperienceValue()) { shopUser.setMemberLevelId(nextConfig.getId()); @@ -388,7 +387,7 @@ public class TbMemberConfigServiceImpl extends ServiceImpl Date: Thu, 13 Nov 2025 11:09:51 +0800 Subject: [PATCH 9/9] =?UTF-8?q?=E7=94=A8=E6=88=B7=E4=BF=A1=E6=81=AF?= =?UTF-8?q?=E8=BF=94=E5=9B=9E=E6=98=AF=E5=90=A6=E5=BC=80=E5=90=AF=E6=94=AF?= =?UTF-8?q?=E4=BB=98=E5=AF=86=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/czg/account/dto/shopuser/ShopUserDetailDTO.java | 1 + .../czg/service/account/service/impl/UShopUserServiceImpl.java | 1 + 2 files changed, 2 insertions(+) diff --git a/cash-common/cash-common-service/src/main/java/com/czg/account/dto/shopuser/ShopUserDetailDTO.java b/cash-common/cash-common-service/src/main/java/com/czg/account/dto/shopuser/ShopUserDetailDTO.java index c45719541..138246214 100644 --- a/cash-common/cash-common-service/src/main/java/com/czg/account/dto/shopuser/ShopUserDetailDTO.java +++ b/cash-common/cash-common-service/src/main/java/com/czg/account/dto/shopuser/ShopUserDetailDTO.java @@ -43,6 +43,7 @@ public class ShopUserDetailDTO extends ShopUser { * 支付密码 */ private String payPwd; + private Integer usePayPwd; /** * 店铺拓展参数 */ diff --git a/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/UShopUserServiceImpl.java b/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/UShopUserServiceImpl.java index 11c5ad581..1d4e747f2 100644 --- a/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/UShopUserServiceImpl.java +++ b/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/UShopUserServiceImpl.java @@ -232,6 +232,7 @@ public class UShopUserServiceImpl implements UShopUserService { shopUserDetailDTO.setFreeDineConfig(freeDineConfigService.getConfig(shopInfoService.getMainIdByShopId(shopId))); shopUserDetailDTO.setPayPwd(userInfo.getPayPwd()); + shopUserDetailDTO.setUsePayPwd(userInfo.getUsePayPwd()); return shopUserDetailDTO; }