From d7b3c61e01aadf99ce6a1d8ebf18c4e6dd81cc2b Mon Sep 17 00:00:00 2001 From: luodangjia <luodangjia> Date: 星期四, 12 十二月 2024 18:05:34 +0800 Subject: [PATCH] 12.12 --- ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/TechnicianSubscribeServiceImpl.java | 50 ++++++++++++++++++++++++++------------------------ 1 files changed, 26 insertions(+), 24 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 6fb0962..de048a9 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 @@ -1,17 +1,17 @@ package com.ruoyi.other.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.exception.ServiceException; +import com.ruoyi.common.core.utils.StringUtils; import com.ruoyi.common.security.utils.SecurityUtils; -import com.ruoyi.other.api.domain.Technician; -import com.ruoyi.other.mapper.TechnicianMapper; -import com.ruoyi.other.mapper.TechnicianSubscribeMapper; +import com.ruoyi.order.feignClient.RemoteOrderGoodsClient; import com.ruoyi.other.api.domain.TechnicianSubscribe; +import com.ruoyi.other.enums.TechnicianStatus; +import com.ruoyi.other.mapper.TechnicianSubscribeMapper; import com.ruoyi.other.service.TechnicianSubscribeService; import com.ruoyi.other.vo.TechnicianSubscribeVO; import org.springframework.stereotype.Service; -import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.time.LocalDateTime; @@ -30,31 +30,33 @@ @Resource private TechnicianSubscribeMapper technicianSubscribeMapper; @Resource - private TechnicianMapper technicianMapper; + private RemoteOrderGoodsClient orderGoodsClient; @Override public List<TechnicianSubscribeVO> getTechnicianSubscribeByUserAndShop(Long userId, Long shopId) { return technicianSubscribeMapper.getTechnicianSubscribeByUserAndShop(userId, shopId); } + @Override + public IPage<TechnicianSubscribeVO> getTechnicianSubscribeByUser(Page<TechnicianSubscribe> page, Long userId, Integer status) { + return technicianSubscribeMapper.getTechnicianSubscribeByUser(page, userId, status); + } @Override - @Transactional(rollbackFor = Exception.class) - public void subscribe(TechnicianSubscribe technicianSubscribe) { - Long technicianId = technicianSubscribe.getTechnicianId(); - Technician technician = technicianMapper.selectOne(new LambdaQueryWrapper<Technician>() - .eq(Technician::getId, technicianId) - .eq(Technician::getStatus, 1) - .eq(Technician::getSubscribeStatus, 1)); - if (null == technician) { - throw new ServiceException("不满足预约条件"); + public void subscribe(TechnicianSubscribe subscribe) { + if (StringUtils.isNotEmpty(subscribe.getIdStr())){ + subscribe.setId(Long.parseLong(subscribe.getIdStr())); + technicianSubscribeMapper.updateById(subscribe); + }else { + Long userId = SecurityUtils.getUserId(); + subscribe.setAppUserId(userId); + subscribe.setStatus(TechnicianStatus.UNSUBSCRIBE.getCode()); + subscribe.setDelFlag(0); + subscribe.setCreateTime(LocalDateTime.now()); + technicianSubscribeMapper.insert(subscribe); } - Long userId = SecurityUtils.getUserId(); - TechnicianSubscribe subscribe = new TechnicianSubscribe(); - subscribe.setAppUserId(userId); - subscribe.setDelFlag(0); - subscribe.setCreateTime(LocalDateTime.now()); - technicianSubscribeMapper.insert(subscribe); - technician.setSubscribeStatus(2); - technicianMapper.updateById(technician); + if (subscribe.getTechnicianId() != null){ + orderGoodsClient.subscribe(subscribe.getOrderId(), subscribe.getTechnicianId()); + } + } } -- Gitblit v1.7.1