update:修改消息推送

This commit is contained in:
sunzheng
2024-07-26 19:17:46 +08:00
parent 825a1b547d
commit b451d47784
@@ -101,7 +101,7 @@ public class HiworkTodoServiceImpl implements PushWorkflowIntegrationAPI {
log.info("统一待办推送入参" + JSON.toJSONString(hiworkTodoList));
log.info("统一待办推送url" + ip + todoUrl);
String isTodo = hiworkTodoList.get(0).getIsTodo();
push(ip + todoUrl,JSON.toJSONString(hiworkTodoAddList),isTodo);
push(ip + todoUrl,JSON.toJSONString(hiworkTodoAddList),hiworkTodoList,isTodo);
}catch (Exception e){
log.error("统一待办推送异常",e);
}
@@ -121,7 +121,7 @@ public class HiworkTodoServiceImpl implements PushWorkflowIntegrationAPI {
log.info("统一待办推送url" + ip + todoUrl);
String isTodo = hiworkTodoList.get(0).getIsTodo();
push(ip + todoUrl,JSON.toJSONString(hiworkTodoAddList),isTodo);
push(ip + todoUrl,JSON.toJSONString(hiworkTodoAddList),hiworkTodoList,isTodo);
}catch (Exception e){
log.error("统一待办推送异常",e);
}
@@ -141,13 +141,13 @@ public class HiworkTodoServiceImpl implements PushWorkflowIntegrationAPI {
log.info("统一待办推送url" + ip + todoUrl);
// 远程调用
String isTodo = hiworkTodoList.get(0).getIsTodo();
push(ip + todoUrl,JSON.toJSONString(hiworkTodoAddList),isTodo);
push(ip + todoUrl,JSON.toJSONString(hiworkTodoAddList),hiworkTodoList,isTodo);
}catch (Exception e){
log.error("统一待办删除推送异常",e);
}
}
private void push(String url, String jsonString, String type) {
private void push(String url, String jsonString, List<HiworkTodo> hiworkTodoList, String type) {
// 设置最大重试次数
int maxRetries = 3;
// 当前重试次数
@@ -156,9 +156,7 @@ public class HiworkTodoServiceImpl implements PushWorkflowIntegrationAPI {
lawsUnifiedTodoLog.setType(Integer.valueOf(type));
while (retries < maxRetries) {
// 远程调用
// JSONObject json = new JSONObject();
// json.put("success5", true);
JSONObject json = restTemplate.postForObject(url,jsonString, JSONObject.class);
JSONObject json = restTemplate.postForObject(url,hiworkTodoList, JSONObject.class);
if(!Objects.isNull(json) && json.containsKey("success") && Objects.equals("true",json.getString("success"))){
log.info("统一待办推送成功");
lawsUnifiedTodoLog.setResponseBody(JSON.toJSONString(json));