Merge branch 'feature/xgh/20241月迭代' into 'master'

加好友统计

See merge request !1687

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/util/InfluxDbMonitorUtils.java

 package com.gic.haoban.manage.service.util;
 
+import com.ctrip.framework.apollo.Config;
+import com.ctrip.framework.apollo.ConfigService;
 import com.gic.haoban.manage.service.pojo.HBQwMonitorBO;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
@@ -29,6 +31,14 @@ public class InfluxDbMonitorUtils {
 
     private static volatile InfluxDbMonitorUtils instance = null;
 
+    private static boolean isDev = false;
+    static {
+        Config config = ConfigService.getConfig("COMMON.gic-properties");
+        String env = config.getProperty("environment.value", "");
+        isDev = !"prod".equals(env);
+    }
+
+
     public static InfluxDbMonitorUtils getInstance() {
         if (instance == null) {
             synchronized (InfluxDbMonitorUtils.class) {
@@ -55,7 +65,11 @@ public class InfluxDbMonitorUtils {
     }
 
     public void friendAdd(HBQwMonitorBO bo) {
-        influxDB.write(Point.measurement("hb_qw_friend_monitor")
+        String tb = "hb_qw_friend_monitor" ;
+        if(isDev) {
+            tb = "hb_qw_friend_monitor_dev" ;
+        }
+        influxDB.write(Point.measurement(tb)
                 .time(System.currentTimeMillis(), TimeUnit.MILLISECONDS)
                 .addField("num", bo.getNum())
                  .addField("failNum",bo.getFailNum())