wenyx
/
CXKG
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

流程待办集成0.3

This commit is contained in:
李靖 2024-05-21 14:33:21 +08:00
parent 50dc02f2a1
commit e6e4f559c0
1 changed files with 19 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
shkd-cosmic-debug/src/main/java/shkd/cosmic/cxkg/integration/MessageListen.java
View File

@ -159,7 +159,7 @@ public class MessageListen extends AbstractMessageServiceHandler {
Map resultMap; Map resultMap;
for (Iterator var6 = requestBodyList.iterator(); var6.hasNext(); resultMap.get("code")) { for (Iterator var6 = requestBodyList.iterator(); var6.hasNext(); resultMap.get("code")) {
Map<String, Object> requestBody = (Map) var6.next(); Map<String, Object> requestBody = (Map) var6.next();
String jsonStr = this.pushZHData(requestBody); String jsonStr = this.deleteUserRequestInfo(requestBody);
log.info("推送结果 jsonStr：" + jsonStr); log.info("推送结果 jsonStr：" + jsonStr);
resultMap = (Map) JSON.parseObject(jsonStr, Map.class); resultMap = (Map) JSON.parseObject(jsonStr, Map.class);
resultMap.get("code"); resultMap.get("code");
@ -754,4 +754,22 @@ public class MessageListen extends AbstractMessageServiceHandler {
} }
return null; return null;
} }
private String deleteUserRequestInfo(Map<String, Object> 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<String> requestEntity = new HttpEntity(jsonBody, headers);
ResponseEntity<String> responseEntity = restTemplate.postForEntity(apiUrl, requestEntity, String.class, new Object[0]);
String jsonStr = (String) responseEntity.getBody();
log.info("{已办完成}", jsonStr);
return jsonStr;
}
} }