EntityLockingServiceImpl.java 文件源码

@Override
@Transactional(propagation = Propagation.MANDATORY)
public EntityLock getLock(BaseEntity entity, String lockId)
{
    EntityLock lock = entityLockDao.findByCriteria(Restrictions.eq("entity", entity));
    if( lock != null )
    {
        if( lockId == null )
        {
            throw new LockedException("Entity is locked by another user '" + lock.getUserID() + "'",
                lock.getUserID(), lock.getUserSession(), entity.getId());
        }
        if( !lockId.equals(lock.getUserSession()) )
        {
            throw new LockedException("Wrong lock id. Entity is locked by user.", lock.getUserID(),
                lock.getUserSession(), entity.getId());
        }
    }
    else if( lockId != null )
    {
        throw new LockedException("Entity is not locked", null, null, entity.getId());
    }
    return lock;
}