From e38dbee7e43f6af65c7e9307d936a1c48e4bb539 Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期二, 14 一月 2025 11:56:33 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/TechnicianSubscribeServiceImpl.java | 21 ++++++++++++++++++---
1 files changed, 18 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..3bc5b95 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;
@@ -96,12 +96,27 @@
}
+ @Override
+ public void switchingTechnician(TechnicianSubscribe technicianSubscribe) {
+ List<TechnicianSubscribe> list = this.list(new LambdaQueryWrapper<TechnicianSubscribe>().eq(TechnicianSubscribe::getOrderId, technicianSubscribe.getOrderId())
+ .eq(TechnicianSubscribe::getDelFlag, 0).eq(TechnicianSubscribe::getStatus, 0));
+ for (TechnicianSubscribe subscribe : list) {
+ if(subscribe.getTechnicianId().equals(technicianSubscribe.getTechnicianId())){
+ throw new RuntimeException("不能切换相同的技师");
+ }
+ subscribe.setTechnicianId(technicianSubscribe.getTechnicianId());
+ this.updateById(subscribe);
+ }
+
+ }
+
/**
* 定时修改到期状态
*/
@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