修改文件提交

amos-boot-module/amos-boot-module-biz/amos-boot-module-avic-biz/pom.xml

@@ -22,6 +22,12 @@
 			<artifactId>cxf-spring-boot-starter-jaxws</artifactId>
 			<version>3.2.6</version>
 		</dependency>
+
+		<dependency>
+			<groupId>com.yeejoin</groupId>
+			<artifactId>indicators-feign</artifactId>
+			<version>1.0.3-SNAPSHOT</version>
+		</dependency>
 	</dependencies>
 
 

amos-boot-module/amos-boot-module-biz/amos-boot-module-avic-biz/src/main/java/com/yeejoin/amos/avic/controller/WebServicesFileFransferResource.java

 package com.yeejoin.amos.avic.controller;
 
-import java.io.File;
 import java.io.InputStream;
+import java.util.ArrayList;
 import java.util.List;
 
 import javax.activation.DataHandler;
-import javax.activation.FileDataSource;
 
 import org.apache.cxf.endpoint.Client;
 import org.apache.cxf.jaxws.endpoint.dynamic.JaxWsDynamicClientFactory;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.util.ObjectUtils;
 import org.springframework.web.bind.annotation.RequestBody;
@@ -28,7 +28,9 @@ import org.typroject.tyboot.core.restful.utils.ResponseModel;
 
 import com.yeejoin.amos.avic.face.model.AvicCustomPathModel;
 import com.yeejoin.amos.avic.face.model.InputStreamDataSource;
-import com.yeejoin.amos.avic.face.model.UploadFileModel;
+import com.yeejoin.indicators.feign.IndicatorsManager;
+import com.yeejoin.indicators.feign.request.DataRecordRequest;
+import com.yeejoin.indicators.feign.workflow.WorkFlowFeign;
 
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
@@ -42,12 +44,21 @@ public class WebServicesFileFransferResource {
 	@Value("${avic.webservice.path}")
 	String webserviceUrl;
 	
-	
+	@Autowired
+	IndicatorsManager indicatorsManager;
+	@Autowired
+	WorkFlowFeign workFlowFeign;
 	
 	@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
 	@ApiOperation(value = "传输文件")
 	@RequestMapping(value = "/file", method = RequestMethod.POST)
-	public ResponseModel postfile(@RequestPart MultipartFile[] files, @RequestParam String code, @RequestParam String path ) {
+	public ResponseModel postfile(
+			@RequestPart MultipartFile[] files, 
+			@RequestParam String code,
+			@RequestParam String path,
+			@RequestParam String processDefinitionId,
+			@RequestParam String taskId,
+			@RequestParam String bizId) {
 		JaxWsDynamicClientFactory dcf = JaxWsDynamicClientFactory.newInstance();
 		Client client = dcf.createClient(webserviceUrl);
 		try {
@@ -64,6 +75,14 @@ public class WebServicesFileFransferResource {
 					client.invoke("useCodetransferFile", handler, file.getOriginalFilename(), path, code);
 				}
 			}
+
+			List<DataRecordRequest> list = new ArrayList<>();
+			DataRecordRequest dataRecordRequest = new DataRecordRequest();
+			dataRecordRequest.put("avicCode", code);
+			dataRecordRequest.put("targetPath", path);
+			list.add(dataRecordRequest);
+			indicatorsManager.indicatorClient.saveBizRecord(taskId, bizId, list);
+			workFlowFeign.startFormByProcess(null, processDefinitionId);
 		} catch (java.lang.Exception e) {
 			e.printStackTrace();
 		}