如何解决使用名称 'dataFlowController' 创建错误 bean 的问题

huangapple
未分类评论49阅读模式
英文:

How to resolve error creating error bean with name 'dataFlowController'

问题

抱歉，由于内容较多，我将无法完整翻译整个代码段。但是，我可以看出您遇到了Spring框架的依赖注入和bean创建相关的问题。您的错误消息表明在创建bean时出现了依赖项不满足的情况。

主要问题似乎出现在以下部分：

  1. Caused by: org.springframework.beans.factory.UnsatisfiedDependencyException:
  2. Error creating bean with name 'pamdaImportDirect': Unsatisfied
  3. dependency expressed through field 'catalogueImportDirectStarter';
  4. nested exception is
  5. org.springframework.beans.factory.BeanNotOfRequiredTypeException: Bean
  6. named 'catalogueImportDirectStarter' is expected to be of type
  7. 'com.orange.pamda.worker.starter.CatalogueImportDirectStarter' but was
  8. actually of type 'com.sun.proxy.$Proxy129'

这个错误表明在 pamdaImportDirect bean 中的 catalogueImportDirectStarter 字段的类型不正确。根据错误信息，期望的类型是 CatalogueImportDirectStarter，但实际类型是代理类型（$Proxy129）。这通常发生在Spring的AOP（面向切面编程）中。

您可能需要检查以下几点来解决这个问题：

  1. 导入包：确保所有涉及的类和接口都正确导入并在类路径中。

  2. 注解标记：确保您正确地使用了Spring的注解（例如 @Autowired）来进行依赖注入。

  3. 配置文件：检查您的配置文件（如XML配置文件或Java配置类）是否正确配置了bean。

  4. 接口/类声明：确保 CatalogueImportDirectStarter 类正确地实现了所需的接口（如果有的话）。

  5. AOP代理：如果在类中使用了Spring的AOP特性，可能会导致代理问题。您可以尝试调整代理设置，或者确保被代理的类是正确的类型。

  6. 循环依赖：检查是否存在循环依赖，这也可能导致依赖注入问题。

  7. Bean命名：检查bean的命名是否与注入点的期望名称匹配。

  8. 使用 @Qualifier 注解：如果有多个候选bean可以注入，可以尝试使用 @Qualifier 注解来明确指定使用哪个bean。

由于限制了单次回答的字数，我无法详细分析您的代码，但以上是一些可能导致您遇到的问题的一般性建议。您可以根据这些方向来检查和排除问题，或者提供更具体的问题细节以获取更准确的帮助。

英文:

hello I am developing a rest service and when I run my application I get the following error:

