clunt
/
RuoYi-Cloud
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

说明：1、修改api预警接口相关名称

This commit is contained in:
xjs 2022-01-01 18:43:24 +08:00
parent a59963be41
commit fb9fe5d648
4 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
ruoyi-api/ruoyi-api-system/src/main/java/com/xjs/business/warning/RemoteWarningCRUDFeign.java
View File

@ -24,14 +24,14 @@ import java.util.List;
public interface RemoteWarningCRUDFeign { public interface RemoteWarningCRUDFeign {
@PostMapping("apiwarning") @PostMapping("apiwarning")
public R<ApiRecord> saveApiRecord(@RequestBody ApiRecord apiRecord); public R<ApiRecord> saveApiRecordForRPC(@RequestBody ApiRecord apiRecord);
@PutMapping("apiwarning") @PutMapping("apiwarning")
public R<ApiRecord> updateApiRecord(@RequestBody ApiRecord apiRecord); public R<ApiRecord> updateApiRecordForRPC(@RequestBody ApiRecord apiRecord);
@GetMapping("apiwarning") @GetMapping("apiwarning")
R<List<ApiRecord>> selectApiRecordList(@SpringQueryMap ApiRecord apiRecord) ; R<List<ApiRecord>> selectApiRecordListForRPC(@SpringQueryMap ApiRecord apiRecord) ;

6
ruoyi-api/ruoyi-api-system/src/main/java/com/xjs/business/warning/factory/RemoteWarningCRUDFactory.java
View File

@ -24,19 +24,19 @@ public class RemoteWarningCRUDFactory implements FallbackFactory<RemoteWarningCR
public RemoteWarningCRUDFeign create(Throwable cause) { public RemoteWarningCRUDFeign create(Throwable cause) {
return new RemoteWarningCRUDFeign() { return new RemoteWarningCRUDFeign() {
@Override @Override
public R<ApiRecord> saveApiRecord(ApiRecord apiRecord) { public R<ApiRecord> saveApiRecordForRPC(ApiRecord apiRecord) {
log.error("调用预警服务添加接口失败，执行降级处理----"+apiRecord.getApiName()); log.error("调用预警服务添加接口失败，执行降级处理----"+apiRecord.getApiName());
return R.fail(); return R.fail();
} }
@Override @Override
public R<ApiRecord> updateApiRecord(ApiRecord apiRecord) { public R<ApiRecord> updateApiRecordForRPC(ApiRecord apiRecord) {
log.error("调用预警服务修改接口失败，执行降级处理----"+apiRecord.getApiName()); log.error("调用预警服务修改接口失败，执行降级处理----"+apiRecord.getApiName());
return R.fail(); return R.fail();
} }
@Override @Override
public R<List<ApiRecord>> selectApiRecordList(ApiRecord apiRecord) { public R<List<ApiRecord>> selectApiRecordListForRPC(ApiRecord apiRecord) {
log.error("调用预警服务查询接口失败，执行降级处理----"+apiRecord.getApiName()); log.error("调用预警服务查询接口失败，执行降级处理----"+apiRecord.getApiName());
return R.fail(); return R.fail();
} }

2
xjs-business/xjs-business-openapi/src/main/java/com/xjs/common/aop/ApiLogAspect.java
View File

@ -162,7 +162,7 @@ public class ApiLogAspect {
remoteWarningCRUDFeign.updateApiRecord(haveApiRecord); remoteWarningCRUDFeign.updateApiRecord(haveApiRecord);
//判断接口请求是否超过阈值 //判断接口请求是否超过阈值
if (haveApiRecord.getDayCount() > haveApiRecord.getLimitCount()) { if (haveApiRecord.getDayCount() > haveApiRecord.getLimitCount()) {
//TODO 把记录添加到预警表中 //TODO 把记录添加到预警表中，表还没设计
} }

6
xjs-business/xjs-business-warning/src/main/java/com/xjs/controller/ApiWarningController.java
View File

@ -28,7 +28,7 @@ public class ApiWarningController extends BaseController {
* @return apiRecord * @return apiRecord
*/ */
@PostMapping @PostMapping
public R<ApiRecord> saveApiRecord(@RequestBody ApiRecord apiRecord) { public R<ApiRecord> saveApiRecordForRPC(@RequestBody ApiRecord apiRecord) {
return apiWarningService.saveApiRecord(apiRecord) ? R.ok() : R.fail(); return apiWarningService.saveApiRecord(apiRecord) ? R.ok() : R.fail();
} }
@ -39,12 +39,12 @@ public class ApiWarningController extends BaseController {
* @return ApiRecord * @return ApiRecord
*/ */
@PutMapping @PutMapping
public R<ApiRecord> updateApiRecord(@RequestBody ApiRecord apiRecord) { public R<ApiRecord> updateApiRecordForRPC(@RequestBody ApiRecord apiRecord) {
return apiWarningService.updateApiRecord(apiRecord) ? R.ok() : R.fail(); return apiWarningService.updateApiRecord(apiRecord) ? R.ok() : R.fail();
} }
@GetMapping @GetMapping
public R<List<ApiRecord>> selectApiRecordList(ApiRecord apiRecord) { public R<List<ApiRecord>> selectApiRecordListForRPC(ApiRecord apiRecord) {
List<ApiRecord> apiRecords = apiWarningService.selectApiRecordList(apiRecord); List<ApiRecord> apiRecords = apiWarningService.selectApiRecordList(apiRecord);
return R.ok(apiRecords); return R.ok(apiRecords);
} }