优化标签埋点数据统计

config-server/src/main/resources/shared/prec-service-dev.yml

@@ -59,11 +59,11 @@ spring:
         outputBiLog:
           destination: myBiLog
         #          contentType: text/plain      # 实体 json string 在传递的类型装换 查看 http://docs.spring
-        outputPoint:
-          destination: myPoint
+        outputStatisti:
+          destination: myStatisti
           #          contentType: text/plain      # 实体 json string 在传递的类型装换 查看 http://docs.spring
-        inputPoint:
-          destination: myPoint
+        inputStatisti:
+          destination: myStatisti
           group: pointReceiveGroup
   #mq
   rabbitmq:

config-server/src/main/resources/shared/prec-service-local.yml

@@ -59,11 +59,11 @@ spring:
         outputBiLog:
           destination: myBiLog
           #          contentType: text/plain      # 实体 json string 在传递的类型装换 查看 http://docs.spring
-        outputPoint:
-          destination: myPoint
+        outputStatisti:
+          destination: myStatisti
           #          contentType: text/plain      # 实体 json string 在传递的类型装换 查看 http://docs.spring
-        inputPoint:
-          destination: myPoint
+        inputStatisti:
+          destination: myStatisti
           group: pointReceiveGroup
 
   #mq

config-server/src/main/resources/shared/prec-service-pre.yml

@@ -59,11 +59,11 @@ spring:
         outputBiLog:
           destination: myBiLog
         #          contentType: text/plain      # 实体 json string 在传递的类型装换 查看 http://docs.spring
-        outputPoint:
-          destination: myPoint
+        outputStatisti:
+          destination: myStatisti
           #          contentType: text/plain      # 实体 json string 在传递的类型装换 查看 http://docs.spring
-        inputPoint:
-          destination: myPoint
+        inputStatisti:
+          destination: myStatisti
           group: pointReceiveGroup
   #mq
   rabbitmq:

config-server/src/main/resources/shared/prec-service-pro.yml

@@ -59,11 +59,11 @@ spring:
         outputBiLog:
           destination: myBiLog
         #          contentType: text/plain      # 实体 json string 在传递的类型装换 查看 http://docs.spring
-        outputPoint:
-          destination: myPoint
+        outputStatisti:
+          destination: myStatisti
           #          contentType: text/plain      # 实体 json string 在传递的类型装换 查看 http://docs.spring
-        inputPoint:
-          destination: myPoint
+        inputStatisti:
+          destination: myStatisti
           group: pointReceiveGroup
   #mq
   rabbitmq:

config-server/src/main/resources/shared/prec-service-test.yml

@@ -59,11 +59,11 @@ spring:
         outputBiLog:
           destination: myBiLog
         #          contentType: text/plain      # 实体 json string 在传递的类型装换 查看 http://docs.spring
-        outputPoint:
-          destination: myPoint
+        outputStatisti:
+          destination: myStatisti
           #          contentType: text/plain      # 实体 json string 在传递的类型装换 查看 http://docs.spring
-        inputPoint:
-          destination: myPoint
+        inputStatisti:
+          destination: myStatisti
           group: pointReceiveGroup
   #mq
   rabbitmq:

prec-service/src/main/java/com/diagbot/rabbit/MyProcessor.java

@@ -30,12 +30,12 @@ public interface MyProcessor {
     @Output(OUTPUT_BI_LOG)
     MessageChannel outputBiLog();
 
-    String INPUT_POINT = "inputPoint";
-    String OUTPUT_POINT = "outputPoint";
+    String INPUT_STATISTI = "inputStatisti";
+    String OUTPUT_STATISTI = "outputStatisti";
 
-    @Input(INPUT_POINT)
-    SubscribableChannel inputPoint();
+    @Input(INPUT_STATISTI)
+    SubscribableChannel inputStatisti();
 
-    @Output(OUTPUT_POINT)
-    MessageChannel outputPoint();
+    @Output(OUTPUT_STATISTI)
+    MessageChannel outputStatisti();
 }

prec-service/src/main/java/com/diagbot/rabbit/MyReceiver.java

@@ -17,7 +17,7 @@ public class MyReceiver {
     @Autowired
     StatisticalFacade statisticalFacade;
 
-    @StreamListener(MyProcessor.INPUT_POINT)
+    @StreamListener(MyProcessor.INPUT_STATISTI)
     public void inputPoint(String message) {
         System.out.println("Received <" + "数据埋点数据" + ">");
         StatisticalVO statisticalVO = GsonUtil.toObject(message, StatisticalVO.class);

prec-service/src/main/java/com/diagbot/rabbit/MySender.java

@@ -36,10 +36,10 @@ public class MySender {
     }
 
     @Autowired
-    @Qualifier("outputPoint")
-    MessageChannel outputPoint;
+    @Qualifier("outputStatisti")
+    MessageChannel outputStatisti;
 
-    public void outputPointSend(StatisticalVO statisticalVO) {
-        outputPoint.send(MessageBuilder.withPayload(GsonUtil.toJson(statisticalVO)).build());
+    public void outputStatistiSend(StatisticalVO statisticalVO) {
+        outputStatisti.send(MessageBuilder.withPayload(GsonUtil.toJson(statisticalVO)).build());
     }
 }

prec-service/src/main/java/com/diagbot/web/StatisticalController.java

@@ -36,14 +36,21 @@ public class StatisticalController {
     StatisticalFacade statisticalFacade;
 
 
-    @ApiOperation(value = "标签数据埋点统计保存[by:wangfeng]", notes = "标签数据埋点统计保存")
-    @PostMapping("/saveStatisticals")
-    @SysLogger("saveStatisticals")
+    @ApiOperation(value = "标签数据埋点统计异步保存[by:wangfeng]", notes = "标签数据埋点统计异步保存")
+    @PostMapping("/saveBuriedSome")
+    @SysLogger("saveBuriedSome")
     @Transactional
     public RespDTO<Boolean> saveBuriedSomeStatisticals(@Valid @RequestBody StatisticalVO statisticalVO) {
-        mySender.outputPointSend(statisticalVO);
-        //boolean res =  statisticalFacade.saveStatistical(statisticalVO);
+        mySender.outputStatistiSend(statisticalVO);
         return RespDTO.onSuc(true);
     }
 
+    @ApiOperation(value = "标签数据埋点统计保存[by:wangfeng]", notes = "标签数据埋点统计保存")
+    @PostMapping("/saveStatisticals")
+    @SysLogger("saveStatisticals")
+    @Transactional
+    public RespDTO<Boolean> saveStatisticals(@Valid @RequestBody StatisticalVO statisticalVO) {
+        boolean res =  statisticalFacade.saveStatistical(statisticalVO);
+        return RespDTO.onSuc(res);
+    }
 }