DataQuery.java
4.6 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
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
package com.java110.service.context;
import com.alibaba.fastjson.JSONObject;
import com.java110.utils.factory.ApplicationContextFactory;
import com.java110.dto.system.ServiceSql;
import com.java110.db.dao.IQueryServiceDAO;
import org.springframework.http.RequestEntity;
import org.springframework.http.ResponseEntity;
import org.springframework.web.client.RestTemplate;
import java.util.List;
import java.util.Map;
/**
* 数据查询对象
* Created by wuxw on 2018/4/19.
*/
public class DataQuery {
//服务编码
private String serviceCode;
private String templateKey;
//请求参数
private JSONObject requestParams;
//返回信息
private JSONObject responseInfo;
private ServiceSql serviceSql;
//rest 返回对象
private ResponseEntity responseEntity;
public String getTemplateKey() {
return templateKey;
}
public void setTemplateKey(String templateKey) {
this.templateKey = templateKey;
}
public String getServiceCode() {
return serviceCode;
}
public void setServiceCode(String serviceCode) {
this.serviceCode = serviceCode;
}
public JSONObject getRequestParams() {
return requestParams;
}
public void setRequestParams(JSONObject requestParams) {
this.requestParams = requestParams;
}
public JSONObject getResponseInfo() {
return responseInfo;
}
public void setResponseInfo(JSONObject responseInfo) {
this.responseInfo = responseInfo;
}
public ServiceSql getServiceSql() {
return serviceSql;
}
public void setServiceSql(ServiceSql serviceSql) {
this.serviceSql = serviceSql;
}
public ResponseEntity getResponseEntity() {
return responseEntity;
}
public void setResponseEntity(ResponseEntity responseEntity) {
this.responseEntity = responseEntity;
}
/**
* {
"bId":"12345678",
"serviceCode": "querycustinfo",
"serviceName": "查询客户",
"remark": "备注",
"datas": {
"params": {
//这个做查询时的参数
}
//这里是具体业务
}
}
* 构建DataQuery
* @return
*/
public DataQuery builder(String businessInfo){
JSONObject businessInfoObj = JSONObject.parseObject(businessInfo);
JSONObject currentBusinessInfo = null;
//这里为了兼容 centerService
if(businessInfoObj.containsKey("business")){
if(businessInfoObj.get("business") instanceof JSONObject){
currentBusinessInfo = (JSONObject) businessInfoObj.get("business");
}/*else if(businessInfoObj.get("business") instanceof JSONArray){
currentBusinessInfo = ((JSONArray) businessInfoObj.get("business")).getJSONObject(0);
}*/else {
return null;
}
}else{
currentBusinessInfo = businessInfoObj;
}
this.setServiceCode(currentBusinessInfo.getString("serviceCode"));
this.setRequestParams(currentBusinessInfo.getJSONObject("datas").getJSONObject("params"));
return this;
}
public DataQuery builder(Map<String, Object> headers){
this.setServiceCode(headers.get("service").toString());
this.setRequestParams(JSONObject.parseObject(JSONObject.toJSONString(headers.get("params"))));
return this;
}
/**
* 根据SQL查询数据
* @param sql sql 语句
* @param sqlParam sql 参数
* @return 查询结果
*/
public List<Map<String, Object>> queryDataBySql(String sql, List<Object> sqlParam){
IQueryServiceDAO queryServiceDAOImpl = ApplicationContextFactory.getBean("queryServiceDAOImpl",IQueryServiceDAO.class);
return queryServiceDAOImpl.executeSql(sql, sqlParam.toArray());
}
/**
* 调用服务接口
* @param requestEntity 请求实体
* @return
*/
public ResponseEntity<String> callService(RequestEntity requestEntity){
return callService(requestEntity,false);
}
/**
* 调用服务接口
* @param requestEntity 请求实体
* @param innerService 内部服务 true 外部服务为false
* @return
*/
public ResponseEntity<String> callService(RequestEntity requestEntity,Boolean innerService){
RestTemplate restTemplate = null;
if(innerService){
restTemplate = ApplicationContextFactory.getBean("restTemplate",RestTemplate.class);
}else{
restTemplate = ApplicationContextFactory.getBean("outRestTemplate",RestTemplate.class);
}
return restTemplate.exchange(requestEntity,String.class);
}
}