import org.exoplatform.container.PortalContainer; //导入依赖的package包/类
@Test
public void testDatabaseAutoGeneratingTimestamp () throws NoSuchFieldException, IllegalAccessException {
  //Given
  IndexingOperation indexingOperation1 = new IndexingOperation();
  indexingOperation1.setEntityType("blog");
  indexingOperation1.setOperation(OperationType.INIT);
  indexingOperationDAO.create(indexingOperation1);
  PortalContainer container = PortalContainer.getInstance();
  entityMgrService = container.getComponentInstanceOfType(EntityManagerService.class);
  entityMgrService.getEntityManager().flush();
  entityMgrService.getEntityManager().refresh(indexingOperation1);
  //When
  indexingOperation1 = indexingOperationDAO.find(indexingOperation1.getId());
  //Then
  Field privateField = IndexingOperation.class.getDeclaredField("timestamp");
  privateField.setAccessible(true);
  Date timestamp = (Date) privateField.get(indexingOperation1);
  assertNotNull(timestamp);
}
 

import org.exoplatform.container.PortalContainer; //导入依赖的package包/类
@Override
public <T> Provider<? extends T> getProvider(final Class<T> implementationType) throws Exception {
  final PortalContainer container = PortalContainer.getInstance();
  if (container == null) {
    return null;
  }
  final ComponentAdapter adapter = container.getComponentAdapterOfType(implementationType);
  if (adapter != null) {
    return new Provider<T>() {
      @Override
      public T get() {
        Object service = adapter.getComponentInstance(container);
        if (service == null) {
          throw new RuntimeException("Could not obtain service " + implementationType + " from container " + container);
        }
        return implementationType.cast(service);
      }
    };
  } else {
    return null;
  }
}
 

import org.exoplatform.container.PortalContainer; //导入依赖的package包/类
private void generateActivity() throws Exception {
	// Get current user and assign to ownerStream
	String username = ConversationState.getCurrent().getIdentity().getUserId();
	IdentityManager identityM =
	(IdentityManager) PortalContainer.getInstance().getComponentInstanceOfType(IdentityManager.class);
	Identity userIdentity = identityM.getOrCreateIdentity(OrganizationIdentityProvider.NAME, username, false);
	Identity ownerStream = userIdentity;
	// New activity
	ExoSocialActivityImpl activity = new ExoSocialActivityImpl();
	activity.setUserId(userIdentity.getId());
	activity.setTitle("This is an activity of type <b>" + ACTIVITY_TYPE + "</b>.");
	activity.setBody("This is for testing");
	activity.setType(ACTIVITY_TYPE);
	// Save activity
	ActivityManager activityM =
	(ActivityManager) PortalContainer.getInstance().getComponentInstanceOfType(ActivityManager.class);
	activityM.saveActivityNoReturn(ownerStream, activity);
}
 

import org.exoplatform.container.PortalContainer; //导入依赖的package包/类
public <T> Provider<? extends T> getProvider(final Class<T> implementationType)
{
  return new Provider<T>() {
    public T get() {
      ExoContainer container = ExoContainerContext.getCurrentContainer();
      T ret = (T)container.getComponentInstance(implementationType);
      if(ret == null)
      {
        PortalContainer portalContainer = PortalContainer.getInstance();
        ret = (T)portalContainer.getComponentInstanceOfType(implementationType);
        if(ret == null)
        {
          RootContainer rootContainer = RootContainer.getInstance();
          ret = (T)rootContainer.getComponentInstanceOfType(implementationType);
        }
      }
      return ret;
    }
  };
}
 

import org.exoplatform.container.PortalContainer; //导入依赖的package包/类
/**
 * 
 * Sets exo and exchange last check full synchronization operation date
 * 
 * @param username
 * @param time
 * @throws Exception
 */
public void setUserLastCheckDate(long time) throws Exception {
  if (organizationService instanceof ComponentRequestLifecycle) {
    ((ComponentRequestLifecycle) organizationService).startRequest(PortalContainer.getInstance());
  }
  try {
    UserProfile userProfile = organizationService.getUserProfileHandler().findUserProfileByName(username);
    userProfile.setAttribute(USER_EXCHANGE_HANDLED_ATTRIBUTE, "" + time);
    long savedTime = userProfile.getAttribute(USER_EXO_HANDLED_ATTRIBUTE) == null ? 0 : Long.valueOf(userProfile.getAttribute(USER_EXO_HANDLED_ATTRIBUTE));
    if (time > savedTime) {
      userProfile.setAttribute(USER_EXO_HANDLED_ATTRIBUTE, "" + time);
    }
    organizationService.getUserProfileHandler().saveUserProfile(userProfile, false);
  } finally {
    if (organizationService instanceof ComponentRequestLifecycle) {
      ((ComponentRequestLifecycle) organizationService).endRequest(PortalContainer.getInstance());
    }
  }
}
 

