本文主要是介绍项目实训--物流管理项目之客户服务中心模块，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
项目配置
操作系统：WindowsXp
JDK：jdk1.7
数据库：Oracle10g
服务器：Tomcat7.0
编辑器：MyEclipse9
浏览器：Google浏览器
本次项目为JavaWeb开发，主要使用Servlet+JSP技术
下面进行详细模块概述：
客户服务中心：
客户管理
对客户信息进行管理，包括对客户信息的增、删、查、改以及各种条件查询。
客户的详细信息可以查看客户的个人信息以及客户所有订单和退单。
修改客户信息：
新订
包括查询客户信息，根据客户生成新订单，以及同时添加客户、生成订单，假如客户所有商品存货不足，可以生成缺货单，从而进货。新订
订单操作
包括对订单信息的增、删、查、改。
退货
通过客户信息，对客户收到的不满意的商品进行退货
代码部分：
数据底层操作:CustomerServiceCenterDao
package com.neusoft.dao;import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;import com.neusoft.services.support.JdbcSupport;
import com.neusoft.system.db.DBUtils;/*** @author xukai* 处理客户服务中心的数据操作*/
public class CustomerServiceCenterDao extends JdbcSupport{/*** 查询所有客户信息*/public List<Map<Object, Object>> queryAllCustomer() throws SQLException{String sql = "SELECT CUSTOMER_ID,CUSTOMER_NAME,JOB_ADD,TEL,CELLPHONE,IDENTITY_NO FROM CUSTOMER_INFO WHERE CUSTOMER_STATUS='可交易' ";return this.queryToMapList(sql, null);}/*** 通过客户ID，查询客户信息*/public Map<Object,Object> queryMoreCustomer(Object val) throws SQLException{String sql = "SELECT CUSTOMER_ID,CUSTOMER_NAME,IDENTITY_NO,JOB_ADD,TEL,CELLPHONE,ADDRESS," +" POST,MAIL FROM CUSTOMER_INFO WHERE CUSTOMER_ID = ? ";return this.queryToMap(sql, val);}/*** 通过客户ID，查询所有订单信息*/public List<Map<Object, Object>> queryOrderByCustomerId(Object[] val) throws SQLException{String sql = "SELECT O.ORDER_ID,P.PRODUCT_NAME,O.PRODUCT_ACCOUNT,P.PRICE,O.PAY_MONEY,O.ORDER_STATUS" +" FROM ORDER_INFO O,PRODUCT_INFO P" +" WHERE O.PRODUCT_ID=P.PRODUCT_ID" +" AND O.CUSTOMER_ID=? ";return this.queryToMapList(sql, val);}/*** 修改客户信息*/public boolean updateCustomer(Object[] val) throws SQLException{String sql = "UPDATE CUSTOMER_INFO SET " +" CUSTOMER_NAME=?," +" IDENTITY_NO=?," +" JOB_ADD=?," +" TEL=?," +" CELLPHONE=?," +" ADDRESS=?," +" POST=?," +" MAIL=?" +" WHERE CUSTOMER_ID =? ";this.pstmAddVal(sql, val);return executeListPstm();}/*** 删除客户信息，实际是修改客户状态*/public boolean deleteCustomer(Object[] val) throws SQLException{String sql = "UPDATE CUSTOMER_INFO SET " +" CUSTOMER_STATUS='不可交易' " +" WHERE CUSTOMER_ID =? ";this.pstmAddVal(sql, val);return executeListPstm();}/*** 添加客户信息*/public boolean registerCustomer(Object[] val) throws SQLException{String sql = "INSERT INTO CUSTOMER_INFO(CUSTOMER_ID,CUSTOMER_NAME,IDENTITY_NO,JOB_ADD,TEL,CELLPHONE,ADDRESS,POST,MAIL)" +" VALUES(SEQ_CUSTOMER_ID.NEXTVAL,?,?,?,?,?,?,?,?) " ;this.pstmAddVal(sql, val);return executeListPstm();}/*** 中心库房商品存量*/public List<Map<Object,Object>> queryAccount() throws SQLException{String sql = "SELECT P.PRODUCT_ID,P.PRODUCT_NAME,C.PRODUCT_EXIT,T1.BACK_ACCOUNT,T2.PRODUCT_ACCOUNT" +" FROM (SELECT P.PRODUCT_ID PRODUCT_ID,NVL(A.BACK_ACCOUNT,0) BACK_ACCOUNT" +" FROM PRODUCT_INFO P LEFT JOIN (SELECT B.PRODUCT_ID,SUM(B.BACK_ACCOUNT) BACK_ACCOUNT FROM BACK_INFO B WHERE B.BACK_STATUS='退货完成' GROUP BY B.PRODUCT_ID) A " +" ON P.PRODUCT_ID=A.PRODUCT_ID) T1, " +" (SELECT P.PRODUCT_ID PRODUCT_ID,NVL(B.PRODUCT_ACCOUNT,0) PRODUCT_ACCOUNT " +" FROM PRODUCT_INFO P LEFT JOIN" +" (SELECT PRODUCT_ID,SUM(PRODUCT_ACCOUNT) PRODUCT_ACCOUNT FROM ORDER_INFO O,MISSION_INFO M" +" WHERE ORDER_TYPE='新订' " +" AND ORDER_STATUS = '已分配'" +" AND M.MISSION_STATUS = '未分配'" +" AND M.ORDER_ID=O.ORDER_ID" +" GROUP BY PRODUCT_ID) B" +" ON P.PRODUCT_ID=B.PRODUCT_ID) T2,CTRM_INFO C,PRODUCT_INFO P" +" WHERE T1.PRODUCT_ID=T2.PRODUCT_ID" +" AND P.PRODUCT_ID = T1.PRODUCT_ID" +" AND C.PRODUCT_ID=P.PRODUCT_ID " +" AND C.PRODUCT_STATUS='可用'";return this.queryToMapList(sql, null);}/*** AJax所需数据*/public Map<Object,Object> findPrductInfo(Object val) throws SQLException{String sql = "SELECT PRODUCT_ID,UNIT,PRICE FROM PRODUCT_INFO WHERE PRODUCT_NAME = ? ";return this.queryToMap(sql, val);}/*** 新建订单*/public boolean addOrder(Object[] val) throws SQLException{String sql = "INSERT INTO ORDER_INFO(ORDER_ID,ORDER_TYPE,ORDER_STATUS,PRODUCT_ID,PRODUCT_ACCOUNT,PAY_MONEY,CUSTOMER_ID,START_DATE,DEADLINE)" +" VALUES(SEQ_ORDER_ID.NEXTVAL,'新订',?,?,?,?,?,?,?)";this.pstmAddVal(sql, val);return this.executeListPstm();}/*** 新建用户和订单*/public boolean AddCustomerAndOrder(Object[] obj1,Object[] obj2) throws SQLException{String sql1 = "INSERT INTO CUSTOMER_INFO(CUSTOMER_ID,CUSTOMER_NAME,IDENTITY_NO,JOB_ADD,TEL,CELLPHONE,ADDRESS,POST,MAIL)" +" VALUES(SEQ_CUSTOMER_ID.NEXTVAL,?,?,?,?,?,?,?,?) " ;String sql2 = "INSERT INTO ORDER_INFO(ORDER_ID,ORDER_TYPE,ORDER_STATUS,PRODUCT_ID,PRODUCT_ACCOUNT,PAY_MONEY,CUSTOMER_ID,START_DATE,DEADLINE)" +" VALUES(SEQ_ORDER_ID.NEXTVAL,'新订',?,?,?,?,SEQ_CUSTOMER_ID.CURRVAL,?,?) ";this.pstmAddVal(sql1, obj1);this.pstmAddVal(sql2, obj2);return executeListPstm();}/*** 查询所有订单信息*/public List<Map<Object, Object>> queryAllOrder() throws SQLException{String sql = "SELECT O.ORDER_ID,O.CUSTOMER_ID,C.CUSTOMER_NAME,C.CELLPHONE,P.PRODUCT_NAME,O.PRODUCT_ACCOUNT," +" O.ORDER_TYPE,O.ORDER_STATUS" +" FROM ORDER_INFO O,CUSTOMER_INFO C,PRODUCT_INFO P" +" WHERE O.PRODUCT_ID=P.PRODUCT_ID" +" AND O.CUSTOMER_ID=C.CUSTOMER_ID" +" AND O.ORDER_TYPE = '新订'";return this.queryToMapList(sql, null);}/*** 查询订单详细信息*/public Map<Object,Object> queryMoreOrder(Object val) throws SQLException{String sql = "SELECT O.ORDER_ID,O.ORDER_TYPE,O.ORDER_STATUS,P.PRODUCT_NAME,P.PRODUCT_ID,O.PRODUCT_ACCOUNT,P.UNIT,P.PRICE," +" O.PAY_MONEY,C.CUSTOMER_NAME,C.CELLPHONE,C.POST,C.ADDRESS,O.START_DATE,O.DEADLINE" +" FROM ORDER_INFO O,PRODUCT_INFO P,CUSTOMER_INFO C" +" WHERE O.PRODUCT_ID=P.PRODUCT_ID" +" AND O.CUSTOMER_ID=C.CUSTOMER_ID" +" AND ORDER_ID = ? ";return this.queryToMap(sql, val);}/*** 更新订单信息*/public boolean updateOrder(Object[] val) throws SQLException{String sql = "UPDATE ORDER_INFO SET " +" ORDER_STATUS=?," +" PRODUCT_ID=?," +" PRODUCT_ACCOUNT=?," +" PAY_MONEY=?," +" START_DATE=?," +" DEADLINE=?" +" WHERE ORDER_ID = ? ";this.pstmAddVal(sql, val);return this.executeListPstm();}/*** 退订*/public int cancelOrder(Object val) throws SQLException{int i = 0;String sql = "UPDATE ORDER_INFO" +" SET ORDER_STATUS = '未分配'," +" ORDER_TYPE= '退订'" +" WHERE (ORDER_STATUS = '可分配'" +" OR ORDER_STATUS = '未分配'" +" OR ORDER_STATUS = '待分配')" +" AND ORDER_ID = ? ";PreparedStatement pstm = DBUtils.preparedStatment(sql);pstm.setObject(1, val);i = pstm.executeUpdate();DBUtils.close(pstm);return i;}/*** 生成缺货单* 1.缺货单 插入 数据* 2.购货单 插入 数据*/public boolean addShortsInfo(List<Object[]> listShort) throws SQLException{String sql1 = "INSERT INTO SHORT_INFO(SHORT_ID,PRODUCT_ID,SHORT_ACCOUNT,SHORT_DATE)" +" VALUES(SEQ_SHORT_ID.NEXTVAL,?,?,?) ";for(Object[] obj : listShort){this.pstmAddVal(sql1, obj);}return this.executeListPstm();}/*** 多条件查询客户信息，*/public Map<Object,Object> findCustomerByOthers(String customerId,String identityNo) throws SQLException{StringBuilder sql = new StringBuilder("SELECT CUSTOMER_ID,CUSTOMER_NAME,IDENTITY_NO," +" JOB_ADD,TEL,CELLPHONE,ADDRESS,POST,MAIL" +" FROM CUSTOMER_INFO" +" WHERE 1 = 1 ");List<String> list = new ArrayList<String>();if(this.checkVal(customerId)){sql.append(" AND CUSTOMER_ID = ? ");list.add(customerId);}if(this.checkVal(identityNo)){sql.append(" AND IDENTITY_NO = ? ");list.add(identityNo);}PreparedStatement pstm = DBUtils.preparedStatment(sql.toString());Map<Object, Object> ins = null;ResultSet rs = null;try {for (int i = 0; i < list.toArray().length; i++) {pstm.setObject(i + 1, list.toArray()[i]);}rs = pstm.executeQuery();/*** 如果没有查询到结果，返回null*/if(rs.next()){ins = new HashMap<Object, Object>();ResultSetMetaData rsmd = rs.getMetaData();for (int i = 1; i <= rsmd.getColumnCount(); i++) {ins.put(rsmd.getColumnLabel(i), rs.getObject(i));}}} finally {DBUtils.close(rs);DBUtils.close(pstm);}return ins;}/*** 通过客户ID，查询该客户所有订单*/public List<Map<Object,Object>> findOrderByCustomerId(Object[] val) throws SQLException{String sql = "SELECT O.ORDER_ID,P.PRODUCT_NAME,O.PRODUCT_ACCOUNT,P.PRICE,O.PAY_MONEY,O.ORDER_STATUS" +" FROM ORDER_INFO O,PRODUCT_INFO P,ASSIGN_INFO A" +" WHERE O.PRODUCT_ID=P.PRODUCT_ID" +" AND A.ORDER_ID=O.ORDER_ID" +" AND P.CAN_RETURN='可以'" +" AND A.ASSIGN_STATUS='已签收'" +" AND O.CUSTOMER_ID = ? " +" AND O.ORDER_STATUS = '签收未付' ";return this.queryToMapList(sql, val);}/*** 查询要退货的订单信息*/public Map<Object,Object> returnProduct(Object val) throws SQLException{String sql = "SELECT O.ORDER_ID,O.ORDER_STATUS,P.PRODUCT_NAME,P.PRODUCT_ID,O.PRODUCT_ACCOUNT,P.UNIT,P.PRICE," +" O.PAY_MONEY,C.CUSTOMER_NAME,C.CELLPHONE,C.POST,C.ADDRESS,O.START_DATE,O.DEADLINE,M.WAREHOUSE_ID," +" M.CUSTOMER_ID,M.SUBSTATION_NAME,M.TAKEOUT_NAME" +" FROM ORDER_INFO O,PRODUCT_INFO P,CUSTOMER_INFO C,MISSION_INFO M" +" WHERE O.PRODUCT_ID=P.PRODUCT_ID" +" AND O.CUSTOMER_ID=C.CUSTOMER_ID" +" AND O.ORDER_ID=M.ORDER_ID" +" AND O.ORDER_ID = ? ";return this.queryToMap(sql, val);}/*** 生成退货单* 1.订单表 修改订单状态：退货中 订单类型：退货* 2.退货单 插入数据* 3.任务单 插入数据*/public boolean addReturnProductInfo(Object[] obj1,Object[] obj2,Object[] obj3) throws SQLException{String sql1 = "UPDATE ORDER_INFO SET " +" ORDER_TYPE = '退货'," +" ORDER_STATUS = '退货中'," +" RETURN_REASON = ?, " +" START_DATE = ?," +" DEADLINE = ? " +" WHERE ORDER_ID = ? ";String sql2 = "INSERT INTO BACK_INFO(BACK_ID,WAREHOUSE_ID,PRODUCT_ID,BACK_ACCOUNT,BACK_DATE,BACK_STATUS,ORDER_ID)" +" VALUES(SEQ_BACK_ID.NEXTVAL,?,?,?,TO_CHAR(SYSDATE,'YYYY-MM-DD'),'退货中',?) ";String sql3 = "INSERT INTO MISSION_INFO(MISSION_ID,ORDER_ID,CUSTOMER_ID,WAREHOUSE_ID,SUBSTATION_NAME,TAKEOUT_NAME," +" TAKEOUT_DATE,MISSION_STATUS,MISSION_DATE,MISSION_TYPE) " +" VALUES(SEQ_MISSION_ID.NEXTVAL,?,?,?,?,?,TO_CHAR(SYSDATE,'YYYY-MM-SS'),'未完成',TO_CHAR(SYSDATE,'YYYY-MM-DD'),'退货')";this.pstmAddVal(sql1, obj1);this.pstmAddVal(sql2, obj2);this.pstmAddVal(sql3, obj3);return this.executeListPstm();}/*** 通过商品信息，生成缺货单*/public List<Map<Object,Object>> queryProductForShort(List<String> list) throws SQLException{List<Map<Object,Object>> listMap = new ArrayList<Map<Object,Object>>();StringBuilder sql = new StringBuilder("SELECT P.PRODUCT_ID,P.PRODUCT_NAME,C.PRODUCT_EXIT,T1.BACK_ACCOUNT,T2.PRODUCT_ACCOUNT" +" FROM (SELECT P.PRODUCT_ID PRODUCT_ID,NVL(A.BACK_ACCOUNT,0) BACK_ACCOUNT" +" FROM PRODUCT_INFO P LEFT JOIN (SELECT B.PRODUCT_ID,SUM(B.BACK_ACCOUNT) BACK_ACCOUNT FROM BACK_INFO B WHERE B.BACK_STATUS='退货完成' GROUP BY B.PRODUCT_ID) A " +" ON P.PRODUCT_ID=A.PRODUCT_ID) T1, " +" (SELECT P.PRODUCT_ID PRODUCT_ID,NVL(B.PRODUCT_ACCOUNT,0) PRODUCT_ACCOUNT " +" FROM PRODUCT_INFO P LEFT JOIN" +" (SELECT PRODUCT_ID,SUM(PRODUCT_ACCOUNT) PRODUCT_ACCOUNT FROM ORDER_INFO O,MISSION_INFO M" +" WHERE ORDER_TYPE='新订' " +" AND ORDER_STATUS = '已分配'" +" AND M.MISSION_STATUS = '未分配'" +" AND M.ORDER_ID=O.ORDER_ID" +" GROUP BY PRODUCT_ID) B" +" ON P.PRODUCT_ID=B.PRODUCT_ID) T2,CTRM_INFO C,PRODUCT_INFO P" +" WHERE T1.PRODUCT_ID=T2.PRODUCT_ID" +" AND P.PRODUCT_ID = T1.PRODUCT_ID" +" AND C.PRODUCT_ID=P.PRODUCT_ID " +" AND C.PRODUCT_STATUS='可用' " +" AND P.PRODUCT_ID = ? ");for(String str : list){Map<Object,Object> map = new HashMap<Object, Object>();map = this.queryToMap(sql.toString(), str);listMap.add(map);}return listMap;}/****************************************************************** 以下为条件可变查询*****************************************************************//*** 查询满足条件的客户信息*/public List<Map<Object,Object>> queryCustomersByOthers(String identityNo,String customerName,String cellphone) throws SQLException{StringBuilder sql = new StringBuilder("SELECT CUSTOMER_ID,CUSTOMER_NAME,JOB_ADD,TEL,CELLPHONE,IDENTITY_NO FROM CUSTOMER_INFO WHERE CUSTOMER_STATUS='可交易' ");List<String> list = new ArrayList<String>();if(this.checkVal(identityNo)){sql.append(" AND IDENTITY_NO = ? ");list.add(identityNo);}if(this.checkVal(customerName)){sql.append(" AND CUSTOMER_NAME LIKE ? ");list.add("%" + customerName + "%");}if(this.checkVal(cellphone)){sql.append(" AND CELLPHONE = ? ");list.add(cellphone);}
// System.out.println("SQL : " + sql.toString());return this.queryToMapList(sql.toString(), list.toArray());}/*** 查询满足条件的订单信息*/public List<Map<Object,Object>> queryOrdersByOthers(String startDate,String deadline,String orderStatus,String customerName,String cellphone,String orderType) throws SQLException{StringBuilder sql = new StringBuilder("SELECT O.ORDER_ID,O.CUSTOMER_ID,C.CUSTOMER_NAME,C.CELLPHONE,P.PRODUCT_NAME,O.PRODUCT_ACCOUNT," +" O.ORDER_TYPE,O.ORDER_STATUS" +" FROM ORDER_INFO O,CUSTOMER_INFO C,PRODUCT_INFO P" +" WHERE O.PRODUCT_ID=P.PRODUCT_ID" +" AND O.CUSTOMER_ID=C.CUSTOMER_ID ");List<String> list = new ArrayList<String>();if(this.checkVal(startDate)){sql.append(" AND START_DATE = ? ");list.add(startDate);}if(this.checkVal(deadline)){sql.append(" AND DEADLINE = ? ");list.add(deadline);}if(this.checkVal(orderStatus)){sql.append(" AND ORDER_STATUS = ? ");list.add(orderStatus);}if(this.checkVal(customerName)){sql.append(" AND CUSTOMER_NAME LIKE ? ");list.add("%" + customerName + "%");}if(this.checkVal(cellphone)){sql.append(" AND CELLPHONE = ? ");list.add(cellphone);}if(this.checkVal(orderType)){sql.append(" AND ORDER_TYPE = ? ");list.add(orderType);}return this.queryToMapList(sql.toString(), list.toArray());}/*** 通过商品名称查询库房中的库存量*/public List<Map<Object,Object>> queryAccountByProductName(String productName) throws SQLException{StringBuilder sql = new StringBuilder("SELECT P.PRODUCT_NAME,C.PRODUCT_EXIT,T1.BACK_ACCOUNT,T2.PRODUCT_ACCOUNT" +" FROM (SELECT P.PRODUCT_ID PRODUCT_ID,NVL(A.BACK_ACCOUNT,0) BACK_ACCOUNT" +" FROM PRODUCT_INFO P LEFT JOIN (SELECT B.PRODUCT_ID,SUM(B.BACK_ACCOUNT) BACK_ACCOUNT FROM BACK_INFO B WHERE B.BACK_STATUS='退货完成' GROUP BY B.PRODUCT_ID) A " +" ON P.PRODUCT_ID=A.PRODUCT_ID) T1, " +" (SELECT P.PRODUCT_ID PRODUCT_ID,NVL(B.PRODUCT_ACCOUNT,0) PRODUCT_ACCOUNT " +" FROM PRODUCT_INFO P LEFT JOIN" +" (SELECT PRODUCT_ID,SUM(PRODUCT_ACCOUNT) PRODUCT_ACCOUNT FROM ORDER_INFO O,MISSION_INFO M" +" WHERE ORDER_TYPE='新订' " +" AND ORDER_STATUS = '已分配'" +" AND M.MISSION_STATUS = '未分配'" +" AND M.ORDER_ID=O.ORDER_ID" +" GROUP BY PRODUCT_ID) B" +" ON P.PRODUCT_ID=B.PRODUCT_ID) T2,CTRM_INFO C,PRODUCT_INFO P" +" WHERE T1.PRODUCT_ID=T2.PRODUCT_ID" +" AND P.PRODUCT_ID = T1.PRODUCT_ID" +" AND C.PRODUCT_ID=P.PRODUCT_ID " +" AND C.PRODUCT_STATUS='可用'");List<String> list = new ArrayList<String>();;if(this.checkVal(productName)){sql.append(" AND P.PRODUCT_NAME LIKE ? ");list.add("%"+productName+"%");}return this.queryToMapList(sql.toString(), list.toArray());}/*************************************************************************** 以下为分页有关**************************************************************************//*** 数据总数*/public int getAllCount() throws SQLException {String sql = "SELECT count(CUSTOMER_ID) COUNT" +" FROM CUSTOMER_INFO" +" WHERE CUSTOMER_STATUS='可交易'";PreparedStatement pstm = DBUtils.preparedStatment(sql);ResultSet rs = pstm.executeQuery();rs.next();return rs.getInt(1);}/*** 条件查询 数据总数*/public int queryCustomersByOthersCount(String identityNo,String customerName,String cellphone) throws SQLException {List<Map<Object,Object>> list = this.queryCustomersByOthers(identityNo, customerName, cellphone);return list==null ? 0 : list.size();}public List<Map<Object, Object>> queryAllCustomerPage(int start_Page,int end_Page) throws SQLException {Object [] val = {start_Page,end_Page};String sql = "SELECT T.* FROM " +" (SELECT CUSTOMER_ID,CUSTOMER_NAME,JOB_ADD,TEL,CELLPHONE,IDENTITY_NO,ROWNUM MYNUM" +" FROM CUSTOMER_INFO WHERE CUSTOMER_STATUS='可交易' AND ROWNUM <= ?) T " +" WHERE T.MYNUM>=? ";return this.queryToMapList(sql, val);}/*** 查询满足条件的客户信息* 分页处理*/public List<Map<Object,Object>> queryCustomersByOthers(String identityNo,String customerName,String cellphone,int start_Page,int end_Page) throws SQLException{StringBuilder sql = new StringBuilder("SELECT T.* FROM " +" (SELECT CUSTOMER_ID,CUSTOMER_NAME,JOB_ADD,TEL,CELLPHONE,IDENTITY_NO,ROWNUM MYNUM" +" FROM CUSTOMER_INFO WHERE CUSTOMER_STATUS='可交易'" );List<String> list = new ArrayList<String>();if(this.checkVal(identityNo)){sql.append(" AND IDENTITY_NO = ? ");list.add(identityNo);}if(this.checkVal(customerName)){sql.append(" AND CUSTOMER_NAME LIKE ? ");list.add("%" + customerName + "%");}if(this.checkVal(cellphone)){sql.append(" AND CELLPHONE = ? ");list.add(cellphone);}sql.append(" AND ROWNUM <= ?) T " +" WHERE T.MYNUM>=? ");list.add(end_Page+"");list.add(start_Page+"");return this.queryToMapList(sql.toString(), list.toArray());}}
CustomerServiceCenterServlet :
package com.neusoft.servlet;import java.io.IOException;
import java.io.PrintWriter;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import javax.swing.text.DefaultEditorKit.CutAction;import com.neusoft.dao.CustomerServiceCenterDao;
import com.neusoft.model.CustomerInfo;
import com.neusoft.service.CustomerServiceCenterService;
import com.neusoft.system.db.DBUtils;public class CustomerServiceCenterServlet extends HttpServlet {public void doGet(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {System.out.println("...CustomerServiceCenterServlet....doGet.....");this.doPost(request, response);}public void doPost(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {System.out.println("...CustomerServiceCenterServlet....doPost.....");String method = request.getParameter("method");if("queryAllCustomer".equals(method)){this.queryAllCustomer(request, response);}else if("queryMoreCustomer".equals(method)){this.queryMoreCustomer(request, response);}else if("queryForUpdate".equals(method)){this.queryForUpdate(request,response);}else if("updateCustomer".equals(method)){this.updateCustomer(request,response);}else if("deleteCustomer".equals(method)){this.deleteCustomer(request,response);}else if("registerCustomer".equals(method)){this.registerCustomer(request,response);}else if("queryCustomerForOrder".equals(method)){this.queryCustomerForOrder(request,response);}else if("queryAccountAndAddOrder".equals(method)){this.queryAccountAndAddOrder(request,response);}else if("findPrductInfo".equals(method)){this.findPrductInfo(request,response);}else if("orderAdd".equals(method)){this.orderAdd(request,response);}else if("AddCustomerAndOrder".equals(method)){this.AddCustomerAndOrder(request,response);}else if("queryAllOrder".equals(method)){this.queryAllOrder(request,response);}else if("queryMoreOrder".equals(method)){this.queryMoreOrder(request,response);}else if("queryMoreOrderUpdate".equals(method)){this.queryMoreOrderUpdate(request,response);}else if("updateOrder".equals(method)){this.updateOrder(request,response);}else if("cancelOrder".equals(method)){this.cancelOrder(request,response);}else if("findCustomerByOthers".equals(method)){this.findCustomerByOthers(request,response);}else if("returnProduct".equals(method)){this.returnProduct(request,response);}else if("addReturnProductInfo".equals(method)){this.addReturnProductInfo(request,response);}else if("queryCustomersByOthers".equals(method)){this.queryCustomersByOthers(request,response);}else if("queryCustomersByOthersTwo".equals(method)){this.queryCustomersByOthersTwo(request,response);}else if("queryOrdersByOthers".equals(method)){this.queryOrdersByOthers(request,response);}else if("queryAccountByProductName".equals(method)){this.queryAccountByProductName(request,response);}else if("queryProductForShort".equals(method)){this.queryProductForShort(request,response);}else if("addShortsInfo".equals(method)){this.addShortsInfo(request,response);}}private void addShortsInfo(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {Object [] productId = request.getParameterValues("productId");Object [] shortAccount = request.getParameterValues("shortAccount");Object [] shortDate = request.getParameterValues("shortDate");List<Object[]> shortInfo = new ArrayList<Object[]>();for(int i = 0; i < productId.length; i++){Object[] obj = {productId[i],shortAccount[i],shortDate[i]};shortInfo.add(obj);}CustomerServiceCenterService service = new CustomerServiceCenterService();boolean tag = false;tag = service.addShortsInfo(shortInfo);String msg = "生成缺货单成功";if(!tag){msg = "生成缺货单失败";}request.setAttribute("msg", msg);this.queryCustomerForOrder(request, response);}private void queryProductForShort(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {String [] productId = request.getParameterValues("productId");List<String> listId = new ArrayList<String>();for(String str : productId){listId.add(str);}//通过商品ID查询商品信息List<Map<Object, Object>> list = new ArrayList<Map<Object, Object>>();CustomerServiceCenterService service = new CustomerServiceCenterService();list = service.queryProductForShort(listId);request.setAttribute("list", list);request.getRequestDispatcher("../guest/short_info_add.jsp").forward(request, response);}private void queryAccountByProductName(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {Object customerId = request.getParameter("customerIdForQuery");String productName = request.getParameter("productName");CustomerServiceCenterService service = new CustomerServiceCenterService();//查询客户信息Map<Object,Object> map = new HashMap<Object, Object>();map = service.queryMoreCustomer(customerId);//查询中心库房中商品的库存量List<Map<Object , Object >> list = new ArrayList<Map<Object,Object>>();list = service.queryAccountByProductName(productName);DBUtils.close();request.setAttribute("id", customerId);request.setAttribute("m", map);request.setAttribute("list", list);request.getRequestDispatcher("../guest/order_add_customer.jsp").forward(request, response);}private void queryOrdersByOthers(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {String startDate = request.getParameter("startDate");String deadline = request.getParameter("deadline");String orderStatus = request.getParameter("orderStatus");String customerName = request.getParameter("customerName");String cellphone = request.getParameter("cellphone");String orderType = request.getParameter("orderType");List<Map<Object , Object >> list = new ArrayList<Map<Object,Object>>();CustomerServiceCenterService service = new CustomerServiceCenterService();list = service.queryOrdersByOthers(startDate,deadline,orderStatus,customerName,cellphone,orderType);DBUtils.close();request.setAttribute("list", list);request.setAttribute("startDate", startDate);request.setAttribute("deadline", deadline);request.setAttribute("orderStatus", orderStatus);request.setAttribute("customerName", customerName);request.setAttribute("cellphone", cellphone);request.setAttribute("orderType", orderType);request.getRequestDispatcher("../guest/query_order.jsp").forward(request, response);}private void queryCustomersByOthersTwo(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {String identityNo = request.getParameter("identityNo");String customerName = request.getParameter("customerName");String cellphone = request.getParameter("cellphone");List<Map<Object , Object >> list = new ArrayList<Map<Object,Object>>();CustomerServiceCenterService service = new CustomerServiceCenterService();list = service.queryCustomersByOthers(identityNo,customerName,cellphone,1);DBUtils.close();request.setAttribute("list", list);request.setAttribute("identityNo", identityNo);request.setAttribute("customerName", customerName);request.setAttribute("cellphone", cellphone);request.getRequestDispatcher("../guest/new_order.jsp").forward(request, response);}private void queryCustomersByOthers(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {int currentPage = 0;if("".equals(request.getParameter("inputPage")+"")||request.getParameter("inputPage")==null){currentPage = 1;}else{currentPage = Integer.parseInt(request.getParameter("inputPage")+"");}String identityNo = request.getParameter("identityNo");String customerName = request.getParameter("customerName");HttpSession session = request.getSession();if(customerName!=null){session.setAttribute("customerName", customerName);}customerName = session.getAttribute("customerName") + "";System.out.println("customerName " + customerName);String cellphone = request.getParameter("cellphone");List<Map<Object , Object >> list = new ArrayList<Map<Object,Object>>();CustomerServiceCenterService service = new CustomerServiceCenterService();list = service.queryCustomersByOthers(identityNo,customerName,cellphone,currentPage);DBUtils.close();request.setAttribute("Page", service.getPage());request.setAttribute("mycheck", "others");request.setAttribute("list", list);request.setAttribute("identityNo", identityNo);request.setAttribute("customerName", customerName);request.setAttribute("cellphone", cellphone);request.getRequestDispatcher("../guest/customer_list.jsp").forward(request, response);}private void addReturnProductInfo(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {String orderId = request.getParameter("orderId");String returnReason = request.getParameter("returnReason");String startDate = request.getParameter("startDate");String deadline = request.getParameter("deadline");String warehouseId = request.getParameter("warehouseId");String productId = request.getParameter("productId");String backAccount = request.getParameter("productAccount");// mission_id,order_id,customer_id,warehouse_id,substation_name,takeout_name,takeout_date
// ,mission_status,mission_date,mission_typeString customerId = request.getParameter("customerId");String substationName = request.getParameter("substationName");String takeoutName = request.getParameter("takeoutName");Object[] val1 = {returnReason,startDate,deadline,orderId};Object[] val2 = {warehouseId,productId,backAccount,orderId};Object[] val3 = {orderId,customerId,warehouseId,substationName,takeoutName};String msg = "生成退货单成功";boolean tag = false;CustomerServiceCenterService service = new CustomerServiceCenterService();tag = service.addReturnProductInfo(val1,val2,val3);DBUtils.close();if(!tag){msg = "生成退货单成功失败";}request.setAttribute("msg", msg);request.getRequestDispatcher("../guest/return_product.jsp").forward(request, response);}private void returnProduct(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {String orderId = request.getParameter("orderId");Map<Object,Object> map = new HashMap<Object,Object>();CustomerServiceCenterService service = new CustomerServiceCenterService();map = service.returnProduct(orderId);DBUtils.close();request.setAttribute("m", map);request.getRequestDispatcher("../guest/return_product_info.jsp").forward(request, response);}private void findCustomerByOthers(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {String customerId = request.getParameter("customerId");String identityNo = request.getParameter("identityNo");Map<Object,Object> map = new HashMap<Object,Object>();List<Map<Object,Object>> list = new ArrayList<Map<Object,Object>>();CustomerServiceCenterService service = new CustomerServiceCenterService();map = service.findCustomerByOthers(customerId, identityNo);DBUtils.close();request.setAttribute("m", map);if(map==null){String msg = "无满足此条件客户";request.setAttribute("msg", msg);}else{Object[] val = {map.get("CUSTOMER_ID")};list = service.findOrderByCustomerId(val);if(list.size()==0){String msg = "该客户无可退单";request.setAttribute("msg", msg);}request.setAttribute("listBack", list);}request.setAttribute("customerId", customerId);request.setAttribute("identityNo", identityNo);request.getRequestDispatcher("../guest/return_product.jsp").forward(request, response);}private void cancelOrder(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {Object orderId = request.getParameter("orderId");String msg = "退订成功";CustomerServiceCenterService service = new CustomerServiceCenterService();int i = service.cancelOrder(orderId);DBUtils.close();if(i==0){msg = "退订失败,该订单已发货";}request.setAttribute("msg", msg);this.queryAllOrder(request, response);}private void updateOrder(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {String orderId = request.getParameter("orderId");String orderStatus = request.getParameter("orderStatus");String productId = request.getParameter("productId");String productAccount = request.getParameter("productAccount");String payMoney = request.getParameter("payMoney");String startDate = request.getParameter("startDate");String deadline = request.getParameter("deadline");Object [] val = {orderStatus,productId,productAccount,payMoney,startDate,deadline,orderId};boolean tag = false;String msg = "订单修改成功";CustomerServiceCenterService service = new CustomerServiceCenterService();tag = service.updateOrder(val);DBUtils.close();if(!tag){msg = "订单修改失败";}request.setAttribute("msg", msg);this.queryAllOrder(request, response);}private void queryMoreOrderUpdate(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {Object orderId = request.getParameter("orderId");CustomerServiceCenterService service = new CustomerServiceCenterService();Map<Object,Object> map = new HashMap<Object, Object>();map = service.queryMoreOrder(orderId);DBUtils.close();request.setAttribute("m", map);request.getRequestDispatcher("../guest/order_info_update.jsp").forward(request, response);}private void queryMoreOrder(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {Object orderId = request.getParameter("orderId");CustomerServiceCenterService service = new CustomerServiceCenterService();Map<Object,Object> map = new HashMap<Object, Object>();map = service.queryMoreOrder(orderId);DBUtils.close();request.setAttribute("m", map);request.getRequestDispatcher("../guest/order_info.jsp").forward(request, response);}private void queryAllOrder(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {CustomerServiceCenterService service = new CustomerServiceCenterService();List<Map<Object, Object>> list = new ArrayList<Map<Object, Object>>();list = service.queryAllOrder();DBUtils.close();request.setAttribute("list", list);request.getRequestDispatcher("../guest/query_order.jsp").forward(request, response);}private void AddCustomerAndOrder(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {String customerName = request.getParameter("customerName");String identityNo = request.getParameter("identityNo");String jobAdd = request.getParameter("jobAdd");String tel = request.getParameter("tel");String cellphone = request.getParameter("cellphone");String address = request.getParameter("address");String post = request.getParameter("post");String mail = request.getParameter("mail");Object[] obj1 = {customerName,identityNo,jobAdd,tel,cellphone,address,post,mail};String orderStatus = request.getParameter("orderStatus");String productId = request.getParameter("productId");String productAccount = request.getParameter("productAccount");String payMoney = request.getParameter("payMoney");String startDate = request.getParameter("startDate");String deadline = request.getParameter("deadline");Object[] obj2 = {orderStatus,productId,productAccount,payMoney,startDate,deadline};CustomerServiceCenterService service = new CustomerServiceCenterService();String msg = "操作成功";boolean tag = service.AddCustomerAndOrder(obj1, obj2);if(!tag){msg = "操作失败";}DBUtils.close();request.setAttribute("msg", msg);this.queryCustomerForOrder(request, response);}private void orderAdd(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {String orderStatus = request.getParameter("orderStatus");String productId = request.getParameter("productId");String productAccount = request.getParameter("productAccount");String payMoney = request.getParameter("payMoney");String customerId = request.getParameter("customerId");String startDate = request.getParameter("startDate");String deadline = request.getParameter("deadline");Object[] val = {orderStatus,productId,productAccount,payMoney,customerId,startDate,deadline};String msg = "新建订单成功";boolean tag = false;CustomerServiceCenterService service = new CustomerServiceCenterService();tag = service.addOrder(val);DBUtils.close();if(!tag){msg = "新建订单失败";}request.setAttribute("msg", msg);this.queryCustomerForOrder(request, response);}private void findPrductInfo(HttpServletRequest request,HttpServletResponse response) throws IOException {String productName =new String (request.getParameter("productName").getBytes("ISO-8859-1"),"UTF-8");CustomerServiceCenterService service = new CustomerServiceCenterService();Map<Object,Object> map = new HashMap<Object, Object>();map = service.findPrductInfo(productName);DBUtils.close();response.setContentType("text/xml");response.setCharacterEncoding("UTF-8");PrintWriter out = response.getWriter();out.println("<message>");out.println("<unit>"+map.get("UNIT")+"</unit>");out.println("<price>"+map.get("PRICE")+"</price>");out.println("<productid>"+map.get("PRODUCT_ID")+"</productid>");out.println("</message>");out.close();}private void queryAccountAndAddOrder(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {Object customerId = request.getParameter("customerId");CustomerServiceCenterService service = new CustomerServiceCenterService();//查询客户信息Map<Object,Object> map = new HashMap<Object, Object>();map = service.queryMoreCustomer(customerId);//查询中心库房中商品的库存量List<Map<Object , Object >> list = new ArrayList<Map<Object,Object>>();list = service.queryAccount();DBUtils.close();request.setAttribute("id", customerId);request.setAttribute("m", map);request.setAttribute("list", list);request.getRequestDispatcher("../guest/order_add_customer.jsp").forward(request, response);}private void queryCustomerForOrder(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {int currentPage = 0;if("".equals(request.getParameter("inputPage")+"")||request.getParameter("inputPage")==null){currentPage = 1;}else{currentPage = Integer.parseInt(request.getParameter("inputPage")+"");}List<Map<Object , Object >> list = new ArrayList<Map<Object,Object>>();CustomerServiceCenterService service = new CustomerServiceCenterService();list = service.queryAllCustomer(currentPage);DBUtils.close();request.setAttribute("list", list);request.setAttribute("Page", service.getPage());request.getRequestDispatcher("../guest/new_order.jsp").forward(request, response);}private void registerCustomer(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {String customerName = request.getParameter("customerName");String identityNo = request.getParameter("identityNo");String jobAdd = request.getParameter("jobAdd");String tel = request.getParameter("tel");String cellphone = request.getParameter("cellphone");String address = request.getParameter("address");String post = request.getParameter("post");String mail = request.getParameter("mail");Object[] obj = {customerName,identityNo,jobAdd,tel,cellphone,address,post,mail};CustomerServiceCenterService service = new CustomerServiceCenterService();boolean tag = service.registerCustomer(obj);String msg = "添加成功";if(!tag){msg = "添加失败";}DBUtils.close();request.setAttribute("msg", msg);this.queryAllCustomer(request, response);}private void deleteCustomer(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {Object customerId = request.getParameter("customerId");Object [] id = {customerId};CustomerServiceCenterService service = new CustomerServiceCenterService();boolean tag = service.deleteCustomer(id);String msg = "删除成功";if(!tag){msg = "删除失败";}DBUtils.close();request.setAttribute("msg", msg);this.queryAllCustomer(request, response);}private void updateCustomer(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {String customerId = request.getParameter("customerId");String customerName = request.getParameter("customerName");String identityNo = request.getParameter("identityNo");String jobAdd = request.getParameter("jobAdd");String tel = request.getParameter("tel");String cellphone = request.getParameter("cellphone");String address = request.getParameter("address");String post = request.getParameter("post");String mail = request.getParameter("mail");Object[] obj = {customerName,identityNo,jobAdd,tel,cellphone,address,post,mail,customerId};CustomerServiceCenterService service = new CustomerServiceCenterService();boolean tag = service.updateCustomer(obj);DBUtils.close();String msg = "修改成功";if(!tag){msg = "修改失败";}request.setAttribute("msg", msg);this.queryAllCustomer(request, response);}private void queryForUpdate(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {Object customerId = request.getParameter("customerId");Map<Object,Object> map = new HashMap<Object, Object>();CustomerServiceCenterService service = new CustomerServiceCenterService();map = service.queryMoreCustomer(customerId);DBUtils.close();request.setAttribute("m", map);request.getRequestDispatcher("../guest/customer_info_update.jsp").forward(request, response);}private void queryMoreCustomer(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {Object customerId = request.getParameter("customerId");Object[] Id = {customerId};Map<Object,Object> map = new HashMap<Object, Object>();List<Map<Object,Object>> list = new ArrayList<Map<Object,Object>>();CustomerServiceCenterService service = new CustomerServiceCenterService();map = service.queryMoreCustomer(customerId);list = service.queryOrderByCustomerId(Id);DBUtils.close();request.setAttribute("m", map);request.setAttribute("list", list);request.getRequestDispatcher("../guest/customer_info.jsp").forward(request, response);}private void queryAllCustomer(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException {int currentPage = 0;if("".equals(request.getParameter("inputPage")+"")||request.getParameter("inputPage")==null){currentPage = 1;}else{currentPage = Integer.parseInt(request.getParameter("inputPage")+"");}List<Map<Object , Object >> list = new ArrayList<Map<Object,Object>>();CustomerServiceCenterService service = new CustomerServiceCenterService();list = service.queryAllCustomer(currentPage);DBUtils.close();System.out.println("fasldf" + request.getAttribute("customerName"));request.removeAttribute("customerName");System.out.println("fasldf" + request.getAttribute("customerName"));request.setAttribute("list", list);request.setAttribute("Page", service.getPage());request.getRequestDispatcher("../guest/customer_list.jsp").forward(request, response);}
}
这篇关于项目实训--物流管理项目之客户服务中心模块的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
