|
@@ -229,11 +229,11 @@ public class MarkLogAop {
|
|
|
if (levelConfig.isAutoCallback()) {//为true则自动打回
|
|
|
List<MarkTask> markTasks = markTaskRepo.findByPaperIdAndStage(paper.getId(), markStage);
|
|
|
Map<Long, String> levelsMap = markTasks.stream().collect(Collectors.toMap(MarkTask::getMarkerId, o -> o.getResult().toUpperCase()));
|
|
|
- LOGGER.info("this:{},markLogAop异步回调进来了", this);
|
|
|
+ LOGGER.info("this:{} markLogAop异步回调进来了", this);
|
|
|
arbitrateCallback.judge(levelsMap, markingConfig.getDeviation(), new ArbitrateResult() {
|
|
|
@Override
|
|
|
public void callback(List<ArbitrateCallback.Distance> list) {
|
|
|
- LOGGER.info("this:{},callback markLogAop异步回调进来了", this);
|
|
|
+ LOGGER.info("this:{} callback markLogAop异步回调进来了", this);
|
|
|
String operResult = DEFAULT_RESULT;
|
|
|
//全部打回则不触发自动仲裁
|
|
|
if (Objects.nonNull(list) && list.size() > 0 && markTasks.size() != list.size()) {
|
|
@@ -259,10 +259,10 @@ public class MarkLogAop {
|
|
|
paperRepo.save(paper);
|
|
|
markLogRepo.save(markLogList);
|
|
|
}
|
|
|
- LOGGER.info("this:{},callback markLogAop异步回调结束了", this);
|
|
|
+ LOGGER.info("this:{} callback markLogAop异步回调结束了", this);
|
|
|
}
|
|
|
});
|
|
|
- LOGGER.info("this:{},markLogAop异步回调结束了", this);
|
|
|
+ LOGGER.info("this:{} markLogAop异步回调结束了", this);
|
|
|
}
|
|
|
}
|
|
|
//20191107wangliang加入仲裁自动打回算法 end
|