From 685c1ab4e9698f4a1e0e942069ca8b3541502e3c Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期二, 14 一月 2025 10:50:09 +0800
Subject: [PATCH] 修改bug

---
 ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/TechnicianSubscribeServiceImpl.java |   18 +++++++++++++++---
 1 files changed, 15 insertions(+), 3 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 68f47f6..77729d9 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
@@ -15,6 +15,7 @@
 import com.ruoyi.other.mapper.TechnicianSubscribeMapper;
 import com.ruoyi.other.service.TechnicianSubscribeService;
 import com.ruoyi.other.vo.TechnicianSubscribeVO;
+import org.springframework.data.redis.connection.RedisZSetCommands;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Service;
 
@@ -40,8 +41,7 @@
     @Resource
     private RemoteOrderGoodsClient orderGoodsClient;
     @Resource
-    private RedisTemplate<String, String> redisTemplate;
-    
+    private RedisTemplate redisTemplate;
     @Resource
     private AppUserClient appUserClient;
     
@@ -82,6 +82,7 @@
 
     @Override
     public void subscribe(TechnicianSubscribe subscribe) {
+
         Long userId = SecurityUtils.getUserId();
         subscribe.setAppUserId(userId);
         subscribe.setStatus(TechnicianStatus.UNSUBSCRIBE.getCode());
@@ -96,12 +97,23 @@
     }
 
 
+    @Override
+    public void switchingTechnician(TechnicianSubscribe technicianSubscribe) {
+        TechnicianSubscribe subscribe = this.getById(technicianSubscribe.getId());
+        if(subscribe.getTechnicianId().equals(technicianSubscribe.getTechnicianId())){
+            throw new RuntimeException("不能切换相同的技师");
+        }
+        subscribe.setTechnicianId(technicianSubscribe.getTechnicianId());
+
+    }
+
     /**
      * 定时修改到期状态
      */
     @Override
     public void taskEditStstus() {
-        Set<String> technician_subscribe = redisTemplate.opsForZSet().range("technician_subscribe", 0, LocalDateTime.now().toEpochSecond(ZoneOffset.UTC));
+        long second = LocalDateTime.now().toEpochSecond(ZoneOffset.UTC);
+        Set<String> technician_subscribe = redisTemplate.opsForZSet().rangeByScore("technician_subscribe", 0, second);
         if(technician_subscribe.size() > 0){
             List<TechnicianSubscribe> list = this.listByIds(technician_subscribe);
             list.forEach(s->s.setStatus(3));

--
Gitblit v1.7.1