|
|
@@ -2,6 +2,7 @@ package cn.seecoder.ojserver.service.impl;
|
|
|
|
|
|
import cn.seecoder.codejudge.client.JudgeDTO;
|
|
|
import cn.seecoder.codejudge.client.JudgeResult;
|
|
|
+import cn.seecoder.ojserver.asyncPost.MQConsumer;
|
|
|
import cn.seecoder.ojserver.dao.entity.Problem;
|
|
|
import cn.seecoder.ojserver.dao.entity.TestCase;
|
|
|
import cn.seecoder.ojserver.exception.ThirdPartyServiceException;
|
|
|
@@ -9,13 +10,19 @@ import cn.seecoder.ojserver.manager.JudgeManager;
|
|
|
import cn.seecoder.ojserver.manager.QuestionManager;
|
|
|
import cn.seecoder.ojserver.model.vo.CodeJudgeVO;
|
|
|
import cn.seecoder.ojserver.service.JudgeService;
|
|
|
+import cn.seecoder.ojserver.utils.PostHelper;
|
|
|
+import com.alibaba.fastjson.JSONObject;
|
|
|
import com.nju.edu.paasMonitorClient.MonitorClient;
|
|
|
import com.nju.edu.paasMonitorClient.entity.Call;
|
|
|
import com.nju.edu.paasMonitorCommon.enums.SeecSystem;
|
|
|
+import okhttp3.*;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
+import com.alibaba.fastjson.JSON;
|
|
|
|
|
|
+import java.io.IOException;
|
|
|
import java.util.List;
|
|
|
import java.util.Map;
|
|
|
+import java.util.concurrent.TimeUnit;
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
@Service
|
|
|
@@ -31,7 +38,7 @@ public class JudgeServiceImpl implements JudgeService {
|
|
|
@Override
|
|
|
public JudgeResult judgeCode(Integer questionId, CodeJudgeVO codeJudgeVO) {
|
|
|
try {
|
|
|
- Call call = MonitorClient.createCall(SeecSystem.CODER,"ojtest1","buildJudge");
|
|
|
+ Call call = MonitorClient.createCall(SeecSystem.CODER,"ojtest119","buildJudge");
|
|
|
call.start();
|
|
|
JudgeDTO judgeDTO = new JudgeDTO();
|
|
|
judgeDTO.setCode(codeJudgeVO.getCode());
|
|
|
@@ -45,14 +52,10 @@ public class JudgeServiceImpl implements JudgeService {
|
|
|
judgeDTO.setInputList(inputList);
|
|
|
judgeDTO.setOutputList(outputList);
|
|
|
call.end();
|
|
|
-// judgeDTO.setInputList(question.getInputOutputMapping().entrySet().stream().map(Map.Entry<String, String>::getKey).collect(Collectors.toList()));
|
|
|
-// judgeDTO.setOutputList(question.getInputOutputMapping().entrySet().stream().map(Map.Entry<String, String>::getValue).collect(Collectors.toList()));
|
|
|
|
|
|
return judgeManager.judgeCodeQuestionAnswers(judgeDTO);
|
|
|
} catch (ThirdPartyServiceException exception) {
|
|
|
throw exception;
|
|
|
}
|
|
|
-
|
|
|
-
|
|
|
}
|
|
|
}
|