商城系统架构设计与实现

您所在的位置:网站首页 购物系统分析与设计 商城系统架构设计与实现

商城系统架构设计与实现

2024-01-21 15:57| 来源: 网络整理| 查看: 265

目录

背景 商城整体架构 订单系统 商品系统 促销系统 支付系统 推荐系统 积分系统 会员系统 总结

 

1. 背景

随着互联网技术广泛应用,各行各业都依托线上平台进行商务活动。小到个人带货,大到企业商业活动,都少不了需要少不了在线交易。于是,到处可见商城影响,不管是加盟大的电商平台如淘宝、京东、拼多多,或是企业自建商城平台,目的基本都是扩大生意渠道,卖货增加业绩收入。

下面基于我们公司自建商城平台,来谈谈我们商城架构设计方案。

 

2. 商城整体架构

一般来说,商城系统按单体服务方案去构思的话,按模块划分至少包括:商品、订单、会员、促销、支付、积分、仓储、物流、风控、企业内部erp、财务系统等。

公司原有技术架构是SpringCloud微服务架构 ,所以商城系统也是在这个体系下,同时根据我们公司实际业务特殊和复杂性,对各个模块进行微服务划分,业务领域分成多个业务中台和数据中台。

设计商城整架构如下:

一个完整商城体系结构是比较复杂的,涉及到很多关联系统和子系统模块。

采用分层设计,从系统分层设计角度考虑,可以划分:前端接入层、应用表示层、中台服务、后端服务层、基础服务层。

3. 订单系统

2.1、订单系统边界

在搭建企业订单系统之前,需要先梳理整体业务系统之间的关系和订单系统上下游关系,只有划分清业务系统边界,才能确定订单系统的职责与功能,进而保证各系统之间高效简洁的工作。

对外服务展示,所有给企业外部用户使用的系统都在这一层,包括WEB、普通用户使用的C端,还包括给商户使用的商家后台和在各个销售渠道进行分销的系统,比如与银行信用卡中心合作、微信合作在合作商的平台展示出本产品。这类系统站在与客户接触的最前线,是企业实现商业模式的桥头堡。

中后台系统,每个C端的业务形态都会有一个对应的系统模块,如负责管理平台交易的订单系统,管理优惠信息的促销系统,管理平台所有产品的产商品系统,以及管理所有对外系统显示内容的内容系统(CMS)等。

基础服务系统,随着企业的发展,信息化建设到达一定程度后,企业需要将通用功能服务化、平台化,以保证应用架构的合理性,提升服务效率。这类系统主要给其他应用系统提供基础服务能力支持。

由此可见,订单系统对上接收用户信息,将用户信息转化为产品订单,同时管理并跟踪订单信息和数据,承载了整个交易线的重要对客环节。

对下则衔接产品系统、促销系统、仓储系统、会员系统、积分系统、支付系统等,对整个电商平台起着承上启下的作用。

2.2、订单系统业务架构

订单服务,该模块的主要功能是用户日常使用的服务和页面,主要有订单列表、订单详情、在线下单等,还包括为公共业务模块提供的多维度订单数据服务。

订单逻辑,订单系统的核心,起着至关重要的作用,在订单系统负责管理订单创建、订单支付、订单生产、订单确认、订单完成、取消订单等订单流程。还涉及到复杂的订单状态规则、订单金额计算规则以及增减库存规则等。

底层服务,信息化建设达到一定程度的企业,一般会将公共服务模块化和中台化,比如:产品,会构建对应的产品系统,代码、数据库,接口等相对独立。但是,这也带来了一个问题,比如:订单创建的场景下需要获取的信息分散在各个系统。组装信息的时候会比较麻烦。

如果需要从各个中台系统调用:一是会花费大量时间,二是代码的维护成本非常高。因此,订单系统接入所需的公共服务模块聚合接口,在订单系统即可完成对接公共系统的服务。

2.3、订单核心功能

功能脑图

 

 

为了使订单系统能够对订单进行高效、精准的管理和跟踪,订单会储存关于产品、优惠、用户、支付信息等一系列的订单实时数据,来和下游系统,如:促销、仓储、物流进行交互。

以一个通用B2C商城的订单为例,梳理其包含的信息如下:

这里要注意的是订单类型,随着平台业务的不断发展,品类丰富、交易方式丰富后,需要对订单进行多维度的分类管理,同时订单类型利于订单系统的扩展性。每种订单类型将会对应一套流程及一套状态,便于对订单进行分类管理和复用。

2.4、订单正向流程

 

 

2.4.1、订单创建

用户下单后,系统需要生成订单,此时需要先获取下单中涉及的商品信息,然后获取该商品所涉及到的优惠信息,如果商品不参与优惠信息,则无此环节。