> > org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'dataFlowController': Unsatisfied
> dependency expressed through field 'pamdaImportDirectStarter'; nested
> exception is
> org.springframework.beans.factory.UnsatisfiedDependencyException:
> Error creating bean with name 'pamdaImportDirect': Unsatisfied
> dependency expressed through field 'catalogueImportDirectStarter';
> nested exception is
> org.springframework.beans.factory.BeanNotOfRequiredTypeException: Bean
> named 'catalogueImportDirectStarter' is expected to be of type
> 'com.orange.pamda.worker.starter.CatalogueImportDirectStarter' but was
> actually of type 'com.sun.proxy.$Proxy129' Apr 08, 2020 12:58:35 PM
> org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean
> destroy INFO: Closing JPA EntityManagerFactory for persistence unit
> 'pamdaPersistenceUnit' Apr 08, 2020 12:58:35 PM
> org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor
> shutdown INFO: Shutting down ExecutorService Apr 08, 2020 12:58:35 PM
> org.springframework.web.context.ContextLoader
> initWebApplicationContext SEVERE: Context initialization failed
> org.springframework.beans.factory.UnsatisfiedDependencyException:
> Error creating bean with name 'dataFlowController': Unsatisfied
> dependency expressed through field 'pamdaImportDirectStarter'; nested
> exception is
> org.springframework.beans.factory.UnsatisfiedDependencyException:
> Error creating bean with name 'pamdaImportDirect': Unsatisfied
> dependency expressed through field 'catalogueImportDirectStarter';
> nested exception is
> org.springframework.beans.factory.BeanNotOfRequiredTypeException: Bean
> named 'catalogueImportDirectStarter' is expected to be of type
> 'com.orange.pamda.worker.starter.CatalogueImportDirectStarter' but was
> actually of type 'com.sun.proxy.$Proxy129' at
> org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:588)
> at
> org.springframework.beans.factory.annotation.InjectionMetadata.inject(InjectionMetadata.java:88)
> at
> org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor.postProcessPropertyValues(AutowiredAnnotationBeanPostProcessor.java:366)
> at
> org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1264)
> at
> org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:553)
> at
> org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:483)
> at
> org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:306)
> at
> org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:230)
> at
> org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:302)
> at
> org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:197)
> at
> org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:761)
> at
> org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:867)
> at
> org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:543)
> at
> org.springframework.web.context.ContextLoader.configureAndRefreshWebApplicationContext(ContextLoader.java:443)
> at
> org.springframework.web.context.ContextLoader.initWebApplicationContext(ContextLoader.java:325)
> at
> org.springframework.web.context.ContextLoaderListener.contextInitialized(ContextLoaderListener.java:107)
> at
> org.apache.catalina.core.StandardContext.listenerStart(StandardContext.java:4685)
> at
> org.apache.catalina.core.StandardContext.startInternal(StandardContext.java:5146)
> at
> org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:183)
> at
> org.apache.catalina.core.ContainerBase$StartChild.call(ContainerBase.java:1384)
> at
> org.apache.catalina.core.ContainerBase$StartChild.call(ContainerBase.java:1374)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266) at
> org.apache.tomcat.util.threads.InlineExecutorService.execute(InlineExecutorService.java:75)
> at
> java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:134)
> at
> org.apache.catalina.core.ContainerBase.startInternal(ContainerBase.java:909)
> at
> org.apache.catalina.core.StandardHost.startInternal(StandardHost.java:841)
> at
> org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:183)
> at
> org.apache.catalina.core.ContainerBase$StartChild.call(ContainerBase.java:1384)
> at
> org.apache.catalina.core.ContainerBase$StartChild.call(ContainerBase.java:1374)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266) at
> org.apache.tomcat.util.threads.InlineExecutorService.execute(InlineExecutorService.java:75)
> at
> java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:134)
> at
> org.apache.catalina.core.ContainerBase.startInternal(ContainerBase.java:909)
> at
> org.apache.catalina.core.StandardEngine.startInternal(StandardEngine.java:262)
> at
> org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:183)
> at
> org.apache.catalina.core.StandardService.startInternal(StandardService.java:421)
> at
> org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:183)
> at
> org.apache.catalina.core.StandardServer.startInternal(StandardServer.java:930)
> at
> org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:183)
> at org.apache.catalina.startup.Catalina.start(Catalina.java:633) at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498) at
> org.apache.catalina.startup.Bootstrap.start(Bootstrap.java:343) at
> org.apache.catalina.startup.Bootstrap.main(Bootstrap.java:474) Caused
> by: org.springframework.beans.factory.UnsatisfiedDependencyException:
> Error creating bean with name 'pamdaImportDirect': Unsatisfied
> dependency expressed through field 'catalogueImportDirectStarter';
> nested exception is
> org.springframework.beans.factory.BeanNotOfRequiredTypeException: Bean
> named 'catalogueImportDirectStarter' is expected to be of type
> 'com.orange.pamda.worker.starter.CatalogueImportDirectStarter' but was
> actually of type 'com.sun.proxy.$Proxy129' at
> org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:588)
> at
> org.springframework.beans.factory.annotation.InjectionMetadata.inject(InjectionMetadata.java:88)

