|
@ -14,7 +14,11 @@ import com.ccsens.util.exception.BaseException; |
|
|
import io.swagger.annotations.*; |
|
|
import io.swagger.annotations.*; |
|
|
import lombok.Data; |
|
|
import lombok.Data; |
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
|
|
import org.springframework.data.repository.query.Param; |
|
|
|
|
|
import org.springframework.web.bind.WebDataBinder; |
|
|
import org.springframework.web.bind.annotation.*; |
|
|
import org.springframework.web.bind.annotation.*; |
|
|
|
|
|
import org.springframework.web.context.request.RequestContextHolder; |
|
|
|
|
|
import org.springframework.web.context.request.ServletRequestAttributes; |
|
|
|
|
|
|
|
|
import javax.annotation.Resource; |
|
|
import javax.annotation.Resource; |
|
|
import javax.servlet.http.HttpServletRequest; |
|
|
import javax.servlet.http.HttpServletRequest; |
|
@ -40,13 +44,19 @@ public class WpsController { |
|
|
@Resource |
|
|
@Resource |
|
|
private IUserService userService; |
|
|
private IUserService userService; |
|
|
|
|
|
|
|
|
|
|
|
@InitBinder |
|
|
|
|
|
protected void initBinder(WebDataBinder binder) { |
|
|
|
|
|
// 解决下划线开头参数无法映射到实体的问题
|
|
|
|
|
|
binder.setFieldMarkerPrefix(null); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
@ApiOperation(value = "获取文件元数据", notes = "在预览或编辑的时候,通过接口校验权限并获取文件信息") |
|
|
@ApiOperation(value = "获取文件元数据", notes = "在预览或编辑的时候,通过接口校验权限并获取文件信息") |
|
|
@ApiImplicitParams({ |
|
|
@ApiImplicitParams({ |
|
|
}) |
|
|
}) |
|
|
@GetMapping(value = "file/info", produces = {"application/json;charset=UTF-8"}) |
|
|
@GetMapping(value = "file/info", produces = {"application/json;charset=UTF-8"}) |
|
|
public WpsVo.FileInfo fileInfo(HttpServletRequest request, @Valid WpsDto.FileInfo fileInfo) throws Exception { |
|
|
public WpsVo.FileInfo fileInfo(HttpServletRequest request, WpsDto.FileInfo fileInfo) throws Exception { |
|
|
log.info("获取文件元数据请求参数:{}", fileInfo); |
|
|
log.info("获取文件元数据请求参数:{}", fileInfo); |
|
|
WpsHeader header = checkSignature(request, fileInfo.getSignature()); |
|
|
WpsHeader header = checkSignature(request, fileInfo.get_w_signature()); |
|
|
// 判断登录,查询userid
|
|
|
// 判断登录,查询userid
|
|
|
WpsVo.FileInfo fileInfoVo = wpsService.getFileInfo(header.getFileId(), header.getToken()); |
|
|
WpsVo.FileInfo fileInfoVo = wpsService.getFileInfo(header.getFileId(), header.getToken()); |
|
|
log.info("获取文件元数据返回:{}", fileInfoVo); |
|
|
log.info("获取文件元数据返回:{}", fileInfoVo); |
|
@ -67,7 +77,7 @@ public class WpsController { |
|
|
log.info("请求参数中没有用户ID"); |
|
|
log.info("请求参数中没有用户ID"); |
|
|
throw new BaseException(CodeEnum.PARAM_ERROR); |
|
|
throw new BaseException(CodeEnum.PARAM_ERROR); |
|
|
} |
|
|
} |
|
|
WpsHeader header = checkSignature(request, userInfo.getSignature()); |
|
|
WpsHeader header = checkSignature(request, userInfo.get_w_signature()); |
|
|
List<UserVo.UserInfo> infos = userService.queryUserInfos(body.getIds()); |
|
|
List<UserVo.UserInfo> infos = userService.queryUserInfos(body.getIds()); |
|
|
log.info("获取用户信息:{}", infos); |
|
|
log.info("获取用户信息:{}", infos); |
|
|
return WpsVo.UserInfo.getInstance(infos); |
|
|
return WpsVo.UserInfo.getInstance(infos); |
|
@ -79,7 +89,7 @@ public class WpsController { |
|
|
@PostMapping(value = "file/save", produces = {"application/json;charset=UTF-8"}) |
|
|
@PostMapping(value = "file/save", produces = {"application/json;charset=UTF-8"}) |
|
|
public WpsVo.FileSave fileSave(HttpServletRequest request, @Valid WpsDto.FileSave fileSave, @RequestBody Part file) throws Exception { |
|
|
public WpsVo.FileSave fileSave(HttpServletRequest request, @Valid WpsDto.FileSave fileSave, @RequestBody Part file) throws Exception { |
|
|
log.info("上传文件新版本请求参数:{}", fileSave); |
|
|
log.info("上传文件新版本请求参数:{}", fileSave); |
|
|
WpsHeader header = checkSignature(request, fileSave.getSignature()); |
|
|
WpsHeader header = checkSignature(request, fileSave.get_w_signature()); |
|
|
|
|
|
|
|
|
WpsVo.FileSave save = wpsService.fileSave(header.getToken(), header.getFileId(), fileSave, file); |
|
|
WpsVo.FileSave save = wpsService.fileSave(header.getToken(), header.getFileId(), fileSave, file); |
|
|
log.info("上传文件新版本返回:{}", save); |
|
|
log.info("上传文件新版本返回:{}", save); |
|
@ -108,7 +118,7 @@ public class WpsController { |
|
|
@GetMapping(value = "file/version/{version}", produces = {"application/json;charset=UTF-8"}) |
|
|
@GetMapping(value = "file/version/{version}", produces = {"application/json;charset=UTF-8"}) |
|
|
public WpsVo.FileBase fileVersion(HttpServletRequest request, @PathVariable("version") Integer version, WpsDto.FileVersion fileVersion) throws Exception { |
|
|
public WpsVo.FileBase fileVersion(HttpServletRequest request, @PathVariable("version") Integer version, WpsDto.FileVersion fileVersion) throws Exception { |
|
|
log.info("上传文件新版本请求参数:{}", fileVersion); |
|
|
log.info("上传文件新版本请求参数:{}", fileVersion); |
|
|
WpsHeader header = checkSignature(request, fileVersion.getSignature()); |
|
|
WpsHeader header = checkSignature(request, fileVersion.get_w_signature()); |
|
|
WpsVo.FileBase base = wpsService.fileVersion(header.getToken(), Long.parseLong(header.getFileId()), version); |
|
|
WpsVo.FileBase base = wpsService.fileVersion(header.getToken(), Long.parseLong(header.getFileId()), version); |
|
|
log.info("版本{}的文件信息:{}", version, base); |
|
|
log.info("版本{}的文件信息:{}", version, base); |
|
|
return base; |
|
|
return base; |
|
@ -121,7 +131,7 @@ public class WpsController { |
|
|
public JsonResponse fileRename(HttpServletRequest request, WpsDto.FileRename fileRename, @RequestBody WpsDto.FileRenameBody renameBody) throws Exception { |
|
|
public JsonResponse fileRename(HttpServletRequest request, WpsDto.FileRename fileRename, @RequestBody WpsDto.FileRenameBody renameBody) throws Exception { |
|
|
|
|
|
|
|
|
log.info("上传文件新版本请求参数:{}", fileRename); |
|
|
log.info("上传文件新版本请求参数:{}", fileRename); |
|
|
WpsHeader header = checkSignature(request, fileRename.getSignature()); |
|
|
WpsHeader header = checkSignature(request, fileRename.get_w_signature()); |
|
|
wpsService.fileRename(header.getToken(), Long.parseLong(header.getFileId()), renameBody); |
|
|
wpsService.fileRename(header.getToken(), Long.parseLong(header.getFileId()), renameBody); |
|
|
return JsonResponse.newInstance().ok(); |
|
|
return JsonResponse.newInstance().ok(); |
|
|
} |
|
|
} |
|
@ -132,7 +142,7 @@ public class WpsController { |
|
|
@PostMapping(value = "file/history", produces = {"application/json;charset=UTF-8"}) |
|
|
@PostMapping(value = "file/history", produces = {"application/json;charset=UTF-8"}) |
|
|
public WpsVo.FileHistory fileHistory(HttpServletRequest request, WpsDto.FileHistory history, @RequestBody WpsDto.FileHistoryBody body) throws Exception { |
|
|
public WpsVo.FileHistory fileHistory(HttpServletRequest request, WpsDto.FileHistory history, @RequestBody WpsDto.FileHistoryBody body) throws Exception { |
|
|
log.info("获取所有历史版本文件信息请求参数:{}, {}", history, body); |
|
|
log.info("获取所有历史版本文件信息请求参数:{}, {}", history, body); |
|
|
WpsHeader header = checkSignature(request, history.getSignature()); |
|
|
WpsHeader header = checkSignature(request, history.get_w_signature()); |
|
|
List<WpsVo.FileHistoryMsg> histories = wpsService.queryFileHistory(header.getToken(), body); |
|
|
List<WpsVo.FileHistoryMsg> histories = wpsService.queryFileHistory(header.getToken(), body); |
|
|
log.info("所有历史版本返回信息:{}", histories); |
|
|
log.info("所有历史版本返回信息:{}", histories); |
|
|
return new WpsVo.FileHistory(histories); |
|
|
return new WpsVo.FileHistory(histories); |
|
@ -143,7 +153,7 @@ public class WpsController { |
|
|
@PostMapping(value = "file/new", produces = {"application/json;charset=UTF-8"}) |
|
|
@PostMapping(value = "file/new", produces = {"application/json;charset=UTF-8"}) |
|
|
public WpsVo.FileNew fileNew(HttpServletRequest request, WpsDto.FileNew fileNew, String name, Part file) throws Exception { |
|
|
public WpsVo.FileNew fileNew(HttpServletRequest request, WpsDto.FileNew fileNew, String name, Part file) throws Exception { |
|
|
log.info("上传文件新版本请求参数:{}", fileNew); |
|
|
log.info("上传文件新版本请求参数:{}", fileNew); |
|
|
WpsHeader header = checkSignature(request, fileNew.getSignature()); |
|
|
WpsHeader header = checkSignature(request, fileNew.get_w_signature()); |
|
|
WpsVo.FileNew fileNewVo = wpsService.fileNew(header.getToken(), header.getFileId(), name, file); |
|
|
WpsVo.FileNew fileNewVo = wpsService.fileNew(header.getToken(), header.getFileId(), name, file); |
|
|
log.info("文件新建返回:{}", fileNewVo); |
|
|
log.info("文件新建返回:{}", fileNewVo); |
|
|
return fileNewVo; |
|
|
return fileNewVo; |
|
@ -154,7 +164,7 @@ public class WpsController { |
|
|
@PostMapping(value = "onnotify", produces = {"application/json;charset=UTF-8"}) |
|
|
@PostMapping(value = "onnotify", produces = {"application/json;charset=UTF-8"}) |
|
|
public JsonResponse onnotify(HttpServletRequest request, WpsDto.Notify notify, @RequestBody WpsDto.NotifyBody body) throws Exception { |
|
|
public JsonResponse onnotify(HttpServletRequest request, WpsDto.Notify notify, @RequestBody WpsDto.NotifyBody body) throws Exception { |
|
|
log.info("wps通知请求参数:{},{}", notify, body); |
|
|
log.info("wps通知请求参数:{},{}", notify, body); |
|
|
WpsHeader header = checkSignature(request, notify.getSignature()); |
|
|
WpsHeader header = checkSignature(request, notify.get_w_signature()); |
|
|
wpsService.notify(header.getToken(), body); |
|
|
wpsService.notify(header.getToken(), body); |
|
|
log.info("wps通知完成"); |
|
|
log.info("wps通知完成"); |
|
|
return JsonResponse.newInstance().ok(); |
|
|
return JsonResponse.newInstance().ok(); |
|
|