接着获取该账户的会员权益,这里要注意的是:优惠信息与会员权益的区别,比如:商品满减是优惠信息,会员全场9.8折指的是会员权益,一个是针对商品,另一个是针对账户。其次就是优惠活动的叠加规则和优先级规则等。

增减库存规则是指订单中的商品,何时从库存系统中对相应商品库存进行扣除,目前主流有两种方式:

(1)下单减库存——即用户下单成功时减少库存数量

优势:用户体验友好,系统逻辑简洁。

缺点:会导致恶意下单或下单后却不买,使得真正有需求的用户无法购买,影响真实销量。

解决办法:

设置订单有效时间,若订单创建成功N分钟不付款,则订单取消,库存回滚;

限购,用各种条件来限制买家的购买件数,比如一个账号、一个ip,只能买一件;

风控,从技术角度进行判断,屏蔽恶意账号,禁止恶意账号购买。

(2)付款减库存——即用户支付完成并反馈给平台后再减少库存数量

优势:减少无效订单带来的资源损耗。

缺点:因第三方支付返回结果存在时差,同一时间多个用户同时付款成功,会导致下单数目超过库存,商家库存不足容易引发断货和投诉,成本增加。

解决办法:

付款前再次校验库存,如确认订单要付款时再验证一次,并友好提示用户库存不足;

增加提示信息:在商品详情页,订单步骤页面提示不及时付款,不能保证有库存等。

综上所述,两种方式各有优缺点,因此,需结合实际场景进行考虑,如:秒杀、抢购、促销活动等,可使用下单减库存的方式。而对于产品库存量大,并发流量没有那么强的产品使用付款减库存的方式(秒杀系统设计是在另外文档中专题描述)。

将两种方式带入到销售场景中,关联商品类型、促销类型、供需关系等,灵活使用,以充分发挥计算机系统的优势。

2.4.2、订单支付

用户支付完订单后,需要获取订单的支付信息,包括支付流水号、支付时间等。支付完订单接着就是等商家发货,但在发货过程中,根据平台业务模式的不同,可能会涉及到订单的拆分。

订单拆分一般分两种:

一种是用户挑选的商品来自于不同渠道(自营与商家,商家与商家);

另一种是在SKU层面上拆分订单:不同仓库,不同运输要求的SKU,包裹重量体积限制等因素需要将订单拆分。

订单拆分也是一个相对独立的模块,可以采用子母单的形式,也可以采用服务单和订单形式,总的来说就是1:N关系。

2.4.3、订单生产

订单生产,是指产品从企业到用户这一流程的概述。如电商平台中,商家发货过程已有一个标准化的流程,订单内容会发送到仓库,仓库对商品进行打单、拣货、包装、交接快递进行配送(在我们这里一般是由供应商完成)。

2.4.4、订单确认

收到货后,订单系统需要在快递被签收后提醒用户对商品做评价。这里要注意,确认收到货不代表交易成功,而是售后服务的开始。

2.4.5、订单完成

订单完成是指在收到货X天的状态,此时订单不在售后的支持时间范围内。到此,一个订单的正向流程就算走完了。

 

2.4、订单逆向流程

 

上面说到逆向流程是各种修改订单、取消订单、退款、退货等操作,需要梳理清楚这些流程与正向流程的关系,才能理清订单系统完整的订单流程。

2.4.1、订单修改

可梳理订单内信息,根据信息关联程度及业务诉求,设定订单的可修改范围是什么,比如:客户下单后,想修改收货人地址及电话。此时只需对相应数据进行更新即可。

2.4.2、订单取消

用户提交订单后没有进行支付操作,此时用户原则上属于取消订单,因为还未付款,则比较简单,只需要将原本提交订单时扣减的库存补回,促销优惠中使用的优惠券,权益等视平台规则,进行相应补回。

2.4.3、退款

用户支付成功后,客户发出退款的诉求后,需商户进行退款审核,双方达成一致后,系统应以退款单的形式完成退款,关联原订单数据。因商品无变化,所以不许考虑与库存系统的交互,仅需考虑促销系统及支付系统交互即可。

2.4.4、退货

用户支付成功后,客户发出退货的诉求后,需商户进行退款审核,双方达成一致后,需对库存系统进行补回,支付系统、促销系统以退款单形式完成退款。最后,在退款/退货流程中,需结合平台业务场景,考虑优惠分摊的逻辑,在发生退款/退货时,优惠该如何退回的处理规则和流程。

2.5、状态机设计

状态机是管理订单状态逻辑的工具。状态机可归纳为3个要素,即现态、动作、次态。

现态:是指当前所处的状态。

动作:动作执行完毕后,可以迁移到新的状态,也可以仍旧保持原状态。

