CmdApi.java
5.37 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
package com.java110.service.api;
import com.java110.core.base.controller.BaseController;
import com.java110.core.factory.GenerateCodeFactory;
import com.java110.core.log.LoggerFactory;
import com.java110.dto.log.LogSystemErrorDto;
import com.java110.po.log.LogSystemErrorPo;
import com.java110.service.smo.ICmdServiceSMO;
import com.java110.service.smo.ISaveSystemErrorSMO;
import com.java110.utils.constant.CommonConstant;
import com.java110.utils.util.ExceptionUtil;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiOperation;
import org.slf4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletRequest;
import java.util.HashMap;
import java.util.Map;
/**
* 查询服务
* add by wuxw on 2018/4/20.
* modify by wuxw on 2019/4/20.
*
* @version 1.1
*/
@RestController
@RequestMapping(path = "/cmd")
public class CmdApi extends BaseController {
private final static Logger logger = LoggerFactory.getLogger(CmdApi.class);
@Autowired
private ICmdServiceSMO cmdServiceSMOImpl;
@Autowired
ISaveSystemErrorSMO saveSystemErrorSMOImpl;
/**
* 微服务 /cmd/xx.xx 接受类
* @param service
* @param postInfo
* @param request
* @return
*/
@RequestMapping(path = "/{service:.+}", method = RequestMethod.POST)
public ResponseEntity<String> service(@PathVariable String service,
@RequestBody String postInfo,
HttpServletRequest request) {
ResponseEntity<String> responseEntity = null;
Map<String, String> headers = new HashMap<String, String>();
try {
//todo 头信息封装
this.getRequestInfo(request, headers);
//todo 将serviceCode 写入到头信息
headers.put(CommonConstant.HTTP_SERVICE, service);
//todo 将请求方式 写入到头信息
headers.put(CommonConstant.HTTP_METHOD, CommonConstant.HTTP_METHOD_POST);
logger.debug("api：{} 请求报文为：{},header信息为：{}", service, postInfo, headers);
//todo 开始调用 cmd 类
responseEntity = cmdServiceSMOImpl.cmd(postInfo, headers);
} catch (Throwable e) {
//todo 异常信息进行记录
LogSystemErrorPo logSystemErrorPo = new LogSystemErrorPo();
logSystemErrorPo.setErrId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_errId));
logSystemErrorPo.setErrType(LogSystemErrorDto.ERR_TYPE_CMD);
logSystemErrorPo.setMsg(ExceptionUtil.getStackTrace(e));
//todo 日志
saveSystemErrorSMOImpl.saveLog(logSystemErrorPo);
logger.error("请求post 方法[" + service + "]失败：" + postInfo, e);
responseEntity = new ResponseEntity<String>(e.getMessage(), HttpStatus.INTERNAL_SERVER_ERROR);
}
logger.debug("cmd：{} 返回信息为：{}", service, responseEntity);
return responseEntity;
}
/**
* 资源请求 post方式
*
* @param resource 请求接口方式
* @param postInfo post内容
* @param request 请求对象 查询头信息 url等信息
* @return http status 200 成功 其他失败
*/
@RequestMapping(path = "/{resource}/{action}", method = RequestMethod.POST)
@ApiOperation(value = "资源post请求", notes = "test: 返回 2XX 表示服务正常")
@ApiImplicitParam(paramType = "query", name = "subServicePost", value = "用户编号", required = true, dataType = "String")
public ResponseEntity<String> subServicePost(
@PathVariable String resource,
@PathVariable String action,
@RequestBody String postInfo,
HttpServletRequest request) {
ResponseEntity<String> responseEntity = null;
Map<String, String> headers = new HashMap<String, String>();
try {
this.getRequestInfo(request, headers);
headers.put(CommonConstant.HTTP_SERVICE, "/" + resource + "/" + action);
headers.put(CommonConstant.HTTP_RESOURCE, resource);
headers.put(CommonConstant.HTTP_ACTION, action);
headers.put(CommonConstant.HTTP_METHOD, CommonConstant.HTTP_METHOD_POST);
logger.debug("api：{} 请求报文为：{},header信息为：{}", action, postInfo, headers);
responseEntity = cmdServiceSMOImpl.cmd(postInfo, headers);
} catch (Throwable e) {
logger.error("请求post 方法[" + action + "]失败：" + postInfo, e);
responseEntity = new ResponseEntity<String>("请求发生异常，" + e.getMessage(), HttpStatus.INTERNAL_SERVER_ERROR);
}
logger.debug("cmd：{} 返回信息为：{}", action, responseEntity);
return responseEntity;
}
/**
* 获取请求信息
*
* @param request
* @param headers
* @throws RuntimeException
*/
private void getRequestInfo(HttpServletRequest request, Map headers) throws Exception {
try {
super.initHeadParam(request, headers);
super.initUrlParam(request, headers);
} catch (Exception e) {
logger.error("加载头信息失败", e);
throw e;
}
}
}