重调接口代码优化

release
xuliangwei 2 years ago
parent a59bc10a15
commit 6a791ac327
  1. 8
      dxhy-erp/src/main/java/com/dxhy/erp/enums/RequestRecordEnum.java
  2. 8
      dxhy-erp/src/main/java/com/dxhy/erp/service/impl/RequestRecordServiceImpl.java

@ -8,9 +8,9 @@ import java.util.Map;
public enum RequestRecordEnum {
SYNC_INVOICE_INFO("/sn/syncInvoiceInfo", "syncInvoiceInfo", Map.class, ResponseEntity.class,"SDNYMainProcessController"),
SYNC_INVOICE_INFO("/sn/syncInvoiceInfo", "syncInvoiceInfo", ResponseEntity.class,"SDNYMainProcessController", Map.class),
SINGLE_INVOICE_CHECK("/sn/singleInvoiceCheck", "singleInvoiceCheck", SNRequestObject.class, ResponseEntity.class, "SDNYMainProcessController"),
SINGLE_INVOICE_CHECK("/sn/singleInvoiceCheck", "singleInvoiceCheck", ResponseEntity.class, "SDNYMainProcessController", SNRequestObject.class),
SINGLE_CHECK_INVOICE("singleCheckInvoice", JSONObject.class, "SNPushCheckRecordService", Map.class, String.class),
@ -24,11 +24,11 @@ public enum RequestRecordEnum {
private Class<?> responseEntityClass;
RequestRecordEnum(String portName, String methodName, Class<?> argClass, Class<?> responseEntityClass, String className) {
RequestRecordEnum(String portName, String methodName, Class<?> responseEntityClass, String className, Class<?>... argClass) {
this.className = className;
this.portName = portName;
this.methodName = methodName;
this.argClass[0] = argClass;
this.argClass = argClass;
this.responseEntityClass = responseEntityClass;
}

@ -121,11 +121,7 @@ public class RequestRecordServiceImpl extends MpBaseServiceImpl<RequestRecordDao
DynamicContextHolder.push(dbname+DbConstant.BUSINESS_READ);
RequestRecord dbRecord = requestRecordDao.selectById(requestRecord.getId());
log.info("数据库匹配信息:{}", JSONObject.toJSONString(dbRecord));
if (dbRecord != null && !dbRecord.getRequestDetail().equals(requestRecord.getRequestDetail())
&& !dbRecord.getResponseDetail().equals(requestRecord.getResponseDetail())
&& !dbRecord.getMethodName().equals(requestRecord.getMethodName())
&& dbRecord.getStatus().equals(requestRecord.getStatus())
&& dbRecord.getStatus() != 0) {
if (dbRecord == null || dbRecord.getStatus() != 0) {
return ResponseEntity.ok(JSONObject.toJSONString(R.error("请求信息错误,请确认后再发送!")));
}
if (dbRecord.getIsRecall() == 0) {
@ -136,7 +132,7 @@ public class RequestRecordServiceImpl extends MpBaseServiceImpl<RequestRecordDao
log.info("获取到的枚举类型:{}",JSONObject.toJSONString(RequestRecordEnums));
for (RequestRecordEnum recordenum : RequestRecordEnums) {
if (recordenum.getMethodName().equals(dbRecord.getActiveCall())) {
snPushCheckRecordService = (SNPushCheckRecordService)applicationContext.getBean(recordenum.getClassName());
snPushCheckRecordService = JSONObject.parseObject(JSONObject.toJSONString(applicationContext.getBean(recordenum.getClassName())),SNPushCheckRecordService.class);
log.info("通过反射获取到的snPushCheckRecordService是否为空:{}",JSONObject.toJSONString(snPushCheckRecordService == null));
Method method = ReflectUtil.getMethodByName(snPushCheckRecordService.getClass(),recordenum.getMethodName());
log.info("通过反射获取到的方法是否为空:{}",JSONObject.toJSONString(method == null));

Loading…
Cancel
Save