SSM框架实现OA系统

开发时间：2019.5-2019.7

包括：发送信息、删除信息、草稿箱管理、查询信息

applicationContext.xml文件作为系统的父容器，用来处理除了controller以外的内容。

```xml





	
	
		
			
				classpath:db_config.properties
			
		
	
	
	
	
		
			
				classpath:db_config.properties
			
		
	

	
	
		
	

	
	
		
		
		
		
		
		
		
		
	

	
	
		
		
		
		
		service.addMes(Message);
	}

	
	@RequestMapping("/mes/addMesByLoginName")
	public void addMesByLoginName(HttpServletRequest request, HttpServletResponse response, Integer[] emp,
			Message mes) {

		for (int i = 0; i < emp.length; i++) {

			Date mesSendDate = new Date();

			HttpSession session = request.getSession();

			String empLoginName = (String) session.getAttribute("empLoginName");
			Employee employee = empService.queryEmpByLoginName(empLoginName);
			employee.setEmpId(empService.getId(empLoginName));

			Integer empId = employee.getEmpId();

			Employee mesSender = new Employee();
			mesSender.setEmpId(empId);
			mes.setMesSender(mesSender);

			Employee mesReciver = empService.getById(emp[i]);

			mes.setMesReciver(mesReciver);

			mes.setMesSendConfirm("已发");
			mes.setMesReadConfirm("未读");
			mes.setMesSendDate(mesSendDate);

			service.addMes(mes);
		}
	}
	
	
	@RequestMapping("/mes/addDraftByLoginNameNew")
	public void addDraftByLoginNameNew(HttpServletRequest request, HttpServletResponse response, Integer[] emp,
			Message mes) {

		for (int i = 0; i < emp.length; i++) {

			Date mesSendDate = new Date();

			HttpSession session = request.getSession();

			String empLoginName = (String) session.getAttribute("empLoginName");
			Employee employee = empService.queryEmpByLoginName(empLoginName);
			employee.setEmpId(empService.getId(empLoginName));

			Integer empId = employee.getEmpId();

			Employee mesSender = new Employee();
			mesSender.setEmpId(empId);
			mes.setMesSender(mesSender);

			Employee mesReciver = empService.getById(emp[i]);

			mes.setMesReciver(mesReciver);

			mes.setMesSendConfirm("未发");
			mes.setMesReadConfirm("未读");
			mes.setMesSendDate(mesSendDate);

			service.addMes(mes);
		}
	}

	
	@RequestMapping("/mes/addDraftByLoginName")
	public void addDraftByLoginName(HttpServletRequest request, HttpServletResponse response, Message mes) {

		Date mesSendDate = new Date();

		HttpSession session = request.getSession();

		String empLoginName = (String) session.getAttribute("empLoginName");
		Employee emp = empService.queryEmpByLoginName(empLoginName);
		emp.setEmpId(empService.getId(empLoginName));

		Integer empId = emp.getEmpId();

		Employee mesSender = new Employee();
		mesSender.setEmpId(empId);
		mes.setMesSender(mesSender);

		mes.setMesSendConfirm("未发");
		mes.setMesReadConfirm("未读");
		mes.setMesSendDate(mesSendDate);

		service.addMes(mes);
	}

	
	@RequestMapping("/mes/deleteMes")
	public void delete(HttpServletRequest request, HttpServletResponse response, Integer mesId) {
		service.deleteMes(mesId);
	}

	
	@RequestMapping("/mes/updateMes")
	public void update(HttpServletRequest request, HttpServletResponse response, Message mes) {

		Date mesSendDate = new Date();

		HttpSession session = request.getSession();

		String empLoginName = (String) session.getAttribute("empLoginName");
		Employee employee = empService.queryEmpByLoginName(empLoginName);
		employee.setEmpId(empService.getId(empLoginName));

		Integer empId = employee.getEmpId();

		Employee mesSender = new Employee();
		mesSender.setEmpId(empId);
		mes.setMesSender(mesSender);
		mes.setMesSendDate(mesSendDate);

		service.updateMes(mes);

	}
	
	
	@RequestMapping("/mes/updateMesNew")
	public void updateNew(HttpServletRequest request, HttpServletResponse response, Message mes) {

		Date mesSendDate = new Date();

		HttpSession session = request.getSession();

		String empLoginName = (String) session.getAttribute("empLoginName");
		Employee employee = empService.queryEmpByLoginName(empLoginName);
		employee.setEmpId(empService.getId(empLoginName));

		Integer empId = employee.getEmpId();

		Employee mesSender = new Employee();
		mesSender.setEmpId(empId);
		mes.setMesSender(mesSender);
		mes.setMesSendDate(mesSendDate);
		mes.setMesSendConfirm("已发");

		service.updateMes(mes);

	}

	
	@RequestMapping("/mes/updateUnread")
	public void updateUnread(HttpServletRequest request, HttpServletResponse response, Message mes) {
		
//		HttpSession session = request.getSession();
//
//		String empLoginName = (String) session.getAttribute("empLoginName");
//		Employee employee = empService.queryEmpByLoginName(empLoginName);
//		employee.setEmpId(empService.getId(empLoginName));
//
//		Integer empId = employee.getEmpId();

//		Employee mesSender = new Employee();
//		mesSender.setEmpId(empId);
//		mes.setMesSendDate(mesSendDate);
		
		HttpSession session = request.getSession();

		String empLoginName = (String) session.getAttribute("empLoginName");
		Employee employee = empService.queryEmpByLoginName(empLoginName);
		employee.setEmpId(empService.getId(empLoginName));

		Integer empId = employee.getEmpId();

		Employee mesSender = new Employee();
		mesSender.setEmpId(empId);
		mes.setMesSender(mesSender);

		mes.setMesReadConfirm("已读");

		service.updateMes(mes);

	}

	
	@RequestMapping("/mes/queryByCondition")
	@ResponseBody
	public HashMap queryByCondition(HttpServletRequest request, HttpServletResponse response,
			Integer pageNum, Integer pageSize, String mesSendDate, String empEmail, String mesTitle, Integer empId,
			String mesInfo) throws UnsupportedEncodingException {

		if (pageNum == null) {
			pageNum = 0;
		}

		if (pageSize == null) {
			pageSize = 5;
		}

		Pager pager = new Pager(service.getMesCountByCondition(mesSendDate, empEmail, mesTitle, empId, mesInfo),
				pageSize, pageNum);

		List list = service.queryMesByCondition(pager, mesSendDate, empEmail, mesTitle, empId, mesInfo);

		// 在Map集合中存储分页数据和信息数据
		HashMap map = new HashMap<>();
		map.put("pager", pager);
		map.put("list", list);

		return map;
	}

	
	@RequestMapping("/mes/queryByCondition1")
	@ResponseBody
	public HashMap queryByCondition1(HttpServletRequest request, HttpServletResponse response,
			Integer pageNum, Integer pageSize, String mesSendDate, String empEmail, String mesTitle) {

		if (pageNum == null) {
			pageNum = 0;
		}

		if (pageSize == null) {
			pageSize = 5;
		}

		Pager pager = new Pager(service.getMesCount(), pageSize, pageNum);

		List list = service.queryMesByCondition1(pager, mesSendDate, empEmail, mesTitle);

		// 在Map集合中存储分页数据和信息数据
		HashMap map = new HashMap<>();
		map.put("pager", pager);
		map.put("list", list);

		return map;
	}

	
	@RequestMapping("/mes/queryByEmpLoginName")
	@ResponseBody
	public HashMap queryByEmpLoginName(HttpServletRequest request, HttpServletResponse response,
			Integer pageNum, Integer pageSize, String empLoginName, String mesSendDate, String empEmail,
			String mesTitle, Integer empId, String mesInfo) {

		HttpSession session = request.getSession();

		empLoginName = (String) session.getAttribute("empLoginName");
		Employee emp = empService.queryEmpByLoginName(empLoginName);
		session.setAttribute("empId", emp.getEmpId()); // 记录用户id

		if (pageNum == null) {
			pageNum = 0;
		}

		if (pageSize == null) {
			pageSize = 5;
		}

		Pager pager = new Pager(
				service.getMesCountByEmpLoginName(empLoginName, mesSendDate, empEmail, mesTitle, empId, mesInfo),
				pageSize, pageNum);

		List list = service.queryMesByLoginName(empLoginName, pager, mesSendDate, empEmail, mesTitle, empId,
				mesInfo);

		// 在Map集合中存储分页数据和信息数据
		HashMap map = new HashMap<>();
		map.put("pager", pager);
		map.put("list", list);

		return map;
	}

	
	@RequestMapping("/mes/queryDraft")
	@ResponseBody
	public HashMap queryDraft(HttpServletRequest request, HttpServletResponse response,
			String mesSendConfirm, Integer pageNum, Integer pageSize, String empLoginName) {

		HttpSession session = request.getSession();

		empLoginName = (String) session.getAttribute("empLoginName");
		Employee emp = empService.queryEmpByLoginName(empLoginName);
		session.setAttribute("empId", emp.getEmpId()); // 记录用户id

		if (pageNum == null) {
			pageNum = 0;
		}

		if (pageSize == null) {
			pageSize = 5;
		}

		Pager pager = new Pager(service.getMesDraftCount("未发", empLoginName), pageSize, pageNum);

		List list = service.queryMesDraft("未发", pager, empLoginName);

		// 在Map集合中存储分页数据和信息数据
		HashMap map = new HashMap<>();
		map.put("pager", pager);
		map.put("list", list);

		return map;
	}

	
	@RequestMapping("/mes/queryOutbox")
	@ResponseBody
	public HashMap queryOutbox(HttpServletRequest request, HttpServletResponse response,
			String mesSendConfirm, Integer pageNum, Integer pageSize, String empLoginName) {

		HttpSession session = request.getSession();

		empLoginName = (String) session.getAttribute("empLoginName");
		Employee emp = empService.queryEmpByLoginName(empLoginName);
		session.setAttribute("empId", emp.getEmpId()); // 记录用户id

		if (pageNum == null) {
			pageNum = 0;
		}

		if (pageSize == null) {
			pageSize = 5;
		}

		Pager pager = new Pager(service.getMesDraftCount("已发", empLoginName), pageSize, pageNum);

		List list = service.queryMesDraft("已发", pager, empLoginName);

		// 在Map集合中存储分页数据和信息数据
		HashMap map = new HashMap<>();
		map.put("pager", pager);
		map.put("list", list);

		return map;
	}

	
	@RequestMapping("/mes/queryInbox")
	@ResponseBody
	public HashMap queryInbox(HttpServletRequest request, HttpServletResponse response, Integer pageNum,
			Integer pageSize, String empLoginName) {

		HttpSession session = request.getSession();

		empLoginName = (String) session.getAttribute("empLoginName");
		Employee emp = empService.queryEmpByLoginName(empLoginName);
		session.setAttribute("empId", emp.getEmpId()); // 记录用户id

		if (pageNum == null) {
			pageNum = 0;
		}

		if (pageSize == null) {
			pageSize = 5;
		}

		Pager pager = new Pager(service.getMesInboxCount(empLoginName), pageSize, pageNum);

		List list = service.queryMesInbox(pager, empLoginName);

		// 在Map集合中存储分页数据和信息数据
		HashMap map = new HashMap<>();
		map.put("pager", pager);
		map.put("list", list);

		return map;
	}

	
	@RequestMapping("/mes/queryUnread")
	@ResponseBody
	public HashMap queryUnread(HttpServletRequest request, HttpServletResponse response,
			String mesSendConfirm, String mesReadConfirm, Integer pageNum, Integer pageSize, String empLoginName) {

		HttpSession session = request.getSession();

		empLoginName = (String) session.getAttribute("empLoginName");
		Employee emp = empService.queryEmpByLoginName(empLoginName);
		session.setAttribute("empId", emp.getEmpId()); // 记录用户id

		if (pageNum == null) {
			pageNum = 0;
		}

		if (pageSize == null) {
			pageSize = 5;
		}

		Pager pager = new Pager(service.getMesUnreadCount("已发", "未读", empLoginName), pageSize, pageNum);

		List list = service.queryMesUnread("已发", "未读", pager, empLoginName);

		// 在Map集合中存储分页数据和信息数据
		HashMap map = new HashMap<>();
		map.put("pager", pager);
		map.put("list", list);

		return map;
	}

	
	@RequestMapping("/mes/queryById")
	@ResponseBody
	public Message queryById(HttpServletRequest request, HttpServletResponse response, Integer mesId) {

		Message mes = service.queryMesById(mesId);

		return mes;
	}

	
	@RequestMapping("mes/queryByIndex")
	@ResponseBody
	public List queryByIndex(HttpServletRequest request, HttpServletResponse response, String queryStr)
			throws ParseException, IOException, InvalidTokenOffsetsException {

		return service.queryMesByIndex(queryStr);
	}

	
	@RequestMapping("mes/deleteMany")
	public void deleteMany(HttpServletRequest request, HttpServletResponse response, Integer[] ids)
			throws ParseException, IOException, InvalidTokenOffsetsException {

		for (int i = 0; i < ids.length; i++) {
			service.deleteMes(ids[i]);
		}

	}

	
	@RequestMapping("mes/addMany")
	public void insertMany(HttpServletRequest request, HttpServletResponse response, Integer[] emp, Message mes) {
		for (int i = 0; i < emp.length; i++) {

			Employee employee = empService.getById(emp[i]);

			mes.setMesReciver(employee);

			service.addMes(mes);
		}
	}

	
	@RequestMapping("mes/getUnreadCount")
	@ResponseBody
	public Integer getUnreadCount(HttpServletRequest request, HttpServletResponse response, Integer count,
			String empLoginName) {

		HttpSession session = request.getSession();

		empLoginName = (String) session.getAttribute("empLoginName");
		Employee emp = empService.queryEmpByLoginName(empLoginName);
		session.setAttribute("empId", emp.getEmpId()); // 记录用户id

		count = service.getMesUnreadCount("已发", "未读", empLoginName);

		return count;

	}

	
	@RequestMapping("mes/getInboxCount")
	@ResponseBody
	public Integer getInboxCount(HttpServletRequest request, HttpServletResponse response, Integer count,
			String empLoginName) {
		HttpSession session = request.getSession();

		empLoginName = (String) session.getAttribute("empLoginName");
		Employee emp = empService.queryEmpByLoginName(empLoginName);
		session.setAttribute("empId", emp.getEmpId()); // 记录用户id

		count = service.getMesInboxCount(empLoginName);

		return count;
	}

	
	@RequestMapping("mes/getOutboxCount")
	@ResponseBody
	public Integer getOutboxCount(HttpServletRequest request, HttpServletResponse response, Integer count,
			String empLoginName) {
		HttpSession session = request.getSession();

		empLoginName = (String) session.getAttribute("empLoginName");
		Employee emp = empService.queryEmpByLoginName(empLoginName);
		session.setAttribute("empId", emp.getEmpId()); // 记录用户id

		count = service.getMesDraftCount("已发", empLoginName);

		return count;
	}

	
	@RequestMapping("mes/getDraftCount")
	@ResponseBody
	public Integer getDraftCount(HttpServletRequest request, HttpServletResponse response, Integer count,
			String empLoginName) {
		HttpSession session = request.getSession();

		empLoginName = (String) session.getAttribute("empLoginName");
		Employee emp = empService.queryEmpByLoginName(empLoginName);
		session.setAttribute("empId", emp.getEmpId()); // 记录用户id

		count = service.getMesDraftCount("未发", empLoginName);

		return count;
	}

	
	@RequestMapping("mes/getCount")
	@ResponseBody
	public Integer getCount(HttpServletRequest request, HttpServletResponse response, Integer count,
			String empLoginName) {
		HttpSession session = request.getSession();

		empLoginName = (String) session.getAttribute("empLoginName");
		Employee emp = empService.queryEmpByLoginName(empLoginName);
		session.setAttribute("empId", emp.getEmpId()); // 记录用户id

		count = service.getMesCountByEmpLoginName(empLoginName, null, null, null, null, null);

		return count;
	}

}

package com.icss.oa.message.service;

import java.io.IOException;
import java.util.Iterator;
import java.util.List;
import org.apache.lucene.analysis.Analyzer;
import org.apache.lucene.analysis.cn.smart.SmartChineseAnalyzer;
import org.apache.lucene.analysis.standard.StandardAnalyzer;
import org.apache.lucene.analysis.util.CharArraySet;
import org.apache.lucene.document.Document;
import org.apache.lucene.document.Field.Store;
import org.apache.lucene.index.Term;
import org.apache.lucene.document.TextField;
import org.apache.lucene.queryparser.classic.MultiFieldQueryParser;
import org.apache.lucene.queryparser.classic.ParseException;
import org.apache.lucene.queryparser.classic.QueryParser;
import org.apache.lucene.search.Query;
import org.apache.lucene.search.highlight.InvalidTokenOffsetsException;
import org.apache.lucene.util.Version;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.icss.oa.common.Pager;
import com.icss.oa.message.dao.MessageMapper;
import com.icss.oa.message.index.MessageIndexDao;
import com.icss.oa.message.pojo.Message;
import com.icss.oa.system.dao.EmployeeMapper;
import com.icss.oa.system.pojo.Employee;


@Service
@Transactional(rollbackFor = Exception.class)
public class MessageService {

	@Autowired
	private MessageMapper mapper;
	
	@Autowired
	private EmployeeMapper empMapper;
	
	@Autowired
	private MessageIndexDao indexDao;

	
	public Message queryMesById(Integer mesId) {
		return mapper.queryById(mesId);
	}

	
	public void addMes(Message mes) {
		mapper.insert(mes);

		// 获得插入员工的自动编号
		int mesId = mapper.getLastInsertId();

		try {
			
			// 创建索引文档
			Document document = new Document();
			document.add(new TextField("mesId", String.valueOf(mesId), Store.YES));
			document.add(new TextField("mesTitle", mes.getMesTitle(), Store.YES));
			document.add(new TextField("mesInfo", mes.getMesInfo(), Store.YES));

			// 调用索引dao
			indexDao.create(document);
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

	
	public void deleteMes(Integer mesId) {
		mapper.delete(mesId);

		// 索引
		try {
			Term term = new Term("mesId", String.valueOf(mesId));
			// 调用索引dao
			indexDao.delete(term);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	
	public void updateMes(Message mes) {
		mapper.update(mes);

		// 索引
		try {
			Term term = new Term("mesId", String.valueOf(mes.getMesId()));

			// 创建索引文档
			Document document = new Document();
			document.add(new TextField("empId", String.valueOf(mes.getMesId()), Store.YES));
			document.add(new TextField("mesTitle", mes.getMesTitle(), Store.YES));
			document.add(new TextField("mesInfo", mes.getMesInfo(), Store.YES));

			// 调用索引dao
			indexDao.update(term, document);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	
	@Transactional(readOnly = true)
	public int getMesCount() {
		return mapper.getCount();
	}

	
	@Transactional(readOnly = true)
	public List queryMesByCondition(Pager pager, String mesSendDate, String empEmail, String mesTitle,
			Integer mesReciver, String mesInfo) {
		return mapper.queryByCondition(pager.getStart(), pager.getPageSize(), mesSendDate, empEmail, mesTitle,
				mesReciver, mesInfo);
	}

	
	@Transactional(readOnly = true)
	public List queryMesByCondition1(Pager pager, String mesSendDate, String empEmail, String mesTitle) {
		return mapper.queryByCondition1(pager.getStart(), pager.getPageSize(), mesSendDate, empEmail, mesTitle);
	}

	
	@Transactional(readOnly = true)
	public Integer getMesCountByCondition(String mesSendDate, String empEmail, String mesTitle, Integer mesReciver,
			String mesInfo) {
		return mapper.getCountByCondition(mesSendDate, empEmail, mesTitle, mesReciver, mesInfo);
	}

	
	@Transactional(readOnly = true)
	public List queryMesByIndex(String queryStr)
			throws IOException, InvalidTokenOffsetsException, ParseException {

		// 设置常见停用词（的，么，啊，着之类的东东）
		String[] self_stop_words = { "的", "着", "啊", "么", "嘛", "是" };
		CharArraySet cas = new CharArraySet(Version.LUCENE_47, 0, true);
		for (int i = 0; i < self_stop_words.length; i++) {
			cas.add(self_stop_words[i]);
		}

		// 加入系统默认停用词
		Iterator