package com.ruoyi.project.mobile.controller;
|
|
|
import com.ruoyi.common.utils.StringUtils;
|
import com.ruoyi.common.utils.file.FileUploadUtils;
|
import com.ruoyi.framework.config.RuoYiConfig;
|
import com.ruoyi.framework.config.ServerConfig;
|
import com.ruoyi.framework.web.domain.AjaxResult;
|
import com.ruoyi.project.mobile.domain.ApiRequestHeader;
|
import com.ruoyi.project.mobile.domain.ApiResult;
|
import com.ruoyi.project.mobile.service.ApiService;
|
import com.ruoyi.project.mobile.service.ApiSystemService;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.lang.reflect.InvocationTargetException;
|
import java.lang.reflect.Method;
|
|
/**
|
* APP使用的统一接口
|
*/
|
@Api("安卓总控制器")
|
@Controller
|
@RequestMapping(value = "/mobile/api")
|
public class ApiController extends BaseMobileController {
|
|
private static Logger logger = LoggerFactory.getLogger(ApiController.class);
|
|
@Autowired
|
ApiService service;
|
|
@Autowired
|
private ServerConfig serverConfig;
|
|
@Autowired
|
ApiSystemService apiSystemService;
|
|
@ApiOperation("登录Index")
|
@RequestMapping(value = "/index", method = RequestMethod.POST)
|
@ResponseBody
|
public ApiResult index(@RequestBody String str, HttpServletRequest request) {
|
ApiResult apiResult = null;
|
ApiRequestHeader header = parseHeader(request);
|
try {
|
logger.debug("╔════════════════════════════════════════════════════════════════════════════════════════");
|
logger.debug("║ " + header.code);
|
logger.debug("╟────────────────────────────────────────────────────────────────────────────────────────");
|
logger.debug("║ token：" + header.token);
|
logger.debug("║ deviceType：" + header.deviceType);
|
logger.debug("║ deviceId：" + header.deviceId);
|
logger.debug("║ appType：" + header.appType);
|
logger.debug("║ loginName：" + header.loginName);
|
logger.debug("║ userId：" + header.userId);
|
logger.debug("╟────────────────────────────────────────────────────────────────────────────────────────");
|
logger.debug("║ " + str);
|
logger.debug("╚════════════════════════════════════════════════════════════════════════════════════════");
|
|
if (StringUtils.isEmpty(header.deviceType)) {
|
return ApiResult.error("设备类型不能为空");
|
}
|
if (StringUtils.isEmpty(header.deviceId)) {
|
return ApiResult.error("设备id不能为空");
|
}
|
if (StringUtils.isEmpty(header.appType)) {
|
return ApiResult.error("app类型不能为空");
|
}
|
if (StringUtils.isEmpty(header.loginName)) {
|
return ApiResult.error("用户登录帐号不能为空");
|
}else{
|
String loginName = java.net.URLDecoder.decode(header.loginName,"utf-8");
|
header.loginName = loginName;
|
}
|
if (StringUtils.isEmpty(header.code)) {
|
return ApiResult.error("请求类型不能为空");
|
}
|
apiResult = processByReflect(str, header);
|
} catch (Exception ex) {
|
logger.error(ex.getLocalizedMessage());
|
ApiResult.error("异常");
|
}
|
return apiResult;
|
|
}
|
|
|
private ApiResult processByReflect(String str, ApiRequestHeader header) {
|
Class clazz = service.getClass();
|
Method mehtod;
|
try {
|
mehtod = clazz.getDeclaredMethod(header.code, String.class, ApiRequestHeader.class);
|
} catch (Exception ex) {
|
logger.error(ex.getLocalizedMessage());
|
return ApiResult.error("业务[" + header.code + "]不存在！");
|
}
|
ApiResult apiResult;
|
//分发
|
try {
|
apiResult = (ApiResult) mehtod.invoke(service, str, header);
|
} catch (IllegalAccessException ex) {
|
logger.error(ex.getLocalizedMessage());
|
//TODO:正式部署，把后面的异常信息移除
|
apiResult = ApiResult.error("业务[" + header.code + "]process1执行异常！" + ex.getLocalizedMessage());
|
} catch (InvocationTargetException ex) {
|
logger.error(ex.getLocalizedMessage());
|
String msg = ex.getTargetException().getLocalizedMessage();
|
logger.error("targetexception: " + msg);
|
//TODO:正式部署，把后面的异常信息移除
|
apiResult = ApiResult.error("业务[" + header.code + "]process2执行异常！" + msg);
|
}
|
return apiResult;
|
}
|
|
|
/**
|
* 手机用上传方法
|
* @param file
|
* @return
|
* @throws Exception
|
*/
|
@PostMapping("/upload")
|
@ResponseBody
|
public AjaxResult uploadImg(MultipartFile file) throws Exception {
|
try {
|
// 上传文件路径
|
String filePath = RuoYiConfig.getUploadPath();
|
// 上传并返回新文件名称
|
String fileName = FileUploadUtils.upload(filePath, file);
|
String url = serverConfig.getUrl() + fileName;
|
AjaxResult ajax = AjaxResult.success();
|
ajax.put("imageName", fileName);
|
ajax.put("imageUrl", url);
|
|
return ajax;
|
} catch (Exception e) {
|
return AjaxResult.error(e.getMessage());
|
}
|
}
|
|
}
|
