custserviceaction.java

JAVA实现的中小型企业CRM客户关系管理系统

package com.crm.custservice;

import java.io.ByteArrayOutputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.lang.reflect.InvocationTargetException;
import java.util.List;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.commons.beanutils.BeanUtils;
import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.ActionMapping;
import org.apache.struts.upload.FormFile;
import org.springframework.context.ApplicationContext;
import org.springframework.web.struts.DispatchActionSupport;

import com.crm.custinfo.ICustInfoDAO;
import com.crm.custinfo.po.CustInfo;
import com.crm.custservice.po.CustService;
import com.crm.mydict.IMyDictDAO;
import com.crm.user.IUserDAO;
import com.crm.user.po.UserInfo;

public class CustServiceAction extends DispatchActionSupport {
	public ActionForward insert(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) {
		CustServiceForm custServiceForm = (CustServiceForm) form;// TODO
		// Auto-generated
		// method
		// stub
		FormFile file = custServiceForm.getFile_name();
		String filename = file.getFileName();
		ApplicationContext context = this.getWebApplicationContext();
		ICustServiceDAO dao = (ICustServiceDAO) context
				.getBean("custservicedao");
		CustService custService = new CustService();
		custService.setCust_id(custServiceForm.getCust_id());
		custService.setEmployee_id(custServiceForm.getEmployee_id());
		custService.setContent(custServiceForm.getContent());
		custService.setService_type(custServiceForm.getService_type());
		custService.setFile_name(filename);
		dao.addCustService(custService);
		try {
			InputStream stream = file.getInputStream();
			// 把文件读入
			String filePath = this.getServletContext().getRealPath("/upload");
			// 上传到指定的upload包中
			ByteArrayOutputStream baos = new ByteArrayOutputStream();
			OutputStream bos = new FileOutputStream(filePath + "/"
					+ file.getFileName());
			// 建立一个上传文件的输出流
			 System.out.println(filePath+"/"+file.getFileName());
			int bytesRead = 0;
			byte[] buffer = new byte[8192];
			while ((bytesRead = stream.read(buffer, 0, 8192)) != -1) {
				bos.write(buffer, 0, bytesRead);// 将文件写入服务器
			}

			bos.close();
			stream.close();
		} catch (Exception e) {

		}
		String msg = "";
		if("1".equals(custService.getService_type())){
			msg="成功增加客客户服务内容";
		}
		if("2".equals(custService.getService_type())){
			msg="成功增加客户投诉内容";
		}
		try {
			PrintWriter out = response.getWriter();
			out
					.println("<script language='javascript'>alert('"+msg+"!');location.href='"
							+ request.getContextPath()
							+ "/manage/custinfo.do?paramtype=querylist&stype="+custService.getService_type()
							//+ request.getParameter("service_type")
							+ "';</script>");
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return null;
	}

	public ActionForward initinsert(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) {
		CustServiceForm custServiceForm = (CustServiceForm) form;// TODO
		// Auto-generated
		// method
		// stub
		custServiceForm.setParamtype("insert");
		String type = request.getParameter("type");
		if ("serv".equals(type)) {
			custServiceForm.setService_type("1");
		} else if ("fault".equals(type)) {
			custServiceForm.setService_type("0");
		}
		ApplicationContext context = this.getWebApplicationContext();
		ICustServiceDAO dao = (ICustServiceDAO) context
				.getBean("custservicedao");
		ICustInfoDAO custdao = (ICustInfoDAO) context.getBean("custinfodao");
		CustInfo custInfo = custdao.getCustInfo(Integer
				.parseInt(custServiceForm.getId()));
		UserInfo userinfo = (UserInfo) request.getSession()
				.getAttribute("user");
		System.out.println("userinfo.getEmployee_name()="
				+ userinfo.getEmployee_name());

		custServiceForm.setEmployee_id(userinfo.getId());
		custServiceForm.setEmployee_name(userinfo.getEmployee_name());
		custServiceForm.setCust_name(custInfo.getCust_name());
		custServiceForm.setCust_id(custInfo.getId().toString());
		custServiceForm.setTelephone(custInfo.getTelephone());
		CustService custService = new CustService();
		custService.setCust_id(custServiceForm.getId());
		custService.setService_type(custServiceForm.getService_type());
		List list = dao.getCustServList(custService, request);
		request.setAttribute("custservlist", list);
		request.setAttribute("custInfoForm", custInfo);
		addTypeList(request); 

		return mapping.findForward("custservadd");
	}

	public ActionForward custServ(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) {
		CustServiceForm custServiceForm = (CustServiceForm) form;// TODO
		// Auto-generated
		// method
		// stub
		ApplicationContext context = this.getWebApplicationContext();
		ICustServiceDAO dao = (ICustServiceDAO) context
				.getBean("custservicedao");
		ICustInfoDAO custdao = (ICustInfoDAO) context.getBean("custinfodao");
		CustInfo custInfo = custdao.getCustInfo(Integer
				.parseInt(custServiceForm.getId()));
		List servList = dao.getCustServListByEmployId(Integer
				.parseInt(custServiceForm.getId()));
		request.setAttribute("custInfo", custInfo);
		request.setAttribute("servList", servList);
		return mapping.findForward("custservlist");
	}

	public ActionForward list(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) {
		CustServiceForm custServiceForm = (CustServiceForm) form;// TODO
		// Auto-generated
		// method
		// stub
		ApplicationContext context = this.getWebApplicationContext();
		ICustServiceDAO dao = (ICustServiceDAO) context
				.getBean("custservicedao");
		CustService custService = new CustService();
		try {
			BeanUtils.copyProperties(custService, custServiceForm);
		} catch (IllegalAccessException e) {
			e.printStackTrace();
		} catch (InvocationTargetException e) {
			e.printStackTrace();
		}
		UserInfo userinfo = (UserInfo)request.getSession().getAttribute("user");
		
		if("SUPPORT".equals(userinfo.getPost()) ){//客服人员只能看到自己的客户,投诉 客服,短信使用
			custService.setEmployee_id(userinfo.getId());
		}		
		addTypeList(request);
		if("3".equals(custServiceForm.getService_type())){//我的客户投诉
			custService.setService_type("2");
		}
		List list = dao.getCustServList(custService, request);
		request.setAttribute("custservlist", list);
		if("1".equals(custServiceForm.getService_type())){
			return mapping.findForward("custservlist");
		}else{
			return new ActionForward("/manage/custservice/mycustcomplaintlist.jsp");
		}
	}
	public ActionForward detail(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) {
		CustServiceForm custServiceForm = (CustServiceForm) form;// TODO
		ApplicationContext context = this.getWebApplicationContext();
		ICustServiceDAO dao = (ICustServiceDAO) context
				.getBean("custservicedao");
		
		addTypeList(request); 
		ICustInfoDAO custdao = (ICustInfoDAO) context.getBean("custinfodao");
		CustInfo custInfo = custdao.getCustInfo(Integer
				.parseInt(custServiceForm.getId()));
		UserInfo userinfo = (UserInfo) request.getSession()
				.getAttribute("user");
		System.out.println("userinfo.getEmployee_name()="
				+ userinfo.getEmployee_name());

		custServiceForm.setEmployee_id(userinfo.getId());
		custServiceForm.setEmployee_name(userinfo.getEmployee_name());
		custServiceForm.setCust_name(custInfo.getCust_name());
		custServiceForm.setCust_id(custInfo.getId().toString());
		CustService custService = new CustService();
		custService.setCust_id(custServiceForm.getId());
		custService.setService_type(custServiceForm.getService_type());
		List list = dao.getCustServList(custService, request);
		request.setAttribute("custservlist", list);
		request.setAttribute("custInfoForm", custInfo);	
		
		
		CustService custService0 = dao.getCustServById(custServiceForm.getComplaint_id());
		custServiceForm.setComplaint_id(custService0.getComplaint_id());
		custServiceForm.setContent(custService0.getContent());
//		/custServiceForm.set

		
		return mapping.findForward("custservedit");
	}
	//增加
	public ActionForward update(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) {
		CustServiceForm custServiceForm = (CustServiceForm) form;// TODO
		ApplicationContext context = this.getWebApplicationContext();
		ICustServiceDAO dao = (ICustServiceDAO) context 
				.getBean("custservicedao");
		CustService custService = new CustService();
		custService.setCust_id(custServiceForm.getCust_id());
		custService.setEmployee_id(custServiceForm.getEmployee_id());
		custService.setContent(custServiceForm.getServ_content());
		custService.setService_type("1");//添加服务反馈
		//custService.setFile_name(filename);


		
		FormFile file = custServiceForm.getServ_file_name();
		String filename = file.getFileName();

		try {
			InputStream stream = file.getInputStream();
			// 把文件读入
			String filePath = this.getServletContext().getRealPath("/upload");
			// 上传到指定的upload包中
			ByteArrayOutputStream baos = new ByteArrayOutputStream();
			OutputStream bos = new FileOutputStream(filePath + "/"
					+ file.getFileName());
			// 建立一个上传文件的输出流
			 System.out.println(filePath+"/"+file.getFileName());
			int bytesRead = 0;
			byte[] buffer = new byte[8192];
			while ((bytesRead = stream.read(buffer, 0, 8192)) != -1) {
				bos.write(buffer, 0, bytesRead);// 将文件写入服务器
			}

			bos.close();
			stream.close();
			custService.setFile_name(filename);
		} catch (Exception e) {

		}
		CustService cserver = dao.addCustService(custService);
		System.out.println("cserver="+cserver);
		//设置关联ID
		CustService custService_c = new CustService();
		custService_c.setComplaint_id(custServiceForm.getComplaint_id());
		custService_c.setRefid(String.valueOf(cserver.getKeyid()));
		System.out.println("custServiceForm.getComplaint_id()="+custServiceForm.getComplaint_id());
		dao.updateCustServiceRefid(custService_c);
		UserInfo userinfo = (UserInfo)request.getSession().getAttribute("user");
		try {
			PrintWriter out = response.getWriter();
			out
					.println("<script language='javascript'>alert('添加服务反馈成功!');location.href='"
							+ request.getContextPath()
							+ "/manage/custserv.do?paramtype=list&service_type=3&employee_id="+userinfo.getId()
							//+ request.getParameter("service_type")
							+ "';</script>");
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return null;
	}	
	public ActionForward guidancelist(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) {
		CustServiceForm custServiceForm = (CustServiceForm) form;// TODO
		// Auto-generated
		// method
		// stub
		ApplicationContext context = this.getWebApplicationContext();
		ICustServiceDAO dao = (ICustServiceDAO) context
				.getBean("custservicedao");
		CustService custService = new CustService();
		try {
			BeanUtils.copyProperties(custService, custServiceForm);
		} catch (IllegalAccessException e) {
			e.printStackTrace();
		} catch (InvocationTargetException e) {
			e.printStackTrace();
		}
		List list = dao.getCustServList(custService, request);
		request.setAttribute("guidancelist", list);
		return mapping.findForward("guidancelist");
	}
	private void addTypeList(HttpServletRequest request){
		ApplicationContext context = this.getWebApplicationContext();
		IMyDictDAO dictdao = (IMyDictDAO)context.getBean("mydictdao");
		List custlevellist = dictdao.getMyDictTypeList("CUST_LEVEL");//客户级别
		request.setAttribute("custlevellist", custlevellist); 
		List custsourcelist = dictdao.getMyDictTypeList("CUST_SOURCE");//客户级别
		request.setAttribute("custsourcelist", custsourcelist); 
		List custstatelist = dictdao.getMyDictTypeList("CUST_STATE");//会员状态
		request.setAttribute("custstatelist", custstatelist); 
		List custtypelist = dictdao.getMyDictTypeList("CUST_TYPE");//会员类别
		request.setAttribute("custtypelist", custtypelist); 
		List paytypelist = dictdao.getMyDictTypeList("PAY_TYPE");//交款方式
		request.setAttribute("paytypelist", paytypelist); 

		//
		IUserDAO dao = (IUserDAO)context.getBean("userdao");
		//UserDAO dao = new UserDAO();
		UserInfo userinfo = new UserInfo();
		userinfo.setPost("SUPPORT");
		List userlist = dao.getUserList(userinfo,request);
		request.setAttribute("userlist", userlist);

		
	}
	
}