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