客户池管理 机构 typeahead

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

@@ -10,16 +10,53 @@ 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 interface ViewCustomerDao {
public abstract class ViewCustomerDao {
	@Nullable
	@SelectOne
	ViewCustomer query(Connection con, String id) throws SQLException;
	public abstract ViewCustomer query(Connection con, String id) throws SQLException;
	
	@PageSelect
	@OrderBy(" ORDER BY create_time")
	PageQueryResult<ViewCustomer> query(Connection con, @Like String name, @Like String address, @Like String orgname, @Nullable Integer sendMailStatus, int pageSize, int pageNo) throws SQLException;
	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 java.util.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

@@ -14,6 +14,8 @@ import org.jfw.util.PageQueryResult;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
@Path("/sys/viewcustomer")
public class ViewCustomerService {
@@ -52,5 +54,25 @@ public class ViewCustomerService {
	@Path("/id/{id}")
	public ViewCustomer query(@JdbcConn Connection con, @PathVar String id)throws SQLException{
		return this.viewCustomerDao.query(con, id);
	}	
	}
	@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 = this.viewCustomerDao.orgName(con, key);
		for (ViewCustomer viewCustomer : typeahead) {
			TestService.TypeaheadItem thi = new TestService.TypeaheadItem();
			thi.setCode(viewCustomer.getOrgname());
			thi.setCaption(viewCustomer.getOrgname());
			ret.add(thi);
		}
		return ret;
	}
}