admin Java项目:仓库管理系统(java+SSM+JSP+JS+JQUERY+Layui+Mysql)
基于SSM的仓库管理系统设计与实现
角色：管理员、员工
管理员：管理员登录系统后，可以对个人中心、员工管理、厂商信息管理、司机信息管理、门店信息管理、仓库信息管理、货物信息管理、货物入库管理、货物出库管理等功能
员工：员工登录到仓库管理系统后，可以对个人中心、厂商信息管理、司机信息管理、门店信息管理、仓库信息管理、货物信息管理、货物入库管理、货物出库管理等功能
环境需要1.运行环境：最好是java jdk 1.8，我们在这个平台上运行的。其他版本理论上也可以。 2.IDE环境：IDEA，Eclipse,Myeclipse都可以。推荐IDEA; 3.tomcat环境：Tomcat 7.x,8.x,9.x版本均可 4.硬件环境：windows 7/8/10 1G内存以上；或者 Mac OS； 5.是否Maven项目: 否；查看源码目录中是否包含pom.xml；若包含，则为maven项目，否则为非maven项目; 6.数据库：MySql 5.7/8.0等版本均可；
技术栈后端：SSM(Spring+SpringMVC+Mybatis) 前端：JSP+CSS+JS+JQUERY+Layui
使用说明1. 使用Navicat或者其它工具，在mysql中创建对应名称的数据库，并导入项目的sql文件； 2. 使用IDEA/Eclipse/MyEclipse导入项目，修改配置，运行项目； 3. 将项目中db.xml配置文件中的数据库配置改为自己的配置，然后运行；
仓库管理员管理请求: /** * 仓库管理员管理请求 Handler * * @author yy */@Controller@RequestMapping(value = "/**/repositoryAdminManage")public class RepositoryAdminManageHandler { @Autowired private RepositoryAdminManageService repositoryAdminManageService; // 查询类型 private static final String SEARCH_BY_ID = "searchByID"; private static final String SEARCH_BY_NAME = "searchByName"; private static final String SEARCH_BY_REPOSITORY_ID = "searchByRepositoryID"; private static final String SEARCH_ALL = "searchAll"; /** * 通用记录查询 * * @param keyWord 查询关键字 * @param searchType 查询类型 * @param offset 分页偏移值 * @param limit 分页大小 * @return 返回所有符合条件的记录 */ private Map query(String keyWord, String searchType, int offset, int limit) throws RepositoryAdminManageServiceException { Map queryResult = null; // query switch (searchType) { case SEARCH_ALL: queryResult = repositoryAdminManageService.selectAll(offset, limit); break; case SEARCH_BY_ID: if (StringUtils.isNumeric(keyWord)) queryResult = repositoryAdminManageService.selectByID(Integer.valueOf(keyWord)); break; case SEARCH_BY_NAME: queryResult = repositoryAdminManageService.selectByName(offset, limit, keyWord); break; case SEARCH_BY_REPOSITORY_ID: if (StringUtils.isNumeric(keyWord)) queryResult = repositoryAdminManageService.selectByRepositoryID(Integer.valueOf(keyWord)); break; default: // do other things break; } return queryResult; } /** * 查询仓库管理员信息 * * @param searchType 查询类型 * @param offset 分页偏移值 * @param limit 分页大小 * @param keyWord 查询关键字 * @return 返回一个Map，其中key=rows，表示查询出来的记录；key=total，表示记录的总条数 */ @SuppressWarnings("unchecked") @RequestMapping(value = "getRepositoryAdminList", method = RequestMethod.GET) public @ResponseBody Map getRepositoryAdmin(@RequestParam("searchType") String searchType, @RequestParam("keyWord") String keyWord, @RequestParam("offset") int offset, @RequestParam("limit") int limit) throws RepositoryAdminManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); List rows = null; long total = 0; // 查询 Map queryResult = query(keyWord, searchType, offset, limit); if (queryResult != null) { rows = (List) queryResult.get("data"); total = (long) queryResult.get("total"); } // 设置 Response responseContent.setCustomerInfo("rows", rows); responseContent.setResponseTotal(total); return responseContent.generateResponse(); } /** * 添加一条仓库管理员信息 * * @param repositoryAdmin 仓库管理员信息 * @return 返回一个map，其中：key 为 result表示操作的结果，包括：success 与 error */ @RequestMapping(value = "addRepositoryAdmin", method = RequestMethod.POST) public @ResponseBody Map addRepositoryAdmin(@RequestBody RepositoryAdmin repositoryAdmin) throws RepositoryAdminManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); // 添加结果 String result = repositoryAdminManageService.addRepositoryAdmin(repositoryAdmin) ? Response.RESPONSE_RESULT_SUCCESS : Response.RESPONSE_RESULT_ERROR; // 设置 Response responseContent.setResponseResult(result); return responseContent.generateResponse(); } /** * 查询指定 ID 的仓库管理员信息 * * @param repositoryAdminID 仓库管理员ID * @return 返回一个map，其中：key 为 result 的值为操作的结果，包括：success 与 error；key 为 data * 的值为仓库管理员信息 */ @RequestMapping(value = "getRepositoryAdminInfo", method = RequestMethod.GET) public @ResponseBody Map getRepositoryAdminInfo(Integer repositoryAdminID) throws RepositoryAdminManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); String result = Response.RESPONSE_RESULT_ERROR; // 查询 RepositoryAdmin repositoryAdmin = null; Map queryResult = repositoryAdminManageService.selectByID(repositoryAdminID); if (queryResult != null) { if ((repositoryAdmin = (RepositoryAdmin) queryResult.get("data")) != null) result = Response.RESPONSE_RESULT_SUCCESS; } // 设置 Response responseContent.setResponseResult(result); responseContent.setResponseData(repositoryAdmin); return responseContent.generateResponse(); } /** * 更新仓库管理员信息 * * @param repositoryAdmin 仓库管理员信息 * @return 返回一个map，其中：key 为 result 的值为操作的结果，包括：success 与 error；key 为 data * 的值为仓库管理员信息 */ @RequestMapping(value = "updateRepositoryAdmin", method = RequestMethod.POST) public @ResponseBody Map updateRepositoryAdmin(@RequestBody RepositoryAdmin repositoryAdmin) throws RepositoryAdminManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); // 更新 String result = repositoryAdminManageService.updateRepositoryAdmin(repositoryAdmin) ? Response.RESPONSE_RESULT_SUCCESS : Response.RESPONSE_RESULT_ERROR; // 设置 Response responseContent.setResponseResult(result); return responseContent.generateResponse(); } /** * 删除指定 ID 的仓库管理员信息 * * @param repositoryAdminID 仓库ID * @return 返回一个map，其中：key 为 result 的值为操作的结果，包括：success 与 error；key 为 data * 的值为仓库管理员信息 */ @RequestMapping(value = "deleteRepositoryAdmin", method = RequestMethod.GET) public @ResponseBody Map deleteRepositoryAdmin(Integer repositoryAdminID) throws RepositoryAdminManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); // 删除记录 String result = repositoryAdminManageService.deleteRepositoryAdmin(repositoryAdminID) ? 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 = "importRepositoryAdmin", method = RequestMethod.POST) public @ResponseBody Map importRepositoryAdmin(MultipartFile file) throws RepositoryAdminManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); String result = Response.RESPONSE_RESULT_ERROR; // 读取文件 long total = 0; long available = 0; if (file != null) { Map importInfo = repositoryAdminManageService.importRepositoryAdmin(file); if (importInfo != null) { total = (long) importInfo.get("total"); available = (long) 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 response HttpServletResponse */ @SuppressWarnings("unchecked") @RequestMapping(value = "exportRepositoryAdmin", method = RequestMethod.GET) public void exportRepositoryAdmin(@RequestParam("searchType") String searchType, @RequestParam("keyWord") String keyWord, HttpServletResponse response) throws RepositoryAdminManageServiceException, IOException { // 导出文件名 String fileName = "repositoryAdminInfo.xlsx"; // 查询 List repositoryAdmins; Map queryResult = query(keyWord, searchType, -1, -1); if (queryResult != null) repositoryAdmins = (List) queryResult.get("data"); else repositoryAdmins = new ArrayList(); // 生成文件 File file = repositoryAdminManageService.exportRepositoryAdmin(repositoryAdmins); // 输出文件 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 * * @author yy */@RequestMapping(value = "/**/goodsManage")@Controllerpublic class GoodsManageHandler { @Autowired private GoodsManageService goodsManageService; 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 返回一个 Map ，包含所有符合要求的查询结果，以及记录的条数 */ private Map query(String searchType, String keyWord, int offset, int limit) throws GoodsManageServiceException { Map queryResult = null; switch (searchType) { case SEARCH_BY_ID: if (StringUtils.isNumeric(keyWord)) queryResult = goodsManageService.selectById(Integer.valueOf(keyWord)); break; case SEARCH_BY_NAME: queryResult = goodsManageService.selectByName(keyWord); break; case SEARCH_ALL: queryResult = goodsManageService.selectAll(offset, limit); break; default: // do other thing break; } return queryResult; } /** * 搜索货物信息 * * @param searchType 搜索类型 * @param offset 如有多条记录时分页的偏移值 * @param limit 如有多条记录时分页的大小 * @param keyWord 搜索的关键字 * @return 返回所有符合要求的记录 */ @SuppressWarnings("unchecked") @RequestMapping(value = "getGoodsList", method = RequestMethod.GET) public @ResponseBody Map getGoodsList(@RequestParam("searchType") String searchType, @RequestParam("offset") int offset, @RequestParam("limit") int limit, @RequestParam("keyWord") String keyWord) throws GoodsManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); List rows = null; long total = 0; // 查询 Map queryResult = query(searchType, keyWord, offset, limit); if (queryResult != null) { rows = (List) queryResult.get("data"); total = (long) queryResult.get("total"); } // 设置 Response responseContent.setCustomerInfo("rows", rows); responseContent.setResponseTotal(total); return responseContent.generateResponse(); } /** * 添加一条货物信息 * * @param goods 货物信息 * @return 返回一个map，其中：key 为 result表示操作的结果，包括：success 与 error */ @RequestMapping(value = "addGoods", method = RequestMethod.POST) public @ResponseBody Map addGoods(@RequestBody Goods goods) throws GoodsManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); // 添加记录 String result = goodsManageService.addGoods(goods) ? Response.RESPONSE_RESULT_SUCCESS : Response.RESPONSE_RESULT_ERROR; // 设置 Response responseContent.setResponseResult(result); return responseContent.generateResponse(); } /** * 查询指定 goods ID 货物的信息 * * @param goodsID 货物ID * @return 返回一个map，其中：key 为 result 的值为操作的结果，包括：success 与 error；key 为 data * 的值为货物信息 */ @RequestMapping(value = "getGoodsInfo", method = RequestMethod.GET) public @ResponseBody Map getGoodsInfo(@RequestParam("goodsID") Integer goodsID) throws GoodsManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); String result = Response.RESPONSE_RESULT_ERROR; // 获取货物信息 Goods goods = null; Map queryResult = goodsManageService.selectById(goodsID); if (queryResult != null) { goods = (Goods) queryResult.get("data"); if (goods != null) { result = Response.RESPONSE_RESULT_SUCCESS; } } // 设置 Response responseContent.setResponseResult(result); responseContent.setResponseData(goods); return responseContent.generateResponse(); } /** * 更新货物信息 * * @param goods 货物信息 * @return 返回一个map，其中：key 为 result表示操作的结果，包括：success 与 error */ @RequestMapping(value = "updateGoods", method = RequestMethod.POST) public @ResponseBody Map updateGoods(@RequestBody Goods goods) throws GoodsManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); // 更新 String result = goodsManageService.updateGoods(goods) ? Response.RESPONSE_RESULT_SUCCESS : Response.RESPONSE_RESULT_ERROR; // 设置 Response responseContent.setResponseResult(result); return responseContent.generateResponse(); } /** * 删除货物记录 * * @param goodsID 货物ID * @return 返回一个map，其中：key 为 result表示操作的结果，包括：success 与 error */ @RequestMapping(value = "deleteGoods", method = RequestMethod.GET) public @ResponseBody Map deleteGoods(@RequestParam("goodsID") Integer goodsID) throws GoodsManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); // 删除 String result = goodsManageService.deleteGoods(goodsID) ? 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 = "importGoods", method = RequestMethod.POST) public @ResponseBody Map importGoods(@RequestParam("file") MultipartFile file) throws GoodsManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); String result = Response.RESPONSE_RESULT_ERROR; // 读取文件内容 int total = 0; int available = 0; if (file != null) { Map importInfo = goodsManageService.importGoods(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 response HttpServletResponse */ @SuppressWarnings("unchecked") @RequestMapping(value = "exportGoods", method = RequestMethod.GET) public void exportGoods(@RequestParam("searchType") String searchType, @RequestParam("keyWord") String keyWord, HttpServletResponse response) throws GoodsManageServiceException, IOException { String fileName = "goodsInfo.xlsx"; List goodsList = null; Map queryResult = query(searchType, keyWord, -1, -1); if (queryResult != null) { goodsList = (List) queryResult.get("data"); } // 获取生成的文件 File file = goodsManageService.exportGoods(goodsList); // 写出文件 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(); } }} 客户信息管理请求: /** * 客户信息管理请求 * * @author yy */@RequestMapping(value = "/**/customerManage")@Controllerpublic 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 query(String searchType, String keyWord, int offset, int limit) throws CustomerManageServiceException { Map 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 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 rows = null; long total = 0; Map queryResult = query(searchType, keyWord, offset, limit); if (queryResult != null) { rows = (List) 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 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 getCustomerInfo(@RequestParam("customerID") String customerID) throws CustomerManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); String result = Response.RESPONSE_RESULT_ERROR; // 获取客户信息 Customer customer = null; Map 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 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 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 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 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 customers = null; Map queryResult = query(searchType, keyWord, -1, -1); if (queryResult != null) { customers = (List) 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(); } }} 商品出入库管理请求: /** * 商品出入库管理请求 * * @author yy */@Controller@RequestMapping(value = "stockRecordManage")public class StockRecordManageHandler { @Autowired private StockRecordManageService stockRecordManageService; /** * 货物出库操作 * * @param customerID 客户ID * @param goodsID 货物ID * @param repositoryIDStr 仓库ID * @param number 出库数量 * @return 返回一个map，key为result的值表示操作是否成功 */ @RequestMapping(value = "stockOut", method = RequestMethod.POST) public @ResponseBody Map stockOut(@RequestParam("customerID") Integer customerID, @RequestParam("goodsID") Integer goodsID, @RequestParam(value = "repositoryID", required = false) String repositoryIDStr, @RequestParam("number") long number) throws StockRecordManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); String result = Response.RESPONSE_RESULT_ERROR; boolean authorizeCheck = true; boolean argumentCheck = true; Integer repositoryID = null; // 参数检查 if (repositoryIDStr != null) { if (StringUtils.isNumeric(repositoryIDStr)) { repositoryID = Integer.valueOf(repositoryIDStr); } else { argumentCheck = false; responseContent.setResponseMsg("request argument error"); } } // 获取 session 中的信息 Subject currentUser = SecurityUtils.getSubject(); Session session = currentUser.getSession(); UserInfoDTO userInfo = (UserInfoDTO) session.getAttribute("userInfo"); String personInCharge = userInfo == null ? "none" : userInfo.getUserName(); Integer repositoryIDBelong = userInfo == null ? -1 : userInfo.getRepositoryBelong(); // 设置非管理员请求的仓库ID if (!currentUser.hasRole("systemAdmin")) { if (repositoryIDBelong < 0) { authorizeCheck = false; responseContent.setResponseMsg("You are not authorized"); } else { repositoryID = repositoryIDBelong; } } if (authorizeCheck && argumentCheck) { if (stockRecordManageService.stockOutOperation(customerID, goodsID, repositoryID, number, personInCharge)) result = Response.RESPONSE_RESULT_SUCCESS; } // 设置 Response responseContent.setResponseResult(result); return responseContent.generateResponse(); } /** * 货物入库操作 * * @param supplierID 供应商ID * @param goodsID 货物ID * @param repositoryIDStr 仓库ID * @param number 入库数目 * @return 返回一个map，key为result的值表示操作是否成功 */ @RequestMapping(value = "stockIn", method = RequestMethod.POST) public @ResponseBody Map stockIn(@RequestParam("supplierID") Integer supplierID, @RequestParam("goodsID") Integer goodsID, @RequestParam(value = "repositoryID", required = false) String repositoryIDStr, @RequestParam("number") long number) throws StockRecordManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); String result = Response.RESPONSE_RESULT_ERROR; boolean authorizeCheck = true; boolean argumentCheck = true; Integer repositoryID = null; // 参数检查 if (repositoryIDStr != null) { if (StringUtils.isNumeric(repositoryIDStr)) { repositoryID = Integer.valueOf(repositoryIDStr); } else { argumentCheck = false; responseContent.setResponseMsg("request argument error"); } } // 获取session中的信息 Subject currentUser = SecurityUtils.getSubject(); Session session = currentUser.getSession(); UserInfoDTO userInfo = (UserInfoDTO) session.getAttribute("userInfo"); String personInCharge = userInfo == null ? "none" : userInfo.getUserName(); Integer repositoryIDBelong = userInfo == null ? -1 : userInfo.getRepositoryBelong(); // 设置非管理员请求的仓库ID if (!currentUser.hasRole("systemAdmin")) { if (repositoryIDBelong < 0) { authorizeCheck = false; responseContent.setResponseMsg("You are not authorized"); } else { repositoryID = repositoryIDBelong; } } // 执行 Service if (authorizeCheck && argumentCheck) { if (stockRecordManageService.stockInOperation(supplierID, goodsID, repositoryID, number, personInCharge)) { result = Response.RESPONSE_RESULT_SUCCESS; } } // 设置 Response responseContent.setResponseResult(result); return responseContent.generateResponse(); } /** * 查询出入库记录 * * @param searchType 查询类型（查询所有或仅查询入库记录或仅查询出库记录） * @param repositoryIDStr 查询记录所对应的仓库ID * @param endDateStr 查询的记录起始日期 * @param startDateStr 查询的记录结束日期 * @param limit 分页大小 * @param offset 分页偏移值 * @return 返回一个Map，其中：Key为rows的值代表所有记录数据，Key为total的值代表记录的总条数 */ @SuppressWarnings({"SingleStatementInBlock", "unchecked"}) @RequestMapping(value = "searchStockRecord", method = RequestMethod.GET) public @ResponseBody Map getStockRecord(@RequestParam("searchType") String searchType, @RequestParam("repositoryID") String repositoryIDStr, @RequestParam("startDate") String startDateStr, @RequestParam("endDate") String endDateStr, @RequestParam("limit") int limit, @RequestParam("offset") int offset) throws ParseException, StockRecordManageServiceException { // 初始化 Response Response responseContent = ResponseFactory.newInstance(); List 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 repositoryIDCheck = (StringUtils.isEmpty(repositoryIDStr) || StringUtils.isNumeric(repositoryIDStr)); if (startDateFormatCheck && endDateFormatCheck && repositoryIDCheck) { Integer repositoryID = -1; if (StringUtils.isNumeric(repositoryIDStr)) { repositoryID = Integer.valueOf(repositoryIDStr); } // 转到 Service 执行查询 Map queryResult = stockRecordManageService.selectStockRecord(repositoryID, startDateStr, endDateStr, searchType, offset, limit); if (queryResult != null) { rows = (List) queryResult.get("data"); total = (long) queryResult.get("total"); } } else responseContent.setResponseMsg("Request argument error"); if (rows == null) rows = new ArrayList(0); responseContent.setCustomerInfo("rows", rows); responseContent.setResponseTotal(total); return responseContent.generateResponse(); }} 源码获取：俺的博客首页 "资源" 里下载！
