efo-master.zip

package com.zhazhapan.efo.service.impl; import com.zhazhapan.efo.EfoApplication; import com.zhazhapan.efo.config.SettingConfig; import com.zhazhapan.efo.dao.DownloadedDAO; import com.zhazhapan.efo.dao.FileDAO; import com.zhazhapan.efo.entity.Category; import com.zhazhapan.efo.entity.File; import com.zhazhapan.efo.entity.User; import com.zhazhapan.efo.model.AuthRecord; import com.zhazhapan.efo.model.BaseAuthRecord; import com.zhazhapan.efo.model.FileBasicRecord; import com.zhazhapan.efo.model.FileRecord; import com.zhazhapan.efo.modules.constant.ConfigConsts; import com.zhazhapan.efo.modules.constant.DefaultValues; import com.zhazhapan.efo.service.IAuthService; import com.zhazhapan.efo.service.ICategoryService; import com.zhazhapan.efo.service.IFileService; import com.zhazhapan.efo.util.BeanUtils; import com.zhazhapan.efo.util.ServiceUtils; import com.zhazhapan.modules.constant.ValueConsts; import com.zhazhapan.util.*; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Isolation; import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.multipart.MultipartFile; import javax.servlet.http.HttpServletRequest; import java.io.UnsupportedEncodingException; import java.net.URLDecoder; import java.util.Date; import java.util.List; import java.util.regex.Pattern; /** * @author pantao * @since 2018/1/29 */ @Service public class FileServiceImpl implements IFileService { private final static Logger logger = LoggerFactory.getLogger(FileServiceImpl.class); private static final String FILE_SUFFIX = "{fileSuffix}"; private static final String RANDOM_ID = "{randomId}"; private static final String YEAR = "{year}"; private static final String MONTH = "{month}"; private static final String DAY = "{day}"; private static final String AUTHOR = "{author}"; private static final String FILE_NAME = "{fileName}"; private static final String CATEGORY_NAME = "{categoryName}"; private final FileDAO fileDAO; private final ICategoryService categoryService; private final IAuthService authService; private final DownloadedDAO downloadDAO; @Autowired public FileServiceImpl(FileDAO fileDAO, ICategoryService categoryService, IAuthService authService, DownloadedDAO downloadDAO) { this.fileDAO = fileDAO; this.categoryService = categoryService; this.authService = authService; this.downloadDAO = downloadDAO; } @Override public boolean updateAuth(long id, String auth) { int[] au = BeanUtils.getAuth(auth); return fileDAO.updateAuthById(id, au[0], au[1], au[2], au[3], au[4]); } @Override public BaseAuthRecord getAuth(long id) { return fileDAO.getAuth(id); } @Override @Transactional(propagation = Propagation.REQUIRED, isolation = Isolation.DEFAULT, timeout = 36000, rollbackFor = Exception.class) public boolean deleteFiles(String ids) { if (Checker.isNotEmpty(ids)) { String[] id = ids.split(ValueConsts.COMMA_SIGN); for (String s : id) { long fileId = Formatter.stringToLong(s); String localUrl = fileDAO.getLocalUrlById(fileId); FileExecutor.deleteFile(localUrl); removeById(fileId); } return true; } return false; } @Override @Transactional(propagation = Propagation.REQUIRED, isolation = Isolation.DEFAULT, timeout = 36000, rollbackFor = Exception.class) public boolean[] updateUrl(int id, String oldLocalUrl, String localUrl, String visitUrl) { boolean[] b = new boolean[]{false, false}; boolean canUpdateLocalUrl = Checker.isExists(oldLocalUrl) && Checker.isNotEmpty(localUrl) && Checker .isNotExists(localUrl) && !localUrlExists(localUrl); if (canUpdateLocalUrl) { FileExecutor.renameTo(oldLocalUrl, localUrl); fileDAO.updateLocalUrlById(id, localUrl); b[0] = true; } if (Checker.isNotEmpty(visitUrl) && !visitUrlExists(visitUrl)) { fileDAO.updateVisitUrlById(id, visitUrl); b[1] = true; } return b; } @Override @Transactional(propagation = Propagation.REQUIRED, isolation = Isolation.DEFAULT, timeout = 36000, rollbackFor = Exception.class) public boolean updateFileInfo(long id, User user, String name, String category, String tag, String description) { File file = fileDAO.getById(id); if (Checker.isNotNull(file) && file.getIsUpdatable() == 1) { AuthRecord authRecord = authService.getByFileIdAndUserId(id, user.getId()); String suffix = FileExecutor.getFileSuffix(name); boolean canUpdate = (Checker.isNull(authRecord) ? user.getIsUpdatable() == 1 : authRecord.getIsUpdatable() == 1) && Checker.isNotEmpty(name) && Pattern.compile(EfoApplication.settings.getStringUseEval(ConfigConsts.FILE_SUFFIX_MATCH_OF_SETTING)).matcher(suffix).matches(); if (canUpdate) { String localUrl = file.getLocalUrl(); java.io.File newFile = new java.io.File(localUrl); String visitUrl = file.getVisitUrl(); String newLocalUrl = localUrl.substring(0, localUrl.lastIndexOf(ValueConsts.SEPARATOR) + 1) + name; String newVisitUrl = visitUrl.substring(0, visitUrl.lastIndexOf(ValueConsts.SPLASH_STRING) + 1) + name; file.setName(name); file.setSuffix(suffix); file.setLocalUrl(newLocalUrl); file.setVisitUrl(newVisitUrl); file.setCategoryId(categoryService.getIdByName(category)); file.setTag(tag); file.setDescription(description); boolean isValid = (localUrl.endsWith(ValueConsts.SEPARATOR + name) || (!Checker.isExists(newLocalUrl) && !localUrlExists(newLocalUrl) && !visitUrlExists(newVisitUrl))); if (isValid && fileDAO.updateFileInfo(file)) { return newFile.renameTo(new java.io.File(newLocalUrl)); } } } return false; } @Override public boolean removeFile(User user, long fileId) { File file = fileDAO.getById(fileId); boolean isDeleted = false; if (Checker.isNotNull(file) && file.getIsDeletable() == 1) { AuthRecord authRecord = authService.getByFileIdAndUserId(fileId, user.getId()); String localUrl = fileDAO.getLocalUrlById(fileId); isDeleted = (Checker.isNull(authRecord) ? user.getIsDeletable() == 1 : authRecord.getIsDeletable() == 1) && removeById(fileId); if (isDeleted) { FileExecutor.deleteFile(localUrl); } } return isDeleted; } @Override public List<FileRecord> listUserDownloaded(int userId, int offset, String search) { return fileDAO.listUserDownloaded(userId, offset, search); } @Override public List<FileRecord> listUserUploaded(int userId, int offset, String search) { return fileDAO.listUserUploaded(userId, offset, search); } @Override @Transactional(propagation = Propagation.REQUIRED, isolation = Isolation.DEFAULT, timeout = 36000, rollbackFor = Exception.class) public boolean removeById(long id) { downloadDAO.removeByFileId(id); authService.removeByFileId(id); return fileDAO.removeById(id); } @Override public boolean removeByVisitUrl(String visitUrl) { long fileId = fileDAO.getIdByVisitUrl(visitUrl);