here is the code for my rest service "dataFlowController" :

  1.  package com.orange.pamda.controller;
  3. import java.io.File;
  4. import java.io.IOException;
  5. import java.util.List;
  7. import org.apache.commons.io.FileUtils;
  8. import org.slf4j.Logger;
  9. import org.slf4j.LoggerFactory;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.beans.factory.annotation.Qualifier;
  12. import org.springframework.context.annotation.Bean;
  13. import org.springframework.http.HttpHeaders;
  14. import org.springframework.http.HttpStatus;
  15. import org.springframework.http.ResponseEntity;
  16. import org.springframework.security.authentication.AuthenticationManager;
  17. import org.springframework.security.authentication.dao.DaoAuthenticationProvider;
  18. import org.springframework.transaction.annotation.Transactional;
  19. import org.springframework.util.ResourceUtils;
  20. import org.springframework.web.bind.annotation.CrossOrigin;
  21. import org.springframework.web.bind.annotation.PostMapping;
  22. import org.springframework.web.bind.annotation.RequestBody;
  23. import org.springframework.web.bind.annotation.RequestMapping;
  24. import org.springframework.web.bind.annotation.RequestMethod;
  25. import org.springframework.web.bind.annotation.RestController;
  27. import com.orange.pamda.config.PamdaServerProperty;
  28. import com.orange.pamda.dao.ProfileDao;
  29. import com.orange.pamda.dao.ScopeDao;
  30. import com.orange.pamda.interfaces.v11.CatalogueSystem;
  31. import com.orange.pamda.worker.service.WorkerService;
  32. import com.orange.pamda.worker.starter.CatalogueImportDirectStarter;
  33. import com.orange.pamda.worker.starter.MappingExportStarter;
  34. import com.orange.pamda.worker.starter.MappingImportStarter;
  35. import com.orange.pamda.worker.starter.CatalogueExportDirectStarter;
  36. import com.orange.pamda.worker.starter.PamdaImportDirectStarter;
  37. import com.orange.pamda.worker.utils.DataFlowParameterInfo;
  38. import com.orange.pamda.worker.utils.Worker;
  39. import com.orange.pamda.worker.utils.WorkerExecutionStatus;
  40. import com.orange.pamda.worker.utils.WorkerParameterInfo;
  42. @RestController
  43. @RequestMapping("dataFlow")
  44. @Transactional
  45. @CrossOrigin
  46. public class DataFlowController {
  48. 	private static final Logger LOGGER = LoggerFactory.getLogger(DataFlowController.class);
  50. 	@Autowired
  51. 	//@Qualifier("catalogueImportDirectStarter")
  52. 	CatalogueImportDirectStarter catalogueImportDirectStarter;
  53. 	
  54. 	@Autowired
  55. 	CatalogueExportDirectStarter catalogueExportDirectStarter;
  56. 	
  57. 	@Autowired
  58. 	MappingImportStarter mappingImportStarter;
  59. 	
  60. 	@Autowired
  61. 	MappingExportStarter mappingExportStarter; 
  62. 	
  63. 	@Autowired
  64. 	PamdaImportDirectStarter pamdaImportDirectStarter;
  65. 	
  66. 	
  67. 	@Autowired
  68. 	WorkerService workerService;
  70. 	@Autowired
  71. 	AuthenticationManager authenticationManager;
  73. 	@Autowired
  74. 	DaoAuthenticationProvider authenticationProvider;
  75. 	
  76. 	@Autowired
  77. 	PamdaServerProperty pamdaProperty;
  79. 	@Autowired
  80. 	ScopeDao scopeDao;
  81. 	
  82. 	
  83. 	 @RequestMapping(value = "/directExportCatalogue", method = RequestMethod.POST)
  84. 	public ResponseEntity<WorkerExecutionStatus> directExportCatalogue(@RequestBody DataFlowParameterInfo dataFlowParameterInfo) {
  85. 	
  86. 	 WorkerExecutionStatus workerExecutionStatus = new WorkerExecutionStatus();
  87. 	 
  88. 	 try {
  89. 		 	long startTime = System.nanoTime();
  90. 			
  91. 		 	dataFlowParameterInfo.setDataFlowName(com.orange.pamda.worker.utils.Worker.catalogueImport.name().toString());
  92. 		 	catalogueExportDirectStarter.start(dataFlowParameterInfo);
  93. 			long endTime = (System.nanoTime() - startTime) / 1000000000;
  94. 			LOGGER.trace("[TIMER] Pamda import direct : {}", endTime);
  95. 			System.out.println("[TIMER] Pamda import direct : {}"+ endTime);
  96. 		} catch (IOException e) {
  97. 			// TODO Auto-generated catch block
  98. 			
  99. 			workerExecutionStatus.setOnError(true);	
  100. 			
  101. 		}
  102. 		return new ResponseEntity<>(workerExecutionStatus, HttpStatus.OK);
  103. 	}
  104. 	
  106. 	@RequestMapping(value = "/directImportCatalogue", method = RequestMethod.POST)
  107. 	public ResponseEntity<WorkerExecutionStatus> directImportCatalogue(@RequestBody DataFlowParameterInfo dataFlowParameterInfo) {
  108. 	 dataFlowParameterInfo.setDataFlowName(com.orange.pamda.worker.utils.Worker.catalogueImport.name().toString());
  109. 	 WorkerExecutionStatus workerExecutionStatus = new WorkerExecutionStatus();
  110. 	 
  111. 	 try {
  112. 		 	long startTime = System.nanoTime();
  113. 			
  114. 			
  115. 			catalogueImportDirectStarter.start(dataFlowParameterInfo);
  116. 			long endTime = (System.nanoTime() - startTime) / 1000000000;
  117. 			LOGGER.trace("[TIMER] directImportCatalogue : {}", endTime);
  118. 			System.out.println("[TIMER] directImportCatalogue : {}"+ endTime);
  119. 		} catch (IOException e) {
  120. 			// TODO Auto-generated catch block
  121. 			
  122. 			workerExecutionStatus.setOnError(true);	
  123. 			
  124. 		} 
  125. 		return new ResponseEntity<>(workerExecutionStatus, HttpStatus.OK);
  126. 	}
  127. 	
  128. 	
  129. 	@PostMapping(value = "/directImportPamda")
  130. 	public ResponseEntity<WorkerExecutionStatus> directImportPamda(@RequestBody DataFlowParameterInfo dataFlowParameterInfo) {
  131. 		
  132. 	 WorkerExecutionStatus workerExecutionStatus = new WorkerExecutionStatus();
  133. 	 
  134. 	 try {
  135. 		 	long startTime = System.nanoTime();
  136. 			
  137. 		 	dataFlowParameterInfo.setDataFlowName(com.orange.pamda.worker.utils.Worker.catalogueImport.name().toString());
  138. 		 	pamdaImportDirectStarter.start(dataFlowParameterInfo);
  139. 			long endTime = (System.nanoTime() - startTime) / 1000000000;
  140. 			LOGGER.trace("[TIMER] Pamda import direct : {}", endTime);
  141. 			System.out.println("[TIMER] Pamda import direct : {}"+ endTime);
  142. 		} catch (IOException e) {
  143. 			// TODO Auto-generated catch block
  144. 			
  145. 			workerExecutionStatus.setOnError(true);	
  146. 			
  147. 		}
  148. 		return new ResponseEntity<>(workerExecutionStatus, HttpStatus.OK);
  149. 	}
  150. 	
  151. 	
  152. 	/* @RequestMapping(value = "/directExportMapping", method = RequestMethod.POST)
  153. 	public ResponseEntity<Void> directExportMapping(@RequestBody WorkerParameterInfo workerParameterInfo) {
  154. 		workerParameterInfo.setWorker(Worker.valueOf(com.orange.pamda.worker.utils.Worker.mappingExport.name()));
  155. 		workerService.launch(workerParameterInfo);
  156. 		return new ResponseEntity<>(HttpStatus.OK);
  157. 	}
  159. 	
  160. 	
  161. 	@RequestMapping(value = "/directImportMapping", method = RequestMethod.POST)
  162. 	public ResponseEntity<WorkerExecutionStatus> directImportMapping(@RequestBody WorkerParameterInfo workerParameterInfo) {
  163. 		workerParameterInfo.setWorker(Worker.valueOf(com.orange.pamda.worker.utils.Worker.mappingImport.name()));
  164. 		List<WorkerExecutionStatus> workerExecutionStatuss = workerService.launch(workerParameterInfo);
  165. 		return new ResponseEntity<>(workerExecutionStatuss.get(0), HttpStatus.OK);
  166. 	}
  167. 	*/
  168. }