次态:动作满足后要迁往的新状态,“次态”是相对于“现态”而言的,“次态”一旦被激活,就转变成新的“现态”了。

状态机的设计需要结合平台实际业务场景,将状态间的切换细化成了执行了某个动作。

以一个B2C商城的订单系统举例,状态分类如下:

订单系统为了高效的对订单进行跟踪和管理,会对订单流程当中的关键节点,抽象出订单状态。而订单状态从不同用户的角度可分为:系统订单状态、商家订单状态、买家订单状态等。

对于订单系统来说,订单状态细分的颗粒度越细、越明确,订单系统管理的精度和可靠性就越高,比如:在待付款和待发货两个状态中,订单系统后台会细分为:订单超时取消、订单支付失败、订单付款完成等。

因此,订单状态模块中,通常会维护状态映射表,以不同的用户角色对系统订单状态进行重新划分,以满足不同用户的需求。

除此以外,随着业务的不断发展,不同的业务类型,所对应的订单状态都会有所区别。所以,订单系统中一般会储存多套状态机,以满足不同的订单类型来使用。

2.5、关键代码片断

对前商提供API访问接口

@Module("订单模块-C端") @RestController @RequestMapping("/customer-api/v1/order") public class OrderCustomerController { @Resource private OrderService orderService; @Resource private OrderCreateCmdExe orderCreateCmdExe; @Resource private OrderPayCmdExe orderPayCmdExe; @Resource private OrderCancelCmdExe orderCancelCmdExe; @Resource private RefundApplyCmdExe refundApplyCmdExe; @Resource private OrderDeleteCmdExe orderDeleteCmdExe; /** * 生成订单 * * @param cmd 订单内容 * @return 订单信息 */ @RestApi(name = "生成订单", logabled = true) @PostMapping("/create") @CheckResubmit public DataResponse create(@RequestBody @Valid OrderCreateCmd cmd) { OrderCreateCO orderCreateCO = orderCreateCmdExe.create(cmd); return DataResponse.of(orderCreateCO); } /** * 订单支付 */ @RestApi(name = "订单支付", logabled = true) @PostMapping("/pay") @CheckResubmit public DataResponse pay(@RequestBody @Valid OrderPayCmd cmd, HttpServletRequest request) { OrderPaymentInfoCO paymentInfoCO = orderPayCmdExe.pay(cmd, request); return DataResponse.of(paymentInfoCO); } /** * 订单列表(分页) * * @param cmd 查询条件 * @return 查询结果 */ @RestApi(name = "订单列表(分页)", logabled = true) @PostMapping("/page") public DataResponse page(@RequestBody OrderPageQryCmd cmd) { OrderQryDTO dto = BeanToolkit.instance().copy(cmd, OrderQryDTO.class); dto.setPageNo(cmd.getPageNo()); dto.setPageSize(cmd.getPageSize()); dto.setCreatorId(HttpContext.getCustomerId()); dto.setCustomerDeleted(0); CustomizePage orderDTOPage = orderService.customerPage(dto); CustomizePage result = new CustomizePage(orderDTOPage.getCurrent(), orderDTOPage.getSize(), orderDTOPage.getTotal()); result.setRecords(OrderConverter.converter2OrderCO(orderDTOPage.getRecords())); return DataResponse.of(result); } /** * 订单详情 * * @param orderId 订单ID * @return 订单详情 */ @RestApi(name = "主订单详情", logabled = true) @GetMapping("/detail/{orderId}") public DataResponse detail(@PathVariable("orderId") Long orderId) { OrderDTO orderDTO = orderService.detail(orderId, TerminalEnum.CUSTOMER); return DataResponse.of(OrderConverter.converter2OrderCO(orderDTO)); } /** * 订单状态统计 */ @RestApi(name = "订单状态统计", logabled = true) @GetMapping("/stateStatistics") public DataResponse orderStateStatistics() { OrderStateStatisticsCustomerCO result = orderService.customerOrderStateStatistics(); return DataResponse.of(result); } /** * 取消订单 * * @param cmd 取消订单 */ @RestApi(name = "取消订单", logabled = true) @PostMapping("/cancel") public Response cancel(@RequestBody @Valid OrderCancelCmd cmd) { orderCancelCmdExe.cancel(cmd); return Response.buildSuccess(); } /** * 退/换货申请 * * @param cmd 申请内容 */ @RestApi(name = "退/换货申请", logabled = true) @PostMapping("/refundApply") public Response refundApply(@RequestBody @Valid RefundApplyCmd cmd) { refundApplyCmdExe.refundApply(cmd); return Response.buildSuccess(); } /** * 退/换货订单列表(分页) * * @param qry 查询条件 * @return 查询结果 */ @RestApi(name = "退/换货订单列表(分页)", logabled = true) @PostMapping("/refundApply/page") public DataResponse refundOrderPage(@RequestBody RefundApplyQry qry) { CustomizePage orderDTOPage = orderService.refundOrderPage(qry); CustomizePage result = new CustomizePage(orderDTOPage.getCurrent(), orderDTOPage.getSize(), orderDTOPage.getTotal()); result.setRecords(OrderConverter.converter2OrderCO(orderDTOPage.getRecords())); return DataResponse.of(result); } /** * 删除订单 */ @RestApi(name = "删除订单", logabled = true) @DeleteMapping("/delete") public Response deleteOrder(@Valid @RequestBody OrderDeleteCmd cmd) { orderDeleteCmdExe.deleteOrder(cmd); return Response.buildSuccess(); } /** * 获取订单开票信息 * * @param orderId 主订单ID * @return 开票信息 */ @RestApi(name = "获取订单开票信息", logabled = true) @GetMapping("/orderInvoiceInfo/{orderId}") public DataResponse getOrderInvoiceInfo(@PathVariable("orderId") Long orderId) { return DataResponse.of(orderService.getOrderInvoiceInfo(orderId)); } }

