Преглед на файлове

推送云阅卷功能BUG修改

wangliang преди 2 години
родител
ревизия
5e3fcf4691
променени са 1 файла, в които са добавени 10 реда и са изтрити 3 реда
  1. 10 3
      themis-mq/src/main/java/com/qmth/themis/mq/service/impl/MqLogicServiceImpl.java

+ 10 - 3
themis-mq/src/main/java/com/qmth/themis/mq/service/impl/MqLogicServiceImpl.java

@@ -245,9 +245,6 @@ public class MqLogicServiceImpl implements MqLogicService {
             }
         } else if (tag.contains("Push".toUpperCase())) {
             TaskSyncTemplete taskSyncTemplete = null;
-            if (Objects.equals(MqTagEnum.CLOUD_MARK_SCORE_SYNC.name(), tag)) {
-                taskSyncTemplete = SpringContextHolder.getBean(TaskSyncCloudMarkTemplete.class);
-            }
             if (Objects.equals(MqTagEnum.CLOUD_MARK_DATA_PUSH.name(), tag)) {
                 taskSyncTemplete = SpringContextHolder.getBean(TaskPushCloudMarkTemplete.class);
             }
@@ -256,6 +253,16 @@ public class MqLogicServiceImpl implements MqLogicService {
             } catch (IOException e) {
                 log.error(SystemConstant.LOG_ERROR, e);
             }
+        } else if (tag.contains("Sync".toUpperCase())) {
+            TaskSyncTemplete taskSyncTemplete = null;
+            if (Objects.equals(MqTagEnum.CLOUD_MARK_SCORE_SYNC.name(), tag)) {
+                taskSyncTemplete = SpringContextHolder.getBean(TaskSyncCloudMarkTemplete.class);
+            }
+            try {
+                taskSyncTemplete.syncTask(map);
+            } catch (IOException e) {
+                log.error(SystemConstant.LOG_ERROR, e);
+            }
         } else {
             TaskExportTemplete taskExportTemplete = null;
             if (Objects.equals(MqTagEnum.ROOM_CODE_EXPORT.name(), tag)) {