From a00400cf9f975a7dbccf3436cf3b57c1fb476597 Mon Sep 17 00:00:00 2001 From: 1 <1> Date: 星期三, 15 十月 2025 09:15:45 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/utils/PostMesDataUtils.java | 71 ++++++++++++++++++++++++++++------- 1 files changed, 57 insertions(+), 14 deletions(-) diff --git a/src/main/java/com/zy/asrs/utils/PostMesDataUtils.java b/src/main/java/com/zy/asrs/utils/PostMesDataUtils.java index 00d53fa..6fd078e 100644 --- a/src/main/java/com/zy/asrs/utils/PostMesDataUtils.java +++ b/src/main/java/com/zy/asrs/utils/PostMesDataUtils.java @@ -2,14 +2,19 @@ import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; +import com.baomidou.mybatisplus.mapper.EntityWrapper; +import com.core.common.Cools; import com.core.common.SpringUtils; import com.core.exception.CoolException; +import com.zy.asrs.entity.ApiLog; import com.zy.asrs.service.ApiLogService; import com.zy.asrs.utils.core.AbstractHandler; import com.zy.asrs.utils.core.ReturnT; import com.zy.common.utils.HttpHandler; +import com.zy.core.model.protocol.StaProtocol; import lombok.extern.slf4j.Slf4j; +import java.util.Date; import java.util.Map; @Slf4j @@ -84,7 +89,7 @@ success = true; } else { log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", URL+"/"+mesPath, JSON.toJSONString(combParam), response); - throw new CoolException("涓婃姤"+name); + throw new CoolException(name); } } catch (Exception e) { log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", URL+"/"+mesPath, JSON.toJSONString(combParam), response); @@ -92,17 +97,21 @@ return FAIL.setMsg(e.getMessage()); } finally { try { - // 淇濆瓨鎺ュ彛鏃ュ織 - ApiLogService apiLogService = SpringUtils.getBean(ApiLogService.class); - apiLogService.save( - "涓婃姤"+name, - URL +"/"+ mesPath, - null, - "127.0.0.1", - JSON.toJSONString(combParam), - response, - success - ); + if (success){ + // 淇濆瓨鎺ュ彛鏃ュ織 + ApiLogService apiLogService = SpringUtils.getBean(ApiLogService.class); + apiLogService.save( + name, + URL +"/"+ mesPath, + null, + "127.0.0.1", + JSON.toJSONString(combParam), + response, + success + ); + } else { + postMesDataCallApiLogSave(response,success,name, URL, mesPath, combParam); + } } catch (Exception e) { log.error("", e); } } @@ -135,7 +144,7 @@ success = true; } else { log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", URL+"/"+mesPath, JSON.toJSONString(combParam), response); - throw new CoolException("涓婃姤"+name); + throw new CoolException(name); } } catch (Exception e) { log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", URL+"/"+mesPath, JSON.toJSONString(combParam), response); @@ -146,7 +155,7 @@ // 淇濆瓨鎺ュ彛鏃ュ織 ApiLogService apiLogService = SpringUtils.getBean(ApiLogService.class); apiLogService.save( - "涓婃姤"+name, + name, URL +"/"+ mesPath, null, "127.0.0.1", @@ -160,4 +169,38 @@ } return SUCCESS; } + + + + + + + public void postMesDataCallApiLogSave(String response,boolean success,String name, String URL, String mesPath, Object combParam) { + ApiLogService apiLogService = SpringUtils.getBean(ApiLogService.class); + + ApiLog apiLog = apiLogService.selectOne(new EntityWrapper<ApiLog>() + .eq("namespace", name) + .eq("response", response) + .eq("url", URL +"/"+ mesPath) + .eq("result", success? 1:0) + .orderBy("create_time", false) + ); + + if (!Cools.isEmpty(apiLog)){ + long parseLong = Long.parseLong(apiLog.getTimestamp()); + if (new Date().getTime()-parseLong<5*1000*60){ + return; + } + } + // 淇濆瓨鎺ュ彛鏃ュ織 + apiLogService.save( + name, + URL +"/"+ mesPath, + null, + "127.0.0.1", + JSON.toJSONString(combParam), + response, + success + ); + } } -- Gitblit v1.9.1