chen 5 лет назад
Родитель
Сommit
36f7f07020

+ 1 - 1
ssj-kmt-exercise-service-impl/src/main/java/com/ssj/service/kmt/kmt/service/impl/KmtExerciseQuestionDealServiceImpl.java

@@ -209,7 +209,7 @@ public class KmtExerciseQuestionDealServiceImpl implements KmtExerciseQuestionDe
         kmtExerciseQuestion.setExerciseBookId(nextQuestion.getExerciseBookId());
         kmtExerciseQuestion.setHandlerSubmitTime(DateUtil.parse_yyyyMMddHHmmss("1970-01-01 00:00:01"));
         kmtExerciseQuestion.setQuestionPath(nextQuestion.getQuestionPath().substring(0, nextQuestion.getQuestionPath().lastIndexOf("/")) + "/" + newQuestionId + ".json");
-        logger.error(JSON.toJSONString(kmtExerciseQuestion));
+//        logger.error(JSON.toJSONString(kmtExerciseQuestion));
         kmtExerciseQuestion = kmtExerciseQuestionService.save(kmtExerciseQuestion);
         if (request.getQuestionClassType() == 2 && StringUtil.isBlank(nextQuestion.getParentId())) {
             kmtExerciseMapper.updateParentIdAndClassType(kmtExerciseQuestion.getId(), 2, book.getBookId(), request.getNum());

+ 2 - 1
ssj-kmt-exercise-service-impl/src/main/java/com/ssj/service/task/SyncSaveExerciseBookCourseTask.java

@@ -44,7 +44,7 @@ public class SyncSaveExerciseBookCourseTask extends Task {
     @Override
     public void run() {
         try {
-            Thread.sleep(2000);
+            logger.info("同步课时开始");
             List<KmtExerciseQuestion> kmtExerciseQuestions = kmtExerciseMapper.findByBookCourseId(this.bookCourseId);
             this.appendQuestionDataFromJSONFile(kmtExerciseQuestions);
             for (KmtExerciseQuestion kmtExerciseQuestion : kmtExerciseQuestions){
@@ -70,6 +70,7 @@ public class SyncSaveExerciseBookCourseTask extends Task {
                 }
                 exerciseQuestionSearchService.insertOrUpdateBatch("kmt_exercise_question_know", elasticEntityList);
             }
+            logger.info("同步课时结束");
         } catch (Exception e){
             logger.error("异步保存es异常", e);
         }

+ 2 - 1
ssj-kmt-exercise-service-impl/src/main/java/com/ssj/service/task/SyncSaveExerciseBookTask.java

@@ -44,7 +44,7 @@ public class SyncSaveExerciseBookTask extends Task {
     @Override
     public void run() {
         try {
-            Thread.sleep(2000);
+            logger.info("同步练习册开始");
             List<KmtExerciseQuestion> kmtExerciseQuestions = kmtExerciseMapper.findByBookId(this.bookId);
             this.appendQuestionDataFromJSONFile(kmtExerciseQuestions);
             for (KmtExerciseQuestion kmtExerciseQuestion : kmtExerciseQuestions){
@@ -70,6 +70,7 @@ public class SyncSaveExerciseBookTask extends Task {
                 }
                 exerciseQuestionSearchService.insertOrUpdateBatch("kmt_exercise_question_know", elasticEntityList);
             }
+            logger.info("同步练习册结束");
         } catch (Exception e){
             logger.error("异步保存es异常", e);
         }

+ 2 - 1
ssj-kmt-exercise-service-impl/src/main/java/com/ssj/service/task/SyncSaveExerciseQuestionsTask.java

@@ -43,7 +43,7 @@ public class SyncSaveExerciseQuestionsTask extends Task {
     @Override
     public void run() {
         try {
-            Thread.sleep(2000);
+            logger.info("同步题目开始");
             List<KmtExerciseQuestion> kmtExerciseQuestions = kmtExerciseMapper.findExerciseQuestionByIds(this.questionIds);
             this.appendQuestionDataFromJSONFile(kmtExerciseQuestions);
             for (KmtExerciseQuestion kmtExerciseQuestion : kmtExerciseQuestions){
@@ -69,6 +69,7 @@ public class SyncSaveExerciseQuestionsTask extends Task {
                 }
                 exerciseQuestionSearchService.insertOrUpdateBatch("kmt_exercise_question_know", elasticEntityList);
             }
+            logger.info("同步题目结束");
         } catch (Exception e){
             logger.error("异步保存es异常", e);
         }