hzya
/
kangarooDataCenterV3
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

新增callback方法

This commit is contained in:
xiang2lin 2024-05-15 08:29:45 +08:00
parent 3849532576
commit 3ed14f2310
1 changed files with 40 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

47
service/src/main/java/com/hzya/frame/sysnew/application/service/impl/SysApplicationServiceImpl.java
View File

@ -1691,6 +1691,8 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
sysExtensionApiEntity.setHeaders(oldheaderMap); sysExtensionApiEntity.setHeaders(oldheaderMap);
sysExtensionApiEntity.setQuerys(oldquerys); sysExtensionApiEntity.setQuerys(oldquerys);
sysExtensionApiEntity.setBodys(oldbodys); sysExtensionApiEntity.setBodys(oldbodys);
Method[] methods = null;
Object object = null;
//TODO 判断是否有内部api 是否扩展api 1、启用 2、停用 //TODO 判断是否有内部api 是否扩展api 1、启用 2、停用
if (receiveApi.getExtensionApi() != null && "1".equals(receiveApi.getExtensionApi()) if (receiveApi.getExtensionApi() != null && "1".equals(receiveApi.getExtensionApi())
@ -1698,14 +1700,13 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
&& receiveApi.getFunName() != null && !"".equals(receiveApi.getFunName()) && receiveApi.getFunName() != null && !"".equals(receiveApi.getFunName())
) { ) {
//获取类 //获取类
Object object = null;
try { try {
object = ApplicationContextUtil.getBeanByName(receiveApi.getBeanName()); object = ApplicationContextUtil.getBeanByName(receiveApi.getBeanName());
} catch (SecurityException e) { } catch (SecurityException e) {
} }
//获取类下面的方法 //获取类下面的方法
Method[] methods = object.getClass().getMethods(); methods = object.getClass().getMethods();
if (methods == null || methods.length == 0) { if (methods == null || methods.length == 0) {
return BaseResult.getFailureMessageEntity("未找到内部方法，请联系管理员"); return BaseResult.getFailureMessageEntity("未找到内部方法，请联系管理员");
} }
@ -1752,8 +1753,8 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
JSONArray jsonArray = JSONArray.parseArray(receiveApi.getHeaderIn()); JSONArray jsonArray = JSONArray.parseArray(receiveApi.getHeaderIn());
if(jsonArray != null && jsonArray.size() > 0){ if(jsonArray != null && jsonArray.size() > 0){
for (int i = 0; i < jsonArray.size(); i++) { for (int i = 0; i < jsonArray.size(); i++) {
JSONObject object = jsonArray.getJSONObject(i); JSONObject object1 = jsonArray.getJSONObject(i);
headers.put(object.getString("parameterName"), object.getString("example")); headers.put(object1.getString("parameterName"), object1.getString("example"));
} }
} }
} }
@ -1817,7 +1818,23 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
} }
logger.info("保存日志开始"); logger.info("保存日志开始");
saveLog(sendApp, receiveApp, receiveApi, oldbodys,bodys, oldheaderMap,headerMap, headers, oldquerys,querys, body.toString(),true); SysMessageManageLogEntity sysMessageManageLogEntity = saveLog(sendApp, receiveApp, receiveApi, oldbodys,bodys, oldheaderMap,headerMap, headers, oldquerys,querys, body.toString(),true);
if (methods != null && methods.length > 0) {
for (Method m : methods) {
if (null != m) {
if (m.getName().equals(receiveApi.getFunName().trim()+"CallBack")) {
try {
logger.info("invoke开始>>>>>>>>>>>>>>>>>>>>>>>>>>>>");
m.invoke(object, sysMessageManageLogEntity);
logger.info("invoke结束>>>>>>>>>>>>>>>>>>>>>>>>>>>>");
} catch (Exception e) {
logger.error("invokeException{}", e.getMessage());
}
}
}
}
}
logger.info("保存日志结束"); logger.info("保存日志结束");
if (flag) { if (flag) {
if (JSONUtil.isTypeJSON(body.toString())) { if (JSONUtil.isTypeJSON(body.toString())) {
@ -1875,7 +1892,22 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
} }
} }
logger.info("保存日志开始"); logger.info("保存日志开始");
saveLog(sendApp, receiveApp, receiveApi, oldbodys,bodys, oldheaderMap,headerMap, headers, oldquerys,querys, body.toString(), true); SysMessageManageLogEntity sysMessageManageLogEntity = saveLog(sendApp, receiveApp, receiveApi, oldbodys,bodys, oldheaderMap,headerMap, headers, oldquerys,querys, body.toString(), true);
if (methods != null && methods.length > 0) {
for (Method m : methods) {
if (null != m) {
if (m.getName().equals(receiveApi.getFunName().trim()+"CallBack")) {
try {
logger.info("invoke开始>>>>>>>>>>>>>>>>>>>>>>>>>>>>");
m.invoke(object, sysMessageManageLogEntity);
logger.info("invoke结束>>>>>>>>>>>>>>>>>>>>>>>>>>>>");
} catch (Exception e) {
logger.error("invokeException{}", e.getMessage());
}
}
}
}
}
logger.info("保存日志结束"); logger.info("保存日志结束");
if (flag) { if (flag) {
return BaseResult.getSuccessMessageEntity("转发成功", body); return BaseResult.getSuccessMessageEntity("转发成功", body);
@ -1944,7 +1976,7 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
* @Description 保存日志 * @Description 保存日志
* @Date 11:36 上午 2023/10/20 * @Date 11:36 上午 2023/10/20
**/ **/
private void saveLog(SysApplicationEntity sendApp, SysApplicationEntity receiveApp, SysApplicationApiEntity receiveApi, private SysMessageManageLogEntity saveLog(SysApplicationEntity sendApp, SysApplicationEntity receiveApp, SysApplicationApiEntity receiveApi,
String oldbodys,String bodys, String oldbodys,String bodys,
Map<String, String> oldheaderMap,Map<String, String> headerMap, Map<String, String> oldheaderMap,Map<String, String> headerMap,
Map<String, String> headers, Map<String, String> headers,
@ -2049,6 +2081,7 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
sysMessageManageLogEntity.setModify_time(new Date()); sysMessageManageLogEntity.setModify_time(new Date());
sysMessageManageLogEntity.setSts("Y"); sysMessageManageLogEntity.setSts("Y");
taskExecutor.execute(() -> doEsbTask(sysMessageManageLogEntity)); taskExecutor.execute(() -> doEsbTask(sysMessageManageLogEntity));
return sysMessageManageLogEntity;
} }
/** /**