and here is the class called by my directImportPamda method for processing :

  1.     package com.orange.pamda.worker.starter;
  3. import java.io.File;
  4. import java.io.IOException;
  5. import java.util.List;
  7. import javax.inject.Inject;
  9. import org.slf4j.Logger;
  10. import org.slf4j.LoggerFactory;
  11. import org.springframework.beans.factory.annotation.Autowired;
  12. import org.springframework.stereotype.Component;
  13. import org.springframework.transaction.annotation.Propagation;
  14. import org.springframework.transaction.annotation.Transactional;
  16. import com.google.common.collect.Lists;
  17. import com.orange.pamda.config.PamdaServerProperty;
  18. import com.orange.pamda.dao.MappingContextDAO;
  19. import com.orange.pamda.entity.jpa.MappingContext;
  20. import com.orange.pamda.service.MappingContextService;
  21. import com.orange.pamda.util.DataFlowParametersBuilder;
  22. import com.orange.pamda.util.DateHelper;
  23. import com.orange.pamda.util.FileFormatter;
  24. import com.orange.pamda.util.FileHelper;
  25. import com.orange.pamda.util.PamdaDataFlowStarter;
  26. import com.orange.pamda.worker.distributon.ArchiveService;
  27. import com.orange.pamda.worker.eraser.DataEraser;
  28. import com.orange.pamda.worker.utils.DataFlowParameterInfo;
  31. @Component("pamdaImportDirect")
  32. public class PamdaImportDirectStarter implements PamdaDataFlowStarter {
  34. 	@Inject
  35. 	private ArchiveService archiveService;
  37. 	@Inject
  38. 	private DataEraser dataEraser;
  39. 	
  40. 	@Autowired
  41. 	CatalogueImportDirectStarter catalogueImportDirectStarter;
  42. 	
  43. 	@Autowired
  44. 	CatalogueExportDirectStarter catalogueExportDirectStarter;
  45. 	
  46. 	@Autowired
  47. 	MappingImportStarter mappingImportStarter;
  48. 	
  49. 	@Autowired
  50. 	MappingExportStarter mappingExportStarter;
  51. 	
  52. 	@Inject
  53. 	private PamdaServerProperty pamdaProperty;
  55. 	@Autowired
  56. 	private MappingContextDAO mappingContextDAO;
  57. 	
  58. 	@Autowired
  59. 	private MappingContextService mappingContextService;
  61. 	protected static Logger logger = LoggerFactory.getLogger(PamdaImportDirectStarter.class);
  62. 	
  63. 	
  64. 	@Transactional(propagation = Propagation.NOT_SUPPORTED)
  65. 	public void start(DataFlowParameterInfo dataFlowParameterInfo)
  66. 			throws  IOException {
  67. 		
  68. 		System.out.println("START launching Pamda Import");
  69. 		
  70. 		
  71. 	    startImport(dataFlowParameterInfo);
  72. 		System.out.println("End launching Pamda Import JOB");
  73. 	
  74. 	}
  76. 	private void startImport(DataFlowParameterInfo dataFlowParameterInfo) {
  77. 		try {
  78. 			catalogueExportDirectStarter.start(dataFlowParameterInfo);
  79. 		} catch (IOException e3) {
  80. 			// TODO Auto-generated catch block
  81. 			e3.printStackTrace();
  82. 		}
  83. 		
  84. 		try {
  85. 			mappingExportStarter.start(dataFlowParameterInfo);
  86. 		} catch (IOException e2) {
  87. 			// TODO Auto-generated catch block
  88. 			e2.printStackTrace();
  89. 		}
  90. 		
  91. 		archive(dataFlowParameterInfo);
  92. 		
  93. 		unZipArchive(dataFlowParameterInfo);
  94. 		
  95. 		dataEraser(dataFlowParameterInfo);
  96. 		
  97. 		try {
  98. 			catalogueImportDirectStarter.start(dataFlowParameterInfo);
  99. 		} catch (IOException e1) {
  100. 			// TODO Auto-generated catch block
  101. 			e1.printStackTrace();
  102. 		}
  103. 		
  104. 		try {
  105. 			mappingImportStarter.start(dataFlowParameterInfo);
  106. 		} catch (IOException e) {
  107. 			// TODO Auto-generated catch block
  108. 			e.printStackTrace();
  109. 		}
  110. 		
  111. 		deleteUnZipFiles();
  112. 	}
  113. 	
  114. 	public void archive(DataFlowParameterInfo dataFlowParameterInfo) {
  115. 		
  116. 		DataFlowParametersBuilder builder = new DataFlowParametersBuilder();
  118. 		String pamdaImportPath = pamdaProperty.getPamdaImportPath();
  120. 		File[] filesList = null;
  121. 		try {
  122. 			filesList =		FileHelper.getFilesFromDirectoryMatchingPattern(pamdaImportPath, pamdaProperty.getPamdaFilename());
  123. 		} catch(Exception ex) {
  124. 			//throw new JobParametersInvalidException(dataFlowParameterInfo.NO_FILE);
  125. 		} 
  126. 		
  127. 		if (filesList != null && filesList.length > 1) 
  128. 			//throw new JobParametersInvalidException(dataFlowParameterInfo.TOO_MANY_FILES);
  129. 		
  130. 		if (filesList != null && filesList.length == 1) {
  131. 			MappingContext selectedMappingContext = mappingContextDAO.findMappingContext(Long.parseLong(dataFlowParameterInfo.getCurrentMappingContext()));
  132. 			
  133. 			//if(!filesList[0].getName().contains(selectedMappingContext.getCode()))
  134. 				//throw new JobParametersInvalidException(dataFlowParameterInfo.DIFFERENT_CONTEXT_FILE + "." + filesList[0].getName());
  135. 		}
  136. 		
  137. 	
  138. 		
  139. 		String parameterPaths = FileHelper.buildSplitFilenameParameter(filesList);
  141. 		
  142. 		String pamdaFilename = pamdaProperty.getPamdaFilename();
  143. 		long startTime = System.currentTimeMillis();
  144. 		String exportDateString = DateHelper.FILE_DATE_TIME_FORMATTER.print(startTime);
  145. 		
  146. 		MappingContext mappCntxt = mappingContextService
  147. 				.findById(Long.valueOf(dataFlowParameterInfo.getCurrentMappingContext()));
  149. 		List<String> pathList = FileHelper.splitFilesParameter(cataloguePath, catalogueFilename);
  150. 		pathList.addAll(FileHelper.splitFilesParameter(mappingPath, mappingFilename));
  152. 		String pamdaExportPath = pamdaProperty.getPamdaExportPath();
  153. 		File pamdaExportResult;
  154. 		
  155. 		try {
  156. 			pamdaExportResult = FileFormatter.getFormattedFileWithDate(mappCntxt.getCode(), pamdaFilename, ".zip",
  157. 					pamdaExportPath, exportDateString);
  158. 			archiveService.archiveFiles(pamdaExportPath, pamdaExportResult.getName(), pathList, currentContext , dataFlowParameterInfo.getPamdaVersion().getVersion() , dataFlowParameterInfo.getPamdaVersion().getCommentaire(), dataFlowParameterInfo.getUser(), dataFlowParameterInfo.getPamdaVersion().getFlag());
  159. 		} catch (IOException e) {
  160. 			// TODO Auto-generated catch block
  161. 			e.printStackTrace();
  162. 		}
  163. 		
  164. 	}
  165. 	
  166. 	
  167. 	
  168. 	
  169. 	private void unZipArchive (DataFlowParameterInfo dataFlowParameterInfo) {
  170. 		
  171. 		
  172. 		String pamdaImportPath = pamdaProperty.getPamdaImportPath();
  173. 		File[] filesList = null;
  174. 		try {
  175. 			filesList =		FileHelper.getFilesFromDirectoryMatchingPattern(pamdaImportPath, pamdaProperty.getPamdaFilename());
  176. 		} catch(Exception ex) {
  177. 			//throw new JobParametersInvalidException(dataFlowParameterInfo.NO_FILE);
  178. 		} 
  179. 		String importFilename = FileHelper.buildSplitFilenameParameter(filesList);
  180. 		List<String> files = FileHelper.splitFilesParameter(pamdaImportPath, importFilename);
  181. 		try {
  182. 			archiveService.unZipArchiveFile( files );
  183. 		} catch (IOException e) {
  184. 			// TODO Auto-generated catch block
  185. 			e.printStackTrace();
  186. 		}
  187. 		
  188. 	}
  189. 	
  190. 	public void dataEraser(DataFlowParameterInfo dataFlowParameterInfo) {
  191. 		
  192. 		dataEraser.eraseData(Long.parseLong(dataFlowParameterInfo.getCurrentMappingContext()));
  193. 	
  194. 	}
  195. 	
  196. public void deleteUnZipFiles() {
  197. 		
  198. 		List<File> folderList = Lists.newArrayList();
  199. 		folderList.add(FileHelper.getFileFromResource(pamdaProperty.getMappingImportPamdaPath()));
  200. 		folderList.add(FileHelper.getFileFromResource(pamdaProperty.getCatalogueImportPamdaPath()));
  202. 		try {
  203. 			archiveService.deleteArchiveFiles(folderList);
  204. 		} catch (IOException e) {
  205. 			// TODO Auto-generated catch block
  206. 			e.printStackTrace();
  207. 		}
  208. 		
  209. 	}
  211. }

