88e030b7
 王彪总
init project
|
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
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
|
package com.java110.dev.cmd.service;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.core.annotation.Java110Cmd;
import com.java110.core.context.ICmdDataFlowContext;
import com.java110.core.event.cmd.Cmd;
import com.java110.core.event.cmd.CmdEvent;
import com.java110.core.factory.GenerateCodeFactory;
import com.java110.dto.app.AppDto;
import com.java110.dto.service.RouteDto;
import com.java110.dto.service.ServiceDto;
import com.java110.intf.community.IAppInnerServiceSMO;
import com.java110.intf.community.IRouteInnerServiceSMO;
import com.java110.intf.community.IServiceInnerServiceSMO;
import com.java110.utils.constant.ResponseConstant;
import com.java110.utils.exception.CmdException;
import com.java110.utils.exception.ListenerExecuteException;
import com.java110.utils.util.Assert;
import com.java110.utils.util.BeanConvertUtil;
import com.java110.utils.util.StringUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
/**
* 服务绑定命令类
* 用于处理应用、服务和路由之间的绑定关系
*
* @Java110Cmd 注解声明这是一个命令类，serviceCode指定服务编码
*/
@Java110Cmd(serviceCode = "service.bindingService")
public class BindingServiceCmd extends Cmd {
// 应用服务接口
@Autowired
private IAppInnerServiceSMO appInnerServiceSMOImpl;
// 服务信息接口
@Autowired
private IServiceInnerServiceSMO serviceInnerServiceSMOImpl;
// 路由服务接口
@Autowired
private IRouteInnerServiceSMO routeInnerServiceSMOImpl;
/**
* 参数验证方法
* 验证请求参数是否完整和有效
*
* @param event 命令事件
* @param context 数据流上下文
* @param reqJson 请求JSON对象
* @throws CmdException 命令异常
*/
@Override
public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
// 从请求中获取数据数组
JSONArray infos = reqJson.getJSONArray("data");
// 验证路由视图中的必填字段
Assert.hasKeyByFlowData(infos, "addRouteView", "orderTypeCd", "必填，请填写订单类型");
Assert.hasKeyByFlowData(infos, "addRouteView", "invokeLimitTimes", "必填，请填写调用次数");
Assert.hasKeyByFlowData(infos, "addRouteView", "invokeModel", "可填，请填写消息队列，订单在异步调用时使用");
// 验证数据数组长度必须为3（应用、服务、路由扩展信息）
if(infos == null || infos.size() !=3){
throw new IllegalArgumentException("请求参数错误，为包含 应用，服务或扩展信息");
}
}
/**
* 命令执行方法
* 处理服务绑定逻辑，包括应用、服务和路由信息的保存
*
* @param event 命令事件
* @param context 数据流上下文
* @param reqJson 请求JSON对象
* @throws CmdException 命令异常
*/
@Override
public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
// 从请求中获取数据数组
JSONArray infos = reqJson.getJSONArray("data");
// 分别获取应用、服务和路由扩展信息
JSONObject viewAppInfo = getObj(infos, "App");
JSONObject viewServiceInfo = getObj(infos, "Service");
JSONObject addRouteView = getObj(infos, "addRouteView");
// 验证各组件信息不能为空
Assert.notNull(viewAppInfo, "未包含应用信息");
Assert.notNull(viewServiceInfo, "未包含服务信息");
Assert.notNull(addRouteView, "未包含扩展信息");
// 处理应用信息：如果应用ID不存在，则保存应用信息并获取应用ID
if(!hasKey(viewAppInfo, "appId")){
viewAppInfo.put("appId", saveAppInfo(reqJson, viewAppInfo));
}
// 处理服务信息：如果服务ID不存在，则保存服务信息并获取服务ID
if(!hasKey(viewServiceInfo, "serviceId")){
viewServiceInfo.put("serviceId", saveServiceInfo(reqJson, viewServiceInfo));
}
// 处理路由信息：将路由扩展信息转换为路由DTO并设置应用ID和服务ID
RouteDto routeDto = BeanConvertUtil.covertBean(addRouteView, RouteDto.class);
routeDto.setAppId(viewAppInfo.getString("appId"));
routeDto.setServiceId(viewServiceInfo.getString("serviceId"));
// 保存路由信息
int count = routeInnerServiceSMOImpl.saveRoute(routeDto);
// 验证保存结果
if (count < 1) {
throw new ListenerExecuteException(ResponseConstant.RESULT_CODE_ERROR, "保存应用数据失败");
}
// 设置响应结果
ResponseEntity<String> responseEntity = new ResponseEntity<String>(JSONObject.toJSONString(routeDto), HttpStatus.OK);
context.setResponseEntity(responseEntity);
}
/**
* 保存应用信息
*
* @param reqJson 请求报文信息
* @param appInfo 应用组件信息
* @return 应用ID
*/
private String saveAppInfo(JSONObject reqJson, JSONObject appInfo){
// 将JSON对象转换为应用DTO
AppDto appDto = BeanConvertUtil.covertBean(appInfo, AppDto.class);
// 生成应用ID
appDto.setAppId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_id));
// 保存应用信息
int count = appInnerServiceSMOImpl.saveApp(appDto);
// 验证保存结果
if (count < 1) {
throw new ListenerExecuteException(ResponseConstant.RESULT_CODE_ERROR, "保存应用数据失败");
}
return appDto.getAppId();
}
/**
* 保存服务信息
*
* @param reqJson 请求报文信息
* @param serviceInfo 服务组件信息
* @return 服务ID
*/
private String saveServiceInfo(JSONObject reqJson, JSONObject serviceInfo){
// 将JSON对象转换为服务DTO
ServiceDto serviceDto = BeanConvertUtil.covertBean(serviceInfo, ServiceDto.class);
// 设置服务默认属性
serviceDto.setProvideAppId("8000418002"); // 提供应用ID
serviceDto.setBusinessTypeCd("API"); // 业务类型编码
serviceDto.setSeq("1"); // 序列号
// 生成服务ID
serviceDto.setServiceId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_service_id));
// 保存服务信息
int count = serviceInnerServiceSMOImpl.saveService(serviceDto);
// 验证保存结果
if (count < 1) {
throw new ListenerExecuteException(ResponseConstant.RESULT_CODE_ERROR, "保存服务数据失败");
}
return serviceDto.getServiceId();
}
/**
* 从数据数组中根据流程组件名称获取对应的JSON对象
*
* @param infos 数据数组
* @param flowComponent 流程组件名称
* @return 对应的JSON对象
*/
private JSONObject getObj(JSONArray infos , String flowComponent){
JSONObject serviceInfo = null;
// 遍历数据数组查找指定组件
for(int infoIndex = 0 ; infoIndex < infos.size(); infoIndex ++){
// 验证每个对象都包含flowComponent字段
Assert.hasKeyAndValue(infos.getJSONObject(infoIndex), "flowComponent", "未包含服务流程组件名称");
// 匹配指定组件名称
if(flowComponent.equals(infos.getJSONObject(infoIndex).getString("flowComponent"))){
serviceInfo = infos.getJSONObject(infoIndex);
Assert.notNull(serviceInfo, "未包含服务信息");
return serviceInfo;
}
}
// 如果未找到指定组件，抛出异常
throw new IllegalArgumentException("未找到组件编码为【" + flowComponent + "】数据");
}
/**
* 检查JSON对象中是否包含指定键且值不为空
*
* @param info JSON对象
* @param key 要检查的键
* @return 如果键存在且值不为空且不以"-"开头，返回true；否则返回false
*/
private boolean hasKey(JSONObject info, String key){
if(!info.containsKey(key)
|| StringUtil.isEmpty(info.getString(key))
|| info.getString(key).startsWith("-")){
return false;
}
return true;
}
}
|
