MyOA.rar_myoa

package com.oa.serviceimpl; import org.apache.log4j.Logger; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.Date; import java.util.GregorianCalendar; import java.util.HashMap; import java.util.List; import java.util.Map; import com.oa.daoimpl.Addressbookdaoimpl; import com.oa.daoimpl.Egressiondaoimpl; import com.oa.daoimpl.Employeedaoimpl; import com.oa.daoimpl.Messagesdaoimpl; import com.oa.daoimpl.Opiniondaoimpl; import com.oa.daoimpl.Tongxundaoimpl; import com.oa.idao.Addressbookidao; import com.oa.idao.Egressiondao; import com.oa.idao.Employeedao; import com.oa.idao.Messagesdao; import com.oa.idao.Opiniondao; import com.oa.idao.Tongxundao; import com.oa.iservice.MessageServicedao; import com.oa.pojos.Employee; import com.oa.pojos.Messages; import com.oa.pojos.Opinion; public class MessagesServiceimpl implements MessageServicedao { /** * Logger for this class */ private static final Logger logger = Logger.getLogger(MessagesServiceimpl.class); private Messagesdao messagesdao = new Messagesdaoimpl(); private Employeedao emp = new Employeedaoimpl(); private Tongxundao tongxun = new Tongxundaoimpl(); private Addressbookidao adress = new Addressbookdaoimpl(); private Opiniondao o = new Opiniondaoimpl(); private Egressiondao egression = new Egressiondaoimpl(); /* * (non-Javadoc) * * @see * com.oa.serviceimpl.MessageServicedao#MessageAdd(com.oa.pojos.Messages) */ public void MessageAdd(Messages obj) { if (logger.isDebugEnabled()) { logger.debug("MessageAdd(Messages) - start"); //$NON-NLS-1$ } messagesdao.add(obj); if (logger.isDebugEnabled()) { logger.debug("MessageAdd(Messages) - end"); //$NON-NLS-1$ } } /* * (non-Javadoc) * * @see com.oa.serviceimpl.MessageServicedao#Selectyifa() */ public List<Messages> Selectyifa() { if (logger.isDebugEnabled()) { logger.debug("Selectyifa() - start"); //$NON-NLS-1$ } List<Messages> returnList = messagesdao.getQuery("select e from Messages e ", null); if (logger.isDebugEnabled()) { logger.debug("Selectyifa() - end"); //$NON-NLS-1$ } return returnList; } /* * (non-Javadoc) * * @see com.oa.serviceimpl.MessageServicedao#SelectYiShou() */ public List<Messages> SelectYiShou() { if (logger.isDebugEnabled()) { logger.debug("SelectYiShou() - start"); //$NON-NLS-1$ } String hql = "select e from Messages e join e.employeeByMincept p where p.isjieshuo=?"; List<Messages> returnList = messagesdao.getQuery(hql, "有"); if (logger.isDebugEnabled()) { logger.debug("SelectYiShou() - end"); //$NON-NLS-1$ } return returnList; } /** * 根据名称查询一个员工 */ public Employee SelectEmp(String name) { if (logger.isDebugEnabled()) { logger.debug("SelectEmp(String) - start"); //$NON-NLS-1$ } Employee returnEmployee = this.emp.getUniqueResult("select e from Employee e where e.ename=?", name); if (logger.isDebugEnabled()) { logger.debug("SelectEmp(String) - end"); //$NON-NLS-1$ } return returnEmployee; } public Employee selectmessage(String id) { if (logger.isDebugEnabled()) { logger.debug("selectmessage(String) - start"); //$NON-NLS-1$ } String hql = "select e from Employee e join e.messagesesForMincept t where t.mid='" + id + "'"; Employee returnEmployee = this.emp.getUniqueResult(hql, null); if (logger.isDebugEnabled()) { logger.debug("selectmessage(String) - end"); //$NON-NLS-1$ } return returnEmployee; } public Map selectMessage(Integer page, int size,Integer eid) { if (logger.isDebugEnabled()) { logger.debug("selectMessage(Integer, int, Integer) - start"); //$NON-NLS-1$ } String hql = "select e from Messages e join e.employeeByMtxd t where t.eid=?"; // 查询 List list = messagesdao.getPageQuery(hql, page, size, eid); // 总条数 int sum = list.size(); // 总页数 int count = sum % size == 0 ? sum / size : sum / size + 1; // 越界检查 if (page <= 1) page = 1; if (page >= count) page = count; Map map = new HashMap(); map.put("page", page); map.put("size", size); map.put("count", count); map.put("list", list); map.put("sum", sum); if (logger.isDebugEnabled()) { logger.debug("selectMessage(Integer, int, Integer) - end"); //$NON-NLS-1$ } return map; } /** * 修改员工 * */ public void updateEmp(String id) { if (logger.isDebugEnabled()) { logger.debug("updateEmp(String) - start"); //$NON-NLS-1$ } Employee e = this.selectmessage(id); System.out.println("e " + e); e.setIsjieshuo("是"); emp.update(e); if (logger.isDebugEnabled()) { logger.debug("updateEmp(String) - end"); //$NON-NLS-1$ } } public void updateEmpone(String name) { if (logger.isDebugEnabled()) { logger.debug("updateEmpone(String) - start"); //$NON-NLS-1$ } Employee e = this.SelectEmp(name); System.out.println("e " + e); e.setIsjieshuo("是"); emp.update(e); if (logger.isDebugEnabled()) { logger.debug("updateEmpone(String) - end"); //$NON-NLS-1$ } } public void del(String id) { if (logger.isDebugEnabled()) { logger.debug("del(String) - start"); //$NON-NLS-1$ } String hql = "delete from Messages m where m.mid in" + id + ""; messagesdao.blukUpdate(hql, null); if (logger.isDebugEnabled()) { logger.debug("del(String) - end"); //$NON-NLS-1$ } } public Map SelectShouxin(Integer page, int size,Integer eid) { if (logger.isDebugEnabled()) { logger.debug("SelectShouxin(Integer, int, Integer) - start"); //$NON-NLS-1$ } String hql = "select e from Messages e join e.employeeByMincept p where p.isjieshuo=? and p.eid=?"; // 查询 List list = messagesdao.getPageQuery(hql, page, size, "是",eid); // 总条数 int sum = list.size(); System.out.println("------------- " + sum); // 总页数 int count = sum % size == 0 ? sum / size : sum / size + 1; // 越界检查 if (page <= 1) page = 1; if (page >= count) page = count; Map map = new HashMap(); map.put("page", page); map.put("size", size); map.put("count", count); map.put("list", list); map.put("sum", sum); if (logger.isDebugEnabled()) { logger.debug("SelectShouxin(Integer, int, Integer) - end"); //$NON-NLS-1$ } return map; } public Map selectTongxunLu(Integer page, int size, Short id, String name) { if (logger.isDebugEnabled()) { logger.debug("selectTongxunLu(Integer, int, Short, String) - start"); //$NON-NLS-1$ } String hql = ""; List list = null; if (id == 0 || name == "") { hql = "select t from Employee t join t.dept d where 1=1"; // 查询 list = tongxun.getPageQuery(hql, page, size, null); } if (id != 0) { hql = "select t from Employee t join t.dept d where d.depid=?"; list = tongxun.getPageQuery(hql, page, size, id); } if (name != "") { System.out.println("ssssssssssss"); hql = "select t from Employee t join t.dept d where t.ename like '%" + name + "%'"; list = tongxun.getPageQuery(hql, page, size, null); } // 总条数 int sum = list.size(); System.out.println("------------- " + list.size()); // 总页数 int count = sum % size == 0 ? sum / size : sum / size + 1; // 越界检查 if (page <= 1) page = 1; if (page >= count) page = count; Map map = new HashMap(); map.put("page", page); map.put("size", size); map.put("count", count); map.put("list", list); map.put("sum", sum); if (logger.isDebugEnabled()) { logger.debug("selectTongxunLu(Integer, int, Short, String) - end"); //$NON-NLS-1$ } return map; } /** * 公共通讯录 */ public Map SelectGongTongxun(Integer page, int size, Stri