and here is the code of my class CatalogExportDirectStarter which is called by the class PamdaImportDirect :

  1.    package com.orange.pamda.worker.starter;
  3. import java.io.File;
  4. import java.io.IOException;
  5. import java.util.ArrayList;
  6. import java.util.List;
  8. import javax.inject.Inject;
  10. import org.slf4j.Logger;
  11. import org.slf4j.LoggerFactory;
  12. import org.springframework.beans.factory.annotation.Autowired;
  13. import org.springframework.beans.factory.annotation.Qualifier;
  14. import org.springframework.stereotype.Component;
  15. import org.springframework.transaction.annotation.Propagation;
  16. import org.springframework.transaction.annotation.Transactional;
  18. import com.orange.pamda.config.PamdaServerProperty;
  19. import com.orange.pamda.dao.MappingContextDAO;
  20. import com.orange.pamda.entity.jpa.MappingContext;
  21. import com.orange.pamda.service.MappingContextService;
  22. import com.orange.pamda.util.DataFlowParameters;
  23. import com.orange.pamda.util.DataFlowParametersBuilder;
  24. import com.orange.pamda.util.DateHelper;
  25. import com.orange.pamda.util.FileFormatter;
  26. import com.orange.pamda.util.FileHelper;
  27. import com.orange.pamda.util.PamdaDataFlowStarter;
  28. import com.orange.pamda.worker.catalogue.exporter.CatalogueExporter;
  29. import com.orange.pamda.worker.catalogue.importer.CatalogueImporter;
  30. import com.orange.pamda.worker.service.XMLValidationService;
  31. import com.orange.pamda.worker.utils.DataFlowParameterInfo;
  34. @Component("catalogueExportDirectStarter")
  35. public class CatalogueExportDirectStarter implements PamdaDataFlowStarter {
  37. 	@Inject
  38. 	@Qualifier("catalogueImporter")
  39. 	private CatalogueExporter catalogueExporter;
  40. 	
  41. 	@Inject
  42. 	private XMLValidationService xmlValidationService;
  43. 	@Inject
  44. 	private PamdaServerProperty pamdaProperty;
  46. 	@Autowired
  47. 	private MappingContextDAO mappingContextDAO;
  48. 	
  49. 	@Autowired
  50. 	private MappingContextService mappingContextService;
  52. 	protected static Logger logger = LoggerFactory.getLogger(PamdaImportDirectStarter.class);
  53. 	
  54. 	
  55. 	@Transactional(propagation = Propagation.NOT_SUPPORTED)
  56. 	public void start(DataFlowParameterInfo dataFlowParameterInfo)
  57. 			throws  IOException {
  59. 		String pamdaExportPath = pamdaProperty.getPamdaExportPath();
  60. 		String pamdaFilename = pamdaProperty.getPamdaFilename();
  61. 		
  63. 		
  64. 		DataFlowParametersBuilder builder = new DataFlowParametersBuilder();
  65. 		long startTime = System.currentTimeMillis();
  67. 		MappingContext mappCntxt = mappingContextService
  68. 				.findById(Long.valueOf(dataFlowParameterInfo.getCurrentMappingContext()));
  70. 		String exportDateString = DateHelper.FILE_DATE_TIME_FORMATTER.print(startTime);
  72. 		File pamdaCatalogueExportResult = FileFormatter.getFormattedFileWithDate(mappCntxt.getCode(),
  73. 				pamdaProperty.getCatalogueFilename(), ".xml", pamdaExportPath, exportDateString);
  74. 		builder.addString(cataloguePath, pamdaExportPath);
  75. 		builder.addString(catalogueFilename, pamdaCatalogueExportResult.getName());
  76. 		builder.addString("catalogueCode", dataFlowParameterInfo.ALL);
  78. 		File pamdaMappingExportResult = FileFormatter.getFormattedFileWithDate(mappCntxt.getCode(),
  79. 				pamdaProperty.getMappingFilename(), ".xml", pamdaExportPath, exportDateString);
  80. 		builder.addString(mappingPath, pamdaExportPath);
  81. 		builder.addString(mappingFilename, pamdaMappingExportResult.getName());
  83. 		File pamdaExportResult = FileFormatter.getFormattedFileWithDate(mappCntxt.getCode(), pamdaFilename, ".zip",
  84. 				pamdaExportPath, exportDateString);
  85. 		builder.addString("archiveTargetName", pamdaExportResult.getName());
  86. 		builder.addString("archiveTargetDirectory", pamdaExportPath);
  87. 		builder.addString(targetFilePathParameterName, "archiveTargetName");
  88. 		builder.addLong(datetime, startTime);
  89. 		
  90. 		builder.addString(currentContext, dataFlowParameterInfo.getCurrentMappingContext());
  91. 		builder.addString(disabledByUser, String.valueOf(dataFlowParameterInfo.isDisabledByUser()));
  92. 		if(dataFlowParameterInfo.getPamdaVersion() != null) {
  93. 			builder.addString("pamdaVersion", dataFlowParameterInfo.getPamdaVersion().getVersion());
  94. 			builder.addString("comVersion", dataFlowParameterInfo.getPamdaVersion().getCommentaire());
  95. 			builder.addString("login", dataFlowParameterInfo.getUser());
  96. 			builder.addDate("flag", dataFlowParameterInfo.getPamdaVersion().getFlag());
  97. 		}
  99. 		startExport(builder.toDataFlowParameters() );
  100. 	}
  101. 		public void startExport(DataFlowParameters dataFlowParameters ) { 
  102. 			
  103. 			
  104. 			
  105. 			//catalogueExport 
  106. 			
  107. 			Long mappingSystemId = Long.parseLong(dataFlowParameters.getString(PamdaDataFlowStarter.currentContext));
  108. 			List<String> inputFilePaths = new ArrayList<String>();
  109. 			inputFilePaths.add(dataFlowParameters.getString(PamdaDataFlowStarter.catalogueFilename));
  110. 			
  111. 			catalogueExporter.export(dataFlowParameters.getString(PamdaDataFlowStarter.cataloguePath) + File.separator + dataFlowParameters.getString(PamdaDataFlowStarter.catalogueFilename), dataFlowParameters.getString(PamdaDataFlowStarter.catalogueCode), dataFlowParameters.getString(PamdaDataFlowStarter.currentContext));
  112. 			
  113. 			//catalogueValidation
  114. 			catalogueValidation(dataFlowParameters);			
  115. 		}
  116. 		
  117. 		
  118. 		public void catalogueValidation(DataFlowParameters dataFlowParameters) {
  119. 			String catalogueFilename = dataFlowParameters.getString(PamdaDataFlowStarter.catalogueFilename);
  120. 			String filePath = dataFlowParameters.getString(PamdaDataFlowStarter.cataloguePath);
  121. 			
  122. 			List<String> files = FileHelper.splitFilesParameter(filePath, catalogueFilename);
  123. 			xmlValidationService.validate( files, pamdaProperty.getCatalogueXSDfile());
  124. 			
  125. 			
  126. 		}
  127. 	
  128. 	
  129. }

there are other classes i use but i can't post them because of the 30,000 word limit imposed by stackoverFlow 如何解决使用名称 'dataFlowController' 创建错误 bean 的问题

can someone please help me to resolve this error ?

huangapple
  • 本文由 发表于 2020年4月8日 19:14:54
  • 转载请务必保留本文链接：https://java.coder-hub.com/61099366.html
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定