indexstatdaoimpl.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.IndexStat;
import com.srit.gcz.bean.IndexStatRel;
import com.srit.gcz.bean.rowmapper.IndexStatRowMapper;
import com.srit.gcz.dao.IndexStatDao;
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 IndexStatDaoImpl implements IndexStatDao{
	// 查询某节点
	private static final String QUERY_INDEXSTAT = "SELECT * FROM "+SysConstant.TABLE_INDEX_STAT+" WHERE ID = ?";
	// 查询所有
	private static final String QUERY_ALL_INDEXSTAT  = "SELECT * FROM "+SysConstant.TABLE_INDEX_STAT;
	// 查询某指标所有
	private static final String QUERY_REL_INDEXSTAT  = "SELECT a.* FROM "+SysConstant.TABLE_INDEX_STAT+" A,"+SysConstant.TABLE_INDEX_INDEXSTAT+" B WHERE A.ID = B.RELID AND B.INDEXID = ?";
	// 查询某指标所有属性ID
	private static final String QUERY_STATID_INDEXSTAT  = "SELECT a.ID FROM "+SysConstant.TABLE_INDEX_STAT+" A,"+SysConstant.TABLE_INDEX_INDEXSTAT+" B WHERE A.ID = B.RELID AND B.INDEXID = ?";
	// 新增统计频度
	private static final String INSERT_INDEXSTAT = "INSERT INTO "+SysConstant.TABLE_INDEX_STAT+"(ID, NAME) VALUES(?, ?)";
	// 新增统计频度指标关系
	private static final String INSERT_REL_INDEXSTAT = "INSERT INTO "+SysConstant.TABLE_INDEX_INDEXSTAT+"(INDEXID, RELID) VALUES(?, ?)";
	// 更新统计频度
	private static final String UPDATE_INDEXSTAT = "UPDATE "+SysConstant.TABLE_INDEX_STAT+" SET NAME = ? WHERE ID = ?";
	// 删除统计频度
	private static final String DELETE_INDEXSTAT= "DELETE FROM "+SysConstant.TABLE_INDEX_STAT+" WHERE ID = ?";
	// 删除统计频度指标关系
	private static final String DELETE_REL_INDEXSTAT= "DELETE FROM "+SysConstant.TABLE_INDEX_INDEXSTAT+" WHERE INDEXID = ?";
	// Srping注入
	private JdbcTemplate jdbcTemplate;

	public boolean delete(IndexStat bean) {
		int operMark = jdbcTemplate.update(DELETE_INDEXSTAT,
				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_INDEXSTAT,new Object[] {id}) < 1){
				return false;
			}
		}
		return true;
	}

	public boolean updateRel(int ID, String rels) {
		deleteRel(ID+"");
		saveRel(ID, rels);
		return false;
	}
	
	public IndexStat getIndexStatByID(int ID) {
		IndexStat bean = (IndexStat) jdbcTemplate.queryForObject(QUERY_INDEXSTAT, new Object[] { ID },
				new IndexStatRowMapper());
		return bean;
	}

	@SuppressWarnings("unchecked")
	public List<IndexStat> getIndexStats() {
		Object obj = jdbcTemplate.query(QUERY_ALL_INDEXSTAT, new RowMapperResultSetExtractor(new IndexStatRowMapper()));
		return (List<IndexStat>)obj;
	}

	@SuppressWarnings("unchecked")
	public List<IndexStat> getIndexStatsByIndexID(int ID) {
		Object obj = jdbcTemplate.query(QUERY_REL_INDEXSTAT, new Object[] { ID }, new RowMapperResultSetExtractor(new IndexStatRowMapper()));
		return (List<IndexStat>)obj;
	}

	public List<IndexStat> getIndexStatsByIndexIDs(String IDs) {
		String[] array = IDs.split(",");
		String[] statIDs = new String[array.length];
		for(int i = 0; i < array.length;i++){
			String temp = getStatsID(Integer.parseInt(array[i]));
			statIDs[i] = temp;
		}
		String reID = SysFuncUtils.getIntersection(statIDs);
		if(reID.length() > 0){
			List<IndexStat> allStats = getIndexStats();
			Map<String, IndexStat> allStatMap = new HashMap<String, IndexStat>();
			for(IndexStat temp : allStats){
				allStatMap.put(temp.getId()+"", temp);
			}
			String[] res = reID.split(",");
			List<IndexStat> reStats = new ArrayList<IndexStat>();
			for(int j = 0;j < res.length;j++){
				reStats.add(allStatMap.get(res[j]));
			}
			return reStats;
		}else{
			return null;
		}
	}
	
	private String getStatsID(int ID){
		List rows = jdbcTemplate.queryForList(QUERY_STATID_INDEXSTAT, 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(IndexStat bean) {
		int operMark = jdbcTemplate.update(INSERT_INDEXSTAT,
				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_INDEXSTAT, new Object[] {
					 ID, Integer.parseInt(rel_Array[i]) });
			if (operMark <= 0) {
				return false;
			}
		}
		return true;
	}

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

}