测试入influxdb的代码

mali
Commit 1acf36a821935729031c0b1e5397076505a8785d 1 parent a53e269c
Showing 1 changed file with 8 additions and 0 deletions
order/src/main/java/com/yohoufo/order/controller/SellerOrderController.java
--- a/order/src/main/java/com/yohoufo/order/controller/SellerOrderController.java
View file @1acf36a
+++ b/order/src/main/java/com/yohoufo/order/controller/SellerOrderController.java
View file @1acf36a
@@ -5,8 +5,13 @@ import com.yohobuy.ufo.model.order.common.TabType;
 import com.yohobuy.ufo.model.order.req.*;
 import com.yohobuy.ufo.model.order.resp.*;
 import com.yohoufo.common.ApiResponse;
+import com.yohoufo.common.alarm.EventBusPublisher;
+import com.yohoufo.common.alarm.UfoInfluxdbEvent;
+import com.yohoufo.common.alarm.UfoInfluxdbVo;
 import com.yohoufo.common.annotation.IgnoreSession;
 import com.yohoufo.common.annotation.IgnoreSignature;
+import com.yohoufo.common.constant.InfluxdbFieldEnum;
+import com.yohoufo.common.constant.InfluxdbMeasurementEnum;
 import com.yohoufo.common.exception.GatewayException;
 import com.yohoufo.dal.order.model.SellerOrder;
 import com.yohoufo.order.model.request.OrderListRequest;
@@ -91,6 +96,9 @@ public class SellerOrderController {
                                   @RequestParam(name="address_id")String address_id,
                                   @RequestParam(name="num", defaultValue = "1", required = false)int num,
                                   @RequestParam(name="skupType", defaultValue = DEFAULT_SKUP_TYPE, required = false) Integer skupType) throws GatewayException {
+        EventBusPublisher.publishEvent(new UfoInfluxdbEvent(new UfoInfluxdbVo.Builder().setMeasurement(InfluxdbMeasurementEnum.MEASUREMENT_ORDER_CANCEL)
+                .addInitField(InfluxdbFieldEnum.FIELD_COUNT).build()));   // 统计取消订单的次数
+
         SellerOrderSubmitReq req = SellerOrderSubmitReq.builder()
                 .uid(uid)
                 .storageId(storage_id)