indexfrequencydaoimpl.java

用户模块和指标模块等等,还有其它的模块吧

package com.srit.gcz.dao.impl;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapperResultSetExtractor;

import com.srit.gcz.bean.IndexFrequency;
import com.srit.gcz.bean.IndexFrequencyRel;
import com.srit.gcz.bean.IndexStat;
import com.srit.gcz.bean.rowmapper.IndexFrequencyRowMapper;
import com.srit.gcz.dao.IndexFrequencyDao;
import com.srit.gcz.util.SysConstant;
import com.srit.gcz.util.SysFuncUtils;

/**
 * 统计频度
 * @Company 国研科技
 * @author 陈鹏昊
 * @date 2009-3-24
 * @version 1.0
 * @since 1.0
 */
public class IndexFrequencyDaoImpl implements IndexFrequencyDao{
	// 查询某节点
	private static final String QUERY_INDEXFREQUENCY = "SELECT * FROM "+SysConstant.TABLE_INDEX_FREQUENCY+" WHERE ID = ?";
	// 查询所有
	private static final String QUERY_ALL_INDEXFREQUENCY  = "SELECT * FROM "+SysConstant.TABLE_INDEX_FREQUENCY;
	// 查询某指标所有
	private static final String QUERY_REL_INDEXFREQUENCY  = "SELECT a.* FROM "+SysConstant.TABLE_INDEX_FREQUENCY+" A,"+SysConstant.TABLE_INDEX_INDEXFREQUENCY+" B WHERE A.ID = B.RELID AND B.INDEXID = ?";
	// 查询某指标所有频度
	private static final String QUERY_FREQUENCYID_INDEXFREQUENCY  = "SELECT a.ID FROM "+SysConstant.TABLE_INDEX_FREQUENCY+" A,"+SysConstant.TABLE_INDEX_INDEXFREQUENCY+" B WHERE A.ID = B.RELID AND B.INDEXID = ?";
	// 查询频度对应的子分类
	private static final String QUERY_FREQUENCYSORT_INDEXFREQUENCY  = "SELECT NAME FROM "+SysConstant.TABLE_INDEX_FREQUENCYSORT+" WHERE FID = ? ORDER BY SEQ";
	// 新增统计频度
	private static final String INSERT_INDEXFREQUENCY = "INSERT INTO "+SysConstant.TABLE_INDEX_FREQUENCY+"(ID, NAME) VALUES(?, ?)";
	// 新增统计频度指标关系
	private static final String INSERT_REL_INDEXFREQUENCY = "INSERT INTO "+SysConstant.TABLE_INDEX_INDEXFREQUENCY+"(INDEXID, RELID) VALUES(?, ?)";
	// 更新统计频度
	private static final String UPDATE_INDEXFREQUENCY = "UPDATE "+SysConstant.TABLE_INDEX_FREQUENCY+" SET NAME = ? WHERE ID = ?";
	// 删除统计频度
	private static final String DELETE_INDEXFREQUENCY= "DELETE FROM "+SysConstant.TABLE_INDEX_FREQUENCY+" WHERE ID = ?";
	// 删除统计频度指标关系
	private static final String DELETE_REL_INDEXFREQUENCY= "DELETE FROM "+SysConstant.TABLE_INDEX_INDEXFREQUENCY+" WHERE INDEXID = ?";
	// Srping注入
	private JdbcTemplate jdbcTemplate;

	public boolean delete(IndexFrequency bean) {
		int operMark = jdbcTemplate.update(DELETE_INDEXFREQUENCY,
				new Object[] {bean.getId()});
		return (operMark > 0) ? true : false;
	}

	public boolean deleteRel(String IDs) {
		String[] idArray = IDs.split(",");
		for(int i = 0;i < idArray.length;i++){
			int id = Integer.parseInt(idArray[i]);
			if(jdbcTemplate.update(DELETE_REL_INDEXFREQUENCY,new Object[] {id}) < 1){
				return false;
			}
		}
		return true;
	}

