持久化抛异常

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

@@ -678,11 +678,16 @@ public class MqLogicServiceImpl implements MqLogicService {
     @Override
     @Transactional
     public void execMqRecordPersistedLogic(MqDto mqDto, String key) {
-        Map<String, Object> param = (Map<String, Object>) mqDto.getBody();
-        Long recordId = Long.parseLong(String.valueOf(param.get(SystemConstant.RECORD_ID)));
-        Long studentId = Long.parseLong(String.valueOf(param.get(SystemConstant.STUDENT_ID)));
-        commonService.persisted(recordId, studentId);
-        tmRocketMessageService.saveMqMessageSuccess(mqDto, key);
+        try {
+            Map<String, Object> param = (Map<String, Object>) mqDto.getBody();
+            Long recordId = Long.parseLong(String.valueOf(param.get(SystemConstant.RECORD_ID)));
+            Long studentId = Long.parseLong(String.valueOf(param.get(SystemConstant.STUDENT_ID)));
+            commonService.persisted(recordId, studentId);
+            tmRocketMessageService.saveMqMessageSuccess(mqDto, key);
+        } catch (Exception e) {
+            log.error(SystemConstant.LOG_ERROR, e);
+            throw new RuntimeException(e);
+        }
     }
 
     /**