import org.exoplatform.container.PortalContainer; //导入依赖的package包/类
/**
 * 
 * Gets last check full synchronization operation date
 * 
 * @return
 * @throws Exception
 */
public Date getUserLastCheckDate() throws Exception {
  if (organizationService instanceof ComponentRequestLifecycle) {
    ((ComponentRequestLifecycle) organizationService).startRequest(PortalContainer.getInstance());
  }
  try {
    UserProfile userProfile = organizationService.getUserProfileHandler().findUserProfileByName(username);
    long time = userProfile.getAttribute(USER_EXCHANGE_HANDLED_ATTRIBUTE) == null ? 0 : Long.valueOf(userProfile.getAttribute(USER_EXCHANGE_HANDLED_ATTRIBUTE));
    Date lastSyncDate = null;
    if (time > 0) {
      lastSyncDate = new Date(time);
    }
    return lastSyncDate;
  } finally {
    if (organizationService instanceof ComponentRequestLifecycle) {
      ((ComponentRequestLifecycle) organizationService).endRequest(PortalContainer.getInstance());
    }
  }
}
 

import org.exoplatform.container.PortalContainer; //导入依赖的package包/类
/**
 * 
 * Sets exo last check operation date.
 * 
 * @param username
 * @param time
 * @throws Exception
 */
public void setUserExoLastCheckDate(long time) throws Exception {
  if (organizationService instanceof ComponentRequestLifecycle) {
    ((ComponentRequestLifecycle) organizationService).startRequest(PortalContainer.getInstance());
  }
  try {
    UserProfile userProfile = organizationService.getUserProfileHandler().findUserProfileByName(username);
    long savedTime = userProfile.getAttribute(USER_EXO_HANDLED_ATTRIBUTE) == null ? 0 : Long.valueOf(userProfile.getAttribute(USER_EXO_HANDLED_ATTRIBUTE));
    if (savedTime <= 0) {
      if (LOG.isTraceEnabled()) {
        LOG.trace("User '" + username + "' exo last check time was not set before, may be the synhronization was not run before or an error occured in the meantime.");
      }
    } else {
      userProfile.setAttribute(USER_EXO_HANDLED_ATTRIBUTE, "" + time);
      organizationService.getUserProfileHandler().saveUserProfile(userProfile, false);
    }
  } finally {
    if (organizationService instanceof ComponentRequestLifecycle) {
      ((ComponentRequestLifecycle) organizationService).endRequest(PortalContainer.getInstance());
    }
  }
}
 

import org.exoplatform.container.PortalContainer; //导入依赖的package包/类
/**
 * 
 * Gets exo last check operation date
 * 
 * @return
 * @throws Exception
 */
public Date getUserExoLastCheckDate() throws Exception {
  if (organizationService instanceof ComponentRequestLifecycle) {
    ((ComponentRequestLifecycle) organizationService).startRequest(PortalContainer.getInstance());
  }
  try {
    UserProfile userProfile = organizationService.getUserProfileHandler().findUserProfileByName(username);
    long time = userProfile.getAttribute(USER_EXO_HANDLED_ATTRIBUTE) == null ? 0 : Long.valueOf(userProfile.getAttribute(USER_EXO_HANDLED_ATTRIBUTE));
    Date lastSyncDate = null;
    if (time > 0) {
      lastSyncDate = new Date(time);
    }
    return lastSyncDate;
  } finally {
    if (organizationService instanceof ComponentRequestLifecycle) {
      ((ComponentRequestLifecycle) organizationService).endRequest(PortalContainer.getInstance());
    }
  }
}
 

import org.exoplatform.container.PortalContainer; //导入依赖的package包/类
/**
 * 
 * @param organizationService
 * @param username
 * @param name
 * @param value
 * @throws Exception
 */
public static void setUserArrtibute(OrganizationService organizationService, String username, String name, String value) throws Exception {
  if (organizationService instanceof ComponentRequestLifecycle) {
    ((ComponentRequestLifecycle) organizationService).startRequest(PortalContainer.getInstance());
  }
  try {
    if (USER_EXCHANGE_PASSWORD_ATTRIBUTE.equals(name)) {
      value = encodePassword(value);
    }
    UserProfile userProfile = organizationService.getUserProfileHandler().findUserProfileByName(username);
    if (userProfile == null) {
      userProfile = organizationService.getUserProfileHandler().createUserProfileInstance(username);
      organizationService.getUserProfileHandler().saveUserProfile(userProfile, true);
    }
    userProfile.setAttribute(name, value);
    organizationService.getUserProfileHandler().saveUserProfile(userProfile, false);
  } finally {
    if (organizationService instanceof ComponentRequestLifecycle) {
      ((ComponentRequestLifecycle) organizationService).endRequest(PortalContainer.getInstance());
    }
  }
}
 

