-
Notifications
You must be signed in to change notification settings - Fork 37
Expand file tree
/
Copy pathDispatcher.java
More file actions
224 lines (177 loc) · 7.83 KB
/
Copy pathDispatcher.java
File metadata and controls
224 lines (177 loc) · 7.83 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
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
221
222
223
224
/**
* Alipay.com Inc.
* Copyright (c) 2004-2014 All Rights Reserved.
*/
package com.java110.dispatcher;
import java.util.Map;
import net.sf.json.JSONObject;
import net.sf.json.xml.XMLSerializer;
import com.alipay.api.internal.util.StringUtils;
import com.java110.common.MyException;
import com.java110.constants.AlipayServiceEventConstants;
import com.java110.constants.AlipayServiceNameConstants;
import com.java110.executor.ActionExecutor;
import com.java110.executor.InAlipayAsyncMsgSendExecutor;
import com.java110.executor.InAlipayChatTextExecutor;
import com.java110.executor.InAlipayDIYQRCodeEnterExecutor;
import com.java110.executor.InAlipayDefaultExecutor;
import com.java110.executor.InAlipayEnterExecutor;
import com.java110.executor.InAlipayFollowExecutor;
import com.java110.executor.InAlipayUnFollowExecutor;
import com.java110.executor.InAlipayVerifyExecutor;
/**
* 业务动作分发器
*
* @author taixu.zqq
* @version $Id: Dispatcher.java, v 0.1 2014年7月24日 下午4:59:58 taixu.zqq Exp $
*/
public class Dispatcher {
/**
* 根据业务参数获取业务执行器
*
* @param params
* @return
* @throws MyException
*/
public static ActionExecutor getExecutor(Map<String, String> params) throws MyException {
//获取服务信息
String service = params.get("service");
if (StringUtils.isEmpty(service)) {
throw new MyException("无法取得服务名");
}
//获取内容信息
String bizContent = params.get("biz_content");
if (StringUtils.isEmpty(bizContent)) {
throw new MyException("无法取得业务内容信息");
}
//将XML转化成json对象
JSONObject bizContentJson = (JSONObject) new XMLSerializer().read(bizContent);
// 1.获取消息类型信息
String msgType = bizContentJson.getString("MsgType");
if (StringUtils.isEmpty(msgType)) {
throw new MyException("无法取得消息类型");
}
// 2.根据消息类型(msgType)进行执行器的分类转发
// 2.1 纯文本聊天类型
if ("text".equals(msgType)) {
return new InAlipayChatTextExecutor(bizContentJson);
// 2.2 事件类型
} else if ("event".equals(msgType)) {
return getEventExecutor(service, bizContentJson);
} else {
// 2.3 后续支付宝还会新增其他类型，因此默认返回ack应答
return new InAlipayDefaultExecutor(bizContentJson);
}
}
/**
* 根据事件类型细化查找对应执行器
*
* @param service
* @param bizContentJson
* @return
* @throws MyException
*/
private static ActionExecutor getEventExecutor(String service, JSONObject bizContentJson)
throws MyException {
// 1. 获取事件类型
String eventType = bizContentJson.getString("EventType");
if (StringUtils.isEmpty(eventType)) {
throw new MyException("无法取得事件类型");
}
// 2.根据事件类型再次区分服务类型
// 2.1 激活验证开发者模式
if (AlipayServiceNameConstants.ALIPAY_CHECK_SERVICE.equals(service)
&& eventType.equals(AlipayServiceEventConstants.VERIFYGW_EVENT)) {
return new InAlipayVerifyExecutor();
// 2.2 其他消息通知类
} else if (AlipayServiceNameConstants.ALIPAY_PUBLIC_MESSAGE_NOTIFY.equals(service)) {
return getMsgNotifyExecutor(eventType, bizContentJson);
// 2.3 对于后续支付宝可能新增的类型，统一默认返回AKC响应
} else {
return new InAlipayDefaultExecutor(bizContentJson);
}
}
/**
* 根据事件类型(eventType)进行执行器的分类转发
*
* @param eventType
* @param bizContentJson
* @return
* @throws MyException
*/
private static ActionExecutor getMsgNotifyExecutor(String eventType, JSONObject bizContentJson)
throws MyException {
if (eventType.equals(AlipayServiceEventConstants.FOLLOW_EVENT)) {
// 服务窗关注事件
return new InAlipayFollowExecutor(bizContentJson);
} else if (eventType.equals(AlipayServiceEventConstants.UNFOLLOW_EVENT)) {
// 服务窗取消关注事件
return new InAlipayUnFollowExecutor(bizContentJson);
//根据actionParam进行执行器的转发
} else if (eventType.equals(AlipayServiceEventConstants.CLICK_EVENT)) {
// 点击事件
return getClickEventExecutor(bizContentJson);
} else if (eventType.equals(AlipayServiceEventConstants.ENTER_EVENT)) {
// 进入事件
return getEnterEventTypeExecutor(bizContentJson);
} else {
// 对于后续支付宝可能新增的类型，统一默认返回AKC响应
return new InAlipayDefaultExecutor(bizContentJson);
}
}
/**
* 进入事件执行器
*
* @param bizContentJson
* @return
*/
private static ActionExecutor getEnterEventTypeExecutor(JSONObject bizContentJson) {
try {
JSONObject param = JSONObject.fromObject(bizContentJson.get("ActionParam"));
JSONObject scene = JSONObject.fromObject(param.get("scene"));
if (!StringUtils.isEmpty(scene.getString("sceneId"))) {
//自定义场景参数进入服务窗事件
return new InAlipayDIYQRCodeEnterExecutor(bizContentJson);
} else {
//普通进入服务窗事件
return new InAlipayEnterExecutor(bizContentJson);
}
} catch (Exception exception) {
//无法解析sceneId的情况作为普通进入服务窗事件
return new InAlipayEnterExecutor(bizContentJson);
}
}
/**
* 点击事件执行器
*
* @param bizContentJson
* @return
*/
private static ActionExecutor getClickEventExecutor(JSONObject bizContentJson) {
String actionParam = bizContentJson.getString("ActionParam");
if ("authentication".equals(actionParam)) {
//申请开发者会员绑定事件: actionParam支付宝服务窗固定值
//TODO 开发者自行实现，开发者若不需要绑定开发者会员，可无需实现
return null;
} else if ("delete".equals(actionParam)) {
//删除开发者会员绑定事件：actionParam支付宝服务窗固定值
//TODO 开发者自行实现，开发者若不需要绑定开发者会员，可无需实现
return null;
// 除上述支付宝保留key外，其他key为开发者配置菜单时自定义
} else {
//服务窗菜单点击事件：actionParam开发者可以自定义，除不能与authentication和delete重复及特殊字符外,没有其他要求
//"async_image_text"即为开发者自定义的异步发送图文消息的菜单key，这里只是个样例而已
if ("async_image_text".equals(actionParam)) {
// 根据配置的菜单具体含义，开发者进行业务应答，这里只是个样例
return new InAlipayAsyncMsgSendExecutor(bizContentJson);
// 其他菜单key请开发者自行补充,并执行开发相应响应
} else if ("xxx".equals(actionParam)) {
// TODO 开发者根据key自行开发相应响应，这里只是个样例
return null;
} else {
// TODO 开发者根据key自行开发相应响应，这里只是个样例
return null;
}
}
}
}