package jnpf.controller;
|
|
import com.alibaba.fastjson.JSON;
|
import io.swagger.v3.oas.annotations.Operation;
|
import io.swagger.v3.oas.annotations.Parameter;
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
import jnpf.base.ActionResult;
|
import jnpf.base.vo.PageListVO;
|
import jnpf.base.vo.PaginationVO;
|
import jnpf.config.ConfigValueUtil;
|
import jnpf.constant.FileTypeConstant;
|
import jnpf.constant.MsgCode;
|
import jnpf.entity.FileEntity;
|
import jnpf.file.FileApi;
|
import jnpf.model.UploaderVO;
|
import jnpf.model.YozoFileParams;
|
import jnpf.model.YozoParams;
|
import jnpf.service.YozoService;
|
import jnpf.util.FileUtil;
|
import jnpf.util.JsonUtil;
|
import jnpf.util.XSSEscape;
|
import jnpf.util.YozoUtils;
|
import jnpf.util.wxutil.HttpUtil;
|
import lombok.RequiredArgsConstructor;
|
import org.apache.commons.io.FileUtils;
|
import org.springframework.http.MediaType;
|
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import java.io.File;
|
import java.io.IOException;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* @author JNPF
|
*/
|
@RestController
|
@RequestMapping
|
@Tag(name = "永中文件预览编辑")
|
@RequiredArgsConstructor
|
public class YozoFileController {
|
|
|
private final YozoService yozoService;
|
private final YozoUtils yozoUtil;
|
private final ConfigValueUtil configValueUtil;
|
private final FileApi fileApi;
|
private final YozoParams yozoParams;
|
|
public static final String APPID = "&appId=";
|
public static final String FILE_VERSION_ID = "fileVersionId";
|
|
|
@PostMapping("/getUrl")
|
@Operation(summary = "在线预览")
|
@Parameter(name = "params", description = "永中模型", required = true)
|
public ActionResult<Object> getUrl(@RequestBody YozoFileParams params) {
|
String previewUrl = yozoService.getPreviewUrl(params);
|
return ActionResult.success("success", previewUrl);
|
}
|
|
@PostMapping(value = "/upload", consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
|
@Operation(summary = "上传本地文件")
|
public ActionResult<Object> upload(@RequestPart("multipartFile") MultipartFile file) throws IOException {
|
String result = yozoUtil.uploadFileInPreview(file.getInputStream(), file.getOriginalFilename());
|
String fileName = file.getOriginalFilename();
|
UploaderVO vo = UploaderVO.builder().name(fileName).build();
|
Map<String, Object> map = JsonUtil.stringToMap(result);
|
if ("操作成功".equals(map.get("message"))) {
|
Map<String, Object> dataMap = JsonUtil.stringToMap(String.valueOf(map.get("data")));
|
String verId = String.valueOf(dataMap.get(FILE_VERSION_ID));
|
vo.setFileVersionId(verId);
|
return ActionResult.success("Success", vo);
|
}
|
|
return ActionResult.fail(MsgCode.FA033.get());
|
}
|
|
@GetMapping("/newCreate")
|
@Operation(summary = "新建文件")
|
@Parameter(name = "fileName", description = "名称")
|
@Parameter(name = "templateType", description = "类型")
|
public ActionResult<Object> newCreate(@RequestParam("fileName") String fileName, @RequestParam("templateType") String templateType) {
|
String fileNa = yozoUtil.getFileName(fileName, templateType);
|
if (fileNa == null) {
|
return ActionResult.fail(MsgCode.FA042.get());
|
}
|
//判断文件是否创建过
|
FileEntity fileEntity = yozoService.selectByName(fileNa);
|
if (fileEntity != null) {
|
return ActionResult.fail(MsgCode.FA043.get());
|
}
|
Map<String, String[]> params = new HashMap<>();
|
params.put("templateType", new String[]{templateType});
|
params.put("fileName", new String[]{fileName});
|
String sign = yozoUtil.generateSign(yozoParams.getAppId(), yozoParams.getAppKey(), params).getData();
|
String url = yozoParams.getCloudDomain() + "/api/file/template?templateType=" + templateType +
|
"&fileName=" + fileName +
|
APPID + yozoParams.getAppId() +
|
FILE_VERSION_ID + sign;
|
String s = HttpUtil.sendHttpPost(url);
|
Map<String, Object> maps = JSON.parseObject(s, Map.class);
|
Map<String, String> fileMap = (Map<String, String>) maps.get("data");
|
String fileVersionId = fileMap.get(FILE_VERSION_ID);
|
String fileId = fileMap.get("fileId");
|
ActionResult<Object> back = yozoService.saveFileId(fileVersionId, fileId, fileNa);
|
//在本地新建文件
|
FileUtil.createFile(configValueUtil.getDocumentPreviewPath(), fileNa);
|
return back;
|
}
|
|
@GetMapping("/uploadByHttp")
|
@Operation(summary = "http上传文件")
|
@Parameter(name = "fileUrl", description = "路径")
|
public ActionResult<Object> uploadByHttp(@RequestParam("fileUrl") String fileUrl) {
|
//获取签名
|
Map<String, String[]> params = new HashMap<>();
|
params.put("fileUrl", new String[]{fileUrl});
|
String sign = yozoUtil.generateSign(yozoParams.getAppId(), yozoParams.getAppKey(), params).getData();
|
String url = yozoParams.getCloudDomain() + "/api/file/http?fileUrl=" + fileUrl +
|
APPID + yozoParams.getAppId() +
|
FILE_VERSION_ID + sign;
|
String s = HttpUtil.sendHttpPost(url);
|
Map<String, Object> maps = JSON.parseObject(s, Map.class);
|
Map<String, String> fileMap = (Map<String, String>) maps.get("data");
|
String fileVersionId = fileMap.get(FILE_VERSION_ID);
|
String fileId = fileMap.get("fileId");
|
return yozoService.saveFileIdByHttp(fileVersionId, fileId, fileUrl);
|
}
|
|
@GetMapping("/downloadFile")
|
@Operation(summary = "永中下载文件")
|
@Parameter(name = FILE_VERSION_ID, description = "主键")
|
public String downloadFile(@RequestParam("fileVersionId") String fileVersionId) {
|
String newFileVersionId = XSSEscape.escape(fileVersionId);
|
FileEntity fileEntity = yozoService.selectByVersionId(newFileVersionId);
|
if (fileEntity == null) {
|
return MsgCode.FA044.get();
|
}
|
//获取签名
|
Map<String, String[]> params = new HashMap<>();
|
params.put(FILE_VERSION_ID, new String[]{newFileVersionId});
|
String sign = yozoUtil.generateSign(yozoParams.getAppId(), yozoParams.getAppKey(), params).getData();
|
return yozoParams.getCloudDomain() + "/api/file/download?fileVersionId=" + newFileVersionId +
|
APPID + yozoParams.getAppId() +
|
FILE_VERSION_ID + sign;
|
}
|
|
|
@GetMapping("/deleteVersionFile")
|
@Operation(summary = "删除文件版本")
|
@Parameter(name = "fileVersionId", description = "主键")
|
public ActionResult<Object> deleteVersion(@RequestParam("fileVersionId") String fileVersionId) {
|
//获取签名
|
Map<String, String[]> params = new HashMap<>();
|
params.put(FILE_VERSION_ID, new String[]{fileVersionId});
|
String sign = yozoUtil.generateSign(yozoParams.getAppId(), yozoParams.getAppKey(), params).getData();
|
String url = yozoParams.getCloudDomain() + "/api/file/delete/version?fileVersionId=" + fileVersionId +
|
APPID + yozoParams.getAppId() +
|
FILE_VERSION_ID + sign;
|
String s = HttpUtil.sendHttpGet(url);
|
Map<String, Object> maps = JSON.parseObject(s, Map.class);
|
String fileName = yozoService.selectByVersionId(fileVersionId).getFileName();
|
String path = fileApi.getPath(FileTypeConstant.DOCUMENTPREVIEW) + fileName;
|
if (FileUtil.fileIsFile(path)) {
|
File file = new File(jnpf.util.XSSEscape.escapePath(path));
|
FileUtils.deleteQuietly(file);
|
}
|
String versionId = (String) maps.get("data");
|
return yozoService.deleteFileByVersionId(versionId);
|
}
|
|
@GetMapping("/batchDelete")
|
@Operation(summary = "批量删除文件版本")
|
@Parameter(name = "fileVersionIds", description = "主键")
|
public ActionResult<Object> batchDelete(@RequestParam("fileVersionIds") String[] fileVersionIds) {
|
//获取签名
|
Map<String, String[]> params = new HashMap<>();
|
params.put("fileVersionIds", fileVersionIds);
|
|
|
for (String s : fileVersionIds) {
|
String fileName = yozoService.selectByVersionId(s).getFileName();
|
String path = fileApi.getPath(FileTypeConstant.DOCUMENTPREVIEW) + fileName;
|
File file = new File(jnpf.util.XSSEscape.escapePath(path));
|
FileUtils.deleteQuietly(file);
|
}
|
|
|
return yozoService.deleteBatch(fileVersionIds);
|
}
|
|
@GetMapping("/editFile")
|
@Operation(summary = "在线编辑")
|
@Parameter(name = "fileVersionId", description = "主键")
|
public ActionResult<Object> editFile(@RequestParam("fileVersionId") String fileVersionId) {
|
String newFileVersionId = XSSEscape.escape(fileVersionId);
|
//获取签名
|
Map<String, String[]> params = new HashMap<>();
|
params.put(FILE_VERSION_ID, new String[]{fileVersionId});
|
String sign = yozoUtil.generateSign(yozoParams.getAppId(), yozoParams.getAppKey(), params).getData();
|
String url = yozoParams.getEditDomain() + "/api/edit/file?fileVersionId=" + newFileVersionId +
|
APPID + yozoParams.getAppId() +
|
FILE_VERSION_ID + sign;
|
return ActionResult.success("success", url);
|
}
|
|
/**
|
* 永中回调
|
*
|
* @param oldFileId
|
* @param newFileId
|
* @param message
|
* @param errorCode
|
* @return
|
*/
|
@PostMapping("/3rd/edit/callBack")
|
@Parameter(name = "oldFileId", description = "主键")
|
@Parameter(name = "newFileId", description = "主键")
|
@Parameter(name = "message", description = "消息")
|
@Parameter(name = "errorCode", description = "编码")
|
public Map<String, Object> editCallBack(@RequestParam("oldFileId") String oldFileId, @RequestParam("newFileId") String newFileId, @RequestParam("message") String message, @RequestParam("errorCode") Integer errorCode) {
|
|
yozoService.editFileVersion(oldFileId, newFileId);
|
|
Map<String, Object> result = new HashMap<>();
|
result.put("oldFileId", oldFileId);
|
result.put("newFileId", newFileId);
|
result.put("message", message);
|
result.put("errorCode", errorCode);
|
result = XSSEscape.escapeObj(result);
|
return result;
|
}
|
|
@PostMapping("/documentList")
|
@Operation(summary = "文档列表")
|
@Parameter(name = "pageModel", description = "分页模型", required = true)
|
public ActionResult<PageListVO<FileEntity>> documentList(@RequestBody PaginationVO pageModel) {
|
List<FileEntity> list = yozoService.getAllList(pageModel);
|
return ActionResult.page(list, pageModel);
|
}
|
|
/**
|
* 传入新的fileVersionId同步
|
*
|
* @param fileVersionId
|
* @return
|
* @throws Exception
|
*/
|
@GetMapping("/updateFile")
|
@Operation(summary = "/同步文件版本到本地")
|
@Parameter(name = "fileVersionId", description = "主键")
|
public ActionResult<Object> updateFile(@RequestParam("fileVersionId") String fileVersionId) throws Exception {
|
FileEntity fileEntity = yozoService.selectByVersionId(fileVersionId);
|
String fileName = fileEntity.getFileName();
|
String path = fileApi.getPath(FileTypeConstant.DOCUMENTPREVIEW) + fileName;
|
if (FileUtil.fileIsFile(path)) {
|
File file = new File(jnpf.util.XSSEscape.escapePath(path));
|
FileUtils.deleteQuietly(file);
|
}
|
String fileUrl = this.downloadFile(fileVersionId);
|
yozoUtil.downloadFile(fileUrl, path);
|
return ActionResult.success(MsgCode.SU004.get());
|
}
|
}
|
