com.broadleafcommerce.dataimport.service

Class ImportProcessExecutor

java.lang.Object

com.broadleafcommerce.process.execution.executor.AbstractProcessExecutor

com.broadleafcommerce.dataimport.service.ImportProcessExecutor

All Implemented Interfaces:

com.broadleafcommerce.process.execution.executor.ProcessExecutor

@Component(value="blImportProcessExecutor")
public class ImportProcessExecutor
extends com.broadleafcommerce.process.execution.executor.AbstractProcessExecutor

Consumer that processes a file that has been uploaded by the ImportService

Author:

Phillip Verheyden (phillipuniverse)

Field Summary

Fields

Modifier and Type	Field and Description
static String	ADMIN_USER_ID
protected org.broadleafcommerce.openadmin.server.security.service.AdminSecurityService	adminSecurityService
protected com.broadleafcommerce.enterprise.common.extension.EnterpriseStateManager	enterpriseStateManager
protected org.broadleafcommerce.common.file.service.BroadleafFileService	fileService
static String	IMPORT_PROCESS
static String	IMPORT_TYPE
static String	LOCALE_CODE
protected org.springframework.context.MessageSource	messageSource
static String	ORIGIN_SITE_ID
protected org.broadleafcommerce.openadmin.server.service.persistence.PersistenceThreadManager	persistenceManager
static String	PROCESS_ID
protected List<FileImportProcessor>	registeredProcessors
static String	RESOURCE_URL
static String	SANDBOX_ID
protected com.broadleafcommerce.enterprise.workflow.dao.WorkflowSandBoxItemDao	sandboxItemDao
protected com.broadleafcommerce.enterprise.workflow.service.WorkflowSandBoxItemService	sandboxItemService
protected org.broadleafcommerce.common.sandbox.service.SandBoxService	sandboxService
protected org.broadleafcommerce.common.site.service.SiteService	siteService
static String	SPECIFICATION
static String	TIMEZONE
static String	TOTAL_RECORDS
protected org.broadleafcommerce.common.util.StreamingTransactionCapableUtil	transUtil
protected org.springframework.security.core.userdetails.UserDetailsService	userDetailsService
protected com.broadleafcommerce.enterprise.workflow.persistence.WorkflowStateManager	workflowStateManager

Fields inherited from class com.broadleafcommerce.process.execution.executor.AbstractProcessExecutor

processService, processStateManager

Constructor Summary

Constructors

Constructor and Description
ImportProcessExecutor()

Method Summary

Modifier and Type	Method and Description
protected com.broadleafcommerce.enterprise.workflow.domain.WorkflowSandBoxItem	addContainerSandboxItem(org.broadleafcommerce.common.web.BroadleafRequestContext brc, String className)
void	execute(Long processId, Map<String,String> processParams)
protected org.broadleafcommerce.common.util.Tuple<org.broadleafcommerce.openadmin.server.security.domain.AdminUser,org.springframework.security.core.userdetails.UserDetails>	getAdminUserForSite(org.broadleafcommerce.common.site.domain.Site site, Map<String,String> processParams)
String	getProcessType()
List<FileImportProcessor>	getRegisteredProcessors()
protected void	initializeRequestContext(org.broadleafcommerce.common.web.BroadleafRequestContext brc, Map<String,String> processParams) Initializes the given context.
protected boolean	isChangesetsModulePresent()
void	setRegisteredProcessors(List<FileImportProcessor> registeredProcessors)
boolean	shouldCreateSandboxContainer()

Methods inherited from class com.broadleafcommerce.process.execution.executor.AbstractProcessExecutor

sendExecutionFailureNotification

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

IMPORT_PROCESS

public static final String IMPORT_PROCESS

See Also:

Constant Field Values

PROCESS_ID

public static final String PROCESS_ID

See Also:

Constant Field Values

SPECIFICATION

public static final String SPECIFICATION

See Also:

Constant Field Values

IMPORT_TYPE

public static final String IMPORT_TYPE

