package com.yc.batchUpload.conterll; import com.yc.batchUpload.service.BatchUploadService; import com.yc.batchUpload.utils.CallBackMsg; import com.yc.multiData.SpObserver; import com.yc.utils.SessionKey; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.CrossOrigin; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.multipart.MultipartFile; import org.springframework.web.multipart.MultipartHttpServletRequest; import org.springframework.web.multipart.MultipartResolver; import org.springframework.web.multipart.commons.CommonsMultipartResolver; import javax.servlet.http.HttpServletRequest; import java.util.List; /** * @USER: xinyb_ * @DATE: 2021-09-17 14:09 */ @RestController @RequestMapping("/batchUpload") public class BatchUploadConterll { @Autowired private BatchUploadService batchUploadService; @RequestMapping("/uploadImage.do") @ResponseBody @CrossOrigin public CallBackMsg batchUpload(HttpServletRequest request) { CallBackMsg msg = new CallBackMsg(); try { MultipartResolver resolver = new CommonsMultipartResolver(request.getSession().getServletContext()); MultipartHttpServletRequest multipartRequest = resolver.resolveMultipart(request); List files = multipartRequest.getFiles("file_data");//文件信息 String formId=multipartRequest.getParameter("formId"); Integer dbid = Integer.parseInt( multipartRequest.getParameter("dbid")); String userCode = multipartRequest.getParameter("userCode"); String userName = multipartRequest.getParameter("userName"); //SpObserver.setDBtoInstance("_" + request.getSession().getAttribute(SessionKey.DATA_BASE_ID)); SpObserver.setDBtoInstance("_" + dbid); msg = batchUploadService.uploadBatchImage(formId,files,userCode,userName,request); } catch (Exception e) { msg.setFail("异常错误:" + (e.getCause() != null ? e.getCause().getMessage() : e.getMessage())); } finally { SpObserver.setDBtoInstance(); } return msg; } }