package com.lf.server.service.data; import com.lf.server.entity.data.MetaFileEntity; import com.lf.server.entity.sys.UserEntity; import com.lf.server.helper.FileHelper; import com.lf.server.helper.PathHelper; import com.lf.server.helper.StringHelper; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.web.multipart.MultipartFile; import org.springframework.web.multipart.support.StandardMultipartHttpServletRequest; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.File; import java.lang.reflect.Field; import java.sql.Timestamp; import java.util.*; /** * 数据上传服务类 * @author WWW */ @Service public class UploaderService { @Autowired PathHelper pathHelper; private final static Log log = LogFactory.getLog(UploaderService.class); /** * 上传文件 */ public List uploadData(T t, UserEntity ue, HttpServletRequest request, HttpServletResponse res) throws Exception { StandardMultipartHttpServletRequest req = (StandardMultipartHttpServletRequest) request; req.setCharacterEncoding("utf-8"); res.setContentType("application/json;charset=utf-8"); if (t != null) { setEntity(t, req); } List list = getFiles(ue, req); return list; } /** * 设置实体类 * class clazz * T t = clazz.newInstance(); */ private void setEntity(T t, StandardMultipartHttpServletRequest req) { Enumeration enumeration = req.getParameterNames(); while (enumeration.hasMoreElements()) { String key = enumeration.nextElement(); try { Field field = t.getClass().getDeclaredField(key); if (field != null) { field.setAccessible(true); String value = req.getParameter(key); switch (field.getType().toString()) { case "long": field.set(t, Long.valueOf(value)); break; case "int": field.set(t, Integer.valueOf(value)); break; case "class java.sql.Timestamp": field.set(t, Timestamp.valueOf(value)); break; //case "class java.lang.String": default: field.set(t, value); break; } } } catch (Exception ex) { log.error(ex.getStackTrace()); } } } /** * 获取文件 */ private List getFiles(UserEntity ue, StandardMultipartHttpServletRequest req) throws Exception { List list = new ArrayList(); String path = pathHelper.getTempPath(ue.getId()); Iterator iterator = req.getFileNames(); while (iterator.hasNext()) { MultipartFile file = req.getFile(iterator.next()); if (StringHelper.isEmpty(file.getOriginalFilename())) { continue; } double sizes = FileHelper.sizeToMb(file.getSize()); MetaFileEntity mf = new MetaFileEntity(); mf.setName(file.getOriginalFilename()); mf.setSizes(sizes); mf.setPath(path + File.separator + mf.getName()); file.transferTo(new File(mf.getPath())); mf.setGuid(FileHelper.getFileMd5(mf.getPath())); list.add(mf); } return list; } /** * 获取参数 * Enumeration headers = req.getHeaderNames(); * Enumeration attributes = req.getAttributeNames(); */ private Map getParams(StandardMultipartHttpServletRequest req) { Map map = new HashMap(3); Enumeration enumeration = req.getParameterNames(); while (enumeration.hasMoreElements()) { String key = enumeration.nextElement(); String value = req.getParameter(key); map.put(key, value); } return map; } }