See Also:

Constant Field Values

TOTAL_RECORDS

public static final String TOTAL_RECORDS

See Also:

Constant Field Values

RESOURCE_URL

public static final String RESOURCE_URL

See Also:

Constant Field Values

TIMEZONE

public static final String TIMEZONE

See Also:

Constant Field Values

LOCALE_CODE

public static final String LOCALE_CODE

See Also:

Constant Field Values

ADMIN_USER_ID

public static final String ADMIN_USER_ID

See Also:

Constant Field Values

SANDBOX_ID

public static final String SANDBOX_ID

See Also:

Constant Field Values

ORIGIN_SITE_ID

public static final String ORIGIN_SITE_ID

See Also:

Constant Field Values

registeredProcessors

protected List<FileImportProcessor> registeredProcessors

fileService

protected org.broadleafcommerce.common.file.service.BroadleafFileService fileService

adminSecurityService

protected org.broadleafcommerce.openadmin.server.security.service.AdminSecurityService adminSecurityService

userDetailsService

protected org.springframework.security.core.userdetails.UserDetailsService userDetailsService

siteService

protected org.broadleafcommerce.common.site.service.SiteService siteService

sandboxService

protected org.broadleafcommerce.common.sandbox.service.SandBoxService sandboxService

workflowStateManager

@Autowired(required=false)
protected com.broadleafcommerce.enterprise.workflow.persistence.WorkflowStateManager workflowStateManager

enterpriseStateManager

@Autowired(required=false)
protected com.broadleafcommerce.enterprise.common.extension.EnterpriseStateManager enterpriseStateManager

sandboxItemService

@Autowired(required=false)
protected com.broadleafcommerce.enterprise.workflow.service.WorkflowSandBoxItemService sandboxItemService

persistenceManager

protected org.broadleafcommerce.openadmin.server.service.persistence.PersistenceThreadManager persistenceManager

sandboxItemDao

@Autowired
 @Lazy
 @Qualifier(value="blWorkflowSandBoxItemDao")
protected com.broadleafcommerce.enterprise.workflow.dao.WorkflowSandBoxItemDao sandboxItemDao

transUtil

protected org.broadleafcommerce.common.util.StreamingTransactionCapableUtil transUtil

messageSource

protected org.springframework.context.MessageSource messageSource

Constructor Detail

ImportProcessExecutor

public ImportProcessExecutor()

Method Detail

execute

public void execute(Long processId,
                    Map<String,String> processParams)

addContainerSandboxItem

protected com.broadleafcommerce.enterprise.workflow.domain.WorkflowSandBoxItem addContainerSandboxItem(org.broadleafcommerce.common.web.BroadleafRequestContext brc,
                                                                                                       String className)

initializeRequestContext

protected void initializeRequestContext(org.broadleafcommerce.common.web.BroadleafRequestContext brc,
                                        Map<String,String> processParams)
                                 throws Exception

Initializes the given context. This should have already been set on thread local prior to invoking this method

Parameters:

brc -

event -

Throws:

Exception

getAdminUserForSite

protected org.broadleafcommerce.common.util.Tuple<org.broadleafcommerce.openadmin.server.security.domain.AdminUser,org.springframework.security.core.userdetails.UserDetails> getAdminUserForSite(org.broadleafcommerce.common.site.domain.Site site,
                                                                                                                                                                                                  Map<String,String> processParams)
                                                                                                                                                                                           throws org.springframework.security.core.userdetails.UsernameNotFoundException

Throws:

org.springframework.security.core.userdetails.UsernameNotFoundException

isChangesetsModulePresent

protected boolean isChangesetsModulePresent()

getProcessType

public String getProcessType()

getRegisteredProcessors

public List<FileImportProcessor> getRegisteredProcessors()

setRegisteredProcessors

public void setRegisteredProcessors(List<FileImportProcessor> registeredProcessors)

shouldCreateSandboxContainer

public boolean shouldCreateSandboxContainer()