Java 实战项目之仓库管理系统的实现流程
一、项目简述
功能包括: 仓库管理,出入库管理,仓库人员管理,基本信息管理, 供应商信息,系统管理等等。
二、项目运行
环境配置: Jdk1.8 + Tomcat8.5 + mysql + Eclispe (IntelliJ IDEA,Eclispe,MyEclispe,Sts 都支持)
项目技术: JSP +Spring + SpringMVC + MyBatis + html+ css + JavaScript + JQuery + Ajax + layui+ maven等等。
客户信息管理请求:
/** * 客户信息管理请求 Handler */ @RequestMapping(value = "/**/customerManage") @Controller public class CustomerManageHandler { @Autowired private CustomerManageService customerManageService; private static final String SEARCH_BY_ID = "searchByID"; private static final String SEARCH_BY_NAME = "searchByName"; private static final String SEARCH_ALL = "searchAll"; /** * 通用的结果查询方法 * * @param searchType 查询方式 * @param keyWord 查询关键字 * @param offset 分页偏移值 * @param limit 分页大小 * @return 返回指定条件查询的结果 */ private Map<String, Object> query(String searchType, String keyWord, int offset, int limit) throws CustomerManageServiceException { Map<String, Object> queryResult = null; switch (searchType) { case SEARCH_BY_ID: if (StringUtils.isNumeric(keyWord)) queryResult = customerManageService.selectById(Integer.valueOf(keyWord)); break; case SEARCH_BY_NAME: queryResult = customerManageService.selectByName(offset, limit, keyWord); break; case SEARCH_ALL: queryResult = customerManageService.selectAll(offset, limit); break; default: // do other thing break; } return queryResult; } /** * 搜索客户信息 * * @param searchType 搜索类型 * @param offset 如有多条记录时分页的偏移值 * @param limit 如有多条记录时分页的大小 * @param keyWord 搜索的关键字 * @return 返回查询的结果,其中键值为 rows 的代表查询到的每一记录,若有分页则为分页大小的记录;键值为 total 代表查询到的符合要求的记录总条数 */ @SuppressWarnings("unchecked") @RequestMapping(value = "getCustomerList", method = RequestMethod.GET) public @ResponseBody Map<String, Object> getCustomerList(@RequestParam("searchType") String searchType, @RequestParam("offset") int offset, @RequestParam("limit") int limit, @RequestParam("keyWord") String keyWord) throws CustomerManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); List<Supplier> rows = null; long total = 0; Map<String, Object> queryResult = query(searchType, keyWord, offset, limit); if (queryResult != null) { rows = (List<Supplier>) queryResult.get("data"); total = (long) queryResult.get("total"); } // 设置 Response responseContent.setCustomerInfo("rows", rows); responseContent.setResponseTotal(total); responseContent.setResponseResult(Response.RESPONSE_RESULT_SUCCESS); return responseContent.generateResponse(); } /** * 添加一条客户信息 * * @param customer 客户信息 * @return 返回一个map,其中:key 为 result表示操作的结果,包括:success 与 error */ @RequestMapping(value = "addCustomer", method = RequestMethod.POST) public @ResponseBody Map<String, Object> addCustomer(@RequestBody Customer customer) throws CustomerManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); // 添加记录 String result = customerManageService.addCustomer(customer) ? Response.RESPONSE_RESULT_SUCCESS : Response.RESPONSE_RESULT_ERROR; responseContent.setResponseResult(result); return responseContent.generateResponse(); } /** * 查询指定 customer ID 客户的信息 * * @param customerID 客户ID * @return 返回一个map,其中:key 为 result 的值为操作的结果,包括:success 与 error;key 为 data * 的值为客户信息 */ @RequestMapping(value = "getCustomerInfo", method = RequestMethod.GET) public @ResponseBody Map<String, Object> getCustomerInfo(@RequestParam("customerID") String customerID) throws CustomerManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); String result = Response.RESPONSE_RESULT_ERROR; // 获取客户信息 Customer customer = null; Map<String, Object> queryResult = query(SEARCH_BY_ID, customerID, -1, -1); if (queryResult != null) { customer = (Customer) queryResult.get("data"); if (customer != null) { result = Response.RESPONSE_RESULT_SUCCESS; } } // 设置 Response responseContent.setResponseResult(result); responseContent.setResponseData(customer); return responseContent.generateResponse(); } /** * 更新客户信息 * * @param customer 客户信息 * @return 返回一个map,其中:key 为 result表示操作的结果,包括:success 与 error */ @RequestMapping(value = "updateCustomer", method = RequestMethod.POST) public @ResponseBody Map<String, Object> updateCustomer(@RequestBody Customer customer) throws CustomerManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); // 更新 String result = customerManageService.updateCustomer(customer) ? Response.RESPONSE_RESULT_SUCCESS : Response.RESPONSE_RESULT_ERROR; responseContent.setResponseResult(result); return responseContent.generateResponse(); } /** * 删除客户记录 * * @param customerIDStr 客户ID * @return 返回一个map,其中:key 为 result表示操作的结果,包括:success 与 error */ @RequestMapping(value = "deleteCustomer", method = RequestMethod.GET) public @ResponseBody Map<String, Object> deleteCustomer(@RequestParam("customerID") String customerIDStr) throws CustomerManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); // 参数检查 if (StringUtils.isNumeric(customerIDStr)) { // 转换为 Integer Integer customerID = Integer.valueOf(customerIDStr); // 刪除 String result = customerManageService.deleteCustomer(customerID) ? Response.RESPONSE_RESULT_SUCCESS : Response.RESPONSE_RESULT_ERROR; responseContent.setResponseResult(result); } else responseContent.setResponseResult(Response.RESPONSE_RESULT_ERROR); return responseContent.generateResponse(); } /** * 导入客户信息 * * @param file 保存有客户信息的文件 * @return 返回一个map,其中:key 为 result表示操作的结果,包括:success 与 * error;key为total表示导入的总条数;key为available表示有效的条数 */ @RequestMapping(value = "importCustomer", method = RequestMethod.POST) public @ResponseBody Map<String, Object> importCustomer(@RequestParam("file") MultipartFile file) throws CustomerManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); String result = Response.RESPONSE_RESULT_SUCCESS; // 读取文件内容 int total = 0; int available = 0; if (file == null) result = Response.RESPONSE_RESULT_ERROR; Map<String, Object> importInfo = customerManageService.importCustomer(file); if (importInfo != null) { total = (int) importInfo.get("total"); available = (int) importInfo.get("available"); } responseContent.setResponseResult(result); responseContent.setResponseTotal(total); responseContent.setCustomerInfo("available", available); return responseContent.generateResponse(); } /** * 导出客户信息 * * @param searchType 查找类型 * @param keyWord 查找关键字 * @param response HttpServletResponse */ @SuppressWarnings("unchecked") @RequestMapping(value = "exportCustomer", method = RequestMethod.GET) public void exportCustomer(@RequestParam("searchType") String searchType, @RequestParam("keyWord") String keyWord, HttpServletResponse response) throws CustomerManageServiceException, IOException { String fileName = "customerInfo.xlsx"; List<Customer> customers = null; Map<String, Object> queryResult = query(searchType, keyWord, -1, -1); if (queryResult != null) { customers = (List<Customer>) queryResult.get("data"); } // 获取生成的文件 File file = customerManageService.exportCustomer(customers); // 写出文件 if (file != null) { // 设置响应头 response.addHeader("Content-Disposition", "attachment;filename=" + fileName); FileInputStream inputStream = new FileInputStream(file); OutputStream outputStream = response.getOutputStream(); byte[] buffer = new byte[8192]; int len; while ((len = inputStream.read(buffer, 0, buffer.length)) > 0) { outputStream.write(buffer, 0, len); outputStream.flush(); } inputStream.close(); outputStream.close(); } } }
库存管理请求处理:
/** * 库存管理请求处理 */ @Controller @RequestMapping(value = "/**/storageManage") public class StorageManageHandler { @Autowired private StorageManageService storageManageService; @Autowired private StockRecordManageService stockRecordManageService; private static final String SEARCH_BY_GOODS_ID = "searchByGoodsID"; private static final String SEARCH_BY_GOODS_NAME = "searchByGoodsName"; private static final String SEARCH_BY_GOODS_TYPE = "searchByGoodsType"; private static final String SEARCH_ALL = "searchAll"; /** * 查询库存信息 * * @param searchType 查询类型 * @param keyword 查询关键字 * @param repositoryBelong 查询仓库 * @param offset 分页偏移值 * @param limit 分页大小 * @return 结果的一个Map,其中: key为 data 的代表记录数据;key 为 total 代表结果记录的数量 */ private Map<String, Object> query(String searchType, String keyword, String repositoryBelong, int offset, int limit) throws StorageManageServiceException { Map<String, Object> queryResult = null; switch (searchType) { case SEARCH_ALL: if (StringUtils.isNumeric(repositoryBelong)) { Integer repositoryID = Integer.valueOf(repositoryBelong); queryResult = storageManageService.selectAll(repositoryID, offset, limit); } else { queryResult = storageManageService.selectAll(-1, offset, limit); } break; case SEARCH_BY_GOODS_ID: if (StringUtils.isNumeric(keyword)) { Integer goodsID = Integer.valueOf(keyword); if (StringUtils.isNumeric(repositoryBelong)) { Integer repositoryID = Integer.valueOf(repositoryBelong); queryResult = storageManageService.selectByGoodsID(goodsID, repositoryID, offset, limit); } else queryResult = storageManageService.selectByGoodsID(goodsID, -1, offset, limit); } break; case SEARCH_BY_GOODS_TYPE: if (StringUtils.isNumeric(repositoryBelong)) { Integer repositoryID = Integer.valueOf(repositoryBelong); queryResult = storageManageService.selectByGoodsType(keyword, repositoryID, offset, limit); } else queryResult = storageManageService.selectByGoodsType(keyword, -1, offset, limit); break; case SEARCH_BY_GOODS_NAME: if (StringUtils.isNumeric(repositoryBelong)) { Integer repositoryID = Integer.valueOf(repositoryBelong); queryResult = storageManageService.selectByGoodsName(keyword, repositoryID, offset, limit); } else queryResult = storageManageService.selectByGoodsName(keyword, -1, offset, limit); break; default: // do other thing break; } return queryResult; } /** * 可指定仓库对库存信息查询 * * @param keyword 查询关键字 * @param searchType 查询类型 * @param repositoryBelong 查询所属的仓库 * @param offset 分页偏移值 * @param limit 分页大小 * @return 结果的一个Map,其中: key为 rows 的代表记录数据;key 为 total 代表结果记录的数量 */ @SuppressWarnings("unchecked") @RequestMapping(value = "getStorageListWithRepository", method = RequestMethod.GET) public @ResponseBody Map<String, Object> getStorageListWithRepoID(@RequestParam("keyword") String keyword, @RequestParam("searchType") String searchType, @RequestParam("repositoryBelong") String repositoryBelong, @RequestParam("offset") int offset, @RequestParam("limit") int limit) throws StorageManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); List<Storage> rows; long total = 0; // query Map<String, Object> queryResult = query(searchType, keyword, repositoryBelong, offset, limit); if (queryResult != null) { rows = (List<Storage>) queryResult.get("data"); total = (long) queryResult.get("total"); } else rows = new ArrayList<>(); // 设置 Response responseContent.setCustomerInfo("rows", rows); responseContent.setResponseTotal(total); return responseContent.generateResponse(); } /** * 查询库存信息,查询所属的仓库为session保存的信息 * * @param keyword 查询关键字 * @param searchType 查询类型 * @param offset 分页偏移值 * @param limit 分页大小 * @param request 请求 * @return 结果的一个Map,其中: key为 rows 的代表记录数据;key 为 total 代表结果记录的数量 */ @SuppressWarnings("unchecked") @RequestMapping(value = "getStorageList", method = RequestMethod.GET) public @ResponseBody Map<String, Object> getStorageList(@RequestParam("keyword") String keyword, @RequestParam("searchType") String searchType, @RequestParam("offset") int offset, @RequestParam("limit") int limit, HttpServletRequest request) throws StorageManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); List<Storage> rows = null; long total = 0; HttpSession session = request.getSession(); UserInfoDTO userInfo = (UserInfoDTO) session.getAttribute("userInfo"); Integer repositoryID = userInfo.getRepositoryBelong(); if (repositoryID > 0) { Map<String, Object> queryResult = query(searchType, keyword, repositoryID.toString(), offset, limit); if (queryResult != null) { rows = (List<Storage>) queryResult.get("data"); total = (long) queryResult.get("total"); } } if (rows == null) rows = new ArrayList<>(); // 设置 Response responseContent.setCustomerInfo("rows", rows); responseContent.setResponseTotal(total); return responseContent.generateResponse(); } /** * 添加一条库存信息 * * @return 返回一个map,其中:key 为 result表示操作的结果,包括:success 与 error */ @RequestMapping(value = "addStorageRecord", method = RequestMethod.POST) public @ResponseBody Map<String, Object> addStorageRecord(@RequestBody Map<String, Object> params) throws StorageManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); String isSuccess = Response.RESPONSE_RESULT_ERROR; boolean isAvailable = true; String goodsID = (String) params.get("goodsID"); String repositoryID = (String) params.get("repositoryID"); String number = (String) params.get("number"); if (StringUtils.isBlank(goodsID) || !StringUtils.isNumeric(goodsID)) isAvailable = false; if (StringUtils.isBlank(repositoryID) || !StringUtils.isNumeric(repositoryID)) isAvailable = false; if (StringUtils.isBlank(number) || !StringUtils.isNumeric(number)) isAvailable = false; if (isAvailable) { isSuccess = storageManageService.addNewStorage(Integer.valueOf(goodsID), Integer.valueOf(repositoryID), Integer.valueOf(number)) ? Response.RESPONSE_RESULT_SUCCESS : Response.RESPONSE_RESULT_ERROR; } // 设置 Response responseContent.setResponseResult(isSuccess); return responseContent.generateResponse(); } /** * 更新库存信息 * * @return 返回一个map,其中:key 为 result表示操作的结果,包括:success 与 error */ @RequestMapping(value = "updateStorageRecord", method = RequestMethod.POST) public @ResponseBody Map<String, Object> updateStorageRecord(@RequestBody Map<String, Object> params) throws StorageManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); boolean isAvailable = true; String result = Response.RESPONSE_RESULT_ERROR; String goodsID = (String) params.get("goodsID"); String repositoryID = (String) params.get("repositoryID"); String number = (String) params.get("number"); if (StringUtils.isBlank(goodsID) || !StringUtils.isNumeric(goodsID)) isAvailable = false; if (StringUtils.isBlank(repositoryID) || !StringUtils.isNumeric(repositoryID)) isAvailable = false; if (StringUtils.isBlank(number) || !StringUtils.isNumeric(number)) isAvailable = false; if (isAvailable) { result = storageManageService.updateStorage(Integer.valueOf(goodsID), Integer.valueOf(repositoryID), Integer.valueOf(number)) ? Response.RESPONSE_RESULT_SUCCESS : Response.RESPONSE_RESULT_ERROR; } // 设置 Response responseContent.setResponseResult(result); return responseContent.generateResponse(); } /** * 删除一条库存信息 * * @param goodsID 货物ID * @param repositoryID 仓库ID * @return 返回一个map,其中:key 为 result表示操作的结果,包括:success 与 error */ @RequestMapping(value = "deleteStorageRecord", method = RequestMethod.GET) public @ResponseBody Map<String, Object> deleteStorageRecord(@RequestParam("goodsID") String goodsID, @RequestParam("repositoryID") String repositoryID) throws StorageManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); String result = Response.RESPONSE_RESULT_ERROR; boolean isAvailable = true; if (StringUtils.isBlank(goodsID) || !StringUtils.isNumeric(goodsID)) isAvailable = false; if (StringUtils.isBlank(repositoryID) || !StringUtils.isNumeric(repositoryID)) isAvailable = false; if (isAvailable) { result = storageManageService.deleteStorage(Integer.valueOf(goodsID), Integer.valueOf(repositoryID)) ? Response.RESPONSE_RESULT_SUCCESS : Response.RESPONSE_RESULT_ERROR; } // 设置 Response responseContent.setResponseResult(result); return responseContent.generateResponse(); } /** * 导入库存信息 * * @param file 保存有库存信息的文件 * @return 返回一个map,其中:key 为 result表示操作的结果,包括:success 与 * error;key为total表示导入的总条数;key为available表示有效的条数 */ @RequestMapping(value = "importStorageRecord", method = RequestMethod.POST) public @ResponseBody Map<String, Object> importStorageRecord(@RequestParam("file") MultipartFile file) throws StorageManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); String result = Response.RESPONSE_RESULT_ERROR; int total = 0; int available = 0; if (file != null) { Map<String, Object> importInfo = storageManageService.importStorage(file); if (importInfo != null) { total = (int) importInfo.get("total"); available = (int) importInfo.get("available"); result = Response.RESPONSE_RESULT_SUCCESS; } } // 设置 Response responseContent.setResponseResult(result); responseContent.setResponseTotal(total); responseContent.setCustomerInfo("available", available); return responseContent.generateResponse(); } /** * 导出库存信息 * * @param searchType 查询类型 * @param keyword 查询关键字 * @param repositoryBelong 查询所属仓库 * @param request 请求 * @param response 响应 */ @SuppressWarnings("unchecked") @RequestMapping(value = "exportStorageRecord", method = RequestMethod.GET) public void exportStorageRecord(@RequestParam("searchType") String searchType, @RequestParam("keyword") String keyword, @RequestParam(value = "repositoryBelong", required = false) String repositoryBelong, HttpServletRequest request, HttpServletResponse response) throws StorageManageServiceException, IOException { String fileName = "storageRecord.xlsx"; HttpSession session = request.getSession(); UserInfoDTO userInfo = (UserInfoDTO) session.getAttribute("userInfo"); Integer sessionRepositoryBelong = userInfo.getRepositoryBelong(); if (sessionRepositoryBelong > 0) repositoryBelong = sessionRepositoryBelong.toString(); List<Storage> storageList = null; Map<String, Object> queryResult = query(searchType, keyword, repositoryBelong, -1, -1); if (queryResult != null) storageList = (List<Storage>) queryResult.get("data"); File file = storageManageService.exportStorage(storageList); if (file != null) { // 设置响应头 response.addHeader("Content-Disposition", "attachment;filename=" + fileName); FileInputStream inputStream = new FileInputStream(file); OutputStream outputStream = response.getOutputStream(); byte[] buffer = new byte[8192]; int len; while ((len = inputStream.read(buffer, 0, buffer.length)) > 0) { outputStream.write(buffer, 0, len); outputStream.flush(); } inputStream.close(); outputStream.close(); } } }
供应商信息管理请求:
/** * 供应商信息管理请求 Handler * */ @RequestMapping(value = "/**/supplierManage") @Controller public class SupplierManageHandler { @Autowired private SupplierManageService supplierManageService; private static final String SEARCH_BY_ID = "searchByID"; private static final String SEARCH_BY_NAME = "searchByName"; private static final String SEARCH_ALL = "searchAll"; /** * 通用的记录查询 * * @param searchType 查询类型 * @param keyWord 查询关键字 * @param offset 分页偏移值 * @param limit 分页大小 * @return 返回所有符合条件的记录 */ private Map<String, Object> query(String searchType, String keyWord, int offset, int limit) throws SupplierManageServiceException { Map<String, Object> queryResult = null; switch (searchType) { case SEARCH_BY_ID: if (StringUtils.isNumeric(keyWord)) { queryResult = supplierManageService.selectById(Integer.valueOf(keyWord)); } break; case SEARCH_BY_NAME: queryResult = supplierManageService.selectByName(offset, limit, keyWord); break; case SEARCH_ALL: queryResult = supplierManageService.selectAll(offset, limit); break; default: // do other thing break; } return queryResult; } /** * 搜索供应商信息 * * @param searchType 搜索类型 * @param offset 如有多条记录时分页的偏移值 * @param limit 如有多条记录时分页的大小 * @param keyWord 搜索的关键字 * @return */ @RequestMapping(value = "getSupplierList", method = RequestMethod.GET) @ResponseBody public Map<String, Object> getSupplierList(@RequestParam("searchType") String searchType, @RequestParam("offset") int offset, @RequestParam("limit") int limit, @RequestParam("keyWord") String keyWord) throws SupplierManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); List<Supplier> rows = null; long total = 0; Map<String, Object> queryResult = query(searchType, keyWord, offset, limit); // 结果转换 if (queryResult != null) { rows = (List<Supplier>) queryResult.get("data"); total = (long) queryResult.get("total"); } responseContent.setCustomerInfo("rows", rows); responseContent.setResponseTotal(total); return responseContent.generateResponse(); } /** * 添加一条供应商信息 * * @param supplier 供应商信息 * @return 返回一个map,其中:key 为 result表示操作的结果,包括:success 与 error */ @RequestMapping(value = "addSupplier", method = RequestMethod.POST) public @ResponseBody Map<String, Object> addSupplier(@RequestBody Supplier supplier) throws SupplierManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); // 添加记录 String result = supplierManageService.addSupplier(supplier) ? Response.RESPONSE_RESULT_SUCCESS : Response.RESPONSE_RESULT_ERROR; // 设置 Response responseContent.setResponseResult(result); return responseContent.generateResponse(); } /** * 查询指定 supplierID 供应商的信息 * * @param supplierID 供应商ID * @return 返回一个map,其中:key 为 result 的值为操作的结果,包括:success 与 error;key 为 data * 的值为供应商信息 */ @RequestMapping(value = "getSupplierInfo", method = RequestMethod.GET) public @ResponseBody Map<String, Object> getSupplierInfo(@RequestParam("supplierID") int supplierID) throws SupplierManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); String result = Response.RESPONSE_RESULT_ERROR; // 获取供应点信息 Supplier supplier = null; Map<String, Object> queryResult = supplierManageService.selectById(supplierID); if (queryResult != null) { supplier = (Supplier) queryResult.get("data"); if (supplier != null) result = Response.RESPONSE_RESULT_SUCCESS; } // 设置 Response responseContent.setResponseResult(result); responseContent.setResponseData(supplier); return responseContent.generateResponse(); } /** * 更新供应商信息 * * @param supplier 供应商信息 * @return 返回一个map,其中:key 为 result表示操作的结果,包括:success 与 error */ @RequestMapping(value = "updateSupplier", method = RequestMethod.POST) public @ResponseBody Map<String, Object> updateSupplier(@RequestBody Supplier supplier) throws SupplierManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); // 更新 String result = supplierManageService.updateSupplier(supplier) ? Response.RESPONSE_RESULT_SUCCESS : Response.RESPONSE_RESULT_ERROR; // 设置 Response responseContent.setResponseResult(result); return responseContent.generateResponse(); } /** * 删除供应商记录 * * @param supplierID 供应商ID * @return 返回一个map,其中:key 为 result表示操作的结果,包括:success 与 error */ @RequestMapping(value = "deleteSupplier", method = RequestMethod.GET) public @ResponseBody Map<String, Object> deleteSupplier(@RequestParam("supplierID") Integer supplierID) { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); // 刪除 String result = supplierManageService.deleteSupplier(supplierID) ? Response.RESPONSE_RESULT_SUCCESS : Response.RESPONSE_RESULT_ERROR; // 设置 Response responseContent.setResponseResult(result); return responseContent.generateResponse(); } /** * 导入供应商信息 * * @param file 保存有供应商信息的文件 * @return 返回一个map,其中:key 为 result表示操作的结果,包括:success 与 * error;key为total表示导入的总条数;key为available表示有效的条数 */ @RequestMapping(value = "importSupplier", method = RequestMethod.POST) public @ResponseBody Map<String, Object> importSupplier(@RequestParam("file") MultipartFile file) throws SupplierManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); String result = Response.RESPONSE_RESULT_SUCCESS; // 读取文件内容 int total = 0; int available = 0; if (file == null) result = Response.RESPONSE_RESULT_ERROR; Map<String, Object> importInfo = supplierManageService.importSupplier(file); if (importInfo != null) { total = (int) importInfo.get("total"); available = (int) importInfo.get("available"); } // 设置 Response responseContent.setResponseResult(result); responseContent.setResponseTotal(total); responseContent.setCustomerInfo("available", available); return responseContent.generateResponse(); } /** * 导出供应商信息 * * @param searchType 查找类型 * @param keyWord 查找关键字 * @param response HttpServletResponse */ @SuppressWarnings("unchecked") @RequestMapping(value = "exportSupplier", method = RequestMethod.GET) public void exportSupplier(@RequestParam("searchType") String searchType, @RequestParam("keyWord") String keyWord, HttpServletResponse response) throws SupplierManageServiceException, IOException { String fileName = "supplierInfo.xlsx"; // 根据查询类型进行查询 List<Supplier> suppliers = null; Map<String, Object> queryResult; queryResult = query(searchType, keyWord, -1, -1); if (queryResult != null) { suppliers = (List<Supplier>) queryResult.get("data"); } // 获取生成的文件 File file = supplierManageService.exportSupplier(suppliers); // 写出文件 if (file != null) { // 设置响应头 response.addHeader("Content-Disposition", "attachment;filename=" + fileName); FileInputStream inputStream = new FileInputStream(file); OutputStream outputStream = response.getOutputStream(); byte[] buffer = new byte[8192]; int len; while ((len = inputStream.read(buffer, 0, buffer.length)) > 0) { outputStream.write(buffer, 0, len); outputStream.flush(); } inputStream.close(); outputStream.close(); } } }
系统操作日志请求:
/** * 系统操作日志请求 Handler */ @Controller @RequestMapping(value = "/systemLog") public class SystemLogHandler { @Autowired private SystemLogService systemLogService; /** * 查询系统的登入登出日志 * * @param userIDStr 用户ID * @param accessType 记录类型(登入、登出或全部) * @param startDateStr 记录的起始日期 * @param endDateStr 记录的结束日期 * @param offset 分页的偏移值 * @param limit 分页的大小 * @return 返回 JSON 数据 其中:Key为rows的值代表所有记录数据,Key为total的值代表记录的总条数 * @throws SystemLogServiceException SystemLogServiceException */ @SuppressWarnings("unchecked") @RequestMapping(value = "getAccessRecords", method = RequestMethod.GET) public @ResponseBody Map<String, Object> getAccessRecords(@RequestParam("userID") String userIDStr, @RequestParam("accessType") String accessType, @RequestParam("startDate") String startDateStr, @RequestParam("endDate") String endDateStr, @RequestParam("offset") int offset, @RequestParam("limit") int limit) throws SystemLogServiceException { // 创建 Response 对象 Response response = ResponseFactory.newInstance(); List<AccessRecordDO> rows = null; long total = 0; // 检查参数 String regex = "([0-9]{4})-([0-9]{2})-([0-9]{2})"; boolean startDateFormatCheck = (StringUtils.isEmpty(startDateStr) || startDateStr.matches(regex)); boolean endDateFormatCheck = (StringUtils.isEmpty(endDateStr) || endDateStr.matches(regex)); boolean userIDCheck = (StringUtils.isEmpty(userIDStr) || StringUtils.isNumeric(userIDStr)); if (startDateFormatCheck && endDateFormatCheck && userIDCheck) { // 转到 Service 执行查询 Integer userID = -1; if (StringUtils.isNumeric(userIDStr)) userID = Integer.valueOf(userIDStr); Map<String, Object> queryResult = systemLogService.selectAccessRecord(userID, accessType, startDateStr, endDateStr, offset, limit); if (queryResult != null) { rows = (List<AccessRecordDO>) queryResult.get("data"); total = (long) queryResult.get("total"); } } else response.setResponseMsg("Request Argument Error"); if (rows == null) rows = new ArrayList<>(0); // 返回 Response response.setCustomerInfo("rows", rows); response.setResponseTotal(total); return response.generateResponse(); } /** * 查询系统的操作日志 * * @param userIDStr 用户ID * @param startDateStr 记录的起始日期 * @param endDateStr 记录的结束日期 * @param offset 分页的偏移值 * @param limit 分页的大小 * @return 返回 JSON 数据 其中:Key为rows的值代表所有记录数据,Key为total的值代表记录的总条数 * @throws SystemLogServiceException SystemLogServiceException */ @SuppressWarnings("unchecked") @RequestMapping(value = "getUserOperationRecords") public @ResponseBody Map<String, Object> selectUserOperationRecords(@RequestParam("userID") String userIDStr, @RequestParam("startDate") String startDateStr, @RequestParam("endDate") String endDateStr, @RequestParam("offset") int offset, @RequestParam("limit") int limit) throws SystemLogServiceException { // 创建 Response Response response = ResponseFactory.newInstance(); List<UserOperationRecordDTO> rows = null; long total = 0; // 检查参数 String regex = "([0-9]{4})-([0-9]{2})-([0-9]{2})"; boolean startDateFormatCheck = (StringUtils.isEmpty(startDateStr) || startDateStr.matches(regex)); boolean endDateFormatCheck = (StringUtils.isEmpty(endDateStr) || endDateStr.matches(regex)); boolean userIDCheck = (StringUtils.isEmpty(userIDStr) || StringUtils.isNumeric(userIDStr)); if (startDateFormatCheck && endDateFormatCheck && userIDCheck) { // 转到 Service 进行查询 Integer userID = -1; if (StringUtils.isNumeric(userIDStr)) userID = Integer.valueOf(userIDStr); Map<String, Object> queryResult = systemLogService.selectUserOperationRecord(userID, startDateStr, endDateStr, offset, limit); if (queryResult != null) { rows = (List<UserOperationRecordDTO>) queryResult.get("data"); total = (long) queryResult.get("total"); } } else response.setResponseMsg("Request argument error"); if (rows == null) rows = new ArrayList<>(0); response.setCustomerInfo("rows", rows); response.setResponseTotal(total); return response.generateResponse(); } }
以上就是Java 实战项目之仓库管理系统的实现流程的详细内容,更多关于Java 仓库管理系统的资料请关注我们其它相关文章!
赞 (0)