xymp
/
backend
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: 增加上传图片接口，并根据文件名解析保存入库

Browse Source
dev
huangfeng 2 months ago
parent 735db9579a
commit dcd2ecc1d8
4 changed files with 86 additions and 3 deletions
Show Stats Download Patch File Download Diff File

14
xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TerminalPhotoController.java
Unescape Escape View File

@ -21,9 +21,9 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpHeaders;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import javax.servlet.http.HttpServletResponse;
import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.util.ArrayList;
import java.util.Date;
@ -292,6 +292,18 @@ public class TerminalPhotoController extends BaseController {
return result;
}
@PostMapping("uploadPhoto")
@ApiOperation("上传图片")
@Log(title = "上传图片", type = "上传")
public ResponseReult<String> uploadPhoto(@RequestParam("file") MultipartFile file,
@RequestParam("cmdid") String cmdid) throws Exception {
if (file != null && file.getInputStream() != null) {
terminalPhotoService.upload(file, cmdid);
return ResponseReult.success("OK");
} else {
return ResponseReult.error("缺少上传文件");
}
}
@ApiOperation(value = "图片轮询", notes = "图片轮询接口", httpMethod = "POST")
@ApiResponses({@ApiResponse(code = 200, message = "请求成功"), @ApiResponse(code = 400, message = "请求参数没填好"), @ApiResponse(code = 404, message = "请求路径没有或页面跳转路径不对")})

1
xymanager_common/src/main/java/com/shxy/xymanager_common/config/SecurityConfig.java
Unescape Escape View File

@ -77,6 +77,7 @@ public class SecurityConfig {
urlWhiteList.add("/xymanager/kaptcha");
urlWhiteList.add("/xymanager/test/**");
urlWhiteList.add("/xymanager/mntn/**");
urlWhiteList.add("/xymanager/uploadPhoto");
StreamReadConstraints streamReadConstraints = StreamReadConstraints
.builder()

72
xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalPhotoServiceImpl.java
Unescape Escape View File

@ -15,6 +15,7 @@ import com.shxy.xymanager_common.dto.*;
import com.shxy.xymanager_common.entity.*;
import com.shxy.xymanager_common.enums.CommonStatus;
import com.shxy.xymanager_common.enums.TakePicStatus;
import com.shxy.xymanager_common.exception.ApiException;
import com.shxy.xymanager_common.exception.Asserts;
import com.shxy.xymanager_common.model.*;
import com.shxy.xymanager_common.page.PageUtils;
@ -25,7 +26,6 @@ import com.shxy.xymanager_common.vo.*;
import com.shxy.xymanager_dao.dao.*;
import com.shxy.xymanager_service.service.*;
import lombok.extern.slf4j.Slf4j;
import org.apache.poi.ss.formula.functions.T;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
@ -34,10 +34,13 @@ import org.springframework.util.CollectionUtils;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;
import javax.validation.constraints.NotNull;
import javax.imageio.ImageIO;
import java.awt.image.BufferedImage;
import java.io.File;
import java.io.IOException;
import java.math.BigInteger;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.*;
/**
@ -423,6 +426,71 @@ public class TerminalPhotoServiceImpl implements TerminalPhotoService {
return Asserts.success("OK");
}
@Override
public void upload(MultipartFile file, String cmdid) throws Exception {
Terminals term = terminalExtService.getByCmdid(cmdid);
if (term == null) {
throw new ApiException(cmdid + "该装置不存在");
}
String suffix;
String hexC = "";
Long time;
TerminalPhoto record = new TerminalPhoto();
try {
String fileName = org.springframework.util.StringUtils.cleanPath(file.getOriginalFilename());
suffix = org.springframework.util.StringUtils.getFilenameExtension(fileName);
String prefix = fileName.replace("." + suffix, "");
String[] str = prefix.split("_");
Long photoId = Long.parseLong(str[1], 16);
Integer channel = Integer.parseInt(str[2], 16);
hexC = str[3];
Integer preset = Integer.parseInt(hexC, 16);
time = Long.parseLong(str[6], 16);
record.setChannelId(channel);
record.setPresetId(preset);
record.setPhotoTime(BigInteger.valueOf(time));
record.setOrginalId(BigInteger.valueOf(photoId));
} catch (Exception ex) {
throw new ApiException("文件名不符合规范，解析失败");
}
int length = cmdid.length();
Date now = new Date();
String folder = DateUtil.format(now, "yyyy/MM/dd") + "/" + cmdid.substring(length - 2);
File dir = new File(C_PATH + folder);
dir.mkdirs();
Date photoTime = new Date(time * 1000);
String strTime = DateUtil.format(photoTime, "yyyyMMddHHmmss");
String filename = cmdid + "_" + record.getChannelId() + "_" + hexC + "_" + strTime + "." + suffix;
String filePath = folder + "/" + filename;
File dest = new File(C_PATH + filePath);
file.transferTo(dest);
log.info("成功上传一张图片" + filePath);
record.setTermId(term.getId());
record.setMediaType(0);
record.setPath(filePath);
record.setRecvTime(BigInteger.valueOf(now.getTime() / 1000));
record.setRecvEndTime(BigInteger.valueOf(now.getTime() / 1000));
record.setCreateTime(now);
record.setFlags(0);
record.setIsMark(0);
try {
BufferedImage image = ImageIO.read(dest);
if (image != null) {
int width = image.getWidth();
int height = image.getHeight();
record.setWidth(width);
record.setHeight(height);
}
} catch (IOException ignore) {
}
long fileSize = Files.size(Paths.get(C_PATH + filePath));
record.setFileSize((int) fileSize);
terminalPhotoDao.insert(record);
}
/**
* 图片查询
*/

2
xymanager_service/src/main/java/com/shxy/xymanager_service/service/TerminalPhotoService.java
Unescape Escape View File

@ -117,5 +117,7 @@ public interface TerminalPhotoService {
ServiceBody<String> takeAlarm(TerminalPhotoTestVo vo);
void upload(MultipartFile file, String cmdid) throws Exception;
}

Write Preview
Loading…
Cancel
Save