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

+ 6 - 2
themis-mq/src/main/java/com/qmth/themis/mq/service/impl/MqLogicServiceImpl.java

@@ -427,8 +427,12 @@ public class MqLogicServiceImpl implements MqLogicService {
                 tIeExamInvigilateCall.setLiveUrl(tIeExamInvigilateCallLog.getLiveUrl());
                 tIeExamInvigilateCall.setStatus(tIeExamInvigilateCallLog.getStatus());
             }
-            long dbtimestamp = tIeExamInvigilateCall.getUpdateTime().getTime();
-            if (mqDto.getTimestamp() > dbtimestamp) {
+            if (Objects.nonNull(tIeExamInvigilateCall.getUpdateTime())) {
+                long dbtimestamp = tIeExamInvigilateCall.getUpdateTime().getTime();
+                if (mqDto.getTimestamp() > dbtimestamp) {
+                    tIeExamInvigilateCallService.updateById(tIeExamInvigilateCall);
+                }
+            } else {
                 tIeExamInvigilateCallService.saveOrUpdate(tIeExamInvigilateCall);
             }
             tIeExamInvigilateCallLogService.saveOrUpdate(tIeExamInvigilateCallLog);