From b6610b9b69e7f8928b6fb605ebe6d76c8d3aeb87 Mon Sep 17 00:00:00 2001
From: cl <1442464845@qq.com>
Date: 星期四, 16 四月 2026 12:41:51 +0800
Subject: [PATCH] 配置文件
---
rsf-open-api/src/main/java/com/vincent/rsf/openApi/service/RcsTvCallbackService.java | 26 +++++++++++++++++++-------
1 files changed, 19 insertions(+), 7 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..1abbb22 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
@@ -64,7 +64,8 @@
continue;
}
if (StringUtils.hasText(staNo)) {
- parts.add("[" + staNo + "]" + msg);
+ // 鍏ㄨ鎷彿鍓嶇紑锛岄伩鍏嶇數瑙嗘満绔� Redis 鍊艰鍒�
+ parts.add("銆�" + staNo + "銆�" + msg);
} else {
parts.add(msg);
}
@@ -122,12 +123,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 +131,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