From 72355fd10ced5aedaa84f9b4696eb4ddd0268682 Mon Sep 17 00:00:00 2001
From: cl <1442464845@qq.com>
Date: 星期二, 28 四月 2026 16:15:21 +0800
Subject: [PATCH] 隐藏打印
---
rsf-open-api/src/main/java/com/vincent/rsf/openApi/tv/TvRcsStationPollService.java | 72 +++++++++++++++++++++++++++++++-----
1 files changed, 62 insertions(+), 10 deletions(-)
diff --git a/rsf-open-api/src/main/java/com/vincent/rsf/openApi/tv/TvRcsStationPollService.java b/rsf-open-api/src/main/java/com/vincent/rsf/openApi/tv/TvRcsStationPollService.java
index a7493c3..78657ff 100644
--- a/rsf-open-api/src/main/java/com/vincent/rsf/openApi/tv/TvRcsStationPollService.java
+++ b/rsf-open-api/src/main/java/com/vincent/rsf/openApi/tv/TvRcsStationPollService.java
@@ -151,16 +151,20 @@
HttpHeaders headers = new HttpHeaders();
headers.setContentType(MediaType.APPLICATION_JSON);
HttpEntity<String> entity = new HttpEntity<>(reqBody, headers);
- log.info("RCS绔欑偣杞璇锋眰 POST /cv/station/getError url={} body={}", url, trimForLog(reqBody));
ResponseEntity<String> resp = restTemplate.exchange(
url, HttpMethod.POST, entity, String.class);
String respBody = resp.getBody();
- log.info("RCS绔欑偣杞鍝嶅簲 POST /cv/station/getError body={}", trimForLog(respBody));
+ if (!shouldSkipInfoLogErrorPoll(respBody)) {
+ log.info("RCS绔欑偣杞璇锋眰 POST /cv/station/getError url={} body={}", url, trimForLog(reqBody));
+ log.info("RCS绔欑偣杞鍝嶅簲 POST /cv/station/getError body={}", trimForLog(respBody));
+ }
return respBody;
}
- log.info("RCS绔欑偣杞璇锋眰 GET /cv/station/getError url={}", url);
String raw = restTemplate.getForObject(url, String.class);
- log.info("RCS绔欑偣杞鍝嶅簲 GET /cv/station/getError body={}", trimForLog(raw));
+ if (!shouldSkipInfoLogErrorPoll(raw)) {
+ log.info("RCS绔欑偣杞璇锋眰 GET /cv/station/getError url={}", url);
+ log.info("RCS绔欑偣杞鍝嶅簲 GET /cv/station/getError body={}", trimForLog(raw));
+ }
return raw;
}
@@ -171,21 +175,69 @@
HttpHeaders headers = new HttpHeaders();
headers.setContentType(MediaType.APPLICATION_JSON);
HttpEntity<String> entity = new HttpEntity<>(reqBody, headers);
- // log.info("RCS绔欑偣杞璇锋眰 GET /cv/station/getTaskNo url={}", url);
- log.info("RCS绔欑偣杞璇锋眰 POST /cv/station/getTaskNo url={} body={}", url, trimForLog(reqBody));
ResponseEntity<String> resp = restTemplate.exchange(
url, HttpMethod.POST, entity, String.class);
String respBody = resp.getBody();
- // log.info("RCS绔欑偣杞鍝嶅簲 GET /cv/station/getTaskNo body={}", trimForLog(raw));
- log.info("RCS绔欑偣杞鍝嶅簲 POST /cv/station/getTaskNo body={}", trimForLog(respBody));
+ if (!shouldSkipInfoLogTaskNoPoll(respBody)) {
+ log.info("RCS绔欑偣杞璇锋眰 POST /cv/station/getTaskNo url={} body={}", url, trimForLog(reqBody));
+ log.info("RCS绔欑偣杞鍝嶅簲 POST /cv/station/getTaskNo body={}", trimForLog(respBody));
+ }
return respBody;
}
- log.info("RCS绔欑偣杞璇锋眰 GET /cv/station/getTaskNo url={}", url);
String raw = restTemplate.getForObject(url, String.class);
- log.info("RCS绔欑偣杞鍝嶅簲 GET /cv/station/getTaskNo body={}", trimForLog(raw));
+ if (!shouldSkipInfoLogTaskNoPoll(raw)) {
+ log.info("RCS绔欑偣杞璇锋眰 GET /cv/station/getTaskNo url={}", url);
+ log.info("RCS绔欑偣杞鍝嶅簲 GET /cv/station/getTaskNo body={}", trimForLog(raw));
+ }
return raw;
}
+ /** code=200 涓旀棤寮傚父鏄庣粏锛堝 data:[]锛夋椂涓嶆墦 INFO锛岄伩鍏嶅埛灞� */
+ private boolean shouldSkipInfoLogErrorPoll(String respBody) {
+ if (!StringUtils.hasText(respBody)) {
+ return true;
+ }
+ try {
+ JsonNode root = objectMapper.readTree(respBody.trim());
+ if (!httpSuccess(root)) {
+ return false;
+ }
+ JsonNode data = root.get("data");
+ if (data == null || data.isNull()) {
+ return true;
+ }
+ return data.isArray() && data.size() == 0;
+ } catch (Exception e) {
+ return false;
+ }
+ }
+
+ /** code=200 涓旀棤浠诲姟鍙风瓑闈炵┖涓氬姟鏁版嵁鏃朵笉鎵� INFO */
+ private boolean shouldSkipInfoLogTaskNoPoll(String respBody) {
+ if (!StringUtils.hasText(respBody)) {
+ return true;
+ }
+ try {
+ JsonNode root = objectMapper.readTree(respBody.trim());
+ if (!httpSuccess(root)) {
+ return false;
+ }
+ if (StringUtils.hasText(extractTaskNo(root))) {
+ return false;
+ }
+ JsonNode data = root.get("data");
+ if (data != null && !data.isNull()) {
+ if (data.isArray()) {
+ return data.size() == 0;
+ }
+ return false;
+ }
+ return true;
+ } catch (Exception e) {
+ return false;
+ }
+ }
+
private ObjectNode createStationBody(String stationId) {
ObjectNode body = objectMapper.createObjectNode();
if (StringUtils.hasText(stationId)) {
--
Gitblit v1.9.1