This commit is contained in:
yangjun 2025-10-10 11:22:39 +08:00
commit a984fff22a
1 changed files with 22 additions and 22 deletions

View File

@ -85,28 +85,28 @@ public class ElderTagServiceImpl extends ServiceImpl<ElderTagMapper, ElderTag> i
etMQDto.setElderTagList(BeanUtil.copyToList(elderTags, ElderTagAsyncMQDto.class)); etMQDto.setElderTagList(BeanUtil.copyToList(elderTags, ElderTagAsyncMQDto.class));
elderTagMQListener.handleIncremental2( etMQDto); elderTagMQListener.handleIncremental2( etMQDto);
String apiAddress = ""; // String apiAddress = "";
//查询源数据平台的接口api地址 // //查询源数据平台的接口api地址
{ // {
//各平台api地址都存在管理系统中 管理系统api地址在系统参数配置中 ope_open_url // //各平台api地址都存在管理系统中 管理系统api地址在系统参数配置中 ope_open_url
JSONObject opeOpenUrl = sysConfigApi.getByKeyByDS("master", "ope_open_url"); // JSONObject opeOpenUrl = sysConfigApi.getByKeyByDS("master", "ope_open_url");
String opeApiAddress = opeOpenUrl.getString("configValue"); // String opeApiAddress = opeOpenUrl.getString("configValue");
if (opeApiAddress.endsWith("/")) { // if (opeApiAddress.endsWith("/")) {
opeApiAddress = opeApiAddress.substring(0, opeApiAddress.length() - 1); // opeApiAddress = opeApiAddress.substring(0, opeApiAddress.length() - 1);
} // }
String bizApiAddress = opeApiAddress + "/api/baseInfo/getOrgApiAddress?orgCode=" + sourceOrgCode; // String bizApiAddress = opeApiAddress + "/api/baseInfo/getOrgApiAddress?orgCode=" + sourceOrgCode;
//
try { // try {
String res = HttpRequestUtil.doGet(bizApiAddress, HttpRequestUtil.createDefaultHeaders()); // String res = HttpRequestUtil.doGet(bizApiAddress, HttpRequestUtil.createDefaultHeaders());
JSONObject jsonResponse = JSON.parseObject(res); // JSONObject jsonResponse = JSON.parseObject(res);
JSONObject result = jsonResponse.getJSONObject("result"); // JSONObject result = jsonResponse.getJSONObject("result");
apiAddress = result.getString("url"); // apiAddress = result.getString("url");
} catch (Exception e) { // } catch (Exception e) {
e.printStackTrace(); // e.printStackTrace();
} // }
} // }
//
elderTagMQListener.handleCreateMedia2(etMQDto, apiAddress); // elderTagMQListener.handleCreateMedia2(etMQDto, apiAddress);
//给对应业务平台发送消息 //给对应业务平台发送消息
return etMQDto; return etMQDto;
} }