一个前后端分离的简易进销存后台管理系统

package cn.toesbieya.jxc.service.doc; import cn.toesbieya.jxc.annoation.Lock; import cn.toesbieya.jxc.annoation.UserAction; import cn.toesbieya.jxc.enumeration.DocFinishEnum; import cn.toesbieya.jxc.enumeration.DocHistoryEnum; import cn.toesbieya.jxc.enumeration.DocStatusEnum; import cn.toesbieya.jxc.exception.JsonResultException; import cn.toesbieya.jxc.mapper.*; import cn.toesbieya.jxc.model.entity.*; import cn.toesbieya.jxc.model.vo.R; import cn.toesbieya.jxc.model.vo.SellOutboundVo; import cn.toesbieya.jxc.model.vo.UserVo; import cn.toesbieya.jxc.model.vo.export.SellOutboundExport; import cn.toesbieya.jxc.model.vo.result.PageResult; import cn.toesbieya.jxc.model.vo.search.SellOutboundSearch; import cn.toesbieya.jxc.model.vo.update.DocStatusUpdate; import cn.toesbieya.jxc.service.BizStockService; import cn.toesbieya.jxc.service.RecService; import cn.toesbieya.jxc.util.DocUtil; import cn.toesbieya.jxc.util.ExcelUtil; import cn.toesbieya.jxc.util.Util; import com.baomidou.mybatisplus.core.conditions.Wrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.github.pagehelper.PageHelper; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.CollectionUtils; import org.springframework.util.StringUtils; import javax.annotation.Resource; import javax.servlet.http.HttpServletResponse; import java.math.BigDecimal; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.stream.Collectors; @Service @Slf4j public class BizSellOutboundService { @Resource private BizSellOutboundMapper mainMapper; @Resource private BizSellOutboundSubMapper subMapper; @Resource private BizSellOrderMapper orderMapper; @Resource private BizSellOrderSubMapper orderSubMapper; @Resource private BizDocHistoryMapper historyMapper; @Resource private BizStockMapper stockMapper; @Resource private RecService recService; @Resource private BizStockService stockService; //组装子表、附件列表的数据 public SellOutboundVo getById(String id) { BizSellOutbound main = mainMapper.selectById(id); if (main == null) return null; SellOutboundVo vo = new SellOutboundVo(main); vo.setData(getSubById(id)); vo.setImageList(recService.getAttachmentByPid(id)); return vo; } //根据主表ID获取子表 public List<BizSellOutboundSub> getSubById(String id) { return subMapper.selectList( Wrappers.lambdaQuery(BizSellOutboundSub.class) .eq(BizSellOutboundSub::getPid, id) ); } public PageResult<BizSellOutbound> search(SellOutboundSearch vo) { PageHelper.startPage(vo.getPage(), vo.getPageSize()); return new PageResult<>(mainMapper.selectList(getSearchCondition(vo))); } public void export(SellOutboundSearch vo, HttpServletResponse response) throws Exception { List<SellOutboundExport> list = mainMapper.export(getSearchCondition(vo)); ExcelUtil.exportSimply(list, response, "销售出库单导出"); } @UserAction("'添加销售出库单'") @Transactional(rollbackFor = Exception.class) public R add(SellOutboundVo doc) { return addMain(doc); } @UserAction("'修改销售出库单'+#doc.id") @Lock("#doc.id") @Transactional(rollbackFor = Exception.class) public R update(SellOutboundVo doc) { return updateMain(doc); } @UserAction("'提交销售出库单'+#doc.id") @Lock("#doc.id") @Transactional(rollbackFor = Exception.class) public R commit(SellOutboundVo doc) { boolean isFirstCreate = StringUtils.isEmpty(doc.getId()); R result = isFirstCreate ? addMain(doc) : updateMain(doc); if (result.isSuccess()) { historyMapper.insert( BizDocHistory.builder() .pid(doc.getId()) .type(DocHistoryEnum.COMMIT.getCode()) .uid(doc.getCid()) .uname(doc.getCname()) .statusBefore(DocStatusEnum.DRAFT.getCode()) .statusAfter(DocStatusEnum.WAIT_VERIFY.getCode()) .time(System.currentTimeMillis()) .build() ); result.setMsg("提交成功"); } else result.setMsg("提交失败，" + result.getMsg()); return result; } @UserAction("'撤回销售出库单'+#vo.id") @Lock("#vo.id") @Transactional(rollbackFor = Exception.class) public R withdraw(DocStatusUpdate vo, UserVo user) { String id = vo.getId(); String info = vo.getInfo(); if (rejectById(id) < 1) { return R.fail("撤回失败，请刷新重试"); } historyMapper.insert( BizDocHistory.builder() .pid(id) .type(DocHistoryEnum.WITHDRAW.getCode()) .uid(user.getId()) .uname(user.getNickName()) .statusBefore(DocStatusEnum.WAIT_VERIFY.getCode()) .statusAfter(DocStatusEnum.DRAFT.getCode()) .time(System.currentTimeMillis()) .info(info) .build() ); return R.success("撤回成功"); } @UserAction("'通过销售出库单'+#vo.id") @Lock({"#vo.pid", "#vo.id"}) @Transactional(rollbackFor = Exception.class) public R pass(DocStatusUpdate vo, UserVo user) { String id = vo.getId(); String info = vo.getInfo(); String pid = vo.getPid(); long now = System.currentTimeMillis(); List<BizSellOutboundSub> subList = getSubById(vo.getId()); String err = check(vo.getPid(), subList); if (err != null) return R.fail("通过失败，" + err); if (1 > mainMapper.update( null, Wrappers.lambdaUpdate(BizSellOutbound.class) .set(BizSellOutbound::getStatus, DocStatusEnum.VERIFIED.getCode()) .set(BizSellOutbound::getVid, user.getId()) .set(BizSellOutbound::getVname, user.getNickName()) .set(BizSellOutbound::getVtime, now) .eq(BizSellOutbound::getId, id) .eq(BizSellOutbound::getStatus, DocStatusEnum.WAIT_VERIFY.getCode()) )) { return R.fail("通过失败，请刷新重试"); } //按分类分组统计出库数量，并出库 Map<Integer, BigDecimal> outboundCount = new HashMap<>(); for (BizSellOutboundSub outboundSub : subList) { int rows = stockMapper.outbound(outboundSub.getSid(), outboundSub.getNum()); if (rows == 0) { throw new JsonResultException(String.format("通过失败，商品%s库存不足", outboundSub.getCname())); } Integer cid = outboundSub.getCid(); BigDecimal num = outboundCount.getOrDefault(cid, BigDecimal.ZERO); outboundCount.put(cid, num.add(outboundSub.getNum())); } //更新销售订单子表的剩余未出库数量，记录销售订单的完成情况 DocFinishEnum finish = DocFinishEnum.FINISHED; List<BizSellOrderSub> orderSubList = getOrderSubListByPid(pid); for (BizSellOrderSub orderSub : orderSubList) { if (orderSub.getRemainNum().equals(BigDecimal.ZERO)) { continue; } BigDecimal outboundNum = outboundCount.get(orderSub.getCid()); if (outboundNum == null) continue; BigDecimal gap = orderSub.getRemainNum().subtract(outboundNum); //如果有任意一个