	public boolean updateRel(int ID, String rels) {
		deleteRel(ID+"");
		saveRel(ID, rels);
		return false;
	}
	
	public IndexFrequency getIndexFrequencyByID(int ID) {
		IndexFrequency bean = (IndexFrequency) jdbcTemplate.queryForObject(QUERY_INDEXFREQUENCY, new Object[] { ID },
				new IndexFrequencyRowMapper());
		return bean;
	}

	@SuppressWarnings("unchecked")
	public List<IndexFrequency> getIndexFrequencys() {
		Object obj = jdbcTemplate.query(QUERY_ALL_INDEXFREQUENCY, new RowMapperResultSetExtractor(new IndexFrequencyRowMapper()));
		return (List<IndexFrequency>)obj;
	}

	@SuppressWarnings("unchecked")
	public List<IndexFrequency> getIndexFrequencysByIndexID(int ID) {
		Object obj = jdbcTemplate.query(QUERY_REL_INDEXFREQUENCY, new Object[] { ID }, new RowMapperResultSetExtractor(new IndexFrequencyRowMapper()));
		return (List<IndexFrequency>)obj;
	}

	public List<IndexFrequency> getIndexFrequencysByIndexIDs(String IDs) {
		String[] array = IDs.split(",");
		String[] statIDs = new String[array.length];
		for(int i = 0; i < array.length;i++){
			String temp = getIndexFrequencysID(Integer.parseInt(array[i]));
			statIDs[i] = temp;
		}
		String reID = SysFuncUtils.getIntersection(statIDs);
		if(reID.length() > 0){
			List<IndexFrequency> allFrequencys = getIndexFrequencys();
			Map<String, IndexFrequency> allStatMap = new HashMap<String, IndexFrequency>();
			for(IndexFrequency temp : allFrequencys){
				allStatMap.put(temp.getId()+"", temp);
			}
			String[] res = reID.split(",");
			List<IndexFrequency> reFrequencys = new ArrayList<IndexFrequency>();
			for(int j = 0;j < res.length;j++){
				reFrequencys.add(allStatMap.get(res[j]));
			}
			return reFrequencys;
		}else{
			return null;
		}
	}
	
	private String getIndexFrequencysID(int ID){
		List rows = jdbcTemplate.queryForList(QUERY_FREQUENCYID_INDEXFREQUENCY, new Object[]{ ID });
		Iterator it = rows.iterator();
		StringBuffer stb = new StringBuffer();
		while(it.hasNext()) {  
		    Map map = (Map) it.next();  
		    String id = map.get("ID").toString();
			stb.append(id).append(",");
		}
		return SysFuncUtils.delLastChart(stb);
	}
	
	public boolean save(IndexFrequency bean) {
		int operMark = jdbcTemplate.update(INSERT_INDEXFREQUENCY,
				new Object[] {bean.getId(), bean.getName()});
		return (operMark > 0) ? true : false;
	}

	public boolean saveRel(int ID, String rels) {
		int operMark = -1;
		String[] rel_Array = rels.split(",");
		for(int i = 0;i < rel_Array.length;i++){
			operMark = jdbcTemplate.update(INSERT_REL_INDEXFREQUENCY, new Object[] {
					 ID, Integer.parseInt(rel_Array[i]) });
			if (operMark <= 0) {
				return false;
			}
		}
		return true;
	}

	public boolean update(IndexFrequency bean) {
		int operMark = jdbcTemplate.update(UPDATE_INDEXFREQUENCY,
				new Object[] {bean.getName(), bean.getId()});
		return (operMark > 0) ? true : false;
	}
	
	public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
		this.jdbcTemplate = jdbcTemplate;
	}

	public List<String> getFrequencySort(int ID) {
		List rows = jdbcTemplate.queryForList(QUERY_FREQUENCYSORT_INDEXFREQUENCY, new Object[]{ ID });
		Iterator it = rows.iterator();
		List<String> sort = new ArrayList<String>();
		while(it.hasNext()) {  
		    Map map = (Map) it.next();  
		    sort.add(map.get("NAME").toString());
		}
		return sort;
	}
}