From 28d1b11176dbddfc6bb966f2b1d8776b946dd9be Mon Sep 17 00:00:00 2001 From: puzhibing <393733352@qq.com> Date: 星期一, 09 十二月 2024 17:34:12 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/TechnicianSubscribeServiceImpl.java | 18 +++++++----------- 1 files changed, 7 insertions(+), 11 deletions(-) diff --git a/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/TechnicianSubscribeServiceImpl.java b/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/TechnicianSubscribeServiceImpl.java index 4acbbe7..a18d4f0 100644 --- a/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/TechnicianSubscribeServiceImpl.java +++ b/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/TechnicianSubscribeServiceImpl.java @@ -4,9 +4,9 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ruoyi.common.security.utils.SecurityUtils; +import com.ruoyi.order.feignClient.RemoteOrderGoodsClient; import com.ruoyi.other.api.domain.TechnicianSubscribe; import com.ruoyi.other.enums.TechnicianStatus; -import com.ruoyi.other.mapper.TechnicianMapper; import com.ruoyi.other.mapper.TechnicianSubscribeMapper; import com.ruoyi.other.service.TechnicianSubscribeService; import com.ruoyi.other.vo.TechnicianSubscribeVO; @@ -29,7 +29,7 @@ @Resource private TechnicianSubscribeMapper technicianSubscribeMapper; @Resource - private TechnicianMapper technicianMapper; + private RemoteOrderGoodsClient orderGoodsClient; @Override public List<TechnicianSubscribeVO> getTechnicianSubscribeByUserAndShop(Long userId, Long shopId) { @@ -41,15 +41,7 @@ } @Override -// @DistributedLock(lockNamePre = "#technician_subscribe_lock", lockNamePost = "#technicianId") - public void subscribe(TechnicianSubscribe subscribe, Long technicianId) { -// Long count = technicianSubscribeMapper.selectCount(new LambdaQueryWrapper<TechnicianSubscribe>() -// .eq(TechnicianSubscribe::getTechnicianId, technicianId) -// .eq(TechnicianSubscribe::getSubscribeTime, subscribe.getSubscribeTime()) -// .eq(TechnicianSubscribe::getStatus, TechnicianStatus.UNSUBSCRIBE.getCode())); -// if (count > 0) { -// throw new ServiceException("当前时间段已被预约", TechnicianErrorCode.TECHNICIAN_ALREADY_SUBSCRIBED.getCode()); -// } + public void subscribe(TechnicianSubscribe subscribe) { // 创建技师预约单 Long userId = SecurityUtils.getUserId(); subscribe.setAppUserId(userId); @@ -58,5 +50,9 @@ subscribe.setCreateTime(LocalDateTime.now()); technicianSubscribeMapper.insert(subscribe); + if (subscribe.getTechnicianId() != null){ + orderGoodsClient.subscribe(subscribe.getOrderId(), Math.toIntExact(subscribe.getId())); + } + } } -- Gitblit v1.7.1