Răsfoiți Sursa

版本修改

wangliang 2 ani în urmă
părinte
comite
37596ad528

+ 2 - 5
themis-business/src/main/java/com/qmth/themis/business/service/impl/TOeExamRecordServiceImpl.java

@@ -383,7 +383,7 @@ public class TOeExamRecordServiceImpl extends ServiceImpl<TOeExamRecordMapper, T
             Long timestamp = System.currentTimeMillis();
             if (!CollectionUtils.isEmpty(record)) {
                 ExamRecordCacheUtil.setStatus(recordId, ExamRecordStatusEnum.PERSISTED, timestamp);
-
+                ExamRecordCacheUtil.setUpdateTime(recordId, timestamp);
                 Object o = redisUtil.get(RedisKeyHelper.examRecordCacheKey(recordId), ExamRecordFieldEnum.status.getCode());
                 if (Objects.nonNull(o) && o instanceof ExamStatusBean) {
                     record.put(ExamRecordFieldEnum.status.getCode(), ((ExamStatusBean) o).getExamRecordStatusEnum());
@@ -616,10 +616,7 @@ public class TOeExamRecordServiceImpl extends ServiceImpl<TOeExamRecordMapper, T
             er.setMobileFirstMonitorStatus(mobileFirstMonitorStatus);
             er.setMobileSecondMonitorStatus(mobileSecondMonitorStatus);
             er.setUpdateTime(updateTime);
-            examRecordStatusEnum = ExamRecordCacheUtil.getStatus(recordId);
-            if (Objects.nonNull(examRecordStatusEnum) && examRecordStatusEnum != ExamRecordStatusEnum.PERSISTED) {
-                this.saveOrUpdate(er);
-            }
+            this.saveOrUpdate(er);
         }
     }
 

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

@@ -714,7 +714,7 @@ public class MqLogicServiceImpl implements MqLogicService {
         Long recordId = Long.parseLong(mqDto.getObjId());
         Long updateTime = ExamRecordCacheUtil.getUpdateTime(recordId);
         if (Objects.isNull(updateTime) || (Objects.nonNull(updateTime) &&
-                mqDto.getTimestamp().longValue() >= updateTime.longValue())) {
+                mqDto.getTimestamp().longValue() > updateTime.longValue())) {
             examRecordService.examRecordDataSave(recordId);
             tIpRegionService.saveIpRegion(recordId);
         }