From 78be20a0887fd6eddcd703fcc0dc863b700b0613 Mon Sep 17 00:00:00 2001
From: gongchunyi <deslre0381@gmail.com>
Date: 星期四, 28 五月 2026 16:30:40 +0800
Subject: [PATCH] fix: 去除AI与个推
---
src/main/java/com/ruoyi/basic/task/ReturnVisitReminderTask.java | 32 ++++++++------------------------
1 files changed, 8 insertions(+), 24 deletions(-)
diff --git a/src/main/java/com/ruoyi/basic/task/ReturnVisitReminderTask.java b/src/main/java/com/ruoyi/basic/task/ReturnVisitReminderTask.java
index 2b57ee7..81066d6 100644
--- a/src/main/java/com/ruoyi/basic/task/ReturnVisitReminderTask.java
+++ b/src/main/java/com/ruoyi/basic/task/ReturnVisitReminderTask.java
@@ -3,15 +3,12 @@
import com.ruoyi.basic.pojo.CustomerReturnVisit;
import com.ruoyi.basic.service.CustomerReturnVisitService;
import com.ruoyi.framework.redis.RedisCache;
-import com.ruoyi.project.system.domain.SysUserClient;
-import com.ruoyi.project.system.service.SysUserClientService;
-import com.ruoyi.project.system.service.impl.UnipushService;
+
+import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
-import java.time.LocalDateTime;
import java.util.Set;
/**
@@ -25,21 +22,16 @@
*/
@Slf4j
@Component
+@RequiredArgsConstructor
public class ReturnVisitReminderTask {
private static final String REMINDER_QUEUE_KEY = "return_visit:reminder:queue";
- @Autowired
- private RedisCache redisCache;
+ private final RedisCache redisCache;
- @Autowired
- private CustomerReturnVisitService customerReturnVisitService;
+ private final CustomerReturnVisitService customerReturnVisitService;
- @Autowired
- private UnipushService unipushService;
- @Autowired
- private SysUserClientService userClientService;
@SuppressWarnings("unchecked")
@Scheduled(fixedDelay = 60000)
@@ -63,30 +55,22 @@
}
}
- @SuppressWarnings("unchecked")
private void processReminder(Long returnVisitId) {
CustomerReturnVisit returnVisit = customerReturnVisitService.getById(returnVisitId);
if (returnVisit == null || returnVisit.getIsEnabled() == 0 || returnVisit.getIsCompleted() == 1) {
return;
}
- SysUserClient client = userClientService.getById(returnVisit.getRemindUserId());
- if (client == null || client.getCid() == null) {
- log.warn("鐢ㄦ埛鏈粦瀹欳ID, 鏃犳硶鍙戦�乁nipush鎺ㄩ��: userId={}", returnVisit.getRemindUserId());
- return;
- }
try {
- unipushService.sendReturnVisitReminder(returnVisitId, client.getCid(), returnVisit.getContent(), returnVisit.getCustomerPrivatePoolId());
+ // 鏍囪宸插鐞嗭紙鎺ㄩ�佸姛鑳藉凡绂佺敤锛�
CustomerReturnVisit updateObj = new CustomerReturnVisit();
updateObj.setId(returnVisitId);
updateObj.setIsCompleted(1);
customerReturnVisitService.updateById(updateObj);
- log.info("鍥炶鎻愰啋宸查�氳繃 Unipush 鍙戦��: ID={}", returnVisitId);
+ log.info("鍥炶鎻愰啋宸插鐞嗭紙鎺ㄩ�佸姛鑳藉凡绂佺敤锛�: ID={}", returnVisitId);
} catch (Exception e) {
- log.error("鍙戦�佸洖璁挎彁閱掑け璐ワ紝閲嶆柊鍔犲叆闃熷垪: ID={}", returnVisitId, e);
- long retryTime = System.currentTimeMillis() + 60000;
- redisCache.redisTemplate.opsForZSet().add(REMINDER_QUEUE_KEY, returnVisitId, retryTime);
+ log.error("澶勭悊鍥炶鎻愰啋澶辫触: ID={}", returnVisitId, e);
}
}
}
\ No newline at end of file
--
Gitblit v1.9.3