test: mysql&MQ

seec-oj-server/src/main/java/cn/seecoder/ojserver/controller/JudgeController.java

@@ -52,6 +52,13 @@ public class JudgeController {
         return Response.buildSuccess(judgeService.rabbit(problemId, codeJudgeVO));
     }
 
+    @PostMapping("/mysqlAndMQ")
+    public Response mysqlAndMQ(@RequestParam(value = "problemId") Integer problemId, @RequestBody CodeJudgeVO codeJudgeVO){
+        return Response.buildSuccess(judgeService.rabbit(problemId, codeJudgeVO));
+    }
+
+
+
 
 
 }

seec-oj-server/src/main/java/cn/seecoder/ojserver/service/JudgeService.java

@@ -8,4 +8,5 @@ public interface JudgeService {
     public JudgeResult asyncJudgeCode(Integer questionId, CodeJudgeVO codeJudgeVO);
     public JudgeResult syncJudgeCode(Integer questionId, CodeJudgeVO codeJudgeVO);
     public JudgeResult rabbit(Integer questionId, CodeJudgeVO codeJudgeVO);
+    public JudgeResult mysqlAndMQ(Integer questionId, CodeJudgeVO codeJudgeVO);
 }

seec-oj-server/src/main/java/cn/seecoder/ojserver/service/impl/JudgeServiceImpl.java

@@ -133,5 +133,19 @@ public class JudgeServiceImpl implements JudgeService {
         return null;
     }
 
+    @Override
+    public JudgeResult mysqlAndMQ(Integer questionId, CodeJudgeVO codeJudgeVO) {
+        Commit commit = new Commit();
+        commit.setUserId(0);
+        commit.setProblemId(questionId);
+        commit.setCode(codeJudgeVO.getCode());
+        commit.setLanguage(codeJudgeVO.getLanguage());
+        commit.setCommitTime(new Date());
+        commitDAO.save(commit);
+        CodeJudgeDTO codeJudgeDTO = new CodeJudgeDTO(commit.getId(), questionId, codeJudgeVO);
+        rabbitTemplate.convertAndSend("test_queue", codeJudgeDTO);
+        return null;
+    }
+
 
 }