首页搜索标签排序在专家表中出现次数混乱问题。

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

@@ -0,0 +1,170 @@
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.Collections;
import java.util.List;
import javax.sql.DataSource;
import org.apache.log4j.Logger;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.Bean;
import org.jfw.util.ListUtil;
import com.ekexiu.portal.pojo.DataDictCode;
import com.ekexiu.portal.service.DataDictService;
@Bean
public class DictTaskJobEntry implements Runnable{
	private static Logger logger = Logger.getLogger(TaskJobEntry.class);
	private long delayTime = 1;
	private int maxCount = 20;
	@Autowrie("dataSource")
	private DataSource dataSource;
	@Autowrie
	private DataDictService dataDictService;
	
	public DataDictService getDataDictService() {
		return dataDictService;
	}
	public void setDataDictService(DataDictService dataDictService) {
		this.dataDictService = dataDictService;
	}
	public DataSource getDataSource() {
		return dataSource;
	}
	public void setDataSource(DataSource dataSource) {
		this.dataSource = dataSource;
	}
	public long getDelayTime() {
		return delayTime;
	}
	public void setDelayTime(long delayTime) {
		this.delayTime = delayTime;
	}
	public int getMaxCount() {
		return maxCount;
	}
	public void setMaxCount(int maxCount) {
		this.maxCount = maxCount;
	}
	@Override
	public void run() {
		try {
			Connection con =dataSource.getConnection();
			try{
				Items items = this.fillSetValue(con, "SELECT INDUSTRY FROM PROFESSOR");
				List<Item> list = items.getItemByDescSort(this.maxCount);
				List<DataDictCode> dicts = new ArrayList<DataDictCode>();
				for(Item item:list){
					DataDictCode d = new DataDictCode();
					d.setCaption(item.getCaption());
					dicts.add(d);
				}
				this.dataDictService.setHotIndustries(dicts);
				
				items = this.fillSetValue(con, "SELECT SUBJECT FROM PROFESSOR");
				list = items.getItemByDescSort(this.maxCount);
				dicts = new ArrayList<DataDictCode>();
				for(Item item:list){
					DataDictCode d = new DataDictCode();
					d.setCaption(item.getCaption());
					dicts.add(d);
				}
				this.dataDictService.setHotSubjects(dicts);
				
            }catch(Exception e){
                try{con.rollback();
                }catch(Exception e1){e1.printStackTrace();}
            }finally{
                try{con.close();
                }catch(Exception e){e.printStackTrace();} 
            }
		} catch (Exception e) {
			e.printStackTrace();
		}
		
	}
	private Items fillSetValue(Connection con, String sql) throws SQLException {
		Items items = new Items();
		Statement st = con.createStatement();
		try {
			ResultSet rs = st.executeQuery(sql);
			try {
				while (rs.next()) {
					mergSet(rs.getString(1), items);
				}
			} finally {
				try {
					rs.close();
				} catch (Exception e) {
				}
			}
		} finally {
			try {
				st.close();
			} catch (Exception e) {
			}
		}
		return items;
	}
	private void mergSet(String valList, Items vals) {
		if (valList == null)
			return;
		List<String> ss = ListUtil.splitTrimExcludeEmpty(valList, ',');
		for(String str:ss){
			if(str!=null && str.length()>0)
			vals.add(str);
		}
	}
	private static class Items{
		private List<Item> items = new ArrayList<Item>();
		
		public void add(String itemCaption){
			for(Item item:this.items){
				if(itemCaption.equals(item.getCaption())){
					item.incVal();
					return;
				}
			}
			this.items.add(new Item(itemCaption));
		}
		public List<Item> getItemByDescSort(int limit){
			Collections.sort(this.items);
			if(limit< items.size()) return items;
			return items.subList(0, limit);
		}
	}
	private static class Item implements Comparable<Item>{
		private String caption;
		private long value = 1;
		public Item(String caption){
			this.caption = caption;
			this.value=1;
		}
		public String getCaption() {
			return caption;
		}
		public void setCaption(String caption) {
			this.caption = caption;
		}
		public void incVal(){
			++this.value;
		}
		@Override
		public int compareTo(Item o) {
			long anVal = o.value;
			return this.value>anVal?-1:this.value==anVal?0:1;
		}
		
	}
	
}

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

@@ -169,45 +169,6 @@ public class SchJob implements AfterBeanFactory {
			}
		}, 1, 5, TimeUnit.MINUTES);
		
//		this.service.scheduleWithFixedDelay(new Runnable() {
//			@Override
//			public void run() {
//				try {
//					Connection con = SchJob.this.dataSource.getConnection();
//					try {
//						Set<String> provinces = fillSetValue(con, " SELECT DISTINCT PROVINCE FROM PROFESSOR ");
//						Set<Map<String, String>> set = new HashSet<Map<String,String>>();
//						for (String province : provinces) {
//							Map<String, String> map = new HashMap<String, String>();
//							Set<String> all = fillSetValue(con, "SELECT DISTINCT ADDRESS FROM PROFESSOR WHERE PROVINCE = '"+province+"'");
//							for (String address : all) {
//								map.put(address, province);
//							}
//							set.add(map);
//							Set<String> exists = fillSetValue(con, "SELECT CAPTION FROM DATA_DICT WHERE DICT_CODE='ADDRESS'");
//							for (String s : exists){
//								all.remove(s);
//							}
//						}
//						batchAddCity(con, "ADDRESS", set);
//						con.commit();
//					} catch (SQLException e) {
//						try {
//							con.rollback();
//						} catch (SQLException ee) {
//						}
//						throw e;
//					} finally {
//						try {
//							con.close();
//						} catch (Exception e) {
//						}
//					}
//				} catch (Throwable th) {
//				}
//			}
//		}, 1, 5, TimeUnit.MINUTES);
	}
	private void mergSet(String valList, Set<String> vals) {
@@ -260,28 +221,4 @@ public class SchJob implements AfterBeanFactory {
			}
		}
	}
