获取序列的方法加锁

huigou-data/src/main/java/com/huigou/data/domain/listener/VersionListener.java

 package com.huigou.data.domain.listener;
 
-import com.huigou.data.query.executor.SQLExecutorDao;
-import com.huigou.data.query.model.QueryDescriptor;
+import com.huigou.data.repository.GeneralRepositorySuper;
 import com.huigou.domain.IdentifiedEntity;
 import com.huigou.util.ApplicationContextWrapper;
 import org.springframework.beans.factory.annotation.Configurable;
+import org.springframework.util.ReflectionUtils;
 
 import javax.persistence.PrePersist;
 import javax.persistence.PreUpdate;
+import java.lang.reflect.Field;
 
 @Configurable
 public class VersionListener {
 
     @Deprecated
     public final static String GET_NEXT_SEQ_SQL = "SELECT version_seq.nextval from DUAL";
+    private final static String VERSION_FIELD_NAME = "version";
 
     private Long getNextId() {
-        SQLExecutorDao sqlExecutor = ApplicationContextWrapper.getBean("sqlExecutorDao", SQLExecutorDao.class);
-        QueryDescriptor queryDescriptor = sqlExecutor.getQuery("config/uasp/query/bmp/common.xml", "common");
-        return sqlExecutor.getSqlQuery().getJDBCDao().queryToLong(String.format(queryDescriptor.getSqlByName("nextSequence"), "version_seq"));
+        GeneralRepositorySuper generalRepository = ApplicationContextWrapper.getBean(GeneralRepositorySuper.class);
+        return generalRepository.getVersionNextId();
     }
 
     @PrePersist
-    public void beforeCreate(IdentifiedEntity target) {
-        target.setVersion(getNextId());
+    public void beforeCreate(Object target) {
+        updateVersion(target);
     }
 
     @PreUpdate
-    public void beforeUpdate(IdentifiedEntity target) {
-        target.setVersion(getNextId());
+    public void beforeUpdate(Object target) {
+        updateVersion(target);
+    }
+
+    private void updateVersion(Object target) {
+        if (target instanceof IdentifiedEntity) {
+            ((IdentifiedEntity) target).setVersion(getNextId());
+        } else {
+            Field field = ReflectionUtils.findField(target.getClass(), VERSION_FIELD_NAME);
+            if (field != null) {
+                field.setAccessible(true);
+                ReflectionUtils.setField(field, target, getNextId());
+            }
+        }
     }
 
 }

huigou-data/src/main/java/com/huigou/data/repository/GeneralRepositorySuper.java

@@ -783,7 +783,7 @@ abstract public class GeneralRepositorySuper {
         query.executeUpdate();
     }
 
-    private long getNextId(String sequenceName) {
+    private synchronized long getNextId(String sequenceName) {
         SQLExecutorDao sqlExecutor = ApplicationContextWrapper.getBean("sqlExecutorDao", SQLExecutorDao.class);
         QueryDescriptor queryDescriptor = sqlExecutor.getQuery("config/uasp/query/bmp/common.xml", "common");
         return sqlExecutor.getSqlQuery().getJDBCDao().queryToLong(String.format(queryDescriptor.getSqlByName("nextSequence"), sequenceName));