ak/zn-cloud-wcs
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

还原日志

Browse Source
This commit is contained in:
cbs 2025-03-27 17:11:55 +08:00
parent 3d8b30c739
commit f39b075104
3 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
yudao-framework/yudao-spring-boot-starter-web/src/main/java/cn/iocoder/yudao/framework/apilog/core/interceptor/ApiAccessLogInterceptor.java
View File

@ -45,12 +45,12 @@ public class ApiAccessLogInterceptor implements HandlerInterceptor {
if (!SpringUtils.isProd()) { if (!SpringUtils.isProd()) {
Map<String, String> queryString = ServletUtils.getParamMap(request); Map<String, String> queryString = ServletUtils.getParamMap(request);
String requestBody = ServletUtils.isJsonRequest(request) ? ServletUtils.getBody(request) : null; String requestBody = ServletUtils.isJsonRequest(request) ? ServletUtils.getBody(request) : null;
/*if (CollUtil.isEmpty(queryString) && StrUtil.isEmpty(requestBody)) { if (CollUtil.isEmpty(queryString) && StrUtil.isEmpty(requestBody)) {
log.info("[preHandle][开始请求 URL({}) 无参数]", request.getRequestURI()); log.info("[preHandle][开始请求 URL({}) 无参数]", request.getRequestURI());
} else { } else {
log.info("[preHandle][开始请求 URL({}) 参数({})]", request.getRequestURI(), log.info("[preHandle][开始请求 URL({}) 参数({})]", request.getRequestURI(),
StrUtil.blankToDefault(requestBody, queryString.toString())); StrUtil.blankToDefault(requestBody, queryString.toString()));
}*/ }
// 计时 // 计时
StopWatch stopWatch = new StopWatch(); StopWatch stopWatch = new StopWatch();
stopWatch.start(); stopWatch.start();
@ -67,8 +67,8 @@ public class ApiAccessLogInterceptor implements HandlerInterceptor {
if (!SpringUtils.isProd()) { if (!SpringUtils.isProd()) {
StopWatch stopWatch = (StopWatch) request.getAttribute(ATTRIBUTE_STOP_WATCH); StopWatch stopWatch = (StopWatch) request.getAttribute(ATTRIBUTE_STOP_WATCH);
stopWatch.stop(); stopWatch.stop();
/* log.info("[afterCompletion][完成请求 URL({}) 耗时({} ms)]", log.info("[afterCompletion][完成请求 URL({}) 耗时({} ms)]",
request.getRequestURI(), stopWatch.getTotalTimeMillis());*/ request.getRequestURI(), stopWatch.getTotalTimeMillis());
} }
} }

4
yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/api/robot/RequestProcessor.java
View File

@ -25,7 +25,7 @@ public class RequestProcessor {
public RequestProcessor() { public RequestProcessor() {
// 每秒执行一次 - 处理并发送数据 - 避免数据丢失 // 每秒执行一次 - 处理并发送数据 - 避免数据丢失
scheduler.scheduleAtFixedRate(this::processAndSend, 1000, 1000, TimeUnit.MILLISECONDS); scheduler.scheduleAtFixedRate(this::processAndSend, 300, 300, TimeUnit.MILLISECONDS);
} }
public void handleRequest(String map, String mac, String data) { public void handleRequest(String map, String mac, String data) {
@ -46,7 +46,7 @@ public class RequestProcessor {
private void sendData(String map, Map<String, String> data) { private void sendData(String map, Map<String, String> data) {
// -- 发送给对应的websocket // -- 发送给对应的websocket
// System.out.println("key:" + map + "发送数据：" + data); // System.out.println("key:" + map + "发送数据：" + data);
log.info("key:" + map + "发送数据：" + JSON.toJSONString(data)); log.info("key:" + map + "发送数据：" + data);
webSocketSenderApi.sendObject(map, "map_push", data); webSocketSenderApi.sendObject(map, "map_push", data);
} }

2
yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/api/robot/RobotStatusApiImpl.java
View File

@ -62,7 +62,7 @@ public class RobotStatusApiImpl implements RobotStatusApi {
* @return * @return
*/ */
@Override @Override
@SystemRateLimiter(time = 1, count = 1, keyArg = "robotStatusUpdate",message = "机器人上报点位超过限流") @SystemRateLimiter(time = 1, count = 150, keyArg = "robotStatusUpdate",message = "机器人上报点位超过限流")
public void robotStatusUpdate(RobotPoseStatusDTO robotStatusDataDTO) { public void robotStatusUpdate(RobotPoseStatusDTO robotStatusDataDTO) {
updateRobotPosed(robotStatusDataDTO); updateRobotPosed(robotStatusDataDTO);
} }