//	private void batchAddCity(Connection con, String dictCode, Set<Map<String, String>> vals) throws SQLException {
//		if (vals.isEmpty())
//			return;
//		PreparedStatement ps = con.prepareStatement("INSERT INTO DATA_DICT(DICT_CODE,CODE,CAPTION,PARENT_CODE,ACTIVED) VALUES(?,?,?,?,'1')");
//		try {
//			for(Map<String, String> map : vals){
//				if(!map.isEmpty()){
//					for(Entry<String, String> entry : map.entrySet()){
//						ps.setString(1, dictCode);
//						ps.setString(2, StringUtil.buildUUID());
//						ps.setString(3, entry.getKey());
//						ps.setString(4, entry.getValue());
//						ps.addBatch();
//					}
//					ps.executeBatch();
//				}
//			}
//		} finally {
//			try {
//				ps.close();
//			} catch (Exception e) {
//			}
//		}
//	}
}

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

@@ -19,6 +19,8 @@ public class TaskJob implements AfterBeanFactory {
	public void handle(BeanFactory bf) throws Throwable {
	
		TaskJobEntry tje = (TaskJobEntry) bf.getBean("com_ekexiu_portal_job_TaskJobEntry");
		UserLogTaskJobEntry ultje = (UserLogTaskJobEntry) bf.getBean("com_ekexiu_portal_job_UserLogTaskJobEntry");
		DictTaskJobEntry dtje =(DictTaskJobEntry) bf.getBean("com_ekexiu_portal_job_DictTaskJobEntry");
		long delayTime = tje.getDelayTime();
		long task = getTimeMillis(tje.getTaskTime());
		long taskTime = task - System.currentTimeMillis();
@@ -26,8 +28,11 @@ public class TaskJob implements AfterBeanFactory {
		
        ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor();
        // 第二个参数为首次执行的延时时间，第三个参数为定时执行的间隔时间  
//        service.scheduleAtFixedRate(tje, 1, 7200, TimeUnit.SECONDS);
        service.scheduleAtFixedRate(tje, taskTime, delayTime, TimeUnit.MILLISECONDS);
//		service.scheduleAtFixedRate(tje, 1, 7200, TimeUnit.SECONDS);
//		service.scheduleAtFixedRate(ultje, 2, 86400, TimeUnit.SECONDS);
		service.scheduleAtFixedRate(tje, taskTime, delayTime, TimeUnit.MILLISECONDS);
		service.scheduleAtFixedRate(ultje, taskTime, delayTime, TimeUnit.MILLISECONDS);
		service.scheduleAtFixedRate(dtje, 0, dtje.getDelayTime(), TimeUnit.HOURS);
	}
	private static long getTimeMillis(String time) {  
	    try {  

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

@@ -2,6 +2,7 @@ package com.ekexiu.portal.service;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import org.jfw.apt.annotation.Autowrie;
@@ -23,6 +24,9 @@ import com.ekexiu.portal.pojo.DataDictCode;
@Path("/dataDict")
public class DataDictService {
	
	private volatile List<DataDictCode> hotSubjects = new ArrayList<DataDictCode>();
	private volatile List<DataDictCode> hotIndustries = new ArrayList<DataDictCode>();
	
	@Autowrie
	private DataDictDao dataDictDao;
	
@@ -46,6 +50,22 @@ public class DataDictService {
		   this.defautLimitQuerySize = defautLimitQuerySize;
	}
	public List<DataDictCode> getHotSubjects() {
		return hotSubjects;
	}
	public void setHotSubjects(List<DataDictCode> hotSubjects) {
		this.hotSubjects = hotSubjects;
	}
	public List<DataDictCode> getHotIndustries() {
		return hotIndustries;
	}
	public void setHotIndustries(List<DataDictCode> hotIndustries) {
		this.hotIndustries = hotIndustries;
	}
	@Post
	@Path
	public void insert(@JdbcConn(true) Connection con,String dictCode,String code,@Nullable String parentCode,String caption,String descp ) throws SQLException
@@ -73,14 +93,24 @@ public class DataDictService {
	
	@Get
	@Path("/qa/{dictCode}")
	public List<DataDictCode> queryDict(@JdbcConn(false) Connection con, @PathVar String dictCode) throws SQLException{
		return this.dataDictDao.queryDictCode(con, dictCode);
	public List<DataDictCode> queryDict( @PathVar String dictCode) throws SQLException{
		 return this.queryDictCode(dictCode.equals("SUBJECT"));
	}
	
	@Get
	@Path("/qaDictCode")
	public List<DataDictCode> queryDictCode(@JdbcConn(false) Connection con, String dictCode) throws SQLException{
		return this.dataDictDao.queryDictCode(con, dictCode);
	public List<DataDictCode> queryDictCode(String dictCode) throws SQLException{
		 return this.queryDictCode(dictCode.equals("SUBJECT"));
	}
	
	private List<DataDictCode> queryDictCode(boolean isSubject){
		List<DataDictCode> ret = null;
		if(isSubject){
			ret = this.getHotSubjects();
		}else{
			ret = this.getHotIndustries();
		}
		return ret;
	}
	
	@Get