import org.exoplatform.container.PortalContainer; //导入依赖的package包/类
/**
 * 
 * @param organizationService
 * @param username
 * @param name
 * @return
 * @throws Exception
 */
public static String getUserArrtibute(OrganizationService organizationService, String username, String name) throws Exception {
  if (organizationService instanceof ComponentRequestLifecycle) {
    ((ComponentRequestLifecycle) organizationService).startRequest(PortalContainer.getInstance());
  }
  try {
    UserProfile userProfile = organizationService.getUserProfileHandler().findUserProfileByName(username);
    String value = null;
    if (userProfile != null) {
      value = userProfile.getAttribute(name);
      if (value != null && USER_EXCHANGE_PASSWORD_ATTRIBUTE.equals(name)) {
        value = decodePassword(value);
      }
    }
    return value;
  } finally {
    if (organizationService instanceof ComponentRequestLifecycle) {
      ((ComponentRequestLifecycle) organizationService).endRequest(PortalContainer.getInstance());
    }
  }
}
 

import org.exoplatform.container.PortalContainer; //导入依赖的package包/类
@Before
public void initializeContainerAndStartRequestLifecycle() {
  PortalContainer container = PortalContainer.getInstance();

  RequestLifeCycle.begin(container);

  entityMgrService = container.getComponentInstanceOfType(EntityManagerService.class);
  entityMgrService.getEntityManager().getTransaction().begin();
}
 

import org.exoplatform.container.PortalContainer; //导入依赖的package包/类
/**
 * Gets the service.
 *
 * @param clazz the class
 * @param containerName the container's name
 *
 * @return the service
 */
public static <T> T getService(Class<T> clazz, String containerName) {
    ExoContainer container = ExoContainerContext.getCurrentContainer();
    if (containerName != null) {
        container = RootContainer.getInstance().getPortalContainer(containerName);
    }
    if (container.getComponentInstanceOfType(clazz)==null) {
        containerName = PortalContainer.getCurrentPortalContainerName();
        container = RootContainer.getInstance().getPortalContainer(containerName);
    }
    return clazz.cast(container.getComponentInstanceOfType(clazz));
}
 

import org.exoplatform.container.PortalContainer; //导入依赖的package包/类
private RelationshipStorage getRelationshipStorage() {
  if (relationshipStorage == null) {
    relationshipStorage = (RelationshipStorage) PortalContainer.getInstance().
                                                                getComponentInstanceOfType(RelationshipStorage.class);
  }
  return relationshipStorage;
}
 

import org.exoplatform.container.PortalContainer; //导入依赖的package包/类
private SpaceStorage getSpaceStorage() {
  if (spaceStorage == null) {
    spaceStorage = (SpaceStorage) PortalContainer.getInstance().getComponentInstanceOfType(SpaceStorage.class);
  }

  return spaceStorage;
}
 

import org.exoplatform.container.PortalContainer; //导入依赖的package包/类
private IdentityStorage getIdentityStorage() {
  if (identityStorage == null) {
    identityStorage = (IdentityStorage) PortalContainer.getInstance().getComponentInstanceOfType(IdentityStorage.class);
  }

  return identityStorage;
}
 

import org.exoplatform.container.PortalContainer; //导入依赖的package包/类
private ActivityStorage getStorage() {
  if (activityStorage == null) {
    activityStorage = (ActivityStorage) PortalContainer.getInstance().getComponentInstanceOfType(ActivityStorage.class);
  }
  
  return activityStorage;
}
 

import org.exoplatform.container.PortalContainer; //导入依赖的package包/类
public IntegrationListener getExchangeListenerService() {
  if (exchangeListenerService == null) {
    try {
      this.exchangeListenerService = (IntegrationListener) PortalContainer.getInstance().getComponentInstanceOfType(IntegrationListener.class);
    } catch (Exception e) {
      LOG.error(e);
    }
  }
  return exchangeListenerService;
}
 

import org.exoplatform.container.PortalContainer; //导入依赖的package包/类
@Before
public void setUp() {
  PortalContainer container = PortalContainer.getInstance();
  indexingOperationDAO = container.getComponentInstanceOfType(IndexingOperationDAO.class);
}
 

import org.exoplatform.container.PortalContainer; //导入依赖的package包/类
private MongoStorage getMongoStorage() {
  if (mongoStorage == null) {
    mongoStorage = (MongoStorage) PortalContainer.getInstance().getComponentInstanceOfType(MongoStorage.class);
  }
  return mongoStorage;
}
 

import org.exoplatform.container.PortalContainer; //导入依赖的package包/类
private Session getSession() throws RepositoryException {
  PortalContainer container = PortalContainer.getInstance();
  RepositoryService repositoryService = (RepositoryService) container.getComponentInstance(RepositoryService.class);
  ManageableRepository repository = repositoryService.getCurrentRepository();
  return repository.getSystemSession("portal-test");
}