From 9ca146e7afa543d2c516a91c95929d34aa48a52c Mon Sep 17 00:00:00 2001
From: cl <1442464845@qq.com>
Date: 星期四, 16 四月 2026 11:45:23 +0800
Subject: [PATCH] 电视机提醒
---
rsf-open-api/src/main/java/com/vincent/rsf/openApi/service/RcsTvCallbackService.java | 23 +++++++++++++++++------
1 files changed, 17 insertions(+), 6 deletions(-)
diff --git a/rsf-open-api/src/main/java/com/vincent/rsf/openApi/service/RcsTvCallbackService.java b/rsf-open-api/src/main/java/com/vincent/rsf/openApi/service/RcsTvCallbackService.java
index e796aa6..e47f443 100644
--- a/rsf-open-api/src/main/java/com/vincent/rsf/openApi/service/RcsTvCallbackService.java
+++ b/rsf-open-api/src/main/java/com/vincent/rsf/openApi/service/RcsTvCallbackService.java
@@ -122,12 +122,7 @@
if (!StringUtils.hasText(staNo)) {
throw new IllegalArgumentException("staNo 涓嶈兘涓虹┖");
}
- if (!StringUtils.hasText(taskNo)) {
- tvMonitorStringRedisTemplate.opsForHash().delete(TvMonitorRedisKeys.TV_RCS_STATION_TASK_NO, staNo);
- } else {
- tvMonitorStringRedisTemplate.opsForHash()
- .put(TvMonitorRedisKeys.TV_RCS_STATION_TASK_NO, staNo, taskNo);
- }
+ writeStationTaskNo(staNo, taskNo);
log.info("RCS 浠诲姟鍙峰凡鍐欏叆 Redis Hash staNo={} taskNo={}", staNo, taskNo);
Map<String, Object> payload = new LinkedHashMap<>();
payload.put("staNo", staNo);
@@ -135,6 +130,22 @@
return rcsOk(payload);
}
+ /**
+ * 杞 RCS 绔欑偣浠诲姟鍙锋椂鍐欏叆 Redis锛屼笌 {@link #handleStationTaskNo} 涓� Hash 瑙勫垯涓�鑷�
+ */
+ public void writeStationTaskNo(String staNo, String taskNo) {
+ if (!StringUtils.hasText(staNo)) {
+ return;
+ }
+ String t = taskNo == null ? "" : taskNo.trim();
+ if (!StringUtils.hasText(t) || "0".equals(t)) {
+ tvMonitorStringRedisTemplate.opsForHash().delete(TvMonitorRedisKeys.TV_RCS_STATION_TASK_NO, staNo);
+ } else {
+ tvMonitorStringRedisTemplate.opsForHash()
+ .put(TvMonitorRedisKeys.TV_RCS_STATION_TASK_NO, staNo, t);
+ }
+ }
+
private Map<String, Object> rcsOk(Object data) {
Map<String, Object> m = new LinkedHashMap<>();
m.put("code", 200);
--
Gitblit v1.9.1