selectmmsserviceimpl.java

来自「移动彩信管理平台」· Java 代码 · 共 150 行

package com.my7g.zj.mobile.mms.business.service;

import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Vector;

import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;

import com.my7g.zj.mobile.mms.bean.SelectMMSBean;
import com.my7g.zj.mobile.mms.business.ISelectMMSService;
import com.my7g.zj.mobile.mms.mapping.TbMmsType;
import com.my7g.zj.mobile.mms.sys.BasicDao;
import com.my7g.zj.mobile.mms.util.DividePageBean;
import com.my7g.zj.mobile.mms.util.PageBean;

public class SelectMMSServiceImpl extends BasicDao implements ISelectMMSService {
	
	
	private EntityManagerFactory entityManagerFactory;
	
	private DividePageBean dividePageBean;

	/**
	 * 获取所有子类栏目
	 * @return
	 */
	public List<TbMmsType> getMmsTypeIndex() {
		List<TbMmsType> typeList = null;
		String hql = "from TbMmsType tn where tn.sortDeep = 3";
		typeList = daoSupport.find(hql);
		return typeList;
	}
	
	
	public PageBean selectMMS(int page, int rowPerPage,String href,String typyIndex,String title,String checkstate,String startDate,String endDate,String keyword){
		
		EntityManager entityManager = null;
		PageBean bean = null;
		try {
			entityManager = entityManagerFactory.createEntityManager();
			startDate = "'"+startDate + " 00:00:00.000'";
			endDate = "'"+endDate + " 00:00:00.999'";
			
			
			String condition = "";
			
			if(!typyIndex.equals("-1")){
				
				condition  += " and type.sort_index = '"+ typyIndex +"'";
			}
			
			if(!title.trim().equals("")){
				condition  += " and upload.mms_title like '%"+ title.trim() +"%'";
			}
			
			if(!checkstate.equals("-1")){
				condition  += " and upload.auditing_state = '"+ checkstate +"'";
			}
			
			if(!keyword.trim().equals("")){
				condition  += " and upload.mms_key = '%"+ keyword.trim() +"%'";
			}
			
			condition  += " and upload.group_send_time >= "+ startDate +" and upload.group_send_time <= "+ endDate;
			
			
			String sql = "select upload.mms_id,type.sort_name,provider.ent_name,upload.mms_title," +
					"upload.group_send_time,upload.auditing_state,sum(transmit.transmit_total) counts " +
					"from tb_mms_upload upload,tb_cjdx_sms_transmit transmit,tb_mms_type type,supermms_cp..tb_mms_cp_provider provider " +
					"where upload.type_index = type.sort_index and provider.type_index = type.sort_index and transmit.sms_id = upload.mms_id " +
					condition +
					"group by upload.mms_id,type.sort_name,provider.ent_name,upload.mms_title,upload.group_send_time,upload.auditing_state";
			
//			System.out.println("=============" + sql);
			
			String countsql = "select count(1) from (" + sql +") tab";
			
			dividePageBean.setwaitPage(String.valueOf(page), rowPerPage);
	
			Long ecount = 0L;
			Vector evs = (Vector) (entityManager.createNativeQuery(countsql)
					.getSingleResult());
			if (evs != null && !evs.isEmpty()) {
				ecount = Long.valueOf(evs.get(0).toString());
			}
			dividePageBean.setPageInfo(ecount.intValue());

			List rs = entityManager.createNativeQuery(sql).setFirstResult(
					(page - 1) * rowPerPage).setMaxResults(rowPerPage)
					.getResultList();
			List rsList = new ArrayList();
//			System.out.println(rs.size() + "==============================================================================");
			for (Iterator it = rs.iterator(); it.hasNext();) {

				Vector vs = (Vector) it.next();
				SelectMMSBean selectMMSBean = new SelectMMSBean();
				selectMMSBean.setId(vs.get(0) == null ? "" : vs.get(0).toString());
				selectMMSBean.setSortName(vs.get(1) == null ? "" : vs.get(1).toString());
				selectMMSBean.setCp(vs.get(2) == null ? "" : vs.get(2).toString());
				selectMMSBean.setTitle(vs.get(3) == null ? "" : vs.get(3).toString());
				selectMMSBean.setSendTime(vs.get(4) == null ? "" : vs.get(4).toString());
				selectMMSBean.setCheckState(vs.get(5) == null ? "" : vs.get(5).toString());
				selectMMSBean.setTransmitCount(vs.get(5) == null ? "" : vs.get(5).toString());
				rsList.add(selectMMSBean);

			}

			String pageHref = dividePageBean.gethrefPage(href, "pagesel",
					"page");
			
			bean = new PageBean(pageHref, rsList);

			entityManager.createNamedQuery(sql);

		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			if (entityManager != null) {
				entityManager.close();
			}
		}

		return bean;
		
		
		
	}

	public EntityManagerFactory getEntityManagerFactory() {
		return entityManagerFactory;
	}

	public void setEntityManagerFactory(EntityManagerFactory entityManagerFactory) {
		this.entityManagerFactory = entityManagerFactory;
	}


	public DividePageBean getDividePageBean() {
		return dividePageBean;
	}


	public void setDividePageBean(DividePageBean dividePageBean) {
		this.dividePageBean = dividePageBean;
	}

}