订单创建执行器

@Slf4j @Component public class OrderCreateCmdExe { @Resource private NumberingGateway numberingGateway; @Resource private OrderValidator orderValidator; @Resource private GoodsService goodsService; @Resource private PointsGateway pointsGateway; @Resource private CustomerMemberGateway customerMemberGateway; @Resource private OrderAutoCancelPublisher orderAutoCancelPublisher; @Resource private OrderDaiZhiFuNoticePublisher orderDaiZhiFuNoticePublisher; @Resource private MemberCartGateway memberCartGateway; /** * 生成订单 */ @Transactional(rollbackFor = Exception.class) public OrderCreateCO create(OrderCreateCmd cmd) { // 1、查询商品信息 List skuIds = cmd.getGoodsList().stream().map(OrderCreateCmd.GoodsList::getSkuId).collect(Collectors.toList()); Map skuMap = goodsService.mapSkuCO(skuIds); // 2、查询客户积分 BigDecimal customerIntegral = pointsGateway.getCustomerIntegral(HttpContext.getCustomerId()); // 3、查询会员信息 MemberDTO memberDTO = customerMemberGateway.findByCustomerId(HttpContext.getCustomerId()); // 4、检查下单条件 orderValidator.createOrderValidate(cmd, skuMap, customerIntegral, memberDTO); // 5、 组装订单信息 List mallOrderDOS = newMallOrderE(cmd, skuMap, memberDTO.getMemberLevel()); // 6、检查用户积分余额 orderValidator.customerIntegralValidate(mallOrderDOS.get(0), customerIntegral); // 7、保存订单信息 MallOrderE.queryInstance().saveBatch(mallOrderDOS); // 8、批量扣除库存,考虑到没有分布式事务,因此最后进行RPC扣库存 List updateInventoryDTOS = GoodsConverter.convert2UpdateInventoryDTO(cmd.getGoodsList()); goodsService.updateInventory(updateInventoryDTOS); // 9、开启延迟队列 // 9.1、待支付订单自动取消 OrderEvent orderEvent = new OrderEvent(); orderEvent.setMainOrderId(mallOrderDOS.get(0).getId()); orderEvent.setMainOrderCode(mallOrderDOS.get(0).getCode()); orderAutoCancelPublisher.sendMessage(orderEvent); // 9.2、待支付订单提醒 orderDaiZhiFuNoticePublisher.sendMessage(orderEvent); // 10、删除购物车中的商品 if (SubmitPageEnum.orderConfirm.getValue().equals(cmd.getSubmitPage())) { deleteGoodsCart(cmd.getGoodsList()); } OrderCreateCO result = new OrderCreateCO(); result.setOrderId(mallOrderDOS.get(0).getId().toString()); result.setOrderNo(mallOrderDOS.get(0).getCode()); return result; } /** * 组装订单信息 * 返回的订单集合中,index=0的为主订单 */ private List newMallOrderE(OrderCreateCmd cmd, Map skuMap, Integer memberLevel) { List result = new ArrayList(); // 1、打包主订单信息 MallOrderE mallOrderE = BeanToolkit.instance().copy(cmd, MallOrderE.class); result.add(mallOrderE); mallOrderE.setId(numberingGateway.getNextId()); String orderCode = numberingGateway.generateOrderCode(); mallOrderE.setCode(orderCode); mallOrderE.setStatus(OrderStatusEnum.DAI_ZHI_FU.getValue()); // 订单总价格、订单总积分、订单总运费 Long totalPrice = 0L; Long totalFreight = 0L; Long totalIntegral = 0L; // 2、打包子订单信息 Queue subOrderCode = numberingGateway.generateSubOrderCode(orderCode, cmd.getGoodsList().size()); for (OrderCreateCmd.GoodsList goods : cmd.getGoodsList()) { SpuApiCO spu = skuMap.get(goods.getSkuId()); MallOrderE mallOrderEItem = BeanToolkit.instance().copy(cmd, MallOrderE.class); mallOrderEItem.setId(numberingGateway.getNextId()); mallOrderEItem.setCode(subOrderCode.poll()); mallOrderEItem.setMainOrderId(mallOrderE.getId()); mallOrderEItem.setMainOrderCode(mallOrderE.getCode()); mallOrderEItem.setStatus(OrderStatusEnum.DAI_ZHI_FU.getValue()); CalcPayPriceDTO calcPayPriceDTO = goodsService.calcPayPrice(spu.getSku(), goods.getCount(), memberLevel, cmd.getReceiverRegion()); mallOrderEItem.setPrice(calcPayPriceDTO.getPayPrice()); // 子订单价格 mallOrderEItem.setIntegral(calcPayPriceDTO.getGoodsTotalIntegral()); // 子订单积分 mallOrderEItem.setFreight(calcPayPriceDTO.getFreight()); // 子订单运费 mallOrderEItem.setSpuId(Long.valueOf(goods.getSpuId())); mallOrderEItem.setSkuId(Long.valueOf(goods.getSkuId())); mallOrderEItem.setQuantity(goods.getCount()); mallOrderEItem.setGoodsName(spu.getGoodsName()); mallOrderEItem.setGoodsSupplierId(spu.getSupplierId()); mallOrderEItem.setGoodsType(spu.getGoodsType()); mallOrderEItem.setCreatorId(HttpContext.getCustomerId()); mallOrderEItem.setCreator(HttpContext.getCustomerName()); mallOrderEItem.setCreateDt(LocalDateTime.now()); mallOrderEItem.setLastUpdatorId(HttpContext.getCustomerId()); mallOrderEItem.setLastUpdator(HttpContext.getCustomerName()); mallOrderEItem.setLastUpdateDt(LocalDateTime.now()); result.add(mallOrderEItem); totalPrice += calcPayPriceDTO.getPayPrice(); totalFreight += calcPayPriceDTO.getFreight(); totalIntegral += calcPayPriceDTO.getGoodsTotalIntegral(); } mallOrderE.setPrice(totalPrice); // 订单总价 mallOrderE.setIntegral(totalIntegral); // 订单总积分 mallOrderE.setFreight(totalFreight); // 订单总运费 mallOrderE.setCreatorId(HttpContext.getCustomerId()); mallOrderE.setCreator(HttpContext.getCustomerName()); mallOrderE.setCreateDt(LocalDateTime.now()); mallOrderE.setLastUpdatorId(HttpContext.getCustomerId()); mallOrderE.setLastUpdator(HttpContext.getCustomerName()); mallOrderE.setLastUpdateDt(LocalDateTime.now()); return result; } /** * 批量删除购物车数据 * * @param goodsList 待删除的商品 */ private void deleteGoodsCart(List goodsList) { for (OrderCreateCmd.GoodsList list : goodsList) { DeleteGoodsCartCmd deleteGoodsCartCmd = new DeleteGoodsCartCmd(); deleteGoodsCartCmd.setSpuId(Long.valueOf(list.getSpuId())); deleteGoodsCartCmd.setSkuId(Long.valueOf(list.getSkuId())); memberCartGateway.deleteGoodsCart(HttpContext.getCustomerId(), deleteGoodsCartCmd); } } }

订单取消执行器

/** * 订单取消执行器 * * @author cgli * @date 2022/12/30 09:19 */ @Component public class OrderCancelCmdExe { @Resource private OrderValidator orderValidator; @Resource private MallOrderGateway orderGateway; @Resource private RollbackIntegralExe rollbackIntegralExe; @Resource private GoodsService goodsService; /** * 取消订单 */ @Transactional(rollbackFor = Exception.class) public void cancel(OrderCancelCmd cmd) { MallOrderE mallOrderE = MallOrderE.queryInstance().getById(cmd.getOrderId()); orderValidator.cancelOrderValidate(mallOrderE); List orderUpdateList = new ArrayList(); List inventoryUpdateList = new ArrayList(); //主订单状态置为"已取消" MallOrderE mainOrderEForUpdate = new MallOrderE(); mainOrderEForUpdate.setId(mallOrderE.getId()); mainOrderEForUpdate.setStatus(OrderStatusEnum.YI_QU_XIAO.getValue()); orderUpdateList.add(mainOrderEForUpdate); List orderDTOS = orderGateway.listByMainOrderId(cmd.getOrderId()); for (OrderDTO orderDTO : orderDTOS) { //子订单状态置为"已取消" MallOrderE subOrderEForUpdate = new MallOrderE(); subOrderEForUpdate.setId(orderDTO.getId()); subOrderEForUpdate.setStatus(OrderStatusEnum.YI_QU_XIAO.getValue()); orderUpdateList.add(subOrderEForUpdate); //回滚库存 UpdateInventoryDTO updateInventoryDTO = new UpdateInventoryDTO(orderDTO.getSkuId().toString(), orderDTO.getQuantity()); inventoryUpdateList.add(updateInventoryDTO); } orderGateway.updateBatchById(orderUpdateList); // 判断是否已经进行了积分支付,需要将积分回滚 rollbackIntegralExe.execute(mallOrderE, "订单取消积分返还"); // 库存回滚 goodsService.updateInventory(inventoryUpdateList); } }

订单删除执行器

/** * 订单删除执行器 * * @author cgli * @date 2022/12/30 09:30 */ @Component public class OrderDeleteCmdExe { @Resource private OrderValidator orderValidator; /** * 删除订单 */ @Transactional(rollbackFor = Exception.class) public void deleteOrder(OrderDeleteCmd cmd) { MallOrderE mallOrderE = MallOrderE.queryInstance().getById(cmd.getOrderId()); orderValidator.deleteValidate(mallOrderE); MallOrderE.queryInstance().customerDeleteByMainOrderId(mallOrderE.getId()); } }

 订单查询服务

@Slf4j @Service public class OrderService extends BaseService { @Autowired private MallOrderGateway orderGateway; @Autowired private MallDeliveryGateway deliveryGateway; @Autowired private GoodsService goodsService; @Autowired private MallOrderBillGateway mallOrderBillGateway; @Autowired private MallInvoiceRecordGateway invoiceRecordGateway; /** * 订单列表(分页) */ public CustomizePage page(OrderQryDTO dto) { dto.setQuerySubOrder(true); CustomizePage page = orderGateway.page(dto); Map supplierMap = goodsService.mapSupplierCO(); //查询订单物流信息 List deliveryIds = page.getRecords().stream().map(OrderDTO::getDeliveryId).filter(Objects::nonNull).distinct().collect(Collectors.toList()); Map deliveryEMap = deliveryGateway.mapById(deliveryIds); for (OrderDTO orderDTO : page.getRecords()) { //整合供应商名称 SupplierDTO supplierDTO = supplierMap.get(orderDTO.getGoodsSupplierId()); if (supplierDTO != null) { orderDTO.setGoodsSupplierName(supplierDTO.getSupplierName()); } //转译订单状态 orderDTO.setStatusDesc(OrderStatusEnum.value2Desc(TerminalEnum.ADMIN, orderDTO.getStatus())); // 物流信息 MallDeliveryE mallDeliveryE = deliveryEMap.get(orderDTO.getDeliveryId()); orderDTO.setDeliveryInfo(mallDeliveryE); // 商品信息 GoodsCO goodsCO = new GoodsCO(); goodsCO.setGoodsName(orderDTO.getGoodsName()); orderDTO.setGoods(goodsCO); } return page; } /** * 消费者端分页查询订单信息 * * @param dto 查询条件 * @return 查询结果 */ public CustomizePage customerPage(OrderQryDTO dto) { dto.setQueryMainOrder(true); CustomizePage mainOrderPage = orderGateway.page(dto); if (CollUtil.isEmpty(mainOrderPage.getRecords())) { return new CustomizePage(mainOrderPage.getCurrent(), mainOrderPage.getSize(), mainOrderPage.getTotal()); } List mainOrderIds = mainOrderPage.getRecords().stream().map(OrderDTO::getId).collect(Collectors.toList()); //查询子订单信息 OrderQryDTO subOrderQry = new OrderQryDTO(); subOrderQry.setMainOrderIds(mainOrderIds); List subOrderList = orderGateway.list(subOrderQry); //查询商品信息 List skuIds = subOrderList.stream().map(OrderDTO::getSkuId).map(String::valueOf).collect(Collectors.toList()); Map spuMap = goodsService.mapSkuCO(skuIds); //查询派送信息 List deliveryIds = subOrderList.stream().map(OrderDTO::getDeliveryId).filter(Objects::nonNull).distinct().collect(Collectors.toList()); Map deliveryMap = deliveryGateway.mapById(deliveryIds); //查询支付信息 Map billMap = mallOrderBillGateway.getBill(mainOrderIds, BillingTypeEnum.PAY, OrderPayWayEnum.INTEGRAL_PAY); //整合发票信息 Map orderInvoiceMap = invoiceRecordGateway.getOrderInvoice(mainOrderIds); //整合子母单、商品信息和物流信息 return OrderConverter.converter2OrderDTO(mainOrderPage, subOrderList, spuMap, deliveryMap, billMap, orderInvoiceMap); } /** * B端订单状态统计 */ public OrderStateStatisticsCO orderStateStatistics(OrderPageQryCmd cmd) { return orderGateway.orderStateStatistics(cmd); } /** * C端订单状态统计 */ public OrderStateStatisticsCustomerCO customerOrderStateStatistics() { return orderGateway.customerOrderStateStatistics(HttpContext.getCustomerId()); } /** * 获取订单详情 * * @param orderId 订单ID * @param terminal 终端类型 * @return 订单详情 */ public OrderDTO detail(Long orderId, TerminalEnum terminal) { OrderDTO result = null; // 1、获取订单信息 MallOrderE mallOrderE = MallOrderE.queryInstance().getById(orderId); if (mallOrderE.isMainOrder()) { // 2、查看主订单维度的详情 // 2.1、查询子订单信息 List orderDTOS = orderGateway.listByMainOrderId(orderId); // 2.2、查询商品信息 List skuIds = orderDTOS.stream().map(OrderDTO::getSkuId).map(String::valueOf).collect(Collectors.toList()); Map spuMap = goodsService.mapSkuCO(skuIds); result = OrderConverter.converter2OrderDTO(mallOrderE, orderDTOS, spuMap, terminal); } else { // 3、查看子单维度的详情 // 3.1、查询母单订单信息 MallOrderE mainOrderInfo = MallOrderE.queryInstance().getById(mallOrderE.getMainOrderId()); // 3.2、查询商品信息 Map spuMap = goodsService.mapSkuCO(Collections.singletonList(String.valueOf(mallOrderE.getSkuId()))); // 4、整合订单详情 OrderDTO subOrderDTO = BeanToolkit.instance().copy(mallOrderE, OrderDTO.class); result = OrderConverter.converter2OrderDTO(mainOrderInfo, Collections.singletonList(subOrderDTO), spuMap, terminal); } return result; } /** * 商品销量统计 */ public List goodsSalesStatistics(GoodsSalesStatisticsQryCmd cmd) { return orderGateway.goodsSalesStatistics(cmd.getSkuIds(), cmd.getCreateDtBegin(), cmd.getCreateDtEnd(), cmd.getLimit()); } /** * 退款订单列表 * * @param qry 查询条件 * @return 查询结果 */ public CustomizePage refundOrderPage(RefundApplyQry qry) { OrderQryDTO qryDTO = BeanToolkit.instance().copy(qry, OrderQryDTO.class); qryDTO.setPageNo(qry.getPageNo()); qryDTO.setPageSize(qry.getPageSize()); qryDTO.setStatusList(Arrays.asList(OrderStatusEnum.TUI_HUO_SHEN_QING.getValue(), OrderStatusEnum.TUI_HUO_WAN_CHENG.getValue())); qryDTO.setQuerySubOrder(true); qryDTO.setCreatorId(HttpContext.getCustomerId()); CustomizePage page = orderGateway.page(qryDTO); //查询商品信息 List skuIds = page.getRecords().stream().map(OrderDTO::getSkuId).map(String::valueOf).collect(Collectors.toList()); Map spuMap = goodsService.mapSkuCO(skuIds); return OrderConverter.converter2OrderDTO(page, spuMap); } /** * 获取导出数据 * * @param cmd 查询条件 * @return 查询结果 */ public List export(OrderPageQryCmd cmd) { int exportCount = 0; //已经处理的数据 OrderQryDTO orderQryDTO = OrderQryDTO.of(cmd); orderQryDTO.setPageNo(1); orderQryDTO.setPageSize(200); //分批整合数据 CustomizePage orderPage = page(orderQryDTO); if (CollUtil.isEmpty(orderPage.getRecords())) { throw new DataNotFoundException(); } List result = new ArrayList(); while (CollUtil.isNotEmpty(orderPage.getRecords()) && BizConstant.MAX_EXPORT_SIZE > exportCount) { List orderExcelDTOList = OrderConverter.converter2OrderExcelDTO(orderPage.getRecords()); result.addAll(orderExcelDTOList); //处理下一页的数据 exportCount += orderQryDTO.getPageSize(); orderQryDTO.setPageNo(orderQryDTO.getPageNo() + 1); orderPage = page(orderQryDTO); } return result; } /** * 获取订单退货申请记录 * * @param orderId 订单ID * @return 查询结果 */ public RefundApplyInfoCO getRefundApplyInfoCO(Long orderId) { MallRefundApplyE refundApplyE = MallRefundApplyE.queryInstance().getByOrderId(orderId); if (refundApplyE == null) { throw new DataNotFoundException(); } RefundApplyInfoCO result = BeanToolkit.instance().copy(refundApplyE, RefundApplyInfoCO.class); result.setRefundTypeDesc(OrderRefundTypeEnum.value2Desc(result.getRefundType())); return result; } /** * 获取订单列表 * * @param cmd 查询条件 * @return 查询结果 */ public List queryOrderList(OrderQryCmd cmd) { OrderQryDTO subOrderQry = BeanToolkit.instance().copy(cmd, OrderQryDTO.class); subOrderQry.setQuerySubOrder(true); return orderGateway.list(subOrderQry); } /** * 获取SKU产生的最新订单 * * @param skuIds skuId集合 * @return 订单信息 */ public List skuLatestSale(List skuIds) { return orderGateway.skuLatestSale(skuIds); } /** * 获取订单开票信息 */ public OrderInvoiceInfoCO getOrderInvoiceInfo(Long orderId) { MallOrderE mainOrderE = MallOrderE.queryInstance().getById(orderId); if (Objects.isNull(mainOrderE)) { throw new ServiceException("订单不存在"); } if (!OrderStatusEnum.YI_WAN_CHENG.getValue().equals(mainOrderE.getStatus())) { throw new ServiceException("未完成的订单无法申请开发票"); } if (!mainOrderE.moneyPaid()) { throw new ServiceException("该订单未进行现金支付,无法开具发票"); } OrderInvoiceInfoCO result = new OrderInvoiceInfoCO(); result.setOrderId(mainOrderE.getId().toString()); result.setOrderCode(mainOrderE.getCode()); //开票金额,该母单的实际支付金额,部分退款则取最终收款金额 long totalRefund = orderGateway.listByMainOrderId(orderId) .stream() .filter(orderDTO -> OrderStatusEnum.TUI_HUO_WAN_CHENG.getValue().equals(orderDTO.getStatus())) .mapToLong(OrderDTO::getPayPrice) .sum(); long invoicePrice = mainOrderE.getPayPrice() - totalRefund; result.setInvoicePrice(BigDecimalUtils.penny2yuan(invoicePrice)); return result; } }

 

/** * 订单领域层服务接口 * */ public interface MallOrderGateway { /** * 分页查询 */ CustomizePage page(OrderQryDTO dto); /** * 订单列表 */ List list(OrderQryDTO dto); /** * 根据主订单ID获取自订单集合 */ List listByMainOrderId(Long orderId); List listByMainOrderIdList(List orderIdList); /** * 统计消费者购买的商品数量 * * @param customerId 消费者ID * @param skuId skuId * @return 统计结果 */ Integer countBySkuId(String customerId, Long skuId); /** * 根据ID查询订单信息 * * @param id 订单ID * @return 查询结果 */ MallOrderE getById(Long id); /** * 根据子单查询母单数据 * * @param id 子单ID * @return 母单数据 */ MallOrderE getMainOrderBySubId(Long id); MallOrderE getByCode(String code); /** * 根据ID批量查询订单信息 * * @param ids 订单ID集合 * @return 查询结果 */ List listById(List ids); /** * 批量保存订单信息 * * @param mallOrderES 待保存内容 * @return 保存结果 */ Boolean saveBatch(List mallOrderES); /** * 根据主键更新订单信息 * * @param mallOrderE 更新内容 * @return 更新结果 */ Boolean updateById(MallOrderE mallOrderE); Boolean updateBatchById(List orderEList); /** * B端订单状态统计 */ OrderStateStatisticsCO orderStateStatistics(OrderPageQryCmd cmd); /** * 消费者订单状态统计 */ OrderStateStatisticsCustomerCO customerOrderStateStatistics(String customerId); /** * 商品销量统计 * * @param skuIds 商品SKUID * @return 统计结果 */ List goodsSalesStatistics(List skuIds, LocalDateTime createDtBegin, LocalDateTime createDtEnd, Integer limit); /** * 删除主订单 * * @param mainOrderId 主订单ID * @return 删除结果 */ Boolean customerDeleteByMainOrderId(Long mainOrderId); /** * 获取SKU产生的最新订单 * * @param skuIds skuId集合 * @return 订单信息 */ List skuLatestSale(List skuIds); /** * 根据订单ID集合批量删除订单 * * @param ids 订单ID集合 * @return 删除结果 */ Boolean deleteBatchById(Collection ids); }

 

 

3. 产品商品系统

由于写在一起篇幅太长,拉上拉下的设置一格式实在不好编辑;另外各位看官看文章太长也心思看完,看久也累!故每个子系统分开写!

请看下一篇》》》》产商品系统架构设计

 



【本文地址】


今日新闻


推荐新闻


CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3