remarklistdao.java

博克后台的开发,有很多使用的方法和例子可以提供给大家学习

package com.remark.manage.dao.impl;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

import com.common.util.DateFormatUtil;
import com.common.util.ListInfo;
import com.emk.manage.exception.ParseStringException;
import com.remark.manage.dao.IRemarkListDAO;
import com.remark.manage.hibernate.po.EmkEcommRemark;
import com.remark.manage.hibernate.po.EmkMemcoIpscreen;
import com.remark.manage.vo.impl.EmkEcommRemarkVO;
import com.res.core.service.ui.component.navbar.PageModel;

public class RemarkListDAO extends HibernateDaoSupport implements IRemarkListDAO{
	//查询记录
	public List listRemark(String username,String rklswzbt,String aip,String adate,String content,String aFlag,PageModel pageModel) throws Exception{
		List retList = new ArrayList();
		List retList2 = new ArrayList();
		ListInfo listInfo = new ListInfo();
		List values = new ArrayList();
		String sql = "select eer from EmkEcommRemark eer where 1=1";
//		通过用户名进行查找
		if(username!=null && !username.equals("")){
			sql += " and eer.memberid in(select emm.memberid from EmkMemcoMemberinfo emm where emm.nickname like ?)";
			values.add("%"+username+"%");
		}
//		通过文章标题查找
		if(rklswzbt!=null && !rklswzbt.equals("")){
			sql += " and eer.AId in(select trkls.rklsrecid from TconRkls trkls where trkls.rklswzbt like ?)";
			values.add("%"+rklswzbt+"%");
		}
//		通过ip进行查找
		if(aip!=null && !aip.equals("")){
			sql += " and eer.AIp='"+aip+"'";
		}
//		通过时间来进行查找
		if(adate!=null && !adate.equals("")){
			sql += " and eer.ADate between to_date('"+ adate +" 00:00:00','YYYY-MM-DD HH24:MI:SS') and to_date('"+ adate +" 23:59:59','YYYY-MM-DD HH24:MI:SS')";
		}
//		通过文章内容进行查找
		if(content!=null && !content.equals("")){
			sql += " and eer.AContent like ?";
			values.add("%"+content+"%");
		}
//		通过显示标志位查找
		if(aFlag!=null && !aFlag.equals("")){
			sql += " and eer.AFlag='" + aFlag +"'";
		}
		retList2 = listInfo.getOfficeBySearchCriteria(this.getHibernateTemplate(),sql,pageModel,values.toArray());
		if(retList2.size()!=0){
			for(int i =0;i<retList2.size();i++){
				//此处因为数据库设计原因，只能多查一遍数据库，待优化时解决
				EmkEcommRemarkVO emkEcommRemarkVO = new EmkEcommRemarkVO((EmkEcommRemark)retList2.get(i));
				String flag = emkEcommRemarkVO.getAFlag();
				if("0".equals(flag)){
					emkEcommRemarkVO.setAFlag("不显示");
				}else if("1".equals(flag)){
					emkEcommRemarkVO.setAFlag("显示");
				}
				String ip = emkEcommRemarkVO.getAIp();
				//System.out.println(ip);
				String sql1 = "from EmkMemcoIpscreen where ip = '" + ip +"'";
				List ipList = this.getHibernateTemplate().find(sql1);
				if(ipList.size()!=0){
					emkEcommRemarkVO.setShowValue("屏蔽");
				}else{
					emkEcommRemarkVO.setShowValue("未屏蔽");
				}
				retList.add(emkEcommRemarkVO);
			}
		}
		return retList;
		
	}
	
	//插入和更新一条数据
	public void saveOrUpdateEmkEcommRemark(EmkEcommRemark emkEcommRemark){
		
		getHibernateTemplate().saveOrUpdate(emkEcommRemark);
	}
	
	//向IP地址屏蔽表中插入一条数据
	public void saveOrUpdateEmkMemcoIpscreen(List ipList){
		for(int i=0;i<ipList.size();i++){
			EmkEcommRemarkVO emkEcommRemarkVO = (EmkEcommRemarkVO) ipList.get(i);
			if(emkEcommRemarkVO.getSelected() == true){
				EmkMemcoIpscreen Ipscreen = new EmkMemcoIpscreen();
				//System.out.println(emkEcommRemarkVO.getAIp());
				Ipscreen.setIp(emkEcommRemarkVO.getAIp());
				Ipscreen.setScreentime(DateFormatUtil.getFormatDate());
				getHibernateTemplate().saveOrUpdate(Ipscreen);
			}
		}
		
	}
	
	//从IP地址屏蔽表中删除一条数据
	public void delIpsreec(List ipList){
		for(int i=0;i<ipList.size();i++){
			EmkEcommRemarkVO emkEcommRemarkVO = (EmkEcommRemarkVO) ipList.get(i);
			if(emkEcommRemarkVO.getSelected() == true){
				/*EmkMemcoIpscreen Ipscreen = new EmkMemcoIpscreen();
				Ipscreen.setIp(emkEcommRemarkVO.getAIp());
				Ipscreen.setScreentime(DateFormatUtil.getFormatDate());*/				
				String ip = emkEcommRemarkVO.getAIp();
				String sql = "from EmkMemcoIpscreen where ip = '" + ip +"'";
				List list = this.getHibernateTemplate().find(sql);
				if(list.size()!=0){
					for(int j=0;j<list.size();j++){
						EmkMemcoIpscreen Ipscreen = (EmkMemcoIpscreen) list.get(j);
						this.getHibernateTemplate().delete(Ipscreen);
					}
					
				}
				
			}
		}
	}
	
	//删除一条记录
	public boolean delRemarkList(List rmkList){
		boolean isDel = false;
		try{
		for(int i=0;i<rmkList.size();i++){
			EmkEcommRemarkVO emkEcommRemarkVO = (EmkEcommRemarkVO) rmkList.get(i);
			if(emkEcommRemarkVO.getSelected() == true){
				getHibernateTemplate().delete(new EmkEcommRemark(emkEcommRemarkVO));
				
			}
			isDel = true;
		}
		}catch(Exception e){
			e.printStackTrace();
		}
		return isDel;
		
	}
}