package frame.object.http;
|
|
import java.lang.reflect.InvocationTargetException;
|
import java.lang.reflect.Method;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
|
import org.apache.log4j.Logger;
|
|
import frame.call.writer.EnvelopWriter;
|
import frame.role.OnlineUser;
|
import frame.role.UserRight;
|
import frame.util.Util;
|
|
public abstract class HttpObject {
|
|
protected static Logger logger;
|
protected HttpServletResponse response;
|
protected HttpServletRequest request;
|
protected OnlineUser onlineUser;
|
protected EnvelopWriter writer;
|
protected ResultPool resultPool;
|
protected HttpDataPool dataPool;
|
protected Path path ;
|
protected Map<String, Method> methodMap;
|
protected Map<String, Method> allMethodMap;
|
protected boolean fireReplay;
|
|
static {
|
logger = Logger.getLogger(HttpObject.class);
|
}
|
|
public HttpObject() {
|
methodMap = new HashMap<String, Method>();
|
allMethodMap = new HashMap<String, Method>();
|
fireReplay = true;
|
|
collectMethod();
|
publishMethod();
|
}
|
|
public void receive(String pathString) { //path为 shortTarget
|
resultPool = new ResultPool();
|
|
try {
|
path = new Path(pathString);
|
|
if (!path.isValid()) {
|
writer.ReplyError("bad path:" + pathString);
|
}
|
|
dataPool = new HttpDataPool();
|
dataPool.load(request);
|
|
writer = new EnvelopWriter(request, response);
|
try {
|
if (onlineUser != null) {
|
try {
|
//1. check user right
|
UserRight userRight = onlineUser.getUserRight();
|
|
if (!userRight.isValid(path)) {
|
resultPool.setInvalidUserRight(path);
|
return;
|
}
|
|
//2. execute
|
doReceive(path);
|
}
|
catch (Exception e) {
|
onError(e);
|
}
|
}
|
else {
|
writer.replayTimeout();
|
}
|
|
if (fireReplay) {
|
writer.replay(resultPool);
|
writer.flush();
|
}
|
}
|
catch (Exception e) {
|
String error = e.getClass().getName() + ": " + e.getMessage();
|
writer.ReplyError(error);
|
logger.error("ajax error: " + e);
|
}
|
}
|
catch (Exception e) {
|
}
|
}
|
|
protected void doReceive(Path path) throws Exception {
|
String lower = path.getOperator().toLowerCase();
|
Method method = methodMap.get(lower);
|
|
if (method == null) {
|
method = methodMap.get("call");
|
}
|
|
if (method != null) {
|
try {
|
beforeExecute();
|
method.invoke(this);
|
}
|
catch (InvocationTargetException e) {
|
Throwable throwable = e.getTargetException();
|
|
if (throwable == null) {
|
throw e;
|
}
|
else {
|
throw (Exception) throwable;
|
}
|
}
|
}
|
else {
|
resultPool.error("method not exists: " + path.getPathString());
|
}
|
}
|
|
protected void beforeExecute() throws Exception {
|
|
}
|
|
protected void onError(Exception e) throws Exception {
|
logger.error(e);
|
e.printStackTrace();
|
}
|
|
public HttpDataPool getDataPool() throws Exception {
|
return dataPool;
|
}
|
|
protected void collectMethod() {
|
Method[] methods = this.getClass().getDeclaredMethods();
|
|
for (Method one : methods) {
|
allMethodMap.put(one.getName().toLowerCase(), one);
|
}
|
}
|
|
protected void publishMethod() {
|
|
}
|
|
protected void addMethod(String name) {
|
if (name == null) {
|
return;
|
}
|
|
name = name.toLowerCase();
|
Method method = allMethodMap.get(name);
|
|
if (method != null) {
|
method.setAccessible(true);
|
methodMap.put(name, method);
|
}
|
}
|
|
protected String locateSQLVariant(String name) throws Exception {
|
String value = request.getParameter(name);
|
|
if (value != null && value.startsWith("@{")) {
|
name = value.subString(2, value.length() - 1);
|
value = getDefaultParameter(name);
|
return value;
|
}
|
else if (value != null) {
|
return value;
|
}
|
|
value = getDefaultParameter(name);
|
|
return value;
|
}
|
|
protected String getDefaultParameter(String name) {
|
if ("userid".equalsIgnoreCase(name)) {
|
return onlineUser.getId();
|
}
|
else if ("rolecode".equalsIgnoreCase(name)) {
|
return onlineUser.getRoleCode();
|
}
|
else if ("username".equalsIgnoreCase(name)) {
|
return onlineUser.getName();
|
}
|
else if ("orgid".equalsIgnoreCase(name)) {
|
return onlineUser.getOrgId();
|
}
|
else if ("newid".equalsIgnoreCase(name)) {
|
return Util.newShortGUID();
|
}
|
else if ("newDate".equalsIgnoreCase(name)) {
|
return Util.DataTimeToString(new Date());
|
}
|
else if ("filter".equalsIgnoreCase(name)) {
|
return "1 = 1";
|
}
|
|
return null;
|
}
|
|
public HttpServletRequest getRequest() {
|
return request;
|
}
|
|
public HttpServletResponse getResponse() {
|
return response;
|
}
|
|
public OnlineUser getOnlineUser() {
|
return onlineUser;
|
}
|
|
public ResultPool getResultPool() {
|
return resultPool;
|
}
|
|
|
public Path getPath() {
|
return path;
|
}
|
|
public EnvelopWriter getWriter() {
|
return writer;
|
}
|
|
}
|
