基於SpringBoot框架和SaaS模式,很是好用的ERP軟件,目前專一進銷存+財務功能。主要模塊有零售管理、採購管理、銷售管理、倉庫管理、財務管理、報表查詢、系統管理等。支持預付款、收入支出、倉庫調撥、組裝拆卸、訂單等特點功能。擁有庫存情況、出入庫統計等報表。權限控制更加精確html
springboot + mybatis + easyuijava
MySQL5.5+, 推薦5.7,5.6node
package com.jsh.erp.controller; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import com.jsh.erp.constants.BusinessConstants; import com.jsh.erp.constants.ExceptionConstants; import com.jsh.erp.datasource.entities.Tenant; import com.jsh.erp.datasource.entities.User; import com.jsh.erp.datasource.entities.UserEx; import com.jsh.erp.datasource.vo.TreeNodeEx; import com.jsh.erp.exception.BusinessParamCheckingException; import com.jsh.erp.service.log.LogService; import com.jsh.erp.service.tenant.TenantService; import com.jsh.erp.service.user.UserService; import com.jsh.erp.utils.*; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Value; import org.springframework.web.bind.annotation.*; import org.springframework.web.context.request.RequestContextHolder; import org.springframework.web.context.request.ServletRequestAttributes; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.net.URLEncoder; import java.security.NoSuchAlgorithmException; import java.util.*; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import static com.jsh.erp.utils.ResponseJsonUtil.returnJson; /** * @author */ @RestController @RequestMapping(value = "/user") public class UserController { private Logger logger = LoggerFactory.getLogger(UserController.class); @Value("${manage.roleId}") private Integer manageRoleId; @Resource private UserService userService; @Resource private TenantService tenantService; @Resource private LogService logService; private static String message = "成功"; private static final String HTTP = "http://"; private static final String CODE_OK = "200"; @PostMapping(value = "/login") public BaseResponseInfo login(@RequestParam(value = "loginName", required = false) String loginName, @RequestParam(value = "password", required = false) String password, HttpServletRequest request)throws Exception { logger.info("============用戶登陸 login 方法調用開始=============="); String msgTip = ""; User user=null; BaseResponseInfo res = new BaseResponseInfo(); try { String username = loginName.trim(); password = password.trim(); //判斷用戶是否已經登陸過,登陸過再也不處理 Object userInfo = request.getSession().getAttribute("user"); User sessionUser = new User(); if (userInfo != null) { sessionUser = (User) userInfo; } if (sessionUser != null && username.equalsIgnoreCase(sessionUser.getLoginame())) { logger.info("====用戶 " + username + "已經登陸過, login 方法調用結束===="); msgTip = "user already login"; } //獲取用戶狀態 int userStatus = -1; try { request.getSession().removeAttribute("tenantId"); userStatus = userService.validateUser(username, password); } catch (Exception e) { e.printStackTrace(); logger.error(">>>>>>>>>>>>>用戶 " + username + " 登陸 login 方法 訪問服務層異常====", e); msgTip = "access service exception"; } switch (userStatus) { case ExceptionCodeConstants.UserExceptionCode.USER_NOT_EXIST: msgTip = "user is not exist"; break; case ExceptionCodeConstants.UserExceptionCode.USER_PASSWORD_ERROR: msgTip = "user password error"; break; case ExceptionCodeConstants.UserExceptionCode.BLACK_USER: msgTip = "user is black"; break; case ExceptionCodeConstants.UserExceptionCode.USER_ACCESS_EXCEPTION: msgTip = "access service error"; break; default: try { msgTip = "user can login"; //驗證經過 ,能夠登陸,放入session,記錄登陸日誌 user = userService.getUserByUserName(username); request.getSession().setAttribute("user",user); if(user.getTenantId()!=null) { Tenant tenant = tenantService.getTenantByTenantId(user.getTenantId()); if(tenant!=null) { Long tenantId = tenant.getTenantId(); Integer userNumLimit = tenant.getUserNumLimit(); Integer billsNumLimit = tenant.getBillsNumLimit(); if(tenantId!=null) { request.getSession().setAttribute("tenantId",tenantId); //租戶tenantId request.getSession().setAttribute("userNumLimit",userNumLimit); //用戶限制數 request.getSession().setAttribute("billsNumLimit",billsNumLimit); //單據限制數 } } } logService.insertLog("用戶", new StringBuffer(BusinessConstants.LOG_OPERATION_TYPE_LOGIN).append(user.getId()).toString(), ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest()); } catch (Exception e) { e.printStackTrace(); logger.error(">>>>>>>>>>>>>>>查詢用戶名爲:" + username + " ,用戶信息異常", e); } break; } Map<String, Object> data = new HashMap<String, Object>(); data.put("msgTip", msgTip); /** * 在IE模式下,沒法獲取到user數據, * 在此處明確添加上user信息 * */ if(user!=null){ data.put("user",user); } res.code = 200; res.data = data; logger.info("===============用戶登陸 login 方法調用結束==============="); } catch(Exception e){ e.printStackTrace(); logger.error(e.getMessage()); res.code = 500; res.data = "用戶登陸失敗"; } return res; } @GetMapping(value = "/getUserSession") public BaseResponseInfo getSessionUser(HttpServletRequest request)throws Exception { BaseResponseInfo res = new BaseResponseInfo(); try { Map<String, Object> data = new HashMap<String, Object>(); Object userInfo = request.getSession().getAttribute("user"); if(userInfo!=null) { User user = (User) userInfo; user.setPassword(null); data.put("user", user); } res.code = 200; res.data = data; } catch(Exception e){ e.printStackTrace(); res.code = 500; res.data = "獲取session失敗"; } return res; } @GetMapping(value = "/logout") public BaseResponseInfo logout(HttpServletRequest request, HttpServletResponse response)throws Exception { BaseResponseInfo res = new BaseResponseInfo(); try { request.getSession().removeAttribute("user"); request.getSession().removeAttribute("tenantId"); request.getSession().removeAttribute("userNumLimit"); request.getSession().removeAttribute("billsNumLimit"); response.sendRedirect("/login.html"); } catch(Exception e){ e.printStackTrace(); res.code = 500; res.data = "退出失敗"; } return res; } @PostMapping(value = "/resetPwd") public String resetPwd(@RequestParam("id") Long id, HttpServletRequest request) throws Exception { Map<String, Object> objectMap = new HashMap<String, Object>(); String password = "123456"; String md5Pwd = Tools.md5Encryp(password); int update = userService.resetPwd(md5Pwd, id); if(update > 0) { return returnJson(objectMap, message, ErpInfo.OK.code); } else { return returnJson(objectMap, message, ErpInfo.ERROR.code); } } @PostMapping(value = "/updatePwd") public String updatePwd(@RequestParam("userId") Long userId, @RequestParam("password") String password, @RequestParam("oldpwd") String oldpwd, HttpServletRequest request)throws Exception { Integer flag = 0; Map<String, Object> objectMap = new HashMap<String, Object>(); try { User user = userService.getUser(userId); String oldPassword = Tools.md5Encryp(oldpwd); String md5Pwd = Tools.md5Encryp(password); //必須和原始密碼一致才能夠更新密碼 if(user.getLoginame().equals("jsh")){ flag = 3; //管理員jsh不能修改密碼 } else if (oldPassword.equalsIgnoreCase(user.getPassword())) { user.setPassword(md5Pwd); flag = userService.updateUserByObj(user); //1-成功 } else { flag = 2; //原始密碼輸入錯誤 } objectMap.put("status", flag); if(flag > 0) { return returnJson(objectMap, message, ErpInfo.OK.code); } else { return returnJson(objectMap, message, ErpInfo.ERROR.code); } } catch (Exception e) { logger.error(">>>>>>>>>>>>>修改用戶ID爲 : " + userId + "密碼信息失敗", e); flag = 3; objectMap.put("status", flag); return returnJson(objectMap, message, ErpInfo.ERROR.code); } } /** * 獲取所有用戶數據列表 * @param request * @return */ @GetMapping(value = "/getAllList") public BaseResponseInfo getAllList(HttpServletRequest request)throws Exception { BaseResponseInfo res = new BaseResponseInfo(); try { Map<String, Object> data = new HashMap<String, Object>(); List<User> dataList = userService.getUser(); if(dataList!=null) { data.put("userList", dataList); } res.code = 200; res.data = data; } catch(Exception e){ e.printStackTrace(); res.code = 500; res.data = "獲取失敗"; } return res; } /** * create by: cjl * description: * 查詢分頁用戶列表 * create time: 2019/3/8 15:08 * @Param: pageSize * @Param: currentPage * @Param: search * @return java.lang.String */ @GetMapping(value = "/getUserList") public String getUserList(@RequestParam(value = Constants.PAGE_SIZE, required = false) Integer pageSize, @RequestParam(value = Constants.CURRENT_PAGE, required = false) Integer currentPage, @RequestParam(value = Constants.SEARCH, required = false) String search)throws Exception { Map<String, Object> parameterMap = new HashMap<String, Object>(); //查詢參數 JSONObject obj= JSON.parseObject(search); Set<String> key= obj.keySet(); for(String keyEach: key){ parameterMap.put(keyEach,obj.getString(keyEach)); } PageQueryInfo queryInfo = new PageQueryInfo(); Map<String, Object> objectMap = new HashMap<String, Object>(); if (pageSize == null || pageSize <= 0) { pageSize = BusinessConstants.DEFAULT_PAGINATION_PAGE_SIZE; } if (currentPage == null || currentPage <= 0) { currentPage = BusinessConstants.DEFAULT_PAGINATION_PAGE_NUMBER; } PageHelper.startPage(currentPage,pageSize,true); List<UserEx> list = userService.getUserList(parameterMap); //獲取分頁查詢後的數據 PageInfo<UserEx> pageInfo = new PageInfo<>(list); objectMap.put("page", queryInfo); if (list == null) { queryInfo.setRows(new ArrayList<Object>()); queryInfo.setTotal(BusinessConstants.DEFAULT_LIST_NULL_NUMBER); return returnJson(objectMap, "查找不到數據", ErpInfo.OK.code); } queryInfo.setRows(list); queryInfo.setTotal(pageInfo.getTotal()); return returnJson(objectMap, ErpInfo.OK.name, ErpInfo.OK.code); } /** * create by: cjl * description: * 新增用戶及機構和用戶關係 * create time: 2019/3/8 16:06 * @Param: beanJson * @return java.lang.Object */ @PostMapping("/addUser") @ResponseBody public Object addUser(@RequestParam("info") String beanJson, HttpServletRequest request)throws Exception{ JSONObject result = ExceptionConstants.standardSuccess(); Long userNumLimit = Long.parseLong(request.getSession().getAttribute("userNumLimit").toString()); Long count = userService.countUser(null,null); if(count>= userNumLimit) { throw new BusinessParamCheckingException(ExceptionConstants.USER_OVER_LIMIT_FAILED_CODE, ExceptionConstants.USER_OVER_LIMIT_FAILED_MSG); } else { UserEx ue= JSON.parseObject(beanJson, UserEx.class); userService.addUserAndOrgUserRel(ue); } return result; } /** * 註冊用戶 * @param loginame * @param password * @return * @throws Exception */ @PostMapping(value = "/registerUser") public Object registerUser(@RequestParam(value = "loginame", required = false) String loginame, @RequestParam(value = "password", required = false) String password, HttpServletRequest request)throws Exception{ JSONObject result = ExceptionConstants.standardSuccess(); UserEx ue= new UserEx(); ue.setUsername(loginame); ue.setLoginame(loginame); ue.setPassword(password); userService.checkUserNameAndLoginName(ue); //檢查用戶名和登陸名 ue = userService.registerUser(ue,manageRoleId,request); return result; } /** * create by: cjl * description: * 修改用戶及機構和用戶關係 * create time: 2019/3/8 16:06 * @Param: beanJson * @return java.lang.Object */ @PostMapping("/updateUser") @ResponseBody public Object updateUser(@RequestParam("info") String beanJson,@RequestParam("id") Long id)throws Exception{ JSONObject result = ExceptionConstants.standardSuccess(); UserEx ue= JSON.parseObject(beanJson, UserEx.class); ue.setId(id); userService.updateUserAndOrgUserRel(ue); return result; } @PostMapping("/deleteUser") @ResponseBody public Object deleteUser(@RequestParam("ids") String ids)throws Exception{ JSONObject result = ExceptionConstants.standardSuccess(); userService.batDeleteUser(ids); return result; } @PostMapping("/batchDeleteUser") @ResponseBody public Object batchDeleteUser(@RequestParam("ids") String ids)throws Exception{ JSONObject result = ExceptionConstants.standardSuccess(); userService.batDeleteUser(ids); return result; } @RequestMapping("/getOrganizationUserTree") public JSONArray getOrganizationUserTree()throws Exception{ JSONArray arr=new JSONArray(); List<TreeNodeEx> organizationUserTree= userService.getOrganizationUserTree(); if(organizationUserTree!=null&&organizationUserTree.size()>0){ for(TreeNodeEx node:organizationUserTree){ String str=JSON.toJSONString(node); JSONObject obj=JSON.parseObject(str); arr.add(obj) ; } } return arr; } }
package com.jsh.erp.controller; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.jsh.erp.constants.BusinessConstants; import com.jsh.erp.constants.ExceptionConstants; import com.jsh.erp.datasource.entities.Account; import com.jsh.erp.datasource.vo.AccountVo4InOutList; import com.jsh.erp.exception.Busine***unTimeException; import com.jsh.erp.service.account.AccountService; import com.jsh.erp.utils.BaseResponseInfo; import com.jsh.erp.utils.ErpInfo; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import java.math.BigDecimal; import java.util.HashMap; import java.util.List; import java.util.Map; import static com.jsh.erp.utils.ResponseJsonUtil.returnJson; /** * @author jishenghua 75271*8920 */ @RestController @RequestMapping(value = "/account") public class AccountController { private Logger logger = LoggerFactory.getLogger(AccountController.class); @Resource private AccountService accountService; /** * 查找結算帳戶信息-下拉框 * @param request * @return */ @GetMapping(value = "/findBySelect") public String findBySelect(HttpServletRequest request) throws Exception { String res = null; try { List<Account> dataList = accountService.findBySelect(); //存放數據json數組 JSONArray dataArray = new JSONArray(); if (null != dataList) { for (Account account : dataList) { JSONObject item = new JSONObject(); item.put("Id", account.getId()); //結算帳戶名稱 item.put("AccountName", account.getName()); dataArray.add(item); } } res = dataArray.toJSONString(); } catch(Exception e){ e.printStackTrace(); res = "獲取數據失敗"; } return res; } /** * 獲取全部結算帳戶 * @param request * @return */ @GetMapping(value = "/getAccount") public BaseResponseInfo getAccount(HttpServletRequest request) throws Exception { BaseResponseInfo res = new BaseResponseInfo(); Map<String, Object> map = new HashMap<String, Object>(); try { List<Account> accountList = accountService.getAccount(); map.put("accountList", accountList); res.code = 200; res.data = map; } catch(Exception e){ e.printStackTrace(); res.code = 500; res.data = "獲取數據失敗"; } return res; } /** * 帳戶流水信息 * @param currentPage * @param pageSize * @param accountId * @param initialAmount * @param request * @return */ @GetMapping(value = "/findAccountInOutList") public BaseResponseInfo findAccountInOutList(@RequestParam("currentPage") Integer currentPage, @RequestParam("pageSize") Integer pageSize, @RequestParam("accountId") Long accountId, @RequestParam("initialAmount") BigDecimal initialAmount, HttpServletRequest request) throws Exception{ BaseResponseInfo res = new BaseResponseInfo(); Map<String, Object> map = new HashMap<String, Object>(); try { List<AccountVo4InOutList> dataList = accountService.findAccountInOutList(accountId, (currentPage-1)*pageSize, pageSize); int total = accountService.findAccountInOutListCount(accountId); map.put("total", total); //存放數據json數組 JSONArray dataArray = new JSONArray(); if (null != dataList) { for (AccountVo4InOutList aEx : dataList) { String timeStr = aEx.getOperTime().toString(); BigDecimal balance = accountService.getAccountSum(accountId, timeStr, "date").add(accountService.getAccountSumByHead(accountId, timeStr, "date")) .add(accountService.getAccountSumByDetail(accountId, timeStr, "date")).add(accountService.getManyAccountSum(accountId, timeStr, "date")).add(initialAmount); aEx.setBalance(balance); dataArray.add(aEx); } } map.put("rows", dataArray); res.code = 200; res.data = map; } catch(Exception e){ e.printStackTrace(); res.code = 500; res.data = "獲取數據失敗"; } return res; } @PostMapping(value = "/updateAmountIsDefault") public String updateAmountIsDefault(@RequestParam("isDefault") Boolean isDefault, @RequestParam("accountId") Long accountId, HttpServletRequest request) throws Exception{ Map<String, Object> objectMap = new HashMap<String, Object>(); int res = accountService.updateAmountIsDefault(isDefault, accountId); if(res > 0) { return returnJson(objectMap, ErpInfo.OK.name, ErpInfo.OK.code); } else { return returnJson(objectMap, ErpInfo.ERROR.name, ErpInfo.ERROR.code); } } /** * create by: qiankunpingtai * website:https://qiankunpingtai.cn * description: * 批量刪除帳戶信息 * create time: 2019/3/29 10:49 * @Param: ids * @return java.lang.Object */ @RequestMapping(value = "/batchDeleteAccountByIds") public Object batchDeleteAccountByIds(@RequestParam("ids") String ids,@RequestParam(value="deleteType", required =false,defaultValue=BusinessConstants.DELETE_TYPE_NORMAL)String deleteType) throws Exception { JSONObject result = ExceptionConstants.standardSuccess(); /** * create by: qiankunpingtai * create time: 2019/4/10 10:19 * website:https://qiankunpingtai.cn * description: * 出於兼容性考慮,沒有傳遞刪除類型時,默認爲正常刪除 */ int i=0; if(BusinessConstants.DELETE_TYPE_NORMAL.equals(deleteType)){ i= accountService.batchDeleteAccountByIdsNormal(ids); }else if(BusinessConstants.DELETE_TYPE_FORCE.equals(deleteType)){ i= accountService.batchDeleteAccountByIds(ids); }else{ logger.error("異常碼[{}],異常提示[{}],參數,ids[{}],deleteType[{}]", ExceptionConstants.DELETE_REFUSED_CODE,ExceptionConstants.DELETE_REFUSED_MSG,ids,deleteType); throw new Busine***unTimeException(ExceptionConstants.DELETE_REFUSED_CODE, ExceptionConstants.DELETE_REFUSED_MSG); } if(i<1){ logger.error("異常碼[{}],異常提示[{}],參數,ids[{}]", ExceptionConstants.ACCOUNT_DELETE_FAILED_CODE,ExceptionConstants.ACCOUNT_DELETE_FAILED_MSG,ids); throw new Busine***unTimeException(ExceptionConstants.ACCOUNT_DELETE_FAILED_CODE, ExceptionConstants.ACCOUNT_DELETE_FAILED_MSG); } return result; } }
關注公衆號【C you again】,回覆「springboot 倉庫ERP管理系統」免費領取。
亦可直接掃描主頁二維碼關注,回覆「springboot 倉庫ERP管理系統」免費領取,點此打開我的主頁git
說明:此源碼來源於網絡,如有侵權,請聯繫刪除!!github
做者: C you again,從事軟件開發 努力在IT搬磚路上的技術小白
公衆號: 【C you again】,分享計算機類畢業設計源碼、IT技術文章、遊戲源碼、網頁模板、程序人生等等。公衆號回覆 【粉絲】進博主技術羣,與大佬交流,領取乾貨學習資料
關於轉載:歡迎轉載博主文章,轉載時代表出處
求贊環節:創做不易,記得 點贊+評論+轉發 謝謝你一路支持web