11

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

@@ -10,7 +10,11 @@ import org.jfw.apt.orm.annotation.dao.param.Like;
import org.jfw.util.PageQueryResult;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
@DAO
public abstract class ViewCustomerDao {
@@ -22,4 +26,37 @@ public abstract class ViewCustomerDao {
	@OrderBy(" ORDER BY create_time")
	public abstract PageQueryResult<ViewCustomer> query(Connection con, @Like String name, @Like String address, @Like String orgname, @Nullable Integer sendMailStatus, int pageSize, int pageNo) throws SQLException;
	public List<ViewCustomer> orgName(Connection con,String orgname) throws SQLException{
		int index = 1;
		boolean oname = null == orgname;
		StringBuilder sql = new StringBuilder();
		sql.append("SELECT ORGNAME FROM view_customer");
		if(!oname){
			sql.append(" WHERE ORGNAME LIKE ? group by orgname");
		}
		PreparedStatement ps = con.prepareStatement(sql.toString());
		try{
			if(!oname){
				ps.setString(index++,orgname);
			}
			ResultSet rs = ps.executeQuery();
			try{
				List<ViewCustomer> viewCustomers = new ArrayList<ViewCustomer>();
				while(rs.next()){
					ViewCustomer viewCustomer =  new ViewCustomer();
					String orgName = rs.getString(1);
					if(rs.wasNull()){
						orgName = null;
					}
					viewCustomer.setOrgname(orgName);
					viewCustomers.add(viewCustomer);
				}
				return viewCustomers;
			}finally{
				try{rs.close();}catch(Exception e){}
			}
		}finally{
			try{ps.close();}catch(Exception e){}
		}
	}
}

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

@@ -11,11 +11,8 @@ import org.jfw.apt.web.annotation.operate.Get;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.apt.web.annotation.param.PathVar;
import org.jfw.util.PageQueryResult;
import org.jfw.util.jdbc.JdbcUtil;
import org.jfw.util.jdbc.ResultSetExtractor;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
@@ -62,15 +59,13 @@ public class ViewCustomerService {
	@Get
	@Path("/orgName")
	public List<TestService.TypeaheadItem> get(@JdbcConn Connection con, String q, @DefaultValue("11") int s) throws SQLException{
		String key=null;
		if(q!=null)
		{
			key="%"+q+"%";
		}
		List<TestService.TypeaheadItem> ret = new ArrayList<>(s);
		List<ViewCustomer> typeahead = JdbcUtil.queryList(con, "SELECT ORGNAME FROM view_customer WHERE ORGNAME LIKE '%" + q + "%' group by orgname", new ResultSetExtractor<ViewCustomer>() {
			@Override
			public ViewCustomer extractData(ResultSet resultSet) throws SQLException {
				ViewCustomer viewCustomer = new ViewCustomer();
				viewCustomer.setOrgname(resultSet.getString("ORGNAME"));
				return viewCustomer;
			}
		});
		List<ViewCustomer> typeahead = this.viewCustomerDao.orgName(con, key);
		for (ViewCustomer viewCustomer : typeahead) {
			TestService.TypeaheadItem thi = new TestService.TypeaheadItem();
			thi.setCode(viewCustomer.getOrgname());