transitinfoserviceimpl.java

一个关于物流的管理系统

package com.shunshi.ssh.service;

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

import org.extremecomponents.table.limit.Limit;

import com.shunshi.ssh.dao.IAllInfoDao;
import com.shunshi.ssh.dao.ITransitinfoDao;
import com.shunshi.ssh.entity.Agent;
import com.shunshi.ssh.entity.AllInfo;
import com.shunshi.ssh.entity.Page;
import com.shunshi.ssh.entity.Transitinfo;
import com.shunshi.ssh.exception.AgentDaoException;
import com.shunshi.ssh.exception.AgentServiceException;
import com.shunshi.ssh.exception.TransitinfoDaoException;
import com.shunshi.ssh.exception.TransitinfoServiceException;

public class TransitinfoServiceImpl implements ITransitinfoService {
	private ITransitinfoDao dao;
	private IAllInfoDao allInfoDao;
	public ITransitinfoDao getDao() {
		return dao;
	}

	public void setDao(ITransitinfoDao dao) {
		this.dao = dao;
	}

	public IAllInfoDao getAllInfoDao() {
		return allInfoDao;
	}

	public void setAllInfoDao(IAllInfoDao allInfoDao) {
		this.allInfoDao = allInfoDao;
	}

	public void addTransitinfo(Transitinfo Transitinfo) throws TransitinfoServiceException {
		try {
			dao.add(Transitinfo);
		} catch (TransitinfoDaoException e) {
			throw new TransitinfoServiceException(e.getMessage());
		}

	}

	public void delete(int[] id) throws TransitinfoServiceException {
		for(int i:id){
			try {
				dao.delete(i);
			} catch (TransitinfoDaoException e) {
				throw new TransitinfoServiceException(e.getMessage());
			}
		}

	}

	public List findAll() throws TransitinfoServiceException {
		try {
			return dao.findAll();
		} catch (TransitinfoDaoException e) {
			throw new TransitinfoServiceException(e.getMessage());
		}
	}

	public Transitinfo findById(int id) throws TransitinfoServiceException {
		try {
			return dao.findById(id);
		} catch (TransitinfoDaoException e) {
			throw new TransitinfoServiceException(e.getMessage());
		}
	}

	public List findByUser(int id) throws TransitinfoServiceException {
		try {
			return dao.findByUserId(id);
		} catch (TransitinfoDaoException e) {
			throw new TransitinfoServiceException(e.getMessage());
		}
	}

	public void updateState(int[] id, int state) throws TransitinfoServiceException {
		
		for(int i=0;i<id.length;i++){
			try {
				dao.updateState(id[i], state);
			} catch (TransitinfoDaoException e) {
				throw new TransitinfoServiceException(e.getMessage());
			}
		}
	}

	public void updateTransitinfo(Transitinfo t) throws TransitinfoServiceException {
		try {
			dao.updateTransitinfo(t);
		} catch (TransitinfoDaoException e) {
			throw new TransitinfoServiceException(e.getMessage());
		}

	}

	public Page findByState(int state, Limit size, int totalRows)
			throws TransitinfoServiceException {
		try{
			if (totalRows < 0) {
			totalRows = dao.getTotalRowsByState(state).intValue();
		}
			size.setRowAttributes(totalRows, Page.DEFAULT_PAGE_SIZE);	
		int[] startAndEnd= new int[]{size.getRowStart(),size.getCurrentRowsDisplayed()};
		
		List<Transitinfo> l=dao.findByState(state, startAndEnd[0],startAndEnd[1]);
		
		List transitinfos=new ArrayList();
		Integer order=new Integer(1);
		for(Transitinfo t:l){
			Map tranMap=new HashMap();
			tranMap.put("deadline",t.getDeadline());
			tranMap.put("title", t.getTitle());
			tranMap.put("userId",t.getUserId());
			tranMap.put("order", order++);
			if(1==t.getState())
				tranMap.put("state","等待审核");
			else if(2==t.getState())
				tranMap.put("state", "通过审核");
			else if(3==t.getState())
				tranMap.put("state", "等待回收");
			tranMap.put("id",t.getId());
			transitinfos.add(tranMap);
		}
		
		
		Page page = new Page(size.getRowStart(),totalRows,size.getPage(),transitinfos);
		return page;
		} catch (TransitinfoDaoException e) {
			throw new TransitinfoServiceException(e.getMessage());
		}
		
	}

	public AllInfo getAllInfo() throws TransitinfoServiceException {
		Transitinfo transitinfo=null;
		try {
			transitinfo = dao.findByMaxId();
		} catch (TransitinfoDaoException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		AllInfo info=new AllInfo();
		info.setName(transitinfo.getTitle());
		info.setType("航空铁路代理信息");
		info.setClassType("transitinfo");
		info.setUserId(transitinfo.getUserId().longValue());
		info.setBid(transitinfo.getId().longValue());
		return info;
	}

	public void saveAllInfo(AllInfo allInfo) throws TransitinfoServiceException {
		allInfoDao.addInfo(allInfo);
		
	}

	public void deleteAllInfo(Transitinfo transitinfo)
			throws TransitinfoServiceException {
		allInfoDao.deleteObject(transitinfo);
	}

}