From 96e622e737ec7d0b9f3a64ecc4e4a53389a207a2 Mon Sep 17 00:00:00 2001 From: JiangYouYao <ak473600000> Date: Fri, 18 Mar 2022 17:00:09 +0800 Subject: [PATCH] 重构:订单取消逻辑 --- zq-erp/src/main/java/com/matrix/system/hive/service/imp/SysOrderServiceImpl.java | 285 ++++++++++++++------------------------------------------ 1 files changed, 74 insertions(+), 211 deletions(-) diff --git a/zq-erp/src/main/java/com/matrix/system/hive/service/imp/SysOrderServiceImpl.java b/zq-erp/src/main/java/com/matrix/system/hive/service/imp/SysOrderServiceImpl.java index def632f..f6bb406 100644 --- a/zq-erp/src/main/java/com/matrix/system/hive/service/imp/SysOrderServiceImpl.java +++ b/zq-erp/src/main/java/com/matrix/system/hive/service/imp/SysOrderServiceImpl.java @@ -1,7 +1,9 @@ package com.matrix.system.hive.service.imp; import cn.hutool.core.bean.BeanUtil; +import cn.hutool.core.collection.CollUtil; import cn.hutool.core.collection.CollectionUtil; +import com.alibaba.fastjson.JSON; import com.google.common.collect.Lists; import com.matrix.component.asyncmessage.AsyncMessageManager; import com.matrix.core.constance.MatrixConstance; @@ -9,10 +11,8 @@ import com.matrix.core.pojo.PaginationVO; import com.matrix.core.tools.DateUtil; import com.matrix.core.tools.LogUtil; -import com.matrix.core.tools.StringUtils; import com.matrix.core.tools.WebUtil; import com.matrix.system.app.dto.OrderListDto; -import com.matrix.system.app.mapper.SysProjUseMapper; import com.matrix.system.app.vo.OrderDetailAchieveItemVo; import com.matrix.system.app.vo.OrderDetailItemVo; import com.matrix.system.app.vo.OrderDetailVo; @@ -29,8 +29,7 @@ import com.matrix.system.enums.OperationFunctionEnum; import com.matrix.system.hive.bean.*; import com.matrix.system.hive.dao.*; -import com.matrix.system.hive.dto.GoodsSealLimitDto; -import com.matrix.system.hive.dto.SysOrderItemDto; +import com.matrix.system.hive.dto.*; import com.matrix.system.hive.plugin.util.CollectionUtils; import com.matrix.system.hive.plugin.util.MoneyUtil; import com.matrix.system.hive.pojo.CzXkVo; @@ -68,7 +67,7 @@ @Autowired SysVipInfoDao sysVipInfoDao; @Autowired - SysOutStoreDao sysOutStoreDao; + SysOutStoreService sysOutStoreService; @Autowired SysOutStoreItemDao sysOutStoreItemDao; @Autowired @@ -185,6 +184,7 @@ /** * 已付款订单取消 + * * @param order */ private void cancelYFKOrder(SysOrder order) { @@ -197,6 +197,7 @@ //储值卡退款 sysOrderServiceHelper.returnMoneyCardPay(order); + //套餐项目取消 List<SysOrderItem> sysOrderItems = orderItemDao.selectByOrderId(order.getId()); for (SysOrderItem orderItem : sysOrderItems) { // 充值卡类型退款 @@ -214,24 +215,14 @@ //删除出库单,恢复库存 SysOutStore sysOutStore = new SysOutStore(); sysOutStore.setOrderId(order.getId()); - List<SysOutStore> sysOutStores = sysOutStoreDao.selectByModel(sysOutStore); + List<SysOutStore> sysOutStores = sysOutStoreService.findByModel(sysOutStore); if (sysOutStores.size() == 1) { sysOutStore = sysOutStores.get(0); - List<SysOutStoreItem> outStoreItemList = sysOutStoreItemDao.selectByOrderId(sysOutStore.getId()); - for (SysOutStoreItem item : outStoreItemList) { - SysStoreInfo sysStoreInfo = storeInfoDao.selectById(item.getStoreId()); - sysStoreInfo.setStoreTotal(sysStoreInfo.getStoreTotal() + item.getAmount()); - //更新库存 - storeInfoDao.update(sysStoreInfo); - } - sysOutStoreDao.deleteById(sysOutStore.getId()); - sysOutStoreItemDao.deleteByOrderId(sysOutStore.getId()); + sysOutStoreService.cancelOutStore(sysOutStore.getId()); } // 删除业绩 - AchieveNew achieveNew = new AchieveNew(); - achieveNew.setOrderId(order.getId()); - achieveNewService.removeByModel(achieveNew); + achieveNewService.removeByOrderId(order.getId()); // 删除收款记录 sysOrderFlowDao.deleteByOrderId(order.getId()); @@ -242,6 +233,7 @@ // 取消订单 order.setStatu(Dictionary.ORDER_STATU_YQX); sysOrderDao.update(order); + //保存单据日志 operationLogService.saveOperation(order.getCompanyId(), order.getShopId(), sysUsers.getSuId(), OperationFunctionEnum.ORDER, @@ -255,6 +247,7 @@ /** * 待付款订单取消 + * * @param order */ private void cancelDFKOrder(SysOrder order) { @@ -285,16 +278,13 @@ */ @Override @Transactional(rollbackFor = Exception.class) - public void updateReceiptMoney(SysOrder pageOrder) throws GlobleException { + public void payOrder(SysOrder pageOrder) throws GlobleException { //校验订单是否满足收款条件 checkOrderAblePay(pageOrder); // 更新订单主表信息 - updateOrderInfo(pageOrder); - - // 设置用户为成交客户 - sysVipInfoService.updateDealStatus(pageOrder.getVipId(), BooleanEnum.TRUE.getValue()); + payEndUpdateOrderInfo(pageOrder); //添加支付流水 sysOrderServiceHelper.addOrderFlow(pageOrder, false); @@ -344,7 +334,7 @@ * * @param pageOrder */ - private void updateOrderInfo(SysOrder pageOrder) { + private void payEndUpdateOrderInfo(SysOrder pageOrder) { LogUtil.info("付款更新订单信息 id={}", pageOrder.getId()); SysUsers user = (SysUsers) WebUtil.getSession().getAttribute(MatrixConstance.LOGIN_KEY); pageOrder.setCashierId(user.getSuId()); @@ -381,12 +371,13 @@ sysOrderDao.update(pageOrder); - - + // 设置用户为成交客户 + sysVipInfoService.updateDealStatus(pageOrder.getVipId(), BooleanEnum.TRUE.getValue()); } /** * 检查订单是否满足支付条件 + * * @param pageOrder */ private void checkOrderAblePay(SysOrder pageOrder) { @@ -497,91 +488,33 @@ */ @Override @Transactional(rollbackFor = Exception.class) - public SysOrder updateAddCardMoney(CzXkVo czVo) { - SysUsers user = (SysUsers) WebUtil.getSession().getAttribute(MatrixConstance.LOGIN_KEY); - -// SysVipInfo vip = (SysVipInfo) WebUtil.getSession().getAttribute(SystemConstance.CURRENT_CUSTOMER); -// czVo.setVipId(vip.getId()); - - //更新会员会员卡金额 - MoneyCardUse cardUser = moneyCardUseDao.selectVipCard(czVo.getVipId()); - cardUser.setRealMoney(MoneyUtil.add(cardUser.getRealMoney(), czVo.getBjmoney())); - cardUser.setGiftMoney(MoneyUtil.add(cardUser.getGiftMoney(), czVo.getGiftMoney())); - moneyCardUseDao.update(cardUser); - - - // 为会员新增积分 - SysVipInfo vipInfo = sysVipInfoDao.selectById(cardUser.getVipId()); - vipInfo.setPointAll(vipInfo.getPointAll() == null ? 0 : vipInfo.getPointAll() + czVo.getJf()); - sysVipInfoDao.update(vipInfo); - + public SysOrder moneyCardCz(CzXkVo czVo) { // 新增一个充值订单 - SysOrder order = new SysOrder(); - order.setArrears(0D); - order.setTotal(czVo.getBjmoney()); - order.setZkTotal(czVo.getBjmoney()); - order.setCashPay(czVo.getBjmoney()); - order.setShopId(user.getShopId()); - order.setOrderNo(codeService.getOrderCode()); - order.setVipId(czVo.getVipId()); - Date orderTime = new Date(); - if (StringUtils.isNotBlank(czVo.getDateTime())) { - orderTime = DateUtil.stringToDateNew(czVo.getDateTime(), DateUtil.DATE_FORMAT_DD); - } - order.setOrderTime(orderTime); - order.setPayTime(orderTime); - order.setRemark(cardUser.getCardName()); - order.setStaffId(user.getSuId()); - order.setIsCross(2 + ""); - order.setOrderType(SysOrder.ORDER_TYPE_SEAL); - order.setStatu(Dictionary.ORDER_STATU_YFK); - order.setCompanyId(user.getCompanyId()); - sysOrderDao.insert(order); + SysOrder order = sysOrderServiceHelper.createCzOrder(czVo); - SysOrderItem orderItem = new SysOrderItem(); - orderItem.setOrderId(order.getId()); - orderItem.setOrderNo(order.getOrderNo()); - orderItem.setArrears(0D); - ShoppingGoods shoppingGoods = shoppingGoodsDao.selectVipCzGoods(); - orderItem.setGoodsId(shoppingGoods.getId()); - orderItem.setPayMethod(Dictionary.PAY_TYPE_MOENY); - orderItem.setCashPay(czVo.getBjmoney()); - orderItem.setZkPrice(czVo.getBjmoney()); - orderItem.setCardPay(0D); - orderItem.setType(Dictionary.SHOPPING_GOODS_TYPE_CZK); - orderItem.setCount(1); - orderItem.setIsFree(Dictionary.FLAG_NO); - orderItem.setPrice(czVo.getBjmoney()); - orderItem.setStatus(Dictionary.ORDER_STATU_YFK); - orderItem.setAchieveList(czVo.getAchaeveList()); - orderItem.setShoppingGoods(shoppingGoods); - orderItemDao.insert(orderItem); - List<SysOrderItem> items = new ArrayList<>(); - items.add(orderItem); - order.setItems(items); + //新增会员卡金额 + MoneyCardUse cardUser = moneyCardUseDao.selectVipCard(czVo.getVipId()); + MoneyCardPayDto moneyCardPayDto = new MoneyCardPayDto(); + moneyCardPayDto.setRealMoney(MoneyUtil.add(cardUser.getRealMoney(), czVo.getBjmoney())); + moneyCardPayDto.setGiftMoney(MoneyUtil.add(cardUser.getGiftMoney(), czVo.getGiftMoney())); + moneyCardPayDto.setCarUseId(cardUser.getId()); + moneyCardPayDto.setOrderId(order.getId()); + moneyCardPayDto.setOrderNo(order.getOrderNo()); + moneyCardPayDto.setType(MoneyCardUseFlow.USE_TYPE_CZ); + moneyCardUseService.changeMoneyCard(Arrays.asList(moneyCardPayDto)); + // 更新订单主表信息 + payEndUpdateOrderInfo(order); - //设置卡项使用流水 - MoneyCardUseFlow moneyCardUseFlow = new MoneyCardUseFlow(); - moneyCardUseFlow.setTotal(czVo.getBjmoney()); - moneyCardUseFlow.setGiftMoney(czVo.getGiftMoney()); - moneyCardUseFlow.setCarUseId(czVo.getCardId()); - moneyCardUseFlow.setVipId(czVo.getVipId()); - moneyCardUseFlow.setType(MoneyCardUseFlow.USE_TYPE_CZ); - moneyCardUseFlow.setOrderNo(order.getOrderNo()); - moneyCardUseFlow.setCreateTime(new Date()); - moneyCardUseFlow.setOperationId(user.getSuId()); - moneyCardUseFlow.setBalance(cardUser.getGiftMoney() + cardUser.getRealMoney()); - moneyCardUseFlow.setCarUseId(cardUser.getId()); - moneyCardUseFlowDao.insert(moneyCardUseFlow); - - order.setFlows(czVo.getFlows()); - + //添加支付流水 sysOrderServiceHelper.addOrderFlow(order, false); - // 添加员工业绩 + // 设置业绩 achieveNewService.addAchaeveByOrder(order); + + //设置会员积分 + sysOrderServiceHelper.addVipScore(order); return order; @@ -628,49 +561,14 @@ return sysOrderDao.selectShopAchieveRanking(sysOrder); } + @Transactional(rollbackFor = Exception.class) @Override - public void refundOrderMoney(SysOrder sysOrder) { - SysUsers user = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY); + public void orderTk(SysOrder sysOrder) { - //原订单设置为退款状态 - SysOrder sourceOrder = new SysOrder(); - sourceOrder.setId(sysOrder.getOldOrderId()); - sourceOrder.setIsHasRefund(SysOrder.IS_HAS_REFUND_Y); -// sourceOrder.setStatu(Dictionary.ORDER_STATU_TK); - sysOrderDao.update(sourceOrder); SysOrder oldOrder = sysOrderDao.selectById(sysOrder.getOldOrderId()); - - sysOrder.setId(null); - sysOrder.setStaffId(user.getSuId()); - sysOrder.setCompanyId(user.getCompanyId()); - sysOrder.setShopId(user.getShopId()); - sysOrder.setOrderType(SysOrder.ORDER_TYPE_REFUND); - sysOrder.setStatu(Dictionary.ORDER_STATU_YFK); - Date now = new Date(); - sysOrder.setOrderTime(now); - sysOrder.setPayTime(now); - sysOrder.setOrderNo(codeService.getRefundOrderNo()); - sysOrder.setZkTotal(-sysOrder.getZkTotal()); - //新增订单 - sysOrderDao.insert(sysOrder); - //插入明细 - for (SysOrderItem item : sysOrder.getItems()) { - - //更新原订单明细的可退数量 - SysOrderItem oldItem = new SysOrderItem(); - oldItem.setId(item.getId()); - oldItem.setRefundCount(item.getCount()); - orderItemDao.update(oldItem); - - //插入新的订单明细 - item.setId(null); - item.setCount(-item.getCount()); - item.setOrderId(sysOrder.getId()); - orderItemDao.insert(item); - } - - + //创建并保存退款订单 + sysOrder = sysOrderServiceHelper.createTkOrder(sysOrder); // 添加订单收款流水 sysOrderServiceHelper.addOrderFlow(sysOrder, false); //退款退套餐退项目 @@ -681,6 +579,7 @@ // 设置业绩 achieveNewService.addAchaeveByOrder(sysOrder); + SysUsers user = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY); //保存单据日志 operationLogService.saveOperation(sysOrder.getCompanyId(), sysOrder.getShopId(), user.getSuId(), OperationFunctionEnum.ORDER, @@ -691,101 +590,65 @@ } - - - /** * 退款退项目,套餐,卡项 * * @param sysOrder */ private void refundProjUse(SysOrder sysOrder) { + SysUsers user = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY); //记录需要退库存的产品 List<SysOrderItem> returnGoodsList = new ArrayList<>(); + //需要退的套餐和项目 + List<ProjUseOperationDto> projUseDtoList = Lists.newArrayList(); + //需要退的储值卡 + List<MoneyCardOperationDto> moneyCardOperationDtos = Lists.newArrayList(); for (SysOrderItem item : sysOrder.getItems()) { - SysProjUse queryProjUse = new SysProjUse(); - queryProjUse.setOrderItemId(item.getOldItemId()); - // 修改项目信息 - if (Dictionary.SHOPPING_GOODS_TYPE_XM.equals(item.getType()) || Dictionary.SHOPPING_GOODS_TYPE_JJCP.equals(item.getType())) { + if (Dictionary.SHOPPING_GOODS_TYPE_JJCP.equals(item.getType()) && Dictionary.FLAG_YES_Y.equals(item.getIsReturnStore())) { - if (Dictionary.SHOPPING_GOODS_TYPE_JJCP.equals(item.getType())) { - if (Dictionary.FLAG_YES_Y.equals(item.getIsReturnStore())) { - returnGoodsList.add(item); - } - } else { - SysProjUse sysProjUse = sysProjUseDao.selectByModel(queryProjUse).get(0); + returnGoodsList.add(item); - int sub = sysProjUse.getSurplusCount() - item.getCount(); - if (sub < 0) { - throw new GlobleException("项目余次不足"); - } else if (sub == 0) { - sysProjUse.setIsOver(Dictionary.FLAG_YES_Y); - sysProjUse.setStatus(Dictionary.TAOCAN_STATUS_WX); - } - sysProjUse.setSurplusCount(sub); - sysProjUseDao.update(sysProjUse); - SysProjUseFlow sysProjUseFlow = SysProjUseMapper.INSTANCE.projUseToFlow(sysProjUse); - sysProjUseFlow.setOptionType("退款修改"); - sysProjUseFlow.setId(null); - sysProjUseFlow.setUpdateBy(user.getSuName()); - sysProjUseFlow.setCreateBy(user.getSuName()); - sysProjUseDao.insertFlow(sysProjUseFlow); - } + } else if (Dictionary.SHOPPING_GOODS_TYPE_TC.equals(item.getType()) + || Dictionary.SHOPPING_GOODS_TYPE_XM.equals(item.getType())) { + ProjUseOperationDto dto = new ProjUseOperationDto(); + dto.setGoodsId(item.getGoodsId()); + dto.setCount(item.getCount()); + dto.setOrderItemId(item.getOldItemId()); + projUseDtoList.add(dto); + + }else if (Dictionary.SHOPPING_GOODS_TYPE_CZK.equals(item.getType())) { + MoneyCardOperationDto moneyCardOperationDto = new MoneyCardOperationDto(); + moneyCardOperationDto.setOrderId(sysOrder.getId()); + moneyCardOperationDto.setOrderItemId(item.getOldItemId()); + moneyCardOperationDto.setType(MoneyCardUseFlow.USE_TYPE_ORDRE_CANCEL); + moneyCardOperationDto.setUpdateUser(user.getSuId()); + moneyCardOperationDto.setOrderNo(sysOrder.getOrderNo()); + moneyCardOperationDtos.add(moneyCardOperationDto); } - - if (Dictionary.SHOPPING_GOODS_TYPE_TC.equals(item.getType())) { - queryProjUse.setTaocanId(-1L); - List<SysProjUse> sysProjUses = sysProjUseDao.selectByModel(queryProjUse); - - - for (int i = 0; i < sysProjUses.size(); i++) { - - SysProjUse sysProjUse = sysProjUses.get(i); - sysProjUse.setIsOver(Dictionary.FLAG_YES_Y); - sysProjUse.setStatus(Dictionary.TAOCAN_STATUS_WX); - sysProjUseDao.update(sysProjUse); - SysProjUseFlow sysProjUseFlow = SysProjUseMapper.INSTANCE.projUseToFlow(sysProjUse); - sysProjUseFlow.setOptionType("退款修改"); - sysProjUseFlow.setId(null); - sysProjUseFlow.setUpdateBy(user.getSuName()); - sysProjUseFlow.setCreateBy(user.getSuName()); - sysProjUseDao.insertFlow(sysProjUseFlow); - } - } - - if (Dictionary.SHOPPING_GOODS_TYPE_CZK.equals(item.getType())) { - MoneyCardUse queryCardUse = new MoneyCardUse(); - queryCardUse.setStatus(Dictionary.TAOCAN_STATUS_YX); - queryCardUse.setOrderItemId(item.getOldItemId()); - - List<MoneyCardUse> moneyCardUses = moneyCardUseDao.selectByModel(queryCardUse); - for (int i = 0; i < item.getCount(); i++) { - MoneyCardUse moneyCardUse = moneyCardUses.get(i); - moneyCardUse.setIsOver(Dictionary.FLAG_YES_Y); - moneyCardUse.setStatus(Dictionary.MONEYCARD_STATUS_WX); - moneyCardUseDao.update(moneyCardUse); - } - } - - - - ShoppingGoods goods = shoppingGoodsDao.selectById(item.getGoodsId()); - goods.setRealSealCount(goods.getRealSealCount() - item.getCount()); - shoppingGoodsDao.update(goods); } BusParameterSettings manageStockSetting = busParameterSettingsDao.selectCompanyParamByCode(AppConstance.WAREHOUSE_MANAGE_STOCK, sysOrder.getCompanyId()); if (AppConstance.IS_Y.equals(manageStockSetting.getParamValue())) { // 家居产品退库存 if (CollectionUtils.isNotEmpty(returnGoodsList)) { + LogUtil.info("订单退款:退产品库存:{}", JSON.toJSONString(returnGoodsList)); refundInstore(returnGoodsList); } } + if(CollUtil.isNotEmpty(projUseDtoList)){ + LogUtil.info("订单退款:退套餐项目:{}", JSON.toJSONString(projUseDtoList)); + sysProjUseService.projectTk(projUseDtoList); + } + + if(CollUtil.isNotEmpty(moneyCardOperationDtos)){ + LogUtil.info("订单退款:储值卡:{}", JSON.toJSONString(moneyCardOperationDtos)); + moneyCardUseService.moneyCardTk(moneyCardOperationDtos); + } } /** -- Gitblit v1.9.1