11

src/main/java/com/ekexiu/portal/job/HotKeyJobEntry.java

package com.ekexiu.portal.job;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import java.util.Collections;
import java.util.Comparator;
import java.util.HashMap;
import java.util.Map;
import javax.sql.DataSource;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.Bean;
import org.jfw.util.jdbc.JdbcUtil;
import com.ekexiu.portal.pojo.DataDictCode;
import com.ekexiu.portal.service.DataDictService;
		this.dataDictService = dataDictService;
	}
	private void addEntry(String caption, Map<String, DataDictCode> map) {
		DataDictCode item = map.get(caption);
		if (item == null) {
			item = new DataDictCode();
			item.setCaption(caption);
			item.setCount(1);
			map.put(caption, item);
		} else {
			item.setCount(1 + item.getCount());
		}
	}
	private void addEntrys(Connection con, String sql, Map<String, DataDictCode> map) throws SQLException {
		Statement st = con.createStatement();
		try {
			ResultSet rs = st.executeQuery(sql);
			try {
				while (rs.next()) {
					addEntry(rs.getString(1), map);
				}
			} finally {
				JdbcUtil.close(rs);
			}
		} finally {
			JdbcUtil.close(st);
		}
	}
	@Override
	public void run() {
		Map<String, DataDictCode> tmpMap = new HashMap<String, DataDictCode>();
		try {
			Connection con = this.dataSource.getConnection();
			try {
				Items items = fillSetValue(con,
						"SELECT SUBJECT FROM PROFESSOR UNION ALL SELECT INDUSTRY FROM PROFESSOR UNION ALL SELECT SUBJECT FROM ARTICLE UNION ALL SELECT SUBJECT FROM RESOURCE");
				List<Item> list = items.getItemByDescSort();
				List<DataDictCode> codes = new ArrayList<DataDictCode>();
				for (Item item : list) {
					if (item.getValue() > 1) {
						DataDictCode code = new DataDictCode();
						code.setCount(item.getValue());
						code.setCaption(item.getCaption());
						codes.add(code);
				addEntrys(con, "SELECT KW FROM ART_KEY_WORD", tmpMap);
				addEntrys(con, "SELECT KW FROM PRO_KEY_WORD", tmpMap);
				addEntrys(con, "SELECT KW FROM ORG_KEY_WORD", tmpMap);
				addEntrys(con, "SELECT KW FROM RES_KEY_WORD", tmpMap);
				addEntrys(con, "SELECT KW FROM PAP_KEY_WORD", tmpMap);
				addEntrys(con, "SELECT KW FROM PAT_KEY_WORD", tmpMap);
				ArrayList<DataDictCode> list = new ArrayList<DataDictCode>(tmpMap.size());
				list.addAll(tmpMap.values());
				Collections.sort(list, new Comparator<DataDictCode>() {
					public int compare(DataDictCode o1, DataDictCode o2) {
						long l = o2.getCount() - o1.getCount();
						if (l == 0)
							return 0;
						else if (l > 0)
							return 1;
						else
							return -1;
					}
				}
				this.dataDictService.setHotKey(codes);
				});
				this.dataDictService.setHotKey(list);
			} catch (Exception e) {
				try {
					con.rollback();
				} catch (Exception e1) {
					e1.printStackTrace();
				}
			} finally {
				try {
					con.close();
				} catch (Exception e) {
					e.printStackTrace();
				}
			} finally {
				JdbcUtil.close(con);
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}

src/main/java/com/ekexiu/portal/service/KeyWordService.java

	private PatKeyWordDao patKeyWordDao;
	@Autowrie
	private PapKeyWordDao papKeyWordDao;
	
	
	public ProKeyWordDao getProKeyWordDao() {
		return proKeyWordDao;
	}
		this.papKeyWordDao = papKeyWordDao;
	}
	public void refreshProfessor(Connection con,String id,String[] kws)throws SQLException{
	public void refreshProfessor(Connection con, String id, String[] kws) throws SQLException {
		proKeyWordDao.delete(con, id);
		if(kws!=null && kws.length>0){
		if (kws != null && kws.length > 0) {
			ProKeyWord[] okws = new ProKeyWord[kws.length];
			for(int i = 0 ;i < kws.length ; ++i){
			for (int i = 0; i < kws.length; ++i) {
				ProKeyWord okw = new ProKeyWord();
				okw.setId(id);
				okw.setKw(kws[i]);
				okws[i]= okw;
				okws[i] = okw;
			}
			proKeyWordDao.insert(con, okws);
		}
	}
	
	public void refreshOrg(Connection con,String id,String[] kws)throws SQLException{
	public void refreshOrg(Connection con, String id, String[] kws) throws SQLException {
		orgKeyWordDao.delete(con, id);
		if(kws!=null && kws.length>0){
		if (kws != null && kws.length > 0) {
			OrgKeyWord[] okws = new OrgKeyWord[kws.length];
			for(int i = 0 ;i < kws.length ; ++i){
			for (int i = 0; i < kws.length; ++i) {
				OrgKeyWord okw = new OrgKeyWord();
				okw.setId(id);
				okw.setKw(kws[i]);
				okws[i]= okw;
				okws[i] = okw;
			}
			orgKeyWordDao.insert(con, okws);
		}
	}
	
	public void refreshArticle(Connection con,String id,String[] kws)throws SQLException{
	public void refreshArticle(Connection con, String id, String[] kws) throws SQLException {
		artKeyWordDao.delete(con, id);
		if(kws!=null && kws.length>0){
		if (kws != null && kws.length > 0) {
			ArtKeyWord[] okws = new ArtKeyWord[kws.length];
			for(int i = 0 ;i < kws.length ; ++i){
			for (int i = 0; i < kws.length; ++i) {
				ArtKeyWord okw = new ArtKeyWord();
				okw.setId(id);
				okw.setKw(kws[i]);
				okws[i]= okw;
				okws[i] = okw;
			}
			artKeyWordDao.insert(con, okws);
		}
	}
	
	public void refreshResource(Connection con,String id,String[] kws)throws SQLException{
	public void refreshResource(Connection con, String id, String[] kws) throws SQLException {
		resKeyWordDao.delete(con, id);
		if(kws!=null && kws.length>0){
		if (kws != null && kws.length > 0) {
			ResKeyWord[] okws = new ResKeyWord[kws.length];
			for(int i = 0 ;i < kws.length ; ++i){
			for (int i = 0; i < kws.length; ++i) {
				ResKeyWord okw = new ResKeyWord();
				okw.setId(id);
				okw.setKw(kws[i]);
				okws[i]= okw;
				okws[i] = okw;
			}
			resKeyWordDao.insert(con, okws);
		}
	}
	
	public void refreshPaper(Connection con,String id,String[] kws)throws SQLException{
	public void refreshPaper(Connection con, String id, String[] kws) throws SQLException {
		papKeyWordDao.delete(con, id);
		if(kws!=null && kws.length>0){
		if (kws != null && kws.length > 0) {
			PapKeyWord[] okws = new PapKeyWord[kws.length];
			for(int i = 0 ;i < kws.length ; ++i){
			for (int i = 0; i < kws.length; ++i) {
				PapKeyWord okw = new PapKeyWord();
				okw.setId(id);
				okw.setKw(kws[i]);
				okws[i]= okw;
				okws[i] = okw;
			}
			papKeyWordDao.insert(con, okws);
		}
	}
	
	
	public void refreshPatent(Connection con,String id,String[] kws)throws SQLException{
	public void refreshPatent(Connection con, String id, String[] kws) throws SQLException {
		patKeyWordDao.delete(con, id);
		if(kws!=null && kws.length>0){
		if (kws != null && kws.length > 0) {
			PatKeyWord[] okws = new PatKeyWord[kws.length];
			for(int i = 0 ;i < kws.length ; ++i){
			for (int i = 0; i < kws.length; ++i) {
				PatKeyWord okw = new PatKeyWord();
				okw.setId(id);
				okw.setKw(kws[i]);
				okws[i]= okw;
				okws[i] = okw;
			}
			patKeyWordDao.insert(con, okws);
		}
	}
	public static String[] splitKeyWord(String kws){
		if(kws == null || kws.trim().length()== 0) return null;
		kws = kws.trim();		
	public static String[] splitKeyWord(String kws) {
		if (kws == null || kws.trim().length() == 0)
			return null;
		kws = kws.trim();
		ArrayList<String> result = new ArrayList<String>();
		char[] cs = kws.toCharArray();
		int mi = cs.length;
			for (int i = 0; i < mi; ++i) {
				char c = cs[i];
				if (c == ',') {
					if (i != begin) result.add(new String(cs, begin, i - begin));
					if (i != begin) {
						String kw = new String(cs, begin, i - begin);
						if (!result.contains(kw)) {
							result.add(new String(cs, begin, i - begin));
						}
					}
					begin = i + 1;
				}
			}
			if (begin!= mi) result.add(new String(cs, begin, mi - begin));
		} 
		return result.isEmpty()?null :result.toArray(new String[result.size()]);
			if (begin != mi)
				result.add(new String(cs, begin, mi - begin));
		}
		return result.isEmpty() ? null : result.toArray(new String[result.size()]);
	}
	
}

src/main/resources/database.sql

ALTER TABLE patent_agree ADD PRIMARY KEY (op_id,patent_id);
ALTER TABLE paper_agree ADD PRIMARY KEY (op_id,paper_id);
ALTER TABLE organization ALTER COLUMN is_join SET DEFAULT '0';
UPDATE organization set is_join='0' WHERE is_join is null;
ALTER TABLE organization ALTER COLUMN is_join SET NOT NULL;