商品管理系统——模拟采购员完成采购

爱被打了一巴掌 2021-07-24 18:16 454阅读 0赞

# 一 API分析 #

1 请求

> POST /ware/purchase/done

2 请求参数

{
        id: 123, //采购单id
        items: [{
            itemId: 1,
            status: 4,
            reason: ""
        }] //完成/失败的需求详情
    }

3 响应数据

{
        "msg": "success",
        "code": 0
    }

# 二 实现 #

1  PurchaseController

/** 
    * 功能描述：完成采购单
    *
    * @param doneVo 请求参数
    * @return R 返回给前端的数据
    * @author cakin
    * @date 2020/11/11
    * @description:
    */
    @PostMapping("/done")
    public R finish(@RequestBody PurchaseDoneVo doneVo) {
        purchaseService.done(doneVo);
        return R.ok();
    }

2 PurchaseDoneVo

/**
    * @className: PurchaseDoneVo
    * @description: 完成采购单请求Vo
    * @date: 2020/11/11
    * @author: cakin
    */
    @Data
    public class PurchaseDoneVo {
        /**
         * 采购单id
         */
        @NotNull
        private Long id;
        private List<PurchaseItemDoneVo> items;
    }

3 PurchaseItemDoneVo

/**
    * @className: PurchaseItemDoneVo
    * @description: 完成采购单采购需求Vo
    * @date: 2020/11/11
    * @author: cakin
    */
    @Data
    public class PurchaseItemDoneVo {
        /**
         * 采购需求
         */
        private Long itemId;
        /**
         * 采购需求状态
         */
        private Integer status;
        /**
         * 未完成原因
         */
        private String reason;
    }

4 PurchaseServiceImpl

/**
    * 功能描述：完成采购单服务
    *
    * @param doneVo 请求Vo
    * @author cakin
    * @date 2020/11/11
    */
    @Transactional
    @Override
    public void done(PurchaseDoneVo doneVo) {
        // 采购单id
        Long id = doneVo.getId();
        // 1 改变采购项的状态
        Boolean flag = true;
        // 得到采购需求的请求
        List<PurchaseItemDoneVo> items = doneVo.getItems();
        List<PurchaseDetailEntity> updates = new ArrayList<>();
        // 遍历采购需求
        for (PurchaseItemDoneVo item : items) {
            PurchaseDetailEntity detailEntity = new PurchaseDetailEntity();
            // 采购需求失败情况
            if (item.getStatus() == WareConstant.PurchaseDetailStatusEnum.HASERROR.getCode()) {
                flag = false;
                // 采购单失败状态
                detailEntity.setStatus(item.getStatus());
            } else { // 采购需求成功情况
                // 采购单成功状态
                detailEntity.setStatus(WareConstant.PurchaseDetailStatusEnum.FINISH.getCode());
                // 2 将成功采购需求的进行入库
                // 采购需求入库
                PurchaseDetailEntity entity = detailService.getById(item.getItemId());
                wareSkuService.addStock(entity.getSkuId(), entity.getWareId(), entity.getSkuNum());
            }
            detailEntity.setId(item.getItemId());
            updates.add(detailEntity);
        }
        // 更新采购需求
        detailService.updateBatchById(updates);
        // 3 改变采购单状态
        PurchaseEntity purchaseEntity = new PurchaseEntity();
        purchaseEntity.setId(id);
        purchaseEntity.setStatus(flag ? WareConstant.PurchaseStatusEnum.FINISH.getCode() : WareConstant.PurchaseStatusEnum.HASERROR.getCode());
        purchaseEntity.setUpdateTime(new Date());
        // 更新采购单状态
        this.updateById(purchaseEntity);
    }

5 WareSkuServiceImpl

/**
    * 功能描述：添加库存
    *
    * @param skuId  skuId
    * @param wareId 仓库Id
    * @param skuNum sku数量
    * @author cakin
    * @date 2020/11/11
    */
    @Override
    public void addStock(Long skuId, Long wareId, Integer skuNum) {
        // 1 判断如果还没有这个库存，新增库存
        List<WareSkuEntity> entities = wareSkuDao.selectList(new QueryWrapper<WareSkuEntity>()
                .eq("sku_id", skuId)
                .eq("ware_id", wareId));
        if (entities == null || entities.size() == 0) {
            WareSkuEntity skuEntity = new WareSkuEntity();
            skuEntity.setSkuId(skuId);
            skuEntity.setStock(skuNum);
            skuEntity.setWareId(wareId);
            skuEntity.setStockLocked(0);
            // TODO 远程查询sku的名字，如果失败，整个事务无需回滚
            // 1 自己catch异常
            // TODO 还可以用什么办法让异常出现以后不回滚？高级
            try {
                R info = productFeignService.info(skuId);
                Map<String, Object> data = (Map<String, Object>) info.get("skuInfo");
                if (info.getCode() == 0) {
                    skuEntity.setSkuName((String) data.get("skuName"));
                }
            } catch (Exception e) {
            }
            wareSkuDao.insert(skuEntity);
        } else {
            // 更新库存数量
            wareSkuDao.addStock(skuId, wareId, skuNum);
        }
    }

6 ProductFeignService

@FeignClient("gulimall-product")
    public interface {
        /**
         * 功能描述：远程调用商品微服务
         *
         * @author cakin
         * @date 2020/11/11
         * @param skuId skuId
         * @return R 远程服务返回数据
         * @description:
         *   1)、让所有请求过网关；
         *          1、@FeignClient("gulimall-gateway")：给gulimall-gateway所在的机器发请求
         *          2、/api/product/skuinfo/info/{skuId}
         *   2）、直接让后台指定服务处理
         *          1、@FeignClient("gulimall-gateway")
         *          2、/product/skuinfo/info/{skuId}
         */
        @RequestMapping("/product/skuinfo/info/{skuId}")
        R info(@PathVariable("skuId") Long skuId);
    }

# 三 测试 #

1 postman请求

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70][]

2 采购单状态

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70 1][]

3 采购需求状态

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70 2][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70]: /images/20210724/4bd7bc657d4447798862ab01b72ddff0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70 1]: /images/20210724/994fa6971b6042b0aacf4a4182a0480a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70 2]: /images/20210724/c98f1bb030f241b9b4ed6b23734a498c.png