package doumeemes.api.common;
|
|
import com.alibaba.fastjson.JSONObject;
|
import doumeemes.api.BaseController;
|
import doumeemes.biz.system.SystemDictDataBiz;
|
import doumeemes.core.model.LoginUserInfo;
|
import doumeemes.core.utils.Constants;
|
import doumeemes.core.utils.DateUtil;
|
import doumeemes.core.utils.aliyun.ALiYunUtil;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiImplicitParam;
|
import io.swagger.annotations.ApiImplicitParams;
|
import io.swagger.annotations.ApiOperation;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.shiro.SecurityUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
import org.springframework.web.multipart.MultipartFile;
|
import org.springframework.web.multipart.MultipartHttpServletRequest;
|
import org.springframework.web.multipart.commons.CommonsMultipartResolver;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
import java.io.IOException;
|
import java.io.PrintWriter;
|
import java.util.HashMap;
|
import java.util.Iterator;
|
import java.util.Map;
|
import java.util.UUID;
|
|
/**
|
* Controller基类
|
* @author Eva.Caesar Liu
|
* @date 2022/04/18 18:12
|
*/
|
@Slf4j
|
@Api(tags = "通用接口类")
|
@RestController
|
public class CommonController extends BaseController {
|
|
@Autowired
|
private SystemDictDataBiz systemDictDataBiz;
|
|
/**
|
* 获取当前登录用户
|
* @author Eva.Caesar Liu
|
* @date 2022/04/18 18:12
|
*/
|
@Override
|
protected LoginUserInfo getLoginUser () {
|
return (LoginUserInfo)SecurityUtils.getSubject().getPrincipal();
|
}
|
/**
|
* 手机端上传
|
*
|
* @param folder
|
* @param request
|
* @param response
|
* @throws Exception
|
*/
|
@ApiOperation(value = "上传", notes = "上传", httpMethod = "POST", position = 6)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "folder", value = "文件夹", required = true, paramType = "query", dataType = "String", dataTypeClass = String.class),
|
})
|
@PostMapping(value = "/upload", headers = "content-type=multipart/form-data")
|
public void uploadMobile(String folder, HttpServletRequest request, HttpServletResponse response) throws Exception {
|
MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request;
|
upload(multipartRequest, response, folder + "/",
|
systemDictDataBiz.queryByCode(Constants.OSS,Constants.BUCKETNAME).getCode(),
|
systemDictDataBiz.queryByCode(Constants.OSS,Constants.ACCESS_ID).getCode(),
|
systemDictDataBiz.queryByCode(Constants.OSS,Constants.ACCESS_KEY).getCode(),
|
systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode(),
|
systemDictDataBiz.queryByCode(Constants.OSS,Constants.ENDPOINT).getCode());
|
}
|
//
|
// public void upload(HttpServletRequest request, HttpServletResponse response, String folder, String bucketName,
|
// String access_id, String access_key, String resourcePath, String endpoint) throws Exception {
|
// response.setCharacterEncoding("UTF-8");
|
// response.setContentType("text/html;charset=UTF-8");
|
// Map<String, Object> context = new HashMap<>();
|
// CommonsMultipartResolver multipartResovler = new CommonsMultipartResolver();
|
// if (multipartResovler.isMultipart(request)) {
|
// MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request;
|
// Iterator<String> it = multipartRequest.getFileNames();
|
// while (it.hasNext()) {
|
// MultipartFile file = multipartRequest.getFile((String) it.next());// file
|
// // multipartRequest.getFile((String)
|
// // it.next());
|
// if (file != null) {
|
// // 1、上传到服务器临时文件夹
|
// String uploadFileName = file.getOriginalFilename();
|
// String originname = uploadFileName;
|
// if (originname.lastIndexOf("/") >= 0) {
|
// originname = originname.substring(originname.lastIndexOf("/") + 1);
|
// }
|
// String nfix = "";// 后缀名
|
// if (StringUtils.isNotBlank(uploadFileName)) {
|
// nfix = uploadFileName.substring(uploadFileName.lastIndexOf("."));
|
// }
|
// if (StringUtils.equalsIgnoreCase(nfix, ".exe")) {
|
// context.put("code", 0);
|
// context.put("message", "对不起，文件格式\".exe\"上传有误！");
|
// return;
|
// }
|
// String nowDate = DateUtil.getNowShortDate();// 当前时间（年月日）
|
// String fileName = UUID.randomUUID().toString() + nfix;
|
// String tempFileName = nowDate + "/" + fileName;
|
// String key = folder + tempFileName;// 文件名
|
// ALiYunUtil obs = new ALiYunUtil(endpoint,access_id, access_key);
|
// if (obs.uploadOnlineObject(file.getInputStream(),bucketName, key,null)) {
|
// // 移动成功,返回文件名
|
// // sendSuccessMessage(response, resourcePath+key);
|
// context.put("error", 0);
|
// context.put("code", 1);
|
// context.put("url", resourcePath + key);
|
// context.put("imgaddr", tempFileName);
|
// context.put("imgname", fileName);
|
// context.put("originname", originname);
|
// writerJson(response, context);
|
// return;
|
// } else {
|
// // 移动失败
|
// context.put("code", 0);
|
// context.put("message", "上传失败");
|
// writerJson(response, context);
|
// return;
|
// }
|
// }
|
//
|
// }
|
// }
|
// context.put("code", 0);
|
// context.put("message", "上传失败");
|
// writerJson(response, context);
|
// return;
|
// }
|
//
|
// public static void writerJson(HttpServletResponse response, Object object) {
|
// response.setContentType("application/json");
|
// writer(response, JSONObject.toJSONString(object));
|
// }
|
//
|
// private static void writer(HttpServletResponse response, String str) {
|
// try {
|
// StringBuffer result = new StringBuffer();
|
// //设置页面不缓存
|
// response.setHeader("Pragma", "No-cache");
|
// response.setHeader("Cache-Control", "no-cache");
|
// response.setCharacterEncoding("UTF-8");
|
// PrintWriter out = null;
|
// out = response.getWriter();
|
// out.print(str);
|
// out.flush();
|
// out.close();
|
// } catch (IOException e) {
|
// e.printStackTrace();
|
// }
|
// }
|
}
|
