代码修改

release
xuliangwei 2 years ago
parent d329bc7239
commit 37d0fca87b
  1. 7
      dxhy-erp/src/main/java/com/dxhy/erp/controller/RequestRecallController.java
  2. 2
      dxhy-erp/src/main/java/com/dxhy/erp/service/impl/RequestRecordServiceImpl.java

@ -1,5 +1,6 @@
package com.dxhy.erp.controller; package com.dxhy.erp.controller;
import com.alibaba.fastjson.JSONObject;
import com.dxhy.common.controller.AbstractController; import com.dxhy.common.controller.AbstractController;
import com.dxhy.erp.entity.RequestRecord; import com.dxhy.erp.entity.RequestRecord;
import com.dxhy.erp.service.RequestRecordService; import com.dxhy.erp.service.RequestRecordService;
@ -25,7 +26,11 @@ public class RequestRecallController extends AbstractController {
@ApiOperation(value = "重调接口入口", notes = "重调接口入口") @ApiOperation(value = "重调接口入口", notes = "重调接口入口")
@RequestMapping(path = "/requestRecordRecall", method = {RequestMethod.POST}) @RequestMapping(path = "/requestRecordRecall", method = {RequestMethod.POST})
public ResponseEntity<?> recall(RequestRecord requestRecord) { public ResponseEntity<?> recall(RequestRecord requestRecord) {
return requestRecordService.reCall(requestRecord); log.info("重调用接口调用开始");
log.info("重调用接口入参:{}", JSONObject.toJSONString(requestRecord));
ResponseEntity responseEntity = requestRecordService.reCall(requestRecord);
log.info("重调用接口调用结束,返回参数:{}", JSONObject.toJSONString(responseEntity));
return responseEntity;
} }

@ -118,6 +118,7 @@ public class RequestRecordServiceImpl extends MpBaseServiceImpl<RequestRecordDao
public ResponseEntity<?> reCall(RequestRecord requestRecord) { public ResponseEntity<?> reCall(RequestRecord requestRecord) {
DynamicContextHolder.push(dbname+DbConstant.BUSINESS_READ); DynamicContextHolder.push(dbname+DbConstant.BUSINESS_READ);
RequestRecord dbRecord = requestRecordDao.selectById(requestRecord.getId()); RequestRecord dbRecord = requestRecordDao.selectById(requestRecord.getId());
log.info("数据库匹配信息:{}", JSONObject.toJSONString(dbRecord));
if (dbRecord != null && !dbRecord.getRequestDetail().equals(requestRecord.getRequestDetail()) if (dbRecord != null && !dbRecord.getRequestDetail().equals(requestRecord.getRequestDetail())
&& !dbRecord.getResponseDetail().equals(requestRecord.getResponseDetail()) && !dbRecord.getResponseDetail().equals(requestRecord.getResponseDetail())
&& !dbRecord.getMethodName().equals(dbRecord.getMethodName())) { && !dbRecord.getMethodName().equals(dbRecord.getMethodName())) {
@ -128,6 +129,7 @@ public class RequestRecordServiceImpl extends MpBaseServiceImpl<RequestRecordDao
} }
RequestRecordEnum[] RequestRecordEnums = RequestRecordEnum.values(); RequestRecordEnum[] RequestRecordEnums = RequestRecordEnum.values();
log.info("获取到的枚举类型:{}",JSONObject.toJSONString(RequestRecordEnums));
for (RequestRecordEnum recordenum : RequestRecordEnums) { for (RequestRecordEnum recordenum : RequestRecordEnums) {
if (recordenum.getMethodName().equals(dbRecord.getActiveCall())) { if (recordenum.getMethodName().equals(dbRecord.getActiveCall())) {
snPushCheckRecordService = (SNPushCheckRecordService)applicationContext.getBean(recordenum.getClassName()); snPushCheckRecordService = (SNPushCheckRecordService)applicationContext.getBean(recordenum.getClassName());

Loading…
Cancel
Save