00

src/main/java/com/ekexiu/console/system/dao/UserDao.java

@@ -4,6 +4,7 @@ import java.sql.Connection;
import java.sql.SQLException;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.Batch;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.Dynamic;
import org.jfw.apt.orm.annotation.dao.method.From;
@@ -44,10 +45,11 @@ public interface UserDao {
	@Dynamic
	int update(Connection con, User user) throws SQLException;
	@Batch
	@IncludeFixSet("modifyTime")
	@UpdateWith
	@From(User.class)
	int resetPassword(Connection con, String id, @Set String loginPassword) throws SQLException;
	int[] resetPassword(Connection con,@Batch  String[] id, @Set String loginPassword) throws SQLException;
	@IncludeFixSet("modifyTime")
	@UpdateWith

src/main/java/com/ekexiu/console/system/service/OrgService.java

@@ -7,6 +7,7 @@ import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.DefaultValue;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.operate.Delete;
import org.jfw.apt.web.annotation.operate.Get;
import org.jfw.apt.web.annotation.operate.Post;
import org.jfw.apt.web.annotation.operate.Put;
@@ -61,6 +62,13 @@ public class OrgService {
	public Organization query(@JdbcConn Connection con,@PathVar String id)throws SQLException{
		return this.orgDao.query(con, id);
	}
	@Delete
	@Path("/id/{id}")
	public void deleteOne(@JdbcConn(true) Connection con,@PathVar String id)throws SQLException{
		this.orgDao.delete(con, id);
	}
	
	
	@Post
	@Path("/del")
	public void delete(@JdbcConn(true) Connection con,String[] ids)throws SQLException{

src/main/java/com/ekexiu/console/system/service/RightService.java

@@ -12,8 +12,8 @@ import java.util.concurrent.atomic.AtomicReference;
import javax.sql.DataSource;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.orm.annotation.dao.method.operator.Delete;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.operate.Delete;
import org.jfw.apt.web.annotation.operate.Get;
import org.jfw.apt.web.annotation.operate.Post;
import org.jfw.apt.web.annotation.operate.Put;

src/main/java/com/ekexiu/console/system/service/TestService.java

@@ -0,0 +1,56 @@
package com.ekexiu.console.system.service;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import javax.sql.DataSource;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.operate.Get;
@Path("/test")
public class TestService {
	@Autowrie("dataSource2")
	private DataSource ds;
	public DataSource getDs() {
		return ds;
	}
	public void setDs(DataSource ds) {
		this.ds = ds;
	}
	@Get
	@Path
	public Object get() throws SQLException {
		Connection con = ds.getConnection();
		try {
			PreparedStatement ps = con.prepareStatement("SELECT ARTICLE_TITLE FROM ARTICLE");
			try {
				ResultSet rs = ps.executeQuery();
				try {
					List<String> list = new ArrayList<String>();
					while (rs.next()) {
						list.add(rs.getString(1));
					}
					return list;
				} finally {
					rs.close();
				}
			} finally {
				ps.close();
			}
		} finally {
			con.close();
		}
	}
}

src/main/java/com/ekexiu/console/system/service/UserService.java

@@ -133,8 +133,24 @@ public class UserService extends Upload {
	@Put
	@Path
	public void update(@JdbcConn(true) Connection con,@RequestBody User user)throws SQLException{
		user.setLoginPassword(null);
		this.userDao.update(con, user);
	}
	
	@Get
	@Path("/info")
	public User editInfo(@JdbcConn Connection con,@LoginUser ConsoleAuthUser cau)throws SQLException{
		User user = this.userDao.queryById(con, cau.getId());
		if(user!=null){
			user.setLoginPassword(null);
		}
		return user;
	}
	@Post
	@Path("/resetpw")
	public void resetpw(@JdbcConn(true) Connection con,String[] ids)throws SQLException{
		this.userDao.resetPassword(con, ids,DEFAULT_PW_STR);
	}
	@Post

src/main/java/com/ekexiu/console/util/HttpService.java

@@ -0,0 +1,13 @@
package com.ekexiu.console.util;
import java.io.IOException;
import java.lang.reflect.Type;
import org.jfw.util.exception.JfwBaseException;
public interface HttpService {
	<T> T get(String url,Type typeOfT) throws JfwBaseException,IOException;
	<T> T post(String url, String data,Type typeOfT) throws JfwBaseException,IOException;
	<T> T put(String url, Object data,Type typeOfT) throws JfwBaseException,IOException;
	<T> T delete(String url,Type typeOfT) throws JfwBaseException,IOException;
}

src/main/java/com/ekexiu/console/util/HttpServiceImpl.java

@@ -0,0 +1,215 @@
package com.ekexiu.console.util;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.StringWriter;
import java.lang.reflect.ParameterizedType;
import java.lang.reflect.Type;
import java.net.HttpURLConnection;
import java.net.URL;
import org.jfw.util.ConstData;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.io.IoUtil;
import org.jfw.util.json.JsonService;
import org.jfw.util.reflect.TypeReference;
public class HttpServiceImpl implements HttpService {
	private static final byte[] SIMPLE_POST_DATA = "1=1".getBytes(ConstData.UTF8);
	private String charset = "UTF-8";
	public Type buildResultType(final Type t) {
		return new ParameterizedType() {
			@Override
			public Type getRawType() {
				return Result.class;
			}
			@Override
			public Type getOwnerType() {
				return HttpServiceImpl.class;
			}
			@Override
			public Type[] getActualTypeArguments() {
				return new Type[] { t };
			}
		};
	}
	private void raise(Result<?> ret) throws JfwBaseException {
		throw new JfwBaseException(ret.getCode().intValue(), "remote calll error:" + ret.getMsg() + ";\r\n" + ret.getDetailMsg());
	}
	private <T> T handResponse(InputStream in, Type typeOfT) throws JfwBaseException {
		if (null != typeOfT) {
			Result<T> ret = JsonService.fromJson(new InputStreamReader(in, ConstData.UTF8), buildResultType(typeOfT));
			if (ret.isSuccess()) {
				return ret.getData();
			} else {
				raise(ret);
			}
		} else {
			Result<String> ret = JsonService.fromJson(new InputStreamReader(in, ConstData.UTF8), new TypeReference<Result<String>>() {
			}.getType());
			if (ret.isSuccess())
				return null;
			else {
				raise(ret);
			}
		}
		return null;
	}
	@Override
	public <T> T get(String url, Type typeOfT) throws JfwBaseException, IOException {
		URL u = new URL(url);
		HttpURLConnection httpURLConnection = (HttpURLConnection) u.openConnection();
		httpURLConnection.setRequestProperty("Accept-Charset", charset);
		httpURLConnection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
		if (httpURLConnection.getResponseCode() != 200) {
			throw new IOException("HTTP Request is not success, Response code is " + httpURLConnection.getResponseCode());
		}
		InputStream in = httpURLConnection.getInputStream();
		try {
			return this.handResponse(in, typeOfT);
		} finally {
			IoUtil.close(in);
		}
	}
	@Override
	public <T> T post(String url, String data, Type typeOfT) throws JfwBaseException, IOException {
		byte[] bs = SIMPLE_POST_DATA;
		if (data != null && data.length() > 0) {
			bs = data.getBytes(ConstData.UTF8);
		}
		URL u = new URL(url);
		HttpURLConnection httpURLConnection = (HttpURLConnection) u.openConnection();
		httpURLConnection.setDoOutput(true);
		httpURLConnection.setRequestMethod("POST");
		httpURLConnection.setRequestProperty("Accept-Charset", charset);
		httpURLConnection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
		httpURLConnection.setRequestProperty("Content-Length", String.valueOf(bs.length));
		OutputStream outputStream = httpURLConnection.getOutputStream();
		try {
			outputStream.write(bs);
			outputStream.flush();
		} finally {
			IoUtil.close(outputStream);
		}
		if (httpURLConnection.getResponseCode() != 200) {
			throw new IOException("HTTP Request is not success, Response code is " + httpURLConnection.getResponseCode());
		}
		InputStream in = httpURLConnection.getInputStream();
		try {
			return this.handResponse(in, typeOfT);
		} finally {
			IoUtil.close(in);
		}
	}
	@Override
	public <T> T put(String url, Object data, Type typeOfT) throws JfwBaseException, IOException {
		StringWriter sw = new StringWriter();
		JsonService.toJson(data, sw);
		byte[] bs = sw.toString().getBytes(ConstData.UTF8);
		URL u = new URL(url);
		HttpURLConnection httpURLConnection = (HttpURLConnection) u.openConnection();
		httpURLConnection.setDoOutput(true);
		httpURLConnection.setRequestMethod("PUT");
		httpURLConnection.setRequestProperty("Accept-Charset", charset);
		httpURLConnection.setRequestProperty("Content-Type", "application/json");
		httpURLConnection.setRequestProperty("Content-Length", String.valueOf(bs.length));
		OutputStream outputStream = httpURLConnection.getOutputStream();
		try {
			outputStream.write(bs);
			outputStream.flush();
		} finally {
			IoUtil.close(outputStream);
		}
		if (httpURLConnection.getResponseCode() != 200) {
			throw new IOException("HTTP Request is not success, Response code is " + httpURLConnection.getResponseCode());
		}
		InputStream in = httpURLConnection.getInputStream();
		try {
			return this.handResponse(in, typeOfT);
		} finally {
			IoUtil.close(in);
		}
	}
	@Override
	public <T> T delete(String url, Type typeOfT) throws JfwBaseException, IOException {
		URL u = new URL(url);
		HttpURLConnection httpURLConnection = (HttpURLConnection) u.openConnection();
		httpURLConnection.setRequestProperty("Accept-Charset", charset);
		httpURLConnection.setRequestMethod("DELETE");
		httpURLConnection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
		if (httpURLConnection.getResponseCode() != 200) {
			throw new IOException("HTTP Request is not success, Response code is " + httpURLConnection.getResponseCode());
		}
		InputStream in = httpURLConnection.getInputStream();
		try {
			return this.handResponse(in, typeOfT);
		} finally {
			IoUtil.close(in);
		}
	}
	public static class Result<T> {
		private boolean success;
		private Integer code;
		private String msg;
		private String detailMsg;
		private T data;
		public boolean isSuccess() {
			return success;
		}
		public void setSuccess(boolean success) {
			this.success = success;
		}
		public Integer getCode() {
			return code;
		}
		public void setCode(Integer code) {
			this.code = code;
		}
		public String getMsg() {
			return msg;
		}
		public void setMsg(String msg) {
			this.msg = msg;
		}
		public String getDetailMsg() {
			return detailMsg;
		}
		public void setDetailMsg(String detailMsg) {
			this.detailMsg = detailMsg;
		}
		public T getData() {
			return data;
		}
		public void setData(T data) {
			this.data = data;
		}
	}
}

src/test/java/com/ekexiu/console/util/HttpServiceTest.java

@@ -0,0 +1,71 @@
package com.ekexiu.console.util;
import java.lang.reflect.Method;
import java.lang.reflect.ParameterizedType;
import java.lang.reflect.Type;
import java.net.URLEncoder;
import org.jfw.util.PageQueryResult;
import org.jfw.util.json.JsonService;
import org.jfw.util.reflect.TypeReference;
import com.ekexiu.console.system.po.Organization;
import com.ekexiu.console.util.HttpServiceImpl.Result;
public class HttpServiceTest {
	private static HttpService http = new HttpServiceImpl();
	public static Organization get()throws Exception{
		PageQueryResult<Organization> ret = http.get("http://192.168.3.76:82/ajax/sys/org/pq?name="+URLEncoder.encode("%中国%","UTF-8"), new TypeReference<PageQueryResult<Organization>>() {
		}.getType());
		return ret.getData().get(0);
	}
	
	public static void post()throws Exception{
		StringBuilder sb  = new StringBuilder();
		sb.append("name=").append(URLEncoder.encode("中国","UTF-8")).append("&type=1&descp=").append(URLEncoder.encode("中华人民共和国","UTF-8"));
		
		
	 http.post("http://192.168.3.76:82/ajax/sys/org",sb.toString(),null);
	
	}
	
	
	
	
	public static void ss(Result<PageQueryResult<Organization>> s){}
	
	public static void main(String[] args)throws Exception{
		post();	
	Organization o = get();
	System.out.println(JsonService.toJson(o));
	o.setDescp("我的中国心");
	http.put("http://192.168.3.76:82/ajax/sys/org", o, null);
	 o = get();
	System.out.println(JsonService.toJson(o));
	http.delete("http://192.168.3.76:82/ajax/sys/org/id/"+o.getId(), null);
	
	
		
//	  Method m =null ;
//	  
//	  
//	 for(Method mm:  HttpServiceTest.class.getDeclaredMethods()){
//		 if(mm.getName().equals("ss")){
//			 m = mm;
//			 break;
//		 }
//	 }
//	 Type t = m.getGenericParameterTypes()[0];	
//	 System.out.println(t instanceof ParameterizedType);
//	 ParameterizedType p = (ParameterizedType)t;
//	 Type r = p.getRawType();
//	 
//	 System.out.println( r instanceof Class );
//	 System.out.println( ((Class)r).getName());
//	 System.out.println(p.getOwnerType());
//	 
		
	}
}