11

src/main/java/com/ekexiu/portal/ware/WareDao.java

@@ -30,9 +30,7 @@ import org.jfw.apt.orm.core.defaultImpl.StringHandler;
import org.jfw.util.PageQueryResult;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
@DAO
@@ -157,95 +155,10 @@ public abstract class WareDao {
	@Where("STATE='1'")
	@OrderBy(cols = { @LimitColumn(value = "sortFirst", asc = false, handlerClass = LongHandler.class), @LimitColumn(value = "modifyTime", asc = false),
			@LimitColumn(value = "id", asc = false) }, value = "")
	public abstract List<Ware> indexSearch(Connection con,
	public abstract List<Ware> indexSearch(Connection con,@Nullable
			@GroupSqlColumn(handlerClass = StringHandler.class, value = { "NAME LIKE ?", "CNT LIKE ?", "KEYWORDS LIKE ?",
					"CATEGORY='1' AND OWNER IN(SELECT ID FROM PROFESSOR WHERE NAME LIKE ?)",
					"CATEGORY ='2' AND OWNER IN(SELECT ID FROM ORGANIZATION WHERE NAME LIKE ? OR FOR_SHORT LIKE ?))" },additional=1,isAnd=false,force=true) String key,
					"CATEGORY ='2' AND OWNER IN(SELECT ID FROM ORGANIZATION WHERE NAME LIKE ? OR FOR_SHORT LIKE ?)" },additional=1,isAnd=false,force=true) String key,
			long sortFirst, String modifyTime, String id, int rows) throws SQLException;
	public List<Ware> indexSeach(Connection con, String key, long sortFirst, String modifyTime, String id, int rows) throws SQLException {
		List<Ware> result = new ArrayList<Ware>(rows);
		StringBuilder sb = new StringBuilder();
		sb.append("SELECT PAGE_VIEWS,ID,NAME,KEYWORDS,CNT,COOPERATION,DESCP,CATEGORY,OWNER,IMAGES,STATE,SHARE_ID,SORT_FIRST,CREATE_TIME,MODIFY_TIME FROM WARE")
				.append(" WHERE STATE='1' AND ((SORT_FIRST<?) OR (SORT_FIRST=? AND MODIFY_TIME < ?) OR ( SORT_FIRST=? AND MODIFY_TIME = ? AND ID < ?))");
		if (key != null) {
			sb.append(" AND (NAME LIKE ? OR CNT LIKE ? OR KEYWORDS LIKE ?  OR(CATEGORY='1' AND OWNER IN(SELECT ID FROM PROFESSOR WHERE NAME LIKE ?))")
					.append(" OR (CATEGORY ='2' AND OWNER IN(SELECT ID FROM ORGANIZATION WHERE NAME LIKE ? OR FOR_SHORT LIKE ?)))");
		}
		sb.append(" ORDER BY SORT_FIRST DESC,MODIFY_TIME DESC,ID DESC LIMIT ?");
		PreparedStatement ps = con.prepareStatement(sb.toString());
		try {
			int idx = 1;
			ps.setLong(idx++, sortFirst);
			ps.setLong(idx++, sortFirst);
			ps.setString(idx++, modifyTime);
			ps.setLong(idx++, sortFirst);
			ps.setString(idx++, modifyTime);
			ps.setString(idx++, id);
			if (key != null) {
				ps.setString(idx++, key);
				ps.setString(idx++, key);
				ps.setString(idx++, key);
				ps.setString(idx++, key);
				ps.setString(idx++, key);
				ps.setString(idx++, key);
			}
			ps.setInt(idx++, rows);
			java.sql.ResultSet rs = ps.executeQuery();
			try {
				while (rs.next()) {
					Ware _obj = new Ware();
					_obj.setPageViews(rs.getLong(1));
					_obj.setId(rs.getString(2));
					_obj.setName(rs.getString(3));
					java.lang.String _m_3 = rs.getString(4);
					if (rs.wasNull()) {
						_m_3 = null;
					}
					_obj.setKeywords(_m_3);
					java.lang.String _m_4 = rs.getString(5);
					if (rs.wasNull()) {
						_m_4 = null;
					}
					_obj.setCnt(_m_4);
					java.lang.String _m_5 = rs.getString(6);
					if (rs.wasNull()) {
						_m_5 = null;
					}
					_obj.setCooperation(_m_5);
					java.lang.String _m_6 = rs.getString(7);
					if (rs.wasNull()) {
						_m_6 = null;
					}
					_obj.setDescp(_m_6);
					_obj.setCategory(rs.getString(8));
					_obj.setOwner(rs.getString(9));
					java.lang.String _m_7 = rs.getString(10);
					if (rs.wasNull()) {
						_m_7 = null;
					}
					_obj.setImages(_m_7);
					_obj.setState(rs.getString(11));
					_obj.setShareId(rs.getLong(12));
					_obj.setSortFirst(rs.getLong(13));
					_obj.setCreateTime(rs.getString(14));
					_obj.setModifyTime(rs.getString(15));
					result.add(_obj);
				}
				return result;
			} finally {
				try {
					rs.close();
				} catch (Exception _m_8) {
				}
			}
		} finally {
			try {
				ps.close();
			} catch (Exception _m_9) {
			}
		}
	}
}

src/main/java/com/ekexiu/portal/ware/WareService.java

@@ -1,24 +1,7 @@
package com.ekexiu.portal.ware;
import java.io.ByteArrayInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Collections;
import java.util.Comparator;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.atomic.AtomicInteger;
import com.ekexiu.portal.service.GrowthLogService;
import com.ekexiu.portal.service.KeyWordService;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.DefaultValue;
import org.jfw.apt.annotation.Nullable;
@@ -39,8 +22,24 @@ import org.jfw.util.jdbc.ResultSetExtractor;
import org.jfw.util.web.fileupload.Item;
import org.jfw.util.web.fileupload.UploadItemIterator;
import com.ekexiu.portal.service.GrowthLogService;
import com.ekexiu.portal.service.KeyWordService;
import java.io.ByteArrayInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Collections;
import java.util.Comparator;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.atomic.AtomicInteger;
@Path("/ware")
public class WareService {
@@ -615,7 +614,7 @@ public class WareService {
		if (key != null) {
			key = "%" + key + "%";
		}
		return wareDao.indexSeach(con, key, sortFirst, time, id, rows);
		return wareDao.indexSearch(con, key, sortFirst, time, id, rows);
	}
	@Get