浏览代码

场景计算统计

dsx 2 年之前
父节点
当前提交
7e38b7f74c

+ 13 - 0
src/main/java/com/fdkankan/job/controller/SceneBuildProcessLogController.java

@@ -1,6 +1,10 @@
 package com.fdkankan.job.controller;
 
 
+import com.fdkankan.job.job.SceneCallCountHandler;
+import com.fdkankan.web.response.ResultData;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 
 import org.springframework.web.bind.annotation.RestController;
@@ -17,5 +21,14 @@ import org.springframework.web.bind.annotation.RestController;
 @RequestMapping("/job/sceneBuildProcessLog")
 public class SceneBuildProcessLogController {
 
+    @Autowired
+    SceneCallCountHandler sceneCallCountHandler;
+
+    @GetMapping("test")
+    public ResultData test() throws Exception {
+        sceneCallCountHandler.sceneCallCountHandler();
+        return ResultData.ok();
+    }
+
 }
 

+ 14 - 2
src/main/java/com/fdkankan/job/job/SceneCallCountHandler.java

@@ -69,7 +69,7 @@ public class SceneCallCountHandler {
             "**错误日志**: %s";
 
     @XxlJob("sceneCallCountHandler")
-    private void sceneCallCountHandler() throws Exception {
+    public void sceneCallCountHandler() throws Exception {
         XxlJobHelper.log("sceneCallCountHandler start.....");
 
         Date time = Calendar.getInstance().getTime();
@@ -124,7 +124,19 @@ public class SceneCallCountHandler {
             errorMsg.append(v3ErrorMsg);
         }
 
-        String ddMsg = String.format(DINGTALK_MSG_PATTERN, DateExtUtil.format(time, DateExtUtil.dateStyle4),
+        String envName = "";
+        if(env.equals("gn")){
+            envName = "国内";
+        }
+        if(env.equals("eur")){
+            envName = "国际";
+        }
+        if(env.equals("jp")){
+            envName = "日本";
+        }
+        String ddMsg = String.format(
+                DINGTALK_MSG_PATTERN, DateExtUtil.format(time, DateExtUtil.dateStyle4),
+                envName,
                 v4Count, v4success, v4Fail, v4Waiting,
                 v3Msg,
                 errorMsg);