From e6e4f559c0f56ac4bac0d483e34fa15ccbe4f702 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E9=9D=96?= Date: Tue, 21 May 2024 14:33:21 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B5=81=E7=A8=8B=E5=BE=85=E5=8A=9E=E9=9B=86?= =?UTF-8?q?=E6=88=900.3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cxkg/integration/MessageListen.java | 20 ++++++++++++++++++- 1 file changed, 19 insertions(+), 1 deletion(-) diff --git a/shkd-cosmic-debug/src/main/java/shkd/cosmic/cxkg/integration/MessageListen.java b/shkd-cosmic-debug/src/main/java/shkd/cosmic/cxkg/integration/MessageListen.java index beba30a..b93f848 100644 --- a/shkd-cosmic-debug/src/main/java/shkd/cosmic/cxkg/integration/MessageListen.java +++ b/shkd-cosmic-debug/src/main/java/shkd/cosmic/cxkg/integration/MessageListen.java @@ -159,7 +159,7 @@ public class MessageListen extends AbstractMessageServiceHandler { Map resultMap; for (Iterator var6 = requestBodyList.iterator(); var6.hasNext(); resultMap.get("code")) { Map requestBody = (Map) var6.next(); - String jsonStr = this.pushZHData(requestBody); + String jsonStr = this.deleteUserRequestInfo(requestBody); log.info("推送结果 jsonStr：" + jsonStr); resultMap = (Map) JSON.parseObject(jsonStr, Map.class); resultMap.get("code"); @@ -754,4 +754,22 @@ public class MessageListen extends AbstractMessageServiceHandler { } return null; } + + private String deleteUserRequestInfo(Map params) { + log.info("推送消息到中环(delete)....."); +// QFilter filter = new QFilter("number", "=", "001"); +// DynamicObject kd21_oa_matters = BusinessDataServiceHelper.loadSingle("kd21_oa_matters", "id,name,kd21_largetextfield", new QFilter[]{filter}); +// String kd21_largetextfield = kd21_oa_matters.getString("kd21_largetextfield"); +// String apiUrl = kd21_largetextfield; + String apiUrl = "http://" + "10.157.226.9:8088" + "/rest/ofs/deleteUserRequestInfoByJson"; + RestTemplate restTemplate = new RestTemplate(); + HttpHeaders headers = new HttpHeaders(); + headers.setContentType(MediaType.APPLICATION_JSON); + String jsonBody = JSON.toJSONString(params); + HttpEntity requestEntity = new HttpEntity(jsonBody, headers); + ResponseEntity responseEntity = restTemplate.postForEntity(apiUrl, requestEntity, String.class, new Object[0]); + String jsonStr = (String) responseEntity.getBody(); + log.info("{已办完成}", jsonStr); + return jsonStr; + } }