加入腾讯云事件监控

themis-admin/src/main/java/com/qmth/themis/admin/api/TENotifyController.java

@@ -133,14 +133,9 @@ public class TENotifyController {
                             }
                             JSONArray jsonArray = this.getVideoUrl(tOeExamRecord.getTencentVideoUrl(), videoSource, jsonObject);
                             if (Objects.nonNull(jsonArray) && jsonArray.size() > 0 && count != jsonArray.size()) {
-                                String tencentViderUrl = tOeExamRecord.getTencentVideoUrl();
-                                UpdateWrapper<TOeExamRecord> updateWrapper = new UpdateWrapper<>();
-                                updateWrapper.lambda().eq(TOeExamRecord::getId, tOeExamRecord.getId());
-                                if (Objects.nonNull(tencentViderUrl) && !Objects.equals(tencentViderUrl.trim(), "")) {
-                                    updateWrapper.lambda().eq(TOeExamRecord::getTencentVideoUrl, tencentViderUrl);
-                                }
-                                updateWrapper.lambda().set(TOeExamRecord::getTencentVideoUrl, jsonArray.toJSONString());
-                                tOeExamRecordService.update(updateWrapper);
+                                tOeExamRecord.setTencentVideoUrl(jsonArray.toJSONString());
+                                tOeExamRecordService.updateById(tOeExamRecord);
+
                                 TMTencentVideoMessage tencentVideoMessage = new TMTencentVideoMessage(SystemConstant.getUuid(), jsonObject.toJSONString());
                                 tencentVideoMessageService.save(tencentVideoMessage);
                             }

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

@@ -344,14 +344,9 @@ public class MqLogicServiceImpl implements MqLogicService {
                     }
                 }
                 if (Objects.nonNull(jsonArray) && jsonArray.size() > 0 && countDb != jsonArray.size()) {
-                    String tencentViderUrl = tOeExamRecord.getTencentVideoUrl();
-                    UpdateWrapper<TOeExamRecord> updateWrapper = new UpdateWrapper<>();
-                    updateWrapper.lambda().eq(TOeExamRecord::getId, tOeExamRecord.getId());
-                    if (Objects.nonNull(tencentViderUrl) && !Objects.equals(tencentViderUrl.trim(), "")) {
-                        updateWrapper.lambda().eq(TOeExamRecord::getTencentVideoUrl, tencentViderUrl);
-                    }
-                    updateWrapper.lambda().set(TOeExamRecord::getTencentVideoUrl, jsonArray.toJSONString());
-                    tOeExamRecordService.update(updateWrapper);
+                    tOeExamRecord.setTencentVideoUrl(jsonArray.toJSONString());
+                    tOeExamRecordService.updateById(tOeExamRecord);
+
                     TMTencentVideoMessage tencentVideoMessage = new TMTencentVideoMessage(response.getRequestId(), JacksonUtil.parseJson(response));
                     tencentVideoMessageService.save(tencentVideoMessage);
                 }