新增bug pool transfer接口

src/main/java/cn/qg/holmes/controller/effect/EffectController.java

@@ -3,13 +3,16 @@ package cn.qg.holmes.controller.effect;
 import cn.qg.holmes.common.JsonResult;
 import cn.qg.holmes.entity.effect.ClearCache;
 import cn.qg.holmes.entity.quality.DingRobot;
+import cn.qg.holmes.entity.quality.JiraBugPool;
 import cn.qg.holmes.entity.quality.SubmitTestInstruction;
 import cn.qg.holmes.service.effect.ClearCacheService;
 import cn.qg.holmes.service.quality.DingRobotService;
+import cn.qg.holmes.service.quality.JiraBugPoolService;
 import cn.qg.holmes.service.quality.SubmitTestInstructionService;
 import cn.qg.holmes.utils.HttpClientUtils;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -18,6 +21,7 @@ import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import javax.xml.transform.Result;
 import java.util.*;
 
 @Slf4j
@@ -34,6 +38,10 @@ public class EffectController {
 
     @Autowired
     SubmitTestInstructionService submitTestInstructionService;
+
+    @Autowired
+    JiraBugPoolService jiraBugPoolService;
+
     /**
      * 获取清缓存实体列表
      * @return
@@ -67,7 +75,9 @@ public class EffectController {
     @GetMapping("/qa/transfer")
     public JsonResult transferData() {
         String doraemonUrl = "https://doraemon.quantgroups.cn/qa/process/transfer";
-        List<DingRobot> dingRobotList = dingRobotService.list();
+        QueryWrapper<DingRobot> queryWrapper = new QueryWrapper<>();
+        queryWrapper.orderByAsc("id");
+        List<DingRobot> dingRobotList = dingRobotService.list(queryWrapper);
         for (DingRobot dingRobot: dingRobotList) {
             JSONObject jsonObject = new JSONObject();
             jsonObject.put("projectName", dingRobot.getProjectName());
@@ -180,4 +190,32 @@ public class EffectController {
         }
         return JsonResult.buildSuccessResult("trasnfer成功");
     }
+
+    @GetMapping("/bug/transfer")
+    public JsonResult bugTransfer() {
+        String doraemonUrl = "https://doraemon.quantgroups.cn/qa/bug/transfer";
+//        String doraemonUrl = "http://localhost:8086/qa/bug/transfer";
+        QueryWrapper<JiraBugPool> queryWrapper = new QueryWrapper<>();
+        queryWrapper.orderByAsc("id");
+        List<JiraBugPool> jiraBugPoolList = jiraBugPoolService.list(queryWrapper);
+        for (JiraBugPool jiraBugPool: jiraBugPoolList) {
+            JSONObject jsonObject = new JSONObject();
+            jsonObject.put("id", jiraBugPool.getId());
+            jsonObject.put("key", jiraBugPool.getKey());
+            jsonObject.put("summary", jiraBugPool.getSummary());
+            jsonObject.put("priority", jiraBugPool.getPriority());
+            jsonObject.put("reporter", jiraBugPool.getReporter());
+            jsonObject.put("assignee", jiraBugPool.getAssignee());
+            jsonObject.put("url", jiraBugPool.getUrl());
+            jsonObject.put("dingUrl", jiraBugPool.getDingUrl());
+            jsonObject.put("processId", jiraBugPool.getDingRobotId());
+            jsonObject.put("enable", jiraBugPool.getEnable());
+            jsonObject.put("createTime", jiraBugPool.getCreateTime());
+            jsonObject.put("updateTime", jiraBugPool.getUpdateTime());
+
+            String response = HttpClientUtils.doPostJson(doraemonUrl, null, jsonObject.toJSONString());
+            log.info(response);
+        }
+        return JsonResult.buildSuccessResult("bug数据清洗完毕");
+    }
 }