influxdb 区分入驻类型

@@ -3,6 +3,7 @@ package com.yohoufo.common.alarm;
 import com.alibaba.fastjson.JSONObject;
 import com.yohoufo.common.constant.InfluxdbFieldEnum;
 import com.yohoufo.common.constant.InfluxdbMeasurementEnum;
+import com.yohoufo.common.constant.InfluxdbTagEnum;
 
 import java.util.HashMap;
 import java.util.Map;
@@ -77,6 +78,11 @@ public class UfoInfluxdbVo {
             return this;
         }
 
+        public Builder addTag(InfluxdbTagEnum tagEnum, Integer value) {
+            this.tags.put(tagEnum.getTagName(), String.valueOf(value));
+            return this;
+        }
+
 
         public Builder setFields(Map<String, Object> fields) {
             this.fields = fields;

 package com.yohoufo.common.constant;
 
+import com.google.common.collect.ImmutableMap;
+import com.google.common.collect.Maps;
+
+import java.util.Map;
+
 /**
  * Created by li.ma on 2019/2/26.
  */
@@ -11,6 +16,7 @@ public enum InfluxdbMeasurementEnum {
 
     String measurement;
 
+
     InfluxdbMeasurementEnum(String measurement) {
         this.measurement = measurement;
     }
@@ -18,4 +24,5 @@ public enum InfluxdbMeasurementEnum {
     public String getMeasurement() {
         return measurement;
     }
+
 }

+package com.yohoufo.common.constant;
+
+/**
+ * Created by li.ma on 2019/3/19.
+ */
+public enum InfluxdbTagEnum {
+    TAG_TYPE("type");
+
+    String tagName;
+
+    InfluxdbTagEnum(String tagName) {
+        this.tagName = tagName;
+    }
+
+    public String getTagName() {
+        return tagName;
+    }
+}

@@ -12,6 +12,7 @@ import com.yohoufo.common.alarm.UfoInfluxdbEvent;
 import com.yohoufo.common.alarm.UfoInfluxdbVo;
 import com.yohoufo.common.constant.InfluxdbFieldEnum;
 import com.yohoufo.common.constant.InfluxdbMeasurementEnum;
+import com.yohoufo.common.constant.InfluxdbTagEnum;
 import com.yohoufo.common.exception.UfoServiceException;
 import com.yohoufo.common.utils.DateUtil;
 import com.yohoufo.dal.order.SellerEnterApplyMapper;
@@ -278,8 +279,10 @@ public class SellerEnterApplyService {
                 SellerLevelFuncBo slfb = sellerFuncService.getSellerLevelFunc(targetEst.getCode(), level);
                 storedSellerService.addUserAsStoredSeller(uid, targetEst, slfb);
 
-                EventBusPublisher.publishEvent(new UfoInfluxdbEvent(new UfoInfluxdbVo.Builder().setMeasurement(InfluxdbMeasurementEnum.MEASUREMENT_SELLER_ENTER)
-                        .addInitField(InfluxdbFieldEnum.FIELD_COUNT).build()));   // 统计入驻商家的记录
+                EventBusPublisher.publishEvent(new UfoInfluxdbEvent(new UfoInfluxdbVo.Builder()
+                        .setMeasurement(InfluxdbMeasurementEnum.MEASUREMENT_SELLER_ENTER)
+                        .addTag(InfluxdbTagEnum.TAG_TYPE, targetEst.getCode() == EntrySellerType.COMMON.getCode() ? 2 : 3)
+                        .addInitField(InfluxdbFieldEnum.FIELD_COUNT).build()));   // 统计入驻商家的记录   2代表普通入驻   3 代表超级卖家入驻
             }else{
                 logger.warn("in upgradeLevel add StoredSeller fail, uid {} orderCode {}",
                         uid, orderCode);
@@ -298,8 +301,10 @@ public class SellerEnterApplyService {
                     merchantOrderPaymentService.changeWalletToSuperSeller(uid);
                 }
 
-                EventBusPublisher.publishEvent(new UfoInfluxdbEvent(new UfoInfluxdbVo.Builder().setMeasurement(InfluxdbMeasurementEnum.MEASUREMENT_SELLER_ENTER)
-                        .addInitField(InfluxdbFieldEnum.FIELD_COUNT).build()));   // 统计入驻商家的记录
+                EventBusPublisher.publishEvent(new UfoInfluxdbEvent(new UfoInfluxdbVo.Builder()
+                        .setMeasurement(InfluxdbMeasurementEnum.MEASUREMENT_SELLER_ENTER)
+                        .addTag(InfluxdbTagEnum.TAG_TYPE, 1)
+                        .addInitField(InfluxdbFieldEnum.FIELD_COUNT).build()));   // 统计入驻商家的记录    1 代表升级
             }else{
                 logger.warn("in upgradeLevel update StoredSeller fail, uid {} orderCode {}",
                         uid, orderCode);